tender_controller.js 40 KB

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