|
|
@@ -499,6 +499,12 @@ func (this *OilSupplierCertController) DeleteEntity() {
|
|
|
func (this *OilSupplierCertController) AuditEntity() {
|
|
|
certId := this.Ctx.Input.Param(":id")
|
|
|
firstAudit := this.GetString("firstAudit")
|
|
|
+
|
|
|
+ //取出审批列表
|
|
|
+ certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
+ var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
+ certSrv.GetEntityById(certId, &supplierCertEntity)
|
|
|
+
|
|
|
var errinfo ErrorDataInfo
|
|
|
defer func() { //finally处理失败的异常
|
|
|
if err := recover(); err != nil {
|
|
|
@@ -521,9 +527,6 @@ func (this *OilSupplierCertController) AuditEntity() {
|
|
|
// result = "0"
|
|
|
//}
|
|
|
|
|
|
- //取出审批列表
|
|
|
- certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
-
|
|
|
svcActiviti := workflow.GetActivitiService(utils.DBE)
|
|
|
//获得有审核权限的人员
|
|
|
var users []userRole.Base_RoleList
|
|
|
@@ -533,6 +536,11 @@ func (this *OilSupplierCertController) AuditEntity() {
|
|
|
rsvc.GetAuditStepRoleEntity(OilAuditSettingName, firstAudit, workflow.FIRST_TRIAL, &auditWorkflow)
|
|
|
users = rsvc.GetUserByRole(strconv.Itoa(auditWorkflow.RoleId), this.User.AccCode) //
|
|
|
|
|
|
+ processInstanceId := ""
|
|
|
+ if supplierCertEntity.WorkflowId == "0" || len(supplierCertEntity.WorkflowId) <= 0 {
|
|
|
+ //启动工作流
|
|
|
+ processInstanceId = svcActiviti.StartProcess(workflow.OIL_SUPPLIER_APPLY, certId, this.User.Id)
|
|
|
+ }
|
|
|
|
|
|
//processInstanceId,_ := certSrv.SubmitOrgAudit(certId, workflow.OIL_SUPPLIER_APPLY, workflow.FIRST_TRIAL, this.User.Id, result, "提交给二级单位初审", OilSupplierCertSubName, OilClassOrgSettingName, "", "")
|
|
|
for _, tmpUser := range users {
|
|
|
@@ -545,7 +553,7 @@ func (this *OilSupplierCertController) AuditEntity() {
|
|
|
ActiComplete.UserNames = userIds
|
|
|
ActiComplete.UserId = this.User.Id
|
|
|
ActiComplete.Result = "1"
|
|
|
- ActiComplete.Remarks = "提交给二级单位初审"
|
|
|
+ ActiComplete.Remarks = ""
|
|
|
ActiComplete.CallbackUrl = ""
|
|
|
receiveVal := svcActiviti.TaskComplete(ActiComplete)
|
|
|
|
|
|
@@ -564,9 +572,8 @@ func (this *OilSupplierCertController) AuditEntity() {
|
|
|
|
|
|
fmt.Println("-----------processInstanceId------------")
|
|
|
//记下workflowID(首次提交时才会记录,中间状态请忽略) 及审批状态
|
|
|
- var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
- certSrv.GetEntityById(certId, supplierCertEntity)
|
|
|
- //supplierCertEntity.WorkflowId = processInstanceId
|
|
|
+
|
|
|
+ supplierCertEntity.WorkflowId = processInstanceId
|
|
|
supplierCertEntity.Status = suppliercert.FIRST_TRIAL_STATUS //二级单位初审
|
|
|
supplierCertEntity.Step = 2
|
|
|
supplierCertEntity.FirstAudit,_ = strconv.Atoi(firstAudit)
|
|
|
@@ -680,7 +687,13 @@ func (this *OilSupplierCertController) AuditEntityappend() {
|
|
|
// @router /auditEntityFir/:id [post]
|
|
|
func (this *OilSupplierCertController) AuditEntityFir() {
|
|
|
certId := this.Ctx.Input.Param(":id")
|
|
|
- status := this.GetString("status")
|
|
|
+ auditer := this.GetString("auditer")
|
|
|
+
|
|
|
+ //取出审批列表
|
|
|
+ certSrv := suppliercert.GetOilSupplierCertService(utils.DBE)
|
|
|
+ var supplierCertEntity suppliercert.OilSupplierCert
|
|
|
+ certSrv.GetEntityById(certId, &supplierCertEntity)
|
|
|
+
|
|
|
var jsonblob = this.Ctx.Input.RequestBody
|
|
|
var dataother ShenHeModel
|
|
|
json.Unmarshal(jsonblob, &dataother)
|
|
|
@@ -700,29 +713,54 @@ func (this *OilSupplierCertController) AuditEntityFir() {
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
- wfNodeCode := "" // 审批步骤
|
|
|
- remarks := ""
|
|
|
- step := "2"
|
|
|
- if status == "1" {
|
|
|
- wfNodeCode = workflow.SECOND_TRIAL
|
|
|
- remarks = "提交给二级单位复审"
|
|
|
- step = "2"
|
|
|
- } else if status == "2" {
|
|
|
- wfNodeCode = workflow.PROF_AUDIT
|
|
|
- remarks = "提交给专业处审批"
|
|
|
- step = "2"
|
|
|
- } else if status == "3" {
|
|
|
+ //remarks := ""
|
|
|
+ step := 2
|
|
|
+ status := ""
|
|
|
+ if supplierCertEntity.Status == "1" {
|
|
|
+ status = suppliercert.SECOND_TRIAL_STATUS
|
|
|
+ //remarks = "提交给二级单位复审"
|
|
|
+ step = 2
|
|
|
+ } else if supplierCertEntity.Status == "2" {
|
|
|
+ //remarks = "提交给专业处"
|
|
|
+ status = suppliercert.THIRD_TRIAL_STATUS
|
|
|
+ step = 2
|
|
|
+ //获得有专业审核接收权限的人员
|
|
|
+ var users1 []userRole.Base_RoleList
|
|
|
+ var auditWorkflow1 auditsetting.Base_OilAuditSetting
|
|
|
+ rsvc := auditsetting.GetOilAuditSettingService(utils.DBE)
|
|
|
+ rsvc.GetAuditStepRoleEntity(OilAuditSettingName, "100000172", workflow.PROF_RECE, &auditWorkflow1)
|
|
|
+ users1 = rsvc.GetUserByRole(strconv.Itoa(auditWorkflow1.RoleId), this.User.AccCode)
|
|
|
+ for _, tmpUser := range users1 {
|
|
|
+ auditer += strconv.FormatInt(tmpUser.Id, 10) + ","
|
|
|
+ }
|
|
|
+ auditer = strings.Trim(auditer, ",")
|
|
|
+ } else if supplierCertEntity.Status == "3" {
|
|
|
|
|
|
- } else if status == "4" {
|
|
|
+ } else if supplierCertEntity.Status == "4" {
|
|
|
|
|
|
}
|
|
|
|
|
|
+ svcActiviti := workflow.GetActivitiService(utils.DBE)
|
|
|
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, step)
|
|
|
- if res == "true" {
|
|
|
- errinfo.Message = "审核通过!"
|
|
|
+ var ActiComplete workflow.ActiCompleteVM
|
|
|
+ ActiComplete.ProcessKey = workflow.OIL_SUPPLIER_APPLY
|
|
|
+ ActiComplete.BusinessKey = certId
|
|
|
+ ActiComplete.UserNames = auditer
|
|
|
+ ActiComplete.UserId = this.User.Id
|
|
|
+ ActiComplete.Result = "1"
|
|
|
+ ActiComplete.Remarks = dataother.AuditorRemark
|
|
|
+ ActiComplete.CallbackUrl = ""
|
|
|
+ receiveVal := svcActiviti.TaskComplete(ActiComplete)
|
|
|
+
|
|
|
+ if receiveVal == "true" {
|
|
|
+ supplierCertEntity.Status = status
|
|
|
+ supplierCertEntity.Step = step
|
|
|
+ cols := []string{
|
|
|
+ "Status",
|
|
|
+ "Step",
|
|
|
+ }
|
|
|
+ certSrv.UpdateEntityByIdCols(certId, supplierCertEntity, cols)
|
|
|
+ errinfo.Message = "提交成功!"
|
|
|
errinfo.Code = 0
|
|
|
this.Data["json"] = &errinfo
|
|
|
this.ServeJSON()
|
|
|
@@ -731,6 +769,7 @@ func (this *OilSupplierCertController) AuditEntityFir() {
|
|
|
errinfo.Code = -1
|
|
|
this.Data["json"] = &errinfo
|
|
|
this.ServeJSON()
|
|
|
+ return
|
|
|
}
|
|
|
} else {
|
|
|
|