eta_api/services/report_approve.go

package services

import (
	"eta_gn/eta_api/models"
	"eta_gn/eta_api/models/report_approve"
	"eta_gn/eta_api/services/alarm_msg"
	"eta_gn/eta_api/utils"
	"fmt"
	"sort"
	"time"
)

func GetReportClassifyTreeRecursive(list []*models.Classify, parentId int) []*report_approve.ReportClassifyTreeItem {
	res := make([]*report_approve.ReportClassifyTreeItem, 0)
	for _, v := range list {
		if v.ParentId == parentId {
			t := new(report_approve.ReportClassifyTreeItem)
			t.ClassifyId = v.Id
			t.ClassifyName = v.ClassifyName
			t.ParentId = v.ParentId
			t.Children = GetReportClassifyTreeRecursive(list, v.Id)
			res = append(res, t)
		}
	}
	return res
}

func CheckReportApproveFlowChange(reportType, classifyFirstId, classifySecondId, classifyThirdId int) (ok bool, err error) {
	var count int
	cond := ` AND classify_id_first = ? AND classify_id_second = ? AND state = ?`
	pars := make([]interface{}, 0)
	pars = append(pars, classifyFirstId, classifySecondId, models.ReportStateWaitApprove)
	switch reportType {
	case report_approve.FlowReportTypeChinese:
		cond += ` AND classify_id_third = ?  `
		pars = append(pars, classifyThirdId)
		ct, e := models.GetReportListCount(cond, pars)
		if e != nil {
			err = fmt.Errorf("GetReportListCount err: %s", e.Error())
			return
		}
		count = ct
	default:
		err = fmt.Errorf("报告类型有误")
		return
	}
	if count <= 0 {
		ok = true
	}
	return
}

func CheckReportOpenApprove(reportType, firstId, secondId, thirdId 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.BusinessConfIsReportApprove]]

	flowOb := new(report_approve.ReportApproveFlow)
	flowCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s = ? AND %s = ?`, report_approve.ReportApproveFlowCols.ReportType, report_approve.ReportApproveFlowCols.ClassifyFirstId, report_approve.ReportApproveFlowCols.ClassifySecondId, report_approve.ReportApproveFlowCols.ClassifyThirdId)
	flowPars := make([]interface{}, 0)
	flowPars = append(flowPars, reportType, firstId, secondId, thirdId)
	flowItem, e := flowOb.GetItemByCondition(flowCond, flowPars, "")
	if e != nil && !utils.IsErrNoRow(e) {
		err = fmt.Errorf("ApproveFlow GetItemByCondition err: %s", e.Error())
		return
	}

	var hasFlow bool
	if flowItem != nil && flowItem.ReportApproveFlowId > 0 {
		hasFlow = true
	}

	if openApprove && (hasFlow || confMap[models.BusinessConfReportApproveType] == models.BusinessConfReportApproveTypeOther) {
		opening = true
		return
	}
	return
}

func CheckReportCurrState(reportType, firstId, secondId, thirdId, 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.BusinessConfIsReportApprove]]

	flowOb := new(report_approve.ReportApproveFlow)
	flowCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s = ? AND %s = ?`, report_approve.ReportApproveFlowCols.ReportType, report_approve.ReportApproveFlowCols.ClassifyFirstId, report_approve.ReportApproveFlowCols.ClassifySecondId, report_approve.ReportApproveFlowCols.ClassifyThirdId)
	flowPars := make([]interface{}, 0)
	flowPars = append(flowPars, reportType, firstId, secondId, thirdId)
	flowItem, e := flowOb.GetItemByCondition(flowCond, flowPars, "")
	if e != nil && !utils.IsErrNoRow(e) {
		err = fmt.Errorf("ApproveFlow GetItemByCondition err: %s", e.Error())
		return
	}

	var hasFlowItem bool
	if flowItem != nil && flowItem.ReportApproveFlowId > 0 {
		hasFlowItem = true
	}

	if openApprove && (hasFlowItem || confMap[models.BusinessConfReportApproveType] == models.BusinessConfReportApproveTypeOther) {
		stateMap := map[int]int{
			models.ReportOperateAdd:           models.ReportStateWaitSubmit,  // 新增
			models.ReportOperateEdit:          models.ReportStateWaitSubmit,  // 编辑
			models.ReportOperatePublish:       models.ReportStateWaitSubmit,  // 发布
			models.ReportOperateCancelPublish: models.ReportStateWaitSubmit,  // 取消发布
			models.ReportOperateSubmitApprove: models.ReportStateWaitApprove, // 提审
			models.ReportOperateCancelApprove: models.ReportStateWaitSubmit,  // 撤回
		}
		state = stateMap[operate]
		return
	}

	stateMap := map[int]int{
		models.ReportOperateAdd:           models.ReportStateUnpublished, // 新增
		models.ReportOperateEdit:          models.ReportStateUnpublished, // 编辑
		models.ReportOperatePublish:       models.ReportStatePublished,   // 发布
		models.ReportOperateCancelPublish: models.ReportStateUnpublished, // 取消发布
		models.ReportOperateSubmitApprove: models.ReportStateUnpublished, // 提审
		models.ReportOperateCancelApprove: models.ReportStateUnpublished, // 撤回
	}
	state = stateMap[operate]
	return
}

