revise_audit.js 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const auditConst = require('../const/audit').revise;
  10. const smsTypeConst = require('../const/sms_type');
  11. const SmsAliConst = require('../const/sms_alitemplate');
  12. module.exports = app => {
  13. class ReviseAudit extends app.BaseService {
  14. /**
  15. * 构造函数
  16. *
  17. * @param {Object} ctx - egg全局变量
  18. * @return {void}
  19. */
  20. constructor(ctx) {
  21. super(ctx);
  22. this.tableName = 'revise_audit';
  23. }
  24. /**
  25. * 获取标段审核人信息
  26. *
  27. * @param {Number} reviseId - 修订id
  28. * @param {Number} auditorId - 审核人id
  29. * @param {Number} times - 第几次审批
  30. * @returns {Promise<*>}
  31. */
  32. async getAuditor(reviseId, auditorId, times = 1) {
  33. const sql = 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`audit_order`, la.`status`, la.`opinion`, la.`begin_time`, la.`end_time` ' +
  34. 'FROM ?? AS la, ?? AS pa ' +
  35. 'WHERE la.`rid` = ? and la.`audit_id` = ? and la.`times` = ?' +
  36. ' and la.`audit_id` = pa.`id`';
  37. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, reviseId, auditorId, times];
  38. return await this.db.queryOne(sql, sqlParam);
  39. }
  40. /**
  41. * 获取标段审核列表信息
  42. *
  43. * @param {Number} reviseId - 修订id
  44. * @param {Number} times - 第几次审批
  45. * @returns {Promise<*>}
  46. */
  47. async getAuditors(reviseId, times = 1) {
  48. const sql = 'SELECT la.`audit_id`, la.`times`, la.`audit_order`, la.`status`, la.`opinion`, la.`begin_time`, la.`end_time`,' +
  49. ' pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`' +
  50. ' FROM ' + this.tableName + ' AS la ' +
  51. ' INNER JOIN ' + this.ctx.service.projectAccount.tableName + ' AS pa ON la.`rid` = ? and la.`times` = ? and la.`audit_id` = pa.`id`' +
  52. ' ORDER BY la.`audit_order`';
  53. const sqlParam = [reviseId, times];
  54. return await this.db.query(sql, sqlParam);
  55. }
  56. /**
  57. * 获取 审核列表信息(修订列表页审批流程用)
  58. *
  59. * @param {Number} rid - 修订id
  60. * @param {Number} times - 第几次审批
  61. * @returns {Promise<*>}
  62. */
  63. async getAuditors2ReviseList(rid, times = 1) {
  64. const sql = 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`audit_order`, la.`status`, la.`opinion`, la.`begin_time`, la.`end_time`, g.`sort` ' +
  65. 'FROM ?? AS la, ?? AS pa, (SELECT `audit_id`,(@i:=@i+1) as `sort` FROM ??, (select @i:=0) as it WHERE `rid` = ? AND `times` = ? GROUP BY `audit_id`) as g ' +
  66. 'WHERE la.`rid` = ? and la.`times` = ? and la.`audit_id` = pa.`id` and g.`audit_id` = la.`audit_id` order by la.`audit_order`';
  67. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, this.tableName, rid, times, rid, times];
  68. const result = await this.db.query(sql, sqlParam);
  69. const sql2 = 'SELECT COUNT(a.`audit_id`) as num FROM (SELECT `audit_id` FROM ?? WHERE `rid` = ? AND `times` = ? GROUP BY `audit_id`) as a';
  70. const sqlParam2 = [this.tableName, rid, times];
  71. const count = await this.db.queryOne(sql2, sqlParam2);
  72. for (const i in result) {
  73. result[i].max_sort = count.num;
  74. }
  75. return result;
  76. }
  77. /**
  78. * 获取标段当前审核人
  79. *
  80. * @param {Number} reviseId - 修订id
  81. * @param {Number} times - 第几次审批
  82. * @returns {Promise<*>}
  83. */
  84. async getCurAuditor(reviseId, times = 1) {
  85. const sql = 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`audit_order`, la.`status`, la.`opinion`, la.`begin_time`, la.`end_time` ' +
  86. 'FROM ?? AS la, ?? AS pa ' +
  87. 'WHERE la.`rid` = ? and la.`status` = ? and la.`times` = ?' +
  88. ' and la.`audit_id` = pa.`id`';
  89. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, reviseId, auditConst.status.checking, times];
  90. return await this.db.queryOne(sql, sqlParam);
  91. }
  92. /**
  93. * 获取最新审核顺序
  94. *
  95. * @param {Number} reviseId - 修订id
  96. * @param {Number} times - 第几次审批
  97. * @returns {Promise<number>}
  98. */
  99. async getNewOrder(reviseId, times = 1) {
  100. const sql = 'SELECT Max(??) As max_order FROM ?? Where `rid` = ? and `times` = ?';
  101. const sqlParam = ['audit_order', this.tableName, reviseId, times];
  102. const result = await this.db.queryOne(sql, sqlParam);
  103. return result && result.max_order ? result.max_order + 1 : 1;
  104. }
  105. /**
  106. * 新增审核人
  107. *
  108. * @param {Object} revise - 修订
  109. * @param {Number} auditorId - 审核人id
  110. * @param {Number} times - 第几次审批
  111. * @returns {Promise<number>}
  112. */
  113. async addAuditor(revise, auditorId) {
  114. const times = revise.times ? revise.times : 1;
  115. const newOrder = await this.getNewOrder(revise.id, times);
  116. const data = {
  117. tender_id: revise.tid,
  118. audit_id: auditorId,
  119. times: times,
  120. audit_order: newOrder,
  121. status: auditConst.status.uncheck,
  122. rid: revise.id,
  123. in_time: new Date(),
  124. };
  125. const result = await this.db.insert(this.tableName, data);
  126. return result.effectRows = 1;
  127. }
  128. /**
  129. * 移除审核人时,同步其后审核人order
  130. * @param transaction - 事务
  131. * @param {Number} reviseId - 修订id
  132. * @param {Number} auditorId - 审核人id
  133. * @param {Number} times - 第几次审批
  134. * @returns {Promise<*>}
  135. * @private
  136. */
  137. async _syncOrderByDelete(transaction, reviseId, order, times) {
  138. this.initSqlBuilder();
  139. this.sqlBuilder.setAndWhere('rid', {
  140. value: this.db.escape(reviseId),
  141. operate: '='
  142. });
  143. this.sqlBuilder.setAndWhere('audit_order', {
  144. value: order,
  145. operate: '>=',
  146. });
  147. this.sqlBuilder.setAndWhere('times', {
  148. value: times,
  149. operate: '=',
  150. });
  151. this.sqlBuilder.setUpdateData('audit_order', {
  152. value: 1,
  153. selfOperate: '-',
  154. });
  155. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'update');
  156. const data = await transaction.query(sql, sqlParam);
  157. return data;
  158. }
  159. /**
  160. * 移除审核人
  161. *
  162. * @param {Object} revise - 修订
  163. * @param {Number} auditorId - 审核人id
  164. * @param {Number} times - 第几次审批
  165. * @returns {Promise<boolean>}
  166. */
  167. async deleteAuditor(revise, auditorId) {
  168. const times = revise.times ? revise.times : 1;
  169. const transaction = await this.db.beginTransaction();
  170. try {
  171. const condition = {rid: revise.id, audit_id: auditorId, times: times};
  172. const auditor = await this.getDataByCondition(condition);
  173. if (!auditor) {
  174. throw '该审核人不存在';
  175. }
  176. await this._syncOrderByDelete(transaction, revise.id, auditor.audit_order, times);
  177. await transaction.delete(this.tableName, condition);
  178. await transaction.commit();
  179. } catch(err) {
  180. await transaction.rollback();
  181. throw err;
  182. }
  183. return true;
  184. }
  185. /**
  186. * 开始审批
  187. *
  188. * @param {Object} revise - 修订
  189. * @param {Number} times - 第几次审批
  190. * @returns {Promise<boolean>}
  191. */
  192. async start(revise, times = 1) {
  193. const audit = await this.getDataByCondition({rid: revise.id, times: times, audit_order: 1});
  194. if (!audit) throw '审核人信息错误';
  195. const time = new Date();
  196. // 拷贝备份台账数据
  197. const [billsHis, posHis] = await this.ctx.service.ledgerRevise.backupReviseHistoryFile(revise);
  198. const transaction = await this.db.beginTransaction();
  199. try {
  200. await transaction.update(this.tableName, {
  201. id: audit.id, status: auditConst.status.checking, begin_time: time,
  202. bills_file: revise.bills_file, pos_file: revise.pos_file,
  203. });
  204. const reviseData = {
  205. id: revise.id, status: auditConst.status.checking,
  206. bills_file: billsHis, pos_file: posHis,
  207. };
  208. if (revise.times === 1) {
  209. reviseData.begin_time = time;
  210. }
  211. await transaction.update(this.ctx.service.ledgerRevise.tableName, reviseData);
  212. // 添加短信通知-需要审批提醒功能
  213. // 下一人
  214. // await this.ctx.helper.sendUserSms(audit.audit_id, smsTypeConst.const.XD,
  215. // smsTypeConst.judge.approval.toString(), '台帐修订需要您审批,请登录系统处理。');
  216. await this.ctx.helper.sendAliSms(audit.audit_id, smsTypeConst.const.XD,
  217. smsTypeConst.judge.approval.toString(), SmsAliConst.template.revise_check);
  218. // 其他参与人
  219. const auditList = await this.getAuditors(revise.tid, times);
  220. const users = this._.pull(this._.map(auditList, 'user_id'), audit.id);
  221. // await this.ctx.helper.sendUserSms(users, smsTypeConst.const.XD,
  222. // smsTypeConst.judge.result.toString(), '台账修订已上报。');
  223. await this.ctx.helper.sendAliSms(users, smsTypeConst.const.XD,
  224. smsTypeConst.judge.result.toString(), SmsAliConst.template.revise_report);
  225. await transaction.commit();
  226. } catch (err) {
  227. await transaction.rollback();
  228. throw err;
  229. }
  230. return true;
  231. }
  232. async _replaceLedgerByRevise(transaction, revise) {
  233. const sqlParam = [revise.tid];
  234. await transaction.delete(this.ctx.service.ledger.tableName, {tender_id: revise.tid});
  235. const bSql = 'Insert Into ' + this.ctx.service.ledger.tableName +
  236. ' (id, code, b_code, name, unit, source, remark, ledger_id, ledger_pid, level, `order`, full_path, is_leaf,' +
  237. ' quantity, total_price, unit_price, drawing_code, memo, dgn_qty1, dgn_qty2, deal_qty, deal_tp,' +
  238. ' sgfh_qty, sgfh_tp, sjcl_qty, sjcl_tp, qtcl_qty, qtcl_tp, node_type, crid, tender_id, is_tp,' +
  239. ' sgfh_expr, sjcl_expr, qtcl_expr)' +
  240. ' Select id, code, b_code, name, unit, source, remark, ledger_id, ledger_pid, level, `order`, full_path, is_leaf,' +
  241. ' quantity, total_price, unit_price, drawing_code, memo, dgn_qty1, dgn_qty2, deal_qty, deal_tp,' +
  242. ' sgfh_qty, sgfh_tp, sjcl_qty, sjcl_tp, qtcl_qty, qtcl_tp, node_type, crid, tender_id, is_tp, ' +
  243. ' sgfh_expr, sjcl_expr, qtcl_expr' +
  244. ' From ' + this.ctx.service.reviseBills.tableName +
  245. ' Where `tender_id` = ?';
  246. await transaction.query(bSql, sqlParam);
  247. await transaction.delete(this.ctx.service.pos.tableName, {tid: revise.tid});
  248. const pSql = 'Insert Into ' + this.ctx.service.pos.tableName +
  249. ' (id, tid, lid, name, drawing_code, quantity, add_stage, add_times, add_user,' +
  250. ' sgfh_qty, sjcl_qty, qtcl_qty, crid, porder, position, ' +
  251. ' sgfh_expr, sjcl_expr, qtcl_expr)' +
  252. ' Select id, tid, lid, name, drawing_code, quantity, add_stage, add_times, add_user,' +
  253. ' sgfh_qty, sjcl_qty, qtcl_qty, crid, porder, position,' +
  254. ' sgfh_expr, sjcl_expr, qtcl_expr' +
  255. ' From ' + this.ctx.service.revisePos.tableName +
  256. ' Where `tid` = ?';
  257. await transaction.query(pSql, sqlParam);
  258. }
  259. /**
  260. * 审批
  261. * @param {Object} revise - 修订
  262. * @param {auditConst.status.checked|auditConst.status.checkNo} checkType - 审批结果
  263. * @param {String} opinion - 审批意见
  264. * @param {Number} times - 第几次审批
  265. * @returns {Promise<void>}
  266. */
  267. async check(revise, checkType, opinion, times = 1) {
  268. if (checkType !== auditConst.status.checked && checkType !== auditConst.status.checkNo) throw '提交数据错误';
  269. const audit = await this.getDataByCondition({rid: revise.id, times: times, status: auditConst.status.checking});
  270. if (!audit) throw '审核数据错误';
  271. const transaction = await this.db.beginTransaction();
  272. try {
  273. // 整理当前流程审核人状态更新
  274. const time = new Date();
  275. // 更新当前审核流程
  276. await transaction.update(this.tableName, {
  277. id: audit.id, status: checkType, opinion, end_time: time,
  278. });
  279. if (checkType === auditConst.status.checked) {
  280. const nextAudit = await this.getDataByCondition({ rid: revise.id, times, audit_order: audit.audit_order + 1 });
  281. // 无下一审核人表示,审核结束
  282. if (nextAudit) {
  283. await transaction.update(this.tableName, { id: nextAudit.id, status: auditConst.status.checking, begin_time: time });
  284. // 短信通知-需要审批提醒功能
  285. // 下一人
  286. // await this.ctx.helper.sendUserSms(nextAudit.user_id, smsTypeConst.const.XD,
  287. // smsTypeConst.judge.approval.toString(), '台帐修订需要您审批,请登录系统处理。');
  288. await this.ctx.helper.sendAliSms(nextAudit.user_id, smsTypeConst.const.XD,
  289. smsTypeConst.judge.result.toString(), SmsAliConst.template.revise_result, { status: SmsAliConst.status.success });
  290. // 其他参与人
  291. const auditList = await this.getAuditors(revise.tid, times);
  292. const users = this._.pull(this._.map(auditList, 'user_id'), audit.id);
  293. users.push(revise.uid);
  294. // await this.ctx.helper.sendUserSms(users, smsTypeConst.const.XD,
  295. // smsTypeConst.judge.result.toString(), '台账修订审批通过。');
  296. await this.ctx.helper.sendAliSms(users, smsTypeConst.const.XD,
  297. smsTypeConst.judge.result.toString(), SmsAliConst.template.revise_result2, { status: SmsAliConst.status.success });
  298. } else {
  299. // 同步修订信息
  300. await transaction.update(this.ctx.service.ledgerRevise.tableName, { id: revise.id, status: checkType, end_time: time });
  301. // 最新一期跟台账相关的缓存数据应过期
  302. const lastStage = await this.ctx.service.stage.getLastestStage(revise.tid, true);
  303. const cacheTime = new Date();
  304. if (lastStage) await transaction.update(this.ctx.service.stage.tableName,
  305. {id: lastStage.id, cache_time_l: cacheTime, cache_time_r: cacheTime});
  306. // 拷贝修订数据至台账
  307. await this._replaceLedgerByRevise(transaction, revise);
  308. const sum = await this.ctx.service.reviseBills.addUp({tender_id: revise.tid/*, is_leaf: true*/});
  309. await transaction.update(this.ctx.service.tender.tableName, {
  310. id: revise.tid, total_price: sum.total_price, deal_tp: sum.deal_tp
  311. });
  312. // 短信通知-审批通过提醒功能
  313. // 下一人
  314. // const msg = '台账修订审批通过,请登录系统处理。';
  315. // await this.ctx.helper.sendUserSms(revise.uid, smsTypeConst.const.XD,
  316. // smsTypeConst.judge.result.toString(), msg);
  317. await this.ctx.helper.sendAliSms(revise.uid, smsTypeConst.const.XD,
  318. smsTypeConst.judge.result.toString(), SmsAliConst.template.revise_result, { status: SmsAliConst.status.success });
  319. // 其他参与人
  320. const auditList = await this.getAuditors(revise.tid, times);
  321. const users = this._.pull(this._.map(auditList, 'user_id'), audit.id);
  322. // await this.ctx.helper.sendUserSms(users, smsTypeConst.const.XD,
  323. // smsTypeConst.judge.result.toString(), '台账修订审批通过。');
  324. await this.ctx.helper.sendAliSms(users, smsTypeConst.const.XD,
  325. smsTypeConst.judge.result.toString(), SmsAliConst.template.revise_result2, { status: SmsAliConst.status.success });
  326. }
  327. } else {
  328. // 同步修订信息
  329. await transaction.update(this.ctx.service.ledgerRevise.tableName, { id: revise.id, times: times + 1, status: checkType });
  330. // 拷贝新一次审核流程列表
  331. const auditors = await this.getAllDataByCondition({
  332. where: { rid: revise.id, times },
  333. columns: ['tender_id', 'rid', 'audit_order', 'audit_id'],
  334. });
  335. for (const a of auditors) {
  336. a.times = times + 1;
  337. a.status = auditConst.status.uncheck;
  338. a.in_time = time;
  339. }
  340. await transaction.insert(this.tableName, auditors);
  341. // 短信通知-审批退回提醒功能
  342. // 下一人
  343. // await this.ctx.helper.sendUserSms(revise.uid, smsTypeConst.const.XD,
  344. // smsTypeConst.judge.result.toString(), '台账修订审批退回,请登录系统处理。');
  345. await this.ctx.helper.sendAliSms(revise.uid, smsTypeConst.const.XD,
  346. smsTypeConst.judge.result.toString(), SmsAliConst.template.revise_result, { status: SmsAliConst.status.back });
  347. // 其他参与人
  348. // await this.ctx.helper.sendUserSms(this._.map(auditors, 'user_id'),
  349. // smsTypeConst.const.XD, smsTypeConst.judge.result.toString(), '台账修订审批退回。');
  350. await this.ctx.helper.sendAliSms(this._.map(auditors, 'user_id'), smsTypeConst.const.XD,
  351. smsTypeConst.judge.result.toString(), SmsAliConst.template.revise_result2, { status: SmsAliConst.status.back });
  352. }
  353. await transaction.commit();
  354. } catch (err) {
  355. await transaction.rollback();
  356. throw err;
  357. }
  358. }
  359. /**
  360. * 获取审核人需要审核的标段列表
  361. *
  362. * @param auditorId
  363. * @returns {Promise<*>}
  364. */
  365. async getAuditRevise(auditorId) {
  366. const sql = 'SELECT ra.`audit_id`, ra.`times`, ra.`audit_order`, ra.`begin_time`, ra.`end_time`,' +
  367. ' r.id, r.corder, r.uid, r.status, r.content,' +
  368. ' t.id As t_id, t.`name` As t_name, t.`project_id` As t_pid, t.`type` As t_type, t.`user_id` As t_uid, t.`status` As t_status, ' +
  369. ' p.name As audit_name, p.role As audit_role, p.company As audit_company' +
  370. ' FROM ' + this.tableName + ' AS ra' +
  371. ' Left Join ' + this.ctx.service.ledgerRevise.tableName + ' As r On ra.rid = r.id' +
  372. ' Left Join ' + this.ctx.service.tender.tableName + ' AS t On r.tid = t.id' +
  373. ' Left Join ' + this.ctx.service.projectAccount.tableName + ' As p On ra.audit_id = p.id' +
  374. ' WHERE r.`valid` != 0 and ((ra.`audit_id` = ? and ra.`status` = ?) OR' +
  375. ' (r.`uid` = ? and r.`status` = ? and ra.`status` = ? and ra.`times` = (r.`times`-1)))';
  376. const sqlParam = [auditorId, auditConst.status.checking, auditorId, auditConst.status.checkNo, auditConst.status.checkNo];
  377. return await this.db.query(sql, sqlParam);
  378. }
  379. /**
  380. * 获取 某时间后 审批进度 更新的台账
  381. * @param {Integer} projectId - 项目id
  382. * @param {Integer} auditorId - 查询人id
  383. * @param {Date} noticeTime - 查询事件
  384. * @returns {Promise<*>}
  385. */
  386. async getNoticeRevise(projectId, auditorId, noticeTime) {
  387. const sql = 'SELECT * FROM (SELECT ra.`audit_id`, ra.`times`, ra.`audit_order`, ra.`end_time`, ra.`status`,' +
  388. ' r.id, r.corder, r.uid, r.status As `r_status`, r.content, ' +
  389. ' t.`id` As t_id, t.`name` As t_name, t.`project_id` As t_pid, t.`type` As t_type, t.`user_id` As t_uid, ' +
  390. ' pa.name As `ru_name`, pa.role As `ru_role`, pa.company As `ru_company`' +
  391. ' FROM (SELECT * FROM ?? WHERE `user_id` = ? OR `id` in (SELECT `tender_id` FROM ?? WHERE `audit_id` = ? GROUP BY `tender_id`)) As t' +
  392. ' LEFT JOIN ' + this.ctx.service.ledgerRevise.tableName + ' As r ON r.`tid` = t.`id`' +
  393. ' LEFT JOIN ' + this.tableName + ' As ra ON ra.rid = r.id' +
  394. ' LEFT JOIN ' + this.ctx.service.projectAccount.tableName + ' As pa ON ra.`audit_id` = pa.`id`' +
  395. ' WHERE ra.end_time > ? and t.project_id = ?' +
  396. ' ORDER By ra.`end_time` DESC LIMIT 1000) as new_t GROUP BY new_t.`id`' +
  397. ' ORDER By new_t.`end_time`';
  398. const sqlParam = [this.ctx.service.tender.tableName, auditorId, this.tableName, auditorId, noticeTime, projectId];
  399. return await this.db.query(sql, sqlParam);
  400. }
  401. /**
  402. * 获取最新的审批人状态
  403. *
  404. * @param {Number} rid - 修订id
  405. * @param {Number} status - 修订状态
  406. * @param {Number} times - 修订次数
  407. * @return {Promise<boolean>}
  408. */
  409. async getAuditorByStatus(rid, status, times = 1) {
  410. let auditor = null;
  411. let sql = '';
  412. let sqlParam = '';
  413. switch (status) {
  414. case auditConst.status.checking :
  415. case auditConst.status.checked :
  416. case auditConst.status.checkNoPre :
  417. sql = 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`rid`, la.`audit_order` ' +
  418. 'FROM ?? AS la, ?? AS pa ' +
  419. 'WHERE la.`rid` = ? and la.`status` = ? and la.`audit_id` = pa.`id` order by la.`times` desc, la.`audit_order` desc';
  420. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, rid, status];
  421. auditor = await this.db.queryOne(sql, sqlParam);
  422. break;
  423. case auditConst.status.checkNo :
  424. sql = 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`rid`, la.`audit_order` ' +
  425. 'FROM ?? AS la, ?? AS pa ' +
  426. 'WHERE la.`rid` = ? and la.`status` = ? and la.`times` = ? and la.`audit_id` = pa.`id` order by la.`times` desc, la.`audit_order` desc';
  427. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, rid, auditConst.status.checkNo, parseInt(times) - 1];
  428. auditor = await this.db.queryOne(sql, sqlParam);
  429. break;
  430. case auditConst.status.uncheck :
  431. default:break;
  432. }
  433. return auditor;
  434. }
  435. /**
  436. * 获取审核人流程列表
  437. *
  438. * @param auditorId
  439. * @returns {Promise<*>}
  440. */
  441. async getAuditGroupByList(rid, times) {
  442. const sql = 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`rid`, la.`audit_order` ' +
  443. 'FROM ?? AS la, ?? AS pa ' +
  444. 'WHERE la.`rid` = ? and la.`times` = ? and la.`audit_id` = pa.`id` GROUP BY la.`audit_id` ORDER BY la.`audit_order`';
  445. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, rid, times];
  446. return await this.db.query(sql, sqlParam);
  447. // const sql = 'SELECT `tid`, `sid`, `aid`, `order` FROM ?? WHERE `sid` = ? and `times` = ? GROUP BY `aid`';
  448. // const sqlParam = [this.tableName, stageId, times];
  449. // return await this.db.query(sql, sqlParam);
  450. }
  451. async getAllAuditors(tenderId) {
  452. const sql = 'SELECT ra.audit_id, ra.tender_id FROM ' + this.tableName + ' ra' +
  453. ' LEFT JOIN ' + this.ctx.service.tender.tableName + ' t On ra.tender_id = t.id' +
  454. ' WHERE t.id = ?' +
  455. ' GROUP BY ra.audit_id';
  456. const sqlParam = [tenderId];
  457. return this.db.query(sql, sqlParam);
  458. }
  459. }
  460. return ReviseAudit;
  461. };