|
|
@@ -3,6 +3,7 @@ package oilsupplier
|
|
|
import (
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
|
+ "strconv"
|
|
|
"strings"
|
|
|
"time"
|
|
|
|
|
|
@@ -520,14 +521,14 @@ func (this *OilSupplierCertController) AuditEntity() {
|
|
|
|
|
|
//取出审批列表
|
|
|
certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
- processInstanceId := certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, workflow.FIRST_TRIAL, this.User.Id, result, "提交给二级单位初审", OilSupplierCertSubName, OilClassOrgSettingName)
|
|
|
+ processInstanceId,_ := certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, workflow.FIRST_TRIAL, this.User.Id, result, "提交给二级单位初审", OilSupplierCertSubName, OilClassOrgSettingName, "", "")
|
|
|
fmt.Println("-----------processInstanceId------------", processInstanceId)
|
|
|
//记下workflowID(首次提交时才会记录,中间状态请忽略) 及审批状态
|
|
|
var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
certSrv.GetEntityById(certId, supplierCertEntity)
|
|
|
supplierCertEntity.WorkflowId = processInstanceId
|
|
|
supplierCertEntity.Status = suppliercert.FIRST_TRIAL_STATUS //二级单位初审
|
|
|
- supplierCertEntity.Step = 4
|
|
|
+ supplierCertEntity.Step = 2
|
|
|
cols := []string{
|
|
|
"Id",
|
|
|
"WorkflowId",
|
|
|
@@ -560,7 +561,7 @@ func (this *OilSupplierCertController) AuditEntityadmission() {
|
|
|
}()
|
|
|
//取出审批列表
|
|
|
certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
- certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, workflow.PROF_AUDIT, this.User.Id, "1", "提交给专业科室审核", OilSupplierCertSubName, OilClassOrgSettingName)
|
|
|
+ certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, workflow.PROF_AUDIT, this.User.Id, "1", "提交给专业科室审核", OilSupplierCertSubName, OilClassOrgSettingName, "", "")
|
|
|
//记下workflowID(首次提交时才会记录,中间状态请忽略) 及审批状态
|
|
|
var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
certSrv.GetEntityById(certId, supplierCertEntity)
|
|
|
@@ -616,43 +617,84 @@ func (this *OilSupplierCertController) AuditEntityappend() {
|
|
|
certSrv.UpdateEntityByIdCols(certId, supplierCertAppendEntity, cols)
|
|
|
}
|
|
|
|
|
|
-//// @Title 提交二级审批
|
|
|
-//// @Description 提交二级审批
|
|
|
-//// @Param body body suppliercert.OilSupplierCert
|
|
|
-//// @Success 200 {object} controllers.Request
|
|
|
-//// @router /audit/:id [post]
|
|
|
-//func (this *OilSupplierCertController) AuditEntity() {
|
|
|
-// certId := this.Ctx.Input.Param(":id")
|
|
|
-
|
|
|
-// var errinfo ErrorDataInfo
|
|
|
-// defer func() { //finally处理失败的异常
|
|
|
-// if err := recover(); err != nil {
|
|
|
-// errinfo.Message = "提交失败," + err.(string)
|
|
|
-// errinfo.Code = -1
|
|
|
-// this.Data["json"] = &errinfo
|
|
|
-// this.ServeJSON()
|
|
|
-// } else {
|
|
|
-// //返回正确结果
|
|
|
-// errinfo.Message = "审核提交成功"
|
|
|
-// errinfo.Code = 0
|
|
|
-// this.Data["json"] = &errinfo
|
|
|
-// this.ServeJSON()
|
|
|
-// }
|
|
|
-// }()
|
|
|
-
|
|
|
-// //取出审批列表
|
|
|
-// certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
-// processInstanceId := certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, workflow.FIRST_TRIAL, this.User.Id, "1", "提交给二级单位初审", OilSupplierCertSubName, OilClassOrgSettingName)
|
|
|
-
|
|
|
-// //记下workflowID(首次提交时才会记录,中间状态请忽略) 及审批状态
|
|
|
-// var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
-// certSrv.GetEntityById(certId, supplierCertEntity)
|
|
|
-// supplierCertEntity.WorkflowId = processInstanceId
|
|
|
-// supplierCertEntity.Status = suppliercert.FIRST_TRIAL_STATUS //二级单位初审
|
|
|
-// cols := []string{
|
|
|
-// "Id",
|
|
|
-// "WorkflowId",
|
|
|
-// "Status",
|
|
|
-// }
|
|
|
-// certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
|
|
|
-//}
|
|
|
+// @Title 审批
|
|
|
+// @Description 审批
|
|
|
+// @Param body body suppliercert.OilSupplierCert
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
+// @router /auditEntityFir/:id [post]
|
|
|
+func (this *OilSupplierCertController) AuditEntityFir() {
|
|
|
+ certId := this.Ctx.Input.Param(":id")
|
|
|
+ status := this.GetString("status")
|
|
|
+ var jsonblob = this.Ctx.Input.RequestBody
|
|
|
+ var dataother ShenHeModel
|
|
|
+ json.Unmarshal(jsonblob, &dataother)
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ defer func() { //finally处理失败的异常
|
|
|
+ if err := recover(); err != nil {
|
|
|
+ errinfo.Message = "提交失败," + err.(string)
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ //返回正确结果
|
|
|
+ errinfo.Message = "审核提交成功"
|
|
|
+ errinfo.Code = 0
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ }()
|
|
|
+
|
|
|
+ wfNodeCode := "" // 审批步骤
|
|
|
+ remarks := ""
|
|
|
+ if status == "1" {
|
|
|
+ wfNodeCode = workflow.SECOND_TRIAL
|
|
|
+ remarks = "提交给二级单位复审"
|
|
|
+ } else if status == "2" {
|
|
|
+ wfNodeCode = workflow.PROF_AUDIT
|
|
|
+ remarks = "提交给专业处审批"
|
|
|
+ } else if status == "3" {
|
|
|
+
|
|
|
+ } else if status == "4" {
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ if dataother.SuccessStatus == 1 {
|
|
|
+ //取出审批列表
|
|
|
+ certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
+ _,res := certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, wfNodeCode, this.User.Id, "1", remarks, OilSupplierCertSubName, OilClassOrgSettingName, suppliercert.SECOND_TRIAL_STATUS, "2")
|
|
|
+ if res == "true" {
|
|
|
+ errinfo.Message = "审核通过!"
|
|
|
+ errinfo.Code = 0
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "工作流异常,请联系管理员!"
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// @Title 审核
|
|
|
+// @Description 审核
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
+// @router /auditcallback [get]
|
|
|
+func (this *OilSupplierCertController) AuditCallback() {
|
|
|
+ id := this.GetString("Id")
|
|
|
+ status := this.GetString("status")
|
|
|
+ step := this.GetString("step")
|
|
|
+ var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
+ svc := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
+ supplierCertEntity.Status = status
|
|
|
+ supplierCertEntity.Step,_ = strconv.Atoi(step)
|
|
|
+ cols := []string{
|
|
|
+ "Id",
|
|
|
+ "Status",
|
|
|
+ "step",
|
|
|
+ }
|
|
|
+ svc.UpdateEntityByIdCols(id, supplierCertEntity, cols)
|
|
|
+ fmt.Println(id,status,step)
|
|
|
+}
|