revise_controller.js 31 KB

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