tender_controller.js 36 KB

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