feign提供文件查询

common/src/main/java/com/sdm/common/entity/req/data/GetSimulationTaskFileReq.java

@@ -1,9 +1,7 @@
-package com.sdm.data.model.req;
+package com.sdm.common.entity.req.data;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
-import com.fasterxml.jackson.annotation.JsonProperty;
 import com.sdm.common.entity.enums.FileBizTypeEnum;
-import com.sdm.common.entity.req.data.BaseReq;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 

common/src/main/java/com/sdm/common/feign/impl/data/DataAnalysisFeignClientImpl.java

@@ -0,0 +1,31 @@
+package com.sdm.common.feign.impl.data;
+
+import com.sdm.common.common.SdmResponse;
+import com.sdm.common.entity.req.data.GetSimulationTaskFileReq;
+import com.sdm.common.entity.resp.data.FileMetadataInfoResp;
+import com.sdm.common.feign.inter.data.IDataAnalysisFeignClient;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Slf4j
+@Component
+public class DataAnalysisFeignClientImpl implements IDataAnalysisFeignClient {
+    @Autowired
+    IDataAnalysisFeignClient dataAnalysisFeignClient;
+
+    @Override
+    public SdmResponse getSimulationTaskFile(GetSimulationTaskFileReq getSimulationTaskFileReq) {
+        SdmResponse response;
+        try {
+            response = dataAnalysisFeignClient.getSimulationTaskFile(getSimulationTaskFileReq);
+            log.info("查询文件夹列表响应："+ response);
+            return response;
+        } catch (Exception e) {
+            log.error("查询文件夹列表失败", e);
+            return SdmResponse.failed("查询文件夹列表失败");
+        }
+    }
+}

common/src/main/java/com/sdm/common/feign/inter/data/IDataAnalysisFeignClient.java

@@ -0,0 +1,13 @@
+package com.sdm.common.feign.inter.data;
+
+import com.sdm.common.common.SdmResponse;
+import com.sdm.common.entity.req.data.GetSimulationTaskFileReq;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(name = "data",contextId = "dataAnalysisFeignClient")
+public interface IDataAnalysisFeignClient {
+    @PostMapping("/getSimulationTaskFile")
+    public SdmResponse getSimulationTaskFile(@RequestBody GetSimulationTaskFileReq getSimulationTaskFileReq);
+}

common/src/main/java/com/sdm/common/feign/inter/data/IDataFeignClient.java

@@ -19,7 +19,7 @@ import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
 
-@FeignClient(name = "data")
+@FeignClient(name = "data",contextId = "dataFeignClient")
 public interface IDataFeignClient {
     @GetMapping("/data/listDir")
     SdmResponse<List<FileMetadataInfoResp>> listDir( @RequestParam(value = "dirType") Integer dirType,@RequestParam(value = "parentDirId", required = false) Long parentDirId);

data/src/main/java/com/sdm/data/controller/DataAnalysisController.java

@@ -1,7 +1,8 @@
 package com.sdm.data.controller;
 
 import com.sdm.common.common.SdmResponse;
-import com.sdm.data.model.req.GetSimulationTaskFileReq;
+import com.sdm.common.entity.req.data.GetSimulationTaskFileReq;
+import com.sdm.common.feign.inter.data.IDataAnalysisFeignClient;
 import com.sdm.data.service.IDataAnalysisService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
@@ -18,7 +19,7 @@ import java.util.List;
 @RestController
 @RequestMapping("/dataAnalysis")
 @Tag(name = "数据分析", description = "结果曲线、结果云图")
-public class DataAnalysisController {
+public class DataAnalysisController implements IDataAnalysisFeignClient {
 
     @Autowired
     private IDataAnalysisService dataAnalysisService;

data/src/main/java/com/sdm/data/service/IDataAnalysisService.java

@@ -1,7 +1,7 @@
 package com.sdm.data.service;
 
 import com.sdm.common.common.SdmResponse;
-import com.sdm.data.model.req.GetSimulationTaskFileReq;
+import com.sdm.common.entity.req.data.GetSimulationTaskFileReq;
 
 import java.util.List;
 

data/src/main/java/com/sdm/data/service/impl/DataAnalysisServiceImpl.java

@@ -3,13 +3,12 @@ package com.sdm.data.service.impl;
 import com.alibaba.fastjson2.JSONObject;
 import com.github.pagehelper.PageInfo;
 import com.sdm.common.common.SdmResponse;
-import com.sdm.common.entity.enums.FileIsLastEnum;
 import com.sdm.common.entity.resp.PageDataResp;
 import com.sdm.common.utils.FileSizeUtils;
 import com.sdm.common.utils.PageUtils;
 import com.sdm.data.model.entity.FileMetadataInfo;
 import com.sdm.data.model.entity.FileStorage;
-import com.sdm.data.model.req.GetSimulationTaskFileReq;
+import com.sdm.common.entity.req.data.GetSimulationTaskFileReq;
 import com.sdm.data.model.req.QueryBigFileReq;
 import com.sdm.data.model.resp.SimulationTaskResultCurveResp;
 import com.sdm.data.service.DataStorageAnalysis;