feat(可回溯): 参数问题

解决feign接收参数问题
This commit is contained in:
BrandWang
2023-05-10 09:54:13 +08:00
parent 636a5522ae
commit 1046a86a03
4 changed files with 17 additions and 19 deletions
@@ -3,9 +3,9 @@ package com.wabestway.recall.api.feign;
import com.wabestway.commons.http.ResObj; import com.wabestway.commons.http.ResObj;
import com.wabestway.recall.api.dto.TraceUpDTO; import com.wabestway.recall.api.dto.TraceUpDTO;
import com.wabestway.recall.api.fallback.TraceFeignClientFallback; import com.wabestway.recall.api.fallback.TraceFeignClientFallback;
import io.swagger.v3.oas.annotations.parameters.RequestBody;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@FeignClient(value = "afis-recall", fallback = TraceFeignClientFallback.class) @FeignClient(value = "afis-recall", fallback = TraceFeignClientFallback.class)
public interface TraceFeignClient { public interface TraceFeignClient {
@@ -19,6 +19,7 @@ public class TraceFeignClientImpl implements TraceFeignClient {
@Override @Override
public ResObj batchTraceUp(TraceUpDTO traceUpDTO) { public ResObj batchTraceUp(TraceUpDTO traceUpDTO) {
log.info("同步请求数据:{}", JSON.toJSONString(traceUpDTO)); log.info("同步请求数据:{}", JSON.toJSONString(traceUpDTO));
if (traceUpDTO != null && traceUpDTO.getRecords() != null) {
traceUpDTO.getRecords().forEach(order -> { traceUpDTO.getRecords().forEach(order -> {
RecallOrderEntity recallOrderEntity = recallOrderService.queryRecallOrderByOrderId(order.getOrderId()); RecallOrderEntity recallOrderEntity = recallOrderService.queryRecallOrderByOrderId(order.getOrderId());
if (recallOrderEntity != null) { if (recallOrderEntity != null) {
@@ -32,6 +33,7 @@ public class TraceFeignClientImpl implements TraceFeignClient {
recallOrderService.updateRecallOrderById(recallOrderEntity); recallOrderService.updateRecallOrderById(recallOrderEntity);
} }
}); });
}
return ResObj.ok(); return ResObj.ok();
} }
} }
@@ -148,7 +148,7 @@ public class RecallOrderApiServiceImpl implements RecallOrderApiService {
e.printStackTrace(); e.printStackTrace();
} }
String[] video = {"rrvideo", "--input", "unpack.json", "--config", "/opt/review/config.json", "--output", "video.mp4"}; String[] video = {"rrvideo", "--input unpack.json --config /opt/review/config.json --output video.mp4"};
ProcessBuilder videoBuilder = new ProcessBuilder(video); ProcessBuilder videoBuilder = new ProcessBuilder(video);
videoBuilder.directory(tempDir.toFile()); videoBuilder.directory(tempDir.toFile());
Process p2 = videoBuilder.start(); Process p2 = videoBuilder.start();
-4
View File
@@ -11,10 +11,7 @@
<modules> <modules>
<module>afis-recall-web</module> <module>afis-recall-web</module>
<module>afis-recall-service</module> <module>afis-recall-service</module>
<module>afis-recall-api</module>
</modules> </modules>
<parent> <parent>
<groupId>org.springframework.boot</groupId> <groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId> <artifactId>spring-boot-starter-parent</artifactId>
@@ -28,7 +25,6 @@
</properties> </properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>io.springfox</groupId> <groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId> <artifactId>springfox-swagger-ui</artifactId>