stage_controller.js 70 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date 2018/6/20
  7. * @version
  8. */
  9. const moment = require('moment');
  10. const auditConst = require('../const/audit').stage;
  11. const changeAudit = require('../const/audit').flow;
  12. const spreadConst = require('../const/spread');
  13. const tenderConst = require('../const/tender');
  14. const payConst = require('../const/deal_pay.js');
  15. const changeConst = require('../const/change');
  16. const measureType = tenderConst.measureType;
  17. const path = require('path');
  18. const PayCalculator = require('../lib/pay_calc');
  19. const accountGroup = require('../const/account_group').group;
  20. const sendToWormhole = require('stream-wormhole');
  21. const fs = require('fs');
  22. module.exports = app => {
  23. class StageController extends app.BaseController {
  24. /**
  25. * 构造函数
  26. *
  27. * @param {Object} ctx - egg全局变量
  28. * @return {void}
  29. */
  30. constructor(ctx) {
  31. super(ctx);
  32. ctx.showProject = true;
  33. ctx.showTender = true;
  34. ctx.showTitle = true;
  35. }
  36. /**
  37. * 获取通用的renderData(用于layout, Menu, subMenu部分)
  38. * @param ctx
  39. * @returns {{tender, tenderMenu, auditConst}}
  40. * @private
  41. */
  42. async _getDefaultRenderData (ctx) {
  43. const data = {
  44. tender: ctx.tender.data,
  45. tenderMenu: JSON.parse(JSON.stringify(this.menu.stageMenu)),
  46. auditConst,
  47. measureType,
  48. preUrl: '/tender/' + ctx.tender.id + '/measure/stage/' + ctx.params.order,
  49. stage: ctx.stage,
  50. };
  51. if ((ctx.stage.status === auditConst.status.uncheck || ctx.stage.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.stage.user_id) {
  52. data.accountGroup = accountGroup;
  53. // 获取所有项目参与者
  54. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  55. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  56. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  57. });
  58. data.accountList = accountList;
  59. }
  60. data.tenderMenu.back.children[0].url = '/tender/' + ctx.tender.id + '/measure/stage';
  61. return data;
  62. }
  63. /**
  64. * 获取SpreadSetting
  65. * @private
  66. */
  67. _getSpreadSetting() {
  68. const _ = this.app._;
  69. function removeFieldCols(setting, cols) {
  70. _.remove(setting.cols, function (c) {
  71. return cols.indexOf(c.field) > -1;
  72. });
  73. }
  74. function setColFormat(cols, field, formatter) {
  75. const filterCols = cols.filter(function (c) {
  76. return c.field.search(field) !== -1;
  77. });
  78. for (const col of filterCols) {
  79. col.formatter = formatter;
  80. }
  81. }
  82. // const tpFormatter = this.ctx.helper.getNumberFormatter(this.ctx.tender.info.decimal.tp);
  83. // const upFormatter = this.ctx.helper.getNumberFormatter(2);
  84. const tender = this.ctx.tender, stage = this.ctx.stage;
  85. const stageSetting = tender.data.measure_type === measureType.tz.value ? spreadConst.stageTz :
  86. (tender.info.display.ledger.clQty ? spreadConst.stageCl : spreadConst.stageNoCl);
  87. const ledger = JSON.parse(JSON.stringify(stageSetting.ledger));
  88. // setColFormat(ledger.cols, 'unit_price', upFormatter);
  89. // setColFormat(ledger.cols, 'total_price', tpFormatter);
  90. // setColFormat(ledger.cols, 'tp', tpFormatter);
  91. if (!tender.info.display.ledger.dgnQty) {
  92. removeFieldCols(ledger, spreadConst.filterCols.stageDgnCols);
  93. }
  94. const pos = JSON.parse(JSON.stringify(stageSetting.pos));
  95. if (this.ctx.stage.readOnly || this.ctx.stage.revising) {
  96. ledger.readOnly = true;
  97. pos.readOnly = true;
  98. }
  99. return [ledger, pos];
  100. }
  101. /**
  102. * 获取审批界面所需的 原报、审批人数据等
  103. * @param ctx
  104. * @returns {Promise<void>}
  105. * @private
  106. */
  107. async _getStageAuditViewData (ctx) {
  108. const times = ctx.stage.status === auditConst.status.checkNo ? ctx.stage.times - 1 : ctx.stage.times;
  109. ctx.stage.user = await ctx.service.projectAccount.getAccountInfoById(ctx.stage.user_id);
  110. ctx.stage.auditHistory = [];
  111. if (ctx.stage.times > 1) {
  112. for (let i = 1; i < ctx.stage.times; i++) {
  113. ctx.stage.auditHistory.push(await ctx.service.stageAudit.getAuditors(ctx.stage.id, i));
  114. }
  115. }
  116. // 获取审批流程中左边列表
  117. ctx.stage.auditors2 = await ctx.service.stageAudit.getAuditGroupByList(ctx.stage.id, times);
  118. if (ctx.stage.status === auditConst.status.uncheck || ctx.stage.status === auditConst.status.checkNo) {
  119. ctx.stage.auditorList = await ctx.service.stageAudit.getAuditors(ctx.stage.id, ctx.stage.times);
  120. }
  121. }
  122. _checkStageCanModify(ctx) {
  123. // 检查登录用户,是否可操作
  124. if (ctx.stage.readOnly) {
  125. throw '该计量期当前您无权操作';
  126. }
  127. if (ctx.stage.revising) {
  128. throw '台账修订中,请勿修改提交期数据';
  129. }
  130. }
  131. /**
  132. * 期计量页面 (Get)
  133. * @param {Object} ctx - egg全局变量
  134. * @returns {Promise<void>}
  135. */
  136. async index(ctx) {
  137. try {
  138. await this._getStageAuditViewData(ctx);
  139. const renderData = await this._getDefaultRenderData(ctx);
  140. [renderData.ledgerSpread, renderData.posSpread] = this._getSpreadSetting();
  141. renderData.changeConst = changeConst;
  142. // renderData.ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  143. // const dgnData = await ctx.service.stageBillsDgn.getDgnData(ctx.tender.id);
  144. // for (const d of dgnData) {
  145. // const l = ctx.app._.find(renderData.ledgerData, {id: d.id});
  146. // ctx.app._.assignIn(l, d);
  147. // }
  148. // let curStageData, preStageData;
  149. // // 当前操作人查看最新数据,其他人查看历史数据
  150. // if (ctx.stage.readOnly) {
  151. // curStageData = await ctx.service.stageBills.getAuditorStageData(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  152. // } else {
  153. // curStageData = await ctx.service.stageBills.getLastestStageData(ctx.tender.id, ctx.stage.id);
  154. // }
  155. // // 查询截止上期数据
  156. // if (ctx.stage.order > 1) {
  157. // preStageData = await ctx.service.stageBillsFinal.getFinalData(ctx.tender.data, ctx.stage.order - 1);
  158. // //renderData.preStageData = await ctx.service.stageBills.getEndStageData(ctx.tender.id, ctx.stage.order - 1);
  159. // } else {
  160. // preStageData = [];
  161. // }
  162. // this.ctx.helper.assignRelaData(renderData.ledgerData, [
  163. // {data: curStageData, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'postil'], prefix: '', relaId: 'lid',},
  164. // {data: preStageData, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid',}
  165. // ]);
  166. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.stage.index);
  167. renderData.whiteList = this.ctx.app.config.multipart.whitelist;
  168. renderData.imType = tenderConst.imType;
  169. // 获取附件列表
  170. const attData = await ctx.service.stageAtt.getDataByTenderIdAndStageId(ctx.tender.id, ctx.params.order);
  171. for (const index in attData) {
  172. attData[index].in_time = moment(attData[index].in_time * 1000).format('YYYY-MM-DD');
  173. }
  174. renderData.attData = attData;
  175. await this.layout('stage/index.ejs', renderData, 'stage/modal.ejs');
  176. } catch (err) {
  177. this.log(err);
  178. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage');
  179. }
  180. }
  181. async _getStageLedgerData(ctx) {
  182. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  183. const dgnData = await ctx.service.stageBillsDgn.getDgnData(ctx.tender.id);
  184. for (const d of dgnData) {
  185. const l = ctx.app._.find(ledgerData, {id: d.id});
  186. ctx.app._.assignIn(l, d);
  187. }
  188. let curStageData, preStageData;
  189. // 当前操作人查看最新数据,其他人查看历史数据
  190. if (ctx.stage.readOnly) {
  191. curStageData = await ctx.service.stageBills.getAuditorStageData(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  192. } else {
  193. curStageData = await ctx.service.stageBills.getLastestStageData(ctx.tender.id, ctx.stage.id);
  194. }
  195. // 查询截止上期数据
  196. if (ctx.stage.order > 1) {
  197. preStageData = await ctx.service.stageBillsFinal.getFinalData(ctx.tender.data, ctx.stage.order - 1);
  198. //renderData.preStageData = await ctx.service.stageBills.getEndStageData(ctx.tender.id, ctx.stage.order - 1);
  199. } else {
  200. preStageData = [];
  201. }
  202. this.ctx.helper.assignRelaData(ledgerData, [
  203. {data: curStageData, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'postil'], prefix: '', relaId: 'lid',},
  204. {data: preStageData, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'used'], prefix: 'pre_', relaId: 'lid',}
  205. ]);
  206. return ledgerData;
  207. }
  208. async _getStagePosData(ctx) {
  209. let curStageData, preStageData;
  210. const posData = await ctx.service.pos.getPosDataWithAddStageOrder({tid: ctx.tender.id});
  211. // 根据当前人,或指定对象查询数据
  212. //console.time('cur');
  213. if (ctx.stage.readOnly) {
  214. curStageData = await ctx.service.stagePos.getAuditorStageData2(ctx.tender.id,
  215. ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  216. } else {
  217. curStageData = await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, ctx.stage.id);
  218. }
  219. //console.timeEnd('cur');
  220. // 查询截止上期数据
  221. //console.time('pre');
  222. if (ctx.stage.order > 1) {
  223. preStageData = await ctx.service.stagePosFinal.getFinalData(ctx.tender.data, ctx.stage.order - 1);
  224. //responseData.data.preStageData = await ctx.service.stagePos.getEndStageData(ctx.tender.id, ctx.stage.order - 1);
  225. } else {
  226. preStageData = [];
  227. }
  228. //console.timeEnd('pre');
  229. //console.time('assign');
  230. //console.log('cur: ' + curStageData.length);
  231. //console.log('pre: ' + preStageData.length);
  232. this.ctx.helper.assignRelaData(posData, [
  233. {data: curStageData, fields: ['contract_qty', 'qc_qty', 'postil'], prefix: '', relaId: 'pid'},
  234. {data: preStageData, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'pid'}
  235. ]);
  236. return posData;
  237. }
  238. async _getStageDetailData(ctx) {
  239. if (ctx.stage.readOnly) {
  240. return await ctx.service.stageDetail.getAuditorStageData(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  241. } else {
  242. return await ctx.service.stageDetail.getLastestStageData(ctx.tender.id, ctx.stage.id);
  243. }
  244. }
  245. async _getStageChangeData(ctx) {
  246. if (ctx.stage.readOnly) {
  247. return await ctx.service.stageChange.getAuditorAllStageData(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  248. } else {
  249. return await ctx.service.stageChange.getLastestAllStageData(ctx.tender.id, ctx.stage.id);
  250. }
  251. }
  252. async getStageData(ctx) {
  253. try {
  254. const ledgerData = await this._getStageLedgerData(ctx);
  255. const posData = await this._getStagePosData(ctx);
  256. const detailData = await this._getStageDetailData(ctx);
  257. const changeData = await this._getStageChangeData(ctx);
  258. ctx.body = {err: 0, msg: '', data: {
  259. ledgerData, posData, detailData, changeData,
  260. }};
  261. } catch (err) {
  262. this.log(err);
  263. ctx.body = {err: 1, msg: err.toString(), data: null};
  264. }
  265. }
  266. /**
  267. * 获取期数据(截止上期 & 本期) (Ajax)
  268. * @param ctx
  269. * @returns {Promise<void>}
  270. */
  271. async getStagePosData(ctx) {
  272. try {
  273. const condition = JSON.parse(ctx.request.body.data) || {};
  274. condition.tid = ctx.tender.id;
  275. const responseData = {err: 0, msg: '', data: {}};
  276. let curStageData, preStageData;
  277. responseData.data = await ctx.service.pos.getPosDataWithAddStageOrder(condition);
  278. // 根据当前人,或指定对象查询数据
  279. //console.time('cur');
  280. const curWhere = JSON.parse(ctx.request.body.data);
  281. if (ctx.stage.readOnly) {
  282. curStageData = await ctx.service.stagePos.getAuditorStageData2(ctx.tender.id,
  283. ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder, curWhere);
  284. } else {
  285. curStageData = await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, ctx.stage.id, curWhere);
  286. }
  287. //console.timeEnd('cur');
  288. // 查询截止上期数据
  289. //console.time('pre');
  290. if (ctx.stage.order > 1) {
  291. preStageData = await ctx.service.stagePosFinal.getFinalData(ctx.tender.data, ctx.stage.order - 1);
  292. //responseData.data.preStageData = await ctx.service.stagePos.getEndStageData(ctx.tender.id, ctx.stage.order - 1);
  293. } else {
  294. preStageData = [];
  295. }
  296. //console.timeEnd('pre');
  297. //console.time('assign');
  298. //console.log('cur: ' + curStageData.length);
  299. //console.log('pre: ' + preStageData.length);
  300. this.ctx.helper.assignRelaData(responseData.data, [
  301. {data: curStageData, fields: ['contract_qty', 'qc_qty', 'postil'], prefix: '', relaId: 'pid'},
  302. {data: preStageData, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'pid'}
  303. ]);
  304. //console.timeEnd('assign');
  305. ctx.body = responseData;
  306. } catch (err) {
  307. this.log(err);
  308. ctx.body = {err: 1, msg: err.toString(), data: null};
  309. }
  310. }
  311. /**
  312. * 保存数据 (Ajax)
  313. * @param ctx
  314. * @returns {Promise<void>}
  315. */
  316. async updateStageData(ctx) {
  317. try {
  318. this._checkStageCanModify(ctx);
  319. const data = JSON.parse(ctx.request.body.data);
  320. const responseData = { err: 0, msg: '', data: {}, };
  321. if (data.pos) {
  322. responseData.data = await ctx.service.stagePos.updateStageData(data.pos);
  323. } else if (data.bills) {
  324. if (data.bills.main) {
  325. const updateDatas = data.bills.main instanceof Array ? data.bills.main : [data.bills.main];
  326. const result = await ctx.app.mysql.updateRows(ctx.service.ledger.tableName, updateDatas);
  327. responseData.data.bills = await ctx.service.ledger.getDataByIds(this.ctx.helper._.map(updateDatas, 'id'));
  328. }
  329. if (data.bills.dgn) {
  330. responseData.data.dgn = await ctx.service.stageBillsDgn.saveDgnData(data.bills.dgn);
  331. }
  332. if (data.bills.stage) {
  333. responseData.data.curStageData = await ctx.service.stageBills.updateStageData(data.bills.stage);
  334. }
  335. if (data.bills.calcType) {
  336. responseData.data = await ctx.service.stageBills.updateStageBillsCalcType(data.bills.calcType); }
  337. }
  338. await ctx.service.stage.updateCheckCalcFlag(ctx.stage.id, true);
  339. await ctx.service.stage.updateCacheTime(ctx.stage.id);
  340. ctx.body = responseData;
  341. } catch (err) {
  342. this.log(err);
  343. ctx.body = {err: 1, msg: err.toString(), data: null};
  344. }
  345. }
  346. /**
  347. * 查询可用变更令 (Ajax-Post)
  348. * @param ctx
  349. * @returns {Promise<void>}
  350. */
  351. async searchValidChange(ctx) {
  352. try {
  353. const data = JSON.parse(ctx.request.body.data);
  354. if (!data.bills && !data.pos) {
  355. throw '数据错误';
  356. }
  357. const bills = data.bills ? data.bills : await ctx.service.ledger.getDataById(data.pos.lid);
  358. const pos = data.pos;
  359. const changes = await ctx.service.change.getValidChanges(ctx.tender.id, bills);
  360. const useChanges = await ctx.service.stageChange.getLastestStageData(ctx.tender.id, ctx.stage.id, bills.id, pos ? pos.id : -1);
  361. ctx.body = {err: 0, msg: '', data: {changes, useChanges}};
  362. } catch(err) {
  363. this.log(err);
  364. ctx.body = {err: 1, msg: err.toString(), data: null};
  365. }
  366. }
  367. /**
  368. * 调用变更令 (Ajax-Post)
  369. * @param ctx
  370. * @returns {Promise<void>}
  371. */
  372. async useChange(ctx) {
  373. try {
  374. this._checkStageCanModify(ctx);
  375. const data = JSON.parse(ctx.request.body.data);
  376. if (!data.target || (!data.target.bills && !data.target.pos) || !data.change) {
  377. throw '调用变更令数据错误'
  378. }
  379. let result;
  380. if (data.target.pos) {
  381. result = await ctx.service.stageChange.posChange(data.target.pos, data.change);
  382. result.change = { target: {lid: data.target.pos.lid, pid: data.target.pos.id } };
  383. result.change.data = await ctx.service.stageChange.getLastestStageData(ctx.tender.id,
  384. ctx.stage.id, data.target.pos.lid, data.target.pos.id);
  385. } else {
  386. result = await ctx.service.stageChange.billsChange(data.target.bills, data.change);
  387. result.change = { target: { lid: data.target.bills.id, pid: '-1' } };
  388. result.change.data = await ctx.service.stageChange.getLastestStageData(ctx.tender.id,
  389. ctx.stage.id, data.target.bills.id, '-1');
  390. }
  391. await ctx.service.stage.updateCheckCalcFlag(ctx.stage.id, true);
  392. await ctx.service.stage.updateCacheTime(ctx.stage.id);
  393. ctx.body = {err: 0, msg: '', data: result};
  394. } catch(err) {
  395. this.log(err);
  396. ctx.body = {err: 1, msg: err.toString(), data: null};
  397. }
  398. }
  399. /**
  400. * 查询变更令 明细数据(包括附件、变更清单、累计使用情况、本期使用情况) (Ajax-Post)
  401. * @param ctx
  402. * @returns {Promise<void>}
  403. */
  404. async changeDetail(ctx) {
  405. try {
  406. const data = JSON.parse(ctx.request.body.data);
  407. if (!data.cid) {
  408. throw '查询数据错误';
  409. }
  410. const detailData = await this._getChangeDetailData(ctx.tender.id, ctx.stage.id, data.cid);
  411. ctx.body = {err: 0, msg: '', data: detailData};
  412. } catch(err) {
  413. this.log(err);
  414. ctx.body = {err: 1, msg: err.toString(), data: null};
  415. }
  416. }
  417. /**
  418. * 中间计量 (Get)
  419. * @param ctx
  420. * @returns {Promise<void>}
  421. */
  422. async detail(ctx) {
  423. try {
  424. await this._getStageAuditViewData(ctx);
  425. const renderData = await this._getDefaultRenderData(ctx);
  426. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.stage.detail);
  427. renderData.imType = tenderConst.imType;
  428. await this.layout('stage/detail.ejs', renderData, 'stage/detail_modal.ejs');
  429. } catch (err) {
  430. this.log(err);
  431. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage/' + ctx.params.order);
  432. }
  433. }
  434. /**
  435. * 设置中间计量生成规则,并生成中间计量数据 (Ajax)
  436. * @param ctx
  437. * @returns {Promise<void>}
  438. */
  439. async buildDetailData (ctx) {
  440. try {
  441. this._checkStageCanModify(ctx);
  442. const data = JSON.parse(ctx.request.body.data);
  443. await ctx.service.stage.buildDetailData(ctx.tender.id, ctx.stage.order, data);
  444. await ctx.service.stage.updateCacheTime(ctx.stage.id);
  445. ctx.body = {err: 0, msg: '', data: null};
  446. } catch (err) {
  447. this.log(err);
  448. ctx.body = {err: 1, msg: err.toString(), data: null};
  449. }
  450. }
  451. /**
  452. * 加载数据 (Ajax)
  453. * @param ctx
  454. * @returns {Promise<void>}
  455. */
  456. async loadDetailRelaData(ctx) {
  457. try {
  458. const data = JSON.parse(ctx.request.body.data);
  459. // 加载台账数据
  460. if (data.loadType === 'ledger') {
  461. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  462. ctx.body = {err: 0, msg: '', data: ledgerData };
  463. } else if (data.loadType === 'all') {
  464. const result = {};
  465. result.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  466. result.pos = await ctx.service.pos.getPosData({tid: ctx.tender.id});
  467. if (ctx.stage.readOnly) {
  468. const curStage = await ctx.service.stageBills.getAuditorStageData(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  469. this.ctx.helper.assignRelaData(result.ledger, [
  470. {data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: '', relaId: 'lid'}
  471. ]);
  472. const curPosStage = await ctx.service.stagePos.getAuditorStageData2(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  473. this.ctx.helper.assignRelaData(result.pos, [
  474. {data: curPosStage, fields: ['contract_qty', 'qc_qty'], prefix: '', relaId: 'pid'}
  475. ]);
  476. } else {
  477. const curStage = await ctx.service.stageBills.getLastestStageData(ctx.tender.id, ctx.stage.id);
  478. this.ctx.helper.assignRelaData(result.ledger, [
  479. {data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: '', relaId: 'lid'}
  480. ]);
  481. const curPosStage = await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, ctx.stage.id);
  482. this.ctx.helper.assignRelaData(result.pos, [
  483. {data: curPosStage, fields: ['contract_qty', 'qc_qty'], prefix: '', relaId: 'pid'}
  484. ]);
  485. }
  486. result.stageDetail = await this._getStageDetailData(ctx);
  487. result.changeData = await this._getStageChangeData(ctx);
  488. ctx.body = { err: 0, msg: '', data: result };
  489. }
  490. } catch (err) {
  491. this.log(err);
  492. ctx.body = { err: 1, msg: err.toString(), data: null };
  493. }
  494. }
  495. /**
  496. * 中间计量,生成规则,高级设置 (Ajax)
  497. * @param ctx
  498. * @returns {Promise<void>}
  499. */
  500. async setAdvancedConfig(ctx) {
  501. try {
  502. this._checkStageCanModify(ctx);
  503. const data = JSON.parse(ctx.request.body.data);
  504. await ctx.service.stage.update(data, { id: ctx.stage.id });
  505. await ctx.service.stage.updateCacheTime(ctx.stage.id);
  506. ctx.body = {err: 0, msg: '', data: this.ctx.stage};
  507. } catch (err) {
  508. this.log(err);
  509. ctx.body = {err: 1, msg: err.toString(), data: null};
  510. }
  511. }
  512. /**
  513. * 中间计量,编辑中间计量数据(Ajax)
  514. * @param ctx
  515. * @returns {Promise<void>}
  516. */
  517. async saveDetailData(ctx) {
  518. try {
  519. this._checkStageCanModify(ctx);
  520. const data = JSON.parse(ctx.request.body.data);
  521. const responseData = { err: 0, msg: '', data: {}, };
  522. if (data instanceof Array) {
  523. responseData.data = await ctx.service.stageDetail.saveDetailDatas(data);
  524. } else {
  525. responseData.data = await ctx.service.stageDetail.saveDetailData(data);
  526. }
  527. await ctx.service.stage.updateCacheTime(ctx.stage.id);
  528. ctx.body = responseData;
  529. } catch (err) {
  530. this.log(err);
  531. ctx.body = {err: 1, msg: err.toString(), data: null};
  532. }
  533. }
  534. /**
  535. * 中间计量,添加草图,上传图片 (Ajax)
  536. * @param ctx
  537. * @returns {Promise<void>}
  538. */
  539. async addCalcImage(ctx) {
  540. try {
  541. this._checkStageCanModify(ctx);
  542. const stream = await ctx.getFileStream();
  543. const create_time = Date.parse(new Date()) / 1000;
  544. const fileInfo = path.parse(stream.filename);
  545. const fileName = path.join('public/upload', this.ctx.tender.id.toString(), 'im', 'calcImg_' + create_time + fileInfo.ext);
  546. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', fileName));
  547. ctx.body = {err: 0, msg: '', data: fileName};
  548. } catch(err) {
  549. this.log(err);
  550. ctx.body = {err: 1, msg: err.toString(), data: null};
  551. }
  552. }
  553. /**
  554. * 中间计量,设置草图 (Ajax)
  555. * @param ctx
  556. * @returns {Promise<void>}
  557. */
  558. async mergeCalcImage(ctx) {
  559. try {
  560. this._checkStageCanModify(ctx);
  561. const data = JSON.parse(ctx.request.body.data);
  562. if (data.updateType === 'update') {
  563. const create_time = Date.parse(new Date()) / 1000;
  564. const fileName = path.join('public/upload', this.ctx.tender.id.toString(), 'im', 'calcImg_' + create_time + '.png');
  565. const base64Data = data.img.replace(/^data:image\/\w+;base64,/, "");
  566. const dataBuffer = new Buffer(base64Data, 'base64');
  567. await this.ctx.helper.saveBufferFile(dataBuffer, path.join(this.app.baseDir, 'app', fileName));
  568. data.calc_img = fileName;
  569. data.calc_img_org = JSON.stringify(data.imgInfo);
  570. delete data.updateType;
  571. delete data.img;
  572. delete data.imgInfo;
  573. } else if (data.updateType === 'clear') {
  574. data.calc_img = null;
  575. data.calc_img_org = null;
  576. delete data.updateType;
  577. }
  578. await this.ctx.service.stageDetail.saveDetailData(data);
  579. const imData = await ctx.service.stageDetail.getLastestImStageData(this.ctx.tender.id, this.ctx.stage.id, data.lid, data.uuid);
  580. await ctx.service.stage.updateCacheTime(ctx.stage.id);
  581. const responseData = {err: 0, msg: '', data: imData};
  582. ctx.body = responseData;
  583. } catch (err) {
  584. this.log(err);
  585. ctx.body = {err: 1, msg: err.toString(), data: null};
  586. }
  587. }
  588. /**
  589. * 合同支付 (Get)
  590. * @param ctx
  591. * @returns {Promise<void>}
  592. */
  593. async pay(ctx) {
  594. try {
  595. await this._getStageAuditViewData(ctx);
  596. const renderData = await this._getDefaultRenderData(ctx);
  597. const dealPay = await ctx.service.stagePay.getStagePays(ctx.stage);
  598. // 附件不取下载地址
  599. for (const index in dealPay) {
  600. if (dealPay[index].attachment !== null) {
  601. const attachments = JSON.parse(dealPay[index].attachment);
  602. for (const att_index in attachments) {
  603. delete attachments[att_index].filepath;
  604. attachments[att_index].username = (await ctx.service.projectAccount.getAccountInfoById(attachments[att_index].uid)).name;
  605. }
  606. dealPay[index].attachment = attachments;
  607. }
  608. }
  609. renderData.dealPay = dealPay;
  610. renderData.calcBase = await ctx.service.stage.getStagePayCalcBase(ctx.stage, ctx.tender.info);
  611. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.stage.pay);
  612. renderData.whiteList = this.ctx.app.config.multipart.whitelist;
  613. if (ctx.stage.order > 1) {
  614. renderData.pre = await ctx.service.stageBillsFinal.getSumTotalPrice(ctx.stage.tid, ctx.stage.order - 1);
  615. renderData.pre.gather_tp = ctx.helper.add(renderData.pre.contract_tp, renderData.pre.qc_tp);
  616. } else {
  617. renderData.pre = {contract_tp: null, qc_tp: null, gather_tp: null};
  618. }
  619. // 用户有无权限上传和删除附件
  620. renderData.uploadPermission = ((ctx.stage.status === auditConst.status.uncheck || ctx.stage.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.stage.user_id) ||
  621. (ctx.stage.status === auditConst.status.checkNoPre && ctx.session.sessionUser.accountId === ctx.stage.curAuditor.aid) ||
  622. (ctx.stage.status === auditConst.status.checking && ctx.stage.curAuditor && ctx.stage.curAuditor.aid === ctx.session.sessionUser.accountId);
  623. if (!ctx.stage.readOnly) {
  624. // 计算 本期金额
  625. const payCalculator = new PayCalculator(ctx, ctx.stage, ctx.tender.info);
  626. await payCalculator.calculateAll(renderData.dealPay);
  627. await this.ctx.service.stage.update({
  628. check_calc: false,
  629. contract_tp: payCalculator.cur.contract_tp, qc_tp: payCalculator.cur.qc_tp,
  630. yf_tp: payCalculator.yf.tp,
  631. }, {id: this.ctx.stage.id});
  632. }
  633. await this.layout('stage/pay.ejs', renderData, 'stage/pay_modal.ejs');
  634. } catch (err) {
  635. console.log(err);
  636. this.log(err);
  637. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage');
  638. }
  639. }
  640. /**
  641. * 合同支付 - 编辑合同支付项 (Ajax)
  642. * @param ctx
  643. * @returns {Promise<void>}
  644. */
  645. async savePayData(ctx) {
  646. function checkCalcField(data) {
  647. return data.sexpr !== undefined || data.sprice !== undefined
  648. || data.rexpr !== undefined || data.rprice !== undefined
  649. || data.minus !== undefined || data.is_yf !== undefined || data.dl_type !== undefined
  650. }
  651. try {
  652. this._checkStageCanModify(ctx);
  653. const data = JSON.parse(ctx.request.body.data);
  654. const responseData = { err: 0, msg: '', data: {}, };
  655. const payCalculator = new PayCalculator(ctx, ctx.stage, ctx.tender.info);
  656. switch (data.type) {
  657. case 'add':
  658. responseData.data = await ctx.service.pay.add();
  659. responseData.data = await ctx.service.stagePay.getStagePay(ctx.stage, responseData.data.pid);
  660. break;
  661. case 'del':
  662. await ctx.service.pay.del(data.id);
  663. responseData.data = await ctx.service.stagePay.getStagePays(ctx.stage);
  664. await payCalculator.calculate(responseData.data);
  665. await this.ctx.service.stage.update({
  666. check_calc: false,
  667. contract_tp: payCalculator.cur.contract_tp, qc_tp: payCalculator.cur.qc_tp,
  668. yf_tp: payCalculator.yf.tp,
  669. }, {id: this.ctx.stage.id});
  670. break;
  671. case 'changeOrder':
  672. responseData.data = await ctx.service.pay.changeOrder(data.id1, data.id2);
  673. break;
  674. case 'info':
  675. responseData.data = await ctx.service.pay.save(data.updateData);
  676. const bReCalc = data.updateData instanceof Array ? checkCalcField(data.updateData[0]) : checkCalcField(data.updateData);
  677. if (bReCalc) {
  678. responseData.data = await ctx.service.stagePay.getStagePays(ctx.stage);
  679. await payCalculator.calculateAll(responseData.data);
  680. await this.ctx.service.stage.update({
  681. check_calc: false,
  682. contract_tp: payCalculator.cur.contract_tp, qc_tp: payCalculator.cur.qc_tp,
  683. yf_tp: payCalculator.yf.tp,
  684. }, {id: this.ctx.stage.id});
  685. } else {
  686. if (data.updateData instanceof Array) {
  687. responseData.data = await ctx.service.stagePay.getStagePay(ctx.stage, this.app._.map(responseData.data, 'id'));
  688. } else {
  689. responseData.data = await ctx.service.stagePay.getStagePay(ctx.stage, responseData.data.id);
  690. }
  691. }
  692. break;
  693. case 'stage':
  694. await ctx.service.stagePay.save(data.updateData);
  695. responseData.data = await ctx.service.stagePay.getStagePays(ctx.stage);
  696. await payCalculator.calculateAll(responseData.data);
  697. await this.ctx.service.stage.update({
  698. check_calc: false,
  699. contract_tp: payCalculator.cur.contract_tp, qc_tp: payCalculator.cur.qc_tp,
  700. yf_tp: payCalculator.yf.tp,
  701. }, {id: this.ctx.stage.id});
  702. break;
  703. }
  704. ctx.body = responseData;
  705. } catch(err) {
  706. this.log(err);
  707. ctx.body = {err: 1, msg: err.toString(), data: null};
  708. }
  709. }
  710. /**
  711. * 合同支付 - 章节明细 (Ajax-Post)
  712. * @param ctx
  713. * @returns {Promise<void>}
  714. */
  715. async chapterDetail(ctx) {
  716. const _ = this.app._;
  717. const fields = ['contract_tp', 'qc_tp', 'gather_tp', 'end_gather_tp'];
  718. function assignStageData(chapter, curStage, preStage) {
  719. chapter.contract_tp = curStage.contract_tp;
  720. chapter.qc_tp = curStage.qc_tp;
  721. chapter.gather_tp = ctx.helper.add(curStage.contract_tp, curStage.qc_tp);
  722. if (preStage) {
  723. chapter.pre_contract_tp = preStage.contract_tp;
  724. chapter.pre_qc_tp = preStage.qc_tp;
  725. chapter.pre_gather_tp = ctx.helper.add(preStage.contract_tp, preStage.qc_tp);
  726. chapter.end_contract_tp = ctx.helper.add(curStage.contract_tp, preStage.contract_tp);
  727. chapter.end_qc_tp = ctx.helper.add(curStage.qc_tp, preStage.qc_tp);
  728. chapter.end_gather_tp = ctx.helper.add(chapter.gather_tp, chapter.pre_gather_tp);
  729. } else {
  730. chapter.end_contract_tp = curStage.contract_tp;
  731. chapter.end_qc_tp = curStage.qc_tp;
  732. chapter.end_gather_tp = chapter.gather_tp;
  733. }
  734. }
  735. try {
  736. const chapterDetail = JSON.parse(JSON.stringify(payConst.chapterDetail));
  737. const calcDetail = _.sortBy(chapterDetail, ['cType']);
  738. for (const cd of calcDetail) {
  739. switch (cd.cType) {
  740. case 1:
  741. const tp = await ctx.service.stageBills.getSumTotalPriceGcl(ctx.stage, cd.filter);
  742. assignStageData(cd, tp);
  743. break;
  744. case 11:
  745. assignStageData(cd, await ctx.service.stageBills.getSumTotalPriceGcl(ctx.stage));
  746. break;
  747. case 21:
  748. const sum = _.find(calcDetail, {cType: 11});
  749. const chapters = _.filter(calcDetail, {cType: 1});
  750. for (const f of fields) {
  751. cd[f] = ctx.helper.sub(sum[f], this.ctx.helper.sum(_.map(chapters, f)));//_.sumBy(chapters, f));
  752. }
  753. break;
  754. case 31:
  755. assignStageData(cd, await ctx.service.stageBills.getSumTotalPriceNotGcl(ctx.stage));
  756. break;
  757. case 41:
  758. const sum1 = _.find(calcDetail, {cType: 11});
  759. const sum2 = _.find(calcDetail, {cType: 31});
  760. for (const f of fields) {
  761. cd[f] = ctx.helper.add(sum1.value, sum2.value);
  762. }
  763. break;
  764. }
  765. }
  766. ctx.body = {err: 0, msg: '', data: {detail: chapterDetail, decimal: ctx.tender.info.decimal}};
  767. } catch (err) {
  768. this.log(err);
  769. ctx.body = {err: 1, msg: err.toString(), data: null};
  770. }
  771. }
  772. // 变更令相关
  773. /**
  774. * 查询变更令 明细数据(包括附件、变更清单、累计使用情况、本期使用情况)
  775. * @param tid
  776. * @param sid
  777. * @param cid
  778. * @returns {Promise<{}>}
  779. * @private
  780. */
  781. async _getChangeDetailData(tid, sid, cid) {
  782. const data = {};
  783. data.attachments = await this.ctx.service.changeAtt.getChangeAttachment(cid);
  784. data.bills = await this.ctx.service.changeAuditList.getAllDataByCondition({where: {cid: cid}});
  785. data.addUsedBills = await this.ctx.service.stageChange.getUsedData(tid, cid);
  786. data.curUsedBills = await this.ctx.service.stageChange.getStageUsedData(sid, cid);
  787. return data;
  788. }
  789. /**
  790. * 获取变更数据 Post(Ajax)
  791. * @param ctx
  792. * @returns {Promise<void>}
  793. */
  794. async getChangeData(ctx) {
  795. try {
  796. const data = {};
  797. data.tenderInfo = ctx.tender.info;
  798. data.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  799. data.usedChangesId = await ctx.service.stageChange.getStageUsedChangeId(ctx.stage.id);
  800. data.changes = await ctx.service.change.getChangeAndUsedInfo(ctx.tender.id);
  801. if (data.changes.length > 0) {
  802. const change = data.changes[0];
  803. change.detail = await this._getChangeDetailData(ctx.tender.id, ctx.stage.id, change.cid);
  804. }
  805. ctx.body = {err: 0, msg: '', data: data};
  806. } catch (err) {
  807. this.log(err);
  808. ctx.body = {err: 1, msg: err.toString(), data: null};
  809. }
  810. }
  811. /**
  812. * 变更令 (Get)
  813. * @param ctx
  814. * @returns {Promise<void>}
  815. */
  816. async change(ctx) {
  817. try {
  818. await this._getStageAuditViewData(ctx);
  819. const renderData = await this._getDefaultRenderData(ctx);
  820. renderData.changeConst = changeConst;
  821. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.stage.change);
  822. await this.layout('stage/change.ejs', renderData, 'stage/audit_modal.ejs');
  823. } catch (err) {
  824. this.log(err);
  825. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage');
  826. }
  827. }
  828. // 审批相关
  829. /**
  830. * 添加审批人
  831. * @param ctx
  832. * @returns {Promise<void>}
  833. */
  834. async addAudit(ctx) {
  835. try {
  836. this._checkStageCanModify(ctx);
  837. const data = JSON.parse(ctx.request.body.data);
  838. const id = this.app._.toInteger(data.auditorId);
  839. if (isNaN(id) || id <= 0) {
  840. throw '参数错误';
  841. }
  842. // 检查权限等
  843. if (ctx.stage.user_id !== ctx.session.sessionUser.accountId) {
  844. throw '您无权添加审核人';
  845. }
  846. if (ctx.stage.status === auditConst.status.checking || ctx.stage.status === auditConst.status.checked) {
  847. throw '当前不允许添加审核人';
  848. }
  849. ctx.stage.auditorList = await ctx.service.stageAudit.getAuditors(ctx.stage.id, ctx.stage.times);
  850. // 检查审核人是否已存在
  851. const exist = this.app._.find(ctx.stage.auditorList, {aid: id});
  852. if (exist) {
  853. throw '该审核人已存在,请勿重复添加';
  854. }
  855. const result = await ctx.service.stageAudit.addAuditor(ctx.stage.id, id, ctx.stage.times);
  856. if (!result) {
  857. throw '添加审核人失败';
  858. }
  859. const audit = await ctx.service.stageAudit.getAuditor(ctx.stage.id, id, ctx.stage.times);
  860. ctx.body = {err: 0, msg: '', data: audit};
  861. } catch (err) {
  862. this.log(err);
  863. ctx.body = {err: 1, msg: err.toString(), data: null};
  864. }
  865. }
  866. /**
  867. * 移除审批人
  868. * @param ctx
  869. * @returns {Promise<void>}
  870. */
  871. async deleteAudit(ctx) {
  872. try {
  873. this._checkStageCanModify(ctx);
  874. const data = JSON.parse(ctx.request.body.data);
  875. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  876. if (isNaN(id) || id <= 0) {
  877. throw '参数错误';
  878. }
  879. const result = await ctx.service.stageAudit.deleteAuditor(ctx.stage.id, id, ctx.stage.times);
  880. if (!result) {
  881. throw '移除审核人失败';
  882. }
  883. const auditors = await ctx.service.stageAudit.getAuditors(ctx.stage.id, ctx.stage.times);
  884. ctx.body = {err: 0, msg: '', data: auditors};
  885. } catch (err) {
  886. ctx.body = {err: 1, msg: err.toString(), data: null};
  887. }
  888. }
  889. /**
  890. * 上报
  891. * @param ctx
  892. * @returns {Promise<void>}
  893. */
  894. async startAudit(ctx) {
  895. try {
  896. this._checkStageCanModify(ctx);
  897. if (ctx.stage.user_id !== ctx.session.sessionUser.accountId) {
  898. throw '您无权上报该期数据';
  899. }
  900. if (ctx.stage.status === auditConst.status.checking || ctx.stage.status === auditConst.status.checked) {
  901. throw '该期数据当前无法上报';
  902. }
  903. await ctx.service.stageAudit.start(ctx.stage.id, ctx.stage.times);
  904. ctx.redirect(ctx.request.header.referer);
  905. } catch (err) {
  906. this.log(err);
  907. ctx.session.postError = err.toString();
  908. ctx.redirect(ctx.request.header.referer);
  909. }
  910. }
  911. /**
  912. * 审批
  913. * @param ctx
  914. * @returns {Promise<void>}
  915. */
  916. async checkAudit(ctx) {
  917. try {
  918. this._checkStageCanModify(ctx);
  919. if (!this.ctx.stage || (this.ctx.stage.status !== auditConst.status.checking && this.ctx.stage.status !== auditConst.status.checkNoPre)) {
  920. throw '当前期数据有误';
  921. }
  922. if (!this.ctx.stage.curAuditor || this.ctx.stage.curAuditor.aid !== ctx.session.sessionUser.accountId) {
  923. throw '您无权进行该操作';
  924. }
  925. const data = {
  926. checkType: parseInt(ctx.request.body.checkType),
  927. opinion: ctx.request.body.opinion,
  928. };
  929. if (!data.checkType || isNaN(data.checkType)) {
  930. throw '提交数据错误';
  931. }
  932. if (data.checkType === auditConst.status.checkNo) {
  933. if (!data.checkType || isNaN(data.checkType)) {
  934. throw '提交数据错误';
  935. }
  936. }
  937. await ctx.service.stageAudit.check(ctx.stage.id, data, ctx.stage.times);
  938. ctx.redirect(ctx.request.header.referer);
  939. } catch (err) {
  940. console.log(err);
  941. this.log(err);
  942. ctx.session.postError = err.toString();
  943. ctx.redirect(ctx.request.header.referer);
  944. }
  945. }
  946. /**
  947. * 重新审批
  948. * @param ctx
  949. * @returns {Promise<void>}
  950. */
  951. async checkAuditAgain(ctx) {
  952. try {
  953. if (ctx.stage.revising) {
  954. throw '台账修订中,请勿修改提交期数据';
  955. }
  956. if (ctx.stage.auditors[ctx.stage.auditors.length - 1].aid === ctx.session.sessionUser.accountId && ctx.stage.status === auditConst.status.checked && ctx.stage.order === ctx.stage.highOrder) {
  957. await ctx.service.stageAudit.checkAgain(ctx.stage.id, ctx.stage.times);
  958. console.log('success');
  959. ctx.redirect(ctx.request.header.referer);
  960. } else {
  961. throw '您无权进行该操作';
  962. }
  963. } catch (err) {
  964. console.log(err);
  965. this.log(err);
  966. ctx.session.postError = err.toString();
  967. ctx.redirect(ctx.request.header.referer);
  968. }
  969. }
  970. // 清单汇总相关
  971. _getGatherSpreadSetting() {
  972. const _ = this.app._;
  973. function removeFieldCols(setting, cols) {
  974. _.remove(setting.cols, function (c) {
  975. return cols.indexOf(c.field) > -1;
  976. });
  977. }
  978. function setColFormat(cols, field, formatter) {
  979. const filterCols = cols.filter(function (c) {
  980. return c.field.search(field) !== -1;
  981. });
  982. for (const col of filterCols) {
  983. col.formatter = formatter;
  984. }
  985. }
  986. //const tpFormatter = this.ctx.helper.getNumberFormatter(this.ctx.tender.info.decimal.tp);
  987. //const upFormatter = this.ctx.helper.getNumberFormatter(2);
  988. const gcl = JSON.parse(JSON.stringify(spreadConst.stageGather.gcl));
  989. //setColFormat(gcl.cols, 'unit_price', upFormatter);
  990. //setColFormat(gcl.cols, 'total_price', tpFormatter);
  991. //setColFormat(gcl.cols, 'tp', tpFormatter);
  992. const leafXmj = JSON.parse(JSON.stringify(spreadConst.stageGather.leafXmj));
  993. const tender = this.ctx.tender;
  994. if (tender.data.measure_type === measureType.tz.value) {
  995. removeFieldCols(gcl, spreadConst.filterCols.tzWithoutCols);
  996. }
  997. return [gcl, leafXmj];
  998. }
  999. /**
  1000. * 清单汇总 页面 (Get)
  1001. * @param ctx
  1002. * @returns {Promise<void>}
  1003. */
  1004. async gather(ctx) {
  1005. try {
  1006. await this._getStageAuditViewData(ctx);
  1007. const renderData = await this._getDefaultRenderData(ctx);
  1008. [renderData.gclSpread, renderData.leafXmjSpread] = this._getGatherSpreadSetting();
  1009. renderData.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  1010. renderData.curLedgerData = await ctx.service.stageBills.getAuditorStageData(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  1011. if (ctx.stage.order > 1) {
  1012. renderData.preLedgerData = await ctx.service.stageBillsFinal.getFinalData(ctx.tender.data, ctx.stage.order - 1);
  1013. } else {
  1014. renderData.preLedgerData = [];
  1015. }
  1016. renderData.pos = await ctx.service.pos.getPosData({tid: ctx.tender.id});
  1017. // todo 根据当前人,或指定对象查询数据
  1018. renderData.curPosData = await ctx.service.stagePos.getAuditorStageData(ctx.tender.id,
  1019. ctx.stage.id, ctx.stage.curTimes, ctx.stage.curOrder);
  1020. if (ctx.stage.order > 1) {
  1021. renderData.prePosData = await ctx.service.stagePosFinal.getFinalData(ctx.tender.data, ctx.stage.order - 1);
  1022. } else {
  1023. renderData.prePosData = [];
  1024. }
  1025. renderData.dealBills = await ctx.service.dealBills.getAllDataByCondition({ where: {tender_id: this.ctx.tender.id} });
  1026. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.stage.gather);
  1027. await this.layout('stage/gather.ejs', renderData, 'stage/gather_modal.ejs');
  1028. } catch (err) {
  1029. this.log(err);
  1030. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage/' + ctx.params.order);
  1031. }
  1032. }
  1033. /**
  1034. * 审核比较 页面 (Get)
  1035. * @param ctx
  1036. * @returns {Promise<void>}
  1037. */
  1038. async compare(ctx) {
  1039. function getCompareSpreadSetting () {
  1040. function setColFormat(cols, field, formatter) {
  1041. const filterCols = cols.filter(function (c) {
  1042. return c.field.search(field) !== -1;
  1043. });
  1044. for (const col of filterCols) {
  1045. col.formatter = formatter;
  1046. }
  1047. }
  1048. const tpFormatter = ctx.helper.getNumberFormatter(ctx.tender.info.decimal.tp);
  1049. const upFormatter = ctx.helper.getNumberFormatter(2);
  1050. const ledger = JSON.parse(JSON.stringify(spreadConst.stageCompare.ledger));
  1051. setColFormat(ledger.baseCols, 'unit_price', upFormatter);
  1052. setColFormat(ledger.extraCols, 'total_price', tpFormatter);
  1053. setColFormat(ledger.extraCols, 'tp', tpFormatter);
  1054. const pos = JSON.parse(JSON.stringify(spreadConst.stageCompare.pos));
  1055. return [ledger, pos];
  1056. }
  1057. try {
  1058. await this._getStageAuditViewData(ctx);
  1059. const renderData = await this._getDefaultRenderData(ctx);
  1060. if (ctx.stage.times !== ctx.stage.curTimes) {
  1061. renderData.compareAuditors = ctx.stage.auditHistory[ctx.stage.curTimes - 1];
  1062. } else {
  1063. renderData.compareAuditors = ctx.stage.auditors;
  1064. }
  1065. [renderData.ledgerSpread, renderData.posSpread] = getCompareSpreadSetting();
  1066. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.stage.compare);
  1067. await this.layout('stage/compare.ejs', renderData, 'stage/compare_modal.ejs');
  1068. } catch (err) {
  1069. this.log(err);
  1070. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage/' + ctx.params.order);
  1071. }
  1072. }
  1073. async compareAuditor(ctx) {
  1074. try {
  1075. const data = JSON.parse(ctx.request.body.data);
  1076. const result = {
  1077. main: null,
  1078. roles: []
  1079. };
  1080. if (data.main) {
  1081. result.main = {};
  1082. result.main.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  1083. result.main.pos = await ctx.service.pos.getPosData({tid: ctx.tender.id});
  1084. }
  1085. for (const order of data.roles) {
  1086. const data = { order: order, bills: [], pos: [] };
  1087. data.bills = await ctx.service.stageBills.getAuditorStageData(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, order);
  1088. data.pos = await ctx.service.stagePos.getAuditorStageData(ctx.tender.id, ctx.stage.id, ctx.stage.curTimes, order);
  1089. result.roles.push(data);
  1090. }
  1091. ctx.body = {err: 0, msg: '', data: result};
  1092. } catch (err) {
  1093. this.log(err);
  1094. ctx.body = {err: 1, msg: err.toString(), data: null};
  1095. }
  1096. }
  1097. /**
  1098. * 报表
  1099. * @param ctx
  1100. * @returns {Promise<void>}
  1101. */
  1102. async report(ctx) {
  1103. try {
  1104. const renderData = await this._getDefaultRenderData(ctx);
  1105. await this.layout('stage/report.ejs', renderData, 'stage/report_modal.ejs');
  1106. } catch (err) {
  1107. this.log(err);
  1108. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage');
  1109. }
  1110. }
  1111. /**
  1112. * 上传附件
  1113. * @param {Object} ctx - egg全局变量
  1114. * @return {void}
  1115. */
  1116. async uploadFile(ctx) {
  1117. const responseData = {
  1118. err: 0,
  1119. msg: '',
  1120. data: [],
  1121. };
  1122. let stream;
  1123. try {
  1124. this._checkStageCanModify(ctx);
  1125. const parts = ctx.multipart({ autoFields: true });
  1126. const files = [];
  1127. let index = 0;
  1128. while ((stream = await parts()) !== undefined) {
  1129. // 判断用户是否选择上传文件
  1130. if (!stream.filename) {
  1131. throw '请选择上传的文件!';
  1132. }
  1133. const dirName = 'app/public/upload/stage/' + moment().format('YYYYMMDD');
  1134. // 判断文件夹是否存在,不存在则直接创建文件夹
  1135. if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
  1136. await fs.mkdirSync(path.join(this.app.baseDir, dirName));
  1137. }
  1138. const create_time = Date.parse(new Date()) / 1000;
  1139. const fileInfo = path.parse(stream.filename);
  1140. const fileName = 'stage' + create_time + '_' + index + fileInfo.ext;
  1141. // 保存文件
  1142. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
  1143. if (stream) {
  1144. await sendToWormhole(stream);
  1145. }
  1146. // 保存数据到att表
  1147. const fileData = {
  1148. tid: ctx.params.id,
  1149. sid: ctx.params.order,
  1150. in_time: create_time,
  1151. filename: fileInfo.name,
  1152. fileext: fileInfo.ext,
  1153. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  1154. filepath: path.join(dirName, fileName),
  1155. };
  1156. const result = await ctx.service.stageAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
  1157. if (!result) {
  1158. throw '导入数据库保存失败';
  1159. }
  1160. const attData = await ctx.service.stageAtt.getDataByFid(result.insertId);
  1161. attData.in_time = moment(create_time * 1000).format('YYYY-MM-DD');
  1162. files.length !== 0 ? files.unshift(attData) : files.push(attData);
  1163. ++index;
  1164. }
  1165. responseData.data = files;
  1166. } catch (err) {
  1167. this.log(err);
  1168. // 失败需要消耗掉stream 以防卡死
  1169. if (stream) {
  1170. await sendToWormhole(stream);
  1171. }
  1172. this.setMessage(err.toString(), this.messageType.ERROR);
  1173. responseData.err = 1;
  1174. responseData.msg = err.toString();
  1175. }
  1176. ctx.body = responseData;
  1177. }
  1178. /**
  1179. * 下载附件
  1180. * @param {Object} ctx - egg全局变量
  1181. * @return {void}
  1182. */
  1183. async downloadFile(ctx) {
  1184. const id = ctx.params.fid;
  1185. if (id) {
  1186. try {
  1187. const fileInfo = await ctx.service.stageAtt.getDataById(id);
  1188. if (fileInfo !== undefined && fileInfo !== '') {
  1189. const fileName = path.join(this.app.baseDir, fileInfo.filepath);
  1190. // 解决中文无法下载问题
  1191. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1192. let disposition = '';
  1193. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1194. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
  1195. } else if (userAgent.indexOf('firefox') >= 0) {
  1196. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
  1197. } else {
  1198. /* safari等其他非主流浏览器只能自求多福了 */
  1199. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
  1200. }
  1201. ctx.response.set({
  1202. 'Content-Type': 'application/octet-stream',
  1203. 'Content-Disposition': disposition,
  1204. 'Content-Length': fileInfo.filesize,
  1205. });
  1206. ctx.body = await fs.createReadStream(fileName);
  1207. } else {
  1208. throw '不存在该文件';
  1209. }
  1210. } catch (err) {
  1211. this.log(err);
  1212. this.setMessage(err.toString(), this.messageType.ERROR);
  1213. }
  1214. }
  1215. }
  1216. /**
  1217. * 删除附件
  1218. * @param {Object} ctx - egg全局变量
  1219. * @return {void}
  1220. */
  1221. async deleteFile(ctx) {
  1222. const responseData = {
  1223. err: 0,
  1224. msg: '',
  1225. data: '',
  1226. };
  1227. try {
  1228. this._checkStageCanModify(ctx);
  1229. const data = JSON.parse(ctx.request.body.data);
  1230. const fileInfo = await ctx.service.stageAtt.getDataById(data.id);
  1231. if (fileInfo !== undefined && fileInfo !== '') {
  1232. // 先删除文件
  1233. await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
  1234. // 再删除数据库
  1235. await ctx.service.stageAtt.deleteById(data.id);
  1236. responseData.data = '';
  1237. } else {
  1238. throw '不存在该文件';
  1239. }
  1240. // if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
  1241. // throw '参数有误';
  1242. // }
  1243. // const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
  1244. // responseData.data = { add: addCompany, select: selectCompany };
  1245. } catch (err) {
  1246. responseData.err = 1;
  1247. responseData.msg = err;
  1248. }
  1249. ctx.body = responseData;
  1250. }
  1251. /**
  1252. * 保存附件(或替换)
  1253. * @param {Object} ctx - egg全局变量
  1254. * @return {void}
  1255. */
  1256. async saveFile(ctx) {
  1257. const responseData = {
  1258. err: 0,
  1259. msg: '',
  1260. data: [],
  1261. };
  1262. let stream;
  1263. try {
  1264. this._checkStageCanModify(ctx);
  1265. stream = await ctx.getFileStream({ requireFile: false });
  1266. let fileData = {};
  1267. if (stream.filename !== undefined) {
  1268. const create_time = Date.parse(new Date()) / 1000;
  1269. const fileInfo = path.parse(stream.filename);
  1270. const dirName = 'app/public/upload/stage/' + moment().format('YYYYMMDD');
  1271. const fileName = 'stage' + create_time + fileInfo.ext;
  1272. // 判断文件夹是否存在,不存在则直接创建文件夹
  1273. if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
  1274. await fs.mkdirSync(path.join(this.app.baseDir, dirName));
  1275. }
  1276. // 保存文件
  1277. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
  1278. // 保存数据到att表
  1279. fileData = {
  1280. filesize: stream.fields.size,
  1281. filepath: path.join(dirName, fileName),
  1282. };
  1283. }
  1284. const result = await ctx.service.stageAtt.updateByID(stream.fields, fileData);
  1285. if (!result) {
  1286. throw '导入数据库保存失败';
  1287. }
  1288. const attData = await ctx.service.stageAtt.getDataByFid(stream.fields.id);
  1289. attData.in_time = moment(attData.in_time * 1000).format('YYYY-MM-DD');
  1290. responseData.data = attData;
  1291. } catch (err) {
  1292. this.log(err);
  1293. // 失败需要消耗掉stream 以防卡死
  1294. if (stream) {
  1295. await sendToWormhole(stream);
  1296. }
  1297. this.setMessage(err.toString(), this.messageType.ERROR);
  1298. responseData.err = 1;
  1299. responseData.msg = err.toString();
  1300. }
  1301. ctx.body = responseData;
  1302. }
  1303. /**
  1304. * 合同支付上传附件
  1305. * @param {Object} ctx - egg全局变量
  1306. * @return {void}
  1307. */
  1308. async payUploadFile(ctx) {
  1309. const responseData = {
  1310. err: 0,
  1311. msg: '',
  1312. data: [],
  1313. };
  1314. let stream;
  1315. try {
  1316. this._checkStageCanModify(ctx);
  1317. const parts = ctx.multipart({ autoFields: true });
  1318. const files = [];
  1319. let index = 0;
  1320. const create_time = Date.parse(new Date()) / 1000;
  1321. while ((stream = await parts()) !== undefined) {
  1322. // 判断用户是否选择上传文件
  1323. if (!stream.filename) {
  1324. throw '请选择上传的文件!';
  1325. }
  1326. const fileInfo = path.parse(stream.filename);
  1327. const dirName = 'app/public/upload/pay/' + moment().format('YYYYMMDD');
  1328. const fileName = 'pay' + create_time + '_' + index + fileInfo.ext;
  1329. // 判断文件夹是否存在,不存在则直接创建文件夹
  1330. if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
  1331. await fs.mkdirSync(path.join(this.app.baseDir, dirName));
  1332. }
  1333. // 保存文件
  1334. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
  1335. await sendToWormhole(stream);
  1336. // 插入到stage_pay对应的附件列表中
  1337. const attData = {
  1338. filename: fileInfo.name,
  1339. fileext: fileInfo.ext,
  1340. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  1341. filepath: path.join(dirName, fileName),
  1342. uid: ctx.session.sessionUser.accountId,
  1343. in_time: moment(create_time * 1000).format('YYYY-MM-DD'),
  1344. };
  1345. const result = await ctx.service.stagePay.saveAtt(parts.field.pay_id, attData);
  1346. if (!result) {
  1347. throw '导入数据库保存失败';
  1348. }
  1349. delete attData.filepath;
  1350. attData.username = ctx.session.sessionUser.name;
  1351. files.length !== 0 ? files.unshift(attData) : files.push(attData);
  1352. ++index;
  1353. }
  1354. responseData.data = files;
  1355. } catch (err) {
  1356. this.log(err);
  1357. // 失败需要消耗掉stream 以防卡死
  1358. if (stream) {
  1359. await sendToWormhole(stream);
  1360. }
  1361. this.setMessage(err.toString(), this.messageType.ERROR);
  1362. responseData.err = 1;
  1363. responseData.msg = err.toString();
  1364. }
  1365. ctx.body = responseData;
  1366. }
  1367. /**
  1368. * 合同支付下载附件
  1369. * @param {Object} ctx - egg全局变量
  1370. * @return {void}
  1371. */
  1372. async payDownloadFile(ctx) {
  1373. const id = ctx.params.pid;
  1374. const index = ctx.params.index;
  1375. if (id && index) {
  1376. try {
  1377. const payInfo = await ctx.service.stagePay.getDataById(id);
  1378. if (payInfo !== undefined && payInfo.attachment !== null) {
  1379. const fileInfo = JSON.parse(payInfo.attachment)[index];
  1380. const fileName = path.join(this.app.baseDir, fileInfo.filepath);
  1381. // 解决中文无法下载问题
  1382. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1383. let disposition = '';
  1384. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1385. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
  1386. } else if (userAgent.indexOf('firefox') >= 0) {
  1387. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
  1388. } else {
  1389. /* safari等其他非主流浏览器只能自求多福了 */
  1390. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
  1391. }
  1392. ctx.response.set({
  1393. 'Content-Type': 'application/octet-stream',
  1394. 'Content-Disposition': disposition,
  1395. 'Content-Length': fileInfo.filesize,
  1396. });
  1397. ctx.body = await fs.createReadStream(fileName);
  1398. } else {
  1399. throw '不存在该文件';
  1400. }
  1401. } catch (err) {
  1402. this.log(err);
  1403. this.setMessage(err.toString(), this.messageType.ERROR);
  1404. }
  1405. }
  1406. }
  1407. /**
  1408. * 合同支付删除附件
  1409. * @param {Object} ctx - egg全局变量
  1410. * @return {void}
  1411. */
  1412. async payDeleteFile(ctx) {
  1413. const responseData = {
  1414. err: 0,
  1415. msg: '',
  1416. data: '',
  1417. };
  1418. try {
  1419. this._checkStageCanModify(ctx);
  1420. const data = JSON.parse(ctx.request.body.data);
  1421. const payInfo = await ctx.service.stagePay.getDataById(data.id);
  1422. if (payInfo !== undefined) {
  1423. const fileInfo = JSON.parse(payInfo.attachment)[data.index];
  1424. // 先删除文件
  1425. await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
  1426. // 再删除数据库
  1427. const attachment = JSON.parse(payInfo.attachment);
  1428. attachment.splice(data.index, 1);
  1429. const result = await ctx.service.stagePay.deleteAtt(data.id, attachment);
  1430. responseData.data = '';
  1431. } else {
  1432. throw '不存在该文件';
  1433. }
  1434. // if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
  1435. // throw '参数有误';
  1436. // }
  1437. // const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
  1438. // responseData.data = { add: addCompany, select: selectCompany };
  1439. } catch (err) {
  1440. responseData.err = 1;
  1441. responseData.msg = err;
  1442. }
  1443. ctx.body = responseData;
  1444. }
  1445. }
  1446. return StageController;
  1447. };