Calculation/app/controller/report_archive_controller.js

'use strict';

/**
 * Created by Tony on 2021/3/31.
 */

const path = require('path');
const uuidV1 = require('uuid').v1;
const fs = require('fs');
const MAX_ARCHIVE = 3;
const tenderMenu = require('../../config/menu').tenderMenu;
const measureType = require('../const/tender').measureType;
const fsUtil = require('../public/js/fsUtil');
const auditConst = require('../const/audit');
const signConst = require('../const/sign');

module.exports = app => {
    class ReportArchiveController extends app.BaseController {

        async index(ctx) {
            const tender = ctx.tender;
            const stage = ctx.stage;
            let stage_id = -1;
            let stage_order = -1;
            let stage_times = -1;
            let stage_status = -1;
            const treeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1, tender.data.project_id]);
            const custTreeNodes = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(this.ctx.session.sessionUser.accountId);
            const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
            //
            // 。。。
            let archiveList = [];
            let archiveEncryptionList = [];
            // console.log('tender.data.project_id: ' + tender.data.project_id);
            if (stage) {
                // console.log('ctx.stage.id: ' + ctx.stage.id);
                const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, ctx.stage.id);
                const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(tender.data.project_id, ctx.stage.id);
                stage_id = stage.id;
                stage_order = stage.order;
                stage_times = stage.times;
                stage_status = stage.status;
                if (archives.length > 0) {
                    archiveList = JSON.parse(archives[0].content);
                }
                if (archiveEncryptions.length > 0) {
                    archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
                }
            } else {
                // console.log('stageList[0].id: ' + stageList[0].id);
                const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, stageList[stageList.length - 1].id);
                const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(tender.data.project_id, stageList[stageList.length - 1].id);
                // stage_id = stageList[0].id;
                // stage_order = stageList[0].order;
                // stage_times = stageList[0].times;
                // stage_status = stageList[0].status;
                if (archives && archives.length > 0) {
                    archiveList = JSON.parse(archives[0].content);
                }
                if (archiveEncryptions && archiveEncryptions.length > 0) {
                    archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
                }
            }
            let rpt_tpl_items = '{ customize: [], common: [] }';
            if (custTreeNodes.length > 0) {
                rpt_tpl_items = custTreeNodes[0].rpt_tpl_items;
            }
            //
            const renderData = {
                tender: tender.data,
                rpt_tpl_data: JSON.stringify(treeNodes),
                cust_tpl_data: rpt_tpl_items,
                project_id: tender.data.project_id,
                tender_id: tender.id,
                stg_id: stage_id,
                stg_order: stage_order,
                stg_times: stage_times,
                stg_status: stage_status,
                stage_list: JSON.stringify(stageList),
                tenderMenu,
                measureType,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
                stages: stageList,
                auditConst: auditConst.stage,
                archiveList,
                archiveEncryptionList,
                can_netcasign: false,
                ossPath: signConst.path.oss,
            };
            await this.layout('report/index_archive.ejs', renderData);
        }

        async getReportArchive(ctx) {
            const params = JSON.parse(ctx.request.body.params);
            // ctx.body = await this._getReport(ctx, params);

            const archives = await ctx.service.rptArchive.getPrjStgArchive(params.prjId, params.stgId);
            const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(params.prjId, params.stgId);
            let archiveList = [];
            let archiveEncryptionList = [];
            if (archives.length > 0) {
                archiveList = JSON.parse(archives[0].content);
            }
            if (archiveEncryptions.length > 0) {
                archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
            }
            const lastAuditor = await ctx.service.stageAudit.getLastestAuditor(params.stgId, params.stgTimes, auditConst.stage.status.checked);

            ctx.body = {
                data: archiveList,
                encryptionData: archiveEncryptionList,
                lastAuditor,
            };
        }

        async addReportArchiveEncryption(ctx) {
            const params = JSON.parse(ctx.request.body.params);
            const prjId = params.prjId;
            const stgId = params.stgId;
            const rptId = params.rptId;
            const ttlPgs = params.ttlPgs;
            const content = params.content;
            const orgArchiveList = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(prjId, stgId);
            if (orgArchiveList.length > 0) {
                const contentArr = JSON.parse(orgArchiveList[0].content);
                let hasArchive = false;
                for (const item of contentArr) {
                    if (item.rpt_id === rptId) {
                        // 考虑到报表模板的稳定性，只保留一项来记录位置就足够了，都不考虑用uuid了
                        item.encryption = content;
                        hasArchive = true;
                        break;
                    }
                }
                if (!hasArchive) {
                    // 表示有新的要加
                    contentArr.push({ rpt_id: rptId, total_page: ttlPgs, encryption: content });
                } else {
                    //
                }
                const updatedRst = await ctx.service.rptArchiveEncryption.updateArchiveEncryption(orgArchiveList[0].id, prjId, stgId, contentArr);
                // console.log(updatedRst);
                ctx.body = { err: 0, msg: '', data: { addedRst: contentArr } };
            } else {
                // 需要增加
                const archiveArr = [];
                archiveArr.push({ rpt_id: rptId, encryption: content });
                const addedRst = await ctx.service.rptArchiveEncryption.createArchiveEncryption(prjId, stgId, archiveArr);
                // console.log(addedRst);
                ctx.body = { err: 0, msg: '', data: { addedRst: archiveArr } };
            }
        }

        async addReportArchive(ctx) {
            try {
                const stream = await ctx.getFileStream();
                const prjId = ctx.params.prjId;
                const stgId = ctx.params.stgId;
                const rptId = ctx.params.rptId;
                const newName = uuidV1();
                const fileName = newName + '.PDF';
                // console.log('adding fileName: ' + fileName);
                // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', 'public/archive', fileName));
                const oss_result = await ctx.oss.put('archive/' + fileName, stream);
                if (!(oss_result && oss_result.url && oss_result.res.status === 200)) {
                    throw '上传文件失败';
                }
                // const url = await ctx.oss.delete('archive/52d3e7f0-c7fb-11eb-b8c2-51b890b95d23.PDF');
                // console.log(url);
                // const flag = true;
                // if (flag) {
                //     throw 'ok';
                // }
                const updateDate = new Date();
                const montStr = (updateDate.getMonth() + 1) < 10 ? ('0' + (updateDate.getMonth() + 1)) : ((updateDate.getMonth() + 1));
                const dateStr = (updateDate.getDate()) < 10 ? ('0' + (updateDate.getDate())) : ((updateDate.getDate()));
                const dtStr = updateDate.getFullYear() + '-' + montStr + '-' + dateStr;
                const orgArchiveList = await ctx.service.rptArchive.getPrjStgArchive(prjId, stgId);
                if (orgArchiveList.length > 0) {
                    const contentArr = JSON.parse(orgArchiveList[0].content);
                    let hasArchive = false;
                    for (const item of contentArr) {
                        if (item.rpt_id === rptId) {
                            hasArchive = true;
                            if (item.items.length >= MAX_ARCHIVE) {
                                // 超出界限，需要删除时间最旧的那个
                                let rmIdx = 0;
                                for (let idx = 1; idx < item.items.length; idx++) {
                                    if (item.items[rmIdx].updateDate_time < item.items[idx].updateDate_time) {
                                        rmIdx = idx;
                                    }
                                }
                                // 同时删除oss文件
                                await ctx.oss.delete('archive/' + item.items[rmIdx].uuid + '.PDF');
                                item.items.splice(rmIdx, 1);
                            }
                            const newItem = { uuid: newName, updateDate_time: dtStr };
                            item.items.push(newItem);
                            break;
                        }
                    }
                    if (!hasArchive) {
                        // 表示有新的模板需要添加
                        contentArr.push({ rpt_id: rptId, items: [{ uuid: newName, updateDate_time: dtStr }] });
                    }
                    const updatedRst = await ctx.service.rptArchive.updateArchive(orgArchiveList[0].id, prjId, stgId, contentArr);
                    // console.log(updatedRst);
                    ctx.body = { err: 0, msg: '', data: { fileName, updateDate, addedRst: contentArr } };
                } else {
                    // 需要增加
                    const archiveArr = [];
                    archiveArr.push({ rpt_id: rptId, items: [{ uuid: newName, updateDate_time: dtStr }] });
                    const addedRst = await ctx.service.rptArchive.createArchive(prjId, stgId, archiveArr);
                    // console.log(addedRst);
                    ctx.body = { err: 0, msg: '', data: { fileName, updateDate, addedRst: archiveArr } };
                }
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        async updateReportArchiveEncryption(ctx) {
            // 在add方法中已经处理
            await this.addReportArchiveEncryption(ctx);
        }

        async updateReportArchive(ctx) {
            try {
                const stream = await ctx.getFileStream();
                const prjId = ctx.params.prjId;
                const stgId = ctx.params.stgId;
                const rptId = ctx.params.rptId;
                const orgName = ctx.params.orgName;
                const fileName = orgName + '.PDF';
                console.log('updating fileName: ' + fileName);
                // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', 'public/archive', fileName));
                const oss_result = await ctx.oss.put('archive/' + fileName, stream);
                if (!(oss_result && oss_result.url && oss_result.res.status === 200)) {
                    throw '上传文件失败';
                }

                const updateDate = new Date();
                const montStr = (updateDate.getMonth() + 1) < 10 ? ('0' + (updateDate.getMonth() + 1)) : ((updateDate.getMonth() + 1));
                const dateStr = (updateDate.getDate()) < 10 ? ('0' + (updateDate.getDate())) : ((updateDate.getDate()));
                const dtStr = updateDate.getFullYear() + '-' + montStr + '-' + dateStr;
                const orgArchiveList = await ctx.service.rptArchive.getPrjStgArchive(prjId, stgId);
                if (orgArchiveList.length > 0) {
                    const contentArr = JSON.parse(orgArchiveList[0].content);
                    for (const item of contentArr) {
                        if (item.rpt_id === rptId) {
                            if (item.items && item.items.length > 0) {
                                for (const subItem of item.items) {
                                    if (subItem.uuid === orgName) {
                                        subItem.updateDate_time = dtStr;
                                        break;
                                    }
                                }
                            } else {
                                item.items = [{ uuid: orgName, updateDate_time: dtStr }];
                            }
                            break;
                        }
                    }
                    const updatedRst = await ctx.service.rptArchive.updateArchive(orgArchiveList[0].id, prjId, stgId, contentArr);
                    // console.log(updatedRst);
                    ctx.body = { err: 0, msg: '', data: { fileName, updateDate, updatedRst: contentArr } };
                } else {
                    // 需要增加
                    const archiveArr = [];
                    archiveArr.push({ rpt_id: rptId, items: [{ uuid: orgName, updateDate_time: dtStr }] });
                    const updatedRst = await ctx.service.rptArchive.createArchive(prjId, stgId, archiveArr);
                    // console.log(updatedRst);
                    ctx.body = { err: 0, msg: '', data: { fileName, updateDate, updatedRst: archiveArr } };
                }
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        async removeReportArchiveEncryption(ctx) {
            try {
                const prjId = ctx.params.prjId;
                const stgId = ctx.params.stgId;
                const rptId = ctx.params.rptId;
                const orgArchiveList = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(prjId, stgId);
                if (orgArchiveList.length > 0) {
                    const contentArr = JSON.parse(orgArchiveList[0].content);
                    for (let idx = 0; idx < contentArr.length; idx++) {
                        if (contentArr[idx].rpt_id === rptId) {
                            contentArr.splice(idx, 1);
                            break;
                        }
                    }
                    const updatedRst = await ctx.service.rptArchive.updateArchive(prjId, stgId, contentArr);
                    ctx.body = { err: 0, msg: '', data: { updatedRst } };
                } else {
                    ctx.body = { err: 0, msg: '', data: { updatedRst: null } };
                }
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        async removeReportArchive(ctx) {
            try {
                const prjId = ctx.params.prjId;
                const stgId = ctx.params.stgId;
                const rptId = ctx.params.rptId;
                const orgName = ctx.params.orgName;
                const fileName = orgName + '.PDF';
                console.log('removing fileName: ' + fileName);
                const fullName = path.join(this.app.baseDir, 'app', 'public/archive', fileName);
                // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', 'public/archive', fileName));
                // fs.stat(fullName, function(err, data) {
                //     if (err) {
                //         console.log(err);
                //     } else {
                //         fs.unlink(fullName, function(err) {
                //             if (err) {
                //                 console.log(err);
                //             }
                //         });
                //     }
                // });
                const oss_result = await ctx.oss.delete('archive/' + fileName);
                if (!(oss_result && oss_result.res.status === 204)) {
                    throw '删除归档文件失败';
                }
                const orgArchiveList = await ctx.service.rptArchive.getPrjStgArchive(prjId, stgId);
                if (orgArchiveList.length > 0) {
                    const contentArr = JSON.parse(orgArchiveList[0].content);
                    for (const item of contentArr) {
                        if (item.rpt_id === rptId) {
                            if (item.items && item.items.length > 0) {
                                for (const subIdx in item.items) {
                                    if (item.items[subIdx].uuid === orgName) {
                                        item.items.splice(subIdx, 1);
                                        break;
                                    }
                                }
                            }
                            break;
                        }
                    }
                    const updatedRst = await ctx.service.rptArchive.updateArchive(prjId, stgId, contentArr);
                    ctx.body = { err: 0, msg: '', data: { fileName, updatedRst } };
                } else {
                    ctx.body = { err: 0, msg: '', data: { fileName, updatedRst: null } };
                }
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        async addMultiReportArchive(ctx, params) {
            // 暂时不支持
        }

        async getArchivedFileByUUID(ctx) {
            // console.log('downloading : ' + ctx.params.uuid);
            const uuid = ctx.params.uuid;
            const rptName = ctx.params.rptName;
            const suffix = '.PDF';
            try {
                const rptNameURI = encodeURI(rptName);
                const filePath = this.app.baseDir + '/app/public/archive/';
                // console.log('filePath: ' + filePath);
                // await this.ctx.helper.recursiveMkdirSync(this.app.baseDir + '/app/public/download');
                ctx.set({
                    'Content-Type': 'application/vnd.openxmlformats',
                    'Content-Disposition': 'attachment; filename="' + rptNameURI + suffix + "\"; filename*=utf-8''" + rptNameURI + suffix,
                });
                ctx.body = await fs.readFileSync(filePath + uuid + suffix);
            } catch (e) {
                console.log(e);
            }
        }

        async pdfShow(ctx) {
            // const renderData = {
            //     can_netcasign: ctx.session.sessionProject.page_show.openNetCaSign === 1,
            // };
            await ctx.render('report/archive_pdf.ejs');
        }

        /*
         *  网证通电子签名页，（和归档报表页高度相似）
         */
        async signReport(ctx) {
            const tender = ctx.tender;
            const stage = ctx.stage;
            let stage_id = -1;
            let stage_order = -1;
            let stage_times = -1;
            let stage_status = -1;
            const treeNodes = await ctx.service.rptTreeNode.getNodesByProjectId([-1, tender.data.project_id]);
            const custTreeNodes = await ctx.service.rptTreeNodeCust.getCustFoldersByUserId(this.ctx.session.sessionUser.accountId);
            const stageList = await ctx.service.stage.getValidStagesShort(tender.id);
            //
            // 。。。
            let archiveList = [];
            let archiveEncryptionList = [];
            // console.log('tender.data.project_id: ' + tender.data.project_id);
            if (stage) {
                // console.log('ctx.stage.id: ' + ctx.stage.id);
                const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, ctx.stage.id);
                const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(tender.data.project_id, ctx.stage.id);
                stage_id = stage.id;
                stage_order = stage.order;
                stage_times = stage.times;
                stage_status = stage.status;
                if (archives.length > 0) {
                    archiveList = JSON.parse(archives[0].content);
                }
                if (archiveEncryptions.length > 0) {
                    archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
                }
            } else {
                // console.log('stageList[0].id: ' + stageList[0].id);
                const archives = await ctx.service.rptArchive.getPrjStgArchive(tender.data.project_id, stageList[stageList.length - 1].id);
                const archiveEncryptions = await ctx.service.rptArchiveEncryption.getPrjStgArchiveEncryption(tender.data.project_id, stageList[stageList.length - 1].id);
                // stage_id = stageList[0].id;
                // stage_order = stageList[0].order;
                // stage_times = stageList[0].times;
                // stage_status = stageList[0].status;
                if (archives && archives.length > 0) {
                    archiveList = JSON.parse(archives[0].content);
                }
                if (archiveEncryptions && archiveEncryptions.length > 0) {
                    archiveEncryptionList = JSON.parse(archiveEncryptions[0].content);
                }
            }
            let rpt_tpl_items = '{ customize: [], common: [] }';
            if (custTreeNodes.length > 0) {
                rpt_tpl_items = custTreeNodes[0].rpt_tpl_items;
            }
            // 获取ukey绑定数据
            const netcaSignData = await ctx.service.netcasign.getDataByCondition({ uid: ctx.session.sessionUser.accountId });
            // 获取已签名数据
            const signLogList = await ctx.service.netcasignLog.getLogList(ctx.tender.id);
            const renderData = {
                tender: tender.data,
                rpt_tpl_data: JSON.stringify(treeNodes),
                cust_tpl_data: rpt_tpl_items,
                project_id: tender.data.project_id,
                tender_id: tender.id,
                stg_id: stage_id,
                stg_order: stage_order,
                stg_times: stage_times,
                stg_status: stage_status,
                stage_list: JSON.stringify(stageList),
                tenderMenu,
                measureType,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.report.main),
                stages: stageList,
                auditConst: auditConst.stage,
                archiveList,
                archiveEncryptionList,
                netcaSignData,
                can_netcasign: ctx.session.sessionProject.page_show.openNetCaSign === 1,
                ossPath: signConst.path.oss,
                signLogList,
            };
            await this.layout('report/index_sign.ejs', renderData, 'report/index_sign_modal.ejs');
        }

        /**
         * 网证通电子签名接口
         *
         * @param {object} ctx - egg全局变量
         * @return {void}
         */
        async signPost(ctx) {
            const response = {
                err: 0,
                msg: '',
            };
            try {
                const data = JSON.parse(ctx.request.body.data);
                let signData;
                const netcaSignApi = signConst.path.api;
                switch (data.type) {
                    case 'pdfIsExist':
                        const pdfMsg = await ctx.oss.head('archive/sign/' + data.uuid + '.PDF');
                        response.data = pdfMsg.res.status === 200;
                        break;
                    // 获取摘要值
                    case 'assemblyDigest':
                        const postData = {
                            requestJson: JSON.stringify(data.requestJson),
                        };
                        const result = await ctx.helper.sendMoreRequest(netcaSignApi + '/assemblyDigest', postData, 'POST');
                        response.data = result;
                        break;
                    // 生成签名pdf
                    case 'assemblyPdf':
                        const postData2 = {
                            requestJson: JSON.stringify(data.requestJson),
                        };

                        const result3 = await this.roundNetcaSign(ctx, postData2);
                        // const result2 = await ctx.helper.sendMoreRequest(netcaSignApi + '/assemblyPdf', postData2, 'POST');
                        // 上传到oss
                        // console.log(result3);
                        if (result3.code === 0) {
                            // const result3 = await ctx.helper.sendMoreRequest(netcaSignApi + result2.data);
                            const oss_reuslt = await ctx.oss.put('archive/sign/' + data.requestJson.fileName + '.PDF', result3.data);
                            if (oss_reuslt && oss_reuslt.res && oss_reuslt.res.status === 200) {
                                if (data.end) {
                                    const versionId = oss_reuslt.res.headers['x-oss-version-id'];
                                    // 记录签名和保存
                                    await ctx.service.netcasignLog.add(data.requestJson.fileName, data.role, ctx.session.sessionUser.accountId, versionId);
                                    const signLogList = await ctx.service.netcasignLog.getLogList(ctx.tender.id);
                                    response.data = signLogList;
                                } else {
                                    // next page
                                }
                            } else {
                                throw '上传文件失败';
                            }
                        } else {
                            throw result3.msg;
                        }
                        break;
                    // 移除签名和已签移除pdf
                    case 'removeSign':
                        const oss_reuslt = await ctx.oss.delete('archive/sign/' + data.uuid + '.PDF');
                        if (oss_reuslt && oss_reuslt.res && oss_reuslt.res.status === 204) {
                            const delSign_result = await ctx.service.netcasignLog.removeSign(ctx.session.sessionUser.accountId, data.uuid);
                            const signLogList = await ctx.service.netcasignLog.getLogList(ctx.tender.id);
                            response.data = signLogList;
                        } else {
                            throw '删除文件失败';
                        }
                        break;
                    default:throw '参数有误';
                }
            } catch (error) {
                response.err = 1;
                response.msg = error.toString();
                const data = JSON.parse(ctx.request.body.data);
                if (data && data.type === 'pdfIsExist') {
                    response.err = 0;
                    response.data = false;
                }
            }

            ctx.body = response;
        }

        async roundNetcaSign(ctx, postData2, round = 3) {
            let response = {
                code: 0,
                data: '',
            };
            // 无法获取到result3，因为result2生成的pdf已损坏，请重复获取result2，直到获取成功或尝试3次失败后报错为止
            try {
                const netcaSignApi = signConst.path.api;
                const result2 = await ctx.helper.sendMoreRequest(netcaSignApi + '/assemblyPdf', postData2, 'POST');
                if (result2.code === 0) {
                    const result3 = await ctx.curl(netcaSignApi + result2.data, {
                        timeout: 300000, // 超时 5分钟中
                    });
                    if (result3) {
                        response.data = result3.data;
                    } else {
                        if (round > 0) {
                            round = round - 1;
                            response = await this.roundNetcaSign(ctx, postData2, round);
                        } else {
                            throw 'pdf获取失败，网证通接口无法生成pdf';
                        }
                    }
                }
            } catch (error) {
                response.code = 1;
                response.msg = error;
            }
            return response;
        }
    }
    return ReportArchiveController;
};