ledger_controller.js 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574
  1. 'use strict';
  2. /**
  3. * 台账相关控制器
  4. *
  5. * @author CaiAoLin
  6. * @date 2017/11/30
  7. * @version
  8. */
  9. const stdDataAddType = {
  10. withParent: 1,
  11. child: 2,
  12. next: 3,
  13. };
  14. const audit = require('../const/audit');
  15. const auditConst = audit.ledger;
  16. const tenderMenu = require('../../config/menu').tenderMenu;
  17. const measureType = require('../const/tender').measureType;
  18. const spreadConst = require('../const/spread');
  19. const fs = require('fs');
  20. const LzString = require('lz-string');
  21. const accountGroup = require('../const/account_group').group;
  22. const path = require('path');
  23. module.exports = app => {
  24. class LedgerController extends app.BaseController {
  25. /**
  26. * 构造函数
  27. *
  28. * @param {Object} ctx - egg全局变量
  29. * @return {void}
  30. */
  31. constructor(ctx) {
  32. super(ctx);
  33. ctx.showProject = true;
  34. ctx.showTitle = true;
  35. ctx.showTender = true;
  36. }
  37. /**
  38. * 检查标段是否只读(审核中,审核完成)
  39. * @param {Object} tenderData
  40. * @return {boolean}
  41. * @private
  42. */
  43. _ledgerReadOnly() {
  44. const tender = this.ctx.tender.data;
  45. return tender.ledger_status === auditConst.status.checking || tender.ledger_status === auditConst.status.checked;
  46. }
  47. /**
  48. * 获取SpreadSetting
  49. * @private
  50. */
  51. _getSpreadSetting() {
  52. const _ = this.app._;
  53. function removeFieldCols(setting, cols) {
  54. _.remove(setting.cols, function(c) {
  55. return cols.indexOf(c.field) > -1;
  56. });
  57. }
  58. function hideFieldCols(setting, cols) {
  59. for (const c of setting.cols) {
  60. if (cols.indexOf(c.field) > -1) {
  61. c.visible = false;
  62. }
  63. }
  64. }
  65. function setColFormat(cols, field, formatter) {
  66. const col = _.find(cols, function (c) {
  67. return c.field === field;
  68. });
  69. col.formatter = formatter;
  70. }
  71. // const tpFormatter = this.ctx.helper.getNumberFormatter(this.ctx.tender.info.decimal.tp);
  72. // const upFormatter = this.ctx.helper.getNumberFormatter(this.ctx.tender.info.decimal.up);
  73. const tender = this.ctx.tender;
  74. const setting = tender.info.display.ledger.clQty ? spreadConst.withCl : spreadConst.withoutCl;
  75. const ledger = JSON.parse(JSON.stringify(setting.ledger));
  76. // setColFormat(ledger.cols, 'unit_price', upFormatter);
  77. // setColFormat(ledger.cols, 'dgn_price', upFormatter);
  78. // setColFormat(ledger.cols, 'total_price', tpFormatter);
  79. // setColFormat(ledger.cols, 'deal_tp', tpFormatter);
  80. const pos = JSON.parse(JSON.stringify(setting.pos));
  81. if (this._ledgerReadOnly(tender.data)) {
  82. ledger.readOnly = true;
  83. pos.readOnly = true;
  84. }
  85. if (tender.data.measure_type === measureType.tz.value) {
  86. removeFieldCols(ledger, spreadConst.filterCols.tzWithoutCols);
  87. }
  88. if (!tender.info.display.ledger.dgnQty) {
  89. removeFieldCols(ledger, spreadConst.filterCols.dgnCols);
  90. }
  91. return [ledger, pos];
  92. }
  93. /**
  94. * 台账分解页面 (Get)
  95. *
  96. * @param {Object} ctx - egg全局变量
  97. * @return {void}
  98. */
  99. async explode(ctx) {
  100. try {
  101. const tender = ctx.tender;
  102. const [ledgerSpread, posSpread] = this._getSpreadSetting();
  103. const curAuditor = await ctx.service.ledgerAudit.getCurAuditor(tender.id, tender.data.ledger_times);
  104. const times = tender.data.ledger_status === auditConst.status.checkNo ? tender.data.ledger_times - 1 : tender.data.ledger_times;
  105. const auditors = await ctx.service.ledgerAudit.getAuditors(tender.id, times);
  106. const user = await ctx.service.projectAccount.getAccountInfoById(ctx.tender.data.user_id);
  107. const auditHistory = [];
  108. if (ctx.tender.data.ledger_times > 1) {
  109. for (let i = 1; i < ctx.tender.data.ledger_times; i++) {
  110. auditHistory.push(await ctx.service.ledgerAudit.getAuditors(ctx.tender.id, i));
  111. }
  112. }
  113. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(ctx.tender.data.valuation);
  114. const renderData = {
  115. tender: tender.data,
  116. tenderInfo: tender.info,
  117. auditConst,
  118. auditors,
  119. curAuditor,
  120. user,
  121. auditHistory,
  122. ledgerSpreadSetting: JSON.stringify(ledgerSpread),
  123. posSpreadSetting: JSON.stringify(posSpread),
  124. tenderMenu,
  125. preUrl: '/tender/' + tender.id,
  126. measureType,
  127. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.explode),
  128. stdBills,
  129. stdChapters,
  130. };
  131. if ((tender.data.ledger_status === auditConst.status.uncheck || tender.data.ledger_status === auditConst.status.checkNo) && tender.data.user_id === ctx.session.sessionUser.accountId) {
  132. renderData.accountGroup = accountGroup;
  133. // 获取所有项目参与者
  134. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  135. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  136. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  137. });
  138. renderData.accountList = accountList;
  139. renderData.auditorList = await ctx.service.ledgerAudit.getAuditors(tender.id, tender.data.ledger_times);
  140. }
  141. await this.layout('ledger/explode.ejs', renderData, 'ledger/explode_modal.ejs');
  142. } catch (err) {
  143. this.log(err);
  144. await this.redirect('/dashboard');
  145. }
  146. }
  147. /**
  148. * 获取子节点 (Ajax)
  149. * @param ctx
  150. * @return {Promise<void>}
  151. */
  152. async getChildren(ctx) {
  153. const responseData = {
  154. err: 0,
  155. msg: '',
  156. data: [],
  157. };
  158. try {
  159. const data = JSON.parse(ctx.request.body.data);
  160. const id = data.ledger_id;
  161. if (isNaN(id) || id <= 0) {
  162. throw '参数错误';
  163. }
  164. responseData.data = await ctx.service.ledger.getChildrenByParentId(ctx.tender.id, id);
  165. } catch (err) {
  166. responseData.err = 1;
  167. responseData.msg = err;
  168. }
  169. ctx.body = responseData;
  170. }
  171. /**
  172. * 树结构基本操作(增、删、上下移、升降级)
  173. * @param {Object} ctx - egg全局变量
  174. * @return {Promise<void>}
  175. */
  176. async _base(ctx, type, data) {
  177. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  178. if (type !== 'add') {
  179. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  180. }
  181. switch (type) {
  182. case 'add':
  183. return await ctx.service.ledger.addNodeBatch(ctx.tender.id, data.id, {}, data.count);
  184. case 'delete':
  185. return await ctx.service.ledger.delete(ctx.tender.id, data.id, data.count);
  186. case 'up-move':
  187. return await ctx.service.ledger.upMoveNode(ctx.tender.id, data.id, data.count);
  188. case 'down-move':
  189. return await ctx.service.ledger.downMoveNode(ctx.tender.id, data.id, data.count);
  190. case 'up-level':
  191. return await ctx.service.ledger.upLevelNode(ctx.tender.id, data.id, data.count);
  192. case 'down-level':
  193. return await ctx.service.ledger.downLevelNode(ctx.tender.id, data.id, data.count);
  194. }
  195. }
  196. /**
  197. * 复制粘贴整块
  198. *
  199. * @param ctx
  200. * @return {Promise<void>}
  201. */
  202. async _pasteBlock(ctx, data) {
  203. if ((isNaN(data.id) || data.id <= 0) ||
  204. (!data.tid && data.tid <= 0) ||
  205. (!data.block || data.block.length <= 0)) throw '参数错误';
  206. return await ctx.service.ledger.pasteBlock(data.tid, data.id, data.block);
  207. }
  208. /**
  209. * 从标准项目表添加数据
  210. * @param ctx
  211. * @return {Promise<void>}
  212. */
  213. async _addStd(ctx, data) {
  214. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdNode) throw '参数错误';
  215. // todo 校验项目是否使用该库的权限
  216. let stdLib, addType;
  217. switch (data.stdType) {
  218. case 'xmj':
  219. stdLib = ctx.service.stdXmj;
  220. addType = stdDataAddType.withParent;
  221. break;
  222. case 'gcl':
  223. stdLib = ctx.service.stdGcl;
  224. const selectNode = await ctx.service.ledger.getDataByNodeId(ctx.tender.id, data.id);
  225. if (selectNode.b_code) {
  226. addType = stdDataAddType.next;
  227. } else {
  228. addType = stdDataAddType.child;
  229. }
  230. break;
  231. default:
  232. throw '未知标准库';
  233. }
  234. const stdData = await stdLib.getDataByDataId(data.stdLibId, data.stdNode);
  235. switch (addType) {
  236. case stdDataAddType.child:
  237. return await ctx.service.ledger.addStdNodeAsChild(ctx.tender.id, data.id, stdData);
  238. break;
  239. case stdDataAddType.next:
  240. return await ctx.service.ledger.addStdNode(ctx.tender.id, data.id, stdData);
  241. case stdDataAddType.withParent:
  242. return await ctx.service.ledger.addStdNodeWithParent(ctx.tender.id, stdData, stdLib);
  243. default:
  244. throw '未知添加方式';
  245. }
  246. }
  247. /**
  248. * 从签约清单添加节点
  249. * @param ctx
  250. * @returns {Promise<void>}
  251. */
  252. async _addDeal(ctx, data) {
  253. if (!data.type || !data.dealBills) throw '数据错误';
  254. data.dealBills.unit_price = this.ctx.helper.round(data.dealBills.unit_price, ctx.tender.info.decimal.up);
  255. if (data.type === 'child') {
  256. return await ctx.service.ledger.addChild(ctx.tender.id, data.id, data.dealBills);
  257. } else if (data.type === 'next') {
  258. return await ctx.service.ledger.addNode(ctx.tender.id, data.id, data.dealBills);
  259. } else {
  260. throw '数据错误';
  261. }
  262. }
  263. /**
  264. * 批量插入数据
  265. *
  266. * data = {id, batchData, batchType}
  267. * data.batchType = 'batchInsertChild'/'batchInsertNext'
  268. * data.batchData = [{name, children}] -- 项目节列表
  269. * data.batchData.children = [{code, name, unit, unit_price, quantity}] -- 工程量清单列表
  270. *
  271. * @param ctx
  272. * @return {Promise<void>}
  273. */
  274. async _batchInsert(ctx, data) {
  275. if ((isNaN(data.id) || data.id <= 0) || !data.batchType) throw '参数错误';
  276. switch (data.batchType) {
  277. case 'child':
  278. return await ctx.service.ledger.batchInsertChild(ctx.tender.id, data.id, data.batchData);
  279. case 'next':
  280. return await ctx.service.ledger.batchInsertNext(ctx.tender.id, data.id, data.batchData);
  281. default:
  282. throw '参数错误';
  283. }
  284. }
  285. /**
  286. * 更新清单相关 (Ajax)
  287. * @param ctx
  288. * @returns {Promise<void>}
  289. */
  290. async update(ctx) {
  291. try {
  292. if (!ctx.tender.data) throw '标段数据错误';
  293. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId || this._ledgerReadOnly()) throw '您无权进行该操作';
  294. const data = JSON.parse(ctx.request.body.data);
  295. if (!data.postType || !data.postData) throw '数据错误';
  296. const responseData = {
  297. err: 0,
  298. msg: '',
  299. data: [],
  300. };
  301. switch (data.postType) {
  302. case 'add':
  303. case 'delete':
  304. case 'up-move':
  305. case 'down-move':
  306. case 'up-level':
  307. case 'down-level':
  308. responseData.data = await this._base(ctx, data.postType, data.postData);
  309. break;
  310. case 'update':
  311. responseData.data = await ctx.service.ledger.updateCalc(ctx.tender.id, data.postData);
  312. break;
  313. case 'paste-block':
  314. responseData.data = await this._pasteBlock(ctx, data.postData);
  315. break;
  316. case 'add-std':
  317. responseData.data = await this._addStd(ctx, data.postData);
  318. break;
  319. case 'add-deal':
  320. responseData.data = await this._addDeal(ctx, data.postData);
  321. break;
  322. case 'batch-insert':
  323. responseData.data = await this._batchInsert(ctx, data.postData);
  324. break;
  325. default:
  326. throw '未知操作';
  327. }
  328. ctx.body = responseData;
  329. } catch (err) {
  330. this.log(err);
  331. ctx.body = this.ajaxErrorBody(err);
  332. }
  333. }
  334. /**
  335. * 定位
  336. * @param ctx
  337. * @return {Promise<void>}
  338. */
  339. async locate(ctx) {
  340. const responseData = {
  341. err: 0,
  342. msg: '',
  343. data: [],
  344. };
  345. try {
  346. const tenderId = ctx.params.id;
  347. if (!tenderId) {
  348. throw '当前未打开标段';
  349. }
  350. const data = JSON.parse(ctx.request.body.data);
  351. if ((isNaN(data.id) || data.id <= 0)) {
  352. throw '参数错误';
  353. }
  354. responseData.data = await ctx.service.ledger.locateNode(tenderId, data.id);
  355. } catch (err) {
  356. this.log(err);
  357. responseData.err = 1;
  358. responseData.msg = err;
  359. }
  360. ctx.body = responseData;
  361. }
  362. /**
  363. * 获取全部子节点
  364. *
  365. * @param ctx
  366. * @return {Promise<void>}
  367. */
  368. async posterity(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. const expandData = await ctx.service.ledger.getPosterityByParentId(tenderId, data.id);
  384. responseData.data = { expand: expandData };
  385. } catch (err) {
  386. this.log(err);
  387. responseData.err = 1;
  388. responseData.msg = err;
  389. }
  390. ctx.body = responseData;
  391. }
  392. /**
  393. * 获取部位明细数据(Ajax)
  394. *
  395. * @param ctx
  396. * @return {Promise<void>}
  397. */
  398. async loadExplodeData(ctx) {
  399. try {
  400. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  401. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  402. ? await ctx.service.pos.getPosData({tid: ctx.tender.id}) : [];
  403. ctx.body = { err: 0, msg: '', data: {bills: ledgerData, pos: posData} };
  404. } catch (err) {
  405. this.log(err);
  406. ctx.body = { err: 1, msg: err.toString(), data: [] };
  407. }
  408. }
  409. /**
  410. * 更新 部位明细数据
  411. *
  412. * @param ctx
  413. * @return {Promise<void>}
  414. */
  415. async posUpdate(ctx) {
  416. try {
  417. await this.checkMeasureType(measureType.tz.value);
  418. const data = JSON.parse(ctx.request.body.data);
  419. const responseData = await ctx.service.pos.savePosData(data, ctx.tender.id);
  420. ctx.body = { err: 0, msg: '', data: responseData };
  421. } catch (err) {
  422. this.log(err);
  423. ctx.body = { err: 1, msg: err.toString(), data: null };
  424. }
  425. }
  426. /**
  427. * 复制粘贴 部位明细
  428. * @param ctx
  429. * @returns {Promise<void>}
  430. */
  431. async posPaste(ctx) {
  432. try {
  433. await this.checkMeasureType(measureType.tz.value);
  434. const data = JSON.parse(ctx.request.body.data);
  435. const result = await ctx.service.pos.pastePosData(data, ctx.tender.id);
  436. ctx.body = { err: 0, msg: '', data: result };
  437. } catch(err) {
  438. this.log(err);
  439. ctx.body = { err: 1, msg: err.toString(), data: null };
  440. }
  441. }
  442. /**
  443. * 上传 清单Excel 并导入
  444. * @param ctx
  445. * @return {Promise<void>}
  446. */
  447. async uploadExcel(ctx) {
  448. try {
  449. const ueType = ctx.params.ueType;
  450. const compressData = ctx.request.body.data;
  451. const data = JSON.parse(LzString.decompressFromUTF16(compressData));
  452. const responseData = { err: 0, msg: '', data: {}, };
  453. switch (ueType) {
  454. case 'tz':
  455. const templateId = await this.ctx.service.valuation.getValuationTemplate(this.ctx.tender.data.valuation);
  456. responseData.data = await ctx.service.ledger.importExcel(templateId, data);
  457. break;
  458. case 'gcl2xmj':
  459. responseData.data = await ctx.service.ledger.importGclExcel(data.id, data.sheet);
  460. break;
  461. default:
  462. throw '数据错误';
  463. }
  464. ctx.body = responseData;
  465. } catch (err) {
  466. this.log(err);
  467. ctx.body = { err: 1, msg: err.toString(), data: null };
  468. }
  469. }
  470. /**
  471. * 下载(清单Excel模板 or 导出项目台账Excel)
  472. * @param ctx
  473. * @return {Promise<void>}
  474. */
  475. async download(ctx) {
  476. const file = ctx.params.file;
  477. if (file) {
  478. try {
  479. let fileName;
  480. if (file === '导入分项清单EXCEL格式.xls') {
  481. fileName = path.join(this.app.baseDir, 'app', 'public', 'files', 'template', 'ledger', '导入分项清单EXCEL格式.xls');
  482. } else if (file === 'ledger') {
  483. const create_time = Date.parse(new Date()) / 1000;
  484. fileName = this.app.baseDir + '/app/public/files/downloads/ledger/' + ctx.tender.id + '-' + create_time + '.xlsx';
  485. // todo 导出台账清单Excel
  486. }
  487. ctx.body = await fs.readFileSync(fileName);
  488. } catch (err) {
  489. this.log(err);
  490. this.setMessage(err.toString(), this.messageType.ERROR);
  491. }
  492. }
  493. }
  494. /**
  495. * 台账对比 页面 (Get)
  496. * @param ctx
  497. * @returns {Promise<void>}
  498. */
  499. async gather(ctx) {
  500. try {
  501. const renderData = {
  502. tender: ctx.tender.data,
  503. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.ledger.gather)
  504. };
  505. await this.layout('ledger/gather.ejs', renderData);
  506. } catch (err) {
  507. this.log(err);
  508. await this.redirect(ctx.request.header.referer);
  509. }
  510. }
  511. /**
  512. * 获取 台账对比 数据 (Ajax)
  513. * @param ctx
  514. * @returns {Promise<void>}
  515. */
  516. async loadGatherData(ctx) {
  517. try {
  518. const billsData = await ctx.service.ledger.getData(ctx.tender.id);
  519. const posData = this.ctx.tender.data.measure_type === measureType.tz.value
  520. ? await ctx.service.pos.getPosData({tid: ctx.tender.id}) : [];
  521. const dealBills = await ctx.service.dealBills.getAllDataByCondition({ where: {tender_id: this.ctx.tender.id} });
  522. ctx.body = { err: 0, msg: '', data: {bills: billsData, pos: posData, dealBills: dealBills} };
  523. } catch (err) {
  524. this.log(err);
  525. ctx.body = { err: 1, msg: err.toString(), data: [] };
  526. }
  527. }
  528. /**
  529. * 计量台账页面 (Get)
  530. *
  531. * @param {object} ctx - egg全局变量
  532. * @return {void}
  533. */
  534. async index(ctx) {
  535. const renderData = {};
  536. await this.layout('ledger/index.ejs', renderData);
  537. }
  538. }
  539. return LedgerController;
  540. };