change_project.js 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date 2018/8/14
  7. * @version
  8. */
  9. const audit = require('../const/audit').changeProject;
  10. const auditType = require('../const/audit').auditType;
  11. // const smsTypeConst = require('../const/sms_type');
  12. // const SMS = require('../lib/sms');
  13. // const SmsAliConst = require('../const/sms_alitemplate');
  14. const wxConst = require('../const/wechat_template');
  15. const pushType = require('../const/audit').pushType;
  16. const projectLogConst = require('../const/project_log');
  17. const codeRuleConst = require('../const/code_rule');
  18. const changeConst = require('../const/change');
  19. module.exports = app => {
  20. class ChangeProject extends app.BaseService {
  21. /**
  22. * 构造函数
  23. *
  24. * @param {Object} ctx - egg全局变量
  25. * @return {void}
  26. */
  27. constructor(ctx) {
  28. super(ctx);
  29. this.tableName = 'change_project';
  30. }
  31. async loadChangeAuditViewData(change) {
  32. const times = change.status === audit.status.back || change.status === audit.status.revise ? change.times - 1 : change.times;
  33. if (!change.user) change.user = await this.ctx.service.projectAccount.getAccountInfoById(change.uid);
  34. change.auditHistory = await this.ctx.service.changeProjectAudit.getAuditorHistory(change.id, times);
  35. // 获取审批流程中左边列表
  36. if ((change.status === audit.status.back || change.status === audit.status.revise) && change.uid !== this.ctx.session.sessionUser.accountId && !this.ctx.session.sessionUser.is_admin) {
  37. const auditors = await this.ctx.service.changeProjectAudit.getAuditors(change.id, times); // 全部参与的审批人
  38. const auditorGroups = this.ctx.helper.groupAuditors(auditors, 'order', true);
  39. change.auditors2 = this.ctx.helper.groupAuditorsUniq(auditorGroups);
  40. change.auditors2.unshift([{
  41. aid: change.user.id, order: 0, times: change.times - 1, audit_order: 0, audit_type: auditType.key.common,
  42. name: change.user.name, role: change.user.role, company: change.user.company,
  43. }]);
  44. } else {
  45. change.auditors2 = change.userGroups;
  46. }
  47. if (change.status === audit.status.uncheck || change.status === audit.status.back || change.status === audit.status.revise) {
  48. change.auditorList = await this.ctx.service.changeProjectAudit.getAuditors(change.id, change.times);
  49. }
  50. }
  51. async loadChangeUser(change) {
  52. const status = audit.status;
  53. const accountId = this.ctx.session.sessionUser.accountId;
  54. change.user = await this.ctx.service.projectAccount.getAccountInfoById(change.uid);
  55. change.auditors = await this.ctx.service.changeProjectAudit.getAuditors(change.id, change.times); // 全部参与的审批人
  56. change.auditorIds = this._.map(change.auditors, 'aid');
  57. change.curAuditors = change.auditors.filter(x => { return x.status === status.checking; }); // 当前流程中审批中的审批人
  58. change.curAuditorIds = this._.map(change.curAuditors, 'aid');
  59. change.flowAuditors = change.curAuditors.length > 0 ? change.auditors.filter(x => { return x.order === change.curAuditors[0].order; }) : []; // 当前流程中参与的审批人(包含会签时,审批通过的人)
  60. change.flowAuditorIds = this._.map(change.flowAuditors, 'aid');
  61. change.nextAuditors = change.curAuditors.length > 0 ? change.auditors.filter(x => { return x.order === change.curAuditors[0].order + 1; }) : [];
  62. change.nextAuditorIds = this._.map(change.nextAuditors, 'aid');
  63. change.auditorGroups = this.ctx.helper.groupAuditors(change.auditors, 'order', true);
  64. change.userGroups = this.ctx.helper.groupAuditorsUniq(change.auditorGroups);
  65. change.userGroups.unshift([{
  66. aid: change.user.id, order: 0, times: change.times, audit_order: 0, audit_type: auditType.key.common,
  67. name: change.user.name, role: change.user.role, company: change.user.company,
  68. }]);
  69. change.finalAuditorIds = change.userGroups[change.userGroups.length - 1].map(x => { return x.aid; });
  70. }
  71. async add(tenderId, userId, code, name) {
  72. const type = userId === this.ctx.tender.data.user_id ? codeRuleConst.ruleType.suggestion : codeRuleConst.ruleType.will;
  73. const sql = 'SELECT COUNT(*) as count FROM ?? WHERE `tid` = ? AND `code` = ? AND type = ?';
  74. const sqlParam = [this.tableName, tenderId, code, type];
  75. const codeCount = await this.db.queryOne(sql, sqlParam);
  76. const count = codeCount.count;
  77. if (count > 0) {
  78. throw '立项书编号重复';
  79. }
  80. // 工程变更类别读取
  81. const fun_set = this.ctx.subProject.fun_set;
  82. const classInfo = this._.find(fun_set.change_class, { checked: true });
  83. // 初始化事务
  84. this.transaction = await this.db.beginTransaction();
  85. let result = false;
  86. try {
  87. const change = {
  88. tid: tenderId,
  89. uid: userId,
  90. status: audit.status.uncheck,
  91. times: 1,
  92. type,
  93. in_time: new Date(),
  94. code,
  95. name,
  96. quality: changeConst.quality.common.name,
  97. class: classInfo.new_name ? classInfo.new_name : classInfo.name,
  98. };
  99. const operate = await this.transaction.insert(this.tableName, change);
  100. if (operate.affectedRows <= 0) {
  101. throw '新建变更令数据失败';
  102. }
  103. change.id = operate.insertId;
  104. // 先找出标段最近存在的变更令审批人的变更令info
  105. const preChangeInfo = await this.getHaveAuditLastInfo(tenderId, type);
  106. if (preChangeInfo) {
  107. // 并把之前存在的变更令审批人添加到zh_change_audit
  108. const auditResult = await this.ctx.service.changeProjectAudit.copyPreChangeProjectAuditors(this.transaction, preChangeInfo, change);
  109. if (!auditResult) {
  110. throw '复制上一次审批流程失败';
  111. }
  112. }
  113. result = change;
  114. this.transaction.commit();
  115. } catch (error) {
  116. console.log(error);
  117. // 回滚
  118. await this.transaction.rollback();
  119. }
  120. return result;
  121. }
  122. async getHaveAuditLastInfo(tenderId, type) {
  123. const sql = 'SELECT a.* FROM ?? as a LEFT JOIN ?? as b ON a.`id` = b.`cpid` WHERE a.`tid` = ? AND a.type = ? ORDER BY a.`in_time` DESC';
  124. const sqlParam = [this.tableName, this.ctx.service.changeProjectAudit.tableName, tenderId, type];
  125. return await this.db.queryOne(sql, sqlParam);
  126. }
  127. /**
  128. * 获取变更立项列表
  129. * @param {int} tenderId - 标段id
  130. * @param {int} status - 状态
  131. * @param {int} hadlimit - 分页
  132. * @return {object} list - 列表
  133. */
  134. async getListByStatus(tenderId, status = 0, hadlimit = 1, sortBy = '', orderBy = '') {
  135. let sql = '';
  136. let sqlParam = '';
  137. if ((this.ctx.tender.isTourist || this.ctx.session.sessionUser.is_admin) && status === 0) {
  138. sql = 'SELECT a.*, p.name as account_name FROM ?? As a LEFT JOIN ?? AS p On a.uid = p.id WHERE a.tid = ?';
  139. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, tenderId];
  140. } else {
  141. switch (status) {
  142. case 0: // 包含你的所有变更立项
  143. sql =
  144. 'SELECT a.*, p.name as account_name FROM ?? AS a LEFT JOIN ?? AS p On a.uid = p.id WHERE a.tid = ? AND' +
  145. ' (a.uid = ? OR (a.status != ? AND (a.id IN (SELECT b.cpid FROM ?? AS b WHERE b.aid = ? GROUP BY b.cpid)' +
  146. ' OR a.id IN (SELECT c.cpid FROM ?? AS c WHERE c.aid = ? AND c.tid = ?)))' +
  147. ' OR a.status = ? )';
  148. sqlParam = [
  149. this.tableName,
  150. this.ctx.service.projectAccount.tableName,
  151. tenderId,
  152. this.ctx.session.sessionUser.accountId,
  153. audit.status.uncheck,
  154. this.ctx.service.changeProjectAudit.tableName,
  155. this.ctx.session.sessionUser.accountId,
  156. this.ctx.service.changeProjectXsAudit.tableName,
  157. this.ctx.session.sessionUser.accountId,
  158. tenderId,
  159. audit.status.checked,
  160. ];
  161. break;
  162. case 1: // 待处理(你的)
  163. sql = 'SELECT a.*, p.name as account_name FROM ?? as a LEFT JOIN ?? AS p On a.uid = p.id WHERE' +
  164. ' a.tid = ? AND (a.id in(SELECT b.cpid FROM ?? as b WHERE b.tid = ? AND b.aid = ? AND b.status = ?)' +
  165. ' OR (a.uid = ? AND (a.status = ? OR a.status = ? OR a.status = ?)))';
  166. sqlParam = [this.tableName,
  167. this.ctx.service.projectAccount.tableName,
  168. tenderId, this.ctx.service.changeProjectAudit.tableName,
  169. tenderId, this.ctx.session.sessionUser.accountId,
  170. audit.status.checking, this.ctx.session.sessionUser.accountId,
  171. audit.status.uncheck, audit.status.back, audit.status.revise,
  172. ];
  173. break;
  174. case 5: // 待上报(所有的)PS:取未上报,退回,修订的变更令
  175. sql =
  176. 'SELECT a.*, p.name as account_name FROM ?? AS a LEFT JOIN ?? AS p On a.uid = p.id WHERE ' +
  177. 'a.uid = ? AND a.tid = ? AND (a.status = ? OR a.status = ? OR a.status = ?)';
  178. sqlParam = [
  179. this.tableName,
  180. this.ctx.service.projectAccount.tableName,
  181. // this.ctx.service.changeProjectAudit.tableName,
  182. this.ctx.session.sessionUser.accountId,
  183. tenderId,
  184. audit.status.uncheck,
  185. audit.status.back,
  186. audit.status.revise,
  187. ];
  188. break;
  189. case 2: // 进行中(所有的)
  190. case 4: // 终止(所有的)
  191. sql =
  192. 'SELECT a.*, p.name as account_name FROM ?? AS a LEFT JOIN ?? AS p On a.uid = p.id WHERE ' +
  193. 'a.status = ? AND a.tid = ? AND (a.uid = ? OR a.id IN (SELECT b.cpid FROM ?? AS b WHERE b.aid = ? GROUP BY b.cpid) OR a.id IN (SELECT c.cpid FROM ?? AS c WHERE c.aid = ? AND c.tid = ?))';
  194. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, status, tenderId, this.ctx.session.sessionUser.accountId, this.ctx.service.changeProjectAudit.tableName, this.ctx.session.sessionUser.accountId, this.ctx.service.changeProjectXsAudit.tableName, this.ctx.session.sessionUser.accountId, tenderId];
  195. break;
  196. case 3: // 已完成(所有的)
  197. sql = 'SELECT a.*, p.name as account_name FROM ?? AS a LEFT JOIN ?? AS p On a.uid = p.id WHERE a.status = ? AND a.tid = ?';
  198. sqlParam = [this.tableName, this.ctx.service.projectAccount.tableName, status, tenderId];
  199. break;
  200. default:
  201. break;
  202. }
  203. }
  204. if (sortBy && orderBy) {
  205. if (sortBy === 'code') {
  206. sql += ' ORDER BY CHAR_LENGTH(a.code) ' + orderBy + ',convert(a.code using gbk) ' + orderBy;
  207. } else {
  208. sql += ' ORDER BY a.in_time ' + orderBy;
  209. }
  210. } else {
  211. sql += ' ORDER BY a.in_time DESC';
  212. }
  213. if (hadlimit) {
  214. const limit = this.ctx.pageSize ? this.ctx.pageSize : this.app.config.pageSize;
  215. const offset = limit * (this.ctx.page - 1);
  216. const limitString = offset >= 0 ? offset + ',' + limit : limit;
  217. sql += ' LIMIT ' + limitString;
  218. }
  219. const list = await this.db.query(sql, sqlParam);
  220. return list;
  221. }
  222. // 获取最后一个变更立项
  223. async getLastChange(tenderId) {
  224. const sql = 'select * from ?? where tid = ? order by in_time desc LIMIT 1';
  225. const sqlParam = [this.tableName, tenderId];
  226. const result = await this.db.queryOne(sql, sqlParam);
  227. return result;
  228. }
  229. /**
  230. * 获取变更令个数
  231. * @param {int} tenderId - 标段id
  232. * @param {int} status - 状态
  233. * @return {void}
  234. */
  235. async getCountByStatus(tenderId, status) {
  236. if ((this.ctx.tender.isTourist || this.ctx.session.sessionUser.is_admin)) {
  237. let touristSql;
  238. let touristSqlParam;
  239. let touristResult;
  240. switch (status) {
  241. case 0:
  242. touristSql = 'SELECT count(*) AS count FROM ?? WHERE tid = ? ORDER BY in_time DESC';
  243. touristSqlParam = [this.tableName, tenderId];
  244. touristResult = await this.db.query(touristSql, touristSqlParam);
  245. return touristResult[0].count;
  246. // case 1:
  247. // touristSql = 'SELECT count(*) AS count FROM ?? WHERE tid = ? AND (status = ? OR status = ?) ORDER BY in_time DESC';
  248. // touristSqlParam = [this.tableName, tenderId, audit.status.uncheck, audit.status.checking];
  249. // touristResult = await this.db.query(touristSql, touristSqlParam);
  250. // return touristResult[0].count;
  251. // case 5:
  252. // touristSql = 'SELECT count(*) AS count FROM ?? WHERE tid = ? AND status = ? ORDER BY in_time DESC';
  253. // touristSqlParam = [this.tableName, tenderId, audit.status.uncheck];
  254. // touristResult = await this.db.query(touristSql, touristSqlParam);
  255. // return touristResult[0].count;
  256. // case 2:
  257. // touristSql = 'SELECT count(*) AS count FROM ?? WHERE tid = ? AND status = ? ORDER BY in_time DESC';
  258. // touristSqlParam = [this.tableName, tenderId, audit.status.uncheck];
  259. // touristResult = await this.db.query(touristSql, touristSqlParam);
  260. // return touristResult[0].count;
  261. // case 4:
  262. // touristSql = 'SELECT count(*) AS count FROM ?? WHERE tid = ? AND status = ? ORDER BY in_time DESC';
  263. // touristSqlParam = [this.tableName, tenderId, status];
  264. // touristResult = await this.db.query(touristSql, touristSqlParam);
  265. // return touristResult[0].count;
  266. default:
  267. break;
  268. }
  269. }
  270. switch (status) {
  271. case 0: // 包含你的所有变更令
  272. const sql =
  273. 'SELECT count(*) AS count FROM ?? AS a WHERE a.tid = ? AND ' +
  274. '(a.uid = ? OR (a.status != ? AND (a.id IN (SELECT b.cpid FROM ?? AS b WHERE b.aid = ? GROUP BY b.cpid) OR a.id IN (SELECT c.cpid FROM ?? AS c WHERE c.aid = ? AND c.tid = ?))) OR a.status = ? )';
  275. const sqlParam = [
  276. this.tableName,
  277. tenderId,
  278. this.ctx.session.sessionUser.accountId,
  279. audit.status.uncheck,
  280. this.ctx.service.changeProjectAudit.tableName,
  281. this.ctx.session.sessionUser.accountId,
  282. this.ctx.service.changeProjectXsAudit.tableName,
  283. this.ctx.session.sessionUser.accountId,
  284. tenderId,
  285. audit.status.checked,
  286. ];
  287. const result = await this.db.query(sql, sqlParam);
  288. return result[0].count;
  289. case 1: // 待处理(你的)
  290. // return await this.ctx.service.changeAudit.count({
  291. // tid: tenderId,
  292. // uid: this.ctx.session.sessionUser.accountId,
  293. // status: 2,
  294. // });
  295. const sql6 = 'SELECT count(*) AS count FROM ?? as a WHERE a.tid = ? AND (a.id in(SELECT b.cpid FROM ?? as b WHERE b.tid = ? AND b.aid = ? AND b.status = ?) OR (a.uid = ? AND (a.status = ? OR a.status = ? OR a.status = ?)))';
  296. const sqlParam6 = [this.tableName, tenderId, this.ctx.service.changeProjectAudit.tableName, tenderId, this.ctx.session.sessionUser.accountId, audit.status.checking, this.ctx.session.sessionUser.accountId, audit.status.uncheck, audit.status.back, audit.status.revise];
  297. const result6 = await this.db.query(sql6, sqlParam6);
  298. return result6[0].count;
  299. case 5: // 待上报(所有的)PS:取未上报,退回的变更立项
  300. const sql2 =
  301. 'SELECT count(*) AS count FROM ?? AS a WHERE ' +
  302. 'a.uid = ? AND a.tid = ? AND (a.status = ? OR a.status = ? OR a.status = ?)';
  303. const sqlParam2 = [
  304. this.tableName,
  305. // this.ctx.service.changeProjectAudit.tableName,
  306. this.ctx.session.sessionUser.accountId,
  307. tenderId,
  308. audit.status.uncheck,
  309. audit.status.back,
  310. audit.status.revise,
  311. ];
  312. const result2 = await this.db.query(sql2, sqlParam2);
  313. return result2[0].count;
  314. case 2: // 进行中(所有的)
  315. case 4: // 终止(所有的)
  316. const sql3 =
  317. 'SELECT count(*) AS count FROM ?? AS a WHERE ' +
  318. 'a.status = ? AND a.tid = ? AND (a.uid = ? OR a.id IN (SELECT b.cpid FROM ?? AS b WHERE b.aid = ? GROUP BY b.cpid) OR a.id IN (SELECT c.cpid FROM ?? AS c WHERE c.aid = ? AND c.tid = ?))';
  319. const sqlParam3 = [this.tableName, status, tenderId, this.ctx.session.sessionUser.accountId, this.ctx.service.changeProjectAudit.tableName, this.ctx.session.sessionUser.accountId, this.ctx.service.changeProjectXsAudit.tableName, this.ctx.session.sessionUser.accountId, tenderId];
  320. const result3 = await this.db.query(sql3, sqlParam3);
  321. return result3[0].count;
  322. case 3: // 已完成(所有的)
  323. const sql4 = 'SELECT count(*) AS count FROM ?? WHERE status = ? AND tid = ?';
  324. const sqlParam4 = [this.tableName, status, tenderId];
  325. const result4 = await this.db.query(sql4, sqlParam4);
  326. return result4[0].count;
  327. default:
  328. break;
  329. }
  330. }
  331. /**
  332. * 保存变更信息
  333. * @param {int} postData - 表单提交的数据
  334. * @param {int} tenderId - 标段id
  335. * @return {void}
  336. */
  337. async saveInfo(cpId, postData) {
  338. // 初始化事务
  339. const transaction = await this.db.beginTransaction();
  340. let result = false;
  341. try {
  342. const updateData = {
  343. id: cpId,
  344. };
  345. updateData[postData.name] = postData.val;
  346. await transaction.update(this.tableName, updateData);
  347. await transaction.commit();
  348. result = true;
  349. } catch (error) {
  350. await transaction.rollback();
  351. result = false;
  352. }
  353. return result;
  354. }
  355. /**
  356. * 判断是否有重名的变更立项
  357. * @param cpid
  358. * @param code
  359. * @param tid
  360. * @return {Promise<void>}
  361. */
  362. async isRepeat(cpId, code, tid, type) {
  363. const sql = 'SELECT COUNT(*) as count FROM ?? WHERE `code` = ? AND `id` != ? AND `tid` = ? AND `type` = ?';
  364. const sqlParam = [this.tableName, code, cpId, tid, type];
  365. const result = await this.db.queryOne(sql, sqlParam);
  366. return result.count !== 0;
  367. }
  368. /**
  369. * 查询可用的变更令
  370. * @param { string } cid - 查询的清单
  371. * @return {Promise<*>} - 可用的变更令列表
  372. */
  373. async delete(id) {
  374. // 初始化事务
  375. this.transaction = await this.db.beginTransaction();
  376. let result = false;
  377. try {
  378. const changeInfo = await this.getDataById(id);
  379. // 先删除审批人列表
  380. await this.transaction.delete(this.ctx.service.changeProjectAudit.tableName, { cpid: id });
  381. // 再删除附件和附件文件ni zuo
  382. const attList = await this.ctx.service.changeProjectAtt.getAllDataByCondition({ where: { cpid: id } });
  383. await this.ctx.helper.delFiles(attList);
  384. await this.transaction.delete(this.ctx.service.changeProjectAtt.tableName, { cpid: id });
  385. // if (attList.length !== 0) {
  386. // for (const att of attList) {
  387. // await fs.unlinkSync(path.join(this.app.baseDir, att.filepath));
  388. // }
  389. // await this.transaction.delete(this.ctx.service.changeAtt.tableName, { cid });
  390. // }
  391. // 最后删除变更令
  392. await this.transaction.delete(this.tableName, { id });
  393. // 删除history
  394. await this.transaction.delete(this.ctx.service.changeProjectHistory.tableName, { cpid: id });
  395. // 记录删除日志
  396. await this.ctx.service.projectLog.addProjectLog(this.transaction, projectLogConst.type.changeProject, projectLogConst.status.delete, changeInfo.code);
  397. await this.transaction.commit();
  398. result = true;
  399. } catch (e) {
  400. await this.transaction.rollback();
  401. result = false;
  402. }
  403. return result;
  404. }
  405. async doCheckChangeCanCancel(change) {
  406. // 获取当前审批人的上一个审批人,判断是否是当前登录人,并赋予撤回功能,(当审批人存在有审批过时,上一人不允许再撤回)
  407. const status = audit.status;
  408. const accountId = this.ctx.session.sessionUser.accountId;
  409. change.cancancel = 0;
  410. if (change.status !== status.checked && change.status !== status.uncheck && change.status !== status.revise) {
  411. if (change.status === status.back) {
  412. const lastAuditors = await this.service.changeProjectAudit.getAuditors(change.id, change.times - 1);
  413. const onAuditor = this._.findLast(lastAuditors, { status: status.back });
  414. if (onAuditor && onAuditor.aid === accountId) {
  415. change.cancancel = 4;// 审批人撤回退回原报
  416. change.preAuditors = lastAuditors.filter(x => { return x.order === onAuditor.order; });
  417. }
  418. } else if (change.status === status.checkNo) {
  419. const lastAuditors = await this.service.changeProjectAudit.getAuditors(change.id, change.times);
  420. const onAuditor = this._.findLast(change.auditors, function(item) {
  421. return item.status === status.checkNo;
  422. });
  423. if (onAuditor && onAuditor.aid === accountId) {
  424. change.cancancel = 3; // 审批人撤回审批终止
  425. change.preAuditors = lastAuditors.filter(x => { return x.order === onAuditor.order; });
  426. }
  427. } else {
  428. // 找出当前操作人上一个审批人,包括审批完成的和退回上一个审批人的,同时当前操作人为第一人时,就是则为原报
  429. if (change.flowAuditors.find(x => { return x.status !== status.checking; }) && change.flowAuditorIds.indexOf(accountId) < 0) return; // 当前流程存在审批人审批通过时,不可撤回
  430. if (change.curAuditorIds.indexOf(accountId) < 0 && change.flowAuditorIds.indexOf(accountId) >= 0) {
  431. change.cancancel = 5; // 会签未全部审批通过时,审批人撤回审批通过
  432. return;
  433. }
  434. const preAuditors = change.curAuditors[0].order !== 1 ? change.auditors.filter(x => { return x.order === change.curAuditors[0].order - 1; }) : [];
  435. const preAuditorCheckAgain = preAuditors.find(pa => { return pa.status === status.checkAgain; });
  436. const preAuditorCheckCancel = preAuditors.find(pa => { return pa.status === status.checkCancel; });
  437. const preAuditorIds = preAuditorCheckAgain ? [] : preAuditors.map(x => { return x.aid; }); // 重审不可撤回
  438. if ((this._.isEqual(change.flowAuditorIds, preAuditorIds) && preAuditorCheckCancel)) {
  439. return; // 不可以多次撤回
  440. }
  441. const preAuditChecked = preAuditors.find(pa => { return pa.status === status.checked && pa.aid === accountId; });
  442. // const preAuditCheckNoPre = preAuditors.find(pa => { return pa.status === status.checkNoPre && pa.uid === accountId; });
  443. if (preAuditorIds.indexOf(accountId) >= 0) {
  444. if (preAuditChecked && change.status === status.checking) {
  445. change.cancancel = 2;// 审批人撤回审批通过
  446. }
  447. // else if (preAuditCheckNoPre && change.status === status.checkNoPre) {
  448. // change.cancancel = 3;// 审批人撤回审批退回上一人
  449. // }
  450. change.preAuditors = preAuditors;
  451. } else if (preAuditors.length === 0 && accountId === change.uid) {
  452. change.cancancel = 1;// 原报撤回
  453. }
  454. }
  455. }
  456. }
  457. async getListByArchives(tid, ids) {
  458. if (ids.length === 0) return [];
  459. const sql = 'SELECT c.* FROM ?? as c LEFT JOIN (SELECT cpid, MAX(end_time) as end_time FROM ?? WHERE ' +
  460. 'tid = ? AND cpid in (' + this.ctx.helper.getInArrStrSqlFilter(ids) + ') GROUP BY cpid) as ca ON c.id = ca.cpid WHERE' +
  461. ' c.tid = ? AND c.id in (' + this.ctx.helper.getInArrStrSqlFilter(ids) + ') AND c.status = ? ORDER BY ca.end_time DESC';
  462. const params = [this.tableName, this.ctx.service.changeProjectAudit.tableName, tid, tid, audit.status.checked];
  463. const list = await this.db.query(sql, params);
  464. return list;
  465. }
  466. }
  467. return ChangeProject;
  468. };