ledger_controller.js 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724
  1. 'use strict';
  2. /**
  3. * 台账相关控制器
  4. *
  5. * @author CaiAoLin
  6. * @date 2017/11/30
  7. * @version
  8. */
  9. const stdDataAddType = {
  10. withParent: 1,
  11. child: 2,
  12. next: 3,
  13. };
  14. const audit = require('../const/audit');
  15. const auditConst = audit.ledger;
  16. const tenderMenu = require('../../config/menu').tenderMenu;
  17. const measureType = require('../const/tender').measureType;
  18. const spreadConst = require('../const/spread');
  19. const externalDataConst = require('../const/external_data.js');
  20. const fs = require('fs');
  21. const LzString = require('lz-string');
  22. const accountGroup = require('../const/account_group').group;
  23. const path = require('path');
  24. const exportExcel = require('../lib/export_excel');
  25. const billsPosConvert = require('../lib/bills_pos_convert');
  26. const xlsx = require('js-xlsx');
  27. module.exports = app => {
  28. class LedgerController extends app.BaseController {
  29. /**
  30. * 构造函数
  31. *
  32. * @param {Object} ctx - egg全局变量
  33. * @return {void}
  34. */
  35. constructor(ctx) {
  36. super(ctx);
  37. ctx.showProject = true;
  38. ctx.showTitle = true;
  39. ctx.showTender = true;
  40. }
  41. /**
  42. * 检查标段是否只读(审核中,审核完成)
  43. * @param {Object} tenderData
  44. * @return {boolean}
  45. * @private
  46. */
  47. _ledgerReadOnly() {
  48. const tender = this.ctx.tender.data;
  49. return tender.user_id !== this.ctx.session.sessionUser.accountId ||
  50. (tender.ledger_status === auditConst.status.checking || tender.ledger_status === auditConst.status.checked);
  51. }
  52. /**
  53. * 获取SpreadSetting
  54. * @private
  55. */
  56. _getSpreadSetting() {
  57. const _ = this.app._;
  58. function removeFieldCols(setting, cols) {
  59. _.remove(setting.cols, function(c) {
  60. return cols.indexOf(c.field) > -1;
  61. });
  62. }
  63. function hideFieldCols(setting, cols) {
  64. for (const c of setting.cols) {
  65. if (cols.indexOf(c.field) > -1) {
  66. c.visible = false;
  67. }
  68. }
  69. }
  70. function setColFormat(cols, field, formatter) {
  71. const col = _.find(cols, function(c) {
  72. return c.field === field;
  73. });
  74. col.formatter = formatter;
  75. }
  76. // const tpFormatter = this.ctx.helper.getNumberFormatter(this.ctx.tender.info.decimal.tp);
  77. // const upFormatter = this.ctx.helper.getNumberFormatter(this.ctx.tender.info.decimal.up);
  78. const tender = this.ctx.tender;
  79. const setting = tender.data.measure_type === measureType.tz.value
  80. ? (tender.info.display.ledger.clQty ? spreadConst.withCl : spreadConst.withoutCl)
  81. : (tender.info.display.ledger.clQty ? spreadConst.withClGcl : spreadConst.withoutClGcl);
  82. const ledger = JSON.parse(JSON.stringify(setting.ledger));
  83. // setColFormat(ledger.cols, 'unit_price', upFormatter);
  84. // setColFormat(ledger.cols, 'dgn_price', upFormatter);
  85. // setColFormat(ledger.cols, 'total_price', tpFormatter);
  86. // setColFormat(ledger.cols, 'deal_tp', tpFormatter);
  87. const pos = setting.pos ? JSON.parse(JSON.stringify(setting.pos)) : spreadConst.blank;
  88. if (this._ledgerReadOnly(tender.data)) {
  89. ledger.readOnly = true;
  90. pos.readOnly = true;
  91. }
  92. if (tender.data.measure_type === measureType.tz.value) {
  93. removeFieldCols(ledger, spreadConst.filterCols.tzWithoutCols);
  94. }
  95. if (!tender.info.display.ledger.dgnQty) {
  96. removeFieldCols(ledger, spreadConst.filterCols.dgnCols);
  97. }
  98. return [ledger, pos];
  99. }
  100. /**
  101. * 台账分解页面 (Get)
  102. *
  103. * @param {Object} ctx - egg全局变量
  104. * @return {void}
  105. */
  106. async explode(ctx) {
  107. try {
  108. const tender = ctx.tender;
  109. const [ledgerSpread, posSpread] = this._getSpreadSetting();
  110. const times = tender.data.ledger_status === auditConst.status.checkNo ? tender.data.ledger_times - 1 : tender.data.ledger_times;
  111. const curAuditor = await ctx.service.ledgerAudit.getCurAuditor(tender.id, tender.data.ledger_times);
  112. const auditors = await ctx.service.ledgerAudit.getAuditorsWithOwner(tender.id, times);
  113. const user = await ctx.service.projectAccount.getAccountInfoById(ctx.tender.data.user_id);
  114. const auditHistory = [];
  115. if (times >= 1) {
  116. for (let i = 1; i <= times; i++) {
  117. auditHistory.push(await ctx.service.ledgerAudit.getAuditors(ctx.tender.id, i));
  118. }
  119. }
  120. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
  121. ctx.tender.data.valuation, ctx.tender.data.measure_type);
  122. const renderData = {
  123. tender: tender.data,
  124. tenderInfo: tender.info,
  125. auditConst,
  126. auditors,
  127. curAuditor,
  128. user,
  129. auditHistory,
  130. ledgerSpreadSetting: JSON.stringify(ledgerSpread),
  131. posSpreadSetting: JSON.stringify(posSpread),
  132. tenderMenu,
  133. preUrl: '/tender/' + tender.id,
  134. measureType,
  135. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.explode),
  136. stdBills,
  137. stdChapters,
  138. };
  139. if ((tender.data.ledger_status === auditConst.status.uncheck || tender.data.ledger_status === auditConst.status.checkNo) && tender.data.user_id === ctx.session.sessionUser.accountId) {
  140. // renderData.accountGroup = accountGroup;
  141. // 获取所有项目参与者
  142. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  143. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  144. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  145. });
  146. renderData.accountList = accountList;
  147. renderData.accountGroup = accountGroup.map((item, idx) => {
  148. const groupList = accountList.filter(item => item.account_group === idx);
  149. return { groupName: item, groupList };
  150. });
  151. renderData.auditorList = await ctx.service.ledgerAudit.getAuditors(tender.id, tender.data.ledger_times);
  152. }
  153. await this.layout('ledger/explode.ejs', renderData, 'ledger/explode_modal.ejs');
  154. } catch (err) {
  155. ctx.helper.log(err);
  156. this.postError(err, '标段数据错误');
  157. await this.redirect('/dashboard');
  158. }
  159. }
  160. /**
  161. * 获取子节点 (Ajax)
  162. * @param ctx
  163. * @return {Promise<void>}
  164. */
  165. async getChildren(ctx) {
  166. const responseData = {
  167. err: 0,
  168. msg: '',
  169. data: [],
  170. };
  171. try {
  172. const data = JSON.parse(ctx.request.body.data);
  173. const id = data.ledger_id;
  174. if (isNaN(id) || id <= 0) {
  175. throw '参数错误';
  176. }
  177. responseData.data = await ctx.service.ledger.getChildrenByParentId(ctx.tender.id, id);
  178. } catch (err) {
  179. responseData.err = 1;
  180. responseData.msg = err;
  181. }
  182. ctx.body = responseData;
  183. }
  184. /**
  185. * 树结构基本操作(增、删、上下移、升降级)
  186. * @param {Object} ctx - egg全局变量
  187. * @return {Promise<void>}
  188. */
  189. async _base(ctx, type, data) {
  190. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  191. if (type !== 'add') {
  192. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  193. }
  194. switch (type) {
  195. case 'add':
  196. return await ctx.service.ledger.addNodeBatch(ctx.tender.id, data.id, {}, data.count);
  197. case 'delete':
  198. return await ctx.service.ledger.delete(ctx.tender.id, data.id, data.count);
  199. case 'up-move':
  200. return await ctx.service.ledger.upMoveNode(ctx.tender.id, data.id, data.count);
  201. case 'down-move':
  202. return await ctx.service.ledger.downMoveNode(ctx.tender.id, data.id, data.count);
  203. case 'up-level':
  204. return await ctx.service.ledger.upLevelNode(ctx.tender.id, data.id, data.count);
  205. case 'down-level':
  206. return await ctx.service.ledger.downLevelNode(ctx.tender.id, data.id, data.count);
  207. }
  208. }
  209. /**
  210. * 复制粘贴整块
  211. *
  212. * @param ctx
  213. * @return {Promise<void>}
  214. */
  215. async _pasteBlock(ctx, data) {
  216. if ((isNaN(data.id) || data.id <= 0) ||
  217. (!data.tid && data.tid <= 0) ||
  218. (!data.block || data.block.length <= 0)) throw '参数错误';
  219. return await ctx.service.ledger.pasteBlockData(ctx.tender.id, data.id, data.block);
  220. }
  221. /**
  222. * 从标准项目表添加数据
  223. * @param ctx
  224. * @return {Promise<void>}
  225. */
  226. async _addStd(ctx, data) {
  227. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdNode) throw '参数错误';
  228. // todo 校验项目是否使用该库的权限
  229. let stdLib,
  230. addType;
  231. switch (data.stdType) {
  232. case 'xmj':
  233. stdLib = ctx.service.stdXmj;
  234. addType = stdDataAddType.withParent;
  235. break;
  236. case 'gcl':
  237. stdLib = ctx.service.stdGcl;
  238. const selectNode = await ctx.service.ledger.getDataByNodeId(ctx.tender.id, data.id);
  239. if (selectNode.b_code) {
  240. addType = stdDataAddType.next;
  241. } else {
  242. addType = stdDataAddType.child;
  243. }
  244. break;
  245. default:
  246. throw '未知标准库';
  247. }
  248. const stdData = await stdLib.getDataByDataId(data.stdLibId, data.stdNode);
  249. switch (addType) {
  250. case stdDataAddType.child:
  251. return await ctx.service.ledger.addStdNodeAsChild(ctx.tender.id, data.id, stdData);
  252. case stdDataAddType.next:
  253. return await ctx.service.ledger.addStdNode(ctx.tender.id, data.id, stdData);
  254. case stdDataAddType.withParent:
  255. return await ctx.service.ledger.addStdNodeWithParent(ctx.tender.id, stdData, stdLib);
  256. default:
  257. throw '未知添加方式';
  258. }
  259. }
  260. /**
  261. * 从签约清单添加节点
  262. * @param ctx
  263. * @return {Promise<void>}
  264. */
  265. async _addDeal(ctx, data) {
  266. if (!data.type || !data.dealBills) throw '数据错误';
  267. data.dealBills.unit_price = this.ctx.helper.round(data.dealBills.unit_price, ctx.tender.info.decimal.up);
  268. if (data.type === 'child') {
  269. return await ctx.service.ledger.addChild(ctx.tender.id, data.id, data.dealBills);
  270. } else if (data.type === 'next') {
  271. return await ctx.service.ledger.addNode(ctx.tender.id, data.id, data.dealBills);
  272. }
  273. throw '数据错误';
  274. }
  275. /**
  276. * 批量插入数据
  277. *
  278. * data = {id, batchData, batchType}
  279. * data.batchType = 'batchInsertChild'/'batchInsertNext'
  280. * data.batchData = [{name, children}] -- 项目节列表
  281. * data.batchData.children = [{code, name, unit, unit_price, quantity}] -- 工程量清单列表
  282. *
  283. * @param ctx
  284. * @return {Promise<void>}
  285. */
  286. async _batchInsert(ctx, data) {
  287. if ((isNaN(data.id) || data.id <= 0) || !data.batchType) throw '参数错误';
  288. switch (data.batchType) {
  289. case 'child':
  290. return await ctx.service.ledger.batchInsertChild(ctx.tender.id, data.id, data.batchData);
  291. case 'next':
  292. return await ctx.service.ledger.batchInsertNext(ctx.tender.id, data.id, data.batchData);
  293. default:
  294. throw '参数错误';
  295. }
  296. }
  297. /**
  298. * 更新清单相关 (Ajax)
  299. * @param ctx
  300. * @return {Promise<void>}
  301. */
  302. async update(ctx) {
  303. try {
  304. if (!ctx.tender.data) throw '标段数据错误';
  305. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId || this._ledgerReadOnly()) throw '您无权进行该操作';
  306. const data = JSON.parse(ctx.request.body.data);
  307. if (!data.postType || !data.postData) throw '数据错误';
  308. const responseData = {
  309. err: 0,
  310. msg: '',
  311. data: [],
  312. };
  313. switch (data.postType) {
  314. case 'add':
  315. case 'delete':
  316. case 'up-move':
  317. case 'down-move':
  318. case 'up-level':
  319. case 'down-level':
  320. responseData.data = await this._base(ctx, data.postType, data.postData);
  321. break;
  322. case 'update':
  323. responseData.data = await ctx.service.ledger.updateCalc(ctx.tender.id, data.postData);
  324. break;
  325. case 'paste-block':
  326. responseData.data = await this._pasteBlock(ctx, data.postData);
  327. break;
  328. case 'add-std':
  329. responseData.data = await this._addStd(ctx, data.postData);
  330. break;
  331. case 'add-deal':
  332. responseData.data = await this._addDeal(ctx, data.postData);
  333. break;
  334. case 'batch-insert':
  335. responseData.data = await this._batchInsert(ctx, data.postData);
  336. break;
  337. default:
  338. throw '未知操作';
  339. }
  340. ctx.body = responseData;
  341. } catch (err) {
  342. this.log(err);
  343. ctx.body = this.ajaxErrorBody(err);
  344. }
  345. }
  346. /**
  347. * 定位
  348. * @param ctx
  349. * @return {Promise<void>}
  350. */
  351. async locate(ctx) {
  352. const responseData = {
  353. err: 0,
  354. msg: '',
  355. data: [],
  356. };
  357. try {
  358. const tenderId = ctx.params.id;
  359. if (!tenderId) {
  360. throw '当前未打开标段';
  361. }
  362. const data = JSON.parse(ctx.request.body.data);
  363. if ((isNaN(data.id) || data.id <= 0)) {
  364. throw '参数错误';
  365. }
  366. responseData.data = await ctx.service.ledger.locateNode(tenderId, data.id);
  367. } catch (err) {
  368. this.log(err);
  369. responseData.err = 1;
  370. responseData.msg = err;
  371. }
  372. ctx.body = responseData;
  373. }
  374. /**
  375. * 获取全部子节点
  376. *
  377. * @param ctx
  378. * @return {Promise<void>}
  379. */
  380. async posterity(ctx) {
  381. const responseData = {
  382. err: 0,
  383. msg: '',
  384. data: [],
  385. };
  386. try {
  387. const tenderId = ctx.params.id;
  388. if (!tenderId) {
  389. throw '当前未打开标段';
  390. }
  391. const data = JSON.parse(ctx.request.body.data);
  392. if ((isNaN(data.id) || data.id <= 0)) {
  393. throw '参数错误';
  394. }
  395. const expandData = await ctx.service.ledger.getPosterityByParentId(tenderId, data.id);
  396. responseData.data = { expand: expandData };
  397. } catch (err) {
  398. this.log(err);
  399. responseData.err = 1;
  400. responseData.msg = err;
  401. }
  402. ctx.body = responseData;
  403. }
  404. /**
  405. * 获取部位明细数据(Ajax)
  406. *
  407. * @param ctx
  408. * @return {Promise<void>}
  409. */
  410. async loadExplodeData(ctx) {
  411. try {
  412. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  413. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  414. ? await ctx.service.pos.getPosData({ tid: ctx.tender.id }) : [];
  415. ctx.body = { err: 0, msg: '', data: { bills: ledgerData, pos: posData } };
  416. } catch (err) {
  417. this.log(err);
  418. ctx.body = { err: 1, msg: err.toString(), data: [] };
  419. }
  420. }
  421. async check(ctx) {
  422. try {
  423. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  424. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  425. ? await ctx.service.pos.getPosData({ tid: ctx.tender.id }) : [];
  426. const qtyData = ctx.helper.checkBillsWithPos(ledgerData, posData,
  427. ['sgfh_qty', 'qtcl_qty', 'sjcl_qty', 'quantity']);
  428. qtyData.error.forEach(x => { x.errorType = 'qty'; });
  429. const tpData = ctx.helper.checkBillsTp(ledgerData, [
  430. {qty: 'sgfh_qty', tp: 'sgfh_tp'}, {qty: 'qtcl_qty', tp: 'qtcl_tp'},
  431. {qty: 'sjcl_qty', tp: 'sjcl_tp'}, {qty: 'quantity', tp: 'total_price'}
  432. ], this.ctx.tender.info.decimal);
  433. tpData.error.forEach(x => { x.errorType = 'tp'; });
  434. ctx.body = { err: 0, msg: '', data: {
  435. error: [...qtyData.error, ...tpData.error],
  436. source: {
  437. bills: [...qtyData.source.bills, ...tpData.source.bills],
  438. pos: [...qtyData.source.pos, ...tpData.source.pos],
  439. },
  440. }};
  441. } catch (err) {
  442. this.log(err);
  443. ctx.body = this.ajaxErrorBody(err, '检查数据错误');
  444. }
  445. }
  446. /**
  447. * 更新 部位明细数据
  448. *
  449. * @param ctx
  450. * @return {Promise<void>}
  451. */
  452. async posUpdate(ctx) {
  453. try {
  454. await this.checkMeasureType(measureType.tz.value);
  455. const data = JSON.parse(ctx.request.body.data);
  456. const responseData = await ctx.service.pos.savePosData(data, ctx.tender.id);
  457. ctx.body = { err: 0, msg: '', data: responseData };
  458. } catch (err) {
  459. this.log(err);
  460. ctx.body = { err: 1, msg: err.toString(), data: null };
  461. }
  462. }
  463. /**
  464. * 复制粘贴 部位明细
  465. * @param ctx
  466. * @return {Promise<void>}
  467. */
  468. async posPaste(ctx) {
  469. try {
  470. await this.checkMeasureType(measureType.tz.value);
  471. const data = JSON.parse(ctx.request.body.data);
  472. const result = await ctx.service.pos.pastePosData(data, ctx.tender.id);
  473. ctx.body = { err: 0, msg: '', data: result };
  474. } catch (err) {
  475. this.log(err);
  476. ctx.body = { err: 1, msg: err.toString(), data: null };
  477. }
  478. }
  479. /**
  480. * 上传 清单Excel 并导入
  481. * @param ctx
  482. * @return {Promise<void>}
  483. */
  484. async uploadExcel(ctx) {
  485. try {
  486. const ueType = ctx.params.ueType;
  487. const compressData = ctx.request.body.data;
  488. const data = JSON.parse(LzString.decompressFromUTF16(compressData));
  489. const responseData = { err: 0, msg: '', data: {} };
  490. switch (ueType) {
  491. case 'tz':
  492. const templateId = await this.ctx.service.valuation.getValuationTemplate(
  493. this.ctx.tender.data.valuation, this.ctx.tender.data.measure_type);
  494. responseData.data = await ctx.service.ledger.importExcel(templateId, data);
  495. break;
  496. case 'gcl2xmj':
  497. responseData.data = await ctx.service.ledger.importGclExcel(data.id, data.sheet);
  498. break;
  499. default:
  500. throw '数据错误';
  501. }
  502. ctx.body = responseData;
  503. } catch (err) {
  504. this.log(err);
  505. ctx.body = { err: 1, msg: err.toString(), data: null };
  506. }
  507. }
  508. // async uploadExcel(ctx) {
  509. // let stream;
  510. // try {
  511. // const responseData = { err: 0, msg: '', data: {}, };
  512. // // 保存文件
  513. // stream = await ctx.getFileStream();
  514. // const create_time = Date.parse(new Date());
  515. // const fileInfo = path.parse(stream.filename);
  516. // const fileName = this.app.config.filePath + '/cache/ledger/uploads/' + create_time + fileInfo.ext;
  517. // await ctx.helper.saveStreamFile(stream, fileName);
  518. // // 读取excel
  519. // console.log(ctx.query);
  520. // const name = ctx.query.sheetName;
  521. // if (!name) throw '未选择需要导入的工作簿';
  522. // const wb = xlsx.readFile(fileName);
  523. // const sheetData = {
  524. // rows: xlsx.utils.sheet_to_json(wb.Sheets[name], {header: 1}),
  525. // merge: wb.Sheets[name]["!merges"],
  526. // };
  527. // if (!sheetData.rows) throw '读取工作簿数据错误';
  528. // const ueType = ctx.query.ueType;
  529. // switch (ueType) {
  530. // case 'tz':
  531. // const templateId = await this.ctx.service.valuation.getValuationTemplate(
  532. // this.ctx.tender.data.valuation, this.ctx.tender.data.measure_type);
  533. // responseData.data = await ctx.service.ledger.importExcel(templateId, sheetData);
  534. // break;
  535. // case 'gcl2xmj':
  536. // responseData.data = await ctx.service.ledger.importGclExcel(ctx.tender.id, sheetData);
  537. // break;
  538. // default:
  539. // throw '数据错误';
  540. // }
  541. // ctx.body = responseData;
  542. // } catch (err) {
  543. // console.log(err);
  544. // this.log(err);
  545. // // 失败需要消耗掉stream 以防卡死
  546. // if (stream) await sendToWormhole(stream);
  547. // ctx.body = {err: 1, msg: err.toString(), data: null};
  548. // }
  549. // }
  550. /**
  551. * 填设计量(Ajax)
  552. *
  553. * @param ctx
  554. * @return {Promise<void>}
  555. */
  556. async deal2sgfh(ctx) {
  557. try {
  558. if (!ctx.tender.data) throw '标段数据错误';
  559. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId || this._ledgerReadOnly()) throw '您无权进行该操作';
  560. if (this.ctx.tender.measure_type === measureType.tz.value) throw '该功能仅工程量清单模式可用';
  561. await this.ctx.service.ledger.deal2sgfh(ctx.tender.id);
  562. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  563. ctx.body = { err: 0, msg: '', data: { bills: ledgerData } };
  564. } catch (err) {
  565. this.log(err);
  566. ctx.body = { err: 1, msg: err.toString(), data: null };
  567. }
  568. }
  569. /**
  570. * 下载(清单Excel模板 or 导出项目台账Excel)
  571. * @param ctx
  572. * @return {Promise<void>}
  573. */
  574. async download(ctx) {
  575. const file = ctx.params.file;
  576. if (file) {
  577. try {
  578. let fileName;
  579. if (file === '导入分项清单EXCEL格式.xls') {
  580. fileName = path.join(this.app.baseDir, 'app', 'public', 'files', 'template', 'ledger', '导入分项清单EXCEL格式.xls');
  581. ctx.body = await fs.readFileSync(fileName);
  582. } else if (file === '台账分解.xlsx') {
  583. console.log(file);
  584. const create_time = Date.parse(new Date()) / 1000;
  585. fileName = this.app.baseDir + '/app/public/files/ledger' + ctx.tender.id + '-' + create_time + '.xlsx';
  586. const exportor = new exportExcel.exportLedger2Excel(ctx);
  587. await exportor.export2File(fileName);
  588. ctx.body = await fs.readFileSync(fileName);
  589. // 输出文件后删除
  590. fs.unlinkSync(fileName);
  591. }
  592. } catch (err) {
  593. this.log(err);
  594. this.setMessage(err.toString(), this.messageType.ERROR);
  595. }
  596. }
  597. }
  598. /**
  599. * 部位台账 页面 (Get)
  600. * @param ctx
  601. * @return {Promise<void>}
  602. */
  603. async bwtz(ctx) {
  604. try {
  605. const renderData = {
  606. tender: ctx.tender.data,
  607. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.bwtz),
  608. };
  609. await this.layout('ledger/bwtz.ejs', renderData);
  610. } catch (err) {
  611. this.log(err);
  612. ctx.redirect(ctx.request.header.referer);
  613. }
  614. }
  615. async loadBwtz(ctx) {
  616. try {
  617. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  618. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  619. ? await ctx.service.pos.getPosData({ tid: ctx.tender.id }) : [];
  620. const convert = new billsPosConvert(ctx);
  621. convert.loadData(ledgerData, posData, []);
  622. const result = await convert.convert();
  623. // const wbsCodeHis = await ctx.service.externalData.getExValue(ctx.tender.id, -1,
  624. // externalDataConst.FuLong.exType, externalDataConst.FuLong.exFields.wbsCode) || [];
  625. // const [result, needUpdate] = convert.convertByWbsCode(wbsCodeHis);
  626. // if (needUpdate) {
  627. // await ctx.service.externalData.saveExValue(ctx.tender.id, -1,
  628. // externalDataConst.FuLong.exType, externalDataConst.FuLong.exFields.wbsCode, wbsCodeHis);
  629. // }
  630. ctx.body = { err: 0, msg: '', data: result };
  631. } catch (err) {
  632. this.log(err);
  633. ctx.body = this.ajaxErrorBody(err, '加载合同支付数据错误');
  634. }
  635. }
  636. /**
  637. * 台账对比 页面 (Get)
  638. * @param ctx
  639. * @return {Promise<void>}
  640. */
  641. async gather(ctx) {
  642. try {
  643. const renderData = {
  644. tender: ctx.tender.data,
  645. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.gather),
  646. };
  647. await this.layout('ledger/gather.ejs', renderData);
  648. } catch (err) {
  649. this.log(err);
  650. await this.redirect(ctx.request.header.referer);
  651. }
  652. }
  653. /**
  654. * 获取 台账对比 数据 (Ajax)
  655. * @param ctx
  656. * @return {Promise<void>}
  657. */
  658. async loadGatherData(ctx) {
  659. try {
  660. const billsData = await ctx.service.ledger.getData(ctx.tender.id);
  661. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  662. ? await ctx.service.pos.getPosData({ tid: ctx.tender.id }) : [];
  663. const dealBills = await ctx.service.dealBills.getAllDataByCondition({ where: { tender_id: this.ctx.tender.id } });
  664. ctx.body = { err: 0, msg: '', data: { bills: billsData, pos: posData, dealBills } };
  665. } catch (err) {
  666. this.log(err);
  667. ctx.body = { err: 1, msg: err.toString(), data: [] };
  668. }
  669. }
  670. /**
  671. * 计量台账页面 (Get)
  672. *
  673. * @param {object} ctx - egg全局变量
  674. * @return {void}
  675. */
  676. async index(ctx) {
  677. const renderData = {};
  678. await this.layout('ledger/index.ejs', renderData);
  679. }
  680. }
  681. return LedgerController;
  682. };