budget_controller.js 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date 2021/10/27
  7. * @version
  8. */
  9. const stdDataAddType = {
  10. withParent: 1,
  11. child: 2,
  12. next: 3,
  13. };
  14. const auditConst = require('../const/audit');
  15. const changeConst = require('../const/change');
  16. const LzString = require('lz-string');
  17. const accountGroup = require('../const/account_group').group;
  18. module.exports = app => {
  19. class BudgetController extends app.BaseController {
  20. /**
  21. * 概算投资
  22. *
  23. * @param ctx
  24. * @returns {Promise<void>}
  25. */
  26. async list(ctx) {
  27. try {
  28. if (!ctx.session.sessionProject.showBudget) {
  29. throw '该功能已关闭或无法查看';
  30. }
  31. const renderData = {
  32. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.budget.list),
  33. auditConst,
  34. };
  35. renderData.budgetList = await ctx.service.subProject.getBudgetProject(ctx.session.sessionProject.id, ctx.session.sessionUser.accountId, ctx.session.sessionUser.is_admin);
  36. renderData.budgetStd = await ctx.service.budgetStd.getDataByProjectId(ctx.session.sessionProject.id);
  37. for (const bl of renderData.budgetList) {
  38. if (bl.is_folder) continue;
  39. bl.gu_tp = await ctx.service.budgetGu.getSumTp(bl.budget_id);
  40. bl.gai_tp = await ctx.service.budgetGai.getSumTp(bl.budget_id);
  41. bl.yu_tp = await ctx.service.budgetYu.getSumTp(bl.budget_id);
  42. bl.zb_tp = await ctx.service.budgetZb.getSumTp(bl.budget_id);
  43. }
  44. renderData.tenderList = await ctx.service.tender.getList4Select('stage');
  45. renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
  46. await this.layout('budget/list.ejs', renderData, 'budget/list_modal.ejs');
  47. } catch (err) {
  48. ctx.log(err);
  49. ctx.session.postError = err.toString();
  50. ctx.redirect(this.menu.menu.dashboard.url);
  51. }
  52. }
  53. async budgetInfo(ctx) {
  54. try {
  55. // 获取变更费用前10的变更令
  56. const changeList = await ctx.service.change.getListByBudgetInfo(ctx.budget.rela_tender);
  57. // 获取变更后总金额
  58. const total_change_tp = await ctx.service.change.getTotalTpByBudgetInfo(ctx.budget.rela_tender);
  59. const renderData = {
  60. changeList,
  61. changeConst,
  62. total_change_tp,
  63. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.budget.info),
  64. auditConst,
  65. };
  66. // const relaTenderId = ctx.helper._.map(ctx.budget.rela_tender.split(','), ctx.helper._.toInteger);
  67. // const tenderList = await ctx.service.tender.getList4Select('stage');
  68. // renderData.tenderList = relaTenderId.length > 0 ? tenderList.filter(x => {
  69. // return relaTenderId.indexOf(x.id) >= 0;
  70. // }) : tenderList;
  71. // renderData.tenderList = renderData.tenderList.map(y => {
  72. // return { id: y.id, name: y.name, lastStageOrder: y.lastStage.order, lastStageStatus: auditConst.stage.statusString[y.lastStage.status], category: y.category };
  73. // });
  74. // renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
  75. await this.layout('budget/info.ejs', renderData);
  76. } catch (err) {
  77. ctx.log(err);
  78. }
  79. }
  80. async compare(ctx) {
  81. try {
  82. const renderData = {
  83. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.budget.compare),
  84. auditConst,
  85. };
  86. const relaTenderId = ctx.helper._.map(ctx.budget.rela_tender.split(','), ctx.helper._.toInteger);
  87. const tenderList = await ctx.service.tender.getList4Select('stage');
  88. renderData.tenderList = relaTenderId.length > 0 ? tenderList.filter(x => {
  89. return relaTenderId.indexOf(x.id) >= 0;
  90. }) : tenderList;
  91. renderData.tenderList = renderData.tenderList.map(y => {
  92. return { id: y.id, name: y.name, lastStageOrder: y.lastStage.order, lastStageStatus: auditConst.stage.statusString[y.lastStage.status], category: y.category };
  93. });
  94. renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
  95. await this.layout('budget/compare.ejs', renderData, 'budget/compare_modal.ejs');
  96. } catch (err) {
  97. ctx.log(err);
  98. }
  99. }
  100. async compareLoad(ctx) {
  101. try {
  102. const data = {};
  103. if (ctx.budget.final_id) {
  104. data.final = await ctx.service.budgetFinal.getAllDataByCondition({ where: { final_id: ctx.budget.final_id } });
  105. data.finalInfo = await ctx.service.budgetFinalList.getFinal(ctx.budget.final_id);
  106. } else {
  107. data.gu = await ctx.service.budgetGu.getData(ctx.budget.id);
  108. data.gai = await ctx.service.budgetGai.getData(ctx.budget.id);
  109. data.yu = await ctx.service.budgetYu.getData(ctx.budget.id);
  110. data.zb = await ctx.service.budgetZb.getData(ctx.budget.id);
  111. }
  112. ctx.body = { err: 0, msg: '', data };
  113. } catch (err) {
  114. ctx.log(err);
  115. ctx.ajaxErrorBody(err, '获取数据错误');
  116. }
  117. }
  118. async compareFinal(ctx) {
  119. try {
  120. const data = JSON.parse(ctx.request.body.data);
  121. if (ctx.budget.final_id && data.final_id !== ctx.budget.final_id) {
  122. const final = await ctx.service.budgetFinal.getAllDataByCondition({ where: { final_id: ctx.budget.final_id } });
  123. const finalInfo = await ctx.service.budgetFinalList.getFinal(ctx.budget.final_id);
  124. ctx.body = { err: 0, msg: `决算数据已在${ctx.moment(finalInfo.update_time).format('YYYY-DD-MM HH:mm:ss')}更新,请先查看后再决定是否生成`, data: { final, finalInfo } };
  125. } else {
  126. const finalInfo = await ctx.service.budgetFinalList.addFinal(ctx.budget, data.id);
  127. const final = await ctx.service.budget.doFinal(ctx.budget, finalInfo);
  128. ctx.body = { err: 0, msg: '', data: { final, finalInfo } };
  129. }
  130. } catch (err) {
  131. ctx.log(err);
  132. ctx.ajaxErrorBody(err, '获取决算数据错误');
  133. }
  134. }
  135. _getSpreadSetting(needGcl) {
  136. const spreadSetting = {
  137. cols: [
  138. {title: '项目节编号', colSpan: '1', rowSpan: '2', field: 'code', hAlign: 0, width: 180, formatter: '@', cellType: 'tree'},
  139. {title: '清单编号', colSpan: '1', rowSpan: '2', field: 'b_code', hAlign: 0, width: 120, formatter: '@'},
  140. {title: '名称', colSpan: '1', rowSpan: '2', field: 'name', hAlign: 0, width: 230, formatter: '@'},
  141. {title: '单位', colSpan: '1', rowSpan: '2', field: 'unit', hAlign: 1, width: 50, formatter: '@', cellType: 'unit', comboEdit: true},
  142. {title: '设计数量|数量1', colSpan: '2|1', rowSpan: '1|1', field: 'dgn_qty1', hAlign: 2, width: 80, type: 'Number'},
  143. {title: '|数量2', colSpan: '|1', rowSpan: '|1', field: 'dgn_qty2', hAlign: 2, width: 80, type: 'Number'},
  144. {title: '经济指标', colSpan: '1', rowSpan: '2', field: 'dgn_price', hAlign: 2, width: 80, type: 'Number', readOnly: true},
  145. {title: '清单数量', colSpan: '1', rowSpan: '2', field: 'quantity', hAlign: 2, width: 80, type: 'Number'},
  146. {title: '单价', colSpan: '1', rowSpan: '2', field: 'unit_price', hAlign: 2, width: 80, type: 'Number'},
  147. {title: '金额', colSpan: '1', rowSpan: '2', field: 'total_price', hAlign: 2, width: 80, type: 'Number'},
  148. {title: '图册号', colSpan: '1', rowSpan: '2', field: 'drawing_code', hAlign: 0, width: 100, formatter: '@'},
  149. {title: '备注', colSpan: '1', rowSpan: '2', field: 'memo', hAlign: 0, width: 100, formatter: '@'},
  150. ],
  151. emptyRows: 3,
  152. headRows: 2,
  153. headRowHeight: [25, 25],
  154. defaultRowHeight: 21,
  155. headerFont: '12px 微软雅黑',
  156. font: '12px 微软雅黑',
  157. localCache: { key: 'budget', colWidth: true },
  158. };
  159. if (!needGcl) {
  160. spreadSetting.cols = spreadSetting.cols.filter(x => {
  161. return ['b_code', 'quantity', 'unit_price'].indexOf(x.field) < 0;
  162. });
  163. }
  164. return spreadSetting;
  165. }
  166. _getRelaService(type) {
  167. switch(type) {
  168. case 'gu': return this.ctx.service.budgetGu;
  169. case 'gai': return this.ctx.service.budgetGai;
  170. case 'yu': return this.ctx.service.budgetYu;
  171. case 'zb': return this.ctx.service.budgetZb;
  172. default: return null;
  173. }
  174. }
  175. async _getNeedGcl() {
  176. if (!this.ctx.params.btype) throw '参数错误';
  177. const funRela = this.ctx.subProject.fun_rela;
  178. return ['yu', 'zb'].indexOf(this.ctx.params.btype) >= 0 && !!funRela.needGcl;
  179. }
  180. async detail(ctx) {
  181. try {
  182. const needGcl = await this._getNeedGcl();
  183. const renderData = {
  184. spreadSetting: this._getSpreadSetting(needGcl),
  185. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.budget.detail),
  186. needGcl,
  187. };
  188. [renderData.stdBills, renderData.stdChapters] = await ctx.service.budgetStd.getStdList(ctx.budget.std_id, ctx.params.btype);
  189. await this.layout('budget/detail.ejs', renderData, 'budget/detail_modal.ejs');
  190. } catch (err) {
  191. ctx.log(err);
  192. }
  193. }
  194. async detailLoad(ctx) {
  195. try {
  196. const relaService = this._getRelaService(ctx.params.btype);
  197. ctx.body = {
  198. err: 0, msg: '',
  199. data: await relaService.getData(ctx.budget.id),
  200. }
  201. } catch (err) {
  202. ctx.log(err);
  203. ctx.ajaxErrorBody(err, '获取数据错误');
  204. }
  205. }
  206. async _billsBase(relaService, type, data) {
  207. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  208. if (type !== 'add') {
  209. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  210. }
  211. switch (type) {
  212. case 'add':
  213. return await relaService.addNodeBatch(this.ctx.budget.id, data.id, {}, data.count);
  214. case 'delete':
  215. return await relaService.delete(this.ctx.budget.id, data.id, data.count);
  216. case 'up-move':
  217. return await relaService.upMoveNode(this.ctx.budget.id, data.id, data.count);
  218. case 'down-move':
  219. return await relaService.downMoveNode(this.ctx.budget.id, data.id, data.count);
  220. case 'up-level':
  221. return await relaService.upLevelNode(this.ctx.budget.id, data.id, data.count);
  222. case 'down-level':
  223. return await relaService.downLevelNode(this.ctx.budget.id, data.id, data.count);
  224. }
  225. }
  226. async _addStd(relaService, data) {
  227. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdNode) throw '参数错误';
  228. let stdLib, addType;
  229. switch (data.stdType) {
  230. case 'xmj':
  231. stdLib = this.ctx.service.stdXmj;
  232. addType = stdDataAddType.withParent;
  233. break;
  234. case 'gcl':
  235. stdLib = this.ctx.service.stdGcl;
  236. const selectNode = await relaService.getDataByKid(this.ctx.budget.id, data.id);
  237. addType = selectNode.b_code ? stdDataAddType.next : stdDataAddType.child;
  238. break;
  239. default:
  240. throw '未知标准库';
  241. }
  242. const stdData = await stdLib.getDataByDataId(data.stdLibId, data.stdNode);
  243. switch (addType) {
  244. case stdDataAddType.child:
  245. return await relaService.addStdNodeAsChild(this.ctx.budget.id, data.id, stdData);
  246. case stdDataAddType.next:
  247. return await relaService.addStdNode(this.ctx.budget.id, data.id, stdData);
  248. case stdDataAddType.withParent:
  249. return await relaService.addStdNodeWithParent(this.ctx.budget.id, stdData, stdLib);
  250. default:
  251. throw '未知添加方式';
  252. }
  253. }
  254. async _pasteBlock(relaService, data) {
  255. if ((isNaN(data.id) || data.id <= 0) ||
  256. (!data.tid && data.tid <= 0) ||
  257. (!data.block || data.block.length <= 0)) throw '参数错误';
  258. return await relaService.pasteBlockData(this.ctx.budget.id, data.id, data.block);
  259. }
  260. async detailUpdate(ctx) {
  261. try {
  262. if (!ctx.budget) throw '项目数据错误';
  263. if (ctx.budget.readOnly) throw '你无权修改数据';
  264. const relaService = this._getRelaService(ctx.params.btype);
  265. const data = JSON.parse(ctx.request.body.data);
  266. if (!data.postType || !data.postData) throw '数据错误';
  267. const responseData = { err: 0, msg: '', data: {} };
  268. switch (data.postType) {
  269. case 'add':
  270. case 'delete':
  271. case 'up-move':
  272. case 'down-move':
  273. case 'up-level':
  274. case 'down-level':
  275. responseData.data = await this._billsBase(relaService, data.postType, data.postData);
  276. break;
  277. case 'update':
  278. ctx.helper.checkDgnQtyPrecision(data.postData);
  279. responseData.data = await relaService.updateCalc(ctx.budget.id, data.postData);
  280. break;
  281. case 'add-std':
  282. responseData.data = await this._addStd(relaService, data.postData);
  283. break;
  284. case 'paste-block':
  285. responseData.data = await this._pasteBlock(relaService, data.postData);
  286. break;
  287. default:
  288. throw '未知操作';
  289. }
  290. ctx.body = responseData;
  291. } catch (err) {
  292. this.log(err);
  293. ctx.body = this.ajaxErrorBody(err, '数据错误');
  294. }
  295. }
  296. async detailUploadExcel(ctx) {
  297. try {
  298. if (!ctx.budget) throw '项目数据错误';
  299. if (ctx.budget.readOnly) throw '你无权导入数据';
  300. const relaService = this._getRelaService(ctx.params.btype);
  301. const needGcl = await this._getNeedGcl();
  302. const ueType = ctx.params.ueType;
  303. const compressData = ctx.request.body.data;
  304. const data = JSON.parse(LzString.decompressFromUTF16(compressData));
  305. const responseData = { err: 0, msg: '', data: {} };
  306. switch (ueType) {
  307. case 'tz':
  308. const templateId = await this.ctx.service.budgetStd.getTemplateId(this.ctx.budget.std_id, ctx.params.btype);
  309. responseData.data = await relaService.importExcel(templateId, data.sheet, needGcl, data.filter);
  310. break;
  311. case 'gcl2xmj':
  312. responseData.data = await relaService.importGclExcel(data.id, data.sheet);
  313. break;
  314. default:
  315. throw '数据错误';
  316. }
  317. ctx.body = responseData;
  318. } catch (err) {
  319. this.log(err);
  320. ctx.body = { err: 1, msg: err.toString(), data: null };
  321. }
  322. }
  323. async decimal(ctx) {
  324. try {
  325. if (!ctx.budget) throw '项目数据错误';
  326. if (ctx.budget.readOnly) throw '你无权修改小数位数';
  327. const data = JSON.parse(ctx.request.body.data);
  328. if (!data || !data.decimal || !data.page) throw '缺少必要参数';
  329. const refreshData = await ctx.service.budget.saveDecimal(data.decimal, data.page);
  330. ctx.body = { err: 0, msg: '', data: refreshData };
  331. } catch (err) {
  332. this.log(err);
  333. this.ajaxErrorBody(err, '保存小数位数失败');
  334. }
  335. }
  336. }
  337. return BudgetController;
  338. };