ledger_controller.js 48 KB

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