8/22 xx

src/main/java/com/example/fms/common/model/dto/SystemFileDTO.java

@@ -21,6 +21,11 @@ public class SystemFileDTO {
     private String GUID;
 
     /**
+     * 配置类型id
+     */
+    private Integer sourceId;
+
+    /**
      * 存储位置
      */
     private Integer pType;

src/main/java/com/example/fms/common/model/vo/SystemFileVO.java

@@ -29,6 +29,8 @@ public class SystemFileVO {
      */
     private Integer pType;
 
+    private Integer sourceId;
+
     /**
      * 文件路径
      */

src/main/java/com/example/fms/domain/SystemFile.java

@@ -30,6 +30,12 @@ public class SystemFile extends BaseEntity<SystemFile> {
     private Integer pType;
 
     /**
+     * 配置类型id
+     */
+    @TableField("SOURCE_ID")
+    private Integer sourceId;
+
+    /**
      * 文件路径
      */
     @TableField("FILE_PATH")

src/main/java/com/example/fms/service/FileFactoryService.java

@@ -37,7 +37,8 @@ public class FileFactoryService {
         if(files != null && files.size() != 0) {
             //调用解析配置方法，获取配置信息
             List<ConfigSettingVO> configSettingVOS = ExcuteConfigUtils.excuteConfigVO();
-            ConfigSettingVO configSettingVO = configSettingVOS.stream().filter(item -> item.getSourceId().equals(sourceId)).findFirst().orElse(null);
+            //根据配置id获得配置
+            ConfigSettingVO configSettingVO = configSettingVOS.stream().filter(item -> item.getId().equals(sourceId)).findFirst().orElse(null);
             if (configSettingVO == null) {
                 return null;
             }
@@ -64,9 +65,10 @@ public class FileFactoryService {
             try {
                 String directoryName = fileUtils.getDirectoryName();
                 SystemFileDTO systemFileDTO = SftpService.upload(configSettingVO.getFilePath() + directoryName, file, configSettingVO);
-                systemFileDTO.setPType(0);
+                systemFileDTO.setPType(configSettingVO.getId());
+                systemFileDTO.setSourceId(configSettingVO.getSourceId());
                 systemFileDTO.setOriginalName(file.getOriginalFilename());
-                systemFileDTO.setFilePath("/file/" + directoryName + "/" + systemFileDTO.getFileName());
+                systemFileDTO.setFilePath(configSettingVO.getFilePath() + directoryName + "/" + systemFileDTO.getFileName());
                 systemFileDTOS.add(systemFileDTO);
             } catch (Exception e) {
                 e.printStackTrace();
@@ -120,16 +122,15 @@ public class FileFactoryService {
      * 删除文件
      *
      * @param filePath
-     * @param pType
+     * @param sourceId
      */
-    public static void delete(String filePath, Integer pType){
+    public static void delete(String filePath, Integer sourceId){
         //调用解析配置方法，获取配置信息
         List<ConfigSettingVO> configSettingVOS = ExcuteConfigUtils.excuteConfigVO();
+        ConfigSettingVO configSettingVO = configSettingVOS.stream().filter(item -> item.getSourceId().equals(sourceId)).findFirst().orElse(null);
         //根据传入类型判断从哪里删除数据
         //如果为1，则为服务器
-        if(pType.equals(1)){
-            int sourceId = 1;
-            ConfigSettingVO configSettingVO = configSettingVOS.stream().filter(item -> item.getSourceId().equals(sourceId)).findFirst().orElse(null);
+        if(sourceId.equals(1)){
             //拆分路径字符串
             int index = filePath.lastIndexOf('/');
             //要删除文件所在目录
@@ -141,9 +142,7 @@ public class FileFactoryService {
             } catch (Exception e) {
                 throw new XiaoShiException("删除错误");
             }
-        } else if(pType.equals(2)){//类型为2，则为阿里云OSS
-            int sourceId = 2;
-            ConfigSettingVO configSettingVO = configSettingVOS.stream().filter(item -> item.getSourceId().equals(sourceId)).findFirst().orElse(null);
+        } else if(sourceId.equals(2)){//类型为2，则为阿里云OSS
         }
     }
 

src/main/java/com/example/fms/service/FileMangerService.java

@@ -105,9 +105,9 @@ public class FileMangerService {
                 //根据id到表中查询该文件记录的数据
                 SystemFileVO systemFileVO = systemFileService.query(ids.get(i));
                 //pType判断是服务器还是阿里云OSS
-                int pType = systemFileVO.getPType();
+                int sourceId = systemFileVO.getSourceId();
                 String filePath = systemFileVO.getFilePath();
-                fileFactoryService.delete(filePath, pType);
+                fileFactoryService.delete(filePath, sourceId);
                 int row = systemFileMapper.deleteById(ids.get(i));
                 if(row != 1){
                     throw new XiaoShiException("删除异常");

src/main/java/com/example/fms/service/SystemFileService.java

@@ -3,7 +3,10 @@ package com.example.fms.service;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.example.fms.common.model.dto.SystemFileDTO;
 import com.example.fms.common.model.dto.SystemFileUpdateDTO;
+import com.example.fms.common.model.vo.PersonnelVO;
 import com.example.fms.common.model.vo.SystemFileVO;
+import com.example.fms.common.utils.CacheUtils;
+import com.example.fms.common.utils.SecurityUtils.LoginUtils;
 import com.example.fms.domain.SystemFile;
 import com.example.fms.exception.XiaoShiException;
 import com.example.fms.mapper.SystemFileMapper;
@@ -24,7 +27,8 @@ import java.util.List;
 @Service
 @RequiredArgsConstructor(onConstructor_ = {@Lazy})
 public class SystemFileService extends ServiceImpl<SystemFileMapper, SystemFile> {
-
+    private final CacheUtils cacheUtils;
+    private final LoginUtils loginUtils;
     /**
      * 新增系统文件（批量）
      *
@@ -40,9 +44,9 @@ public class SystemFileService extends ServiceImpl<SystemFileMapper, SystemFile>
                 //取集合中的dto对象，并赋值给实体类
                 SystemFileDTO systemFileDTO = systemFileDTOS.get(i);
                 BeanUtils.copyProperties(systemFileDTO, systemFile);
-                //获取当前登陆人的信息
+//                //获取当前登陆人的信息
 //                PersonnelVO personnelVO = cacheUtils.getLoginUser(loginUtils.getId());
-                //给实体类赋值登陆人id
+//                //给实体类赋值登陆人id
 //                systemFile.setCreateId(personnelVO.getId());
                 systemFile.setCreateId(1);
                 //插入数据

src/main/resources/mapper/SystemFileMapper.xml

@@ -5,8 +5,8 @@
     <!--新增系统文件-->
     <!--int add(SystemFile systemFile);-->
     <insert id="add" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO SYSTEM_FILE(GUID, P_TYPE, FILE_PATH, FILE_NAME, ORIGINAL_NAME, FILE_LENGTH, CREATE_ID, UPDATE_TIME, IS_DELETE)
-        VALUES (#{GUID}, #{pType}, #{filePath}, #{fileName}, #{originalName}, #{fileLength},#{createId}, #{updateTime}, #{isDelete})
+        INSERT INTO SYSTEM_FILE(GUID, P_TYPE, SOURCE_ID, FILE_PATH, FILE_NAME, ORIGINAL_NAME, FILE_LENGTH, CREATE_ID, UPDATE_TIME, IS_DELETE)
+        VALUES (#{GUID}, #{pType}, #{sourceId}, #{filePath}, #{fileName}, #{originalName}, #{fileLength},#{createId}, #{updateTime}, #{isDelete})
     </insert>
 
 
@@ -46,14 +46,14 @@
     <!--查询系统文件-->
     <!--SystemFileVO query(Integer id);-->
     <select id="query" resultMap="queryMap">
-        SELECT ID, GUID, P_TYPE, FILE_PATH, FILE_NAME, ORIGINAL_NAME, FILE_LENGTH, CREATE_ID, UPDATE_TIME, CREATE_TIME, IS_DELETE
+        SELECT ID, GUID, P_TYPE, SOURCE_ID, FILE_PATH, FILE_NAME, ORIGINAL_NAME, FILE_LENGTH, CREATE_ID, UPDATE_TIME, CREATE_TIME, IS_DELETE
         FROM SYSTEM_FILE
         WHERE ID = #{id}
         ORDER BY CREATE_TIME DESC
     </select>
 
     <select id="getSystemFile" resultMap="queryMap">
-        SELECT ID, GUID, P_TYPE, FILE_PATH, FILE_NAME, ORIGINAL_NAME, FILE_LENGTH, CREATE_ID, UPDATE_TIME, CREATE_TIME, IS_DELETE
+        SELECT ID, GUID, P_TYPE, SOURCE_ID, FILE_PATH, FILE_NAME, ORIGINAL_NAME, FILE_LENGTH, CREATE_ID, UPDATE_TIME, CREATE_TIME, IS_DELETE
         FROM SYSTEM_FILE
         WHERE FILE_NAME = #{fileName}
         ORDER BY CREATE_TIME DESC
@@ -64,6 +64,7 @@
         <id column="ID" property="id"/>
         <result column="GUID" property="GUID"/>
         <result column="P_TYPE" property="pType"/>
+        <result column="SOURCE_ID" property="sourceId"/>
         <result column="FILE_PATH" property="filePath"/>
         <result column="FILE_NAME" property="fileName"/>
         <result column="ORIGINAL_NAME" property="originalName"/>

target/classes/configSetting.json

@@ -1,20 +1,38 @@
 [
     {
-        "sourceId": "1",   
+        "sourceId": "1",
         "sourceName": "FSS",
         "name": "192.168.1.24",
         "id": 1,
         "userName": "root",
         "passWord": "xiaoshi221101",
-        "filePath": "/file/"
+        "filePath": "/project/pas/prod/file/"
     },
     {
-        "sourceId": "2",   
-        "sourceName": "OSS",
-        "name": "阿里云",
+        "sourceId": "1",
+        "sourceName": "FSS",
+        "name": "192.168.1.24",
         "id": 2,
-        "userName": "xiexiang",
-        "passWord": "xiexiang123456",
-        "filePath": "/file/"
+        "userName": "root",
+        "passWord": "xiaoshi221101",
+        "filePath": "/project/rms/prod/file/"
+    },
+    {
+        "sourceId": "1",
+        "sourceName": "FSS",
+        "name": "139.224.24.90",
+        "id": 3,
+        "userName": "root",
+        "passWord": "cslg-pas-820f1e412aaf",
+        "filePath": "/project/pas/prod/file/"
+    },
+    {
+        "sourceId": "1",
+        "sourceName": "FSS",
+        "name": "139.224.24.90",
+        "id": 4,
+        "userName": "root",
+        "passWord": "cslg-pas-820f1e412aaf",
+        "filePath": "/project/rms/prod/file/"
     }
 ]