压缩和派发全部公司

ruoyi-admin/src/main/java/com/ruoyi/jjh/declaration/controller/BmsDeclarationRecordsController.java

@@ -1,5 +1,8 @@
 package com.ruoyi.jjh.declaration.controller;
 
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.core.util.ZipUtil;
+import cn.hutool.http.HttpUtil;
 import com.ruoyi.common.annotation.Log;
 import com.ruoyi.common.core.controller.BaseController;
 import com.ruoyi.common.core.domain.AjaxResult;
@@ -14,14 +17,25 @@ import com.ruoyi.jjh.declaration.entity.dto.BmsDeclarationRecordsDto;
 import com.ruoyi.jjh.declaration.entity.vo.ApprovalDeclarationRecordsQueryVo;
 import com.ruoyi.jjh.declaration.entity.vo.BmsDeclarationRecordsQueryVo;
 import com.ruoyi.jjh.declaration.entity.vo.BmsMunicipalBureauReviewQueryVo;
+import com.ruoyi.jjh.declaration.mapper.BmsDeclarationRecordsMapper;
 import com.ruoyi.jjh.declaration.service.IBmsDeclarationRecordsService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.FileSystemResource;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
+import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
-import javax.validation.Valid;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.UnsupportedEncodingException;
+import java.net.URLEncoder;
 import java.util.List;
 
 /**
@@ -34,10 +48,14 @@ import java.util.List;
 @RequestMapping("/system/declarationRecords")
 @Api(tags = "在线申报记录")
 public class BmsDeclarationRecordsController extends BaseController {
-    @Autowired
+    @Resource
     private IBmsDeclarationRecordsService bmsDeclarationRecordsService;
 
+    @Value("${ruoyi.profile}")
+    private String fileAddress;
 
+    @Resource
+    private BmsDeclarationRecordsMapper bmsDeclarationRecordsMapper;
     /**
      * 审核列表
      *
@@ -76,8 +94,43 @@ public class BmsDeclarationRecordsController extends BaseController {
 //    @RequiresPermissions("system:declarationRecords:list")
     @GetMapping("/fileList")
     @ApiOperation("根据列表id集合压缩所有文件")
-    public AjaxResult fileList(@RequestParam(name = "list") List<Long> list) {
-        return AjaxResult.success(bmsDeclarationRecordsService.fileList(list));
+    public ResponseEntity<byte[]> fileList(@RequestParam(name = "list") List<Long> list) throws FileNotFoundException, UnsupportedEncodingException {
+        List<BmsDeclarationRecordsQueryVo> rd = bmsDeclarationRecordsMapper.selectDeclarationRecordsToIdList(list);
+        // 创建父文件目录
+        String fatherFile = fileAddress + "/" + "项目压缩文件";
+        FileUtil.mkdir(fatherFile);
+        for (BmsDeclarationRecordsQueryVo item : rd) {
+            String itemsFileName = fatherFile + "/" +item.getProjectName()+item.getEnterpriseName();
+            FileUtil.mkdir(itemsFileName);
+            String[] splitList = bmsDeclarationRecordsService.getAllFile(item.getTemplateId(), item.getDetailId()).split(",");
+            for (String s : splitList) {
+                // 下载文件
+                try {
+                    HttpUtil.downloadFile(s, itemsFileName);
+                } catch (Exception e) {
+                    throw new RuntimeException(itemsFileName+"某文件下载失败");
+                }
+            }
+        }
+        // 压缩后的文件路径
+        String zipFilePath = fatherFile + ".zip";
+        // 使用Hutool压缩文件夹
+        ZipUtil.zip(fatherFile, zipFilePath);
+        // 从本地读取压缩文件
+        File zipFile = FileUtil.file(zipFilePath);
+//        FileSystemResource resource = new FileSystemResource(zipFile);
+        // 读取本地压缩文件并转为字节数组
+        byte[] bytes = FileUtil.readBytes(zipFile);
+        // 设置响应头
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
+        headers.setContentDispositionFormData("attachment", URLEncoder.encode("项目压缩文件.zip","UTF-8"));
+        // 删除压缩之前的文件夹
+        FileUtil.del(zipFilePath);
+        // 删除压缩包
+        FileUtil.del(fatherFile);
+        // 创建响应实体
+        return new ResponseEntity<>(bytes, headers, HttpStatus.OK);
     }
 
     /**

ruoyi-admin/src/main/java/com/ruoyi/jjh/declaration/mapper/BmsDeclarationRecordsMapper.java

@@ -82,4 +82,6 @@ public interface BmsDeclarationRecordsMapper extends BaseMapper<BmsDeclarationRe
      * @create 2023/9/6 15:13
      */
     public int updateProjectNameById(@Param("id") Long id, @Param("projectName")String projectName,@Param("projectId")Long projectId);
