|
|
@@ -2,6 +2,7 @@ package oilsupplier
|
|
|
|
|
|
import (
|
|
|
"dashoo.cn/backend/api/business/codecsequence"
|
|
|
+ "dashoo.cn/backend/api/business/invoiceinfo"
|
|
|
msg2 "dashoo.cn/backend/api/business/msg"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/annualaudit"
|
|
|
"dashoo.cn/backend/api/business/oilsupplier/infochange"
|
|
|
@@ -1740,37 +1741,37 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
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 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
|
|
|
@@ -1905,7 +1906,38 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- // 删除注册信息
|
|
|
+ //删除发票信息
|
|
|
+ var invoice []invoiceinfo.Del_OilInvoiceInfo
|
|
|
+ where = "SupplierId=" + id
|
|
|
+ sql = "select * from OilInvoiceInfo where " + where
|
|
|
+ utils.DBE.SQL(sql).Find(&invoice)
|
|
|
+
|
|
|
+ err = svc.DeleteEntityBytbl("OilInvoiceInfo", where)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for idx, app := range invoice {
|
|
|
+ invoice[idx].DeleteDate = time.Now()
|
|
|
+ needWorkflowId = append(needWorkflowId, app.WorkflowId)
|
|
|
+ }
|
|
|
+ _, err = svc.InsertEntityBytbl("Del_OilInvoiceInfo", &invoice)
|
|
|
+
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ errinfo.Message = "提交失败!" + utils.AlertProcess(err.Error())
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 删除注册信息,用户信息
|
|
|
var corporateInfo register.Del_OilCorporateInfo
|
|
|
where = "CommercialNo = '" + modelsupp.CommercialNo + "'"
|
|
|
sql = "select * from " + OilCorporateInfoName + " where " + where
|
|
|
@@ -1921,26 +1953,8 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
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 {
|
|
|
+ // 删除用户信息
|
|
|
+ where = "Id = " + strconv.Itoa(corporateInfo.UserId)
|
|
|
err = svc.DeleteEntityBytbl(BaseUserName, where)
|
|
|
if err != nil {
|
|
|
session.Rollback()
|
|
|
@@ -1950,17 +1964,7 @@ func (this *OilSupplierCertController) ReInput() {
|
|
|
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
|
|
|
- }
|
|
|
}
|
|
|
|
|
|
// 删除企业资质
|