advance_audit.js 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614
  1. 'use strict';
  2. const auditConst = require('../const/audit').advance;
  3. const shenpiConst = require('../const/shenpi');
  4. const pushType = require('../const/audit').pushType;
  5. const smsTypeConst = require('../const/sms_type');
  6. const wxConst = require('../const/wechat_template.js');
  7. module.exports = app => {
  8. class AdvanceAudit extends app.BaseService {
  9. constructor(ctx) {
  10. super(ctx);
  11. this.tableName = 'advance_audit';
  12. }
  13. /**
  14. * 获取审核人流程列表
  15. * @param {Number} vid 预付款记录id
  16. * @param {Number} times 审核次数
  17. * @return {Promise<Array>} 查询结果集
  18. */
  19. async getAuditGroupByList(vid, times = 1) {
  20. const sql =
  21. 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`vid`, la.`order` ' +
  22. 'FROM ?? AS la, ?? AS pa ' +
  23. 'WHERE la.`vid` = ? and la.`times` = ? and la.`audit_id` = pa.`id` GROUP BY la.`audit_id` ORDER BY la.`order`';
  24. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, vid, times];
  25. return await this.db.query(sql, sqlParam);
  26. }
  27. /**
  28. * 获取审核人流程列表(包括原报)
  29. * @param {Number} vid 预付款记录id
  30. * @param {Number} times 审核次数
  31. * @return {Promise<Array>} 查询结果集(包括原报)
  32. */
  33. async getAuditorsWithOwner(vid, times = 1) {
  34. const result = await this.getAuditGroupByList(vid, times);
  35. const sql =
  36. 'SELECT pa.`id` As audit_id, pa.`name`, pa.`company`, pa.`role`, ? As times, ? As vid, 0 As `order`' +
  37. ' FROM ' +
  38. this.ctx.service.advance.tableName +
  39. ' As s' +
  40. ' LEFT JOIN ' +
  41. this.ctx.service.projectAccount.tableName +
  42. ' As pa' +
  43. ' ON s.uid = pa.id' +
  44. ' WHERE s.id = ?';
  45. const sqlParam = [times, vid, vid];
  46. const user = await this.db.queryOne(sql, sqlParam);
  47. result.unshift(user);
  48. return result;
  49. }
  50. /**
  51. * 获取最新审核顺序
  52. * @param {Number} vid - 预付款id
  53. * @param {Number} times - 第几次审批
  54. * @return {Number} 审核顺序
  55. */
  56. async getNewOrder(vid, times = 1) {
  57. const sql = 'SELECT Max(??) As max_order FROM ?? Where `vid` = ? and `times` = ?';
  58. const sqlParam = ['order', this.tableName, vid, times];
  59. const result = await this.db.queryOne(sql, sqlParam);
  60. return result && result.max_order ? result.max_order + 1 : 1;
  61. }
  62. /**
  63. * 新增审核人
  64. * @param {Number} tid - 标段id
  65. * @param {Number} vid - 预付款id
  66. * @param {Number} audit_id - 审核人id
  67. * @param {Number} times - 第几次审批
  68. * @return {Boolean} 是否插入成功
  69. */
  70. async addAuditor(tid, vid, audit_id, times = 1, is_gdzs = 0) {
  71. const transaction = await this.db.beginTransaction();
  72. try {
  73. let newOrder = await this.getNewOrder(vid, times);
  74. // 判断是否存在固定终审,存在则newOrder - 1并使终审order+1
  75. newOrder = is_gdzs === 1 ? newOrder - 1 : newOrder;
  76. if (is_gdzs) await this._syncOrderByDelete(transaction, vid, newOrder, times, '+');
  77. const record = {
  78. tid,
  79. vid,
  80. audit_id,
  81. times,
  82. order: newOrder,
  83. status: auditConst.status.uncheck,
  84. };
  85. const result = await transaction.insert(this.tableName, record);
  86. await transaction.commit();
  87. return result && result.affectedRows === 1;
  88. } catch (err) {
  89. await transaction.rollback();
  90. throw err;
  91. }
  92. return false;
  93. }
  94. /**
  95. * 移除审核人
  96. * @param {Number} vid - 预付款id
  97. * @param {Number} audit_id - 审核人id
  98. * @param {Number} times - 第几次审批
  99. * @return {Promise<boolean>}
  100. */
  101. async deleteAuditor(vid, audit_id, times = 1) {
  102. const transaction = await this.db.beginTransaction();
  103. try {
  104. const condition = { vid, audit_id, times };
  105. const auditor = await this.getDataByCondition(condition);
  106. if (!auditor) {
  107. throw '该审核人不存在';
  108. }
  109. await this._syncOrderByDelete(transaction, vid, auditor.order, times);
  110. await transaction.delete(this.tableName, condition);
  111. await transaction.commit();
  112. } catch (err) {
  113. await transaction.rollback();
  114. throw err;
  115. }
  116. return true;
  117. }
  118. /**
  119. * 移除审核人时,同步其后审核人order
  120. * @param {Function} transaction - 事务
  121. * @param {Number} vid - 预付款id
  122. * @param {Number} order - 审核顺序
  123. * @param {Number} times - 第几次审批
  124. * @return {Promise<*>} 查询结果集
  125. * @private
  126. */
  127. async _syncOrderByDelete(transaction, vid, order, times, selfOperate = '-') {
  128. this.initSqlBuilder();
  129. this.sqlBuilder.setAndWhere('vid', {
  130. value: this.db.escape(vid),
  131. operate: '=',
  132. });
  133. this.sqlBuilder.setAndWhere('order', {
  134. value: order,
  135. operate: '>=',
  136. });
  137. this.sqlBuilder.setAndWhere('times', {
  138. value: times,
  139. operate: '=',
  140. });
  141. this.sqlBuilder.setUpdateData('order', {
  142. value: 1,
  143. selfOperate: selfOperate,
  144. });
  145. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'update');
  146. const data = await transaction.query(sql, sqlParam);
  147. return data;
  148. }
  149. /**
  150. * 获取当前审核人
  151. * @param {Number} vid - 预付款id
  152. * @param {Number} times - 第几次审批
  153. * @return {Promise<Object>} 查询结果集
  154. */
  155. async getCurAuditor(vid, times = 1) {
  156. const sql =
  157. 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`order`, la.`status`, la.`opinion`, la.`create_time`, la.`end_time` ' +
  158. 'FROM ?? AS la, ?? AS pa ' +
  159. 'WHERE la.`vid` = ? and la.`status` = ? and la.`times` = ?' +
  160. ' and la.`audit_id` = pa.`id`';
  161. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, vid, auditConst.status.checking, times];
  162. return await this.db.queryOne(sql, sqlParam);
  163. }
  164. /**
  165. * 获取审核列表信息
  166. * @param {Number} vid - 预付款id
  167. * @param {Number} times - 第几次审批
  168. * @return {Promise<Array>} 查询结果集
  169. */
  170. async getAuditors(vid, times = 1) {
  171. const sql =
  172. 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`order`, la.`status`, la.`opinion`, la.`create_time`, la.`end_time`, g.`sort` ' +
  173. 'FROM ?? AS la, ?? AS pa, (SELECT `audit_id`,(@i:=@i+1) as `sort` FROM ??, (select @i:=0) as it WHERE `vid` = ? AND `times` = ? GROUP BY `audit_id`) as g ' +
  174. 'WHERE la.`vid` = ? and la.`times` = ? and la.`audit_id` = pa.`id` and g.`audit_id` = la.`audit_id` order by la.`order`';
  175. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, this.tableName, vid, times, vid, times];
  176. const result = await this.db.query(sql, sqlParam);
  177. const sql2 = 'SELECT COUNT(a.`audit_id`) as num FROM (SELECT `audit_id` FROM ?? WHERE `vid` = ? AND `times` = ? GROUP BY `audit_id`) as a';
  178. const sqlParam2 = [this.tableName, vid, times];
  179. const count = await this.db.queryOne(sql2, sqlParam2);
  180. for (const i in result) {
  181. result[i].max_sort = count.num;
  182. }
  183. return result;
  184. }
  185. /**
  186. * 获取审核人信息
  187. * @param {Number} vid - 预付款id
  188. * @param {Number} audit_id - 审核人id
  189. * @param {Number} times - 第几次审批
  190. * @return {Promise<*>} 查询结果
  191. */
  192. async getAuditor(vid, audit_id, times = 1) {
  193. const sql =
  194. 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, pa.`mobile`, pa.`telephone`, la.`times`, la.`order`, la.`status`, la.`opinion`, la.`create_time`, la.`end_time` ' +
  195. 'FROM ?? AS la, ?? AS pa ' +
  196. 'WHERE la.`vid` = ? and la.`audit_id` = ? and la.`times` = ?' +
  197. ' and la.`audit_id` = pa.`id`';
  198. const sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, vid, audit_id, times];
  199. return await this.db.queryOne(sql, sqlParam);
  200. }
  201. /**
  202. * 开始审批
  203. * @param {Number} vid - 预付款id
  204. * @param {Number} times - 第几次审批
  205. * @param {Object} data - 载荷
  206. */
  207. async start(vid, times = 1, data) {
  208. const audit = await this.getDataByCondition({ vid, times, order: 1 });
  209. if (!audit) {
  210. if(this.ctx.tender.info.shenpi.advance === shenpiConst.sp_status.gdspl) {
  211. throw '请联系管理员添加审批人';
  212. } else {
  213. throw '请先选择审批人,再上报数据';
  214. }
  215. }
  216. const transaction = await this.db.beginTransaction();
  217. try {
  218. await transaction.update(this.tableName, { id: audit.id, status: auditConst.status.checking, create_time: new Date() });
  219. await transaction.update(this.ctx.service.advance.tableName, {
  220. id: audit.vid,
  221. ...data,
  222. });
  223. // 微信模板通知
  224. const advanceInfo = await this.ctx.service.advance.getDataById(vid);
  225. const wechatData = {
  226. qi: advanceInfo.type === 0 ? '开工预付款第' + advanceInfo.order + '期' : '材料预付款第' + advanceInfo.order + '期',
  227. status: wxConst.status.check,
  228. tips: wxConst.tips.check,
  229. tp: parseFloat(advanceInfo.cur_amount),
  230. };
  231. await this.ctx.helper.sendWechat(audit.audit_id, smsTypeConst.const.YFK, smsTypeConst.judge.approval.toString(), wxConst.template.advance, wechatData);
  232. await transaction.commit();
  233. } catch (err) {
  234. await transaction.rollback();
  235. throw err;
  236. }
  237. return true;
  238. }
  239. async _checked(pid, advanceId, checkData, times) {
  240. const time = new Date();
  241. // 整理当前流程审核人状态更新
  242. const audit = await this.getDataByCondition({ vid: advanceId, times, status: auditConst.status.checking });
  243. if (!audit) {
  244. throw '审核数据错误';
  245. }
  246. // 获取审核人列表
  247. const sql = 'SELECT `tid`, `vid`, `audit_id`, `order` FROM ?? WHERE `vid` = ? and `times` = ? GROUP BY `audit_id` ORDER BY `id` ASC';
  248. const sqlParam = [this.tableName, advanceId, times];
  249. const auditors = await this.db.query(sql, sqlParam);
  250. const nextAudit = await this.getDataByCondition({ vid: advanceId, times, order: audit.order + 1 });
  251. const transaction = await this.db.beginTransaction();
  252. try {
  253. await transaction.update(this.tableName, { id: audit.id, status: checkData.checkType, opinion: checkData.opinion, end_time: time });
  254. // 获取推送必要信息
  255. const noticeContent = await this.getNoticeContent(pid, audit.tid, advanceId, audit.audit_id);
  256. // 添加推送
  257. const records = [{ pid, type: pushType.advance, uid: this.ctx.advance.uid, status: auditConst.status.checked, content: noticeContent }];
  258. auditors.forEach(audit => {
  259. records.push({ pid, type: pushType.advance, uid: audit.audit_id, status: auditConst.status.checked, content: noticeContent });
  260. });
  261. await transaction.insert(this.ctx.service.noticePush.tableName, records);
  262. // 无下一审核人表示,审核结束
  263. const advanceInfo = await this.ctx.service.advance.getDataById(advanceId);
  264. if (nextAudit) {
  265. // 流程至下一审批人
  266. await transaction.update(this.tableName, { id: nextAudit.id, status: auditConst.status.checking, create_time: time });
  267. // 同步期信息
  268. await transaction.update(this.ctx.service.advance.tableName, {
  269. id: advanceId,
  270. status: auditConst.status.checking,
  271. });
  272. // 微信模板通知
  273. const wechatData = {
  274. qi: advanceInfo.type === 0 ? '开工预付款第' + advanceInfo.order + '期' : '材料预付款第' + advanceInfo.order + '期',
  275. status: wxConst.status.check,
  276. tips: wxConst.tips.check,
  277. tp: parseFloat(advanceInfo.cur_amount),
  278. };
  279. await this.ctx.helper.sendWechat(nextAudit.audit_id, smsTypeConst.const.YFK, smsTypeConst.judge.approval.toString(), wxConst.template.advance, wechatData);
  280. } else {
  281. await transaction.update(this.ctx.service.advance.tableName, {
  282. id: advanceId,
  283. status: checkData.checkType,
  284. end_time: time,
  285. });
  286. // 微信模板通知
  287. const users = this._.uniq(this._.concat(this._.map(auditors, 'audit_id'), advanceInfo.uid));
  288. const wechatData = {
  289. qi: advanceInfo.type === 0 ? '开工预付款第' + advanceInfo.order + '期' : '材料预付款第' + advanceInfo.order + '期',
  290. status: wxConst.status.success,
  291. tips: wxConst.tips.success,
  292. tp: parseFloat(advanceInfo.cur_amount),
  293. };
  294. await this.ctx.helper.sendWechat(users, smsTypeConst.const.YFK, smsTypeConst.judge.result.toString(), wxConst.template.advance, wechatData);
  295. }
  296. await transaction.commit();
  297. } catch (err) {
  298. await transaction.rollback();
  299. throw err;
  300. }
  301. }
  302. async _checkNo(pid, advanceId, checkData, times) {
  303. const time = new Date();
  304. // 整理当前流程审核人状态更新
  305. const audit = await this.getDataByCondition({ vid: advanceId, times, status: auditConst.status.checking });
  306. if (!audit) {
  307. throw '审核数据错误';
  308. }
  309. const sql = 'SELECT `tid`, `vid`, `audit_id`, `order` FROM ?? WHERE `vid` = ? and `times` = ? GROUP BY `audit_id` ORDER BY `id` ASC';
  310. const sqlParam = [this.tableName, advanceId, times];
  311. const auditors = await this.db.query(sql, sqlParam);
  312. let order = 1;
  313. for (const a of auditors) {
  314. a.times = times + 1;
  315. a.order = order;
  316. a.status = auditConst.status.uncheck;
  317. order++;
  318. }
  319. const transaction = await this.db.beginTransaction();
  320. try {
  321. await transaction.update(this.tableName, { id: audit.id, status: checkData.checkType, opinion: checkData.opinion, end_time: time });
  322. // 添加到消息推送表
  323. const noticeContent = await this.getNoticeContent(pid, audit.tid, advanceId, audit.audit_id);
  324. const records = [{ pid, type: pushType.advance, uid: this.ctx.advance.uid, status: auditConst.status.checkNo, content: noticeContent }];
  325. auditors.forEach(audit => {
  326. records.push({ pid, type: pushType.advance, uid: audit.audit_id, status: auditConst.status.checkNo, content: noticeContent });
  327. });
  328. await transaction.insert(this.ctx.service.noticePush.tableName, records);
  329. // 同步期信息
  330. await transaction.update(this.ctx.service.advance.tableName, {
  331. id: advanceId,
  332. status: checkData.checkType,
  333. times: times + 1,
  334. });
  335. // 微信模板通知
  336. const advanceInfo = await this.ctx.service.advance.getDataById(advanceId);
  337. const users = this._.uniq(this._.concat(this._.map(auditors, 'audit_id'), advanceInfo.uid));
  338. const wechatData = {
  339. qi: advanceInfo.type === 0 ? '开工预付款第' + advanceInfo.order + '期' : '材料预付款第' + advanceInfo.order + '期',
  340. status: wxConst.status.back,
  341. tips: wxConst.tips.back,
  342. tp: parseFloat(advanceInfo.cur_amount),
  343. };
  344. await this.ctx.helper.sendWechat(users, smsTypeConst.const.YFK, smsTypeConst.judge.result.toString(), wxConst.template.advance, wechatData);
  345. // 拷贝新一次审核流程列表
  346. await transaction.insert(this.tableName, auditors);
  347. await transaction.commit();
  348. } catch (err) {
  349. await transaction.rollback();
  350. throw err;
  351. }
  352. }
  353. async _checkNoPre(pid, advanceId, checkData, times) {
  354. const time = new Date();
  355. // 整理当前流程审核人状态更新
  356. const audit = await this.getDataByCondition({ vid: advanceId, times, status: auditConst.status.checking });
  357. if (!audit || audit.order <= 1) {
  358. throw '审核数据错误';
  359. }
  360. // 添加重新审批后,不能用order-1,取groupby值里的上一个才对
  361. const auditors2 = await this.getAuditGroupByList(advanceId, times);
  362. const auditorIndex = await auditors2.findIndex(function(item) {
  363. return item.audit_id === audit.audit_id;
  364. });
  365. const preAuditor = auditors2[auditorIndex - 1];
  366. const noticeContent = await this.getNoticeContent(pid, audit.tid, advanceId, audit.audit_id);
  367. const transaction = await this.db.beginTransaction();
  368. try {
  369. // 添加到消息推送表
  370. const records = [{ pid, type: pushType.advance, uid: this.ctx.advance.uid, status: auditConst.status.checkNoPre, content: noticeContent }];
  371. auditors2.forEach(audit => {
  372. records.push({ pid, type: pushType.advance, uid: audit.audit_id, status: auditConst.status.checkNoPre, content: noticeContent });
  373. });
  374. await transaction.insert(this.ctx.service.noticePush.tableName, records);
  375. await transaction.update(this.tableName, { id: audit.id, status: checkData.checkType, opinion: checkData.opinion, end_time: time });
  376. // 顺移气候审核人流程顺序
  377. this.initSqlBuilder();
  378. this.sqlBuilder.setAndWhere('vid', { value: advanceId, operate: '=' });
  379. this.sqlBuilder.setAndWhere('order', { value: audit.order, operate: '>' });
  380. this.sqlBuilder.setUpdateData('order', { value: 2, selfOperate: '+' });
  381. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'update');
  382. await transaction.query(sql, sqlParam);
  383. const newAuditors = [];
  384. newAuditors.push({
  385. tid: audit.tid,
  386. vid: audit.vid,
  387. audit_id: preAuditor.audit_id,
  388. times: audit.times,
  389. order: audit.order + 1,
  390. status: auditConst.status.checking,
  391. create_time: time,
  392. });
  393. newAuditors.push({
  394. tid: audit.tid,
  395. vid: audit.vid,
  396. audit_id: audit.audit_id,
  397. times: audit.times,
  398. order: audit.order + 2,
  399. status: auditConst.status.uncheck,
  400. });
  401. // 微信模板通知
  402. const advanceInfo = await this.ctx.service.advance.getDataById(advanceId);
  403. const wechatData = {
  404. qi: advanceInfo.type === 0 ? '开工预付款第' + advanceInfo.order + '期' : '材料预付款第' + advanceInfo.order + '期',
  405. status: wxConst.status.check,
  406. tips: wxConst.tips.check,
  407. tp: parseFloat(advanceInfo.cur_amount),
  408. };
  409. await this.ctx.helper.sendWechat(preAuditor.audit_id, smsTypeConst.const.YFK, smsTypeConst.judge.approval.toString(), wxConst.template.advance, wechatData);
  410. await transaction.insert(this.tableName, newAuditors);
  411. await transaction.commit();
  412. } catch (error) {
  413. await transaction.rollback();
  414. throw error;
  415. }
  416. }
  417. /**
  418. * 审批
  419. * @param {Number} advanceId - 预付款id
  420. * @param {auditConst.status.checked|auditConst.status.checkNo} checkData - 审批结果
  421. * @param {Number} times - 第几次审批
  422. * @return {Promise<void>}
  423. */
  424. async check(advanceId, checkData, times = 1) {
  425. if (checkData.checkType !== auditConst.status.checked && checkData.checkType !== auditConst.status.checkNo && checkData.checkType !== auditConst.status.checkNoPre) {
  426. throw '提交数据错误';
  427. }
  428. const pid = this.ctx.session.sessionProject.id;
  429. switch (checkData.checkType) {
  430. case auditConst.status.checked:
  431. await this._checked(pid, advanceId, checkData, times);
  432. break;
  433. case auditConst.status.checkNo:
  434. await this._checkNo(pid, advanceId, checkData, times);
  435. break;
  436. case auditConst.status.checkNoPre:
  437. await this._checkNoPre(pid, advanceId, checkData, times);
  438. break;
  439. default:
  440. throw '无效审批操作';
  441. }
  442. }
  443. /**
  444. * 用于添加推送所需的content内容
  445. * @param {Number} pid 项目id
  446. * @param {Number} tid 台账id
  447. * @param {Number} vid 预付款id
  448. * @param {Number} uid 审批人id
  449. */
  450. async getNoticeContent(pid, tid, vid, uid) {
  451. const noticeSql =
  452. 'SELECT * FROM (SELECT ' +
  453. ' t.`id` As `tid`, ad.`vid`, t.`name`, m.`order`, pa.`name` As `su_name`, pa.role As `su_role`' +
  454. ' FROM (SELECT * FROM ?? WHERE `id` = ? ) As t' +
  455. ' LEFT JOIN ?? As m On t.`id` = m.`tid` AND m.`id` = ?' +
  456. ' LEFT JOIN ?? As ad ON m.`id` = ad.`vid`' +
  457. ' LEFT JOIN ?? As pa ON pa.`id` = ?' +
  458. ' WHERE t.`project_id` = ? ) as new_t GROUP BY new_t.`tid`';
  459. const noticeSqlParam = [
  460. this.ctx.service.tender.tableName,
  461. tid,
  462. this.ctx.service.advance.tableName,
  463. vid,
  464. this.tableName,
  465. this.ctx.service.projectAccount.tableName,
  466. uid,
  467. pid,
  468. ];
  469. const content = await this.db.query(noticeSql, noticeSqlParam);
  470. return content.length ? JSON.stringify(content[0]) : '';
  471. }
  472. /**
  473. * 通过状态获取审核人信息
  474. * @param {Number} vid - 预付款id
  475. * @param {Number} status - 期状态
  476. * @param {Number} times - 审批次数
  477. * @return {Object} auditor 审核人信息
  478. */
  479. async getAuditorByStatus(vid, status, times = 1) {
  480. let auditor = null;
  481. let sql = '';
  482. let sqlParam = '';
  483. switch (status) {
  484. case auditConst.status.checking:
  485. case auditConst.status.checked:
  486. case auditConst.status.checkNoPre:
  487. sql =
  488. 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`vid`, la.`order` ' +
  489. 'FROM ?? AS la, ?? AS pa ' +
  490. 'WHERE la.`vid` = ? and la.`status` = ? and la.`audit_id` = pa.`id` order by la.`times` desc, la.`order` desc';
  491. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, vid, status];
  492. auditor = await this.db.queryOne(sql, sqlParam);
  493. break;
  494. case auditConst.status.checkNo:
  495. sql =
  496. 'SELECT la.`audit_id`, pa.`name`, pa.`company`, pa.`role`, la.`times`, la.`vid`, la.`order` ' +
  497. 'FROM ?? AS la, ?? AS pa ' +
  498. 'WHERE la.`vid` = ? and la.`status` = ? and la.`times` = ? and la.`audit_id` = pa.`id` order by la.`times` desc, la.`order` desc';
  499. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, vid, auditConst.status.checkNo, parseInt(times) - 1];
  500. auditor = await this.db.queryOne(sql, sqlParam);
  501. break;
  502. case auditConst.status.uncheck:
  503. default:
  504. break;
  505. }
  506. return auditor;
  507. }
  508. /**
  509. * 获取所有审核人
  510. * @param {Number} tenderId 标段id
  511. */
  512. async getAllAuditors(tenderId) {
  513. const sql = 'SELECT au.audit_id, au.tid FROM ' + this.tableName + ' au' +
  514. ' LEFT JOIN ' + this.ctx.service.tender.tableName + ' t On au.tid = t.id' +
  515. ' WHERE t.id = ?' +
  516. ' GROUP BY au.audit_id';
  517. const sqlParam = [tenderId];
  518. return this.db.query(sql, sqlParam);
  519. }
  520. /**
  521. * 获取待处理审核列表
  522. * @param {Number} auditorId 审核人id
  523. */
  524. async getAuditAdvance(auditorId) {
  525. const sql = 'SELECT ma.`audit_id`, ma.`times`, ma.`order`, ma.`create_time`, ma.`end_time`, ma.`tid`, ma.`vid`,' +
  526. ' m.`order` As `morder`, m.`status` As `mstatus`,' +
  527. ' t.`name`, t.`project_id`, t.`type`, t.`user_id` ' +
  528. ' FROM ?? AS ma, ?? AS m, ?? As t ' +
  529. ' WHERE ((ma.`audit_id` = ? and ma.`status` = ?) OR (m.`uid` = ? and ma.`status` = ? and m.`status` = ? and ma.`times` = (m.`times`-1)))' +
  530. ' and ma.`vid` = m.`id` and ma.`tid` = t.`id` ORDER BY ma.`create_time` DESC';
  531. const sqlParam = [this.tableName, this.ctx.service.advance.tableName, this.ctx.service.tender.tableName, auditorId, auditConst.status.checking, auditorId, auditConst.status.checkNo, auditConst.status.checkNo];
  532. return await this.db.query(sql, sqlParam);
  533. }
  534. async updateNewAuditList(advance, newIdList) {
  535. const transaction = await this.db.beginTransaction();
  536. try {
  537. // 先删除旧的审批流,再添加新的
  538. await transaction.delete(this.tableName, { vid: advance.id, times: advance.times });
  539. const newAuditors = [];
  540. let order = 1;
  541. for (const aid of newIdList) {
  542. newAuditors.push({
  543. tid: advance.tid, vid: advance.id, audit_id: aid,
  544. times: advance.times, order, status: auditConst.status.uncheck,
  545. });
  546. order++;
  547. }
  548. if(newAuditors.length > 0) await transaction.insert(this.tableName, newAuditors);
  549. await transaction.commit();
  550. } catch (err) {
  551. await transaction.rollback();
  552. throw err;
  553. }
  554. }
  555. async updateLastAudit(advance, auditList, lastId) {
  556. const transaction = await this.db.beginTransaction();
  557. try {
  558. // 先判断auditList里的aid是否与lastId相同,相同则删除并重新更新order
  559. const idList = this._.map(auditList, 'audit_id');
  560. let order = idList.length + 1;
  561. if (idList.indexOf(lastId) !== -1) {
  562. await transaction.delete(this.tableName, { vid: advance.id, times: advance.times, audit_id: lastId });
  563. const audit = this._.find(auditList, { 'audit_id': lastId });
  564. // 顺移之后审核人流程顺序
  565. await this._syncOrderByDelete(transaction, advance.id, audit.order, advance.times);
  566. order = order - 1;
  567. }
  568. // 添加终审
  569. const newAuditor = {
  570. tid: advance.tid, vid: advance.id, audit_id: lastId,
  571. times: advance.times, order, status: auditConst.status.uncheck,
  572. };
  573. await transaction.insert(this.tableName, newAuditor);
  574. await transaction.commit();
  575. } catch (err) {
  576. await transaction.rollback();
  577. throw err;
  578. }
  579. }
  580. }
  581. return AdvanceAudit;
  582. };