report_memory.js 75 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const _ = require('lodash');
  10. const StageIm = require('../lib/stage_im');
  11. const imType = require('../const/tender').imType;
  12. const audit = require('../const/audit');
  13. const changeConst = require('../const/change');
  14. // const path = require('path');
  15. // const fs = require('fs');
  16. const stageImTz = 'mem_stage_im_tz';
  17. const stageImTzBills = 'mem_stage_im_tz_bills';
  18. const stageImZl = 'mem_stage_im_zl';
  19. const stageImVersion = '1.3';
  20. const PermissionCheck = require('../const/account_permission').PermissionCheck;
  21. const Ledger = require('../lib/ledger');
  22. const moment = require('moment');
  23. const auditConst = require('../const/audit');
  24. const billsFields = (function () {
  25. const cur = ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp', 'qc_minus_qty', 'qc_minus_tp', 'gather_qty', 'gather_tp', 'postil'];
  26. const pre = ['pre_contract_qty', 'pre_contract_tp', 'pre_qc_qty', 'pre_qc_tp', 'pre_qc_minus_qty', 'pre_qc_minus_tp', 'pre_gather_qty', 'pre_gather_tp'];
  27. const end = ['end_contract_qty', 'end_contract_tp', 'end_qc_qty', 'end_qc_tp', 'end_qc_minus_qty', 'end_qc_minus_tp', 'end_gather_qty', 'end_gather_tp'];
  28. const year = ['year_contract_qty', 'year_contract_tp', 'year_qc_qty', 'year_qc_tp', 'year_qc_minus_qty', 'year_qc_minus_tp', 'year_gather_qty', 'year_gather_tp'];
  29. const final = ['final_tp', 'final_ratio'];
  30. const final1 = [ 'final_1_qty', 'final_1_tp', 'final_1_ratio'];
  31. const stageDgn = ['deal_dgn_qty1', 'deal_dgn_qty2', 'c_dgn_qty1', 'c_dgn_qty2'];
  32. const stage = cur.concat(pre, end, final);
  33. const stageEnd = pre.concat(end, final);
  34. const bgl = ['qc_bgl_code', 'pre_qc_bgl_code', 'end_qc_bgl_code'];
  35. const endBgl = ['pre_qc_bgl_code', 'end_qc_bgl_code'];
  36. const leafXmj = ['leaf_xmj_id'];
  37. return {cur, pre, end, final, final1, stageDgn, stage, stageEnd, bgl, leafXmj, endBgl};
  38. })();
  39. const posFields = (function () {
  40. const cur = ['contract_qty', 'qc_qty', 'qc_minus_qty', 'gather_qty', 'postil'];
  41. const pre = ['pre_contract_qty', 'pre_qc_qty', 'pre_qc_minus_qty', 'pre_gather_qty'];
  42. const end = ['end_contract_qty', 'end_qc_qty', 'end_qc_minus_qty', 'end_gather_qty'];
  43. const final = ['final_ratio'];
  44. const final1 = ['final_1_qty', 'final_1_ratio'];
  45. const stage = cur.concat(pre, end, final);
  46. const stageEnd = pre.concat(end, final);
  47. const bgl = ['qc_bgl_code'];
  48. return {cur, pre, end, final, final1, stage, stageEnd, bgl};
  49. })();
  50. module.exports = app => {
  51. class ReportMemory extends app.BaseService {
  52. /**
  53. * 构造函数
  54. *
  55. * @param {Object} ctx - egg全局context
  56. * @return {void}
  57. */
  58. constructor(ctx) {
  59. super(ctx);
  60. const self = this;
  61. // 基础数据类
  62. // mainData
  63. this.pos = new Ledger.pos({
  64. id: 'id', ledgerId: 'lid',
  65. updateFields: ['contract_qty', 'qc_qty', 'postil'],
  66. calc: function (p) {
  67. p.pre_gather_qty = ctx.helper.add(p.pre_contract_qty, p.pre_qc_qty);
  68. p.gather_qty = ctx.helper.add(p.contract_qty, p.qc_qty);
  69. p.end_contract_qty = self.ctx.helper.add(p.pre_contract_qty, p.contract_qty);
  70. p.end_qc_qty = self.ctx.helper.add(p.pre_qc_qty, p.qc_qty);
  71. p.end_gather_qty = self.ctx.helper.add(p.pre_gather_qty, p.gather_qty);
  72. p.final_qty = ctx.helper.add(p.end_qc_qty, p.quantity);
  73. p.final_ratio = ctx.helper.mul(ctx.helper.div(p.end_gather_qty, p.final_qty, 4), 100);
  74. p.end_qc_minus_qty = ctx.helper.add(p.pre_qc_minus_qty, p.qc_minus_qty);
  75. p.final_1_qty = ctx.helper.add(p.end_qc_minus_qty, p.quantity);
  76. p.end_final_1_qty = ctx.helper.add(p.end_qc_qty, p.final_1_qty);
  77. p.final_1_ratio = ctx.helper.mul(ctx.helper.div(p.end_gather_qty, p.end_final_1_qty, 4), 100);
  78. p.due_final_qty = ctx.helper.add(p.quantity, p.due_qc_qty);
  79. }
  80. });
  81. // 需要缓存的数据
  82. this.stageImData = null;
  83. this.changeData = null;
  84. this.changeApplyData = null;
  85. this.changeProjectData = null;
  86. this.stageValidRole = [];
  87. }
  88. _getNewBillsTree(calcFields) {
  89. return new Ledger.billsTree(this.ctx, {
  90. id: 'ledger_id',
  91. pid: 'ledger_pid',
  92. order: 'order',
  93. level: 'level',
  94. rootId: -1,
  95. keys: ['id', 'tender_id', 'ledger_id'],
  96. stageId: 'id',
  97. calcFields: calcFields || ['deal_tp', 'total_price',
  98. 'contract_tp', 'qc_tp', 'contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'gather_tp',
  99. 'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp', 'final_1_tp',
  100. 'end_contract_pc_tp', 'end_qc_pc_tp', 'end_pc_tp',
  101. 'year_contract_tp', 'year_qc_tp', 'year_contract_pc_tp', 'year_qc_pc_tp', 'year_pc_tp', 'year_gather_tp',
  102. 'due_qc_tp', 'due_final_tp',
  103. ],
  104. calc: function (node, helper, decimal) {
  105. if (node.children && node.children.length === 0) {
  106. node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
  107. node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
  108. node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
  109. node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
  110. node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
  111. node.end_qc_minus_qty = helper.add(node.pre_qc_minus_qty, node.qc_minus_qty);
  112. node.final_1_qty = helper.add(node.quantity, node.end_qc_minus_qty);
  113. node.end_final_1_qty = helper.add(node.final_1_qty, node.end_qc_qty);
  114. node.due_final_qty = helper.add(node.quantity, node.due_qc_qty);
  115. }
  116. node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
  117. node.gather_tp = helper.sum([node.contract_tp, node.qc_tp, node.pc_tp]);
  118. node.end_contract_tp = helper.sum([node.pre_contract_tp, node.contract_tp, node.contract_pc_tp]);
  119. node.end_qc_tp = helper.sum([node.pre_qc_tp, node.qc_tp, node.qc_pc_tp]);
  120. node.end_gather_tp = helper.add(node.pre_gather_tp, node.gather_tp);
  121. node.final_tp = helper.add(node.total_price, node.end_qc_tp);
  122. node.final_ratio = helper.mul(helper.div(node.end_gather_tp, node.final_tp, 4), 100);
  123. node.final_1_tp = helper.mul(node.unit_price, node.final_1_qty, decimal.tp);
  124. node.end_final_1_tp = helper.add(node.final_1_tp, node.end_qc_tp);
  125. node.final_1_ratio = helper.mul(helper.div(node.end_gather_tp, node.end_final_1_tp, 4), 100);
  126. node.due_final_tp = helper.add(node.total_price, node.due_qc_tp);
  127. }
  128. });
  129. }
  130. _checkFieldsExist(source, check) {
  131. for (const s of source) {
  132. if (check.indexOf(s) >= 0) {
  133. return true;
  134. }
  135. }
  136. return false;
  137. }
  138. _checkFieldsExistReg(source, regStr) {
  139. const reg = new RegExp(regStr, 'igm');
  140. for (const s of source) {
  141. if (reg.test(s)) {
  142. return true;
  143. }
  144. }
  145. return false;
  146. }
  147. // build-time: 162-384ms, redis-cache: 0-41ms, mysql + IO: 116-146ms
  148. // 一定程度上算是大Value缓存,数据多了以后:
  149. // 1. 达到redis内存阈值时,数据会swap到磁盘,此时将消耗IO时间
  150. // 2. redis单独服务器
  151. // 3. redis集群
  152. async _getReportMemoryCache(name, tid, sid, time, version = '') {
  153. // redis
  154. const cacheKey = name + '-t' + tid + (sid ? '-s' + sid : '') + (time ? '-' + time : '') + version;
  155. const data = await this.cache.get(cacheKey);
  156. if (data) {
  157. return eval(data);
  158. } else {
  159. return null;
  160. }
  161. // mysql + IO
  162. // const rm = await this.getDataByCondition({
  163. // tid: tid, sid: sid, name: name, time: time
  164. // });
  165. // if (rm && rm.file) {
  166. // const file = path.join(this.ctx.app.config.filePath, 'report', 'cache', rm.file);
  167. // if (fs.existsSync(file)) {
  168. // const data = await fs.readFileSync(file, 'utf8');
  169. // return eval(data);
  170. // } else {
  171. // return null;
  172. // }
  173. // }
  174. }
  175. async _setReportMemoryCache(name, tid, sid, time, data, version = '') {
  176. // redis
  177. const cacheKey = name + '-t' + tid + (sid ? '-s' + sid : '') + (time ? '-' + time : '') + version;
  178. this.cache.set(cacheKey, JSON.stringify(data), 'EX', this.ctx.app.config.cacheTime);
  179. // mysql + IO
  180. // const file = path.join('report', 'cache', 'rm' + (new Date()).getTime() + '.json');
  181. // await this.ctx.helper.saveBufferFile(JSON.stringify(data), path.join(this.ctx.app.config.filePath, file));
  182. // const rm = await this.getDataByCondition({
  183. // tid: tid, sid: sid, name: name, time: time
  184. // });
  185. // if (rm) {
  186. // await this.db.update(this.tableName, {id: rm.id, file: file});
  187. // } else {
  188. // await this.db.insert(this.tableName, {tid: tid, sid: sid, name: name, time: time, file: file});
  189. // }
  190. }
  191. async _generateStageIm(tid, sid, isTz = true) {
  192. if (isTz && [imType.tz.value, imType.bb.value].indexOf(this.ctx.stage.im_type) === -1) {
  193. throw '您查看的报表跟设置不符,请查看“总量控制”的报表';
  194. } else if (!isTz && [imType.zl.value, imType.bw.value].indexOf(this.ctx.stage.im_type) === -1) {
  195. throw '您查看的报表跟设置不符,请查看“0号台账”的报表';
  196. }
  197. const stageIm = new StageIm(this.ctx);
  198. await stageIm.buildImData();
  199. this.stageImData.main = stageIm.ImData;
  200. if (isTz) {
  201. this.stageImData.bills = stageIm.ImBillsData;
  202. await this._setReportMemoryCache(stageImTz, tid, sid, this.ctx.stage.cacheTime, this.stageImData.main, stageImVersion);
  203. await this._setReportMemoryCache(stageImTzBills, tid, sid, this.ctx.stage.cacheTime, this.stageImData.bills, stageImVersion);
  204. } else {
  205. await this._setReportMemoryCache(stageImZl, tid, sid, this.ctx.stage.cacheTime, this.stageImData.main, stageImVersion);
  206. }
  207. }
  208. async getStageImTzData(tid, sid, fields, readCache = true) {
  209. try {
  210. await this.ctx.service.tender.checkTender(tid);
  211. await this.ctx.service.stage.checkStage(sid);
  212. if (readCache) {
  213. const cache = await this._getReportMemoryCache('mem_stage_im_tz', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
  214. if (cache) return cache;
  215. }
  216. if (!this.stageImData) {
  217. this.stageImData = {};
  218. try {
  219. await this._generateStageIm(tid, sid);
  220. } catch (err) {
  221. if (err.stack) {
  222. this.ctx.logger.error(err);
  223. }
  224. this.stageImData.main = err.stack ? '数据错误' : err;
  225. this.stageImData.bills = this.stageImData.main;
  226. }
  227. }
  228. return this.stageImData.main;
  229. } catch (err) {
  230. return [];
  231. }
  232. }
  233. async getStageImTzBillsData(tid, sid, fields, readCache = true) {
  234. try {
  235. await this.ctx.service.tender.checkTender(tid);
  236. await this.ctx.service.stage.checkStage(sid);
  237. if (readCache) {
  238. const cache = await this._getReportMemoryCache('mem_stage_im_tz_bills', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
  239. if (cache) return cache;
  240. }
  241. if (!this.stageImData) {
  242. this.stageImData = {};
  243. try {
  244. await this._generateStageIm(tid, sid);
  245. } catch (err) {
  246. if (err.stack) {
  247. this.ctx.logger.error(err);
  248. }
  249. this.stageImData.main = err.stack ? '数据错误' : err;
  250. this.stageImData.bills = this.stageImData.main;
  251. }
  252. }
  253. return this.stageImData.bills;
  254. } catch (err) {
  255. return [];
  256. }
  257. }
  258. async getStageImZlData(tid, sid, fields, readCache = true) {
  259. try {
  260. await this.ctx.service.tender.checkTender(tid);
  261. await this.ctx.service.stage.checkStage(sid);
  262. if (readCache) {
  263. const cache = await this._getReportMemoryCache('mem_stage_im_zl', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
  264. if (cache) return cache;
  265. }
  266. this.stageImData = {};
  267. try {
  268. await this._generateStageIm(tid, sid, false);
  269. } catch (err) {
  270. if (err.stack) {
  271. this.ctx.logger.error(err);
  272. }
  273. this.stageImData.main = err.statck ? '数据错误' : err;
  274. }
  275. return this.stageImData.main;
  276. } catch (err) {
  277. return [];
  278. }
  279. }
  280. async getMonthProgress(tid, fields) {
  281. const helper = this.ctx.helper;
  282. await this.ctx.service.tender.checkTender(tid);
  283. const tender = this.ctx.tender;
  284. const stages = await this.ctx.service.stage.getValidStages(tender.id);
  285. const lastStage = stages.length > 0 ? stages[0] : null;
  286. if (lastStage) {
  287. await this.ctx.service.stage.checkStageGatherData(lastStage, this.ctx.session.sessionUser.is_admin);
  288. tender.gather_tp = helper.add(lastStage.contract_tp, lastStage.qc_tp);
  289. tender.end_contract_tp = helper.add(lastStage.contract_tp, lastStage.pre_contract_tp);
  290. tender.end_qc_tp = helper.add(lastStage.qc_tp, lastStage.pre_qc_tp);
  291. tender.end_gather_tp = helper.add(tender.end_contract_tp, tender.end_qc_tp);
  292. tender.pre_gather_tp = helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
  293. tender.yf_tp = lastStage.yf_tp;
  294. tender.qc_ratio = helper.mul(helper.div(tender.end_qc_tp, tender.info.deal_param.contractPrice, 2), 100);
  295. tender.sum = helper.add(tender.total_price, tender.end_qc_tp);
  296. tender.pre_ratio = helper.mul(helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
  297. tender.cur_ratio = helper.mul(helper.div(tender.gather_tp, tender.sum, 2), 100);
  298. tender.other_tp = helper.sub(helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
  299. tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
  300. }
  301. const monthProgress = [];
  302. for (const s of stages) {
  303. if (s.s_time) {
  304. let progress = monthProgress.find(function (x) {
  305. return x.month === s.s_time;
  306. });
  307. if (!progress) {
  308. progress = {month: s.s_time};
  309. monthProgress.push(progress);
  310. }
  311. progress.tp = helper.add(helper.add(progress.tp, s.contract_tp), s.qc_tp);
  312. }
  313. }
  314. monthProgress.sort(function (x, y) {
  315. return Date.parse(x.month) - Date.parse(y.month);
  316. });
  317. let sum = 0;
  318. for (const p of monthProgress) {
  319. p.ratio = helper.mul(helper.div(p.tp, tender.sum, 4), 100);
  320. sum = helper.add(sum, p.tp);
  321. p.end_tp = sum;
  322. p.end_ratio = helper.mul(helper.div(p.end_tp, tender.sum, 4), 100);
  323. }
  324. return monthProgress;
  325. }
  326. async _calcBillsBgl(billsTree) {
  327. if (!this.ctx.stage) return;
  328. const helper = this.ctx.helper;
  329. const tender = this.ctx.tender;
  330. const stage = this.ctx.stage;
  331. const bglData = this.ctx.stage.readOnly
  332. ? await this.ctx.service.stageChange.getAuditorAllStageData(tender.id, stage.id, stage.curTimes, stage.curOrder)
  333. : await this.ctx.service.stageChange.getLastestAllStageData(tender.id, stage.id);
  334. for (const node of billsTree.nodes) {
  335. node.qc_bgl_code = '';
  336. node.qc_bgl_arr = [];
  337. if (node.children && node.children.length > 0) continue;
  338. const nodeBgl = helper._.filter(bglData, {lid: node.id});
  339. if (nodeBgl.length === 0) continue;
  340. helper._.pullAll(bglData, nodeBgl);
  341. const validBgl = helper._.filter(nodeBgl, function (x) {
  342. return !helper.checkZero(x.qty);
  343. });
  344. node.qc_bgl_arr = helper._.uniq(helper._.map(validBgl, 'c_code'));
  345. node.qc_bgl_code = node.qc_bgl_arr.join(';');
  346. }
  347. }
  348. async _calcBillsEndBgl(billsTree) {
  349. if (!this.ctx.stage) return;
  350. const helper = this.ctx.helper;
  351. const tender = this.ctx.tender;
  352. const stage = this.ctx.stage;
  353. const preBglData = stage.preCheckedStage ? await this.ctx.service.stageChangeFinal.getFinalChangeBills(tender.id, stage.preCheckedStage.order) : [];
  354. for (const node of billsTree.nodes) {
  355. node.pre_qc_bgl_code = '';
  356. node.pre_qc_bgl_arr = [];
  357. if (node.children && node.children.length > 0) continue;
  358. if (preBglData.length === 0) continue;
  359. const nodePreBgl = helper._.filter(preBglData, {lid: node.id});
  360. if (nodePreBgl.length === 0) continue;
  361. helper._.pullAll(preBglData, nodePreBgl);
  362. const validBgl = helper._.filter(nodePreBgl, function(x) {
  363. return !helper.checkZero(x.qty);
  364. });
  365. node.pre_qc_bgl_arr = helper._.uniq(helper._.map(validBgl, 'c_code'));
  366. node.pre_qc_bgl_code = node.pre_qc_bgl_arr.join(';');
  367. }
  368. for (const node of billsTree.nodes) {
  369. node.end_qc_bgl_arr = helper._.uniq(node.pre_qc_bgl_arr.concat(node.qc_bgl_arr));
  370. node.end_qc_bgl_code = node.end_qc_bgl_arr.join(';');
  371. }
  372. }
  373. _calcLeafXmjRela(billsTree) {
  374. for (const node of billsTree.nodes) {
  375. if (node.b_code) {
  376. const leafXmj = billsTree.getLeafXmjParent(node);
  377. node.leaf_xmj_id = leafXmj ? leafXmj.id : -1;
  378. }
  379. }
  380. }
  381. async _getValidStages(tenderId) {
  382. const stages = await this.db.select(this.ctx.service.stage.tableName, {
  383. where: { tid: tenderId },
  384. orders: [['order', 'desc']],
  385. });
  386. if (stages.length !== 0) {
  387. const lastStage = stages[0];
  388. if (lastStage.status === auditConst.stage.status.uncheck && lastStage.user_id !== this.ctx.session.sessionUser.accountId) {
  389. stages.splice(0, 1);
  390. }
  391. }
  392. return stages;
  393. }
  394. async _getTimeZoneStages(tender, zone) {
  395. const times = zone.split(' - ');
  396. if (times.length !== 2) throw '选择的汇总周期无效';
  397. const beginTime = moment(times[0], 'YYYY-MM');
  398. const endTime = moment(times[1], 'YYYY-MM');
  399. const stages = await this._getValidStages(tender.id), validStages = [];
  400. for (const stage of stages) {
  401. const sTime = moment(stage.s_time, 'YYYY-MM');
  402. if (sTime.isBetween(beginTime, endTime, null, '[]')) {
  403. validStages.push(stage);
  404. }
  405. }
  406. return validStages;
  407. }
  408. async _gatherStageBills(tender, stages) {
  409. let billsIndexData = {};
  410. const helper = this.ctx.helper;
  411. const sumAssignRelaData = function (index, rela) {
  412. const loadFields = function (datas, fields, prefix, relaId) {
  413. for (const d of datas) {
  414. if (!index[d[relaId]]) index[d[relaId]] = {};
  415. const m = index[d[relaId]];
  416. m[relaId] = d[relaId];
  417. if (m) {
  418. for (const f of fields) {
  419. if (d[f] !== undefined) {
  420. m[prefix + f] = helper.add(m[prefix + f], d[f]);
  421. }
  422. }
  423. }
  424. }
  425. };
  426. for (const r of rela) {
  427. loadFields(r.data, r.fields, r.prefix, r.relaId);
  428. }
  429. };
  430. for (const stage of stages) {
  431. await this.ctx.service.stage.doCheckStage(stage);
  432. const curStage = stage.readOnly
  433. ? await this.ctx.service.stageBills.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
  434. : await this.ctx.service.stageBills.getLastestStageData2(tender.id, stage.id);
  435. const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
  436. sumAssignRelaData(billsIndexData, [
  437. { data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: '', relaId: 'lid' },
  438. { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
  439. ]);
  440. }
  441. const result = [];
  442. for (const prop in billsIndexData) {
  443. const yearStageBills = billsIndexData[prop];
  444. yearStageBills.gather_qty = helper.add(yearStageBills.contract_qty, yearStageBills.qc_qty);
  445. yearStageBills.gather_tp = helper.sum([yearStageBills.contract_tp, yearStageBills.qc_tp, yearStageBills.pc_tp]);
  446. result.push(yearStageBills);
  447. }
  448. return result;
  449. };
  450. async _loadStageBillsZone(tender, zone){
  451. const stages = await this._getTimeZoneStages(tender, zone);
  452. return await this._gatherStageBills(tender, stages);
  453. }
  454. async _loadStageBillsYear(tender, year) {
  455. return await this._loadStageBillsZone(tender, `${year}-01 - ${year}-12`);
  456. }
  457. async getStageBillsData(tid, sid, fields, showLevel) {
  458. try {
  459. await this.ctx.service.tender.checkTender(tid);
  460. if (sid) {
  461. await this.ctx.service.stage.checkStage(sid);
  462. }
  463. const billsData = this.ctx.stage.ledgerHis
  464. ? await this.ctx.helper.loadLedgerDataFromOss(this.ctx.stage.ledgerHis.bills_file)
  465. : await this.ctx.service.ledger.getData(this.ctx.tender.id);
  466. const memoData = this.ctx.stage.ledgerHis ? await this.ctx.service.ledger.getAllDataByCondition({ columns: ['id', 'memo'], where: { tender_id: this.ctx.tender.id } }) : [];
  467. if (this._checkFieldsExist(fields, billsFields.stageDgn)) {
  468. const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(this.ctx.tender.id);
  469. for (const d of dgnData) {
  470. const l = this.ctx.helper._.find(billsData, {id: d.id});
  471. this.ctx.helper._.assignIn(l, d);
  472. }
  473. }
  474. let preStage = [], curStage = [];
  475. if (this._checkFieldsExist(fields, billsFields.stage)) {
  476. if (this.ctx.stage.readOnly) {
  477. curStage = await this.ctx.service.stageBills.getAuditorStageData2(this.ctx.tender.id,
  478. this.ctx.stage.id, this.ctx.stage.curTimes, this.ctx.stage.curOrder);
  479. } else {
  480. curStage = await this.ctx.service.stageBills.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id);
  481. }
  482. }
  483. if (this._checkFieldsExist(fields, billsFields.stageEnd)) {
  484. preStage = this.ctx.stage.preCheckedStage ? await this.ctx.service.stageBillsFinal.getFinalData(this.ctx.tender, this.ctx.stage.preCheckedStage.order) : [];
  485. }
  486. const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: this.ctx.stage.id } });
  487. const endBpcStage = await this.ctx.service.stageBillsPc.getEndStageData(this.ctx.stage);
  488. const yearStage = this._checkFieldsExistReg(fields, 'year_') && this.ctx.stage.s_time
  489. ? await this._loadStageBillsYear(this.ctx.tender, this.ctx.stage.s_time.split('-')[0])
  490. : [];
  491. const changeData = this._checkFieldsExistReg(fields, 'due_')
  492. ? await this.ctx.service.changeAuditList.getBillsSum(this.ctx.tender.id)
  493. : [];
  494. this.ctx.helper.assignRelaData(billsData, [
  495. { data: memoData, fields: ['memo'], prefix: '', relaId: 'id' },
  496. { data: curStage, fields: ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp', 'qc_minus_qty', 'postil'], prefix: '', relaId: 'lid' },
  497. { data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'pre_', relaId: 'lid' },
  498. { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'org_price'], prefix: '', relaId: 'lid' },
  499. { data: endBpcStage, fields: ['end_contract_pc_tp', 'end_qc_pc_tp', 'end_pc_tp', 'org_price_his'], prefix: '', relaId: 'lid' },
  500. { data: yearStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty', 'contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'gather_qty', 'gather_tp'], prefix: 'year_', relaId: 'lid' },
  501. { data: changeData, fields: ['qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'due_', relaId: 'gcl_id' },
  502. ]);
  503. billsData.forEach(x => {
  504. if (x.org_price_his && x.org_price_his.length > 0) {
  505. for (const prop of x.org_price_his) {
  506. x[`org_price_${prop}`] = x.org_price_his[prop];
  507. }
  508. } else {
  509. x.org_price_0 = x.unit_price;
  510. }
  511. });
  512. const billsTree = this._getNewBillsTree();
  513. billsTree.loadDatas(billsData);
  514. billsTree.calculateAll();
  515. if (this._checkFieldsExist(fields, billsFields.bgl)) {
  516. await this._calcBillsBgl(billsTree);
  517. if (this._checkFieldsExist(fields, billsFields.endBgl)) await this._calcBillsEndBgl(billsTree)
  518. }
  519. if (this._checkFieldsExist(fields, billsFields.leafXmj)) {
  520. this._calcLeafXmjRela(billsTree);
  521. }
  522. return showLevel ? billsTree.getDefaultDatasByLevel(this.ctx.tender.rpt_show_level) : billsTree.getDefaultDatas();
  523. } catch(err) {
  524. this.ctx.log(err);
  525. return [];
  526. }
  527. }
  528. async _calcPosBgl() {
  529. if (!this.ctx.stage) return;
  530. const helper = this.ctx.helper;
  531. const tender = this.ctx.tender;
  532. const stage = this.ctx.stage;
  533. const bglData = this.ctx.stage.readOnly
  534. ? await this.ctx.service.stageChange.getAuditorAllStageData(tender.id, stage.id, stage.curTimes, stage.curOrder)
  535. : await this.ctx.service.stageChange.getLastestAllStageData(tender.id, stage.id);
  536. for (const p of this.pos.datas) {
  537. p.qc_bgl_code = '';
  538. const pBgl = helper._.filter(bglData, {lid: p.lid, pid: p.id});
  539. if (pBgl.length === 0) continue;
  540. helper._.pullAll(bglData, pBgl);
  541. const validBgl = helper._.filter(pBgl, function (x) {
  542. return !helper.checkZero(x.qty);
  543. });
  544. p.qc_bgl_code = helper._.uniq(helper._.map(validBgl, 'c_code')).join(';');
  545. }
  546. }
  547. async getStagePosData(tid, sid, fields) {
  548. try {
  549. await this.ctx.service.tender.checkTender(tid);
  550. if (sid) {
  551. await this.ctx.service.stage.checkStage(sid);
  552. }
  553. const posData = await this.ctx.service.pos.getAllDataByCondition({ where: {tid: this.ctx.tender.id }});
  554. let curPosStage = [], prePosStage = [];
  555. if (this._checkFieldsExist(fields, posFields.stage)) {
  556. if (this.ctx.stage.readOnly) {
  557. curPosStage = await this.ctx.service.stagePos.getAuditorStageData2(this.ctx.tender.id,
  558. this.ctx.stage.id, this.ctx.stage.curTimes, this.ctx.stage.curOrder);
  559. } else {
  560. curPosStage = await this.ctx.service.stagePos.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id);
  561. }
  562. }
  563. if (this._checkFieldsExist(fields, posFields.stageEnd)) {
  564. prePosStage = this.ctx.stage.preCheckedStage ? await this.ctx.service.stagePosFinal.getFinalData(this.ctx.tender, this.ctx.stage.preCheckedStage.order) : [];
  565. }
  566. const changeData = this._checkFieldsExistReg(fields, 'due_')
  567. ? await this.ctx.service.changeAuditList.getPosSum(this.ctx.tender.id)
  568. : [];
  569. this.ctx.helper.assignRelaData(posData, [
  570. {data: curPosStage, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty', 'contract_expr', 'postil'], prefix: '', relaId: 'pid'},
  571. {data: prePosStage, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty'], prefix: 'pre_', relaId: 'pid'},
  572. {data: changeData, fields: ['qc_qty', 'qc_minus_qty'], prefix: 'due_', relaId: 'mx_id'},
  573. ]);
  574. this.pos.loadDatas(posData);
  575. this.pos.calculateAll();
  576. if (this._checkFieldsExist(fields, posFields.bgl)) {
  577. await this._calcPosBgl();
  578. }
  579. return this.pos.getDatas();
  580. } catch (err) {
  581. return [];
  582. }
  583. }
  584. _getStageValidRole () {
  585. if (!this.ctx.stage) throw '期数据错误,请重试';
  586. if (this.stageValidRole && this.stageValidRole.length > 0) return;
  587. const result = [{dataOrder: 0, flowOrder: 0, uid: this.ctx.stage.user_id}];
  588. for (const auditorGroup of this.ctx.stage.auditorGroups) {
  589. const hasChecked = auditorGroup.find(x => { return x.status === audit.stage.status.checked });
  590. const hasOtherStatus = auditorGroup.find(x => { return x.status === audit.stage.status.checkNo || x.status === audit.stage.status.checkNoPre || x.status === audit.stage.status.checkAgain || x.status === audit.stage.status.checkCancel });
  591. const isCur = auditorGroup.find(x => { return x.status === audit.stage.status.checking}) && (!this.ctx.stage.readOnly || this.ctx.stage.canCheck);
  592. if ((hasChecked && !hasOtherStatus) || isCur) {
  593. const role = result.find(function (r) {
  594. return r.uid === auditorGroup.map(x => { return x.aid }).join(',');
  595. });
  596. if (role) {
  597. role.dataOrder = auditorGroup[0].order;
  598. } else {
  599. result.push({
  600. dataOrder: auditorGroup[0].order,
  601. flowOrder: auditorGroup[0].audit_order,
  602. uid: auditorGroup.map(x => { return x.aid }).join(',')
  603. })
  604. }
  605. }
  606. }
  607. this.stageValidRole = result;
  608. };
  609. async getStageBillsCompareData(tid, sid, fields, showLevel) {
  610. try {
  611. await this.ctx.service.tender.checkTender(tid);
  612. await this.ctx.service.stage.checkStage(sid);
  613. await this._getStageValidRole();
  614. const stage = this.ctx.stage, helper = this.ctx.helper;
  615. const validRole = this.stageValidRole;
  616. const billsData = this.ctx.stage.ledgerHis
  617. ? await this.ctx.helper.loadLedgerDataFromOss(this.ctx.stage.ledgerHis.bills_file)
  618. : await this.ctx.service.ledger.getData(this.ctx.tender.id);
  619. const memoData = this.ctx.stage.ledgerHis ? await this.ctx.service.ledger.getAllDataByCondition({ columns: ['id', 'memo'], where: { tender_id: this.ctx.tender.id } }) : [];
  620. const allStageBills = await this.ctx.service.stageBills.getAllDataByCondition({where: {sid: sid}});
  621. const stageBillsIndex = {}, timesLen = 100;
  622. for (const role of validRole) {
  623. const stageBills = this.ctx.helper._.filter(allStageBills, function (x) {
  624. return x.times < stage.curTimes || (x.times === stage.curTimes && x.order <= role.dataOrder);
  625. });
  626. this.ctx.helper._.pullAll(allStageBills, stageBills);
  627. for (const sb of stageBills) {
  628. const key = 'sb-' + sb.lid;
  629. const sbi = stageBillsIndex[key];
  630. if (sbi) {
  631. if ((sbi.times * timesLen + sbi.order) < (sb.times * timesLen + sb.order)) stageBillsIndex[key] = sb;
  632. } else {
  633. stageBillsIndex[key] = sb;
  634. }
  635. }
  636. const filterStageBills = [];
  637. for (const prop in stageBillsIndex) {
  638. filterStageBills.push(stageBillsIndex[prop]);
  639. }
  640. this.ctx.helper.assignRelaData(billsData, [
  641. {data: filterStageBills, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'r' + role.flowOrder + '_', relaId: 'lid'}
  642. ]);
  643. }
  644. const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: this.ctx.stage.id } });
  645. const endBpcStage = await this.ctx.service.stageBillsPc.getEndStageData(this.ctx.stage);
  646. const preStage = this._checkFieldsExist(fields, billsFields.stageEnd) && this.ctx.stage.preCheckedStage
  647. ? await this.ctx.service.stageBillsFinal.getFinalData(this.ctx.tender, this.ctx.stage.preCheckedStage.order)
  648. : [];
  649. this.ctx.helper.assignRelaData(billsData, [
  650. { data: memoData, fields: ['memo'], prefix: '', relaId: 'id' },
  651. { data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'pre_', relaId: 'lid'},
  652. { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'org_price'], prefix: '', relaId: 'lid' },
  653. { data: endBpcStage, fields: ['end_contract_pc_tp', 'end_qc_pc_tp', 'end_pc_tp', 'org_price_his'], prefix: '', relaId: 'lid' },
  654. ]);
  655. billsData.forEach(x => {
  656. if (x.org_price_his && x.org_price_his.length > 0) {
  657. for (const prop of x.org_price_his) {
  658. x[`org_price_${prop}`] = x.org_price_his[prop];
  659. }
  660. } else {
  661. x.org_price_0 = x.unit_price;
  662. }
  663. });
  664. const billsTree = this._getNewBillsTree();
  665. billsTree.loadDatas(billsData);
  666. for (const role of validRole) {
  667. const prefix = 'r' + role.flowOrder + '_';
  668. billsTree.setting.calcFields.push(prefix + 'contract_tp', prefix + 'qc_tp', prefix + 'gather_tp');
  669. }
  670. billsTree.calculateAll(function(node) {
  671. let prefix = '';
  672. if (node.children && node.children.length === 0) {
  673. node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
  674. for (const role of validRole) {
  675. prefix = 'r' + role.flowOrder + '_';
  676. node[prefix + 'gather_qty'] = helper.add(node[prefix + 'contract_qty'], node[prefix + 'qc_qty']);
  677. }
  678. }
  679. node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
  680. for (const role of validRole) {
  681. prefix = 'r' + role.flowOrder + '_';
  682. node[prefix + 'gather_tp'] = helper.sum([node[prefix + 'contract_tp'], node[prefix + 'qc_tp'], node.pc_tp]);
  683. }
  684. });
  685. if (this._checkFieldsExist(fields, billsFields.leafXmj)) {
  686. this._calcLeafXmjRela(billsTree);
  687. }
  688. return showLevel ? billsTree.getDefaultDatasByLevel(this.ctx.tender.rpt_show_level) : billsTree.getDefaultDatas();
  689. } catch (err) {
  690. return [];
  691. }
  692. }
  693. async getStagePosCompareData(tid, sid, fields) {
  694. try {
  695. await this.ctx.service.tender.checkTender(tid);
  696. await this.ctx.service.stage.checkStage(sid);
  697. await this._getStageValidRole();
  698. const stage = this.ctx.stage, helper = this.ctx.helper;
  699. const validRole = this.stageValidRole;
  700. const allStagePos = await this.ctx.service.stagePos.getAllDataByCondition({where: {sid: sid}});
  701. const posData = await this.ctx.service.pos.getAllDataByCondition({ where: {tid: this.ctx.tender.id }});
  702. const prePosStage = this.ctx.stage.preCheckedStage ? await this.ctx.service.stagePosFinal.getFinalData(this.ctx.tender, this.ctx.stage.preCheckedStage.order) : [];
  703. this.ctx.helper.assignRelaData(posData, [
  704. {data: prePosStage, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty'], prefix: 'pre_', relaId: 'pid'}
  705. ]);
  706. const stagePosIndex = {}, timesLen = 100;
  707. for (const role of validRole) {
  708. const stagePos = this.ctx.helper._.filter(allStagePos, function (x) {
  709. return x.times < stage.curTimes || (x.times === stage.curTimes && x.order <= role.dataOrder);
  710. });
  711. this.ctx.helper._.pullAll(allStagePos, stagePos);
  712. for (const sp of stagePos) {
  713. const key = 'sp-' + sp.pid;
  714. const spi = stagePosIndex[key];
  715. if (spi) {
  716. if ((spi.times * timesLen + spi.order) < (sp.times * timesLen + sp.order)) stagePosIndex[key] = sp;
  717. } else {
  718. stagePosIndex[key] = sp;
  719. }
  720. }
  721. const filterStagePos = [];
  722. for (const prop in stagePosIndex) {
  723. filterStagePos.push(stagePosIndex[prop]);
  724. }
  725. this.ctx.helper.assignRelaData(posData, [
  726. {data: filterStagePos, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty'], prefix: 'r' + role.flowOrder + '_', relaId: 'pid'}
  727. ]);
  728. }
  729. this.pos.loadDatas(posData);
  730. this.pos.calculateAll(function (p) {
  731. p.pre_gather_qty = helper.add(p.pre_contract_qty, p.pre_qc_qty);
  732. for (const role of validRole) {
  733. const prefix = 'r' + role.flowOrder + '_';
  734. p[prefix + 'gather_qty'] = helper.add(p[prefix + 'contract_qty'], p[prefix + 'qc_qty']);
  735. }
  736. });
  737. return this.pos.getDatas();
  738. } catch (err) {
  739. return [];
  740. }
  741. }
  742. async getStagePayData(tid, sid, fields) {
  743. try {
  744. await this.ctx.service.tender.checkTender(tid);
  745. await this.ctx.service.stage.checkStage(sid);
  746. const stage = this.ctx.stage;
  747. const dealPay = await this.ctx.service.stagePay.getStagePays(this.ctx.stage);
  748. if (!this.ctx.stage.readOnly) {
  749. // 计算 本期金额
  750. const PayCalculator = require('../lib/pay_calc');
  751. const payCalculator = new PayCalculator(this.ctx, this.ctx.stage, this.ctx.tender.info);
  752. await payCalculator.calculateAll(dealPay);
  753. }
  754. if (this._checkFieldsExist(fields, ['start_stage_order']) && this.ctx.stage.status !== audit.stage.status.checked) {
  755. for (const dp of dealPay) {
  756. if (!dp.start_stage_order || dp.start_stage_order === this.ctx.stage.order) {
  757. dp.start_stage_order = this.ctx.helper.checkZero(dp.tp) ? null : this.ctx.stage.order;
  758. }
  759. }
  760. }
  761. if (this._checkFieldsExistReg(fields, 'r[0-9]+_tp')) {
  762. this._getStageValidRole();
  763. const allStagePays = await this.ctx.service.stagePay.getAllDataByCondition({
  764. where: {sid: stage.id, stimes: stage.curTimes}
  765. });
  766. for (const [i, role] of this.stageValidRole.entries()) {
  767. if (i < this.stageValidRole.length - 1) {
  768. const stagePays = this.ctx.helper._.filter(allStagePays, function (x) {
  769. return x.stimes === stage.curTimes && x.sorder === role.dataOrder;
  770. });
  771. this.ctx.helper._.pullAll(allStagePays, stagePays);
  772. for (const sp of stagePays) {
  773. const dp = dealPay.find(function (x) {return x.pid === sp.pid});
  774. if (dp) {
  775. dp['r' + role.flowOrder + '_tp'] = sp.tp;
  776. }
  777. }
  778. } else {
  779. for (const dp of dealPay) {
  780. dp['r' + role.flowOrder + '_tp'] = dp.tp;
  781. }
  782. }
  783. }
  784. }
  785. return dealPay;
  786. } catch (err) {
  787. return [];
  788. }
  789. }
  790. async getStageChangeBillsData(tid, sid, fields) {
  791. try {
  792. await this.ctx.service.tender.checkTender(tid);
  793. await this.ctx.service.stage.checkStage(sid);
  794. if (this.ctx.stage.readOnly) {
  795. return await this.ctx.service.stageChange.getReportAuditorAllStageData(tid, sid,
  796. this.ctx.stage.curTimes, this.ctx.stage.curOrder);
  797. } else {
  798. return await this.ctx.service.stageChange.getReportLastestAllStageData(tid, sid);
  799. }
  800. } catch (err) {
  801. return [];
  802. }
  803. }
  804. _getChangeConstName(define, value) {
  805. for (const prop in define) {
  806. if (define[prop].value === value) {
  807. return define[prop].name;
  808. }
  809. }
  810. return '';
  811. }
  812. async _generateChange(tid) {
  813. if (this.changeData !== null) return;
  814. const self = this;
  815. try {
  816. const decimal = this.ctx.tender.info.decimal, ctx = this.ctx;
  817. const where = { tid, valid: 1 };
  818. if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = audit.flow.status.checked;
  819. const change = await this.ctx.service.change.getAllDataByCondition({ where, orders: [['code', 'asc']] });
  820. for (const c of change) {
  821. const types = ctx.helper._.map(c.type.split(','), function (t) {
  822. return self._getChangeConstName(changeConst.type, ctx.helper._.toInteger(t));
  823. });
  824. c.type = types.join(';');
  825. c.class = this._getChangeConstName(changeConst.class, c.class);
  826. c.quality = this._getChangeConstName(changeConst.quality, c.quality);
  827. c.charge = this._getChangeConstName(changeConst.charge, c.charge);
  828. c.attachments = await ctx.service.changeAtt.getChangeAttachment(c.cid);
  829. const names = ctx.helper._.map(c.attachments, function (x) {
  830. return x.filename + x.fileext;
  831. });
  832. c.attNames = names.join('\n');
  833. }
  834. const changeBills = await this.ctx.service.changeAuditList.getChangeAuditBills(tid, this.ctx.session.sessionProject.page_show.isOnlyChecked);
  835. for (const d of changeBills) {
  836. d.o_qty = d.oamount;
  837. d.o_tp = this.ctx.helper.mul(d.o_qty, d.unit_price, decimal.tp);
  838. d.c_qty = d.camount;
  839. d.c_tp = this.ctx.helper.mul(d.c_qty, d.unit_price, decimal.tp);
  840. d.s_qty = d.samount ? parseFloat(d.samount) : 0;
  841. d.s_tp = this.ctx.helper.mul(d.s_qty, d.unit_price, decimal.tp);
  842. d.sp_qty = d.spamount;
  843. d.sp_tp = this.ctx.helper.mul(d.sp_qty, d.unit_price, decimal.tp);
  844. const auditAmount = d.audit_amount ? d.audit_amount.split(',') : [];
  845. const relaChange = ctx.helper._.find(change, {cid: d.cid});
  846. for (const [i, aa] of auditAmount.entries()) {
  847. const amountField = 'qty_' + (i+1), tpField = 'tp_' + (i+1);
  848. d[amountField] = aa ? parseFloat(aa) : 0;
  849. d[tpField] = ctx.helper.mul(d[amountField], d.unit_price, decimal.tp);
  850. if (relaChange) {
  851. relaChange[tpField] = ctx.helper.add(relaChange[tpField], d[tpField]);
  852. }
  853. }
  854. }
  855. changeBills.sort(function (a, b) {
  856. const aCIndex = change.findIndex(function (c) {
  857. return c.cid === a.cid;
  858. });
  859. const bCIndex = change.findIndex(function (c) {
  860. return c.cid === b.cid;
  861. });
  862. return aCIndex === bCIndex
  863. ? ctx.helper.compareCode(a.code, b.code)
  864. : aCIndex - bCIndex;
  865. });
  866. this.changeData = {change: change, bills: changeBills};
  867. } catch(err) {
  868. this.ctx.helper.log(err);
  869. throw err;
  870. this.changeData = {change: [], bills: []};
  871. }
  872. }
  873. async _generateChangeAudit() {
  874. if (!!this.changeData.audit) return;
  875. this.changeData.audit = [];
  876. for (const c of this.changeData.change) {
  877. const changeAudit = await this.ctx.service.changeAudit.getListGroupByTimes(c.cid, c.times);
  878. this.changeData.audit.push(...changeAudit);
  879. }
  880. }
  881. async getChangeData(tid, sid, fields) {
  882. try {
  883. await this.ctx.service.tender.checkTender(tid);
  884. await this._generateChange(tid);
  885. return this.changeData.change;
  886. } catch (err) {
  887. return [];
  888. }
  889. }
  890. async getChangeBillsData(tid, sid, fields) {
  891. try {
  892. await this.ctx.service.tender.checkTender(tid);
  893. await this._generateChange(tid);
  894. return this.changeData.bills;
  895. } catch (err) {
  896. return [];
  897. }
  898. }
  899. async getChangeAuditData(tid, sid, fields) {
  900. try {
  901. await this.ctx.service.tender.checkTender(tid);
  902. await this._generateChange(tid);
  903. await this._generateChangeAudit();
  904. return this.changeData.audit;
  905. } catch (err) {
  906. return [];
  907. }
  908. }
  909. async _generateImportChange(sid) {
  910. if (this.importChange !== undefined) return;
  911. const self = this;
  912. try {
  913. const ctx = this.ctx;
  914. const change = await this.ctx.service.stageImportChange.getImportChange(sid);
  915. for (const c of change) {
  916. const types = ctx.helper._.map(c.type.split(','), function (t) {
  917. return self._getChangeConstName(changeConst.type, ctx.helper._.toInteger(t));
  918. });
  919. c.type = types.join(';');
  920. c.class = this._getChangeConstName(changeConst.class, c.class);
  921. c.quality = this._getChangeConstName(changeConst.quality, c.quality);
  922. c.charge = this._getChangeConstName(changeConst.charge, c.charge);
  923. }
  924. change.sort(function (a, b) {
  925. return a.code.localeCompare(b.code);
  926. });
  927. const changeBills = [];
  928. for (const c of change) {
  929. const bills = await this.ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: c.cid } });
  930. for (const b of bills) {
  931. b.o_qty = b.oamount;
  932. b.c_qty = b.camount;
  933. b.s_qty = b.samount ? parseFloat(b.samount) : 0;
  934. b.sp_qty = b.spamount;
  935. }
  936. bills.sort(function (a, b) {
  937. return ctx.helper.compareCode(a.code, b.code);
  938. });
  939. changeBills.push(...bills);
  940. }
  941. this.importChange = {change: change, bills: changeBills};
  942. } catch(err) {
  943. this.ctx.helper.log(err);
  944. throw err;
  945. this.importChange = {change: [], bills: []};
  946. }
  947. }
  948. async getImportChangeData(tid, sid, fields) {
  949. try {
  950. await this._generateImportChange(sid);
  951. return this.importChange.change;
  952. } catch (err) {
  953. return [];
  954. }
  955. }
  956. async getImportChangeBillsData(tid, sid, fields) {
  957. try {
  958. await this._generateImportChange(sid);
  959. return this.importChange.bills;
  960. } catch (err) {
  961. return [];
  962. }
  963. }
  964. async _generateChangeApply(tid) {
  965. if (!!this.changeApplyData) return;
  966. const helper = this.ctx.helper;
  967. const decimal = this.ctx.tender.info.decimal;
  968. const where = { tid };
  969. if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = audit.changeApply.status.checked;
  970. const apply = await this.ctx.service.changeApply.getAllDataByCondition({ where });
  971. const bills = await this.ctx.service.changeApplyList.getChangeBills(tid, this.ctx.session.sessionProject.page_show.isOnlyChecked);
  972. bills.forEach(x => {
  973. const a = apply.find(y => { return y.id === x.caid });
  974. const a_decimal = a.decimal ? JSON.stringify(a.decimal) : { tp: decimal.tp, up: decimal.up };
  975. x.o_tp = helper.mul(x.oamount, x.unit_price, a_decimal.tp);
  976. x.c_tp = helper.mul(x.camount, x.unit_price, a_decimal.tp);
  977. });
  978. bills.sort(function(a, b ) {
  979. const aCIndex = apply.findIndex(function (c) {
  980. return c.id === a.caid;
  981. });
  982. const bCIndex = apply.findIndex(function (c) {
  983. return c.id === b.caid;
  984. });
  985. return aCIndex === bCIndex
  986. ? helper.compareCode(a.code, b.code)
  987. : aCIndex - bCIndex;
  988. });
  989. this.changeApplyData = { data: apply, bills };
  990. }
  991. async _generateChangeApplyAudit() {
  992. if (!!this.changeApplyData.audit) return;
  993. this.changeApplyData.audit = [];
  994. for (const c of this.changeApplyData.data) {
  995. const changeAudit = await this.ctx.service.changeApplyAudit.getAllDataByCondition({ where: { caid: c.id, times: c.times }});
  996. const changeAuditFilter = this.ctx.helper.filterLastestData(changeAudit, ['aid']);
  997. this.changeApplyData.audit.push(...changeAuditFilter);
  998. }
  999. }
  1000. async getChangeApplyData(tid, sid, fields) {
  1001. try {
  1002. await this._generateChangeApply(tid);
  1003. return this.changeApplyData.data;
  1004. } catch (err) {
  1005. return [];
  1006. }
  1007. }
  1008. async getChangeApplyBillsData(tid, sid, fields) {
  1009. try {
  1010. await this._generateChangeApply(tid);
  1011. return this.changeApplyData.bills;
  1012. } catch (err) {
  1013. return [];
  1014. }
  1015. }
  1016. async getChangeApplyAuditData(tid, sid, fields) {
  1017. try {
  1018. await this._generateChangeApply(tid);
  1019. await this._generateChangeApplyAudit();
  1020. return this.changeApplyData.audit;
  1021. } catch (err) {
  1022. this.ctx.log(err);
  1023. return [];
  1024. }
  1025. }
  1026. async _generateChangePlan(tid) {
  1027. if (!!this.changePlanData) return;
  1028. const helper = this.ctx.helper;
  1029. const decimal = this.ctx.tender.info.decimal;
  1030. this.changePlanData = {};
  1031. const where = { tid };
  1032. if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = audit.changeApply.status.checked;
  1033. const data = await this.ctx.service.changePlan.getAllDataByCondition({ where });
  1034. const bills = await this.ctx.service.changePlanList.getChangeBills(tid, this.ctx.session.sessionProject.page_show.isOnlyChecked);
  1035. bills.forEach(x => {
  1036. const plan = data.find(y => { return y.id === x.cpid });
  1037. const p_decimal = plan.decimal ? JSON.stringify(plan.decimal) : { tp: decimal.tp, up: decimal.up };
  1038. x.o_tp = helper.mul(x.oamount, x.unit_price, p_decimal.tp);
  1039. x.c_tp = helper.mul(x.camount, x.unit_price, p_decimal.tp);
  1040. x.s_tp = helper.mul(x.samount, x.unit_price, p_decimal.tp);
  1041. x.sp_tp = helper.mul(x.spamount, x.unit_price, p_decimal.tp);
  1042. const auditAmount = x.audit_amount ? x.audit_amount.split(',') : [];
  1043. for (const [i, aa] of auditAmount.entries()) {
  1044. const amountField = 'qty_' + (i+1), tpField = 'tp_' + (i+1);
  1045. x[amountField] = aa ? parseFloat(aa) : 0;
  1046. x[tpField] = helper.mul(x[amountField], x.unit_price, p_decimal.tp);
  1047. if (plan) {
  1048. plan[tpField] = helper.add(plan[tpField], x[tpField]);
  1049. }
  1050. }
  1051. });
  1052. bills.sort(function(a, b ) {
  1053. const aCIndex = data.findIndex(function (c) {
  1054. return c.id === a.cpid;
  1055. });
  1056. const bCIndex = data.findIndex(function (c) {
  1057. return c.id === b.cpid;
  1058. });
  1059. return aCIndex === bCIndex
  1060. ? helper.compareCode(a.code, b.code)
  1061. : aCIndex - bCIndex;
  1062. });
  1063. this.changePlanData = { data, bills };
  1064. }
  1065. async _generateChangePlanAudit() {
  1066. if (!!this.changePlanData.audit) return;
  1067. this.changePlanData.audit = [];
  1068. for (const c of this.changePlanData.data) {
  1069. const changeAudit = await this.ctx.service.changePlanAudit.getAllDataByCondition({ where: { cpid: c.id, times: c.times }});
  1070. const changeAuditFilter = this.ctx.helper.filterLastestData(changeAudit, ['aid']);
  1071. this.changePlanData.audit.push(...changeAuditFilter);
  1072. }
  1073. }
  1074. async getChangePlanData(tid, sid, fields) {
  1075. try {
  1076. await this._generateChangePlan(tid);
  1077. return this.changePlanData.data;
  1078. } catch (err) {
  1079. return [];
  1080. }
  1081. }
  1082. async getChangePlanBillsData(tid, sid, fields) {
  1083. try {
  1084. await this._generateChangePlan(tid);
  1085. return this.changePlanData.bills;
  1086. } catch (err) {
  1087. return [];
  1088. }
  1089. }
  1090. async getChangePlanAuditData(tid, sid, fields) {
  1091. try {
  1092. await this._generateChangePlan(tid);
  1093. await this._generateChangePlanAudit();
  1094. return this.changePlanData.audit;
  1095. } catch (err) {
  1096. this.ctx.log(err);
  1097. return [];
  1098. }
  1099. }
  1100. async _generateChangeProject(tid) {
  1101. if (!!this.changeProjectData) return;
  1102. const where = { tid };
  1103. if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = audit.changeProject.status.checked;
  1104. this.changeProjectData = { data: await this.ctx.service.changeProject.getAllDataByCondition({ where }) };
  1105. }
  1106. async _generateChangeProjectAudit() {
  1107. if (!!this.changeProjectData.audit) return;
  1108. this.changeProjectData.audit = [];
  1109. for (const c of this.changeProjectData.data) {
  1110. const changeAudit = await this.ctx.service.changeProjectAudit.getAllDataByCondition({ where: { cpid: c.id, times: c.times }});
  1111. const changeAuditFilter = this.ctx.helper.filterLastestData(changeAudit, ['aid']);
  1112. this.changeProjectData.audit.push(...changeAuditFilter);
  1113. }
  1114. }
  1115. async getChangeProjectData(tid, sid, fields) {
  1116. try {
  1117. await this._generateChangeProject(tid);
  1118. return this.changeProjectData.data;
  1119. } catch (err) {
  1120. this.ctx.log(err);
  1121. return [];
  1122. }
  1123. }
  1124. async getChangeProjectAuditData(tid, sid, fields) {
  1125. try {
  1126. await this._generateChangeProject(tid);
  1127. await this._generateChangeProjectAudit();
  1128. return this.changeProjectData.audit;
  1129. } catch (err) {
  1130. return [];
  1131. }
  1132. }
  1133. async getStageJgcl(tid, sid, fields) {
  1134. try {
  1135. await this.ctx.service.tender.checkTender(tid);
  1136. await this.ctx.service.stage.checkStage(sid);
  1137. const data = await this.ctx.service.stageJgcl.getStageData(this.ctx.stage);
  1138. const preData = await this.ctx.service.stageJgcl.getPreStageData(tid, this.ctx.stage.order);
  1139. for (const d of data) {
  1140. const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
  1141. if (pd) {
  1142. d.pre_arrive_qty = pd.arrive_qty;
  1143. d.pre_arrive_tp = pd.arrive_tp;
  1144. d.pre_deduct_qty = pd.deduct_qty;
  1145. d.pre_deduct_tp = pd.deduct_tp;
  1146. }
  1147. d.end_arrive_qty = this.ctx.helper.add(d.pre_arrive_qty, d.arrive_qty);
  1148. d.end_arrive_tp = this.ctx.helper.add(d.pre_arrive_tp, d.arrive_tp);
  1149. d.end_deduct_qty = this.ctx.helper.add(d.pre_deduct_qty, d.deduct_qty);
  1150. d.end_deduct_tp = this.ctx.helper.add(d.pre_deduct_tp, d.deduct_tp);
  1151. }
  1152. return data;
  1153. } catch (err) {
  1154. return [];
  1155. }
  1156. }
  1157. async getStageBonus(tid, sid, fields) {
  1158. try {
  1159. await this.ctx.service.tender.checkTender(tid);
  1160. await this.ctx.service.stage.checkStage(sid);
  1161. const data = await this.ctx.service.stageBonus.getEndStageData(tid, this.ctx.stage.order);
  1162. for (const d of data) {
  1163. const names = this.ctx.helper._.map(d.proof_file, function (x) {
  1164. return x.filename + x.fileext;
  1165. });
  1166. d.proof = names.join('\n');
  1167. }
  1168. return data;
  1169. } catch (err) {
  1170. return [];
  1171. }
  1172. }
  1173. async getStageOther(tid, sid, fields) {
  1174. try {
  1175. await this.ctx.service.tender.checkTender(tid);
  1176. await this.ctx.service.stage.checkStage(sid);
  1177. const data = await this.ctx.service.stageOther.getStageData(this.ctx.stage);
  1178. const preData = await this.ctx.service.stageOther.getPreStageData(tid, this.ctx.stage.order);
  1179. for (const d of data) {
  1180. const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
  1181. if (pd) {
  1182. d.pre_tp = pd.tp;
  1183. }
  1184. d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
  1185. }
  1186. return data;
  1187. } catch (err) {
  1188. return [];
  1189. }
  1190. }
  1191. async getStageSafeProd(tid, sid, fields) {
  1192. try {
  1193. await this.ctx.service.tender.checkTender(tid);
  1194. await this.ctx.service.stage.checkStage(sid);
  1195. const data = await this.ctx.service.stageSafeProd.getStageData(this.ctx.stage);
  1196. const preData = await this.ctx.service.stageSafeProd.getPreStageData(tid, this.ctx.stage.order);
  1197. for (const d of data) {
  1198. const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
  1199. if (pd) {
  1200. d.pre_qty = pd.qty;
  1201. d.pre_tp = pd.tp;
  1202. }
  1203. d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
  1204. d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
  1205. }
  1206. return data;
  1207. } catch (err) {
  1208. return [];
  1209. }
  1210. }
  1211. async getStageTempLand(tid, sid, fields) {
  1212. try {
  1213. await this.ctx.service.tender.checkTender(tid);
  1214. await this.ctx.service.stage.checkStage(sid);
  1215. const data = await this.ctx.service.stageTempLand.getStageData(this.ctx.stage);
  1216. const preData = await this.ctx.service.stageTempLand.getPreStageData(tid, this.ctx.stage.order);
  1217. for (const d of data) {
  1218. const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
  1219. if (pd) {
  1220. d.pre_qty = pd.qty;
  1221. d.pre_tp = pd.tp;
  1222. }
  1223. d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
  1224. d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
  1225. }
  1226. return data;
  1227. } catch (err) {
  1228. return [];
  1229. }
  1230. }
  1231. async getSumStageBillsData(tid, sid, fields) {
  1232. try {
  1233. await this.ctx.service.tender.checkTender(tid);
  1234. const billsData = await this.ctx.service.ledger.getData(this.ctx.tender.id);
  1235. const checkStageField = function (stageOrder) {
  1236. for (const f of fields) {
  1237. if (f.indexOf('s' + stageOrder + '_') >= 0) {
  1238. return true;
  1239. }
  1240. }
  1241. return false;
  1242. };
  1243. const calcFields = ['deal_tp', 'total_price'], calcPrefix = [];
  1244. const stages = this.ctx.service.stage.getValidStages(this.ctx.tender.id);
  1245. for (const stage of stages) {
  1246. if (!checkStageField(stage.order)) return;
  1247. await this.ctx.service.stage.doCheckStage(stage);
  1248. calcFields.push('s' + stage.order + '_contract_tp');
  1249. calcFields.push('s' + stage.order + '_qc_tp');
  1250. calcFields.push('s' + stage.order + '_gather_tp');
  1251. calcFields.push('s' + stage.order + '_');
  1252. const curStage = stage.readOnly
  1253. ? await this.ctx.service.stageBills.getAuditorStageData2(this.ctx.tender.id, stage.id, stage.curTimes, stage.curOrder)
  1254. : await this.ctx.service.stageBills.getLastestStageData2(this.ctx.tender.id, stage.id);
  1255. this.ctx.helper.assignRelaData(billsData, [
  1256. {data: curStage, fields: ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp'], prefix: 's' + stage.order + '_', relaId: 'lid'}
  1257. ]);
  1258. }
  1259. const billsTree = new Ledger.billsTree(this.ctx, {
  1260. id: 'ledger_id',
  1261. pid: 'ledger_pid',
  1262. order: 'order',
  1263. level: 'level',
  1264. rootId: -1,
  1265. keys: ['id', 'tender_id', 'ledger_id'],
  1266. stageId: 'id',
  1267. calcFields: calcFields,
  1268. calc: function (node) {
  1269. for (const prefix of calcPrefix) {
  1270. if (node.children && node.children.length === 0) {
  1271. node[prefix + 'gather_qty'] = self.ctx.helper.add(node[prefix + 'contract_qty'], node[prefix + 'qc_qty']);
  1272. }
  1273. node[prefix + 'gather_tp'] = self.ctx.helper.add(node[prefix + 'contract_tp'], node[prefix + 'qc_tp']);
  1274. }
  1275. }
  1276. });
  1277. billsTree.loadDatas(billsData);
  1278. billsTree.calculateAll();
  1279. return billsTree.getDefaultDatas();
  1280. } catch (err) {
  1281. return [];
  1282. }
  1283. }
  1284. async getStageAuditors(tid, sid) {
  1285. await this.ctx.service.tender.checkTender(tid);
  1286. await this.ctx.service.stage.checkStage(sid);
  1287. const auditors = await this.ctx.service.stageAudit.getFinalAuditGroup(this.ctx.stage.id, this.ctx.stage.curTimes);
  1288. const user = await this.ctx.service.projectAccount.getDataById(this.ctx.stage.user_id);
  1289. const result = [{
  1290. aid: user.id,
  1291. name: user.name,
  1292. company: user.company,
  1293. role: user.role,
  1294. mobile: user.mobile,
  1295. telephone: user.telephone,
  1296. sign_path: user.sign_path,
  1297. opinion: user.opinion,
  1298. end_time: auditors && auditors.length > 0 ? auditors[0].begin_time : null,
  1299. sort: 0,
  1300. }, ...auditors];
  1301. return result;
  1302. }
  1303. async getSignSelect(tid, sid, customSelect) {
  1304. await this.ctx.service.tender.checkTender(tid);
  1305. await this.ctx.service.stage.checkStage(sid);
  1306. const signSelect = customSelect.sign_select, result = {};
  1307. for (const [i, ss] of signSelect.entries()) {
  1308. const user = await this.ctx.service.projectAccount.getDataById(ss.id);
  1309. const sign = {
  1310. id: ss.id, name: user.name, company: user.company, role: user.role,
  1311. mobile: user.mobile, telephone: user.telephone,
  1312. };
  1313. if (ss.id !== this.ctx.stage.user_id) {
  1314. const audit = this.ctx.stage.auditors.find(x => {return x.aid === ss.id});
  1315. user.end_time = audit ? audit.end_time : ss.audit_time;
  1316. } else {
  1317. user.end_time = this.ctx.stage.auditors[0].end_time;
  1318. }
  1319. if (user.end_time) sign.sign_path = user.sign_path;
  1320. result['sign' + (i+1)] = sign;
  1321. }
  1322. return result;
  1323. }
  1324. async getStageAuditAss(tid, sid) {
  1325. await this.ctx.service.tender.checkTender(tid);
  1326. await this.ctx.service.stage.checkStage(sid);
  1327. return await this.ctx.service.stageAuditAss.getReportData(this.ctx.stage.id, this.ctx.stage.times);
  1328. }
  1329. async getChangeInfo(tid, sid) {
  1330. await this.ctx.service.tender.checkTender(tid);
  1331. await this.ctx.service.stage.checkStage(sid);
  1332. this.changeInfo = await this.ctx.service.stageChange.getChangeWithUsedInfo(this.ctx.stage);
  1333. const usedChangesId = await this.ctx.service.stageChange.getStageUsedChangeId(sid);
  1334. for (const c of this.changeInfo) {
  1335. c.cur_used = usedChangesId.indexOf(c.cid) >= 0;
  1336. c.used_ratio = c.used_pt;
  1337. c.is_import = 0;
  1338. }
  1339. return this.changeInfo;
  1340. }
  1341. async getChangeInfoBills(tid, sid) {
  1342. if (!this.changeInfo) await this.getChangeInfo(tid, sid);
  1343. this.changeInfoBills = [];
  1344. for (const c of this.changeInfo) {
  1345. const cb = await this.ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: c.cid } });
  1346. const cbu = await this.ctx.service.stageChange.getUsedData(tid, c.cid);
  1347. const curUsedBills = await this.ctx.service.stageChange.getStageUsedData(sid, c.cid);
  1348. for (const b of cb) {
  1349. b.qty = this.ctx.helper._.toNumber(b.samount);
  1350. b.tp = this.ctx.helper.round(this.ctx.helper.mul(b.qty, b.unit_price), this.ctx.tender.info.decimal.tp);
  1351. const u = cbu.filter(x => { return x.cbid === b.id; });
  1352. b.used_qty = u.length > 0 ? this.ctx.helper.sum(u.map(x => { return x.qty})) : 0;
  1353. b.valid_qty = this.ctx.helper.sub(b.qty, b.used_qty);
  1354. const cur = this.ctx.helper._.filter(curUsedBills, { cbid: b.id });
  1355. b.cur_qty = 0;
  1356. for (const cc of cur) {
  1357. b.cur_qty = this.ctx.helper.add(b.cur_qty, cc.qty);
  1358. }
  1359. b.cur_used = !!b.cur_qty;
  1360. this.changeInfoBills.push(b);
  1361. }
  1362. }
  1363. return this.changeInfoBills;
  1364. }
  1365. async getPmDeal() {
  1366. let result = [];
  1367. if (!PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission)) return result;
  1368. let selects;
  1369. if (!this.pmDeal) {
  1370. selects = await this.ctx.service.project.getPmDealCache(this.ctx.session.sessionProject.id);
  1371. const pm = require('../lib/pm');
  1372. this.pmDeal = await pm.dealData(this.ctx, this.ctx.session.sessionProject.code, selects);
  1373. }
  1374. result = this.pmDeal.contracts ? this.pmDeal.contracts.filter(x => { return x.ContractsType === 2 }) : [];
  1375. const fields = ['Code', 'Name', 'ContractName', 'ContractCode', 'ContractPrice', 'ContractReturned', 'ContractsPaid', 'ContractStatus', 'ContractLocking', 'CreateTime'], self = this;
  1376. result.forEach(x => {
  1377. const treeNode = self.pmDeal.tree_contracts.find(y => { return x.TreeId === y.Id });
  1378. if (!treeNode) return;
  1379. for (const f of fields) {
  1380. x['Tree_' + f] = treeNode[f];
  1381. }
  1382. });
  1383. // 排序:标段-合同类别-创建时间
  1384. result.sort((x, y) => {
  1385. const bidSort = selects.indexOf(x.BidsectionId + '') - selects.indexOf(y.BidsectionId + '');
  1386. if (bidSort) return bidSort;
  1387. const typeSort = x.ContractsType - y.ContractsType;
  1388. if (typeSort) return typeSort;
  1389. return x.create_time - y.create_time;
  1390. });
  1391. const helper = this.ctx.helper;
  1392. result.forEach(x => {
  1393. x.PaidPercent = x.Price ? helper.mul(helper.div(x.Paid, x.Price, 4), 100) : 0;
  1394. x.Tree_PaidPercent = x.Tree_ContractPrice ? helper.mul(helper.div(x.Tree_ContractsPaid, x.Tree_ContractPrice, 4), 100) : 0;
  1395. });
  1396. return result;
  1397. }
  1398. async getPmDealTree() {
  1399. const result = [];
  1400. if (!PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission)) return result;
  1401. if (!this.pmDeal) {
  1402. const selects = await this.ctx.service.project.getPmDealCache(this.ctx.session.sessionProject.id);
  1403. const pm = require('../lib/pm');
  1404. this.pmDeal = await pm.dealData(this.ctx, this.ctx.session.sessionProject.code, selects);
  1405. }
  1406. for (const tc of this.pmDeal.tree_contracts) {
  1407. tc.children = this.pmDeal.tree_contracts.filter(x => { return x.ParentId === tc.TreeId && x.TreeType === tc.TreeType});
  1408. }
  1409. const root = this.pmDeal.tree_contracts.filter(x => { return x.Depth === 0; });
  1410. root.sort((x, y) => {
  1411. const type = x.TreeType - y.TreeType;
  1412. return type ? type : x.Serail - y.Serail;
  1413. });
  1414. const helper = this.ctx.helper;
  1415. const sortSumChildren = function (children, data, fields) {
  1416. if (!children || children.length === 0) return null;
  1417. const sum = {};
  1418. for (const c of children) {
  1419. data.push(c);
  1420. const cSum = sortSumChildren(c.children, data, fields);
  1421. if (cSum) {
  1422. for (const f of fields) {
  1423. c[f] = cSum[f].toFixed(2);
  1424. }
  1425. }
  1426. for (const f of fields) {
  1427. sum[f] = helper.add(sum[f], parseFloat(c[f]));
  1428. }
  1429. }
  1430. return sum;
  1431. };
  1432. sortSumChildren(root, result, ['ContractPrice', 'ContractReturned', 'ContractsPaid', 'ContractDeductionTotal']);
  1433. result.forEach(x => {
  1434. x.PaidPercent = x.ContractPrice ? helper.mul(helper.div(x.ContractsPaid, x.ContractPrice, 4), 100) : 0;
  1435. delete x.children
  1436. });
  1437. return result;
  1438. }
  1439. }
  1440. return ReportMemory;
  1441. };