ledger_controller.js 49 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117
  1. 'use strict';
  2. /**
  3. * 台账相关控制器
  4. *
  5. * @author CaiAoLin
  6. * @date 2017/11/30
  7. * @version
  8. */
  9. const audit = require('../const/audit');
  10. const moment = require('moment');
  11. const auditConst = audit.ledger;
  12. const tenderMenu = require('../../config/menu').tenderMenu;
  13. const measureType = require('../const/tender').measureType;
  14. const shenpiConst = require('../const/shenpi');
  15. const fs = require('fs');
  16. const LzString = require('lz-string');
  17. const accountGroup = require('../const/account_group').group;
  18. const path = require('path');
  19. const exportExcel = require('../lib/export_excel');
  20. const billsPosConvert = require('../lib/bills_pos_convert');
  21. const xlsx = require('js-xlsx');
  22. const stdConst = require('../const/standard');
  23. const sendToWormhole = require('stream-wormhole');
  24. const spreadSetting = require('../lib/spread_setting');
  25. const PermissionCheck = require('../const/account_permission').PermissionCheck;
  26. const streamToArray = require('stream-to-array');
  27. const DSK = require('../lib/dsk');
  28. module.exports = app => {
  29. class LedgerController extends app.BaseController {
  30. /**
  31. * 构造函数
  32. *
  33. * @param {Object} ctx - egg全局变量
  34. * @return {void}
  35. */
  36. constructor(ctx) {
  37. super(ctx);
  38. ctx.showProject = true;
  39. ctx.showTitle = true;
  40. ctx.showTender = true;
  41. }
  42. /**
  43. * 检查标段是否只读(审核中,审核完成)
  44. * @param {Object} tenderData
  45. * @return {boolean}
  46. * @private
  47. */
  48. _ledgerReadOnly() {
  49. const tender = this.ctx.tender.data;
  50. return tender.user_id !== this.ctx.session.sessionUser.accountId ||
  51. (tender.ledger_status === auditConst.status.checking || tender.ledger_status === auditConst.status.checked);
  52. }
  53. _canUpdateDealBills(tender, auditors) {
  54. const isUser = tender.user_id === this.ctx.session.sessionUser.accountId;
  55. const auditorsId = this.ctx.helper._.map(auditors, 'audit_id');
  56. const isAuditor = auditorsId.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
  57. const upPermission = this.ctx.session.sessionUser.permission && this.ctx.session.sessionUser.permission.tender
  58. ? this.ctx.session.sessionUser.permission.tender.indexOf('3') >= 0
  59. : false;
  60. return ((tender.ledger_status === auditConst.status.uncheck || tender.ledger_status === auditConst.status.checkNo) && isUser) ||
  61. (tender.ledger_status === auditConst.status.checking && isAuditor) ||
  62. (tender.ledger_status === auditConst.status.checked && upPermission);
  63. }
  64. async _getLedgerColumn() {
  65. const tender = this.ctx.tender;
  66. const ledgerColumn = [
  67. 'id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf',
  68. 'code', 'b_code', 'name', 'unit', 'unit_price', 'quantity', 'total_price',
  69. 'sgfh_qty', 'sgfh_expr', 'sgfh_tp', 'memo', 'features', 'drawing_code', 'node_type'];
  70. if (tender.info.display.ledger.deal) ledgerColumn.push('deal_qty', 'deal_tp');
  71. if (tender.info.display.ledger.dgnQty) ledgerColumn.push('dgn_qty1', 'dgn_qty2');
  72. if (tender.info.display.ledger.clQty) ledgerColumn.push('sjcl_qty', 'qtcl_qty', 'sjcl_expr', 'qtcl_expr', 'sjcl_tp', 'qtcl_tp');
  73. const posColumn = ['id', 'tid', 'lid', 'name', 'position', 'porder', 'sgfh_qty', 'sgfh_expr', 'add_stage_order', 'drawing_code', 'quantity'];
  74. if (tender.info.display.ledger.clQty) posColumn.push('sjcl_qty', 'qtcl_qty', 'sjcl_expr', 'qtcl_expr');
  75. const extraFields = await spreadSetting.getExtraFields(this.ctx, tender.id);
  76. if (extraFields.length > 0) {
  77. ledgerColumn.push(...extraFields);
  78. posColumn.push(...extraFields);
  79. }
  80. return [ledgerColumn, posColumn];
  81. }
  82. /**
  83. * 台账分解页面 (Get)
  84. *
  85. * @param {Object} ctx - egg全局变量
  86. * @return {void}
  87. */
  88. async explode(ctx) {
  89. try {
  90. const tender = ctx.tender;
  91. const [ledgerSpread, posSpread] = await spreadSetting.getLedgerSpreadSetting(ctx, tender.id,
  92. this._ledgerReadOnly(tender.data));
  93. await ctx.service.ledgerAudit.loadLedgerUser(tender.data);
  94. await ctx.service.ledgerAudit.loadLedgerAuditViewData(tender.data);
  95. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
  96. ctx.tender.data.valuation, ctx.tender.data.measure_type);
  97. // 获取附件列表
  98. const attData = await ctx.service.ledgerAtt.getDataByTenderId(ctx.tender.id);
  99. for (const index in attData) {
  100. attData[index].in_time = moment(attData[index].in_time * 1000).format('YYYY-MM-DD');
  101. attData[index].orginpath = ctx.app.config.fujianOssPath + attData[index].filepath;
  102. delete attData[index].filepath;
  103. }
  104. const whiteList = this.ctx.app.config.multipart.whitelist;
  105. const categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
  106. const syncLedger = await this.ctx.service.specPull.syncLedger(this.ctx.session.sessionProject.id);
  107. // 是否已验证手机短信
  108. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  109. const revise = await this.ctx.service.ledgerRevise.getLastestRevise(tender.id);
  110. tender.data.hasRevise = !!revise;
  111. const stage = await this.ctx.service.stage.getDataByCondition({ tid: tender.id });
  112. tender.data.hasStage = !!stage;
  113. const renderData = {
  114. tender: tender.data,
  115. tenderInfo: tender.info,
  116. auditConst,
  117. auditType: audit.auditType,
  118. auditors: tender.data.auditors,
  119. curAuditors: tender.data.curAuditors,
  120. auditHistory: tender.data.auditHistory,
  121. user: tender.data.user,
  122. attData,
  123. whiteList,
  124. ledgerSpreadSetting: JSON.stringify(ledgerSpread),
  125. posSpreadSetting: JSON.stringify(posSpread),
  126. tenderMenu,
  127. preUrl: '/tender/' + tender.id,
  128. measureType,
  129. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.explode),
  130. stdBills,
  131. stdChapters,
  132. dealBillsPermission: this._canUpdateDealBills(tender.data, tender.data.auditors),
  133. shenpiConst,
  134. categoryData,
  135. syncLedgerUrl: syncLedger ? `${ctx.app.config.url3f}/${syncLedger.pull_class}/sync-tz/${tender.id}` : '',
  136. nodeType: stdConst.nodeType,
  137. authMobile: pa.auth_mobile,
  138. deleteFilePermission: PermissionCheck.delFile(this.ctx.session.sessionUser.permission),
  139. };
  140. if ((tender.data.ledger_status !== auditConst.status.checked && ctx.session.sessionUser.is_admin) ||
  141. ((tender.data.ledger_status === auditConst.status.uncheck || tender.data.ledger_status === auditConst.status.checkNo) && tender.data.user_id === ctx.session.sessionUser.accountId)) {
  142. // 获取所有项目参与者
  143. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  144. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  145. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  146. });
  147. renderData.accountList = accountList;
  148. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  149. renderData.accountGroup = unitList.map(item => {
  150. const groupList = accountList.filter(item1 => item1.company === item.name);
  151. return { groupName: item.name, groupList };
  152. });
  153. renderData.auditorList = await ctx.service.ledgerAudit.getAuditors(tender.id, tender.data.ledger_times);
  154. }
  155. await this.layout('ledger/explode.ejs', renderData, 'ledger/explode_modal.ejs');
  156. } catch (err) {
  157. ctx.helper.log(err);
  158. this.postError(err, '标段数据错误');
  159. // await this.redirect('/dashboard');
  160. ctx.redirect(ctx.request.header.referer);
  161. }
  162. }
  163. /**
  164. * 获取子节点 (Ajax)
  165. * @param ctx
  166. * @return {Promise<void>}
  167. */
  168. async getChildren(ctx) {
  169. const responseData = {
  170. err: 0,
  171. msg: '',
  172. data: [],
  173. };
  174. try {
  175. const data = JSON.parse(ctx.request.body.data);
  176. const id = data.ledger_id;
  177. if (isNaN(id) || id <= 0) {
  178. throw '参数错误';
  179. }
  180. responseData.data = await ctx.service.ledger.getChildrenByParentId(ctx.tender.id, id);
  181. } catch (err) {
  182. responseData.err = 1;
  183. responseData.msg = err;
  184. }
  185. ctx.body = responseData;
  186. }
  187. /**
  188. * 树结构基本操作(增、删、上下移、升降级)
  189. * @param {Object} ctx - egg全局变量
  190. * @return {Promise<void>}
  191. */
  192. async _base(ctx, type, data) {
  193. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  194. if (type !== 'add') {
  195. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  196. }
  197. switch (type) {
  198. case 'add':
  199. return await ctx.service.ledger.addNodeBatch(ctx.tender.id, data.id, {}, data.count);
  200. case 'delete':
  201. return await ctx.service.ledger.delete(ctx.tender.id, data.id, data.count);
  202. case 'up-move':
  203. return await ctx.service.ledger.upMoveNode(ctx.tender.id, data.id, data.count);
  204. case 'down-move':
  205. return await ctx.service.ledger.downMoveNode(ctx.tender.id, data.id, data.count);
  206. case 'up-level':
  207. return await ctx.service.ledger.upLevelNode(ctx.tender.id, data.id, data.count);
  208. case 'down-level':
  209. return await ctx.service.ledger.downLevelNode(ctx.tender.id, data.id, data.count);
  210. }
  211. }
  212. /**
  213. * 复制粘贴整块
  214. *
  215. * @param ctx
  216. * @return {Promise<void>
  217. */
  218. async _pasteBlock(ctx, data) {
  219. if ((isNaN(data.id) || data.id <= 0) ||
  220. (!data.tid && data.tid <= 0) ||
  221. (!data.block || data.block.length <= 0)) throw '参数错误';
  222. return await ctx.service.ledger.pasteBlockData(ctx.tender.id, data.id, data.block);
  223. }
  224. /**
  225. * 从标准项目表添加数据
  226. * @param ctx
  227. * @return {Promise<void>}
  228. */
  229. async _addStd(ctx, data) {
  230. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdData) throw '参数错误';
  231. // todo 校验项目是否使用该库的权限
  232. switch (data.stdType) {
  233. case 'xmj':
  234. return await ctx.service.ledger.addStdNodeWithParent(ctx.tender.id, data.stdData);
  235. case 'gcl':
  236. return data.withParent
  237. ? await ctx.service.ledger.addGclStdNodeWithParent(ctx.tender.id, data.id, data.stdData)
  238. : await ctx.service.ledger.addGclStdNode(ctx.tender.id, data.id, data.stdData[data.stdData.length - 1]);
  239. default:
  240. throw '未知标准库';
  241. }
  242. }
  243. /**
  244. * 从签约清单添加节点
  245. * @param ctx
  246. * @return {Promise<void>}
  247. */
  248. async _addDeal(ctx, data) {
  249. if (!data.type || !data.dealBills) throw '数据错误';
  250. data.dealBills.unit_price = this.ctx.helper.round(data.dealBills.unit_price, ctx.tender.info.decimal.up);
  251. if (data.type === 'child') {
  252. return await ctx.service.ledger.addChild(ctx.tender.id, data.id, data.dealBills);
  253. } else if (data.type === 'next') {
  254. return await ctx.service.ledger.addNode(ctx.tender.id, data.id, data.dealBills);
  255. }
  256. throw '数据错误';
  257. }
  258. /**
  259. * 批量插入数据
  260. *
  261. * data = {id, batchData, batchType}
  262. * data.batchType = 'batchInsertChild'/'batchInsertNext'
  263. * data.batchData = [{name, children}] -- 项目节列表
  264. * data.batchData.children = [{code, name, unit, unit_price, quantity}] -- 工程量清单列表
  265. *
  266. * @param ctx
  267. * @return {Promise<void>}
  268. */
  269. async _batchInsert(ctx, data) {
  270. if ((isNaN(data.id) || data.id <= 0) || !data.batchType) throw '参数错误';
  271. switch (data.batchType) {
  272. case 'child':
  273. return await ctx.service.ledger.batchInsertChild(ctx.tender.id, data.id, data.batchData);
  274. case 'next':
  275. return await ctx.service.ledger.batchInsertNext(ctx.tender.id, data.id, data.batchData);
  276. default:
  277. throw '参数错误';
  278. }
  279. }
  280. /**
  281. * 更新清单相关 (Ajax)
  282. * @param ctx
  283. * @return {Promise<void>}
  284. */
  285. async update(ctx) {
  286. try {
  287. if (!ctx.tender.data) throw '标段数据错误';
  288. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId || this._ledgerReadOnly()) throw '您无权进行该操作';
  289. const data = JSON.parse(ctx.request.body.data);
  290. if (!data.postType || !data.postData) throw '数据错误';
  291. const responseData = {
  292. err: 0,
  293. msg: '',
  294. data: [],
  295. };
  296. switch (data.postType) {
  297. case 'add':
  298. case 'delete':
  299. case 'up-move':
  300. case 'down-move':
  301. case 'up-level':
  302. case 'down-level':
  303. responseData.data = await this._base(ctx, data.postType, data.postData);
  304. break;
  305. case 'update':
  306. ctx.helper.checkDgnQtyPrecision(data.postData);
  307. responseData.data = await ctx.service.ledger.updateCalc(ctx.tender.id, data.postData);
  308. break;
  309. case 'paste-block':
  310. responseData.data = await this._pasteBlock(ctx, data.postData);
  311. break;
  312. case 'add-std':
  313. responseData.data = await this._addStd(ctx, data.postData);
  314. break;
  315. case 'add-deal':
  316. responseData.data = await this._addDeal(ctx, data.postData);
  317. break;
  318. case 'batch-insert':
  319. responseData.data = await this._batchInsert(ctx, data.postData);
  320. break;
  321. default:
  322. throw '未知操作';
  323. }
  324. ctx.body = responseData;
  325. } catch (err) {
  326. this.log(err);
  327. ctx.body = this.ajaxErrorBody(err);
  328. }
  329. }
  330. /**
  331. * 定位
  332. * @param ctx
  333. * @return {Promise<void>}
  334. */
  335. async locate(ctx) {
  336. const responseData = {
  337. err: 0,
  338. msg: '',
  339. data: [],
  340. };
  341. try {
  342. const tenderId = ctx.params.id;
  343. if (!tenderId) {
  344. throw '当前未打开标段';
  345. }
  346. const data = JSON.parse(ctx.request.body.data);
  347. if ((isNaN(data.id) || data.id <= 0)) {
  348. throw '参数错误';
  349. }
  350. responseData.data = await ctx.service.ledger.locateNode(tenderId, data.id);
  351. } catch (err) {
  352. this.log(err);
  353. responseData.err = 1;
  354. responseData.msg = err;
  355. }
  356. ctx.body = responseData;
  357. }
  358. /**
  359. * 获取全部子节点
  360. *
  361. * @param ctx
  362. * @return {Promise<void>}
  363. */
  364. async posterity(ctx) {
  365. const responseData = {
  366. err: 0,
  367. msg: '',
  368. data: [],
  369. };
  370. try {
  371. const tenderId = ctx.params.id;
  372. if (!tenderId) {
  373. throw '当前未打开标段';
  374. }
  375. const data = JSON.parse(ctx.request.body.data);
  376. if ((isNaN(data.id) || data.id <= 0)) {
  377. throw '参数错误';
  378. }
  379. const expandData = await ctx.service.ledger.getPosterityByParentId(tenderId, data.id);
  380. responseData.data = { expand: expandData };
  381. } catch (err) {
  382. this.log(err);
  383. responseData.err = 1;
  384. responseData.msg = err;
  385. }
  386. ctx.body = responseData;
  387. }
  388. /**
  389. * 获取部位明细数据(Ajax)
  390. *
  391. * @param ctx
  392. * @return {Promise<void>}
  393. */
  394. async loadExplodeData(ctx) {
  395. try {
  396. const [ledgerColumn, posColumn] = await this._getLedgerColumn();
  397. // const ledgerData = ctx.tender.ledgerReadOnly && ctx.tender.his
  398. // ? await ctx.helper.loadLedgerDataFromOss(ctx.tender.his.bills_file)
  399. // : await ctx.service.ledger.getAllDataByCondition({ columns: ledgerColumn, where: { tender_id: ctx.tender.id } });
  400. // const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  401. // ? (ctx.tender.ledgerReadOnly && ctx.tender.his
  402. // ? await ctx.helper.loadLedgerDataFromOss(ctx.tender.his.pos_file)
  403. // : await ctx.service.pos.getPosData({tid: ctx.tender.id}, posColumn))
  404. // : [];
  405. const ledgerData = await ctx.service.ledger.getAllDataByCondition({ columns: ledgerColumn, where: { tender_id: ctx.tender.id } });
  406. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  407. ? await ctx.service.pos.getPosData({tid: ctx.tender.id}, posColumn)
  408. : [];
  409. const ancillaryGclData = this.ctx.tender.data.measure_type === measureType.tz.value
  410. ? await ctx.service.ancillaryGcl.getAllDataByCondition({ where: { tid: ctx.tender.id } })
  411. : [];
  412. const ledgerTags = await this.ctx.service.ledgerTag.getDatas(ctx.tender.id);
  413. ctx.body = { err: 0, msg: '', data: { bills: ledgerData, pos: posData, ancGcl: ancillaryGclData, tags: ledgerTags } };
  414. } catch (err) {
  415. this.log(err);
  416. ctx.body = { err: 1, msg: err.toString(), data: [] };
  417. }
  418. }
  419. async check(ctx) {
  420. try {
  421. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  422. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  423. ? await ctx.service.pos.getPosData({ tid: ctx.tender.id }) : [];
  424. const checkDataModel = require('../lib/ledger').checkData;
  425. const checkData = new checkDataModel(ctx, measureType);
  426. checkData.loadData(ledgerData, posData);
  427. ctx.tender.info.ledger_check.same_code && checkData.checkSameCode();
  428. ctx.tender.info.ledger_check.sibling && checkData.checkSibling();
  429. if (ctx.tender.data.measure_type === measureType.tz.value) checkData.checkBillsQty(['sgfh_qty', 'qtcl_qty', 'sjcl_qty', 'quantity']);
  430. checkData.checkBillsTp([
  431. {qty: 'sgfh_qty', tp: 'sgfh_tp'}, {qty: 'qtcl_qty', tp: 'qtcl_tp'},
  432. {qty: 'sjcl_qty', tp: 'sjcl_tp'}, {qty: 'quantity', tp: 'total_price'}
  433. ], this.ctx.tender.info.decimal);
  434. ctx.body = { err: 0, msg: '', data: checkData.checkResult };
  435. } catch (err) {
  436. this.log(err);
  437. ctx.body = this.ajaxErrorBody(err, '检查数据错误');
  438. }
  439. }
  440. async ancGclUpdate(ctx) {
  441. try {
  442. await this.checkMeasureType(measureType.tz.value);
  443. const data = JSON.parse(ctx.request.body.data);
  444. const responseData = await ctx.service.ancillaryGcl.updateDatas(data);
  445. ctx.body = { err: 0, msg: '', data: responseData };
  446. } catch (err) {
  447. this.log(err);
  448. ctx.body = { err: 1, msg: err.toString(), data: null };
  449. }
  450. }
  451. /**
  452. * 更新 部位明细数据
  453. *
  454. * @param ctx
  455. * @return {Promise<void>}
  456. */
  457. async posUpdate(ctx) {
  458. try {
  459. await this.checkMeasureType(measureType.tz.value);
  460. const data = JSON.parse(ctx.request.body.data);
  461. const responseData = await ctx.service.pos.savePosData(data, ctx.tender.id);
  462. ctx.body = { err: 0, msg: '', data: responseData };
  463. } catch (err) {
  464. this.log(err);
  465. ctx.body = { err: 1, msg: err.toString(), data: null };
  466. }
  467. }
  468. /**
  469. * 复制粘贴 部位明细
  470. * @param ctx
  471. * @return {Promise<void>}
  472. */
  473. async posPaste(ctx) {
  474. try {
  475. await this.checkMeasureType(measureType.tz.value);
  476. const data = JSON.parse(ctx.request.body.data);
  477. const result = await ctx.service.pos.pastePosData(data, ctx.tender.id);
  478. ctx.body = { err: 0, msg: '', data: result };
  479. } catch (err) {
  480. this.log(err);
  481. ctx.body = { err: 1, msg: err.toString(), data: null };
  482. }
  483. }
  484. /**
  485. * 上传 清单Excel 并导入
  486. * @param ctx
  487. * @return {Promise<void>}
  488. */
  489. async uploadExcel(ctx) {
  490. try {
  491. const ueType = ctx.params.ueType;
  492. const compressData = ctx.request.body.data;
  493. const data = JSON.parse(LzString.decompressFromUTF16(compressData));
  494. const responseData = { err: 0, msg: '', data: {} };
  495. switch (ueType) {
  496. case 'tz':
  497. const templateId = await this.ctx.service.valuation.getValuationTemplate(
  498. this.ctx.tender.data.valuation, this.ctx.tender.data.measure_type);
  499. responseData.data = await ctx.service.ledger.importExcel(templateId, data.sheet, data.filter);
  500. break;
  501. case 'gcl2xmj':
  502. responseData.data = await ctx.service.ledger.importGclExcel(data.id, data.sheet);
  503. break;
  504. default:
  505. throw '数据错误';
  506. }
  507. ctx.body = responseData;
  508. } catch (err) {
  509. this.log(err);
  510. ctx.body = { err: 1, msg: err.toString(), data: null };
  511. }
  512. }
  513. async uploadYbp(ctx) {
  514. const stream = await ctx.getFileStream();
  515. try {
  516. // 读取字节流
  517. const parts = await streamToArray(stream);
  518. // 转化为buffer
  519. const buffer = Buffer.concat(parts);
  520. const bills = await ctx.service.ledger.importYbp(ctx.tender, buffer.toString());
  521. ctx.body = { err: 0, msg: '', data: { bills, pos: [] }};
  522. } catch (err) {
  523. await sendToWormhole(stream);
  524. ctx.log(err);
  525. ctx.ajaxErrorBody(err, '导入计价文件出错');
  526. }
  527. }
  528. async importDsk(ctx) {
  529. try {
  530. const data = JSON.parse(ctx.request.body.data);
  531. if (!data.subjects || data.subjects.length === 0) throw '无导入计价数据';
  532. // 拼凑ybp数据
  533. const ybpData = { header: {}, subjects: [] };
  534. const dsk = new DSK(ctx);
  535. for (const s of data.subjects) {
  536. const subject = { project: { name: '' }, rations: [], };
  537. subject.bills = await dsk.getProjectBills(s.compilationId, s.subjectId);
  538. // 拼凑fees.marketCommon.totalFee,fees.marketLabour.totalFee防止出错
  539. subject.bills.forEach(b => {
  540. b.fees = {
  541. marketCommon: { unitPrice: b.unitPrice, totalFee: b.totalPrice },
  542. marketLabour: { unitPrice: 0, totalFee: 0 },
  543. };
  544. });
  545. ybpData.subjects.push(subject);
  546. }
  547. const bills = await ctx.service.ledger.importYbpData(ctx.tender, ybpData);
  548. ctx.body = { err: 0, msg: '', data: { bills, pos: [] }};
  549. } catch (err) {
  550. ctx.log(err);
  551. ctx.ajaxErrorBody(err, '导入计价分段出错');
  552. }
  553. }
  554. // async uploadExcel(ctx) {
  555. // let stream;
  556. // try {
  557. // const responseData = { err: 0, msg: '', data: {}, };
  558. // // 保存文件
  559. // stream = await ctx.getFileStream();
  560. // const create_time = Date.parse(new Date());
  561. // const fileInfo = path.parse(stream.filename);
  562. // const fileName = this.app.config.filePath + '/cache/ledger/uploads/' + create_time + fileInfo.ext;
  563. // await ctx.helper.saveStreamFile(stream, fileName);
  564. // // 读取excel
  565. // console.log(ctx.query);
  566. // const name = ctx.query.sheetName;
  567. // if (!name) throw '未选择需要导入的工作簿';
  568. // const wb = xlsx.readFile(fileName);
  569. // const sheetData = {
  570. // rows: xlsx.utils.sheet_to_json(wb.Sheets[name], {header: 1}),
  571. // merge: wb.Sheets[name]["!merges"],
  572. // };
  573. // if (!sheetData.rows) throw '读取工作簿数据错误';
  574. // const ueType = ctx.query.ueType;
  575. // switch (ueType) {
  576. // case 'tz':
  577. // const templateId = await this.ctx.service.valuation.getValuationTemplate(
  578. // this.ctx.tender.data.valuation, this.ctx.tender.data.measure_type);
  579. // responseData.data = await ctx.service.ledger.importExcel(templateId, sheetData);
  580. // break;
  581. // case 'gcl2xmj':
  582. // responseData.data = await ctx.service.ledger.importGclExcel(ctx.tender.id, sheetData);
  583. // break;
  584. // default:
  585. // throw '数据错误';
  586. // }
  587. // ctx.body = responseData;
  588. // } catch (err) {
  589. // console.log(err);
  590. // this.log(err);
  591. // // 失败需要消耗掉stream 以防卡死
  592. // if (stream) await sendToWormhole(stream);
  593. // ctx.body = {err: 1, msg: err.toString(), data: null};
  594. // }
  595. // }
  596. /**
  597. * 填设计量(Ajax)
  598. *
  599. * @param ctx
  600. * @return {Promise<void>}
  601. */
  602. async deal2sgfh(ctx) {
  603. try {
  604. if (!ctx.tender.data) throw '标段数据错误';
  605. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId || this._ledgerReadOnly()) throw '您无权进行该操作';
  606. if (this.ctx.tender.measure_type === measureType.tz.value) throw '该功能仅工程量清单模式可用';
  607. await this.ctx.service.ledger.deal2sgfh(ctx.tender.id);
  608. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  609. ctx.body = { err: 0, msg: '', data: { bills: ledgerData } };
  610. } catch (err) {
  611. this.log(err);
  612. ctx.body = { err: 1, msg: err.toString(), data: null };
  613. }
  614. }
  615. /**
  616. * 下载(清单Excel模板 or 导出项目台账Excel)
  617. * @param ctx
  618. * @return {Promise<void>}
  619. */
  620. async download(ctx) {
  621. const file = ctx.params.file;
  622. if (file) {
  623. try {
  624. let fileName;
  625. if (file === '导入分项清单EXCEL格式.xlsx') {
  626. fileName = path.join(this.app.baseDir, 'app', 'public', 'files', 'template', 'ledger', '导入分项清单EXCEL格式.xlsx');
  627. ctx.body = await fs.readFileSync(fileName);
  628. } else if (file === '台账分解.xlsx') {
  629. const create_time = Date.parse(new Date()) / 1000;
  630. fileName = this.app.baseDir + '/app/public/files/ledger' + ctx.tender.id + '-' + create_time + '.xlsx';
  631. const exportor = new exportExcel.exportLedger2Excel(ctx);
  632. await exportor.export2File(fileName);
  633. ctx.body = await fs.readFileSync(fileName);
  634. // 输出文件后删除
  635. fs.unlinkSync(fileName);
  636. }
  637. } catch (err) {
  638. this.log(err);
  639. this.setMessage(err.toString(), this.messageType.ERROR);
  640. }
  641. }
  642. }
  643. /**
  644. * 部位台账 页面 (Get)
  645. * @param ctx
  646. * @return {Promise<void>}
  647. */
  648. async bwtz(ctx) {
  649. try {
  650. const sjsRela = await ctx.service.project.getTenderSjsRela(ctx.session.sessionProject.id, ctx.tender.info.display.exMemo);
  651. const renderData = {
  652. tender: ctx.tender.data,
  653. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.bwtz),
  654. ex_memo1: sjsRela.ledgerCol.find(x => { return x.field === 'ex_memo1'; }),
  655. ex_memo2: sjsRela.ledgerCol.find(x => { return x.field === 'ex_memo2'; }),
  656. ex_memo3: sjsRela.ledgerCol.find(x => { return x.field === 'ex_memo3'; }),
  657. };
  658. await this.layout('ledger/bwtz.ejs', renderData);
  659. } catch (err) {
  660. this.log(err);
  661. ctx.redirect(ctx.request.header.referer);
  662. }
  663. }
  664. async loadBwtz(ctx) {
  665. try {
  666. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  667. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  668. ? await ctx.service.pos.getPosData({ tid: ctx.tender.id }) : [];
  669. const convert = new billsPosConvert(ctx);
  670. convert.loadData(ledgerData, posData, []);
  671. const result = await convert.convert();
  672. // const wbsCodeHis = await ctx.service.externalData.getExValue(ctx.tender.id, -1,
  673. // externalDataConst.FuLong.exType, externalDataConst.FuLong.exFields.wbsCode) || [];
  674. // const [result, needUpdate] = convert.convertByWbsCode(wbsCodeHis);
  675. // if (needUpdate) {
  676. // await ctx.service.externalData.saveExValue(ctx.tender.id, -1,
  677. // externalDataConst.FuLong.exType, externalDataConst.FuLong.exFields.wbsCode, wbsCodeHis);
  678. // }
  679. ctx.body = { err: 0, msg: '', data: result };
  680. } catch (err) {
  681. this.log(err);
  682. ctx.body = this.ajaxErrorBody(err, '加载合同支付数据错误');
  683. }
  684. }
  685. /**
  686. * 台账对比 页面 (Get)
  687. * @param ctx
  688. * @return {Promise<void>}
  689. */
  690. async gather(ctx) {
  691. try {
  692. const renderData = {
  693. measureType,
  694. tender: ctx.tender.data,
  695. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.gather),
  696. };
  697. await this.layout('ledger/gather.ejs', renderData);
  698. } catch (err) {
  699. this.log(err);
  700. await this.redirect(ctx.request.header.referer);
  701. }
  702. }
  703. async _getChangeData(ctx) {
  704. const change = await ctx.service.change.getAllDataByCondition({
  705. columns: [ 'cid', 'code', 'name', 'w_code' ],
  706. where: { tid: ctx.tender.id, valid: 1, status: audit.flow.status.checked },
  707. orders: [['code', 'asc']],
  708. });
  709. const changeBills = await ctx.service.changeAuditList.getAllDataByCondition({
  710. columns: [ 'cid', 'code', 'name', 'unit', 'unit_price', 'oamount2', 'checked_amount', 'checked_price', 'is_valuation' ],
  711. where: { tid: ctx.tender.id }
  712. });
  713. const changeIndex = {};
  714. change.forEach(x => { changeIndex[x.cid] = x; x.bills = [] });
  715. changeBills.forEach(cb => {
  716. const c = changeIndex[cb.cid];
  717. if (!c) return;
  718. c.bills.push(cb);
  719. });
  720. return change;
  721. }
  722. /**
  723. * 获取 台账对比 数据 (Ajax)
  724. * @param ctx
  725. * @return {Promise<void>}
  726. */
  727. async loadGatherData(ctx) {
  728. try {
  729. const billsData = await ctx.service.ledger.getData(ctx.tender.id);
  730. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  731. ? await ctx.service.pos.getPosData({ tid: ctx.tender.id }) : [];
  732. const dealBills = await ctx.service.dealBills.getAllDataByCondition({ where: { tender_id: this.ctx.tender.id } });
  733. const ancGcl = this.ctx.tender.data.measure_type === measureType.tz.value
  734. ? await ctx.service.ancillaryGcl.getAllDataByCondition({ where: { tid: ctx.tender.id } }) : [];
  735. const change = await this._getChangeData(ctx);
  736. const zlj = JSON.parse(JSON.stringify(stdConst.zlj));
  737. zlj.deal_bills_tp = ctx.tender.info.deal_param.zanLiePrice;
  738. ctx.body = { err: 0, msg: '', data: {
  739. bills: billsData, pos: posData, ancGcl, dealBills, change, spec: {zlj: zlj, jrg: stdConst.jrg},
  740. }};
  741. } catch (err) {
  742. this.log(err);
  743. ctx.body = { err: 1, msg: err.toString(), data: [] };
  744. }
  745. }
  746. /**
  747. * 计量台账页面 (Get)
  748. *
  749. * @param {object} ctx - egg全局变量
  750. * @return {void}
  751. */
  752. async index(ctx) {
  753. const renderData = {};
  754. await this.layout('ledger/index.ejs', renderData);
  755. }
  756. /**
  757. * 审批流程(Get)
  758. * @param ctx
  759. * @return {Promise<void>}
  760. */
  761. async ledgerAuditors(ctx) {
  762. try {
  763. const tender = ctx.tender.data;
  764. await ctx.service.ledgerAudit.loadLedgerUser(tender);
  765. await ctx.service.ledgerAudit.loadLedgerAuditViewData(tender);
  766. ctx.body = {err: 0, msg: '', data: tender};
  767. } catch (error) {
  768. this.log(error);
  769. ctx.body = { err: 1, msg: error.toString(), data: null };
  770. }
  771. }
  772. /**
  773. * 上传附件
  774. * @param {Object} ctx - egg全局变量
  775. * @return {void}
  776. */
  777. async uploadFile(ctx) {
  778. const responseData = {
  779. err: 0,
  780. msg: '',
  781. data: [],
  782. };
  783. let stream;
  784. try {
  785. const parts = ctx.multipart({ autoFields: true });
  786. const files = [];
  787. let index = 0;
  788. const extra_upload = ctx.tender.data.ledger_status === auditConst.status.checked;
  789. while ((stream = await parts()) !== undefined) {
  790. // 判断用户是否选择上传文件
  791. if (!stream.filename) {
  792. throw '请选择上传的文件!';
  793. }
  794. const fileInfo = path.parse(stream.filename);
  795. const create_time = Date.parse(new Date()) / 1000;
  796. const filepath = `app/public/upload/${this.ctx.tender.id}/ledger/fujian_${create_time + index.toString() + fileInfo.ext}`;
  797. // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath));
  798. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  799. if (stream) {
  800. await sendToWormhole(stream);
  801. }
  802. // 保存数据到att表
  803. const fileData = {
  804. tid: ctx.params.id,
  805. in_time: create_time,
  806. filename: fileInfo.name,
  807. fileext: fileInfo.ext,
  808. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  809. filepath,
  810. extra_upload,
  811. };
  812. const result = await ctx.service.ledgerAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
  813. if (!result) {
  814. throw '导入数据库保存失败';
  815. }
  816. const attData = await ctx.service.ledgerAtt.getDataByFid(result.insertId);
  817. attData.in_time = moment(create_time * 1000).format('YYYY-MM-DD');
  818. files.length !== 0 ? files.unshift(attData) : files.push(attData);
  819. ++index;
  820. }
  821. responseData.data = files;
  822. } catch (err) {
  823. this.log(err);
  824. // 失败需要消耗掉stream 以防卡死
  825. if (stream) {
  826. await sendToWormhole(stream);
  827. }
  828. this.setMessage(err.toString(), this.messageType.ERROR);
  829. responseData.err = 1;
  830. responseData.msg = err.toString();
  831. }
  832. ctx.body = responseData;
  833. }
  834. /**
  835. * 下载附件
  836. * @param {Object} ctx - egg全局变量
  837. * @return {void}
  838. */
  839. async downloadFile(ctx) {
  840. const id = ctx.params.fid;
  841. if (id) {
  842. try {
  843. const fileInfo = await ctx.service.ledgerAtt.getDataById(id);
  844. if (fileInfo !== undefined && fileInfo !== '') {
  845. // const fileName = path.join(this.app.baseDir, fileInfo.filepath);
  846. // 解决中文无法下载问题
  847. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  848. let disposition = '';
  849. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  850. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
  851. } else if (userAgent.indexOf('firefox') >= 0) {
  852. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
  853. } else {
  854. /* safari等其他非主流浏览器只能自求多福了 */
  855. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
  856. }
  857. ctx.response.set({
  858. 'Content-Type': 'application/octet-stream',
  859. 'Content-Disposition': disposition,
  860. 'Content-Length': fileInfo.filesize,
  861. });
  862. // ctx.body = await fs.createReadStream(fileName);
  863. ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
  864. } else {
  865. throw '不存在该文件';
  866. }
  867. } catch (err) {
  868. this.log(err);
  869. this.setMessage(err.toString(), this.messageType.ERROR);
  870. }
  871. }
  872. }
  873. /**
  874. * 查看附件
  875. * @param {Object} ctx - egg全局变量
  876. * @return {void}
  877. */
  878. async checkFile(ctx) {
  879. const responseData = { err: 0, msg: '' };
  880. const { id = '' } = JSON.parse(ctx.request.body.data);
  881. if (id) {
  882. try {
  883. const fileInfo = await ctx.service.ledgerAtt.getDataById(id);
  884. if (fileInfo && Object.keys(fileInfo).length) {
  885. let filepath = fileInfo.filepath;
  886. if (!ctx.helper.canPreview(fileInfo.fileext)) {
  887. filepath = `/tender/${ctx.tender.id}/ledger/download/file/${fileInfo.id}`;
  888. } else {
  889. // filepath = filepath.replace(/^app|\/app/, '');
  890. filepath = ctx.app.config.fujianOssPath + filepath;
  891. }
  892. fileInfo.filepath && (responseData.data = { filepath });
  893. }
  894. } catch (error) {
  895. this.log(error);
  896. this.setMessage(error.toString(), this.messageType.ERROR);
  897. responseData.err = 1;
  898. responseData.msg = error.toString();
  899. }
  900. }
  901. ctx.body = responseData;
  902. }
  903. /**
  904. * 删除附件
  905. * @param {Object} ctx - egg全局变量
  906. * @return {void}
  907. */
  908. async deleteFile(ctx) {
  909. const responseData = {
  910. err: 0,
  911. msg: '',
  912. data: '',
  913. };
  914. try {
  915. // this._checkStageCanModifyRe(ctx);
  916. const data = JSON.parse(ctx.request.body.data);
  917. const fileInfo = await ctx.service.ledgerAtt.getDataById(data.id);
  918. if (!fileInfo || !Object.keys(fileInfo).length) {
  919. throw '该文件不存在';
  920. }
  921. if (!fileInfo.extra_upload && ctx.tender.status === auditConst.status.checked) {
  922. throw '无权限删除';
  923. }
  924. if (fileInfo !== undefined && fileInfo !== '') {
  925. // 先删除文件
  926. // await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
  927. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  928. // 再删除数据库
  929. await ctx.service.ledgerAtt.deleteById(data.id);
  930. responseData.data = '';
  931. } else {
  932. throw '不存在该文件';
  933. }
  934. } catch (err) {
  935. responseData.err = 1;
  936. responseData.msg = err;
  937. }
  938. ctx.body = responseData;
  939. }
  940. /**
  941. * 保存附件(或替换)
  942. * @param {Object} ctx - egg全局变量
  943. * @return {void}
  944. */
  945. async saveFile(ctx) {
  946. const responseData = {
  947. err: 0,
  948. msg: '',
  949. data: [],
  950. };
  951. let stream;
  952. try {
  953. // this._checkStageCanModifyRe(ctx);
  954. stream = await ctx.getFileStream({ requireFile: false });
  955. let fileData = {};
  956. if (stream.filename !== undefined) {
  957. const create_time = Date.parse(new Date()) / 1000;
  958. const fileInfo = path.parse(stream.filename);
  959. const dirName = `app/public/upload/${this.ctx.tender.id}/ledger`;
  960. const fileName = 'fujian_' + create_time + fileInfo.ext;
  961. // 判断文件夹是否存在,不存在则直接创建文件夹
  962. // if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
  963. // await fs.mkdirSync(path.join(this.app.baseDir, dirName));
  964. // }
  965. // 保存文件
  966. // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
  967. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + path.join(dirName, fileName), stream);
  968. // 保存数据到att表
  969. fileData = {
  970. filesize: stream.fields.size,
  971. filepath: path.join(dirName, fileName),
  972. };
  973. }
  974. const result = await ctx.service.ledgerAtt.updateByID(stream.fields, fileData);
  975. if (!result) {
  976. throw '导入数据库保存失败';
  977. }
  978. const attData = await ctx.service.ledgerAtt.getDataByFid(stream.fields.id);
  979. attData.in_time = moment(attData.in_time * 1000).format('YYYY-MM-DD');
  980. responseData.data = attData;
  981. } catch (err) {
  982. this.log(err);
  983. // 失败需要消耗掉stream 以防卡死
  984. if (stream) {
  985. await sendToWormhole(stream);
  986. }
  987. this.setMessage(err.toString(), this.messageType.ERROR);
  988. responseData.err = 1;
  989. responseData.msg = err.toString();
  990. }
  991. ctx.body = responseData;
  992. }
  993. /**
  994. * 批量下载 - 压缩成zip文件返回
  995. * @param {Object} ctx - 全局上下文
  996. */
  997. async downloadZip(ctx) {
  998. const zipFilename = `${ctx.tender.data.name}-台账分解-附件.zip`;
  999. const time = Date.now();
  1000. const zipPath = `app/public/upload/${ctx.tender.id}/ledger/fu_jian_zip${time}.zip`;
  1001. const responseData = {
  1002. err: 0,
  1003. msg: '',
  1004. };
  1005. try {
  1006. const { fileIds = [] } = JSON.parse(ctx.request.body.data);
  1007. const size = await ctx.service.ledgerAtt.compressedFile(fileIds, zipPath);
  1008. // 解决中文无法下载问题
  1009. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1010. let disposition = '';
  1011. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1012. disposition = 'attachment; filename=' + encodeURIComponent(zipFilename);
  1013. } else if (userAgent.indexOf('firefox') >= 0) {
  1014. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(zipFilename) + '"';
  1015. } else {
  1016. /* safari等其他非主流浏览器只能自求多福了 */
  1017. disposition = 'attachment; filename=' + new Buffer(zipFilename).toString('binary');
  1018. }
  1019. ctx.response.set({
  1020. 'Content-Type': 'application/octet-stream',
  1021. 'Content-Disposition': disposition,
  1022. 'Content-Length': size,
  1023. });
  1024. const readStream = fs.createReadStream(path.join(this.app.baseDir, zipPath));
  1025. ctx.body = readStream;
  1026. readStream.on('close', () => {
  1027. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1028. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1029. }
  1030. });
  1031. // fs的错误不能被try catch捕捉
  1032. readStream.on('error', err => {
  1033. this.log(err);
  1034. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1035. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1036. }
  1037. responseData.err = 1;
  1038. responseData.msg = err.toString();
  1039. ctx.body = responseData;
  1040. });
  1041. } catch (err) {
  1042. this.log(err);
  1043. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1044. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1045. }
  1046. this.setMessage(err.toString(), this.messageType.ERROR);
  1047. responseData.err = 1;
  1048. responseData.msg = err.toString();
  1049. ctx.body = responseData;
  1050. }
  1051. }
  1052. }
  1053. return LedgerController;
  1054. };