后端：准入 增项 年审 信息变更 记录快照 暂时注释

src/dashoo.cn/backend/api/controllers/oilsupplier/annualListener.go

@@ -3,9 +3,9 @@ package oilsupplier
 import (
 	msg2 "dashoo.cn/backend/api/business/msg"
 	"dashoo.cn/backend/api/business/oilsupplier/annualaudit"
+	"dashoo.cn/backend/api/business/oilsupplier/infochange"
 	"dashoo.cn/backend/api/business/oilsupplier/oilcostmanage"
 	"dashoo.cn/backend/api/business/oilsupplier/supplier"
-	"dashoo.cn/backend/api/business/oilsupplier/supplierlog"
 	"dashoo.cn/backend/api/business/paymentinfo"
 	"encoding/json"
 	"strconv"
@@ -328,9 +328,9 @@ func (this *OilAnnualListenerController) WorkflowEndAudit() {
 	paymentInfoSvc.UpdateEntityByIdCols(strconv.Itoa(annualEntity.CerId), &certModel, []string{"ApplyTime", "InFlag"})
 
 	// 入库成功 记录快照
-	supplierLogService := supplierlog.GetSupplierLogService(utils.DBE)
-	sourceId, _ := strconv.Atoi(annualId)
-	supplierLogService.SaveSupplierLogForAnnual(annualEntity.SupplierId, sourceId) // 年审
+	//supplierLogService := supplierlog.GetSupplierLogService(utils.DBE)
+	//sourceId, _ := strconv.Atoi(annualId)
+	//supplierLogService.SaveSupplierLogForAnnual(annualEntity.SupplierId, sourceId) // 年审
 
 	this.Data["json"] = 1
 	this.ServeJSON()
@@ -389,3 +389,18 @@ func (this *OilAnnualListenerController) AuditRejectNotice(supplierCertEntity su
 	msgService := msg2.GetMsgService(utils.DBE)
 	msgService.HandleMsg(toMobile, msg, "5-2", supplierCertEntity.CreateBy, supplierEntity.ContactName, strconv.Itoa(supplierCertEntity.CreateUserId), this.User.Username)
 }
+
+func (this *OilAnnualListenerController) updateSupplierAfterInStorage(supName string, supPid int, infoItems []infochange.OilAnnualChangeItem) error {
+	svc := infochange.GetInfoChangeService(utils.DBE)
+	var err error
+	if len(infoItems) > 0 {
+		for i := 0; i < len(infoItems); i++ {
+			where := " Id = " + utils.ToStr(supPid)
+			var sql string
+			sql = `UPDATE ` + supName + ` set ` + infoItems[i].SelectItem + ` = '` + infoItems[i].ChangeInfo + `' where ` + where
+			_, err = svc.DBE.Exec(sql)
+		}
+	}
+
+	return err
+}

src/dashoo.cn/backend/api/controllers/oilsupplier/infoChangeListener.go

@@ -8,7 +8,6 @@ import (
 	"dashoo.cn/backend/api/business/oilsupplier/supplier"
 	"dashoo.cn/backend/api/business/oilsupplier/suppliercert"
 	"dashoo.cn/backend/api/business/oilsupplier/suppliercertappend"
-	"dashoo.cn/backend/api/business/oilsupplier/supplierlog"
 	"dashoo.cn/backend/api/business/paymentinfo"
 	"dashoo.cn/backend/api/business/workflow"
 	. "dashoo.cn/backend/api/controllers"
@@ -256,9 +255,9 @@ func (this *OilInfoChangeListenerController) WorkflowEndAudit() {
 	certAppendSrv.UpdateEntityByIdCols(infoId, infoChangeEntity, cols)
 
 	//  入库成功 实际更新前 记录快照
-	supplierLogService := supplierlog.GetSupplierLogService(utils.DBE)
-	sourceId, _ := strconv.Atoi(infoId)
-	supplierLogService.SaveSupplierLogForInfoChange(infoChangeEntity.SupplierId, sourceId) // 信息变更
+	//supplierLogService := supplierlog.GetSupplierLogService(utils.DBE)
+	//sourceId, _ := strconv.Atoi(infoId)
+	//supplierLogService.SaveSupplierLogForInfoChange(infoChangeEntity.SupplierId, sourceId) // 信息变更
 
 	this.Data["json"] = 1
 	this.ServeJSON()

src/dashoo.cn/backend/api/controllers/oilsupplier/suppliercert.go

@@ -11,7 +11,6 @@ import (
 	"dashoo.cn/backend/api/business/oilsupplier/suppliercertappend"
 	"dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
 	"dashoo.cn/backend/api/business/oilsupplier/supplierfile"
-	"dashoo.cn/backend/api/business/oilsupplier/supplierlog"
 	"dashoo.cn/backend/api/business/organize"
 	"dashoo.cn/backend/api/business/paymentinfo"
 	baseparameter "dashoo.cn/business2/parameter"
@@ -1071,10 +1070,10 @@ func (this *OilSupplierCertController) UpdateIsStorage() {
 				errinfo.Message = "入库成功"
 
 				// 入库成功 记录快照	// 也可以在监听器工作流结束环节记录
-				supplierLogService := supplierlog.GetSupplierLogService(utils.DBE)
-				sourceId, _ := strconv.Atoi(id)
-				supplierId, _ := strconv.Atoi(SupplierId)
-				supplierLogService.SaveSupplierLogForAccess(supplierId, sourceId) // 准入
+				//supplierLogService := supplierlog.GetSupplierLogService(utils.DBE)
+				//sourceId, _ := strconv.Atoi(id)
+				//supplierId, _ := strconv.Atoi(SupplierId)
+				//supplierLogService.SaveSupplierLogForAccess(supplierId, sourceId) // 准入
 			} else {
 				errinfo.Message = "退回成功"
 			}

src/dashoo.cn/backend/api/controllers/oilsupplier/suppliercertAppendListener.go

@@ -7,7 +7,6 @@ import (
 	"dashoo.cn/backend/api/business/oilsupplier/suppliercertappendsub"
 	"dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
 	"dashoo.cn/backend/api/business/oilsupplier/supplierfile"
-	"dashoo.cn/backend/api/business/oilsupplier/supplierlog"
 	"dashoo.cn/backend/api/business/paymentinfo"
 	"encoding/json"
 	"strconv"
@@ -342,9 +341,9 @@ func (this *OilSupplierCertAppendListenerController) WorkflowEndAudit() {
 	certAppendSrv.UpdateEntityBywheretbl(OilSupplierCertSubName, &appendSubModel, []string{"Type"}, appendWhere)
 	// TODO 实际更新前 记录申请快照
 	// 选择在准入项更新以后记录快照，防止第一次审批未通过后又改变了准入范围(待验证)。	// CertSubStatus字段 -1是什么状态
-	supplierLogService := supplierlog.GetSupplierLogService(utils.DBE)
-	sourceId, _ := strconv.Atoi(supplierCertAppendId)
-	supplierLogService.SaveSupplierLogForAppend(supplierCertAppendEntity.SupplierId, sourceId) // 增项
+	//supplierLogService := supplierlog.GetSupplierLogService(utils.DBE)
+	//sourceId, _ := strconv.Atoi(supplierCertAppendId)
+	//supplierLogService.SaveSupplierLogForAppend(supplierCertAppendEntity.SupplierId, sourceId) // 增项
 	//更新资质表
 	appendFileWhere := " SupplierId = " + utils.ToStr(supplierCertAppendEntity.SupplierId) + " and SupType = 2"
 	var appendSubFileModel supplierfile.OilSupplierFile