stage_pos.js 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const measureType = require('../const/tender').measureType;
  10. const timesLen = require('../const/audit').stage.timesLen;
  11. module.exports = app => {
  12. class StagePos 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_pos';
  22. this.qtyFields = ['contract_qty', 'qc_qty']
  23. }
  24. _getPosFilterSql(where, asTable = '') {
  25. let whereSql = '';
  26. if (!where) return whereSql;
  27. if (where.pid) {
  28. if (where.pid instanceof Array) {
  29. whereSql += ' And ' + asTable + 'pid in (' + this.ctx.helper.getInArrStrSqlFilter(where.pid) + ')';
  30. } else if (typeof where.pid === "string") {
  31. whereSql += ' And ' + asTable + 'pid = ' + this.db.escape(where.pid);
  32. }
  33. }
  34. if (where.lid) {
  35. if (where.lid instanceof Array) {
  36. whereSql += ' And ' + asTable + 'lid in (' + this.ctx.helper.getInArrStrSqlFilter(where.lid) + ')';
  37. } else if (typeof where.pid === "string") {
  38. whereSql += ' And ' + asTable + 'lid = ' + this.db.escape(where.lid);
  39. }
  40. }
  41. return whereSql;
  42. }
  43. /**
  44. * 查询期计量最后审核人数据
  45. * @param {Number} tid - 标段id
  46. * @param {Number} sid - 期id
  47. * @param {Number|Array} pid - 部位明细id(可以为空)
  48. * @returns {Promise<*>}
  49. */
  50. async getLastestStageData(tid, sid, where) {
  51. const filterSql = this._getPosFilterSql(where);
  52. const sql = 'SELECT Pos.id, Pos.tid, Pos.sid, Pos.lid, Pos.pid, Pos.contract_qty, Pos.qc_qty, Pos.postil, Pos.times, Pos.order, Pos.contract_expr FROM ' +
  53. ' (SELECT * FROM ' + this.tableName + ' WHERE tid = ? And sid = ?) As Pos ' +
  54. ' INNER JOIN ( ' +
  55. ' SELECT MAX(`times` * ' + timesLen + ' + `order`) As `flow`, `tid`, `sid`, `pid` From ' + this.tableName +
  56. ' WHERE `tid` = ? And sid = ?' + filterSql +
  57. ' GROUP BY `pid`' +
  58. ' ) As MaxFilter ' +
  59. ' ON (Pos.times * ' + timesLen + ' + Pos.order) = MaxFilter.flow And Pos.pid = MaxFilter.pid And Pos.sid = MaxFilter.sid';
  60. const sqlParam = [tid, sid, tid, sid];
  61. return await this.db.query(sql, sqlParam);
  62. }
  63. /**
  64. * 查询 某期 某轮审批 某审核人数据
  65. * @param {Number} tid - 标段id
  66. * @param {Number} sid - 期id
  67. * @param {Number} times - 期第几轮审批
  68. * @param {Number} order - 审核人顺序
  69. * @param {Number|Array|Null} pid - 部位明细id - 为空则查询全部
  70. * @returns {Promise<*>}
  71. */
  72. async getAuditorStageData(tid, sid, times, order, where) {
  73. const filterSql = this._getPosFilterSql(where);
  74. const sql = 'SELECT Pos.id, Pos.tid, Pos.sid, Pos.pid, Pos.lid, Pos.contract_qty, Pos.qc_qty, Pos.postil, Pos.times, Pos.order, Pos.contract_expr FROM ' +
  75. ' (SELECT * FROM '+ this.tableName + ' WHERE tid = ? And sid = ?) As Pos ' +
  76. ' INNER JOIN ( ' +
  77. ' SELECT MAX(`times` * ' + timesLen + ' + `order`) As `flow`, `pid`, `sid` From ' + this.tableName +
  78. ' WHERE (`times` < ? OR (`times` = ? AND `order` <= ?)) And tid = ? And sid = ?' + filterSql +
  79. ' GROUP BY `pid`' +
  80. ' ) As MaxFilter ' +
  81. ' ON (Pos.times * ' + timesLen + ' + Pos.order) = MaxFilter.flow And Pos.pid = MaxFilter.pid And Pos.sid = MaxFilter.sid';
  82. const sqlParam = [tid, sid, times, times, order, tid, sid];
  83. return await this.db.query(sql, sqlParam);
  84. }
  85. async _filterLastestData(stagePos) {
  86. const stagePosIndex = {};
  87. for (const sp of stagePos) {
  88. const key = 'sp-' + sp.pid;
  89. const spi = stagePosIndex[key];
  90. if (spi) {
  91. if ((spi.times * timesLen + spi.order) < (sp.times * timesLen + sp.order)) stagePosIndex[key] = sp;
  92. } else {
  93. stagePosIndex[key] = sp;
  94. }
  95. }
  96. const result = [];
  97. for (const prop in stagePosIndex) {
  98. result.push(stagePosIndex[prop]);
  99. }
  100. return result;
  101. }
  102. async getLastestStageData2(tid, sid, where) {
  103. const filterSql = this._getPosFilterSql(where);
  104. const sql = 'SELECT id, tid, sid, pid, lid, contract_qty, qc_qty, postil, `times`, `order`, `contract_expr`' +
  105. ' FROM ' + this.tableName +
  106. ' WHERE tid = ? And sid = ? ' + filterSql;
  107. const sqlParam = [tid, sid];
  108. const stagePos = await this.db.query(sql, sqlParam);
  109. return this._filterLastestData(stagePos);
  110. }
  111. async getAuditorStageData2(tid, sid, times, order, where) {
  112. const filterSql = this._getPosFilterSql(where);
  113. const sql = 'SELECT id, tid, sid, pid, lid, contract_qty, qc_qty, postil, `times`, `order`, `contract_expr`' +
  114. ' FROM ' + this.tableName +
  115. ' WHERE tid = ? And sid = ? And (`times` < ? OR (`times` = ? AND `order` <= ?)) ' + filterSql;
  116. const sqlParam = [tid, sid, times, times, order];
  117. const stagePos = await this.db.query(sql, sqlParam);
  118. return this._filterLastestData(stagePos);
  119. }
  120. async getStageUsedPos(tid, sid, where) {
  121. const self = this;
  122. const stagePos = await this.getLastestStageData2(tid, sid, where);
  123. const pids = this._.map(stagePos, function (sp) {
  124. if (!self.ctx.helper.checkZero(sp.contract_qty) || !self.ctx.helper.checkZero(sp.qc_qty)) {
  125. return sp.pid;
  126. } else {
  127. return -1;
  128. }
  129. });
  130. return this._.pull(pids, -1);
  131. }
  132. /**
  133. * 新增部位明细数据(仅供updateStageData调用)
  134. *
  135. * @param transaction - 事务
  136. * @param data - 新增数据
  137. * @returns {Promise<{}>}
  138. * @private
  139. */
  140. async _addStagePosData(data) {
  141. let bills , precision, updateBills = null;
  142. const result = {pos: [], ledger: []};
  143. const datas = data instanceof Array ? data : [data], calcStageBills = [];
  144. if (datas[0].sgfh_qty !== undefined || datas[0].sjcl_qty !== undefined || datas[0].qtcl_qty !== undefined
  145. || datas[0].contract_qty !== undefined || datas[0].qc_qty !== undefined) {
  146. bills = await this.ctx.service.ledger.getDataById(datas[0].lid);
  147. precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, bills.unit);
  148. result.ledger.push(bills.id);
  149. }
  150. if (datas[0].contract_qty !== undefined || datas[0].qc_qty !== undefined || datas[0].postil !== undefined) {
  151. result.stageUpdate = true;
  152. }
  153. const insertPos = [], insertPosStage = [];
  154. for (const d of datas) {
  155. const p = {
  156. id: this.uuid.v4(), tid: this.ctx.tender.id, lid: d.lid, name: d.name, porder: d.porder, position: d.position,
  157. add_stage: this.ctx.stage.id,
  158. add_times: this.ctx.stage.curTimes,
  159. add_user: this.ctx.session.sessionUser.accountId,
  160. };
  161. if (d.sgfh_qty !== undefined || d.sjcl_qty !== undefined || d.qtcl_qty !== undefined) {
  162. if (d.sgfh_qty!== undefined) p.sgfh_qty = this.round(d.sgfh_qty, precision.value);
  163. if (d.sjcl_qty!== undefined) p.sjcl_qty = this.round(d.sjcl_qty, precision.value);
  164. if (d.qtcl_qty!== undefined) p.qtcl_qty = this.round(d.qtcl_qty, precision.value);
  165. if (d.sgfh_expr !== undefined) p.sgfh_expr = d.sgfh_expr;
  166. if (d.sjcl_expr !== undefined) p.sjcl_expr = d.sjcl_expr;
  167. if (d.qtcl_expr !== undefined) p.qtcl_expr = d.qtcl_expr;
  168. p.quantity = this.ctx.helper.sum([p.sgfh_qty, p.sjcl_qty, p.qtcl_qty]);
  169. if (!updateBills) updateBills = {id: bills.id, sgfh_qty: bills.sgfh_qty, sjcl_qty: bills.sjcl_qty, qtcl_qty: bills.qtcl_qty};
  170. }
  171. insertPos.push(p);
  172. result.pos.push(p.id);
  173. if (d.contract_qty!== undefined || d.qc_qty!== undefined || d.postil!== undefined) {
  174. const ps = {
  175. pid: p.id,
  176. lid: d.lid,
  177. tid: this.ctx.tender.id,
  178. sid: this.ctx.stage.id,
  179. said: this.ctx.session.sessionUser.accountId,
  180. times: this.ctx.stage.curTimes,
  181. order: this.ctx.stage.curOrder,
  182. };
  183. if (d.contract_qty !== undefined) ps.contract_qty = this.round(d.contract_qty, precision.value);
  184. if (d.contract_expr !== undefined) p.contract_expr = d.contract_expr;
  185. if (d.qc_qty!== undefined) ps.qc_qty = this.round(d.qc_qty, precision.value);
  186. if (d.postil!== undefined) ps.postil = d.postil;
  187. insertPosStage.push(ps);
  188. if ((d.contract_qty || d.qc_qty) && calcStageBills.indexOf(ps.lid) === -1) {
  189. calcStageBills.push(ps.lid);
  190. }
  191. }
  192. }
  193. if (updateBills) {
  194. for (const d of insertPos) {
  195. if (d.sgfh_qty) {
  196. d.sgfh_qty = this.ctx.helper.round(d.sgfh_qty, precision.value);
  197. updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, d.sgfh_qty);
  198. }
  199. if (d.sjcl_qty) {
  200. d.sjcl_qty = this.ctx.helper.round(d.sjcl_qty, precision.value);
  201. updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, d.sjcl_qty);
  202. }
  203. if (d.qtcl_qty) {
  204. d.qtcl_qty = this.ctx.helper.round(d.qtcl_qty, precision.value);
  205. updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, d.qtcl_qty);
  206. }
  207. d.quantity = this.ctx.helper.sum([d.sgfh_qty, d.qtcl_qty, d.sjcl_qty]);
  208. }
  209. updateBills.quantity = this.ctx.helper.sum([updateBills.sgfh_qty, updateBills.qtcl_qty, updateBills.sjcl_qty]);
  210. const info = this.ctx.tender.info;
  211. updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
  212. updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
  213. updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
  214. updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
  215. }
  216. const transaction = await this.db.beginTransaction();
  217. try {
  218. if (insertPos.length > 0) await transaction.insert(this.ctx.service.pos.tableName, insertPos);
  219. if (updateBills) await transaction.update(this.ctx.service.ledger.tableName, updateBills);
  220. if (insertPosStage.length > 0) await transaction.insert(this.tableName, insertPosStage);
  221. for (const lid of calcStageBills) {
  222. await this.ctx.service.stageBills.calc(this.ctx.tender.id, this.ctx.stage.id, lid, transaction);
  223. }
  224. await transaction.commit();
  225. return result;
  226. } catch(err) {
  227. await transaction.rollback();
  228. throw err;
  229. }
  230. }
  231. /**
  232. * 更新部位明细数据(仅供updateStageData调用)
  233. *
  234. * @param transaction - 事务
  235. * @param data - 更新数据(允许一次性提交多条)
  236. * @returns {Promise<{ledger: Array, pos: Array}>}
  237. * @private
  238. */
  239. async _updateStagePosData(data) {
  240. let bills, precision, updateBills = null;
  241. const datas = data instanceof Array ? data : [data];
  242. const orgPos = await this.ctx.service.pos.getPosDataByIds(this._.map(datas, 'pid'));
  243. const result = {ledger: [], pos: [], stageUpdate: true};
  244. const orgStagePos = await this.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id,
  245. {pid: this._.map(datas, 'pid')});
  246. if (datas[0].sgfh_qty !== undefined || datas[0].qtcl_qty !== undefined || datas[0].sjcl_qty !== undefined
  247. || datas[0].contract_qty !== undefined || datas[0].qc_qty !== undefined) {
  248. bills = await this.ctx.service.ledger.getDataById(datas[0].lid);
  249. precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, bills.unit);
  250. result.ledger.push(bills.id);
  251. }
  252. const updatePos = [], updatePosStage = [], insertPosStage = [];
  253. for (const d of datas) {
  254. if (d.name !== undefined || d.drawing_code !== undefined || d.position !== undefined
  255. || d.sgfh_qty !== undefined || d.qtcl_qty !== undefined || d.sjcl_qty !== undefined) {
  256. const op = this._.find(orgPos, {id: d.pid});
  257. if (op.add_stage !== this.ctx.stage.id) throw '不可修改数据';
  258. const p = {id: op.id};
  259. if (d.name !== undefined) p.name = d.name;
  260. if (d.position !== undefined) p.position = d.position;
  261. if (d.sgfh_qty !== undefined || d.qtcl_qty !== undefined || d.sjcl_qty !== undefined) {
  262. p.sgfh_qty = d.sgfh_qty !== undefined ? d.sgfh_qty : op.sgfh_qty;
  263. p.sjcl_qty = d.sjcl_qty !== undefined ? d.sjcl_qty : op.sjcl_qty;
  264. p.qtcl_qty = d.qtcl_qty !== undefined ? d.qtcl_qty : op.qtcl_qty;
  265. if (d.sgfh_expr !== undefined) p.sgfh_expr = d.sgfh_expr;
  266. if (d.sjcl_expr !== undefined) p.sjcl_expr = d.sjcl_expr;
  267. if (d.qtcl_expr !== undefined) p.qtcl_expr = d.qtcl_expr;
  268. p.quantity = this.ctx.helper.sum([p.sgfh_qty, p.sjcl_qty, p.qtcl_qty]);
  269. if (!updateBills) updateBills = {id: bills.id};
  270. }
  271. if (d.drawing_code !== undefined) p.drawing_code = d.drawing_code;
  272. updatePos.push(p);
  273. }
  274. if (d.contract_qty !== undefined || d.qc_qty !== undefined || d.postil !== undefined) {
  275. const osp = this._.find(orgStagePos, function (p) { return p.pid === d.pid; });
  276. if (osp && osp.times === this.ctx.stage.curTimes && osp.order === this.ctx.stage.curOrder) {
  277. const sp = {id: osp.id};
  278. if (d.contract_qty !== undefined) {
  279. sp.contract_qty = this.ctx.helper.round(d.contract_qty, precision.value);
  280. }
  281. if (d.contract_expr !== undefined) sp.contract_expr = d.contract_expr;
  282. if (d.qc_qty !== undefined) {
  283. sp.qc_qty = this.ctx.helper.round(d.qc_qty, precision.value);
  284. }
  285. if (d.postil !== undefined) {
  286. sp.postil = d.postil;
  287. }
  288. updatePosStage.push(sp);
  289. } else {
  290. const sp = {
  291. pid: d.pid, lid: d.lid,
  292. tid: this.ctx.tender.id, sid: this.ctx.stage.id,
  293. said: this.ctx.session.sessionUser.accountId,
  294. times: this.ctx.stage.curTimes, order: this.ctx.stage.curOrder
  295. };
  296. if (d.contract_qty !== undefined || osp) {
  297. sp.contract_qty = d.contract_qty === undefined && osp
  298. ? osp.contract_qty
  299. : this.ctx.helper.round(d.contract_qty, precision.value);
  300. }
  301. if (d.contract_expr !== undefined) sp.contract_expr = d.contract_expr;
  302. if (d.qc_qty || osp) {
  303. sp.qc_qty = d.qc_qty === undefined && osp
  304. ? osp.qc_qty
  305. : this.ctx.helper.round(d.qc_qty, precision.value);
  306. }
  307. if (d.postil || osp) {
  308. sp.postil = d.postil === undefined && osp ? osp.postil : d.postil;
  309. }
  310. insertPosStage.push(sp);
  311. }
  312. }
  313. result.pos.push(d.pid);
  314. }
  315. if (updateBills) {
  316. const billsPos = await this.ctx.service.pos.getAllDataByCondition({where: {tid: bills.tender_id, lid: bills.id} });
  317. for (const bp of billsPos) {
  318. const newPos = updatePos.find(function (x) { return x.id === bp.id });
  319. const calcData = newPos ? newPos : bp;
  320. updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, calcData.sgfh_qty);
  321. updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, calcData.sjcl_qty);
  322. updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, calcData.qtcl_qty);
  323. updateBills.quantity = this.ctx.helper.add(updateBills.quantity, calcData.quantity);
  324. }
  325. const info = this.ctx.tender.info;
  326. updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
  327. updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
  328. updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
  329. updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
  330. }
  331. const transaction = await this.db.beginTransaction();
  332. try {
  333. if (updatePos.length > 0) {
  334. await transaction.updateRows(this.ctx.service.pos.tableName, updatePos);
  335. }
  336. if (updateBills) {
  337. await transaction.update(this.ctx.service.ledger.tableName, updateBills);
  338. }
  339. if (updatePosStage.length > 0) {
  340. await transaction.updateRows(this.tableName, updatePosStage);
  341. }
  342. if (insertPosStage.length > 0) {
  343. await transaction.insert(this.tableName, insertPosStage);
  344. }
  345. for (const lid of result.ledger) {
  346. await this.ctx.service.stageBills.calc(this.ctx.tender.id, this.ctx.stage.id, lid, transaction);
  347. }
  348. await transaction.commit();
  349. return result;
  350. } catch (err) {
  351. await transaction.rollback();
  352. throw err;
  353. }
  354. }
  355. /**
  356. * 删除部位明细数据(仅供updateStageData调用)
  357. *
  358. * @param transaction - 事务
  359. * @param data - 删除的部位明细(允许一次提醒多条,也允许跨清单(但前端操作不允许))
  360. * @returns {Promise<{}>}
  361. * @private
  362. */
  363. async _deleteStagePosData(data) {
  364. const pos = await this.ctx.service.pos.getPosData({tid: this.ctx.tender.id, id: data});
  365. const result = { pos: data, isDeletePos: true};
  366. if (pos instanceof Array) {
  367. for (const p of pos) {
  368. if (p.add_stage !== this.ctx.stage.id /*|| p.add_times !== this.ctx.stage.curTimes || p.add_user !== this.ctx.session.sessionUser.accountId*/) {
  369. throw '不可删除该数据';
  370. }
  371. if (p.lid !== pos[0].lid) {
  372. throw '提交数据错误';
  373. }
  374. }
  375. } else if (pos.add_stage !== this.ctx.stage.id /*|| pos.add_times !== this.ctx.stage.curTimes || pos.add_user !== this.ctx.session.sessionUser.accountId*/) {
  376. throw '不可删除该数据';
  377. }
  378. const bills = await this.ctx.service.ledger.getDataById(pos[0].lid);
  379. const billsPos = await this.ctx.service.pos.getAllDataByCondition({ where: {tid: bills.tender_id, lid: bills.id} });
  380. const updateBills = {id: bills.id, sgfh_qty: null, sjcl_qty: null, qtcl_qty: null, quantity: null};
  381. for (const bp of billsPos) {
  382. if (data.indexOf(bp.id) >= 0) continue;
  383. updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, bp.sgfh_qty);
  384. updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, bp.sjcl_qty);
  385. updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, bp.qtcl_qty);
  386. updateBills.quantity = this.ctx.helper.add(updateBills.quantity, bp.quantity);
  387. }
  388. const info = this.ctx.tender.info;
  389. updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
  390. updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
  391. updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
  392. updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
  393. const transaction = await this.db.beginTransaction();
  394. try {
  395. // 删除部位明细
  396. await transaction.delete(this.ctx.service.pos.tableName, {tid: this.ctx.tender.id, id: data});
  397. await transaction.update(this.ctx.service.ledger.tableName, updateBills);
  398. // 删除部位明细计量数据
  399. await transaction.delete(this.tableName, {tid: this.ctx.tender.id, lid: data});
  400. await this.ctx.service.stageBills.calc(this.ctx.tender.id, this.ctx.stage.id, bills.id, transaction);
  401. await transaction.commit();
  402. // 获取需要更新的数据
  403. result.ledger = [bills.id];
  404. result.stageUpdate = true;
  405. return result;
  406. } catch (err) {
  407. await transaction.rollback();
  408. throw err;
  409. }
  410. }
  411. /**
  412. * 根据前端提交数据,更新并计算
  413. *
  414. * @param data
  415. * @returns {Promise<{ledger: {}, pos: {}}>}
  416. */
  417. async updateStageData(data) {
  418. if ((data.updateType === 'add' || data.upateType === 'delete') && this.ctx.tender.measure_type === measureType.tz) {
  419. throw '台账模式下,不可在计量中新增或删除部位明细,如需操作,请进行台账修订';
  420. }
  421. let refreshData;
  422. if (data.updateType === 'add') {
  423. refreshData = await this._addStagePosData(data.updateData);
  424. } else if (data.updateType === 'update') {
  425. refreshData = await this._updateStagePosData(data.updateData);
  426. } else if (data.updateType === 'delete') {
  427. if (!data.updateData || data.updateData.length === 0) {
  428. throw '提交数据错误';
  429. }
  430. refreshData = await this._deleteStagePosData(data.updateData);
  431. } else {
  432. throw '提交数据错误';
  433. }
  434. try {
  435. const result = {ledger: {}, pos: {}};
  436. if (refreshData.ledger && refreshData.ledger.length > 0) {
  437. result.ledger.bills = await this.ctx.service.ledger.getDataByIds(refreshData.ledger);
  438. if (refreshData.stageUpdate) {
  439. result.ledger.curStageData = await this.ctx.service.stageBills.getLastestStageData(this.ctx.tender.id, this.ctx.stage.id, refreshData.ledger);
  440. }
  441. }
  442. if (refreshData.pos) {
  443. if (refreshData.isDeletePos) {
  444. result.pos.pos = refreshData.pos;
  445. } else if (refreshData.pos.length > 0) {
  446. result.pos.pos = await this.ctx.service.pos.getPosDataWithAddStageOrder({id: refreshData.pos});
  447. if (refreshData.stageUpdate) {
  448. result.pos.curStageData = await this.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id, {pid: refreshData.pos});
  449. }
  450. }
  451. }
  452. return result;
  453. } catch(err) {
  454. throw '获取数据异常,请刷新页面。';
  455. }
  456. }
  457. async updateChangeQuantity(transaction, pos, qty) {
  458. let orgPos = await this.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id, {pid: pos.id});
  459. if (orgPos.length > 1) {
  460. throw '数据错误';
  461. } else {
  462. orgPos = orgPos[0];
  463. }
  464. if (orgPos && orgPos.times === this.ctx.stage.curTimes && orgPos.order === this.ctx.stage.curOrder) {
  465. await transaction.update(this.tableName, {id: orgPos.id, qc_qty: qty});
  466. } else {
  467. await transaction.insert(this.tableName, {
  468. tid: this.ctx.tender.id,
  469. sid: this.ctx.stage.id,
  470. lid: pos.lid,
  471. pid: pos.id,
  472. said: this.ctx.session.sessionUser.accountId,
  473. times: this.ctx.stage.curTimes,
  474. order: this.ctx.stage.curOrder,
  475. contract_qty: orgPos ? orgPos.contract_qty : 0,
  476. qc_qty: qty,
  477. });
  478. }
  479. await this.ctx.service.stageBills.calc(this.ctx.tender.id, this.ctx.stage.id, pos.lid, transaction);
  480. }
  481. /**
  482. * 统计清单下部位明细合计
  483. * @param {Number} tid - 标段id
  484. * @param {Number} sid - 期id
  485. * @param {Number} lid - 清单节点id
  486. * @param transaction - 事务(不为空则在事务中查询,反之在数据库中查询)
  487. * @returns {Promise<*>}
  488. */
  489. async getPosGather(tid, sid, lid, transaction) {
  490. const calcQtySql = 'SELECT SUM(`contract_qty`) As `contract_qty`, SUM(`qc_qty`) As `qc_qty` FROM (' +
  491. ' SELECT `contract_qty`, `qc_qty` FROM ' + this.ctx.service.stagePos.tableName + ' As Pos ' +
  492. ' INNER JOIN (' +
  493. ' SELECT MAX(`times` * ' + timesLen + ' + `order`) As `flow`, `pid` ' +
  494. ' FROM ' + this.ctx.service.stagePos.tableName +
  495. ' WHERE `tid` = ? And sid = ? And `lid` = ? ' +
  496. ' GROUP BY `pid`' +
  497. ' ) As MaxFilter ' +
  498. ' ON (Pos.times * ' + timesLen + ' + Pos.order) = MaxFilter.flow And Pos.pid = MaxFilter.pid ' +
  499. ' WHERE Pos.tid = ? And Pos.sid = ? And Pos.lid = ?' +
  500. ' ) As Gather';
  501. const param = [tid, sid, lid];
  502. const sqlParam = param.concat(param);
  503. if (transaction) {
  504. return await transaction.queryOne(calcQtySql, sqlParam);
  505. } else {
  506. return await this.db.queryOne(calcQtySql, sqlParam);
  507. }
  508. }
  509. /**
  510. * 多期清单数据整合 (材料调差调用)
  511. * @param {Number} tid - 标段id
  512. * @param {String} stage_id_list - 期id列表
  513. * @returns {Promise<void>}
  514. */
  515. async getStagesData(tid, stage_id_list) {
  516. let stage_id_listSql = '';
  517. stage_id_list = stage_id_list.indexOf(',') !== -1 ? stage_id_list.split(',') : stage_id_list;
  518. if (stage_id_list) {
  519. if (stage_id_list instanceof Array) {
  520. stage_id_listSql = stage_id_list.length > 0 ? ' And sid in (' + this.ctx.helper.getInArrStrSqlFilter(stage_id_list) + ')' : '';
  521. } else {
  522. stage_id_listSql = ' And sid in (' + this.db.escape(stage_id_list) + ')';
  523. }
  524. }
  525. const sql = 'SELECT `id`, `tid`, `sid`, `pid`, `lid`, SUM(`contract_qty`) as `contract_qty`, SUM(`qc_qty`) as `qc_qty`' +
  526. ' FROM ' + this.tableName + ' WHERE `tid` = ? ' +
  527. stage_id_listSql + 'GROUP BY `pid`';
  528. const sqlParam = [tid];
  529. const result = await this.db.query(sql, sqlParam);
  530. return result;
  531. }
  532. /**
  533. * 获取多期(合同和数量变更相加)计量-小计(材料调差调用)
  534. * @param {Number} tid - 标段id
  535. * @param {String} stage_id_list - 期id列表
  536. * @param {String} lid - 台账id
  537. * @param {String} pid - 部位id
  538. * @returns {Promise<void>}
  539. */
  540. async getGatherQtyByMaterial(tid, stage_id_list, lid, pid) {
  541. stage_id_list = stage_id_list !== null ? stage_id_list.split(',') : [];
  542. let gather_qty = 0;
  543. for (const sid of stage_id_list) {
  544. const sql = 'SELECT Pos.contract_qty, Pos.qc_qty FROM ' +
  545. ' (SELECT * FROM ' + this.tableName + ' WHERE tid = ? AND sid = ?) As Pos ' +
  546. ' INNER JOIN ( ' +
  547. ' SELECT MAX(`times` * ' + timesLen + ' + `order`) As `flow`, `tid`, `sid`, `pid` From ' + this.tableName +
  548. ' WHERE `tid` = ? AND sid = ?' +
  549. ' GROUP BY `pid`' +
  550. ' ) As MaxFilter ' +
  551. ' ON (Pos.times * ' + timesLen + ' + Pos.order) = MaxFilter.flow And Pos.pid = MaxFilter.pid And Pos.sid = MaxFilter.sid' +
  552. ' WHERE Pos.lid = ? AND Pos.pid = ?';
  553. const sqlParam = [tid, sid, tid, sid, lid, pid];
  554. const result = await this.db.queryOne(sql, sqlParam);
  555. if (result) {
  556. gather_qty = this.ctx.helper.add(gather_qty, this.ctx.helper.add(result.contract_qty, result.qc_qty));
  557. }
  558. }
  559. return gather_qty !== 0 ? gather_qty : null;
  560. }
  561. }
  562. return StagePos;
  563. };