revise_controller.js 48 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042
  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 shenpiConst = require('../const/shenpi');
  20. const fs = require('fs');
  21. const LzString = require('lz-string');
  22. const stdConst = require('../const/standard');
  23. module.exports = app => {
  24. class ReviseController extends app.BaseController {
  25. /**
  26. * 构造函数
  27. *
  28. * @param {Object} ctx - egg全局变量
  29. * @return {void}
  30. */
  31. constructor(ctx) {
  32. super(ctx);
  33. }
  34. /**
  35. * 是否可以新增修订
  36. * @param ctx
  37. * @return {Promise<boolean>}
  38. * @private
  39. */
  40. async _getAddReviseValid(ctx) {
  41. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  42. const lastStage = await ctx.service.stage.getLastestStage(ctx.tender.id, true);
  43. return (ctx.tender.data.user_id === ctx.session.sessionUser.accountId) &&
  44. (ctx.tender.data.ledger_status === audit.ledger.status.checked) &&
  45. (!revise || !revise.valid || revise.status === audit.revise.status.checked) &&
  46. (!lastStage || lastStage.status !== audit.stage.status.checking);
  47. }
  48. /**
  49. * 台账修订页面 (Get)
  50. *
  51. * @param {object} ctx - egg全局变量
  52. * @return {void}
  53. */
  54. async index(ctx) {
  55. try {
  56. // 分页相关
  57. const count = await ctx.service.ledgerRevise.count({ tid: ctx.tender.id });
  58. const ledgerRevise = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id);
  59. if (ledgerRevise.length > 0) {
  60. const revise = ledgerRevise[0];
  61. if (ctx.page === 1) {
  62. if (revise.status === audit.revise.status.checked || !revise.valid) {
  63. revise.lastest = true;
  64. } else {
  65. if (ledgerRevise.length > 1) ledgerRevise[1].lastest = true;
  66. // if (revise.status === audit.revise.status.checking) {
  67. // revise.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  68. // }
  69. }
  70. }
  71. }
  72. for (const lr of ledgerRevise) {
  73. if (lr.valid) {
  74. lr.curAuditor = await ctx.service.reviseAudit.getAuditorByStatus(lr.id, lr.status, lr.times);
  75. }
  76. }
  77. const addValid = await this._getAddReviseValid(ctx);
  78. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
  79. ctx.tender.data.valuation, ctx.tender.data.measure_type);
  80. const renderData = {
  81. tender: ctx.tender.data,
  82. tenderMenu: this.menu.tenderMenu,
  83. preUrl: '/tender/' + ctx.tender.id,
  84. pageInfo: {
  85. page: ctx.page,
  86. total: Math.ceil(count / app.config.pageSize),
  87. queryData: JSON.stringify(ctx.urlInfo.query),
  88. },
  89. ledgerRevise,
  90. addValid,
  91. auditConst: audit.revise,
  92. auditConst2: JSON.stringify(audit.revise),
  93. stdBills,
  94. stdChapters,
  95. };
  96. await this.layout('revise/index.ejs', renderData, 'revise/modal.ejs');
  97. } catch (err) {
  98. this.log(err);
  99. ctx.redirect(ctx.request.header.referer);
  100. }
  101. }
  102. /**
  103. * 修订审批流程(Get)
  104. * @param ctx
  105. * @return {Promise<void>}
  106. */
  107. async reviseAuditors(ctx) {
  108. try {
  109. const responseData = {
  110. err: 0, msg: '', data: {},
  111. };
  112. const rid = JSON.parse(ctx.request.body.data).id;
  113. const reviseInfo = await ctx.service.ledgerRevise.getDataById(rid);
  114. // 获取审批流程中右边列表
  115. const auditHistory = [];
  116. const times = reviseInfo.status === audit.revise.status.checkNo ? reviseInfo.times - 1 : reviseInfo.times;
  117. if (times >= 1) {
  118. for (let i = 1; i <= times; i++) {
  119. auditHistory.push(await ctx.service.reviseAudit.getAuditors2ReviseList(reviseInfo.id, i));
  120. }
  121. }
  122. responseData.data.user = await ctx.service.projectAccount.getAccountInfoById(reviseInfo.uid);
  123. responseData.data.auditHistory = auditHistory;
  124. // 获取审批流程中左边列表
  125. responseData.data.auditors = await ctx.service.reviseAudit.getAuditorsWithOwner(reviseInfo.id, times);
  126. // 获取原报信息
  127. // const reviseAuditor = await ctx.service.projectAccount.getAccountInfoById(reviseInfo.uid);
  128. // responseData.data.reviseAuditor = reviseAuditor;
  129. ctx.body = responseData;
  130. } catch (error) {
  131. this.log(error);
  132. ctx.body = { err: 1, msg: error.toString(), data: null };
  133. }
  134. }
  135. /**
  136. * 新增 修订 (Post)
  137. * @param ctx
  138. * @return {Promise<void>}
  139. */
  140. async add(ctx) {
  141. try {
  142. const addValid = await this._getAddReviseValid(ctx);
  143. if (!addValid) {
  144. throw '无法新增修订';
  145. }
  146. const revise = await ctx.service.ledgerRevise.add(ctx.tender.id, ctx.session.sessionUser.accountId);
  147. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  148. } catch (err) {
  149. this.log(err);
  150. ctx.redirect(ctx.request.header.referer);
  151. }
  152. }
  153. /**
  154. * 作废 修订 (Post)
  155. * @param ctx
  156. * @return {Promise<void>}
  157. */
  158. async cancel(ctx) {
  159. try {
  160. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  161. if (revise.uid !== ctx.session.sessionUser.accountId) {
  162. throw '您无权作废该修订';
  163. }
  164. if (revise.status === audit.revise.checking) {
  165. throw '修订审批中,不可作废';
  166. } else if (revise.status === audit.revise.checked) {
  167. throw '修订已审批通过,不可作废';
  168. }
  169. if (revise.valid) {
  170. const result = await ctx.service.ledgerRevise.cancelRevise(revise);
  171. }
  172. ctx.redirect('/tender/' + ctx.tender.id + '/revise/');
  173. } catch (err) {
  174. this.log(err);
  175. ctx.redirect(ctx.request.header.referer);
  176. }
  177. }
  178. /**
  179. * 保存 修订详情 (Ajax-post)
  180. * @param ctx
  181. * @return {Promise<void>}
  182. */
  183. async save(ctx) {
  184. try {
  185. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  186. if (!revise.valid) {
  187. throw '该修订已作废';
  188. } else if (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo) {
  189. if (ctx.session.sessionUser.accountId !== revise.uid) {
  190. throw '您无权修改';
  191. }
  192. } else if (revise.status === audit.revise.status.checking) {
  193. throw '修订在审批中,不可修改修订数据';
  194. } else if (revise.staut === audit.revise.status.checked) {
  195. throw '修订已经审批通过,不可修改修订数据,请新增下一修订';
  196. }
  197. const data = JSON.parse(ctx.request.body.data);
  198. if (data.content === undefined) {
  199. throw '保存数据有误';
  200. }
  201. const result = await ctx.service.ledgerRevise.defaultUpdate({ id: revise.id, content: data.content });
  202. if (result.affectedRows !== 1) {
  203. throw '保存数据失败,请重试';
  204. }
  205. ctx.body = { err: 0, msg: '', data: null };
  206. } catch (err) {
  207. this.log(err);
  208. ctx.body = this.ajaxErrorBody(err, '保存数据失败,请重试');
  209. }
  210. }
  211. /**
  212. * 获取SpreadSetting
  213. * @private
  214. */
  215. _getSpreadSetting(revise) {
  216. const _ = this.app._;
  217. function removeFieldCols(setting, cols) {
  218. _.remove(setting.cols, function(c) {
  219. return cols.indexOf(c.field) > -1;
  220. });
  221. }
  222. const tender = this.ctx.tender;
  223. const setting = tender.data.measure_type === measureType.tz.value
  224. ? (tender.info.display.ledger.clQty ? spreadConst.withCl : spreadConst.withoutCl)
  225. : (tender.info.display.ledger.clQty ? spreadConst.withClGcl : spreadConst.withoutClGcl);
  226. const ledger = JSON.parse(JSON.stringify(setting.ledger));
  227. const pos = setting.pos ? JSON.parse(JSON.stringify(setting.pos)) : spreadConst.blank;
  228. if (revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  229. ledger.readOnly = true;
  230. pos.readOnly = true;
  231. }
  232. if (tender.data.measure_type === measureType.tz.value) {
  233. removeFieldCols(ledger, spreadConst.filterCols.tzWithoutCols);
  234. }
  235. if (!tender.info.display.ledger.dgnQty) {
  236. removeFieldCols(ledger, spreadConst.filterCols.dgnCols);
  237. }
  238. return [ledger, pos];
  239. }
  240. async _getDefaultReviseInfoData(ctx, revise) {
  241. // const reviseBills = revise.bills_file
  242. // ? JSON.parse(await fs.readFileSync(this.ctx.app.config.filePath + revise.bills_file, 'utf8'))
  243. // : await ctx.service.reviseBills.getData(ctx.tender.id);
  244. // const revisePos = revise.pos_file
  245. // ? JSON.parse(await fs.readFileSync(this.ctx.app.config.filePath + revise.pos_file, 'utf8'))
  246. // : await ctx.service.revisePos.getData(ctx.tender.id);
  247. const [ledgerSpread, posSpread] = this._getSpreadSetting(revise);
  248. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
  249. ctx.tender.data.valuation, ctx.tender.data.measure_type);
  250. const curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  251. const user = await ctx.service.projectAccount.getAccountInfoById(revise.uid);
  252. const times = revise.status === audit.revise.status.checkNo ? revise.times - 1 : revise.times;
  253. const auditors = revise.status === audit.revise.status.checkNo && revise.uid === ctx.session.sessionUser.accountId ?
  254. await ctx.service.reviseAudit.getAuditorsWithOwner(revise.id, revise.times) :
  255. await ctx.service.reviseAudit.getAuditorsWithOwner(revise.id, times);
  256. const auditHistory = [];
  257. if (times >= 1) {
  258. for (let i = 1; i <= times; i++) {
  259. auditHistory.push(await ctx.service.reviseAudit.getAuditors(revise.id, i));
  260. }
  261. }
  262. return {
  263. revise, tender: ctx.tender.data,
  264. // reviseBills, revisePos,
  265. ledgerSpread, posSpread, tenderMenu, measureType,
  266. preUrl: '/tender/' + ctx.tender.id,
  267. audit: audit.revise,
  268. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.info),
  269. stdBills,
  270. auditConst: audit.revise,
  271. stdChapters,
  272. curAuditor,
  273. auditors,
  274. user,
  275. auditHistory,
  276. shenpiConst,
  277. };
  278. }
  279. /**
  280. * 历史修订页面(修订完成后,用于查看)
  281. * @param ctx
  282. * @param revise
  283. * @return {Promise<void>}
  284. * @private
  285. */
  286. async _getHistoryReviseInfo(ctx, revise) {
  287. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  288. renderData.ledgerSpread.readOnly = true;
  289. renderData.posSpread.readOnly = true;
  290. renderData.readOnly = true;
  291. renderData.history = true;
  292. renderData.historyRevise = await ctx.service.ledgerRevise.getAllReviseList(ctx.tender.id);
  293. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  294. }
  295. /**
  296. * 修订页面(草稿,审批中)
  297. * @param ctx
  298. * @param revise
  299. * @return {Promise<void>}
  300. * @private
  301. */
  302. async _getAuditReviseInfo(ctx, revise) {
  303. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  304. renderData.readOnly = true;
  305. renderData.ledgerSpread.readOnly = true;
  306. renderData.posSpread.readOnly = true;
  307. renderData.history = false;
  308. renderData.historyRevise = [];
  309. renderData.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  310. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  311. }
  312. async _getDraftReviseInfo(ctx, revise) {
  313. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  314. // 台账只读、使用数据
  315. renderData.readOnly = false;
  316. // const lastStage = await ctx.service.stage.getLastestStage(ctx.tender.id, true);
  317. // if (lastStage) {
  318. // if (lastStage.status === audit.stage.status.checked) {
  319. // const usedPreBills = await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, lastStage.order);
  320. // for (const b of renderData.reviseBills) {
  321. // b.used = usedPreBills.indexOf(b.id) >= 0;
  322. // }
  323. // const usedPrePos = await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, lastStage.order);
  324. // for (const p of renderData.revisePos) {
  325. // p.used = usedPrePos.indexOf(p.id) >= 0;
  326. // }
  327. // } else {
  328. // const usedPreBills = lastStage.order > 1 ? await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, lastStage.order - 1) : [];
  329. // const usedCurBills = await ctx.service.stageBills.getStageUsedBills(ctx.tender.id, lastStage.id);
  330. // for (const b of renderData.reviseBills) {
  331. // b.used = usedPreBills.indexOf(b.id) >= 0 || usedCurBills.indexOf(b.id) >= 0;
  332. // }
  333. // const usedPrePos = lastStage.order > 1 ? await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, lastStage.order - 1) : [];
  334. // const usedCurPos = await ctx.service.stagePos.getStageUsedPos(ctx.tender.id, lastStage.id);
  335. // for (const p of renderData.revisePos) {
  336. // p.used = usedPrePos.indexOf(p.id) >= 0 || usedCurPos.indexOf(p.id) >= 0;
  337. // }
  338. // }
  339. // }
  340. // 修订历史
  341. renderData.history = false;
  342. renderData.historyRevise = [];
  343. // 添加审批人相关
  344. // renderData.accountGroup = accountGroup;
  345. renderData.accountList = await ctx.service.projectAccount.getAllDataByCondition({
  346. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  347. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  348. });
  349. renderData.accountGroup = accountGroup.map((item, idx) => {
  350. const groupList = renderData.accountList.filter(item => item.account_group === idx);
  351. return { groupName: item, groupList };
  352. });
  353. renderData.auditorList = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
  354. renderData.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  355. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  356. }
  357. /**
  358. * 修订 详细页面(Get)
  359. * @param ctx
  360. * @return {Promise<void>}
  361. */
  362. async info(ctx) {
  363. try {
  364. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  365. if (!revise) throw '台账修订数据有误';
  366. if (revise.uid === ctx.session.sessionUser.accountId &&
  367. (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
  368. await this._getDraftReviseInfo(ctx, revise);
  369. } else if (revise.status === audit.revise.status.checked) {
  370. await this._getHistoryReviseInfo(ctx, revise);
  371. } else {
  372. await this._getAuditReviseInfo(ctx, revise);
  373. }
  374. } catch (err) {
  375. this.log(err);
  376. ctx.redirect(ctx.request.header.referer);
  377. }
  378. }
  379. async loadInfoData(ctx) {
  380. try {
  381. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  382. if (!revise) throw '台账修订数据有误';
  383. const billsFile = revise.status === audit.revise.status.checked && revise.bills_file
  384. ? this.ctx.app.config.filePath + revise.bills_file
  385. : undefined;
  386. const reviseBills = billsFile && fs.existsSync(billsFile)
  387. ? JSON.parse(await fs.readFileSync(billsFile, 'utf8'))
  388. : await ctx.service.reviseBills.getData(ctx.tender.id);
  389. const posFile = revise.status === audit.revise.status.checked && revise.pos_file
  390. ? this.ctx.app.config.filePath + revise.pos_file
  391. : undefined;
  392. const revisePos = posFile && fs.existsSync(posFile)
  393. ? JSON.parse(await fs.readFileSync(posFile, 'utf8'))
  394. : await ctx.service.revisePos.getData(ctx.tender.id);
  395. if (revise.uid === ctx.session.sessionUser.accountId &&
  396. (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
  397. const lastStage = await ctx.service.stage.getLastestStage(ctx.tender.id, true);
  398. if (lastStage) {
  399. if (lastStage.status === audit.stage.status.checked) {
  400. const usedPreBills = await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, lastStage.order);
  401. for (const b of reviseBills) {
  402. b.used = usedPreBills.indexOf(b.id) >= 0;
  403. }
  404. const usedPrePos = await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, lastStage.order);
  405. for (const p of revisePos) {
  406. p.used = usedPrePos.indexOf(p.id) >= 0;
  407. }
  408. } else {
  409. const usedPreBills = lastStage.order > 1 ? await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, lastStage.order - 1) : [];
  410. const usedCurBills = await ctx.service.stageBills.getStageUsedBills(ctx.tender.id, lastStage.id);
  411. for (const b of reviseBills) {
  412. b.used = usedPreBills.indexOf(b.id) >= 0 || usedCurBills.indexOf(b.id) >= 0;
  413. }
  414. const usedPrePos = lastStage.order > 1 ? await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, lastStage.order - 1) : [];
  415. const usedCurPos = await ctx.service.stagePos.getStageUsedPos(ctx.tender.id, lastStage.id);
  416. for (const p of revisePos) {
  417. p.used = usedPrePos.indexOf(p.id) >= 0 || usedCurPos.indexOf(p.id) >= 0;
  418. }
  419. }
  420. }
  421. }
  422. ctx.body = { err: 0, msg: '', data: { bills: reviseBills, pos: revisePos } };
  423. } catch (err) {
  424. ctx.helper.log(err);
  425. this.ajaxErrorBody(err, '加载台账修订数据错误');
  426. }
  427. }
  428. async checkData(ctx) {
  429. try {
  430. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  431. if (!revise) throw '台账修订数据有误';
  432. const reviseBills = await ctx.service.reviseBills.getData(ctx.tender.id);
  433. const revisePos = await ctx.service.revisePos.getData(ctx.tender.id);
  434. const qtyData = ctx.helper.checkBillsWithPos(reviseBills, revisePos,
  435. ['sgfh_qty', 'qtcl_qty', 'sjcl_qty', 'quantity']);
  436. qtyData.error.forEach(x => { x.errorType = 'qty'; });
  437. const tpData = ctx.helper.checkBillsTp(reviseBills, [
  438. {qty: 'sgfh_qty', tp: 'sgfh_tp'}, {qty: 'qtcl_qty', tp: 'qtcl_tp'},
  439. {qty: 'sjcl_qty', tp: 'sjcl_tp'}, {qty: 'quantity', tp: 'total_price'}
  440. ], this.ctx.tender.info.decimal);
  441. tpData.error.forEach(x => { x.errorType = 'tp'; });
  442. ctx.body = { err: 0, msg: '', data: {
  443. error: [...qtyData.error, ...tpData.error],
  444. source: {
  445. bills: [...qtyData.source.bills, ...tpData.source.bills],
  446. pos: [...qtyData.source.pos, ...tpData.source.pos],
  447. },
  448. }
  449. };
  450. } catch (err) {
  451. this.log(err);
  452. ctx.body = this.ajaxErrorBody(err, '检查数据错误');
  453. }
  454. }
  455. async history(ctx) {
  456. try {
  457. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id, false);
  458. if (!revise) throw '台账修订数据有误';
  459. // const reviseBills = await ctx.service.ledger.getData(ctx.tender.id);
  460. // const revisePos = await ctx.service.pos.getPosData({tid: ctx.tender.id});
  461. const [ledgerSpread, posSpread] = this._getSpreadSetting(revise);
  462. ledgerSpread.readOnly = true;
  463. posSpread.readOnly = true;
  464. const historyRevise = await ctx.service.ledgerRevise.getAllReviseList(ctx.tender.id);
  465. // 获取审批流程中右边列表
  466. const auditHistory = [];
  467. const times = revise.status === audit.revise.status.checkNo ? revise.times - 1 : revise.times;
  468. if (times >= 1) {
  469. for (let i = 1; i <= times; i++) {
  470. auditHistory.push(await ctx.service.reviseAudit.getAuditors2ReviseList(revise.id, i));
  471. }
  472. }
  473. const user = await ctx.service.projectAccount.getAccountInfoById(revise.uid);
  474. // 获取审批流程中左边列表
  475. const auditors = await ctx.service.reviseAudit.getAuditorsWithOwner(revise.id, times);
  476. const renderData = {
  477. measureType, audit, revise,
  478. ledgerSpread, posSpread,
  479. // reviseBills, revisePos,
  480. readOnly: true,
  481. historyRevise,
  482. auditHistory,
  483. auditors,
  484. auditConst: audit.revise,
  485. user,
  486. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.history),
  487. };
  488. await this.layout('revise/history.ejs', renderData, 'revise/history_modal.ejs');
  489. } catch (err) {
  490. this.log(err);
  491. ctx.redirect(ctx.request.header.referer);
  492. }
  493. }
  494. async historyInfo(ctx) {
  495. try {
  496. const data = JSON.parse(ctx.request.body.data);
  497. if (!data || !data.rid || data.rid === '') throw '查询的台账修订有误';
  498. const reviseInfo = await ctx.service.ledgerRevise.getRevise(ctx.tender.id, data.rid);
  499. reviseInfo.end_time_str = reviseInfo.end_time ? ctx.moment(reviseInfo.end_time).format('YYYY-MM-DD HH:mm:ss') : '';
  500. ctx.body = { err: 0, msg: '', data: reviseInfo };
  501. } catch (err) {
  502. this.log(err);
  503. ctx.body = this.ajaxErrorBody(err, '获取台账修订历史数据错误');
  504. }
  505. }
  506. /**
  507. * 加载 数据
  508. * @param {} ctx
  509. */
  510. async loadHistoryData(ctx) {
  511. try {
  512. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id, false);
  513. if (!revise) throw '台账修订数据有误';
  514. const reviseBills = await ctx.service.ledger.getData(ctx.tender.id);
  515. const revisePos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  516. ctx.body = { err: 0, msg: '', data: { bills: reviseBills, pos: revisePos } };
  517. } catch (error) {
  518. ctx.helper.log(error);
  519. this.ajaxErrorBody(error, '获取台账修订数据错误,请刷新页面');
  520. }
  521. }
  522. async checkRevise(ctx) {
  523. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  524. if (revise.uid !== ctx.session.sessionUser.accountId) {
  525. throw '修订数据错误';
  526. } else if (revise.status === audit.revise.status.checking) {
  527. throw '修订审批中,不可修改';
  528. } else if (revise.status === audit.revise.status.checked) {
  529. throw '修订已完成,如需修订台账,请新增修订';
  530. }
  531. return revise;
  532. }
  533. async _billsBase(revise, type, data) {
  534. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  535. if (type !== 'add') {
  536. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  537. }
  538. switch (type) {
  539. case 'add':
  540. return await this.ctx.service.reviseBills.addReviseNode(revise.tid, revise.id, data.id, data.count);
  541. case 'delete':
  542. return await this.ctx.service.reviseBills.delete(revise.tid, data.id, data.count);
  543. case 'up-move':
  544. return await this.ctx.service.reviseBills.upMoveNode(revise.tid, data.id, data.count);
  545. case 'down-move':
  546. return await this.ctx.service.reviseBills.downMoveNode(revise.tid, data.id, data.count);
  547. case 'up-level':
  548. return await this.ctx.service.reviseBills.upLevelNode(revise.tid, data.id, data.count);
  549. case 'down-level':
  550. return await this.ctx.service.reviseBills.downLevelNode(revise.tid, data.id, data.count);
  551. }
  552. }
  553. async _batchInsert(revise, data) {
  554. if ((isNaN(data.id) || data.id <= 0) || !data.batchType) {
  555. throw '参数错误';
  556. }
  557. switch (data.batchType) {
  558. case 'child':
  559. return await this.ctx.service.reviseBills.batchInsertChild(revise.tid, revise.id, data.id, data.batchData);
  560. case 'next':
  561. return await this.ctx.service.reviseBills.batchInsertNext(revise.tid, revise.id, data.id, data.batchData);
  562. default:
  563. throw '参数错误';
  564. }
  565. }
  566. async _pasteBlock(revise, data) {
  567. if ((isNaN(data.id) || data.id <= 0) ||
  568. (!data.tid && data.tid <= 0) ||
  569. (!data.block || data.block.length <= 0)) throw '参数错误';
  570. return await this.ctx.service.reviseBills.pasteBlockData(this.ctx.tender.id, data.id, data.block, { crid: revise.id });
  571. }
  572. async _addStd(revise, data) {
  573. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdNode) throw '参数错误';
  574. // todo 校验项目是否使用该库的权限
  575. let stdLib,
  576. addType;
  577. switch (data.stdType) {
  578. case 'xmj':
  579. stdLib = this.ctx.service.stdXmj;
  580. addType = stdDataAddType.withParent;
  581. break;
  582. case 'gcl':
  583. stdLib = this.ctx.service.stdGcl;
  584. const selectNode = await this.ctx.service.reviseBills.getDataByKid(revise.tid, data.id);
  585. if (selectNode.b_code) {
  586. addType = stdDataAddType.next;
  587. } else {
  588. addType = stdDataAddType.child;
  589. }
  590. break;
  591. default:
  592. throw '未知标准库';
  593. }
  594. const stdData = await stdLib.getDataByDataId(data.stdLibId, data.stdNode);
  595. switch (addType) {
  596. case stdDataAddType.child:
  597. return await this.ctx.service.reviseBills.addStdNodeAsChild(revise.tid, data.id, stdData, revise.id);
  598. break;
  599. case stdDataAddType.next:
  600. return await this.ctx.service.reviseBills.addStdNode(revise.tid, data.id, stdData, revise.id);
  601. case stdDataAddType.withParent:
  602. return await this.ctx.service.reviseBills.addStdNodeWithParent(revise.tid, stdData, stdLib, revise.id);
  603. default:
  604. throw '未知添加方式';
  605. }
  606. }
  607. async _addDeal(revise, data) {
  608. if (!data.type || !data.dealBills) throw '数据错误';
  609. data.dealBills.unit_price = this.ctx.helper.round(data.dealBills.unit_price, this.ctx.tender.info.decimal.up);
  610. if (data.type === 'child') {
  611. return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.dealBills, revise.id);
  612. } else if (data.type === 'next') {
  613. return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.dealBills, revise.id);
  614. }
  615. throw '数据错误';
  616. }
  617. async _addBg(revise, data) {
  618. if (!data.type || !data.bgBills) throw '数据错误';
  619. data.bgBills.unit_price = this.ctx.helper.round(data.bgBills.unit_price, this.ctx.tender.info.decimal.up);
  620. if (data.type === 'child') {
  621. return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.bgBills, revise.id);
  622. } else if (data.type === 'next') {
  623. return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.bgBills, revise.id);
  624. }
  625. throw '数据错误';
  626. }
  627. async _updatePos(revise, data) {
  628. await this.checkMeasureType(measureType.tz.value);
  629. if (!data.posPostType) throw '数据错误';
  630. switch (data.posPostType) {
  631. case 'add':
  632. return await this.ctx.service.revisePos.addPos(revise.tid, revise.id, data.postData);
  633. case 'update':
  634. if (data.postData instanceof Array) {
  635. return await this.ctx.service.revisePos.updatePosArr(revise.tid, data.postData);
  636. }
  637. return await this.ctx.service.revisePos.updatePos(revise.tid, data.postData);
  638. case 'delete':
  639. return await this.ctx.service.revisePos.deletePos(revise.tid, data.postData);
  640. case 'paste':
  641. return await this.ctx.service.revisePos.pastePosData(revise.tid, revise.id, data.postData);
  642. default:
  643. throw '未知操作';
  644. }
  645. }
  646. async update(ctx) {
  647. try {
  648. if (!ctx.tender.data) throw '标段数据错误';
  649. const data = JSON.parse(ctx.request.body.data);
  650. if (!data.postType || !data.postData) throw '数据错误';
  651. const responseData = { err: 0, msg: '', data: {} };
  652. const revise = await this.checkRevise(ctx);
  653. switch (data.postType) {
  654. case 'add':
  655. case 'delete':
  656. case 'up-move':
  657. case 'down-move':
  658. case 'up-level':
  659. case 'down-level':
  660. responseData.data = await this._billsBase(revise, data.postType, data.postData);
  661. break;
  662. case 'update':
  663. responseData.data = await this.ctx.service.reviseBills.updateCalc(revise.tid, data.postData);
  664. break;
  665. case 'batch-insert':
  666. responseData.data = await this._batchInsert(revise, data.postData);
  667. break;
  668. case 'add-deal':
  669. responseData.data = await this._addDeal(revise, data.postData);
  670. break;
  671. case 'add-bg':
  672. responseData.data = await this._addDeal(revise, data.postData);
  673. break;
  674. case 'add-std':
  675. responseData.data = await this._addStd(revise, data.postData);
  676. break;
  677. case 'paste-block':
  678. responseData.data = await this._pasteBlock(revise, data.postData);
  679. break;
  680. case 'pos':
  681. responseData.data = await this._updatePos(revise, data);
  682. break;
  683. default:
  684. throw '未知操作';
  685. }
  686. ctx.body = responseData;
  687. } catch (err) {
  688. this.log(err);
  689. ctx.body = this.ajaxErrorBody(err, '数据错误');
  690. }
  691. }
  692. /**
  693. * 上传 清单Excel 并导入
  694. * @param ctx
  695. * @return {Promise<void>}
  696. */
  697. async uploadExcel(ctx) {
  698. try {
  699. const revise = await this.checkRevise(ctx);
  700. const ueType = ctx.params.ueType;
  701. const compressData = ctx.request.body.data;
  702. const data = JSON.parse(LzString.decompressFromUTF16(compressData));
  703. const responseData = { err: 0, msg: '', data: {} };
  704. switch (ueType) {
  705. case 'gcl2xmj':
  706. responseData.data = await ctx.service.reviseBills.importGclExcel(data.id, data.sheet, { crid: revise.id });
  707. break;
  708. }
  709. ctx.body = responseData;
  710. } catch (err) {
  711. this.log(err);
  712. ctx.body = { err: 1, msg: err.toString(), data: null };
  713. }
  714. }
  715. /**
  716. * 填设计量(Ajax)
  717. *
  718. * @param ctx
  719. * @return {Promise<void>}
  720. */
  721. async deal2sgfh(ctx) {
  722. try {
  723. const revise = await this.checkRevise(ctx);
  724. if (this.ctx.tender.measure_type === measureType.tz.value) throw '该功能仅工程量清单模式可用';
  725. await this.ctx.service.revise.deal2sgfh(ctx.tender.id);
  726. const ledgerData = await ctx.service.revise.getData(ctx.tender.id);
  727. ctx.body = { err: 0, msg: '', data: { bills: ledgerData } };
  728. } catch (err) {
  729. this.log(err);
  730. ctx.body = { err: 1, msg: err.toString(), data: null };
  731. }
  732. }
  733. /**
  734. * 新增审批人(Ajax)
  735. *
  736. * @param ctx
  737. * @return {Promise<void>}
  738. */
  739. async addAuditor(ctx) {
  740. try {
  741. const data = JSON.parse(ctx.request.body.data);
  742. const id = data.auditorId;
  743. if (isNaN(id) || id <= 0) {
  744. throw '参数错误';
  745. }
  746. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  747. if (!revise) throw '台账修订数据有误';
  748. // 检查权限等
  749. if (revise.uid !== ctx.session.sessionUser.accountId) throw '您无权添加审核人';
  750. if (revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  751. throw '当前不允许添加审核人';
  752. }
  753. // 检查审核人是否已存在
  754. const exist = await ctx.service.reviseAudit.getAuditor(revise.id, id, revise.times);
  755. if (exist) throw '该审核人已存在,请勿重复添加';
  756. const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.revise, sp_status: shenpiConst.sp_status.gdzs });
  757. const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.revise === shenpiConst.sp_status.gdzs ? 1 : 0;
  758. const result = await ctx.service.reviseAudit.addAuditor(revise, id, is_gdzs);
  759. if (!result) throw '添加审核人失败';
  760. const resultData = await ctx.service.reviseAudit.getAuditorsWithOwner(revise.id, revise.times);
  761. ctx.body = { err: 0, msg: '', data: resultData };
  762. } catch (err) {
  763. this.log(err, '数据错误');
  764. ctx.body = this.ajaxErrorBody(err);
  765. }
  766. }
  767. /**
  768. * 移除审批人(Ajax)
  769. *
  770. * @param ctx
  771. * @return {Promise<void>}
  772. */
  773. async removeAuditor(ctx) {
  774. try {
  775. const data = JSON.parse(ctx.request.body.data);
  776. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  777. if (isNaN(id) || id <= 0) {
  778. throw '参数错误';
  779. }
  780. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  781. if (!revise) throw '台账修订数据有误';
  782. const result = await ctx.service.reviseAudit.deleteAuditor(revise, id);
  783. if (!result) {
  784. throw '移除审核人失败';
  785. }
  786. const resultData = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
  787. ctx.body = { err: 0, msg: '', data: resultData };
  788. } catch (err) {
  789. this.log(err, '数据错误');
  790. ctx.body = this.ajaxErrorBody(err);
  791. }
  792. }
  793. /**
  794. * 上报(ajax-post)
  795. *
  796. * @param ctx
  797. * @return {Promise<void>}
  798. */
  799. async start(ctx) {
  800. try {
  801. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  802. if (!revise || revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  803. throw '台账修订数据有误';
  804. }
  805. if (revise.content === '') {
  806. throw '未填写修订内容,请先填写并保存修订内容';
  807. }
  808. if (revise.uid !== ctx.session.sessionUser.accountId) throw '上报失败';
  809. await ctx.service.reviseAudit.start(revise, revise.times);
  810. ctx.body = { err: 0, msg: '', data: {} };
  811. } catch (err) {
  812. this.log(err);
  813. ctx.session.postError = err.toString();
  814. ctx.body = this.ajaxErrorBody(err, '上报失败');
  815. }
  816. }
  817. /**
  818. * 审批(post)
  819. *
  820. * @param ctx
  821. * @return {Promise<void>}
  822. */
  823. async check(ctx) {
  824. try {
  825. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  826. if (!revise || revise.status !== audit.revise.status.checking) throw '台账修订数据有误';
  827. const curAudit = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  828. if (curAudit.audit_id !== ctx.session.sessionUser.accountId) throw '审批失败';
  829. const checkType = parseInt(ctx.request.body.checkType);
  830. if (!checkType || isNaN(checkType)) throw '提交数据错误';
  831. await ctx.service.reviseAudit.check(revise, checkType, ctx.request.body.opinion, revise.times);
  832. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  833. } catch (err) {
  834. this.log(err);
  835. this.postError(err, '审批失败');
  836. ctx.redirect('/tender/' + ctx.tender.id + '/revise/info');
  837. }
  838. }
  839. async _getLastStage(ctx) {
  840. const stages = await ctx.service.stage.getAllDataByCondition({
  841. where: {tid: ctx.tender.id},
  842. orders: [['order', 'desc']],
  843. });
  844. if (stages.length > 0) {
  845. if (stages[0].status !== audit.stage.status.uncheck || stages[0].user_id === ctx.session.sessionUser.accountId) {
  846. return stages[0]
  847. } else if (stages.length > 1) {
  848. return stages[1];
  849. }
  850. }
  851. return null;
  852. }
  853. async compare(ctx) {
  854. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  855. if (!revise) throw '台账修订数据有误';
  856. const lastStage = await this._getLastStage(ctx);
  857. const renderData = {
  858. revise,
  859. measureType,
  860. lastStage,
  861. audit,
  862. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.compare),
  863. };
  864. await this.layout('revise/compare.ejs', renderData, 'revise/compare_modal.ejs');
  865. }
  866. _loadPreData(curData, preData, field, prefix, relaId, extraFields = []) {
  867. if (preData.length === 0) return;
  868. for (const pd of preData) {
  869. const cd = curData.find(x => {return x[relaId] === pd[relaId]});
  870. if (cd) {
  871. for (const f of field) {
  872. cd[prefix + f] = pd[f];
  873. }
  874. } else {
  875. const ncd = {id: pd.id};
  876. ncd[relaId] = pd[relaId];
  877. for (const ef of extraFields) {
  878. ncd[ef] = pd[ef];
  879. }
  880. for (const f of field) {
  881. ncd[prefix + f] = pd[f];
  882. }
  883. curData.push(ncd);
  884. }
  885. }
  886. }
  887. async _loadLastStageBillsData(ctx) {
  888. let curStageData;
  889. if (ctx.lastStage.readOnly) {
  890. curStageData = await ctx.service.stageBills.getAuditorStageData(ctx.tender.id,
  891. ctx.lastStage.id, ctx.lastStage.curTimes, ctx.lastStage.curOrder);
  892. } else {
  893. curStageData = await ctx.service.stageBills.getLastestStageData(ctx.tender.id, ctx.lastStage.id);
  894. }
  895. const preStageData = ctx.lastStage.order > 1
  896. ? await ctx.service.stageBillsFinal.getFinalData(ctx.tender.data, ctx.lastStage.order - 1)
  897. : [];
  898. this._loadPreData(curStageData, preStageData, ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], 'pre_', 'lid');
  899. return curStageData;
  900. }
  901. async _loadLastStagePosData(ctx) {
  902. let curStageData;
  903. if (ctx.lastStage.readOnly) {
  904. curStageData = await ctx.service.stagePos.getAuditorStageData2(ctx.tender.id,
  905. ctx.lastStage.id, ctx.lastStage.curTimes, ctx.lastStage.curOrder);
  906. } else {
  907. curStageData = await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, ctx.lastStage.id);
  908. }
  909. const preStageData = ctx.lastStage.order > 1
  910. ? await ctx.service.stagePosFinal.getFinalData(ctx.tender.data, ctx.lastStage.order - 1)
  911. : [];
  912. this._loadPreData(curStageData, preStageData, ['contract_qty', 'qc_qty'], 'pre_', 'pid', ['lid']);
  913. return curStageData;
  914. }
  915. async _loadDataByFilter(ctx, filter) {
  916. switch(filter) {
  917. case 'bills': return await ctx.service.ledger.getAllDataByCondition({where: {tender_id: ctx.tender.id} });
  918. case 'pos': return await ctx.service.pos.getAllDataByCondition({where: {tid: ctx.tender.id} });
  919. case 'reviseBills': return await ctx.service.reviseBills.getAllDataByCondition({where: {tender_id: ctx.tender.id}});
  920. case 'revisePos': return await ctx.service.revisePos.getAllDataByCondition({where: {tid: ctx.tender.id}});
  921. case 'stageBills':
  922. case 'stagePos':
  923. if (!ctx.lastStage) ctx.lastStage = await this._getLastStage(ctx);
  924. await this.ctx.service.stage.doCheckStage(ctx.lastStage);
  925. if (filter === 'stageBills') {
  926. return await this._loadLastStageBillsData(ctx);
  927. } else {
  928. return await this._loadLastStagePosData(ctx);
  929. }
  930. case 'dealBills': return await ctx.service.dealBills.getAllDataByCondition({where: {tender_id: ctx.tender.id}});
  931. }
  932. }
  933. async loadData(ctx) {
  934. try {
  935. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  936. if (!revise) throw '台账修订数据有误';
  937. const data = JSON.parse(ctx.request.body.data);
  938. const filter = data.filter ? data.filter.split(';') : [];
  939. const responseData = { err: 0, msg: '', data: {} };
  940. for (const f of filter) {
  941. if (!f) continue;
  942. responseData.data[f] = await this._loadDataByFilter(ctx, f);
  943. }
  944. ctx.body = responseData;
  945. } catch (err) {
  946. this.ctx.helper.log(err);
  947. this.ajaxErrorBody(err, '加载数据错误,请刷新页面重试');
  948. }
  949. }
  950. async gclCompare(ctx) {
  951. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  952. if (!revise) throw '台账修订数据有误';
  953. const renderData = {
  954. revise,
  955. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.gclCompare),
  956. chapterFilter: stdConst.chapterFilter,
  957. };
  958. await this.layout('revise/gcl_compare.ejs', renderData);
  959. }
  960. async bwtz(ctx) {
  961. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  962. if (!revise) throw '台账修订数据有误';
  963. const renderData = {
  964. revise,
  965. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.bwtz),
  966. };
  967. await this.layout('revise/bwtz.ejs', renderData);
  968. }
  969. }
  970. return ReviseController;
  971. };