stage_pay.js 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306
  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. module.exports = app => {
  12. class StagePay extends app.BaseService {
  13. /**
  14. * 构造函数
  15. *
  16. * @param {Object} ctx - egg全局变量
  17. * @return {void}
  18. */
  19. constructor(ctx) {
  20. super(ctx);
  21. this.tableName = 'stage_pay';
  22. }
  23. /**
  24. * 查询 某期 某轮审批 某审核人数据
  25. *
  26. * @param {Number} pid - 合同支付id
  27. * @param {Number} sid - 期id
  28. * @param {Number} times - 期第几轮审批
  29. * @param {Number} order - 审核人顺序
  30. * @param {Number|Array|Null} pid - 部位明细id - 为空则查询全部
  31. * @returns {Promise<*>}
  32. */
  33. async getAuditorStagePay(pid, sid, times, order) {
  34. const pidSql = pid instanceof Array ? ' And SP.`pid` in (' + pid.join(',') + ')' : 'And SP.`pid` = ' + pid;
  35. 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 ' +
  36. ' FROM ?? As SP, ?? As P ' +
  37. ' WHERE SP.`sid` = ? AND SP.`stimes` = ? AND SP.`sorder` = ? AND SP.`pid` = P.`id` AND P.`valid`' + pidSql +
  38. ' ORDER BY P.`order`';
  39. const sqlParam = [this.tableName, this.ctx.service.pay.tableName, sid, times, order, pid];
  40. if (pid instanceof Array) {
  41. return await this.db.query(sql, sqlParam);
  42. } else {
  43. return await this.db.queryOne(sql, sqlParam);
  44. }
  45. }
  46. /**
  47. * 查询 某期 某轮审批 某审核人数据
  48. * @param {Number} sid - 期id
  49. * @param {Number} times - 期第几轮审批
  50. * @param {Number} order - 审核人顺序
  51. * @param {Number|Array|Null} pid - 部位明细id - 为空则查询全部
  52. * @returns {Promise<*>}
  53. */
  54. async getAuditorStageData(sid, times, order) {
  55. const sql = 'SELECT SP.*,' +
  56. ' 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, P.name as pName ' +
  57. ' FROM ?? As SP, ?? As P ' +
  58. ' WHERE SP.`sid` = ? AND SP.`stimes` = ? AND SP.`sorder` = ? AND SP.`pid` = P.`id` AND P.`valid`' +
  59. ' ORDER BY P.`order`';
  60. const sqlParam = [this.tableName, this.ctx.service.pay.tableName, sid, times, order];
  61. return await this.db.query(sql, sqlParam);
  62. }
  63. /**
  64. * 新增期时,初始化 期--合同支付 数据
  65. * @param {Object} stage - 新增的期
  66. * @param transaction - 事务
  67. * @returns {Promise<void>}
  68. */
  69. async addInitialStageData(stage, transaction) {
  70. if (!stage) {
  71. throw '初始化期合同支付数据失败';
  72. }
  73. let pays = await this.ctx.service.pay.getAllDataByCondition({where: { tid: this.ctx.tender.id } });
  74. // 兼容旧项目,无初始化合同支付数据
  75. if (!pays || pays.length === 0) {
  76. const result = await this.ctx.service.pay.addDefaultPayData(this.ctx.tender.id, transaction);
  77. if (!result) {
  78. throw '初始化合同支付数据失败';
  79. }
  80. pays = await transaction.select(this.ctx.service.pay.tableName, {where: { tid: this.ctx.tender.id } });
  81. }
  82. const stagePays = [];
  83. // 获取截止上期数据
  84. if (stage.order > 1) {
  85. const preStage = await this.ctx.service.stage.getDataByCondition({tid: stage.tid, order: stage.order - 1});
  86. if (!preStage) {
  87. throw '标段数据有误';
  88. }
  89. const prePays = await this.getStageLastestPays(preStage.id);
  90. for (const pp of prePays) {
  91. const p = this._.find(pays, {id: pp.pid});
  92. stagePays.push({
  93. tid: p.tid, sid: stage.id, pid: p.id,
  94. stimes: stage.times, sorder: 0,
  95. name: pp.name, expr: pp.expr, pause: pp.pause,
  96. pre_tp: pp.end_tp,
  97. pre_used: pp.pre_used || !this.ctx.helper.checkZero(pp.tp),
  98. pre_finish: pp.pre_finish || (pp.rprice ? pp.end_tp === pp.rprice : false),
  99. });
  100. }
  101. } else {
  102. for (const p of pays) {
  103. stagePays.push({
  104. tid: p.tid, sid: stage.id, pid: p.id,
  105. stimes: stage.times, sorder: 0, expr: p.expr, name: p.name,
  106. });
  107. }
  108. }
  109. let result;
  110. if (transaction) {
  111. result = await transaction.insert(this.tableName, stagePays);
  112. } else {
  113. result = await this.db.insert(this.tableName, stagePays);
  114. }
  115. return result.affectedRows === stagePays.length;
  116. }
  117. async getStagePay(stage, pid) {
  118. return await this.getAuditorStagePay(pid, stage.id, stage.curTimes, stage.curOrder);
  119. }
  120. /**
  121. * 获取某期合同支付数据
  122. *
  123. * @param {Object} stage - 期数据(通过StageController._getStageData()获取)
  124. * @returns {Promise<*>}
  125. */
  126. async getStagePays(stage) {
  127. return await this.getAuditorStageData(stage.id, stage.curTimes, stage.curOrder);
  128. }
  129. /**
  130. * 获取某期最后数据(不限制该期是否已经审批通过)
  131. *
  132. * @param {Number} sid - 期id
  133. * @returns {Promise<*>}
  134. */
  135. async getStageLastestPays(sid) {
  136. 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 ' +
  137. ' FROM ' + this.tableName + ' As SP' +
  138. ' INNER JOIN ' + this.ctx.service.pay.tableName + ' As P ON SP.pid = P.id' +
  139. ' INNER JOIN ( ' +
  140. ' SELECT MAX(`stimes` * ' + timesLen + ' + `sorder`) As `sprogress` ' +
  141. ' FROM ' + this.tableName +
  142. ' WHERE `sid` = ? ' +
  143. ' GROUP BY `sid`) As M ON (SP.`stimes` * ' + timesLen + ' + SP.`sorder`) = M.`sprogress`' +
  144. ' WHERE SP.`sid` = ? AND P.`valid` = true' +
  145. ' ORDER BY P.`order`';
  146. const sqlParam = [sid, sid];
  147. return await this.db.query(sql, sqlParam);
  148. }
  149. /**
  150. * 同步新增 (仅供合同支付新增时调用)
  151. * @param {Object} pay - 合同支付项数据
  152. * @param transaction - 新增合同支付的事务
  153. * @returns {Promise<{tid, sid: number|*, pid, stimes: number|*, sorder: number|*}>}
  154. */
  155. async syncAdd(pay, transaction) {
  156. const stagePay = {
  157. tid: pay.tid,
  158. sid: pay.csid,
  159. pid: pay.id,
  160. stimes: pay.cstimes,
  161. sorder: pay.csaorder,
  162. };
  163. const result = await transaction.insert(this.tableName, stagePay);
  164. if (result.affectedRows !== 1) {
  165. throw '新增数据失败';
  166. }
  167. stagePay.id = result.insertId;
  168. return stagePay;
  169. }
  170. /**
  171. * 保存本期金额/表达式
  172. * @param data
  173. * @returns {Promise<void>}
  174. */
  175. async save(saveData) {
  176. const datas = saveData instanceof Array ? saveData : [saveData], updateDatas = [];
  177. const stagePays = await this.getStagePay(this.ctx.stage, this._.map(datas, 'pid'));
  178. for (const data of datas) {
  179. const stagePay = stagePays.find(function (x) {
  180. return x.pid === data.pid;
  181. });
  182. const updateData = {id: stagePay.id};
  183. if (data.name !== undefined) { updateData.name = data.name }
  184. if (data.expr !== undefined) { updateData.expr = data.expr }
  185. if (data.tp !== undefined) { updateData.tp = data.tp }
  186. if (data.pause !== undefined) { updateData.pause = data.pause }
  187. updateDatas.push(updateData);
  188. }
  189. const result = await this.db.updateRows(this.tableName, updateDatas);
  190. if (result.affectedRows !== updateDatas.length) {
  191. throw '保存数据失败';
  192. }
  193. }
  194. /**
  195. * 计算
  196. * @param stage
  197. * @param transaction
  198. * @returns {Promise<boolean>}
  199. */
  200. async calcAllStagePays(stage, transaction) {
  201. if (!stage || !transaction) {
  202. throw '计算数据错误';
  203. }
  204. const stagePays = await this.getStagePays(stage);
  205. const PayCalculator = require('../lib/pay_calc');
  206. const payCalculator = new PayCalculator(this.ctx, stage, this.ctx.tender.info);
  207. await payCalculator.calculateAll(stagePays);
  208. const srUpdate = [], update = [];
  209. for (const sp of stagePays) {
  210. update.push({
  211. id: sp.id,
  212. tp: sp.tp,
  213. end_tp: sp.end_tp,
  214. });
  215. if (stage.order === 1 || sp.csorder >= stage.order) {
  216. srUpdate.push({
  217. id: sp.pid,
  218. sprice: sp.sprice,
  219. rprice: sp.rprice,
  220. });
  221. }
  222. }
  223. await transaction.updateRows(this.tableName, update);
  224. if (srUpdate.length > 0) {
  225. await transaction.updateRows(this.ctx.service.pay.tableName, srUpdate);
  226. }
  227. const yf = this._.find(stagePays, {ptype: payConst.payType.yf});
  228. return yf;
  229. }
  230. async getYfTotalPrice(stage) {
  231. if (!stage) throw '计算数据错误';
  232. const stagePays = await this.getStagePays(stage);
  233. const PayCalculator = require('../lib/pay_calc');
  234. const tenderInfo = await this.ctx.service.tenderInfo.getTenderInfo(stage.tid);
  235. const payCalculator = new PayCalculator(this.ctx, stage, tenderInfo);
  236. await payCalculator.calculateAll(stagePays);
  237. const yf = this._.find(stagePays, {ptype: payConst.payType.yf});
  238. return yf ? yf.tp : 0;
  239. }
  240. /**
  241. * 拷贝上一操作人数据 为 下一操作人数据
  242. * @param stage - 期数据
  243. * @param times - 下一操作人 该期第几次
  244. * @param order - 下一操作人顺序
  245. * @param transaction - 事务
  246. * @returns {Promise<*>}
  247. */
  248. async copyAuditStagePays(stage, times, order, transaction) {
  249. if (!stage || !transaction || !times || order === undefined) {
  250. throw '数据错误';
  251. }
  252. const sql = 'INSERT INTO ?? (`tid`, `sid`, `pid`, `stimes`, `sorder`, `name`, `tp`, `expr`, `pause`, `attachment`, `pre_tp`) ' +
  253. ' SELECT SP.`tid`, SP.`sid`, SP.`pid`, ?, ?, SP.name, SP.`tp`, SP.`expr`, SP.`pause`, SP.`attachment`, SP.`pre_tp` ' +
  254. ' FROM ?? As SP, ?? As P ' +
  255. ' WHERE SP.`sid` = ? AND SP.`stimes` = ? AND SP.`sorder` = ? And SP.`pid` = P.`id` And P.`valid`';
  256. const sqlParam = [this.tableName, times, order, this.tableName, this.ctx.service.pay.tableName,
  257. stage.id, stage.curTimes, stage.curOrder];
  258. return await transaction.query(sql, sqlParam);
  259. }
  260. /**
  261. * 保存附件
  262. * @param data
  263. * @returns {Promise<void>}
  264. */
  265. async saveAtt(id, att) {
  266. // 获取attachment
  267. const info = await this.getDataById(id);
  268. let attachment = null;
  269. if (info.attachment !== null && JSON.parse(info.attachment).length !== 0) {
  270. attachment = JSON.parse(info.attachment);
  271. attachment.unshift(att);
  272. } else {
  273. attachment = new Array(att);
  274. }
  275. const result = await this.db.update(this.tableName, { id, attachment: JSON.stringify(attachment) });
  276. return result.affectedRows === 1;
  277. }
  278. /**
  279. * 删除附件
  280. * @param data
  281. * @returns {Promise<void>}
  282. */
  283. async deleteAtt(id, attachment) {
  284. const result = await this.db.update(this.tableName, { id, attachment: JSON.stringify(attachment) });
  285. return result.affectedRows === 1;
  286. }
  287. }
  288. return StagePay;
  289. };