hongze_mobile_admin/models/tables/contract_approval/contract_approval.go

package contract_approval

import (
	"github.com/beego/beego/v2/client/orm"
	"hongze/hongze_mobile_admin/models/tables/contract"
	"hongze/hongze_mobile_admin/models/tables/contract_approval_record"
	"hongze/hongze_mobile_admin/utils"
	"time"
)

//合同审批单
type ContractApproval struct {
	ContractApprovalId int       `orm:"column(contract_approval_id);pk"`
	ApprovalType       string    `description:"审批单类型，枚举值，合同：contract；用印：seal；默认：contract"`
	ContractId         int       `orm:"column(contract_id)" description:"合同id"`
	Status             string    `description:"审批单状态，枚举值：待审批','已审批','已驳回','已撤回'，默认待审批"`
	ApplyContent       string    `description:"待审内容，长度255位"`
	ContractDetail     string    `description:"审批单详情，完整的合同json数据"`
	ApplyUserId        int       `description:"申请人id"`
	ApplyUserName      string    `description:"申请人名称"`
	ApproveRemark      string    `description:"审批人备注，可以是驳回理由，长度128位"`
	FlowId             int       `description:"审批流程id"`
	FlowVersion        int       `description:"审批流程版本"`
	CurrNodeId         int       `description:"当前审批节点id"`
	StartNodeId        int       `description:"开始审批节点id"`
	ModifyTime         time.Time `description:"发起申请时间"`
	CreateTime         time.Time `description:"最近一次审批单修改时间"`
}

//根据合同审批单id获取合同审批单信息
func GetContractApprovalById(contractApprovalId int) (contractApprovalInfo *ContractApproval, err error) {
	o := orm.NewOrm()
	sql := `select * from contract_approval where contract_approval_id = ? `
	err = o.Raw(sql, contractApprovalId).QueryRow(&contractApprovalInfo)
	return
}

//根据合同id获取最近一次待审批的合同审批单信息
func GetLastPendingContractApprovalByContractId(contractId int) (contractApprovalInfo *ContractApproval, err error) {
	o := orm.NewOrm()
	sql := `select * from contract_approval where status = "待审批" AND contract_id=? order by contract_approval_id desc`
	err = o.Raw(sql, contractId).QueryRow(&contractApprovalInfo)
	return
}

//根据合同id获取最近一次提交的合同审批单信息
func GetLastContractApprovalByContractId(contractId int, approvalType string) (contractApprovalInfo *ContractApproval, err error) {
	o := orm.NewOrm()
	sql := `select * from contract_approval where contract_id=? and approval_type =? order by contract_approval_id desc`
	err = o.Raw(sql, contractId, approvalType).QueryRow(&contractApprovalInfo)
	return
}

//根据合同id获取总共被驳回的次数
func GetRejectContractCountByContractId(contractId int) (total int64, err error) {
	o := orm.NewOrm()
	sql := `select count(1) total from contract_approval where status = "已驳回" AND contract_id=? `
	err = o.Raw(sql, contractId).QueryRow(&total)
	return
}

//获取合同审批列表数据数量
func GetContractApprovalListCount(childCondition, condition, joinCondition string, childPars, pars []interface{}) (count int, err error) {
	o := orm.NewOrm()
	sql := `
SELECT
a.contract_approval_id,a.contract_id,a.apply_content,a.contract_detail,a.approve_remark,a.create_time,a.modify_time,a.status approve_status,c.status,c.product_id,
c.contract_type,c.start_date,c.end_date,c.price,c.company_name,c.seller_id,c.seller_name,c.file_url,c.contract_code from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="contract" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN contract c ON a.contract_id = c.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
WHERE c.is_delete = 0  AND a.approval_type="contract" `
	sql += condition
	sql += ` group by contract_id `

	sql = `select count(*) count from (` + sql + `) g`
	err = o.Raw(sql, childPars, pars).QueryRow(&count)
	return
}

