123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500 |
- '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'];
- const leafXmj = ['leaf_xmj_id'];
- return {cur, pre, end, final, final1, stageDgn, stage, stageEnd, bgl, leafXmj};
- })();
- 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);
- }
- });
- // 需要缓存的数据
- 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',
- ],
- 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.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);
- }
- });
- }
- _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 _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();
- 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 = '';
- 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_code = helper._.uniq(helper._.map(validBgl, 'c_code')).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.order > 1 ? await this.ctx.service.stageBillsFinal.getFinalData(this.ctx.tender, this.ctx.stage.order - 1) : [];
- }
- 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])
- : [];
- 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' },
- ]);
- 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.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.order > 1 ? await this.ctx.service.stagePosFinal.getFinalData(this.ctx.tender, this.ctx.stage.order - 1) : [];
- }
- 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'}
- ]);
- 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}];
- for (const auditor of this.ctx.stage.auditors) {
- if (auditor.status === audit.stage.status.checked ||
- (auditor.status === audit.stage.status.checking && !this.ctx.stage.readOnly)) {
- const role = result.find(function (r) {
- return r.uid === auditor.aid;
- });
- if (role) {
- role.dataOrder = auditor.order;
- } else {
- result.push({
- dataOrder: auditor.order,
- flowOrder: result.length,
- uid: auditor.aid
- })
- }
- }
- }
- 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.order > 1
- ? await this.ctx.service.stageBillsFinal.getFinalData(this.ctx.tender, this.ctx.stage.order - 1)
- : [];
- 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.order > 1 ? await this.ctx.service.stagePosFinal.getFinalData(this.ctx.tender, this.ctx.stage.order - 1) : [];
- 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: [['in_time', 'desc']] });
- 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.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]);
- }
- }
- }
- change.sort(function (a, b) {
- return a.code.localeCompare(b.code);
- });
- 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;
- 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 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,
- }, ...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);
- this.changeInfoBills = [];
- for (const c of this.changeInfo) {
- const cb = await this.ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: c.cid } });
- 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.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;
- 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);
- 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;
- });
- return result;
- }
- }
- return ReportMemory;
- };
|