report_memory.js 78 KB

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