123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749 |
- 'use strict';
- /**
- * 标段管理控制器
- *
- * @author CaiAoLin
- * @date 2018/2/5
- * @version
- */
- const tenderConst = require('../const/tender');
- const codeRuleConst = require('../const/code_rule');
- const settingConst = require('../const/setting.js');
- const tenderMenu = require('../../config/menu').tenderMenu;
- const auditConst = require('../const/audit');
- const shenpiConst = require('../const/shenpi');
- const accountGroup = require('../const/account_group').group;
- const accountPermission = require('../const/account_permission');
- const measureType = require('../const/tender').measureType;
- const billsPosConvert = require('../lib/bills_pos_convert');
- const path = require('path');
- const sendToWormhole = require('stream-wormhole');
- const scheduleConst = require('../const/schedule');
- const changeConst = require('../const/change');
- const tenderInfoModel = require('../lib/tender_info');
- const mapConst = require('../const/map');
- const advanceConst = require('../const/advance');
- const projectSetting = require('../const/project_setting');
- const profileConst = require('../const/profile');
- const materialConst = require('../const/material');
- module.exports = app => {
- class TenderController extends app.BaseController {
- /**
- * 构造函数
- *
- * @param {Object} ctx - egg全局变量
- * @return {void}
- */
- constructor(ctx) {
- super(ctx);
- ctx.showProject = true;
- ctx.showTitle = true;
- this.colSet = [];
- }
- async _listDetailCache(view, modal = '', type) {
- try {
- // 获取用户新建标段权利
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== ''
- ? JSON.parse(accountInfo.permission) : null;
- const tenderList = await this.ctx.service.tender.getBuildList('', userPermission, this.ctx.session.sessionUser.is_admin);
- for (const t of tenderList) {
- await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
- t.canFinish = await this.ctx.service.tender.checkTenderCanFinish(t);
- }
- const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.subProject);
- const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
- const subProject = await this.ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin, true);
- const renderData = {
- tenderList,
- tenderConst,
- settingConst,
- categoryData,
- measureType: tenderConst.measureType,
- jsFiles: this.app.jsFiles.common.concat(this.jsFiles),
- auditConst,
- userPermission,
- valuations,
- uid: this.ctx.session.sessionUser.accountId,
- pid: this.ctx.session.sessionProject.id,
- colSet: this.colSet,
- subProject,
- buildStatus: tenderConst.buildStatus,
- };
- renderData.selfCategoryLevel = await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
- renderData.is_finish = false;
- await this.layout(view, renderData, modal);
- } catch (err) {
- this.log(err);
- this.ctx.redirect('/dashboard');
- }
- }
- async _listDetailFinish(view, modal = '', type) {
- try {
- // 获取用户新建标段权利
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== ''
- ? JSON.parse(accountInfo.permission) : null;
- const tenderList = await this.ctx.service.tender.getFinishList('', userPermission, this.ctx.session.sessionUser.is_admin);
- for (const t of tenderList) {
- await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
- t.canFinish = await this.ctx.service.tender.checkTenderCanFinish(t);
- }
- const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.subProject);
- const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
- const subProject = await this.ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin, true);
- const renderData = {
- tenderList,
- tenderConst,
- settingConst,
- categoryData,
- measureType: tenderConst.measureType,
- jsFiles: this.app.jsFiles.common.concat(this.jsFiles),
- auditConst,
- userPermission,
- valuations,
- uid: this.ctx.session.sessionUser.accountId,
- pid: this.ctx.session.sessionProject.id,
- colSet: this.colSet,
- subProject,
- buildStatus: tenderConst.buildStatus,
- };
- renderData.selfCategoryLevel = await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
- renderData.is_finish = true;
- await this.layout(view, renderData, modal);
- } catch (err) {
- this.log(err);
- this.ctx.redirect('/dashboard');
- }
- }
- async _listCache(view, renderData, modal = '', list_status = '') {
- try {
- renderData.tenderList = await this.ctx.service.tender.getBuildList(list_status, renderData.userPermission, this.ctx.session.sessionUser.is_admin);
- for (const t of renderData.tenderList) {
- t.visitor = (await this.ctx.service.tenderTourist.getTourists(t.id)).map(x => { return x.user_name; });
- await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
- t.canFinish = await this.ctx.service.tender.checkTenderCanFinish(t);
- }
- renderData.categoryData = await this.ctx.service.category.getAllCategory(this.ctx.subProject);
- renderData.valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
- renderData.tenderConst = tenderConst;
- renderData.settingConst = settingConst;
- renderData.measureType = tenderConst.measureType;
- renderData.jsFiles = this.app.jsFiles.common.concat(this.jsFiles);
- renderData.auditConst = auditConst;
- renderData.uid = this.ctx.session.sessionUser.accountId;
- renderData.pid = this.ctx.session.sessionProject.id;
- renderData.selfCategoryLevel = await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
- renderData.is_finish = false;
- renderData.colSet = this.colSet;
- renderData.buildStatus = tenderConst.buildStatus;
- renderData.subProject = await this.ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin, true);
- await this.layout(view, renderData, modal);
- } catch (err) {
- this.log(err);
- this.ctx.redirect('/dashboard');
- }
- }
- async _listFinish(view, renderData, modal = '', list_status = '') {
- try {
- renderData.tenderList = await this.ctx.service.tender.getFinishList(list_status, renderData.userPermission, this.ctx.session.sessionUser.is_admin);
- for (const t of renderData.tenderList) {
- t.visitor = (await this.ctx.service.tenderTourist.getTourists(t.id)).map(x => { return x.user_name; });
- await this.ctx.service.tenderCache.loadTenderCache(t, this.ctx.session.sessionUser.accountId);
- t.canFinish = await this.ctx.service.tender.checkTenderCanFinish(t);
- }
- renderData.categoryData = await this.ctx.service.category.getAllCategory(this.ctx.subProject);
- renderData.valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
- renderData.tenderConst = tenderConst;
- renderData.settingConst = settingConst;
- renderData.measureType = tenderConst.measureType;
- renderData.jsFiles = this.app.jsFiles.common.concat(this.jsFiles);
- renderData.auditConst = auditConst;
- renderData.uid = this.ctx.session.sessionUser.accountId;
- renderData.pid = this.ctx.session.sessionProject.id;
- renderData.selfCategoryLevel = await this.ctx.service.projectAccount.getSelfCategoryLevel(this.ctx.session.sessionUser.accountId);
- renderData.is_finish = true;
- renderData.colSet = this.colSet;
- renderData.buildStatus = tenderConst.buildStatus;
- renderData.subProject = await this.ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, this.ctx.session.sessionUser.is_admin, true);
- await this.layout(view, renderData, modal);
- } catch (err) {
- this.log(err);
- this.ctx.redirect('/dashboard');
- }
- }
- async listDefault(ctx) {
- this.jsFiles = this.app.jsFiles.tender.list;
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
- const renderData = {
- accountInfo,
- userPermission,
- colSet: this.colSet,
- };
- await this._listCache('tender/index.ejs', renderData, 'tender/modal.ejs');
- }
- /**
- * 标段概况(Get)
- *
- * @param {object} ctx - egg全局变量
- * @return {void}
- */
- async listInfo(ctx) {
- this.jsFiles = this.app.jsFiles.tender.info;
- const projectColSet = await ctx.service.projectColSet.getProjectColSet(ctx.session.sessionProject.id);
- this.colSet = ctx.service.projectColSet.analysisColSetWithDefine(projectSetting.colSet.info, projectColSet.info);
- await this._listDetailCache('tender/info.ejs', 'tender/modal.ejs');
- }
- /**
- * 计量进度(Get)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async listProgress(ctx) {
- this.jsFiles = this.app.jsFiles.tender.progress;
- await this._listDetailCache('tender/progress.ejs', 'tender/modal.ejs');
- }
- /**
- * 标段管理(Get)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async listManage(ctx) {
- this.jsFiles = this.app.jsFiles.tender.manage;
- // 先判断权限
- // 获取用户新建标段权利
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
- if (userPermission !== null && userPermission.tender !== undefined && userPermission.tender.indexOf('1') !== -1) {
- const renderData = {
- accountInfo,
- userPermission,
- };
- await this._listCache('tender/manage.ejs', renderData, 'tender/manage_modal.ejs', 'manage');
- } else {
- this.ctx.redirect(ctx.request.header.referer);
- }
- }
- async listDefaultFinish(ctx) {
- this.jsFiles = this.app.jsFiles.tender.list;
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
- const renderData = {
- accountInfo,
- userPermission,
- };
- await this._listFinish('tender/index.ejs', renderData, 'tender/modal.ejs');
- }
- async listInfoFinish(ctx) {
- this.jsFiles = this.app.jsFiles.tender.info;
- const projectColSet = await ctx.service.projectColSet.getProjectColSet(ctx.session.sessionProject.id);
- this.colSet = ctx.service.projectColSet.analysisColSetWithDefine(projectSetting.colSet.info, projectColSet.info);
- await this._listDetailFinish('tender/info.ejs', 'tender/modal.ejs');
- }
- /**
- * 标段管理(Get)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async listManageFinish(ctx) {
- this.jsFiles = this.app.jsFiles.tender.manage;
- // 先判断权限
- // 获取用户新建标段权利
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
- if (userPermission !== null && userPermission.tender !== undefined && userPermission.tender.indexOf('1') !== -1) {
- const renderData = {
- accountInfo,
- userPermission,
- };
- await this._listFinish('tender/manage.ejs', renderData, 'tender/manage_modal.ejs', 'manage');
- } else {
- this.ctx.redirect(ctx.request.header.referer);
- }
- }
- /**
- * 新增标段(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async addTender(ctx) {
- try {
- const responseData = {
- err: 0, msg: '', data: null,
- };
- // 获取用户新建标段权利
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
- if (userPermission === null || userPermission.tender === undefined || userPermission.tender.indexOf('1') === -1) {
- throw '当前用户没有创建标段的权限';
- }
- const data = JSON.parse(ctx.request.body.data);
- if (!data.name || data.name === '' || !data.valuation) {
- throw '标段信息不完整';
- }
- responseData.data = await ctx.service.tender.add(data);
- ctx.body = responseData;
- } catch (error) {
- this.log(error);
- ctx.body = { err: 1, msg: error.toString(), data: null };
- }
- }
- /**
- * 编辑标段(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async updateTender(ctx) {
- try {
- const responseData = {
- err: 0, msg: '', data: null,
- };
- const data = JSON.parse(ctx.request.body.data);
- if (!data.id) {
- throw '提交信息错误';
- }
- if (!data.name || data.name === '') {
- throw '标段信息不完整';
- }
- if (await ctx.service.tender.save(data, data.id)) {
- responseData.data = await ctx.service.tender.getTender(data.id);
- }
- ctx.body = responseData;
- } catch (error) {
- this.log(error);
- ctx.body = { err: 1, msg: error.toString(), data: null };
- }
- }
- /**
- * 删除标段(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async deleteTender(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data),
- result = [];
- if (!(data instanceof Array) && (data.length === 0)) {
- throw '提交数据有误';
- }
- for (const id of data) {
- if (await ctx.service.tender.deleteTenderNoBackup(id)) {
- result.push(id);
- }
- }
- ctx.body = { err: 0, msg: '', data: result };
- } catch (err) {
- ctx.body = { err: 1, msg: err.toString(), data: [] };
- }
- }
- /**
- * 标段概况(Get)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async tenderInfo(ctx) {
- try {
- const tender = ctx.tender.data;
- let bCalcTp = tender.user_id === this.ctx.session.sessionUser.accountId && (
- tender.ledger_status === auditConst.ledger.status.checkNo || tender.ledger_status === auditConst.ledger.status.uncheck);
- const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
- const lastStage = stages.length > 0 ? stages[0] : null; // await ctx.service.stage.getLastestStage(ctx.tender.id);
- const [change_tp, change_p_tp, change_n_tp, change_valuation_tp, change_unvaluation_tp] = await ctx.service.change.getChangeTp(tender.id);
- tender.change_tp = change_tp;
- tender.change_p_tp = change_p_tp;
- tender.change_n_tp = change_n_tp;
- tender.change_valuation_tp = change_valuation_tp;
- tender.change_unvaluation_tp = change_unvaluation_tp;
- if (lastStage) {
- await this.ctx.service.stage.checkStageGatherData(lastStage, this.ctx.session.sessionUser.is_admin);
- if ((!bCalcTp) && tender.measure_type === measureType.gcl.value) {
- bCalcTp = lastStage.status !== auditConst.stage.status.checked && !lastStage.readOnly;
- }
- if (bCalcTp) {
- const sum = await this.ctx.service.ledger.addUp({ tender_id: tender.id/* , is_leaf: true*/ });
- tender.total_price = sum.total_price;
- tender.deal_tp = sum.deal_tp;
- }
- tender.sum = ctx.helper.add(tender.total_price, tender.change_tp);
- tender.gather_tp = ctx.helper.sum([lastStage.contract_tp, lastStage.qc_tp, lastStage.pc_tp]);
- tender.end_contract_tp = ctx.helper.sum([lastStage.contract_tp, lastStage.pre_contract_tp, lastStage.contract_pc_tp]);
- tender.end_qc_tp = ctx.helper.sum([lastStage.qc_tp, lastStage.pre_qc_tp, lastStage.qc_pc_tp]);
- tender.end_positive_qc_tp = ctx.helper.sum([lastStage.positive_qc_tp, lastStage.pre_positive_qc_tp, lastStage.positive_qc_pc_tp]);
- tender.end_negative_qc_tp = ctx.helper.sum([lastStage.negative_qc_tp, lastStage.pre_negative_qc_tp, lastStage.negative_qc_pc_tp]);
- tender.end_gather_tp = ctx.helper.add(tender.end_contract_tp, tender.end_qc_tp);
- tender.pre_gather_tp = ctx.helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
- tender.yf_tp = lastStage.yf_tp;
- tender.sf_tp = lastStage.sf_tp;
- tender.qc_ratio = ctx.helper.mul(ctx.helper.div(tender.end_qc_tp, ctx.tender.info.deal_param.contractPrice, 2), 100);
- tender.pre_ratio = ctx.helper.mul(ctx.helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
- tender.cur_ratio = ctx.helper.mul(ctx.helper.div(tender.gather_tp, tender.sum, 2), 100);
- tender.other_tp = ctx.helper.sub(ctx.helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
- tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
- tender.end_yf_tp = ctx.helper.add(lastStage.yf_tp, lastStage.pre_yf_tp);
- tender.end_sf_tp = ctx.helper.add(lastStage.sf_tp, lastStage.pre_sf_tp);
- tender.undone_tp = ctx.helper.sub(ctx.helper.sub(ctx.helper.add(tender.total_price, change_tp), tender.end_contract_tp), tender.end_qc_tp);
- if (lastStage.status === auditConst.stage.status.uncheck) {
- const status_name = await this.ctx.service.projectAccount.getAccountInfoById(lastStage.user_id);
- lastStage.status_users = status_name ? status_name.name : '';
- lastStage.auditors = [];
- } else {
- lastStage.status = lastStage.status === auditConst.stage.status.checkNoPre ? auditConst.stage.status.checking : lastStage.status;
- let cur;
- if (lastStage.status === auditConst.stage.status.checked) {
- cur = await this.ctx.service.stageAudit.getLastestAuditors(lastStage.id, lastStage.times, auditConst.stage.status.checked);
- } else if (lastStage.status === auditConst.stage.status.checking) {
- cur = await this.ctx.service.stageAudit.getCurAuditors(lastStage.id, lastStage.times);
- } else {
- cur = await this.ctx.service.stageAudit.getAuditorsByStatus(lastStage.id, lastStage.status, lastStage.times);
- }
- // const status_name = await this.ctx.service.stageAudit.getAuditorByStatus(lastStage.id, lastStage.status, lastStage.times);
- lastStage.status_users = cur.length > 0 ? (cur[0].audit_type === auditConst.auditType.key.common ? cur[0].name : ctx.helper.transFormToChinese(cur[0].audit_order) + '审') : '';
- const times = lastStage.status === auditConst.stage.status.checkNo ? lastStage.times - 1 : lastStage.times;
- const history = await ctx.service.stageAudit.getAuditorHistory(lastStage.id, times);
- lastStage.auditors = history[history.length - 1];
- }
- } else {
- if (bCalcTp) {
- const sum = await this.ctx.service.ledger.addUp({ tender_id: tender.id/* , is_leaf: true*/ });
- tender.total_price = sum.total_price;
- tender.deal_tp = sum.deal_tp;
- }
- tender.sum = ctx.helper.add(tender.total_price, tender.change_tp);
- if (tender.ledger_status !== auditConst.ledger.status.uncheck) {
- let cur;
- if (tender.ledger_status === auditConst.ledger.status.checked) {
- cur = await this.ctx.service.ledgerAudit.getLastestAuditors(tender.id, tender.ledger_times, auditConst.ledger.status.checked);
- } else if (tender.ledger_status === auditConst.ledger.status.checking) {
- cur = await this.ctx.service.ledgerAudit.getCurAuditors(tender.id, tender.ledger_times);
- } else {
- cur = await this.ctx.service.ledgerAudit.getAuditorsByStatus(tender.id, tender.ledger_status, tender.ledger_times);
- }
- // const status_name = await this.ctx.service.ledgerAudit.getStatusName(tender.id, tender.ledger_times);
- // tender.status_users = status_name ? status_name.name : '';
- tender.status_users = cur.length > 0 ? (cur[0].audit_type === auditConst.auditType.key.common ? cur[0].name : ctx.helper.transFormToChinese(cur[0].audit_order) + '审') : '';
- const times = tender.ledger_status === auditConst.ledger.status.checkNo ? tender.ledger_times - 1 : tender.ledger_times;
- const history = await ctx.service.ledgerAudit.getAuditorHistory(tender.id, times);
- tender.auditors = history[history.length - 1];
- } else {
- const status_name = await this.ctx.service.projectAccount.getAccountInfoById(tender.user_id);
- tender.status_users = status_name ? status_name.name : '';
- }
- }
- const tiModel = new tenderInfoModel(ctx);
- const gclChapter = await tiModel.gatherChapter();
- 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 = ctx.helper.add(ctx.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 = ctx.helper.mul(ctx.helper.div(p.tp, tender.sum, 4), 100);
- sum = ctx.helper.add(sum, p.tp);
- p.end_tp = sum;
- p.end_ratio = ctx.helper.mul(ctx.helper.div(p.end_tp, tender.sum, 4), 100);
- }
- const revise = await ctx.service.ledgerRevise.getLastestRevise(tender.id);
- // const tenders = await ctx.service.tender.getList('', null, 1);
- const tenders = await ctx.service.tender.getList('manage');
- const categoryData = await ctx.service.category.getAllCategory(ctx.subProject);
- // 变更图表数据
- const change_done_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.checked);
- const change_doing_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.checking);
- const change_uncheck_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.uncheck);
- const change_status_total = [
- { num: change_uncheck_total, name: '待上报' },
- { num: change_doing_total, name: '审批中' },
- { num: change_done_total, name: '已完成' },
- ];
- const change_common_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.common.value);
- const change_more_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.more.value);
- const change_great_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.great.value);
- const change_quality_total = [
- { num: change_common_total, name: '一般变更' },
- { num: change_more_total, name: '较大变更' },
- { num: change_great_total, name: '重大变更' },
- ];
- // 调差最新期数据
- const materials = await ctx.service.material.getValidMaterials(ctx.tender.id);
- let materialData = null;
- let openMaterialTax = ctx.session.sessionProject.page_show.openMaterialTax;
- let allMaterialTax = true;
- if (materials && materials.length > 0) {
- materialData = materials[0];
- // materialData.curAuditor = await ctx.service.materialAudit.getAuditorByStatus(materialData.id, materialData.status, materialData.times);
- // const times = materialData.status === auditConst.material.status.checkNo ? materialData.times - 1 : materialData.times;
- // materialData.auditors = materialData.status === auditConst.material.status.uncheck ? [] : await ctx.service.materialAudit.getFinalAuditGroup(materialData.id, times);
- for (const s of materials) {
- if (allMaterialTax && s.material_tax === 0) {
- allMaterialTax = false;
- }
- if (!openMaterialTax && s.material_tax === 1) {
- openMaterialTax = 1;
- }
- }
- materialData.decimal = materialData.decimal ? JSON.parse(materialData.decimal) : materialConst.decimal;
- materialData.status = materialData.status === auditConst.material.status.checkNoPre ? auditConst.material.status.checking : materialData.status;
- const times = materialData.status === auditConst.material.status.checkNo ? materialData.times - 1 : materialData.times;
- let cur;
- if (materialData.status === auditConst.material.status.checked) {
- cur = await this.ctx.service.materialAudit.getLastestAuditors(materialData.id, materialData.times, auditConst.material.status.checked);
- } else if (materialData.status === auditConst.material.status.checking) {
- cur = await this.ctx.service.materialAudit.getCurAuditors(materialData.id, materialData.times);
- } else {
- cur = await this.ctx.service.materialAudit.getAuditorsByStatus(materialData.id, materialData.status, materialData.times);
- }
- // const status_name = await this.ctx.service.stageAudit.getAuditorByStatus(lastStage.id, lastStage.status, lastStage.times);
- materialData.status_users = cur.length > 0 ? (cur[0].audit_type === auditConst.auditType.key.common ? cur[0].name : ctx.helper.transFormToChinese(cur[0].audit_order) + '审') : '';
- const history = await ctx.service.materialAudit.getAuditorHistory(materialData.id, times);
- materialData.auditors = history[history.length - 1];
- }
- // 修订完成数目
- // const reviseNum = await ctx.service.ledgerRevise.count({ tid: tender.id, status: auditConst.revise.status.checked });
- // 计量完成概况
- // tender.total_price
- const stage_total = [
- { num: tender.end_contract_tp ? tender.end_contract_tp : 0, name: '合同完成' },
- { num: tender.end_qc_tp ? tender.end_qc_tp : 0, name: '变更完成' },
- { num: tender.undone_tp ? tender.undone_tp : 0, name: '未完成' },
- ];
- // 地图
- const tenderALLInfo = await ctx.service.tender.getDataById(tender.id);
- const hadMap = tenderALLInfo.had_map === 0 ? 3 : tenderALLInfo.had_map;// 0为初始值,因为默认可能会变化,所以暂时把0都默认为1。共三种模式坐标模式1,图片模式2,无图模式3。
- // const tenderMapList = await ctx.service.tenderMap.getAllDataByCondition({ where: { tid: tender.id } });
- const tenderMapList = [];
- // 默认坐标,否则则取办事处坐标
- // const projectData = await ctx.service.project.getDataById(ctx.session.sessionProject.id);
- // let map_json = {
- // province: mapConst.map[0].province,
- // lng: mapConst.map[0].lng,
- // lat: mapConst.map[0].lat,
- // level: 15,
- // };
- // if (projectData.map_json) {
- // map_json = JSON.parse(projectData.map_json);
- // } else {
- // const mapInfo = ctx.helper._.find(mapConst.map, { office: projectData.manager_office });
- // if (mapInfo) {
- // map_json.province = mapInfo.province;
- // map_json.lng = mapInfo.lng;
- // map_json.lat = mapInfo.lat;
- // }
- // }
- const canFinish = await this.ctx.service.tender.checkTenderCanFinish(tender);
- const projectSpread = await ctx.service.projectSpread.getProjectSpreadType(tender.project_id);
- const renderData = {
- tenders,
- categoryData,
- tender,
- revise,
- tenderInfo: ctx.tender.info,
- tenderMenu: this.menu.tenderMenu,
- preUrl: '/tender/' + ctx.tender.id,
- cooperation: ctx.session.sessionUser.cooperation,
- lastStage,
- stages: stages.reverse(),
- monthProgress,
- audit: auditConst,
- change_status_total,
- change_quality_total,
- materialData,
- openMaterialTax,
- allMaterialTax,
- // reviseNum,
- stage_total,
- hadMap,
- map_pic: tenderALLInfo.map_pic,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.tenderInfo),
- gclChapter,
- tenderMapList,
- // map_json,
- fujianOssPath: ctx.app.config.fujianOssPath,
- canFinish,
- buildStatus: tenderConst.buildStatus,
- projectSpread,
- };
- if (ctx.session.sessionUser.is_admin) {
- renderData.tourists = await ctx.service.tenderTourist.getTourists(tender.id);
- for (const t of renderData.tourists) {
- t.permission = await ctx.service.tenderTourist.getTouristPermission(t);
- }
- // 获取所有项目参与者
- const 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 } });
- const accountGroupList = unitList.map(item => {
- const groupList = accountList.filter(item1 => item1.company === item.name);
- return { groupName: item.name, groupList };
- });
- renderData.accountList = accountList;
- renderData.accountGroup = accountGroupList;
- }
- if (ctx.session.sessionProject.page_show.xxjd && ctx.session.sessionUser.is_admin) {
- // 投资进度内容
- renderData.scheduleAuditList = await ctx.service.scheduleAudit.getAllDataByCondition({ where: { tid: tender.id } });
- renderData.scPermission = scheduleConst.permission;
- }
- await this.layout('tender/detail.ejs', renderData, 'tender/detail_modal.ejs');
- } catch (error) {
- this.log(error);
- this.ctx.redirect('/list');
- }
- }
- /**
- * 保存标段属性等(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async saveTenderInfo(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data) {
- throw '提交数据错误';
- }
- // 针对查阅所有标段者但非原报和审批人提示
- const times = ctx.tender.data.ledger_status === auditConst.ledger.status.checkNo ? ctx.tender.data.ledger_times - 1 : ctx.tender.data.ledger_times;
- const auditors = await this.service.ledgerAudit.getAuditors(ctx.tender.id, times);
- const auditorsId = ctx.helper._.map(auditors, 'audit_id');
- const stageAuditors = await this.service.stageAudit.getAllAuditors(ctx.tender.id);
- const stageAUditorsId = ctx.helper._.map(stageAuditors, 'aid');
- const accountId = ctx.session.sessionUser.accountId;
- if (auditorsId.indexOf(accountId) === -1 && ctx.tender.data.user_id !== accountId &&
- stageAUditorsId.indexOf(accountId) === -1 && !ctx.session.sessionUser.is_admin) {
- throw '您无权修改标段设置内容';
- }
- if (ctx.tender.data.ledger_status === auditConst.ledger.status.checked) {
- if (data.deal_param && !ctx.session.sessionUser.is_admin) {
- const lastStage = await this.ctx.service.stage.getLastestStage(ctx.tender.id, true);
- if (lastStage) {
- if (lastStage.order > 1 || (lastStage.status === auditConst.stage.status.checked || lastStage.status === auditConst.stage.status.checking)) throw '第一期上报后不可修改合同参数';
- if (lastStage.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改合同参数';
- }
- }
- }
- if (data.decimal) {
- if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改小数位数';
- await ctx.service.tenderInfo.saveDecimal(ctx.tender.id, data.decimal, ctx.tender.info.decimal);
- } else if (data.precision) {
- if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改清单精度';
- await ctx.service.tenderInfo.savePrecision(ctx.tender.id,
- data.precision, ctx.tender.info.precision, ctx.tender.info.decimal);
- } else {
- await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, data);
- if (data.deal_param) ctx.service.tenderCache.updateContractPriceCache(ctx.tender);
- }
- ctx.body = { err: 0, msg: '', data: JSON.parse(ctx.request.body.data) };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '保存标段设置失败');
- }
- }
- async saveTenderInfo2(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data || (!data.ledger_check && !data.fun_rela && !data.s_type && !data.over_range_check)) throw '提交数据错误';
- if (!ctx.session.sessionUser.is_admin) throw '您无权修改该内容';
- const updateData = {};
- if (data.ledger_check) updateData.ledger_check = data.ledger_check;
- if (data.fun_rela) updateData.fun_rela = data.fun_rela;
- await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, data);
- ctx.body = { err: 0, msg: '', data: JSON.parse(ctx.request.body.data) };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '保存失败');
- }
- }
- async saveBuildStatus(ctx) {
- try {
- const status = parseInt(ctx.query.status || ctx.request.body.status);
- await ctx.service.tender.saveBuildStatus(ctx.tender.data, status);
- } catch (err) {
- this.log(err);
- this.postError(err, '修改在建状态失败');
- }
- ctx.redirect(ctx.request.header.referer);
- }
- /**
- * 设置标段计量类型并调整到标段概况(Get)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async tenderType(ctx) {
- try {
- const tenderId = ctx.params.id,
- type = ctx.query.type;
- if (!tenderId) {
- throw '当前未打开标段';
- }
- await ctx.service.tender.checkTender(tenderId);
- if (!ctx.tender) {
- throw '标段数据错误';
- }
- if (!ctx.tender.measure_type) {
- await ctx.service.tender.setTenderType(ctx.tender, parseInt(type));
- }
- ctx.redirect('/tender/' + tenderId);
- } catch (error) {
- ctx.helper.log(error);
- this.postError(error, '设置标段类型错误');
- ctx.redirect('/list');
- }
- }
- /**
- * 标段协作办公
- *
- * @param {Object} ctx - egg全局变量
- * @return {void}
- */
- async tenderCooperation(ctx) {
- const tenderId = ctx.params.id;
- try {
- if (!ctx.session.sessionUser.cooperation) {
- throw '权限不足';
- }
- const tender = await ctx.service.tender.getDataById(tenderId);
- const user = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
- // 获取已参与协作用户列表
- const cooperationArray = [];
- if (tender.cooperation !== null && tender.cooperation !== '') {
- const cooperationList = JSON.parse(tender.cooperation);
- for (const cl in cooperationList) {
- const clArray = [];
- for (const audit of cooperationList[cl]) {
- const userInfo = await ctx.service.projectAccount.getDataById(audit);
- clArray.push(userInfo);
- }
- cooperationArray[cl] = clArray;
- }
- }
- const renderData = {
- user,
- tender,
- tenderMenu: this.menu.tenderMenu,
- preUrl: '/tender/' + tenderId,
- tenderPermissionList: accountPermission.tenderPermissionList,
- cooperationArray,
- };
- await this.layout('tender/cooperation.ejs', renderData, 'tender/cooperationModal.ejs');
- } catch (error) {
- ctx.helper.log(error);
- this.ctx.redirect('/tender/' + tenderId);
- }
- }
- /**
- * 添加标段操作
- *
- * @param {Object} ctx - egg全局变量
- * @return {void}
- */
- async add(ctx) {
- try {
- const rule = ctx.service.tender.rule('add');
- ctx.helper.validate(rule);
- const result = ctx.service.tender.add(ctx.request.body);
- if (!result) {
- throw '新增标段失败';
- }
- } catch (error) {
- ctx.helper.log(error);
- this.setMessage(error.toString(), this.messageType.ERROR);
- }
- ctx.redirect(ctx.request.header.referer);
- }
- /**
- * 保存标段操作
- *
- * @param {Object} ctx - egg全局变量
- * @return {void}
- */
- async save(ctx) {
- let id = ctx.request.body.tenderId;
- id = parseInt(id);
- try {
- if (isNaN(id) || id < 0) {
- throw '参数错误';
- }
- // 获取数据规则
- const rule = ctx.service.tender.rule('save');
- ctx.validate(rule);
- const result = await ctx.service.tender.save(ctx.request.body, id);
- if (!result) {
- throw '保存标段数据失败';
- }
- this.setMessage('保存标段数据成功', this.messageType.SUCCESS);
- } catch (error) {
- this.postError(error, '保存标段数据失败');
- }
- ctx.redirect(ctx.request.header.referer);
- }
- /**
- * 删除标段
- *
- * @param {Object} ctx -egg全局变量
- * @return {void}
- */
- async delete(ctx) {
- let id = ctx.request.body.tenderId;
- id = parseInt(id);
- try {
- if (isNaN(id) || id <= 0) {
- throw '参数错误';
- }
- const result = ctx.service.tender.deleteTenderById(id);
- if (!result) {
- throw '删除标段失败';
- }
- this.setMessage('删除标段成功', this.messageType.SUCCESS);
- } catch (error) {
- this.postError(error, '删除标段失败');
- }
- ctx.redirect(ctx.request.header.referer);
- }
- async rule(ctx) {
- const responseData = {
- err: 0,
- msg: '',
- data: {},
- };
- try {
- const tenderId = ctx.session.sessionUser.tenderId;
- if (!tenderId) {
- throw '当前未打开标段';
- }
- const data = JSON.parse(ctx.request.body.data);
- if (!data.rule || !JSON.parse(data.data).length || !codeRuleConst.ruleField[data.rule]) {
- throw '请选择组件再添加';
- }
- if (!data.connector) {
- throw '请选择连接符';
- }
- const updateData = {
- id: tenderId,
- };
- if (data.type) {
- const tenderData = await ctx.service.tender.getDataById(tenderId);
- const c_code_rules = tenderData.c_code_rules ? JSON.parse(tenderData.c_code_rules) : {};
- c_code_rules[data.type + '_rule'] = JSON.parse(data.data);
- c_code_rules[data.type + '_rule_first'] = 0;
- c_code_rules[data.type + '_connector'] = data.connector;
- updateData.c_code_rules = JSON.stringify(c_code_rules);
- } else {
- updateData[codeRuleConst.ruleField[data.rule]] = data.data;
- updateData.c_connector = data.connector;
- updateData.c_rule_first = 0;
- }
- const result = await ctx.service.tender.db.update(ctx.service.tender.tableName, updateData);
- if (result.affectedRows !== 1) {
- throw '更新规则失败';
- }
- } catch (err) {
- ctx.helper.log(err);
- responseData.err = 1;
- responseData.msg = err.toString();
- }
- ctx.body = responseData;
- }
- async ruleFirst(ctx) {
- const responseData = {
- err: 0,
- msg: '',
- data: {},
- };
- try {
- const tenderId = ctx.session.sessionUser.tenderId;
- if (!tenderId) {
- throw '当前未打开标段';
- }
- const updateData = {
- id: tenderId,
- };
- const data = JSON.parse(ctx.request.body.data);
- if (data && data.type) {
- const tenderData = await ctx.service.tender.getDataById(tenderId);
- const c_code_rules = tenderData.c_code_rules ? JSON.parse(tenderData.c_code_rules) : {};
- c_code_rules[data.type + '_rule_first'] = 0;
- updateData.c_code_rules = JSON.stringify(c_code_rules);
- } else {
- updateData.c_rule_first = 0;
- }
- const result = await ctx.service.tender.db.update(ctx.service.tender.tableName, updateData);
- if (result.affectedRows !== 1) {
- throw '更新规则失败';
- }
- } catch (err) {
- ctx.helper.log(err);
- responseData.err = 1;
- responseData.msg = err.toString();
- }
- ctx.body = responseData;
- }
- async shenpiSet(ctx) {
- if (ctx.session.sessionUser.is_admin === 0) {
- ctx.request.headers.referer ? ctx.redirect(ctx.request.headers.referer) : ctx.redirect('/list');
- }
- // 获取所有项目参与者
- const 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 } });
- const accountGroupList = unitList.map(item => {
- const groupList = accountList.filter(item1 => item1.company === item.name);
- return { groupName: item.name, groupList };
- });
- // 获取固定审批流 or 固定终审
- const spConst = ctx.helper._.cloneDeep(shenpiConst);
- for (const sp of spConst.sp_lc) {
- sp.status = ctx.tender.info.shenpi ? ctx.tender.info.shenpi[sp.code] : spConst.sp_status.sqspr;
- if (sp.status === shenpiConst.sp_status.gdspl) {
- sp.groupList = await ctx.service.shenpiGroup.getGroupList(ctx.tender.id, sp.type) || [];
- if (sp.groupList && sp.groupList.length > 0) {
- for (const group of sp.groupList) {
- if (group.change_type) group.change_type = JSON.parse(group.change_type);
- group.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(ctx.tender.id, sp.type, sp.status, group.id);
- if (group.is_select) sp.auditGroupList = group.auditGroupList;
- }
- } else {
- sp.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(ctx.tender.id, sp.type, sp.status);
- }
- } else if (sp.status === shenpiConst.sp_status.gdzs) {
- sp.audit = await ctx.service.shenpiAudit.getAudit(ctx.tender.id, sp.type, sp.status);
- }
- }
- const tenders = await ctx.service.tender.getList('', null, 1);
- const removeTenders = await ctx.service.shenpiAudit.getRemoveTenders(tenders);
- if (removeTenders.length > 0) {
- ctx.helper._.remove(tenders, function(n) {
- return removeTenders.indexOf(n.id) !== -1;
- });
- }
- const categoryData = await ctx.service.category.getAllCategory(ctx.subProject);
- // 是否修订中
- const lastRevise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
- const revising = (lastRevise && lastRevise.status !== auditConst.revise.status.checked) || false;
- const cooperationNum = await ctx.service.ledgerCooperation.count({ tid: ctx.tender.id, status: 1 });
- const renderData = {
- shenpi: spConst,
- accountList,
- accountGroup: accountGroupList,
- tenders,
- categoryData,
- auditConst,
- revising,
- measureType,
- cooperationNum,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.shenpi),
- auditType: auditConst.auditType,
- change_type_list: shenpiConst.change_type_list,
- };
- await this.layout('tender/shenpi.ejs', renderData, 'tender/shenpi_modal.ejs');
- }
- async saveTenderInfoShenpi(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data) {
- throw '提交数据错误';
- }
- // 判断修改权限
- if (ctx.session.sessionUser.is_admin === 0) {
- throw '你没有权限修改审批流程';
- }
- // let postData = {};
- // if (!ctx.tender.info.shenpi) {
- // for (const sp of shenpiConst.sp_lc) {
- // if (sp.code === data.code) {
- // postData[sp.code] = data.status;
- // } else {
- // postData[sp.code] = shenpiConst.sp_status.sqspr;
- // }
- // }
- // } else {
- const postData = ctx.tender.info.shenpi;
- postData[data.code] = data.status;
- if (data.code === shenpiConst.sp_lc[shenpiConst.sp_type.stage - 1].code) {
- const status = parseInt(data.status) === shenpiConst.sp_status.gdspl ? 1 : 0;
- await ctx.service.ledgerCooperation.changeAllStatus(status);
- }
- // }
- await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, { shenpi: postData });
- let auditList = [];
- let groupList = [];
- if (data.status === shenpiConst.sp_status.gdspl) {
- groupList = await ctx.service.shenpiGroup.getGroupList(ctx.tender.id, shenpiConst.sp_type[data.code]) || [];
- if (groupList && groupList.length > 0) {
- for (const group of groupList) {
- if (group.change_type) group.change_type = JSON.parse(group.change_type);
- group.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(ctx.tender.id, shenpiConst.sp_type[data.code], data.status, group.id);
- if (group.is_select) auditList = group.auditGroupList;
- }
- } else {
- auditList = await ctx.service.shenpiAudit.getAuditGroupList(ctx.tender.id, shenpiConst.sp_type[data.code], data.status);
- }
- } else if (data.status === shenpiConst.sp_status.gdzs) {
- auditList = await ctx.service.shenpiAudit.getAudit(ctx.tender.id, shenpiConst.sp_type[data.code], data.status);
- }
- ctx.body = { err: 0, msg: '', data: { auditList, groupList } };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '保存审批流程设置失败');
- }
- }
- async saveShenpiAudit(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data) {
- throw '提交数据错误';
- }
- // 判断修改权限
- if (ctx.session.sessionUser.is_admin === 0) {
- throw '你没有权限修改审批流程';
- }
- let info = '';
- switch (data.type) {
- case 'add':
- info = await ctx.service.shenpiAudit.addAudit(data);
- break;
- case 'del':
- await ctx.service.shenpiAudit.removeAudit(data);
- break;
- case 'copy2ot':
- await ctx.service.shenpiAudit.copyAudit2otherTender(data);
- break;
- case 'copy2os':
- await ctx.service.shenpiAudit.copyAudit2otherShenpi(data);
- break;
- case 'pwd':
- info = await ctx.service.ledgerCooperation.save(data);
- break;
- case 'company':
- info = await ctx.service.ledgerCooperation.saveCompany(data);
- break;
- case 'audit-ass':
- info = await ctx.service.auditAss.updateData(data);
- break;
- case 'audit-type':
- await ctx.service.shenpiAudit.setAuditType(data);
- break;
- case 'save-group':
- info = await ctx.service.shenpiGroup.saveGroup(ctx.tender.id, data);
- break;
- case 'change-group':
- await ctx.service.shenpiGroup.changeGroup(data);
- break;
- case 'delete-group':
- await ctx.service.shenpiGroup.deleteGroup(data);
- break;
- default:break;
- }
- ctx.body = { err: 0, msg: '', data: info };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '保存审批流程设置失败');
- }
- }
- /**
- * 签名,上传图片 (Ajax)
- * @param ctx
- * @return {Promise<void>}
- */
- async saveCooperateSign(ctx) {
- try {
- const stream = await ctx.getFileStream();
- const create_time = Date.parse(new Date()) / 1000;
- const id = stream.fields.id;
- const fileInfo = path.parse(stream.filename);
- const fileName = path.join('public/upload', ctx.tender.id.toString(), 'sign', 'signImg_' + create_time + fileInfo.ext);
- await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', fileName));
- if (stream) {
- await sendToWormhole(stream);
- }
- await ctx.service.ledgerCooperation.saveSign(id, fileName);
- ctx.body = { err: 0, msg: '', data: fileName };
- } catch (err) {
- this.log(err);
- ctx.body = { err: 1, msg: err.toString(), data: null };
- }
- }
- /**
- * 拷贝设置
- * @param {object} ctx - 上下文
- */
- async copyTender(ctx) {
- try {
- const id = ctx.tender.data.id;
- const { id: copy_id = '', type: typeArr = [] } = JSON.parse(ctx.request.body.data);
- await ctx.service.tenderInfo.copyTenderHandler(id, copy_id, typeArr);
- ctx.body = { err: 0, msg: '' };
- } catch (error) {
- this.log(error);
- ctx.body = this.ajaxErrorBody(error, '保存审批流程设置失败');
- }
- }
- async certSet(ctx) {
- try {
- const allCertList = await ctx.service.accountCert.getAllCertByPid(ctx.session.sessionProject.id);
- const tenderCertList = await ctx.service.tenderCert.getListByTid(ctx.tender.id, allCertList);
- const renderData = {
- allCertList,
- tenderCertList,
- certTypeConst: profileConst.cert.certType,
- certSourceConst: [...profileConst.cert.certReg, ...profileConst.cert.certQual],
- fujianOssPath: ctx.app.config.fujianOssPath,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.cert),
- };
- const uidList = ctx.helper._.uniq(ctx.helper._.map(allCertList, 'uid'));
- const accountList = uidList.length > 0 ? await ctx.service.projectAccount.getAllDataByCondition({
- where: { project_id: ctx.session.sessionProject.id, enable: 1, id: uidList },
- columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
- }) : [];
- renderData.accountList = accountList;
- const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
- renderData.accountGroup = unitList.map(item => {
- const groupList = accountList.filter(item1 => item1.company === item.name);
- return { groupName: item.name, groupList };
- });
- await this.layout('tender/cert.ejs', renderData, 'tender/cert_modal.ejs');
- } catch (err) {
- this.log(err);
- ctx.redirect('/tender/' + ctx.tender.id);
- }
- }
- async saveCert(ctx) {
- const response = { err: 0, msg: '', data: {} };
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data) {
- throw '提交数据错误';
- }
- switch (data.type) {
- case 'save_user':
- response.data = await ctx.service.tenderCert.saveUserCert(ctx.tender.id, data.list);
- break;
- case 'update_cert':
- response.data = await ctx.service.tenderCert.updateOneCert(data.update_data);
- break;
- case 'paste_cert':
- response.data = await ctx.service.tenderCert.updateMoreCert(ctx.tender.id, data.update_data);
- break;
- default:break;
- }
- ctx.body = response;
- } catch (err) {
- this.log(err);
- ctx.body = { err: 1, msg: err.toString(), data: {} };
- }
- }
- /**
- * 游客账号设置
- * @param {object} ctx - 上下文
- */
- async saveTourist(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data) {
- throw '提交数据错误';
- }
- // 判断修改权限
- if (ctx.session.sessionUser.is_admin === 0) {
- throw '你没有权限修改游客账号';
- }
- let info = '';
- switch (data.type) {
- case 'add':
- const result = await ctx.service.tenderTourist.addAudit(data);
- if (!result) {
- throw '添加审批人失败';
- }
- info = result;
- break;
- case 'del':
- await ctx.service.tenderTourist.removeAudit(data);
- break;
- case 'permission':
- await ctx.service.tenderTourist.setPermission(data);
- break;
- default:break;
- }
- ctx.body = { err: 0, msg: '', data: info };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '保存游客账号设置失败');
- }
- }
- /**
- * 获取设置协同人相关(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async loadAuditAss(ctx) {
- try {
- const ledgerData = await ctx.service.ledger.getAllDataByCondition({
- columns: ['id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf', 'code', 'b_code', 'name'],
- where: { tender_id: ctx.tender.id }
- });
- const result = ledgerData.filter(x => { return !x.b_code; });
- const auditAssList = await ctx.service.auditAss.getData(ctx.tender.id);
- ctx.body = { err: 0, msg: '', data: { ledgerList: result, auditAssList } };
- } catch (err) {
- this.log(err);
- ctx.body = { err: 1, msg: err.toString(), data: [] };
- }
- }
- async loadUnionAudit(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const result = {};
- result.unionAuditors = await ctx.service.shenpiAudit.getUnionAudit(ctx.tender.id, shenpiConst.sp_type[data.sp_type], data.audit_order);
- if (data.ledger) {
- const ledgerData = await ctx.service.ledger.getAllDataByCondition({
- columns: ['id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf', 'code', 'b_code', 'name'],
- where: { tender_id: ctx.tender.id }
- });
- result.ledgerList = ledgerData.filter(x => { return !x.b_code; });
- }
- ctx.body = { err: 0, msg: '', data: result };
- } catch (err) {
- this.log(err);
- ctx.body = { err: 1, msg: err.toString(), data: [] };
- }
- }
- async saveUnionAudit(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- await ctx.service.shenpiAudit.saveUnionAudit(ctx.tender.id, data);
- ctx.body = {err: 0, msg: '', data: null};
- } catch(err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存协同审批数据错误');
- }
- }
- async billsTag(ctx) {
- try {
- const isValidTourist = ctx.tender.isTourist && ctx.tender.touristPermission.tag;
- if (ctx.stage) {
- const isAuditor = ctx.stage.userIds.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
- if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
- } else if (ctx.revise) {
- const isAuditor = ctx.revise.reviseUsers.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
- if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
- } else if (ctx.settle) {
- const isAuditor = ctx.settle.userIds.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
- if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
- } else {
- const isAuditor = ctx.tender.ledgerUsers.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
- if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
- }
- const data = JSON.parse(ctx.request.body.data);
- const result = await ctx.service.ledgerTag.update(data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '书签数据错误');
- }
- }
- async listLoad(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.type || !data.tid) throw '数据错误';
- if (data.type !== 'stageBatch' && !data.lid) throw '数据错误';
- const responseData = {
- err: 0,
- msg: '',
- data: { ledgerAuditConst: auditConst.ledger, stageAuditConst: auditConst.stage },
- };
- responseData.data.category = await this.ctx.service.category.getAllCategory(ctx.subProject);
- // 获取用户权限
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
- const tenderList = await this.ctx.service.tender.getList('', userPermission);
- for (const t of tenderList) {
- if (t.ledger_status === auditConst.ledger.status.checked) {
- t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, false);
- }
- }
- if (data.type === 'all') {
- responseData.data.tenders = tenderList;
- } else if (data.type === 'ledger') {
- responseData.data.tenders = tenderList.filter(x => {
- return x.ledger_status === auditConst.ledger.status.checked;
- });
- const history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
- if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
- } else if (data.type === 'stage') {
- responseData.data.tenders = tenderList.filter(x => {
- return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
- });
- let history = await this.ctx.service.sumLoadHistory.getStageHistory(data.tid, data.lid);
- if (history) {
- responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'stage' };
- } else {
- history = await this.ctx.service.sumLoadHistory.getReviseHistory(data.tid, data.lid);
- if (history) {
- responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'revise' };
- } else {
- history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
- if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
- }
- }
- } else if (data.type === 'stageBatch') {
- responseData.data.tenders = tenderList.filter(x => {
- return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
- });
- responseData.data.history = await this.ctx.service.sumLoadHistory.getBatchHistory(data.tid);
- } else if (data.type === 'revise') {
- responseData.data.tenders = tenderList.filter(x => {
- return x.ledger_status === auditConst.ledger.status.checked;
- });
- let history = await this.ctx.service.sumLoadHistory.getReviseHistory(data.tid, data.lid);
- if (history) {
- responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'revise' };
- } else {
- history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
- if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
- }
- }
- ctx.body = responseData;
- } catch (err) {
- this.log(err);
- this.ajaxErrorBody(err, '获取标段列表错误');
- }
- }
- async listLoad2(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.type) throw '数据错误';
- const responseData = {
- err: 0,
- msg: '',
- data: { ledgerAuditConst: auditConst.ledger, stageAuditConst: auditConst.stage },
- };
- responseData.data.category = await this.ctx.service.category.getAllCategory(ctx.subProject);
- // 获取用户权限
- const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
- const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
- const tenderList = await this.ctx.service.tender.getList('', userPermission);
- for (const t of tenderList) {
- if (t.ledger_status === auditConst.ledger.status.checked) {
- t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, false);
- t.lastCheckedStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
- }
- }
- if (data.type === 'all') {
- responseData.data.tenders = tenderList;
- } else if (data.type === 'ledger-checked') {
- responseData.data.tenders = tenderList.filter(x => {
- return x.ledger_status === auditConst.ledger.status.checked;
- });
- } else if (data.type === 'stage') {
- responseData.data.tenders = tenderList.filter(x => {
- return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
- });
- } else if (data.type === 'stage-checked') {
- responseData.data.tenders = tenderList.filter(x => {
- return x.ledger_status === auditConst.ledger.status.checked && !!x.lastCheckedStage;
- });
- } else if (data.type === 'stageBatch') {
- responseData.data.tenders = tenderList.filter(x => {
- return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
- });
- }
- ctx.body = responseData;
- } catch (err) {
- this.log(err);
- this.ajaxErrorBody(err, '获取标段列表错误');
- }
- }
- async sumLoad(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.lid || !data.type || !data.tenders) throw '数据错误';
- switch (data.type) {
- case 'ledger':
- const refreshData = await this.ctx.service.ledger.sumLoad(data.lid, data.tenders);
- ctx.body = {err: 0, msg: '', data: refreshData};
- break;
- case 'revise':
- const reviseData = await this.ctx.service.reviseBills.sumLoad(data.lid, this.ctx.revise.id, data.tenders, data.subUp);
- ctx.body = {err: 0, msg: '', data: reviseData};
- break;
- case 'stage':
- const stageData = await this.ctx.service.stageBills.sumLoad(data.lid, data.tenders, data.cover, data.ignore, data.change);
- stageData.import_change = { target: { import_lid: data.lid } };
- stageData.import_change.data = await this.ctx.service.stageImportChange.getLeafXmjStageImportData(ctx.stage, data.lid);
- await ctx.service.stage.updateCheckCalcFlag(ctx.stage, true);
- await ctx.service.stage.updateCacheTime(ctx.stage.id);
- ctx.body = {err: 0, msg: '', data: stageData};
- break;
- default:
- throw '数据错误';
- }
- } catch (err) {
- this.log(err);
- ctx.ajaxErrorBody(err, '导入数据失败');
- }
- }
- async auditAssist(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.user_id || !data.type) throw '数据错误';
- switch (data.type) {
- case 'stage':
- const stageAssists = await this.ctx.service.stageAuditAss.getUserAssist(ctx.stage, data.user_id);
- ctx.body = { err: 0, msg: '', data: stageAssists };
- break;
- default:
- throw '数据错误';
- }
- } catch (err) {
- this.log(err);
- ctx.ajaxErrorBody(err, '操作失败');
- }
- }
- async auditAssistConfirm(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.user_id || !data.ass_user_id || !data.type || data.confirm === undefined) throw '数据错误';
- switch (data.type) {
- case 'stage':
- const stageAss = await this.ctx.service.stageAuditAss.updateData(data);
- ctx.body = { err: 0, msg: '', data: stageAss };
- break;
- default:
- throw '数据错误';
- }
- } catch (err) {
- this.log(err);
- ctx.ajaxErrorBody(err, '操作失败');
- }
- }
- /**
- * 地图数据设置(Ajax)
- *
- * @param ctx
- * @return {Promise<void>}
- */
- async saveMap(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data) {
- throw '提交数据错误';
- }
- // 判断修改权限
- if (ctx.session.sessionUser.is_admin === 0) {
- throw '你没有权限修改概况设置';
- }
- let info = '';
- let result = '';
- switch (data.type) {
- case 'select-map':
- result = await ctx.service.tender.saveTenderData(ctx.tender.id, { had_map: data.value });
- if (!result) {
- throw '修改概况设置失败';
- }
- info = result;
- break;
- case 'add-map':
- result = await ctx.service.tenderMap.addMap(ctx.tender.id, data.name);
- info = await ctx.service.tenderMap.getDataById(result.insertId);
- break;
- case 'del-map':
- await ctx.service.tenderMap.deleteById(data.id);
- break;
- case 'save-map':
- await ctx.service.tenderMap.saveMap(data.mapData);
- break;
- default:break;
- }
- ctx.body = { err: 0, msg: '', data: info };
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '保存概况设置失败');
- }
- }
- /**
- * 上传静态图
- *
- * @param {object} ctx - egg全局变量
- * @return {void}
- */
- async uploadMap(ctx) {
- const responseData = {
- err: 0, msg: '', data: null,
- };
- try {
- const stream = await ctx.getFileStream();
- const create_time = Date.parse(new Date()) / 1000;
- const fileInfo = path.parse(stream.filename);
- const filepath = `app/public/upload/${ctx.tender.id}/map/${create_time}${fileInfo.ext}`;
- await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
- await sendToWormhole(stream);
- const tenderInfo = await ctx.service.tender.getDataById(ctx.tender.id);
- const oldMapPic = tenderInfo && tenderInfo.map_pic ? tenderInfo.map_pic : null;
- const result = await ctx.service.tender.update({ map_pic: filepath }, { id: ctx.tender.id });
- if (result) {
- // 移除旧的map_pic oss
- if (oldMapPic) {
- await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + oldMapPic);
- }
- responseData.data = { map_pic: filepath };
- } else {
- throw '添加数据库失败';
- }
- } catch (err) {
- this.log(err);
- responseData.err = 1;
- responseData.msg = err;
- }
- ctx.body = responseData;
- }
- async loadData(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const filter = data.filter.split(';');
- const responseData = { err: 0, msg: '', data: {} };
- const where = { tid: this.ctx.tender.id };
- for (const f of filter) {
- switch (f) {
- case 'change':
- where.valid = 1;
- if (ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.flow.status.checked;
- responseData.data[f] = await ctx.service.change.getAllDataByCondition({
- columns: [ 'cid', 'code', 'name', 'selected' ],
- where,
- orders: [['in_time', 'desc']],
- });
- break;
- case 'change_project':
- if (ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.changeProject.status.checked;
- responseData.data[f] = await ctx.service.changeProject.getAllDataByCondition({
- columns: [ 'id', 'code', 'name', 'selected' ],
- where,
- orders: [['in_time', 'desc']],
- });
- break;
- case 'change_apply':
- if (ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.changeApply.status.checked;
- responseData.data[f] = await ctx.service.changeApply.getAllDataByCondition({
- columns: [ 'id', 'code', 'name', 'selected' ],
- where,
- orders: [['in_time', 'desc']],
- });
- break;
- case 'change_plan':
- if (ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.changeApply.status.checked;
- responseData.data[f] = await ctx.service.changePlan.getAllDataByCondition({
- columns: [ 'id', 'code', 'name', 'selected' ],
- where,
- orders: [['in_time', 'desc']],
- });
- break;
- case 'advance':
- const advance = await ctx.service.advance.getAllDataByCondition({
- columns: [ 'id', 'order', 'status', 'selected', 'type' ],
- where,
- orders: [['type', 'asc'], ['create_time', 'desc']],
- });
- advance.forEach(x => {
- x.orderStr = `第${x.order}期`;
- x.statusStr = auditConst.advance.statusString[x.status];
- x.typeStr = advanceConst.typeColMap[x.type].text;
- });
- responseData.data[f] = advance;
- break;
- case 'pm_deal':
- if (accountPermission.PermissionCheck.viewPmData(this.ctx.session.sessionUser.permission)) {
- const selects = await this.ctx.service.project.getPmDealCache(this.ctx.session.sessionProject.id);
- const pm = require('../lib/pm');
- const tenders = await pm.dealCatagory(ctx, this.ctx.session.sessionProject.code);
- tenders.forEach(x => {
- x.selected = selects.indexOf(x.bidsectionId + '') >= 0;
- });
- responseData.data[f] = tenders;
- } else {
- throw '您无权查看该数据';
- }
- break;
- case 'show_level':
- responseData.data[f] = ctx.tender.data.rpt_show_level;
- break;
- case 'tender_info':
- responseData.data[f] = ctx.tender.info;
- break;
- default:
- throw '未知数据类型';
- }
- }
- ctx.body = responseData;
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '加载数据错误');
- }
- }
- async saveRelaData(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const responseData = { err: 0, msg: '', data: {} };
- if (data.change) await this.ctx.service.change.updateChangeSelect(data.change);
- if (data.change_apply) await this.ctx.service.changeApply.defaultUpdateRows(data.change_apply);
- if (data.change_project) await this.ctx.service.changeProject.defaultUpdateRows(data.change_project);
- if (data.change_plan) await this.ctx.service.changePlan.defaultUpdateRows(data.change_plan);
- if (data.advance) await this.ctx.service.advance.defaultUpdateRows(data.advance);
- if (data.pm_deal) await this.ctx.service.project.setPmDealCache(this.ctx.session.sessionProject.id, data.pm_deal);
- if (data.show_level) await this.ctx.service.tender.saveTenderData(ctx.tender.id, { rpt_show_level: data.show_level });
- ctx.body = responseData;
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存数据错误');
- }
- }
- async refreshCache(ctx) {
- try {
- const tid = ctx.query.tid;
- if (!tid) throw '参数错误';
- const tender = await this.ctx.service.tender.getTender(tid);
- await this.ctx.service.tenderCache.refreshTenderCache(tender);
- } catch (err) {
- ctx.log(err);
- }
- ctx.redirect(ctx.request.header.referer);
- }
- async saveExpr(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.calc_module || !data.calc_tag || !data.calc_id) throw '保存计算式参数有误';
- await this.ctx.service.expr.saveExpr(ctx.tender.id, data);
- ctx.body = { err: 0, msg: '', data: data.expr };
- } catch(err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存计算式失败');
- }
- }
- async loadExpr(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.calc_module || !data.calc_tag || !data.calc_id) throw '获取计算式参数有误';
- const expr = await this.ctx.service.expr.loadExpr(ctx.tender.id, data);
- ctx.body = { err: 0, msg: '', data: expr };
- } catch(err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存计算式失败');
- }
- }
- }
- return TenderController;
- };
|