获取redis中算法文件上传进度接口

simulation-resource-server/src/main/java/com/css/simulation/resource/feign/FileDownService.java

@@ -37,9 +37,4 @@ public interface FileDownService {
     @PostMapping("/minio/download")
     Response download(@RequestBody @Validated MinioParameter minioParameter);
 
-    @PostMapping(value = "/redis/get")
-    ResponseBodyVO<String> getProgress(@RequestBody @Validated RedisParameter redisParameter);
-
-
-
 }

simulation-resource-server/src/main/java/com/css/simulation/resource/feign/RedisService.java

@@ -5,7 +5,9 @@ import api.common.pojo.param.RedisParameter;
 import com.css.simulation.resource.common.config.FeignConfiguration;
 import com.css.simulation.resource.feign.fallback.RedisServiceFallback;
 import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 
 import java.util.List;
 import java.util.Map;
@@ -30,4 +32,7 @@ public interface RedisService {
     @PostMapping("/redis/getDictMaps")
     ResponseBodyVO<Map<String,String>> getDictMaps(List<String> keyList);
 
+    @PostMapping(value = "/redis/get")
+    ResponseBodyVO<String> getProgress(RedisParameter redisParameter);
+
 }

simulation-resource-server/src/main/java/com/css/simulation/resource/feign/fallback/FileDownServiceFallback.java

@@ -39,8 +39,4 @@ public class FileDownServiceFallback implements FileDownService {
         return null;
     }
 
-    @Override
-    public ResponseBodyVO<String> getProgress(RedisParameter redisParameter) {
-        return null;
-    }
 }

simulation-resource-server/src/main/java/com/css/simulation/resource/feign/fallback/RedisServiceFallback.java

@@ -31,4 +31,9 @@ public class RedisServiceFallback implements RedisService {
     public ResponseBodyVO<Map<String, String>> getDictMaps(List<String> keyList) {
         return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE);
     }
+
+    @Override
+    public ResponseBodyVO<String> getProgress(RedisParameter redisParameter) {
+        return new ResponseBodyVO<>(ResponseBodyVO.Response.SERVER_FAILURE);
+    }
 }

simulation-resource-server/src/main/java/com/css/simulation/resource/scene/ctrl/FileController.java

@@ -6,6 +6,7 @@ import api.common.pojo.param.MinioParameter;
 import api.common.pojo.param.RedisParameter;
 import api.common.util.TimeUtil;
 import com.css.simulation.resource.feign.FileDownService;
+import com.css.simulation.resource.feign.RedisService;
 import feign.Response;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.MediaType;
@@ -32,6 +33,9 @@ public class FileController {
     @Resource
     private FileDownService fileDownService;
 
+    @Resource
+    private RedisService redisService;
+
     @PostMapping(value = "/uploadWj", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
     public ResponseBodyVO<Map> uploadWj(@RequestParam("file") MultipartFile multipartFile, HttpServletRequest request) {
         //获取文件类型
@@ -83,8 +87,8 @@ public class FileController {
     @PostMapping(value = "/getProgress")
     public ResponseBodyVO getProgress(@RequestParam("objectPath") String objectPath){
         RedisParameter redisParameter = new RedisParameter();
-        redisParameter.setKey(objectPath);
-        ResponseBodyVO resp = fileDownService.getProgress(redisParameter);
+        redisParameter.setKey(DictConstants.ALGORITHM_KEY + objectPath);
+        ResponseBodyVO resp = redisService.getProgress(redisParameter);
         return resp;
     }