settle_audit.js 54 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006
  1. 'use strict';
  2. /**
  3. * 与期不同,含原报
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const auditConst = require('../const/audit');
  10. const auditType = auditConst.auditType;
  11. const pushType = auditConst.pushType;
  12. const smsTypeConst = require('../const/sms_type');
  13. const wxConst = require('../const/wechat_template');
  14. module.exports = app => {
  15. class SettleAudit extends app.BaseService {
  16. /**
  17. * 构造函数
  18. *
  19. * @param {Object} ctx - egg全局变量
  20. * @return {void}
  21. */
  22. constructor(ctx) {
  23. super(ctx);
  24. this.tableName = 'settle_audit';
  25. }
  26. // ***** 查询审批人相关
  27. // 获取全部参与人
  28. async getAuditors(settleId, auditTimes) {
  29. return await this.getAllDataByCondition({ where: { settle_id: settleId, audit_times: auditTimes } }); // 全部参与的审批人
  30. }
  31. // 获取全部参与人 分组
  32. async getAuditorGroup(settleId, auditTimes) {
  33. const auditors = await this.getAuditors(settleId, auditTimes); // 全部参与的审批人
  34. return this.ctx.helper.groupAuditors(auditors, 'active_order');
  35. }
  36. // 获取全部参与人 去重
  37. async getUniqAuditors(settle) {
  38. const auditors = await this.getAuditors(settle.id, settle.audit_times); // 全部参与的审批人
  39. const result = [];
  40. auditors.forEach(x => {
  41. if (result.findIndex(r => { return x.audit_id === r.audit_id && x.audit_order === x.audit_order; }) < 0) {
  42. result.push(x);
  43. }
  44. });
  45. return result;
  46. }
  47. // 获取全部参与人 分组 去重
  48. async getUniqAuditorsGroup(settleId, auditTimes) {
  49. const group = await this.getAuditorGroup(settleId, auditTimes);
  50. return this.ctx.helper.groupAuditorsUniq(group);
  51. }
  52. // 获取某个状态的审批人
  53. async getAuditorsByStatus(settleId, auditStatus, auditTimes) {
  54. const cur = await this.db.queryOne(`SELECT * From ${this.tableName} where settle_id = ? AND audit_times = ? AND audit_status = ? ORDER By audit_times DESC, active_order DESC `, [settleId, auditTimes, auditStatus]);
  55. if (!cur) return [];
  56. return await this.getAllDataByCondition({ where: { settle_id: settleId, audit_times: auditTimes, audit_order: cur.audit_order, audit_status: auditStatus}});
  57. }
  58. // 获取全部审批历史
  59. async getAuditorHistory(settleId, auditTimes, reverse = false) {
  60. const history = [];
  61. if (auditTimes >= 1) {
  62. for (let i = 1; i <= auditTimes; i++) {
  63. const auditors = await this.getAuditors(settleId, i);
  64. const group = this.ctx.helper.groupAuditors(auditors);
  65. const historyGroup = [];
  66. const max_order = group.length > 0 && group[group.length - 1].length > 0 ? group[group.length - 1][0].audit_order : -1;
  67. for (const g of group) {
  68. const his = {
  69. auditYear: '', auditDate: '', auditTime: '', audit_time: null,
  70. audit_type: g[0].audit_type, audit_order: g[0].audit_order,
  71. auditors: g
  72. };
  73. his.is_final = his.audit_order === max_order;
  74. his.auditName = his.audit_order === 0 ? '原报' : (his.is_final ? '终审' : his.audit_order + '审');
  75. his.auditCnName = his.audit_order === 0 ? '原报' : (his.is_final ? '终审' : this.ctx.helper.transFormToChinese(his.audit_order) + '审');
  76. his.name = his.audit_type === auditType.key.common ? g[0].name : his.auditName;
  77. let audit_time;
  78. g.forEach(x => {
  79. if (x.audit_status === auditConst.settle.status.checkSkip) return;
  80. if (!his.audit_status || x.audit_status === auditConst.settle.status.checking) his.audit_status = x.audit_status;
  81. if (x.audit_time && (!audit_time || x.audit_time > audit_time)) {
  82. audit_time = x.audit_time;
  83. if (his.audit_status !== auditConst.settle.status.checking) his.audit_status = x.audit_status;
  84. }
  85. });
  86. if (audit_time) {
  87. his.audit_time = audit_time;
  88. const auditTime = this.ctx.moment(audit_time);
  89. his.auditYear = auditTime.format('YYYY');
  90. his.auditDate = auditTime.format('MM-DD');
  91. his.auditTime = auditTime.format('HH:mm:ss');
  92. }
  93. historyGroup.push(his);
  94. }
  95. if (reverse) {
  96. history.push(historyGroup.reverse());
  97. } else {
  98. history.push(historyGroup);
  99. }
  100. }
  101. }
  102. return history;
  103. }
  104. async getAllAuditors(tenderId) {
  105. const sql =
  106. 'SELECT audit_id, tid FROM ' + this.tableName +
  107. ' WHERE tid = ?' +
  108. ' GROUP BY audit_id';
  109. const sqlParam = [tenderId];
  110. return this.db.query(sql, sqlParam);
  111. }
  112. // ***** 查询审批人相关
  113. // ***** 修改审批人相关
  114. /**
  115. * 获取 最新审核顺序
  116. *
  117. * @param {Number} settleId - 期id
  118. * @param {Number} auditTimes - 第几次审批
  119. * @return {Promise<number>}
  120. */
  121. async getNewOrder(settleId, auditTimes = 1) {
  122. const sql = `SELECT Max(active_order) As max_order, Max(audit_order) As max_audit_order FROM ${this.tableName} Where settle_id = ? and audit_times = ?`;
  123. const result = await this.db.queryOne(sql, [settleId, auditTimes]);
  124. return result && result.max_order ? [result.max_order + 1, result.max_audit_order + 1] : [1, 1];
  125. }
  126. /**
  127. * 同步审核人order
  128. * @param transaction - 事务
  129. * @param {Number} settleId - 结算期id
  130. * @param {Number} auditOrder - 审核顺序(实际顺序)
  131. * @param {Number} auditTimes - 第几次审批
  132. * @param {String} selfOperate - 操作符(+/-)
  133. * @return {Promise<*>}
  134. * @private
  135. */
  136. async _syncAuditOrder(transaction, settleId, auditOrder, auditTimes, selfOperate = '-') {
  137. this.initSqlBuilder();
  138. this.sqlBuilder.setAndWhere('settle_id', {
  139. value: settleId,
  140. operate: '=',
  141. });
  142. this.sqlBuilder.setAndWhere('active_order', {
  143. value: auditOrder,
  144. operate: '>=',
  145. });
  146. this.sqlBuilder.setAndWhere('audit_times', {
  147. value: auditTimes,
  148. operate: '=',
  149. });
  150. this.sqlBuilder.setUpdateData('active_order', {
  151. value: 1,
  152. selfOperate: selfOperate,
  153. });
  154. this.sqlBuilder.setUpdateData('audit_order', {
  155. value: 1,
  156. selfOperate: selfOperate,
  157. });
  158. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'update');
  159. const data = await transaction.query(sql, sqlParam);
  160. return data;
  161. }
  162. /**
  163. * 新增审核人
  164. *
  165. * @param {Number} settleId - 期id
  166. * @param {Number} auditor - 审核人
  167. * @param {Number} auditTimes - 第几次审批
  168. * @param {Number} is_gdzs - 是否固定终审
  169. * @return {Promise<number>}
  170. */
  171. async addAuditor(settleId, auditor, auditTimes = 1, is_gdzs = 0) {
  172. let [newOrder, newAuditOrder] = await this.getNewOrder(settleId, auditTimes);
  173. // 判断是否存在固定终审,存在则newOrder - 1并使终审order+1
  174. newOrder = is_gdzs === 1 ? newOrder - 1 : newOrder;
  175. newAuditOrder = is_gdzs === 1 ? newAuditOrder - 1 : newAuditOrder;
  176. const transaction = await this.db.beginTransaction();
  177. try {
  178. if (is_gdzs) await this._syncAuditOrder(transaction, settleId, newOrder, auditTimes, '+');
  179. const data = {
  180. tid: this.ctx.tender.id, settle_id: settleId, audit_id: auditor.id,
  181. name: auditor.name, company: auditor.company, role: auditor.role, mobile: auditor.mobile,
  182. audit_times: auditTimes, active_order: newOrder, audit_status: auditConst.settle.status.uncheck,
  183. audit_order: newAuditOrder, audit_type: auditType.key.common,
  184. };
  185. const result = await transaction.insert(this.tableName, data);
  186. await transaction.commit();
  187. return result.effectRows = 1;
  188. } catch (err) {
  189. await transaction.rollback();
  190. throw err;
  191. }
  192. return false;
  193. }
  194. /**
  195. * 移除审核人
  196. *
  197. * @param {Number} settleId - 期id
  198. * @param {Number} auditorId - 审核人id
  199. * @param {Number} auditTimes - 第几次审批
  200. * @return {Promise<boolean>}
  201. */
  202. async deleteAuditor(settleId, auditorId, auditTimes = 1) {
  203. const transaction = await this.db.beginTransaction();
  204. try {
  205. const condition = { settle_id: settleId, audit_id: auditorId, audit_times: auditTimes };
  206. const auditor = await this.getDataByCondition(condition);
  207. if (!auditor) throw '审批人不存在';
  208. // 移除整个流程的人
  209. await transaction.delete(this.tableName, { settle_id: settleId, active_order: auditor.active_order, audit_times: auditTimes});
  210. await this._syncAuditOrder(transaction, settleId, auditor.active_order, auditTimes);
  211. await transaction.commit();
  212. } catch (err) {
  213. await transaction.rollback();
  214. throw err;
  215. }
  216. return true;
  217. }
  218. // 拷贝上一期审批流程
  219. async copyPreAuditors(transaction, preSettle, newSettle) {
  220. const auditors = preSettle ? await this.getUniqAuditors(preSettle) : [];
  221. const newAuditors = [];
  222. // 添加原报
  223. const user = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  224. newAuditors.push({
  225. tid: newSettle.tid, settle_id: newSettle.id,
  226. audit_id: this.ctx.session.sessionUser.accountId,
  227. audit_times: 1, audit_order: 0, audit_type: auditConst.auditType.key.common,
  228. active_order: 0, audit_status: auditConst.settle.status.uncheck,
  229. name: user.name, company: user.company, role: user.role, mobile: user.mobile,
  230. });
  231. // 添加其他参与人
  232. for (const a of auditors) {
  233. newAuditors.push({
  234. tid: newSettle.tid, settle_id: newSettle.id,
  235. audit_id: a.id,
  236. audit_times: 1, audit_order: a.audit_order, audit_type: a.audit_type,
  237. active_order: a.audit_order, audit_status: auditConst.settle.status.uncheck,
  238. name: a.name, company: a.company, role: a.role, mobile: a.mobile,
  239. });
  240. }
  241. const result = await transaction.insert(this.tableName, newAuditors);
  242. if (result.affectedRows !== newAuditors.length) throw '初始化审批流程错误';
  243. }
  244. // 固定审批流-更新
  245. async updateNewAuditList(settle, newList) {
  246. const newAuditsInfo = await this.ctx.service.projectAccount.getAllDataByCondition({ where: { id: newList.map(x => { return x.audit_id; })} });
  247. const transaction = await this.db.beginTransaction();
  248. try {
  249. // 先删除旧的审批流,再添加新的
  250. await transaction.query(`DELETE FROM ${this.tableName} where settle_id = ? and audit_times = ? and audit_order > 0`, [settle.id, settle.audit_times]);
  251. // todo 协同
  252. //await transaction.delete(this.ctx.service.settleAuditAss.tableName, { settle_id: settle.id, audit_times: settle.audit_times });
  253. const newAuditors = [];
  254. for (const auditor of newList) {
  255. const auditorInfo = newAuditsInfo.find(x => { return x.id === auditor.audit_id; });
  256. if (!auditorInfo) throw '配置的审批人不存在';
  257. newAuditors.push({
  258. tid: settle.tid, settle_id: settle.id, audit_id: auditor.audit_id,
  259. name: auditorInfo.name, company: auditorInfo.company, role: auditorInfo.role, mobile: auditorInfo.mobile,
  260. audit_times: settle.audit_times, active_order: auditor.audit_order, audit_status: auditConst.settle.status.uncheck,
  261. audit_type: auditor.audit_type, audit_order: auditor.audit_order,
  262. });
  263. }
  264. if(newAuditors.length > 0) await transaction.insert(this.tableName, newAuditors);
  265. await transaction.commit();
  266. } catch (err) {
  267. await transaction.rollback();
  268. throw err;
  269. }
  270. }
  271. // 固定终审-更新
  272. async updateLastAudit(settle, auditList, lastId) {
  273. const lastUser = await this.ctx.service.projectAccount.getDataById(lastId);
  274. const transaction = await this.db.beginTransaction();
  275. try {
  276. // 先判断auditList里的aid是否与lastId相同,相同则删除并重新更新order
  277. const existAudit = auditList.find(x => { return x.audit_id === lastId });
  278. let auditOrder = auditList.length > 0 ? auditList.reduce((rst, a) => { return Math.max(rst, a.active_order)}, 0) + 1 : 1; // 最大值 + 1
  279. if (existAudit) {
  280. await transaction.delete(this.tableName, { settle_id: settle.id, audit_times: settle.audit_times, audit_id: lastId });
  281. const sameOrder = auditList.filter(x => { return x.active_order === existAudit.active_order });
  282. if (sameOrder.length === 1) {
  283. const updateData = [];
  284. auditList.forEach(x => {
  285. if (x.active_order <= existAudit.active_order) return;
  286. updateData.push({id: x.id, active_order: x.active_order - 1, audit_order: x.audit_order - 1});
  287. });
  288. if (updateData.length > 0) {
  289. await transaction.updateRows(updateData);
  290. }
  291. auditOrder = auditOrder - 1;
  292. }
  293. }
  294. // 添加终审
  295. const newAuditor = {
  296. tid: settle.tid, settle_id: settle.id, audit_id: lastId,
  297. name: lastUser.name, company: lastUser.company, role: lastUser.role, mobile: lastUser.mobile,
  298. audit_times: settle.audit_times, active_order: auditOrder, audit_status: auditConst.settle.status.uncheck,
  299. audit_type: auditType.key.common, audit_order: auditOrder,
  300. };
  301. await transaction.insert(this.tableName, newAuditor);
  302. await transaction.commit();
  303. } catch (err) {
  304. await transaction.rollback();
  305. throw err;
  306. }
  307. }
  308. // ***** 修改审批人相关
  309. // ***** 审批操作
  310. /**
  311. * 用于添加推送所需的content内容
  312. * @param {Number} pid 项目id
  313. * @param {Number} tid 台账id
  314. * @param {Number} sid 期id
  315. * @param {Number} uid 审核人id
  316. */
  317. async _getNoticeContent(pid, tid, sid, uid, opinion = '') {
  318. const noticeSql =
  319. 'SELECT * FROM (SELECT ' +
  320. ' t.`id` As `tid`, t.`name`, s.`settle_order` as `order`, pa.`name` As `su_name`, pa.role As `su_role`' +
  321. ` FROM (SELECT * FROM ${this.ctx.service.tender.tableName} WHERE id = ? ) As t` +
  322. ` LEFT JOIN ${this.ctx.service.settle.tableName} As s On s.id = ?` +
  323. ` LEFT JOIN ${this.ctx.service.projectAccount.tableName} As pa ON pa.id = ?` +
  324. ' WHERE t.`project_id` = ? ) as new_t GROUP BY new_t.`tid`';
  325. const noticeSqlParam = [tid, sid, uid, pid];
  326. const content = await this.db.query(noticeSql, noticeSqlParam);
  327. if (content.length) {
  328. content[0].opinion = opinion;
  329. }
  330. return content.length ? JSON.stringify(content[0]) : '';
  331. }
  332. async start(settle) {
  333. const audits = await this.getAllDataByCondition({ where: { settle_id: settle.id, audit_times: settle.audit_times, audit_order: 1 } });
  334. if (audits.length === 0) {
  335. if(this.ctx.tender.info.shenpi.settle === shenpiConst.sp_status.gdspl) {
  336. throw '请联系管理员添加审批人';
  337. } else {
  338. throw '请先选择审批人,再上报数据';
  339. }
  340. }
  341. const transaction = await this.db.beginTransaction();
  342. try {
  343. const audit_time = new Date();
  344. // 更新原报数据
  345. await transaction.update(this.tableName, { audit_status: auditConst.settle.status.checked, audit_time }, { where: { settle_id: settle.id, audit_times: settle.audit_times, audit_order: 0 } });
  346. // 更新下一审批人数据
  347. const updateData = audits.map(x => { return { id: x.id, audit_status: auditConst.settle.status.checking } });
  348. await transaction.updateRows(this.tableName, updateData);
  349. // 生成结算台账
  350. const settleSum = await this.ctx.service.settle.doSettle(transaction, settle);
  351. // todo 计算部分缓存汇总数据
  352. await transaction.update(this.ctx.service.settle.tableName, {
  353. id: settle.id, audit_status: auditConst.settle.status.checking,
  354. ...settleSum,
  355. final_sid: settle.latestStage.id, final_sorder: settle.latestStage.order,
  356. });
  357. // 多人协同,取消下一审批人存在的锁定
  358. // await this.ctx.service.settleAuditAss.cancelLock(settle, audits.map(x => { return x.audit_id; }), transaction);
  359. // todo 添加短信通知-需要审批提醒功能
  360. const shenpiUrl = await this.ctx.helper.urlToShort(this.ctx.protocol + '://' + this.ctx.host + '/wap/tender/' + settle.tid + '/settle/' + settle.settle_order);
  361. const auditIds = this._.map(audits, 'audit_id');
  362. const users = this._.map(settle.auditAssists.filter(x => { return auditIds.indexOf(x.user_id) >= 0; }), 'ass_user_id');
  363. users.push(...auditIds);
  364. // await this.ctx.helper.sendAliSms(users, smsTypeConst.const.JS, smsTypeConst.judge.approval.toString(), SmsAliConst.template.settle_check, {
  365. // qi: settle.audit_order,
  366. // code: shenpiUrl,
  367. // });
  368. // 微信模板通知
  369. const wechatData = {
  370. wap_url: shenpiUrl,
  371. qi: settle.settle_order,
  372. status: wxConst.status.check,
  373. tips: wxConst.tips.check,
  374. code: this.ctx.session.sessionProject.code,
  375. };
  376. await this.ctx.helper.sendWechat(users, smsTypeConst.const.JS, smsTypeConst.judge.approval.toString(), wxConst.template.settle, wechatData);
  377. // todo 上报/审批 - 检查三方特殊推送
  378. // await this.ctx.service.specMsg.addSettleMsg(transaction, this.ctx.session.sessionProject.id, settle, pushOperate.settle.flow);
  379. await transaction.commit();
  380. } catch (err) {
  381. await transaction.rollback();
  382. throw err;
  383. }
  384. }
  385. async _checked(settle, opinion) {
  386. const accountId = this.ctx.session.sessionUser.accountId;
  387. const time = new Date();
  388. const selfAudit = settle.curAuditors.find(x => { return x.audit_id === accountId; });
  389. if (!selfAudit) throw '当前标段您无权审批';
  390. const nextAudits = await this.getAllDataByCondition({ where: { settle_id: settle.id, audit_times: settle.audit_times, active_order: selfAudit.active_order + 1 } });
  391. const transaction = await this.db.beginTransaction();
  392. try {
  393. // 添加通知
  394. const noticeContent = await this._getNoticeContent(this.ctx.session.sessionProject.id, settle.tid, settle.id, accountId, opinion);
  395. const defaultNoticeRecord = {
  396. pid: this.ctx.session.sessionProject.id,
  397. type: pushType.settle,
  398. status: auditConst.settle.status.checked,
  399. content: noticeContent,
  400. };
  401. const records = settle.userIds.map(x => {
  402. return { uid: x, ...defaultNoticeRecord };
  403. });
  404. await transaction.insert('zh_notice', records);
  405. // 更新本人审批状态
  406. await transaction.update(this.tableName, {
  407. id: selfAudit.id,
  408. audit_status: auditConst.settle.status.checked, opinion: opinion,
  409. audit_time: time,
  410. });
  411. let auditStatus;
  412. if (settle.curAuditors.length === 1 || selfAudit.audit_type !== auditType.key.and) {
  413. // 或签更新他人审批状态
  414. if (selfAudit.audit_type === auditType.key.or) {
  415. const updateOther = [];
  416. for (const audit of settle.curAuditors) {
  417. if (audit.audit_id === selfAudit.audit_id) continue;
  418. updateOther.push({
  419. id: audit.id,
  420. audit_status: auditConst.settle.status.checkSkip,
  421. opinion: '',
  422. audit_time: time,
  423. });
  424. }
  425. if (updateOther.length > 0) transaction.updateRows(this.tableName, updateOther);
  426. }
  427. // 无下一审核人表示,审核结束
  428. auditStatus = nextAudits.length > 0 ? auditConst.settle.status.checking : auditConst.settle.status.checked;
  429. if (nextAudits.length > 0) {
  430. // 流程至下一审批人
  431. const updateData = nextAudits.map(x => { return { id: x.id, audit_status: auditConst.settle.status.checking }; });
  432. await transaction.updateRows(this.tableName, updateData);
  433. // todo 多人协同,取消下一审批人存在的锁定
  434. // await this.ctx.service.settleAuditAss.cancelLock(settle, nextAudits.map(x => { return x.audit_id; }), transaction);
  435. // todo 添加短信通知-需要审批提醒功能
  436. const shenpiUrl = await this.ctx.helper.urlToShort(this.ctx.protocol + '://' + this.ctx.host + '/wap/tender/' + this.ctx.tender.id + '/settle/' + settle.settle_order);
  437. const nextAuditIds = this._.map(nextAudits, 'audit_id');
  438. const users = this._.map(this._.filter(this.ctx.auditAssists, function (x) { return nextAuditIds.indexOf(x.user_id) >= 0; }), 'ass_user_id');
  439. users.push(...nextAuditIds);
  440. // await this.ctx.helper.sendAliSms(users, smsTypeConst.const.JS, smsTypeConst.judge.approval.toString(), SmsAliConst.template.settle_check, {
  441. // qi: settle.settle_order,
  442. // code: shenpiUrl,
  443. // });
  444. // 微信模板通知
  445. const wechatData = {
  446. wap_url: shenpiUrl,
  447. qi: settle.settle_order,
  448. status: wxConst.status.check,
  449. tips: wxConst.tips.check,
  450. code: this.ctx.session.sessionProject.code,
  451. };
  452. await this.ctx.helper.sendWechat(users, smsTypeConst.const.JS, smsTypeConst.judge.approval.toString(), wxConst.template.settle, wechatData);
  453. } else {
  454. // 添加短信通知-审批通过提醒功能
  455. const users = this._.uniq(settle.userIds);
  456. // await this.ctx.helper.sendAliSms(users, smsTypeConst.const.JS, smsTypeConst.judge.result.toString(), SmsAliConst.template.settle_result, {
  457. // qi: settle.settle_order,
  458. // status: SmsAliConst.status.success,
  459. // });
  460. // 微信模板通知
  461. const shenpiUrl = await this.ctx.helper.urlToShort(this.ctx.protocol + '://' + this.ctx.host + '/wap/tender/' + this.ctx.tender.id + '/settle/' + settle.settle_order);
  462. const wechatData = {
  463. wap_url: shenpiUrl,
  464. qi: settle.settle_order,
  465. status: wxConst.status.success,
  466. tips: wxConst.tips.success,
  467. code: this.ctx.session.sessionProject.code,
  468. };
  469. await this.ctx.helper.sendWechat(users, smsTypeConst.const.JS, smsTypeConst.judge.result.toString(), wxConst.template.settle, wechatData);
  470. // todo 审批通过 - 检查三方特殊推送
  471. // await this.ctx.service.specMsg.addSettleMsg(transaction, this.ctx.session.sessionProject.id, settle, pushOperate.settle.checked);
  472. }
  473. // todo 上报/审批 - 检查三方特殊推送
  474. // await this.ctx.service.specMsg.addSettleMsg(transaction, this.ctx.session.sessionProject.id, settle, pushOperate.settle.flow);
  475. } else {
  476. auditStatus = auditConst.settle.status.checking;
  477. }
  478. // 同步 期信息
  479. await transaction.update(this.ctx.service.settle.tableName, { id: settle.id, audit_status: auditStatus });
  480. await transaction.commit();
  481. } catch (err) {
  482. await transaction.rollback();
  483. throw err;
  484. }
  485. }
  486. async _checkNo(settle, opinion) {
  487. const pid = this.ctx.session.sessionProject.id;
  488. const accountId = this.ctx.session.sessionUser.accountId;
  489. const time = new Date();
  490. // 整理当前流程审核人状态更新
  491. const selfAudit = settle.curAuditors.find(x => { return x.audit_id === accountId; });
  492. if (!selfAudit) throw '当前标段您无权审批';
  493. const auditors = await this.getUniqAuditors(settle); // 全部参与的审批人
  494. const newAuditors = auditors.map(x => {
  495. return {
  496. tid: settle.tid, settle_id: settle.id, audit_id: x.audit_id,
  497. audit_times: settle.audit_times + 1, audit_order: x.audit_order, audit_type: x.audit_type,
  498. active_order: x.audit_order, audit_status: auditConst.settle.status.uncheck,
  499. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  500. }
  501. });
  502. const transaction = await this.db.beginTransaction();
  503. try {
  504. // 添加提醒
  505. const noticeContent = await this._getNoticeContent(pid, selfAudit.tid, settle.id, selfAudit.audit_id, opinion);
  506. const defaultNoticeRecord = { pid, type: pushType.settle, status: auditConst.settle.status.checkNo, content: noticeContent };
  507. const records = settle.userIds.map(x => {
  508. return { uid: x, ...defaultNoticeRecord };
  509. });
  510. await transaction.insert(this.ctx.service.noticePush.tableName, records);
  511. // 更新审批人状态数据
  512. const updateData = [];
  513. settle.curAuditors.forEach(x => {
  514. if (x.audit_id === selfAudit.audit_id) {
  515. updateData.push({ id: x.id, audit_status: auditConst.settle.status.checkNo, opinion: opinion, audit_time: time});
  516. } else {
  517. updateData.push({ id: x.id, audit_status: auditConst.settle.status.checkSkip, opinion: '', audit_time: null});
  518. }
  519. });
  520. await transaction.updateRows(this.tableName, updateData);
  521. // 更新 期信息
  522. await transaction.update(this.ctx.service.settle.tableName, {
  523. id: settle.id, audit_status: auditConst.settle.status.checkNo, audit_times: settle.audit_times + 1,
  524. });
  525. // 拷贝新一次审核流程列表
  526. await transaction.insert(this.tableName, newAuditors);
  527. // todo 锁定本人数据,保留锁定数据相关确认状态
  528. // await this.ctx.service.settleAuditAss.lockConfirm4CheckNo(settle, curAuditorIds, auditors, transaction);
  529. // todo 添加短信通知-审批退回提醒功能
  530. const users = this._.uniq(settle.userIds);
  531. // await this.ctx.helper.sendAliSms(users, smsTypeConst.const.JS, smsTypeConst.judge.result.toString(), SmsAliConst.template.settle_result, {
  532. // qi: settle.settle_order, status: SmsAliConst.status.back,
  533. // });
  534. // 微信模板通知
  535. const shenpiUrl = await this.ctx.helper.urlToShort(this.ctx.protocol + '://' + this.ctx.host + '/wap/tender/' + settle.tid + '/settle/' + settle.settle_order);
  536. const wechatData = {
  537. wap_url: shenpiUrl,
  538. qi: settle.settle_order,
  539. status: wxConst.status.back,
  540. tips: wxConst.tips.back,
  541. code: this.ctx.session.sessionProject.code,
  542. };
  543. await this.ctx.helper.sendWechat(users, smsTypeConst.const.JS, smsTypeConst.judge.result.toString(), wxConst.template.settle, wechatData);
  544. // todo 上报/审批 - 检查三方特殊推送
  545. // await this.ctx.service.specMsg.addSettleMsg(transaction, pid, settle, pushOperate.settle.flow);
  546. await transaction.commit();
  547. } catch (err) {
  548. await transaction.rollback();
  549. throw err;
  550. }
  551. }
  552. async _checkNoPre(settle, opinion) {
  553. const pid = this.ctx.session.sessionProject.id;
  554. const accountId = this.ctx.session.sessionUser.accountId;
  555. const time = new Date();
  556. // 整理当前流程审核人状态更新
  557. const selfAudit = settle.curAuditors.find(x => { return x.audit_id === accountId; });
  558. if (!selfAudit) throw '当前标段您无权审批';
  559. const preAuditors = settle.userGroups.find(x => { return x[0].audit_order === selfAudit.audit_order - 1; });
  560. const transaction = await this.db.beginTransaction();
  561. try {
  562. // 添加通知
  563. const noticeContent = await this._getNoticeContent(pid, settle.tid, settle.id, selfAudit.audit_id, opinion);
  564. const defaultNoticeRecord = {
  565. pid, type: pushType.settle, status: auditConst.settle.status.checkNoPre, content: noticeContent,
  566. };
  567. const records = settle.userIds.map(x => {
  568. return { uid: x, ...defaultNoticeRecord };
  569. });
  570. await transaction.insert('zh_notice', records);
  571. // 更新同一流程所有审批人状态
  572. const updateData = [];
  573. for (const audit of settle.curAuditors) {
  574. if (audit.audit_id === selfAudit.audit_id) {
  575. updateData.push({
  576. id: audit.id, audit_status: auditConst.settle.status.checkNoPre, opinion, audit_time: time,
  577. });
  578. } else {
  579. updateData.push({
  580. id: audit.id, audit_status: auditConst.settle.status.checkSkip, opinion: '', audit_time: null,
  581. });
  582. }
  583. }
  584. await transaction.updateRows(this.tableName, updateData);
  585. // 顺移其后审核人流程顺序
  586. const sql = 'UPDATE ' + this.tableName + ' SET `active_order` = `active_order` + 2 WHERE settle_id = ? AND audit_times = ? AND `active_order` > ?';
  587. await transaction.query(sql, [settle.id, selfAudit.audit_times, selfAudit.active_order]);
  588. // 上一审批人,当前审批人 再次添加至流程
  589. const newAuditors = [];
  590. preAuditors.forEach(x => {
  591. newAuditors.push({
  592. tid: x.tid, settle_id: x.settle_id, audit_id: x.audit_id,
  593. audit_times: x.audit_times, audit_order: selfAudit.audit_order - 1,
  594. audit_status: auditConst.settle.status.checking,
  595. audit_type: x.audit_type, active_order: selfAudit.active_order + 1,
  596. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  597. });
  598. });
  599. settle.flowAuditors.forEach(x => {
  600. newAuditors.push({
  601. tid: x.tid, settle_id: x.settle_id, audit_id: x.audit_id,
  602. audit_times: x.audit_times, active_order: selfAudit.active_order + 2,
  603. audit_status: auditConst.settle.status.uncheck,
  604. audit_type: x.audit_type, audit_order: x.audit_order,
  605. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  606. });
  607. });
  608. await transaction.insert(this.tableName, newAuditors);
  609. const preAuditorIds = preAuditors.map(x => { return x.audit_id; });
  610. // todo 锁定本人数据,保留锁定数据相关确认状态
  611. // await this.ctx.service.settleAuditAss.lockConfirm4CheckNoPre(settle, settle.curAuditorIds, preAuditorIds, transaction);
  612. // 同步 期信息
  613. await transaction.update(this.ctx.service.settle.tableName, {
  614. id: settle.id, audit_status: auditConst.settle.status.checkNoPre,
  615. });
  616. const shenpiUrl = await this.ctx.helper.urlToShort(this.ctx.protocol + '://' + this.ctx.host + '/wap/tender/' + settle.tid + '/settle/' + settle.settle_order);
  617. const users = this._.map(settle.auditAssists.filter(x => {return preAuditorIds.indexOf(x.user_id) >= 0 }), 'ass_user_id');
  618. users.push(...preAuditorIds);
  619. // await this.ctx.helper.sendAliSms(users, smsTypeConst.const.JS, smsTypeConst.judge.approval.toString(), SmsAliConst.template.settle_check, {
  620. // qi: settle.settle_order,
  621. // code: shenpiUrl,
  622. // });
  623. // 微信模板通知
  624. const wechatData = {
  625. wap_url: shenpiUrl,
  626. qi: settle.settle_order,
  627. status: wxConst.status.check,
  628. tips: wxConst.tips.check,
  629. code: this.ctx.session.sessionProject.code,
  630. };
  631. await this.ctx.helper.sendWechat(users, smsTypeConst.const.JS, smsTypeConst.judge.approval.toString(), wxConst.template.settle, wechatData);
  632. // todo 上报/审批 - 检查三方特殊推送
  633. // await this.ctx.service.specMsg.addSettleMsg(transaction, pid, settle, pushOperate.settle.flow);
  634. await transaction.commit();
  635. } catch (err) {
  636. await transaction.rollback();
  637. throw err;
  638. }
  639. }
  640. async check(settle, checkType, opinion = '') {
  641. switch (checkType) {
  642. case auditConst.settle.status.checked:
  643. await this._checked(settle, opinion);
  644. break;
  645. case auditConst.settle.status.checkNo:
  646. await this._checkNo(settle, opinion);
  647. break;
  648. case auditConst.settle.status.checkNoPre:
  649. await this._checkNoPre(settle, opinion);
  650. break;
  651. default:
  652. throw '无效审批操作';
  653. }
  654. }
  655. async checkAgain(settle, force = false) {
  656. const accountId = this.ctx.session.sessionUser.accountId;
  657. const time = new Date();
  658. // 整理当前流程审核人状态更新
  659. const finalAudits = settle.auditorGroups[settle.auditorGroups.length - 1];
  660. if (!finalAudits || finalAudits.length === 0 || finalAudits[0].audit_order < 1) throw '审核数据错误';
  661. const selfAudit = finalAudits.find(x => { return x.audit_id === accountId; });
  662. if (!selfAudit && !force) throw '当前标段您无权审批';
  663. const finalAudit = selfAudit || finalAudits[0];
  664. const transaction = await this.db.beginTransaction();
  665. try {
  666. // 当前审批人2次添加至流程中
  667. const checkAgainAuditors = [], checkingAuditors = [];
  668. finalAudits.forEach(x => {
  669. checkAgainAuditors.push({
  670. tid: x.tid, settle_id: x.settle_id, audit_id: x.audit_id,
  671. audit_type: x.audit_type, audit_order: x.audit_order,
  672. audit_times: x.audit_times, active_order: x.active_order + 1,
  673. audit_status: x.audit_id === finalAudit.audit_id ? auditConst.settle.status.checkAgain : auditConst.settle.status.checkSkip,
  674. audit_time: time, opinion: '',
  675. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  676. });
  677. });
  678. finalAudits.forEach(x => {
  679. checkingAuditors.push({
  680. tid: x.tid, settle_id: x.settle_id, audit_id: x.audit_id,
  681. audit_type: x.audit_type, audit_order: x.audit_order,
  682. audit_times: x.audit_times, active_order: x.active_order + 2,
  683. audit_status: auditConst.settle.status.checking, audit_time: time, opinion: '',
  684. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  685. });
  686. });
  687. await transaction.insert(this.tableName, [...checkAgainAuditors, ...checkingAuditors]);
  688. // 同步 期信息
  689. await transaction.update(this.ctx.service.settle.tableName, {
  690. id: settle.id, audit_status: auditConst.settle.status.checking,
  691. });
  692. // todo 添加短信通知-需要审批提醒功能
  693. const shenpiUrl = await this.ctx.helper.urlToShort(this.ctx.protocol + '://' + this.ctx.host + '/wap/tender/' + settle.tid + '/settle/' + settle.settle_order);
  694. const users = this._.map(settle.auditAssists.filter(x => { return settle.finalAuditorIds.indexOf(x.user_id) >= 0; }), 'ass_user_id');
  695. users.push(...settle.finalAuditorIds);
  696. // await this.ctx.helper.sendAliSms(users, smsTypeConst.const.JS, smsTypeConst.judge.approval.toString(), SmsAliConst.template.settle_check, {
  697. // qi: settle.settle_order, code: shenpiUrl,
  698. // });
  699. // 微信模板通知
  700. const wechatData = {
  701. wap_url: shenpiUrl,
  702. qi: settle.settle_order,
  703. status: wxConst.status.check,
  704. tips: wxConst.tips.check,
  705. code: this.ctx.session.sessionProject.code,
  706. };
  707. await this.ctx.helper.sendWechat(users, smsTypeConst.const.JS, smsTypeConst.judge.approval.toString(), wxConst.template.settle, wechatData);
  708. // todo 上报/审批 - 检查三方特殊推送
  709. // await this.ctx.service.specMsg.addSettleMsg(transaction, this.ctx.session.sessionProject.id, settle, pushOperate.settle.flow);
  710. await transaction.commit();
  711. } catch (err) {
  712. await transaction.rollback();
  713. throw err;
  714. }
  715. }
  716. /**
  717. * 原报撤回,直接改动审批人状态
  718. * 如果存在审批人数据,将其改为原报流程数据,但保留原提交人
  719. *
  720. * 一审 1 A checking -> A uncheck status改 pay/jl:删0(jl为增量数据,只删重复部分) 1->0 删1
  721. * ...
  722. *
  723. * @param settle
  724. * @returns {Promise<void>}
  725. * @private
  726. */
  727. async _userCheckCancel(settle) {
  728. const transaction = await this.db.beginTransaction();
  729. try {
  730. // 整理当前流程审核人状态更新
  731. // 审批人变成待审批状态
  732. const updateData = settle.curAuditors.map(x => {
  733. return {
  734. id: x.id, audit_status: auditConst.settle.status.uncheck,
  735. audit_time: null, opinion: '',
  736. }
  737. });
  738. await transaction.updateRows(this.tableName, updateData);
  739. await transaction.update(this.ctx.service.settle.tableName, {
  740. id: settle.id, audit_times: settle.audit_times,
  741. audit_status: settle.audit_times === 1 ? auditConst.settle.status.uncheck : auditConst.settle.status.checkNo,
  742. });
  743. // todo 上报/审批 - 检查三方特殊推送
  744. // await this.ctx.service.specMsg.addSettleMsg(transaction, this.ctx.session.sessionProject.id, settle, pushOperate.settle.flow);
  745. await transaction.commit();
  746. } catch(err) {
  747. await transaction.rollback();
  748. throw err;
  749. }
  750. }
  751. /**
  752. * 审批人撤回审批通过,插入两条数据
  753. *
  754. * @param settle
  755. * @returns {Promise<void>}
  756. * @private
  757. */
  758. async _auditCheckCancel(settle) {
  759. if (settle.curAuditors.length === 0 || settle.curAuditors[0].active_order <= 1) {
  760. throw '撤回用户数据错误';
  761. }
  762. const accountId = this.ctx.session.sessionUser.accountId;
  763. const selfAuditor = settle.preAuditors.find(x => { return x.audit_id === accountId; });
  764. if (!selfAuditor) throw '撤回用户数据错误';
  765. const time = new Date();
  766. const transaction = await this.db.beginTransaction();
  767. try {
  768. // 整理当前流程审核人状态更新
  769. // 顺移其后审核人流程顺序
  770. const sql = 'UPDATE ' + this.tableName + ' SET `active_order` = `active_order` + 2 WHERE settle_id = ? AND audit_times = ? AND `active_order` > ?';
  771. await transaction.query(sql, [settle.id, selfAuditor.audit_times, settle.curAuditors[0].active_order]);
  772. // 当前审批人2次添加至流程中
  773. const checkCancelAuditors = [], checkingAuditors = [];
  774. settle.preAuditors.forEach(x => {
  775. checkCancelAuditors.push({
  776. tid: settle.tid, settle_id: settle.id, audit_id: x.audit_id,
  777. audit_times: x.audit_times, active_order: x.active_order + 1,
  778. audit_type: x.audit_type, audit_order: x.audit_order,
  779. status: x.audit_id === selfAuditor.audit_id ? auditConst.settle.status.checkCancel : auditConst.settle.status.checkSkip,
  780. audit_time: time, opinion: '',
  781. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  782. });
  783. });
  784. settle.preAuditors.forEach(x => {
  785. checkingAuditors.push({
  786. tid: settle.tid, settle_id: settle.id, audit_id: x.audit_id,
  787. audit_times: x.audit_times, active_order: x.active_order + 2,
  788. audit_type: x.audit_type, audit_order: x.audit_order,
  789. status: auditConst.settle.status.checking,
  790. audit_time: time, opinion: '',
  791. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  792. });
  793. });
  794. await transaction.insert(this.tableName, [...checkCancelAuditors, ...checkingAuditors]);
  795. // 当前审批人变成待审批
  796. await transaction.updateRows(this.tableName, settle.curAuditors.map(x => { return {
  797. id: x.id, audit_time: null, status: auditConst.settle.status.uncheck, active_order: x.active_order + 2
  798. }}));
  799. // 同步 期信息
  800. await transaction.update(this.ctx.service.settle.tableName, {
  801. id: settle.id, audit_times: settle.audit_times,
  802. });
  803. // todo 上报/审批 - 检查三方特殊推送
  804. // await this.ctx.service.specMsg.addSettleMsg(transaction, this.ctx.session.sessionProject.id, settle, pushOperate.settle.flow);
  805. await transaction.commit();
  806. } catch(err) {
  807. await transaction.rollback();
  808. throw err;
  809. }
  810. }
  811. /**
  812. * 审批人撤回审批退回上一人,插入两条数据
  813. *
  814. * @param settle
  815. * @returns {Promise<void>}
  816. * @private
  817. */
  818. async _auditCheckCancelNoPre(settle) {
  819. if (settle.curAuditors.length === 0 || settle.curAuditors[0].active_order <= 1) {
  820. throw '撤回用户数据错误';
  821. }
  822. const accountId = this.ctx.session.sessionUser.accountId;
  823. const selfAuditor = settle.preAuditors.find(x => { return x.audit_id === accountId; });
  824. if (!selfAuditor) throw '撤回用户数据错误';
  825. const time = new Date();
  826. const transaction = await this.db.beginTransaction();
  827. try {
  828. // 整理当前流程审核人状态更新
  829. // 删除当前审批人
  830. await transaction.delete(this.tableName, { id: settle.curAuditors.map(x => { return x.id; }) });
  831. // 添加撤回人到审批流程中
  832. const newAuditors = [];
  833. settle.preAuditors.forEach(x => {
  834. newAuditors.push({
  835. tid: settle.tid, settle_id: settle.id, audit_id: x.audit_id,
  836. audit_times: x.audit_times, active_order: x.active_order + 1,
  837. audit_type: x.audit_type, audit_order: x.audit_order,
  838. audit_status: x.audit_id === selfAuditor.audit_id ? auditConst.settle.status.checkCancel : auditConst.settle.status.checkSkip,
  839. audit_time: time, opinion: '',
  840. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  841. });
  842. });
  843. await transaction.insert(this.tableName, newAuditors);
  844. // 更新上一个人,最新审批状态为审批中
  845. await transaction.update(this.tableName, { audit_time: null, opinion: '', audit_status: auditConst.settle.status.checking }, {
  846. where: { settle_id: settle.id, audit_times: selfAuditor.audit_times, active_order: selfAuditor.active_order + 2 }
  847. });
  848. // 同步 期信息
  849. await transaction.update(this.ctx.service.settle.tableName, {
  850. id: settle.id, audit_times: settle.audit_times, status: auditConst.settle.status.checking,
  851. });
  852. // todo 上报/审批 - 检查三方特殊推送
  853. // await this.ctx.service.specMsg.addSettleMsg(transaction, this.ctx.session.sessionProject.id, settle, pushOperate.settle.flow);
  854. await transaction.commit();
  855. } catch(err) {
  856. await transaction.rollback();
  857. throw err;
  858. }
  859. }
  860. /**
  861. * 审批人撤回审批退回原报
  862. *
  863. * @param settle
  864. * @returns {Promise<void>}
  865. * @private
  866. */
  867. async _auditCheckCancelNo(settle) {
  868. const accountId = this.ctx.session.sessionUser.accountId;
  869. const selfAuditor = settle.preAuditors.find(x => { return x.audit_id === accountId && x.audit_status === auditConst.settle.status.checkNo; });
  870. if (!selfAuditor) throw '该标段由他人审批退回,您不可撤回';
  871. const time = new Date();
  872. const transaction = await this.db.beginTransaction();
  873. try {
  874. // 整理上一个流程审核人状态更新
  875. // 顺移其后审核人流程顺序
  876. const sql = 'UPDATE ' + this.tableName + ' SET `active_order` = `active_order` + 2 WHERE settle_id = ? AND audit_times = ? AND `active_order` > ?';
  877. await transaction.query(sql, [settle.id, selfAuditor.audit_times, selfAuditor.active_order]);
  878. // 当前审批人2次添加至流程中
  879. const checkCancelAuditors = [], checkingAuditors = [];
  880. settle.preAuditors.forEach(x => {
  881. checkCancelAuditors.push({
  882. tid: settle.tid, settle_id: settle.id, audit_id: x.audit_id,
  883. audit_times: x.audit_times, active_order: x.active_order + 1,
  884. audit_type: x.audit_type, audit_order: x.audit_order,
  885. audit_status: x.audit_id === selfAuditor.audit_id ? auditConst.settle.status.checkCancel : auditConst.settle.status.checkSkip,
  886. audit_time: time, opinion: '',
  887. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  888. });
  889. });
  890. settle.preAuditors.forEach(x => {
  891. checkingAuditors.push({
  892. tid: settle.tid, settle_id: settle.id, audit_id: x.audit_id,
  893. audit_times: x.audit_times, active_order: x.active_order + 2,
  894. audit_type: x.audit_type, audit_order: x.audit_order,
  895. audit_status: auditConst.settle.status.checking,
  896. audit_time: time, opinion: '',
  897. name: x.name, company: x.company, role: x.role, mobile: x.mobile,
  898. });
  899. });
  900. await transaction.insert(this.tableName, [...checkCancelAuditors, ...checkingAuditors]);
  901. // 删除当前次审批流
  902. await transaction.delete(this.tableName, { settle_id: settle.id, audit_times: settle.audit_times });
  903. // 计算并合同支付最终数据
  904. await transaction.update(this.ctx.service.settle.tableName, {
  905. id: settle.id, audit_times: settle.audit_times - 1, status: auditConst.settle.status.checking,
  906. });
  907. // todo 上报/审批 - 检查三方特殊推送
  908. // await this.ctx.service.specMsg.addSettleMsg(transaction, this.ctx.session.sessionProject.id, settle, pushOperate.settle.flow);
  909. await transaction.commit();
  910. } catch(err) {
  911. await transaction.rollback();
  912. throw err;
  913. }
  914. }
  915. /**
  916. * 会签未全部审批通过时,撤回仅修改本人状态
  917. *
  918. * @param settle
  919. * @returns {Promise<void>}
  920. * @private
  921. */
  922. async _auditCheckCancelAnd(settle) {
  923. const accountId = this.ctx.session.sessionUser.accountId;
  924. const selfAuditor = settle.flowAuditors.find(x => { return x.audit_id === accountId; });
  925. if (!selfAuditor || selfAuditor.audit_status !== auditConst.settle.status.checked) throw '不可撤回';
  926. const transaction = await this.db.beginTransaction();
  927. try {
  928. await transaction.update(this.tableName, {
  929. id: selfAuditor.id, status: auditConst.settle.status.checking, opinion: '', audit_time: null,
  930. });
  931. await transaction.commit();
  932. } catch(err) {
  933. await transaction.rollback();
  934. throw err;
  935. }
  936. }
  937. /**
  938. * 审批撤回
  939. * @param {Number} settle - 结算期
  940. * @return {Promise<void>}
  941. */
  942. async checkCancel(settle) {
  943. // 分5种情况,根据settle.cancancel值判断:
  944. // 1.原报发起撤回,当前流程删除,并回到待上报
  945. // 2.审批人撤回审批通过,增加流程,并回到它审批中
  946. // 3.审批人撤回审批退回上一人,并删除退回人,增加流程,并回到它审批中,并更新计量期状态为审批中
  947. // 4.审批人撤回退回原报操作,删除新增的审批流,增加流程,回滚到它审批中
  948. // 5.会签审批人撤回审批通过(还有其他审批人未审批通过),仅修改本人流程状态
  949. console.log(settle.cancancel);
  950. if (settle.cancancel === 5) {
  951. await this._auditCheckCancelAnd(settle);
  952. } else {
  953. switch (settle.cancancel) {
  954. case 1: await this._userCheckCancel(settle); break;
  955. case 2: await this._auditCheckCancel(settle); break;
  956. case 3: await this._auditCheckCancelNoPre(settle); break;
  957. case 4: await this._auditCheckCancelNo(settle); break;
  958. default: throw '不可撤回,请刷新页面重试';
  959. }
  960. }
  961. }
  962. // ***** 审批操作
  963. }
  964. return SettleAudit;
  965. };