//合同审批列表
type ContractApprovalList struct {
	ContractApprovalId       int                     `description:"审批单id"`
	ContractId               int                     `description:"合同id"`
	ContractApprovalRecordId int                     `description:"审批流id"`
	ContractCode             string                  `description:"合同编号"`
	Status                   string                  `description:"合同状态，枚举值：待审批','已审批','已驳回','已撤回'，默认待审批"`
	ApproveStatus            string                  `json:"-" description:"审批单状态，枚举值：待审批','已审批','已驳回','已撤回'，默认待审批"`
	ApplyContent             string                  `description:"待审内容"`
	ContractDetail           string                  `json:"-" description:"提交审批时的合同信息；合同快照"`
	ContractInfo             contract.ContractDetail `json:"-" description:"提交审批时的合同信息；合同快照"`
	ApproveRemark            string                  `description:"审核备注"`
	ContractBusinessType     string                  `description:"合同业务类型，枚举值：'业务合同','代付合同'"`
	ContractType             string                  `description:"合同类型"`
	Price                    float64                 `description:"合同金额"`
	CompanyName              string                  `description:"客户名称"`
	CreditCode               string                  `description:"社会统一信用代码,长度64位"`
	FileUrl                  string                  `description:"合同下载地址"`
	SellerId                 int                     `description:"销售id"`
	ProductId                int                     `description:"产品id，1：ficc；2：权益"`
	SellerName               string                  `description:"销售名称"`
	StartDate                time.Time               `description:"合同开始日期"`
	EndDate                  time.Time               `description:"合同结束日期"`
	CreateTime               time.Time               `description:"发起审批的时间"`
	ModifyTime               time.Time               `description:"最后一次修改的时间"`
	ApproveTime              time.Time               `description:"审批时间"`
	InvalidTime              time.Time               `description:"作废时间"`
	CheckBackFileTime        time.Time               `description:"合同签回时间"`
	RescindTime              time.Time               `description:"解约时间"`
	StartDateStr             string                  `description:"合同开始日期(字符串类型)"`
	EndDateStr               string                  `description:"合同结束日期(字符串类型)"`
	CreateTimeStr            string                  `description:"发起审批的时间(字符串类型)"`
	ModifyTimeStr            string                  `description:"最后一次修改的时间(字符串类型)"`
	ApproveTimeStr           string                  `description:"审批时间（字符串类型）"`
	InvalidTimeStr           string                  `description:"作废时间（字符串类型）"`
	CheckBackFileTimeStr     string                  `description:"合同签回时间（字符串类型）"`
	RescindTimeStr           string                  `description:"解约时间（字符串类型）"`
}

// GetContractApprovalList 获取合同审批列表数据
func GetContractApprovalList(childCondition, condition, joinCondition string, childPars, pars []interface{}, startSize, pageSize int) (list []*ContractApprovalList, err error) {
	o := orm.NewOrm()
	sql := `
SELECT
a.contract_approval_id,d.contract_approval_record_id,a.contract_id,a.apply_content,a.approve_remark,a.create_time,a.modify_time,a.status approve_status,c.status,c.product_id,
c.contract_type,c.start_date,c.end_date,c.price,c.company_name,c.credit_code,c.seller_id,c.seller_name,c.file_url,c.contract_code,c.approve_time,c.invalid_time,c.check_back_file_time,c.rescind_time,c.contract_business_type from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="contract" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN contract c ON a.contract_id = c.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
WHERE c.is_delete = 0  AND a.approval_type="contract" `
	sql += condition
	sql += ` group by contract_id order by modify_time desc LIMIT ?,? `
	_, err = o.Raw(sql, childPars, pars, startSize, pageSize).QueryRows(&list)
	return
}

// GetContractApprovalListCountV2 获取审批后的数据（待审批、处理中的）
func GetContractApprovalListCountV2(childCondition, condition string, childPars, pars []interface{}) (count int, err error) {
	o := orm.NewOrm()
	sql := `
SELECT
a.contract_approval_id,a.contract_id,a.apply_content,a.contract_detail,a.approve_remark,a.create_time,a.modify_time,a.status approve_status,c.status,c.product_id,
c.contract_type,c.start_date,c.end_date,c.price,c.company_name,c.seller_id,c.seller_name,c.file_url,c.contract_code from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="contract" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN contract c ON a.contract_id = c.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
WHERE c.is_delete = 0  AND a.approval_type="contract" `
	sql += condition
	sql += ` group by contract_id `

	sql = `select count(*) count from (` + sql + `) g`
	err = o.Raw(sql, childPars, pars).QueryRow(&count)
	return
}

