Merge remote-tracking branch 'origin/master'

pmapi/src/main/java/com/ningdatech/pmapi/common/constant/CommonConst.java

@@ -39,6 +39,8 @@ public interface CommonConst {
     String TITLE = "title";
 
     String FILE_NAME_STR = "fileName";
+    String FILE_ID_STR = "fileId";
+    String ID_STR = "id";
     String FILE_LIST = "fileList";
     String ITEM_BASED = "依据项:";
     String ITEM_BASED_FILE_NAME = "依据文件名:";

pmapi/src/main/java/com/ningdatech/pmapi/common/util/ExcelDownUtil.java

@@ -46,7 +46,7 @@ import org.assertj.core.util.Lists;
 @Slf4j
 public class ExcelDownUtil {
 
-    private static String encodeName(String name) {
+    public static String encodeName(String name) {
         String fileName;
         try {
             fileName = URLEncoder.encode(name, "UTF-8");

pmapi/src/main/java/com/ningdatech/pmapi/filemanage/controller/ProjectFileController.java

@@ -12,6 +12,8 @@ import lombok.AllArgsConstructor;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletResponse;
+
 /**
  * @Classname ProjectFileController
  * @Description
@@ -46,4 +48,10 @@ public class ProjectFileController {
         String instanceId = projectFileManage.startApplyBorrowProcess(projectId);
         return "启动申请借阅流程实例 【" + instanceId + "】 成功";
     }
+
+    @PostMapping("/download/{projectId}")
+    @ApiOperation(value = "档案下载",notes = "档案下载")
+    public void downloadFile(@PathVariable Long projectId,HttpServletResponse response){
+        projectFileManage.downloadFile(projectId, response);
+    }
 }

pmapi/src/main/java/com/ningdatech/pmapi/filemanage/manage/ProjectFileManage.java

@@ -1,14 +1,26 @@
 package com.ningdatech.pmapi.filemanage.manage;
 
 import cn.hutool.core.collection.CollUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.common.collect.Lists;
+import com.ningdatech.basic.exception.BizException;
 import com.ningdatech.basic.function.VUtils;
 import com.ningdatech.basic.model.PageVo;
+import com.ningdatech.basic.util.CollUtils;
+import com.ningdatech.file.entity.File;
+import com.ningdatech.file.entity.vo.result.AttachFileVo;
+import com.ningdatech.file.service.FileService;
+import com.ningdatech.file.utils.StrPool;
 import com.ningdatech.pmapi.common.constant.BizConst;
+import com.ningdatech.pmapi.common.constant.CommonConst;
 import com.ningdatech.pmapi.common.enumeration.ProjectProcessStageEnum;
 import com.ningdatech.pmapi.common.helper.UserInfoHelper;
+import com.ningdatech.pmapi.common.util.ExcelDownUtil;
+import com.ningdatech.pmapi.expert.manage.ExpertReviewManage;
+import com.ningdatech.pmapi.expert.model.vo.ExpertReviewDetailVO;
+import com.ningdatech.pmapi.expert.model.vo.ProjectReviewDetailVO;
 import com.ningdatech.pmapi.filemanage.model.entity.ProjectApplyBorrow;
 import com.ningdatech.pmapi.filemanage.model.param.ProjectFileListParam;
 import com.ningdatech.pmapi.filemanage.model.vo.ProjectFileListVO;
@@ -17,12 +29,18 @@ import com.ningdatech.pmapi.filemanage.service.INdProjectApplyBorrowService;
 import com.ningdatech.pmapi.organization.model.entity.DingOrganization;
 import com.ningdatech.pmapi.organization.service.IDingOrganizationService;
 import com.ningdatech.pmapi.projectdeclared.manage.DefaultDeclaredProjectManage;
+import com.ningdatech.pmapi.projectdeclared.model.entity.Contract;
+import com.ningdatech.pmapi.projectdeclared.model.entity.Purchase;
+import com.ningdatech.pmapi.projectdeclared.service.IContractService;
+import com.ningdatech.pmapi.projectdeclared.service.IPurchaseService;
 import com.ningdatech.pmapi.projectlib.enumeration.InstTypeEnum;
 import com.ningdatech.pmapi.projectlib.enumeration.ProjectStatusEnum;
 import com.ningdatech.pmapi.projectlib.manage.ProjectLibManage;
 import com.ningdatech.pmapi.projectlib.model.entity.Project;
+import com.ningdatech.pmapi.projectlib.model.entity.ProjectApplication;
 import com.ningdatech.pmapi.projectlib.model.entity.ProjectInst;
 import com.ningdatech.pmapi.projectlib.model.vo.ProjectDetailVO;
+import com.ningdatech.pmapi.projectlib.service.IProjectApplicationService;
 import com.ningdatech.pmapi.projectlib.service.IProjectInstService;
 import com.ningdatech.pmapi.projectlib.service.IProjectService;
 import com.ningdatech.pmapi.staging.enums.MsgTypeEnum;
@@ -34,20 +52,34 @@ import com.wflow.bean.entity.WflowModels;
 import com.wflow.contants.HisProInsEndActId;
 import com.wflow.exception.BusinessException;
 import com.wflow.workflow.bean.dto.OrgInfoDTO;
+import com.wflow.workflow.bean.process.FileBasicInfo;
+import com.wflow.workflow.bean.process.ProcessComment;
 import com.wflow.workflow.bean.vo.ProcessStartParamsVo;
 import com.wflow.workflow.service.ProcessInstanceService;
 import com.wflow.workflow.service.ProcessModelService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.compress.archivers.zip.ZipArchiveEntry;
+import org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream;
+import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.checkerframework.checker.nullness.qual.Nullable;
 import org.flowable.engine.HistoryService;
+import org.flowable.engine.TaskService;
 import org.flowable.engine.history.HistoricProcessInstance;
+import org.flowable.engine.task.Comment;
 import org.springframework.stereotype.Component;
 
-import java.time.LocalDateTime;
+import javax.servlet.http.HttpServletResponse;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URL;
 import java.util.*;
 import java.util.stream.Collectors;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipOutputStream;
 
 /**
  * @Classname ProjectFileManage
@@ -71,6 +103,12 @@ public class ProjectFileManage {
     private final HistoryService historyService;
     private final INdProjectApplyBorrowService projectApplyBorrowService;
     private final IDingOrganizationService dingOrganizationService;
+    private final IProjectApplicationService projectApplicationService;
+    private final TaskService taskService;
+    private final IPurchaseService purchaseService;
+    private final IContractService contractService;
+    private final ExpertReviewManage expertReviewManage;
+    private final FileService fileService;
 
     public PageVo<ProjectFileListVO> list(ProjectFileListParam param) {
 
@@ -141,7 +179,7 @@ public class ProjectFileManage {
             return vo;
         }).collect(Collectors.toList());
 
-        return PageVo.of(vos, projectList.size());
+        return PageVo.of(vos, projects.size());
     }
 
     private Set<String> getSubOrgList(String empPosUnitCode) {
@@ -211,4 +249,226 @@ public class ProjectFileManage {
 
         return instanceId;
     }
+
+    public void downloadFile(Long projectId, HttpServletResponse response) {
+        Project project = projectService.getById(projectId);
+        // 获取项目各阶段上传文件ID
+        List<Long> fileIdList = Lists.newArrayList();
+        getProjectAppendix(project, fileIdList);
+
+        String zipFileName = "项目档案";
+
+        // 设置response的header
+        response.setContentType("application/zip");
+        response.setHeader("Content-disposition",
+            "attachment;filename*=utf-8''" + ExcelDownUtil.encodeName(zipFileName) + ".zip");
+
+        try {
+            // 创建ZipOutputStream
+            ZipOutputStream zos = new ZipOutputStream(response.getOutputStream());
+            if (CollUtil.isNotEmpty(fileIdList)) {
+                // 获取文件输入流
+                for (Long fileId : fileIdList) {
+                    File file = fileService.getById(fileId);
+                    // 文件不存在，跳过
+                    if (Objects.isNull(file)) {
+                        continue;
+                    }
+                    String originalFileName = file.getOriginalFileName();
+                    String name = originalFileName.substring(0, originalFileName.indexOf(StrPool.DOT));
+                    String fileName = name + StrPool.UNDERSCORE + fileId
+                        + originalFileName.substring(originalFileName.indexOf(StrPool.DOT));
+                    InputStream fileInputStream = fileService.getFileInputStream(file);
+                    // 文件
+                    ZipEntry zipEntry = new ZipEntry(fileName);
+                    zos.putNextEntry(zipEntry);
+                    byte[] bytes = new byte[1024];
+                    int length;
+                    while ((length = fileInputStream.read(bytes)) >= 0) {
+                        zos.write(bytes, 0, length);
+                    }
+                    fileInputStream.close();
+                    zos.closeEntry();
+                }
+                zos.close();
+            }
+        } catch (IOException e) {
+            throw new BizException(e.getMessage());
+        }
+    }
+
+    private void getProjectAppendix(Project project, List<Long> fileIdList) {
+        Long projectId = project.getId();
+        // 项目申报阶段
+        // 获取立项依据
+        String buildBasis = project.getBuildBasis();
+        List<JSONObject> buildBasisFileArray = JSON.parseArray(buildBasis, JSONObject.class);
+        for (JSONObject jsonObject : buildBasisFileArray) {
+            String fileInfo = jsonObject.getString(CommonConst.FILE_LIST);
+            List<Long> buildBasisFileIdList = getFileIdList(fileInfo);
+            fileIdList.addAll(buildBasisFileIdList);
+        }
+        // 获取附件-初步方案
+        String preliminaryPlanFile = project.getPreliminaryPlanFile();
+        List<Long> prePlanFileIdList = getFileIdList(preliminaryPlanFile);
+        fileIdList.addAll(prePlanFileIdList);
+        // 获取附件-佐证材料
+        String supMaterialsFile = project.getSupportingMaterialsFile();
+        List<Long> supMaterialFileIdList = getFileIdList(supMaterialsFile);
+        fileIdList.addAll(supMaterialFileIdList);
+        // 获取附件-项目总投资测算明细
+        String calTotalInvestFile = project.getCalculationTotalInvestmentFile();
+        List<Long> calTotalInvestFileIdList = getFileIdList(calTotalInvestFile);
+        fileIdList.addAll(calTotalInvestFileIdList);
+        // 获取附件-申报单位主要职责(单位三定方案)
+        String mainResAppFile = project.getMainResponsibilitiesApplicantFile();
+        List<Long> mainResAppFileIdList = getFileIdList(mainResAppFile);
+        fileIdList.addAll(mainResAppFileIdList);
+        // 获取附件-项目申报书
+        String projectApplicationForm = project.getProjectApplicationForm();
+        List<Long> projectAppFormFileIdList = getFileIdList(projectApplicationForm);
+        fileIdList.addAll(projectAppFormFileIdList);
+        // 获取项目应用信息中的文件
+        List<ProjectApplication> applicationList = projectApplicationService
+            .list(Wrappers.lambdaQuery(ProjectApplication.class).eq(ProjectApplication::getProjectId, projectId));
+        for (ProjectApplication projectApplication : applicationList) {
+            // 获取试点文件
+            String experimentsFile = projectApplication.getExperimentsFile();
+            List<Long> experimentsFileIdList = getFileIdList(experimentsFile);
+            fileIdList.addAll(experimentsFileIdList);
+            // 获取应用总投资测算明细
+            String appEstimateFile = projectApplication.getApplicationEstimateFile();
+            List<Long> appEstimateFileIdList = getFileIdList(appEstimateFile);
+            fileIdList.addAll(appEstimateFileIdList);
+        }
+        // 流程审核意见文件
+        // 获取项目关联的流程实例
+        List<ProjectInst> projectInstList =
+            projectInstService.list(Wrappers.lambdaQuery(ProjectInst.class).eq(ProjectInst::getProjectId, projectId));
+        // 从历史评论表中获取对应流程实例的评论附件信息
+        for (ProjectInst projectInst : projectInstList) {
+            String instanceId = projectInst.getInstCode();
+            List<Comment> commentList = taskService.getProcessInstanceComments(instanceId);
+            for (Comment comment : commentList) {
+                ProcessComment processComment = JSONObject.parseObject(comment.getFullMessage(), ProcessComment.class);
+                List<FileBasicInfo> attachments = processComment.getAttachments();
+                if (CollUtil.isNotEmpty(attachments)) {
+                    List<Long> idList = attachments.stream().map(FileBasicInfo::getFileId).collect(Collectors.toList());
+                    fileIdList.addAll(idList);
+                }
+            }
+        }
+
+        // 预审申报阶段
+        // 预审申报上级条线主管单位审核意见
+        String higherLineSuperOrgReviewComments = project.getHigherLineSuperOrgReviewComments();
+        if (StringUtils.isNotBlank(higherLineSuperOrgReviewComments)) {
+            List<Long> highSuperOrgFileIdList = getFileIdList(higherLineSuperOrgReviewComments);
+            fileIdList.addAll(highSuperOrgFileIdList);
+        }
+
+        // 方案申报阶段
+        // 获取建设方案文件
+        String constructionPlanFile = project.getConstructionPlanFile();
+        JSONObject jsonObject = JSON.parseObject(constructionPlanFile, JSONObject.class);
+        Long constructFileId = jsonObject.getLong(CommonConst.FILE_ID_STR);
+        fileIdList.add(constructFileId);
+
+        // 立项批复阶段
+        // 获取批复文件
+        String approvedFile = project.getApprovedFile();
+        fileIdList.add(Long.valueOf(approvedFile));
+        // 获取建设方案文件
+        String approvedConstructionPlanFile = project.getApprovedConstructionPlanFile();
+        fileIdList.add(Long.valueOf(approvedConstructionPlanFile));
+
+        // 采购结果备案阶段
+        Purchase purchase = purchaseService
+            .getOne(Wrappers.lambdaQuery(Purchase.class).eq(Purchase::getProjectId, projectId).last(BizConst.LIMIT_1));
+        // 获取投标文件
+        String biddingDoc = purchase.getBiddingDoc();
+        List<Long> biddingFileIdList = getFileIdList(biddingDoc);
+        fileIdList.addAll(biddingFileIdList);
+        // 获取招标文件
+        String bidDoc = purchase.getBidDoc();
+        List<Long> bidFileIdList = getFileIdList(bidDoc);
+        fileIdList.addAll(bidFileIdList);
+        // 获取中标通知书
+        String acceptanceLetter = purchase.getAcceptanceLetter();
+        List<Long> acceptFileIdList = getFileIdList(acceptanceLetter);
+        fileIdList.addAll(acceptFileIdList);
+
+        // 合同备案阶段
+        Contract contract = contractService
+            .getOne(Wrappers.lambdaQuery(Contract.class).eq(Contract::getProjectId, projectId).last(BizConst.LIMIT_1));
+        // 获取合同附件
+        String attachment = contract.getAttachment();
+        List<Long> contractFileIdList = getFileIdList(attachment);
+        fileIdList.addAll(contractFileIdList);
+        // 初验备案阶段
+        // 获取初验材料
+        String preliminaryInspectionMaterials = project.getPreliminaryInspectionMaterials();
+        getInspectionMaterials(fileIdList, preliminaryInspectionMaterials);
+
+        // 终验申报阶段
+        // 获取终验材料
+        String finalAcceptanceMaterials = project.getFinalAcceptanceMaterials();
+        getInspectionMaterials(fileIdList, finalAcceptanceMaterials);
+
+        // 专家评审记录-如果有初步方案评审会议、部门联审评审会议、建设方案评审会议、验收评审会议对应的附件
+        // 获取项目的所有评审意见
+        String projectCode = project.getProjectCode();
+        ProjectReviewDetailVO projectReviewDetailVO = expertReviewManage.projectExpertReviewDetail(projectCode);
+        Collection<ProjectReviewDetailVO.ReviewDetailByTypeVO> reviews = projectReviewDetailVO.getReviews();
+        // 获取最终评审意见附件
+        if (CollUtil.isNotEmpty(reviews)) {
+            List<Long> finalReviewFileIdList = reviews.stream().map(r -> {
+                ExpertReviewDetailVO finalReview = r.getFinalReview();
+                return finalReview.getAttachFileId();
+            }).collect(Collectors.toList());
+            fileIdList.addAll(finalReviewFileIdList);
+            // 获取组员评审意见
+            for (ProjectReviewDetailVO.ReviewDetailByTypeVO review : reviews) {
+                List<ExpertReviewDetailVO> teamMemberReviews = review.getTeamMemberReviews();
+                for (ExpertReviewDetailVO teamMemberReview : teamMemberReviews) {
+                    Long attachFileId = teamMemberReview.getAttachFileId();
+                    fileIdList.add(attachFileId);
+                }
+            }
+        }
+    }
+
+    private void getInspectionMaterials(List<Long> fileIdList, String preliminaryInspectionMaterials) {
+        List<String> fileStrList = JSON.parseArray(preliminaryInspectionMaterials, String.class);
+        if (CollUtil.isNotEmpty(fileStrList)) {
+            for (String fileStr : fileStrList) {
+                JSONObject object = JSON.parseObject(fileStr, JSONObject.class);
+                String dataStr = object.getString("data");
+                List<String> array = JSON.parseArray(dataStr, String.class);
+                for (String file : array) {
+                    JSONObject fileObject = JSON.parseObject(file, JSONObject.class);
+                    String filesStr = fileObject.getString("files");
+                    List<JSONObject> jsonObjects = JSON.parseArray(filesStr, JSONObject.class);
+                    if (CollUtil.isEmpty(jsonObjects)) {
+                        // 如果没有上传附件,跳过
+                        continue;
+                    }
+                    for (JSONObject json : jsonObjects) {
+                        String response = json.getString("response");
+                        JSONObject responseJson = JSON.parseObject(response, JSONObject.class);
+                        String fileData = responseJson.getString("data");
+                        JSONObject fileInfoObject = JSON.parseObject(fileData, JSONObject.class);
+                        Long fileId = fileInfoObject.getLong("id");
+                        fileIdList.add(fileId);
+                    }
+                }
+            }
+        }
+    }
+
+    private List<Long> getFileIdList(String buildBasis) {
+        List<JSONObject> prePlanFileArray = JSON.parseArray(buildBasis, JSONObject.class);
+        List<Long> prePlanFileIdList = CollUtils.fieldList(prePlanFileArray, w -> w.getLong(CommonConst.ID_STR));
+        return prePlanFileIdList;
+    }
 }

pmapi/src/main/java/com/ningdatech/pmapi/projectlib/handle/ProjectFinalInspectionHandle.java

@@ -89,7 +89,7 @@ public class ProjectFinalInspectionHandle extends AbstractProcessBusinessHandle
             processDetailVO.setFinishTime(finishTime);
         }
         processDetailVO.setProcessProgressVo(instanceDetail);
-        processDetailVO.setProcessName(CommonConst.PRELIMINARY_PREVIEW);
+        processDetailVO.setProcessName(CommonConst.PROJECT_FINAL_INSPECTION);
         processSchedule.add(processDetailVO);
     }
 }

pmapi/src/main/java/com/ningdatech/pmapi/projectlib/handle/ProjectPreliminaryInspectionHandle.java

@@ -74,7 +74,7 @@ public class ProjectPreliminaryInspectionHandle extends AbstractProcessBusinessH
                     .last("limit 1"));
             processDetailVO.setFinishTime(projectStatusChange.getCreateOn());
         }
-        processDetailVO.setProcessName(CommonConst.TENDER_PURCHASE);
+        processDetailVO.setProcessName(CommonConst.PROJECT_PRELIMINARY_INSPECTION);
         processSchedule.add(processDetailVO);
     }
 }