tender_controller.js 64 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327
  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. const measureType = require('../const/tender').measureType;
  18. const billsPosConvert = require('../lib/bills_pos_convert');
  19. const path = require('path');
  20. const sendToWormhole = require('stream-wormhole');
  21. const scheduleConst = require('../const/schedule');
  22. const changeConst = require('../const/change');
  23. const tenderInfoModel = require('../lib/tender_info');
  24. const mapConst = require('../const/map');
  25. module.exports = app => {
  26. class TenderController extends app.BaseController {
  27. /**
  28. * 构造函数
  29. *
  30. * @param {Object} ctx - egg全局变量
  31. * @return {void}
  32. */
  33. constructor(ctx) {
  34. super(ctx);
  35. ctx.showProject = true;
  36. ctx.showTitle = true;
  37. }
  38. async _getLedgerAuditInfo(tender) {
  39. tender.cur_flow = {
  40. title: '台账',
  41. status: auditConst.ledger.tiStatusString[tender.ledger_status],
  42. status_class: auditConst.ledger.tiStatusStringClass[tender.ledger_status],
  43. };
  44. if (tender.ledger_status === auditConst.ledger.status.uncheck) {
  45. tender.cur_flow.name = tender.user_name;
  46. } else {
  47. const cur = tender.ledger_status === auditConst.ledger.status.checkNo
  48. ? await this.ctx.service.ledgerAudit.getLastestAuditor(tender.id, tender.ledger_times - 1, auditConst.ledger.status.checkNo)
  49. : await this.ctx.service.ledgerAudit.getLastestAuditor(tender.id, tender.ledger_times, tender.ledger_status);
  50. if (cur) {
  51. tender.cur_flow.name = cur.name;
  52. if (cur.audit_order === 1) {
  53. tender.pre_flow = { name: tender.user_name, time: cur.begin_time };
  54. } else {
  55. const pre = await this.ctx.service.ledgerAudit.getAuditorByOrder(tender.id, cur.audit_order - 1, cur.times);
  56. if (pre) tender.pre_flow = { name: pre.name, time: pre.end_time };
  57. }
  58. } else {
  59. tender.cur_flow.name = '';
  60. }
  61. }
  62. }
  63. async _getStageAuditInfo(tender, stage) {
  64. tender.cur_flow = {
  65. title: '第' + stage.order + '期',
  66. status: auditConst.stage.tiStatusString[stage.status],
  67. status_class: auditConst.stage.tiStatusStringClass[stage.status],
  68. };
  69. if (stage.status === auditConst.stage.status.uncheck) {
  70. if (tender.user_id === stage.user_id) {
  71. tender.cur_flow.name = tender.user_name;
  72. } else {
  73. const user = await this.ctx.service.projectAccount.getDataById(stage.user_id);
  74. tender.cur_flow.name = user.name;
  75. }
  76. if (stage.order > 1) {
  77. const preStage = await this.ctx.service.stage.getDataByCondition({ tid: tender.id, order: stage.order - 1 });
  78. if (!preStage) return;
  79. const pre = await this.ctx.service.stageAudit.getLastestAuditor(preStage.id, preStage.times, auditConst.stage.status.checked);
  80. if (pre) tender.pre_flow = { name: pre.name, time: pre.end_time };
  81. }
  82. } else {
  83. let cur;
  84. if (stage.status === auditConst.stage.status.checkNo) {
  85. cur = await this.ctx.service.stageAudit.getLastestAuditor(stage.id, stage.times - 1, auditConst.stage.status.checkNo);
  86. } else if (stage.status === auditConst.stage.status.checked) {
  87. cur = await this.ctx.service.stageAudit.getLastestAuditor(stage.id, stage.times, auditConst.stage.status.checked);
  88. } else {
  89. cur = await this.ctx.service.stageAudit.getCurAuditor(stage.id, stage.times);
  90. }
  91. if (cur) {
  92. tender.cur_flow.name = cur.name;
  93. if (cur.order === 1) {
  94. tender.pre_flow = {};
  95. if (tender.user_id === stage.user_id) {
  96. tender.pre_flow.name = tender.user_name;
  97. } else {
  98. const user = await this.ctx.service.projectAccount.getDataById(stage.user_id);
  99. tender.pre_flow.name = user.name;
  100. }
  101. tender.pre_flow.time = cur.begin_time;
  102. } else {
  103. const pre = await this.ctx.service.stageAudit.getAuditorByOrder(stage.id, cur.order - 1, cur.times);
  104. if (pre) tender.pre_flow = { name: pre.name, time: pre.end_time };
  105. }
  106. } else {
  107. tender.cur_flow.name = '';
  108. }
  109. }
  110. }
  111. async _listDetail(view, modal = '') {
  112. try {
  113. // 获取用户新建标段权利
  114. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  115. const userPermission = accountInfo !== undefined && accountInfo.permission !== ''
  116. ? JSON.parse(accountInfo.permission) : null;
  117. const tenderList = await this.ctx.service.tender.getList('', userPermission, this.ctx.session.sessionUser.is_admin);
  118. for (const t of tenderList) {
  119. if (t.user_id === this.ctx.session.sessionUser.accountId && (
  120. t.ledger_status === auditConst.ledger.status.checkNo || t.ledger_status === auditConst.ledger.status.uncheck)) {
  121. const sum = await this.ctx.service.ledger.addUp({ tender_id: t.id/* , is_leaf: true*/ });
  122. t.total_price = sum.total_price;
  123. t.deal_tp = sum.deal_tp;
  124. }
  125. t.advance_tp = await this.ctx.service.advance.getSumAdvance(t.id);
  126. if (t.ledger_status === auditConst.ledger.status.checked) {
  127. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  128. if (t.lastStage && t.lastStage.status === auditConst.stage.status.uncheck &&
  129. t.lastStage.user_id !== this.ctx.session.sessionUser.accountId) {
  130. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id);
  131. }
  132. if (t.lastStage) await this.ctx.service.stage.checkStageGatherData(t.lastStage);
  133. t.completeStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
  134. }
  135. if (t.lastStage) {
  136. await this._getStageAuditInfo(t, t.lastStage);
  137. } else {
  138. await this._getLedgerAuditInfo(t);
  139. }
  140. }
  141. const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  142. const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  143. const renderData = {
  144. tenderList,
  145. tenderConst,
  146. settingConst,
  147. categoryData,
  148. measureType: tenderConst.measureType,
  149. jsFiles: this.app.jsFiles.common.concat(this.jsFiles),
  150. auditConst,
  151. userPermission,
  152. valuations,
  153. uid: this.ctx.session.sessionUser.accountId,
  154. pid: this.ctx.session.sessionProject.id,
  155. };
  156. await this.layout(view, renderData, modal);
  157. } catch (err) {
  158. this.log(err);
  159. this.ctx.redirect('/dashboard');
  160. }
  161. }
  162. async _list(view, renderData, modal = '', list_status = '') {
  163. try {
  164. renderData.tenderList = await this.ctx.service.tender.getList(list_status, renderData.userPermission, this.ctx.session.sessionUser.is_admin);
  165. for (const t of renderData.tenderList) {
  166. if (t.ledger_status === auditConst.ledger.status.checked) {
  167. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  168. t.completeStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
  169. }
  170. if (t.lastStage) {
  171. if (t.lastStage.status === auditConst.stage.status.uncheck) {
  172. const status_name = await this.ctx.service.projectAccount.getAccountInfoById(t.lastStage.user_id);
  173. t.status_users = status_name ? status_name.name : '';
  174. // const status_name = await this.ctx.service.stageAudit.getStatusName(t.lastStage.id, t.lastStage.times - 1);
  175. // t.status_users = status_name ? status_name.name : '';
  176. } else {
  177. const status_name = await this.ctx.service.stageAudit.getAuditorByStatus(t.lastStage.id, t.lastStage.status, t.lastStage.times);
  178. t.status_users = status_name ? status_name.name : '';
  179. }
  180. } else {
  181. if (t.ledger_status !== auditConst.ledger.status.uncheck) {
  182. const status_name = await this.ctx.service.ledgerAudit.getStatusName(t.id, t.ledger_times);
  183. t.status_users = status_name ? status_name.name : '';
  184. }
  185. }
  186. }
  187. renderData.categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  188. renderData.valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  189. renderData.tenderConst = tenderConst;
  190. renderData.settingConst = settingConst;
  191. renderData.measureType = tenderConst.measureType;
  192. renderData.jsFiles = this.app.jsFiles.common.concat(this.jsFiles);
  193. renderData.auditConst = auditConst;
  194. renderData.uid = this.ctx.session.sessionUser.accountId;
  195. renderData.pid = this.ctx.session.sessionProject.id;
  196. await this.layout(view, renderData, modal);
  197. } catch (err) {
  198. this.log(err);
  199. this.ctx.redirect('/dashboard');
  200. }
  201. }
  202. async listDefault(ctx) {
  203. this.jsFiles = this.app.jsFiles.tender.list;
  204. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  205. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  206. const renderData = {
  207. accountInfo,
  208. userPermission,
  209. };
  210. await this._list('tender/index.ejs', renderData, 'tender/modal.ejs');
  211. }
  212. /**
  213. * 标段概况(Get)
  214. *
  215. * @param {object} ctx - egg全局变量
  216. * @return {void}
  217. */
  218. async listInfo(ctx) {
  219. this.jsFiles = this.app.jsFiles.tender.info;
  220. await this._listDetail('tender/info.ejs', 'tender/modal.ejs');
  221. }
  222. /**
  223. * 计量进度(Get)
  224. *
  225. * @param ctx
  226. * @return {Promise<void>}
  227. */
  228. async listProgress(ctx) {
  229. this.jsFiles = this.app.jsFiles.tender.progress;
  230. await this._listDetail('tender/progress.ejs', 'tender/modal.ejs');
  231. }
  232. /**
  233. * 标段管理(Get)
  234. *
  235. * @param ctx
  236. * @return {Promise<void>}
  237. */
  238. async listManage(ctx) {
  239. this.jsFiles = this.app.jsFiles.tender.manage;
  240. // 先判断权限
  241. // 获取用户新建标段权利
  242. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  243. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  244. if (userPermission !== null && userPermission.tender !== undefined && userPermission.tender.indexOf('1') !== -1) {
  245. const renderData = {
  246. accountInfo,
  247. userPermission,
  248. };
  249. await this._list('tender/manage.ejs', renderData, 'tender/manage_modal.ejs', 'manage');
  250. // 获取用户新建标段权利
  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. //
  254. // const tenderList = await this.ctx.service.tender.getList('manage', userPermission);
  255. // for (const t of tenderList) {
  256. // t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);
  257. // t.completeStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
  258. // }
  259. // const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  260. // const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
  261. // const renderData = {
  262. // tenderList,
  263. // tenderConst,
  264. // settingConst,
  265. // categoryData,
  266. // measureType: tenderConst.measureType,
  267. // jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.manage),
  268. // auditConst,
  269. // userPermission,
  270. // valuations,
  271. // };
  272. // await this.layout('tender/manage.ejs', renderData, 'tender/manage_modal.ejs');
  273. } else {
  274. this.ctx.redirect(ctx.request.header.referer);
  275. }
  276. }
  277. /**
  278. * 新增标段(Ajax)
  279. *
  280. * @param ctx
  281. * @return {Promise<void>}
  282. */
  283. async addTender(ctx) {
  284. try {
  285. const responseData = {
  286. err: 0, msg: '', data: null,
  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. throw '当前用户没有创建标段的权限';
  293. }
  294. const data = JSON.parse(ctx.request.body.data);
  295. if (!data.name || data.name === '' || !data.valuation) {
  296. throw '标段信息不完整';
  297. }
  298. responseData.data = await ctx.service.tender.add(data);
  299. ctx.body = responseData;
  300. } catch (error) {
  301. this.log(error);
  302. ctx.body = { err: 1, msg: error.toString(), data: null };
  303. }
  304. }
  305. /**
  306. * 编辑标段(Ajax)
  307. *
  308. * @param ctx
  309. * @return {Promise<void>}
  310. */
  311. async updateTender(ctx) {
  312. try {
  313. const responseData = {
  314. err: 0, msg: '', data: null,
  315. };
  316. const data = JSON.parse(ctx.request.body.data);
  317. if (!data.id) {
  318. throw '提交信息错误';
  319. }
  320. if (!data.name || data.name === '') {
  321. throw '标段信息不完整';
  322. }
  323. if (await ctx.service.tender.save(data, data.id)) {
  324. responseData.data = await ctx.service.tender.getTender(data.id);
  325. }
  326. ctx.body = responseData;
  327. } catch (error) {
  328. this.log(error);
  329. ctx.body = { err: 1, msg: error.toString(), data: null };
  330. }
  331. }
  332. /**
  333. * 删除标段(Ajax)
  334. *
  335. * @param ctx
  336. * @return {Promise<void>}
  337. */
  338. async deleteTender(ctx) {
  339. try {
  340. const data = JSON.parse(ctx.request.body.data),
  341. result = [];
  342. if (!(data instanceof Array) && (data.length === 0)) {
  343. throw '提交数据有误';
  344. }
  345. for (const id of data) {
  346. if (await ctx.service.tender.deleteTenderNoBackup(id)) {
  347. result.push(id);
  348. }
  349. }
  350. ctx.body = { err: 0, msg: '', data: result };
  351. } catch (err) {
  352. ctx.body = { err: 1, msg: err.toString(), data: [] };
  353. }
  354. }
  355. /**
  356. * 标段概况(Get)
  357. *
  358. * @param ctx
  359. * @return {Promise<void>}
  360. */
  361. async tenderInfo(ctx) {
  362. try {
  363. const tender = ctx.tender.data;
  364. if (tender.user_id === this.ctx.session.sessionUser.accountId && (
  365. tender.ledger_status === auditConst.ledger.status.checkNo || tender.ledger_status === auditConst.ledger.status.uncheck)) {
  366. const sum = await this.ctx.service.ledger.addUp({ tender_id: tender.id/* , is_leaf: true*/ });
  367. tender.total_price = sum.total_price;
  368. tender.deal_tp = sum.deal_tp;
  369. }
  370. const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
  371. const lastStage = stages.length > 0 ? stages[0] : null; // await ctx.service.stage.getLastestStage(ctx.tender.id);
  372. if (lastStage) {
  373. await this.ctx.service.stage.checkStageGatherData(lastStage);
  374. tender.gather_tp = ctx.helper.add(lastStage.contract_tp, lastStage.qc_tp);
  375. tender.end_contract_tp = ctx.helper.add(lastStage.contract_tp, lastStage.pre_contract_tp);
  376. tender.end_qc_tp = ctx.helper.add(lastStage.qc_tp, lastStage.pre_qc_tp);
  377. tender.end_gather_tp = ctx.helper.add(tender.end_contract_tp, tender.end_qc_tp);
  378. tender.pre_gather_tp = ctx.helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
  379. tender.yf_tp = lastStage.yf_tp;
  380. tender.qc_ratio = ctx.helper.mul(ctx.helper.div(tender.end_qc_tp, ctx.tender.info.deal_param.contractPrice, 2), 100);
  381. tender.sum = ctx.helper.add(tender.total_price, tender.end_qc_tp);
  382. tender.pre_ratio = ctx.helper.mul(ctx.helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
  383. tender.cur_ratio = ctx.helper.mul(ctx.helper.div(tender.gather_tp, tender.sum, 2), 100);
  384. tender.other_tp = ctx.helper.sub(ctx.helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
  385. tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
  386. tender.end_yf_tp = ctx.helper.add(lastStage.yf_tp, lastStage.pre_yf_tp);
  387. tender.end_sf_tp = ctx.helper.add(lastStage.sf_tp, lastStage.pre_sf_tp);
  388. const change_tp = await ctx.service.change.getChangeTp(tender.id);
  389. tender.undone_tp = ctx.helper.sub(ctx.helper.sub(ctx.helper.add(tender.total_price, change_tp), tender.end_contract_tp), tender.end_qc_tp);
  390. if (lastStage.status === auditConst.stage.status.uncheck) {
  391. const status_name = await this.ctx.service.projectAccount.getAccountInfoById(lastStage.user_id);
  392. lastStage.status_users = status_name ? status_name.name : '';
  393. lastStage.auditors = [];
  394. } else {
  395. lastStage.status = lastStage.status === auditConst.stage.status.checkNoPre ? auditConst.stage.status.checking : lastStage.status;
  396. let cur;
  397. if (lastStage.status === auditConst.stage.status.checked) {
  398. cur = await this.ctx.service.stageAudit.getLastestAuditor(lastStage.id, lastStage.times, auditConst.stage.status.checked);
  399. } else if (lastStage.status === auditConst.stage.status.checking) {
  400. cur = await this.ctx.service.stageAudit.getCurAuditor(lastStage.id, lastStage.times);
  401. } else {
  402. cur = await this.ctx.service.stageAudit.getAuditorByStatus(lastStage.id, lastStage.status, lastStage.times);
  403. }
  404. // const status_name = await this.ctx.service.stageAudit.getAuditorByStatus(lastStage.id, lastStage.status, lastStage.times);
  405. lastStage.status_users = cur ? cur.name : '';
  406. const times = lastStage.status === auditConst.stage.status.checkNo ? lastStage.times - 1 : lastStage.times;
  407. lastStage.auditors = await ctx.service.stageAudit.getFinalAuditGroup(lastStage.id, times);
  408. }
  409. } else {
  410. if (tender.ledger_status !== auditConst.ledger.status.uncheck) {
  411. const status_name = await this.ctx.service.ledgerAudit.getStatusName(tender.id, tender.ledger_times);
  412. tender.status_users = status_name ? status_name.name : '';
  413. const times = tender.ledger_status === auditConst.ledger.status.checkNo ? tender.ledger_times - 1 : tender.ledger_times;
  414. tender.auditors = await ctx.service.ledgerAudit.getFinalAuditGroup(tender.id, times);
  415. } else {
  416. const status_name = await this.ctx.service.projectAccount.getAccountInfoById(tender.user_id);
  417. tender.status_users = status_name ? status_name.name : '';
  418. }
  419. }
  420. const tiModel = new tenderInfoModel(ctx);
  421. const gclChapter = await tiModel.gatherChapter();
  422. const monthProgress = [];
  423. for (const s of stages) {
  424. if (s.s_time) {
  425. let progress = monthProgress.find(function(x) {
  426. return x.month === s.s_time;
  427. });
  428. if (!progress) {
  429. progress = { month: s.s_time };
  430. monthProgress.push(progress);
  431. }
  432. progress.tp = ctx.helper.add(ctx.helper.add(progress.tp, s.contract_tp), s.qc_tp);
  433. }
  434. }
  435. monthProgress.sort(function(x, y) {
  436. return Date.parse(x.month) - Date.parse(y.month);
  437. });
  438. let sum = 0;
  439. for (const p of monthProgress) {
  440. p.ratio = ctx.helper.mul(ctx.helper.div(p.tp, tender.sum, 4), 100);
  441. sum = ctx.helper.add(sum, p.tp);
  442. p.end_tp = sum;
  443. p.end_ratio = ctx.helper.mul(ctx.helper.div(p.end_tp, tender.sum, 4), 100);
  444. }
  445. const revise = await ctx.service.ledgerRevise.getLastestRevise(tender.id);
  446. const tenders = await ctx.service.tender.getList('', null, 1);
  447. const categoryData = await ctx.service.category.getAllCategory(ctx.session.sessionProject.id);
  448. // 变更图表数据
  449. const change_done_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.checked);
  450. const change_doing_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.checking);
  451. const change_uncheck_total = await ctx.service.change.getCountByStatus2(tender.id, auditConst.filter.status.uncheck);
  452. const change_status_total = [
  453. { num: change_uncheck_total, name: '待上报' },
  454. { num: change_doing_total, name: '审批中' },
  455. { num: change_done_total, name: '已完成' },
  456. ];
  457. const change_common_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.common.value);
  458. const change_more_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.more.value);
  459. const change_great_total = await ctx.service.change.getCountByQuality(tender.id, changeConst.quality.great.value);
  460. const change_quality_total = [
  461. { num: change_common_total, name: '一般变更' },
  462. { num: change_more_total, name: '较大变更' },
  463. { num: change_great_total, name: '重大变更' },
  464. ];
  465. // 调差最新期数据
  466. const materials = await ctx.service.material.getValidMaterials(ctx.tender.id);
  467. let materialData = null;
  468. if (materials && materials.length > 0) {
  469. materialData = materials[0];
  470. materialData.curAuditor = await ctx.service.materialAudit.getAuditorByStatus(materialData.id, materialData.status, materialData.times);
  471. const times = materialData.status === auditConst.material.status.checkNo ? materialData.times - 1 : materialData.times;
  472. materialData.auditors = materialData.status === auditConst.material.status.uncheck ? [] : await ctx.service.materialAudit.getFinalAuditGroup(materialData.id, times);
  473. }
  474. // 修订完成数目
  475. // const reviseNum = await ctx.service.ledgerRevise.count({ tid: tender.id, status: auditConst.revise.status.checked });
  476. // 计量完成概况
  477. // tender.total_price
  478. const stage_total = [
  479. { num: tender.end_contract_tp ? tender.end_contract_tp : 0, name: '合同完成' },
  480. { num: tender.end_qc_tp ? tender.end_qc_tp : 0, name: '变更完成' },
  481. { num: tender.undone_tp ? tender.undone_tp : 0, name: '未完成' },
  482. ];
  483. // 地图
  484. const tenderALLInfo = await ctx.service.tender.getDataById(tender.id);
  485. const hadMap = tenderALLInfo.had_map === 1 ? 0 : 1;
  486. const tenderMapList = await ctx.service.tenderMap.getAllDataByCondition({ where: { tid: tender.id } });
  487. // 默认坐标,否则则取办事处坐标
  488. const projectData = await ctx.service.project.getDataById(ctx.session.sessionProject.id);
  489. let map_json = {
  490. province: mapConst.map[0].province,
  491. lng: mapConst.map[0].lng,
  492. lat: mapConst.map[0].lat,
  493. level: 15,
  494. };
  495. if (projectData.map_json) {
  496. map_json = JSON.parse(projectData.map_json);
  497. } else {
  498. const mapInfo = ctx.helper._.find(mapConst.map, { office: projectData.manager_office });
  499. if (mapInfo) {
  500. map_json.province = mapInfo.province;
  501. map_json.lng = mapInfo.lng;
  502. map_json.lat = mapInfo.lat;
  503. }
  504. }
  505. const renderData = {
  506. tenders,
  507. categoryData,
  508. tender,
  509. revise,
  510. tenderInfo: ctx.tender.info,
  511. tenderMenu: this.menu.tenderMenu,
  512. preUrl: '/tender/' + ctx.tender.id,
  513. cooperation: ctx.session.sessionUser.cooperation,
  514. lastStage,
  515. stages: stages.reverse(),
  516. monthProgress,
  517. audit: auditConst,
  518. change_status_total,
  519. change_quality_total,
  520. materialData,
  521. // reviseNum,
  522. stage_total,
  523. hadMap,
  524. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.tenderInfo),
  525. gclChapter,
  526. tenderMapList,
  527. map_json,
  528. };
  529. if (ctx.session.sessionUser.is_admin) {
  530. renderData.tourists = await ctx.service.tenderTourist.getTourists(tender.id);
  531. for (const t of renderData.tourists) {
  532. t.permission = await ctx.service.tenderTourist.getTouristPermission(t);
  533. }
  534. // 获取所有项目参与者
  535. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  536. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  537. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  538. });
  539. const accountGroupList = accountGroup.map((item, idx) => {
  540. const groupList = accountList.filter(item => item.account_group === idx);
  541. return { groupName: item, groupList };
  542. });
  543. renderData.accountList = accountList;
  544. renderData.accountGroup = accountGroupList;
  545. }
  546. if (ctx.session.sessionProject.page_show.xxjd && ctx.session.sessionUser.is_admin) {
  547. // 投资进度内容
  548. renderData.scheduleAuditList = await ctx.service.scheduleAudit.getAllDataByCondition({ where: { tid: tender.id } });
  549. renderData.scPermission = scheduleConst.permission;
  550. }
  551. await this.layout('tender/detail.ejs', renderData, 'tender/detail_modal.ejs');
  552. } catch (error) {
  553. this.log(error);
  554. this.ctx.redirect('/list');
  555. }
  556. }
  557. /**
  558. * 保存标段属性等(Ajax)
  559. *
  560. * @param ctx
  561. * @return {Promise<void>}
  562. */
  563. async saveTenderInfo(ctx) {
  564. try {
  565. const data = JSON.parse(ctx.request.body.data);
  566. if (!data) {
  567. throw '提交数据错误';
  568. }
  569. // 针对查阅所有标段者但非原报和审批人提示
  570. const times = ctx.tender.data.ledger_status === auditConst.ledger.status.checkNo ? ctx.tender.data.ledger_times - 1 : ctx.tender.data.ledger_times;
  571. const auditors = await this.service.ledgerAudit.getAuditors(ctx.tender.id, times);
  572. const auditorsId = ctx.helper._.map(auditors, 'audit_id');
  573. const stageAuditors = await this.service.stageAudit.getAllAuditors(ctx.tender.id);
  574. const stageAUditorsId = ctx.helper._.map(stageAuditors, 'aid');
  575. const accountId = ctx.session.sessionUser.accountId;
  576. if (auditorsId.indexOf(accountId) === -1 && ctx.tender.data.user_id !== accountId &&
  577. stageAUditorsId.indexOf(accountId) === -1) {
  578. throw '您无权修改标段设置内容';
  579. }
  580. if (ctx.tender.data.ledger_status === auditConst.ledger.status.checked) {
  581. if (data.deal_param) {
  582. const lastStage = await this.ctx.service.stage.getLastestStage(ctx.tender.id, true);
  583. if (lastStage) {
  584. if (lastStage.order > 1 || (lastStage.status === auditConst.stage.status.checked || lastStage.status === auditConst.stage.status.checking)) throw '第一期上报后不可修改合同参数';
  585. if (lastStage.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改合同参数';
  586. }
  587. }
  588. }
  589. if (data.decimal) {
  590. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改小数位数';
  591. await ctx.service.tenderInfo.saveDecimal(ctx.tender.id, data.decimal, ctx.tender.info.decimal);
  592. } else if (data.precision) {
  593. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) throw '仅原报可修改清单精度';
  594. await ctx.service.tenderInfo.savePrecision(ctx.tender.id,
  595. data.precision, ctx.tender.info.precision, ctx.tender.info.decimal);
  596. } else {
  597. await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, data);
  598. }
  599. ctx.body = { err: 0, msg: '', data: JSON.parse(ctx.request.body.data) };
  600. } catch (err) {
  601. this.log(err);
  602. ctx.body = this.ajaxErrorBody(err, '保存标段设置失败');
  603. }
  604. }
  605. async saveTenderInfo2(ctx) {
  606. try {
  607. const data = JSON.parse(ctx.request.body.data);
  608. if (!data || (!data.ledger_check && !data.fun_rela)) throw '提交数据错误';
  609. if (!ctx.session.sessionUser.is_admin) throw '您无权修改该内容';
  610. const updateData = {};
  611. if (data.ledger_check) updateData.ledger_check = data.ledger_check;
  612. if (data.fun_rela) updateData.fun_rela = data.fun_rela;
  613. await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, data);
  614. ctx.body = { err: 0, msg: '', data: JSON.parse(ctx.request.body.data) };
  615. } catch (err) {
  616. this.log(err);
  617. ctx.body = this.ajaxErrorBody(err, '保存失败');
  618. }
  619. }
  620. /**
  621. * 设置标段计量类型并调整到标段概况(Get)
  622. *
  623. * @param ctx
  624. * @return {Promise<void>}
  625. */
  626. async tenderType(ctx) {
  627. try {
  628. const tenderId = ctx.params.id,
  629. type = ctx.query.type;
  630. if (!tenderId) {
  631. throw '当前未打开标段';
  632. }
  633. await ctx.service.tender.checkTender(tenderId);
  634. if (!ctx.tender) {
  635. throw '标段数据错误';
  636. }
  637. if (!ctx.tender.measure_type) {
  638. await ctx.service.tender.setTenderType(ctx.tender, parseInt(type));
  639. }
  640. ctx.redirect('/tender/' + tenderId);
  641. } catch (error) {
  642. ctx.helper.log(error);
  643. this.postError(error, '设置标段类型错误');
  644. ctx.redirect('/list');
  645. }
  646. }
  647. /**
  648. * 标段协作办公
  649. *
  650. * @param {Object} ctx - egg全局变量
  651. * @return {void}
  652. */
  653. async tenderCooperation(ctx) {
  654. const tenderId = ctx.params.id;
  655. try {
  656. if (!ctx.session.sessionUser.cooperation) {
  657. throw '权限不足';
  658. }
  659. const tender = await ctx.service.tender.getDataById(tenderId);
  660. const user = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  661. // 获取已参与协作用户列表
  662. const cooperationArray = [];
  663. if (tender.cooperation !== null && tender.cooperation !== '') {
  664. const cooperationList = JSON.parse(tender.cooperation);
  665. for (const cl in cooperationList) {
  666. const clArray = [];
  667. for (const audit of cooperationList[cl]) {
  668. const userInfo = await ctx.service.projectAccount.getDataById(audit);
  669. clArray.push(userInfo);
  670. }
  671. cooperationArray[cl] = clArray;
  672. }
  673. }
  674. const renderData = {
  675. user,
  676. tender,
  677. tenderMenu: this.menu.tenderMenu,
  678. preUrl: '/tender/' + tenderId,
  679. tenderPermissionList: accountPermission.tenderPermissionList,
  680. cooperationArray,
  681. };
  682. await this.layout('tender/cooperation.ejs', renderData, 'tender/cooperationModal.ejs');
  683. } catch (error) {
  684. ctx.helper.log(error);
  685. this.ctx.redirect('/tender/' + tenderId);
  686. }
  687. }
  688. /**
  689. * 添加标段操作
  690. *
  691. * @param {Object} ctx - egg全局变量
  692. * @return {void}
  693. */
  694. async add(ctx) {
  695. try {
  696. const rule = ctx.service.tender.rule('add');
  697. ctx.helper.validate(rule);
  698. const result = ctx.service.tender.add(ctx.request.body);
  699. if (!result) {
  700. throw '新增标段失败';
  701. }
  702. } catch (error) {
  703. ctx.helper.log(error);
  704. this.setMessage(error.toString(), this.messageType.ERROR);
  705. }
  706. ctx.redirect(ctx.request.header.referer);
  707. }
  708. /**
  709. * 保存标段操作
  710. *
  711. * @param {Object} ctx - egg全局变量
  712. * @return {void}
  713. */
  714. async save(ctx) {
  715. let id = ctx.request.body.tenderId;
  716. id = parseInt(id);
  717. try {
  718. if (isNaN(id) || id < 0) {
  719. throw '参数错误';
  720. }
  721. // 获取数据规则
  722. const rule = ctx.service.tender.rule('save');
  723. ctx.validate(rule);
  724. const result = await ctx.service.tender.save(ctx.request.body, id);
  725. if (!result) {
  726. throw '保存标段数据失败';
  727. }
  728. this.setMessage('保存标段数据成功', this.messageType.SUCCESS);
  729. } catch (error) {
  730. this.postError(error, '保存标段数据失败');
  731. }
  732. ctx.redirect(ctx.request.header.referer);
  733. }
  734. /**
  735. * 删除标段
  736. *
  737. * @param {Object} ctx -egg全局变量
  738. * @return {void}
  739. */
  740. async delete(ctx) {
  741. let id = ctx.request.body.tenderId;
  742. id = parseInt(id);
  743. try {
  744. if (isNaN(id) || id <= 0) {
  745. throw '参数错误';
  746. }
  747. const result = ctx.service.tender.deleteTenderById(id);
  748. if (!result) {
  749. throw '删除标段失败';
  750. }
  751. this.setMessage('删除标段成功', this.messageType.SUCCESS);
  752. } catch (error) {
  753. this.postError(error, '删除标段失败');
  754. }
  755. ctx.redirect(ctx.request.header.referer);
  756. }
  757. async rule(ctx) {
  758. const responseData = {
  759. err: 0,
  760. msg: '',
  761. data: {},
  762. };
  763. try {
  764. const tenderId = ctx.session.sessionUser.tenderId;
  765. if (!tenderId) {
  766. throw '当前未打开标段';
  767. }
  768. const data = JSON.parse(ctx.request.body.data);
  769. if (!data.rule || !JSON.parse(data.data).length || !codeRuleConst.ruleField[data.rule]) {
  770. throw '请选择组件再添加';
  771. }
  772. if (!data.connector) {
  773. throw '请选择连接符';
  774. }
  775. const updateData = {
  776. id: tenderId,
  777. };
  778. updateData[codeRuleConst.ruleField[data.rule]] = data.data;
  779. updateData.c_connector = data.connector;
  780. updateData.c_rule_first = 0;
  781. const result = await ctx.service.tender.db.update(ctx.service.tender.tableName, updateData);
  782. if (result.affectedRows !== 1) {
  783. throw '更新规则失败';
  784. }
  785. } catch (err) {
  786. ctx.helper.log(err);
  787. responseData.err = 1;
  788. responseData.msg = err.toString();
  789. }
  790. ctx.body = responseData;
  791. }
  792. async ruleFirst(ctx) {
  793. const responseData = {
  794. err: 0,
  795. msg: '',
  796. data: {},
  797. };
  798. try {
  799. const tenderId = ctx.session.sessionUser.tenderId;
  800. if (!tenderId) {
  801. throw '当前未打开标段';
  802. }
  803. const updateData = {
  804. id: tenderId,
  805. };
  806. updateData.c_rule_first = 0;
  807. const result = await ctx.service.tender.db.update(ctx.service.tender.tableName, updateData);
  808. if (result.affectedRows !== 1) {
  809. throw '更新规则失败';
  810. }
  811. } catch (err) {
  812. ctx.helper.log(err);
  813. responseData.err = 1;
  814. responseData.msg = err.toString();
  815. }
  816. ctx.body = responseData;
  817. }
  818. async shenpiSet(ctx) {
  819. if (ctx.session.sessionUser.is_admin === 0) {
  820. ctx.request.headers.referer ? ctx.redirect(ctx.request.headers.referer) : ctx.redirect('/list');
  821. }
  822. // 获取所有项目参与者
  823. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  824. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  825. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  826. });
  827. const accountGroupList = accountGroup.map((item, idx) => {
  828. const groupList = accountList.filter(item => item.account_group === idx);
  829. return { groupName: item, groupList };
  830. });
  831. // 获取固定审批流 or 固定终审
  832. for (const sp of shenpiConst.sp_lc) {
  833. sp.status = ctx.tender.info.shenpi ? ctx.tender.info.shenpi[sp.code] : shenpiConst.sp_status.sqspr;
  834. if (sp.status === shenpiConst.sp_status.gdspl) {
  835. sp.auditList = await ctx.service.shenpiAudit.getAuditList(ctx.tender.id, sp.type, sp.status);
  836. } else if (sp.status === shenpiConst.sp_status.gdzs) {
  837. sp.audit = await ctx.service.shenpiAudit.getAudit(ctx.tender.id, sp.type, sp.status);
  838. }
  839. }
  840. const tenders = await ctx.service.tender.getList('', null, 1);
  841. const removeTenders = [];
  842. for (const tender of tenders) {
  843. const shenpiInfo = await ctx.service.tenderInfo.getTenderShenpiInfo(tender.id);
  844. if (!shenpiInfo) {
  845. removeTenders.push(tender.id);
  846. } else {
  847. tender.shenpiInfo = shenpiInfo;
  848. // 获取所有的固定审批流或固定终审
  849. const shenpiauditList = {};
  850. for (const shenpi in tender.shenpiInfo) {
  851. if (tender.shenpiInfo[shenpi] === shenpiConst.sp_status.gdspl) {
  852. const shenpiList = await ctx.service.shenpiAudit.getAllDataByCondition({ where: { tid: tender.id, sp_type: shenpiConst.sp_type[shenpi], sp_status: tender.shenpiInfo[shenpi] } });
  853. const shenpiIdList = ctx.helper._.map(shenpiList, 'audit_id');
  854. shenpiauditList[shenpi] = shenpiIdList.length ? shenpiIdList : null;
  855. } else if (tender.shenpiInfo[shenpi] === shenpiConst.sp_status.gdzs) {
  856. const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: tender.id, sp_type: shenpiConst.sp_type[shenpi], sp_status: tender.shenpiInfo[shenpi] });
  857. shenpiauditList[shenpi] = shenpiInfo && shenpiInfo.audit_id ? [shenpiInfo.audit_id] : null;
  858. }
  859. }
  860. tender.shenpiauditList = shenpiauditList;
  861. }
  862. }
  863. if (removeTenders.length > 0) {
  864. ctx.helper._.remove(tenders, function(n) {
  865. return removeTenders.indexOf(n.id) !== -1;
  866. });
  867. }
  868. const categoryData = await ctx.service.category.getAllCategory(ctx.session.sessionProject.id);
  869. // 是否修订中
  870. const lastRevise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  871. const revising = (lastRevise && lastRevise.status !== auditConst.revise.status.checked) || false;
  872. const cooperationNum = await ctx.service.ledgerCooperation.count({ tid: ctx.tender.id, status: 1 });
  873. const renderData = {
  874. shenpi: shenpiConst,
  875. accountList,
  876. accountGroup: accountGroupList,
  877. tenders,
  878. categoryData,
  879. auditConst,
  880. revising,
  881. measureType,
  882. cooperationNum,
  883. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.shenpi),
  884. };
  885. await this.layout('tender/shenpi.ejs', renderData, 'tender/shenpi_modal.ejs');
  886. }
  887. async saveTenderInfoShenpi(ctx) {
  888. try {
  889. const data = JSON.parse(ctx.request.body.data);
  890. if (!data) {
  891. throw '提交数据错误';
  892. }
  893. // 判断修改权限
  894. if (ctx.session.sessionUser.is_admin === 0) {
  895. throw '你没有权限修改审批流程';
  896. }
  897. // let postData = {};
  898. // if (!ctx.tender.info.shenpi) {
  899. // for (const sp of shenpiConst.sp_lc) {
  900. // if (sp.code === data.code) {
  901. // postData[sp.code] = data.status;
  902. // } else {
  903. // postData[sp.code] = shenpiConst.sp_status.sqspr;
  904. // }
  905. // }
  906. // } else {
  907. const postData = ctx.tender.info.shenpi;
  908. postData[data.code] = data.status;
  909. if (data.code === shenpiConst.sp_lc[shenpiConst.sp_type.stage - 1].code) {
  910. const status = parseInt(data.status) === shenpiConst.sp_status.gdspl ? 1 : 0;
  911. await ctx.service.ledgerCooperation.changeAllStatus(status);
  912. }
  913. // }
  914. // console.log(postData);
  915. await ctx.service.tenderInfo.saveTenderInfo(ctx.tender.id, { shenpi: postData });
  916. let auditList = [];
  917. if (data.status === shenpiConst.sp_status.gdspl) {
  918. auditList = await ctx.service.shenpiAudit.getAuditList(ctx.tender.id, shenpiConst.sp_type[data.code], data.status);
  919. } else if (data.status === shenpiConst.sp_status.gdzs) {
  920. auditList = await ctx.service.shenpiAudit.getAudit(ctx.tender.id, shenpiConst.sp_type[data.code], data.status);
  921. }
  922. ctx.body = { err: 0, msg: '', data: auditList };
  923. } catch (err) {
  924. this.log(err);
  925. ctx.body = this.ajaxErrorBody(err, '保存审批流程设置失败');
  926. }
  927. }
  928. async saveShenpiAudit(ctx) {
  929. try {
  930. const data = JSON.parse(ctx.request.body.data);
  931. if (!data) {
  932. throw '提交数据错误';
  933. }
  934. // 判断修改权限
  935. if (ctx.session.sessionUser.is_admin === 0) {
  936. throw '你没有权限修改审批流程';
  937. }
  938. let info = '';
  939. switch (data.type) {
  940. case 'add':
  941. const result = await ctx.service.shenpiAudit.addAudit(data);
  942. if (result) {
  943. throw '添加审批人失败';
  944. }
  945. break;
  946. case 'del':
  947. await ctx.service.shenpiAudit.removeAudit(data);
  948. break;
  949. case 'copy2ot':
  950. await ctx.service.shenpiAudit.copyAudit2otherTender(data);
  951. break;
  952. case 'copy2os':
  953. await ctx.service.shenpiAudit.copyAudit2otherShenpi(data);
  954. break;
  955. case 'pwd':
  956. info = await ctx.service.ledgerCooperation.save(data);
  957. break;
  958. case 'company':
  959. info = await ctx.service.ledgerCooperation.saveCompany(data);
  960. break;
  961. default:break;
  962. }
  963. ctx.body = { err: 0, msg: '', data: info };
  964. } catch (err) {
  965. this.log(err);
  966. ctx.body = this.ajaxErrorBody(err, '保存审批流程设置失败');
  967. }
  968. }
  969. /**
  970. * 签名,上传图片 (Ajax)
  971. * @param ctx
  972. * @return {Promise<void>}
  973. */
  974. async saveCooperateSign(ctx) {
  975. try {
  976. const stream = await ctx.getFileStream();
  977. const create_time = Date.parse(new Date()) / 1000;
  978. const id = stream.fields.id;
  979. const fileInfo = path.parse(stream.filename);
  980. const fileName = path.join('public/upload', ctx.tender.id.toString(), 'sign', 'signImg_' + create_time + fileInfo.ext);
  981. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', fileName));
  982. if (stream) {
  983. await sendToWormhole(stream);
  984. }
  985. await ctx.service.ledgerCooperation.saveSign(id, fileName);
  986. ctx.body = { err: 0, msg: '', data: fileName };
  987. } catch (err) {
  988. this.log(err);
  989. ctx.body = { err: 1, msg: err.toString(), data: null };
  990. }
  991. }
  992. /**
  993. * 拷贝设置
  994. * @param {object} ctx - 上下文
  995. */
  996. async copyTender(ctx) {
  997. try {
  998. const id = ctx.tender.data.id;
  999. const { id: copy_id = '', type: typeArr = [] } = JSON.parse(ctx.request.body.data);
  1000. await ctx.service.tenderInfo.copyTenderHandler(id, copy_id, typeArr);
  1001. ctx.body = { err: 0, msg: '' };
  1002. } catch (error) {
  1003. this.log(error);
  1004. ctx.body = this.ajaxErrorBody(error, '保存审批流程设置失败');
  1005. }
  1006. }
  1007. /**
  1008. * 游客账号设置
  1009. * @param {object} ctx - 上下文
  1010. */
  1011. async saveTourist(ctx) {
  1012. try {
  1013. const data = JSON.parse(ctx.request.body.data);
  1014. if (!data) {
  1015. throw '提交数据错误';
  1016. }
  1017. // 判断修改权限
  1018. if (ctx.session.sessionUser.is_admin === 0) {
  1019. throw '你没有权限修改游客账号';
  1020. }
  1021. let info = '';
  1022. switch (data.type) {
  1023. case 'add':
  1024. const result = await ctx.service.tenderTourist.addAudit(data);
  1025. if (!result) {
  1026. throw '添加审批人失败';
  1027. }
  1028. info = result;
  1029. break;
  1030. case 'del':
  1031. await ctx.service.tenderTourist.removeAudit(data);
  1032. break;
  1033. case 'permission':
  1034. await ctx.service.tenderTourist.setPermission(data);
  1035. break;
  1036. default:break;
  1037. }
  1038. ctx.body = { err: 0, msg: '', data: info };
  1039. } catch (err) {
  1040. this.log(err);
  1041. ctx.body = this.ajaxErrorBody(err, '保存游客账号设置失败');
  1042. }
  1043. }
  1044. /**
  1045. * 获取部位明细数据(Ajax)
  1046. *
  1047. * @param ctx
  1048. * @return {Promise<void>}
  1049. */
  1050. async loadLedgerData(ctx) {
  1051. try {
  1052. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  1053. const posData = ctx.tender.data.measure_type === measureType.tz.value
  1054. ? await ctx.service.pos.getPosData({ tid: ctx.tender.id }) : [];
  1055. const convert = new billsPosConvert(ctx);
  1056. convert.loadData(ledgerData, posData, []);
  1057. const result = await convert.convert();
  1058. const ledgerCooperationList = await ctx.service.ledgerCooperation.getAllDataByCondition({ where: { tid: ctx.tender.id, status: 1 } });
  1059. ctx.body = { err: 0, msg: '', data: { ledgerList: result, ledgerCooperationList } };
  1060. } catch (err) {
  1061. this.log(err);
  1062. ctx.body = { err: 1, msg: err.toString(), data: [] };
  1063. }
  1064. }
  1065. async billsTag(ctx) {
  1066. try {
  1067. const isValidTourist = ctx.tender.isTourist && ctx.tender.touristPermission.tag;
  1068. if (ctx.stage) {
  1069. const isAuditor = ctx.stage.users.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
  1070. if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
  1071. } else {
  1072. const isAuditor = ctx.tender.ledgerUsers.indexOf(this.ctx.session.sessionUser.accountId) >= 0;
  1073. if (!isAuditor && !isValidTourist) throw '您无权进行该操作';
  1074. }
  1075. const data = JSON.parse(ctx.request.body.data);
  1076. const result = await ctx.service.ledgerTag.update(data);
  1077. ctx.body = { err: 0, msg: '', data: result };
  1078. } catch (err) {
  1079. this.log(err);
  1080. ctx.body = this.ajaxErrorBody(err, '书签数据错误');
  1081. }
  1082. }
  1083. async listLoad(ctx) {
  1084. try {
  1085. const data = JSON.parse(ctx.request.body.data);
  1086. if (!data.tid || !data.lid || !data.type) throw '数据错误';
  1087. const responseData = {
  1088. err: 0,
  1089. msg: '',
  1090. data: { ledgerAuditConst: auditConst.ledger, stageAuditConst: auditConst.stage },
  1091. };
  1092. responseData.data.category = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  1093. // 获取用户权限
  1094. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  1095. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  1096. const tenderList = await this.ctx.service.tender.getList('', userPermission);
  1097. for (const t of tenderList) {
  1098. if (t.ledger_status === auditConst.ledger.status.checked) {
  1099. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, false);
  1100. }
  1101. }
  1102. if (data.type === 'ledger') {
  1103. responseData.data.tenders = tenderList.filter(x => {
  1104. return x.ledger_status === auditConst.ledger.status.checked;
  1105. });
  1106. const history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
  1107. if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
  1108. } else if (data.type === 'stage') {
  1109. responseData.data.tenders = tenderList.filter(x => {
  1110. return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
  1111. });
  1112. let history = await this.ctx.service.sumLoadHistory.getStageHistory(data.tid, data.lid);
  1113. if (history) {
  1114. responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'stage' };
  1115. } else {
  1116. history = await this.ctx.service.sumLoadHistory.getReviseHistory(data.tid, data.lid);
  1117. if (history) {
  1118. responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'revise' };
  1119. } else {
  1120. history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
  1121. if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
  1122. }
  1123. }
  1124. } else if (data.type === 'revise') {
  1125. responseData.data.tenders = tenderList.filter(x => {
  1126. return x.ledger_status === auditConst.ledger.status.checked;
  1127. });
  1128. let history = await this.ctx.service.sumLoadHistory.getReviseHistory(data.tid, data.lid);
  1129. if (history) {
  1130. responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'revise' };
  1131. } else {
  1132. history = await this.ctx.service.sumLoadHistory.getLedgerHistory(data.tid, data.lid);
  1133. if (history) responseData.data.history = { tenders: history.tenders, load_time: history.load_time, type: 'ledger' };
  1134. }
  1135. }
  1136. ctx.body = responseData;
  1137. } catch(err) {
  1138. this.log(err);
  1139. this.ajaxErrorBody(err, '获取标段列表错误');
  1140. }
  1141. }
  1142. async listLoad2(ctx) {
  1143. try {
  1144. const data = JSON.parse(ctx.request.body.data);
  1145. if (!data.type) throw '数据错误';
  1146. const responseData = {
  1147. err: 0,
  1148. msg: '',
  1149. data: { ledgerAuditConst: auditConst.ledger, stageAuditConst: auditConst.stage },
  1150. };
  1151. responseData.data.category = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
  1152. // 获取用户权限
  1153. const accountInfo = await this.ctx.service.projectAccount.getDataById(this.ctx.session.sessionUser.accountId);
  1154. const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;
  1155. const tenderList = await this.ctx.service.tender.getList('', userPermission);
  1156. for (const t of tenderList) {
  1157. if (t.ledger_status === auditConst.ledger.status.checked) {
  1158. t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, false);
  1159. t.lastCheckedStage = await this.ctx.service.stage.getLastestCompleteStage(t.id);
  1160. }
  1161. }
  1162. if (data.type === 'all') {
  1163. responseData.data.tenders = tenderList;
  1164. } else if (data.type === 'ledger-checked') {
  1165. responseData.data.tenders = tenderList.filter(x => {
  1166. return x.ledger_status === auditConst.ledger.status.checked;
  1167. });
  1168. } else if (data.type === 'stage') {
  1169. responseData.data.tenders = tenderList.filter(x => {
  1170. return x.ledger_status === auditConst.ledger.status.checked && !!x.lastStage;
  1171. });
  1172. } else if (data.type === 'stage-checked') {
  1173. responseData.data.tenders = tenderList.filter(x => {
  1174. return x.ledger_status === auditConst.ledger.status.checked && !!x.lastCheckedStage;
  1175. });
  1176. }
  1177. ctx.body = responseData;
  1178. } catch(err) {
  1179. this.log(err);
  1180. this.ajaxErrorBody(err, '获取标段列表错误');
  1181. }
  1182. }
  1183. async sumLoad(ctx) {
  1184. try {
  1185. const data = JSON.parse(ctx.request.body.data);
  1186. if (!data.lid || !data.type || !data.tenders) throw '数据错误';
  1187. switch (data.type) {
  1188. case 'ledger':
  1189. const refreshData = await this.ctx.service.ledger.sumLoad(data.lid, data.tenders);
  1190. ctx.body = {err: 0, msg: '', data: refreshData};
  1191. break;
  1192. case 'revise':
  1193. const reviseData = await this.ctx.service.reviseBills.sumLoad(data.lid, this.ctx.revise.id, data.tenders);
  1194. ctx.body = {err: 0, msg: '', data: reviseData};
  1195. break;
  1196. case 'stage':
  1197. const stageData = await this.ctx.service.stageBills.sumLoad(data.lid, data.tenders, data.cover);
  1198. ctx.body = {err: 0, msg: '', data: stageData};
  1199. break;
  1200. default:
  1201. throw '数据错误';
  1202. }
  1203. } catch (err) {
  1204. this.log(err);
  1205. this.ajaxErrorBody(err, '导入数据失败');
  1206. }
  1207. }
  1208. /**
  1209. * 地图数据设置(Ajax)
  1210. *
  1211. * @param ctx
  1212. * @return {Promise<void>}
  1213. */
  1214. async saveMap(ctx) {
  1215. try {
  1216. const data = JSON.parse(ctx.request.body.data);
  1217. if (!data) {
  1218. throw '提交数据错误';
  1219. }
  1220. // 判断修改权限
  1221. if (ctx.session.sessionUser.is_admin === 0) {
  1222. throw '你没有权限修改概况设置';
  1223. }
  1224. let info = '';
  1225. let result = '';
  1226. switch (data.type) {
  1227. case 'select-map':
  1228. result = await ctx.service.tender.saveTenderData(ctx.tender.id, { had_map: data.value });
  1229. if (!result) {
  1230. throw '修改概况设置失败';
  1231. }
  1232. info = result;
  1233. break;
  1234. case 'add-map':
  1235. result = await ctx.service.tenderMap.addMap(ctx.tender.id, data.name);
  1236. info = await ctx.service.tenderMap.getDataById(result.insertId);
  1237. break;
  1238. case 'del-map':
  1239. await ctx.service.tenderMap.deleteById(data.id);
  1240. break;
  1241. case 'save-map':
  1242. await ctx.service.tenderMap.saveMap(data.mapData);
  1243. break;
  1244. default:break;
  1245. }
  1246. ctx.body = { err: 0, msg: '', data: info };
  1247. } catch (err) {
  1248. this.log(err);
  1249. ctx.body = this.ajaxErrorBody(err, '保存概况设置失败');
  1250. }
  1251. }
  1252. }
  1253. return TenderController;
  1254. };