|
@@ -16,6 +16,7 @@ import (
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/supplierlog"
|
|
"dashoo.cn/backend/api/business/oilsupplier/supplierlog"
|
|
|
"dashoo.cn/backend/api/business/organize"
|
|
"dashoo.cn/backend/api/business/organize"
|
|
|
"dashoo.cn/backend/api/business/paymentinfo"
|
|
"dashoo.cn/backend/api/business/paymentinfo"
|
|
|
|
|
+ "dashoo.cn/backend/api/business/register"
|
|
|
baseparameter "dashoo.cn/business2/parameter"
|
|
baseparameter "dashoo.cn/business2/parameter"
|
|
|
"encoding/json"
|
|
"encoding/json"
|
|
|
"fmt"
|
|
"fmt"
|
|
@@ -984,6 +985,11 @@ func (this *OilSupplierCertController) RecallApply() {
|
|
|
panic("权限错误,仅申请人可撤回当前申请!")
|
|
panic("权限错误,仅申请人可撤回当前申请!")
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ date := supplierCertEntity.CreateOn.Format("2006-01-02 15:04:05")
|
|
|
|
|
+ if date < "2021-03-05 00:00:00" {
|
|
|
|
|
+ panic("当前申请不可撤回!")
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
svcPaymentInfo := paymentinfo.GetPaymentService(utils.DBE)
|
|
svcPaymentInfo := paymentinfo.GetPaymentService(utils.DBE)
|
|
|
var paymentInfo paymentinfo.OilPaymentInfo
|
|
var paymentInfo paymentinfo.OilPaymentInfo
|
|
|
wherePay := " SrcId=" + certId + " and SupplierId=" + strconv.Itoa(supplierCertEntity.SupplierId) + " and SupplierCertId=" + certId
|
|
wherePay := " SrcId=" + certId + " and SupplierId=" + strconv.Itoa(supplierCertEntity.SupplierId) + " and SupplierCertId=" + certId
|
|
@@ -1672,7 +1678,7 @@ func (this *OilSupplierCertController) ChangeSupplierStatus() {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// @Title 更新Inflag状态
|
|
// @Title 更新Inflag状态
|
|
|
-// @Description 删除所有关联表并存到del表
|
|
|
|
|
|
|
+// @Description 确认重新准入按钮,删除所有关联表并存到del表
|
|
|
// @Success 200 {object} controllers.Request
|
|
// @Success 200 {object} controllers.Request
|
|
|
// @router /reinput/:id [post]
|
|
// @router /reinput/:id [post]
|
|
|
func (this *OilSupplierCertController) ReInput() {
|
|
func (this *OilSupplierCertController) ReInput() {
|
|
@@ -1687,6 +1693,8 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ needWorkflowId := [] string{}
|
|
|
|
|
+
|
|
|
session := utils.DBE.NewSession()
|
|
session := utils.DBE.NewSession()
|
|
|
svc := suppliercert.GetOilSupplierCertSession(session)
|
|
svc := suppliercert.GetOilSupplierCertSession(session)
|
|
|
defer func() {
|
|
defer func() {
|
|
@@ -1722,7 +1730,7 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
|
|
|
|
|
item.DeleteDate = time.Now()
|
|
item.DeleteDate = time.Now()
|
|
|
_, err = svc.InsertEntityBytbl(DelOilSupplierCertName, &item)
|
|
_, err = svc.InsertEntityBytbl(DelOilSupplierCertName, &item)
|
|
|
-
|
|
|
|
|
|
|
+ needWorkflowId = append(needWorkflowId, item.WorkflowId)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
session.Rollback()
|
|
session.Rollback()
|
|
|
errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
@@ -1733,36 +1741,36 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
// 交费信息
|
|
// 交费信息
|
|
|
- var delpay []paymentinfo.Del_OilPaymentInfo
|
|
|
|
|
- wherepay := "SupplierCertId=" + strconv.Itoa(model[0].Id)
|
|
|
|
|
- var sqlpay string
|
|
|
|
|
- sqlpay = "select * from " + OilPaymentInfoName + " where " + wherepay
|
|
|
|
|
- utils.DBE.SQL(sqlpay).Find(&delpay)
|
|
|
|
|
-
|
|
|
|
|
- err = svc.DeleteEntityBytbl(OilPaymentInfoName, wherepay)
|
|
|
|
|
- if err != nil {
|
|
|
|
|
- session.Rollback()
|
|
|
|
|
- errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
|
|
- errinfo.Code = -1
|
|
|
|
|
- this.Data["json"] = &errinfo
|
|
|
|
|
- this.ServeJSON()
|
|
|
|
|
- return
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- for idx, _ := range delpay {
|
|
|
|
|
- delpay[idx].DeleteDate = time.Now()
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- _, err = svc.InsertEntityBytbl(DelOilPaymentInfoName, &delpay)
|
|
|
|
|
-
|
|
|
|
|
- if err != nil {
|
|
|
|
|
- session.Rollback()
|
|
|
|
|
- errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
|
|
- errinfo.Code = -1
|
|
|
|
|
- this.Data["json"] = &errinfo
|
|
|
|
|
- this.ServeJSON()
|
|
|
|
|
- return
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ //var delpay []paymentinfo.Del_OilPaymentInfo
|
|
|
|
|
+ //wherepay := "SupplierCertId=" + strconv.Itoa(model[0].Id)
|
|
|
|
|
+ //var sqlpay string
|
|
|
|
|
+ //sqlpay = "select * from " + OilPaymentInfoName + " where " + wherepay
|
|
|
|
|
+ //utils.DBE.SQL(sqlpay).Find(&delpay)
|
|
|
|
|
+ //
|
|
|
|
|
+ //err = svc.DeleteEntityBytbl(OilPaymentInfoName, wherepay)
|
|
|
|
|
+ //if err != nil {
|
|
|
|
|
+ // session.Rollback()
|
|
|
|
|
+ // errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
|
|
+ // errinfo.Code = -1
|
|
|
|
|
+ // this.Data["json"] = &errinfo
|
|
|
|
|
+ // this.ServeJSON()
|
|
|
|
|
+ // return
|
|
|
|
|
+ //}
|
|
|
|
|
+ //
|
|
|
|
|
+ //for idx, _ := range delpay {
|
|
|
|
|
+ // delpay[idx].DeleteDate = time.Now()
|
|
|
|
|
+ //}
|
|
|
|
|
+ //
|
|
|
|
|
+ //_, err = svc.InsertEntityBytbl(DelOilPaymentInfoName, &delpay)
|
|
|
|
|
+ //
|
|
|
|
|
+ //if err != nil {
|
|
|
|
|
+ // session.Rollback()
|
|
|
|
|
+ // errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
|
|
+ // errinfo.Code = -1
|
|
|
|
|
+ // this.Data["json"] = &errinfo
|
|
|
|
|
+ // this.ServeJSON()
|
|
|
|
|
+ // return
|
|
|
|
|
+ //}
|
|
|
|
|
|
|
|
// 删除增项记录
|
|
// 删除增项记录
|
|
|
var modelapp []suppliercertappend.Del_OilSupplierCertAppend
|
|
var modelapp []suppliercertappend.Del_OilSupplierCertAppend
|
|
@@ -1781,8 +1789,9 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- for idx, _ := range modelapp {
|
|
|
|
|
|
|
+ for idx, app := range modelapp {
|
|
|
modelapp[idx].DeleteDate = time.Now()
|
|
modelapp[idx].DeleteDate = time.Now()
|
|
|
|
|
+ needWorkflowId = append(needWorkflowId, app.WorkFlowId)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
_, err = svc.InsertEntityBytbl(DelOilSupplierCertAppendName, &modelapp)
|
|
_, err = svc.InsertEntityBytbl(DelOilSupplierCertAppendName, &modelapp)
|
|
@@ -1813,8 +1822,10 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- for idx, _ := range modelann {
|
|
|
|
|
|
|
+ for idx, app := range modelann {
|
|
|
modelann[idx].DeleteDate = time.Now()
|
|
modelann[idx].DeleteDate = time.Now()
|
|
|
|
|
+ needWorkflowId = append(needWorkflowId, app.WorkflowId)
|
|
|
|
|
+
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
_, err = svc.InsertEntityBytbl(DelOilAnnualAuditName, &modelann)
|
|
_, err = svc.InsertEntityBytbl(DelOilAnnualAuditName, &modelann)
|
|
@@ -1894,6 +1905,64 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ // 删除注册信息
|
|
|
|
|
+ var corporateInfo register.Del_OilCorporateInfo
|
|
|
|
|
+ where = "CommercialNo = '" + modelsupp.CommercialNo + "'"
|
|
|
|
|
+ sql = "select * from " + OilCorporateInfoName + " where " + where
|
|
|
|
|
+ utils.DBE.SQL(sql).Get(&corporateInfo)
|
|
|
|
|
+
|
|
|
|
|
+ if corporateInfo.Id > 0 {
|
|
|
|
|
+ err = svc.DeleteEntityBytbl(OilCorporateInfoName, where)
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ session.Rollback()
|
|
|
|
|
+ errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
|
|
+ errinfo.Code = -1
|
|
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+ corporateInfo.DeleteDate = time.Now()
|
|
|
|
|
+ _, err = svc.InsertEntityBytbl(DelOilCorporateInfoName, &corporateInfo)
|
|
|
|
|
+
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ session.Rollback()
|
|
|
|
|
+ errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
|
|
+ errinfo.Code = -1
|
|
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ // 删除用户信息
|
|
|
|
|
+ var user register.Del_Base_User
|
|
|
|
|
+ where = "Id = " + strconv.Itoa(corporateInfo.UserId)
|
|
|
|
|
+ sql = "select * from " + BaseUserName + " where " + where
|
|
|
|
|
+ utils.DBE.SQL(sql).Get(&user)
|
|
|
|
|
+
|
|
|
|
|
+ if corporateInfo.Id > 0 {
|
|
|
|
|
+ err = svc.DeleteEntityBytbl(BaseUserName, where)
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ session.Rollback()
|
|
|
|
|
+ errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
|
|
+ errinfo.Code = -1
|
|
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+ user.DeleteDate = time.Now()
|
|
|
|
|
+ _, err = svc.InsertEntityBytbl(DelBaseNameName, &user)
|
|
|
|
|
+
|
|
|
|
|
+ if err != nil {
|
|
|
|
|
+ session.Rollback()
|
|
|
|
|
+ errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
|
|
+ errinfo.Code = -1
|
|
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
|
|
+ this.ServeJSON()
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
// 删除企业资质
|
|
// 删除企业资质
|
|
|
var delfile []supplierfile.Del_OilSupplierFile
|
|
var delfile []supplierfile.Del_OilSupplierFile
|
|
|
wheref := "SupplierId=" + strconv.Itoa(model[0].SupplierId)
|
|
wheref := "SupplierId=" + strconv.Itoa(model[0].SupplierId)
|
|
@@ -1943,8 +2012,9 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- for idx, _ := range delinfo {
|
|
|
|
|
|
|
+ for idx, app := range delinfo {
|
|
|
delinfo[idx].DeleteDate = time.Now()
|
|
delinfo[idx].DeleteDate = time.Now()
|
|
|
|
|
+ needWorkflowId = append(needWorkflowId, app.WorkFlowId)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
_, err = svc.InsertEntityBytbl(DelOilInfoChangeName, &delinfo)
|
|
_, err = svc.InsertEntityBytbl(DelOilInfoChangeName, &delinfo)
|
|
@@ -1962,12 +2032,11 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
|
|
|
|
|
err = session.Commit()
|
|
err = session.Commit()
|
|
|
if err == nil {
|
|
if err == nil {
|
|
|
- //TODO: 删除工作流, 年审、增项、信息变更等有流程的都要删除
|
|
|
|
|
activitiService := workflow.GetActivitiService(utils.DBE)
|
|
activitiService := workflow.GetActivitiService(utils.DBE)
|
|
|
var deleteProcessVM workflow.DeleteProcessVM
|
|
var deleteProcessVM workflow.DeleteProcessVM
|
|
|
- for _, supplierCertItem := range model {
|
|
|
|
|
- if supplierCertItem.WorkflowId != "" && supplierCertItem.WorkflowId != "0" && supplierCertItem.InFlag == "3" {
|
|
|
|
|
- deleteProcessVM.ProcessInstanceId = supplierCertItem.WorkflowId
|
|
|
|
|
|
|
+ for _, workflowId := range needWorkflowId {
|
|
|
|
|
+ if workflowId != "" && workflowId != "0"{
|
|
|
|
|
+ deleteProcessVM.ProcessInstanceId = workflowId
|
|
|
deleteProcessVM.DeleteReason = "企业重新入库"
|
|
deleteProcessVM.DeleteReason = "企业重新入库"
|
|
|
activitiService.DeleteComplete(deleteProcessVM)
|
|
activitiService.DeleteComplete(deleteProcessVM)
|
|
|
}
|
|
}
|