+
+    List<BmsDeclarationRecordsQueryVo> selectDeclarationRecordsToIdList(@Param("list") List<Long> list);
 }

ruoyi-admin/src/main/java/com/ruoyi/jjh/declaration/service/IBmsDeclarationRecordsService.java

@@ -2,11 +2,7 @@ package com.ruoyi.jjh.declaration.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.ruoyi.jjh.declaration.entity.BmsDeclarationRecords;
-import com.ruoyi.jjh.declaration.entity.dto.ApprovalDeclarationRecordsQueryDto;
-import com.ruoyi.jjh.declaration.entity.dto.BmsApprovalInfoUpdateDto;
-import com.ruoyi.jjh.declaration.entity.dto.BmsDeclarationRecordsAddDto;
-import com.ruoyi.jjh.declaration.entity.dto.BmsDeclarationRecordsDto;
-import com.ruoyi.jjh.declaration.entity.dto.MunicipalReviewDto;
+import com.ruoyi.jjh.declaration.entity.dto.*;
 import com.ruoyi.jjh.declaration.entity.vo.ApprovalDeclarationRecordsQueryVo;
 import com.ruoyi.jjh.declaration.entity.vo.BmsDeclarationRecordsQueryVo;
 import com.ruoyi.jjh.declaration.entity.vo.BmsMunicipalBureauReviewQueryVo;
@@ -105,5 +101,8 @@ public interface IBmsDeclarationRecordsService extends IService<BmsDeclarationRe
 
     public int updateDeclarationRecords(Long declarationId, Long projectId, String projectName, Long status);
 
-    String fileList(List<Long> list);
+    /**
+     * 根据id集合压缩所有文件使用类
+     */
+    String getAllFile(Long args,Long id);
 }

ruoyi-admin/src/main/java/com/ruoyi/jjh/declaration/service/impl/BmsDeclarationRecordsServiceImpl.java

@@ -2,8 +2,6 @@ package com.ruoyi.jjh.declaration.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollectionUtil;
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ruoyi.common.context.SecurityContextHolder;
@@ -19,8 +17,8 @@ import com.ruoyi.jjh.declaration.mapper.BmsDeclarationRecordsMapper;
 import com.ruoyi.jjh.declaration.service.*;
 import com.ruoyi.jjh.ent.entity.JProject;
 import com.ruoyi.jjh.ent.service.JProjectService;
-import org.apache.ibatis.annotations.Param;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -60,9 +58,67 @@ public class BmsDeclarationRecordsServiceImpl extends ServiceImpl<BmsDeclaration
     @Autowired
     private IBmsEnterpriseBasicInfoService iBmsEnterpriseBasicInfoService;
 
