ledger_controller.js 48 KB

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