compilation_controller.js 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701
  1. /**
  2. * 编办控制控制器
  3. *
  4. * @author CaiAoLin
  5. * @date 2017/7/28
  6. * @compilation
  7. */
  8. import BaseController from "../../common/base/base_controller";
  9. import CompilationModel from "../models/compilation_model";
  10. import STDRationLibMapModel from "../../common/std/std_ration_lib_map_model";
  11. import STDBillLibListsModel from "../../common/std/std_bills_lib_lists_model";
  12. import STDGLJLibMapModel from "../../common/std/std_glj_lib_map_model";
  13. import STDFeeRateLibsModel from "../../common/std/std_fee_rate_libs_model";
  14. import {default as EngineeringConst, List as EngineeringList} from "../../common/const/engineering";
  15. import BillsTemplateModel from "../models/bills_template_model";
  16. import {default as BillsFixedFlagConst, List as BillsFixedFlagList} from "../../common/const/bills_fixed.js";
  17. import {default as BillsTypeFlagConst, List as BillsTypeFlagList} from "../../common/const/bills_type.js";
  18. import EngineeringLibModel from "../models/engineering_lib_model";
  19. import STDLabourCoesModel from "../../common/std/std_labour_coes_model";
  20. import STDCalcProgramModel from "../../common/std/std_calc_program_model";
  21. const billsGuidanceFc = require('../../std_billsGuidance_lib/facade/facades');
  22. import mainColFacade from "../../main_col_lib/facade/main_col_facade";
  23. import billTemplateFacade from "../../bills_template_lib/facade/bills_template_facade";
  24. import projectFeatureFacade from "../../project_feature_lib/facade/project_feature_facade";
  25. import progressiveFacade from "../../progressive_interval_lib/facade/progressive_facade";
  26. import vvTaxFacade from "../../vehicleVessel_lib/facade/vvTax_facade";
  27. import {default as category, List as categoryList} from "../../common/const/category_const.js";
  28. let config = require("../../../config/config.js");
  29. const fs = require('fs');
  30. class CompilationController extends BaseController {
  31. /**
  32. * 编办管理控制页面
  33. *
  34. * @param {object} request
  35. * @param {object} response
  36. * @return {void}
  37. */
  38. async index(request, response) {
  39. let id = request.query.id;
  40. let compilationList = [];
  41. let selectedCompilation = {};
  42. try {
  43. let compilationModel = new CompilationModel();
  44. compilationList = await compilationModel.getCompilationList();
  45. if (compilationList.length <= 0) {
  46. throw '没有数据';
  47. }
  48. // 循环查找数据
  49. for (let tmp of compilationList) {
  50. if (tmp._id.toString() === id) {
  51. selectedCompilation = tmp;
  52. break;
  53. }
  54. }
  55. selectedCompilation = Object.keys(selectedCompilation).length <= 0 ? compilationList[0] : selectedCompilation;
  56. request.session.selectedCompilation = selectedCompilation;
  57. } catch (error) {
  58. console.log(error);
  59. }
  60. if (selectedCompilation.example && Array.isArray(selectedCompilation.example)) {
  61. selectedCompilation.example = selectedCompilation.example.join(';');
  62. }
  63. let renderData = {
  64. id: id,
  65. compilationList: compilationList,
  66. categoryList: categoryList,
  67. selectedCompilation: selectedCompilation,
  68. layout: 'users/views/layout/layout',
  69. LicenseKey:config.getLicenseKey(process.env.NODE_ENV)
  70. };
  71. response.render('users/views/compilation/index', renderData);
  72. }
  73. /**
  74. * 新增计价页面
  75. *
  76. * @param {object} request
  77. * @param {object} response
  78. * @return {void}
  79. */
  80. async addValuation(request, response) {
  81. let name = request.body.name;
  82. let id = request.body.id;
  83. let section = request.body.section;
  84. let responseData = {
  85. err: 0,
  86. msg: ''
  87. };
  88. try {
  89. if (id === undefined || id === '') {
  90. throw '参数错误';
  91. }
  92. let insertData = {
  93. name: name,
  94. };
  95. let compilationModel = new CompilationModel();
  96. let valuationId = await compilationModel.addValuation(id, section, insertData);
  97. if (!valuationId) {
  98. throw '新增计价规则失败';
  99. }
  100. //添加标准工程专业 2018-08-24 不自动添加标准工程了
  101. /*let engineeringLibModel = new EngineeringLibModel();
  102. let stdEngs = await engineeringLibModel.addStdLib(valuationId);
  103. console.log(stdEngs);*/
  104. } catch (error) {
  105. console.log(error);
  106. responseData.err = 1;
  107. responseData.msg = error;
  108. }
  109. response.json(responseData);
  110. }
  111. /**
  112. * 修改计价规则页面
  113. *
  114. * @param {object} request
  115. * @param {object} response
  116. * @return {void}
  117. */
  118. async editValuation(request, response) {
  119. let selectedCompilation = request.session.selectedCompilation;
  120. let valuationId = request.params.id;
  121. let section = request.params.section;
  122. let compilationList = [];
  123. let engineeringList = [];
  124. let valuationData = {};
  125. let valuationList = {};
  126. try {
  127. let compilationModel = new CompilationModel();
  128. compilationList = await compilationModel.getCompilationList();
  129. // 获取对应的计价规则数据
  130. [valuationData, valuationList] = await compilationModel.getValuation(selectedCompilation._id, valuationId, section);
  131. if (Object.keys(valuationData).length <= 0) {
  132. throw '不存在数据';
  133. }
  134. // 获取计价规则中对应的标准库数据
  135. let engineeringLibModel = new EngineeringLibModel();
  136. engineeringList = await engineeringLibModel.getLibsByValuationID(valuationId);
  137. } catch (error) {
  138. console.log(error);
  139. }
  140. let renderData = {
  141. compilationList: compilationList,
  142. engineeringList: engineeringList,
  143. selectedCompilation: selectedCompilation,
  144. valuationData: valuationData,
  145. valuationList: valuationList,
  146. valuationId: valuationId,
  147. section: section,
  148. layout: 'users/views/layout/layout',
  149. LicenseKey:config.getLicenseKey(process.env.NODE_ENV)
  150. };
  151. response.render('users/views/compilation/add', renderData);
  152. }
  153. /**
  154. * 编辑工程专业页面
  155. *
  156. * @param {object} request
  157. * @param {object} response
  158. * @return {void}
  159. */
  160. async editEngineering(request, response) {
  161. let engineerID = request.params.engineerID;
  162. let valuationId = request.params.id;
  163. let section = request.params.section;
  164. let selectedCompilation = request.session.selectedCompilation;
  165. let compilationList = [],
  166. billList = [],
  167. rationList = [],
  168. gljList = [],
  169. feeRateList = [],
  170. libData = {},
  171. billsTemplateData = [],
  172. featureList = [],
  173. progressiveList = [],
  174. vvTaxList = [];
  175. let valuationData = {}, valuationList = {}, artificialCoefficientList = [], calculationList = [], billsGuidanceList = [], mainTreeColList = [];
  176. let billTemplateList = [];
  177. try {
  178. let compilationModel = new CompilationModel();
  179. compilationList = await compilationModel.getCompilationList();
  180. // 获取标准清单,不绑定编办
  181. let stdBillLibListsModel = new STDBillLibListsModel();
  182. billList = await stdBillLibListsModel.getBillList();
  183. // 获取定额库
  184. let stdRationLibMapModel = new STDRationLibMapModel();
  185. rationList = await stdRationLibMapModel.getRationLib(selectedCompilation._id);
  186. // 获取工料机库
  187. let stdGLJLibMapModel = new STDGLJLibMapModel();
  188. gljList = await stdGLJLibMapModel.getGLJLibList(selectedCompilation._id);
  189. // 获取费率标准库
  190. let stdFeeRateLibsModel = new STDFeeRateLibsModel();
  191. feeRateList = await stdFeeRateLibsModel.getFeeRateList(selectedCompilation._id);
  192. // 获取人工系数标准库
  193. let stdLabourCoesModel = new STDLabourCoesModel();
  194. artificialCoefficientList = await stdLabourCoesModel.getLabourCoesList();
  195. // 获取计算程序库
  196. let stdCalcProgramModel = new STDCalcProgramModel();
  197. calculationList = await stdCalcProgramModel.getProgramList(selectedCompilation._id);
  198. //获取列设置库
  199. mainTreeColList = await mainColFacade.getColLibsByCompilationID(selectedCompilation._id);
  200. //获取清单模板库
  201. billTemplateList = await billTemplateFacade.getTemplateLibByCompilationID(selectedCompilation._id);
  202. // 获取对应的计价规则数据
  203. [valuationData, valuationList] = await compilationModel.getValuation(selectedCompilation._id, valuationId, section);
  204. if (Object.keys(valuationData).length <= 0) {
  205. throw '不存在数据';
  206. }
  207. // 获取对应专业工程下的标准库数据
  208. let engineeringLibModel = new EngineeringLibModel();
  209. libData = await engineeringLibModel.findDataByCondition({_id:engineerID});
  210. // 获取清单模板数据
  211. let billsTemplateModel = new BillsTemplateModel();
  212. billsTemplateData = await billsTemplateModel.getTemplateData(valuationId, libData.engineering);
  213. //获取清单指引数据
  214. billsGuidanceList = await billsGuidanceFc.getBillsGuideLibs({compilationId: selectedCompilation._id, $or: [{deleted: null}, {deleted: false}]});
  215. //获取工程特征库
  216. featureList = await projectFeatureFacade.findByCondition({},null,false);
  217. //获取累进区间库
  218. progressiveList = await progressiveFacade.findByCondition({},null,false);
  219. //获取车船税库
  220. vvTaxList = await vvTaxFacade.findByCondition({}, false, false);
  221. } catch (error) {
  222. console.log(error);
  223. }
  224. //example Array to example String
  225. if (selectedCompilation.example && Array.isArray(selectedCompilation.example)) {
  226. selectedCompilation.example = selectedCompilation.example.join(';');
  227. }
  228. let renderData = {
  229. section: section,
  230. valuationId: valuationId,
  231. compilationList: compilationList,
  232. selectedCompilation: selectedCompilation,
  233. libData: libData,
  234. billList: JSON.stringify(billList),
  235. rationList: JSON.stringify(rationList),
  236. gljList: JSON.stringify(gljList),
  237. artificialCoefficientList: JSON.stringify(artificialCoefficientList),
  238. feeRateList: JSON.stringify(feeRateList),
  239. billsTemplateData: JSON.stringify(billsTemplateData),
  240. billTemplateList:JSON.stringify(billTemplateList),
  241. mainTreeColList: JSON.stringify(mainTreeColList),
  242. gljCol:JSON.stringify(libData.glj_col),
  243. calculationList: JSON.stringify(calculationList),
  244. billsGuidanceList: JSON.stringify(billsGuidanceList),
  245. featureList:JSON.stringify(featureList),
  246. progressiveList:JSON.stringify(progressiveList),
  247. vvTaxList: JSON.stringify(vvTaxList),
  248. layout: 'users/views/layout/layout',
  249. LicenseKey:config.getLicenseKey(process.env.NODE_ENV)
  250. };
  251. response.render('users/views/compilation/engineering', renderData);
  252. }
  253. /**
  254. * 保存工程专业标准库
  255. *
  256. * @param {object} request
  257. * @param {object} response
  258. * @return {void}
  259. */
  260. async saveEngineering(request, response) {
  261. let engineerId = request.body.id;
  262. try {
  263. if (engineerId === '') {
  264. throw 'id参数错误';
  265. }
  266. // 先存入工程专业标准库表
  267. let engineeringLibModel = new EngineeringLibModel();
  268. let result = await engineeringLibModel.addLib(engineerId, request.body);
  269. if (!result) {
  270. throw '保存失败';
  271. }
  272. } catch (error) {
  273. console.log(error);
  274. }
  275. response.redirect(request.headers.referer);
  276. }
  277. /**
  278. * 通过工程专业ID删除工程专业
  279. * @param request
  280. * @param response
  281. * @returns {Promise.<void>}
  282. */
  283. async deleteEngineer(request,response){
  284. let result={
  285. error:0
  286. };
  287. try {
  288. let data = request.body.data;
  289. data = JSON.parse(data);
  290. if(data.id ){
  291. let engineeringLibModel = new EngineeringLibModel();
  292. result.data = await engineeringLibModel.deleteById(data.id,true);
  293. }else {
  294. throw new Error("提交数据有误");
  295. }
  296. }catch (err){
  297. console.log(err);
  298. result.error=1;
  299. result.message = err.message;
  300. }
  301. response.json(result);
  302. }
  303. /**
  304. * 修改保存工程专业信息-用于异步操作
  305. * @param request
  306. * @param response
  307. * @returns {Promise.<void>}
  308. */
  309. async updateEngineer(request,response){
  310. let result={
  311. error:0
  312. };
  313. try {
  314. let data = request.body.data;
  315. data = JSON.parse(data);
  316. if(data.id && data.updateData){
  317. let engineeringLibModel = new EngineeringLibModel();
  318. result.data = await engineeringLibModel.updateById(data.id,data.updateData);
  319. }else {
  320. throw new Error("提交数据有误");
  321. }
  322. }catch (err){
  323. console.log(err);
  324. result.error=1;
  325. result.message = err.message;
  326. }
  327. response.json(result);
  328. }
  329. /**
  330. * 保存计价规则
  331. *
  332. * @param {object} request
  333. * @param {object} response
  334. * @return {void}
  335. */
  336. async saveValuation(request, response) {
  337. let valuationId = request.body.id;
  338. try {
  339. if (valuationId === '') {
  340. throw 'id参数错误';
  341. }
  342. let compilationModel = new CompilationModel();
  343. let result = await compilationModel.saveValuation(valuationId, request.body);
  344. if (!result) {
  345. throw '保存失败';
  346. }
  347. } catch (error) {
  348. console.log(error);
  349. }
  350. response.redirect(request.headers.referer);
  351. }
  352. /**
  353. * 删除计价规则
  354. *
  355. * @param {object} request
  356. * @param {object} response
  357. * @return {void}
  358. */
  359. async deleteValuation(request, response) {
  360. let id = request.params.id;
  361. let section = request.params.section;
  362. let selectedCompilation = request.session.selectedCompilation;
  363. try {
  364. if (id === undefined || id === '' || section === undefined || section === '') {
  365. throw '参数错误';
  366. }
  367. //先删除对应的工程专业
  368. let engineeringLibModel = new EngineeringLibModel();
  369. await engineeringLibModel.deleteByValuationID(id);
  370. //删除计价规则
  371. let compilationModel = new CompilationModel();
  372. let result = compilationModel.deleteValuation(selectedCompilation._id, id, section);
  373. if (!result) {
  374. throw '删除失败';
  375. }
  376. } catch (error) {
  377. console.log(error);
  378. }
  379. response.redirect(request.headers.referer);
  380. }
  381. /**
  382. * 快速切换启用/禁用
  383. *
  384. * @param {object} request
  385. * @param {object} response
  386. * @return {void}
  387. */
  388. async enableSwitch(request, response) {
  389. let id = request.body.id;
  390. let section = request.params.section;
  391. let enable = request.body.enable;
  392. let responseData = {
  393. err: 0,
  394. msg: ''
  395. };
  396. try {
  397. let compilationModel = new CompilationModel();
  398. let result = await compilationModel.switchEnable(id, section, enable);
  399. if (!result) {
  400. throw '新增编办失败';
  401. }
  402. } catch (error) {
  403. console.log(error);
  404. responseData.err = 1;
  405. responseData.msg = error;
  406. }
  407. response.json(responseData);
  408. }
  409. /**
  410. * 发布/取消编办
  411. *
  412. * @param {object} request
  413. * @param {object} response
  414. * @return {void}
  415. */
  416. async release(request, response) {
  417. let id = request.body.id;
  418. let release = request.body.status;
  419. release = parseInt(release);
  420. let responseData = {
  421. err: 0,
  422. msg: ''
  423. };
  424. try {
  425. let compilationModel = new CompilationModel();
  426. let result = await compilationModel.release(id, release);
  427. if (!result) {
  428. throw '发布编办失败';
  429. }
  430. } catch (error) {
  431. console.log(error);
  432. responseData.err = 1;
  433. responseData.msg = error;
  434. }
  435. response.json(responseData);
  436. }
  437. /**
  438. * 新增编办操作
  439. *
  440. * @param {object} request
  441. * @param {object} response
  442. * @return {void}
  443. */
  444. async addCompilation(request, response) {
  445. let name = request.body.name;
  446. let responseData = {
  447. err: 0,
  448. msg: ''
  449. };
  450. try {
  451. let sessionManager = request.session.managerData;
  452. let insertData = {
  453. name: name,
  454. creator: sessionManager.userID
  455. };
  456. let compilationModel = new CompilationModel();
  457. let result = await compilationModel.add(insertData);
  458. if (!result) {
  459. throw '新增编办失败';
  460. }
  461. } catch (error) {
  462. console.log(error);
  463. responseData.err = 1;
  464. responseData.msg = error;
  465. }
  466. response.json(responseData);
  467. }
  468. async setDescription(request, response){
  469. let compilationId = request.body.id;
  470. let description = request.body.description;
  471. try{
  472. let compilationModel = new CompilationModel();
  473. await compilationModel.setDescription(compilationId, description);
  474. response.json({err: 0, msg: '', data: null});
  475. }
  476. catch (err){
  477. response.json({err: 1, msg: err, data: null});
  478. }
  479. }
  480. async setOverWriteUrl(request, response){
  481. let compilationId = request.body.id;
  482. let overWriteUrl = request.body.overWriteUrl;
  483. try{
  484. let compilationModel = new CompilationModel();
  485. //绝对路径
  486. let absoluteUrl = request.app.locals.rootDir + overWriteUrl;
  487. //文件是否存在
  488. let fileExists = fs.existsSync(absoluteUrl);
  489. let pricePropertiesTemplate = [],
  490. consumeAmtPropertiesTemplate = [];
  491. if(fileExists && fs.statSync(absoluteUrl).isFile()){
  492. //读取配置文件并赋值
  493. let overWriteExports = require(absoluteUrl);
  494. if(overWriteExports){
  495. pricePropertiesTemplate = overWriteExports.pricePropertiesTemplate ? overWriteExports.pricePropertiesTemplate : [];
  496. consumeAmtPropertiesTemplate = overWriteExports.consumeAmtPropertiesTemplate ? overWriteExports.consumeAmtPropertiesTemplate : [];
  497. }
  498. }
  499. await compilationModel.setOverWriteUrl(compilationId, overWriteUrl, pricePropertiesTemplate, consumeAmtPropertiesTemplate);
  500. response.json({err: 0, msg: '', data: null});
  501. }
  502. catch (err){
  503. console.log(err);
  504. response.json({err: 1, msg: err, data: null});
  505. }
  506. }
  507. async setExample(request, response){
  508. let compilationId = request.body.id,
  509. example = request.body.example;
  510. try {
  511. let compilationModel = new CompilationModel();
  512. await compilationModel.setExample(compilationId, example);
  513. response.json({err: 0, msg: 'success', data: null});
  514. }
  515. catch (err){
  516. console.log(err);
  517. response.json({err: 1, msg: err, data: null});
  518. }
  519. }
  520. /**
  521. * 模板设置页面
  522. *
  523. * @param {object} request
  524. * @param {object} response
  525. * @return {void}
  526. */
  527. async billsTemplate(request, response) {
  528. let billList = {};
  529. let valuationList = {};
  530. let valuationData = {};
  531. let compilationList = [];
  532. let billsTemplateData = [];
  533. let selectedCompilation = request.session.selectedCompilation;
  534. let engineering = request.params.engineering;
  535. let valuationId = request.params.id;
  536. let section = request.params.section;
  537. try {
  538. let compilationModel = new CompilationModel;
  539. // 获取对应的计价规则数据
  540. [valuationData, valuationList] = await compilationModel.getValuation(selectedCompilation._id, valuationId, section);
  541. compilationList = await compilationModel.getCompilationList();
  542. // 获取标准清单
  543. let stdBillLibListsModel = new STDBillLibListsModel();
  544. billList = await stdBillLibListsModel.getBillList(selectedCompilation._id);
  545. // 获取清单模板数据
  546. let billsTemplateModel = new BillsTemplateModel();
  547. billsTemplateData = await billsTemplateModel.getTemplateData(valuationId, engineering);
  548. } catch (error) {
  549. console.log(error);
  550. }
  551. let renderData = {
  552. engineering: engineering,
  553. billList: JSON.stringify(billList),
  554. billsTemplateData: JSON.stringify(billsTemplateData),
  555. billsFixedFlagList: JSON.stringify(BillsFixedFlagList),
  556. billsTypeFlagList: JSON.stringify(BillsTypeFlagList),
  557. valuationData: valuationData,
  558. valuationList: valuationList,
  559. selectedCompilation: selectedCompilation,
  560. compilationList: compilationList,
  561. valuationId: valuationId,
  562. section: section,
  563. layout: 'users/views/layout/layout',
  564. LicenseKey:config.getLicenseKey(process.env.NODE_ENV)
  565. };
  566. response.render('users/views/compilation/template', renderData);
  567. }
  568. /**
  569. * 清单模板,更新数据操作
  570. *
  571. * @param request
  572. * @param response
  573. */
  574. async updateBillsTemplate(request, response) {
  575. let engineering = request.params.engineering;
  576. let valuationId = request.params.id;
  577. let section = request.params.section;
  578. let data = JSON.parse(request.body.data);
  579. let billsTemplateModel = new BillsTemplateModel();
  580. let result = await billsTemplateModel.updateTemplate(valuationId, engineering, data);
  581. if (result) {
  582. response.json({error: 0, message: '', data: data});
  583. } else {
  584. response.json({error: 1, message: '更新数据错误', data: null});
  585. }
  586. }
  587. async addEngineer(request,response){
  588. let engineeringLibModel = new EngineeringLibModel();
  589. try {
  590. await engineeringLibModel.addEngineer(request.body);
  591. }catch (error) {
  592. console.log(error);
  593. }
  594. response.redirect(request.headers.referer);
  595. }
  596. /**
  597. * 更改编办所属办事处信息
  598. *
  599. * @param request
  600. * @param response
  601. * @return {Promise.<void>}
  602. */
  603. async changeCategory(request, response) {
  604. let valuationId = request.body.id;
  605. let category = request.body.category;
  606. category = parseInt(category);
  607. try {
  608. let compilationModel = new CompilationModel();
  609. let result = await compilationModel.updateCategory(valuationId, category);
  610. if (result) {
  611. response.json({error: 0, message: '', data: null});
  612. } else {
  613. response.json({error: 1, message: '更新数据错误', data: null});
  614. }
  615. } catch(error) {
  616. response.json({error: 1, message: '更新数据错误', data: null});
  617. }
  618. }
  619. }
  620. export default CompilationController;