budget_controller.js 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398
  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 LzString = require('lz-string');
  16. const accountGroup = require('../const/account_group').group;
  17. module.exports = app => {
  18. class BudgetController extends app.BaseController {
  19. /**
  20. * 概算投资
  21. *
  22. * @param ctx
  23. * @returns {Promise<void>}
  24. */
  25. async list(ctx) {
  26. try {
  27. const renderData = {
  28. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.budget.list),
  29. auditConst,
  30. };
  31. renderData.budgetList = await ctx.service.budget.getBudget(ctx.session.sessionUser.is_admin);
  32. renderData.budgetStd = await ctx.service.budgetStd.getDataByProjectId(ctx.session.sessionProject.id);
  33. for (const bl of renderData.budgetList) {
  34. const std = renderData.budgetStd.find(x => { return x.id === bl.std_id; });
  35. bl.std_name = std ? std.name : '';
  36. bl.gu_tp = await ctx.service.budgetGu.getSumTp(bl.id);
  37. bl.gai_tp = await ctx.service.budgetGai.getSumTp(bl.id);
  38. bl.yu_tp = await ctx.service.budgetYu.getSumTp(bl.id);
  39. }
  40. renderData.tenderList = await ctx.service.tender.getList4Select('stage');
  41. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  42. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  43. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  44. });
  45. renderData.accountList = accountList;
  46. renderData.accountGroup = accountGroup.map((item, idx) => {
  47. const groupList = accountList.filter(item => item.account_group === idx);
  48. return { groupName: item, groupList };
  49. });
  50. renderData.permissionConst = ctx.service.budgetPermission.PermissionConst;
  51. await this.layout('budget/list.ejs', renderData, 'budget/list_modal.ejs');
  52. } catch (err) {
  53. ctx.log(err);
  54. }
  55. }
  56. async add(ctx) {
  57. try {
  58. const data = JSON.parse(ctx.request.body.data);
  59. if (!data.name || data.name.length > 100) throw '项目名称有误';
  60. if (!data.std_id) throw '概预算标准有误';
  61. const result = await ctx.service.budget.add(data);
  62. ctx.body = { err: 0, msg: '', data: result };
  63. } catch (err) {
  64. ctx.log(err);
  65. ctx.ajaxErrorBody(err, '新建项目失败');
  66. }
  67. }
  68. async del(ctx) {
  69. try {
  70. const data = JSON.parse(ctx.request.body.data);
  71. if (!data.id) throw '参数有误';
  72. const result = await ctx.service.budget.deleteBudgetNoBackup(data.id);
  73. ctx.body = { err: 0, msg: '', data: result };
  74. } catch(err) {
  75. ctx.log(err);
  76. ctx.ajaxErrorBody(err, '删除项目失败');
  77. }
  78. }
  79. async save(ctx) {
  80. try {
  81. const data = JSON.parse(ctx.request.body.data);
  82. if (!data.id) throw '参数有误';
  83. let result = null;
  84. if (data.name !== undefined) {
  85. if (!data.name || data.name.length > 100) throw '项目名称有误';
  86. result = await ctx.service.budget.save({ id: data.id, name: data.name });
  87. } else if (data.rela_tender !== undefined) {
  88. result = await ctx.service.budget.save({ id: data.id, rela_tender: data.rela_tender });
  89. }
  90. ctx.body = { err: 0, msg: '', data: result };
  91. } catch(err) {
  92. ctx.log(err);
  93. ctx.ajaxErrorBody(err, '保存数据失败');
  94. }
  95. }
  96. async member(ctx) {
  97. try {
  98. const data = JSON.parse(ctx.request.body.data);
  99. const member = await ctx.service.budgetPermission.getBudgetPermission(data.id);
  100. ctx.body = { err: 0, msg: '', data: member };
  101. } catch (err) {
  102. ctx.log(err);
  103. ctx.ajaxErrorBody(err, '查询项目成员失败');
  104. }
  105. }
  106. async memberSave(ctx) {
  107. try {
  108. const data = JSON.parse(ctx.request.body.data);
  109. if (!data.id) throw '参数有误';
  110. await ctx.service.budgetPermission.saveBudgetPermission(data.id, data.member);
  111. ctx.body = { err: 0, msg: '', data: '' };
  112. } catch (err) {
  113. ctx.log(err);
  114. ctx.ajaxErrorBody(err, '保存数据失败');
  115. }
  116. }
  117. async compare(ctx) {
  118. try {
  119. const renderData = {
  120. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.budget.compare),
  121. auditConst,
  122. };
  123. const relaTenderId = ctx.helper._.map(ctx.budget.rela_tender.split(','), ctx.helper._.toInteger);
  124. const tenderList = await ctx.service.tender.getList4Select('stage');
  125. renderData.tenderList = relaTenderId.length > 0 ? tenderList.filter(x => {
  126. return relaTenderId.indexOf(x.id) >= 0;
  127. }) : tenderList;
  128. await this.layout('budget/compare.ejs', renderData, 'budget/compare_modal.ejs');
  129. } catch (err) {
  130. ctx.log(err);
  131. }
  132. }
  133. async compareLoad(ctx) {
  134. try {
  135. const gu = await ctx.service.budgetGu.getData(ctx.budget.id);
  136. const gai = await ctx.service.budgetGai.getData(ctx.budget.id);
  137. const yu = await ctx.service.budgetYu.getData(ctx.budget.id);
  138. ctx.body = { err: 0, msg: '', data: { gu, gai, yu } }
  139. } catch (err) {
  140. ctx.log(err);
  141. ctx.ajaxErrorBody(err, '获取数据错误');
  142. }
  143. }
  144. async compareFinal(ctx) {
  145. try {
  146. const data = JSON.parse(ctx.request.body.data);
  147. const final = [], helper = this.ctx.helper;
  148. for (const id of data.id) {
  149. const bills = await ctx.service.ledger.getFinalData(id, ['id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf',
  150. 'code', 'b_code', 'name', 'unit', 'dgn_qty1', 'dgn_qty2', 'total_price']);
  151. // 使用完成数据对比
  152. // const stage = ctx.service.stage.getLastestCompleteStage(id);
  153. // const finalBills = ctx.service.stageBillsFinal.getFinalData(id, stage.id);
  154. // ctx.helper.assignRelaData(bills, [
  155. // { data: finalBills, fields: ['contract_tp', 'qc_tp', 'used'], prefix: 'end_', relaId: 'lid' },
  156. // ]);
  157. // 使用最新一期对比
  158. const stage = await ctx.service.stage.getLastestStage(id);
  159. if (stage.status === auditConst.stage.status.checked) {
  160. const finalBills = await ctx.service.stageBillsFinal.getFinalData({id}, stage.order);
  161. ctx.helper.assignRelaData(bills, [
  162. { data: finalBills, fields: ['contract_tp', 'qc_tp'], prefix: 'end_', relaId: 'lid' },
  163. ]);
  164. bills.forEach(b => {
  165. b.end_gather_tp = helper.add(b.end_qc_tp, b.end_contract_tp);
  166. delete b.end_contract_tp;
  167. delete b.end_qc_tp;
  168. });
  169. } else {
  170. await ctx.service.stage.doCheckStage(stage);
  171. const curBills = stage.readOnly
  172. ? await ctx.service.stageBills.getAuditorStageData2(id, stage.id, stage.curTimes, stage.curOrder)
  173. : await ctx.service.stageBills.getLastestStageData2(id, stage.id);
  174. const preBills = stage.order > 1 ? await ctx.service.stageBillsFinal.getFinalData({id}, stage.order - 1) : [];
  175. ctx.helper.assignRelaData(bills, [
  176. { data: curBills, fields: ['contract_tp', 'qc_tp'], prefix: '', relaId: 'lid' },
  177. { data: preBills, fields: ['contract_tp', 'qc_tp'], prefix: 'pre_', relaId: 'lid' },
  178. ]);
  179. bills.forEach(b => {
  180. b.end_gather_tp = helper.sum([b.qc_tp, b.contract_tp, b.pre_qc_tp, b.pre_contract_tp]);
  181. delete b.contract_tp;
  182. delete b.qc_tp;
  183. delete b.pre_contract_tp;
  184. delete b.pre_qc_tp;
  185. });
  186. }
  187. final.push(bills);
  188. }
  189. ctx.body = { err: 0, msg: '', data: final }
  190. } catch (err) {
  191. ctx.log(err);
  192. ctx.ajaxErrorBody(err, '获取决算数据错误');
  193. }
  194. }
  195. _getSpreadSetting(needGcl) {
  196. const spreadSetting = {
  197. cols: [
  198. {title: '项目节编号', colSpan: '1', rowSpan: '2', field: 'code', hAlign: 0, width: 180, formatter: '@', cellType: 'tree'},
  199. {title: '清单编号', colSpan: '1', rowSpan: '2', field: 'b_code', hAlign: 0, width: 120, formatter: '@'},
  200. {title: '名称', colSpan: '1', rowSpan: '2', field: 'name', hAlign: 0, width: 230, formatter: '@'},
  201. {title: '单位', colSpan: '1', rowSpan: '2', field: 'unit', hAlign: 1, width: 50, formatter: '@', cellType: 'unit'},
  202. {title: '设计数量|数量1', colSpan: '2|1', rowSpan: '1|1', field: 'dgn_qty1', hAlign: 2, width: 80, type: 'Number'},
  203. {title: '|数量2', colSpan: '|1', rowSpan: '|1', field: 'dgn_qty2', hAlign: 2, width: 80, type: 'Number'},
  204. {title: '经济指标', colSpan: '1', rowSpan: '2', field: 'dgn_price', hAlign: 2, width: 80, type: 'Number', readOnly: true},
  205. {title: '清单数量', colSpan: '1', rowSpan: '2', field: 'quantity', hAlign: 2, width: 80, type: 'Number'},
  206. {title: '单价', colSpan: '1', rowSpan: '2', field: 'unit_price', hAlign: 2, width: 80, type: 'Number'},
  207. {title: '金额', colSpan: '1', rowSpan: '2', field: 'total_price', hAlign: 2, width: 80, type: 'Number'},
  208. {title: '图册号', colSpan: '1', rowSpan: '2', field: 'drawing_code', hAlign: 0, width: 100, formatter: '@'},
  209. {title: '备注', colSpan: '1', rowSpan: '2', field: 'memo', hAlign: 0, width: 100, formatter: '@'},
  210. ],
  211. emptyRows: 3,
  212. headRows: 2,
  213. headRowHeight: [25, 25],
  214. defaultRowHeight: 21,
  215. headerFont: '12px 微软雅黑',
  216. font: '12px 微软雅黑',
  217. };
  218. if (!needGcl) {
  219. spreadSetting.cols = spreadSetting.cols.filter(x => {
  220. return ['b_code', 'quantity', 'unit_price'].indexOf(x.field) < 0;
  221. });
  222. }
  223. return spreadSetting;
  224. }
  225. _getRelaService(type) {
  226. switch(type) {
  227. case 'gu': return this.ctx.service.budgetGu;
  228. case 'gai': return this.ctx.service.budgetGai;
  229. case 'yu': return this.ctx.service.budgetYu;
  230. default: return null;
  231. }
  232. }
  233. async _getNeedGcl() {
  234. if (!this.ctx.params.btype) throw '参数错误';
  235. const funRela = await this.ctx.service.project.getFunRela(this.ctx.session.sessionProject.id);
  236. return this.ctx.params.btype === 'yu' && !!funRela.needGcl;
  237. }
  238. async detail(ctx) {
  239. try {
  240. const needGcl = await this._getNeedGcl();
  241. const renderData = {
  242. spreadSetting: this._getSpreadSetting(needGcl),
  243. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.budget.detail),
  244. needGcl,
  245. };
  246. [renderData.stdBills, renderData.stdChapters] = await ctx.service.budgetStd.getStdList(ctx.budget.std_id, ctx.params.btype);
  247. await this.layout('budget/detail.ejs', renderData, 'budget/detail_modal.ejs');
  248. } catch (err) {
  249. ctx.log(err);
  250. }
  251. }
  252. async detailLoad(ctx) {
  253. try {
  254. const relaService = this._getRelaService(ctx.params.btype);
  255. ctx.body = {
  256. err: 0, msg: '',
  257. data: await relaService.getData(ctx.budget.id),
  258. }
  259. } catch (err) {
  260. ctx.log(err);
  261. ctx.ajaxErrorBody(err, '获取数据错误');
  262. }
  263. }
  264. async _billsBase(relaService, type, data) {
  265. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  266. if (type !== 'add') {
  267. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  268. }
  269. switch (type) {
  270. case 'add':
  271. return await relaService.addNodeBatch(this.ctx.budget.id, data.id, {}, data.count);
  272. case 'delete':
  273. return await relaService.delete(this.ctx.budget.id, data.id, data.count);
  274. case 'up-move':
  275. return await relaService.upMoveNode(this.ctx.budget.id, data.id, data.count);
  276. case 'down-move':
  277. return await relaService.downMoveNode(this.ctx.budget.id, data.id, data.count);
  278. case 'up-level':
  279. return await relaService.upLevelNode(this.ctx.budget.id, data.id, data.count);
  280. case 'down-level':
  281. return await relaService.downLevelNode(this.ctx.budget.id, data.id, data.count);
  282. }
  283. }
  284. async _addStd(relaService, data) {
  285. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdNode) throw '参数错误';
  286. let stdLib, addType;
  287. switch (data.stdType) {
  288. case 'xmj':
  289. stdLib = this.ctx.service.stdXmj;
  290. addType = stdDataAddType.withParent;
  291. break;
  292. case 'gcl':
  293. stdLib = this.ctx.service.stdGcl;
  294. const selectNode = await relaService.getDataByKid(this.ctx.budget.id, data.id);
  295. addType = selectNode.b_code ? stdDataAddType.next : stdDataAddType.child;
  296. break;
  297. default:
  298. throw '未知标准库';
  299. }
  300. const stdData = await stdLib.getDataByDataId(data.stdLibId, data.stdNode);
  301. switch (addType) {
  302. case stdDataAddType.child:
  303. return await relaService.addStdNodeAsChild(this.ctx.budget.id, data.id, stdData);
  304. case stdDataAddType.next:
  305. return await relaService.addStdNode(this.ctx.budget.id, data.id, stdData);
  306. case stdDataAddType.withParent:
  307. return await relaService.addStdNodeWithParent(this.ctx.budget.id, stdData, stdLib);
  308. default:
  309. throw '未知添加方式';
  310. }
  311. }
  312. async _pasteBlock(relaService, data) {
  313. if ((isNaN(data.id) || data.id <= 0) ||
  314. (!data.tid && data.tid <= 0) ||
  315. (!data.block || data.block.length <= 0)) throw '参数错误';
  316. return await relaService.pasteBlockData(this.ctx.budget.id, data.id, data.block);
  317. }
  318. async detailUpdate(ctx) {
  319. try {
  320. const relaService = this._getRelaService(ctx.params.btype);
  321. if (!ctx.budget) throw '项目数据错误';
  322. const data = JSON.parse(ctx.request.body.data);
  323. if (!data.postType || !data.postData) throw '数据错误';
  324. const responseData = { err: 0, msg: '', data: {} };
  325. switch (data.postType) {
  326. case 'add':
  327. case 'delete':
  328. case 'up-move':
  329. case 'down-move':
  330. case 'up-level':
  331. case 'down-level':
  332. responseData.data = await this._billsBase(relaService, data.postType, data.postData);
  333. break;
  334. case 'update':
  335. ctx.helper.checkDgnQtyPrecision(data.postData);
  336. responseData.data = await relaService.updateCalc(ctx.budget.id, data.postData);
  337. break;
  338. case 'add-std':
  339. responseData.data = await this._addStd(relaService, data.postData);
  340. break;
  341. case 'paste-block':
  342. responseData.data = await this._pasteBlock(relaService, data.postData);
  343. break;
  344. default:
  345. throw '未知操作';
  346. }
  347. ctx.body = responseData;
  348. } catch (err) {
  349. this.log(err);
  350. ctx.body = this.ajaxErrorBody(err, '数据错误');
  351. }
  352. }
  353. async detailUploadExcel(ctx) {
  354. try {
  355. const relaService = this._getRelaService(ctx.params.btype);
  356. const needGcl = await this._getNeedGcl();
  357. const ueType = ctx.params.ueType;
  358. const compressData = ctx.request.body.data;
  359. const data = JSON.parse(LzString.decompressFromUTF16(compressData));
  360. const responseData = { err: 0, msg: '', data: {} };
  361. switch (ueType) {
  362. case 'tz':
  363. const templateId = await this.ctx.service.budgetStd.getTemplateId(this.ctx.budget.std_id, ctx.params.btype);
  364. responseData.data = await relaService.importExcel(templateId, data.sheet, needGcl, data.filter);
  365. break;
  366. case 'gcl2xmj':
  367. responseData.data = await relaService.importGclExcel(data.id, data.sheet);
  368. break;
  369. default:
  370. throw '数据错误';
  371. }
  372. ctx.body = responseData;
  373. } catch (err) {
  374. this.log(err);
  375. ctx.body = { err: 1, msg: err.toString(), data: null };
  376. }
  377. }
  378. }
  379. return BudgetController;
  380. };