func SubmitReportApprove(reportType, reportId int, reportTitle string, firstId, secondId, thirdId 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.BusinessConfIsReportApprove]]
	if !openApprove {
		err = fmt.Errorf("未开启审批")
		return
	}
	confApproveType := confMap[models.BusinessConfReportApproveType]
	if confApproveType == "" {
		confApproveType = models.BusinessConfReportApproveTypeEta
	}
	if confApproveType == models.BusinessConfReportApproveTypeOther {
		return
	}

	flowOb := new(report_approve.ReportApproveFlow)
	flowCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s = ? AND %s = ?`, report_approve.ReportApproveFlowCols.ReportType, report_approve.ReportApproveFlowCols.ClassifyFirstId, report_approve.ReportApproveFlowCols.ClassifySecondId, report_approve.ReportApproveFlowCols.ClassifyThirdId)
	flowPars := make([]interface{}, 0)
	flowPars = append(flowPars, reportType, firstId, secondId, thirdId)
	flowItem, e := flowOb.GetItemByCondition(flowCond, flowPars, "")
	if e != nil {
		err = fmt.Errorf("ApproveFlow GetItemByCondition err: %s", e.Error())
		return
	}

	nodeOb := new(report_approve.ReportApproveNode)
	nodeCond := fmt.Sprintf(` AND %s = ? AND %s = ?`, report_approve.ReportApproveNodeCols.ReportApproveFlowId, report_approve.ReportApproveNodeCols.CurrVersion)
	nodePars := make([]interface{}, 0)
	nodePars = append(nodePars, flowItem.ReportApproveFlowId, 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(report_approve.ReportApproveNode)
	for _, v := range nodeItems {
		if v.PrevNodeId == 0 {
			firstNodeItem = v
			continue
		}
	}
	if firstNodeItem == nil {
		err = fmt.Errorf("首个审批节点有误")
		return
	}

	now := time.Now().Local()
	newApprove := new(report_approve.ReportApprove)
	newApprove.ReportType = reportType
	newApprove.ReportId = reportId
	newApprove.ReportTitle = reportTitle
	newApprove.ClassifyFirstId = firstId
	newApprove.ClassifySecondId = secondId
	newApprove.ClassifyThirdId = thirdId
	newApprove.State = report_approve.ReportApproveStateApproving
	newApprove.FlowId = flowItem.ReportApproveFlowId
	newApprove.FlowVersion = flowItem.CurrVersion
	newApprove.StartNodeId = firstNodeItem.ReportApproveNodeId
	newApprove.CurrNodeId = firstNodeItem.ReportApproveNodeId
	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.ReportApproveId

	err = BuildNextNodeRecordAndMsg(firstNodeItem, newApprove.ReportApproveId, sysAdminId, sysAdminName)
	return
}

func CancelReportApprove(reportType, reportId, 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.BusinessConfIsReportApprove]]
	if !openApprove {
		return
	}
	confApproveType := confMap[models.BusinessConfReportApproveType]
	if confApproveType == "" {
		confApproveType = models.BusinessConfReportApproveTypeEta
	}
	if confApproveType == models.BusinessConfReportApproveTypeOther {
		e = updateReportApproveState(reportType, reportId, 0, models.ReportStateWaitSubmit)
		if e != nil {
			err = fmt.Errorf("更新报告审批撤回失败, Err: %s", e.Error())
			return
		}
		return
	}

	approveOb := new(report_approve.ReportApprove)
	approveItem, e := approveOb.GetItemById(approveId)
	if e != nil {
		if utils.IsErrNoRow(e) {
			return
		}
		err = fmt.Errorf("approve GetItemById err: %s", e.Error())
		return
	}
	if approveItem.State == report_approve.ReportApproveStateCancel {
		return
	}
	approveItem.State = report_approve.ReportApproveStateCancel
	cols := []string{"State", "ModifyTime"}
	if e = approveItem.Update(cols); e != nil {
		err = fmt.Errorf("approve Update err: %s", e.Error())
		return
	}

	e = updateReportApproveState(reportType, reportId, 0, models.ReportStateWaitSubmit)
	if e != nil {
		err = fmt.Errorf("更新报告审批撤回失败, Err: %s", e.Error())
		return
	}

	go func() {
		recordOb := new(report_approve.ReportApproveRecord)
		recordCond := fmt.Sprintf(` AND %s = ?`, report_approve.ReportApproveRecordCols.ReportApproveId)
		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(report_approve.ReportApproveMessage)
		messages := make([]*report_approve.ReportApproveMessage, 0)
		for _, v := range recordItems {
			m := new(report_approve.ReportApproveMessage)
			m.SendUserId = sysAdminId
			m.ReceiveUserId = v.ApproveUserId
			m.Content = fmt.Sprintf("%s提交的【研报审批】已撤回", sysAdminName)
			m.ReportApproveId = approveId
			m.ApproveState = report_approve.ReportApproveStateCancel
			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("CancelReportApprove messages err: %s", e.Error()))
			return
		}
	}()
	return
}

func updateReportApproveState(reportType, reportId, approveId, state int) (err error) {
	updateCols := []string{"ApproveId", "State", "ModifyTime"}
	reportOb := new(models.Report)
	reportItem, e := reportOb.GetItemById(reportId)
	if e != nil && !utils.IsErrNoRow(e) {
		err = fmt.Errorf("获取中文研报失败, Err: %s", e.Error())
		return
	}
	if reportItem != nil {
		reportItem.ApproveId = approveId
		reportItem.State = state
		reportItem.ModifyTime = time.Now().Local()
		if state == models.ReportStatePass || state == models.ReportStateRefused {
			updateCols = append(updateCols, "ApproveTime")
			reportItem.ApproveTime = time.Now().Local()
		}
		if state == models.ReportStatePass {
			updateCols = append(updateCols, "PublishTime")
			reportItem.PublishTime = time.Now().Local()
		}
		if e = reportItem.UpdateReport(updateCols); e != nil {
			err = fmt.Errorf("更新中文研报审批状态失败, Err: %s", e.Error())
			return
		}
	}

	return
}

func PassReportApprove(approveItem *report_approve.ReportApprove, recordItem *report_approve.ReportApproveRecord, sysAdminId int, reportUrl string) (tips string, err error) {
	if approveItem == nil {
		err = fmt.Errorf("审批信息有误")
		return
	}
	if recordItem == nil {
		err = fmt.Errorf("审批记录有误")
		return
	}

	flowOb := new(report_approve.ReportApproveFlow)
	flowItem, e := flowOb.GetItemById(approveItem.FlowId)
	if e != nil {
		err = fmt.Errorf("获取审批流失败, Err: %s", e.Error())
		return
	}
	nodeOb := new(report_approve.ReportApproveNode)
	nodeCond := fmt.Sprintf(` AND %s = ? AND %s = ?`, report_approve.ReportApproveNodeCols.ReportApproveFlowId, report_approve.ReportApproveNodeCols.CurrVersion)
	nodePars := make([]interface{}, 0)
	nodePars = append(nodePars, flowItem.ReportApproveFlowId, 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
	}
	nodeMap := make(map[int]*report_approve.ReportApproveNode)
	for _, v := range nodeItems {
		nodeMap[v.ReportApproveNodeId] = v
	}

	currNodeItem := nodeMap[recordItem.NodeId]
	if currNodeItem == nil {
		err = fmt.Errorf("当前节点信息有误")
		return
	}
	currNode, e := report_approve.FormatReportApproveNode2Item(currNodeItem)
	if e != nil {
		err = fmt.Errorf("当前节点信息有误, Err: %s", e.Error())
		return
	}
	now := time.Now().Local()
	recordItem.State = report_approve.ReportApproveStatePass
	recordItem.ApproveTime = now
	recordItem.ModifyTime = now
	recordItem.NodeState = report_approve.ReportApproveStatePass
	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 == report_approve.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)
		nextUser := new(report_approve.ReportApproveNodeUserReq) // 下一个审批人, 为nil则表示当前审批人即为最后
		for k, v := range currNode.Users {
			if v.UserId == sysAdminId && recordItem.ApproveUserSort == v.Sort {
				if (k + 1) < userLen {
					nextUser = currNode.Users[k+1]
				}
			}
		}

		if nextUser.UserId > 0 {
			newRecord := new(report_approve.ReportApproveRecord)
			newRecord.ReportApproveId = recordItem.ReportApproveId
			newRecord.State = report_approve.ReportApproveStateApproving
			newRecord.NodeId = currNode.ReportApproveNodeId
			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 = report_approve.ReportApproveStateApproving
			if e = newRecord.Create(); e != nil {
				err = fmt.Errorf("生成审批记录失败, Err: %s", e.Error())
				return
			}

			go func() {
				messageItem := new(report_approve.ReportApproveMessage)
				messageItem.SendUserId = approveItem.ApplyUserId
				messageItem.ReceiveUserId = nextUser.UserId
				messageItem.Content = "您有新的待办任务"
				messageItem.Remark = fmt.Sprintf("%s提交的【研报审批】需要您审批，请及时处理", approveItem.ApplyUserName)
				messageItem.ReportApproveId = approveItem.ReportApproveId
				messageItem.ApproveState = report_approve.ReportApproveStateApproving
				messageItem.CreateTime = now
				messageItem.ModifyTime = now
				if e = messageItem.Create(); e != nil {
					utils.FileLog.Info(fmt.Sprintf("PassReportApprove 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.ReportApproveId, approveItem.ApplyUserId, approveItem.ApplyUserName)
			return
		} else {
			lastApprove = true
		}
	}

	if currNode.ApproveType == report_approve.NodeApproveTypeAll {
		otherOb := new(report_approve.ReportApproveRecord)
		otherCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s <> ?`, report_approve.ReportApproveRecordCols.ReportApproveId, report_approve.ReportApproveRecordCols.NodeId, report_approve.ReportApproveRecordCols.ApproveUserId)
		otherPars := make([]interface{}, 0)
		otherPars = append(otherPars, approveItem.ReportApproveId, recordItem.NodeId, sysAdminId)
		otherRecords, e := otherOb.GetItemsByCondition(otherCond, otherPars, []string{}, "")
		if e != nil {
			err = fmt.Errorf("获取节点审批记录失败, Err: %s", e.Error())
			return
		}
		otherPass := true
		for _, v := range otherRecords {
			if v.State != report_approve.ReportApproveStatePass {
				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.ReportApproveId, approveItem.ApplyUserId, approveItem.ApplyUserName)
			return
		}
	}

	if currNode.ApproveType == report_approve.NodeApproveTypeAny {
		if approveItem.CurrNodeId != recordItem.NodeId {
			tips = "该节点已完成审批, 请刷新页面"
			return
		}

		if e = recordItem.Update(recordCols); e != nil {
			err = fmt.Errorf("更新审批记录状态失败, Err: %s", e.Error())
			return
		}

		if e = recordItem.UpdateNodeState(recordItem.ReportApproveId, 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.ReportApproveId, approveItem.ApplyUserId, approveItem.ApplyUserName)
			return
		}
	}

	if lastApprove {
		if e = recordItem.Update(recordCols); e != nil {
			err = fmt.Errorf("更新审批记录状态失败, Err: %s", e.Error())
			return
		}
		approveItem.State = report_approve.ReportApproveStatePass
		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 = updateReportApproveState(approveItem.ReportType, approveItem.ReportId, approveItem.ReportApproveId, models.ReportStatePass); e != nil {
			err = fmt.Errorf("更新报告审批状态失败, Err: %s", e.Error())
			return
		}

		go func() {
			messageItem := new(report_approve.ReportApproveMessage)
			messageItem.SendUserId = sysAdminId
			messageItem.ReceiveUserId = approveItem.ApplyUserId
			messageItem.Content = "您提交的审批已通过"
			messageItem.Remark = "您提交的【研报审批】已通过"
			messageItem.ReportApproveId = approveItem.ReportApproveId
			messageItem.ApproveState = report_approve.ReportApproveStatePass
			messageItem.CreateTime = now
			messageItem.ModifyTime = now
			if e = messageItem.Create(); e != nil {
				utils.FileLog.Info(fmt.Sprintf("PassReportApprove message err: %s", e.Error()))
				return
			}
		}()

		go func() {
			if e = AfterReportApprovePass(approveItem.ReportType, approveItem.ReportId); e != nil {
				utils.FileLog.Info(fmt.Sprintf("AfterReportApprovePass err: %s, ReportType: %d, ReportId: %d", e.Error(), approveItem.ReportType, approveItem.ReportId))
				return
			}
		}()
	}
	return
}

