123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296 |
- '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');
- 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 = [];
- // 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);
- 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);
- }
- } 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);
- // 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);
- }
- }
- 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,
- };
- 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);
- let archiveList = [];
- if (archives.length > 0) {
- archiveList = JSON.parse(archives[0].content);
- }
- ctx.body = {
- data: archiveList,
- };
- }
- 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 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 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);
- }
- }
- }
- return ReportArchiveController;
- };
|