tender_controller.js 64 KB

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