report_archive_controller.js 30 KB

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