+    /**
+     * 项目落户奖补
+     */
+    @Resource
+    private IBmsProjectSettlementAwardService bmsProjectSettlementAwardService;
+    /**
+     * 做大做强奖
+     */
+    @Autowired
+    private IBmsBigStrongAwardService bmsBigStrongAwardService;
+    /**
+     * 载体建设奖补
+     */
+    @Autowired
+    private IBmsCarrierConstructionAwardService bmsCarrierConstructionAwardService;
+    /**
+     * 平台建设奖补
+     */
+    @Autowired
+    private IBmsPlatformConstructionAwardService bmsPlatformConstructionAwardService;
+    /**
+     * 品牌打造奖补
+     */
+    @Autowired
+    private IBmsBrandingAwardService bmsBrandingAwardService;
+    /**
+     * 场景开放奖补
+     */
+    @Autowired
+    private IBmsSceneOpeningAwardService bmsSceneOpeningAwardService;
+    /**
+     * 信用管理奖补
+     */
+    @Autowired
+    private IBmsCreditManagementService bmsCreditManagementService;
+    /**
+     * 5G+工业互联网奖补
+     */
+    @Autowired
+    private IBmsIndustrialInternetAwardService bmsIndustrialInternetAwardService;
+    /**
+     * 制造服务业有效投入奖补
+     */
+    @Autowired
+    private IBmsManufacturingServicesAwardService bmsManufacturingServicesAwardService;
+    /**
+     * 物流发展奖补
+     */
+    @Autowired
+    private IBmsLogisticsDevelopmentAwardService bmsLogisticsDevelopmentAwardService;
+    /**
+     * 两业融合奖补
+     */
+    @Autowired
+    private IBmsIntegrationIndustriesService bmsIntegrationIndustriesService;
     @Resource
     private JProjectService jProjectService;
 
+    @Value("${ruoyi.profile}")
+    private String fileAddress;
+
     /**
      * 查询在线申报记录
      *
@@ -583,10 +639,59 @@ public class BmsDeclarationRecordsServiceImpl extends ServiceImpl<BmsDeclaration
         return baseMapper.updateById(bmsDeclarationRecords);
     }
 
-    @Override
-    public String fileList(List<Long> list) {
-        List<BmsDeclarationRecords> rd = baseMapper.selectBatchIds(list);
-        System.out.println(rd);
-        return null;
+
+    /**
+     * 根据id集合压缩所有文件使用类
+     */
+    public String getAllFile(Long args,Long id) {
+        if (args == 1) {
+            BmsProjectSettlementAward lh = bmsProjectSettlementAwardService.getById(id);
+            return lh.getAgreement() + "," +
+                    lh.getReport() + "," +
+                    lh.getBusinessLicense() + "," +
+                    lh.getOtherMaterials();
+        } else if (args == 2) {
+            BmsBigStrongAward zdzq = bmsBigStrongAwardService.getById(id);
+            return zdzq.getDevelopmentPlan();
+        }else if (args == 3) {
+            BmsCarrierConstructionAward ztjs = bmsCarrierConstructionAwardService.getById(id);
+            return ztjs.getSupportingMaterials() + "," +
+                   ztjs.getBusinessLicense() + "," +
+                    ztjs.getFireReport();
+        }else if (args == 4) {
+            BmsPlatformConstructionAward ptjs = bmsPlatformConstructionAwardService.getById(id);
+            return ptjs.getAgreement();
+        }else if (args == 5) {
+            BmsBrandingAward ppdz = bmsBrandingAwardService.getById(id);
+            return ppdz.getEvidence();
+        }else if (args == 6) {
+            BmsSceneOpeningAward cjkf = bmsSceneOpeningAwardService.getById(id);
+            return cjkf.getMaterial();
+        }else if (args == 7) {
+            BmsCreditManagement xygl = bmsCreditManagementService.getById(id);
+            return xygl.getProjectPlan() + "," + xygl.getUsesFunds() + "," + xygl.getAuditReport() ;
+        }else if (args == 8) {
+            BmsIndustrialInternetAward g5 = bmsIndustrialInternetAwardService.getById(id);
+            return g5.getMaterial();
+        }else if (args == 9) {
+            BmsManufacturingServicesAward zzfw = bmsManufacturingServicesAwardService.getById(id);
+            return zzfw.getFilingNotice() + "," + zzfw.getInvoice() + "," + zzfw.getAuditReport() + ","+ zzfw.getFinancialStatements() ;
+        }else if (args == 10) {
+            BmsLogisticsDevelopmentAward wl = bmsLogisticsDevelopmentAwardService.getById(id);
+            return wl.getFilingNotice() + "," + wl.getHonorCertificate() + "," + wl.getAuditReport() + ","+ wl.getPlatformName();
+        }else if (args == 11) {
+            BmsIntegrationIndustries ly = bmsIntegrationIndustriesService.getById(id);
+            return ly.getEvidence() + ","+
+                    ly.getBusinessLicense() + "," +
+                    ly.getTaxPaymentCertificate() + "," +
+                    ly.getAuditReport() + "," +
+                    ly.getEquityStructureChart() + "," +
+                    ly.getDeclarationReport() + "," +
+                    ly.getIndependentAccounting() + "," +
+                    ly.getCapitalVerificationReport() + "," +
+                    ly.getOtherEvidence();
+        }else {
+            return null;
+        }
     }
 }