// GetContractApprovalListV2 获取审批后的数据（待审批、处理中的）
func GetContractApprovalListV2(childCondition, condition, orderBy string, childPars, pars []interface{}, startSize, pageSize int) (list []*ContractApprovalList, err error) {
	o := orm.NewOrm()
	sql := `
SELECT
a.contract_approval_id,d.contract_approval_record_id,a.contract_id,a.apply_content,a.approve_remark,a.create_time,a.modify_time,a.status approve_status,c.status,c.product_id,
c.contract_type,c.start_date,c.end_date,c.price,c.company_name,c.credit_code,c.seller_id,c.seller_name,c.file_url,c.contract_code,c.approve_time,c.invalid_time,c.check_back_file_time,c.rescind_time,c.contract_business_type from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="contract" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN contract c ON a.contract_id = c.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
WHERE c.is_delete = 0  AND a.approval_type="contract" `
	sql += condition
	sql += ` group by contract_id order by ` + orderBy + ` LIMIT ?,? `
	_, err = o.Raw(sql, childPars, pars, startSize, pageSize).QueryRows(&list)
	return
}

//获取客户名称
func GetCompanyNameListV2(childCondition, condition string, childPars, pars []interface{}) (list []*contract.CompanyNameList, err error) {
	o := orm.NewOrm()
	sql := `
SELECT c.company_name from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="contract" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN contract c ON a.contract_id = c.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
WHERE c.is_delete = 0  AND a.approval_type="contract" `
	sql += condition
	sql += ` group by company_name order by a.modify_time desc`
	_, err = o.Raw(sql, childPars, pars).QueryRows(&list)
	return
}

// GetContractListCountV2 合同客户统计数（包含待提交的）
func GetContractListCountV2(childCondition, condition, joinCondition, unionCondition string, childPars, pars, unionPars []interface{}) (count int, err error) {
	o := orm.NewOrm()
	sql := `
SELECT
a.contract_approval_id,d.contract_approval_record_id,a.contract_id,a.apply_content,a.approve_remark,a.create_time,a.modify_time,a.status approve_status,c.status,c.product_id,
c.contract_type,c.start_date,c.end_date,c.price,c.company_name,c.seller_id,c.seller_name,c.file_url,c.contract_code,c.approve_time,c.invalid_time,c.check_back_file_time,c.rescind_time from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="contract" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN contract c ON a.contract_id = c.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
WHERE c.is_delete = 0  AND a.approval_type="contract" `
	sql += condition

	sql += ` union (SELECT
 contract_approval_id, 0 as contract_approval_record_id,c.contract_id,"" as apply_content,"" as approve_remark,
 c.create_time,c.modify_time,"待提交" as approve_status,c.status,c.product_id,
c.contract_type,c.start_date,c.end_date,c.price,c.company_name,c.seller_id,c.seller_name,c.file_url,c.contract_code,c.approve_time,c.invalid_time,c.check_back_file_time,c.rescind_time 
from contract c left join contract_approval b on c.contract_id=b.contract_id 
where is_delete=0 and b.contract_approval_id is null ` + unionCondition + `)`

	sql = `select count(*) count from (select * from (` + sql + `) g group by contract_id ) f`
	err = o.Raw(sql, childPars, pars, unionPars).QueryRow(&count)
	return
}

// GetContractListV2 获取合同审批列表数据（包含待提交的）
func GetContractListV2(childCondition, condition, joinCondition, unionCondition string, childPars, pars, unionPars []interface{}, startSize, pageSize int) (list []*ContractApprovalList, err error) {
	o := orm.NewOrm()
	sql := `
SELECT
a.contract_approval_id,d.contract_approval_record_id,a.contract_id,a.apply_content,a.approve_remark,a.create_time,a.modify_time,a.status approve_status,c.status,c.product_id,
c.contract_type,c.start_date,c.end_date,c.price,c.company_name,c.seller_id,c.seller_name,c.file_url,c.contract_code,c.approve_time,c.invalid_time,c.check_back_file_time,c.rescind_time,c.contract_business_type from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="contract" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN contract c ON a.contract_id = c.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
WHERE c.is_delete = 0  AND a.approval_type="contract" `
	sql += condition

	sql += ` union (SELECT
 contract_approval_id, 0 as contract_approval_record_id,c.contract_id,"" as apply_content,"" as approve_remark,
 c.create_time,c.modify_time,"待提交" as approve_status,c.status,c.product_id,
c.contract_type,c.start_date,c.end_date,c.price,c.company_name,c.seller_id,c.seller_name,c.file_url,c.contract_code,c.approve_time,c.invalid_time,c.check_back_file_time,c.rescind_time 
from contract c left join contract_approval b on c.contract_id=b.contract_id 
where is_delete=0 and b.contract_approval_id is null ` + unionCondition + `)`

	sql = `select * from (` + sql + `) g group by contract_id order by modify_time desc LIMIT ?,?`

	_, err = o.Raw(sql, childPars, pars, unionPars, startSize, pageSize).QueryRows(&list)
	return
}

