tender_controller.js 31 KB

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