Merge remote-tracking branch 'origin/dev' into dev

# Conflicts:
#	RMS/src/main/resources/application-dev.yml

RMS/src/main/java/cn/cslg/report/common/model/dto/ProductDTO.java

@@ -1,15 +1,13 @@
 package cn.cslg.report.common.model.dto;
 
-import cn.cslg.report.common.model.vo.ReportFileStandardVO;
 import lombok.Data;
 import lombok.experimental.Accessors;
 
 import java.io.Serializable;
 import java.util.Date;
-import java.util.List;
 
 /**
- * 新增产品DTO类
+ * 新增产品的前端传输DTO类
  *
  * @Author chenyu
  * @Data 2022/12/20

RMS/src/main/java/cn/cslg/report/controller/ProductController.java

@@ -32,14 +32,15 @@ import java.util.List;
 @RequestMapping(Constants.REPORT_API + "/product")
 @RequiredArgsConstructor
 public class ProductController {
-    private final IProductService productService;  //装配产品的Service层接口和实现类
+    private final IProductService productService;  //产品的Service层装配
 
     @Operation(summary = "新增产品")
     @PostMapping("/addProduct")
     public String addProduct(String jsons, List<MultipartFile> files) {
-        log.info("开始处理【新增产品】的请求，参数为：{}, {}", jsons, files);
+        log.info("开始处理【新增产品】的请求，参数为产品信息：{}, 产品附件：{}", jsons, files);
+
         if (jsons == null) {
-            return Response.error("产品创建失败，无新增产品的数据");
+            return Response.error("前端未传参数");
         }
         ProductDTO productDTO = JSONObject.parseObject(jsons, ProductDTO.class);
         try {

RMS/src/main/java/cn/cslg/report/entity/AssoProductFile.java

@@ -15,10 +15,6 @@ import java.io.Serializable;
 @Data
 public class AssoProductFile implements Serializable {
     /**
-     * ID
-     */
-    private Integer id;
-    /**
      * 产品ID
      */
     private Integer productId;

RMS/src/main/java/cn/cslg/report/mapper/AssoProductFileMapper.java

