ledger_controller.js 47 KB

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