revise_controller.js 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702
  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 checkRevise(ctx) {
  359. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  360. if (revise.uid !== ctx.session.sessionUser.accountId) {
  361. throw '修订数据错误';
  362. } else if (revise.status === audit.revise.status.checking) {
  363. throw '修订审批中,不可修改';
  364. } else if (revise.status === audit.revise.status.checked) {
  365. throw '修订已完成,如需修订台账,请新增修订';
  366. }
  367. return revise;
  368. }
  369. async _billsBase(revise, type, data) {
  370. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  371. if (type !== 'add') {
  372. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  373. }
  374. switch (type) {
  375. case 'add':
  376. return await this.ctx.service.reviseBills.addReviseNode(revise.tid, revise.id, data.id, data.count);
  377. case 'delete':
  378. return await this.ctx.service.reviseBills.delete(revise.tid, data.id, data.count);
  379. case 'up-move':
  380. return await this.ctx.service.reviseBills.upMoveNode(revise.tid, data.id, data.count);
  381. case 'down-move':
  382. return await this.ctx.service.reviseBills.downMoveNode(revise.tid, data.id, data.count);
  383. case 'up-level':
  384. return await this.ctx.service.reviseBills.upLevelNode(revise.tid, data.id, data.count);
  385. case 'down-level':
  386. return await this.ctx.service.reviseBills.downLevelNode(revise.tid, data.id, data.count);
  387. }
  388. }
  389. async _batchInsert(revise, data) {
  390. if ((isNaN(data.id) || data.id <= 0) || !data.batchType) {
  391. throw '参数错误';
  392. }
  393. switch (data.batchType) {
  394. case 'child':
  395. return await this.ctx.service.reviseBills.batchInsertChild(revise.tid, revise.id, data.id, data.batchData);
  396. case 'next':
  397. return await this.ctx.service.reviseBills.batchInsertNext(revise.tid, revise.id, data.id, data.batchData);
  398. default:
  399. throw '参数错误';
  400. }
  401. }
  402. async _pasteBlock(revise, data) {
  403. if ((isNaN(data.id) || data.id <= 0) ||
  404. (!data.tid && data.tid <= 0) ||
  405. (!data.block || data.block.length <= 0)) throw '参数错误';
  406. return await this.ctx.service.revise.pasteBlock(data.tid, data.id, data.block);
  407. }
  408. async _addStd(revise, data) {
  409. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdNode) throw '参数错误';
  410. // todo 校验项目是否使用该库的权限
  411. let stdLib, addType;
  412. switch (data.stdType) {
  413. case 'xmj':
  414. stdLib = this.ctx.service.stdXmj;
  415. addType = stdDataAddType.withParent;
  416. break;
  417. case 'gcl':
  418. stdLib = this.ctx.service.stdGcl;
  419. const selectNode = await this.ctx.service.reviseBills.getDataByKid(revise.tid, data.id);
  420. if (selectNode.b_code) {
  421. addType = stdDataAddType.next;
  422. } else {
  423. addType = stdDataAddType.child;
  424. }
  425. break;
  426. default:
  427. throw '未知标准库';
  428. }
  429. const stdData = await stdLib.getDataByDataId(data.stdLibId, data.stdNode);
  430. switch (addType) {
  431. case stdDataAddType.child:
  432. return await this.ctx.service.reviseBills.addStdNodeAsChild(revise.tid, data.id, stdData, revise.id);
  433. break;
  434. case stdDataAddType.next:
  435. return await this.ctx.service.reviseBills.addStdNode(revise.tid, data.id, stdData, revise.id);
  436. case stdDataAddType.withParent:
  437. return await this.ctx.service.reviseBills.addStdNodeWithParent(revise.tid, stdData, stdLib, revise.id);
  438. default:
  439. throw '未知添加方式';
  440. }
  441. }
  442. async _addDeal(revise, data) {
  443. if (!data.type || !data.dealBills) throw '数据错误';
  444. data.dealBills.unit_price = this.ctx.helper.round(data.dealBills.unit_price, this.ctx.tender.info.decimal.up);
  445. if (data.type === 'child') {
  446. return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.dealBills, revise.id);
  447. } else if (data.type === 'next') {
  448. return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.dealBills, revise.id);
  449. } else {
  450. throw '数据错误';
  451. }
  452. }
  453. async _addBg(revise, data) {
  454. if (!data.type || !data.bgBills) throw '数据错误';
  455. data.bgBills.unit_price = this.ctx.helper.round(data.bgBills.unit_price, this.ctx.tender.info.decimal.up);
  456. if (data.type === 'child') {
  457. return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.bgBills, revise.id);
  458. } else if (data.type === 'next') {
  459. return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.bgBills, revise.id);
  460. } else {
  461. throw '数据错误';
  462. }
  463. }
  464. async _updatePos(revise, data) {
  465. await this.checkMeasureType(measureType.tz.value);
  466. if (!data.posPostType) throw '数据错误';
  467. switch (data.posPostType) {
  468. case 'add':
  469. return await this.ctx.service.revisePos.addPos(revise.tid, revise.id, data.postData);
  470. case 'update':
  471. if (data.postData instanceof Array) {
  472. return await this.ctx.service.revisePos.updatePosArr(revise.tid, data.postData);
  473. } else {
  474. return await this.ctx.service.revisePos.updatePos(revise.tid, data.postData);
  475. }
  476. case 'delete':
  477. return await this.ctx.service.revisePos.deletePos(revise.tid, data.postData);
  478. case 'paste':
  479. return await this.ctx.service.revisePos.pastePosData(revise.tid, revise.id, data.postData);
  480. default:
  481. throw '未知操作';
  482. }
  483. }
  484. async update(ctx) {
  485. try {
  486. if (!ctx.tender.data) throw '标段数据错误';
  487. const data = JSON.parse(ctx.request.body.data);
  488. if (!data.postType || !data.postData) throw '数据错误';
  489. const responseData = {err: 0, msg: '', data: {}};
  490. const revise = await this.checkRevise(ctx);
  491. switch (data.postType) {
  492. case 'add':
  493. case 'delete':
  494. case 'up-move':
  495. case 'down-move':
  496. case 'up-level':
  497. case 'down-level':
  498. responseData.data = await this._billsBase(revise, data.postType, data.postData);
  499. break;
  500. case 'update':
  501. responseData.data = await this.ctx.service.reviseBills.updateCalc(revise.tid, data.postData);
  502. break;
  503. case 'batch-insert':
  504. responseData.data = await this._batchInsert(revise, data.postData);
  505. break;
  506. case 'add-deal':
  507. responseData.data = await this._addDeal(revise, data.postData);
  508. break;
  509. case 'add-bg':
  510. responseData.data = await this._addDeal(revise, data.postData);
  511. break;
  512. case 'add-std':
  513. responseData.data = await this._addStd(revise, data.postData);
  514. break;
  515. case 'paste-block':
  516. responseData.data = await this._pasteBlock(revise, data.postData);
  517. break;
  518. case 'pos':
  519. responseData.data = await this._updatePos(revise, data);
  520. break;
  521. default:
  522. throw '未知操作';
  523. }
  524. ctx.body = responseData;
  525. } catch (err) {
  526. this.log(err);
  527. ctx.body = this.ajaxErrorBody(err, '数据错误');
  528. }
  529. }
  530. /**
  531. * 上传 清单Excel 并导入
  532. * @param ctx
  533. * @return {Promise<void>}
  534. */
  535. async uploadExcel(ctx) {
  536. try {
  537. const revise = await this.checkRevise(ctx);
  538. const ueType = ctx.params.ueType;
  539. const compressData = ctx.request.body.data;
  540. const data = JSON.parse(LzString.decompressFromUTF16(compressData));
  541. const responseData = { err: 0, msg: '', data: {}, };
  542. switch (ueType) {
  543. case 'gcl2xmj':
  544. responseData.data = await ctx.service.reviseBills.importGclExcel(data.id, data.sheet, {crid: revise.id});
  545. break;
  546. }
  547. ctx.body = responseData;
  548. } catch (err) {
  549. this.log(err);
  550. ctx.body = { err: 1, msg: err.toString(), data: null };
  551. }
  552. }
  553. /**
  554. * 新增审批人(Ajax)
  555. *
  556. * @param ctx
  557. * @return {Promise<void>}
  558. */
  559. async addAuditor(ctx) {
  560. try {
  561. const data = JSON.parse(ctx.request.body.data);
  562. const id = data.auditorId;
  563. if (isNaN(id) || id <= 0) {
  564. throw '参数错误';
  565. }
  566. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  567. if (!revise) throw '台账修订数据有误';
  568. // 检查权限等
  569. if (revise.uid !== ctx.session.sessionUser.accountId) throw '您无权添加审核人';
  570. if (revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  571. throw '当前不允许添加审核人';
  572. }
  573. // 检查审核人是否已存在
  574. const exist = await ctx.service.reviseAudit.getAuditor(revise.id, id, revise.times);
  575. if (exist) throw '该审核人已存在,请勿重复添加';
  576. const result = await ctx.service.reviseAudit.addAuditor(revise, id);
  577. if (!result) throw '添加审核人失败';
  578. const resultData = await ctx.service.reviseAudit.getAuditor(revise.id, id, revise.times);
  579. ctx.body = {err: 0, msg: '', data: resultData};
  580. } catch (err) {
  581. this.log(err, '数据错误');
  582. ctx.body = this.ajaxErrorBody(err);
  583. }
  584. }
  585. /**
  586. * 移除审批人(Ajax)
  587. *
  588. * @param ctx
  589. * @return {Promise<void>}
  590. */
  591. async removeAuditor(ctx) {
  592. try {
  593. const data = JSON.parse(ctx.request.body.data);
  594. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  595. if (isNaN(id) || id <= 0) {
  596. throw '参数错误';
  597. }
  598. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  599. if (!revise) throw '台账修订数据有误';
  600. const result = await ctx.service.reviseAudit.deleteAuditor(revise, id);
  601. if (!result) {
  602. throw '移除审核人失败';
  603. }
  604. const resultData = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
  605. ctx.body = {err: 0, msg: '', data: resultData};
  606. } catch (err) {
  607. this.log(err, '数据错误');
  608. ctx.body = this.ajaxErrorBody(err);
  609. }
  610. }
  611. /**
  612. * 上报(post)
  613. *
  614. * @param ctx
  615. * @return {Promise<void>}
  616. */
  617. async start(ctx) {
  618. try {
  619. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  620. if (!revise || revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  621. throw '台账修订数据有误';
  622. }
  623. if (revise.content === '') {
  624. throw '未填写修订内容,请先填写并保存修订内容';
  625. }
  626. if (revise.uid !== ctx.session.sessionUser.accountId) throw '上报失败';
  627. await ctx.service.reviseAudit.start(revise, revise.times);
  628. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  629. } catch (err) {
  630. this.log(err);
  631. this.postError(err, '上报失败');
  632. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  633. }
  634. }
  635. /**
  636. * 审批(post)
  637. *
  638. * @param ctx
  639. * @return {Promise<void>}
  640. */
  641. async check(ctx) {
  642. try {
  643. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  644. if (!revise || revise.status !== audit.revise.status.checking) throw '台账修订数据有误';
  645. const curAudit = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  646. if (curAudit.audit_id !== ctx.session.sessionUser.accountId) throw '审批失败';
  647. const checkType = parseInt(ctx.request.body.checkType);
  648. if (!checkType || isNaN(checkType)) throw '提交数据错误';
  649. await ctx.service.reviseAudit.check(revise, checkType, ctx.request.body.opinion, revise.times);
  650. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  651. } catch (err) {
  652. this.log(err);
  653. this.postError(err, '审批失败');
  654. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  655. }
  656. }
  657. }
  658. return ReviseController;
  659. };