report_archive_controller.js 30 KB

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