type CompanyNameList struct {
	CompanyName string `description:"客户名称，甲方名称,长度32位"`
}

//根据合同id获取合同审批单信息
func (ContractApproval) CheckPendingByContractId(contractId int, approvalType string) (has bool, err error) {
	o := orm.NewOrm()
	var contractApprovalInfo ContractApproval
	sql := `select * from contract_approval where contract_id = ? AND approval_type =? AND status="待审批" limit 1`
	err = o.Raw(sql, contractId, approvalType).QueryRow(&contractApprovalInfo)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			//如果不存在待审批记录，那么报错信息置空，存在与否直接返回false
			err = nil
			return
		}
		//系统异常，返回错误信息
		return
	}
	//存在待审批的审批单
	has = true
	return
}

//发起审批（工作流）
func (ContractApproval) Apply(contractApprovalInfo *ContractApproval, contractApprovalRecordList []*contract_approval_record.ContractApprovalRecord) (err error) {
	o := orm.NewOrm()
	tx, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = tx.Rollback()
		} else {
			_ = tx.Commit()
		}
	}()
	//审批单记录
	ContractApprovalId, err := tx.Insert(contractApprovalInfo)
	if err != nil {
		return
	}
	//审批单id
	contractApprovalInfo.ContractApprovalId = int(ContractApprovalId)

	for _, contractApprovalRecord := range contractApprovalRecordList {
		//审批流记录
		contractApprovalRecord.ContractApprovalId = contractApprovalInfo.ContractApprovalId
		contractApprovalRecordId, tmpErr := tx.Insert(contractApprovalRecord)
		if tmpErr != nil {
			err = tmpErr
			return
		}
		//审批流id
		contractApprovalRecord.ContractApprovalRecordId = int(contractApprovalRecordId)
	}

	switch contractApprovalInfo.ApprovalType {
	case "contract":
		//修改合同状态为待审批
		sql := `UPDATE contract SET status="待审批",modify_time=NOW() WHERE contract_id = ?`
		_, err = tx.Raw(sql, contractApprovalInfo.ContractId).Exec()
	case "seal":
		//修改用印状态为待审批
		sql := `UPDATE seal SET status="待审批",modify_time=NOW() WHERE seal_id = ?`
		_, err = tx.Raw(sql, contractApprovalInfo.ContractId).Exec()
	}
	return
}

//撤回审核单
func (ContractApproval) Cancel(contractApprovalInfo *ContractApproval, contractApprovalRecordList []*contract_approval_record.ContractApprovalRecord) (err error) {
	o := orm.NewOrm()
	tx, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = tx.Rollback()
		} else {
			_ = tx.Commit()
		}
	}()
	//变更审批单记录
	contractApprovalInfo.Status = "已撤回"
	contractApprovalInfo.ModifyTime = time.Now()
	_, err = tx.Update(contractApprovalInfo, "Status", "ModifyTime")
	if err != nil {
		return
	}

	//变更所有审批流记录
	for _, contractApprovalRecord := range contractApprovalRecordList {
		contractApprovalRecord.Status = "已撤回"
		contractApprovalRecord.ModifyTime = time.Now()
		_, tmpErr := tx.Update(contractApprovalRecord, "Status", "ModifyTime")
		if tmpErr != nil {
			err = tmpErr
			return
		}
	}

	switch contractApprovalInfo.ApprovalType {
	case "contract":
		//修改合同状态为已撤回
		sql := `UPDATE contract SET status="已撤回",modify_time=NOW() WHERE contract_id = ?`
		_, err = tx.Raw(sql, contractApprovalInfo.ContractId).Exec()
	case "seal":
		//修改用印状态为已撤回
		sql := `UPDATE seal SET status="已撤回",modify_time=NOW() WHERE seal_id = ?`
		_, err = tx.Raw(sql, contractApprovalInfo.ContractId).Exec()
	}
	return
}

