|
|
@@ -1,6 +1,23 @@
|
|
|
package biapprove
|
|
|
|
|
|
-import "eta_gn/eta_api/models/bi_dashboard"
|
|
|
+import (
|
|
|
+ "encoding/json"
|
|
|
+ "eta_gn/eta_api/models"
|
|
|
+ biapprove "eta_gn/eta_api/models/bi_approve"
|
|
|
+ "eta_gn/eta_api/models/bi_approve/response"
|
|
|
+ "eta_gn/eta_api/models/bi_dashboard"
|
|
|
+ "eta_gn/eta_api/utils"
|
|
|
+ "fmt"
|
|
|
+ "sort"
|
|
|
+ "strings"
|
|
|
+ "time"
|
|
|
+)
|
|
|
+
|
|
|
+var (
|
|
|
+ timeField = map[int]string{1: fmt.Sprintf("a.%s", biapprove.BiApproveCols.CreateTime), 2: fmt.Sprintf("a.%s", biapprove.BiApproveCols.ApproveTime), 3: fmt.Sprintf("b.%s", biapprove.BiApproveCols.ApproveTime)}
|
|
|
+ myTimeField = map[int]string{1: biapprove.BiApproveCols.CreateTime, 3: biapprove.BiApproveCols.ApproveTime}
|
|
|
+ orderRules = map[int]string{1: "ASC", 2: "DESC"}
|
|
|
+)
|
|
|
|
|
|
func GetPulicBiClassifyList() (res []*bi_dashboard.BiDashboardClassifyItem, msg string, err error) {
|
|
|
classifyList, err := bi_dashboard.GetBiDashboardClassifyAllList()
|
|
|
@@ -12,6 +29,289 @@ func GetPulicBiClassifyList() (res []*bi_dashboard.BiDashboardClassifyItem, msg
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+func PassBiApprove(approveId int, adminId int) (msg string, err error) {
|
|
|
+ approveItem, e := biapprove.GetBiApproveById(approveId)
|
|
|
+ if e != nil {
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
+ msg = "审批不存在, 请刷新页面"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ msg = "操作失败"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if approveItem.State != BiApproveStateApproving {
|
|
|
+ msg = "审批状态有误, 请刷新页面"
|
|
|
+ err = fmt.Errorf("审批状态有误, State: %d", approveItem.State)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ var ApprovePars []interface{}
|
|
|
+ Approveconds := ` AND bi_approve_id =? AND approve_user_id =? AND state =? `
|
|
|
+ ApprovePars = append(ApprovePars, approveId, adminId, BiApproveStateApproving)
|
|
|
+
|
|
|
+ recordItem, er := biapprove.GetBiApproveRecordByCondition(Approveconds, ApprovePars)
|
|
|
+ if er != nil {
|
|
|
+ if utils.IsErrNoRow(er) {
|
|
|
+ msg = "无权审批"
|
|
|
+ err = er
|
|
|
+ return
|
|
|
+ }
|
|
|
+ msg = "操作失败"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 查询审批流和审批流节点
|
|
|
+ flowItem, e := biapprove.GetBiApproveFlowById(approveItem.FlowId)
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("获取审批流失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ nodePars := make([]interface{}, 0)
|
|
|
+ nodeCond := ` AND bi_approve_flow_id =? AND curr_version =? `
|
|
|
+ nodePars = append(nodePars, flowItem.BiApproveFlowId, flowItem.CurrVersion)
|
|
|
+ nodeItems, e := biapprove.GetBiApproveNodeByCondition(nodeCond, nodePars)
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("ApproveNodes GetItemsByCondition err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(nodeItems) == 0 {
|
|
|
+ err = fmt.Errorf("无审批节点")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ nodeMap := make(map[int]*biapprove.BiApproveNode)
|
|
|
+ for _, v := range nodeItems {
|
|
|
+ nodeMap[v.BiApproveNodeId] = v
|
|
|
+ }
|
|
|
+
|
|
|
+ // 取出审批记录的节点
|
|
|
+ currNodeItem := nodeMap[recordItem.NodeId]
|
|
|
+ if currNodeItem == nil {
|
|
|
+ err = fmt.Errorf("当前节点信息有误")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ currNode, e := FormatBiApproveNode2Item(currNodeItem)
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("当前节点信息有误, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ now := time.Now().Local()
|
|
|
+ recordItem.State = BiApproveStatePass
|
|
|
+ recordItem.ApproveTime = now
|
|
|
+ recordItem.ModifyTime = now
|
|
|
+ recordItem.NodeState = BiApproveStatePass
|
|
|
+ recordItem.NodeApproveUserId = recordItem.ApproveUserId
|
|
|
+ recordItem.NodeApproveUserName = recordItem.ApproveUserName
|
|
|
+ recordItem.NodeApproveTime = now
|
|
|
+
|
|
|
+ recordCols := []string{"State", "ApproveTime", "ModifyTime", "NodeState", "NodeApproveUserId", "NodeApproveUserName", "NodeApproveTime"}
|
|
|
+ lastApprove := false
|
|
|
+
|
|
|
+ // 依次审批
|
|
|
+ if currNode.ApproveType == NodeApproveTypeRoll {
|
|
|
+ if e = recordItem.Update(recordCols); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批记录状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 检查依次审批情况
|
|
|
+ sort.Slice(currNode.Users, func(k, j int) bool {
|
|
|
+ return currNode.Users[k].Sort < currNode.Users[j].Sort
|
|
|
+ })
|
|
|
+ userLen := len(currNode.Users)
|
|
|
+ //lastRoll := false
|
|
|
+ nextUser := new(response.BiApproveNodeUser) // 下一个审批人, 为nil则表示当前审批人即为最后
|
|
|
+ for k, v := range currNode.Users {
|
|
|
+ // 当前审批人
|
|
|
+ if v.UserId == adminId && recordItem.ApproveUserSort == v.Sort {
|
|
|
+ //if k == (userLen - 1) {
|
|
|
+ // lastRoll = true
|
|
|
+ // break
|
|
|
+ //}
|
|
|
+ if (k + 1) < userLen {
|
|
|
+ nextUser = currNode.Users[k+1]
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //if lastRoll && currNode.NextNodeId == 0 {
|
|
|
+ // lastApprove = true
|
|
|
+ //}
|
|
|
+
|
|
|
+ // 当前节点下一个审批人, 生成下一个审批记录且return
|
|
|
+ if nextUser.UserId > 0 {
|
|
|
+ newRecord := new(biapprove.BiApproveRecord)
|
|
|
+ newRecord.BiApproveId = recordItem.BiApproveId
|
|
|
+ newRecord.State = BiApproveStateApproving
|
|
|
+ newRecord.NodeId = currNode.BiApproveNodeId
|
|
|
+ newRecord.PrevNodeId = currNode.PrevNodeId
|
|
|
+ newRecord.NextNodeId = currNode.NextNodeId
|
|
|
+ newRecord.ApproveType = currNode.ApproveType
|
|
|
+ newRecord.ApproveUserId = nextUser.UserId
|
|
|
+ newRecord.ApproveUserName = nextUser.UserName
|
|
|
+ newRecord.ApproveUserSort = nextUser.Sort
|
|
|
+ newRecord.CreateTime = now
|
|
|
+ newRecord.ModifyTime = now
|
|
|
+ newRecord.NodeState = BiApproveStateApproving
|
|
|
+ if e = newRecord.Create(); e != nil {
|
|
|
+ err = fmt.Errorf("生成审批记录失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 推送审批消息
|
|
|
+ go func() {
|
|
|
+ messageItem := new(biapprove.BiApproveMessage)
|
|
|
+ messageItem.SendUserId = approveItem.ApplyUserId
|
|
|
+ messageItem.ReceiveUserId = nextUser.UserId
|
|
|
+ messageItem.Content = "您有新的待办任务"
|
|
|
+ messageItem.Remark = fmt.Sprintf("%s提交的【%s】需要您审批，请及时处理", approveItem.ApplyUserName, approveItem.BiTitle)
|
|
|
+ messageItem.BiApproveId = approveItem.BiApproveId
|
|
|
+ messageItem.ApproveState = BiApproveStateApproving
|
|
|
+ messageItem.CreateTime = now
|
|
|
+ messageItem.ModifyTime = now
|
|
|
+ if e = messageItem.Create(); e != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf("PassBiApprove message err: %s", e.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 更新审批当前节点并进入下一个节点
|
|
|
+ if currNode.NextNodeId > 0 {
|
|
|
+ nextNode := nodeMap[currNode.NextNodeId]
|
|
|
+ approveItem.CurrNodeId = currNode.NextNodeId
|
|
|
+ approveItem.ModifyTime = now
|
|
|
+ if e = approveItem.Update([]string{"CurrNodeId", "ModifyTime"}); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批当前节点失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ err = BuildNextNodeRecordAndMsg(nextNode, approveItem.BiApproveId, approveItem.ApplyUserId, approveItem.ApplyUserName)
|
|
|
+ return
|
|
|
+ } else {
|
|
|
+ // 最后一个节点
|
|
|
+ lastApprove = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 会签
|
|
|
+ if currNode.ApproveType == NodeApproveTypeAll {
|
|
|
+ // 查询其他审批人是否已审批
|
|
|
+ otherCond := ` AND bi_approve_id =? AND node_id =? AND approve_user_id <> ? `
|
|
|
+ otherPars := make([]interface{}, 0)
|
|
|
+ otherPars = append(otherPars, approveItem.BiApproveId, recordItem.NodeId, adminId)
|
|
|
+ otherRecords, e := biapprove.GetBiApproveRecordItemsByCondition(otherCond, otherPars)
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("获取节点审批记录失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ otherPass := true
|
|
|
+ for _, v := range otherRecords {
|
|
|
+ if v.State != BiApproveStatePass {
|
|
|
+ otherPass = false
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 其他人未审批, 仅更新当前审批记录
|
|
|
+ if e = recordItem.Update(recordCols); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批记录状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 其他人已审批且为最后节点
|
|
|
+ if otherPass && currNode.NextNodeId == 0 {
|
|
|
+ lastApprove = true
|
|
|
+ }
|
|
|
+
|
|
|
+ // 其他人已审批且不为最后节点, 进入下一节点
|
|
|
+ if otherPass && currNode.NextNodeId > 0 {
|
|
|
+ nextNode := nodeMap[currNode.NextNodeId]
|
|
|
+ approveItem.CurrNodeId = currNode.NextNodeId
|
|
|
+ approveItem.ModifyTime = now
|
|
|
+ if e = approveItem.Update([]string{"CurrNodeId", "ModifyTime"}); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批当前节点失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ err = BuildNextNodeRecordAndMsg(nextNode, approveItem.BiApproveId, approveItem.ApplyUserId, approveItem.ApplyUserName)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 或签
|
|
|
+ if currNode.ApproveType == NodeApproveTypeAny {
|
|
|
+ // 需检查一下审批的当前节点和记录的节点是否匹配, 不匹配可能是因为另外的审批人已通过, 所以此处应给提示
|
|
|
+ // 前端也有做相应的判断，但是两个人同时进入审批详情页时就可能出现这种情况
|
|
|
+ if approveItem.CurrNodeId != recordItem.NodeId {
|
|
|
+ msg = "该节点已完成审批, 请刷新页面"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if e = recordItem.Update(recordCols); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批记录状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 将该审批的同一个节点的记录标记为已审批
|
|
|
+ if e = recordItem.UpdateNodeState(recordItem.BiApproveId, recordItem.NodeId, recordItem.NodeState, recordItem.NodeApproveUserId, recordItem.NodeApproveUserName, recordItem.NodeApproveTime); e != nil {
|
|
|
+ err = fmt.Errorf("更新同一节点的其他审批记录状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if currNode.NextNodeId == 0 {
|
|
|
+ lastApprove = true
|
|
|
+ }
|
|
|
+ if currNode.NextNodeId > 0 {
|
|
|
+ nextNode := nodeMap[currNode.NextNodeId]
|
|
|
+ approveItem.CurrNodeId = currNode.NextNodeId
|
|
|
+ approveItem.ModifyTime = now
|
|
|
+ if e = approveItem.Update([]string{"CurrNodeId", "ModifyTime"}); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批当前节点失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ err = BuildNextNodeRecordAndMsg(nextNode, approveItem.BiApproveId, approveItem.ApplyUserId, approveItem.ApplyUserName)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 最后一个审批, 更新审批记录、审批、报告状态、推送消息给申请人
|
|
|
+ if lastApprove {
|
|
|
+ if e = recordItem.Update(recordCols); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批记录状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ approveItem.State = BiApproveStatePass
|
|
|
+ approveItem.ApproveTime = now
|
|
|
+ approveItem.ModifyTime = now
|
|
|
+ approveCols := []string{"State", "ApproveTime", "ModifyTime"}
|
|
|
+ if e = approveItem.Update(approveCols); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批信息失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if e = updateBiApproveState(approveItem.BiId, approveItem.BiApproveId, BiStatePass); e != nil {
|
|
|
+ err = fmt.Errorf("更新报告审批状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ go func() {
|
|
|
+ messageItem := new(biapprove.BiApproveMessage)
|
|
|
+ messageItem.SendUserId = adminId
|
|
|
+ messageItem.ReceiveUserId = approveItem.ApplyUserId
|
|
|
+ messageItem.Content = "您提交的审批已通过"
|
|
|
+ messageItem.Remark = fmt.Sprintf("您提交的【%s】已通过", approveItem.BiTitle)
|
|
|
+ messageItem.BiApproveId = approveItem.BiApproveId
|
|
|
+ messageItem.ApproveState = BiApproveStatePass
|
|
|
+ messageItem.CreateTime = now
|
|
|
+ messageItem.ModifyTime = now
|
|
|
+ if e = messageItem.Create(); e != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf("PassBiApprove message err: %s", e.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ }
|
|
|
+ return
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
func toClassifyItem(src []*bi_dashboard.BiDashboardClassify) (dst []*bi_dashboard.BiDashboardClassifyItem) {
|
|
|
for _, item := range src {
|
|
|
dst = append(dst, &bi_dashboard.BiDashboardClassifyItem{
|
|
|
@@ -21,3 +321,861 @@ func toClassifyItem(src []*bi_dashboard.BiDashboardClassify) (dst []*bi_dashboar
|
|
|
}
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+// BuildNextNodeRecordAndMsg 生成下一个节点的审批记录并推送消息
|
|
|
+func BuildNextNodeRecordAndMsg(approveNodeItem *biapprove.BiApproveNode, approveId, sysAdminId int, sysAdminName string) (err error) {
|
|
|
+ if approveNodeItem == nil {
|
|
|
+ err = fmt.Errorf("approve node nil")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 根据节点审批方式生成审批记录
|
|
|
+ now := time.Now().Local()
|
|
|
+ approveNode, e := FormatBiApproveNode2Item(approveNodeItem)
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("FormatBiApproveNode2Item err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(approveNode.Users) == 0 {
|
|
|
+ err = fmt.Errorf("审批节点用户有误")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ newRecords := make([]*biapprove.BiApproveRecord, 0)
|
|
|
+ sort.Slice(approveNode.Users, func(k, j int) bool {
|
|
|
+ return approveNode.Users[k].Sort < approveNode.Users[j].Sort
|
|
|
+ })
|
|
|
+ for _, u := range approveNode.Users {
|
|
|
+ r := new(biapprove.BiApproveRecord)
|
|
|
+ r.BiApproveId = approveId
|
|
|
+ r.State = BiApproveStateApproving
|
|
|
+ r.NodeId = approveNode.BiApproveNodeId
|
|
|
+ r.PrevNodeId = approveNode.PrevNodeId
|
|
|
+ r.NextNodeId = approveNode.NextNodeId
|
|
|
+ r.ApproveType = approveNode.ApproveType
|
|
|
+ r.ApproveUserId = u.UserId
|
|
|
+ r.ApproveUserName = u.UserName
|
|
|
+ r.ApproveUserSort = u.Sort
|
|
|
+ r.CreateTime = now
|
|
|
+ r.ModifyTime = now
|
|
|
+ r.NodeState = BiApproveStateApproving // 当前节点审批状态
|
|
|
+ newRecords = append(newRecords, r)
|
|
|
+ // 依次审批仅生成一条记录
|
|
|
+ if approveNode.ApproveType == NodeApproveTypeRoll {
|
|
|
+ break
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ recordOb := new(biapprove.BiApproveRecord)
|
|
|
+ if e = recordOb.CreateMulti(newRecords); e != nil {
|
|
|
+ err = fmt.Errorf("生成节点审批记录失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 推送审批消息
|
|
|
+ go func() {
|
|
|
+ messageOb := new(biapprove.BiApproveMessage)
|
|
|
+ messages := make([]*biapprove.BiApproveMessage, 0)
|
|
|
+ for _, v := range newRecords {
|
|
|
+ m := new(biapprove.BiApproveMessage)
|
|
|
+ m.SendUserId = sysAdminId
|
|
|
+ m.ReceiveUserId = v.ApproveUserId
|
|
|
+ m.Content = "您有新的待办任务"
|
|
|
+ m.Remark = fmt.Sprintf("%s提交的【看板审批】需要您审批，请及时处理", sysAdminName)
|
|
|
+ m.BiApproveId = approveId
|
|
|
+ m.ApproveState = BiApproveStateApproving
|
|
|
+ m.CreateTime = now
|
|
|
+ m.ModifyTime = now
|
|
|
+ messages = append(messages, m)
|
|
|
+ }
|
|
|
+ e = messageOb.CreateMulti(messages)
|
|
|
+ if e != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf("BuildNextNodeRecordAndMsg messages err: %s", e.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// updateBiApproveState 更新Bi看板审批状态
|
|
|
+func updateBiApproveState(biId, approveId, state int) (err error) {
|
|
|
+ // updateCols := []string{"ApproveId", "State", "ModifyTime"}
|
|
|
+ updateCols := []string{"State", "ModifyTime"}
|
|
|
+ BiItem, e := bi_dashboard.GetDashboardById(biId)
|
|
|
+ if e != nil && !utils.IsErrNoRow(e) {
|
|
|
+ err = fmt.Errorf("获取智能看板失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if BiItem != nil && BiItem.BiDashboardId > 0 {
|
|
|
+ // BiItem.ApproveId = approveId
|
|
|
+ BiItem.State = state
|
|
|
+ BiItem.ModifyTime = time.Now().Local()
|
|
|
+
|
|
|
+ // if state == models.BiStatePass || state == models.BiStateRefused {
|
|
|
+ // updateCols = append(updateCols, "ApproveTime")
|
|
|
+ // // BiItem.ApproveTime = time.Now().Local()
|
|
|
+ // }
|
|
|
+ // if state == models.BiStatePass {
|
|
|
+ // updateCols = append(updateCols, "PublishTime")
|
|
|
+ // // BiItem.PublishTime = time.Now().Local()
|
|
|
+ // }
|
|
|
+ if e = BiItem.Update(updateCols); e != nil {
|
|
|
+ err = fmt.Errorf("更新Bi看板审批状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func ProcessingBiApprove(adminId, classifyId, timeType, sortField, sortRule, startSize, pageSize int, adminName, startTime, endTime, keyword string) (respList []*response.BiApproveItemOrmResp, respTotal int, msg string, err error) {
|
|
|
+ cond := fmt.Sprintf(` AND a.%s = ? AND b.%s = ? AND a.%s = ?`, biapprove.BiApproveRecordCols.State, biapprove.BiApproveCols.State, biapprove.BiApproveRecordCols.ApproveUserId)
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, BiApproveStateApproving, BiApproveStateApproving, adminId)
|
|
|
+ order := ""
|
|
|
+
|
|
|
+ // 筛选条件
|
|
|
+ if classifyId > 0 {
|
|
|
+ cond += fmt.Sprintf(` AND b.%s = ?`, biapprove.BiApproveCols.ClassifyId)
|
|
|
+ pars = append(pars, classifyId)
|
|
|
+ }
|
|
|
+ if timeType <= 0 {
|
|
|
+ timeType = 1
|
|
|
+ }
|
|
|
+ if timeType == 1 && startTime != "" && endTime != "" {
|
|
|
+ _, e := time.Parse(utils.FormatDate, startTime)
|
|
|
+ if e != nil {
|
|
|
+ msg = "开始时间格式有误"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tmpEndTime, e := time.Parse(utils.FormatDate, endTime)
|
|
|
+ if e != nil {
|
|
|
+ msg = "结束时间格式有误"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tmpEndTime = tmpEndTime.AddDate(0, 0, 1)
|
|
|
+ cond += fmt.Sprintf(` AND (b.%s BETWEEN ? AND ?)`, biapprove.BiApproveCols.CreateTime)
|
|
|
+ pars = append(pars, startTime, tmpEndTime)
|
|
|
+ }
|
|
|
+ keyword = strings.TrimSpace(keyword)
|
|
|
+ if keyword != "" {
|
|
|
+ kw := fmt.Sprint("%", keyword, "%")
|
|
|
+ cond += fmt.Sprintf(` AND b.%s LIKE ?`, biapprove.BiApproveCols.BiTitle)
|
|
|
+ pars = append(pars, kw)
|
|
|
+ }
|
|
|
+ if sortField > 0 && sortRule > 0 {
|
|
|
+ orderField := timeField[sortField]
|
|
|
+ if orderField == "" {
|
|
|
+ msg = "时间排序字段有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ orderRule := orderRules[sortRule]
|
|
|
+ if orderRule == "" {
|
|
|
+ msg = "时间排序方式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ order = fmt.Sprintf("%s %s", orderField, orderRule)
|
|
|
+ }
|
|
|
+ total, e := biapprove.GetApprovingBiApproveCount(cond, pars)
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetApprovingBiApproveCount err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ list, e := biapprove.GetApprovingBiApprovePageList(cond, pars, order, startSize, pageSize)
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetApprovingBiApprovePageList err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ respList = toBiApproveItemOrmResp(list)
|
|
|
+ respTotal = total
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// SolvedBiApprove 已处理的审批
|
|
|
+func SolvedBiApprove(adminId, classifyId, timeType, sortField, sortRule, approveState, startSize, pageSize int, adminName, startTime, endTime, keyword string) (respList []*response.BiApproveItemOrmResp, respTotal int, msg string, err error) {
|
|
|
+ cond := fmt.Sprintf(` AND a.%s = ? AND a.%s IN (?)`, biapprove.BiApproveRecordCols.ApproveUserId, biapprove.BiApproveRecordCols.NodeState)
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, adminId, []int{BiApproveStatePass, BiApproveStateRefuse})
|
|
|
+ order := ""
|
|
|
+
|
|
|
+ // 筛选条件
|
|
|
+ if classifyId > 0 {
|
|
|
+ cond += fmt.Sprintf(` AND b.%s = ?`, biapprove.BiApproveCols.ClassifyId)
|
|
|
+ pars = append(pars, classifyId)
|
|
|
+ }
|
|
|
+ if timeType > 0 && startTime != "" && endTime != "" {
|
|
|
+ _, e := time.Parse(utils.FormatDate, startTime)
|
|
|
+ if e != nil {
|
|
|
+ msg = "开始时间格式有误"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tmpEndTime, e := time.Parse(utils.FormatDate, endTime)
|
|
|
+ if e != nil {
|
|
|
+ msg = "结束时间格式有误"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tmpEndTime = tmpEndTime.AddDate(0, 0, 1)
|
|
|
+ cond += fmt.Sprintf(` AND (%s BETWEEN ? AND ?)`, timeField[timeType])
|
|
|
+ pars = append(pars, startTime, tmpEndTime)
|
|
|
+ }
|
|
|
+ keyword = strings.TrimSpace(keyword)
|
|
|
+ if keyword != "" {
|
|
|
+ kw := fmt.Sprint("%", keyword, "%")
|
|
|
+ cond += fmt.Sprintf(` AND b.%s LIKE ?`, biapprove.BiApproveCols.BiTitle)
|
|
|
+ pars = append(pars, kw)
|
|
|
+ }
|
|
|
+ if sortField > 0 && sortRule > 0 {
|
|
|
+ orderField := timeField[sortField]
|
|
|
+ if orderField == "" {
|
|
|
+ msg = "时间排序字段有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ orderRule := orderRules[sortRule]
|
|
|
+ if orderRule == "" {
|
|
|
+ msg = "时间排序方式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ order = fmt.Sprintf("%s %s", orderField, orderRule)
|
|
|
+ }
|
|
|
+ if approveState > 0 {
|
|
|
+ cond += fmt.Sprintf(` AND a.%s = ?`, biapprove.BiApproveRecordCols.State)
|
|
|
+ pars = append(pars, approveState)
|
|
|
+ }
|
|
|
+ total, e := biapprove.GetApprovedBiApproveCount(cond, pars)
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetApprovedBiApproveCount err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ list, e := biapprove.GetApprovedBiApprovePageList(cond, pars, order, startSize, pageSize)
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetApprovedBiApprovePageList err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range list {
|
|
|
+ // 这个时候的状态，用审批状态
|
|
|
+ v.RecordState = v.NodeState
|
|
|
+ v.ApproveTime = v.NodeApproveTime
|
|
|
+ }
|
|
|
+ respList = toBiApproveItemOrmResp(list)
|
|
|
+ respTotal = total
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func MyApplyBiApproves(adminId, classifyId, timeType, sortField, sortRule, approveState, startSize, pageSize int, adminName, startTime, endTime, keyword string) (respList []*response.BiApproveItemOrmResp, respTotal int, msg string, err error) {
|
|
|
+ cond := fmt.Sprintf(` AND a.%s = ?`, biapprove.BiApproveCols.ApplyUserId)
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, adminId)
|
|
|
+ order := ""
|
|
|
+
|
|
|
+ // 筛选条件
|
|
|
+ if classifyId > 0 {
|
|
|
+ cond += fmt.Sprintf(` AND a.%s = ?`, biapprove.BiApproveCols.ClassifyId)
|
|
|
+ pars = append(pars, classifyId)
|
|
|
+ }
|
|
|
+ if timeType > 0 && startTime != "" && endTime != "" {
|
|
|
+ _, e := time.Parse(utils.FormatDate, startTime)
|
|
|
+ if e != nil {
|
|
|
+ msg = "开始时间格式有误"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tmpEndTime, e := time.Parse(utils.FormatDate, endTime)
|
|
|
+ if e != nil {
|
|
|
+ msg = "结束时间格式有误"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ tmpEndTime = tmpEndTime.AddDate(0, 0, 1)
|
|
|
+ cond += fmt.Sprintf(` AND (%s BETWEEN ? AND ?)`, timeField[timeType])
|
|
|
+ pars = append(pars, startTime, tmpEndTime)
|
|
|
+ }
|
|
|
+ keyword = strings.TrimSpace(keyword)
|
|
|
+ if keyword != "" {
|
|
|
+ kw := fmt.Sprint("%", keyword, "%")
|
|
|
+ cond += fmt.Sprintf(` AND a.%s LIKE ?`, biapprove.BiApproveCols.BiTitle)
|
|
|
+ pars = append(pars, kw)
|
|
|
+ }
|
|
|
+ if sortField > 0 && sortRule > 0 {
|
|
|
+ orderField := myTimeField[sortField]
|
|
|
+ if orderField == "" {
|
|
|
+ msg = "时间排序字段有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ orderRule := orderRules[sortRule]
|
|
|
+ if orderRule == "" {
|
|
|
+ msg = "时间排序方式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ order = fmt.Sprintf("%s %s", orderField, orderRule)
|
|
|
+ }
|
|
|
+ if approveState > 0 {
|
|
|
+ cond += fmt.Sprintf(` AND a.%s = ?`, biapprove.BiApproveRecordCols.State)
|
|
|
+ pars = append(pars, approveState)
|
|
|
+ }
|
|
|
+ total, e := biapprove.GetApplyBiApproveCount(cond, pars)
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetApplyBiApproveCount err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ respTotal = total
|
|
|
+ list, e := biapprove.GetApplyBiApprovePageList(cond, pars, order, startSize, pageSize)
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetApplyBiApprovePageList err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ respList = toBiApproveItemOrmResp(list)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func GetApproveDetail(approveId int) (resp *response.BiApproveDetail, msg string, err error) {
|
|
|
+ approveItem, e := biapprove.GetBiApproveById(approveId)
|
|
|
+ if e != nil {
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
+ msg = "审批已被删除, 请刷新页面"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetItemById err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 审批信息
|
|
|
+ detail := new(response.BiApproveDetail)
|
|
|
+ detail.Approve = new(response.BiApproveDetailItem)
|
|
|
+ detail.Approve.BiApproveId = approveItem.BiApproveId
|
|
|
+ detail.Approve.State = approveItem.State
|
|
|
+ detail.Approve.FlowId = approveItem.FlowId
|
|
|
+ detail.Approve.FlowVersion = approveItem.FlowVersion
|
|
|
+ detail.Approve.StartNodeId = approveItem.StartNodeId
|
|
|
+ detail.Approve.CurrNodeId = approveItem.CurrNodeId
|
|
|
+ detail.Approve.ApplyUserId = approveItem.ApplyUserId
|
|
|
+ detail.Approve.ApplyUserName = approveItem.ApplyUserName
|
|
|
+ detail.Approve.ApproveTime = utils.TimeTransferString(utils.FormatDateTime, approveItem.ApproveTime)
|
|
|
+ detail.Approve.CreateTime = utils.TimeTransferString(utils.FormatDateTime, approveItem.CreateTime)
|
|
|
+ detail.Approve.ModifyTime = utils.TimeTransferString(utils.FormatDateTime, approveItem.ModifyTime)
|
|
|
+
|
|
|
+ // 审批节点
|
|
|
+ nodeOb := new(biapprove.BiApproveNode)
|
|
|
+ nodeCond := fmt.Sprintf(` AND %s = ? AND %s = ?`, biapprove.BiApproveNodeCols.BiApproveFlowId, biapprove.BiApproveNodeCols.CurrVersion)
|
|
|
+ nodePars := make([]interface{}, 0)
|
|
|
+ nodePars = append(nodePars, approveItem.FlowId, approveItem.FlowVersion)
|
|
|
+ nodeItems, e := nodeOb.GetItemsByCondition(nodeCond, nodePars, []string{}, "")
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetItemsByCondition err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 审批记录
|
|
|
+ recordOb := new(biapprove.BiApproveRecord)
|
|
|
+ recordCond := fmt.Sprintf(` AND %s = ?`, biapprove.BiApproveRecordCols.BiApproveId)
|
|
|
+ recordPars := make([]interface{}, 0)
|
|
|
+ recordPars = append(recordPars, approveItem.BiApproveId)
|
|
|
+ recordItems, e := recordOb.GetItemsByCondition(recordCond, recordPars, []string{}, fmt.Sprintf("%s DESC", biapprove.BiApproveRecordCols.ApproveTime))
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetItemsByCondition err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ recordMap := make(map[string]*biapprove.BiApproveRecord)
|
|
|
+ for _, v := range recordItems {
|
|
|
+ k := fmt.Sprintf("%d-%d", v.NodeId, v.ApproveUserId)
|
|
|
+ recordMap[k] = v
|
|
|
+ }
|
|
|
+
|
|
|
+ // 审批流节点详情
|
|
|
+ detail.ApproveFlowNodes = make([]*response.BiApproveDetailNodes, 0)
|
|
|
+ for _, v := range nodeItems {
|
|
|
+ t := new(response.BiApproveDetailNodes)
|
|
|
+ t.BiApproveNodeId = v.BiApproveNodeId
|
|
|
+ t.BiApproveFlowId = v.BiApproveFlowId
|
|
|
+ t.PrevNodeId = v.PrevNodeId
|
|
|
+ t.NextNodeId = v.NextNodeId
|
|
|
+ t.NodeType = v.NodeType
|
|
|
+ t.ApproveType = v.ApproveType
|
|
|
+ t.Users = make([]*response.BiApproveDetailNodeUser, 0)
|
|
|
+ us := make([]*response.BiApproveNodeUserReq, 0)
|
|
|
+ if v.Users != "" {
|
|
|
+ e = json.Unmarshal([]byte(v.Users), &us)
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("json.Unmarshal err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ for _, vu := range us {
|
|
|
+ u := new(response.BiApproveDetailNodeUser)
|
|
|
+ u.UserType = vu.UserType
|
|
|
+ u.UserId = vu.UserId
|
|
|
+ u.UserName = vu.UserName
|
|
|
+ u.Sort = vu.Sort
|
|
|
+ // 审批记录
|
|
|
+ k := fmt.Sprintf("%d-%d", v.BiApproveNodeId, vu.UserId)
|
|
|
+ r := recordMap[k]
|
|
|
+ if r != nil {
|
|
|
+ u.ApproveRecord = new(response.BiApproveDetailNodeUserRecord)
|
|
|
+ u.ApproveRecord.BiApproveRecordId = r.BiApproveRecordId
|
|
|
+ u.ApproveRecord.State = r.State
|
|
|
+ u.ApproveRecord.ApproveUserId = r.ApproveUserId
|
|
|
+ u.ApproveRecord.ApproveUserName = r.ApproveUserName
|
|
|
+ u.ApproveRecord.ApproveRemark = r.ApproveRemark
|
|
|
+ u.ApproveRecord.ApproveTime = utils.TimeTransferString(utils.FormatDateTime, r.ApproveTime)
|
|
|
+ }
|
|
|
+ t.Users = append(t.Users, u)
|
|
|
+ }
|
|
|
+ sort.Slice(t.Users, func(k, j int) bool {
|
|
|
+ return t.Users[k].Sort < t.Users[j].Sort
|
|
|
+ })
|
|
|
+ detail.ApproveFlowNodes = append(detail.ApproveFlowNodes, t)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 看板信息
|
|
|
+ cnClassifyIdName := make(map[int]string)
|
|
|
+ cnClassify, e := bi_dashboard.GetBiDashboardClassifyAllList()
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetBiDashboardClassifyAllList err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range cnClassify {
|
|
|
+ cnClassifyIdName[v.BiDashboardClassifyId] = v.BiDashboardClassifyName
|
|
|
+ }
|
|
|
+ detail.Bi = new(response.BiApproveDetailBi)
|
|
|
+ detail.Bi.BiId = approveItem.BiId
|
|
|
+ detail.Bi.BiTitle = approveItem.BiTitle
|
|
|
+ detail.Bi.BiClassify = cnClassifyIdName[approveItem.ClassifyId]
|
|
|
+ resp = detail
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func BiApproveRefuse(biApproveId, adminId int, approveRemark string) (msg string, err error) {
|
|
|
+ approveItem, e := biapprove.GetBiApproveById(biApproveId)
|
|
|
+ if e != nil {
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
+ msg = "审批不存在, 请刷新页面"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ msg = "操作失败"
|
|
|
+ err = fmt.Errorf("GetBiApproveById err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if approveItem.State != BiApproveStateApproving {
|
|
|
+ msg = "审批状态有误, 请刷新页面"
|
|
|
+ err = fmt.Errorf("审批状态有误, State: %d", approveItem.State)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 校验审批记录和审批
|
|
|
+ recordOb := new(biapprove.BiApproveRecord)
|
|
|
+ recordCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s = ?`, biapprove.BiApproveRecordCols.BiApproveId, biapprove.BiApproveRecordCols.ApproveUserId, biapprove.BiApproveRecordCols.State)
|
|
|
+ recordPars := make([]interface{}, 0)
|
|
|
+ recordPars = append(recordPars, approveItem.BiApproveId, adminId, BiApproveStateApproving)
|
|
|
+ recordItem, e := recordOb.GetItemByCondition(recordCond, recordPars, "")
|
|
|
+ if e != nil {
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
+ msg = "无权审批"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ msg = "操作失败"
|
|
|
+ err = fmt.Errorf("GetItemByCondition err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 驳回审批
|
|
|
+ if e = RefuseBiApprove(approveItem, recordItem, approveRemark, adminId); e != nil {
|
|
|
+ msg = "操作失败"
|
|
|
+ err = fmt.Errorf("RefuseBiApprove err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// RefuseBiApprove 驳回审批
|
|
|
+func RefuseBiApprove(approveItem *biapprove.BiApprove, recordItem *biapprove.BiApproveRecord, approveRemark string, sysAdminId int) (err error) {
|
|
|
+ if approveItem == nil {
|
|
|
+ err = fmt.Errorf("审批信息有误")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if recordItem == nil {
|
|
|
+ err = fmt.Errorf("审批记录有误")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 更新审批记录
|
|
|
+ now := time.Now().Local()
|
|
|
+ recordItem.State = BiApproveStateRefuse
|
|
|
+ recordItem.ApproveRemark = approveRemark
|
|
|
+ recordItem.ApproveTime = now
|
|
|
+ recordItem.ModifyTime = now
|
|
|
+
|
|
|
+ recordItem.NodeState = BiApproveStateRefuse
|
|
|
+ recordItem.NodeApproveUserId = recordItem.ApproveUserId
|
|
|
+ recordItem.NodeApproveUserName = recordItem.ApproveUserName
|
|
|
+ recordItem.NodeApproveTime = now
|
|
|
+
|
|
|
+ recordCols := []string{"State", "ApproveRemark", "ApproveTime", "ModifyTime", "NodeState", "NodeApproveUserId", "NodeApproveUserName", "NodeApproveTime"}
|
|
|
+ if e := recordItem.Update(recordCols); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批记录状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 将该审批的同一个节点的记录标记为已审批
|
|
|
+ if e := recordItem.UpdateNodeState(recordItem.BiApproveId, recordItem.NodeId, recordItem.NodeState, recordItem.NodeApproveUserId, recordItem.NodeApproveUserName, recordItem.NodeApproveTime); e != nil {
|
|
|
+ err = fmt.Errorf("更新同一节点的其他审批记录状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 驳回-更新审批, 报告状态, 推送消息
|
|
|
+ approveItem.State = BiApproveStateRefuse
|
|
|
+ approveItem.ApproveRemark = approveRemark
|
|
|
+ approveItem.ApproveTime = now
|
|
|
+ approveItem.ModifyTime = now
|
|
|
+ approveCols := []string{"State", "ApproveRemark", "ApproveTime", "ModifyTime"}
|
|
|
+ if e := approveItem.Update(approveCols); e != nil {
|
|
|
+ err = fmt.Errorf("更新审批状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if e := updateBiApproveState(approveItem.BiId, approveItem.BiApproveId, BiStateRefused); e != nil {
|
|
|
+ err = fmt.Errorf("更新报告状态失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 推送驳回消息给申请人
|
|
|
+ go func() {
|
|
|
+ messageItem := new(biapprove.BiApproveMessage)
|
|
|
+ messageItem.SendUserId = sysAdminId
|
|
|
+ messageItem.ReceiveUserId = approveItem.ApplyUserId
|
|
|
+ messageItem.Content = "您提交的审批被驳回"
|
|
|
+ messageItem.Remark = "您提交的【看板审批】已被驳回"
|
|
|
+ messageItem.BiApproveId = approveItem.BiApproveId
|
|
|
+ messageItem.ApproveState = BiApproveStateRefuse
|
|
|
+ messageItem.CreateTime = now
|
|
|
+ messageItem.ModifyTime = now
|
|
|
+ if e := messageItem.Create(); e != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf("ApproveBi message err: %s", e.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func BiApproveCancel(biApproveId, adminId int, adminName string) (msg string, err error) {
|
|
|
+ approveItem, e := biapprove.GetBiApproveById(biApproveId)
|
|
|
+ if e != nil {
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
+ msg = "审批已被删除, 请刷新页面"
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ msg = "操作失败"
|
|
|
+ err = fmt.Errorf("GetBiApproveById err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if approveItem.ApplyUserId != adminId {
|
|
|
+ msg = "非申请人不可撤销"
|
|
|
+ err = fmt.Errorf("非申请人不可撤销")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 撤销审批
|
|
|
+ e = cancelBiApprove(approveItem.BiId, approveItem.BiApproveId, adminId, adminName)
|
|
|
+ if e != nil {
|
|
|
+ msg = "操作失败"
|
|
|
+ err = fmt.Errorf("cancelBiApprove err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// cancelBiApprove 撤回审批
|
|
|
+func cancelBiApprove(biId, approveId, sysAdminId int, sysAdminName string) (err error) {
|
|
|
+ // 默认内部审批, 如果是走的第三方审批, 那么仅修改状态
|
|
|
+ confMap, e := models.GetBusinessConf()
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("GetBusinessConf err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ openMap := map[string]bool{"false": false, "true": true}
|
|
|
+ openApprove := openMap[confMap[models.BusinessConfIsBIApprove]]
|
|
|
+ if !openApprove {
|
|
|
+ //err = fmt.Errorf("未开启审批")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 修改审批信息状态
|
|
|
+ approveItem, e := biapprove.GetBiApproveById(approveId)
|
|
|
+ if e != nil {
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
+ err = e
|
|
|
+ return
|
|
|
+ }
|
|
|
+ err = fmt.Errorf("approve GetItemById err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if approveItem.State == BiApproveStateCancel {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ approveItem.State = BiApproveStateCancel
|
|
|
+ approveItem.ModifyTime = time.Now()
|
|
|
+ cols := []string{"State", "ModifyTime"}
|
|
|
+ if e = approveItem.Update(cols); e != nil {
|
|
|
+ err = fmt.Errorf("approve Update err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 修改报告状态
|
|
|
+ e = updateBiApproveState(biId, 0, BiStateWaitSubmit)
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("更新报告审批撤回失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 推送撤回消息
|
|
|
+ go func() {
|
|
|
+ recordOb := new(biapprove.BiApproveRecord)
|
|
|
+ recordCond := fmt.Sprintf(` AND %s = ?`, biapprove.BiApproveRecordCols.BiApproveId)
|
|
|
+ recordPars := make([]interface{}, 0)
|
|
|
+ recordPars = append(recordPars, approveId)
|
|
|
+ recordItems, e := recordOb.GetItemsByCondition(recordCond, recordPars, []string{}, "")
|
|
|
+ if e != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf("approve record GetItemsByCondition err: %s", e.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ messageOb := new(biapprove.BiApproveMessage)
|
|
|
+ messages := make([]*biapprove.BiApproveMessage, 0)
|
|
|
+ for _, v := range recordItems {
|
|
|
+ m := new(biapprove.BiApproveMessage)
|
|
|
+ m.SendUserId = sysAdminId
|
|
|
+ m.ReceiveUserId = v.ApproveUserId
|
|
|
+ m.Content = fmt.Sprintf("%s提交的【看板审批】已撤回", sysAdminName)
|
|
|
+ m.BiApproveId = approveId
|
|
|
+ m.ApproveState = BiApproveStateCancel
|
|
|
+ m.CreateTime = time.Now().Local()
|
|
|
+ m.ModifyTime = time.Now().Local()
|
|
|
+ messages = append(messages, m)
|
|
|
+ }
|
|
|
+ e = messageOb.CreateMulti(messages)
|
|
|
+ if e != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf("CancelBiApprove messages err: %s", e.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// CheckBiOpenApprove 校验报告是否开启了审批流
|
|
|
+func CheckBiOpenApprove(classifyId int) (opening bool, err error) {
|
|
|
+ // 获取审批配置
|
|
|
+ confMap, e := models.GetBusinessConf()
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("GetBusinessConf err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ openMap := map[string]bool{"false": false, "true": true}
|
|
|
+ openApprove := openMap[confMap[models.BusinessConfIsBIApprove]]
|
|
|
+
|
|
|
+ // 查询对应分类是否有审批流
|
|
|
+ flowOb := new(biapprove.BiApproveFlow)
|
|
|
+ flowCond := fmt.Sprintf(` AND %s = ?`, biapprove.BiApproveFlowCols.ClassifyId)
|
|
|
+ flowPars := make([]interface{}, 0)
|
|
|
+ flowPars = append(flowPars, classifyId)
|
|
|
+ flowItem, e := flowOb.GetItemByCondition(flowCond, flowPars, "")
|
|
|
+ if e != nil && !utils.IsErrNoRow(e) {
|
|
|
+ err = fmt.Errorf("ApproveFlow GetItemByCondition err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if utils.IsErrNoRow(e) {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 开启审批/有审批流
|
|
|
+ if openApprove && (flowItem != nil) {
|
|
|
+ opening = true
|
|
|
+ return
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// CheckBiCurrState 校验报告当前应有的状态
|
|
|
+func CheckBiCurrState(classifyId, operate int) (state int, err error) {
|
|
|
+ // 获取审批配置
|
|
|
+ confMap, e := models.GetBusinessConf()
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("GetBusinessConf err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ openMap := map[string]bool{"false": false, "true": true}
|
|
|
+ openApprove := openMap[confMap[models.BusinessConfIsBIApprove]]
|
|
|
+
|
|
|
+ // 查询对应分类是否有审批流
|
|
|
+ flowOb := new(biapprove.BiApproveFlow)
|
|
|
+ flowCond := fmt.Sprintf(` AND %s = ?`, biapprove.BiApproveFlowCols.ClassifyId)
|
|
|
+ flowPars := make([]interface{}, 0)
|
|
|
+ flowPars = append(flowPars, classifyId)
|
|
|
+ flowItem, e := flowOb.GetItemByCondition(flowCond, flowPars, "")
|
|
|
+ if e != nil && !utils.IsErrNoRow(e) {
|
|
|
+ err = fmt.Errorf("ApproveFlow GetItemByCondition err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 开启审批/有审批流
|
|
|
+ if openApprove && (flowItem != nil) {
|
|
|
+ // 操作为无审批的操作时, 会转为有审批的初始状态-待提交
|
|
|
+ stateMap := map[int]int{
|
|
|
+ BiOperateAdd: BiStateWaitSubmit, // 新增
|
|
|
+ BiOperateEdit: BiStateWaitSubmit, // 编辑
|
|
|
+ BiOperatePublish: BiStateWaitSubmit, // 发布
|
|
|
+ BiOperateCancelPublish: BiStateWaitSubmit, // 取消发布
|
|
|
+ BiOperateSubmitApprove: BiStateWaitApprove, // 提审
|
|
|
+ BiOperateCancelApprove: BiStateWaitSubmit, // 撤回
|
|
|
+ }
|
|
|
+ state = stateMap[operate]
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 关闭审批/分类无审批
|
|
|
+ // 操作为有审批的操作时, 会转为无审批的初始状态-未发布
|
|
|
+ stateMap := map[int]int{
|
|
|
+ BiOperateAdd: BiStateUnpublished, // 新增
|
|
|
+ BiOperateEdit: BiStateUnpublished, // 编辑
|
|
|
+ BiOperatePublish: BiStatePublished, // 发布
|
|
|
+ BiOperateCancelPublish: BiStateUnpublished, // 取消发布
|
|
|
+ BiOperateSubmitApprove: BiStateUnpublished, // 提审
|
|
|
+ BiOperateCancelApprove: BiStateUnpublished, // 撤回
|
|
|
+ }
|
|
|
+ state = stateMap[operate]
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// SubmitBiApprove 提交审批
|
|
|
+func SubmitBiApprove(biId int, reportTitle string, classifyId int, sysAdminId int, sysAdminName string) (approveId int, err error) {
|
|
|
+ // 默认内部审批, 如果是走的第三方审批, 那么仅修改状态
|
|
|
+ confMap, e := models.GetBusinessConf()
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("GetBusinessConf err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ openMap := map[string]bool{"false": false, "true": true}
|
|
|
+ openApprove := openMap[confMap[models.BusinessConfIsBIApprove]]
|
|
|
+ if !openApprove {
|
|
|
+ err = fmt.Errorf("未开启审批")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 查询审批流
|
|
|
+ flowOb := new(biapprove.BiApproveFlow)
|
|
|
+ flowCond := fmt.Sprintf(` AND %s = ?`, biapprove.BiApproveFlowCols.ClassifyId)
|
|
|
+ flowPars := make([]interface{}, 0)
|
|
|
+ flowPars = append(flowPars, classifyId)
|
|
|
+ flowItem, e := flowOb.GetItemByCondition(flowCond, flowPars, "")
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("ApproveFlow GetItemByCondition err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 查询审批节点
|
|
|
+ nodeOb := new(biapprove.BiApproveNode)
|
|
|
+ nodeCond := fmt.Sprintf(` AND %s = ? AND %s = ?`, biapprove.BiApproveNodeCols.BiApproveFlowId, biapprove.BiApproveNodeCols.CurrVersion)
|
|
|
+ nodePars := make([]interface{}, 0)
|
|
|
+ nodePars = append(nodePars, flowItem.BiApproveFlowId, flowItem.CurrVersion)
|
|
|
+ nodeItems, e := nodeOb.GetItemsByCondition(nodeCond, nodePars, []string{}, "")
|
|
|
+ if e != nil {
|
|
|
+ err = fmt.Errorf("ApproveNodes GetItemsByCondition err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(nodeItems) == 0 {
|
|
|
+ err = fmt.Errorf("无审批节点")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 取出首个节点
|
|
|
+ firstNodeItem := new(biapprove.BiApproveNode)
|
|
|
+ for _, v := range nodeItems {
|
|
|
+ if v.PrevNodeId == 0 {
|
|
|
+ firstNodeItem = v
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if firstNodeItem == nil {
|
|
|
+ err = fmt.Errorf("首个审批节点有误")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 审批信息
|
|
|
+ now := time.Now().Local()
|
|
|
+ newApprove := new(biapprove.BiApprove)
|
|
|
+ newApprove.BiId = biId
|
|
|
+ newApprove.BiTitle = reportTitle
|
|
|
+ newApprove.ClassifyId = classifyId
|
|
|
+ newApprove.State = BiApproveStateApproving
|
|
|
+ newApprove.FlowId = flowItem.BiApproveFlowId
|
|
|
+ newApprove.FlowVersion = flowItem.CurrVersion
|
|
|
+ newApprove.StartNodeId = firstNodeItem.BiApproveNodeId
|
|
|
+ newApprove.CurrNodeId = firstNodeItem.BiApproveNodeId
|
|
|
+ newApprove.ApplyUserId = sysAdminId
|
|
|
+ newApprove.ApplyUserName = sysAdminName
|
|
|
+ newApprove.CreateTime = now
|
|
|
+ newApprove.ModifyTime = now
|
|
|
+ if e = newApprove.Create(); e != nil {
|
|
|
+ err = fmt.Errorf("生成审批信息失败, Err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ approveId = newApprove.BiApproveId
|
|
|
+
|
|
|
+ // 生成节点审批记录
|
|
|
+ err = BuildNextNodeRecordAndMsg(firstNodeItem, newApprove.BiApproveId, sysAdminId, sysAdminName)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func toBiApproveItemOrmResp(src []*biapprove.BiApproveItemOrm) (res []*response.BiApproveItemOrmResp) {
|
|
|
+ for _, v := range src {
|
|
|
+ r := new(response.BiApproveItemOrmResp)
|
|
|
+ r.BiApproveId = v.BiApproveId
|
|
|
+ r.BiApproveRecordId = v.BiApproveRecordId
|
|
|
+ r.BiId = v.BiId
|
|
|
+ r.BiTitle = v.BiTitle
|
|
|
+ r.ClassifyId = v.ClassifyId
|
|
|
+ r.State = v.State
|
|
|
+ r.RecordState = v.RecordState
|
|
|
+ r.FlowId = v.FlowId
|
|
|
+ r.FlowVersion = v.FlowVersion
|
|
|
+ r.StartNodeId = v.StartNodeId
|
|
|
+ r.CurrNodeId = v.CurrNodeId
|
|
|
+ r.ApplyUserId = v.ApplyUserId
|
|
|
+ r.ApplyUserName = v.ApplyUserName
|
|
|
+ r.ApproveRemark = v.ApproveRemark
|
|
|
+ r.ApproveTime = v.ApproveTime.Format(utils.FormatDateTime)
|
|
|
+ r.HandleTime = v.HandleTime.Format(utils.FormatDateTime)
|
|
|
+ r.CreateTime = v.CreateTime.Format(utils.FormatDateTime)
|
|
|
+ r.ModifyTime = v.ModifyTime.Format(utils.FormatDateTime)
|
|
|
+ r.NodeState = v.NodeState
|
|
|
+ res = append(res, r)
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func GetBiClassifyAll() (list []*bi_dashboard.BiDashboardClassify, msg string, err error) {
|
|
|
+ ClassifyList, e := bi_dashboard.GetBiDashboardClassifyAllList()
|
|
|
+ if e != nil {
|
|
|
+ msg = "获取失败"
|
|
|
+ err = fmt.Errorf("GetBiDashboardClassifyAllList err: %s", e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ list = ClassifyList
|
|
|
+ return
|
|
|
+}
|
zwxi