tender_controller.js 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621
  1. 'use strict';
  2. /**
  3. * 标段管理控制器
  4. *
  5. * @author CaiAoLin
  6. * @date 2018/2/5
  7. * @version
  8. */
  9. const tenderConst = require('../const/tender');
  10. const codeRuleConst = require('../const/code_rule');
  11. const settingConst = require('../const/setting.js');
  12. const tenderMenu = require('../../config/menu').tenderMenu;
  13. const auditConst = require('../const/audit');
  14. const accountPermission = require('../const/account_permission');
  15. module.exports = app => {
  16. class TenderController extends app.BaseController {
  17. /**
  18. * 构造函数
  19. *
  20. * @param {Object} ctx - egg全局变量
  21. * @return {void}
  22. */
  23. constructor(ctx) {
  24. super(ctx);
  25. ctx.showProject = true;
  26. ctx.showTitle = true;
  27. }
  28. async _listDetail(view, modal = '') {
  29. try {
  30. // 获取用户新建标段权利
  31. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  32. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  33. const tenderList = await this.ctx.service.tender.getList('', userPermission);
  34. for (const t of tenderList) {
  35. if (t.user_id === this.ctx.session.sessionUser.accountId && (
  36. t.ledger_status === auditConst.ledger.status.checkNo || t.ledger_status === auditConst.ledger.status.uncheck)) {
  37. const sum = await this.ctx.service.ledger.addUp({tender_id: t.id, is_leaf: true});
  38. t.total_price = sum.total_price;
  39. t.deal_tp = sum.deal_tp;
  40. }
  41. if (t.ledger_status === auditConst.ledger.status.checked) {
  42. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  43. if (t.lastStage) {
  44. await this.ctx.service.stage.checkStageGatherData(t.lastStage);
  45. }
  46. }
  47. }
  48. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  49. const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  50. const renderData = {
  51. tenderList,
  52. tenderConst,
  53. settingConst,
  54. categoryData,
  55. measureType: tenderConst.measureType,
  56. jsFiles: this.app.jsFiles.common.concat(this.jsFiles),
  57. auditConst,
  58. userPermission,
  59. valuations,
  60. };
  61. await this.layout(view, renderData, modal);
  62. } catch (err) {
  63. this.log(err);
  64. this.ctx.redirect('/dashboard');
  65. }
  66. }
  67. async _list(view, renderData, modal = '') {
  68. try {
  69. renderData.tenderList = await this.ctx.service.tender.getList('', renderData.userPermission);
  70. for (const t of renderData.tenderList) {
  71. if (t.ledger_status === auditConst.ledger.status.checked) {
  72. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  73. t.completeStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
  74. }
  75. }
  76. renderData.categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  77. renderData.valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  78. renderData.tenderConst = tenderConst;
  79. renderData.settingConst = settingConst;
  80. renderData.measureType = tenderConst.measureType;
  81. renderData.jsFiles = this.app.jsFiles.common.concat(this.jsFiles);
  82. renderData.auditConst = auditConst;
  83. await this.layout(view, renderData, modal);
  84. } catch (err) {
  85. this.log(err);
  86. this.ctx.redirect('/dashboard')
  87. }
  88. }
  89. async listDefault(ctx) {
  90. this.jsFiles = this.app.jsFiles.tender.list;
  91. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  92. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  93. const renderData = {
  94. accountInfo,
  95. userPermission,
  96. };
  97. await this._list('tender/index.ejs', renderData, 'tender/modal.ejs');
  98. }
  99. /**
  100. * 标段概况(Get)
  101. *
  102. * @param {object} ctx - egg全局变量
  103. * @return {void}
  104. */
  105. async listInfo(ctx) {
  106. this.jsFiles = this.app.jsFiles.tender.info;
  107. await this._listDetail('tender/info.ejs', 'tender/modal.ejs');
  108. }
  109. /**
  110. * 计量进度(Get)
  111. *
  112. * @param ctx
  113. * @return {Promise<void>}
  114. */
  115. async listProgress(ctx) {
  116. this.jsFiles = this.app.jsFiles.tender.progress;
  117. await this._listDetail('tender/progress.ejs', 'tender/modal.ejs');
  118. }
  119. /**
  120. * 标段管理(Get)
  121. *
  122. * @param ctx
  123. * @return {Promise<void>}
  124. */
  125. async listManage(ctx) {
  126. this.jsFiles = this.app.jsFiles.tender.manage;
  127. // 先判断权限
  128. // 获取用户新建标段权利
  129. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  130. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  131. if (userPermission !== null && userPermission.tender !== undefined && userPermission.tender.indexOf('1') !== -1) {
  132. const renderData = {
  133. accountInfo,
  134. userPermission
  135. };
  136. await this._list('tender/manage.ejs', renderData, 'tender/manage_modal.ejs')
  137. // 获取用户新建标段权利
  138. // const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  139. // const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  140. //
  141. // const tenderList = await this.ctx.service.tender.getList('manage', userPermission);
  142. // for (const t of tenderList) {
  143. // t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  144. // t.completeStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
  145. // }
  146. // const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  147. // const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  148. // const renderData = {
  149. // tenderList,
  150. // tenderConst,
  151. // settingConst,
  152. // categoryData,
  153. // measureType: tenderConst.measureType,
  154. // jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.manage),
  155. // auditConst,
  156. // userPermission,
  157. // valuations,
  158. // };
  159. // await this.layout('tender/manage.ejs', renderData, 'tender/manage_modal.ejs');
  160. } else {
  161. this.ctx.redirect(ctx.request.header.referer);
  162. }
  163. }
  164. /**
  165. * 新增标段(Ajax)
  166. *
  167. * @param ctx
  168. * @return {Promise<void>}
  169. */
  170. async addTender(ctx) {
  171. try {
  172. const responseData = {
  173. err: 0, msg: '', data: null,
  174. };
  175. // 获取用户新建标段权利
  176. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  177. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  178. if (userPermission === null || userPermission.tender === undefined || userPermission.tender.indexOf('1') === -1) {
  179. throw '当前用户没有创建标段的权限';
  180. }
  181. const data = JSON.parse(ctx.request.body.data);
  182. if (!data.name || data.name === '' || !data.valuation) {
  183. throw '标段信息不完整';
  184. }
  185. responseData.data = await ctx.service.tender.add(data);
  186. ctx.body = responseData;
  187. } catch (error) {
  188. this.log(error);
  189. ctx.body = { err: 1, msg: error.toString(), data: null };
  190. }
  191. }
  192. /**
  193. * 编辑标段(Ajax)
  194. *
  195. * @param ctx
  196. * @return {Promise<void>}
  197. */
  198. async updateTender(ctx) {
  199. try {
  200. const responseData = {
  201. err: 0, msg: '', data: null,
  202. };
  203. const data = JSON.parse(ctx.request.body.data);
  204. if (!data.id) {
  205. throw '提交信息错误';
  206. }
  207. if (!data.name || data.name === '') {
  208. throw '标段信息不完整';
  209. }
  210. if (await ctx.service.tender.save(data, data.id)) {
  211. responseData.data = await ctx.service.tender.getTender(data.id);
  212. }
  213. ctx.body = responseData;
  214. } catch (error) {
  215. this.log(error);
  216. ctx.body = { err: 1, msg: error.toString(), data: null };
  217. }
  218. }
  219. /**
  220. * 删除标段(Ajax)
  221. *
  222. * @param ctx
  223. * @return {Promise<void>}
  224. */
  225. async deleteTender(ctx) {
  226. try {
  227. const data = JSON.parse(ctx.request.body.data), result = [];
  228. if (!(data instanceof Array) && (data.length === 0)) {
  229. throw '提交数据有误';
  230. }
  231. for (const id of data) {
  232. if (await ctx.service.tender.deleteTenderNoBackup(id)) {
  233. result.push(id);
  234. }
  235. }
  236. ctx.body = {err: 0, msg: '', data: result};
  237. } catch (err) {
  238. ctx.body = {err: 1, msg: err.toString(), data: []}
  239. }
  240. }
  241. /**
  242. * 标段概况(Get)
  243. *
  244. * @param ctx
  245. * @return {Promise<void>}
  246. */
  247. async tenderInfo(ctx) {
  248. try {
  249. const tender = ctx.tender.data;
  250. if (tender.user_id === this.ctx.session.sessionUser.accountId && (
  251. tender.ledger_status === auditConst.ledger.status.checkNo || tender.ledger_status === auditConst.ledger.status.uncheck)) {
  252. const sum = await this.ctx.service.ledger.addUp({tender_id: tender.id, is_leaf: true});
  253. tender.total_price = sum.total_price;
  254. tender.deal_tp = sum.deal_tp;
  255. }
  256. const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
  257. const lastStage = stages[0]; //await ctx.service.stage.getLastestStage(ctx.tender.id);
  258. if (lastStage) {
  259. await this.ctx.service.stage.checkStageGatherData(lastStage);
  260. tender.gather_tp = ctx.helper.add(lastStage.contract_tp, lastStage.qc_tp);
  261. tender.end_contract_tp = ctx.helper.add(lastStage.contract_tp, lastStage.pre_contract_tp);
  262. tender.end_qc_tp = ctx.helper.add(lastStage.qc_tp, lastStage.pre_qc_tp);
  263. tender.end_gather_tp = ctx.helper.add(tender.end_contract_tp, tender.end_qc_tp);
  264. tender.pre_gather_tp = ctx.helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
  265. tender.yf_tp = lastStage.yf_tp;
  266. tender.qc_ratio = ctx.helper.mul(ctx.helper.div(tender.end_qc_tp, tender.gather_tp, 2), 100);
  267. tender.sum = ctx.helper.add(tender.total_price, tender.end_qc_tp);
  268. tender.pre_ratio = ctx.helper.mul(ctx.helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
  269. tender.cur_ratio = ctx.helper.mul(ctx.helper.div(tender.gather_tp, tender.sum, 2), 100);
  270. tender.other_tp = ctx.helper.sub(ctx.helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
  271. tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
  272. }
  273. const monthProgress = [];
  274. for (const s of stages) {
  275. if (s.s_time) {
  276. let progress = monthProgress.find(function (x) {
  277. return x.month === s.s_time;
  278. });
  279. if (!progress) {
  280. progress = {month: s.s_time};
  281. monthProgress.push(progress);
  282. }
  283. progress.tp = ctx.helper.add(ctx.helper.add(progress.tp, s.contract_tp), s.qc_tp);
  284. }
  285. }
  286. monthProgress.sort(function (x, y) {
  287. return Date.parse(x.month) - Date.parse(y.month);
  288. });
  289. let sum = 0;
  290. for (const p of monthProgress) {
  291. p.ratio = ctx.helper.mul(ctx.helper.div(p.tp, tender.sum, 4), 100);
  292. sum = ctx.helper.add(sum, p.tp);
  293. p.end_tp = sum;
  294. p.end_ratio = ctx.helper.mul(ctx.helper.div(p.end_tp, tender.sum, 4), 100);
  295. }
  296. const renderData = {
  297. tender: tender,
  298. tenderInfo: ctx.tender.info,
  299. tenderMenu: this.menu.tenderMenu,
  300. preUrl: '/tender/' + ctx.tender.id,
  301. cooperation: ctx.session.sessionUser.cooperation,
  302. lastStage,
  303. stages: stages.reverse(),
  304. monthProgress,
  305. audit: auditConst,
  306. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.tenderInfo),
  307. };
  308. await this.layout('tender/detail.ejs', renderData, 'tender/detail_modal.ejs');
  309. } catch (error) {
  310. this.log(error);
  311. this.ctx.redirect('/list');
  312. }
  313. }
  314. /**
  315. * 保存标段属性等(Ajax)
  316. *
  317. * @param ctx
  318. * @return {Promise<void>}
  319. */
  320. async saveTenderInfo(ctx) {
  321. try {
  322. const data = JSON.parse(ctx.request.body.data);
  323. if (!data) {
  324. throw '提交数据错误';
  325. }
  326. if (ctx.tender.data.ledger_status === auditConst.ledger.status.checked) {
  327. if (data.deal_param) {
  328. const lastStage = await this.ctx.service.stage.getLastestStage(ctx.tender.id, true);
  329. if (lastStage) {
  330. if (lastStage.order > 1 || (lastStage.status === auditConst.stage.status.checked || lastStage.status === auditConst.stage.status.checking))
  331. throw '第一期上报后不可修改合同参数';
  332. if (lastStage.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改合同参数';
  333. }
  334. }
  335. }
  336. if (data.decimal) {
  337. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改小数位数';
  338. await ctx.service.tenderInfo.saveDecimal(ctx.tender.id, data.decimal, ctx.tender.info.decimal);
  339. } else if (data.precision) {
  340. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改清单精度';
  341. await ctx.service.tenderInfo.savePrecision(ctx.tender.id,
  342. data.precision, ctx.tender.info.precision, ctx.tender.info.decimal);
  343. } else {
  344. await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, data);
  345. }
  346. ctx.body = { err: 0, msg: '', data: JSON.parse(ctx.request.body.data) };
  347. } catch (err) {
  348. this.log(err);
  349. ctx.body = { err: 1, msg: err.toString(), data: null };
  350. }
  351. }
  352. /**
  353. * 设置标段计量类型并调整到标段概况(Get)
  354. *
  355. * @param ctx
  356. * @return {Promise<void>}
  357. */
  358. async tenderType(ctx) {
  359. try {
  360. const tenderId = ctx.params.id,
  361. type = ctx.query.type;
  362. if (!tenderId) {
  363. throw '当前未打开标段';
  364. }
  365. const tender = await ctx.service.tender.getTender(tenderId);
  366. if (!tender) {
  367. throw '标段数据错误';
  368. }
  369. if (!tender.measure_type) {
  370. await ctx.service.tender.update({ measure_type: type }, { id: tender.id });
  371. }
  372. ctx.redirect('/tender/' + tenderId);
  373. } catch (error) {
  374. this.log(error);
  375. ctx.redirect('/list');
  376. }
  377. }
  378. /**
  379. * 标段协作办公
  380. *
  381. * @param {Object} ctx - egg全局变量
  382. * @return {void}
  383. */
  384. async tenderCooperation(ctx) {
  385. const tenderId = ctx.params.id;
  386. try {
  387. if (!ctx.session.sessionUser.cooperation) {
  388. throw '权限不足';
  389. }
  390. const tender = await ctx.service.tender.getDataById(tenderId);
  391. const user = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  392. // 获取已参与协作用户列表
  393. const cooperationArray = [];
  394. if (tender.cooperation !== null && tender.cooperation !== '') {
  395. const cooperationList = JSON.parse(tender.cooperation);
  396. for (const cl in cooperationList) {
  397. const clArray = [];
  398. for (const audit of cooperationList[cl]) {
  399. const userInfo = await ctx.service.projectAccount.getDataById(audit);
  400. clArray.push(userInfo);
  401. }
  402. cooperationArray[cl] = clArray;
  403. }
  404. }
  405. const renderData = {
  406. user,
  407. tender,
  408. tenderMenu: this.menu.tenderMenu,
  409. preUrl: '/tender/' + tenderId,
  410. tenderPermissionList: accountPermission.tenderPermissionList,
  411. cooperationArray,
  412. };
  413. await this.layout('tender/cooperation.ejs', renderData, 'tender/cooperationModal.ejs');
  414. } catch (error) {
  415. this.log(error);
  416. this.ctx.redirect('/tender/' + tenderId);
  417. }
  418. }
  419. /**
  420. * 添加标段操作
  421. *
  422. * @param {Object} ctx - egg全局变量
  423. * @return {void}
  424. */
  425. async add(ctx) {
  426. try {
  427. const rule = ctx.service.tender.rule('add');
  428. ctx.helper.validate(rule);
  429. const result = ctx.service.tender.add(ctx.request.body);
  430. if (!result) {
  431. throw '新增标段失败';
  432. }
  433. } catch (error) {
  434. this.log(error);
  435. this.setMessage(error.toString(), this.messageType.ERROR);
  436. }
  437. ctx.redirect(ctx.request.header.referer);
  438. }
  439. /**
  440. * 切换标段 --》 暂时废弃,不存在此功能
  441. *
  442. * @param {Object} ctx - egg全局变量
  443. * @return {void}
  444. */
  445. async switchTender(ctx) {
  446. let tenderId = ctx.params.tenderId;
  447. tenderId = parseInt(tenderId);
  448. try {
  449. if (isNaN(tenderId) || tenderId <= 0) {
  450. throw '参数错误';
  451. }
  452. const result = await ctx.service.tender.switchTender(tenderId);
  453. if (!result) {
  454. throw '切换标段失败!';
  455. }
  456. } catch (error) {
  457. this.setMessage(error.toString(), this.messageType.ERROR);
  458. }
  459. ctx.redirect(ctx.request.header.referer);
  460. }
  461. /**
  462. * 保存标段操作
  463. *
  464. * @param {Object} ctx - egg全局变量
  465. * @return {void}
  466. */
  467. async save(ctx) {
  468. let id = ctx.request.body.tenderId;
  469. id = parseInt(id);
  470. try {
  471. if (isNaN(id) || id < 0) {
  472. throw '参数错误';
  473. }
  474. // 获取数据规则
  475. const rule = ctx.service.tender.rule('save');
  476. ctx.validate(rule);
  477. const result = await ctx.service.tender.save(ctx.request.body, id);
  478. if (!result) {
  479. throw '保存标段数据失败';
  480. }
  481. this.setMessage('保存标段数据成功', this.messageType.SUCCESS);
  482. } catch (error) {
  483. this.setMessage(error.toString(), this.messageType.ERROR);
  484. }
  485. ctx.redirect(ctx.request.header.referer);
  486. }
  487. /**
  488. * 删除标段
  489. *
  490. * @param {Object} ctx -egg全局变量
  491. * @return {void}
  492. */
  493. async delete(ctx) {
  494. let id = ctx.request.body.tenderId;
  495. id = parseInt(id);
  496. try {
  497. if (isNaN(id) || id <= 0) {
  498. throw '参数错误';
  499. }
  500. const result = ctx.service.tender.deleteTenderById(id);
  501. if (!result) {
  502. throw '删除标段失败';
  503. }
  504. this.setMessage('删除标段成功', this.messageType.SUCCESS);
  505. } catch (error) {
  506. this.setMessage(error.toString(), this.messageType.ERROR);
  507. }
  508. ctx.redirect(ctx.request.header.referer);
  509. }
  510. async rule(ctx) {
  511. const responseData = {
  512. err: 0,
  513. msg: '',
  514. data: {},
  515. };
  516. try {
  517. const tenderId = ctx.session.sessionUser.tenderId;
  518. if (!tenderId) {
  519. throw '当前未打开标段';
  520. }
  521. const data = JSON.parse(ctx.request.body.data);
  522. if (!data.rule || !JSON.parse(data.data).length || !codeRuleConst.ruleField[data.rule]) {
  523. throw '请选择组件再添加';
  524. }
  525. if (!data.connector) {
  526. throw '请选择连接符';
  527. }
  528. const updateData = {
  529. id: tenderId,
  530. };
  531. updateData[codeRuleConst.ruleField[data.rule]] = data.data;
  532. updateData.c_connector = data.connector;
  533. updateData.c_rule_first = 0;
  534. const result = await ctx.service.tender.db.update(ctx.service.tender.tableName, updateData);
  535. if (result.affectedRows !== 1) {
  536. throw '更新规则失败';
  537. }
  538. } catch (err) {
  539. this.log(err);
  540. responseData.err = 1;
  541. responseData.msg = err.toString();
  542. }
  543. ctx.body = responseData;
  544. }
  545. async ruleFirst(ctx) {
  546. const responseData = {
  547. err: 0,
  548. msg: '',
  549. data: {},
  550. };
  551. try {
  552. const tenderId = ctx.session.sessionUser.tenderId;
  553. if (!tenderId) {
  554. throw '当前未打开标段';
  555. }
  556. const updateData = {
  557. id: tenderId,
  558. };
  559. updateData.c_rule_first = 0;
  560. const result = await ctx.service.tender.db.update(ctx.service.tender.tableName, updateData);
  561. if (result.affectedRows !== 1) {
  562. throw '更新规则失败';
  563. }
  564. } catch (err) {
  565. this.log(err);
  566. responseData.err = 1;
  567. responseData.msg = err.toString();
  568. }
  569. ctx.body = responseData;
  570. }
  571. }
  572. return TenderController;
  573. };