//审核驳回
func (ContractApproval) Reject(contractApprovalInfo *ContractApproval, contractApprovalRecord *contract_approval_record.ContractApprovalRecord, approveUserId int, approveUserName, remark string) (err error) {
	o := orm.NewOrm()
	tx, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = tx.Rollback()
		} else {
			_ = tx.Commit()
		}
	}()
	//变更审批单记录
	contractApprovalInfo.Status = "已驳回"
	contractApprovalInfo.ApproveRemark = remark //审核失败理由
	contractApprovalInfo.ModifyTime = time.Now()
	//contractApprovalInfo.CurrNodeId = 0 //当前节点变更为0，代表当前审批流程已经结束了
	_, err = tx.Update(contractApprovalInfo, "Status", "ApproveRemark", "ModifyTime")
	if err != nil {
		return
	}

	//变更审批流记录
	contractApprovalRecord.Status = "已驳回"
	contractApprovalRecord.ApproveRemark = remark            //审核失败理由
	contractApprovalRecord.ApproveUserId = approveUserId     //审批人id
	contractApprovalRecord.ApproveUserName = approveUserName //审批人名称
	contractApprovalRecord.ApproveTime = time.Now()          //审批人名称
	contractApprovalRecord.ModifyTime = time.Now()
	_, err = tx.Update(contractApprovalRecord)
	if err != nil {
		return
	}

	switch contractApprovalInfo.ApprovalType {
	case "contract":
		//修改合同状态为已驳回
		sql := `UPDATE contract SET status="已驳回",modify_content="",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE contract_id = ?`
		_, err = tx.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
	case "seal":
		//修改用印状态为已驳回
		sql := `UPDATE seal SET status="已驳回",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE seal_id = ?`
		_, err = tx.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
	}
	return
}

//下级审批人信息
type NextApproval struct {
	ApproveRoleTypeCode string
	ApproveUserId       int
	ApproveUserName     string
}

//审核通过
func (ContractApproval) Approved(contractApprovalInfo *ContractApproval, contractApprovalRecord *contract_approval_record.ContractApprovalRecord, remark string) (err error) {
	o := orm.NewOrm()
	tx, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = tx.Rollback()
		} else {
			_ = tx.Commit()
		}
	}()

	//变更审批流记录
	contractApprovalRecord.Status = "已审批"
	contractApprovalRecord.ApproveRemark = remark   //审核失败理由
	contractApprovalRecord.ApproveTime = time.Now() //审批时间
	contractApprovalRecord.ModifyTime = time.Now()
	_, err = tx.Update(contractApprovalRecord, "Status", "ApproveRemark", "ApproveTime", "ModifyTime")
	if err != nil {
		return
	}

	//如果没有下级节点了，那么完成该审批单
	if contractApprovalRecord.NextNodeId <= 0 {
		//变更审批单记录
		contractApprovalInfo.Status = "已审批"
		contractApprovalInfo.ApproveRemark = remark //审核理由
		//contractApprovalInfo.CurrNodeId = contractApprovalRecord.NextNodeId //下级审批节点id
		contractApprovalInfo.ModifyTime = time.Now()
		_, tmpErr := tx.Update(contractApprovalInfo, "Status", "ApproveRemark", "ModifyTime")
		if tmpErr != nil {
			err = tmpErr
			return
		}

		switch contractApprovalInfo.ApprovalType {
		case "contract":
			//修改合同状态为已审批
			sql := `UPDATE contract SET status="已审批",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE contract_id = ?`
			_, tmpErr = tx.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
			if tmpErr != nil {
				err = tmpErr
				return
			}
		case "seal":
			//修改用印状态为已审批
			sql := `UPDATE seal SET status="已审批",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE seal_id = ?`
			_, tmpErr = tx.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
			if tmpErr != nil {
				err = tmpErr
				return
			}
		}
	} else {
		//变更审批单记录
		contractApprovalInfo.ApproveRemark = remark                         //审核理由
		contractApprovalInfo.CurrNodeId = contractApprovalRecord.NextNodeId //下级审批节点id
		contractApprovalInfo.ModifyTime = time.Now()
		_, tmpErr := tx.Update(contractApprovalInfo, "ApproveRemark", "CurrNodeId", "ModifyTime")
		if tmpErr != nil {
			err = tmpErr
			return
		}
	}

	return
}

