package seal import ( "encoding/json" "errors" "fmt" "hongze/hongze_mobile_admin/models/custom" "hongze/hongze_mobile_admin/models/tables/admin" "hongze/hongze_mobile_admin/models/tables/approval_flow_node" "hongze/hongze_mobile_admin/models/tables/contract_approval" "hongze/hongze_mobile_admin/models/tables/contract_approval_record" "hongze/hongze_mobile_admin/models/tables/seal" "hongze/hongze_mobile_admin/services" "hongze/hongze_mobile_admin/services/flow" "strings" "time" ) var sourceType = 3 //提交审批 func Apply(sealInfo *seal.Seal) (err error) { //用印状态判断 ignoreStatus := []string{"待提交", "已撤回", "已驳回"} if !strings.Contains(strings.Join(ignoreStatus, ","), sealInfo.Status) { err = errors.New("用印单状态异常,不允许提交审批,当前用印单状态:" + sealInfo.Status) return } //将用印数据存为快照 sealDetailByte, err := json.Marshal(sealInfo) if err != nil { err = errors.New(fmt.Sprint("用印单异常,当前用印单数据格式化失败:", err)) return } //获取基础审批流 flowId := 5 //如果是法人章或者是公章 if sealInfo.SealType == "法人章" || sealInfo.SealType == "公章" { flowId = 6 } flowItemInfo, err := flow.GetApprovalFlow(flowId) if err != nil { return } if len(flowItemInfo.NodeList) <= 0 { err = errors.New("审批流程未配置") return } //校验是否存在待审批的审批单(其实没有多大意义,只是为了 异常数据校验) approval := &contract_approval.ContractApproval{ ContractId: sealInfo.SealId, Status: "待审批", ApplyContent: sealInfo.Use, ContractDetail: string(sealDetailByte), ApplyUserId: sealInfo.UserId, ApplyUserName: sealInfo.UserName, FlowId: flowItemInfo.FlowId, FlowVersion: flowItemInfo.CurrVersion, CurrNodeId: flowItemInfo.NodeList[0].NodeId, ModifyTime: time.Now(), CreateTime: time.Now(), } has, err := approval.CheckPendingByContractId(sealInfo.SealId, "seal") if err != nil { return } if has { err = errors.New("用印异常,不允许提交审批,存在待审核的审批单") return } contractApprovalRecordList := make([]*contract_approval_record.ContractApprovalRecord, 0) ApproveUserMap := make(map[int]approval_flow_node.User) for _, nodeItem := range flowItemInfo.NodeList { //审批流记录 if len(nodeItem.UserList) <= 0 { err = errors.New(fmt.Sprint("审批流程异常,没有可审批的人员,Err:", err)) return } for _, userItem := range nodeItem.UserList { contractApprovalRecord := &contract_approval_record.ContractApprovalRecord{ Status: "待审批", ApproveRemark: "", ApproveUserId: userItem.AdminId, ApproveUserName: userItem.Name, ApproveRoleTypeCode: userItem.RoleTypeCode, NodeId: nodeItem.NodeId, NodeType: nodeItem.NodeType, NextNodeId: nodeItem.NextNodeId, CreateTime: time.Now(), ModifyTime: time.Now(), } contractApprovalRecordList = append(contractApprovalRecordList, contractApprovalRecord) ApproveUserMap[userItem.AdminId] = userItem } } err = approval.Apply(approval, contractApprovalRecordList) if err != nil { return } //待办通知 { //发送消息下级审批人 go messageToNodeUser(contractApprovalRecordList[0].NodeId, approval.ApplyUserId, approval.ContractApprovalId, 1, 1, sealInfo.CompanyName, sealInfo.Use) //发送消息给所有的抄送人 go messageToAllCcUser(approval.ApplyUserId, approval.ContractApprovalId, 1, 1, sealInfo.CompanyName, sealInfo.Use) } return } //驳回审批 func Reject(approvalRecord *contract_approval_record.ContractApprovalRecord, opUser *custom.AdminWx, rejectRemark string) (err error) { if approvalRecord == nil { err = errors.New("审批流异常,没有审批流信息") return } //审批流状态判断 if approvalRecord.Status != "待审批" { err = errors.New("审批流状态异常,不允许驳回申请,当前审批流状态:" + approvalRecord.Status) return } //判断是否审批类型,如果不是审批类型,那么就没有审批权限 if approvalRecord.NodeType != "check" { err = errors.New("当前账号没有审批权限") return } //操作人 opUserId := opUser.AdminId opUserName := opUser.RealName //操作权限校验 if opUser.RoleTypeCode != approvalRecord.ApproveRoleTypeCode { err = errors.New("当前账号没有审批权限") return } if approvalRecord.ApproveUserId > 0 && approvalRecord.ApproveUserId != opUserId { err = errors.New("当前账号没有审批权限,需要指定人操作") return } //获取审批单详情 approvalInfo, err := contract_approval.GetContractApprovalById(approvalRecord.ContractApprovalId) if err != nil { return } //审批单状态判断 if approvalInfo.Status != "待审批" { err = errors.New("审批单状态异常,不允许驳回申请,当前审批单状态:" + approvalInfo.Status) return } //获取用印信息 sealInfo, err := seal.GetSealInfoById(approvalInfo.ContractId) if err != nil { return } //用印状态判断 if sealInfo.Status != "待审批" { err = errors.New("用印状态异常,不允许驳回申请,当前用印状态:" + sealInfo.Status) return } err = approvalInfo.Reject(approvalInfo, approvalRecord, opUserId, opUserName, rejectRemark) if err != nil { return } //添加操作日志 //remark := "驳回申请" //_ = contract_operation_record.AddContractOperationRecord(contractInfo.ContractId, opUserId, approvalRecord.ContractApprovalRecordId, "reject", opUserName, remark) //待办通知 { content := sealInfo.CompanyName + " 用印已驳回" approvalSysUser, _ := admin.GetAdminById(sealInfo.UserId) go services.AddCompanyApprovalMessage(opUserId, sealInfo.UserId, 0, approvalRecord.ContractApprovalRecordId, 2, 2, 3, sealInfo.CompanyName, content, content, approvalSysUser.Mobile) //发送消息给所有的抄送人 go messageToAllCcUser(opUserId, approvalRecord.ContractApprovalId, 2, 3, sealInfo.CompanyName, content) } return } //审批通过 func Approved(approvalRecord *contract_approval_record.ContractApprovalRecord, opUser *custom.AdminWx, approvedRemark string) (err error) { if approvalRecord == nil { err = errors.New("审批流异常,没有审批流信息") return } //审批流状态判断 if approvalRecord.Status != "待审批" { err = errors.New("审批流状态异常,不允许审批,当前审批流状态:" + approvalRecord.Status) return } //判断是否审批类型,如果不是审批类型,那么就没有审批权限 if approvalRecord.NodeType != "check" { err = errors.New("当前账号没有审批权限") return } //操作人 opUserId := opUser.AdminId //opUserName := opUser.RealName //操作权限校验 if opUser.RoleTypeCode != approvalRecord.ApproveRoleTypeCode { err = errors.New("当前账号没有审批权限") return } if approvalRecord.ApproveUserId > 0 && approvalRecord.ApproveUserId != opUserId { err = errors.New("当前账号没有审批权限,需要指定人操作") return } //获取审批单详情 approvalInfo, err := contract_approval.GetContractApprovalById(approvalRecord.ContractApprovalId) if err != nil { return } //审批单状态判断 if approvalInfo.Status != "待审批" { err = errors.New("审批单状态异常,不允许审批,当前审批单状态:" + approvalInfo.Status) return } //获取用印信息 sealInfo, err := seal.GetSealInfoById(approvalInfo.ContractId) if err != nil { return } //用印状态判断 if sealInfo.Status != "待审批" { err = errors.New("用印状态异常,不允许审批,当前用印状态:" + sealInfo.Status) return } err = approvalInfo.Approved(approvalInfo, approvalRecord, approvedRemark) if err != nil { return } //添加操作日志 //remark := "审批通过" //_ = contract_operation_record.AddContractOperationRecord(contractInfo.ContractId, opUserId, approvalRecord.ContractApprovalRecordId, "approval", opUserName, remark) //发送信息给所有抄送人 content := sealInfo.CompanyName + " 用印已审核" go messageToAllCcUser(opUserId, approvalRecord.ContractApprovalId, 2, 2, sealInfo.CompanyName, content) //如果下一个节点属于结束节点,那么通知对应的销售 if approvalRecord.NextNodeId == 0 { //待办通知(通知销售已经审核通过了) { content := sealInfo.CompanyName + " 用印已审核" approvalSysUser, _ := admin.GetAdminById(sealInfo.UserId) go services.AddCompanyApprovalMessage(opUserId, sealInfo.UserId, 0, approvalRecord.ContractApprovalRecordId, 2, 2, 2, sealInfo.CompanyName, content, content, approvalSysUser.Mobile) } } else { //获取下级节点信息 flowNodeInfo, tmpErr := approval_flow_node.GetByNodeId(approvalRecord.NextNodeId) if tmpErr != nil { err = tmpErr return } //如果该级节点是抄送类型,那么需要将该节点给处理掉 if flowNodeInfo.NodeType == "cc" { go approvedByCc(approvedRemark, approvalRecord) } else { //发送消息下级审批人 go messageToNodeUser(approvalRecord.NextNodeId, sealInfo.UserId, approvalInfo.ContractApprovalId, 1, 1, sealInfo.CompanyName, content) } } return } //审批通过(抄送节点) func approvedByCc(approvedRemark string, sourceApprovalRecord *contract_approval_record.ContractApprovalRecord) (err error) { //下个流程节点id nextNodeId := 0 //获取审批单中抄送节点的所有数据列表 approvalRecordList, err := contract_approval_record.GetContractApprovalRecordListByContractIdAndNode(sourceApprovalRecord.ContractApprovalId, sourceApprovalRecord.NextNodeId) if err != nil { return } //遍历所有的抄送单 for _, approvalRecord := range approvalRecordList { nextNodeId = approvalRecord.NextNodeId //审批流状态判断 if approvalRecord.Status != "待审批" { err = errors.New("审批流状态异常,不允许审批,当前审批流状态:" + approvalRecord.Status) return } //判断是否审批类型,如果不是审批类型,那么就没有审批权限 if approvalRecord.NodeType != "cc" { err = errors.New("当前账号不是抄送权限") return } } //获取审批单详情 approvalInfo, err := contract_approval.GetContractApprovalById(sourceApprovalRecord.ContractApprovalId) if err != nil { return } //获取用印信息 sealInfo, err := seal.GetSealInfoById(approvalInfo.ContractId) if err != nil { return } //if contractApprovalRecord err = approvalInfo.ApprovedByCc(approvalInfo, approvalRecordList, approvedRemark, nextNodeId) if err != nil { return } //如果下一个节点属于结束节点,那么通知对应的销售 if nextNodeId == 0 { //待办通知 { content := sealInfo.CompanyName + " 用印已审核" approvalSysUser, _ := admin.GetAdminById(sealInfo.UserId) go services.AddCompanyApprovalMessage(sourceApprovalRecord.ApproveUserId, sealInfo.UserId, 0, sourceApprovalRecord.ContractApprovalRecordId, 2, 2, 2, sealInfo.CompanyName, content, content, approvalSysUser.Mobile) } } else { //获取下级节点信息 flowNodeInfo, tmpErr := approval_flow_node.GetByNodeId(nextNodeId) if tmpErr != nil { err = tmpErr return } //如果下级节点是抄送类型,那么还是需要处理抄送节点逻辑 if flowNodeInfo.NodeType == "cc" { go approvedByCc(approvedRemark, sourceApprovalRecord) } else { //如果下级级节点是审批类型 //发送消息下级审批人 go messageToNodeUser(nextNodeId, sealInfo.UserId, approvalInfo.ContractApprovalId, 1, 1, sealInfo.CompanyName, approvalInfo.ApplyContent) } } return } //抄送信息给用户(根据节点来推送) func messageToNodeUser(flowNodeId, createUserId, contractApprovalId, messageType, approvalStatus int, companyName, content string) (err error) { //获取审批单中抄送节点的所有数据列表 contractApprovalRecordList, err := contract_approval_record.GetContractApprovalRecordListByContractIdAndNode(contractApprovalId, flowNodeId) if err != nil { return } err = messageToUser(contractApprovalRecordList, createUserId, messageType, approvalStatus, companyName, content) return } //发送信息给所有抄送人 // @param createUserId 消息发起人 // @param contractApprovalId 审批单id // @param messageType 消息类型:1:申请消息,2:审批结果 // @param approvalStatus 审批状态:1:待审批,2:已审批,3:已驳回" // @param companyName 企业客户名称 // @param content 消息内容 func messageToAllCcUser(createUserId, contractApprovalId, messageType, approvalStatus int, companyName, content string) (err error) { //获取审批单中抄送节点的所有数据列表 contractApprovalRecordList, err := contract_approval_record.GetContractApprovalRecordListByContractApprovalId(contractApprovalId) if err != nil { return } err = messageToUser(contractApprovalRecordList, createUserId, messageType, approvalStatus, companyName, content) return } //抄送信息给用户(发送给所有抄送人) // @param createUserId 待审批、抄送记录 // @param createUserId 消息发起人 // @param contractApprovalId 审批单id // @param messageType 消息类型:1:申请消息,2:审批结果 // @param approvalStatus 审批状态:1:待审批,2:已审批,3:已驳回" // @param companyName 企业客户名称 // @param content 消息内容 func messageToUser(contractApprovalRecordList []*contract_approval_record.ContractApprovalRecord, createUserId, messageType, approvalStatus int, companyName, content string) (err error) { for _, contractApprovalRecord := range contractApprovalRecordList { sysUserMobile := "" sysUser, _ := admin.GetAdminById(contractApprovalRecord.ApproveUserId) if sysUser != nil { sysUserMobile = sysUser.Mobile } //接收人,就是审批记录里面的待审核人(抄送人) receiveUserId := contractApprovalRecord.ApproveUserId go services.AddCompanyApprovalMessage(createUserId, receiveUserId, 0, contractApprovalRecord.ContractApprovalRecordId, messageType, sourceType, approvalStatus, companyName, content, content, sysUserMobile) } return }