tender_controller.js 60 KB

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