//抄送
func (ContractApproval) ApprovedByCc(contractApprovalInfo *ContractApproval, contractApprovalRecordList []*contract_approval_record.ContractApprovalRecord, remark string, nextNodeId int) (err error) {
	o := orm.NewOrm()
	tx, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = tx.Rollback()
		} else {
			_ = tx.Commit()
		}
	}()

	for _, contractApprovalRecord := range contractApprovalRecordList {
		//变更审批流记录
		contractApprovalRecord.Status = "已审批"
		contractApprovalRecord.ApproveTime = time.Now() //审批时间
		contractApprovalRecord.ModifyTime = time.Now()
		_, err = tx.Update(contractApprovalRecord, "Status", "ApproveTime", "ModifyTime")
		if err != nil {
			return
		}

	}
	if err != nil {
		return
	}

	//如果没有下级节点了，那么完成该审批单
	if nextNodeId <= 0 {
		//变更审批单记录
		contractApprovalInfo.Status = "已审批"
		//contractApprovalInfo.CurrNodeId = nextNodeId //下级审批节点id
		contractApprovalInfo.ModifyTime = time.Now()
		_, tmpErr := tx.Update(contractApprovalInfo, "Status", "ModifyTime")
		if tmpErr != nil {
			err = tmpErr
			return
		}

		switch contractApprovalInfo.ApprovalType {
		case "contract":
			//修改合同状态为已审批
			sql := `UPDATE contract SET status="已审批",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE contract_id = ?`
			_, tmpErr = tx.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
			if tmpErr != nil {
				err = tmpErr
				return
			}
		case "seal":
			//修改用印状态为已审批
			sql := `UPDATE seal SET status="已审批",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE seal_id = ?`
			_, tmpErr = tx.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
			if tmpErr != nil {
				err = tmpErr
				return
			}
		}
	} else {
		//变更审批单记录
		contractApprovalInfo.CurrNodeId = nextNodeId //下级审批节点id
		contractApprovalInfo.ModifyTime = time.Now()
		_, tmpErr := tx.Update(contractApprovalInfo, "CurrNodeId", "ModifyTime")
		if tmpErr != nil {
			err = tmpErr
			return
		}
	}

	return
}

//根据合同审批单id集合获取合同审批单信息列表
func GetContractApprovalByIds(contractApprovalIds string) (contractApprovalList []*ContractApproval, err error) {
	o := orm.NewOrm()
	sql := `select * from contract_approval where contract_approval_id in (` + contractApprovalIds + `) `
	_, err = o.Raw(sql).QueryRows(&contractApprovalList)
	return
}

//获取用印审批列表数据数量
func GetSealApprovalListCount(childCondition, condition, joinCondition string, childPars, pars []interface{}) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT a.contract_approval_id,a.contract_id,a.apply_content,a.approve_remark,a.create_time,a.modify_time,a.status,c.status seal_status,
c.seal_type,c.company_name,c.user_id,c.user_name,c.file_url,c.code from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="seal" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN seal c ON c.seal_id = a.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
WHERE c.is_delete = 0  AND a.approval_type="seal" `
	sql += condition
	sql += ` group by contract_id `

	sql = `select count(*) count from (` + sql + `) g`
	err = o.Raw(sql, childPars, pars).QueryRow(&count)
	return
}

//用印审批列表
type SealApprovalList struct {
	ContractApprovalId       int                     `description:"审批单id"`
	ContractId               int                     `description:"合同id"`
	ContractApprovalRecordId int                     `description:"审批流id"`
	ContractCode             string                  `description:"合同编号"`
	Status                   string                  `description:"合同状态，枚举值：待审批','已审批','已驳回','已撤回','已签回'，默认待审批"`
	ApproveStatus            string                  `json:"-" description:"审批单状态，枚举值：待审批','已审批','已驳回','已撤回'，默认待审批"`
	ApplyContent             string                  `description:"待审内容"`
	ApplyUserId              int                     `description:"待审内容"`
	ApplyUserName            string                  `description:"待审内容"`
	ContractDetail           string                  `json:"-" description:"提交审批时的合同信息；用印快照"`
	ContractInfo             contract.ContractDetail `json:"-" description:"提交审批时的合同信息；用印快照"`
	ApproveRemark            string                  `description:"审核备注"`
	SealType                 string                  `description:"用印类型"`
	CompanyName              string                  `description:"客户名称"`
	FileUrl                  string                  `description:"合同下载地址"`
	UserId                   int                     `description:"申请人id"`
	CurrNodeId               int                     `description:"当前审批节点id"`
	StartNodeId              int                     `description:"开始审批节点id"`
	UserName                 string                  `description:"申请人名称"`
	CreateTime               time.Time               `description:"发起审批的时间"`
	ModifyTime               time.Time               `description:"最后一次修改的时间"`
	ApproveTime              time.Time               `description:"审批时间"`
	InvalidTime              time.Time               `description:"作废时间"`
	CheckBackFileTime        time.Time               `description:"签回用印附件时间"`
	StartDateStr             string                  `description:"合同开始日期(字符串类型)"`
	EndDateStr               string                  `description:"合同结束日期(字符串类型)"`
	CreateTimeStr            string                  `description:"发起审批的时间(字符串类型)"`
	ModifyTimeStr            string                  `description:"最后一次修改的时间(字符串类型)"`
	ApproveTimeStr           string                  `description:"审批时间（字符串类型）"`
	InvalidTimeStr           string                  `description:"作废时间（字符串类型）"`
}

//获取合同审批列表数据
func GetSealApprovalList(childCondition, condition, joinCondition string, childPars, pars []interface{}, startSize, pageSize int) (list []*SealApprovalList, err error) {
	o := orm.NewOrm()
	sql := `SELECT a.contract_approval_id,a.contract_id,a.apply_content,a.approve_remark,a.apply_user_id,a.apply_user_name,a.curr_node_id,a.start_node_id,a.create_time,a.modify_time,a.status approval_status,c.status,c.seal_type,c.company_name,c.user_id,c.user_name,c.file_url,c.approve_time,c.invalid_time,c.code,c.check_back_file_time from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="seal" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN seal c ON c.seal_id = a.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
