revise_controller.js 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const stdDataAddType = {
  10. withParent: 1,
  11. child: 2,
  12. next: 3,
  13. };
  14. const audit = require('../const/audit');
  15. const accountGroup = require('../const/account_group').group;
  16. const tenderMenu = require('../../config/menu').tenderMenu;
  17. const measureType = require('../const/tender').measureType;
  18. const spreadConst = require('../const/spread');
  19. const fs = require('fs');
  20. const LzString = require('lz-string');
  21. module.exports = app => {
  22. class ReviseController extends app.BaseController {
  23. /**
  24. * 构造函数
  25. *
  26. * @param {Object} ctx - egg全局变量
  27. * @return {void}
  28. */
  29. constructor(ctx) {
  30. super(ctx);
  31. }
  32. /**
  33. * 是否可以新增修订
  34. * @param ctx
  35. * @returns {Promise<boolean>}
  36. * @private
  37. */
  38. async _getAddReviseValid(ctx) {
  39. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  40. const lastStage = await ctx.service.stage.getLastestStage(ctx.tender.id, true);
  41. return (ctx.tender.data.user_id === ctx.session.sessionUser.accountId) &&
  42. (ctx.tender.data.ledger_status === audit.revise.status.checked) &&
  43. (!revise || !revise.valid || revise.status === audit.revise.status.checked) &&
  44. (!lastStage || lastStage.status !== audit.stage.status.checking);
  45. }
  46. /**
  47. * 台账修订页面 (Get)
  48. *
  49. * @param {object} ctx - egg全局变量
  50. * @return {void}
  51. */
  52. async index(ctx) {
  53. try {
  54. // 分页相关
  55. const count = await ctx.service.ledgerRevise.count({tid: ctx.tender.id});
  56. const ledgerRevise = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id);
  57. if (ledgerRevise.length > 0) {
  58. const revise = ledgerRevise[0];
  59. if (revise.status === audit.revise.status.checked || !revise.valid) {
  60. revise.lastest = true;
  61. } else {
  62. if (ledgerRevise.length > 1) ledgerRevise[1].lastest = true;
  63. if (revise.status === audit.revise.status.checking) {
  64. revise.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  65. }
  66. }
  67. }
  68. const addValid = await this._getAddReviseValid(ctx);
  69. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(ctx.tender.data.valuation);
  70. const renderData = {
  71. tender: ctx.tender.data,
  72. tenderMenu: this.menu.tenderMenu,
  73. preUrl: '/tender/' + ctx.tender.id,
  74. pageInfo: {
  75. page: ctx.page,
  76. total: Math.ceil(count/app.config.pageSize),
  77. queryData: JSON.stringify(ctx.urlInfo.query),
  78. },
  79. ledgerRevise,
  80. addValid,
  81. auditConst: audit.revise,
  82. stdBills,
  83. stdChapters,
  84. };
  85. await this.layout('revise/index.ejs', renderData, 'revise/modal.ejs');
  86. } catch (err) {
  87. this.log(err);
  88. ctx.redirect(ctx.request.header.referer);
  89. }
  90. }
  91. /**
  92. * 新增 修订 (Post)
  93. * @param ctx
  94. * @returns {Promise<void>}
  95. */
  96. async add(ctx) {
  97. try {
  98. const addValid = await this._getAddReviseValid(ctx);
  99. if (!addValid) {
  100. throw '无法新增修订';
  101. }
  102. const revise = await ctx.service.ledgerRevise.add(ctx.tender.id, ctx.session.sessionUser.accountId);
  103. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  104. } catch(err) {
  105. this.log(err);
  106. ctx.redirect(ctx.request.header.referer);
  107. }
  108. }
  109. /**
  110. * 作废 修订 (Post)
  111. * @param ctx
  112. * @returns {Promise<void>}
  113. */
  114. async cancel(ctx) {
  115. try {
  116. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  117. if (revise.uid !== ctx.session.sessionUser.accountId) {
  118. throw '您无权作废该修订';
  119. }
  120. if (revise.status === audit.revise.checking) {
  121. throw '修订审批中,不可作废';
  122. } else if (revise.status === audit.revise.checked) {
  123. throw '修订已审批通过,不可作废';
  124. }
  125. if (revise.valid) {
  126. const result = await ctx.service.ledgerRevise.cancelRevise(revise);
  127. }
  128. ctx.redirect('/tender/' + ctx.tender.id + '/revise/');
  129. } catch(err) {
  130. this.log(err);
  131. ctx.redirect(ctx.request.header.referer);
  132. }
  133. }
  134. /**
  135. * 保存 修订详情 (Ajax-post)
  136. * @param ctx
  137. * @returns {Promise<void>}
  138. */
  139. async save(ctx) {
  140. try {
  141. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  142. if (!revise.valid) {
  143. throw '该修订已作废';
  144. } else if (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo) {
  145. if (ctx.session.sessionUser.accountId !== revise.uid) {
  146. throw '您无权修改';
  147. }
  148. } else if (revise.status === audit.revise.status.checking) {
  149. throw '修订在审批中,不可修改修订数据';
  150. } else if (revise.staut === audit.revise.status.checked) {
  151. throw '修订已经审批通过,不可修改修订数据,请新增下一修订';
  152. }
  153. const data = JSON.parse(ctx.request.body.data);
  154. if (data.content === undefined) {
  155. throw '保存数据有误'
  156. }
  157. const result = await ctx.service.ledgerRevise.defaultUpdate({id: revise.id, content: data.content});
  158. if (result.affectedRows !== 1) {
  159. throw '保存数据失败,请重试';
  160. }
  161. ctx.body = {err: 0, msg: '', data: null};
  162. } catch(err) {
  163. this.log(err);
  164. ctx.body = this.ajaxErrorBody(err, '保存数据失败,请重试');
  165. }
  166. }
  167. /**
  168. * 获取SpreadSetting
  169. * @private
  170. */
  171. _getSpreadSetting(revise) {
  172. const _ = this.app._;
  173. function removeFieldCols(setting, cols) {
  174. _.remove(setting.cols, function(c) {
  175. return cols.indexOf(c.field) > -1;
  176. });
  177. }
  178. const tender = this.ctx.tender;
  179. const setting = tender.info.display.ledger.clQty ? spreadConst.withCl : spreadConst.withoutCl;
  180. const ledger = JSON.parse(JSON.stringify(setting.ledger));
  181. const pos = JSON.parse(JSON.stringify(setting.pos));
  182. if (revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  183. ledger.readOnly = true;
  184. pos.readOnly = true;
  185. }
  186. if (tender.data.measure_type === measureType.tz.value) {
  187. removeFieldCols(ledger, spreadConst.filterCols.tzWithoutCols);
  188. }
  189. if (!tender.info.display.ledger.dgnQty) {
  190. removeFieldCols(ledger, spreadConst.filterCols.dgnCols);
  191. }
  192. return [ledger, pos];
  193. }
  194. async _getDefaultReviseInfoData(ctx, revise) {
  195. const reviseBills = revise.bills_file
  196. ? JSON.parse(await fs.readFileSync(this.ctx.app.config.filePath + revise.bills_file, 'utf8'))
  197. : await ctx.service.reviseBills.getData(ctx.tender.id);
  198. const revisePos = revise.pos_file
  199. ? JSON.parse(await fs.readFileSync(this.ctx.app.config.filePath + revise.pos_file, 'utf8'))
  200. : await ctx.service.revisePos.getData(ctx.tender.id);
  201. const [ledgerSpread, posSpread] = this._getSpreadSetting(revise);
  202. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(ctx.tender.data.valuation);
  203. const curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  204. const auditors = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
  205. const user = await ctx.service.projectAccount.getAccountInfoById(revise.uid);
  206. const auditHistory = [];
  207. if (revise.times > 1) {
  208. for (let i = 1; i < revise.times; i++) {
  209. auditHistory.push(await ctx.service.reviseAudit.getAuditors(revise.id, i));
  210. }
  211. }
  212. return {
  213. revise: revise, tender: ctx.tender.data,
  214. reviseBills, revisePos, ledgerSpread, posSpread, tenderMenu, measureType,
  215. preUrl: '/tender/' + ctx.tender.id,
  216. audit: audit.revise,
  217. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.info),
  218. stdBills,
  219. stdChapters,
  220. curAuditor,
  221. auditors,
  222. user,
  223. auditHistory,
  224. };
  225. }
  226. /**
  227. * 历史修订页面(修订完成后,用于查看)
  228. * @param ctx
  229. * @param revise
  230. * @returns {Promise<void>}
  231. * @private
  232. */
  233. async _getHistoryReviseInfo(ctx, revise) {
  234. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  235. renderData.ledgerSpread.readOnly = true;
  236. renderData.posSpread.readOnly = true;
  237. renderData.readOnly = true;
  238. renderData.history = true;
  239. renderData.historyRevise = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id);
  240. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  241. }
  242. /**
  243. * 修订页面(草稿,审批中)
  244. * @param ctx
  245. * @param revise
  246. * @returns {Promise<void>}
  247. * @private
  248. */
  249. async _getAuditReviseInfo(ctx, revise) {
  250. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  251. renderData.readOnly = true;
  252. renderData.ledgerSpread.readOnly = true;
  253. renderData.posSpread.readOnly = true;
  254. renderData.history = false;
  255. renderData.historyRevise = [];
  256. renderData.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  257. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  258. }
  259. async _getDraftReviseInfo(ctx, revise) {
  260. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  261. // 台账只读、使用数据
  262. renderData.readOnly = false;
  263. const lastStage = await ctx.service.stage.getLastestStage(ctx.tender.id, true);
  264. if (lastStage) {
  265. if (lastStage.status === audit.stage.status.checked) {
  266. const usedPreBills = await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, lastStage.order);
  267. for (const b of renderData.reviseBills) {
  268. b.used = usedPreBills.indexOf(b.id) >= 0;
  269. }
  270. const usedPrePos = await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, lastStage.order);
  271. for (const p of renderData.revisePos) {
  272. p.used = usedPrePos.indexOf(p.id) >= 0;
  273. }
  274. } else {
  275. const usedPreBills = lastStage.order > 1 ? await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, lastStage.order - 1) : [];
  276. const usedCurBills = await ctx.service.stageBills.getStageUsedBills(ctx.tender.id, lastStage.id);
  277. for (const b of renderData.reviseBills) {
  278. b.used = usedPreBills.indexOf(b.id) >= 0 || usedCurBills.indexOf(b.id) >= 0;
  279. }
  280. const usedPrePos = lastStage.order > 1 ? await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, lastStage.order - 1) : [];
  281. const usedCurPos = await ctx.service.stagePos.getStageUsedPos(ctx.tender.id, lastStage.id);
  282. for (const p of renderData.revisePos) {
  283. p.used = usedPrePos.indexOf(p.id) >= 0 || usedCurPos.indexOf(p.id) >= 0;
  284. }
  285. }
  286. }
  287. // 修订历史
  288. renderData.history = false;
  289. renderData.historyRevise = [];
  290. // 添加审批人相关
  291. renderData.accountGroup = accountGroup;
  292. renderData.accountList = await ctx.service.projectAccount.getAllDataByCondition({
  293. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  294. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  295. });
  296. renderData.auditorList = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
  297. renderData.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  298. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  299. }
  300. /**
  301. * 修订 详细页面(Get)
  302. * @param ctx
  303. * @returns {Promise<void>}
  304. */
  305. async info(ctx) {
  306. try {
  307. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  308. if (!revise) throw '台账修订数据有误';
  309. if (revise.uid === ctx.session.sessionUser.accountId &&
  310. (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
  311. await this._getDraftReviseInfo(ctx, revise);
  312. } else if (revise.status === audit.revise.status.checked) {
  313. await this._getHistoryReviseInfo(ctx, revise);
  314. } else {
  315. await this._getAuditReviseInfo(ctx, revise);
  316. }
  317. } catch (err) {
  318. this.log(err);
  319. ctx.redirect(ctx.request.header.referer);
  320. }
  321. }
  322. async history(ctx) {
  323. try {
  324. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id, false);
  325. if (!revise) throw '台账修订数据有误';
  326. const reviseBills = await ctx.service.ledger.getData(ctx.tender.id);
  327. const revisePos = await ctx.service.pos.getPosData({tid: ctx.tender.id});
  328. const [ledgerSpread, posSpread] = this._getSpreadSetting(revise);
  329. ledgerSpread.readOnly = true;
  330. posSpread.readOnly = true;
  331. const historyRevise = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id);
  332. const renderData = {
  333. measureType, audit, revise,
  334. ledgerSpread, posSpread,
  335. reviseBills, revisePos,
  336. readOnly: true,
  337. historyRevise,
  338. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.history),
  339. };
  340. await this.layout('revise/history.ejs', renderData);
  341. } catch (err) {
  342. this.log(err);
  343. ctx.redirect(ctx.request.header.referer);
  344. }
  345. }
  346. async historyInfo(ctx) {
  347. try {
  348. const data = JSON.parse(ctx.request.body.data);
  349. if (!data || !data.rid || data.rid === '') throw '查询的台账修订有误';
  350. const reviseInfo = await ctx.service.ledgerRevise.getRevise(ctx.tender.id, data.rid);
  351. reviseInfo.end_time_str = reviseInfo.end_time ? reviseInfo.end_time.toLocaleString() : '';
  352. ctx.body = { err: 0, msg: '', data: reviseInfo };
  353. } catch(err) {
  354. this.log(err);
  355. ctx.body = this.ajaxErrorBody(err, '获取台账修订历史数据错误');
  356. }
  357. }
  358. async _billsBase(revise, type, data) {
  359. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  360. if (type !== 'add') {
  361. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  362. }
  363. switch (type) {
  364. case 'add':
  365. return await this.ctx.service.reviseBills.addReviseNode(revise.tid, revise.id, data.id);
  366. case 'delete':
  367. return await this.ctx.service.reviseBills.delete(revise.tid, data.id, data.count);
  368. case 'up-move':
  369. return await this.ctx.service.reviseBills.upMoveNode(revise.tid, data.id, data.count);
  370. case 'down-move':
  371. return await this.ctx.service.reviseBills.downMoveNode(revise.tid, data.id, data.count);
  372. case 'up-level':
  373. return await this.ctx.service.reviseBills.upLevelNode(revise.tid, data.id, data.count);
  374. case 'down-level':
  375. return await this.ctx.service.reviseBills.downLevelNode(revise.tid, data.id, data.count);
  376. }
  377. }
  378. async _batchInsert(revise, data) {
  379. if ((isNaN(data.id) || data.id <= 0) || !data.batchType) {
  380. throw '参数错误';
  381. }
  382. switch (data.batchType) {
  383. case 'child':
  384. return await this.ctx.service.reviseBills.batchInsertChild(revise.tid, revise.id, data.id, data.batchData);
  385. case 'next':
  386. return await this.ctx.service.reviseBills.batchInsertNext(revise.tid, revise.id, data.id, data.batchData);
  387. default:
  388. throw '参数错误';
  389. }
  390. }
  391. async _pasteBlock(revise, data) {
  392. if ((isNaN(data.id) || data.id <= 0) ||
  393. (!data.tid && data.tid <= 0) ||
  394. (!data.block || data.block.length <= 0)) throw '参数错误';
  395. return await this.ctx.service.revise.pasteBlock(data.tid, data.id, data.block);
  396. }
  397. async _addStd(revise, data) {
  398. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdNode) throw '参数错误';
  399. // todo 校验项目是否使用该库的权限
  400. let stdLib, addType;
  401. switch (data.stdType) {
  402. case 'xmj':
  403. stdLib = this.ctx.service.stdXmj;
  404. addType = stdDataAddType.withParent;
  405. break;
  406. case 'gcl':
  407. stdLib = this.ctx.service.stdGcl;
  408. const selectNode = await this.ctx.service.reviseBills.getDataByKid(revise.tid, data.id);
  409. if (selectNode.b_code) {
  410. addType = stdDataAddType.next;
  411. } else {
  412. addType = stdDataAddType.child;
  413. }
  414. break;
  415. default:
  416. throw '未知标准库';
  417. }
  418. const stdData = await stdLib.getDataByDataId(data.stdLibId, data.stdNode);
  419. switch (addType) {
  420. case stdDataAddType.child:
  421. return await this.ctx.service.reviseBills.addStdNodeAsChild(revise.tid, data.id, stdData, revise.id);
  422. break;
  423. case stdDataAddType.next:
  424. return await this.ctx.service.reviseBills.addStdNode(revise.tid, data.id, stdData, revise.id);
  425. case stdDataAddType.withParent:
  426. return await this.ctx.service.reviseBills.addStdNodeWithParent(revise.tid, stdData, stdLib, revise.id);
  427. default:
  428. throw '未知添加方式';
  429. }
  430. }
  431. async _addDeal(revise, data) {
  432. if (!data.type || !data.dealBills) throw '数据错误';
  433. if (data.type === 'child') {
  434. return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.dealBills, revise.id);
  435. } else if (data.type === 'next') {
  436. return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.dealBills, revise.id);
  437. } else {
  438. throw '数据错误';
  439. }
  440. }
  441. async _updatePos(revise, data) {
  442. await this.checkMeasureType(measureType.tz.value);
  443. if (!data.posPostType) throw '数据错误';
  444. switch (data.posPostType) {
  445. case 'add':
  446. return await this.ctx.service.revisePos.addPos(revise.tid, revise.id, data.postData);
  447. case 'update':
  448. if (data.postData instanceof Array) {
  449. return await this.ctx.service.revisePos.updatePosArr(revise.tid, data.postData);
  450. } else {
  451. return await this.ctx.service.revisePos.updatePos(revise.tid, data.postData);
  452. }
  453. case 'delete':
  454. return await this.ctx.service.revisePos.deletePos(revise.tid, data.postData);
  455. case 'paste':
  456. return await this.ctx.service.revisePos.pastePosData(revise.tid, revise.id, data.postData);
  457. default:
  458. throw '未知操作';
  459. }
  460. }
  461. async update(ctx) {
  462. try {
  463. if (!ctx.tender.data) throw '标段数据错误';
  464. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  465. if (revise.uid !== ctx.session.sessionUser.accountId) {
  466. throw '修订数据错误';
  467. } else if (revise.status === audit.revise.status.checking) {
  468. throw '修订审批中,不可修改';
  469. } else if (revise.status === audit.revise.status.checked) {
  470. throw '修订已完成,如需修订台账,请新增修订';
  471. }
  472. const data = JSON.parse(ctx.request.body.data);
  473. if (!data.postType || !data.postData) throw '数据错误';
  474. const responseData = {err: 0, msg: '', data: {}};
  475. switch (data.postType) {
  476. case 'add':
  477. case 'delete':
  478. case 'up-move':
  479. case 'down-move':
  480. case 'up-level':
  481. case 'down-level':
  482. responseData.data = await this._billsBase(revise, data.postType, data.postData);
  483. break;
  484. case 'update':
  485. responseData.data = await this.ctx.service.reviseBills.updateCalc(revise.tid, data.postData);
  486. break;
  487. case 'batch-insert':
  488. responseData.data = await this._batchInsert(revise, data.postData);
  489. break;
  490. case 'add-deal':
  491. responseData.data = await this._addDeal(revise, data.postData);
  492. break;
  493. case 'add-std':
  494. responseData.data = await this._addStd(revise, data.postData);
  495. break;
  496. case 'paste-block':
  497. responseData.data = await this._pasteBlock(revise, data.postData);
  498. break;
  499. case 'pos':
  500. responseData.data = await this._updatePos(revise, data);
  501. break;
  502. default:
  503. throw '未知操作';
  504. }
  505. ctx.body = responseData;
  506. } catch (err) {
  507. this.log(err);
  508. ctx.body = this.ajaxErrorBody(err, '数据错误');
  509. }
  510. }
  511. /**
  512. * 新增审批人(Ajax)
  513. *
  514. * @param ctx
  515. * @return {Promise<void>}
  516. */
  517. async addAuditor(ctx) {
  518. try {
  519. const data = JSON.parse(ctx.request.body.data);
  520. const id = data.auditorId;
  521. if (isNaN(id) || id <= 0) {
  522. throw '参数错误';
  523. }
  524. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  525. if (!revise) throw '台账修订数据有误';
  526. // 检查权限等
  527. if (revise.uid !== ctx.session.sessionUser.accountId) throw '您无权添加审核人';
  528. if (revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  529. throw '当前不允许添加审核人';
  530. }
  531. // 检查审核人是否已存在
  532. const exist = await ctx.service.reviseAudit.getAuditor(revise.id, id, revise.times);
  533. if (exist) throw '该审核人已存在,请勿重复添加';
  534. const result = await ctx.service.reviseAudit.addAuditor(revise, id);
  535. if (!result) throw '添加审核人失败';
  536. const resultData = await ctx.service.reviseAudit.getAuditor(revise.id, id, revise.times);
  537. ctx.body = {err: 0, msg: '', data: resultData};
  538. } catch (err) {
  539. this.log(err, '数据错误');
  540. ctx.body = this.ajaxErrorBody(err);
  541. }
  542. }
  543. /**
  544. * 移除审批人(Ajax)
  545. *
  546. * @param ctx
  547. * @return {Promise<void>}
  548. */
  549. async removeAuditor(ctx) {
  550. try {
  551. const data = JSON.parse(ctx.request.body.data);
  552. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  553. if (isNaN(id) || id <= 0) {
  554. throw '参数错误';
  555. }
  556. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  557. if (!revise) throw '台账修订数据有误';
  558. const result = await ctx.service.reviseAudit.deleteAuditor(revise, id);
  559. if (!result) {
  560. throw '移除审核人失败';
  561. }
  562. const resultData = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
  563. ctx.body = {err: 0, msg: '', data: resultData};
  564. } catch (err) {
  565. this.log(err, '数据错误');
  566. ctx.body = this.ajaxErrorBody(err);
  567. }
  568. }
  569. /**
  570. * 上报(post)
  571. *
  572. * @param ctx
  573. * @return {Promise<void>}
  574. */
  575. async start(ctx) {
  576. try {
  577. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  578. if (!revise || revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  579. throw '台账修订数据有误';
  580. }
  581. if (revise.content === '') {
  582. throw '未填写修订内容,请先填写并保存修订内容';
  583. }
  584. if (revise.uid !== ctx.session.sessionUser.accountId) throw '上报失败';
  585. await ctx.service.reviseAudit.start(revise, revise.times);
  586. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  587. } catch (err) {
  588. this.log(err);
  589. this.postError(err, '上报失败');
  590. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  591. }
  592. }
  593. /**
  594. * 审批(post)
  595. *
  596. * @param ctx
  597. * @return {Promise<void>}
  598. */
  599. async check(ctx) {
  600. try {
  601. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  602. if (!revise || revise.status !== audit.revise.status.checking) throw '台账修订数据有误';
  603. const curAudit = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  604. if (curAudit.audit_id !== ctx.session.sessionUser.accountId) throw '审批失败';
  605. const checkType = parseInt(ctx.request.body.checkType);
  606. if (!checkType || isNaN(checkType)) throw '提交数据错误';
  607. await ctx.service.reviseAudit.check(revise, checkType, ctx.request.body.opinion, revise.times);
  608. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  609. } catch (err) {
  610. this.log(err);
  611. this.postError(err, '审批失败');
  612. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  613. }
  614. }
  615. }
  616. return ReviseController;
  617. };