contract_approval.go 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668
  1. package contract_approval
  2. import (
  3. "hongze/hongze_mobile_admin/models/tables/contract"
  4. "hongze/hongze_mobile_admin/models/tables/contract_approval_record"
  5. "hongze/hongze_mobile_admin/utils"
  6. "rdluck_tools/orm"
  7. "time"
  8. )
  9. //合同审批单
  10. type ContractApproval struct {
  11. ContractApprovalId int `orm:"column(contract_approval_id);pk"`
  12. ApprovalType string `description:"审批单类型,枚举值,合同:contract;用印:seal;默认:contract"`
  13. ContractId int `orm:"column(contract_id)" description:"合同id"`
  14. Status string `description:"审批单状态,枚举值:待审批','已审批','已驳回','已撤回',默认待审批"`
  15. ApplyContent string `description:"待审内容,长度255位"`
  16. ContractDetail string `description:"审批单详情,完整的合同json数据"`
  17. ApplyUserId int `description:"申请人id"`
  18. ApplyUserName string `description:"申请人名称"`
  19. ApproveRemark string `description:"审批人备注,可以是驳回理由,长度128位"`
  20. FlowId int `description:"审批流程id"`
  21. FlowVersion int `description:"审批流程版本"`
  22. CurrNodeId int `description:"当前审批节点id"`
  23. StartNodeId int `description:"开始审批节点id"`
  24. ModifyTime time.Time `description:"发起申请时间"`
  25. CreateTime time.Time `description:"最近一次审批单修改时间"`
  26. }
  27. //根据合同审批单id获取合同审批单信息
  28. func GetContractApprovalById(contractApprovalId int) (contractApprovalInfo *ContractApproval, err error) {
  29. o := orm.NewOrm()
  30. sql := `select * from contract_approval where contract_approval_id = ? `
  31. err = o.Raw(sql, contractApprovalId).QueryRow(&contractApprovalInfo)
  32. return
  33. }
  34. //根据合同id获取最近一次待审批的合同审批单信息
  35. func GetLastPendingContractApprovalByContractId(contractId int) (contractApprovalInfo *ContractApproval, err error) {
  36. o := orm.NewOrm()
  37. sql := `select * from contract_approval where status = "待审批" AND contract_id=? order by contract_approval_id desc`
  38. err = o.Raw(sql, contractId).QueryRow(&contractApprovalInfo)
  39. return
  40. }
  41. //根据合同id获取最近一次提交的合同审批单信息
  42. func GetLastContractApprovalByContractId(contractId int, approvalType string) (contractApprovalInfo *ContractApproval, err error) {
  43. o := orm.NewOrm()
  44. sql := `select * from contract_approval where contract_id=? and approval_type =? order by contract_approval_id desc`
  45. err = o.Raw(sql, contractId, approvalType).QueryRow(&contractApprovalInfo)
  46. return
  47. }
  48. //根据合同id获取总共被驳回的次数
  49. func GetRejectContractCountByContractId(contractId int) (total int64, err error) {
  50. o := orm.NewOrm()
  51. sql := `select count(1) total from contract_approval where status = "已驳回" AND contract_id=? `
  52. err = o.Raw(sql, contractId).QueryRow(&total)
  53. return
  54. }
  55. //获取合同审批列表数据数量
  56. func GetContractApprovalListCount(childCondition, condition, joinCondition string, childPars, pars []interface{}) (count int, err error) {
  57. o := orm.NewOrm()
  58. sql := `
  59. SELECT
  60. 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,
  61. 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
  62. join
  63. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  64. sql += childCondition
  65. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  66. JOIN contract c ON a.contract_id = c.contract_id
  67. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
  68. WHERE c.is_delete = 0 AND a.approval_type="contract" `
  69. sql += condition
  70. sql += ` group by contract_id `
  71. sql = `select count(*) count from (` + sql + `) g`
  72. err = o.Raw(sql, childPars, pars).QueryRow(&count)
  73. return
  74. }
  75. //合同审批列表
  76. type ContractApprovalList struct {
  77. ContractApprovalId int `description:"审批单id"`
  78. ContractId int `description:"合同id"`
  79. ContractApprovalRecordId int `description:"审批流id"`
  80. ContractCode string `description:"合同编号"`
  81. Status string `description:"合同状态,枚举值:待审批','已审批','已驳回','已撤回',默认待审批"`
  82. ApproveStatus string `json:"-" description:"审批单状态,枚举值:待审批','已审批','已驳回','已撤回',默认待审批"`
  83. ApplyContent string `description:"待审内容"`
  84. ContractDetail string `json:"-" description:"提交审批时的合同信息;合同快照"`
  85. ContractInfo contract.ContractDetail `json:"-" description:"提交审批时的合同信息;合同快照"`
  86. ApproveRemark string `description:"审核备注"`
  87. ContractType string `description:"合同类型"`
  88. Price float64 `description:"合同金额"`
  89. CompanyName string `description:"客户名称"`
  90. CreditCode string `description:"社会统一信用代码,长度64位"`
  91. FileUrl string `description:"合同下载地址"`
  92. SellerId int `description:"销售id"`
  93. ProductId int `description:"产品id,1:ficc;2:权益"`
  94. SellerName string `description:"销售名称"`
  95. StartDate time.Time `description:"合同开始日期"`
  96. EndDate time.Time `description:"合同结束日期"`
  97. CreateTime time.Time `description:"发起审批的时间"`
  98. ModifyTime time.Time `description:"最后一次修改的时间"`
  99. ApproveTime time.Time `description:"审批时间"`
  100. InvalidTime time.Time `description:"作废时间"`
  101. CheckBackFileTime time.Time `description:"合同签回时间"`
  102. RescindTime time.Time `description:"解约时间"`
  103. StartDateStr string `description:"合同开始日期(字符串类型)"`
  104. EndDateStr string `description:"合同结束日期(字符串类型)"`
  105. CreateTimeStr string `description:"发起审批的时间(字符串类型)"`
  106. ModifyTimeStr string `description:"最后一次修改的时间(字符串类型)"`
  107. ApproveTimeStr string `description:"审批时间(字符串类型)"`
  108. InvalidTimeStr string `description:"作废时间(字符串类型)"`
  109. CheckBackFileTimeStr string `description:"合同签回时间(字符串类型)"`
  110. RescindTimeStr string `description:"解约时间(字符串类型)"`
  111. }
  112. //获取合同审批列表数据
  113. func GetContractApprovalList(childCondition, condition, joinCondition string, childPars, pars []interface{}, startSize, pageSize int) (list []*ContractApprovalList, err error) {
  114. o := orm.NewOrm()
  115. sql := `
  116. SELECT
  117. 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,
  118. 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 from contract_approval a
  119. join
  120. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  121. sql += childCondition
  122. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  123. JOIN contract c ON a.contract_id = c.contract_id
  124. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
  125. WHERE c.is_delete = 0 AND a.approval_type="contract" `
  126. sql += condition
  127. sql += ` group by contract_id order by modify_time desc LIMIT ?,? `
  128. _, err = o.Raw(sql, childPars, pars, startSize, pageSize).QueryRows(&list)
  129. return
  130. }
  131. //获取审批后的数据
  132. func GetContractApprovalListCountV2(childCondition, condition string, childPars, pars []interface{}) (count int, err error) {
  133. o := orm.NewOrm()
  134. sql := `
  135. SELECT
  136. 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,
  137. 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
  138. join
  139. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  140. sql += childCondition
  141. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  142. JOIN contract c ON a.contract_id = c.contract_id
  143. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
  144. WHERE c.is_delete = 0 AND a.approval_type="contract" `
  145. sql += condition
  146. sql += ` group by contract_id `
  147. sql = `select count(*) count from (` + sql + `) g`
  148. err = o.Raw(sql, childPars, pars).QueryRow(&count)
  149. return
  150. }
  151. func GetContractApprovalListV2(childCondition, condition string, childPars, pars []interface{}, startSize, pageSize int) (list []*ContractApprovalList, err error) {
  152. o := orm.NewOrm()
  153. sql := `
  154. SELECT
  155. 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,
  156. 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
  157. join
  158. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  159. sql += childCondition
  160. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  161. JOIN contract c ON a.contract_id = c.contract_id
  162. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
  163. WHERE c.is_delete = 0 AND a.approval_type="contract" `
  164. sql += condition
  165. sql += ` group by contract_id order by modify_time desc LIMIT ?,? `
  166. _, err = o.Raw(sql, childPars, pars, startSize, pageSize).QueryRows(&list)
  167. return
  168. }
  169. //获取客户名称
  170. func GetCompanyNameListV2(childCondition, condition string, childPars, pars []interface{}) (list []*contract.CompanyNameList, err error) {
  171. o := orm.NewOrm()
  172. sql := `
  173. SELECT c.company_name from contract_approval a
  174. join
  175. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  176. sql += childCondition
  177. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  178. JOIN contract c ON a.contract_id = c.contract_id
  179. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
  180. WHERE c.is_delete = 0 AND a.approval_type="contract" `
  181. sql += condition
  182. sql += ` group by company_name order by a.modify_time desc`
  183. _, err = o.Raw(sql, childPars, pars).QueryRows(&list)
  184. return
  185. }
  186. //合同客户统计数
  187. func GetContractListCountV2(childCondition, condition, joinCondition, unionCondition string, childPars, pars, unionPars []interface{}) (count int, err error) {
  188. o := orm.NewOrm()
  189. sql := `
  190. SELECT
  191. 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,
  192. 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
  193. join
  194. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  195. sql += childCondition
  196. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  197. JOIN contract c ON a.contract_id = c.contract_id
  198. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
  199. WHERE c.is_delete = 0 AND a.approval_type="contract" `
  200. sql += condition
  201. sql += ` union (SELECT
  202. contract_approval_id, 0 as contract_approval_record_id,c.contract_id,"" as apply_content,"" as approve_remark,
  203. c.create_time,c.modify_time,"待提交" as approve_status,c.status,c.product_id,
  204. 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
  205. from contract c left join contract_approval b on c.contract_id=b.contract_id
  206. where is_delete=0 and b.contract_approval_id is null ` + unionCondition + `)`
  207. sql = `select count(*) count from (select * from (` + sql + `) g group by contract_id ) f`
  208. err = o.Raw(sql, childPars, pars, unionPars).QueryRow(&count)
  209. return
  210. }
  211. //获取合同审批列表数据
  212. func GetContractListV2(childCondition, condition, joinCondition, unionCondition string, childPars, pars, unionPars []interface{}, startSize, pageSize int) (list []*ContractApprovalList, err error) {
  213. o := orm.NewOrm()
  214. sql := `
  215. SELECT
  216. 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,
  217. 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
  218. join
  219. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  220. sql += childCondition
  221. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  222. JOIN contract c ON a.contract_id = c.contract_id
  223. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
  224. WHERE c.is_delete = 0 AND a.approval_type="contract" `
  225. sql += condition
  226. sql += ` union (SELECT
  227. contract_approval_id, 0 as contract_approval_record_id,c.contract_id,"" as apply_content,"" as approve_remark,
  228. c.create_time,c.modify_time,"待提交" as approve_status,c.status,c.product_id,
  229. 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
  230. from contract c left join contract_approval b on c.contract_id=b.contract_id
  231. where is_delete=0 and b.contract_approval_id is null ` + unionCondition + `)`
  232. sql = `select * from (` + sql + `) g group by contract_id order by modify_time desc LIMIT ?,?`
  233. _, err = o.Raw(sql, childPars, pars, unionPars, startSize, pageSize).QueryRows(&list)
  234. return
  235. }
  236. type CompanyNameList struct {
  237. CompanyName string `description:"客户名称,甲方名称,长度32位"`
  238. }
  239. //根据合同id获取合同审批单信息
  240. func (ContractApproval) CheckPendingByContractId(contractId int, approvalType string) (has bool, err error) {
  241. o := orm.NewOrm()
  242. var contractApprovalInfo ContractApproval
  243. sql := `select * from contract_approval where contract_id = ? AND approval_type =? AND status="待审批" limit 1`
  244. err = o.Raw(sql, contractId, approvalType).QueryRow(&contractApprovalInfo)
  245. if err != nil {
  246. if err.Error() == utils.ErrNoRow() {
  247. //如果不存在待审批记录,那么报错信息置空,存在与否直接返回false
  248. err = nil
  249. return
  250. }
  251. //系统异常,返回错误信息
  252. return
  253. }
  254. //存在待审批的审批单
  255. has = true
  256. return
  257. }
  258. //发起审批(工作流)
  259. func (ContractApproval) Apply(contractApprovalInfo *ContractApproval, contractApprovalRecordList []*contract_approval_record.ContractApprovalRecord) (err error) {
  260. o := orm.NewOrm()
  261. o.Begin()
  262. defer func() {
  263. if err != nil {
  264. o.Rollback()
  265. } else {
  266. o.Commit()
  267. }
  268. }()
  269. //审批单记录
  270. ContractApprovalId, err := o.Insert(contractApprovalInfo)
  271. if err != nil {
  272. return
  273. }
  274. //审批单id
  275. contractApprovalInfo.ContractApprovalId = int(ContractApprovalId)
  276. for _, contractApprovalRecord := range contractApprovalRecordList {
  277. //审批流记录
  278. contractApprovalRecord.ContractApprovalId = contractApprovalInfo.ContractApprovalId
  279. contractApprovalRecordId, tmpErr := o.Insert(contractApprovalRecord)
  280. if tmpErr != nil {
  281. err = tmpErr
  282. return
  283. }
  284. //审批流id
  285. contractApprovalRecord.ContractApprovalRecordId = int(contractApprovalRecordId)
  286. }
  287. switch contractApprovalInfo.ApprovalType {
  288. case "contract":
  289. //修改合同状态为待审批
  290. sql := `UPDATE contract SET status="待审批",modify_time=NOW() WHERE contract_id = ?`
  291. _, err = o.Raw(sql, contractApprovalInfo.ContractId).Exec()
  292. case "seal":
  293. //修改用印状态为待审批
  294. sql := `UPDATE seal SET status="待审批",modify_time=NOW() WHERE seal_id = ?`
  295. _, err = o.Raw(sql, contractApprovalInfo.ContractId).Exec()
  296. }
  297. return
  298. }
  299. //撤回审核单
  300. func (ContractApproval) Cancel(contractApprovalInfo *ContractApproval, contractApprovalRecordList []*contract_approval_record.ContractApprovalRecord) (err error) {
  301. o := orm.NewOrm()
  302. o.Begin()
  303. defer func() {
  304. if err != nil {
  305. o.Rollback()
  306. } else {
  307. o.Commit()
  308. }
  309. }()
  310. //变更审批单记录
  311. contractApprovalInfo.Status = "已撤回"
  312. contractApprovalInfo.ModifyTime = time.Now()
  313. _, err = o.Update(contractApprovalInfo, "Status", "ModifyTime")
  314. if err != nil {
  315. return
  316. }
  317. //变更所有审批流记录
  318. for _, contractApprovalRecord := range contractApprovalRecordList {
  319. contractApprovalRecord.Status = "已撤回"
  320. contractApprovalRecord.ModifyTime = time.Now()
  321. _, tmpErr := o.Update(contractApprovalRecord, "Status", "ModifyTime")
  322. if tmpErr != nil {
  323. err = tmpErr
  324. return
  325. }
  326. }
  327. switch contractApprovalInfo.ApprovalType {
  328. case "contract":
  329. //修改合同状态为已撤回
  330. sql := `UPDATE contract SET status="已撤回",modify_time=NOW() WHERE contract_id = ?`
  331. _, err = o.Raw(sql, contractApprovalInfo.ContractId).Exec()
  332. case "seal":
  333. //修改用印状态为已撤回
  334. sql := `UPDATE seal SET status="已撤回",modify_time=NOW() WHERE seal_id = ?`
  335. _, err = o.Raw(sql, contractApprovalInfo.ContractId).Exec()
  336. }
  337. return
  338. }
  339. //审核驳回
  340. func (ContractApproval) Reject(contractApprovalInfo *ContractApproval, contractApprovalRecord *contract_approval_record.ContractApprovalRecord, approveUserId int, approveUserName, remark string) (err error) {
  341. o := orm.NewOrm()
  342. o.Begin()
  343. defer func() {
  344. if err != nil {
  345. o.Rollback()
  346. } else {
  347. o.Commit()
  348. }
  349. }()
  350. //变更审批单记录
  351. contractApprovalInfo.Status = "已驳回"
  352. contractApprovalInfo.ApproveRemark = remark //审核失败理由
  353. contractApprovalInfo.ModifyTime = time.Now()
  354. //contractApprovalInfo.CurrNodeId = 0 //当前节点变更为0,代表当前审批流程已经结束了
  355. _, err = o.Update(contractApprovalInfo, "Status", "ApproveRemark", "ModifyTime")
  356. if err != nil {
  357. return
  358. }
  359. //变更审批流记录
  360. contractApprovalRecord.Status = "已驳回"
  361. contractApprovalRecord.ApproveRemark = remark //审核失败理由
  362. contractApprovalRecord.ApproveUserId = approveUserId //审批人id
  363. contractApprovalRecord.ApproveUserName = approveUserName //审批人名称
  364. contractApprovalRecord.ApproveTime = time.Now() //审批人名称
  365. contractApprovalRecord.ModifyTime = time.Now()
  366. _, err = o.Update(contractApprovalRecord)
  367. if err != nil {
  368. return
  369. }
  370. switch contractApprovalInfo.ApprovalType {
  371. case "contract":
  372. //修改合同状态为已驳回
  373. sql := `UPDATE contract SET status="已驳回",modify_content="",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE contract_id = ?`
  374. _, err = o.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
  375. case "seal":
  376. //修改用印状态为已驳回
  377. sql := `UPDATE seal SET status="已驳回",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE seal_id = ?`
  378. _, err = o.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
  379. }
  380. return
  381. }
  382. //下级审批人信息
  383. type NextApproval struct {
  384. ApproveRoleTypeCode string
  385. ApproveUserId int
  386. ApproveUserName string
  387. }
  388. //审核通过
  389. func (ContractApproval) Approved(contractApprovalInfo *ContractApproval, contractApprovalRecord *contract_approval_record.ContractApprovalRecord, remark string) (err error) {
  390. o := orm.NewOrm()
  391. o.Begin()
  392. defer func() {
  393. if err != nil {
  394. o.Rollback()
  395. } else {
  396. o.Commit()
  397. }
  398. }()
  399. //变更审批流记录
  400. contractApprovalRecord.Status = "已审批"
  401. contractApprovalRecord.ApproveRemark = remark //审核失败理由
  402. contractApprovalRecord.ApproveTime = time.Now() //审批时间
  403. contractApprovalRecord.ModifyTime = time.Now()
  404. _, err = o.Update(contractApprovalRecord, "Status", "ApproveRemark", "ApproveTime", "ModifyTime")
  405. if err != nil {
  406. return
  407. }
  408. //如果没有下级节点了,那么完成该审批单
  409. if contractApprovalRecord.NextNodeId <= 0 {
  410. //变更审批单记录
  411. contractApprovalInfo.Status = "已审批"
  412. contractApprovalInfo.ApproveRemark = remark //审核理由
  413. //contractApprovalInfo.CurrNodeId = contractApprovalRecord.NextNodeId //下级审批节点id
  414. contractApprovalInfo.ModifyTime = time.Now()
  415. _, tmpErr := o.Update(contractApprovalInfo, "Status", "ApproveRemark", "ModifyTime")
  416. if tmpErr != nil {
  417. err = tmpErr
  418. return
  419. }
  420. switch contractApprovalInfo.ApprovalType {
  421. case "contract":
  422. //修改合同状态为已审批
  423. sql := `UPDATE contract SET status="已审批",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE contract_id = ?`
  424. _, tmpErr = o.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
  425. if tmpErr != nil {
  426. err = tmpErr
  427. return
  428. }
  429. case "seal":
  430. //修改用印状态为已审批
  431. sql := `UPDATE seal SET status="已审批",approval_remark=?,approve_time=NOW(),modify_time=NOW() WHERE seal_id = ?`
  432. _, tmpErr = o.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
  433. if tmpErr != nil {
  434. err = tmpErr
  435. return
  436. }
  437. }
  438. } else {
  439. //变更审批单记录
  440. contractApprovalInfo.ApproveRemark = remark //审核理由
  441. contractApprovalInfo.CurrNodeId = contractApprovalRecord.NextNodeId //下级审批节点id
  442. contractApprovalInfo.ModifyTime = time.Now()
  443. _, tmpErr := o.Update(contractApprovalInfo, "ApproveRemark", "CurrNodeId", "ModifyTime")
  444. if tmpErr != nil {
  445. err = tmpErr
  446. return
  447. }
  448. }
  449. return
  450. }
  451. //抄送
  452. func (ContractApproval) ApprovedByCc(contractApprovalInfo *ContractApproval, contractApprovalRecordList []*contract_approval_record.ContractApprovalRecord, remark string, nextNodeId int) (err error) {
  453. o := orm.NewOrm()
  454. o.Begin()
  455. defer func() {
  456. if err != nil {
  457. o.Rollback()
  458. } else {
  459. o.Commit()
  460. }
  461. }()
  462. for _, contractApprovalRecord := range contractApprovalRecordList {
  463. //变更审批流记录
  464. contractApprovalRecord.Status = "已审批"
  465. contractApprovalRecord.ApproveTime = time.Now() //审批时间
  466. contractApprovalRecord.ModifyTime = time.Now()
  467. _, err = o.Update(contractApprovalRecord, "Status", "ApproveTime", "ModifyTime")
  468. if err != nil {
  469. return
  470. }
  471. }
  472. if err != nil {
  473. return
  474. }
  475. //如果没有下级节点了,那么完成该审批单
  476. if nextNodeId <= 0 {
  477. //变更审批单记录
  478. contractApprovalInfo.Status = "已审批"
  479. //contractApprovalInfo.CurrNodeId = nextNodeId //下级审批节点id
  480. contractApprovalInfo.ModifyTime = time.Now()
  481. _, tmpErr := o.Update(contractApprovalInfo, "Status", "ModifyTime")
  482. if tmpErr != nil {
  483. err = tmpErr
  484. return
  485. }
  486. switch contractApprovalInfo.ApprovalType {
  487. case "contract":
  488. //修改合同状态为已审批
  489. sql := `UPDATE contract SET status="已审批",approval_remark=?,modify_time=NOW() WHERE contract_id = ?`
  490. _, tmpErr = o.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
  491. if tmpErr != nil {
  492. err = tmpErr
  493. return
  494. }
  495. case "seal":
  496. //修改用印状态为已审批
  497. sql := `UPDATE seal SET status="已审批",approval_remark=?,modify_time=NOW() WHERE seal_id = ?`
  498. _, tmpErr = o.Raw(sql, remark, contractApprovalInfo.ContractId).Exec()
  499. if tmpErr != nil {
  500. err = tmpErr
  501. return
  502. }
  503. }
  504. } else {
  505. //变更审批单记录
  506. contractApprovalInfo.CurrNodeId = nextNodeId //下级审批节点id
  507. contractApprovalInfo.ModifyTime = time.Now()
  508. _, tmpErr := o.Update(contractApprovalInfo, "CurrNodeId", "ModifyTime")
  509. if tmpErr != nil {
  510. err = tmpErr
  511. return
  512. }
  513. }
  514. return
  515. }
  516. //根据合同审批单id集合获取合同审批单信息列表
  517. func GetContractApprovalByIds(contractApprovalIds string) (contractApprovalList []*ContractApproval, err error) {
  518. o := orm.NewOrm()
  519. sql := `select * from contract_approval where contract_approval_id in (` + contractApprovalIds + `) `
  520. _, err = o.Raw(sql).QueryRows(&contractApprovalList)
  521. return
  522. }
  523. //获取用印审批列表数据数量
  524. func GetSealApprovalListCount(childCondition, condition, joinCondition string, childPars, pars []interface{}) (count int, err error) {
  525. o := orm.NewOrm()
  526. 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,
  527. c.seal_type,c.company_name,c.user_id,c.user_name,c.file_url,c.code from contract_approval a
  528. join
  529. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  530. sql += childCondition
  531. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  532. JOIN seal c ON c.seal_id = a.contract_id
  533. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
  534. WHERE c.is_delete = 0 AND a.approval_type="seal" `
  535. sql += condition
  536. sql += ` group by contract_id `
  537. sql = `select count(*) count from (` + sql + `) g`
  538. err = o.Raw(sql, childPars, pars).QueryRow(&count)
  539. return
  540. }
  541. //用印审批列表
  542. type SealApprovalList struct {
  543. ContractApprovalId int `description:"审批单id"`
  544. ContractId int `description:"合同id"`
  545. ContractApprovalRecordId int `description:"审批流id"`
  546. ContractCode string `description:"合同编号"`
  547. Status string `description:"合同状态,枚举值:待审批','已审批','已驳回','已撤回',默认待审批"`
  548. ApproveStatus string `json:"-" description:"审批单状态,枚举值:待审批','已审批','已驳回','已撤回',默认待审批"`
  549. ApplyContent string `description:"待审内容"`
  550. ContractDetail string `json:"-" description:"提交审批时的合同信息;用印快照"`
  551. ContractInfo contract.ContractDetail `json:"-" description:"提交审批时的合同信息;用印快照"`
  552. ApproveRemark string `description:"审核备注"`
  553. SealType string `description:"用印类型"`
  554. CompanyName string `description:"客户名称"`
  555. FileUrl string `description:"合同下载地址"`
  556. UserId int `description:"申请人id"`
  557. UserName string `description:"申请人名称"`
  558. CreateTime time.Time `description:"发起审批的时间"`
  559. ModifyTime time.Time `description:"最后一次修改的时间"`
  560. ApproveTime time.Time `description:"审批时间"`
  561. InvalidTime time.Time `description:"作废时间"`
  562. StartDateStr string `description:"合同开始日期(字符串类型)"`
  563. EndDateStr string `description:"合同结束日期(字符串类型)"`
  564. CreateTimeStr string `description:"发起审批的时间(字符串类型)"`
  565. ModifyTimeStr string `description:"最后一次修改的时间(字符串类型)"`
  566. ApproveTimeStr string `description:"审批时间(字符串类型)"`
  567. InvalidTimeStr string `description:"作废时间(字符串类型)"`
  568. }
  569. //获取合同审批列表数据
  570. func GetSealApprovalList(childCondition, condition, joinCondition string, childPars, pars []interface{}, startSize, pageSize int) (list []*SealApprovalList, err error) {
  571. o := orm.NewOrm()
  572. sql := `SELECT a.contract_approval_id,a.contract_id,a.apply_content,a.approve_remark,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 from contract_approval a
  573. join
  574. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  575. sql += childCondition
  576. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  577. JOIN seal c ON c.seal_id = a.contract_id
  578. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id ` + joinCondition + `
  579. WHERE c.is_delete = 0 AND a.approval_type="seal" `
  580. sql += condition
  581. sql += ` group by contract_id order by modify_time desc LIMIT ?,? `
  582. _, err = o.Raw(sql, childPars, pars, startSize, pageSize).QueryRows(&list)
  583. return
  584. }
  585. //处理后的
  586. func GetSealApprovalListCountV2(childCondition, condition string, childPars, pars []interface{}) (count int, err error) {
  587. o := orm.NewOrm()
  588. 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,
  589. c.seal_type,c.company_name,c.user_id,c.user_name,c.file_url,c.code from contract_approval a
  590. join
  591. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  592. sql += childCondition
  593. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  594. JOIN seal c ON c.seal_id = a.contract_id
  595. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
  596. WHERE c.is_delete = 0 AND a.approval_type="seal" `
  597. sql += condition
  598. sql += ` group by contract_id `
  599. sql = `select count(*) count from (` + sql + `) g`
  600. err = o.Raw(sql, childPars, pars).QueryRow(&count)
  601. return
  602. }
  603. func GetSealApprovalListV2(childCondition, condition string, childPars, pars []interface{}, startSize, pageSize int) (list []*SealApprovalList, err error) {
  604. o := orm.NewOrm()
  605. sql := `SELECT a.contract_approval_id,a.contract_id,a.apply_content,a.approve_remark,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 from contract_approval a
  606. join
  607. ( SELECT max( contract_approval_id ) max_id,contract_id FROM contract_approval where 1=1 `
  608. sql += childCondition
  609. sql += ` GROUP BY contract_id ) b on a.contract_approval_id=b.max_id
  610. JOIN seal c ON c.seal_id = a.contract_id
  611. JOIN contract_approval_record d on a.contract_approval_id=d.contract_approval_id
  612. WHERE c.is_delete = 0 AND a.approval_type="seal" `
  613. sql += condition
  614. sql += ` group by contract_id order by modify_time desc LIMIT ?,? `
  615. _, err = o.Raw(sql, childPars, pars, startSize, pageSize).QueryRows(&list)
  616. return
  617. }