WHERE c.is_delete = 0 AND a.approval_type="seal" `
	sql += condition
	sql += ` group by contract_id order by modify_time desc LIMIT ?,? `
	_, err = o.Raw(sql, childPars, pars, startSize, pageSize).QueryRows(&list)
	return
}

//处理后的
func GetSealApprovalListCountV2(childCondition, condition string, childPars, pars []interface{}) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT a.contract_approval_id,a.contract_id,a.apply_content,a.approve_remark,a.create_time,a.modify_time,a.status,c.status seal_status,
c.seal_type,c.company_name,c.user_id,c.user_name,c.file_url,c.code from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="seal" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN seal c ON c.seal_id = a.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
WHERE c.is_delete = 0  AND a.approval_type="seal" `
	sql += condition
	sql += ` group by contract_id `

	sql = `select count(*) count from (` + sql + `) g`
	err = o.Raw(sql, childPars, pars).QueryRow(&count)
	return
}
func GetSealApprovalListV2(childCondition, condition, orderBy string, childPars, pars []interface{}, startSize, pageSize int) (list []*SealApprovalList, err error) {
	o := orm.NewOrm()
	sql := `SELECT a.contract_approval_id,a.contract_id,a.apply_content,a.approve_remark,a.apply_user_id,a.apply_user_name,a.curr_node_id,a.start_node_id,a.create_time,a.modify_time,a.status approval_status,c.status,c.seal_type,c.company_name,c.user_id,c.user_name,c.file_url,c.approve_time,c.invalid_time,c.code,c.check_back_file_time from contract_approval a
	join 
	( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="seal" `
	sql += childCondition
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
	JOIN seal c ON c.seal_id = a.contract_id 
	JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id 
WHERE c.is_delete = 0 AND a.approval_type="seal" `
	sql += condition
	sql += ` group by contract_id order by ` + orderBy + ` LIMIT ?,? `
	_, err = o.Raw(sql, childPars, pars, startSize, pageSize).QueryRows(&list)
	return
}

//审批列表
type CompanyApprovalList struct {
	ContractApprovalId       int                     `description:"审批单id"`
	ContractId               int                     `description:"客户单id"`
	ContractApprovalRecordId int                     `description:"审批流id"`
	ContractCode             string                  `description:"合同编号"`
	Status                   string                  `description:"审批单状态，枚举值：待审批','已审批','已驳回','已撤回'，默认待审批"`
	ApplyContent             string                  `description:"待审内容"`
	ContractDetail           string                  `json:"-" description:"提交审批时的客户审批信息；客户审批快照"`
	ContractInfo             contract.ContractDetail `description:"提交审批时的合同信息；合同快照"`
	ApproveRemark            string                  `description:"审核备注"`
	CompanyName              string                  `description:"客户名称"`
	SellerId                 int                     `description:"销售id"`
	ApplyUserId              int                     `description:"申请人id"`
	CurrNodeId               int                     `description:"当前节点"`
	StartNodeId              int                     `description:"开始节点"`
	ProductId                int                     `description:"产品id，1：ficc；2：权益"`
	SellerName               string                  `description:"销售名称"`
	StartDate                time.Time               `description:"合同开始日期"`
	EndDate                  time.Time               `description:"合同结束日期"`
	CreateTime               time.Time               `description:"发起审批的时间"`
	ModifyTime               time.Time               `description:"最后一次修改的时间"`
	ApproveTime              time.Time               `description:"审批时间"`
	StartDateStr             string                  `description:"合同开始日期(字符串类型)"`
	EndDateStr               string                  `description:"合同结束日期(字符串类型)"`
	CreateTimeStr            string                  `description:"发起审批的时间(字符串类型)"`
	ModifyTimeStr            string                  `description:"最后一次修改的时间(字符串类型)"`
	ApproveTimeStr           string                  `description:"审批时间（字符串类型）"`

	CompanyId            int
	CreditCode           string `description:"社会统一信用码"`
	CompanyType          string `description:"客户类型"`
	IndustryName         string `description:"行业名称"`
	ApprovalTime         string `description:"提交申请时间"`
	CompanyProductStatus string `description:"客户状态"`
	ApproveContent       string `description:"待审内容"`
	ApproveStatus        string `description:"当前状态"`
	ApplyMethod          int    `description:"申请类型：1:试用->正式,2:冻结—>试用,3:试用延期,4:原销售申请领取流失客户，5:正式客户申请服务更新，6：正式客户补充协议"`
	ApplyReasons         string `description:"申请理由"`
	FreezeStartDate      string `description:"冻结开始日期"`
	FreezeEndDate        string `description:"冻结结束日期"`
	FreezeExpireDays     int    `description:"冻结到期天数"`
	Address              string `description:"地址"`
	Source               string `description:"客户来源"`
	ExpireDay            int    `description:"服务到期天数"`
	CompanyApprovalId    int    `description:"审批记录ID"`
	ApprovalCount        int    `description:"已延期审批次数"`
	CompanyContractId    int    `description:"合同id"`
	DelayPermission      string `description:"延期申请品种"`
	ApplyRealName        string `description:"申请人姓名"`
	ContractSourceTag    string `description:"合同来源标签：非标合同，标准合同"`
}

func GetCompanyApprovalCount(condition string, pars []interface{}) (count int, err error) {
	o := orm.NewOrm()
	sql := `
SELECT
a.contract_approval_id,a.contract_id,a.apply_content,a.contract_detail,a.create_time,a.modify_time,a.status,a.curr_node_id,a.start_node_id,a.apply_user_id,c.approve_time,c.company_approval_id,c.company_id,c.product_id,c.apply_real_name,d.company_type,d.industry_name,d.seller_name,d.status company_product_status,c.approve_status,c.apply_method,c.apply_reasons,d.freeze_start_date,d.freeze_end_date,e.address,d.source,c.approve_remark,d.start_date,d.end_date,c.company_contract_id,e.company_name,e.credit_code
from contract_approval a
	join  ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="company" `
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
			INNER JOIN company_approval AS c ON a.contract_id=c.company_approval_id
			INNER JOIN company_product AS d ON d.company_id=c.company_id AND d.product_id=c.product_id
			INNER JOIN company AS e ON e.company_id=d.company_id
	JOIN contract_approval_record f on a.contract_approval_id=f.contract_approval_id 
 			WHERE 1=1 and  a.approval_type="company" `
	sql += condition
	sql += ` group by contract_id `
	sql = `select count(1) from (` + sql + `) z `
	err = o.Raw(sql, pars).QueryRow(&count)
	return
}