ruoyi-admin/src/main/java/com/ruoyi/jjh/declaration/service/impl/BmsTemplateRecordServiceImpl.java

@@ -21,25 +21,29 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.ArrayList;
+import java.util.Collection;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * 在线模板Service业务层处理
- * 
+ *
  * @author farben
  * @date 2023-09-07
  */
 @Service
-public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordMapper,BmsTemplateRecord> implements IBmsTemplateRecordService {
+public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordMapper, BmsTemplateRecord> implements IBmsTemplateRecordService {
 
     @Autowired
     private IBmsEnterpriseDirectoryService enterpriseDirectoryService;
 
     @Autowired
     private IBmsEnterpriseBasicInfoService iBmsEnterpriseBasicInfoService;
+
     /**
      * 查询在线模板
-     * 
+     *
      * @param id 在线模板主键
      * @return 在线模板
      */
@@ -54,7 +58,7 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
 
     /**
      * 查询在线模板列表
-     * 
+     *
      * @param bmsTemplateRecordQueryDto 在线模板
      * @return 在线模板
      */
@@ -72,7 +76,7 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
     public List<BmsTemplateRecordQueryVo> selectBmsTemplateNameList(BmsTemplateQueryDto bmsTemplateQueryDto) {
         Long enterpriseId = bmsTemplateQueryDto.getEnterpriseId();
         BmsEnterpriseBasicInfo bmsEnterpriseBasicInfo = iBmsEnterpriseBasicInfoService.selectBmsEnterpriseBasicInfoById(enterpriseId);
-        if (BeanUtil.isNotEmpty(bmsEnterpriseBasicInfo)){
+        if (BeanUtil.isNotEmpty(bmsEnterpriseBasicInfo)) {
             bmsTemplateQueryDto.setCreditCode(bmsEnterpriseBasicInfo.getCreditCode());
             return baseMapper.selectBmsTemplateNameList(bmsTemplateQueryDto);
         }
@@ -81,7 +85,7 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
 
     /**
      * 新增在线模板
-     * 
+     *
      * @param bmsTemplateRecordAddDto 在线模板
      * @return 结果
      */
@@ -94,13 +98,24 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
             num = baseMapper.insertBmsTemplateRecord(bmsTemplateRecordAddDto);
             List<BmsEnterpriseDirectory> enterpriseDirectoryList = bmsTemplateRecordAddDto
                     .getEnterpriseDirectoryList();
-            if (null != enterpriseDirectoryList && enterpriseDirectoryList.size()>0){
-                enterpriseDirectoryList.forEach(x->{
+            if (null != enterpriseDirectoryList && enterpriseDirectoryList.size() > 0) {
+                enterpriseDirectoryList.forEach(x -> {
                     x.setTemplateRecordId(bmsTemplateRecordAddDto.getId());
                 });
                 enterpriseDirectoryService.saveOrUpdateBatch(enterpriseDirectoryList);
+            } else {
+                List<BmsEnterpriseBasicInfo> list = iBmsEnterpriseBasicInfoService.list();
+                Collection<BmsEnterpriseDirectory> copyList = new ArrayList<>();
+                for (BmsEnterpriseBasicInfo items : list) {
+                    BmsEnterpriseDirectory bms = new BmsEnterpriseDirectory();
+                    bms.setTemplateRecordId(bmsTemplateRecordAddDto.getId());
+                    bms.setEnterpriseName(items.getEnterpriseName());
+                    bms.setCreditCode(items.getCreditCode());
+                    copyList.add(bms);
+                }
+                enterpriseDirectoryService.saveBatch(copyList);
             }
-        }catch (Exception e){
+        } catch (Exception e) {
             e.printStackTrace();
         }
         return num;
@@ -108,7 +123,7 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
 
     /**
      * 修改在线模板
-     * 
+     *
      * @param bmsTemplateRecordUpdateDto 在线模板
      * @return 结果
      */
@@ -119,13 +134,13 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
         int num = baseMapper.updateBmsTemplateRecord(bmsTemplateRecordUpdateDto);
         // 删除企业相关列表
         QueryWrapper<BmsEnterpriseDirectory> queryWrapper = new QueryWrapper<>();
-        queryWrapper.eq("template_record_id",bmsTemplateRecordUpdateDto.getId());
+        queryWrapper.eq("template_record_id", bmsTemplateRecordUpdateDto.getId());
         enterpriseDirectoryService.remove(queryWrapper);
         // 新增企业相关列表
         List<BmsEnterpriseDirectory> enterpriseDirectoryList = bmsTemplateRecordUpdateDto
                 .getEnterpriseDirectoryList();
-        if (null != enterpriseDirectoryList && enterpriseDirectoryList.size()>0){
-            enterpriseDirectoryList.forEach(x->{
+        if (null != enterpriseDirectoryList && enterpriseDirectoryList.size() > 0) {
+            enterpriseDirectoryList.forEach(x -> {
                 x.setTemplateRecordId(bmsTemplateRecordUpdateDto.getId());
             });
             enterpriseDirectoryService.saveOrUpdateBatch(enterpriseDirectoryList);
@@ -135,7 +150,7 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
 
     /**
      * 批量删除在线模板
-     * 
+     *
      * @param ids 需要删除的在线模板主键
      * @return 结果
      */
@@ -146,7 +161,7 @@ public class BmsTemplateRecordServiceImpl extends ServiceImpl<BmsTemplateRecordM
 
     /**
      * 删除在线模板信息
-     * 
+     *
      * @param id 在线模板主键
      * @return 结果
      */

ruoyi-admin/src/main/resources/mapper/jjh/declaration/BmsDeclarationRecordsMapper.xml

@@ -245,6 +245,46 @@
                  INNER JOIN bms_enterprise_basic_info b ON a.enterprise_id = b.id
         WHERE a.`status` = 4
     </select>
+    <select id="selectDeclarationRecordsToIdList"
+            resultType="com.ruoyi.jjh.declaration.entity.vo.BmsDeclarationRecordsQueryVo">
+        SELECT
+        a.id,
+        d.project_name,
+        a.project_id,
+        a.enterprise_id,
+        c.LEVEL,
+        a.YEAR,
+        c.type,
+        a.template_record_id,
+        c.id as template_id,
+        c.responsibility_unit,
+        a.declaration_template_type,
+        a.detail_id,
+        a.STATUS,
+        a.is_deleted,
+        a.create_by,
+        a.create_time,
+        a.update_by,
+        a.update_time,
+        a.remark,
+        b.enterprise_name,
+        f.road
+        FROM
+        bms_declaration_records AS a
+        inner join bms_template_record f on a.template_record_id = f.id
+        LEFT JOIN bms_enterprise_basic_info b ON a.enterprise_id = b.id
+        LEFT JOIN bms_template_info c on a.declaration_template_type = c.id
+        LEFT JOIN bms_project_info d on a.project_id = d.id
+        left join sys_dict_data e on a.status = e.dict_value and e.dict_type='bms_approval_status'
+        <where>
+            <if test="list != null and list.size>0">
+                and a.id in
+                <foreach collection="list" item="item" separator="," open="(" close=")">
+                    #{item}
+                </foreach>
+            </if>
+        </where>
+    </select>
 
     <insert id="insertBmsDeclarationRecords" parameterType="com.ruoyi.jjh.declaration.entity.BmsDeclarationRecords"
             useGeneratedKeys="true" keyProperty="id">