新增：查询流程节点接口，增加文件id的本地磁盘目录返回，用于本地应用回传数据

common/src/main/java/com/sdm/common/entity/req/capability/FlowNodeDto.java

@@ -8,7 +8,6 @@ import lombok.Data;
 
 import java.time.LocalDateTime;
 import java.util.List;
-import java.util.Map;
 
 @Data
 public class FlowNodeDto {
@@ -34,9 +33,15 @@ public class FlowNodeDto {
     @Schema(description = "输入文件夹id")
     private Long inputDirId;
 
+    @Schema(description = "输入文件夹本地磁盘路径")
+    private String inputDirNasPath;
+
     @Schema(description = "输出文件夹id")
     private Long outputDirId;
 
+    @Schema(description = "输出文件夹本地磁盘路径")
+    private String outputDirNasPath;
+
     @Schema(description = "节点状态:finished/active/pending")
     private String nodeStatus;
 

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

@@ -9,12 +9,11 @@ import com.sdm.common.entity.resp.data.BatchCreateNormalDirResp;
 import com.sdm.common.entity.resp.data.FileMetadataInfoResp;
 import com.sdm.common.feign.inter.data.IDataFeignClient;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
-import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
+import java.util.Set;
 
 @Slf4j
 @Component
@@ -327,4 +326,17 @@ public class DataClientFeignClientImpl implements IDataFeignClient {
         }
     }
 
+    @Override
+    public SdmResponse<List<FileMetadataInfoResp>> getFileMinioObjectkeysByDirIds(Set<Long> dirIds) {
+        SdmResponse<List<FileMetadataInfoResp>> response;
+        try {
+            response = dataClient.getFileMinioObjectkeysByDirIds(dirIds);
+            return response;
+        } catch (Exception e) {
+            log.error("根据id查询文件路径失败：", e);
+            return SdmResponse.failed("根据id查询文件路径失败");
+        }
+    }
+
+
 }

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

@@ -16,6 +16,7 @@ import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
+import java.util.Set;
 
 @FeignClient(name = "data",contextId = "dataFeignClient")
 public interface IDataFeignClient {
@@ -109,4 +110,9 @@ public interface IDataFeignClient {
 
     @PostMapping("/data/copyFileToTask")
     SdmResponse<Long> copyFileToTask(@RequestBody CopyFileToTaskReq req);
+
+    //"根据主键id查询文件的路径" 只返回id 和 objectkey,只能查1000个
+    @PostMapping("/data/getFileMinioObjectkeysByDirIds")
+    SdmResponse<List<FileMetadataInfoResp>> getFileMinioObjectkeysByDirIds(@RequestBody Set<Long> dirIds);
+
 }