func RefuseReportApprove(approveItem *report_approve.ReportApprove, recordItem *report_approve.ReportApproveRecord, 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 = report_approve.ReportApproveStateRefuse
	recordItem.ApproveRemark = approveRemark
	recordItem.ApproveTime = now
	recordItem.ModifyTime = now

	recordItem.NodeState = report_approve.ReportApproveStateRefuse
	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.ReportApproveId, recordItem.NodeId, recordItem.NodeState, recordItem.NodeApproveUserId, recordItem.NodeApproveUserName, recordItem.NodeApproveTime); e != nil {
		err = fmt.Errorf("更新同一节点的其他审批记录状态失败, Err: %s", e.Error())
		return
	}

	approveItem.State = report_approve.ReportApproveStateRefuse
	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 := updateReportApproveState(approveItem.ReportType, approveItem.ReportId, approveItem.ReportApproveId, models.ReportStateRefused); e != nil {
		err = fmt.Errorf("更新报告状态失败, Err: %s", e.Error())
		return
	}

	go func() {
		messageItem := new(report_approve.ReportApproveMessage)
		messageItem.SendUserId = sysAdminId
		messageItem.ReceiveUserId = approveItem.ApplyUserId
		messageItem.Content = "您提交的审批被驳回"
		messageItem.Remark = "您提交的【研报审批】已被驳回"
		messageItem.ReportApproveId = approveItem.ReportApproveId
		messageItem.ApproveState = report_approve.ReportApproveStateRefuse
		messageItem.CreateTime = now
		messageItem.ModifyTime = now
		if e := messageItem.Create(); e != nil {
			utils.FileLog.Info(fmt.Sprintf("ApproveReport message err: %s", e.Error()))
			return
		}
	}()
	return
}

