123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158 |
- 'use strict';
- /**
- *
- *
- * @author Mai
- * @date
- * @version
- */
- const stdDataAddType = {
- withParent: 1,
- child: 2,
- next: 3,
- };
- const audit = require('../const/audit');
- const accountGroup = require('../const/account_group').group;
- const tenderMenu = require('../../config/menu').tenderMenu;
- const measureType = require('../const/tender').measureType;
- const shenpiConst = require('../const/shenpi');
- const LzString = require('lz-string');
- const stdConst = require('../const/standard');
- const spreadSetting = require('../lib/spread_setting');
- const path = require('path');
- const sendToWormhole = require('stream-wormhole');
- module.exports = app => {
- class ReviseController extends app.BaseController {
- /**
- * 构造函数
- *
- * @param {Object} ctx - egg全局变量
- * @return {void}
- */
- constructor(ctx) {
- super(ctx);
- }
- /**
- * 是否可以新增修订
- * @param ctx
- * @return {Promise<boolean>}
- * @private
- */
- async _getAddReviseValid(ctx) {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- const lastStage = await ctx.service.stage.getFlowLatestStage(ctx.tender.id, true);
- const addVisible = (ctx.tender.data.user_id === ctx.session.sessionUser.accountId) &&
- (ctx.tender.data.ledger_status === audit.ledger.status.checked) &&
- (!revise || !revise.valid || revise.status === audit.revise.status.checked);
- const addValid = addVisible && (!lastStage || lastStage.status === audit.stage.status.uncheck ||
- lastStage.status === audit.stage.status.checkNo || lastStage.status === audit.stage.status.checked);
- let changeValid = true;
- // 判断变更是否存在审批中,有则可能无法新增修订
- const changeList = await ctx.service.change.getAllDataByCondition({
- where: {
- tid: ctx.tender.id,
- status: [audit.change.status.checking, audit.change.status.checkNoPre],
- },
- });
- if (changeList.length > 0) {
- // 判断是否已存在新增部位,有则可能无法新增修订
- const changeLedgerList = await ctx.service.changeLedger.getAllDataByCondition({ where: { tender_id: ctx.tender.id, is_leaf: 1 } });
- const changePosList = await ctx.service.changePos.getAllDataByCondition({ where: { tid: ctx.tender.id } });
- // 判断变更是否已添加新增部位,有则可能无法新增修订
- if (changeLedgerList.length > 0 || changePosList.length > 0) {
- // 判断审批中的变更令是否有调用了新增部位,有则无法新增修订,都没有则可新增修订
- for (const c of changeList) {
- const caList = await ctx.service.changeAuditList.getList(c.cid, 0);
- const gclIdList = ctx.helper._.uniq(ctx.helper._.map(caList, 'gcl_id'));
- for (const gcl of gclIdList) {
- if (gcl && (ctx.helper._.findIndex(changeLedgerList, { id: gcl }) !== -1)) {
- changeValid = false;
- break;
- }
- }
- if (!changeValid) {
- break;
- }
- const posIdList = ctx.helper._.uniq(ctx.helper._.map(caList, 'mx_id'));
- for (const pos of posIdList) {
- if (pos && (ctx.helper._.findIndex(changePosList, { id: pos }) !== -1)) {
- changeValid = false;
- break;
- }
- }
- if (!changeValid) {
- break;
- }
- }
- }
- }
- return [addVisible, addValid, changeValid];
- }
- /**
- * 台账修订页面 (Get)
- *
- * @param {object} ctx - egg全局变量
- * @return {void}
- */
- async index(ctx) {
- try {
- // 分页相关
- const user = await this.ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
- const condition = { tid: ctx.tender.id };
- if (!user.show_revise_invalid) condition.valid = 1;
- const count = await ctx.service.ledgerRevise.count(condition);
- const ledgerRevise = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id, user.show_revise_invalid);
- if (ledgerRevise.length > 0) {
- const revise = ledgerRevise[0];
- if (ctx.page === 1) {
- if (revise.status === audit.revise.status.checked || !revise.valid) {
- revise.lastest = true;
- } else {
- if (ledgerRevise.length > 1) ledgerRevise[1].lastest = true;
- // if (revise.status === audit.revise.status.checking) {
- // revise.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
- // }
- }
- }
- }
- for (const lr of ledgerRevise) {
- if (lr.valid) {
- lr.curAuditors = await ctx.service.reviseAudit.getAuditorsByStatus(lr.id, lr.status, lr.times);
- lr.curAuditorIds = lr.curAuditors.map(x => { return x.audit_id; });
- }
- }
- const [addVisible, addValid, changeValid] = await this._getAddReviseValid(ctx);
- const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
- ctx.tender.data.valuation, ctx.tender.data.measure_type);
- const renderData = {
- tender: ctx.tender.data,
- tenderMenu: this.menu.tenderMenu,
- preUrl: '/tender/' + ctx.tender.id,
- pageInfo: {
- page: ctx.page,
- total: Math.ceil(count / app.config.pageSize),
- queryData: JSON.stringify(ctx.urlInfo.query),
- },
- ledgerRevise,
- addVisible,
- addValid,
- changeValid,
- auditConst: audit.revise,
- auditType: audit.auditType,
- auditConst2: JSON.stringify(audit.revise),
- stdBills,
- stdChapters,
- show_invalid: user.show_revise_invalid,
- };
- await this.layout('revise/index.ejs', renderData, 'revise/modal.ejs');
- } catch (err) {
- this.log(err);
- ctx.redirect(ctx.request.header.referer);
- }
- }
- async showInvalid(ctx) {
- try {
- await ctx.service.projectAccount.defaultUpdate({ id: ctx.session.sessionUser.accountId, show_revise_invalid: ctx.query.show });
- } catch (err) {
- this.log(err);
- }
- ctx.redirect(ctx.request.header.referer);
- }
- /**
- * 修订审批流程(Get)
- * @param ctx
- * @return {Promise<void>}
- */
- async reviseAuditors(ctx) {
- try {
- const rid = JSON.parse(ctx.request.body.data).id;
- const reviseInfo = await ctx.service.ledgerRevise.getDataById(rid);
- await ctx.service.reviseAudit.loadReviseUser(reviseInfo);
- await ctx.service.reviseAudit.loadReviseAuditViewData(reviseInfo);
- ctx.body = { err: 0, msg: '', data: reviseInfo};
- } catch (error) {
- this.log(error);
- ctx.body = { err: 1, msg: error.toString(), data: null };
- }
- }
- /**
- * 新增 修订 (Post)
- * @param ctx
- * @return {Promise<void>}
- */
- async add(ctx) {
- try {
- const [addValid, changeValid] = await this._getAddReviseValid(ctx);
- if (!addValid) {
- throw '无法新增修订';
- }
- if (!changeValid) {
- throw '台账修订会影响审批中的变更令(包含新增部位),请审批完成后再创建台账修订';
- }
- const revise = await ctx.service.ledgerRevise.add(ctx.tender.id, ctx.session.sessionUser.accountId);
- ctx.redirect(`/tender/${ctx.tender.id}/revise/${revise.id}/info`);
- } catch (err) {
- this.log(err);
- ctx.redirect(ctx.request.header.referer);
- }
- }
- /**
- * 作废 修订 (Post)
- * @param ctx
- * @return {Promise<void>}
- */
- async cancel(ctx) {
- try {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise) throw '当前标段无任何修订数据';
- if (revise.uid !== ctx.session.sessionUser.accountId) {
- throw '您无权作废该修订';
- }
- if (revise.status === audit.revise.checking) {
- throw '修订审批中,不可作废';
- } else if (revise.status === audit.revise.checked) {
- throw '修订已审批通过,不可作废';
- }
- if (revise.valid) {
- revise.readySettle = await this.service.settle.getReadySettle(revise.tid);
- const result = await ctx.service.ledgerRevise.cancelRevise(revise);
- }
- ctx.redirect('/tender/' + ctx.tender.id + '/revise/');
- } catch (err) {
- this.log(err);
- ctx.redirect(ctx.request.header.referer);
- }
- }
- /**
- * 保存 修订详情 (Ajax-post)
- * @param ctx
- * @return {Promise<void>}
- */
- async save(ctx) {
- try {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise.valid) {
- throw '该修订已作废';
- } else if (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo) {
- if (ctx.session.sessionUser.accountId !== revise.uid) {
- throw '您无权修改';
- }
- } else if (revise.status === audit.revise.status.checking) {
- throw '修订在审批中,不可修改修订数据';
- } else if (revise.staut === audit.revise.status.checked) {
- throw '修订已经审批通过,不可修改修订数据,请新增下一修订';
- }
- const data = JSON.parse(ctx.request.body.data);
- if (data.content === undefined) {
- throw '保存数据有误';
- }
- const result = await ctx.service.ledgerRevise.defaultUpdate({ id: revise.id, content: data.content });
- if (result.affectedRows !== 1) {
- throw '保存数据失败,请重试';
- }
- ctx.body = { err: 0, msg: '', data: null };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '保存数据失败,请重试');
- }
- }
- async _getDefaultReviseInfoData(ctx, revise) {
- const [ledgerSpread, posSpread] = await spreadSetting.getLedgerSpreadSetting(ctx, revise.tid,
- revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked);
- const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
- ctx.tender.data.valuation, ctx.tender.data.measure_type);
- await ctx.service.reviseAudit.loadReviseUser(revise);
- await ctx.service.reviseAudit.loadReviseAuditViewData(revise);
- return {
- revise, tender: ctx.tender.data,
- ledgerSpread, posSpread, tenderMenu, measureType,
- audit: audit.revise,
- auditType: audit.auditType,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.info),
- stdBills,
- auditConst: audit.revise,
- stdChapters,
- shenpiConst,
- nodeType: stdConst.nodeType,
- settleStatus: ctx.service.settle.settleStatus,
- };
- }
- /**
- * 历史修订页面(修订完成后,用于查看)
- * @param ctx
- * @param revise
- * @return {Promise<void>}
- * @private
- */
- async _getHistoryReviseInfo(ctx, revise) {
- const renderData = await this._getDefaultReviseInfoData(ctx, revise);
- renderData.ledgerSpread.readOnly = true;
- renderData.posSpread.readOnly = true;
- renderData.readOnly = true;
- renderData.history = true;
- renderData.historyRevise = await ctx.service.ledgerRevise.getAllReviseList(ctx.tender.id);
- renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
- renderData.preUrl = ctx.url.replace('/info', '');
- await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
- }
- /**
- * 修订页面(草稿,审批中)
- * @param ctx
- * @param revise
- * @return {Promise<void>}
- * @private
- */
- async _getAuditReviseInfo(ctx, revise) {
- const renderData = await this._getDefaultReviseInfoData(ctx, revise);
- renderData.readOnly = true;
- renderData.ledgerSpread.readOnly = true;
- renderData.posSpread.readOnly = true;
- renderData.history = false;
- renderData.historyRevise = [];
- renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
- renderData.preUrl = ctx.url.replace('/info', '');
- await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
- }
- async _getDraftReviseInfo(ctx, revise) {
- const renderData = await this._getDefaultReviseInfoData(ctx, revise);
- // 台账只读、使用数据
- renderData.readOnly = false;
- // 修订历史
- renderData.history = false;
- renderData.historyRevise = [];
- // 添加审批人相关
- // renderData.accountGroup = accountGroup;
- renderData.accountList = await ctx.service.projectAccount.getAllDataByCondition({
- where: { project_id: ctx.session.sessionProject.id, enable: 1 },
- columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
- });
- const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
- renderData.accountGroup = unitList.map(item => {
- const groupList = renderData.accountList.filter(item1 => item1.company === item.name);
- return { groupName: item.name, groupList };
- });
- renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
- renderData.preUrl = ctx.url.replace('/info', '');
- await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
- }
- /**
- * 修订 详细页面(Get)
- * @param ctx
- * @return {Promise<void>}
- */
- async info(ctx) {
- try {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise) throw '台账修订数据有误';
- if (revise.uid === ctx.session.sessionUser.accountId &&
- (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
- await this._getDraftReviseInfo(ctx, revise);
- } else if (revise.status === audit.revise.status.checked) {
- await this._getHistoryReviseInfo(ctx, revise);
- } else {
- await this._getAuditReviseInfo(ctx, revise);
- }
- } catch (err) {
- this.log(err);
- ctx.redirect(ctx.request.header.referer);
- }
- }
- async loadInfoData(ctx) {
- try {
- const revise = await ctx.revise;
- const reviseBills = revise.readOnly
- ? await ctx.helper.loadLedgerDataFromOss(revise.curHis.bills_file)
- : await ctx.service.reviseBills.getData(ctx.tender.id);
- const revisePos = revise.readOnly
- ? await ctx.helper.loadLedgerDataFromOss(revise.curHis.pos_file)
- : await ctx.service.revisePos.getData(ctx.tender.id);
- // 已计量
- if (revise.uid === ctx.session.sessionUser.accountId &&
- (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
- const stages = await ctx.service.stage.getAllDataByCondition({
- where: { tid: ctx.tender.id },
- orders: [['order', 'desc']],
- });
- if (stages.length > 0) {
- const usedBills = [], usedPos = [];
- for (const s of stages) {
- if (s.status === audit.stage.status.checked) {
- const usedPreBills = await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, s.order);
- usedBills.push(...usedPreBills);
- const usedPrePos = await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, s.order);
- usedPos.push(...usedPrePos);
- break;
- } else {
- const usedCurBills = await ctx.service.stageBills.getStageUsedBills(ctx.tender.id, s.id);
- usedBills.push(...usedCurBills);
- const usedCurPos = await ctx.service.stagePos.getStageUsedPos(ctx.tender.id, s.id);
- usedPos.push(...usedCurPos);
- }
- }
- for (const b of reviseBills) {
- b.used = usedBills.indexOf(b.id) >= 0;
- }
- for (const p of revisePos) {
- p.used = usedPos.indexOf(p.id) >= 0;
- }
- }
- }
- // 结算状态
- const settleStatusBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
- this.ctx.helper.assignRelaData(reviseBills, [
- { data: settleStatusBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
- ]);
- const settleStatusPos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
- this.ctx.helper.assignRelaData(revisePos, [
- { data: settleStatusPos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
- ]);
- const ledgerTags = await this.ctx.service.ledgerTag.getDatas(ctx.tender.id);
- const price = !revise.readOnly ? await this.ctx.service.revisePrice.getAllDataByCondition({ where: { rid: revise.id } }) : [];
- const att = await this.ctx.service.ledgerAtt.getReviseViewData(ctx.tender.id, ctx.revise.id);
- ctx.body = { err: 0, msg: '', data: { bills: reviseBills, pos: revisePos, tags: ledgerTags, price, att } };
- } catch (err) {
- ctx.helper.log(err);
- this.ajaxErrorBody(err, '加载台账修订数据错误');
- }
- }
- async checkData(ctx) {
- try {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise) throw '台账修订数据有误';
- const reviseBills = await ctx.service.reviseBills.getData(ctx.tender.id);
- const revisePos = await ctx.service.revisePos.getData(ctx.tender.id);
- const checkDataModel = require('../lib/ledger').checkData;
- const reviseCheck = new checkDataModel(ctx, measureType);
- reviseCheck.loadData(reviseBills, revisePos);
- ctx.tender.info.ledger_check.same_code && reviseCheck.checkSameCode();
- ctx.tender.info.ledger_check.sibling && reviseCheck.checkSibling();
- if (ctx.tender.data.measure_type === measureType.tz.value) reviseCheck.checkBillsQty(['sgfh_qty', 'qtcl_qty', 'sjcl_qty', 'quantity']);
- reviseCheck.checkBillsTp([
- {qty: 'sgfh_qty', tp: 'sgfh_tp'}, {qty: 'qtcl_qty', tp: 'qtcl_tp'},
- {qty: 'sjcl_qty', tp: 'sjcl_tp'}, {qty: 'quantity', tp: 'total_price'}
- ], this.ctx.tender.info.decimal, x => { return !x.check_calc; });
- ctx.body = { err: 0, msg: '', data: reviseCheck.checkResult };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '检查数据错误');
- }
- }
- async history(ctx) {
- try {
- const revise = ctx.revise;
- await ctx.service.reviseAudit.loadReviseUser(revise);
- await ctx.service.reviseAudit.loadReviseAuditViewData(revise);
- const [ledgerSpread, posSpread] = await spreadSetting.getLedgerSpreadSetting(ctx, revise.tid,
- revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked);
- ledgerSpread.readOnly = true;
- posSpread.readOnly = true;
- const historyRevise = await ctx.service.ledgerRevise.getAllReviseList(ctx.tender.id);
- const user = await ctx.service.projectAccount.getAccountInfoById(revise.uid);
- const renderData = {
- preUrl: ctx.url.replace('/info', ''),
- measureType, audit, revise,
- ledgerSpread, posSpread,
- readOnly: true,
- historyRevise,
- auditConst: audit.revise,
- auditType: audit.auditType,
- user,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.history),
- nodeType: stdConst.nodeType,
- settleStatus: ctx.service.settle.settleStatus,
- };
- await this.layout('revise/history.ejs', renderData, 'revise/history_modal.ejs');
- } catch (err) {
- this.log(err);
- ctx.redirect(ctx.request.header.referer);
- }
- }
- async checkRevise(ctx) {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (revise.uid !== ctx.session.sessionUser.accountId) {
- throw '修订数据错误';
- } else if (revise.status === audit.revise.status.checking) {
- throw '修订审批中,不可修改';
- } else if (revise.status === audit.revise.status.checked) {
- throw '修订已完成,如需修订台账,请新增修订';
- }
- return revise;
- }
- async _billsBase(revise, type, data) {
- if (isNaN(data.id) || data.id <= 0) throw '数据错误';
- if (type !== 'add') {
- if (isNaN(data.count) || data.count <= 0) data.count = 1;
- }
- switch (type) {
- case 'add':
- return await this.ctx.service.reviseBills.addReviseNode(revise.tid, revise.id, data.id, data.count);
- case 'delete':
- return await this.ctx.service.reviseBills.delete(revise.tid, data.id, data.count);
- case 'up-move':
- return await this.ctx.service.reviseBills.upMoveNode(revise.tid, data.id, data.count);
- case 'down-move':
- return await this.ctx.service.reviseBills.downMoveNode(revise.tid, data.id, data.count);
- case 'up-level':
- return await this.ctx.service.reviseBills.upLevelNode(revise.tid, data.id, data.count);
- case 'down-level':
- return await this.ctx.service.reviseBills.downLevelNode(revise.tid, data.id, data.count);
- }
- }
- async _batchInsert(revise, data) {
- if ((isNaN(data.id) || data.id <= 0) || !data.batchType) {
- throw '参数错误';
- }
- switch (data.batchType) {
- case 'child':
- return await this.ctx.service.reviseBills.batchInsertChild(revise.tid, revise.id, data.id, data.batchData);
- case 'next':
- return await this.ctx.service.reviseBills.batchInsertNext(revise.tid, revise.id, data.id, data.batchData);
- default:
- throw '参数错误';
- }
- }
- async _pasteBlock(revise, data) {
- if ((isNaN(data.id) || data.id <= 0) ||
- (!data.tid && data.tid <= 0) ||
- (!data.block || data.block.length <= 0)) throw '参数错误';
- return await this.ctx.service.reviseBills.pasteBlockData(this.ctx.tender.id, data.id, data.block, { crid: revise.id });
- }
- async _addStd(revise, data) {
- if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdData) throw '参数错误';
- // todo 校验项目是否使用该库的权限
- switch (data.stdType) {
- case 'xmj':
- return await this.ctx.service.reviseBills.addStdNodeWithParent(revise.tid, data.stdData, revise.id);
- case 'gcl':
- return data.withParent
- ? await this.ctx.service.reviseBills.addGclStdNodeWithParent(revise.tid, data.id, data.stdData, revise.id)
- : await this.ctx.service.reviseBills.addGclStdNode(revise.tid, data.id, data.stdData[data.stdData.length - 1], revise.id);
- default:
- throw '未知标准库';
- }
- }
- async _addDeal(revise, data) {
- if (!data.type || !data.dealBills) throw '数据错误';
- data.dealBills.unit_price = this.ctx.helper.round(data.dealBills.unit_price, this.ctx.tender.info.decimal.up);
- if (data.type === 'child') {
- return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.dealBills, revise.id);
- } else if (data.type === 'next') {
- return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.dealBills, revise.id);
- }
- throw '数据错误';
- }
- async _addBg(revise, data) {
- if (!data.type || !data.bgBills) throw '数据错误';
- data.bgBills.unit_price = this.ctx.helper.round(data.bgBills.unit_price, this.ctx.tender.info.decimal.up);
- if (data.type === 'child') {
- return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.bgBills, revise.id);
- } else if (data.type === 'next') {
- return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.bgBills, revise.id);
- }
- throw '数据错误';
- }
- async _updatePos(revise, data) {
- // await this.checkMeasureType(measureType.tz.value);
- if (!data.posPostType) throw '数据错误';
- switch (data.posPostType) {
- case 'add':
- return await this.ctx.service.revisePos.addPos(revise.tid, revise.id, data.postData);
- case 'update':
- if (data.postData instanceof Array) {
- return await this.ctx.service.revisePos.updatePosArr(revise.tid, data.postData);
- }
- return await this.ctx.service.revisePos.updatePos(revise.tid, data.postData);
- case 'delete':
- return await this.ctx.service.revisePos.deletePos(revise.tid, data.postData);
- case 'paste':
- return await this.ctx.service.revisePos.pastePosData(revise.tid, revise.id, data.postData);
- case 'insert':
- return await this.ctx.service.revisePos.insertPos(revise.tid, revise.id, data.postData);
- default:
- throw '未知操作';
- }
- }
- async update(ctx) {
- try {
- if (!ctx.tender.data) throw '标段数据错误';
- const data = JSON.parse(ctx.request.body.data);
- if (!data.postType || !data.postData) throw '数据错误';
- const responseData = { err: 0, msg: '', data: {} };
- const revise = await this.checkRevise(ctx);
- switch (data.postType) {
- case 'add':
- case 'delete':
- case 'up-move':
- case 'down-move':
- case 'up-level':
- case 'down-level':
- responseData.data = await this._billsBase(revise, data.postType, data.postData);
- break;
- case 'update':
- ctx.helper.checkDgnQtyPrecision(data.postData);
- responseData.data = await this.ctx.service.reviseBills.updateCalc(revise.tid, data.postData);
- break;
- case 'batch-insert':
- responseData.data = await this._batchInsert(revise, data.postData);
- break;
- case 'add-deal':
- responseData.data = await this._addDeal(revise, data.postData);
- break;
- case 'add-bg':
- responseData.data = await this._addDeal(revise, data.postData);
- break;
- case 'add-std':
- responseData.data = await this._addStd(revise, data.postData);
- break;
- case 'paste-block':
- responseData.data = await this._pasteBlock(revise, data.postData);
- break;
- case 'pos':
- responseData.data = await this._updatePos(revise, data);
- break;
- default:
- throw '未知操作';
- }
- ctx.body = responseData;
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '数据错误');
- }
- }
- /**
- * 上传 清单Excel 并导入
- * @param ctx
- * @return {Promise<void>}
- */
- async uploadExcel(ctx) {
- try {
- const revise = await this.checkRevise(ctx);
- const ueType = ctx.params.ueType;
- const compressData = ctx.request.body.data;
- const data = JSON.parse(LzString.decompressFromUTF16(compressData));
- const responseData = { err: 0, msg: '', data: {} };
- switch (ueType) {
- case 'gcl2xmj':
- responseData.data = await ctx.service.reviseBills.importGclExcel(data.id, data.sheet, { crid: revise.id });
- break;
- }
- ctx.body = responseData;
- } catch (err) {
- this.log(err);
- ctx.body = { err: 1, msg: err.toString(), data: null };
- }
- }
- /**
- * 填设计量(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async deal2sgfh(ctx) {
- try {
- if (this.ctx.tender.measure_type === measureType.tz.value) throw '该功能仅工程量清单模式可用';
- await this.ctx.service.reviseBills.deal2sgfh(ctx.tender.id);
- const ledgerData = await ctx.service.reviseBills.getData(ctx.tender.id);
- ctx.body = { err: 0, msg: '', data: { bills: ledgerData } };
- } catch (err) {
- this.log(err);
- ctx.body = { err: 1, msg: err.toString(), data: null };
- }
- }
- /**
- * 新增审批人(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async addAuditor(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const id = data.auditorId;
- if (isNaN(id) || id <= 0) {
- throw '参数错误';
- }
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise) throw '台账修订数据有误';
- // 检查权限等
- if (revise.uid !== ctx.session.sessionUser.accountId) throw '您无权添加审核人';
- if (revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
- throw '当前不允许添加审核人';
- }
- // 检查审核人是否已存在
- const exist = await ctx.service.reviseAudit.getAuditor(revise.id, id, revise.times);
- if (exist) throw '该审核人已存在,请勿重复添加';
- const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.revise, sp_status: shenpiConst.sp_status.gdzs });
- const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.revise === shenpiConst.sp_status.gdzs ? 1 : 0;
- const result = await ctx.service.reviseAudit.addAuditor(revise, id, is_gdzs);
- if (!result) throw '添加审核人失败';
- const resultData = await ctx.service.reviseAudit.getUserGroup(revise.id, revise.times);
- ctx.body = { err: 0, msg: '', data: resultData };
- } catch (err) {
- this.log(err, '数据错误');
- ctx.body = this.ajaxErrorBody(err);
- }
- }
- /**
- * 移除审批人(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async removeAuditor(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
- if (isNaN(id) || id <= 0) {
- throw '参数错误';
- }
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise) throw '台账修订数据有误';
- const result = await ctx.service.reviseAudit.deleteAuditor(revise, id);
- if (!result) {
- throw '移除审核人失败';
- }
- const resultData = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
- ctx.body = { err: 0, msg: '', data: resultData };
- } catch (err) {
- this.log(err, '数据错误');
- ctx.body = this.ajaxErrorBody(err);
- }
- }
- /**
- * 上报(ajax-post)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async start(ctx) {
- try {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise || revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
- throw '台账修订数据有误';
- }
- if (revise.content === '') {
- throw '未填写修订内容,请先填写并保存修订内容';
- }
- if (revise.uid !== ctx.session.sessionUser.accountId) throw '上报失败';
- revise.readySettle = await this.service.settle.getReadySettle(revise.tid);
- await ctx.service.reviseAudit.start(revise, revise.times);
- ctx.body = { err: 0, msg: '', data: {} };
- } catch (err) {
- this.log(err);
- ctx.session.postError = err.toString();
- ctx.body = this.ajaxErrorBody(err, '上报失败');
- }
- }
- /**
- * 审批(post)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async check(ctx) {
- try {
- const revise = ctx.revise;
- if (!revise || revise.status !== audit.revise.status.checking) throw '台账修订数据有误';
- const curAudits = await ctx.service.reviseAudit.getCurAuditors(revise.id, revise.times);
- const curAuditorIds = curAudits.map(x => { return x.audit_id; });
- if (curAuditorIds.indexOf(ctx.session.sessionUser.accountId) < 0) throw '审批失败';
- const checkType = parseInt(ctx.request.body.checkType);
- if (!checkType || isNaN(checkType)) throw '提交数据错误';
- await ctx.service.reviseAudit.check(ctx.revise, checkType, ctx.request.body.opinion, revise.times);
- ctx.redirect(ctx.request.headers.referer);
- } catch (err) {
- this.log(err);
- this.postError(err, '审批失败');
- ctx.redirect(ctx.request.headers.referer);
- }
- }
- async _getLastStage(ctx) {
- const stages = await ctx.service.stage.getAllDataByCondition({
- where: {tid: ctx.tender.id},
- orders: [['order', 'desc']],
- });
- if (stages.length > 0) {
- if (stages[0].status !== audit.stage.status.uncheck || stages[0].user_id === ctx.session.sessionUser.accountId) {
- return stages[0]
- } else if (stages.length > 1) {
- return stages[1];
- }
- }
- return null;
- }
- async compare(ctx) {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise) throw '台账修订数据有误';
- const lastStage = await this._getLastStage(ctx);
- const renderData = {
- preUrl: ctx.url.replace('/compare', ''),
- revise,
- measureType,
- lastStage,
- audit,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.compare),
- };
- await this.layout('revise/compare.ejs', renderData, 'revise/compare_modal.ejs');
- }
- _loadPreData(curData, preData, field, prefix, relaId, extraFields = []) {
- if (preData.length === 0) return;
- for (const pd of preData) {
- const cd = curData.find(x => {return x[relaId] === pd[relaId]});
- if (cd) {
- for (const f of field) {
- cd[prefix + f] = pd[f];
- }
- } else {
- const ncd = {id: pd.id};
- ncd[relaId] = pd[relaId];
- for (const ef of extraFields) {
- ncd[ef] = pd[ef];
- }
- for (const f of field) {
- ncd[prefix + f] = pd[f];
- }
- curData.push(ncd);
- }
- }
- }
- async _loadLastStageBillsData(ctx) {
- let curStageData;
- if (ctx.lastStage.readOnly) {
- curStageData = await ctx.service.stageBills.getAuditorStageData2(ctx.tender.id,
- ctx.lastStage.id, ctx.lastStage.curTimes, ctx.lastStage.curOrder);
- } else {
- curStageData = await ctx.service.stageBills.getLastestStageData2(ctx.tender.id, ctx.lastStage.id);
- }
- const preStageData = ctx.lastStage.order > 1
- ? await ctx.service.stageBillsFinal.getFinalData(ctx.tender.data, ctx.lastStage.order - 1)
- : [];
- this._loadPreData(curStageData, preStageData, ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], 'pre_', 'lid');
- return curStageData;
- }
- async _loadLastStagePosData(ctx) {
- let curStageData;
- if (ctx.lastStage.readOnly) {
- curStageData = await ctx.service.stagePos.getAuditorStageData2(ctx.tender.id,
- ctx.lastStage.id, ctx.lastStage.curTimes, ctx.lastStage.curOrder);
- } else {
- curStageData = await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, ctx.lastStage.id);
- }
- const preStageData = ctx.lastStage.order > 1
- ? await ctx.service.stagePosFinal.getFinalData(ctx.tender.data, ctx.lastStage.order - 1)
- : [];
- this._loadPreData(curStageData, preStageData, ['contract_qty', 'qc_qty'], 'pre_', 'pid', ['lid']);
- return curStageData;
- }
- async _loadChange(ctx) {
- const change = await ctx.service.change.getAllDataByCondition({
- columns: [ 'cid', 'code', 'name', 'w_code' ],
- where: { tid: ctx.tender.id },
- orders: [['code', 'asc']],
- });
- const changeBills = await ctx.service.changeAuditList.getAllDataByCondition({
- columns: [ 'cid', 'code', 'name', 'unit', 'unit_price' ],
- where: { tid: ctx.tender.id }
- });
- const changeIndex = {};
- change.forEach(x => { changeIndex[x.cid] = x; x.bills = [] });
- changeBills.forEach(cb => {
- const c = changeIndex[cb.cid];
- if (!c) return;
- c.bills.push(cb);
- });
- const helper = ctx.helper;
- change.forEach(x => {
- x.bills.sort((a, b) => { return helper.compareCode(a.code, b.code)});
- });
- return change;
- }
- async _loadDataByFilter(ctx, filter) {
- switch(filter) {
- case 'bills':
- const billsData = ctx.revise.preHis ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.preHis.bills_file) : [];
- const settleStatusBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
- this.ctx.helper.assignRelaData(billsData, [
- { data: settleStatusBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
- ]);
- return billsData;
- case 'pos':
- const posData = ctx.revise.preHis ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.preHis.pos_file) : [];
- const settleStatusPos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
- this.ctx.helper.assignRelaData(posData, [
- { data: settleStatusPos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
- ]);
- return posData;
- case 'reviseBills':
- const reviseBillsData = ctx.revise.readOnly && ctx.revise.curHis
- ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.curHis.bills_file)
- : await ctx.service.reviseBills.getAllDataByCondition({ where: { tender_id: ctx.tender.id } });
- const settleBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
- this.ctx.helper.assignRelaData(reviseBillsData, [
- { data: settleBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
- ]);
- return reviseBillsData;
- case 'revisePos':
- const revisePosData = ctx.revise.readOnly && ctx.revise.curHis
- ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.curHis.pos_file)
- : await ctx.service.revisePos.getAllDataByCondition({ where: { tid: ctx.tender.id } });
- const settlePos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
- this.ctx.helper.assignRelaData(revisePosData, [
- { data: settlePos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
- ]);
- return revisePosData;
- case 'stageBills':
- case 'stagePos':
- if (!ctx.lastStage) ctx.lastStage = await this._getLastStage(ctx);
- await this.ctx.service.stage.doCheckStage(ctx.lastStage);
- if (filter === 'stageBills') {
- return await this._loadLastStageBillsData(ctx);
- } else {
- return await this._loadLastStagePosData(ctx);
- }
- case 'dealBills': return await ctx.service.dealBills.getAllDataByCondition({where: {tender_id: ctx.tender.id}});
- case 'spec':
- const spec = {zlj: stdConst.zlj, jrg: stdConst.jrg};
- spec.zlj.deal_bills_tp = ctx.tender.info.deal_param.zanLiePrice;
- return spec;
- case 'tags':
- return await this.ctx.service.ledgerTag.getDatas(ctx.tender.id);
- case 'price':
- return await this.ctx.service.revisePrice.getAllDataByCondition({ where: { rid: ctx.revise.id } });
- case 'change':
- return await this._loadChange(ctx);
- case 'att':
- return await this.ctx.service.ledgerAtt.getReviseViewData(ctx.tender.id, ctx.revise.id);
- default: throw '请求的数据不存在';
- }
- }
- async loadData(ctx) {
- try {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise) throw '台账修订数据有误';
- const data = JSON.parse(ctx.request.body.data);
- const filter = data.filter ? data.filter.split(';') : [];
- const responseData = { err: 0, msg: '', data: {} };
- for (const f of filter) {
- if (!f) continue;
- responseData.data[f] = await this._loadDataByFilter(ctx, f);
- }
- ctx.body = responseData;
- } catch (err) {
- this.ctx.helper.log(err);
- this.ajaxErrorBody(err, '加载数据错误,请刷新页面重试');
- }
- }
- async gclCompare(ctx) {
- const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- if (!revise) throw '台账修订数据有误';
- const renderData = {
- measureType,
- preUrl: ctx.url.replace('/gcl-compare', ''),
- revise,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.gclCompare),
- };
- await this.layout('revise/gcl_compare.ejs', renderData);
- }
- async price(ctx) {
- if (!ctx.revise) throw '台账修订数据有误';
- const renderData = {
- preUrl: ctx.url.replace('/price', ''),
- revise: ctx.revise,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.price),
- settleStatus: ctx.service.settle.settleStatus,
- };
- await this.layout('revise/price.ejs', renderData, 'revise/price_modal.ejs');
- }
- async priceUpdate(ctx) {
- try {
- if (!ctx.revise) throw '台账修订数据有误';
- const data = JSON.parse(ctx.request.body.data);
- const result = await ctx.service.revisePrice.updateDatas(data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存数据失败');
- }
- }
- async uploadFile(ctx) {
- let stream;
- try {
- const parts = ctx.multipart({ autoFields: true });
- const files = [];
- let index = 0;
- const extra_upload = ctx.revise.audit_status === audit.revise.status.checked;
- stream = await parts();
- while (stream) {
- // 判断用户是否选择上传文件
- if (!stream.filename) {
- throw '请选择上传的文件!';
- }
- const fileInfo = path.parse(stream.filename);
- const create_time = Date.parse(new Date()) / 1000;
- const filepath = `${ctx.session.sessionProject.id}/${ctx.tender.id}/revise/att_${create_time + index.toString() + fileInfo.ext}`;
- await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
- if (stream) await sendToWormhole(stream);
- // 保存数据到att表
- const fileData = {
- tid: ctx.tender.id,
- revise_id: ctx.revise.id,
- revising: !extra_upload,
- in_time: create_time,
- filename: fileInfo.name,
- fileext: fileInfo.ext,
- filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
- filepath,
- extra_upload,
- };
- const result = await ctx.service.ledgerAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
- if (!result) throw '保存数据失败';
- const attData = await ctx.service.ledgerAtt.getViewDataByFid(result.insertId);
- files.length !== 0 ? files.unshift(attData) : files.push(attData);
- ++index;
- if (Array.isArray(parts.field.size) && index < parts.field.size.length) {
- stream = await parts();
- } else {
- stream = undefined;
- }
- }
- ctx.body = { err: 0, msg: '', data: files };
- } catch (err) {
- ctx.log(err);
- // 失败需要消耗掉stream 以防卡死
- if (stream) await sendToWormhole(stream);
- ctx.ajaxErrorBody(err, '上传文件失败');
- }
- }
- async deleteFile(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const fileInfo = await ctx.service.ledgerAtt.getDataById(data.id);
- if (!fileInfo || !Object.keys(fileInfo).length) throw '该文件不存在';
- if (!fileInfo.extra_upload && ctx.revise.status === audit.revise.status.checked) throw '无权限删除';
- if (fileInfo !== undefined && fileInfo !== '') {
- // 先删除文件
- await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
- // 再删除数据库
- await ctx.service.ledgerAtt.deleteById(data.id);
- } else {
- throw '不存在该文件';
- }
- ctx.body = { err: 0, msg: '', data: null}
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '删除文件失败');
- }
- }
- async saveFile(ctx) {
- let stream;
- try {
- stream = await ctx.getFileStream({ requireFile: false });
- let fileData = {};
- if (stream.filename !== undefined) {
- const create_time = Date.parse(new Date()) / 1000;
- const fileInfo = path.parse(stream.filename);
- const filepath = `${ctx.session.sessionProject.id}/${ctx.tender.id}/revise/att_${create_time + fileInfo.ext}`;
- // 保存文件
- await ctx.oss.put(ctx.app.config.fujianOssFolder + filepath, stream);
- // 保存数据到att表
- fileData = {
- filesize: stream.fields.size,
- filepath,
- };
- }
- const org = await ctx.service.ledgerAtt.getDataById(stream.fields.id);
- const result = await ctx.service.ledgerAtt.updateByID(stream.fields, fileData);
- if (!result) throw '保存数据失败';
- // 删除原附件
- await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + org.filepath);
- const attData = await ctx.service.ledgerAtt.getViewDataByFid(stream.fields.id);
- ctx.body = { err: 0, msg: '', data: attData };
- responseData.data = attData;
- } catch (err) {
- ctx.log(err);
- // 失败需要消耗掉stream 以防卡死
- if (stream) await sendToWormhole(stream);
- ctx.ajaxErrorBody(err, '保存数据失败');
- }
- }
- }
- return ReviseController;
- };
|