report_archive_controller.js 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618
  1. 'use strict';
  2. /**
  3. * Created by Tony on 2021/3/31.
  4. */
  5. const path = require('path');
  6. const uuidV1 = require('uuid').v1;
  7. const fs = require('fs');
  8. const MAX_ARCHIVE = 3;
  9. const tenderMenu = require('../../config/menu').tenderMenu;
  10. const measureType = require('../const/tender').measureType;
  11. const fsUtil = require('../public/js/fsUtil');
  12. const auditConst = require('../const/audit');
  13. const signConst = require('../const/sign');
  14. module.exports = app => {
  15. class ReportArchiveController extends app.BaseController {
  16. async index(ctx) {
  17. const tender = ctx.tender;
  18. let stage = ctx.stage;
  19. let stage_id = -1;
  20. let stage_order = -1;
  21. let stage_times = -1;
  22. let stage_status = -1;
  23. const treeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1, tender.data.project_id]);
  24. const custTreeNodes = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(this.ctx.session.sessionUser.accountId);
  25. const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
  26. //
  27. // 。。。
  28. let archiveList = [];
  29. let archiveEncryptionList = [];
  30. // console.log('tender.data.project_id: ' + tender.data.project_id);
  31. if (stage) {
  32. // console.log('ctx.stage.id: ' + ctx.stage.id);
  33. const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, ctx.stage.id);
  34. const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(tender.data.project_id, ctx.stage.id);
  35. stage_id = stage.id;
  36. stage_order = stage.order;
  37. stage_times = stage.times;
  38. stage_status = stage.status;
  39. if (archives.length > 0) {
  40. archiveList = JSON.parse(archives[0].content);
  41. }
  42. if (archiveEncryptions.length > 0) {
  43. archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
  44. }
  45. } else {
  46. // console.log('stageList[0].id: ' + stageList[0].id);
  47. let archives = [];
  48. for (let sidx = stageList.length - 1; sidx >= 0; sidx--) {
  49. if (stageList[sidx].status === 3) {
  50. archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, stageList[sidx].id);
  51. stage_id = stageList[sidx].id;
  52. stage = stageList[sidx];
  53. ctx.stage = stageList[sidx];
  54. break;
  55. }
  56. }
  57. // const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, stageList[stageList.length - 1].id);
  58. const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(tender.data.project_id, stageList[stageList.length - 1].id);
  59. // stage_id = stageList[0].id;
  60. // stage_order = stageList[0].order;
  61. // stage_times = stageList[0].times;
  62. // stage_status = stageList[0].status;
  63. if (archives && archives.length > 0) {
  64. archiveList = JSON.parse(archives[0].content);
  65. }
  66. if (archiveEncryptions && archiveEncryptions.length > 0) {
  67. archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
  68. }
  69. }
  70. let rpt_tpl_items = '{ customize: [], common: [] }';
  71. if (custTreeNodes.length > 0) {
  72. rpt_tpl_items = custTreeNodes[0].rpt_tpl_items;
  73. }
  74. //
  75. const renderData = {
  76. tender: tender.data,
  77. rpt_tpl_data: JSON.stringify(treeNodes),
  78. cust_tpl_data: rpt_tpl_items,
  79. project_id: tender.data.project_id,
  80. tender_id: tender.id,
  81. stg_id: stage_id,
  82. stg_order: stage_order,
  83. stg_times: stage_times,
  84. stg_status: stage_status,
  85. stage_list: JSON.stringify(stageList),
  86. tenderMenu,
  87. measureType,
  88. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
  89. stages: stageList,
  90. auditConst: auditConst.stage,
  91. archiveList,
  92. archiveEncryptionList,
  93. can_netcasign: false,
  94. ossPath: signConst.path.oss,
  95. };
  96. await this.layout('report/index_archive.ejs', renderData);
  97. }
  98. async getReportArchive(ctx) {
  99. const params = JSON.parse(ctx.request.body.params);
  100. // ctx.body = await this._getReport(ctx, params);
  101. const archives = await ctx.service.rptArchive.getPrjStgArchive(params.prjId, params.stgId);
  102. const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(params.prjId, params.stgId);
  103. let archiveList = [];
  104. let archiveEncryptionList = [];
  105. if (archives.length > 0) {
  106. archiveList = JSON.parse(archives[0].content);
  107. }
  108. if (archiveEncryptions.length > 0) {
  109. archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
  110. }
  111. const lastAuditor = await ctx.service.stageAudit.getLastestAuditor(params.stgId, params.stgTimes, auditConst.stage.status.checked);
  112. ctx.body = {
  113. data: archiveList,
  114. encryptionData: archiveEncryptionList,
  115. lastAuditor,
  116. };
  117. }
  118. async addReportArchiveEncryption(ctx) {
  119. const params = JSON.parse(ctx.request.body.params);
  120. const prjId = params.prjId;
  121. const stgId = params.stgId;
  122. const rptId = params.rptId;
  123. const ttlPgs = params.ttlPgs;
  124. const content = params.content;
  125. const orgArchiveList = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(prjId, stgId);
  126. if (orgArchiveList.length > 0) {
  127. const contentArr = JSON.parse(orgArchiveList[0].content);
  128. let hasArchive = false;
  129. for (const item of contentArr) {
  130. if (item.rpt_id === rptId) {
  131. // 考虑到报表模板的稳定性,只保留一项来记录位置就足够了,都不考虑用uuid了
  132. item.encryption = content;
  133. item.total_page = ttlPgs;
  134. hasArchive = true;
  135. break;
  136. }
  137. }
  138. if (!hasArchive) {
  139. // 表示有新的要加
  140. contentArr.push({ rpt_id: rptId, total_page: ttlPgs, encryption: content });
  141. } else {
  142. //
  143. }
  144. const updatedRst = await ctx.service.rptArchiveEncryption.updateArchiveEncryption(orgArchiveList[0].id, prjId, stgId, contentArr);
  145. // console.log(updatedRst);
  146. ctx.body = { err: 0, msg: '', data: { addedRst: contentArr } };
  147. } else {
  148. // 需要增加
  149. const archiveArr = [];
  150. archiveArr.push({ rpt_id: rptId, total_page: ttlPgs, encryption: content });
  151. const addedRst = await ctx.service.rptArchiveEncryption.createArchiveEncryption(prjId, stgId, archiveArr);
  152. // console.log(addedRst);
  153. ctx.body = { err: 0, msg: '', data: { addedRst: archiveArr } };
  154. }
  155. }
  156. async addReportArchive(ctx) {
  157. try {
  158. const stream = await ctx.getFileStream();
  159. const prjId = ctx.params.prjId;
  160. const stgId = ctx.params.stgId;
  161. const rptId = ctx.params.rptId;
  162. const newName = uuidV1();
  163. const fileName = newName + '.PDF';
  164. // console.log('adding fileName: ' + fileName);
  165. // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', 'public/archive', fileName));
  166. const oss_result = await ctx.oss.put('archive/' + fileName, stream);
  167. if (!(oss_result && oss_result.url && oss_result.res.status === 200)) {
  168. throw '上传文件失败';
  169. }
  170. // const url = await ctx.oss.delete('archive/52d3e7f0-c7fb-11eb-b8c2-51b890b95d23.PDF');
  171. // console.log(url);
  172. // const flag = true;
  173. // if (flag) {
  174. // throw 'ok';
  175. // }
  176. const updateDate = new Date();
  177. const montStr = (updateDate.getMonth() + 1) < 10 ? ('0' + (updateDate.getMonth() + 1)) : ((updateDate.getMonth() + 1));
  178. const dateStr = (updateDate.getDate()) < 10 ? ('0' + (updateDate.getDate())) : ((updateDate.getDate()));
  179. const dtStr = updateDate.getFullYear() + '-' + montStr + '-' + dateStr;
  180. const orgArchiveList = await ctx.service.rptArchive.getPrjStgArchive(prjId, stgId);
  181. if (orgArchiveList.length > 0) {
  182. const contentArr = JSON.parse(orgArchiveList[0].content);
  183. let hasArchive = false;
  184. for (const item of contentArr) {
  185. if (item.rpt_id === rptId) {
  186. hasArchive = true;
  187. if (item.items.length >= MAX_ARCHIVE) {
  188. // 超出界限,需要删除时间最旧的那个
  189. let rmIdx = 0;
  190. for (let idx = 1; idx < item.items.length; idx++) {
  191. if (item.items[rmIdx].updateDate_time < item.items[idx].updateDate_time) {
  192. rmIdx = idx;
  193. }
  194. }
  195. // 同时删除oss文件
  196. await ctx.oss.delete('archive/' + item.items[rmIdx].uuid + '.PDF');
  197. item.items.splice(rmIdx, 1);
  198. }
  199. const newItem = { uuid: newName, updateDate_time: dtStr };
  200. item.items.push(newItem);
  201. break;
  202. }
  203. }
  204. if (!hasArchive) {
  205. // 表示有新的模板需要添加
  206. contentArr.push({ rpt_id: rptId, items: [{ uuid: newName, updateDate_time: dtStr }] });
  207. }
  208. const updatedRst = await ctx.service.rptArchive.updateArchive(orgArchiveList[0].id, prjId, stgId, contentArr);
  209. // console.log(updatedRst);
  210. ctx.body = { err: 0, msg: '', data: { fileName, updateDate, addedRst: contentArr } };
  211. } else {
  212. // 需要增加
  213. const archiveArr = [];
  214. archiveArr.push({ rpt_id: rptId, items: [{ uuid: newName, updateDate_time: dtStr }] });
  215. const addedRst = await ctx.service.rptArchive.createArchive(prjId, stgId, archiveArr);
  216. // console.log(addedRst);
  217. ctx.body = { err: 0, msg: '', data: { fileName, updateDate, addedRst: archiveArr } };
  218. }
  219. } catch (err) {
  220. this.log(err);
  221. ctx.body = { err: 1, msg: err.toString(), data: null };
  222. }
  223. }
  224. async updateReportArchiveEncryption(ctx) {
  225. // 在add方法中已经处理
  226. await this.addReportArchiveEncryption(ctx);
  227. }
  228. async updateReportArchive(ctx) {
  229. try {
  230. const stream = await ctx.getFileStream();
  231. const prjId = ctx.params.prjId;
  232. const stgId = ctx.params.stgId;
  233. const rptId = ctx.params.rptId;
  234. const orgName = ctx.params.orgName;
  235. const fileName = orgName + '.PDF';
  236. console.log('updating fileName: ' + fileName);
  237. // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', 'public/archive', fileName));
  238. const oss_result = await ctx.oss.put('archive/' + fileName, stream);
  239. if (!(oss_result && oss_result.url && oss_result.res.status === 200)) {
  240. throw '上传文件失败';
  241. }
  242. // 判断是否存在已签名文档,存在则删除文档并删除签名记录
  243. const pdfMsg = await ctx.curl(signConst.path.oss + '/sign/' + orgName + '.PDF');
  244. if (pdfMsg && pdfMsg.status === 200) {
  245. const oss_reuslt = await ctx.oss.delete('archive/sign/' + fileName);
  246. if (oss_reuslt && oss_reuslt.res && oss_reuslt.res.status === 204) {
  247. const delSign_result = await ctx.service.netcasignLog.removeSign(orgName);
  248. } else {
  249. throw '删除已签文档失败';
  250. }
  251. }
  252. const updateDate = new Date();
  253. const montStr = (updateDate.getMonth() + 1) < 10 ? ('0' + (updateDate.getMonth() + 1)) : ((updateDate.getMonth() + 1));
  254. const dateStr = (updateDate.getDate()) < 10 ? ('0' + (updateDate.getDate())) : ((updateDate.getDate()));
  255. const dtStr = updateDate.getFullYear() + '-' + montStr + '-' + dateStr;
  256. const orgArchiveList = await ctx.service.rptArchive.getPrjStgArchive(prjId, stgId);
  257. if (orgArchiveList.length > 0) {
  258. const contentArr = JSON.parse(orgArchiveList[0].content);
  259. for (const item of contentArr) {
  260. if (item.rpt_id === rptId) {
  261. if (item.items && item.items.length > 0) {
  262. for (const subItem of item.items) {
  263. if (subItem.uuid === orgName) {
  264. subItem.updateDate_time = dtStr;
  265. break;
  266. }
  267. }
  268. } else {
  269. item.items = [{ uuid: orgName, updateDate_time: dtStr }];
  270. }
  271. break;
  272. }
  273. }
  274. const updatedRst = await ctx.service.rptArchive.updateArchive(orgArchiveList[0].id, prjId, stgId, contentArr);
  275. // console.log(updatedRst);
  276. ctx.body = { err: 0, msg: '', data: { fileName, updateDate, updatedRst: contentArr } };
  277. } else {
  278. // 需要增加
  279. const archiveArr = [];
  280. archiveArr.push({ rpt_id: rptId, items: [{ uuid: orgName, updateDate_time: dtStr }] });
  281. const updatedRst = await ctx.service.rptArchive.createArchive(prjId, stgId, archiveArr);
  282. // console.log(updatedRst);
  283. ctx.body = { err: 0, msg: '', data: { fileName, updateDate, updatedRst: archiveArr } };
  284. }
  285. } catch (err) {
  286. this.log(err);
  287. ctx.body = { err: 1, msg: err.toString(), data: null };
  288. }
  289. }
  290. async removeReportArchiveEncryption(ctx) {
  291. try {
  292. const prjId = ctx.params.prjId;
  293. const stgId = ctx.params.stgId;
  294. const rptId = ctx.params.rptId;
  295. const orgArchiveList = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(prjId, stgId);
  296. if (orgArchiveList.length > 0) {
  297. const contentArr = JSON.parse(orgArchiveList[0].content);
  298. for (let idx = 0; idx < contentArr.length; idx++) {
  299. if (contentArr[idx].rpt_id === rptId) {
  300. contentArr.splice(idx, 1);
  301. break;
  302. }
  303. }
  304. const updatedRst = await ctx.service.rptArchive.updateArchive(prjId, stgId, contentArr);
  305. ctx.body = { err: 0, msg: '', data: { updatedRst } };
  306. } else {
  307. ctx.body = { err: 0, msg: '', data: { updatedRst: null } };
  308. }
  309. } catch (err) {
  310. this.log(err);
  311. ctx.body = { err: 1, msg: err.toString(), data: null };
  312. }
  313. }
  314. async removeReportArchive(ctx) {
  315. try {
  316. const prjId = ctx.params.prjId;
  317. const stgId = ctx.params.stgId;
  318. const rptId = ctx.params.rptId;
  319. const orgName = ctx.params.orgName;
  320. const fileName = orgName + '.PDF';
  321. console.log('removing fileName: ' + fileName);
  322. const fullName = path.join(this.app.baseDir, 'app', 'public/archive', fileName);
  323. // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', 'public/archive', fileName));
  324. // fs.stat(fullName, function(err, data) {
  325. // if (err) {
  326. // console.log(err);
  327. // } else {
  328. // fs.unlink(fullName, function(err) {
  329. // if (err) {
  330. // console.log(err);
  331. // }
  332. // });
  333. // }
  334. // });
  335. const oss_result = await ctx.oss.delete('archive/' + fileName);
  336. if (!(oss_result && oss_result.res.status === 204)) {
  337. throw '删除归档文件失败';
  338. }
  339. const orgArchiveList = await ctx.service.rptArchive.getPrjStgArchive(prjId, stgId);
  340. if (orgArchiveList.length > 0) {
  341. const contentArr = JSON.parse(orgArchiveList[0].content);
  342. for (const item of contentArr) {
  343. if (item.rpt_id === rptId) {
  344. if (item.items && item.items.length > 0) {
  345. for (const subIdx in item.items) {
  346. if (item.items[subIdx].uuid === orgName) {
  347. item.items.splice(subIdx, 1);
  348. break;
  349. }
  350. }
  351. }
  352. break;
  353. }
  354. }
  355. const updatedRst = await ctx.service.rptArchive.updateArchive(prjId, stgId, contentArr);
  356. ctx.body = { err: 0, msg: '', data: { fileName, updatedRst } };
  357. } else {
  358. ctx.body = { err: 0, msg: '', data: { fileName, updatedRst: null } };
  359. }
  360. } catch (err) {
  361. this.log(err);
  362. ctx.body = { err: 1, msg: err.toString(), data: null };
  363. }
  364. }
  365. async addMultiReportArchive(ctx, params) {
  366. // 暂时不支持
  367. }
  368. async getArchivedFileByUUID(ctx) {
  369. // console.log('downloading : ' + ctx.params.uuid);
  370. const uuid = ctx.params.uuid;
  371. const rptName = ctx.params.rptName;
  372. const suffix = '.PDF';
  373. try {
  374. const rptNameURI = encodeURI(rptName);
  375. const filePath = this.app.baseDir + '/app/public/archive/';
  376. // console.log('filePath: ' + filePath);
  377. // await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
  378. ctx.set({
  379. 'Content-Type': 'application/vnd.openxmlformats',
  380. 'Content-Disposition': 'attachment; filename="' + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix,
  381. });
  382. ctx.body = await fs.readFileSync(filePath + uuid + suffix);
  383. } catch (e) {
  384. console.log(e);
  385. }
  386. }
  387. async pdfShow(ctx) {
  388. // const renderData = {
  389. // can_netcasign: ctx.session.sessionProject.page_show.openNetCaSign === 1,
  390. // };
  391. await ctx.render('report/archive_pdf.ejs');
  392. }
  393. /*
  394. * 网证通电子签名页,(和归档报表页高度相似)
  395. */
  396. async signReport(ctx) {
  397. const tender = ctx.tender;
  398. const stage = ctx.stage;
  399. let stage_id = -1;
  400. let stage_order = -1;
  401. let stage_times = -1;
  402. let stage_status = -1;
  403. const treeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1, tender.data.project_id]);
  404. const custTreeNodes = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(this.ctx.session.sessionUser.accountId);
  405. const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
  406. //
  407. // 。。。
  408. let archiveList = [];
  409. let archiveEncryptionList = [];
  410. // console.log('tender.data.project_id: ' + tender.data.project_id);
  411. if (stage) {
  412. // console.log('ctx.stage.id: ' + ctx.stage.id);
  413. const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, ctx.stage.id);
  414. const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(tender.data.project_id, ctx.stage.id);
  415. stage_id = stage.id;
  416. stage_order = stage.order;
  417. stage_times = stage.times;
  418. stage_status = stage.status;
  419. if (archives.length > 0) {
  420. archiveList = JSON.parse(archives[0].content);
  421. }
  422. if (archiveEncryptions.length > 0) {
  423. archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
  424. }
  425. } else {
  426. // console.log('stageList[0].id: ' + stageList[0].id);
  427. // const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, stageList[stageList.length - 1].id);
  428. let archives = [];
  429. for (let sidx = stageList.length - 1; sidx >= 0; sidx--) {
  430. if (stageList[sidx].status === 3) {
  431. archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, stageList[sidx].id);
  432. stage_id = stageList[sidx].id;
  433. break;
  434. }
  435. }
  436. const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(tender.data.project_id, stageList[stageList.length - 1].id);
  437. // stage_id = stageList[0].id;
  438. // stage_order = stageList[0].order;
  439. // stage_times = stageList[0].times;
  440. // stage_status = stageList[0].status;
  441. if (archives && archives.length > 0) {
  442. archiveList = JSON.parse(archives[0].content);
  443. }
  444. if (archiveEncryptions && archiveEncryptions.length > 0) {
  445. archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
  446. }
  447. }
  448. let rpt_tpl_items = '{ customize: [], common: [] }';
  449. if (custTreeNodes.length > 0) {
  450. rpt_tpl_items = custTreeNodes[0].rpt_tpl_items;
  451. }
  452. // 获取ukey绑定数据
  453. const netcaSignData = await ctx.service.netcasign.getDataByCondition({ uid: ctx.session.sessionUser.accountId });
  454. // 获取已签名数据
  455. const signLogList = await ctx.service.netcasignLog.getLogList(ctx.tender.id);
  456. const renderData = {
  457. tender: tender.data,
  458. rpt_tpl_data: JSON.stringify(treeNodes),
  459. cust_tpl_data: rpt_tpl_items,
  460. project_id: tender.data.project_id,
  461. tender_id: tender.id,
  462. stg_id: stage_id,
  463. stg_order: stage_order,
  464. stg_times: stage_times,
  465. stg_status: stage_status,
  466. stage_list: JSON.stringify(stageList),
  467. tenderMenu,
  468. measureType,
  469. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
  470. stages: stageList,
  471. auditConst: auditConst.stage,
  472. archiveList,
  473. archiveEncryptionList,
  474. netcaSignData,
  475. can_netcasign: ctx.session.sessionProject.page_show.openNetCaSign === 1,
  476. ossPath: signConst.path.oss,
  477. signLogList,
  478. };
  479. await this.layout('report/index_sign.ejs', renderData, 'report/index_sign_modal.ejs');
  480. }
  481. /**
  482. * 网证通电子签名接口
  483. *
  484. * @param {object} ctx - egg全局变量
  485. * @return {void}
  486. */
  487. async signPost(ctx) {
  488. const response = {
  489. err: 0,
  490. msg: '',
  491. };
  492. try {
  493. const data = JSON.parse(ctx.request.body.data);
  494. let signData;
  495. const netcaSignApi = signConst.path.api;
  496. switch (data.type) {
  497. case 'pdfIsExist':
  498. const pdfMsg = await ctx.oss.head('archive/sign/' + data.uuid + '.PDF');
  499. response.data = pdfMsg.res.status === 200;
  500. break;
  501. // 获取摘要值
  502. case 'assemblyDigest':
  503. const postData = {
  504. requestJson: JSON.stringify(data.requestJson),
  505. };
  506. const result = await ctx.helper.sendMoreRequest(netcaSignApi + '/assemblyDigest', postData, 'POST');
  507. response.data = result;
  508. break;
  509. // 生成签名pdf
  510. case 'assemblyPdf':
  511. const postData2 = {
  512. requestJson: JSON.stringify(data.requestJson),
  513. };
  514. const result3 = await this.roundNetcaSign(ctx, postData2);
  515. // const result2 = await ctx.helper.sendMoreRequest(netcaSignApi + '/assemblyPdf', postData2, 'POST');
  516. // 上传到oss
  517. // console.log(result3);
  518. if (result3.code === 0) {
  519. // const result3 = await ctx.helper.sendMoreRequest(netcaSignApi + result2.data);
  520. const oss_reuslt = await ctx.oss.put('archive/sign/' + data.requestJson.fileName + '.PDF', result3.data);
  521. if (oss_reuslt && oss_reuslt.res && oss_reuslt.res.status === 200) {
  522. if (data.end) {
  523. const versionId = oss_reuslt.res.headers['x-oss-version-id'];
  524. // 记录签名和保存
  525. await ctx.service.netcasignLog.add(data.requestJson.fileName, data.role, ctx.session.sessionUser.accountId, versionId);
  526. const signLogList = await ctx.service.netcasignLog.getLogList(ctx.tender.id);
  527. response.data = signLogList;
  528. } else {
  529. // next page
  530. }
  531. } else {
  532. throw '上传文件失败';
  533. }
  534. } else {
  535. throw result3.msg;
  536. }
  537. break;
  538. // 移除签名和已签移除pdf
  539. case 'removeSign':
  540. const oss_reuslt = await ctx.oss.delete('archive/sign/' + data.uuid + '.PDF');
  541. if (oss_reuslt && oss_reuslt.res && oss_reuslt.res.status === 204) {
  542. const delSign_result = await ctx.service.netcasignLog.removeSign(data.uuid);
  543. const signLogList = await ctx.service.netcasignLog.getLogList(ctx.tender.id);
  544. response.data = signLogList;
  545. } else {
  546. throw '删除文件失败';
  547. }
  548. break;
  549. default:throw '参数有误';
  550. }
  551. } catch (error) {
  552. response.err = 1;
  553. response.msg = error.toString();
  554. const data = JSON.parse(ctx.request.body.data);
  555. if (data && data.type === 'pdfIsExist') {
  556. response.err = 0;
  557. response.data = false;
  558. }
  559. }
  560. ctx.body = response;
  561. }
  562. async roundNetcaSign(ctx, postData2, round = 3) {
  563. let response = {
  564. code: 0,
  565. data: '',
  566. };
  567. // 无法获取到result3,因为result2生成的pdf已损坏,请重复获取result2,直到获取成功或尝试3次失败后报错为止
  568. try {
  569. const netcaSignApi = signConst.path.api;
  570. const result2 = await ctx.helper.sendMoreRequest(netcaSignApi + '/assemblyPdf', postData2, 'POST');
  571. if (result2.code === 0) {
  572. const result3 = await ctx.curl(netcaSignApi + result2.data, {
  573. timeout: 300000, // 超时 5分钟中
  574. });
  575. if (result3) {
  576. response.data = result3.data;
  577. } else {
  578. if (round > 0) {
  579. round = round - 1;
  580. response = await this.roundNetcaSign(ctx, postData2, round);
  581. } else {
  582. throw 'pdf获取失败,网证通接口无法生成pdf';
  583. }
  584. }
  585. }
  586. } catch (error) {
  587. response.code = 1;
  588. response.msg = error;
  589. }
  590. return response;
  591. }
  592. }
  593. return ReportArchiveController;
  594. };