func GetCompanyApprovalList(condition string, pars []interface{}, startSize, pageSize int) (list []*CompanyApprovalList, err error) {
	o := orm.NewOrm()
	sql := `
SELECT
a.contract_approval_id,a.contract_id,a.apply_content,a.contract_detail,a.create_time,a.modify_time,a.status,a.curr_node_id,a.start_node_id,a.apply_user_id,c.approve_time,c.company_approval_id,c.company_id,c.product_id,c.apply_real_name,d.company_type,d.industry_name,d.seller_name,d.status company_product_status,c.approve_status,c.apply_method,c.apply_reasons,d.freeze_start_date,d.freeze_end_date,e.address,d.source,c.approve_remark,d.start_date,d.end_date,c.company_contract_id,e.company_name,e.credit_code
from contract_approval a
	join  ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 and approval_type="company" `
	sql += `  GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
			INNER JOIN company_approval AS c ON a.contract_id=c.company_approval_id
			INNER JOIN company_product AS d ON d.company_id=c.company_id AND d.product_id=c.product_id
			INNER JOIN company AS e ON e.company_id=d.company_id
	JOIN contract_approval_record f on a.contract_approval_id=f.contract_approval_id 
 			WHERE 1=1 and  a.approval_type="company" `
	sql += condition
	sql += ` group by contract_id order by modify_time desc LIMIT ?,? `
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
	return
}