基于JavaScript、Go、CSS、Shell、HTML、Python的集成式开源工单系统设计源码

package service import ( "encoding/json" "errors" "ferry/global/orm" "ferry/models/base" "ferry/models/process" "ferry/models/system" "ferry/pkg/notify" "ferry/tools" "fmt" "reflect" "time" "github.com/jinzhu/gorm" "github.com/gin-gonic/gin" ) /* @Author : lanyulei @Desc : 处理工单 */ /* -- 节点 -- start: 开始节点 userTask: 审批节点 receiveTask: 处理节点 scriptTask: 任务节点 end: 结束节点 -- 网关 -- exclusiveGateway: 排他网关 parallelGateway: 并行网关 inclusiveGateway: 包容网关 */ type Handle struct { cirHistoryList []process.CirculationHistory workOrderId int updateValue map[string]interface{} stateValue map[string]interface{} targetStateValue map[string]interface{} WorkOrderData [][]byte workOrderDetails process.WorkOrderInfo endHistory bool flowProperties int circulationValue string processState ProcessState tx *gorm.DB } // 会签 func (h *Handle) Countersign(c *gin.Context) (err error) { var ( stateList []map[string]interface{} stateIdMap map[string]interface{} currentState map[string]interface{} cirHistoryCount int userInfoList []system.SysUser circulationStatus bool ) err = json.Unmarshal(h.workOrderDetails.State, &stateList) if err != nil { return } stateIdMap = make(map[string]interface{}) for _, v := range stateList { stateIdMap[v["id"].(string)] = v["label"] if v["id"].(string) == h.stateValue["id"].(string) { currentState = v } } userStatusCount := 0 circulationStatus = false for _, cirHistoryValue := range h.cirHistoryList { if len(currentState["processor"].([]interface{})) > 1 { if _, ok := stateIdMap[cirHistoryValue.Source]; !ok { break } } if currentState["process_method"].(string) == "person" { // 用户会签 for _, processor := range currentState["processor"].([]interface{}) { if cirHistoryValue.ProcessorId != tools.GetUserId(c) && cirHistoryValue.Source == currentState["id"].(string) && cirHistoryValue.ProcessorId == int(processor.(float64)) { cirHistoryCount += 1 } } if cirHistoryCount == len(currentState["processor"].([]interface{}))-1 { circulationStatus = true break } } else if currentState["process_method"].(string) == "role" || currentState["process_method"].(string) == "department" { // 全员处理 var tmpUserList []system.SysUser if h.stateValue["fullHandle"].(bool) { db := orm.Eloquent.Model(&system.SysUser{}) if currentState["process_method"].(string) == "role" { db = db.Where("role_id in (?)", currentState["processor"].([]interface{})) } else if currentState["process_method"].(string) == "department" { db = db.Where("dept_id in (?)", currentState["processor"].([]interface{})) } err = db.Find(&userInfoList).Error if err != nil { return } temp := map[string]struct{}{} for _, user := range userInfoList { if _, ok := temp[user.Username]; !ok { temp[user.Username] = struct{}{} tmpUserList = append(tmpUserList, user) } } for _, user := range tmpUserList { if cirHistoryValue.Source == currentState["id"].(string) && cirHistoryValue.ProcessorId != tools.GetUserId(c) && cirHistoryValue.ProcessorId == user.UserId { userStatusCount += 1 break } } } else { // 普通会签 for _, processor := range currentState["processor"].([]interface{}) { db := orm.Eloquent.Model(&system.SysUser{}) if currentState["process_method"].(string) == "role" { db = db.Where("role_id = ?", processor) } else if currentState["process_method"].(string) == "department" { db = db.Where("dept_id = ?", processor) } err = db.Find(&userInfoList).Error if err != nil { return } for _, user := range userInfoList { if user.UserId != tools.GetUserId(c) && cirHistoryValue.Source == currentState["id"].(string) && cirHistoryValue.ProcessorId == user.UserId { userStatusCount += 1 break } } } } if h.stateValue["fullHandle"].(bool) { if userStatusCount == len(tmpUserList)-1 { circulationStatus = true } } else { if userStatusCount == len(currentState["processor"].([]interface{}))-1 { circulationStatus = true } } } } if circulationStatus { h.endHistory = true err = h.circulation() if err != nil { return } } return } // 工单跳转 func (h *Handle) circulation() (err error) { var ( stateValue []byte ) stateList := make([]interface{}, 0) for _, v := range h.updateValue["state"].([]map[string]interface{}) { stateList = append(stateList, v) } err = GetVariableValue(stateList, h.workOrderDetails.Creator) if err != nil { return } stateValue, err = json.Marshal(h.updateValue["state"]) if err != nil { return } err = h.tx.Model(&process.WorkOrderInfo{}). Where("id = ?", h.workOrderId). Updates(map[string]interface{}{ "state": stateValue, "is_denied": h.flowProperties, "related_person": h.updateValue["related_person"], }).Error if err != nil { h.tx.Rollback() return } // 如果是跳转到结束节点，则需要修改节点状态 if h.targetStateValue["clazz"] == "end" { err = h.tx.Model(&process.WorkOrderInfo{}). Where("id = ?", h.workOrderId). Update("is_end", 1).Error if err != nil { h.tx.Rollback() return } } return } // 条件判断 func (h *Handle) ConditionalJudgment(condExpr map[string]interface{}) (result bool, err error) { var ( condExprOk bool condExprValue interface{} ) defer func() { if r := recover(); r != nil { switch e := r.(type) { case string: err = errors.New(e) case error: err = e default: err = errors.New("未知错误") } return } }() for _, data := range h.WorkOrderData { var formData map[string]interface{} err = json.Unmarshal(data, &formData) if err != nil { return } if condExprValue, condExprOk = formData[condExpr["key"].(string)]; condExprOk { break } } if condExprValue == nil { err = errors.New("未查询到对应的表单数据。") return } // todo 待优化 switch reflect.TypeOf(condExprValue).String() { case "string": switch condExpr["sign"] { case "==": if condExprValue.(string) == condExpr["value"].(string) { result = true } case "!=": if condExprValue.(string) != condExpr["value"].(string) { result = true } case ">": if condExprValue.(string) > condExpr["value"].(string) { result = true } case ">=": if condExprValue.(string) >= condExpr["value"].(string) { result = true } case "<": if condExprValue.(string) < condExpr["value"].(string) { result = true } case "<=": if condExprValue.(string) <= condExpr["value"].(string) { result = true } default: err = errors.New("目前仅支持6种常规判断类型，包括（等于、不等于、大于、大于等于、小于、小于等于）") } case "float64": switch condExpr["sign"] { case "==": if condExprValue.(float64) == condExpr["value"].(float64) { result = true } case "!=": if condExprValue.(float64) != condExpr["value"].(float64) { result = true } case ">": if condExprValue.(float64) > condExpr["value"].(float64) { result = true } case ">=": if condExprValue.(float64) >= condExpr["value"].(float64) { result = true } case "<": if condExprValue.(float64) < condExpr["value"].(float64) { result = true } case "<=": if condExprValue.(float64) <= condExpr["value"].(float64) { result = true } default: err = errors.New("目前仅支持6种常规判断类型，包括（等于、不等于、大于、大于等于、小于、小于等于）") } default: err = errors.New("条件判断目前仅支持字符串、整型。") }