|
@@ -0,0 +1,989 @@
|
|
|
+/*
|
|
|
+ * @description: 审批流程数据库操作相关
|
|
|
+ * @Author: LanJianRong
|
|
|
+ * @Date: 2021-01-06
|
|
|
+ * @FilePath: \construction_management\dao\approver_dao.go
|
|
|
+ */
|
|
|
+
|
|
|
+package dao
|
|
|
+
|
|
|
+import (
|
|
|
+ "errors"
|
|
|
+ "fmt"
|
|
|
+ "strconv"
|
|
|
+ "time"
|
|
|
+
|
|
|
+ "github.com/go-xorm/xorm"
|
|
|
+ "go.mod/comm"
|
|
|
+ "go.mod/conf"
|
|
|
+ "go.mod/models"
|
|
|
+ "go.mod/web/viewmodels"
|
|
|
+)
|
|
|
+
|
|
|
+// 数据库操作引擎
|
|
|
+type ApproverDao struct {
|
|
|
+ engine *xorm.Engine
|
|
|
+}
|
|
|
+
|
|
|
+// 获得一个DAO对象
|
|
|
+func NewApproverDao(engine *xorm.Engine) *ApproverDao {
|
|
|
+ return &ApproverDao{
|
|
|
+ engine: engine,
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// 批量插入数据
|
|
|
+func (d *ApproverDao) InsertData(cur_uid int, bid int, pid int, dataType int, dataId int, auditors []int, reAuditors []int) error {
|
|
|
+ data := make([]models.CmApprover, 0)
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+ var content string
|
|
|
+ var title string
|
|
|
+ if dataType == 1 {
|
|
|
+ safe := &models.CmSafe{Id: dataId}
|
|
|
+ _, err := d.engine.Get(safe)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ account := &models.CmProjectAccount{Id: safe.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title = fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+ content = fmt.Sprintf("%s|%s|已上报,审批中", safe.Code, safe.InspectionDetail)
|
|
|
+ } else {
|
|
|
+ quality := &models.CmQuality{Id: dataId}
|
|
|
+ _, err := d.engine.Get(quality)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ account := &models.CmProjectAccount{Id: quality.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ title = fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+ content = fmt.Sprintf("%s|%s|已上报,审批中", quality.Code, quality.InspectionDetail)
|
|
|
+ }
|
|
|
+ _, err := d.engine.Exec("delete from project_message where data_type = ? and data_id = ?", dataType, dataId)
|
|
|
+ for i, item := range auditors {
|
|
|
+ approverVM := models.CmApprover{}
|
|
|
+ approverVM.AuditId = item
|
|
|
+ approverVM.AuditOrder = i + 1
|
|
|
+ approverVM.Progress = 0
|
|
|
+ approverVM.BidsectionId = bid
|
|
|
+ approverVM.ProjectId = pid
|
|
|
+ approverVM.DataType = dataType
|
|
|
+ approverVM.DataId = dataId
|
|
|
+ approverVM.Status = 0
|
|
|
+ if i == 0 {
|
|
|
+ approverVM.Status = 1
|
|
|
+ }
|
|
|
+ data = append(data, approverVM)
|
|
|
+
|
|
|
+ // 消息推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item
|
|
|
+ msgVM.BidsectionId = bid
|
|
|
+ msgVM.ProjectId = pid
|
|
|
+ msgVM.DataId = dataId
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = content
|
|
|
+ msgVM.Title = title
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+ checkVM := models.CmApprover{}
|
|
|
+ checkVM.AuditOrder = len(auditors) + 1
|
|
|
+ checkVM.Progress = 1
|
|
|
+ checkVM.BidsectionId = bid
|
|
|
+ checkVM.ProjectId = pid
|
|
|
+ checkVM.DataType = dataType
|
|
|
+ checkVM.DataId = dataId
|
|
|
+ data = append(data, checkVM)
|
|
|
+ for i, item := range reAuditors {
|
|
|
+ approverVM := models.CmApprover{}
|
|
|
+ approverVM.AuditId = item
|
|
|
+ approverVM.AuditOrder = i + 2 + len(auditors)
|
|
|
+ approverVM.Progress = 2
|
|
|
+ approverVM.BidsectionId = bid
|
|
|
+ approverVM.ProjectId = pid
|
|
|
+ approverVM.DataType = dataType
|
|
|
+ approverVM.DataId = dataId
|
|
|
+ data = append(data, approverVM)
|
|
|
+
|
|
|
+ // 消息推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item
|
|
|
+ msgVM.BidsectionId = bid
|
|
|
+ msgVM.ProjectId = pid
|
|
|
+ msgVM.DataId = dataId
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = content
|
|
|
+ msgVM.Title = title
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+ // 再推送自己
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = cur_uid
|
|
|
+ msgVM.BidsectionId = bid
|
|
|
+ msgVM.ProjectId = pid
|
|
|
+ msgVM.DataId = dataId
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = content
|
|
|
+ msgVM.Title = title
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ _, err = d.engine.Insert(data)
|
|
|
+ _, err = d.engine.Insert(msg)
|
|
|
+
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+// 更改状态
|
|
|
+func (d *ApproverDao) ChangeStatus(id int, status int) error {
|
|
|
+ data := &models.CmApprover{Status: status}
|
|
|
+ _, err := d.engine.Where("id = ?", id).Cols("status").Update(data)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+// 更改审批人
|
|
|
+func (d *ApproverDao) ChangeAuditId(bid int, dataType int, dataId int, auditOrder int, uid int) error {
|
|
|
+ data := &models.CmApprover{AuditId: uid}
|
|
|
+ _, err := d.engine.Where("bidsection_id = ? and data_type = ? and data_id = ? and audit_order = ?", bid, dataType, dataId, auditOrder).Cols("audit_id").Update(data)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+// 更改下一个审批人的状态
|
|
|
+func (d *ApproverDao) ChangeNextStatus(id int, status int) error {
|
|
|
+ data := &models.CmApprover{Id: id}
|
|
|
+ _, err := d.engine.Get(data)
|
|
|
+ newData := &models.CmApprover{Status: status}
|
|
|
+ _, err = d.engine.Where("bidsection_id = ? and data_type = ? and data_id = ? and audit_order = ?", data.BidsectionId, data.DataType, data.DataId, data.AuditOrder+1).Cols("status").Update(newData)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+// 根据当前times,获取审批流程(包括原报)
|
|
|
+func (d *ApproverDao) GetAuditorsWithOwner(bid int, dataType int, dataId int, cur_uid int) []viewmodels.Auditors {
|
|
|
+ auditors := make([]viewmodels.Auditors, 0)
|
|
|
+ auditor := viewmodels.Auditors{Progress: "", Id: "", Status: 2}
|
|
|
+
|
|
|
+ _, err := d.engine.Sql("select name, company, position, mobile, id as `audit_id` from `cm_project_account` where id = ?", cur_uid).Get(&auditor)
|
|
|
+
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err)
|
|
|
+ }
|
|
|
+ auditors = append(auditors, auditor)
|
|
|
+
|
|
|
+ d.engine.Sql("select pa.`company`, pa.`name`, pa.`account_group`,pa.`mobile`, pa.`position`,ca.`audit_id` as `audit_id`, ca.`id`, ca.`status`, ca.`audit_order`, ca.`progress` from `cm_project_account` as pa, `cm_approver` as ca where ca.`bidsection_id` = ? and ca.`data_type` = ? and ca.`data_id` = ? and ca.audit_id = pa.id order by `audit_order`", bid, dataType, dataId).Find(&auditors)
|
|
|
+ // 原报
|
|
|
+ return auditors
|
|
|
+}
|
|
|
+
|
|
|
+func (d *ApproverDao) FindApproverById(id int) (*models.CmApprover, error) {
|
|
|
+ data := &models.CmApprover{}
|
|
|
+ _, err := d.engine.ID(id).Get(data)
|
|
|
+ return data, err
|
|
|
+}
|
|
|
+
|
|
|
+// 获取最新的审核人
|
|
|
+func (d *ApproverDao) GetLastedAuditor(bid int, dataType int, dataId int) *viewmodels.Approver {
|
|
|
+ data := &models.CmApprover{BidsectionId: bid, DataType: dataType, DataId: dataId, Status: 1}
|
|
|
+ has, _ := d.engine.Get(data)
|
|
|
+ approverVM := &viewmodels.Approver{}
|
|
|
+ if has == true {
|
|
|
+ id, _ := comm.AesEncrypt(strconv.Itoa(data.Id), conf.SignSecret)
|
|
|
+ approverVM.Id = id
|
|
|
+ pid, _ := comm.AesEncrypt(strconv.Itoa(data.ProjectId), conf.SignSecret)
|
|
|
+ approverVM.ProjectId = pid
|
|
|
+ bid, _ := comm.AesEncrypt(strconv.Itoa(data.BidsectionId), conf.SignSecret)
|
|
|
+ approverVM.BidsectionId = bid
|
|
|
+ dataId, _ := comm.AesEncrypt(strconv.Itoa(data.DataId), conf.SignSecret)
|
|
|
+ approverVM.DataId = dataId
|
|
|
+ auditId, _ := comm.AesEncrypt(strconv.Itoa(data.AuditId), conf.SignSecret)
|
|
|
+ approverVM.AuditId = auditId
|
|
|
+ approverVM.AuditOrder = data.AuditOrder
|
|
|
+ approverVM.DataType = data.DataType
|
|
|
+ approverVM.Progress = strconv.Itoa(data.Progress)
|
|
|
+ approverVM.Status = data.Status
|
|
|
+ }
|
|
|
+ return approverVM
|
|
|
+}
|
|
|
+
|
|
|
+// 获取最后一个审批人
|
|
|
+func (d *ApproverDao) GetLastAuditor(bid int, dataType int, dataId int) (*models.CmApprover, error) {
|
|
|
+ data := &models.CmApprover{BidsectionId: bid, DataType: dataType, DataId: dataId}
|
|
|
+ _, err := d.engine.Desc("audit_order").Limit(1).Get(data)
|
|
|
+ return data, err
|
|
|
+}
|
|
|
+
|
|
|
+// 初始化审批流程状态
|
|
|
+func (d *ApproverDao) InitStatus(auditType string, bid int, dataType int, dataId int, auditId int, times int, progress int, opinion string) error {
|
|
|
+ session := d.engine.NewSession()
|
|
|
+ defer session.Close()
|
|
|
+ err := session.Begin()
|
|
|
+ if err != nil {
|
|
|
+ return errors.New("操作失败-db")
|
|
|
+ }
|
|
|
+
|
|
|
+ // 消息推送,先删除旧的推送
|
|
|
+ _, err = session.Exec("delete from cm_project_message where data_type = ? and data_id = ?", auditType, dataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ approvers := make([]models.CmApprover, 0)
|
|
|
+ err = session.Where("data_type = ? and data_id = ? and audit_id != 0", dataType, dataId).Find(&approvers)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ data := &models.CmApprover{Status: 0}
|
|
|
+ _, err = session.Where("bidsection_id = ? and data_type = ? and data_id = ?", bid, dataType, dataId).Cols("status").Update(data)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ if auditType == "safe" {
|
|
|
+ safe := &models.CmSafe{}
|
|
|
+ _, err = session.ID(dataId).Get(safe)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ account := &models.CmProjectAccount{Id: safe.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title := fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+ for _, item := range approvers {
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item.AuditId
|
|
|
+ msgVM.BidsectionId = item.BidsectionId
|
|
|
+ msgVM.ProjectId = item.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = item.DataId
|
|
|
+ msgVM.DataType = item.DataType
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|审批退回到上报人", safe.Code, safe.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加巡检拥有者的推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = safe.Uid
|
|
|
+ msgVM.BidsectionId = safe.BidsectionId
|
|
|
+ msgVM.ProjectId = safe.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = safe.Id
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|审批退回到上报人", safe.Code, safe.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+
|
|
|
+ // 插入消息
|
|
|
+ _, err = session.Insert(msg)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ _, err = session.Exec("update cm_safe set status = ?, times = ? where id = ?", 0, times+1, dataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 增加审批日志
|
|
|
+ safeAudit := &models.CmSafeAudit{BidsectionId: bid, SafeId: dataId, Times: times, AuditId: auditId, Status: 1, Progress: progress, CreateTime: time.Now(), Opinion: opinion}
|
|
|
+ _, err = session.Insert(safeAudit)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 说明本身除于整改人流程,退回原报,要将整改总数-1,未整改总数+1
|
|
|
+ if progress-1 != 0 {
|
|
|
+ _, err = session.Exec("update cm_tree set safe_rectification = safe_rectification + 1, safe_rectification_in = if(safe_rectification_in >= 1, safe_rectification_in - 1, 0) where bidsection_id = ?", bid)
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ quality := &models.CmQuality{}
|
|
|
+ _, err = session.ID(dataId).Get(quality)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ account := &models.CmProjectAccount{Id: quality.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title := fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+ for _, item := range approvers {
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item.AuditId
|
|
|
+ msgVM.BidsectionId = item.BidsectionId
|
|
|
+ msgVM.ProjectId = item.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = item.DataId
|
|
|
+ msgVM.DataType = item.DataType
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|审批退回到上报人", quality.Code, quality.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加巡检拥有者的推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = quality.Uid
|
|
|
+ msgVM.BidsectionId = quality.BidsectionId
|
|
|
+ msgVM.ProjectId = quality.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = quality.Id
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|审批退回到上报人", quality.Code, quality.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+
|
|
|
+ // 插入消息
|
|
|
+ _, err = session.Insert(msg)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ _, err = session.Exec("update cm_quality set status = ?, times = ? where id = ?", 0, times+1, dataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 增加审批日志
|
|
|
+ qualityAudit := &models.CmQualityAudit{BidsectionId: bid, QualityId: dataId, Times: times, AuditId: auditId, Status: 1, Progress: progress, CreateTime: time.Now(), Opinion: opinion}
|
|
|
+ _, err = session.Insert(qualityAudit)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ if progress-1 != 0 {
|
|
|
+ _, err = session.Exec("update cm_tree set quality_rectification = quality_rectification + 1, quality_rectification_in = if(quality_rectification_in >= 1, quality_rectification_in - 1, 0) where bidsection_id = ?", bid)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ err = session.Commit()
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+// 审批通过
|
|
|
+func (d *ApproverDao) PassHandler(auditType string, id int, uid int, auditId int, opinion string, rectifiedInfo string) error {
|
|
|
+ session := d.engine.NewSession()
|
|
|
+ defer session.Close()
|
|
|
+ // add Begin() before any action
|
|
|
+ err := session.Begin()
|
|
|
+ auditor, err := d.FindApproverById(id)
|
|
|
+ if err != nil {
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ if auditor.AuditId != uid {
|
|
|
+ return errors.New("该用户没有审批权限!")
|
|
|
+ }
|
|
|
+
|
|
|
+ var msgContent string
|
|
|
+ switch auditor.Progress {
|
|
|
+ case 0:
|
|
|
+ msgContent = "审批完成,待整改"
|
|
|
+ case 1:
|
|
|
+ msgContent = "整改完成,待复查"
|
|
|
+ case 2:
|
|
|
+ msgContent = "复查完成"
|
|
|
+ }
|
|
|
+ // 消息推送,先删除旧的推送
|
|
|
+ _, err = session.Exec("delete from cm_project_message where data_type = ? and data_id = ?", auditor.DataType, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ approvers := make([]models.CmApprover, 0)
|
|
|
+ err = session.Where("data_type = ? and data_id = ? and audit_id != 0", auditor.DataType, auditor.DataId).Find(&approvers)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ // 安全巡检
|
|
|
+ if auditType == "safe" {
|
|
|
+ safe := &models.CmSafe{}
|
|
|
+ _, err = session.ID(auditor.DataId).Get(safe)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ account := &models.CmProjectAccount{Id: safe.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title := fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+ for _, item := range approvers {
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item.AuditId
|
|
|
+ msgVM.BidsectionId = item.BidsectionId
|
|
|
+ msgVM.ProjectId = item.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = item.DataId
|
|
|
+ msgVM.DataType = item.DataType
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|%s", msgContent, safe.Code, safe.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加巡检拥有者的推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = safe.Uid
|
|
|
+ msgVM.BidsectionId = safe.BidsectionId
|
|
|
+ msgVM.ProjectId = safe.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = safe.Id
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|%s", msgContent, safe.Code, safe.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+
|
|
|
+ // 插入消息
|
|
|
+ _, err = session.Insert(msg)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 增加审批日志
|
|
|
+ auditReacord := &models.CmSafeAudit{BidsectionId: auditor.BidsectionId, SafeId: auditor.DataId, AuditId: auditor.AuditId, Times: safe.Times, CreateTime: time.Now(), Status: 0, Progress: auditor.Progress + 1, Opinion: opinion, Rectifiedinfo: rectifiedInfo}
|
|
|
+ _, err = session.Insert(auditReacord)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 改变审批流程中当前审批人以及下一个审批人的审批流程状态
|
|
|
+ curData := &models.CmApprover{Status: 2}
|
|
|
+ _, err = session.ID(id).Cols("status").Update(curData)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ nextData := &models.CmApprover{Status: 1}
|
|
|
+ _, err = session.Where("bidsection_id = ? and data_type = ? and data_id = ? and audit_order = ?", auditor.BidsectionId, auditor.DataType, auditor.DataId, auditor.AuditOrder+1).Cols("status").Update(nextData)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ if auditId != 0 {
|
|
|
+ // 审批人选择了整改人
|
|
|
+ // 修改cm_safe表的status状态为待整改
|
|
|
+ _, err = session.Exec("update `cm_safe` set status = ? where id = ?", 2, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ // 将cm_tree的safe_rectification待整改+1
|
|
|
+ _, err := session.Exec("update cm_tree set safe_rectification_in = safe_rectification_in + 1, safe_rectification = if(safe_rectification >= 1, safe_rectification - 1, 0) where bidsection_id = ?", auditor.BidsectionId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 改变审批流程中的整改人id
|
|
|
+ _, err = session.Exec("update `cm_approver` set `audit_id` = ? where `bidsection_id` = ? and `data_type` = ? and `data_id` = ? and `audit_order` = ?", auditId, auditor.BidsectionId, auditor.DataType, auditor.DataId, auditor.AuditOrder+1)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ if auditor.Progress == 1 {
|
|
|
+ // 整改人审批流程
|
|
|
+ // 修改cm_safe表的status状态为待复查
|
|
|
+ _, err = session.Exec("update `cm_safe` set status = ? where id = ?", 3, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ // 复查流程
|
|
|
+ // 查找最后一个审批人
|
|
|
+ lastAuditor := &models.CmApprover{BidsectionId: auditor.BidsectionId, DataType: auditor.DataType, DataId: auditor.DataId}
|
|
|
+ _, err = session.Desc("audit_order").Limit(1).Get(lastAuditor)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ if lastAuditor.AuditId == auditor.AuditId {
|
|
|
+ // 说明审批流程已经走完
|
|
|
+ _, err = session.Exec("update `cm_safe` set status = ? where id = ?", 4, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 将cm_tree的safe_rectification_finish待整改+1
|
|
|
+ _, err := session.Exec("update cm_tree set safe_rectification_finish = safe_rectification_finish + 1, safe_rectification_in = if(safe_rectification_in >= 1, safe_rectification_in - 1, 0)where bidsection_id = ?", auditor.BidsectionId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ // 质量巡检
|
|
|
+ quality := &models.CmQuality{}
|
|
|
+ _, err = session.ID(auditor.DataId).Get(quality)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ account := &models.CmProjectAccount{Id: quality.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title := fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+ for _, item := range approvers {
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item.AuditId
|
|
|
+ msgVM.BidsectionId = item.BidsectionId
|
|
|
+ msgVM.ProjectId = item.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = item.DataId
|
|
|
+ msgVM.DataType = item.DataType
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|%s", msgContent, quality.Code, quality.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加巡检拥有者的推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = quality.Uid
|
|
|
+ msgVM.BidsectionId = quality.BidsectionId
|
|
|
+ msgVM.ProjectId = quality.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = quality.Id
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|%s", msgContent, quality.Code, quality.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+
|
|
|
+ // 插入消息
|
|
|
+ _, err = session.Insert(msg)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ // 增加审批日志
|
|
|
+ auditReacord := &models.CmQualityAudit{BidsectionId: auditor.BidsectionId, QualityId: auditor.DataId, AuditId: auditor.AuditId, Times: quality.Times, CreateTime: time.Now(), Status: 0, Progress: auditor.Progress + 1, Opinion: opinion, Rectifiedinfo: rectifiedInfo}
|
|
|
+ _, err = session.Insert(auditReacord)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 改变审批流程中当前审批人以及下一个审批人的审批流程状态
|
|
|
+ curData := &models.CmApprover{Status: 2}
|
|
|
+ _, err = session.ID(id).Cols("status").Update(curData)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ nextData := &models.CmApprover{Status: 1}
|
|
|
+ _, err = session.Where("bidsection_id = ? and data_type = ? and data_id = ? and audit_order = ?", auditor.BidsectionId, auditor.DataType, auditor.DataId, auditor.AuditOrder+1).Cols("status").Update(nextData)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ if auditId != 0 {
|
|
|
+ // 审批人选择了整改人
|
|
|
+ // 修改cm_quality表的status状态为待整改
|
|
|
+ _, err = session.Exec("update `cm_quality` set status = ? where id = ?", 2, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ // 将cm_tree的quality_rectification待整改+1
|
|
|
+ _, err := session.Exec("update cm_tree set quality_rectification_in = quality_rectification_in + 1, quality_rectification = if(quality_rectification >= 1, quality_rectification - 1, 0) where bidsection_id = ?", auditor.BidsectionId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 改变审批流程中的整改人id
|
|
|
+ _, err = session.Exec("update `cm_approver` set `audit_id` = ? where `bidsection_id` = ? and `data_type` = ? and `data_id` = ? and `audit_order` = ?", auditId, auditor.BidsectionId, auditor.DataType, auditor.DataId, auditor.AuditOrder+1)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ if auditor.Progress == 1 {
|
|
|
+ // 整改人审批流程
|
|
|
+ // 修改cm_quality表的status状态为待复查
|
|
|
+ _, err = session.Exec("update `cm_quality` set status = ? where id = ?", 3, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ // 复查流程
|
|
|
+ // 查找最后一个审批人
|
|
|
+ lastAuditor := &models.CmApprover{BidsectionId: auditor.BidsectionId, DataType: auditor.DataType, DataId: auditor.DataId}
|
|
|
+ _, err = session.Desc("audit_order").Limit(1).Get(lastAuditor)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ if lastAuditor.AuditId == auditor.AuditId {
|
|
|
+ // 说明审批流程已经走完
|
|
|
+ _, err = session.Exec("update `cm_quality` set status = ? where id = ?", 4, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 将cm_tree的quality_rectification_finish待整改+1
|
|
|
+ _, err := session.Exec("update cm_tree set quality_rectification_finish = quality_rectification_finish + 1, quality_rectification_in = if(quality_rectification_in >= 1, quality_rectification_in - 1, 0) where bidsection_id = ?", auditor.BidsectionId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ err = session.Commit()
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+// 审批流程-退回
|
|
|
+func (d *ApproverDao) BackHandlerWithId(auditType string, id int, uid int, times int, progress int, opinion string) error {
|
|
|
+ session := d.engine.NewSession()
|
|
|
+ defer session.Close()
|
|
|
+ err := session.Begin()
|
|
|
+
|
|
|
+ auditor := &models.CmApprover{}
|
|
|
+ _, err = session.ID(id).Get(auditor)
|
|
|
+ data := &models.CmApprover{Status: 0}
|
|
|
+ // 将往后的所有记录的status改为0
|
|
|
+ _, err = session.Where("bidsection_id = ? and data_type = ? and data_id = ? and audit_order > ?", auditor.BidsectionId, auditor.DataType, auditor.DataId, auditor.AuditOrder).Cols("status").Update(data)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 获取改账号的信息
|
|
|
+ account := &models.CmProjectAccount{Id: auditor.AuditId}
|
|
|
+ _, err = session.Get(account)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 将当前的记录改为1-待审批
|
|
|
+ data.Status = 1
|
|
|
+ _, err = session.ID(id).Cols("status").Update(data)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ // 消息推送,先删除旧的推送
|
|
|
+ _, err = session.Exec("delete from cm_project_message where data_type = ? and data_id = ?", auditor.DataType, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ approvers := make([]models.CmApprover, 0)
|
|
|
+ err = session.Where("data_type = ? and data_id = ? and audit_id != 0", auditor.DataType, auditor.DataId).Find(&approvers)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ // 增加审批日志
|
|
|
+ if auditType == "safe" {
|
|
|
+ safe := &models.CmSafe{}
|
|
|
+ _, err = session.ID(auditor.DataId).Get(safe)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ account := &models.CmProjectAccount{Id: safe.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title := fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+
|
|
|
+ for _, item := range approvers {
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item.AuditId
|
|
|
+ msgVM.BidsectionId = item.BidsectionId
|
|
|
+ msgVM.ProjectId = item.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = item.DataId
|
|
|
+ msgVM.DataType = item.DataType
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|审批退回,退回至%s", safe.Code, safe.InspectionDetail, account.Name)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加巡检拥有者的推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = safe.Uid
|
|
|
+ msgVM.BidsectionId = safe.BidsectionId
|
|
|
+ msgVM.ProjectId = safe.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = safe.Id
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|审批退回,退回至%s", safe.Code, safe.InspectionDetail, account.Name)
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+
|
|
|
+ // 插入消息
|
|
|
+ _, err = session.Insert(msg)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ safeAudit := &models.CmSafeAudit{BidsectionId: auditor.BidsectionId, SafeId: auditor.DataId, Times: times, AuditId: uid, Status: 1, Progress: progress, CreateTime: time.Now(), Opinion: opinion}
|
|
|
+ _, err = session.Insert(safeAudit)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ quality := &models.CmQuality{}
|
|
|
+ _, err = session.ID(auditor.DataId).Get(quality)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ account := &models.CmProjectAccount{Id: quality.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title := fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+ for _, item := range approvers {
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item.AuditId
|
|
|
+ msgVM.BidsectionId = item.BidsectionId
|
|
|
+ msgVM.ProjectId = item.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = item.DataId
|
|
|
+ msgVM.DataType = item.DataType
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|审批退回,退回至%s", quality.Code, quality.InspectionDetail, account.Name)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加巡检拥有者的推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = quality.Uid
|
|
|
+ msgVM.BidsectionId = quality.BidsectionId
|
|
|
+ msgVM.ProjectId = quality.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = quality.Id
|
|
|
+ msgVM.DataType = 2
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|审批退回,退回至%s", quality.Code, quality.InspectionDetail, account.Name)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+
|
|
|
+ // 插入消息
|
|
|
+ _, err = session.Insert(msg)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ qualityAudit := &models.CmQualityAudit{BidsectionId: auditor.BidsectionId, QualityId: auditor.DataId, Times: times, AuditId: uid, Status: 1, Progress: progress, CreateTime: time.Now(), Opinion: opinion}
|
|
|
+ _, err = session.Insert(qualityAudit)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ }
|
|
|
+ curAuditor := &models.CmApprover{}
|
|
|
+ _, err = session.ID(uid).Get(curAuditor)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 当前审批人是整改或者复查流程的并且退回的是审批流程的
|
|
|
+ if curAuditor.Progress >= 1 && auditor.Progress == 0 {
|
|
|
+ var sql string
|
|
|
+ if auditType == "safe" {
|
|
|
+ sql = "update cm_tree set safe_rectification = safe_rectification_in + 1 and safe_rectification_in = if(safe_rectification_in >= 1, safe_rectification_in - 1, 0) where bidsection_id = ?"
|
|
|
+ } else {
|
|
|
+ sql = "update cm_tree set quality_rectification = quality_rectification_in + 1 and quality_rectification_in = if(quality_rectification_in >= 1, quality_rectification_in - 1, 0) where bidsection_id = ?"
|
|
|
+ }
|
|
|
+ _, err = session.Exec(sql, auditor.BidsectionId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ err = session.Commit()
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (d *ApproverDao) CloseHandler(auditType string, id int, opinion string, curUid int, saveId int) error {
|
|
|
+ session := d.engine.NewSession()
|
|
|
+ defer session.Close()
|
|
|
+ // add Begin() before any action
|
|
|
+ err := session.Begin()
|
|
|
+ auditor, err := d.FindApproverById(id)
|
|
|
+ if auditor.AuditId != curUid {
|
|
|
+ return errors.New("该用户没有审批权限!")
|
|
|
+ }
|
|
|
+
|
|
|
+ // 消息推送,先删除旧的推送
|
|
|
+ _, err = session.Exec("delete from cm_project_message where data_type = ? and data_id = ?", auditor.DataType, auditor.DataId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ approvers := make([]models.CmApprover, 0)
|
|
|
+ err = session.Where("data_type = ? and data_id = ? and audit_id != 0", auditor.DataType, auditor.DataId).Find(&approvers)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ if auditType == "safe" {
|
|
|
+ safe := &models.CmSafe{}
|
|
|
+ _, err = session.ID(saveId).Get(safe)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ account := &models.CmProjectAccount{Id: safe.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title := fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+ for _, item := range approvers {
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item.AuditId
|
|
|
+ msgVM.BidsectionId = item.BidsectionId
|
|
|
+ msgVM.ProjectId = item.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = item.DataId
|
|
|
+ msgVM.DataType = item.DataType
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|已关闭,停止审批流程", safe.Code, safe.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加巡检拥有者的推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = safe.Uid
|
|
|
+ msgVM.BidsectionId = safe.BidsectionId
|
|
|
+ msgVM.ProjectId = safe.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = safe.Id
|
|
|
+ msgVM.DataType = 1
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|已关闭,停止审批流程", safe.Code, safe.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+
|
|
|
+ // 插入消息
|
|
|
+ _, err = session.Insert(msg)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ // 增加审批日志
|
|
|
+ safeAudit := &models.CmSafeAudit{BidsectionId: auditor.BidsectionId, SafeId: auditor.DataId, Times: safe.Times, AuditId: auditor.AuditId, Status: 2, Progress: auditor.Progress, CreateTime: time.Now(), Opinion: opinion}
|
|
|
+ _, err = session.Insert(safeAudit)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 更改cm_safe的记录
|
|
|
+ _, err = session.Exec("update `cm_safe` set status = ? where id = ? ", 5, saveId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ quality := &models.CmQuality{}
|
|
|
+ _, err = session.ID(saveId).Get(quality)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ account := &models.CmProjectAccount{Id: quality.Uid}
|
|
|
+ _, err = d.engine.Get(account)
|
|
|
+ title := fmt.Sprintf("%s - %s", account.Name, account.Position)
|
|
|
+
|
|
|
+ msg := make([]models.CmProjectMessage, 0)
|
|
|
+ for _, item := range approvers {
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = item.AuditId
|
|
|
+ msgVM.BidsectionId = item.BidsectionId
|
|
|
+ msgVM.ProjectId = item.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = item.DataId
|
|
|
+ msgVM.DataType = item.DataType
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|已关闭,停止审批流程", quality.Code, quality.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 添加巡检拥有者的推送
|
|
|
+ msgVM := models.CmProjectMessage{}
|
|
|
+ msgVM.AccountId = quality.Uid
|
|
|
+ msgVM.BidsectionId = quality.BidsectionId
|
|
|
+ msgVM.ProjectId = quality.ProjectId
|
|
|
+ msgVM.CreateTime = time.Now()
|
|
|
+ msgVM.DataId = quality.Id
|
|
|
+ msgVM.DataType = 2
|
|
|
+ msgVM.Content = fmt.Sprintf("%s|%s|已关闭,停止审批流程", quality.Code, quality.InspectionDetail)
|
|
|
+ msgVM.Title = title
|
|
|
+ msg = append(msg, msgVM)
|
|
|
+
|
|
|
+ // 插入消息
|
|
|
+ _, err = session.Insert(msg)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 增加审批日志
|
|
|
+ qualityAudit := &models.CmQualityAudit{BidsectionId: auditor.BidsectionId, QualityId: auditor.DataId, Times: quality.Times, AuditId: auditor.AuditId, Status: 2, Progress: auditor.Progress, CreateTime: time.Now(), Opinion: opinion}
|
|
|
+ _, err = session.Insert(qualityAudit)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ // 更改cm_quality的记录
|
|
|
+ _, err = session.Exec("update `cm_quality` set status = ? where id = ? ", 5, saveId)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 更改cm_approver的记录
|
|
|
+ _, err = session.Exec("update `cm_approver` set status = ? where id = ? ", 3, id)
|
|
|
+ if err != nil {
|
|
|
+ session.Rollback()
|
|
|
+ return err
|
|
|
+ }
|
|
|
+
|
|
|
+ err = session.Commit()
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+// 删除旧的审批流程
|
|
|
+func (d *ApproverDao) DeleteOldAuditors(bid int, dataType int, dataId int) error {
|
|
|
+ data := &models.CmApprover{BidsectionId: bid, DataType: dataType, DataId: dataId}
|
|
|
+ _, err := d.engine.Delete(data)
|
|
|
+ return err
|
|
|
+}
|
|
|
+
|
|
|
+func (d *ApproverDao) GetStatusByProjectAndAccount(projectId int, projectAccountId int, status int) []models.CmApprover {
|
|
|
+ datalist := make([]models.CmApprover, 0)
|
|
|
+ _ = d.engine.
|
|
|
+ Where("project_id = ? and audit_id= ? and status=? ", projectId, projectAccountId, status).
|
|
|
+ Desc("id").
|
|
|
+ Find(&datalist)
|
|
|
+ return datalist
|
|
|
+}
|