func BuildNextNodeRecordAndMsg(approveNodeItem *report_approve.ReportApproveNode, approveId, sysAdminId int, sysAdminName string) (err error) {
	if approveNodeItem == nil {
		err = fmt.Errorf("approve node nil")
		return
	}

	now := time.Now().Local()
	approveNode, e := report_approve.FormatReportApproveNode2Item(approveNodeItem)
	if e != nil {
		err = fmt.Errorf("FormatReportApproveNode2Item err: %s", e.Error())
		return
	}
	if len(approveNode.Users) == 0 {
		err = fmt.Errorf("审批节点用户有误")
		return
	}
	newRecords := make([]*report_approve.ReportApproveRecord, 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(report_approve.ReportApproveRecord)
		r.ReportApproveId = approveId
		r.State = report_approve.ReportApproveStateApproving
		r.NodeId = approveNode.ReportApproveNodeId
		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 = report_approve.ReportApproveStateApproving // 当前节点审批状态
		newRecords = append(newRecords, r)
		if approveNode.ApproveType == report_approve.NodeApproveTypeRoll {
			break
		}
	}

	recordOb := new(report_approve.ReportApproveRecord)
	if e = recordOb.CreateMulti(newRecords); e != nil {
		err = fmt.Errorf("生成节点审批记录失败, Err: %s", e.Error())
		return
	}

	go func() {
		messageOb := new(report_approve.ReportApproveMessage)
		messages := make([]*report_approve.ReportApproveMessage, 0)
		for _, v := range newRecords {
			m := new(report_approve.ReportApproveMessage)
			m.SendUserId = sysAdminId
			m.ReceiveUserId = v.ApproveUserId
			m.Content = "您有新的待办任务"
			m.Remark = fmt.Sprintf("%s提交的【研报审批】需要您审批，请及时处理", sysAdminName)
			m.ReportApproveId = approveId
			m.ApproveState = report_approve.ReportApproveStateApproving
			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
}

func AfterReportApprovePass(reportType, reportId int) (err error) {
	reportInfo, e := models.GetReportByReportId(reportId)
	if e != nil {
		if utils.IsErrNoRow(e) {
			return
		}
		err = fmt.Errorf("获取研报信息失败, Err: %s", e.Error())
		return
	}
	go UpdateReportVideo(reportInfo)

	{
		reportPdfUrl := GetGeneralPdfUrl(reportInfo.ReportCode, reportInfo.ClassifyNameFirst, reportInfo.ReportLayout)
		go Report2pdfAndJpeg(reportPdfUrl, reportId, 1)
	}

	_ = UpdateReportEs(reportInfo.Id, models.ReportStatePublished)

	return
}

func CheckCloseReportApproveConf() (yes bool, err error) {
	count, e := models.GetReportStateCount(models.ReportStateWaitApprove)
	if e != nil {
		err = fmt.Errorf("查询审批中的报告数量失败, Err: %s", e.Error())
		return
	}
	if count > 0 {
		return
	}
	yes = true

	return
}

func FlowOperateResetReportState(reportType, classifyFirstId, classifySecondId, classifyThirdId, oldState, State int) (err error) {
	defer func() {
		if err != nil {
			tips := fmt.Sprintf("审批流变化-重置报告初始状态失败, ErrMsg: %s", err.Error())
			utils.FileLog.Info(tips)
			go alarm_msg.SendAlarmMsg(tips, 2)
		}
	}()

	e := models.UpdateReportsStateByCond(classifyFirstId, classifySecondId, classifyThirdId, oldState, State)
	if e != nil {
		err = fmt.Errorf("UpdateReportsStateByCond err: %s", e.Error())
	}

	return
}

func ConfigChangeResetReportState(changeType string) (err error) {
	defer func() {
		if err != nil {
			tips := fmt.Sprintf("审批配置变化-重置报告初始状态失败, ErrMsg: %s", err.Error())
			utils.FileLog.Info(tips)
			go alarm_msg.SendAlarmMsg(tips, 2)
		}
	}()

	if changeType == "" {
		e := models.UpdateReportsStateByCond(0, 0, 0, models.ReportStateWaitSubmit, models.ReportStateUnpublished)
		if e != nil {
			err = fmt.Errorf("UpdateReportsStateByCond err: %s", e.Error())
		}
		return
	}

	if changeType == models.BusinessConfReportApproveTypeEta {
		flowOb := new(report_approve.ReportApproveFlow)
		flows, e := flowOb.GetItemsByCondition(``, make([]interface{}, 0), []string{}, "")
		if e != nil {
			err = fmt.Errorf("GetApproveFlows err: %s", e.Error())
			return
		}
		reportSecondIds := make([]int, 0)
		for _, v := range flows {
			reportSecondIds = append(reportSecondIds, v.ClassifySecondId)
		}
		if len(reportSecondIds) > 0 {
			e = models.UpdateReportsStateBySecondIds(models.ReportStateUnpublished, models.ReportStateWaitSubmit, reportSecondIds)
			if e != nil {
				err = fmt.Errorf("UpdateReportsStateBySecondIds err: %s", e.Error())
				return
			}
		}

		return
	}

	if changeType == models.BusinessConfReportApproveTypeOther {
		e := models.UpdateReportsStateByCond(0, 0, 0, models.ReportStateUnpublished, models.ReportStateWaitSubmit)
		if e != nil {
			err = fmt.Errorf("UpdateReportsStateByCond err: %s", e.Error())
		}
		return
	}
	return
}