@@ -14,9 +14,9 @@ import java.util.List;
 @Repository
 public interface AssoProductFileMapper {
     /**
-     * 批量插入产品文件关联表数据
+     * 批量插入数据
      *
-     * @param assoProductFiles 产品文件关联数据对象集合
+     * @param assoProductFiles 数据对象集合
      * @return 返回受影响的行数
      */
     int insertBatch(List<AssoProductFile> assoProductFiles);

RMS/src/main/java/cn/cslg/report/service/IProductService.java

@@ -19,8 +19,8 @@ public interface IProductService {
     /**
      * 新增产品
      *
-     * @param productDTO 产品数据前端传输DTO对象
-     * @param files      附件
+     * @param productDTO 新增产品的前端传输DTO类对象
+     * @param files      产品附件
      */
     @Transactional
     void addProduct(ProductDTO productDTO, List<MultipartFile> files);

RMS/src/main/java/cn/cslg/report/service/impl/AssoProductFileServiceImpl.java

@@ -4,6 +4,7 @@ import cn.cslg.report.entity.AssoProductFile;
 import cn.cslg.report.mapper.AssoProductFileMapper;
 import cn.cslg.report.service.IAssoProductFileService;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
@@ -15,16 +16,17 @@ import java.util.List;
  * @Author chenyu
  * @Data 2022/12/20
  */
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class AssoProductFileServiceImpl implements IAssoProductFileService {
-    private final AssoProductFileMapper assoProductFileMapper;
+    private final AssoProductFileMapper assoProductFileMapper;  //产品文件关联表的Mapper层装配
 
     /**
      * 新增产品文件关联数据
      *
      * @param productId 产品id
-     * @param fileIds   附件id
+     * @param fileIds   附件id集合
      */
     @Override
     public void addAsso(Integer productId, List<Integer> fileIds) {
@@ -36,6 +38,7 @@ public class AssoProductFileServiceImpl implements IAssoProductFileService {
                     .setFileUseType(0);
             list.add(assoProductFile);
         }
+        log.info("数据入产品文件关联表");
         assoProductFileMapper.insertBatch(list);
     }
 

RMS/src/main/java/cn/cslg/report/service/impl/ProductServiceImpl.java

@@ -7,8 +7,10 @@ import cn.cslg.report.common.model.vo.ProductIncludeFilesVO;
 import cn.cslg.report.common.model.vo.ReportFileStandardVO;
 import cn.cslg.report.common.utils.CacheUtils;
 import cn.cslg.report.common.utils.SecurityUtils.LoginUtils;
+import cn.cslg.report.entity.AssoProductFile;
 import cn.cslg.report.entity.Product;
 import cn.cslg.report.exception.XiaoShiException;
+import cn.cslg.report.mapper.AssoProductFileMapper;
 import cn.cslg.report.mapper.ProductMapper;
 import cn.cslg.report.service.IAssoProductFileService;
 import cn.cslg.report.service.IProductService;
@@ -32,47 +34,75 @@ import java.util.List;
 @Service
 @RequiredArgsConstructor
 public class ProductServiceImpl implements IProductService {
-    private final ProductMapper productMapper;  //产品的Mapper层接口
-    private final ReportFileService reportFileService;  //报告系统文件的Service层实现类
-    private final IAssoProductFileService assoProductFileService;  //产品文件关联的Service层实现类
+    private final ProductMapper productMapper;  //产品表的Mapper层装配
+    private final AssoProductFileMapper assoProductFileMapper;  //产品文件关联表的Mapper层装配
+    private final ReportFileService reportFileService;  //报告系统文件的Service层装配
+    private final IAssoProductFileService assoProductFileService;  //产品文件关联的Service层装配
     private final CacheUtils cacheUtils;
     private final LoginUtils loginUtils;
 
     /**
      * 新增产品
      *
-     * @param productDTO 产品数据前端传输DTO对象
-     * @param files      附件
+     * @param productDTO 新增产品的前端传输DTO类对象
+     * @param files      产品附件
      */
     @Override
     public void addProduct(ProductDTO productDTO, List<MultipartFile> files) {
-        log.info("开始处理【新增产品】的业务，参数为：{}, {}", productDTO, files);
-        //新增产品DTO类对象赋值给产品表实体类对象
+        log.info("开始处理【新增产品】的业务，参数为产品信息：{}, 产品附件：{}", productDTO, files);
+
+        //DTO赋值给产品表实体类
         Product product = new Product();
         BeanUtils.copyProperties(productDTO, product);
-        //获取创建人信息
+        //获取登陆人信息
         PersonnelVO personnelVO = cacheUtils.getLoginUser(loginUtils.getId());
-        //将创建人id和姓名赋值给产品表实体类对象
+        //登陆人id和姓名赋值给产品表实体类
         product.setCreatePersonId(personnelVO.getId())
                 .setCreatePersonName(personnelVO.getName());
 
-        //检查当前报告是否已有创建的产品 (根据报告id查询产品，1个报告只能创建有1个产品)
+        //检查当前报告是否已创建产品 (一个报告只能创建一个产品，根据报告id查询产品)
         Integer reportId = product.getReportId();
+        log.info("检查当前报告是否已创建产品");
         int count = productMapper.countByReportId(reportId);
         if (count > 0) {
-            String message = "新增产品失败，当前报告产品已创建";
+            String message = "新增产品失败，当前报告产品已创建产品";
+            log.info("{}", message);
+            throw new XiaoShiException(message);
+        }
+
+        //1.数据入产品表
+        log.info("数据入产品表");
+        int rows = productMapper.insert(product);
+        if (rows != 1) {
+            String message = "新增产品失败，服务器忙请稍后再试";
             log.info("{}", message);
             throw new XiaoShiException(message);
         }
 
-        //1.产品数据入产品表
-        productMapper.insert(product);
-        //2.附件数据(如果有附件)入报告系统文件表并返回附件的id集合
+        //2.数据入报告系统文件表(并返回附件的id集合)
         if (files != null && files.size() != 0) {
+            log.info("数据入报告系统文件表");
             List<Integer> fileIds = reportFileService.uploadFiles(files);
-            //3.产品productId和附件fileId入产品文件关联表
-            assoProductFileService.addAsso(product.getId(), fileIds);
+            //3.数据入产品文件关联表
+            Integer productId = product.getId();
+            //之前是直接调用产品文件关联的Service层业务：assoProductFileService.addAsso(productId, fileIds); 现在自己敲👇
+            ArrayList<AssoProductFile> assoProductFiles = new ArrayList<>();
+            for (Integer fileId : fileIds) {
+                AssoProductFile assoProductFile = new AssoProductFile()
+                        .setProductId(productId)
+                        .setFileId(fileId)
+                        .setFileUseType(0);
+                assoProductFiles.add(assoProductFile);
+            }
+            log.info("数据入产品文件关联表");
+            rows = assoProductFileMapper.insertBatch(assoProductFiles);
+            if (rows != fileIds.size()) {
+                String message = "新增产品失败，服务器忙请稍后再试";
+                log.info("{}", message);
+                throw new XiaoShiException(message);
+            }
         }
+
         log.info("新增产品完成");
 
     }