tender_controller.js 21 KB

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