|
|
@@ -182,7 +182,7 @@ func (this *OilSupplierCertListenerController) ConcentrateAudit() {
|
|
|
certSrv.UpdateEntityByIdCols(supplierCertId, supplierCertEntity, cols)
|
|
|
|
|
|
//查出集中审批的人员
|
|
|
- stepCode := workflow.PROF_CONCENT //集中审批
|
|
|
+ stepCode := workflow.PROF_REGULATION //集中审批 其实就是企业法规处
|
|
|
auditSettingService := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
approverIds := auditSettingService.GetApproverIdsByStepCodeForConcentrateAudit(stepCode)
|
|
|
var approveInfo ListenerApproveInfo
|
|
|
@@ -331,6 +331,60 @@ func (this *OilSupplierCertListenerController) GetPrePayer() {
|
|
|
this.ServeJSON()
|
|
|
}
|
|
|
|
|
|
+// @Title 企业法规处入库人员列表 --回调
|
|
|
+// @Description get user by token
|
|
|
+// @Success 200 {string} string
|
|
|
+// @router /pre-storage-audit [post]
|
|
|
+func (this *OilSupplierCertListenerController) GetStorageAuditor() {
|
|
|
+ var jsonBlob = this.Ctx.Input.RequestBody
|
|
|
+ var listenerApprove ListenerApproveParams
|
|
|
+ json.Unmarshal(jsonBlob, &listenerApprove)
|
|
|
+ supplierCertId := strings.Split(listenerApprove.BusinessKey, "-")[0]
|
|
|
+
|
|
|
+ certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
+ var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
+ certSrv.GetEntityById(supplierCertId, &supplierCertEntity)
|
|
|
+ cols := []string{
|
|
|
+ "Id",
|
|
|
+ "Status",
|
|
|
+ }
|
|
|
+ //进入此步骤,记录在数据库中
|
|
|
+ supplierCertEntity.Status = suppliercert.STOREING_STATUS //待入库
|
|
|
+ certSrv.UpdateEntityByIdCols(supplierCertId, supplierCertEntity, cols)
|
|
|
+
|
|
|
+ //查出入库审批的人员
|
|
|
+ stepCode := workflow.PROF_REGULATION //待入库(企业法规处)
|
|
|
+ auditSettingService := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
+ approverIds := auditSettingService.GetApproverIdsByStepCodeForConcentrateAudit(stepCode)
|
|
|
+ var approveInfo ListenerApproveInfo
|
|
|
+ approveInfo.Users = approverIds
|
|
|
+ this.Data["json"] = &approveInfo
|
|
|
+ this.ServeJSON()
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 企业法规处审批入库完成, 工作流结束--回调
|
|
|
+// @Description get user by token
|
|
|
+// @Success 200 {string} string
|
|
|
+// @router /workflow-end [get]
|
|
|
+func (this *OilSupplierCertListenerController) WorkflowEndAudit() {
|
|
|
+ businessKey := this.GetString("businessKey")
|
|
|
+ supplierCertId := strings.Split(businessKey, "-")[0]
|
|
|
+ certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
+ var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
+ certSrv.GetEntityById(supplierCertId, &supplierCertEntity)
|
|
|
+
|
|
|
+ cols := []string{
|
|
|
+ "Id",
|
|
|
+ "Status",
|
|
|
+ }
|
|
|
+ //进入此步骤,记录在数据库中
|
|
|
+ supplierCertEntity.Status = suppliercert.STORE_STATUS //已入库
|
|
|
+ certSrv.UpdateEntityByIdCols(supplierCertId, supplierCertEntity, cols)
|
|
|
+
|
|
|
+ this.Data["json"] = 1
|
|
|
+ this.ServeJSON()
|
|
|
+}
|
|
|
+
|
|
|
// @Title 审批驳回--回调
|
|
|
// @Description get user by token
|
|
|
// @Success 200 {string} string
|
|
|
@@ -350,7 +404,6 @@ func (this *OilSupplierCertListenerController) ApprovalRefuse() {
|
|
|
supplierCertEntity.Status = suppliercert.DRAFT_STATUS //重置为草稿状态
|
|
|
certSrv.UpdateEntityByIdCols(supplierCertId, supplierCertEntity, cols)
|
|
|
|
|
|
- //创建人即为交费的人员
|
|
|
this.Data["json"] = 1
|
|
|
this.ServeJSON()
|
|
|
}
|