stage_pay.js 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const timesLen = require('../const/audit').stage.timesLen;
  10. const payConst = require('../const/deal_pay');
  11. const auditConst = require('../const/audit');
  12. module.exports = app => {
  13. class StagePay extends app.BaseService {
  14. /**
  15. * 构造函数
  16. *
  17. * @param {Object} ctx - egg全局变量
  18. * @return {void}
  19. */
  20. constructor(ctx) {
  21. super(ctx);
  22. this.tableName = 'stage_pay';
  23. }
  24. /**
  25. * 查询 某期 某轮审批 某审核人数据
  26. *
  27. * @param {Number} pid - 合同支付id
  28. * @param {Number} sid - 期id
  29. * @param {Number} times - 期第几轮审批
  30. * @param {Number} order - 审核人顺序
  31. * @param {Number|Array|Null} pid - 部位明细id - 为空则查询全部
  32. * @returns {Promise<*>}
  33. */
  34. async getAuditorStagePay(pid, sid, times, order) {
  35. const pidSql = pid instanceof Array ? ' And SP.`pid` in (' + pid.join(',') + ')' : 'And SP.`pid` = ' + pid;
  36. const sql = 'SELECT SP.*, P.`csorder`, P.`cstimes`, P.`csaorder`, P.`order`, P.uid, P.minus, P.ptype, P.sprice, P.sexpr, P.rprice, P.rexpr, P.is_yf, P.dl_type, P.dl_count, P.dl_tp_type, P.dl_tp ' +
  37. ' FROM ' + this.tableName + ' As SP ' +
  38. ' LEFT JOIN ' + this.ctx.service.pay.tableName + ' As P ' +
  39. ' ON SP.pid = P.id' +
  40. ' WHERE SP.`sid` = ? AND SP.`stimes` = ? AND SP.`sorder` = ? AND SP.`pid` = P.`id` AND P.`valid`' + pidSql +
  41. ' ORDER BY P.`order`';
  42. const sqlParam = [sid, times, order, pid];
  43. if (pid instanceof Array) {
  44. return await this.db.query(sql, sqlParam);
  45. } else {
  46. return await this.db.queryOne(sql, sqlParam);
  47. }
  48. }
  49. /**
  50. * 查询 某期 某轮审批 某审核人数据
  51. * @param {Number} sid - 期id
  52. * @param {Number} times - 期第几轮审批
  53. * @param {Number} order - 审核人顺序
  54. * @param {Number|Array|Null} pid - 部位明细id - 为空则查询全部
  55. * @returns {Promise<*>}
  56. */
  57. async getAuditorStageData(sid, times, order) {
  58. const sql = 'SELECT SP.*,' +
  59. ' P.`csorder`, P.`cstimes`, P.`csaorder`, P.`order`, P.uid, P.minus, P.ptype, P.sprice, P.sexpr,' +
  60. ' P.rprice, P.rexpr, P.is_yf, P.dl_type, P.dl_count, P.dl_tp_type, P.dl_tp, P.name as pName ' +
  61. ' FROM ' + this.tableName + ' As SP ' +
  62. ' LEFT JOIN ' + this.ctx.service.pay.tableName + ' As P ' +
  63. ' ON SP.pid = P.id' +
  64. ' WHERE SP.`sid` = ? AND SP.`stimes` = ? AND SP.`sorder` = ? AND SP.`pid` = P.`id` AND P.`valid`' +
  65. ' ORDER BY P.`order`';
  66. const sqlParam = [sid, times, order];
  67. return await this.db.query(sql, sqlParam);
  68. }
  69. /**
  70. * 新增期时,初始化 期--合同支付 数据
  71. * @param {Object} stage - 新增的期
  72. * @param transaction - 事务
  73. * @returns {Promise<void>}
  74. */
  75. async addInitialStageData(stage, transaction) {
  76. const basesReg = new RegExp(payConst.calcBase.map(x => {return '(' + x.code + ')'}).join('|'));
  77. const orderReg = /f\d+/im;
  78. if (!stage) {
  79. throw '初始化期合同支付数据失败';
  80. }
  81. let pays = await this.ctx.service.pay.getAllDataByCondition({where: { tid: this.ctx.tender.id } });
  82. // 兼容旧项目,无初始化合同支付数据
  83. if (!pays || pays.length === 0) {
  84. const result = await this.ctx.service.pay.addDefaultPayData(this.ctx.tender.id, transaction);
  85. if (!result) {
  86. throw '初始化合同支付数据失败';
  87. }
  88. pays = await transaction.select(this.ctx.service.pay.tableName, {where: { tid: this.ctx.tender.id } });
  89. }
  90. const stagePays = [];
  91. // 获取截止上期数据
  92. if (stage.order > 1) {
  93. const preStage = await this.ctx.service.stage.getDataByCondition({tid: stage.tid, order: stage.order - 1});
  94. if (!preStage) {
  95. throw '标段数据有误';
  96. }
  97. const prePays = await this.getStageLastestPays(preStage.id);
  98. for (const pp of prePays) {
  99. const p = this._.find(pays, {id: pp.pid});
  100. stagePays.push({
  101. tid: p.tid, sid: stage.id, pid: p.id,
  102. stimes: stage.times, sorder: 0,
  103. name: pp.name,
  104. expr: (p.ptype === payConst.payType.normal || p.ptype === payConst.payType.sf)
  105. ? (basesReg.test(pp.expr) || orderReg.test(pp.expr) ? pp.expr : null)
  106. : (p.type === payConst.wc ? pp.expr : null),
  107. pause: pp.pause,
  108. pre_tp: pp.end_tp,
  109. pre_used: pp.pre_used || !this.ctx.helper.checkZero(pp.tp),
  110. pre_finish: pp.pre_finish || (pp.rprice ? pp.end_tp === pp.rprice : false),
  111. start_stage_order: pp.start_stage_order,
  112. });
  113. }
  114. } else {
  115. for (const p of pays) {
  116. stagePays.push({
  117. tid: p.tid, sid: stage.id, pid: p.id,
  118. stimes: stage.times, sorder: 0, expr: p.expr, name: p.name,
  119. });
  120. }
  121. }
  122. let result;
  123. if (transaction) {
  124. result = await transaction.insert(this.tableName, stagePays);
  125. } else {
  126. result = await this.db.insert(this.tableName, stagePays);
  127. }
  128. return result.affectedRows === stagePays.length;
  129. }
  130. async getStagePay(stage, pid) {
  131. return await this.getAuditorStagePay(pid, stage.id, stage.curTimes, stage.curOrder);
  132. }
  133. async resortStagePays(stage, stagePays) {
  134. if (stage.status !== auditConst.stage.status.checked) return;
  135. stagePays.sort((x, y) => { return x.porder - y.porder; });
  136. }
  137. /**
  138. * 获取某期合同支付数据
  139. *
  140. * @param {Object} stage - 期数据(通过StageController._getStageData()获取)
  141. * @returns {Promise<*>}
  142. */
  143. async getStagePays(stage) {
  144. const result = await this.getAuditorStageData(stage.id, stage.curTimes, stage.curOrder);
  145. this.resortStagePays(stage, result);
  146. return result;
  147. }
  148. /**
  149. * 获取某期最后数据(不限制该期是否已经审批通过)
  150. *
  151. * @param {Number} sid - 期id
  152. * @returns {Promise<*>}
  153. */
  154. async getStageLastestPays(sid) {
  155. const sql = 'SELECT SP.*, P.`order`, P.uid, P.minus, P.ptype, P.sprice, P.sexpr, P.rprice, P.rexpr, P.is_yf, P.dl_type, P.dl_count, P.dl_tp_type, P.dl_tp ' +
  156. ' FROM ' + this.tableName + ' As SP' +
  157. ' INNER JOIN ' + this.ctx.service.pay.tableName + ' As P ON SP.pid = P.id' +
  158. ' INNER JOIN ( ' +
  159. ' SELECT MAX(`stimes` * ' + timesLen + ' + `sorder`) As `sprogress` ' +
  160. ' FROM ' + this.tableName +
  161. ' WHERE `sid` = ? ' +
  162. ' GROUP BY `sid`) As M ON (SP.`stimes` * ' + timesLen + ' + SP.`sorder`) = M.`sprogress`' +
  163. ' WHERE SP.`sid` = ? AND P.`valid` = true' +
  164. ' ORDER BY P.`order`';
  165. const sqlParam = [sid, sid];
  166. const result = await this.db.query(sql, sqlParam);
  167. return result;
  168. }
  169. /**
  170. * 同步新增 (仅供合同支付新增时调用)
  171. * @param {Object} pay - 合同支付项数据
  172. * @param transaction - 新增合同支付的事务
  173. * @returns {Promise<{tid, sid: number|*, pid, stimes: number|*, sorder: number|*}>}
  174. */
  175. async syncAdd(pay, transaction) {
  176. const stagePay = {
  177. tid: pay.tid,
  178. sid: pay.csid,
  179. pid: pay.id,
  180. stimes: pay.cstimes,
  181. sorder: pay.csaorder,
  182. };
  183. const result = await transaction.insert(this.tableName, stagePay);
  184. if (result.affectedRows !== 1) {
  185. throw '新增数据失败';
  186. }
  187. stagePay.id = result.insertId;
  188. return stagePay;
  189. }
  190. /**
  191. * 保存本期金额/表达式
  192. * @param data
  193. * @returns {Promise<void>}
  194. */
  195. async save(saveData) {
  196. const datas = saveData instanceof Array ? saveData : [saveData], updateDatas = [];
  197. const stagePays = await this.getStagePay(this.ctx.stage, this._.map(datas, 'pid'));
  198. for (const data of datas) {
  199. const stagePay = stagePays.find(x => {
  200. return x.pid === data.pid;
  201. });
  202. const updateData = {id: stagePay.id};
  203. if (data.name !== undefined) { updateData.name = data.name }
  204. if (data.expr !== undefined) { updateData.expr = data.expr }
  205. if (data.tp !== undefined) { updateData.tp = data.tp; updateData.end_tp = this.ctx.helper.add(data.tp, data.pre_tp); }
  206. if (data.pause !== undefined) { updateData.pause = data.pause }
  207. if (data.postil !== undefined) updateData.postil = data.postil;
  208. updateDatas.push(updateData);
  209. }
  210. const result = await this.db.updateRows(this.tableName, updateDatas);
  211. if (result.affectedRows !== updateDatas.length) {
  212. throw '保存数据失败';
  213. }
  214. }
  215. /**
  216. * 计算
  217. * @param {object} stage - 期数据
  218. * @param {object} transaction - 事务
  219. * @return {Promise<Array>} 计算结果(应付和实付数据)
  220. */
  221. async calcAllStagePays(stage, transaction) {
  222. if (!stage || !transaction) {
  223. throw '计算数据错误';
  224. }
  225. const stagePays = await this.getStagePays(stage);
  226. const PayCalculator = require('../lib/pay_calc');
  227. const payCalculator = new PayCalculator(this.ctx, stage, this.ctx.tender.info);
  228. await payCalculator.calculateAll(stagePays);
  229. const srUpdate = [], update = [];
  230. for (const sp of stagePays) {
  231. update.push({
  232. id: sp.id,
  233. tp: sp.tp,
  234. end_tp: sp.end_tp,
  235. start_stage_order: sp.start_stage_order && sp.start_stage_order < stage.order
  236. ? sp.start_stage_order
  237. : (this.ctx.helper.checkZero(sp.tp) ? null : stage.order),
  238. });
  239. srUpdate.push({
  240. id: sp.pid,
  241. sprice: sp.sprice,
  242. rprice: sp.rprice,
  243. });
  244. }
  245. await transaction.updateRows(this.tableName, update);
  246. if (srUpdate.length > 0) {
  247. await transaction.updateRows(this.ctx.service.pay.tableName, srUpdate);
  248. }
  249. const yf = this._.find(stagePays, {ptype: payConst.payType.yf});
  250. const sf = this._.find(stagePays, {ptype: payConst.payType.sf});
  251. return [yf, sf];
  252. }
  253. async getSpecialTotalPrice(stage) {
  254. if (!stage) throw '计算数据错误';
  255. const stagePays = await this.getStagePays(stage);
  256. const PayCalculator = require('../lib/pay_calc');
  257. const tenderInfo = await this.ctx.service.tenderInfo.getTenderInfo(stage.tid);
  258. const payCalculator = new PayCalculator(this.ctx, stage, tenderInfo);
  259. await payCalculator.calculateAll(stagePays);
  260. const yf = this._.find(stagePays, {ptype: payConst.payType.yf});
  261. const sf = this._.find(stagePays, {ptype: payConst.payType.sf});
  262. return { yf: yf ? yf.tp : 0, sf: sf ? sf.tp : 0 };
  263. }
  264. async getHistorySf(stage) {
  265. if (!stage) return 0;
  266. const stagePays = stage.status === auditConst.stage.status.checked
  267. ? await this.getStageLastestPays(stage.id)
  268. : await this.getStagePays(stage);
  269. const sf = this._.find(stagePays, {ptype: payConst.payType.sf});
  270. return sf;
  271. }
  272. /**
  273. * 拷贝上一操作人数据 为 下一操作人数据
  274. * @param {object} stage - 期数据
  275. * @param {int} times - 下一操作人 该期第几次
  276. * @param {int} order - 下一操作人顺序
  277. * @param {object} transaction - 事务
  278. * @return {Promise<*>} 初始化sql执行结果
  279. */
  280. async copyAuditStagePays(stage, times, order, transaction, curTimes = stage.curTimes, curOrder = stage.curOrder) {
  281. if (!stage || !transaction || !times || order === undefined) {
  282. throw '数据错误';
  283. }
  284. const sql = 'INSERT INTO ?? (`tid`, `sid`, `pid`, `stimes`, `sorder`, `porder`, `name`, `tp`, `expr`, `pause`,' +
  285. ' `pre_tp`, `end_tp`, `pre_used`, `pre_finish`, `start_stage_order`, `postil`) ' +
  286. ' SELECT SP.`tid`, SP.`sid`, SP.`pid`, ?, ?, SP.`porder`, SP.name, SP.`tp`, SP.`expr`, SP.`pause`,' +
  287. ' SP.`pre_tp`, SP.`end_tp`, SP.`pre_used`, SP.`pre_finish`, SP.`start_stage_order`, SP.`postil` ' +
  288. ' FROM ?? As SP' +
  289. ' WHERE SP.`sid` = ? AND SP.`stimes` = ? AND SP.`sorder` = ?';
  290. const sqlParam = [this.tableName, times, order, this.tableName, stage.id, curTimes, curOrder];
  291. return await transaction.query(sql, sqlParam);
  292. }
  293. /**
  294. * 删除操作人数据
  295. * @param stage - 期数据
  296. * @param times - 操作人 该期第几次
  297. * @param order - 操作人顺序
  298. * @param transaction - 事务
  299. * @returns {Promise<*>}
  300. */
  301. async deleteAuditStagePays(stage, times, order, transaction) {
  302. if (!stage || !transaction || !times || order === undefined) {
  303. throw '数据错误';
  304. }
  305. return await transaction.delete(this.tableName, { sid: stage.id, stimes: times, sorder: order });
  306. }
  307. async getLastestPayId(id) {
  308. const info = await this.getDataById(id);
  309. const sql = 'SELECT SP.* FROM ?? As SP WHERE SP.`sid` = ? AND SP.`pid` = ? ORDER BY SP.`stimes` DESC, SP.`sorder` DESC';
  310. const sqlParam = [this.tableName, info.sid, info.pid];
  311. const lst = await this.db.queryOne(sql, sqlParam);
  312. if (!lst || !lst.id) throw '数据错误';
  313. return lst.id;
  314. }
  315. /**
  316. * 删除审批流程时,拷贝数据
  317. * @param {object} stage - 期数据
  318. * @param {int} times - 拷贝至 该期第几次
  319. * @param {int} order - 拷贝至 槽作人顺序
  320. * @param {int} copyTimes - 源 该期第几次
  321. * @param {int} copyOrder - 源 操作人顺序
  322. * @param {object} transaction - 事务
  323. * @return {Promise<*>} 初始化sql执行结果
  324. */
  325. async copyStagePays4DeleteTimes(stage, times, order, copyTimes, copyOrder, transaction) {
  326. const sql = 'INSERT INTO ?? (`tid`, `sid`, `pid`, `stimes`, `sorder`, `name`, `tp`, `expr`, `pause`,' +
  327. ' `pre_tp`, `end_tp`, `pre_used`, `pre_finish`, `start_stage_order`) ' +
  328. ' SELECT SP.`tid`, SP.`sid`, SP.`pid`, ?, ?, SP.name, SP.`tp`, SP.`expr`, SP.`pause`,' +
  329. ' SP.`pre_tp`, SP.`end_tp`, SP.`pre_used`, SP.`pre_finish`, SP.`start_stage_order` ' +
  330. ' FROM ?? As SP, ?? As P ' +
  331. ' WHERE SP.`sid` = ? AND SP.`stimes` = ? AND SP.`sorder` = ? And SP.`pid` = P.`id` And P.`valid`';
  332. const sqlParam = [this.tableName, times, order, this.tableName, this.ctx.service.pay.tableName,
  333. stage.id, copyTimes, copyOrder];
  334. return await transaction.query(sql, sqlParam);
  335. }
  336. _splitExprByOrder(expr) {
  337. const orderParam = [...expr.matchAll(/f\d+/ig)];
  338. if (orderParam.length === 0) return [false, expr];
  339. const exprPart = [];
  340. for (const [i, op] of orderParam.entries()) {
  341. if (i === 0) {
  342. exprPart.push(expr.substring(0, op.index));
  343. } else {
  344. const preOp = orderParam[i-1];
  345. exprPart.push(expr.substring(preOp.index + preOp[0].length, op.index));
  346. }
  347. exprPart.push(op[0]);
  348. if (i === orderParam.length - 1) exprPart.push(expr.substring(op.index + op[0].length, expr.length));
  349. }
  350. return [true, exprPart];
  351. }
  352. _newExprAfterChangeOrder(expr, orderPart1, orderPart2) {
  353. if (!expr) return [false, expr];
  354. const [hasOrder, exprPart] = this._splitExprByOrder(expr);
  355. if (!hasOrder) return [false, expr];
  356. const newExprPart = [];
  357. let change = false;
  358. for (const ep of exprPart) {
  359. if (ep === orderPart1) {
  360. newExprPart.push(orderPart2);
  361. change = true;
  362. } else if (ep === orderPart2) {
  363. newExprPart.push(orderPart1);
  364. change = true;
  365. } else {
  366. newExprPart.push(ep);
  367. }
  368. }
  369. return [change, newExprPart.join('')];
  370. }
  371. /**
  372. * 交换两个合同支付项的顺序
  373. * @param {Number} id1 - 合同支付项1的id
  374. * @param {Number} id2 - 合同支付项1的id
  375. * @returns {Promise<void>}
  376. */
  377. async changeOrder(id1, id2) {
  378. if (!this.ctx.tender || !this.ctx.stage) throw '数据错误';
  379. const pay1 = await this.ctx.service.pay.getDataByCondition({tid: this.ctx.tender.id, id: id1});
  380. const pay2 = await this.ctx.service.pay.getDataByCondition({tid: this.ctx.tender.id, id: id2});
  381. if (!pay1 || !pay2) throw '数据错误';
  382. const stagePays = await this.getStagePays(this.ctx.stage);
  383. const conn = await this.db.beginTransaction();
  384. try {
  385. const orderPart1 = `f${pay1.order}`;
  386. const orderPart2 = `f${pay2.order}`;
  387. const updateData = [{id: pay1.id, order: pay2.order}, {id: pay2.id, order: pay1.order}];
  388. const updateStageData = [];
  389. for (const p of stagePays) {
  390. const [change, newExpr] = this._newExprAfterChangeOrder(p.expr, orderPart1, orderPart2);
  391. if (change) {
  392. updateStageData.push({ condition: { where: { sid: this.ctx.stage.id, pid: p.pid } }, update: { expr: newExpr } });
  393. }
  394. }
  395. await conn.updateRows(this.ctx.service.pay.tableName, updateData);
  396. for (const usd of updateStageData) {
  397. await conn.update(this.tableName, usd.update, usd.condition);
  398. }
  399. await conn.commit();
  400. return await this.getStagePays(this.ctx.stage);
  401. } catch (err) {
  402. await conn.rollback();
  403. throw err;
  404. }
  405. }
  406. _newExprAfterDelete(expr, orderParts) {
  407. if (!expr) return [false, expr];
  408. const [hasOrder, exprPart] = this._splitExprByOrder(expr);
  409. if (!hasOrder) return [false, expr];
  410. const newExprPart = [];
  411. let change = false;
  412. for (const ep of exprPart) {
  413. const orderPart = orderParts.find(x => {return x.orgOrder === ep; });
  414. if (orderPart) {
  415. change = true;
  416. newExprPart.push(orderPart.newOrder);
  417. } else {
  418. newExprPart.push(ep);
  419. }
  420. }
  421. return [change, newExprPart.join('')];
  422. }
  423. async del(id) {
  424. if (!this.ctx.tender || !this.ctx.stage) throw '数据错误';
  425. // 检查是否可以删除
  426. const pay = await this.ctx.service.pay.getDataByCondition({id: id});
  427. if (!pay) {
  428. throw '合同支付项不存在';
  429. } else if (pay.ptype !== payConst.payType.normal) {
  430. throw '该合同支付项不可删除';
  431. }
  432. const stagePays = await this.getStagePays(this.ctx.stage);
  433. const orderParts = [], updateStageData = [], updateData = [];
  434. for (const sp of stagePays) {
  435. if (sp.order === pay.order) {
  436. orderParts.push({ orgOrder: `f${sp.order}`, newOrder: '#ref!'});
  437. } else if (sp.order > pay.order) {
  438. orderParts.push({ orgOrder: `f${sp.order}`, newOrder: `f${sp.order-1}`});
  439. updateData.push({id: sp.pid, order: sp.order -1 });
  440. }
  441. }
  442. for (const sp of stagePays) {
  443. const [change, newExpr] = this._newExprAfterDelete(sp.expr, orderParts);
  444. if (change) {
  445. updateStageData.push({ condition: { where: { sid: this.ctx.stage.id, pid: sp.pid } }, update: { expr: newExpr } });
  446. }
  447. }
  448. // 删除合同支付
  449. const transaction = await this.db.beginTransaction();
  450. try {
  451. // 假删除
  452. const result = await transaction.update(this.ctx.service.pay.tableName, { id: id, valid: false });
  453. if (result.affectedRows !== 1) throw '删除合同支付项失败';
  454. if (updateData.length > 0) await transaction.updateRows(this.ctx.service.pay.tableName, updateData);
  455. for (const usd of updateStageData) {
  456. await transaction.update(this.tableName, usd.update, usd.condition);
  457. }
  458. await transaction.commit();
  459. return true;
  460. } catch(err) {
  461. await transaction.rollback();
  462. throw err;
  463. }
  464. }
  465. async cacheOrder(stage, transaction) {
  466. const sql = `UPDATE ${this.tableName} sp LEFT JOIN ${this.ctx.service.pay.tableName} p ON sp.pid = p.id SET sp.porder = p.\`order\` Where sp.sid = ?`;
  467. await transaction.query(sql, [stage.id]);
  468. }
  469. }
  470. return StagePay;
  471. };