|
|
@@ -1,6 +1,7 @@
|
|
|
package oilsupplier
|
|
|
|
|
|
import (
|
|
|
+ "dashoo.cn/backend/api/business/audithistory"
|
|
|
"encoding/json"
|
|
|
"strconv"
|
|
|
"strings"
|
|
|
@@ -151,7 +152,16 @@ func (this *QualChangeController) GetMyTaskEntityList() {
|
|
|
//找出待办任务
|
|
|
actisvc := workflow.GetActivitiService(utils.DBE)
|
|
|
certIdList := actisvc.GetMyTasks(workflow.OIL_QUAL_CHANGE, this.User.Id)
|
|
|
+ appendIdarr := strings.Split(certIdList, ",")
|
|
|
+ for i, item := range appendIdarr {
|
|
|
+ idx := strings.Index(item, "-")
|
|
|
+ if idx >= 0 {
|
|
|
+ appendIdarr[i] = strings.Split(item, "-")[0]
|
|
|
+ }
|
|
|
+ }
|
|
|
+ certIdList = strings.Join(appendIdarr, ",")
|
|
|
where += " and Id in (" + certIdList + ")"
|
|
|
+ where += " and Status != -2 "
|
|
|
|
|
|
svc := qualchange.GetQualChangeService(utils.DBE)
|
|
|
var list []qualchange.OilQualChangeMain
|
|
|
@@ -200,6 +210,36 @@ func (this *QualChangeController) FileList() {
|
|
|
this.ServeJSON()
|
|
|
}
|
|
|
|
|
|
+// @Title 添加
|
|
|
+// @Description 新增信息变更
|
|
|
+// @Success 200 {object} controllers.Request
|
|
|
+// @router /addqualmain [post]
|
|
|
+func (this *QualChangeController) AddQualMain() {
|
|
|
+ SupplierId := this.GetString("SupplierId")
|
|
|
+ Remark := this.GetString("Remark")
|
|
|
+ var qualchmain qualchange.OilQualChangeMain
|
|
|
+ var errinfo ErrorDataInfo
|
|
|
+ qualchmain.SupplierId, _ = strconv.Atoi(SupplierId)
|
|
|
+ qualchmain.Remark = Remark
|
|
|
+ qualchmain.CreateOn = time.Now()
|
|
|
+ qualchmain.CreateBy = this.User.Realname
|
|
|
+ qualchmain.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+ svc := qualchange.GetQualChangeService(utils.DBE)
|
|
|
+ _, err := svc.InsertEntityBytbl(OilQualChangeMainName, &qualchmain)
|
|
|
+ if err == nil {
|
|
|
+ errinfo.Message = "添加成功!"
|
|
|
+ errinfo.Code = 0
|
|
|
+ errinfo.Item = qualchmain.Id
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ } else {
|
|
|
+ errinfo.Message = "添加失败!"
|
|
|
+ errinfo.Code = -1
|
|
|
+ this.Data["json"] = &errinfo
|
|
|
+ this.ServeJSON()
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
// @Title 资质文件
|
|
|
// @Description get user by token
|
|
|
// @Success 200 {object} models.Userblood
|
|
|
@@ -454,31 +494,39 @@ func (this *QualChangeController) EditQualChange() {
|
|
|
var jsonblob = this.Ctx.Input.RequestBody
|
|
|
svc := qualchange.GetQualChangeService(utils.DBE)
|
|
|
json.Unmarshal(jsonblob, &model)
|
|
|
+ model.FileUrl = strings.Trim(model.FileUrl, "$")
|
|
|
+ model.FileName = strings.Trim(model.FileName, "$")
|
|
|
+ model.OldFileUrl = strings.Trim(model.OldFileUrl, "$")
|
|
|
+ model.OldFileName = strings.Trim(model.OldFileName, "$")
|
|
|
+ var err error
|
|
|
var entity qualchange.OilQualChangeDetail
|
|
|
+ var qualdetaimodel []qualchange.OilQualChangeDetail
|
|
|
var mainentirt qualchange.OilQualChangeMain
|
|
|
var qualmain []qualchange.OilQualChangeMain
|
|
|
qmwhere := " SupplierId = " + utils.ToStr(model.SupplierId)
|
|
|
svc.GetEntitysByWhere(OilQualChangeMainName, qmwhere, &qualmain)
|
|
|
- var qualmainId int
|
|
|
- if len(qualmain) == 0 {
|
|
|
- mainentirt.SupplierCertId = model.SupplierCertId
|
|
|
- mainentirt.SupplierId = model.SupplierId
|
|
|
- mainentirt.Status = "0"
|
|
|
- mainentirt.Step = 1
|
|
|
- svc.InsertEntityBytbl(OilQualChangeMainName, &mainentirt)
|
|
|
- qualmainId = mainentirt.Id
|
|
|
- } else {
|
|
|
- qualmainId = qualmain[0].Id
|
|
|
- }
|
|
|
+ mainentirt.SupplierCertId = model.SupplierCertId
|
|
|
+ mainentirt.Status = "0"
|
|
|
+ mainentirt.Step = 1
|
|
|
+ err = svc.UpdateEntityBywheretbl(OilQualChangeMainName, &mainentirt, []string{"SupplierCertId", "Status", "Step"}, qmwhere)
|
|
|
+ qualmainId := mainentirt.Id
|
|
|
+
|
|
|
+ qdwhere := " SupplierId = " + utils.ToStr(model.SupplierId) + " and FileId = "+ id
|
|
|
+ svc.GetEntitysByWhere(OilQualChangeDetailName, qdwhere, &qualdetaimodel)
|
|
|
entity = model
|
|
|
entity.Id = 0
|
|
|
entity.ParentId = qualmainId
|
|
|
entity.SupplierCertId = model.SupplierCertId
|
|
|
entity.FileId, _ = utils.StrTo(id).Int()
|
|
|
- entity.CreateOn = time.Now()
|
|
|
- entity.CreateBy = this.User.Realname
|
|
|
- entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
- _, err := svc.InsertEntityBytbl(OilQualChangeDetailName, &entity)
|
|
|
+ if len(qualdetaimodel) == 0 {
|
|
|
+ entity.CreateOn = time.Now()
|
|
|
+ entity.CreateBy = this.User.Realname
|
|
|
+ entity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+ _, err = svc.InsertEntityBytbl(OilQualChangeDetailName, &entity)
|
|
|
+ }else {
|
|
|
+ err = svc.UpdateEntityBywheretbl(OilQualChangeDetailName, &entity, []string{"OldEffectDate", "FileUrl", "FileName", "OtherRemark"}, qdwhere)
|
|
|
+ }
|
|
|
+
|
|
|
if err == nil {
|
|
|
errinfo.Message = "操作成功!"
|
|
|
errinfo.Code = 0
|
|
|
@@ -525,14 +573,16 @@ func (this *QualChangeController) AuditEntity() {
|
|
|
}()
|
|
|
svcActiviti := workflow.GetActivitiService(utils.DBE)
|
|
|
processInstanceId := ""
|
|
|
+ businessKey := ""
|
|
|
if qualmain.WorkFlowId == "0" || len(qualmain.WorkFlowId) <= 0 {
|
|
|
//启动工作流
|
|
|
- processInstanceId = svcActiviti.StartProcess(workflow.OIL_QUAL_CHANGE, utils.ToStr(qualmain.Id), this.User.Id)
|
|
|
+ businessKey = utils.ToStr(qualmain.Id) + "-" + strconv.Itoa(qualmain.AuditIndex)
|
|
|
+ processInstanceId = svcActiviti.StartProcess(workflow.OIL_QUAL_CHANGE, businessKey, this.User.Id)
|
|
|
}
|
|
|
|
|
|
var ActiComplete workflow.ActiCompleteVM
|
|
|
ActiComplete.ProcessKey = workflow.OIL_QUAL_CHANGE
|
|
|
- ActiComplete.BusinessKey = utils.ToStr(qualmain.Id)
|
|
|
+ ActiComplete.BusinessKey = businessKey
|
|
|
ActiComplete.UserNames = firstAudit
|
|
|
ActiComplete.UserId = this.User.Id
|
|
|
ActiComplete.Result = "1"
|
|
|
@@ -545,6 +595,8 @@ func (this *QualChangeController) AuditEntity() {
|
|
|
var qualmainmodel qualchange.OilQualChangeMain
|
|
|
qualmainmodel.WorkFlowId = processInstanceId
|
|
|
qualmainmodel.Status = suppliercert.FIRST_TRIAL_STATUS //二级单位初审
|
|
|
+ qualmainmodel.AuditIndex = qualmain.AuditIndex + 1
|
|
|
+ qualmainmodel.BusinessKey = ActiComplete.BusinessKey
|
|
|
qualmainmodel.CreateOn = time.Now()
|
|
|
qualmainmodel.CreateBy = this.User.Realname
|
|
|
qualmainmodel.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
@@ -555,6 +607,8 @@ func (this *QualChangeController) AuditEntity() {
|
|
|
"WorkflowId",
|
|
|
"Status",
|
|
|
"Step",
|
|
|
+ "AuditIndex",
|
|
|
+ "BusinessKey",
|
|
|
"CreateOn",
|
|
|
"CreateBy",
|
|
|
"CreateUserId",
|
|
|
@@ -627,7 +681,7 @@ func (this *QualChangeController) QualAudit() {
|
|
|
svcActiviti := workflow.GetActivitiService(utils.DBE)
|
|
|
var ActiComplete workflow.ActiCompleteVM
|
|
|
ActiComplete.ProcessKey = workflow.OIL_QUAL_CHANGE
|
|
|
- ActiComplete.BusinessKey = utils.ToStr(qualid)
|
|
|
+ ActiComplete.BusinessKey = qualmodel.BusinessKey
|
|
|
ActiComplete.UserNames = userIds
|
|
|
ActiComplete.UserId = this.User.Id
|
|
|
ActiComplete.Remarks = dataother.AuditorRemark
|
|
|
@@ -687,12 +741,29 @@ func (this *QualChangeController) QualAudit() {
|
|
|
qualchanentity.Status = "-3" //企业法规处审批
|
|
|
}
|
|
|
receiveVal := svcActiviti.TaskComplete(ActiComplete)
|
|
|
+ if qualchanentity.Status == "-2" {
|
|
|
+ // 审批历史
|
|
|
+ var audithistoryentity audithistory.Base_AuditHistory
|
|
|
+ audithistoryentity.EntityId = qualid
|
|
|
+ audithistoryentity.WorkflowId = qualmodel.WorkFlowId
|
|
|
+ audithistoryentity.Process = ActiComplete.ProcessKey
|
|
|
+ audithistoryentity.BusinessKey = ActiComplete.BusinessKey
|
|
|
+ audithistoryentity.Type = "05"
|
|
|
+ audithistoryentity.BackStep = qualmodel.Status
|
|
|
+ audithistoryentity.Index = qualmodel.AuditIndex
|
|
|
+ audithistoryentity.CreateOn = time.Now()
|
|
|
+ audithistoryentity.CreateBy = this.User.Realname
|
|
|
+ audithistoryentity.CreateUserId, _ = utils.StrTo(this.User.Id).Int()
|
|
|
+ certSrv.InsertEntity(audithistoryentity)
|
|
|
+ qualchanentity.WorkFlowId = ""
|
|
|
+ }
|
|
|
if receiveVal == "true" {
|
|
|
qualchanentity.Step = step
|
|
|
cols := []string{
|
|
|
"Id",
|
|
|
"Status",
|
|
|
"Step",
|
|
|
+ "WorkFlowId",
|
|
|
}
|
|
|
_, err := svc.UpdateEntityByIdCols(qualid, qualchanentity, cols)
|
|
|
if err == nil {
|