|
|
@@ -0,0 +1,1003 @@
|
|
|
+package company_apply
|
|
|
+
|
|
|
+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"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/approval_flow_node"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/company"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/company_approval"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/company_approval_message"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/company_contract"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/company_product"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/company_product_log"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/contract_approval"
|
|
|
+ "hongze/hongze_mobile_admin/models/tables/contract_approval_record"
|
|
|
+ "hongze/hongze_mobile_admin/services"
|
|
|
+ "hongze/hongze_mobile_admin/services/flow"
|
|
|
+ "hongze/hongze_mobile_admin/utils"
|
|
|
+ "strings"
|
|
|
+ "time"
|
|
|
+)
|
|
|
+
|
|
|
+var sourceType = 1 //来源客户
|
|
|
+//提交审批
|
|
|
+func Apply(companyApprovalId int, messageContent string) (err error) {
|
|
|
+ //获取客户单详情
|
|
|
+ recodeInfo, err := company_approval.GetCompanyApprovalByApprovalId(companyApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取合同信息失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if recodeInfo == nil {
|
|
|
+ err = errors.New("客户单异常，找不到客户单信息")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //获取客户信息
|
|
|
+ companyInfo, err := company.GetCompanyById(recodeInfo.CompanyId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取合同信息失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if companyInfo == nil {
|
|
|
+ err = errors.New("客户信息异常，找不到客户信息")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //合同状态判断
|
|
|
+ ignoreStatus := []string{"待审批", "已撤回", "驳回"}
|
|
|
+ if !strings.Contains(strings.Join(ignoreStatus, ","), recodeInfo.ApproveStatus) {
|
|
|
+ err = errors.New("客户单状态异常，不允许提交审批，当前客户单状态：" + recodeInfo.ApproveStatus)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //待审内容
|
|
|
+ applyContent := `试用转正式`
|
|
|
+ switch recodeInfo.ApplyMethod { //"1:试用->正式,2:冻结—>试用,3:试用延期,4:原销售申请领取流失客户，5:正式客户申请服务更新"
|
|
|
+ case 1:
|
|
|
+ applyContent = `试用转正式`
|
|
|
+ case 2:
|
|
|
+ applyContent = `冻结转试用`
|
|
|
+ case 3:
|
|
|
+ applyContent = `试用延期`
|
|
|
+ case 4:
|
|
|
+ applyContent = `原销售申领客户`
|
|
|
+ case 5:
|
|
|
+ applyContent = `服务更新`
|
|
|
+ }
|
|
|
+
|
|
|
+ contractDetailByte, err := json.Marshal(recodeInfo)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New(fmt.Sprint("合同状态异常，当前合同数据格式化失败：", err))
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取基础审批流
|
|
|
+ var flowItemInfo *approval_flow.ApprovalFlowItem
|
|
|
+ if recodeInfo.ProductId == 1 {
|
|
|
+ tmpFlowItemInfo, tmpErr := flow.GetApprovalFlow(1)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New(fmt.Sprint("查找审批流程配置失败：", tmpErr))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ flowItemInfo = tmpFlowItemInfo
|
|
|
+ } else {
|
|
|
+ tmpFlowItemInfo, tmpErr := flow.GetApprovalFlow(2)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New(fmt.Sprint("查找审批流程配置失败：", tmpErr))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ flowItemInfo = tmpFlowItemInfo
|
|
|
+ }
|
|
|
+
|
|
|
+ //校验是否存在待审批的审批单（其实没有多大意义，只是为了 异常数据校验）
|
|
|
+ contractApproval := &contract_approval.ContractApproval{
|
|
|
+ ContractId: recodeInfo.CompanyApprovalId,
|
|
|
+ Status: "待审批",
|
|
|
+ ApprovalType: "company",
|
|
|
+ ApplyContent: applyContent,
|
|
|
+ ContractDetail: string(contractDetailByte),
|
|
|
+ ApplyUserId: recodeInfo.ApplyUserId,
|
|
|
+ ApplyUserName: recodeInfo.ApplyRealName,
|
|
|
+ FlowId: flowItemInfo.FlowId,
|
|
|
+ FlowVersion: flowItemInfo.CurrVersion,
|
|
|
+ CurrNodeId: flowItemInfo.NodeList[0].NodeId,
|
|
|
+ StartNodeId: flowItemInfo.NodeList[0].NodeId,
|
|
|
+ ModifyTime: time.Now(),
|
|
|
+ CreateTime: time.Now(),
|
|
|
+ }
|
|
|
+ has, err := contractApproval.CheckPendingByContractId(recodeInfo.CompanyApprovalId, "company")
|
|
|
+ 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,
|
|
|
+ PrevNodeId: nodeItem.PrevNodeId,
|
|
|
+ AuditType: nodeItem.AuditType,
|
|
|
+ CreateTime: time.Now(),
|
|
|
+ ModifyTime: time.Now(),
|
|
|
+ }
|
|
|
+ contractApprovalRecordList = append(contractApprovalRecordList, contractApprovalRecord)
|
|
|
+ ApproveUserMap[userItem.AdminId] = userItem
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ err = contractApproval.Apply(contractApproval, contractApprovalRecordList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //待办通知
|
|
|
+ {
|
|
|
+ //发送消息下级审批人
|
|
|
+ go messageToNodeUser(contractApproval.CurrNodeId, recodeInfo.ApplyUserId, companyInfo.CompanyId, contractApproval.ContractId, contractApproval.ContractApprovalId, 1, 1, companyInfo.CompanyName, messageContent)
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// CancelApply 撤回审批
|
|
|
+func CancelApply(recordInfo *company_approval.CompanyApproval, opUserId int) (err error) {
|
|
|
+ if recordInfo == nil {
|
|
|
+ err = errors.New("客户单异常，没有客户单信息")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //客户单状态判断
|
|
|
+ if recordInfo.ApproveStatus != "待审批" {
|
|
|
+ err = errors.New("客户单状态异常，不允许撤回申请，当前客户单状态：" + recordInfo.ApproveStatus)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //校验操作人与客户单申请人是否同一人
|
|
|
+ if recordInfo.ApplyUserId != opUserId {
|
|
|
+ err = errors.New(fmt.Sprint("操作人异常，不允许撤回非本人提交的申请；客户单发起人：", recordInfo.ApplyUserId, ";撤销人：", opUserId))
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取最近一次待审批的审批单信息
|
|
|
+ approval, err := contract_approval.GetLastContractApprovalByContractId(recordInfo.CompanyApprovalId, "company")
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //是否一级审批节点判断，如果不是一级审批节点，那么不允许撤回
|
|
|
+ if approval.StartNodeId != approval.CurrNodeId {
|
|
|
+ err = errors.New("审批单状态异常，不允许撤回申请，当前审批单已被审批操作，进入了下一级审批节点")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取当前待审批的审批流信息
|
|
|
+ approvalRecord, err := contract_approval_record.GetCurrContractApprovalRecordByContractId(approval.ContractApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //判断当前节点是否存在上级节点，如果存在，那么说明
|
|
|
+ if approvalRecord.PrevNodeId > 0 {
|
|
|
+ err = errors.New("合同已存在审批操作，不允许撤回申请")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取当前审批单中所有待审批的流程流
|
|
|
+ approvalRecordList, err := contract_approval_record.GetPendingContractApprovalRecordListByContractId(approval.ContractApprovalId, approvalRecord.NodeId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //撤回审批流
|
|
|
+ err = approval.Cancel(approval, approvalRecordList)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //添加操作日志 （？？这个看情况再说，或许没有必要）
|
|
|
+
|
|
|
+ //作废原有消息
|
|
|
+ for _, contractApprovalRecord := range approvalRecordList {
|
|
|
+ go company_approval_message.CancelCompanyApprovalMessage(contractApprovalRecord.ContractApprovalRecordId, 2)
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// Reject 驳回审批
|
|
|
+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
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取审批单详情
|
|
|
+ approval, err := contract_approval.GetContractApprovalById(approvalRecord.ContractApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //审批单状态判断
|
|
|
+ if approval.Status != "待审批" {
|
|
|
+ err = errors.New("审批单状态异常，不允许驳回申请，当前审批单状态：" + approval.Status)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取 客户单 信息
|
|
|
+ recordInfo, err := company_approval.GetCompanyApprovalById(approval.ContractId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //客户单 状态判断
|
|
|
+ if recordInfo.ApproveStatus != "待审批" {
|
|
|
+ err = errors.New("客户单状态异常，不允许驳回申请，当前客户单状态：" + recordInfo.ApproveStatus)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取 客户 信息
|
|
|
+ companyInfo, err := company.GetCompanyById(recordInfo.CompanyId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ err = approval.Reject(approval, approvalRecord, opUserId, opUserName, rejectRemark)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //添加操作日志
|
|
|
+ //remark := "驳回申请"
|
|
|
+ //_ = contract.AddContractOperationRecord(contractInfo.ContractId, opUserId, approvalRecord.ContractApprovalRecordId, "reject", opUserName, remark)
|
|
|
+
|
|
|
+ //完成审批后的驳回操作
|
|
|
+ go afterReject(approval.ContractId, opUserId, opUserName, rejectRemark)
|
|
|
+
|
|
|
+ //待办通知
|
|
|
+ {
|
|
|
+ //content := contractInfo.CompanyName + " 合同模板已驳回"
|
|
|
+ content := companyInfo.CompanyName + " " + recordInfo.ApproveContent + "审批驳回"
|
|
|
+ approvalSysUser, _ := admin.GetAdminById(approval.ApplyUserId)
|
|
|
+ go services.AddCompanyApprovalMessage(opUserId, approval.ApplyUserId, companyInfo.CompanyId, approval.ContractId, 2, sourceType, 3, companyInfo.CompanyName, content, content, approvalSysUser.Mobile)
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// Approved 审批通过
|
|
|
+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
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取审批单详情
|
|
|
+ approval, err := contract_approval.GetContractApprovalById(approvalRecord.ContractApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //审批单状态判断
|
|
|
+ if approval.Status != "待审批" {
|
|
|
+ err = errors.New("审批单状态异常，不允许审批，当前审批单状态：" + approval.Status)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取 客户单 信息
|
|
|
+ recordInfo, err := company_approval.GetCompanyApprovalById(approval.ContractId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //客户单 状态判断
|
|
|
+ if recordInfo.ApproveStatus != "待审批" {
|
|
|
+ err = errors.New("客户单状态异常，不允许审批，当前客户单状态：" + recordInfo.ApproveStatus)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取 客户 信息
|
|
|
+ companyInfo, err := company.GetCompanyById(recordInfo.CompanyId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //if contractApprovalRecord
|
|
|
+ err = approval.Approved(approval, approvalRecord, approvedRemark)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //添加操作日志
|
|
|
+ //remark := "审批通过"
|
|
|
+ //_ = contract.AddContractOperationRecord(contractInfo.ContractId, opUserId, approvalRecord.ContractApprovalRecordId, "approval", opUserName, remark)
|
|
|
+
|
|
|
+ //发送信息给所有抄送人
|
|
|
+ content := companyInfo.CompanyName + " " + recordInfo.ApproveContent + "审批通过"
|
|
|
+
|
|
|
+ //如果下一个节点属于结束节点，那么通知对应的销售，同时，异步生成合同pdf
|
|
|
+ if approvalRecord.NextNodeId == 0 {
|
|
|
+ //待办通知（通知销售已经审核通过了）
|
|
|
+ {
|
|
|
+ approvalSysUser, _ := admin.GetAdminById(approval.ApplyUserId)
|
|
|
+ go services.AddCompanyApprovalMessage(opUserId, approval.ApplyUserId, companyInfo.CompanyId, approval.ContractId, 2, sourceType, 2, companyInfo.CompanyName, content, content, approvalSysUser.Mobile)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 客户单审批后的异步操作（修改客户单信息、修改合同权限等）
|
|
|
+ go afterApproved(recordInfo.CompanyApprovalId, opUser.AdminId, opUser.RealName)
|
|
|
+ } 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, approval.ApplyUserId, companyInfo.CompanyId, approval.ContractId, approval.ContractApprovalId, 1, 1, companyInfo.CompanyName, content)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// approvedByCc 审批通过（抄送节点）
|
|
|
+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 _, contractApprovalRecord := range approvalRecordList {
|
|
|
+ nextNodeId = contractApprovalRecord.NextNodeId
|
|
|
+ //审批流状态判断
|
|
|
+ if contractApprovalRecord.Status != "待审批" {
|
|
|
+ err = errors.New("审批流状态异常，不允许审批，当前审批流状态：" + contractApprovalRecord.Status)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //判断是否审批类型，如果不是审批类型，那么就没有审批权限
|
|
|
+ if contractApprovalRecord.NodeType != "cc" {
|
|
|
+ err = errors.New("当前账号不是抄送权限")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取审批单详情
|
|
|
+ approval, err := contract_approval.GetContractApprovalById(sourceApprovalRecord.ContractApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取 客户单 信息
|
|
|
+ recordInfo, err := company_approval.GetCompanyApprovalById(approval.ContractId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //客户单 状态判断
|
|
|
+ if recordInfo.ApproveStatus != "待审批" {
|
|
|
+ err = errors.New("客户单状态异常，不允许审批，当前客户单状态：" + recordInfo.ApproveStatus)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取 客户 信息
|
|
|
+ companyInfo, err := company.GetCompanyById(recordInfo.CompanyId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //if contractApprovalRecord
|
|
|
+ err = approval.ApprovedByCc(approval, approvalRecordList, approvedRemark, nextNodeId)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ content := companyInfo.CompanyName + " " + recordInfo.ApproveContent + "审批通过"
|
|
|
+ //发送消息给抄送人
|
|
|
+ go messageToNodeUser(approvalRecordList[0].NodeId, approval.ApplyUserId, companyInfo.CompanyId, approval.ContractId, approval.ContractApprovalId, 1, 1, companyInfo.CompanyName, content)
|
|
|
+
|
|
|
+ //如果下一个节点属于结束节点，那么通知对应的销售，同时，异步生成合同pdf
|
|
|
+ if nextNodeId == 0 {
|
|
|
+ //待办通知
|
|
|
+ {
|
|
|
+ approvalSysUser, _ := admin.GetAdminById(approval.ApplyUserId)
|
|
|
+ go services.AddCompanyApprovalMessage(sourceApprovalRecord.ApproveUserId, approval.ApplyUserId, companyInfo.CompanyId, sourceApprovalRecord.ContractApprovalRecordId, 2, sourceType, 2, companyInfo.CompanyName, content, content, approvalSysUser.Mobile)
|
|
|
+ }
|
|
|
+
|
|
|
+ //客户单审批后的异步操作（修改客户单信息、修改合同权限等）
|
|
|
+ go afterApproved(recordInfo.CompanyApprovalId, sourceApprovalRecord.ApproveUserId, sourceApprovalRecord.ApproveUserName)
|
|
|
+ } 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, approval.ApplyUserId, companyInfo.CompanyId, approval.ContractId, approval.ContractApprovalId, 1, 1, companyInfo.CompanyName, content)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// messageToNodeUser 抄送信息给用户（根据节点来推送）
|
|
|
+func messageToNodeUser(flowNodeId, createUserId, companyId, companyApprovalId, 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, companyId, companyApprovalId, messageType, approvalStatus, companyName, content)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// messageToAllCcUser 发送信息给所有抄送人
|
|
|
+// @param createUserId 消息发起人
|
|
|
+// @param contractApprovalId 审批单id
|
|
|
+// @param messageType 消息类型：1:申请消息，2:审批结果
|
|
|
+// @param approvalStatus 审批状态：1:待审批，2:已审批，3:已驳回"
|
|
|
+// @param companyName 企业客户名称
|
|
|
+// @param content 消息内容
|
|
|
+func messageToAllCcUser(createUserId, companyId, companyApprovalId, contractApprovalId, messageType, approvalStatus int, companyName, content string) (err error) {
|
|
|
+ //获取审批单中抄送节点的所有数据列表
|
|
|
+ contractApprovalRecordList, err := contract_approval_record.GetContractApprovalRecordListByContractApprovalId(contractApprovalId)
|
|
|
+
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ err = messageToUser(contractApprovalRecordList, createUserId, companyId, companyApprovalId, messageType, approvalStatus, companyName, content)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// messageToUser 抄送信息给用户（发送给所有抄送人）
|
|
|
+// @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, companyId, companyApprovalId, 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, companyId, companyApprovalId, messageType, sourceType, approvalStatus, companyName, content, content, sysUserMobile)
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// afterApproved 审批完成后操作
|
|
|
+func afterApproved(companyApprovalId int, opUserId int, opUserName string) (err error) {
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ //fmt.Println("异常提醒:"+utils.RunMode, "合同审批通过后，生成pdf失败，ERR:"+err.Error()+"", utils.EmailSendToUsers)
|
|
|
+ go utils.SendEmail("异常提醒:"+utils.RunMode, "合同审批通过后，生成pdf失败，ERR:"+err.Error()+"", utils.EmailSendToUsers)
|
|
|
+ }
|
|
|
+
|
|
|
+ }()
|
|
|
+ opUser := custom.AdminWx{
|
|
|
+ AdminId: opUserId,
|
|
|
+ RealName: opUserName,
|
|
|
+ }
|
|
|
+ //获取客户单详情
|
|
|
+ recodeInfo, err := company_approval.GetCompanyApprovalByApprovalId(companyApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取合同信息失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if recodeInfo == nil {
|
|
|
+ err = errors.New("客户单异常，找不到客户单信息")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //获取客户信息
|
|
|
+ companyInfo, err := company.GetCompanyById(recodeInfo.CompanyId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取合同信息失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if companyInfo == nil {
|
|
|
+ err = errors.New("客户信息异常，找不到客户信息")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //客户产品信息
|
|
|
+ companyProduct, err := company_product.GetCompanyProductByCompanyIdAndProductId(recodeInfo.CompanyId, recodeInfo.ProductId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New(fmt.Sprint("获取信息客户产品失败", ";Err:"+err.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if companyProduct == nil {
|
|
|
+ err = errors.New("获取信息客户产品失败2")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ switch recodeInfo.ApplyMethod {
|
|
|
+ case 1: //试用转正式
|
|
|
+ //获取合同信息
|
|
|
+ contractInfo, tmpErr := company_contract.GetCompanyContractDetail(recodeInfo.CompanyId, recodeInfo.ProductId, recodeInfo.CompanyContractId)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New(fmt.Sprint("待审批信息不存在,CompanyId:", recodeInfo.CompanyId, ";productId:", recodeInfo.ProductId, ";Err:"+tmpErr.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if contractInfo == nil {
|
|
|
+ err = errors.New(fmt.Sprint("待审批信息不存在,CompanyId:", recodeInfo.CompanyId, ";productId:", recodeInfo.ProductId))
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //格式化合同开始时间
|
|
|
+ contractStartDate, tmpErr := time.Parse(utils.FormatDate, contractInfo.StartDate)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New("合同开始时间转换失败,Err:" + tmpErr.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //格式化合同结束日期
|
|
|
+ contractEndDate, tmpErr := time.Parse(utils.FormatDate, contractInfo.EndDate)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New("合同结束时间转换失败,Err:" + tmpErr.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //格式化 产品中 合同结束日期
|
|
|
+ //productContractEndDate, err := time.Parse(utils.FormatDate, companyProduct.ContractEndDate)
|
|
|
+ //if err != nil {
|
|
|
+ // br.Msg = "审批失败"
|
|
|
+ // br.ErrMsg = "产品中合同结束时间转换失败,Err:" + err.Error()
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //如果合同时间小于等于今天，那么立马执行合同内容
|
|
|
+ if time.Now().After(contractStartDate) {
|
|
|
+ tmpErr = company_approval.TryOutToFormal(recodeInfo.CompanyId, recodeInfo.ProductId, opUser.AdminId, recodeInfo.CompanyApprovalId, contractInfo.CompanyContractId, contractInfo.StartDate, contractInfo.EndDate, opUser.RealName, companyProduct.ProductName)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New("试用转正式失败,Err:" + tmpErr.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ tmpErr = company_approval.ApplyApproveContract(recodeInfo.CompanyId, recodeInfo.ProductId, recodeInfo.CompanyApprovalId, contractInfo.CompanyContractId)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New("试用转正式失败,Err:" + tmpErr.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //如果合同中的结束日期大于产品中的合同结束日期，那么就去修改产品中的合同结束日期
|
|
|
+ if contractEndDate.After(companyProduct.ContractEndDate) {
|
|
|
+ companyProduct.ContractEndDate = contractEndDate
|
|
|
+ cols := make([]string, 0)
|
|
|
+ cols = append(cols, "ContractEndDate")
|
|
|
+ _ = companyProduct.Update(cols)
|
|
|
+ }
|
|
|
+ case 2: //冻结->试用
|
|
|
+ tmpErr := company_approval.FreezeToTryOut(recodeInfo.CompanyId, recodeInfo.ProductId, opUser.AdminId, recodeInfo.CompanyApprovalId, recodeInfo.ApplyUserId, opUser.RealName, companyProduct.ProductName)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New("冻结转试用失败,Err:" + tmpErr.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ case 3: //试用延期
|
|
|
+ tmpErr := company_approval.TryOutDelay(recodeInfo.CompanyId, recodeInfo.ProductId, opUser.AdminId, recodeInfo.CompanyApprovalId, opUser.RealName, companyProduct.EndDate, companyProduct.ProductName)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New("试用延期失败,Err:" + tmpErr.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ case 4: //原销售申请领取流失客户
|
|
|
+ tmpErr := company_approval.ApplyReceive(recodeInfo.CompanyId, recodeInfo.ProductId, opUser.AdminId, recodeInfo.CompanyApprovalId, recodeInfo.ApplyUserId, opUser.RealName, companyProduct.ProductName)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New("原销售申请领取流失客户失败,Err:" + tmpErr.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ case 5: //正式客户申请服务更新
|
|
|
+ //获取合同信息
|
|
|
+ contractInfo, tmpErr := company_contract.GetCompanyContractDetail(recodeInfo.CompanyId, recodeInfo.ProductId, recodeInfo.CompanyContractId)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New(fmt.Sprint("正式客户申请服务更新失败，待审批合同信息不存在,CompanyId：", recodeInfo.CompanyId, ";productId:", recodeInfo.ProductId, ";Err:"+tmpErr.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if contractInfo == nil {
|
|
|
+ err = errors.New(fmt.Sprint("正式客户申请服务更新失败，待审批合同信息不存在2,CompanyId：", recodeInfo.CompanyId, ";productId:", recodeInfo.ProductId))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //格式化合同开始时间
|
|
|
+ contractStartDate, tmpErr := time.Parse(utils.FormatDate, contractInfo.StartDate)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New(fmt.Sprint("正式客户申请服务更新失败，合同开始时间转换失败;Err:" + tmpErr.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //格式化合同结束日期
|
|
|
+ contractEndDate, tmpErr := time.Parse(utils.FormatDate, contractInfo.EndDate)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New(fmt.Sprint("正式客户申请服务更新失败，合同结束时间转换失败;Err:" + tmpErr.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //格式化 产品中 合同结束日期
|
|
|
+ //productContractEndDate, err := time.Parse(utils.FormatDate, companyProduct.ContractEndDate)
|
|
|
+ //if err != nil {
|
|
|
+ // br.Msg = "审批失败"
|
|
|
+ // br.ErrMsg = "产品中合同结束时间转换失败,Err:" + err.Error()
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
+ //如果合同时间小于等于今天，那么立马执行合同内容
|
|
|
+ if time.Now().After(contractStartDate) {
|
|
|
+ err = company_approval.ApplyServiceUpdate(recodeInfo.CompanyId, recodeInfo.ProductId, opUser.AdminId, recodeInfo.CompanyApprovalId, recodeInfo.CompanyContractId, companyProduct.StartDate, contractInfo.EndDate, opUser.RealName, companyProduct.ProductName)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New(fmt.Sprint("正式客户申请服务更新失败，执行失败;Err:" + tmpErr.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ tmpErr = company_approval.ApplyApproveContract(recodeInfo.CompanyId, recodeInfo.ProductId, recodeInfo.CompanyApprovalId, recodeInfo.CompanyContractId)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New(fmt.Sprint("正式客户申请服务更新失败，执行失败2;Err:" + tmpErr.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //如果合同中的结束日期大于产品中的合同结束日期，那么就去修改产品中的合同结束日期
|
|
|
+ if contractEndDate.After(companyProduct.ContractEndDate) {
|
|
|
+ companyProduct.ContractEndDate = contractEndDate
|
|
|
+ cols := make([]string, 0)
|
|
|
+ cols = append(cols, "ContractEndDate")
|
|
|
+ _ = companyProduct.Update(cols)
|
|
|
+ }
|
|
|
+ default:
|
|
|
+ err = errors.New(fmt.Sprint("无效的审批状态,CompanyId:", recodeInfo.CompanyId, ";productId:", recodeInfo.ProductId, ";ApplyMethod:", recodeInfo.ApplyMethod, ";ApproveStatus:", recodeInfo.ApproveStatus))
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //新增客户产品日志
|
|
|
+ {
|
|
|
+ productLog := new(company_product_log.CompanyProductLog)
|
|
|
+ productLog.CompanyProductId = companyProduct.CompanyProductId
|
|
|
+ productLog.CompanyId = companyProduct.CompanyId
|
|
|
+ productLog.ProductId = companyProduct.ProductId
|
|
|
+ productLog.ProductName = companyProduct.ProductName
|
|
|
+ productLog.CompanyName = companyProduct.CompanyName
|
|
|
+ productLog.CompanyName = companyProduct.CompanyName
|
|
|
+ productLog.Source = companyProduct.Source
|
|
|
+ productLog.Reasons = companyProduct.Reasons
|
|
|
+ productLog.Status = companyProduct.Status
|
|
|
+ productLog.IndustryId = companyProduct.IndustryId
|
|
|
+ productLog.IndustryName = companyProduct.IndustryName
|
|
|
+ productLog.SellerId = companyProduct.SellerId
|
|
|
+ productLog.SellerName = companyProduct.SellerName
|
|
|
+ productLog.GroupId = companyProduct.GroupId
|
|
|
+ productLog.DepartmentId = companyProduct.DepartmentId
|
|
|
+ productLog.IsSuspend = companyProduct.IsSuspend
|
|
|
+ productLog.SuspendTime = companyProduct.SuspendTime
|
|
|
+ productLog.ApproveStatus = companyProduct.ApproveStatus
|
|
|
+ productLog.FreezeTime = companyProduct.FreezeTime
|
|
|
+ productLog.Remark = companyProduct.Remark
|
|
|
+ productLog.StartDate = companyProduct.StartDate
|
|
|
+ productLog.EndDate = companyProduct.EndDate
|
|
|
+ productLog.CreateTime = companyProduct.CreateTime
|
|
|
+ productLog.ModifyTime = companyProduct.ModifyTime
|
|
|
+ productLog.LoseReason = companyProduct.LoseReason
|
|
|
+ productLog.LossTime = companyProduct.LossTime
|
|
|
+ productLog.LogType = "modify"
|
|
|
+ productLog.LogCreateTime = time.Now()
|
|
|
+ productLog.AdminId = opUserId
|
|
|
+ go company_product_log.AddCompanyProductLog(productLog)
|
|
|
+ }
|
|
|
+ //新增操作记录
|
|
|
+ {
|
|
|
+ remark := "审批"
|
|
|
+ operation := "approve"
|
|
|
+ approveContent := "审批通过"
|
|
|
+
|
|
|
+ services.AddCompanyOperationRecord(recodeInfo.CompanyId, companyProduct.SellerId, opUserId, recodeInfo.ProductId, opUserId, companyProduct.CompanyName,
|
|
|
+ companyProduct.ProductName, opUserName, remark, operation, approveContent, opUserName, "", companyProduct.Status)
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// afterReject 驳回完成后操作
|
|
|
+func afterReject(companyApprovalId, opUserId int, opUserName, remark string) (err error) {
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("异常提醒:"+utils.RunMode, "合同审批通过后，生成pdf失败，ERR:"+err.Error()+"", utils.EmailSendToUsers)
|
|
|
+ go utils.SendEmail("异常提醒:"+utils.RunMode, "合同审批通过后，生成pdf失败，ERR:"+err.Error()+"", utils.EmailSendToUsers)
|
|
|
+ }
|
|
|
+
|
|
|
+ }()
|
|
|
+ //获取客户单详情
|
|
|
+ recodeInfo, err := company_approval.GetCompanyApprovalByApprovalId(companyApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取合同信息失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if recodeInfo == nil {
|
|
|
+ err = errors.New("客户单异常，找不到客户单信息")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //获取客户信息
|
|
|
+ companyInfo, err := company.GetCompanyById(recodeInfo.CompanyId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取合同信息失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if companyInfo == nil {
|
|
|
+ err = errors.New("客户信息异常，找不到客户信息")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //客户产品信息
|
|
|
+ companyProduct, err := company_product.GetCompanyProductByCompanyIdAndProductId(recodeInfo.CompanyId, recodeInfo.ProductId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New(fmt.Sprint("获取信息客户产品失败", ";Err:"+err.Error()))
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if companyProduct == nil {
|
|
|
+ err = errors.New("获取信息客户产品失败2")
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ approveStatus := "驳回"
|
|
|
+ err = company_approval.ApproveRefuse(recodeInfo.CompanyId, recodeInfo.ProductId, approveStatus, remark)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("客户单审批驳回失败,Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //新增客户产品日志
|
|
|
+ {
|
|
|
+ productLog := new(company_product_log.CompanyProductLog)
|
|
|
+ productLog.CompanyProductId = companyProduct.CompanyProductId
|
|
|
+ productLog.CompanyId = companyProduct.CompanyId
|
|
|
+ productLog.ProductId = companyProduct.ProductId
|
|
|
+ productLog.ProductName = companyProduct.ProductName
|
|
|
+ productLog.CompanyName = companyProduct.CompanyName
|
|
|
+ productLog.CompanyName = companyProduct.CompanyName
|
|
|
+ productLog.Source = companyProduct.Source
|
|
|
+ productLog.Reasons = companyProduct.Reasons
|
|
|
+ productLog.Status = companyProduct.Status
|
|
|
+ productLog.IndustryId = companyProduct.IndustryId
|
|
|
+ productLog.IndustryName = companyProduct.IndustryName
|
|
|
+ productLog.SellerId = companyProduct.SellerId
|
|
|
+ productLog.SellerName = companyProduct.SellerName
|
|
|
+ productLog.GroupId = companyProduct.GroupId
|
|
|
+ productLog.DepartmentId = companyProduct.DepartmentId
|
|
|
+ productLog.IsSuspend = companyProduct.IsSuspend
|
|
|
+ productLog.SuspendTime = companyProduct.SuspendTime
|
|
|
+ productLog.ApproveStatus = companyProduct.ApproveStatus
|
|
|
+ productLog.FreezeTime = companyProduct.FreezeTime
|
|
|
+ productLog.Remark = companyProduct.Remark
|
|
|
+ productLog.StartDate = companyProduct.StartDate
|
|
|
+ productLog.EndDate = companyProduct.EndDate
|
|
|
+ productLog.CreateTime = companyProduct.CreateTime
|
|
|
+ productLog.ModifyTime = companyProduct.ModifyTime
|
|
|
+ productLog.LoseReason = companyProduct.LoseReason
|
|
|
+ productLog.LossTime = companyProduct.LossTime
|
|
|
+ productLog.LogType = "modify"
|
|
|
+ productLog.LogCreateTime = time.Now()
|
|
|
+ productLog.AdminId = opUserId
|
|
|
+ go company_product_log.AddCompanyProductLog(productLog)
|
|
|
+ }
|
|
|
+ //新增操作记录
|
|
|
+ {
|
|
|
+ remark := "审批"
|
|
|
+ operation := "approve"
|
|
|
+ approveContent := "审批驳回"
|
|
|
+
|
|
|
+ services.AddCompanyOperationRecord(recodeInfo.CompanyId, companyProduct.SellerId, opUserId, recodeInfo.ProductId, opUserId, companyProduct.CompanyName,
|
|
|
+ companyProduct.ProductName, opUserName, remark, operation, approveContent, opUserName, remark, companyProduct.Status)
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// CheckApproveAuth 校验审批操作权限
|
|
|
+func CheckApproveAuth(companyId, productId int, opUser *custom.AdminWx) (approvalItem *company_approval.CompanyApproval, approvalInfo *contract_approval.ContractApproval, approvalRecord *contract_approval_record.ContractApprovalRecord, err error) {
|
|
|
+ //客户单详情
|
|
|
+ approvalItem, err = company_approval.GetCompanyApprovalByCompanyId(companyId, productId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取客户单失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //客户单状态判断
|
|
|
+ if approvalItem.ApproveStatus != "待审批" {
|
|
|
+ err = errors.New("客户单状态异常，不允许操作申请，当前客户单状态：" + approvalItem.ApproveStatus)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //获取该最近一条审批单详情
|
|
|
+ approvalInfo, err = contract_approval.GetLastContractApprovalByContractId(approvalItem.CompanyApprovalId, "company")
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取审批单失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if approvalInfo.Status != "待审批" {
|
|
|
+ err = errors.New("当前审批单状态异常，不允许审批，审批单状态：" + approvalInfo.Status)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //审批流
|
|
|
+ approvalRecordList, err := contract_approval_record.GetContractApprovalRecordListByContractApprovalIdAndNodeId(approvalInfo.ContractApprovalId, approvalInfo.CurrNodeId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取审批失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, tmpApprovalRecord := range approvalRecordList {
|
|
|
+ if tmpApprovalRecord.NodeType == "check" && tmpApprovalRecord.ApproveUserId == opUser.AdminId {
|
|
|
+ approvalRecord = tmpApprovalRecord
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if approvalRecord == nil {
|
|
|
+ err = errors.New("当前账号没有审批权限")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+//获取审批流和权限
|
|
|
+func GetOpButton(approvalItem *company_approval.CompanyApprovalList, contractApprovalInfo *contract_approval.ContractApproval, opUser *custom.AdminWx) (flowNodeListResp [][]contract_approval_record.ContractApprovalRecord, err error) {
|
|
|
+ //审批流
|
|
|
+ approvalRecordList, err := contract_approval_record.GetContractApprovalRecordListByContractApprovalId(contractApprovalInfo.ContractApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取审批失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ flowNodeMap := make(map[int][]contract_approval_record.ContractApprovalRecord, 0)
|
|
|
+ keySort := make([]int, 0)
|
|
|
+ for _, approvalRecord := range approvalRecordList {
|
|
|
+ //如果当前节点正好是该节点，同时审批单状态是待审批状态，然后当前账号又有权限，该账号也正是审批人，那么允许审批操作
|
|
|
+ if contractApprovalInfo.CurrNodeId == approvalRecord.NodeId && contractApprovalInfo.Status == "待审批" {
|
|
|
+ if opUser.AdminId == approvalRecord.ApproveUserId && approvalRecord.NodeType == "check" {
|
|
|
+ approvalItem.OpButton = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //如果当前节点正好是该节点，同时审批单状态又是第一层节点
|
|
|
+ if contractApprovalInfo.CurrNodeId == approvalRecord.NodeId && approvalRecord.PrevNodeId == 0 && contractApprovalInfo.Status == "待审批" {
|
|
|
+ //发起人具有撤回审批单权限
|
|
|
+ //if opUser.AdminId == sealInfo.UserId {
|
|
|
+ // sealOpButton.Cancel = true
|
|
|
+ //}
|
|
|
+ }
|
|
|
+ if tmpFlowNodeList, ok := flowNodeMap[approvalRecord.NodeId]; ok {
|
|
|
+ flowNodeMap[approvalRecord.NodeId] = append(tmpFlowNodeList, *approvalRecord)
|
|
|
+ } else {
|
|
|
+ tmpFlowNodeList := make([]contract_approval_record.ContractApprovalRecord, 1)
|
|
|
+ tmpFlowNodeList[0] = *approvalRecord
|
|
|
+ flowNodeMap[approvalRecord.NodeId] = tmpFlowNodeList
|
|
|
+
|
|
|
+ keySort = append(keySort, approvalRecord.NodeId)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ for _, key := range keySort {
|
|
|
+ flowNodeListResp = append(flowNodeListResp, flowNodeMap[key])
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// GetApprovalDetailByCompanyApprovalId 根据客户单id获取客户单审批详情
|
|
|
+func GetApprovalDetailByCompanyApprovalId(companyApprovalId int, opUser *custom.AdminWx) (approvalItem *company_approval.CompanyApprovalList, flowNodeListResp [][]contract_approval_record.ContractApprovalRecord, err error) {
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ approvalItem, err = company_approval.GetApprovalListByApprovalId(condition, pars, companyApprovalId)
|
|
|
+ if err != nil {
|
|
|
+ err = errors.New("获取客户单详情失败,ERR:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if approvalItem.FreezeStartDate != "" && approvalItem.FreezeEndDate != "" && approvalItem.Status == utils.COMPANY_STATUS_FREEZE {
|
|
|
+ freezeEndDate, _ := time.Parse(utils.FormatDate, approvalItem.FreezeEndDate)
|
|
|
+ if time.Now().Before(freezeEndDate) {
|
|
|
+ expireDays := freezeEndDate.Sub(time.Now()).Hours() / 24
|
|
|
+ approvalItem.FreezeExpireDays = int(expireDays)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if approvalItem.StartDate != "" && approvalItem.EndDate != "" {
|
|
|
+ endDate, _ := time.Parse(utils.FormatDate, approvalItem.EndDate)
|
|
|
+ if time.Now().Before(endDate) {
|
|
|
+ expireDays := endDate.Sub(time.Now()).Hours() / 24
|
|
|
+ approvalItem.ExpireDay = int(expireDays)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ approvalCount, err := company_approval.GetCompanyApprovalCount(approvalItem.CompanyId, approvalItem.ProductId)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ err = errors.New("获取延期审批次数失败，Err:" + err.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ approvalItem.ApprovalCount = approvalCount
|
|
|
+
|
|
|
+ //查询最近一次审批单信息
|
|
|
+ lastApprovalInfo, err := contract_approval.GetLastContractApprovalByContractId(approvalItem.CompanyApprovalId, "company")
|
|
|
+ if err != nil {
|
|
|
+ if err.Error() != utils.ErrNoRow() {
|
|
|
+ err = errors.New("获取最近一次审批单信息失败,ERR:" + err.Error())
|
|
|
+ }
|
|
|
+ err = nil
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if lastApprovalInfo != nil {
|
|
|
+ //获取审批操作和审批流数据
|
|
|
+ tmpFlowNodeListResp, tmpErr := GetOpButton(approvalItem, lastApprovalInfo, opUser)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = errors.New("获取客户单按钮权限、审批流程失败，Err:" + tmpErr.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ flowNodeListResp = tmpFlowNodeListResp
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
