revise_controller.js 54 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158
  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 shenpiConst = require('../const/shenpi');
  19. const LzString = require('lz-string');
  20. const stdConst = require('../const/standard');
  21. const spreadSetting = require('../lib/spread_setting');
  22. const path = require('path');
  23. const sendToWormhole = require('stream-wormhole');
  24. module.exports = app => {
  25. class ReviseController extends app.BaseController {
  26. /**
  27. * 构造函数
  28. *
  29. * @param {Object} ctx - egg全局变量
  30. * @return {void}
  31. */
  32. constructor(ctx) {
  33. super(ctx);
  34. }
  35. /**
  36. * 是否可以新增修订
  37. * @param ctx
  38. * @return {Promise<boolean>}
  39. * @private
  40. */
  41. async _getAddReviseValid(ctx) {
  42. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  43. const lastStage = await ctx.service.stage.getFlowLatestStage(ctx.tender.id, true);
  44. const addVisible = (ctx.tender.data.user_id === ctx.session.sessionUser.accountId) &&
  45. (ctx.tender.data.ledger_status === audit.ledger.status.checked) &&
  46. (!revise || !revise.valid || revise.status === audit.revise.status.checked);
  47. const addValid = addVisible && (!lastStage || lastStage.status === audit.stage.status.uncheck ||
  48. lastStage.status === audit.stage.status.checkNo || lastStage.status === audit.stage.status.checked);
  49. let changeValid = true;
  50. // 判断变更是否存在审批中,有则可能无法新增修订
  51. const changeList = await ctx.service.change.getAllDataByCondition({
  52. where: {
  53. tid: ctx.tender.id,
  54. status: [audit.change.status.checking, audit.change.status.checkNoPre],
  55. },
  56. });
  57. if (changeList.length > 0) {
  58. // 判断是否已存在新增部位,有则可能无法新增修订
  59. const changeLedgerList = await ctx.service.changeLedger.getAllDataByCondition({ where: { tender_id: ctx.tender.id, is_leaf: 1 } });
  60. const changePosList = await ctx.service.changePos.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  61. // 判断变更是否已添加新增部位,有则可能无法新增修订
  62. if (changeLedgerList.length > 0 || changePosList.length > 0) {
  63. // 判断审批中的变更令是否有调用了新增部位,有则无法新增修订,都没有则可新增修订
  64. for (const c of changeList) {
  65. const caList = await ctx.service.changeAuditList.getList(c.cid, 0);
  66. const gclIdList = ctx.helper._.uniq(ctx.helper._.map(caList, 'gcl_id'));
  67. for (const gcl of gclIdList) {
  68. if (gcl && (ctx.helper._.findIndex(changeLedgerList, { id: gcl }) !== -1)) {
  69. changeValid = false;
  70. break;
  71. }
  72. }
  73. if (!changeValid) {
  74. break;
  75. }
  76. const posIdList = ctx.helper._.uniq(ctx.helper._.map(caList, 'mx_id'));
  77. for (const pos of posIdList) {
  78. if (pos && (ctx.helper._.findIndex(changePosList, { id: pos }) !== -1)) {
  79. changeValid = false;
  80. break;
  81. }
  82. }
  83. if (!changeValid) {
  84. break;
  85. }
  86. }
  87. }
  88. }
  89. return [addVisible, addValid, changeValid];
  90. }
  91. /**
  92. * 台账修订页面 (Get)
  93. *
  94. * @param {object} ctx - egg全局变量
  95. * @return {void}
  96. */
  97. async index(ctx) {
  98. try {
  99. // 分页相关
  100. const user = await this.ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  101. const condition = { tid: ctx.tender.id };
  102. if (!user.show_revise_invalid) condition.valid = 1;
  103. const count = await ctx.service.ledgerRevise.count(condition);
  104. const ledgerRevise = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id, user.show_revise_invalid);
  105. if (ledgerRevise.length > 0) {
  106. const revise = ledgerRevise[0];
  107. if (ctx.page === 1) {
  108. if (revise.status === audit.revise.status.checked || !revise.valid) {
  109. revise.lastest = true;
  110. } else {
  111. if (ledgerRevise.length > 1) ledgerRevise[1].lastest = true;
  112. // if (revise.status === audit.revise.status.checking) {
  113. // revise.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
  114. // }
  115. }
  116. }
  117. }
  118. for (const lr of ledgerRevise) {
  119. if (lr.valid) {
  120. lr.curAuditors = await ctx.service.reviseAudit.getAuditorsByStatus(lr.id, lr.status, lr.times);
  121. lr.curAuditorIds = lr.curAuditors.map(x => { return x.audit_id; });
  122. }
  123. }
  124. const [addVisible, addValid, changeValid] = await this._getAddReviseValid(ctx);
  125. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
  126. ctx.tender.data.valuation, ctx.tender.data.measure_type);
  127. const renderData = {
  128. tender: ctx.tender.data,
  129. tenderMenu: this.menu.tenderMenu,
  130. preUrl: '/tender/' + ctx.tender.id,
  131. pageInfo: {
  132. page: ctx.page,
  133. total: Math.ceil(count / app.config.pageSize),
  134. queryData: JSON.stringify(ctx.urlInfo.query),
  135. },
  136. ledgerRevise,
  137. addVisible,
  138. addValid,
  139. changeValid,
  140. auditConst: audit.revise,
  141. auditType: audit.auditType,
  142. auditConst2: JSON.stringify(audit.revise),
  143. stdBills,
  144. stdChapters,
  145. show_invalid: user.show_revise_invalid,
  146. };
  147. await this.layout('revise/index.ejs', renderData, 'revise/modal.ejs');
  148. } catch (err) {
  149. this.log(err);
  150. ctx.redirect(ctx.request.header.referer);
  151. }
  152. }
  153. async showInvalid(ctx) {
  154. try {
  155. await ctx.service.projectAccount.defaultUpdate({ id: ctx.session.sessionUser.accountId, show_revise_invalid: ctx.query.show });
  156. } catch (err) {
  157. this.log(err);
  158. }
  159. ctx.redirect(ctx.request.header.referer);
  160. }
  161. /**
  162. * 修订审批流程(Get)
  163. * @param ctx
  164. * @return {Promise<void>}
  165. */
  166. async reviseAuditors(ctx) {
  167. try {
  168. const rid = JSON.parse(ctx.request.body.data).id;
  169. const reviseInfo = await ctx.service.ledgerRevise.getDataById(rid);
  170. await ctx.service.reviseAudit.loadReviseUser(reviseInfo);
  171. await ctx.service.reviseAudit.loadReviseAuditViewData(reviseInfo);
  172. ctx.body = { err: 0, msg: '', data: reviseInfo};
  173. } catch (error) {
  174. this.log(error);
  175. ctx.body = { err: 1, msg: error.toString(), data: null };
  176. }
  177. }
  178. /**
  179. * 新增 修订 (Post)
  180. * @param ctx
  181. * @return {Promise<void>}
  182. */
  183. async add(ctx) {
  184. try {
  185. const [addValid, changeValid] = await this._getAddReviseValid(ctx);
  186. if (!addValid) {
  187. throw '无法新增修订';
  188. }
  189. if (!changeValid) {
  190. throw '台账修订会影响审批中的变更令(包含新增部位),请审批完成后再创建台账修订';
  191. }
  192. const revise = await ctx.service.ledgerRevise.add(ctx.tender.id, ctx.session.sessionUser.accountId);
  193. ctx.redirect(`/tender/${ctx.tender.id}/revise/${revise.id}/info`);
  194. } catch (err) {
  195. this.log(err);
  196. ctx.redirect(ctx.request.header.referer);
  197. }
  198. }
  199. /**
  200. * 作废 修订 (Post)
  201. * @param ctx
  202. * @return {Promise<void>}
  203. */
  204. async cancel(ctx) {
  205. try {
  206. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  207. if (!revise) throw '当前标段无任何修订数据';
  208. if (revise.uid !== ctx.session.sessionUser.accountId) {
  209. throw '您无权作废该修订';
  210. }
  211. if (revise.status === audit.revise.checking) {
  212. throw '修订审批中,不可作废';
  213. } else if (revise.status === audit.revise.checked) {
  214. throw '修订已审批通过,不可作废';
  215. }
  216. if (revise.valid) {
  217. revise.readySettle = await this.service.settle.getReadySettle(revise.tid);
  218. const result = await ctx.service.ledgerRevise.cancelRevise(revise);
  219. }
  220. ctx.redirect('/tender/' + ctx.tender.id + '/revise/');
  221. } catch (err) {
  222. this.log(err);
  223. ctx.redirect(ctx.request.header.referer);
  224. }
  225. }
  226. /**
  227. * 保存 修订详情 (Ajax-post)
  228. * @param ctx
  229. * @return {Promise<void>}
  230. */
  231. async save(ctx) {
  232. try {
  233. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  234. if (!revise.valid) {
  235. throw '该修订已作废';
  236. } else if (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo) {
  237. if (ctx.session.sessionUser.accountId !== revise.uid) {
  238. throw '您无权修改';
  239. }
  240. } else if (revise.status === audit.revise.status.checking) {
  241. throw '修订在审批中,不可修改修订数据';
  242. } else if (revise.staut === audit.revise.status.checked) {
  243. throw '修订已经审批通过,不可修改修订数据,请新增下一修订';
  244. }
  245. const data = JSON.parse(ctx.request.body.data);
  246. if (data.content === undefined) {
  247. throw '保存数据有误';
  248. }
  249. const result = await ctx.service.ledgerRevise.defaultUpdate({ id: revise.id, content: data.content });
  250. if (result.affectedRows !== 1) {
  251. throw '保存数据失败,请重试';
  252. }
  253. ctx.body = { err: 0, msg: '', data: null };
  254. } catch (err) {
  255. this.log(err);
  256. ctx.body = this.ajaxErrorBody(err, '保存数据失败,请重试');
  257. }
  258. }
  259. async _getDefaultReviseInfoData(ctx, revise) {
  260. const [ledgerSpread, posSpread] = await spreadSetting.getLedgerSpreadSetting(ctx, revise.tid,
  261. revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked);
  262. const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
  263. ctx.tender.data.valuation, ctx.tender.data.measure_type);
  264. await ctx.service.reviseAudit.loadReviseUser(revise);
  265. await ctx.service.reviseAudit.loadReviseAuditViewData(revise);
  266. return {
  267. revise, tender: ctx.tender.data,
  268. ledgerSpread, posSpread, tenderMenu, measureType,
  269. audit: audit.revise,
  270. auditType: audit.auditType,
  271. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.info),
  272. stdBills,
  273. auditConst: audit.revise,
  274. stdChapters,
  275. shenpiConst,
  276. nodeType: stdConst.nodeType,
  277. settleStatus: ctx.service.settle.settleStatus,
  278. };
  279. }
  280. /**
  281. * 历史修订页面(修订完成后,用于查看)
  282. * @param ctx
  283. * @param revise
  284. * @return {Promise<void>}
  285. * @private
  286. */
  287. async _getHistoryReviseInfo(ctx, revise) {
  288. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  289. renderData.ledgerSpread.readOnly = true;
  290. renderData.posSpread.readOnly = true;
  291. renderData.readOnly = true;
  292. renderData.history = true;
  293. renderData.historyRevise = await ctx.service.ledgerRevise.getAllReviseList(ctx.tender.id);
  294. renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
  295. renderData.preUrl = ctx.url.replace('/info', '');
  296. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  297. }
  298. /**
  299. * 修订页面(草稿,审批中)
  300. * @param ctx
  301. * @param revise
  302. * @return {Promise<void>}
  303. * @private
  304. */
  305. async _getAuditReviseInfo(ctx, revise) {
  306. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  307. renderData.readOnly = true;
  308. renderData.ledgerSpread.readOnly = true;
  309. renderData.posSpread.readOnly = true;
  310. renderData.history = false;
  311. renderData.historyRevise = [];
  312. renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
  313. renderData.preUrl = ctx.url.replace('/info', '');
  314. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  315. }
  316. async _getDraftReviseInfo(ctx, revise) {
  317. const renderData = await this._getDefaultReviseInfoData(ctx, revise);
  318. // 台账只读、使用数据
  319. renderData.readOnly = false;
  320. // 修订历史
  321. renderData.history = false;
  322. renderData.historyRevise = [];
  323. // 添加审批人相关
  324. // renderData.accountGroup = accountGroup;
  325. renderData.accountList = await ctx.service.projectAccount.getAllDataByCondition({
  326. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  327. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  328. });
  329. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  330. renderData.accountGroup = unitList.map(item => {
  331. const groupList = renderData.accountList.filter(item1 => item1.company === item.name);
  332. return { groupName: item.name, groupList };
  333. });
  334. renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
  335. renderData.preUrl = ctx.url.replace('/info', '');
  336. await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
  337. }
  338. /**
  339. * 修订 详细页面(Get)
  340. * @param ctx
  341. * @return {Promise<void>}
  342. */
  343. async info(ctx) {
  344. try {
  345. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  346. if (!revise) throw '台账修订数据有误';
  347. if (revise.uid === ctx.session.sessionUser.accountId &&
  348. (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
  349. await this._getDraftReviseInfo(ctx, revise);
  350. } else if (revise.status === audit.revise.status.checked) {
  351. await this._getHistoryReviseInfo(ctx, revise);
  352. } else {
  353. await this._getAuditReviseInfo(ctx, revise);
  354. }
  355. } catch (err) {
  356. this.log(err);
  357. ctx.redirect(ctx.request.header.referer);
  358. }
  359. }
  360. async loadInfoData(ctx) {
  361. try {
  362. const revise = await ctx.revise;
  363. const reviseBills = revise.readOnly
  364. ? await ctx.helper.loadLedgerDataFromOss(revise.curHis.bills_file)
  365. : await ctx.service.reviseBills.getData(ctx.tender.id);
  366. const revisePos = revise.readOnly
  367. ? await ctx.helper.loadLedgerDataFromOss(revise.curHis.pos_file)
  368. : await ctx.service.revisePos.getData(ctx.tender.id);
  369. // 已计量
  370. if (revise.uid === ctx.session.sessionUser.accountId &&
  371. (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
  372. const stages = await ctx.service.stage.getAllDataByCondition({
  373. where: { tid: ctx.tender.id },
  374. orders: [['order', 'desc']],
  375. });
  376. if (stages.length > 0) {
  377. const usedBills = [], usedPos = [];
  378. for (const s of stages) {
  379. if (s.status === audit.stage.status.checked) {
  380. const usedPreBills = await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, s.order);
  381. usedBills.push(...usedPreBills);
  382. const usedPrePos = await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, s.order);
  383. usedPos.push(...usedPrePos);
  384. break;
  385. } else {
  386. const usedCurBills = await ctx.service.stageBills.getStageUsedBills(ctx.tender.id, s.id);
  387. usedBills.push(...usedCurBills);
  388. const usedCurPos = await ctx.service.stagePos.getStageUsedPos(ctx.tender.id, s.id);
  389. usedPos.push(...usedCurPos);
  390. }
  391. }
  392. for (const b of reviseBills) {
  393. b.used = usedBills.indexOf(b.id) >= 0;
  394. }
  395. for (const p of revisePos) {
  396. p.used = usedPos.indexOf(p.id) >= 0;
  397. }
  398. }
  399. }
  400. // 结算状态
  401. const settleStatusBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
  402. this.ctx.helper.assignRelaData(reviseBills, [
  403. { data: settleStatusBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
  404. ]);
  405. const settleStatusPos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
  406. this.ctx.helper.assignRelaData(revisePos, [
  407. { data: settleStatusPos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
  408. ]);
  409. const ledgerTags = await this.ctx.service.ledgerTag.getDatas(ctx.tender.id);
  410. const price = !revise.readOnly ? await this.ctx.service.revisePrice.getAllDataByCondition({ where: { rid: revise.id } }) : [];
  411. const att = await this.ctx.service.ledgerAtt.getReviseViewData(ctx.tender.id, ctx.revise.id);
  412. ctx.body = { err: 0, msg: '', data: { bills: reviseBills, pos: revisePos, tags: ledgerTags, price, att } };
  413. } catch (err) {
  414. ctx.helper.log(err);
  415. this.ajaxErrorBody(err, '加载台账修订数据错误');
  416. }
  417. }
  418. async checkData(ctx) {
  419. try {
  420. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  421. if (!revise) throw '台账修订数据有误';
  422. const reviseBills = await ctx.service.reviseBills.getData(ctx.tender.id);
  423. const revisePos = await ctx.service.revisePos.getData(ctx.tender.id);
  424. const checkDataModel = require('../lib/ledger').checkData;
  425. const reviseCheck = new checkDataModel(ctx, measureType);
  426. reviseCheck.loadData(reviseBills, revisePos);
  427. ctx.tender.info.ledger_check.same_code && reviseCheck.checkSameCode();
  428. ctx.tender.info.ledger_check.sibling && reviseCheck.checkSibling();
  429. if (ctx.tender.data.measure_type === measureType.tz.value) reviseCheck.checkBillsQty(['sgfh_qty', 'qtcl_qty', 'sjcl_qty', 'quantity']);
  430. reviseCheck.checkBillsTp([
  431. {qty: 'sgfh_qty', tp: 'sgfh_tp'}, {qty: 'qtcl_qty', tp: 'qtcl_tp'},
  432. {qty: 'sjcl_qty', tp: 'sjcl_tp'}, {qty: 'quantity', tp: 'total_price'}
  433. ], this.ctx.tender.info.decimal, x => { return !x.check_calc; });
  434. ctx.body = { err: 0, msg: '', data: reviseCheck.checkResult };
  435. } catch (err) {
  436. this.log(err);
  437. ctx.body = this.ajaxErrorBody(err, '检查数据错误');
  438. }
  439. }
  440. async history(ctx) {
  441. try {
  442. const revise = ctx.revise;
  443. await ctx.service.reviseAudit.loadReviseUser(revise);
  444. await ctx.service.reviseAudit.loadReviseAuditViewData(revise);
  445. const [ledgerSpread, posSpread] = await spreadSetting.getLedgerSpreadSetting(ctx, revise.tid,
  446. revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked);
  447. ledgerSpread.readOnly = true;
  448. posSpread.readOnly = true;
  449. const historyRevise = await ctx.service.ledgerRevise.getAllReviseList(ctx.tender.id);
  450. const user = await ctx.service.projectAccount.getAccountInfoById(revise.uid);
  451. const renderData = {
  452. preUrl: ctx.url.replace('/info', ''),
  453. measureType, audit, revise,
  454. ledgerSpread, posSpread,
  455. readOnly: true,
  456. historyRevise,
  457. auditConst: audit.revise,
  458. auditType: audit.auditType,
  459. user,
  460. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.history),
  461. nodeType: stdConst.nodeType,
  462. settleStatus: ctx.service.settle.settleStatus,
  463. };
  464. await this.layout('revise/history.ejs', renderData, 'revise/history_modal.ejs');
  465. } catch (err) {
  466. this.log(err);
  467. ctx.redirect(ctx.request.header.referer);
  468. }
  469. }
  470. async checkRevise(ctx) {
  471. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  472. if (revise.uid !== ctx.session.sessionUser.accountId) {
  473. throw '修订数据错误';
  474. } else if (revise.status === audit.revise.status.checking) {
  475. throw '修订审批中,不可修改';
  476. } else if (revise.status === audit.revise.status.checked) {
  477. throw '修订已完成,如需修订台账,请新增修订';
  478. }
  479. return revise;
  480. }
  481. async _billsBase(revise, type, data) {
  482. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  483. if (type !== 'add') {
  484. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  485. }
  486. switch (type) {
  487. case 'add':
  488. return await this.ctx.service.reviseBills.addReviseNode(revise.tid, revise.id, data.id, data.count);
  489. case 'delete':
  490. return await this.ctx.service.reviseBills.delete(revise.tid, data.id, data.count);
  491. case 'up-move':
  492. return await this.ctx.service.reviseBills.upMoveNode(revise.tid, data.id, data.count);
  493. case 'down-move':
  494. return await this.ctx.service.reviseBills.downMoveNode(revise.tid, data.id, data.count);
  495. case 'up-level':
  496. return await this.ctx.service.reviseBills.upLevelNode(revise.tid, data.id, data.count);
  497. case 'down-level':
  498. return await this.ctx.service.reviseBills.downLevelNode(revise.tid, data.id, data.count);
  499. }
  500. }
  501. async _batchInsert(revise, data) {
  502. if ((isNaN(data.id) || data.id <= 0) || !data.batchType) {
  503. throw '参数错误';
  504. }
  505. switch (data.batchType) {
  506. case 'child':
  507. return await this.ctx.service.reviseBills.batchInsertChild(revise.tid, revise.id, data.id, data.batchData);
  508. case 'next':
  509. return await this.ctx.service.reviseBills.batchInsertNext(revise.tid, revise.id, data.id, data.batchData);
  510. default:
  511. throw '参数错误';
  512. }
  513. }
  514. async _pasteBlock(revise, data) {
  515. if ((isNaN(data.id) || data.id <= 0) ||
  516. (!data.tid && data.tid <= 0) ||
  517. (!data.block || data.block.length <= 0)) throw '参数错误';
  518. return await this.ctx.service.reviseBills.pasteBlockData(this.ctx.tender.id, data.id, data.block, { crid: revise.id });
  519. }
  520. async _addStd(revise, data) {
  521. if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdData) throw '参数错误';
  522. // todo 校验项目是否使用该库的权限
  523. switch (data.stdType) {
  524. case 'xmj':
  525. return await this.ctx.service.reviseBills.addStdNodeWithParent(revise.tid, data.stdData, revise.id);
  526. case 'gcl':
  527. return data.withParent
  528. ? await this.ctx.service.reviseBills.addGclStdNodeWithParent(revise.tid, data.id, data.stdData, revise.id)
  529. : await this.ctx.service.reviseBills.addGclStdNode(revise.tid, data.id, data.stdData[data.stdData.length - 1], revise.id);
  530. default:
  531. throw '未知标准库';
  532. }
  533. }
  534. async _addDeal(revise, data) {
  535. if (!data.type || !data.dealBills) throw '数据错误';
  536. data.dealBills.unit_price = this.ctx.helper.round(data.dealBills.unit_price, this.ctx.tender.info.decimal.up);
  537. if (data.type === 'child') {
  538. return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.dealBills, revise.id);
  539. } else if (data.type === 'next') {
  540. return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.dealBills, revise.id);
  541. }
  542. throw '数据错误';
  543. }
  544. async _addBg(revise, data) {
  545. if (!data.type || !data.bgBills) throw '数据错误';
  546. data.bgBills.unit_price = this.ctx.helper.round(data.bgBills.unit_price, this.ctx.tender.info.decimal.up);
  547. if (data.type === 'child') {
  548. return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.bgBills, revise.id);
  549. } else if (data.type === 'next') {
  550. return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.bgBills, revise.id);
  551. }
  552. throw '数据错误';
  553. }
  554. async _updatePos(revise, data) {
  555. // await this.checkMeasureType(measureType.tz.value);
  556. if (!data.posPostType) throw '数据错误';
  557. switch (data.posPostType) {
  558. case 'add':
  559. return await this.ctx.service.revisePos.addPos(revise.tid, revise.id, data.postData);
  560. case 'update':
  561. if (data.postData instanceof Array) {
  562. return await this.ctx.service.revisePos.updatePosArr(revise.tid, data.postData);
  563. }
  564. return await this.ctx.service.revisePos.updatePos(revise.tid, data.postData);
  565. case 'delete':
  566. return await this.ctx.service.revisePos.deletePos(revise.tid, data.postData);
  567. case 'paste':
  568. return await this.ctx.service.revisePos.pastePosData(revise.tid, revise.id, data.postData);
  569. case 'insert':
  570. return await this.ctx.service.revisePos.insertPos(revise.tid, revise.id, data.postData);
  571. default:
  572. throw '未知操作';
  573. }
  574. }
  575. async update(ctx) {
  576. try {
  577. if (!ctx.tender.data) throw '标段数据错误';
  578. const data = JSON.parse(ctx.request.body.data);
  579. if (!data.postType || !data.postData) throw '数据错误';
  580. const responseData = { err: 0, msg: '', data: {} };
  581. const revise = await this.checkRevise(ctx);
  582. switch (data.postType) {
  583. case 'add':
  584. case 'delete':
  585. case 'up-move':
  586. case 'down-move':
  587. case 'up-level':
  588. case 'down-level':
  589. responseData.data = await this._billsBase(revise, data.postType, data.postData);
  590. break;
  591. case 'update':
  592. ctx.helper.checkDgnQtyPrecision(data.postData);
  593. responseData.data = await this.ctx.service.reviseBills.updateCalc(revise.tid, data.postData);
  594. break;
  595. case 'batch-insert':
  596. responseData.data = await this._batchInsert(revise, data.postData);
  597. break;
  598. case 'add-deal':
  599. responseData.data = await this._addDeal(revise, data.postData);
  600. break;
  601. case 'add-bg':
  602. responseData.data = await this._addDeal(revise, data.postData);
  603. break;
  604. case 'add-std':
  605. responseData.data = await this._addStd(revise, data.postData);
  606. break;
  607. case 'paste-block':
  608. responseData.data = await this._pasteBlock(revise, data.postData);
  609. break;
  610. case 'pos':
  611. responseData.data = await this._updatePos(revise, data);
  612. break;
  613. default:
  614. throw '未知操作';
  615. }
  616. ctx.body = responseData;
  617. } catch (err) {
  618. this.log(err);
  619. ctx.body = this.ajaxErrorBody(err, '数据错误');
  620. }
  621. }
  622. /**
  623. * 上传 清单Excel 并导入
  624. * @param ctx
  625. * @return {Promise<void>}
  626. */
  627. async uploadExcel(ctx) {
  628. try {
  629. const revise = await this.checkRevise(ctx);
  630. const ueType = ctx.params.ueType;
  631. const compressData = ctx.request.body.data;
  632. const data = JSON.parse(LzString.decompressFromUTF16(compressData));
  633. const responseData = { err: 0, msg: '', data: {} };
  634. switch (ueType) {
  635. case 'gcl2xmj':
  636. responseData.data = await ctx.service.reviseBills.importGclExcel(data.id, data.sheet, { crid: revise.id });
  637. break;
  638. }
  639. ctx.body = responseData;
  640. } catch (err) {
  641. this.log(err);
  642. ctx.body = { err: 1, msg: err.toString(), data: null };
  643. }
  644. }
  645. /**
  646. * 填设计量(Ajax)
  647. *
  648. * @param ctx
  649. * @return {Promise<void>}
  650. */
  651. async deal2sgfh(ctx) {
  652. try {
  653. if (this.ctx.tender.measure_type === measureType.tz.value) throw '该功能仅工程量清单模式可用';
  654. await this.ctx.service.reviseBills.deal2sgfh(ctx.tender.id);
  655. const ledgerData = await ctx.service.reviseBills.getData(ctx.tender.id);
  656. ctx.body = { err: 0, msg: '', data: { bills: ledgerData } };
  657. } catch (err) {
  658. this.log(err);
  659. ctx.body = { err: 1, msg: err.toString(), data: null };
  660. }
  661. }
  662. /**
  663. * 新增审批人(Ajax)
  664. *
  665. * @param ctx
  666. * @return {Promise<void>}
  667. */
  668. async addAuditor(ctx) {
  669. try {
  670. const data = JSON.parse(ctx.request.body.data);
  671. const id = data.auditorId;
  672. if (isNaN(id) || id <= 0) {
  673. throw '参数错误';
  674. }
  675. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  676. if (!revise) throw '台账修订数据有误';
  677. // 检查权限等
  678. if (revise.uid !== ctx.session.sessionUser.accountId) throw '您无权添加审核人';
  679. if (revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  680. throw '当前不允许添加审核人';
  681. }
  682. // 检查审核人是否已存在
  683. const exist = await ctx.service.reviseAudit.getAuditor(revise.id, id, revise.times);
  684. if (exist) throw '该审核人已存在,请勿重复添加';
  685. const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.revise, sp_status: shenpiConst.sp_status.gdzs });
  686. const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.revise === shenpiConst.sp_status.gdzs ? 1 : 0;
  687. const result = await ctx.service.reviseAudit.addAuditor(revise, id, is_gdzs);
  688. if (!result) throw '添加审核人失败';
  689. const resultData = await ctx.service.reviseAudit.getUserGroup(revise.id, revise.times);
  690. ctx.body = { err: 0, msg: '', data: resultData };
  691. } catch (err) {
  692. this.log(err, '数据错误');
  693. ctx.body = this.ajaxErrorBody(err);
  694. }
  695. }
  696. /**
  697. * 移除审批人(Ajax)
  698. *
  699. * @param ctx
  700. * @return {Promise<void>}
  701. */
  702. async removeAuditor(ctx) {
  703. try {
  704. const data = JSON.parse(ctx.request.body.data);
  705. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  706. if (isNaN(id) || id <= 0) {
  707. throw '参数错误';
  708. }
  709. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  710. if (!revise) throw '台账修订数据有误';
  711. const result = await ctx.service.reviseAudit.deleteAuditor(revise, id);
  712. if (!result) {
  713. throw '移除审核人失败';
  714. }
  715. const resultData = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
  716. ctx.body = { err: 0, msg: '', data: resultData };
  717. } catch (err) {
  718. this.log(err, '数据错误');
  719. ctx.body = this.ajaxErrorBody(err);
  720. }
  721. }
  722. /**
  723. * 上报(ajax-post)
  724. *
  725. * @param ctx
  726. * @return {Promise<void>}
  727. */
  728. async start(ctx) {
  729. try {
  730. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  731. if (!revise || revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
  732. throw '台账修订数据有误';
  733. }
  734. if (revise.content === '') {
  735. throw '未填写修订内容,请先填写并保存修订内容';
  736. }
  737. if (revise.uid !== ctx.session.sessionUser.accountId) throw '上报失败';
  738. revise.readySettle = await this.service.settle.getReadySettle(revise.tid);
  739. await ctx.service.reviseAudit.start(revise, revise.times);
  740. ctx.body = { err: 0, msg: '', data: {} };
  741. } catch (err) {
  742. this.log(err);
  743. ctx.session.postError = err.toString();
  744. ctx.body = this.ajaxErrorBody(err, '上报失败');
  745. }
  746. }
  747. /**
  748. * 审批(post)
  749. *
  750. * @param ctx
  751. * @return {Promise<void>}
  752. */
  753. async check(ctx) {
  754. try {
  755. const revise = ctx.revise;
  756. if (!revise || revise.status !== audit.revise.status.checking) throw '台账修订数据有误';
  757. const curAudits = await ctx.service.reviseAudit.getCurAuditors(revise.id, revise.times);
  758. const curAuditorIds = curAudits.map(x => { return x.audit_id; });
  759. if (curAuditorIds.indexOf(ctx.session.sessionUser.accountId) < 0) throw '审批失败';
  760. const checkType = parseInt(ctx.request.body.checkType);
  761. if (!checkType || isNaN(checkType)) throw '提交数据错误';
  762. await ctx.service.reviseAudit.check(ctx.revise, checkType, ctx.request.body.opinion, revise.times);
  763. ctx.redirect(ctx.request.headers.referer);
  764. } catch (err) {
  765. this.log(err);
  766. this.postError(err, '审批失败');
  767. ctx.redirect(ctx.request.headers.referer);
  768. }
  769. }
  770. async _getLastStage(ctx) {
  771. const stages = await ctx.service.stage.getAllDataByCondition({
  772. where: {tid: ctx.tender.id},
  773. orders: [['order', 'desc']],
  774. });
  775. if (stages.length > 0) {
  776. if (stages[0].status !== audit.stage.status.uncheck || stages[0].user_id === ctx.session.sessionUser.accountId) {
  777. return stages[0]
  778. } else if (stages.length > 1) {
  779. return stages[1];
  780. }
  781. }
  782. return null;
  783. }
  784. async compare(ctx) {
  785. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  786. if (!revise) throw '台账修订数据有误';
  787. const lastStage = await this._getLastStage(ctx);
  788. const renderData = {
  789. preUrl: ctx.url.replace('/compare', ''),
  790. revise,
  791. measureType,
  792. lastStage,
  793. audit,
  794. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.compare),
  795. };
  796. await this.layout('revise/compare.ejs', renderData, 'revise/compare_modal.ejs');
  797. }
  798. _loadPreData(curData, preData, field, prefix, relaId, extraFields = []) {
  799. if (preData.length === 0) return;
  800. for (const pd of preData) {
  801. const cd = curData.find(x => {return x[relaId] === pd[relaId]});
  802. if (cd) {
  803. for (const f of field) {
  804. cd[prefix + f] = pd[f];
  805. }
  806. } else {
  807. const ncd = {id: pd.id};
  808. ncd[relaId] = pd[relaId];
  809. for (const ef of extraFields) {
  810. ncd[ef] = pd[ef];
  811. }
  812. for (const f of field) {
  813. ncd[prefix + f] = pd[f];
  814. }
  815. curData.push(ncd);
  816. }
  817. }
  818. }
  819. async _loadLastStageBillsData(ctx) {
  820. let curStageData;
  821. if (ctx.lastStage.readOnly) {
  822. curStageData = await ctx.service.stageBills.getAuditorStageData2(ctx.tender.id,
  823. ctx.lastStage.id, ctx.lastStage.curTimes, ctx.lastStage.curOrder);
  824. } else {
  825. curStageData = await ctx.service.stageBills.getLastestStageData2(ctx.tender.id, ctx.lastStage.id);
  826. }
  827. const preStageData = ctx.lastStage.order > 1
  828. ? await ctx.service.stageBillsFinal.getFinalData(ctx.tender.data, ctx.lastStage.order - 1)
  829. : [];
  830. this._loadPreData(curStageData, preStageData, ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], 'pre_', 'lid');
  831. return curStageData;
  832. }
  833. async _loadLastStagePosData(ctx) {
  834. let curStageData;
  835. if (ctx.lastStage.readOnly) {
  836. curStageData = await ctx.service.stagePos.getAuditorStageData2(ctx.tender.id,
  837. ctx.lastStage.id, ctx.lastStage.curTimes, ctx.lastStage.curOrder);
  838. } else {
  839. curStageData = await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, ctx.lastStage.id);
  840. }
  841. const preStageData = ctx.lastStage.order > 1
  842. ? await ctx.service.stagePosFinal.getFinalData(ctx.tender.data, ctx.lastStage.order - 1)
  843. : [];
  844. this._loadPreData(curStageData, preStageData, ['contract_qty', 'qc_qty'], 'pre_', 'pid', ['lid']);
  845. return curStageData;
  846. }
  847. async _loadChange(ctx) {
  848. const change = await ctx.service.change.getAllDataByCondition({
  849. columns: [ 'cid', 'code', 'name', 'w_code' ],
  850. where: { tid: ctx.tender.id },
  851. orders: [['code', 'asc']],
  852. });
  853. const changeBills = await ctx.service.changeAuditList.getAllDataByCondition({
  854. columns: [ 'cid', 'code', 'name', 'unit', 'unit_price' ],
  855. where: { tid: ctx.tender.id }
  856. });
  857. const changeIndex = {};
  858. change.forEach(x => { changeIndex[x.cid] = x; x.bills = [] });
  859. changeBills.forEach(cb => {
  860. const c = changeIndex[cb.cid];
  861. if (!c) return;
  862. c.bills.push(cb);
  863. });
  864. const helper = ctx.helper;
  865. change.forEach(x => {
  866. x.bills.sort((a, b) => { return helper.compareCode(a.code, b.code)});
  867. });
  868. return change;
  869. }
  870. async _loadDataByFilter(ctx, filter) {
  871. switch(filter) {
  872. case 'bills':
  873. const billsData = ctx.revise.preHis ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.preHis.bills_file) : [];
  874. const settleStatusBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
  875. this.ctx.helper.assignRelaData(billsData, [
  876. { data: settleStatusBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
  877. ]);
  878. return billsData;
  879. case 'pos':
  880. const posData = ctx.revise.preHis ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.preHis.pos_file) : [];
  881. const settleStatusPos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
  882. this.ctx.helper.assignRelaData(posData, [
  883. { data: settleStatusPos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
  884. ]);
  885. return posData;
  886. case 'reviseBills':
  887. const reviseBillsData = ctx.revise.readOnly && ctx.revise.curHis
  888. ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.curHis.bills_file)
  889. : await ctx.service.reviseBills.getAllDataByCondition({ where: { tender_id: ctx.tender.id } });
  890. const settleBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
  891. this.ctx.helper.assignRelaData(reviseBillsData, [
  892. { data: settleBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
  893. ]);
  894. return reviseBillsData;
  895. case 'revisePos':
  896. const revisePosData = ctx.revise.readOnly && ctx.revise.curHis
  897. ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.curHis.pos_file)
  898. : await ctx.service.revisePos.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  899. const settlePos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
  900. this.ctx.helper.assignRelaData(revisePosData, [
  901. { data: settlePos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
  902. ]);
  903. return revisePosData;
  904. case 'stageBills':
  905. case 'stagePos':
  906. if (!ctx.lastStage) ctx.lastStage = await this._getLastStage(ctx);
  907. await this.ctx.service.stage.doCheckStage(ctx.lastStage);
  908. if (filter === 'stageBills') {
  909. return await this._loadLastStageBillsData(ctx);
  910. } else {
  911. return await this._loadLastStagePosData(ctx);
  912. }
  913. case 'dealBills': return await ctx.service.dealBills.getAllDataByCondition({where: {tender_id: ctx.tender.id}});
  914. case 'spec':
  915. const spec = {zlj: stdConst.zlj, jrg: stdConst.jrg};
  916. spec.zlj.deal_bills_tp = ctx.tender.info.deal_param.zanLiePrice;
  917. return spec;
  918. case 'tags':
  919. return await this.ctx.service.ledgerTag.getDatas(ctx.tender.id);
  920. case 'price':
  921. return await this.ctx.service.revisePrice.getAllDataByCondition({ where: { rid: ctx.revise.id } });
  922. case 'change':
  923. return await this._loadChange(ctx);
  924. case 'att':
  925. return await this.ctx.service.ledgerAtt.getReviseViewData(ctx.tender.id, ctx.revise.id);
  926. default: throw '请求的数据不存在';
  927. }
  928. }
  929. async loadData(ctx) {
  930. try {
  931. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  932. if (!revise) throw '台账修订数据有误';
  933. const data = JSON.parse(ctx.request.body.data);
  934. const filter = data.filter ? data.filter.split(';') : [];
  935. const responseData = { err: 0, msg: '', data: {} };
  936. for (const f of filter) {
  937. if (!f) continue;
  938. responseData.data[f] = await this._loadDataByFilter(ctx, f);
  939. }
  940. ctx.body = responseData;
  941. } catch (err) {
  942. this.ctx.helper.log(err);
  943. this.ajaxErrorBody(err, '加载数据错误,请刷新页面重试');
  944. }
  945. }
  946. async gclCompare(ctx) {
  947. const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
  948. if (!revise) throw '台账修订数据有误';
  949. const renderData = {
  950. measureType,
  951. preUrl: ctx.url.replace('/gcl-compare', ''),
  952. revise,
  953. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.gclCompare),
  954. };
  955. await this.layout('revise/gcl_compare.ejs', renderData);
  956. }
  957. async price(ctx) {
  958. if (!ctx.revise) throw '台账修订数据有误';
  959. const renderData = {
  960. preUrl: ctx.url.replace('/price', ''),
  961. revise: ctx.revise,
  962. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.price),
  963. settleStatus: ctx.service.settle.settleStatus,
  964. };
  965. await this.layout('revise/price.ejs', renderData, 'revise/price_modal.ejs');
  966. }
  967. async priceUpdate(ctx) {
  968. try {
  969. if (!ctx.revise) throw '台账修订数据有误';
  970. const data = JSON.parse(ctx.request.body.data);
  971. const result = await ctx.service.revisePrice.updateDatas(data);
  972. ctx.body = { err: 0, msg: '', data: result };
  973. } catch (err) {
  974. ctx.log(err);
  975. ctx.ajaxErrorBody(err, '保存数据失败');
  976. }
  977. }
  978. async uploadFile(ctx) {
  979. let stream;
  980. try {
  981. const parts = ctx.multipart({ autoFields: true });
  982. const files = [];
  983. let index = 0;
  984. const extra_upload = ctx.revise.audit_status === audit.revise.status.checked;
  985. stream = await parts();
  986. while (stream) {
  987. // 判断用户是否选择上传文件
  988. if (!stream.filename) {
  989. throw '请选择上传的文件!';
  990. }
  991. const fileInfo = path.parse(stream.filename);
  992. const create_time = Date.parse(new Date()) / 1000;
  993. const filepath = `${ctx.session.sessionProject.id}/${ctx.tender.id}/revise/att_${create_time + index.toString() + fileInfo.ext}`;
  994. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  995. if (stream) await sendToWormhole(stream);
  996. // 保存数据到att表
  997. const fileData = {
  998. tid: ctx.tender.id,
  999. revise_id: ctx.revise.id,
  1000. revising: !extra_upload,
  1001. in_time: create_time,
  1002. filename: fileInfo.name,
  1003. fileext: fileInfo.ext,
  1004. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  1005. filepath,
  1006. extra_upload,
  1007. };
  1008. const result = await ctx.service.ledgerAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
  1009. if (!result) throw '保存数据失败';
  1010. const attData = await ctx.service.ledgerAtt.getViewDataByFid(result.insertId);
  1011. files.length !== 0 ? files.unshift(attData) : files.push(attData);
  1012. ++index;
  1013. if (Array.isArray(parts.field.size) && index < parts.field.size.length) {
  1014. stream = await parts();
  1015. } else {
  1016. stream = undefined;
  1017. }
  1018. }
  1019. ctx.body = { err: 0, msg: '', data: files };
  1020. } catch (err) {
  1021. ctx.log(err);
  1022. // 失败需要消耗掉stream 以防卡死
  1023. if (stream) await sendToWormhole(stream);
  1024. ctx.ajaxErrorBody(err, '上传文件失败');
  1025. }
  1026. }
  1027. async deleteFile(ctx) {
  1028. try {
  1029. const data = JSON.parse(ctx.request.body.data);
  1030. const fileInfo = await ctx.service.ledgerAtt.getDataById(data.id);
  1031. if (!fileInfo || !Object.keys(fileInfo).length) throw '该文件不存在';
  1032. if (!fileInfo.extra_upload && ctx.revise.status === audit.revise.status.checked) throw '无权限删除';
  1033. if (fileInfo !== undefined && fileInfo !== '') {
  1034. // 先删除文件
  1035. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  1036. // 再删除数据库
  1037. await ctx.service.ledgerAtt.deleteById(data.id);
  1038. } else {
  1039. throw '不存在该文件';
  1040. }
  1041. ctx.body = { err: 0, msg: '', data: null}
  1042. } catch (err) {
  1043. ctx.log(err);
  1044. ctx.ajaxErrorBody(err, '删除文件失败');
  1045. }
  1046. }
  1047. async saveFile(ctx) {
  1048. let stream;
  1049. try {
  1050. stream = await ctx.getFileStream({ requireFile: false });
  1051. let fileData = {};
  1052. if (stream.filename !== undefined) {
  1053. const create_time = Date.parse(new Date()) / 1000;
  1054. const fileInfo = path.parse(stream.filename);
  1055. const filepath = `${ctx.session.sessionProject.id}/${ctx.tender.id}/revise/att_${create_time + fileInfo.ext}`;
  1056. // 保存文件
  1057. await ctx.oss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  1058. // 保存数据到att表
  1059. fileData = {
  1060. filesize: stream.fields.size,
  1061. filepath,
  1062. };
  1063. }
  1064. const org = await ctx.service.ledgerAtt.getDataById(stream.fields.id);
  1065. const result = await ctx.service.ledgerAtt.updateByID(stream.fields, fileData);
  1066. if (!result) throw '保存数据失败';
  1067. // 删除原附件
  1068. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + org.filepath);
  1069. const attData = await ctx.service.ledgerAtt.getViewDataByFid(stream.fields.id);
  1070. ctx.body = { err: 0, msg: '', data: attData };
  1071. responseData.data = attData;
  1072. } catch (err) {
  1073. ctx.log(err);
  1074. // 失败需要消耗掉stream 以防卡死
  1075. if (stream) await sendToWormhole(stream);
  1076. ctx.ajaxErrorBody(err, '保存数据失败');
  1077. }
  1078. }
  1079. }
  1080. return ReviseController;
  1081. };