1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657 |
- 'use strict';
- /**
- *
- *
- * @author Mai
- * @date
- * @version
- */
- const _ = require('lodash');
- const StageIm = require('../lib/stage_im');
- const imType = require('../const/tender').imType;
- const audit = require('../const/audit');
- const changeConst = require('../const/change');
- // const path = require('path');
- // const fs = require('fs');
- const stageImTz = 'mem_stage_im_tz';
- const stageImTzBills = 'mem_stage_im_tz_bills';
- const stageImZl = 'mem_stage_im_zl';
- const stageImVersion = '1.3';
- const PermissionCheck = require('../const/account_permission').PermissionCheck;
- const Ledger = require('../lib/ledger');
- const moment = require('moment');
- const auditConst = require('../const/audit');
- const billsFields = (function () {
- const cur = ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp', 'qc_minus_qty', 'qc_minus_tp', 'gather_qty', 'gather_tp', 'postil'];
- 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'];
- 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'];
- 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'];
- const final = ['final_tp', 'final_ratio'];
- const final1 = [ 'final_1_qty', 'final_1_tp', 'final_1_ratio'];
- const stageDgn = ['deal_dgn_qty1', 'deal_dgn_qty2', 'c_dgn_qty1', 'c_dgn_qty2'];
- const stage = cur.concat(pre, end, final);
- const stageEnd = pre.concat(end, final);
- const bgl = ['qc_bgl_code', 'pre_qc_bgl_code', 'end_qc_bgl_code'];
- const endBgl = ['pre_qc_bgl_code', 'end_qc_bgl_code'];
- const leafXmj = ['leaf_xmj_id'];
- return {cur, pre, end, final, final1, stageDgn, stage, stageEnd, bgl, leafXmj, endBgl};
- })();
- const posFields = (function () {
- const cur = ['contract_qty', 'qc_qty', 'qc_minus_qty', 'gather_qty', 'postil'];
- const pre = ['pre_contract_qty', 'pre_qc_qty', 'pre_qc_minus_qty', 'pre_gather_qty'];
- const end = ['end_contract_qty', 'end_qc_qty', 'end_qc_minus_qty', 'end_gather_qty'];
- const final = ['final_ratio'];
- const final1 = ['final_1_qty', 'final_1_ratio'];
- const stage = cur.concat(pre, end, final);
- const stageEnd = pre.concat(end, final);
- const bgl = ['qc_bgl_code'];
- return {cur, pre, end, final, final1, stage, stageEnd, bgl};
- })();
- module.exports = app => {
- class ReportMemory extends app.BaseService {
- /**
- * 构造函数
- *
- * @param {Object} ctx - egg全局context
- * @return {void}
- */
- constructor(ctx) {
- super(ctx);
- const self = this;
- // 基础数据类
- // mainData
- this.pos = new Ledger.pos({
- id: 'id', ledgerId: 'lid',
- updateFields: ['contract_qty', 'qc_qty', 'postil'],
- calc: function (p) {
- p.pre_gather_qty = ctx.helper.add(p.pre_contract_qty, p.pre_qc_qty);
- p.gather_qty = ctx.helper.add(p.contract_qty, p.qc_qty);
- p.end_contract_qty = self.ctx.helper.add(p.pre_contract_qty, p.contract_qty);
- p.end_qc_qty = self.ctx.helper.add(p.pre_qc_qty, p.qc_qty);
- p.end_gather_qty = self.ctx.helper.add(p.pre_gather_qty, p.gather_qty);
- p.final_qty = ctx.helper.add(p.end_qc_qty, p.quantity);
- p.final_ratio = ctx.helper.mul(ctx.helper.div(p.end_gather_qty, p.final_qty, 4), 100);
- p.end_qc_minus_qty = ctx.helper.add(p.pre_qc_minus_qty, p.qc_minus_qty);
- p.final_1_qty = ctx.helper.add(p.end_qc_minus_qty, p.quantity);
- p.end_final_1_qty = ctx.helper.add(p.end_qc_qty, p.final_1_qty);
- p.final_1_ratio = ctx.helper.mul(ctx.helper.div(p.end_gather_qty, p.end_final_1_qty, 4), 100);
- p.due_final_qty = ctx.helper.add(p.quantity, p.due_qc_qty);
- }
- });
- // 需要缓存的数据
- this.stageImData = null;
- this.changeData = null;
- this.changeApplyData = null;
- this.changeProjectData = null;
- this.stageValidRole = [];
- }
- _getNewBillsTree(calcFields) {
- return new Ledger.billsTree(this.ctx, {
- id: 'ledger_id',
- pid: 'ledger_pid',
- order: 'order',
- level: 'level',
- rootId: -1,
- keys: ['id', 'tender_id', 'ledger_id'],
- stageId: 'id',
- calcFields: calcFields || ['deal_tp', 'total_price',
- 'contract_tp', 'qc_tp', 'contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'gather_tp',
- 'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp', 'final_1_tp',
- 'end_contract_pc_tp', 'end_qc_pc_tp', 'end_pc_tp',
- 'year_contract_tp', 'year_qc_tp', 'year_contract_pc_tp', 'year_qc_pc_tp', 'year_pc_tp', 'year_gather_tp',
- 'due_qc_tp', 'due_final_tp',
- ],
- calc: function (node, helper, decimal) {
- if (node.children && node.children.length === 0) {
- node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
- node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
- node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
- node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
- node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
- node.end_qc_minus_qty = helper.add(node.pre_qc_minus_qty, node.qc_minus_qty);
- node.final_1_qty = helper.add(node.quantity, node.end_qc_minus_qty);
- node.end_final_1_qty = helper.add(node.final_1_qty, node.end_qc_qty);
- node.due_final_qty = helper.add(node.quantity, node.due_qc_qty);
- }
- node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
- node.gather_tp = helper.sum([node.contract_tp, node.qc_tp, node.pc_tp]);
- node.end_contract_tp = helper.sum([node.pre_contract_tp, node.contract_tp, node.contract_pc_tp]);
- node.end_qc_tp = helper.sum([node.pre_qc_tp, node.qc_tp, node.qc_pc_tp]);
- node.end_gather_tp = helper.add(node.pre_gather_tp, node.gather_tp);
- node.final_tp = helper.add(node.total_price, node.end_qc_tp);
- node.final_ratio = helper.mul(helper.div(node.end_gather_tp, node.final_tp, 4), 100);
- node.final_1_tp = helper.mul(node.unit_price, node.final_1_qty, decimal.tp);
- node.end_final_1_tp = helper.add(node.final_1_tp, node.end_qc_tp);
- node.final_1_ratio = helper.mul(helper.div(node.end_gather_tp, node.end_final_1_tp, 4), 100);
- node.due_final_tp = helper.add(node.total_price, node.due_qc_tp);
- }
- });
- }
- _checkFieldsExist(source, check) {
- for (const s of source) {
- if (check.indexOf(s) >= 0) {
- return true;
- }
- }
- return false;
- }
- _checkFieldsExistReg(source, regStr) {
- const reg = new RegExp(regStr, 'igm');
- for (const s of source) {
- if (reg.test(s)) {
- return true;
- }
- }
- return false;
- }
- // build-time: 162-384ms, redis-cache: 0-41ms, mysql + IO: 116-146ms
- // 一定程度上算是大Value缓存,数据多了以后:
- // 1. 达到redis内存阈值时,数据会swap到磁盘,此时将消耗IO时间
- // 2. redis单独服务器
- // 3. redis集群
- async _getReportMemoryCache(name, tid, sid, time, version = '') {
- // redis
- const cacheKey = name + '-t' + tid + (sid ? '-s' + sid : '') + (time ? '-' + time : '') + version;
- const data = await this.cache.get(cacheKey);
- if (data) {
- return eval(data);
- } else {
- return null;
- }
- // mysql + IO
- // const rm = await this.getDataByCondition({
- // tid: tid, sid: sid, name: name, time: time
- // });
- // if (rm && rm.file) {
- // const file = path.join(this.ctx.app.config.filePath, 'report', 'cache', rm.file);
- // if (fs.existsSync(file)) {
- // const data = await fs.readFileSync(file, 'utf8');
- // return eval(data);
- // } else {
- // return null;
- // }
- // }
- }
- async _setReportMemoryCache(name, tid, sid, time, data, version = '') {
- // redis
- const cacheKey = name + '-t' + tid + (sid ? '-s' + sid : '') + (time ? '-' + time : '') + version;
- this.cache.set(cacheKey, JSON.stringify(data), 'EX', this.ctx.app.config.cacheTime);
- // mysql + IO
- // const file = path.join('report', 'cache', 'rm' + (new Date()).getTime() + '.json');
- // await this.ctx.helper.saveBufferFile(JSON.stringify(data), path.join(this.ctx.app.config.filePath, file));
- // const rm = await this.getDataByCondition({
- // tid: tid, sid: sid, name: name, time: time
- // });
- // if (rm) {
- // await this.db.update(this.tableName, {id: rm.id, file: file});
- // } else {
- // await this.db.insert(this.tableName, {tid: tid, sid: sid, name: name, time: time, file: file});
- // }
- }
- async _loadImAuditorAssistData(stageIm) {
- const auditorGroups = JSON.parse(JSON.stringify(this.ctx.stage.userGroups));
- auditorGroups.forEach(group => {
- group.forEach(auditor => {
- auditor.ass_ledger_id = auditor.ass_ledger_id ? auditor.ass_ledger_id.split(',') : [];
- });
- });
- for (const im of stageIm.ImData) {
- const relas = [];
- const bills = stageIm.getRelaBills(im);
- if (!bills) continue;
- const relaIds = bills ? bills.full_path.split('-').reverse() : [];
- for (const [i, group] of auditorGroups.entries()) {
- if (group[0].audit_type === auditConst.auditType.key.union) {
- const auditors = group.filter(x => {
- for (const id of relaIds) {
- if (x.ass_ledger_id.indexOf(id + '') >= 0) return true;
- }
- return false;
- });
- relas.push(auditors.map(x => { return x.aid; }).join(','));
- } else {
- relas.push(group.map(x => { return x.aid; }).join(','));
- }
- }
- im.users = relas.join(';');
- }
- }
- async _generateStageIm(tid, sid, isTz = true) {
- if (isTz && [imType.tz.value, imType.bb.value].indexOf(this.ctx.stage.im_type) === -1) {
- throw '您查看的报表跟设置不符,请查看“总量控制”的报表';
- } else if (!isTz && [imType.zl.value, imType.bw.value].indexOf(this.ctx.stage.im_type) === -1) {
- throw '您查看的报表跟设置不符,请查看“0号台账”的报表';
- }
- const stageIm = new StageIm(this.ctx);
- await stageIm.buildImData();
- // await this._loadImAuditorAssistData(stageIm);
- this.stageImData.main = stageIm.ImData;
- if (isTz) {
- this.stageImData.bills = stageIm.ImBillsData;
- await this._setReportMemoryCache(stageImTz, tid, sid, this.ctx.stage.cacheTime, this.stageImData.main, stageImVersion);
- await this._setReportMemoryCache(stageImTzBills, tid, sid, this.ctx.stage.cacheTime, this.stageImData.bills, stageImVersion);
- } else {
- await this._setReportMemoryCache(stageImZl, tid, sid, this.ctx.stage.cacheTime, this.stageImData.main, stageImVersion);
- }
- }
- async getStageImTzData(tid, sid, fields, readCache = true) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- if (readCache) {
- const cache = await this._getReportMemoryCache('mem_stage_im_tz', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
- if (cache) return cache;
- }
- if (!this.stageImData) {
- this.stageImData = {};
- try {
- await this._generateStageIm(tid, sid);
- } catch (err) {
- if (err.stack) {
- this.ctx.logger.error(err);
- }
- this.stageImData.main = err.stack ? '数据错误' : err;
- this.stageImData.bills = this.stageImData.main;
- }
- }
- return this.stageImData.main;
- } catch (err) {
- return [];
- }
- }
- async getStageImTzBillsData(tid, sid, fields, readCache = true) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- if (readCache) {
- const cache = await this._getReportMemoryCache('mem_stage_im_tz_bills', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
- if (cache) return cache;
- }
- if (!this.stageImData) {
- this.stageImData = {};
- try {
- await this._generateStageIm(tid, sid);
- } catch (err) {
- if (err.stack) {
- this.ctx.logger.error(err);
- }
- this.stageImData.main = err.stack ? '数据错误' : err;
- this.stageImData.bills = this.stageImData.main;
- }
- }
- return this.stageImData.bills;
- } catch (err) {
- return [];
- }
- }
- async getStageImZlData(tid, sid, fields, readCache = true) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- if (readCache) {
- const cache = await this._getReportMemoryCache('mem_stage_im_zl', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
- if (cache) return cache;
- }
- this.stageImData = {};
- try {
- await this._generateStageIm(tid, sid, false);
- } catch (err) {
- if (err.stack) {
- this.ctx.logger.error(err);
- }
- this.stageImData.main = err.statck ? '数据错误' : err;
- }
- return this.stageImData.main;
- } catch (err) {
- return [];
- }
- }
- async getMonthProgress(tid, fields) {
- const helper = this.ctx.helper;
- await this.ctx.service.tender.checkTender(tid);
- const tender = this.ctx.tender;
- const stages = await this.ctx.service.stage.getValidStages(tender.id);
- const lastStage = stages.length > 0 ? stages[0] : null;
- if (lastStage) {
- await this.ctx.service.stage.checkStageGatherData(lastStage, this.ctx.session.sessionUser.is_admin);
- tender.gather_tp = helper.add(lastStage.contract_tp, lastStage.qc_tp);
- tender.end_contract_tp = helper.add(lastStage.contract_tp, lastStage.pre_contract_tp);
- tender.end_qc_tp = helper.add(lastStage.qc_tp, lastStage.pre_qc_tp);
- tender.end_gather_tp = helper.add(tender.end_contract_tp, tender.end_qc_tp);
- tender.pre_gather_tp = helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
- tender.yf_tp = lastStage.yf_tp;
- tender.qc_ratio = helper.mul(helper.div(tender.end_qc_tp, tender.info.deal_param.contractPrice, 2), 100);
- tender.sum = helper.add(tender.total_price, tender.end_qc_tp);
- tender.pre_ratio = helper.mul(helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
- tender.cur_ratio = helper.mul(helper.div(tender.gather_tp, tender.sum, 2), 100);
- tender.other_tp = helper.sub(helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
- tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
- }
- const monthProgress = [];
- for (const s of stages) {
- if (s.s_time) {
- let progress = monthProgress.find(function (x) {
- return x.month === s.s_time;
- });
- if (!progress) {
- progress = {month: s.s_time};
- monthProgress.push(progress);
- }
- progress.tp = helper.add(helper.add(progress.tp, s.contract_tp), s.qc_tp);
- }
- }
- monthProgress.sort(function (x, y) {
- return Date.parse(x.month) - Date.parse(y.month);
- });
- let sum = 0;
- for (const p of monthProgress) {
- p.ratio = helper.mul(helper.div(p.tp, tender.sum, 4), 100);
- sum = helper.add(sum, p.tp);
- p.end_tp = sum;
- p.end_ratio = helper.mul(helper.div(p.end_tp, tender.sum, 4), 100);
- }
- return monthProgress;
- }
- async _calcBillsBgl(billsTree) {
- if (!this.ctx.stage) return;
- const helper = this.ctx.helper;
- const tender = this.ctx.tender;
- const stage = this.ctx.stage;
- const bglData = this.ctx.stage.readOnly
- ? await this.ctx.service.stageChange.getAuditorAllStageData(tender.id, stage.id, stage.curTimes, stage.curOrder)
- : await this.ctx.service.stageChange.getLastestAllStageData(tender.id, stage.id);
- for (const node of billsTree.nodes) {
- node.qc_bgl_code = '';
- node.qc_bgl_arr = [];
- if (node.children && node.children.length > 0) continue;
- const nodeBgl = helper._.filter(bglData, {lid: node.id});
- if (nodeBgl.length === 0) continue;
- helper._.pullAll(bglData, nodeBgl);
- const validBgl = helper._.filter(nodeBgl, function (x) {
- return !helper.checkZero(x.qty);
- });
- node.qc_bgl_arr = helper._.uniq(helper._.map(validBgl, 'c_code'));
- node.qc_bgl_code = node.qc_bgl_arr.join(';');
- }
- }
- async _calcBillsEndBgl(billsTree) {
- if (!this.ctx.stage) return;
- const helper = this.ctx.helper;
- const tender = this.ctx.tender;
- const stage = this.ctx.stage;
- const preBglData = stage.preCheckedStage ? await this.ctx.service.stageChangeFinal.getFinalChangeBills(tender.id, stage.preCheckedStage.order) : [];
- for (const node of billsTree.nodes) {
- node.pre_qc_bgl_code = '';
- node.pre_qc_bgl_arr = [];
- if (node.children && node.children.length > 0) continue;
- if (preBglData.length === 0) continue;
- const nodePreBgl = helper._.filter(preBglData, {lid: node.id});
- if (nodePreBgl.length === 0) continue;
- helper._.pullAll(preBglData, nodePreBgl);
- const validBgl = helper._.filter(nodePreBgl, function(x) {
- return !helper.checkZero(x.qty);
- });
- node.pre_qc_bgl_arr = helper._.uniq(helper._.map(validBgl, 'c_code'));
- node.pre_qc_bgl_code = node.pre_qc_bgl_arr.join(';');
- }
- for (const node of billsTree.nodes) {
- node.end_qc_bgl_arr = helper._.uniq(node.pre_qc_bgl_arr.concat(node.qc_bgl_arr));
- node.end_qc_bgl_code = node.end_qc_bgl_arr.join(';');
- }
- }
- _calcLeafXmjRela(billsTree) {
- for (const node of billsTree.nodes) {
- if (node.b_code) {
- const leafXmj = billsTree.getLeafXmjParent(node);
- node.leaf_xmj_id = leafXmj ? leafXmj.id : -1;
- }
- }
- }
- async _getValidStages(tenderId) {
- const stages = await this.db.select(this.ctx.service.stage.tableName, {
- where: { tid: tenderId },
- orders: [['order', 'desc']],
- });
- if (stages.length !== 0) {
- const lastStage = stages[0];
- if (lastStage.status === auditConst.stage.status.uncheck && lastStage.user_id !== this.ctx.session.sessionUser.accountId) {
- stages.splice(0, 1);
- }
- }
- return stages;
- }
- async _getTimeZoneStages(tender, zone) {
- const times = zone.split(' - ');
- if (times.length !== 2) throw '选择的汇总周期无效';
- const beginTime = moment(times[0], 'YYYY-MM');
- const endTime = moment(times[1], 'YYYY-MM');
- const stages = await this._getValidStages(tender.id), validStages = [];
- for (const stage of stages) {
- const sTime = moment(stage.s_time, 'YYYY-MM');
- if (sTime.isBetween(beginTime, endTime, null, '[]')) {
- validStages.push(stage);
- }
- }
- return validStages;
- }
- async _gatherStageBills(tender, stages) {
- let billsIndexData = {};
- const helper = this.ctx.helper;
- const sumAssignRelaData = function (index, rela) {
- const loadFields = function (datas, fields, prefix, relaId) {
- for (const d of datas) {
- if (!index[d[relaId]]) index[d[relaId]] = {};
- const m = index[d[relaId]];
- m[relaId] = d[relaId];
- if (m) {
- for (const f of fields) {
- if (d[f] !== undefined) {
- m[prefix + f] = helper.add(m[prefix + f], d[f]);
- }
- }
- }
- }
- };
- for (const r of rela) {
- loadFields(r.data, r.fields, r.prefix, r.relaId);
- }
- };
- for (const stage of stages) {
- await this.ctx.service.stage.doCheckStage(stage);
- const curStage = stage.readOnly
- ? await this.ctx.service.stageBills.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
- : await this.ctx.service.stageBills.getLastestStageData2(tender.id, stage.id);
- const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
- sumAssignRelaData(billsIndexData, [
- { data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: '', relaId: 'lid' },
- { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
- ]);
- }
- const result = [];
- for (const prop in billsIndexData) {
- const yearStageBills = billsIndexData[prop];
- yearStageBills.gather_qty = helper.add(yearStageBills.contract_qty, yearStageBills.qc_qty);
- yearStageBills.gather_tp = helper.sum([yearStageBills.contract_tp, yearStageBills.qc_tp, yearStageBills.pc_tp]);
- result.push(yearStageBills);
- }
- return result;
- };
- async _loadStageBillsZone(tender, zone){
- const stages = await this._getTimeZoneStages(tender, zone);
- return await this._gatherStageBills(tender, stages);
- }
- async _loadStageBillsYear(tender, year) {
- return await this._loadStageBillsZone(tender, `${year}-01 - ${year}-12`);
- }
- async getStageBillsData(tid, sid, fields, showLevel) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- if (sid) {
- await this.ctx.service.stage.checkStage(sid);
- }
- const billsData = this.ctx.stage.ledgerHis
- ? await this.ctx.helper.loadLedgerDataFromOss(this.ctx.stage.ledgerHis.bills_file)
- : await this.ctx.service.ledger.getData(this.ctx.tender.id);
- const memoData = this.ctx.stage.ledgerHis ? await this.ctx.service.ledger.getAllDataByCondition({ columns: ['id', 'memo'], where: { tender_id: this.ctx.tender.id } }) : [];
- if (this._checkFieldsExist(fields, billsFields.stageDgn)) {
- const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(this.ctx.tender.id);
- for (const d of dgnData) {
- const l = this.ctx.helper._.find(billsData, {id: d.id});
- this.ctx.helper._.assignIn(l, d);
- }
- }
- let preStage = [], curStage = [];
- if (this._checkFieldsExist(fields, billsFields.stage)) {
- if (this.ctx.stage.readOnly) {
- curStage = await this.ctx.service.stageBills.getAuditorStageData2(this.ctx.tender.id,
- this.ctx.stage.id, this.ctx.stage.curTimes, this.ctx.stage.curOrder);
- } else {
- curStage = await this.ctx.service.stageBills.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id);
- }
- }
- if (this._checkFieldsExist(fields, billsFields.stageEnd)) {
- preStage = this.ctx.stage.preCheckedStage ? await this.ctx.service.stageBillsFinal.getFinalData(this.ctx.tender, this.ctx.stage.preCheckedStage.order) : [];
- }
- const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: this.ctx.stage.id } });
- const endBpcStage = await this.ctx.service.stageBillsPc.getEndStageData(this.ctx.stage);
- const yearStage = this._checkFieldsExistReg(fields, 'year_') && this.ctx.stage.s_time
- ? await this._loadStageBillsYear(this.ctx.tender, this.ctx.stage.s_time.split('-')[0])
- : [];
- const changeData = this._checkFieldsExistReg(fields, 'due_')
- ? await this.ctx.service.changeAuditList.getBillsSum(this.ctx.tender.id)
- : [];
- this.ctx.helper.assignRelaData(billsData, [
- { data: memoData, fields: ['memo'], prefix: '', relaId: 'id' },
- { data: curStage, fields: ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp', 'qc_minus_qty', 'postil'], prefix: '', relaId: 'lid' },
- { data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'pre_', relaId: 'lid' },
- { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'org_price'], prefix: '', relaId: 'lid' },
- { data: endBpcStage, fields: ['end_contract_pc_tp', 'end_qc_pc_tp', 'end_pc_tp', 'org_price_his'], prefix: '', relaId: 'lid' },
- { 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' },
- { data: changeData, fields: ['qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'due_', relaId: 'gcl_id' },
- ]);
- billsData.forEach(x => {
- if (x.org_price_his && x.org_price_his.length > 0) {
- for (const prop of x.org_price_his) {
- x[`org_price_${prop}`] = x.org_price_his[prop];
- }
- } else {
- x.org_price_0 = x.unit_price;
- }
- });
- const billsTree = this._getNewBillsTree();
- billsTree.loadDatas(billsData);
- billsTree.calculateAll();
- if (this._checkFieldsExist(fields, billsFields.bgl)) {
- await this._calcBillsBgl(billsTree);
- if (this._checkFieldsExist(fields, billsFields.endBgl)) await this._calcBillsEndBgl(billsTree)
- }
- if (this._checkFieldsExist(fields, billsFields.leafXmj)) {
- this._calcLeafXmjRela(billsTree);
- }
- return showLevel ? billsTree.getDefaultDatasByLevel(this.ctx.tender.rpt_show_level) : billsTree.getDefaultDatas();
- } catch(err) {
- this.ctx.log(err);
- return [];
- }
- }
- async _calcPosBgl() {
- if (!this.ctx.stage) return;
- const helper = this.ctx.helper;
- const tender = this.ctx.tender;
- const stage = this.ctx.stage;
- const bglData = this.ctx.stage.readOnly
- ? await this.ctx.service.stageChange.getAuditorAllStageData(tender.id, stage.id, stage.curTimes, stage.curOrder)
- : await this.ctx.service.stageChange.getLastestAllStageData(tender.id, stage.id);
- for (const p of this.pos.datas) {
- p.qc_bgl_code = '';
- const pBgl = helper._.filter(bglData, {lid: p.lid, pid: p.id});
- if (pBgl.length === 0) continue;
- helper._.pullAll(bglData, pBgl);
- const validBgl = helper._.filter(pBgl, function (x) {
- return !helper.checkZero(x.qty);
- });
- p.qc_bgl_code = helper._.uniq(helper._.map(validBgl, 'c_code')).join(';');
- }
- }
- async getStagePosData(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- if (sid) {
- await this.ctx.service.stage.checkStage(sid);
- }
- const posData = await this.ctx.service.pos.getAllDataByCondition({ where: {tid: this.ctx.tender.id }});
- let curPosStage = [], prePosStage = [];
- if (this._checkFieldsExist(fields, posFields.stage)) {
- if (this.ctx.stage.readOnly) {
- curPosStage = await this.ctx.service.stagePos.getAuditorStageData2(this.ctx.tender.id,
- this.ctx.stage.id, this.ctx.stage.curTimes, this.ctx.stage.curOrder);
- } else {
- curPosStage = await this.ctx.service.stagePos.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id);
- }
- }
- if (this._checkFieldsExist(fields, posFields.stageEnd)) {
- prePosStage = this.ctx.stage.preCheckedStage ? await this.ctx.service.stagePosFinal.getFinalData(this.ctx.tender, this.ctx.stage.preCheckedStage.order) : [];
- }
- const changeData = this._checkFieldsExistReg(fields, 'due_')
- ? await this.ctx.service.changeAuditList.getPosSum(this.ctx.tender.id)
- : [];
- this.ctx.helper.assignRelaData(posData, [
- {data: curPosStage, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty', 'contract_expr', 'postil'], prefix: '', relaId: 'pid'},
- {data: prePosStage, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty'], prefix: 'pre_', relaId: 'pid'},
- {data: changeData, fields: ['qc_qty', 'qc_minus_qty'], prefix: 'due_', relaId: 'mx_id'},
- ]);
- this.pos.loadDatas(posData);
- this.pos.calculateAll();
- if (this._checkFieldsExist(fields, posFields.bgl)) {
- await this._calcPosBgl();
- }
- return this.pos.getDatas();
- } catch (err) {
- return [];
- }
- }
- _getStageValidRole () {
- if (!this.ctx.stage) throw '期数据错误,请重试';
- if (this.stageValidRole && this.stageValidRole.length > 0) return;
- const result = [{dataOrder: 0, flowOrder: 0, uid: this.ctx.stage.user_id, audit_type: 0}];
- for (const auditorGroup of this.ctx.stage.auditorGroups) {
- const hasChecked = auditorGroup.find(x => { return x.status === audit.stage.status.checked });
- 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 });
- const isCur = auditorGroup.find(x => { return x.status === audit.stage.status.checking}) && (!this.ctx.stage.readOnly || this.ctx.stage.canCheck);
- if ((hasChecked && !hasOtherStatus) || isCur) {
- const uid = auditorGroup.map(x => { return x.aid }).sort((x, y) => { return x - y; });
- const role = result.find(function (r) {
- return r.uid === uid.join(',') && r.audit_type === auditorGroup[0].audit_type;
- });
- if (role) {
- role.dataOrder = auditorGroup[0].order;
- } else {
- result.push({
- dataOrder: auditorGroup[0].order,
- flowOrder: auditorGroup[0].audit_order,
- uid: uid.join(','),
- audit_type: auditorGroup.audit_type,
- })
- }
- }
- }
- this.stageValidRole = result;
- };
- async getStageBillsCompareData(tid, sid, fields, showLevel) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- await this._getStageValidRole();
- const stage = this.ctx.stage, helper = this.ctx.helper;
- const validRole = this.stageValidRole;
- const billsData = this.ctx.stage.ledgerHis
- ? await this.ctx.helper.loadLedgerDataFromOss(this.ctx.stage.ledgerHis.bills_file)
- : await this.ctx.service.ledger.getData(this.ctx.tender.id);
- const memoData = this.ctx.stage.ledgerHis ? await this.ctx.service.ledger.getAllDataByCondition({ columns: ['id', 'memo'], where: { tender_id: this.ctx.tender.id } }) : [];
- const allStageBills = await this.ctx.service.stageBills.getAllDataByCondition({where: {sid: sid}});
- const stageBillsIndex = {}, timesLen = 100;
- for (const role of validRole) {
- const stageBills = this.ctx.helper._.filter(allStageBills, function (x) {
- return x.times < stage.curTimes || (x.times === stage.curTimes && x.order <= role.dataOrder);
- });
- this.ctx.helper._.pullAll(allStageBills, stageBills);
- for (const sb of stageBills) {
- const key = 'sb-' + sb.lid;
- const sbi = stageBillsIndex[key];
- if (sbi) {
- if ((sbi.times * timesLen + sbi.order) < (sb.times * timesLen + sb.order)) stageBillsIndex[key] = sb;
- } else {
- stageBillsIndex[key] = sb;
- }
- }
- const filterStageBills = [];
- for (const prop in stageBillsIndex) {
- filterStageBills.push(stageBillsIndex[prop]);
- }
- this.ctx.helper.assignRelaData(billsData, [
- {data: filterStageBills, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'r' + role.flowOrder + '_', relaId: 'lid'}
- ]);
- }
- const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: this.ctx.stage.id } });
- const endBpcStage = await this.ctx.service.stageBillsPc.getEndStageData(this.ctx.stage);
- const preStage = this._checkFieldsExist(fields, billsFields.stageEnd) && this.ctx.stage.preCheckedStage
- ? await this.ctx.service.stageBillsFinal.getFinalData(this.ctx.tender, this.ctx.stage.preCheckedStage.order)
- : [];
- this.ctx.helper.assignRelaData(billsData, [
- { data: memoData, fields: ['memo'], prefix: '', relaId: 'id' },
- { data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'pre_', relaId: 'lid'},
- { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'org_price'], prefix: '', relaId: 'lid' },
- { data: endBpcStage, fields: ['end_contract_pc_tp', 'end_qc_pc_tp', 'end_pc_tp', 'org_price_his'], prefix: '', relaId: 'lid' },
- ]);
- billsData.forEach(x => {
- if (x.org_price_his && x.org_price_his.length > 0) {
- for (const prop of x.org_price_his) {
- x[`org_price_${prop}`] = x.org_price_his[prop];
- }
- } else {
- x.org_price_0 = x.unit_price;
- }
- });
- const billsTree = this._getNewBillsTree();
- billsTree.loadDatas(billsData);
- for (const role of validRole) {
- const prefix = 'r' + role.flowOrder + '_';
- billsTree.setting.calcFields.push(prefix + 'contract_tp', prefix + 'qc_tp', prefix + 'gather_tp');
- }
- billsTree.calculateAll(function(node) {
- let prefix = '';
- if (node.children && node.children.length === 0) {
- node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
- for (const role of validRole) {
- prefix = 'r' + role.flowOrder + '_';
- node[prefix + 'gather_qty'] = helper.add(node[prefix + 'contract_qty'], node[prefix + 'qc_qty']);
- }
- }
- node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
- for (const role of validRole) {
- prefix = 'r' + role.flowOrder + '_';
- node[prefix + 'gather_tp'] = helper.sum([node[prefix + 'contract_tp'], node[prefix + 'qc_tp'], node.pc_tp]);
- }
- });
- if (this._checkFieldsExist(fields, billsFields.leafXmj)) {
- this._calcLeafXmjRela(billsTree);
- }
- return showLevel ? billsTree.getDefaultDatasByLevel(this.ctx.tender.rpt_show_level) : billsTree.getDefaultDatas();
- } catch (err) {
- return [];
- }
- }
- async getStagePosCompareData(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- await this._getStageValidRole();
- const stage = this.ctx.stage, helper = this.ctx.helper;
- const validRole = this.stageValidRole;
- const allStagePos = await this.ctx.service.stagePos.getAllDataByCondition({where: {sid: sid}});
- const posData = await this.ctx.service.pos.getAllDataByCondition({ where: {tid: this.ctx.tender.id }});
- const prePosStage = this.ctx.stage.preCheckedStage ? await this.ctx.service.stagePosFinal.getFinalData(this.ctx.tender, this.ctx.stage.preCheckedStage.order) : [];
- this.ctx.helper.assignRelaData(posData, [
- {data: prePosStage, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty'], prefix: 'pre_', relaId: 'pid'}
- ]);
- const stagePosIndex = {}, timesLen = 100;
- for (const role of validRole) {
- const stagePos = this.ctx.helper._.filter(allStagePos, function (x) {
- return x.times < stage.curTimes || (x.times === stage.curTimes && x.order <= role.dataOrder);
- });
- this.ctx.helper._.pullAll(allStagePos, stagePos);
- for (const sp of stagePos) {
- const key = 'sp-' + sp.pid;
- const spi = stagePosIndex[key];
- if (spi) {
- if ((spi.times * timesLen + spi.order) < (sp.times * timesLen + sp.order)) stagePosIndex[key] = sp;
- } else {
- stagePosIndex[key] = sp;
- }
- }
- const filterStagePos = [];
- for (const prop in stagePosIndex) {
- filterStagePos.push(stagePosIndex[prop]);
- }
- this.ctx.helper.assignRelaData(posData, [
- {data: filterStagePos, fields: ['contract_qty', 'qc_qty', 'qc_minus_qty'], prefix: 'r' + role.flowOrder + '_', relaId: 'pid'}
- ]);
- }
- this.pos.loadDatas(posData);
- this.pos.calculateAll(function (p) {
- p.pre_gather_qty = helper.add(p.pre_contract_qty, p.pre_qc_qty);
- for (const role of validRole) {
- const prefix = 'r' + role.flowOrder + '_';
- p[prefix + 'gather_qty'] = helper.add(p[prefix + 'contract_qty'], p[prefix + 'qc_qty']);
- }
- });
- return this.pos.getDatas();
- } catch (err) {
- return [];
- }
- }
- async getStagePayData(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const stage = this.ctx.stage;
- const dealPay = await this.ctx.service.stagePay.getStagePays(this.ctx.stage);
- if (!this.ctx.stage.readOnly) {
- // 计算 本期金额
- const PayCalculator = require('../lib/pay_calc');
- const payCalculator = new PayCalculator(this.ctx, this.ctx.stage, this.ctx.tender.info);
- await payCalculator.calculateAll(dealPay);
- }
- if (this._checkFieldsExist(fields, ['start_stage_order']) && this.ctx.stage.status !== audit.stage.status.checked) {
- for (const dp of dealPay) {
- if (!dp.start_stage_order || dp.start_stage_order === this.ctx.stage.order) {
- dp.start_stage_order = this.ctx.helper.checkZero(dp.tp) ? null : this.ctx.stage.order;
- }
- }
- }
- if (this._checkFieldsExistReg(fields, 'r[0-9]+_tp')) {
- this._getStageValidRole();
- const allStagePays = await this.ctx.service.stagePay.getAllDataByCondition({
- where: {sid: stage.id, stimes: stage.curTimes}
- });
- for (const [i, role] of this.stageValidRole.entries()) {
- if (i < this.stageValidRole.length - 1) {
- const stagePays = this.ctx.helper._.filter(allStagePays, function (x) {
- return x.stimes === stage.curTimes && x.sorder === role.dataOrder;
- });
- this.ctx.helper._.pullAll(allStagePays, stagePays);
- for (const sp of stagePays) {
- const dp = dealPay.find(function (x) {return x.pid === sp.pid});
- if (dp) {
- dp['r' + role.flowOrder + '_tp'] = sp.tp;
- }
- }
- } else {
- for (const dp of dealPay) {
- dp['r' + role.flowOrder + '_tp'] = dp.tp;
- }
- }
- }
- }
- return dealPay;
- } catch (err) {
- return [];
- }
- }
- async getStageChangeBillsData(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- if (this.ctx.stage.readOnly) {
- return await this.ctx.service.stageChange.getReportAuditorAllStageData(tid, sid,
- this.ctx.stage.curTimes, this.ctx.stage.curOrder);
- } else {
- return await this.ctx.service.stageChange.getReportLastestAllStageData(tid, sid);
- }
- } catch (err) {
- return [];
- }
- }
- _getChangeConstName(define, value) {
- for (const prop in define) {
- if (define[prop].value === value) {
- return define[prop].name;
- }
- }
- return '';
- }
- async _generateChange(tid) {
- if (this.changeData !== null) return;
- const self = this;
- try {
- const decimal = this.ctx.tender.info.decimal, ctx = this.ctx;
- const where = { tid, valid: 1 };
- if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = audit.flow.status.checked;
- const change = await this.ctx.service.change.getAllDataByCondition({ where, orders: [['code', 'asc']] });
- for (const c of change) {
- const types = ctx.helper._.map(c.type.split(','), function (t) {
- return self._getChangeConstName(changeConst.type, ctx.helper._.toInteger(t));
- });
- c.type = types.join(';');
- c.class = this._getChangeConstName(changeConst.class, c.class);
- c.quality = this._getChangeConstName(changeConst.quality, c.quality);
- c.charge = this._getChangeConstName(changeConst.charge, c.charge);
- c.attachments = await ctx.service.changeAtt.getChangeAttachment(c.cid);
- const names = ctx.helper._.map(c.attachments, function (x) {
- return x.filename + x.fileext;
- });
- c.attNames = names.join('\n');
- }
- const changeBills = await this.ctx.service.changeAuditList.getChangeAuditBills(tid, this.ctx.session.sessionProject.page_show.isOnlyChecked);
- for (const d of changeBills) {
- d.o_qty = d.oamount;
- d.o_tp = this.ctx.helper.mul(d.o_qty, d.unit_price, decimal.tp);
- d.o_qty2 = d.oamount2;
- d.o_tp2 = this.ctx.helper.mul(d.o_qty2, d.unit_price, decimal.tp);
- d.c_qty = d.camount;
- d.c_tp = this.ctx.helper.mul(d.c_qty, d.unit_price, decimal.tp);
- d.s_qty = d.samount ? parseFloat(d.samount) : 0;
- d.s_tp = this.ctx.helper.mul(d.s_qty, d.unit_price, decimal.tp);
- d.sp_qty = d.spamount;
- d.sp_tp = this.ctx.helper.mul(d.sp_qty, d.unit_price, decimal.tp);
- const auditAmount = d.audit_amount ? d.audit_amount.split(',') : [];
- const relaChange = ctx.helper._.find(change, {cid: d.cid});
- for (const [i, aa] of auditAmount.entries()) {
- const amountField = 'qty_' + (i+1), tpField = 'tp_' + (i+1);
- d[amountField] = aa ? parseFloat(aa) : 0;
- d[tpField] = ctx.helper.mul(d[amountField], d.unit_price, decimal.tp);
- if (relaChange) {
- relaChange[tpField] = ctx.helper.add(relaChange[tpField], d[tpField]);
- }
- }
- }
- changeBills.sort(function (a, b) {
- const aCIndex = change.findIndex(function (c) {
- return c.cid === a.cid;
- });
- const bCIndex = change.findIndex(function (c) {
- return c.cid === b.cid;
- });
- return aCIndex === bCIndex
- ? ctx.helper.compareCode(a.code, b.code)
- : aCIndex - bCIndex;
- });
- this.changeData = {change: change, bills: changeBills};
- } catch(err) {
- this.ctx.helper.log(err);
- throw err;
- this.changeData = {change: [], bills: []};
- }
- }
- async _generateChangeAudit() {
- if (!!this.changeData.audit) return;
- this.changeData.audit = [];
- for (const c of this.changeData.change) {
- const changeAudit = await this.ctx.service.changeAudit.getListGroupByTimes(c.cid, c.times);
- this.changeData.audit.push(...changeAudit);
- }
- }
- async getChangeData(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this._generateChange(tid);
- return this.changeData.change;
- } catch (err) {
- return [];
- }
- }
- async getChangeBillsData(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this._generateChange(tid);
- return this.changeData.bills;
- } catch (err) {
- return [];
- }
- }
- async getChangeAuditData(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this._generateChange(tid);
- await this._generateChangeAudit();
- return this.changeData.audit;
- } catch (err) {
- return [];
- }
- }
- async _generateImportChange(sid) {
- if (this.importChange !== undefined) return;
- const self = this;
- try {
- const ctx = this.ctx;
- const change = await this.ctx.service.stageImportChange.getImportChange(sid);
- for (const c of change) {
- const types = ctx.helper._.map(c.type.split(','), function (t) {
- return self._getChangeConstName(changeConst.type, ctx.helper._.toInteger(t));
- });
- c.type = types.join(';');
- c.class = this._getChangeConstName(changeConst.class, c.class);
- c.quality = this._getChangeConstName(changeConst.quality, c.quality);
- c.charge = this._getChangeConstName(changeConst.charge, c.charge);
- }
- change.sort(function (a, b) {
- return a.code.localeCompare(b.code);
- });
- const changeBills = [];
- for (const c of change) {
- const bills = await this.ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: c.cid } });
- for (const b of bills) {
- b.o_qty = b.oamount;
- d.o_qty2 = d.oamount2;
- b.c_qty = b.camount;
- b.s_qty = b.samount ? parseFloat(b.samount) : 0;
- b.sp_qty = b.spamount;
- }
- bills.sort(function (a, b) {
- return ctx.helper.compareCode(a.code, b.code);
- });
- changeBills.push(...bills);
- }
- this.importChange = {change: change, bills: changeBills};
- } catch(err) {
- this.ctx.helper.log(err);
- throw err;
- this.importChange = {change: [], bills: []};
- }
- }
- async getImportChangeData(tid, sid, fields) {
- try {
- await this._generateImportChange(sid);
- return this.importChange.change;
- } catch (err) {
- return [];
- }
- }
- async getImportChangeBillsData(tid, sid, fields) {
- try {
- await this._generateImportChange(sid);
- return this.importChange.bills;
- } catch (err) {
- return [];
- }
- }
- async _generateChangeApply(tid) {
- if (!!this.changeApplyData) return;
- const helper = this.ctx.helper;
- const decimal = this.ctx.tender.info.decimal;
- const where = { tid };
- if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = audit.changeApply.status.checked;
- const apply = await this.ctx.service.changeApply.getAllDataByCondition({ where });
- const bills = await this.ctx.service.changeApplyList.getChangeBills(tid, this.ctx.session.sessionProject.page_show.isOnlyChecked);
- bills.forEach(x => {
- const a = apply.find(y => { return y.id === x.caid });
- const a_decimal = a.decimal ? JSON.stringify(a.decimal) : { tp: decimal.tp, up: decimal.up };
- x.o_tp = helper.mul(x.oamount, x.unit_price, a_decimal.tp);
- x.c_tp = helper.mul(x.camount, x.unit_price, a_decimal.tp);
- });
- bills.sort(function(a, b ) {
- const aCIndex = apply.findIndex(function (c) {
- return c.id === a.caid;
- });
- const bCIndex = apply.findIndex(function (c) {
- return c.id === b.caid;
- });
- return aCIndex === bCIndex
- ? helper.compareCode(a.code, b.code)
- : aCIndex - bCIndex;
- });
- this.changeApplyData = { data: apply, bills };
- }
- async _generateChangeApplyAudit() {
- if (!!this.changeApplyData.audit) return;
- this.changeApplyData.audit = [];
- for (const c of this.changeApplyData.data) {
- const changeAudit = await this.ctx.service.changeApplyAudit.getAllDataByCondition({ where: { caid: c.id, times: c.times }});
- const changeAuditFilter = this.ctx.helper.filterLastestData(changeAudit, ['aid']);
- this.changeApplyData.audit.push(...changeAuditFilter);
- }
- }
- async getChangeApplyData(tid, sid, fields) {
- try {
- await this._generateChangeApply(tid);
- return this.changeApplyData.data;
- } catch (err) {
- return [];
- }
- }
- async getChangeApplyBillsData(tid, sid, fields) {
- try {
- await this._generateChangeApply(tid);
- return this.changeApplyData.bills;
- } catch (err) {
- return [];
- }
- }
- async getChangeApplyAuditData(tid, sid, fields) {
- try {
- await this._generateChangeApply(tid);
- await this._generateChangeApplyAudit();
- return this.changeApplyData.audit;
- } catch (err) {
- this.ctx.log(err);
- return [];
- }
- }
- async _generateChangePlan(tid) {
- if (!!this.changePlanData) return;
- const helper = this.ctx.helper;
- const decimal = this.ctx.tender.info.decimal;
- this.changePlanData = {};
- const where = { tid };
- if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = audit.changeApply.status.checked;
- const data = await this.ctx.service.changePlan.getAllDataByCondition({ where });
- const bills = await this.ctx.service.changePlanList.getChangeBills(tid, this.ctx.session.sessionProject.page_show.isOnlyChecked);
- bills.forEach(x => {
- const plan = data.find(y => { return y.id === x.cpid });
- const p_decimal = plan.decimal ? JSON.stringify(plan.decimal) : { tp: decimal.tp, up: decimal.up };
- x.o_tp = helper.mul(x.oamount, x.unit_price, p_decimal.tp);
- x.c_tp = helper.mul(x.camount, x.unit_price, p_decimal.tp);
- x.s_tp = helper.mul(x.samount, x.unit_price, p_decimal.tp);
- x.sp_tp = helper.mul(x.spamount, x.unit_price, p_decimal.tp);
- const auditAmount = x.audit_amount ? x.audit_amount.split(',') : [];
- for (const [i, aa] of auditAmount.entries()) {
- const amountField = 'qty_' + (i+1), tpField = 'tp_' + (i+1);
- x[amountField] = aa ? parseFloat(aa) : 0;
- x[tpField] = helper.mul(x[amountField], x.unit_price, p_decimal.tp);
- if (plan) {
- plan[tpField] = helper.add(plan[tpField], x[tpField]);
- }
- }
- });
- bills.sort(function(a, b ) {
- const aCIndex = data.findIndex(function (c) {
- return c.id === a.cpid;
- });
- const bCIndex = data.findIndex(function (c) {
- return c.id === b.cpid;
- });
- return aCIndex === bCIndex
- ? helper.compareCode(a.code, b.code)
- : aCIndex - bCIndex;
- });
- this.changePlanData = { data, bills };
- }
- async _generateChangePlanAudit() {
- if (!!this.changePlanData.audit) return;
- this.changePlanData.audit = [];
- for (const c of this.changePlanData.data) {
- const changeAudit = await this.ctx.service.changePlanAudit.getAllDataByCondition({ where: { cpid: c.id, times: c.times }});
- const changeAuditFilter = this.ctx.helper.filterLastestData(changeAudit, ['aid']);
- this.changePlanData.audit.push(...changeAuditFilter);
- }
- }
- async getChangePlanData(tid, sid, fields) {
- try {
- await this._generateChangePlan(tid);
- return this.changePlanData.data;
- } catch (err) {
- return [];
- }
- }
- async getChangePlanBillsData(tid, sid, fields) {
- try {
- await this._generateChangePlan(tid);
- return this.changePlanData.bills;
- } catch (err) {
- return [];
- }
- }
- async getChangePlanAuditData(tid, sid, fields) {
- try {
- await this._generateChangePlan(tid);
- await this._generateChangePlanAudit();
- return this.changePlanData.audit;
- } catch (err) {
- this.ctx.log(err);
- return [];
- }
- }
- async _generateChangeProject(tid) {
- if (!!this.changeProjectData) return;
- const where = { tid };
- if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = audit.changeProject.status.checked;
- this.changeProjectData = { data: await this.ctx.service.changeProject.getAllDataByCondition({ where }) };
- }
- async _generateChangeProjectAudit() {
- if (!!this.changeProjectData.audit) return;
- this.changeProjectData.audit = [];
- for (const c of this.changeProjectData.data) {
- const changeAudit = await this.ctx.service.changeProjectAudit.getAllDataByCondition({ where: { cpid: c.id, times: c.times }});
- const changeAuditFilter = this.ctx.helper.filterLastestData(changeAudit, ['aid']);
- this.changeProjectData.audit.push(...changeAuditFilter);
- }
- }
- async getChangeProjectData(tid, sid, fields) {
- try {
- await this._generateChangeProject(tid);
- return this.changeProjectData.data;
- } catch (err) {
- this.ctx.log(err);
- return [];
- }
- }
- async getChangeProjectAuditData(tid, sid, fields) {
- try {
- await this._generateChangeProject(tid);
- await this._generateChangeProjectAudit();
- return this.changeProjectData.audit;
- } catch (err) {
- return [];
- }
- }
- async getStageJgcl(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const data = await this.ctx.service.stageJgcl.getStageData(this.ctx.stage);
- const preData = await this.ctx.service.stageJgcl.getPreStageData(tid, this.ctx.stage.order);
- for (const d of data) {
- const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
- if (pd) {
- d.pre_arrive_qty = pd.arrive_qty;
- d.pre_arrive_tp = pd.arrive_tp;
- d.pre_deduct_qty = pd.deduct_qty;
- d.pre_deduct_tp = pd.deduct_tp;
- }
- d.end_arrive_qty = this.ctx.helper.add(d.pre_arrive_qty, d.arrive_qty);
- d.end_arrive_tp = this.ctx.helper.add(d.pre_arrive_tp, d.arrive_tp);
- d.end_deduct_qty = this.ctx.helper.add(d.pre_deduct_qty, d.deduct_qty);
- d.end_deduct_tp = this.ctx.helper.add(d.pre_deduct_tp, d.deduct_tp);
- }
- return data;
- } catch (err) {
- return [];
- }
- }
- async getStageYjcl(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const data = await this.ctx.service.stageYjcl.getStageData(this.ctx.stage);
- for (const d of data) {
- d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
- d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
- }
- return data;
- } catch (err) {
- return [];
- }
- }
- async getStageBonus(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const data = await this.ctx.service.stageBonus.getEndStageData(tid, this.ctx.stage.order);
- for (const d of data) {
- const names = this.ctx.helper._.map(d.proof_file, function (x) {
- return x.filename + x.fileext;
- });
- d.proof = names.join('\n');
- }
- return data;
- } catch (err) {
- return [];
- }
- }
- async getStageOther(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const data = await this.ctx.service.stageOther.getStageData(this.ctx.stage);
- const preData = await this.ctx.service.stageOther.getPreStageData(tid, this.ctx.stage.order);
- for (const d of data) {
- const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
- if (pd) {
- d.pre_tp = pd.tp;
- }
- d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
- }
- return data;
- } catch (err) {
- return [];
- }
- }
- async getStageSafeProd(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const data = await this.ctx.service.stageSafeProd.getStageData(this.ctx.stage);
- const preData = await this.ctx.service.stageSafeProd.getPreStageData(tid, this.ctx.stage.order);
- for (const d of data) {
- const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
- if (pd) {
- d.pre_qty = pd.qty;
- d.pre_tp = pd.tp;
- }
- d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
- d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
- }
- return data;
- } catch (err) {
- return [];
- }
- }
- async getStageTempLand(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const data = await this.ctx.service.stageTempLand.getStageData(this.ctx.stage);
- const preData = await this.ctx.service.stageTempLand.getPreStageData(tid, this.ctx.stage.order);
- for (const d of data) {
- const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
- if (pd) {
- d.pre_qty = pd.qty;
- d.pre_tp = pd.tp;
- }
- d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
- d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
- }
- return data;
- } catch (err) {
- return [];
- }
- }
- async getSumStageBillsData(tid, sid, fields) {
- try {
- await this.ctx.service.tender.checkTender(tid);
- const billsData = await this.ctx.service.ledger.getData(this.ctx.tender.id);
- const checkStageField = function (stageOrder) {
- for (const f of fields) {
- if (f.indexOf('s' + stageOrder + '_') >= 0) {
- return true;
- }
- }
- return false;
- };
- const calcFields = ['deal_tp', 'total_price'], calcPrefix = [];
- const stages = this.ctx.service.stage.getValidStages(this.ctx.tender.id);
- for (const stage of stages) {
- if (!checkStageField(stage.order)) return;
- await this.ctx.service.stage.doCheckStage(stage);
- calcFields.push('s' + stage.order + '_contract_tp');
- calcFields.push('s' + stage.order + '_qc_tp');
- calcFields.push('s' + stage.order + '_gather_tp');
- calcFields.push('s' + stage.order + '_');
- const curStage = stage.readOnly
- ? await this.ctx.service.stageBills.getAuditorStageData2(this.ctx.tender.id, stage.id, stage.curTimes, stage.curOrder)
- : await this.ctx.service.stageBills.getLastestStageData2(this.ctx.tender.id, stage.id);
- this.ctx.helper.assignRelaData(billsData, [
- {data: curStage, fields: ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp'], prefix: 's' + stage.order + '_', relaId: 'lid'}
- ]);
- }
- const billsTree = new Ledger.billsTree(this.ctx, {
- id: 'ledger_id',
- pid: 'ledger_pid',
- order: 'order',
- level: 'level',
- rootId: -1,
- keys: ['id', 'tender_id', 'ledger_id'],
- stageId: 'id',
- calcFields: calcFields,
- calc: function (node) {
- for (const prefix of calcPrefix) {
- if (node.children && node.children.length === 0) {
- node[prefix + 'gather_qty'] = self.ctx.helper.add(node[prefix + 'contract_qty'], node[prefix + 'qc_qty']);
- }
- node[prefix + 'gather_tp'] = self.ctx.helper.add(node[prefix + 'contract_tp'], node[prefix + 'qc_tp']);
- }
- }
- });
- billsTree.loadDatas(billsData);
- billsTree.calculateAll();
- return billsTree.getDefaultDatas();
- } catch (err) {
- return [];
- }
- }
- async getStageAuditors(tid, sid) {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const auditors = await this.ctx.service.stageAudit.getFinalAuditGroup(this.ctx.stage.id, this.ctx.stage.curTimes);
- const user = await this.ctx.service.projectAccount.getDataById(this.ctx.stage.user_id);
- const result = [{
- aid: user.id,
- name: user.name,
- company: user.company,
- role: user.role,
- mobile: user.mobile,
- telephone: user.telephone,
- sign_path: user.sign_path,
- opinion: user.opinion,
- end_time: auditors && auditors.length > 0 ? auditors[0].begin_time : null,
- sort: 0, order: 0, audit_order: 0
- }, ...auditors];
- return result;
- }
- async getSignSelect(tid, sid, customSelect) {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- const signSelect = customSelect.sign_select, result = {};
- for (const [i, ss] of signSelect.entries()) {
- const user = await this.ctx.service.projectAccount.getDataById(ss.id);
- const sign = {
- id: ss.id, name: user.name, company: user.company, role: user.role,
- mobile: user.mobile, telephone: user.telephone,
- };
- if (ss.id !== this.ctx.stage.user_id) {
- const audit = this.ctx.stage.auditors.find(x => {return x.aid === ss.id});
- user.end_time = audit ? audit.end_time : ss.audit_time;
- } else {
- user.end_time = this.ctx.stage.auditors[0].end_time;
- }
- if (user.end_time) sign.sign_path = user.sign_path;
- result['sign' + (i+1)] = sign;
- }
- return result;
- }
- async getStageAuditAss(tid, sid) {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- return await this.ctx.service.stageAuditAss.getReportData(this.ctx.stage.id, this.ctx.stage.times);
- }
- async getChangeInfo(tid, sid) {
- await this.ctx.service.tender.checkTender(tid);
- await this.ctx.service.stage.checkStage(sid);
- this.changeInfo = await this.ctx.service.stageChange.getChangeWithUsedInfo(this.ctx.stage);
- const usedChangesId = await this.ctx.service.stageChange.getStageUsedChangeId(sid);
- for (const c of this.changeInfo) {
- c.cur_used = usedChangesId.indexOf(c.cid) >= 0;
- c.used_ratio = c.used_pt;
- c.is_import = 0;
- }
- return this.changeInfo;
- }
- async getChangeInfoBills(tid, sid) {
- if (!this.changeInfo) await this.getChangeInfo(tid, sid);
- const helper = this.ctx.helper;
- this.changeInfoBills = [];
- for (const c of this.changeInfo) {
- const cb = await this.ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: c.cid } });
- cb.sort((a, b) => { return helper.compareCode(a.code, b.code)});
- const cbu = await this.ctx.service.stageChange.getUsedData(tid, c.cid);
- const curUsedBills = await this.ctx.service.stageChange.getStageUsedData(sid, c.cid);
- for (const b of cb) {
- b.o_qty = this.ctx.helper._.toNumber(b.oamount);
- b.o_tp = this.ctx.helper.round(this.ctx.helper.mul(b.o_qty, b.unit_price), this.ctx.tender.info.decimal.tp);
- b.qty = this.ctx.helper._.toNumber(b.samount);
- b.tp = this.ctx.helper.round(this.ctx.helper.mul(b.qty, b.unit_price), this.ctx.tender.info.decimal.tp);
- const u = cbu.filter(x => { return x.cbid === b.id; });
- b.used_qty = u.length > 0 ? this.ctx.helper.sum(u.map(x => { return x.qty})) : 0;
- b.valid_qty = this.ctx.helper.sub(b.qty, b.used_qty);
- const cur = this.ctx.helper._.filter(curUsedBills, { cbid: b.id });
- b.cur_qty = 0;
- for (const cc of cur) {
- b.cur_qty = this.ctx.helper.add(b.cur_qty, cc.qty);
- }
- b.cur_used = !!b.cur_qty;
- this.changeInfoBills.push(b);
- }
- }
- return this.changeInfoBills;
- }
- async getPmDeal() {
- let result = [];
- if (!PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission)) return result;
- let selects;
- if (!this.pmDeal) {
- selects = await this.ctx.service.project.getPmDealCache(this.ctx.session.sessionProject.id);
- const pm = require('../lib/pm');
- this.pmDeal = await pm.dealData(this.ctx, this.ctx.session.sessionProject.code, selects);
- }
- result = this.pmDeal.contracts ? this.pmDeal.contracts.filter(x => { return x.ContractsType === 2 }) : [];
- const fields = ['Code', 'Name', 'ContractName', 'ContractCode', 'ContractPrice', 'ContractReturned', 'ContractsPaid', 'ContractStatus', 'ContractLocking', 'CreateTime'], self = this;
- result.forEach(x => {
- const treeNode = self.pmDeal.tree_contracts.find(y => { return x.TreeId === y.Id });
- if (!treeNode) return;
- for (const f of fields) {
- x['Tree_' + f] = treeNode[f];
- }
- });
- // 排序:标段-合同类别-创建时间
- result.sort((x, y) => {
- const bidSort = selects.indexOf(x.BidsectionId + '') - selects.indexOf(y.BidsectionId + '');
- if (bidSort) return bidSort;
- const typeSort = x.ContractsType - y.ContractsType;
- if (typeSort) return typeSort;
- return x.create_time - y.create_time;
- });
- const helper = this.ctx.helper;
- result.forEach(x => {
- x.PaidPercent = x.Price ? helper.mul(helper.div(x.Paid, x.Price, 4), 100) : 0;
- x.Tree_PaidPercent = x.Tree_ContractPrice ? helper.mul(helper.div(x.Tree_ContractsPaid, x.Tree_ContractPrice, 4), 100) : 0;
- });
- return result;
- }
- async getPmDealTree() {
- const result = [];
- if (!PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission)) return result;
- if (!this.pmDeal) {
- const selects = await this.ctx.service.project.getPmDealCache(this.ctx.session.sessionProject.id);
- const pm = require('../lib/pm');
- this.pmDeal = await pm.dealData(this.ctx, this.ctx.session.sessionProject.code, selects);
- }
- for (const tc of this.pmDeal.tree_contracts) {
- tc.children = this.pmDeal.tree_contracts.filter(x => { return x.ParentId === tc.TreeId && x.TreeType === tc.TreeType});
- }
- const root = this.pmDeal.tree_contracts.filter(x => { return x.Depth === 0; });
- root.sort((x, y) => {
- const type = x.TreeType - y.TreeType;
- return type ? type : x.Serail - y.Serail;
- });
- const helper = this.ctx.helper;
- const sortSumChildren = function (children, data, fields) {
- if (!children || children.length === 0) return null;
- const sum = {};
- for (const c of children) {
- data.push(c);
- const cSum = sortSumChildren(c.children, data, fields);
- if (cSum) {
- for (const f of fields) {
- c[f] = cSum[f].toFixed(2);
- }
- }
- for (const f of fields) {
- sum[f] = helper.add(sum[f], parseFloat(c[f]));
- }
- }
- return sum;
- };
- sortSumChildren(root, result, ['ContractPrice', 'ContractReturned', 'ContractsPaid', 'ContractDeductionTotal']);
- result.forEach(x => {
- x.PaidPercent = x.ContractPrice ? helper.mul(helper.div(x.ContractsPaid, x.ContractPrice, 4), 100) : 0;
- delete x.children
- });
- return result;
- }
- }
- return ReportMemory;
- };
|