From 9696c65f1e3b9b14a76455e2523ba6ab2cf9e23b Mon Sep 17 00:00:00 2001 From: lxu75 Date: Tue, 20 May 2025 16:09:01 +0800 Subject: [PATCH 1/8] =?UTF-8?q?=E7=B4=A2=E8=B5=94=E6=A3=80=E6=A0=B8?= =?UTF-8?q?=EF=BC=8Cretry=E6=9C=BA=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ai-analytic-center-api/pom.xml | 5 ++++- .../ai/analytic/center/feign/DiFyFeign.java | 8 ++++++++ .../ai/analytic/center/service/DiFyService.java | 2 ++ .../impl/ClaimVerificationServiceImpl.java | 2 +- .../center/service/impl/DiFyServiceImpl.java | 17 +++++++++++++++++ 5 files changed, 32 insertions(+), 2 deletions(-) diff --git a/ai-analytic-center-api/pom.xml b/ai-analytic-center-api/pom.xml index 6ac34ab..26e1e34 100644 --- a/ai-analytic-center-api/pom.xml +++ b/ai-analytic-center-api/pom.xml @@ -19,7 +19,10 @@ org.springframework.cloud spring-cloud-starter-openfeign - + + org.springframework.retry + spring-retry + com.alibaba.cloud diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java index 46595e2..1cadd7f 100644 --- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java @@ -3,6 +3,8 @@ package com.volvo.ai.analytic.center.feign; import com.alibaba.fastjson.JSONObject; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.http.MediaType; +import org.springframework.retry.annotation.Backoff; +import org.springframework.retry.annotation.Retryable; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; @@ -16,6 +18,12 @@ public interface DiFyFeign { , produces = MediaType.APPLICATION_JSON_VALUE) JSONObject runWorkflows(@RequestHeader(value = "Authorization") String authorization, @RequestBody Map map); + @Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000)) + @PostMapping(value = "v1/workflows/run" + , consumes = MediaType.APPLICATION_JSON_VALUE + , produces = MediaType.APPLICATION_JSON_VALUE) + JSONObject runWorkflowsRetry(@RequestHeader(value = "Authorization") String authorization, @RequestBody Map map); + @PostMapping(value = "/v1/files/upload" , consumes = MediaType.MULTIPART_FORM_DATA_VALUE) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/DiFyService.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/DiFyService.java index 7159e60..ead8f53 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/DiFyService.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/DiFyService.java @@ -8,6 +8,8 @@ public interface DiFyService { public Object getDiFyObject(DiFyReq diFyReq); + public Object getDiFyObjectRetry(DiFyReq diFyReq); + public JSONObject executeDifyFlow(DiFyReq diFyReq, String businessType, String businessData, String aiAnalysisRequestId); public JSONObject executeDifyFlow(DiFyReq diFyReq); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java index 98a8333..953e2e2 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java @@ -163,7 +163,7 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService { diFyReq.setFlowId(verificationToken); diFyReq.setInputs(parsedAudit); //调用dify 工作流 - diFyObject = (JSONObject) diFyService.getDiFyObject(diFyReq); + diFyObject = (JSONObject) diFyService.getDiFyObjectRetry(diFyReq); //处理结果并推送MQ if (diFyObject == null) { log.error("售后索赔检核审计报告dify返回结果为空"); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java index 024fccc..f112d2f 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java @@ -48,6 +48,23 @@ public class DiFyServiceImpl implements DiFyService{ return ""; } + @Override + public Object getDiFyObjectRetry(DiFyReq diFyReq) { + Map map = new HashMap<>(); + map.put("inputs",diFyReq.getInputs()); + map.put("response_mode","blocking"); + map.put("user",diFyReq.getUser()); + log.info("请求DiFy入参-Retry:{}",JSON.toJSONString(map)); + JSONObject difyResult = diFyFeign.runWorkflowsRetry("Bearer "+diFyReq.getFlowId(),map); + log.info("请求DiFy响应结果:{}",difyResult.toJSONString()); + JSONObject data = difyResult.getJSONObject("data"); + if (data != null && "succeeded".equals(data.get("status"))){ + JSONObject outputs = data.getJSONObject("outputs"); + return outputs; + } + return ""; + } + @Override public JSONObject executeDifyFlow(DiFyReq diFyReq, String businessType, String businessData, String oldAiAnalysisRequestId) { String aiAnalysisRequestId = StringUtils.isEmpty(oldAiAnalysisRequestId)? AiAnalysisUtils.getAiAnalysisRequestId(businessType):oldAiAnalysisRequestId; From e090a1e82fba7f3b88f249186771b3e86129e7cc Mon Sep 17 00:00:00 2001 From: lxu75 Date: Tue, 20 May 2025 18:22:23 +0800 Subject: [PATCH 2/8] =?UTF-8?q?=E5=BC=80=E5=90=AFretry=E6=9C=BA=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/analytic/center/AiAnalyticCenterServiceApplication.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/AiAnalyticCenterServiceApplication.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/AiAnalyticCenterServiceApplication.java index 450aec1..7eddcf7 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/AiAnalyticCenterServiceApplication.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/AiAnalyticCenterServiceApplication.java @@ -6,6 +6,7 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.context.annotation.Bean; +import org.springframework.retry.annotation.EnableRetry; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.web.client.RestTemplate; @@ -16,6 +17,7 @@ import com.volvo.common.feign.annotation.EnableVolvoFeignClients; @EnableScheduling @MapperScan({"com.volvo.ai.analytic.center.mapper"}) @EnableDiscoveryClient +@EnableRetry public class AiAnalyticCenterServiceApplication { public static void main(String[] args) { From 6016288fd33933553c5c204e4e7691dad1e3a3e3 Mon Sep 17 00:00:00 2001 From: lxu75 Date: Tue, 20 May 2025 18:56:48 +0800 Subject: [PATCH 3/8] =?UTF-8?q?retry=E6=9C=BA=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java index f112d2f..42d507a 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java @@ -13,6 +13,8 @@ import com.volvo.ai.analytic.center.utils.AiAnalysisUtils; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.retry.annotation.Backoff; +import org.springframework.retry.annotation.Retryable; import org.springframework.stereotype.Service; import java.util.HashMap; @@ -49,6 +51,7 @@ public class DiFyServiceImpl implements DiFyService{ } @Override + @Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000)) public Object getDiFyObjectRetry(DiFyReq diFyReq) { Map map = new HashMap<>(); map.put("inputs",diFyReq.getInputs()); From 0669a5d287e06afd345a800792557c6b4851093a Mon Sep 17 00:00:00 2001 From: lxu75 Date: Wed, 21 May 2025 11:14:58 +0800 Subject: [PATCH 4/8] =?UTF-8?q?retry=E6=9C=BA=E5=88=B6=E6=8A=9B=E5=87=BA?= =?UTF-8?q?=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../center/service/impl/ClaimVerificationServiceImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java index 953e2e2..c1b4589 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java @@ -187,6 +187,7 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService { sendErrorCallBack(claimVerificationFileAnalysisDTO, aiAnalysisRequestId); //保存错误日志 saveException(e.getMessage(), aiAnalysisRequestId, diFyObject); + throw e; } } From a231fecaa5ba216beaab236c2b0cd4b2776ba45a Mon Sep 17 00:00:00 2001 From: lxu75 Date: Wed, 21 May 2025 14:50:37 +0800 Subject: [PATCH 5/8] =?UTF-8?q?retry=E6=9C=BA=E5=88=B6=E6=8A=9B=E5=87=BA?= =?UTF-8?q?=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/analytic/center/feign/DiFyFeign.java | 1 - .../impl/ClaimVerificationServiceImpl.java | 8 ++++--- .../center/service/impl/DiFyRetryImpl.java | 22 +++++++++++++++++++ 3 files changed, 27 insertions(+), 4 deletions(-) create mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java index 1cadd7f..f45a458 100644 --- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java @@ -18,7 +18,6 @@ public interface DiFyFeign { , produces = MediaType.APPLICATION_JSON_VALUE) JSONObject runWorkflows(@RequestHeader(value = "Authorization") String authorization, @RequestBody Map map); - @Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000)) @PostMapping(value = "v1/workflows/run" , consumes = MediaType.APPLICATION_JSON_VALUE , produces = MediaType.APPLICATION_JSON_VALUE) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java index c1b4589..2cb0b7a 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java @@ -79,6 +79,9 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService { @Autowired private AiAnalysisErrorsMapper aiAnalysisErrorsMapper; + @Autowired + private DiFyRetryImpl diFyRetry; + @Override public void consumerMessageByMQ(String message) { // 生成ai分析请求id @@ -162,8 +165,8 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService { diFyReq.setUser(BusinessTypeEnum.CLAIM_VERIFICATION.getCode()); diFyReq.setFlowId(verificationToken); diFyReq.setInputs(parsedAudit); - //调用dify 工作流 - diFyObject = (JSONObject) diFyService.getDiFyObjectRetry(diFyReq); + //调用dify 工作流 失败重试一次 + diFyObject = diFyRetry.getDiFyRetry(diFyReq); //处理结果并推送MQ if (diFyObject == null) { log.error("售后索赔检核审计报告dify返回结果为空"); @@ -187,7 +190,6 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService { sendErrorCallBack(claimVerificationFileAnalysisDTO, aiAnalysisRequestId); //保存错误日志 saveException(e.getMessage(), aiAnalysisRequestId, diFyObject); - throw e; } } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java new file mode 100644 index 0000000..a14a510 --- /dev/null +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java @@ -0,0 +1,22 @@ +package com.volvo.ai.analytic.center.service.impl; + +import com.alibaba.fastjson.JSONObject; +import com.volvo.ai.analytic.center.dto.req.DiFyReq; +import com.volvo.ai.analytic.center.service.DiFyService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +/** + * dify调用retry + */ +@Service +public class DiFyRetryImpl { + + @Autowired + private DiFyService diFyService; + public JSONObject getDiFyRetry(DiFyReq diFyReq) { + + return (JSONObject) diFyService.getDiFyObjectRetry(diFyReq); + } + +} From af152be1a67173b961cfadad228c657d42fb5ed2 Mon Sep 17 00:00:00 2001 From: lxu75 Date: Wed, 21 May 2025 15:57:39 +0800 Subject: [PATCH 6/8] =?UTF-8?q?retry=E6=9C=BA=E5=88=B6=E6=8A=9B=E5=87=BA?= =?UTF-8?q?=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/volvo/ai/analytic/center/feign/DiFyFeign.java | 1 + .../ai/analytic/center/service/impl/DiFyRetryImpl.java | 7 ++++++- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java index f45a458..1cadd7f 100644 --- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java @@ -18,6 +18,7 @@ public interface DiFyFeign { , produces = MediaType.APPLICATION_JSON_VALUE) JSONObject runWorkflows(@RequestHeader(value = "Authorization") String authorization, @RequestBody Map map); + @Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000)) @PostMapping(value = "v1/workflows/run" , consumes = MediaType.APPLICATION_JSON_VALUE , produces = MediaType.APPLICATION_JSON_VALUE) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java index a14a510..e639ff2 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java @@ -3,19 +3,24 @@ package com.volvo.ai.analytic.center.service.impl; import com.alibaba.fastjson.JSONObject; import com.volvo.ai.analytic.center.dto.req.DiFyReq; import com.volvo.ai.analytic.center.service.DiFyService; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.retry.annotation.Backoff; +import org.springframework.retry.annotation.Retryable; import org.springframework.stereotype.Service; /** * dify调用retry */ +@Slf4j @Service public class DiFyRetryImpl { @Autowired private DiFyService diFyService; + @Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000)) public JSONObject getDiFyRetry(DiFyReq diFyReq) { - + log.info("diFyService class: {}", diFyService.getClass()); return (JSONObject) diFyService.getDiFyObjectRetry(diFyReq); } From 2554343a13d646099daf49223ff63a33571f332d Mon Sep 17 00:00:00 2001 From: lxu75 Date: Wed, 21 May 2025 16:19:31 +0800 Subject: [PATCH 7/8] =?UTF-8?q?retry=E6=9C=BA=E5=88=B6=E6=8A=9B=E5=87=BA?= =?UTF-8?q?=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java | 2 +- .../volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java | 2 +- .../volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java index 1cadd7f..97c808e 100644 --- a/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java +++ b/ai-analytic-center-api/src/main/java/com/volvo/ai/analytic/center/feign/DiFyFeign.java @@ -18,7 +18,7 @@ public interface DiFyFeign { , produces = MediaType.APPLICATION_JSON_VALUE) JSONObject runWorkflows(@RequestHeader(value = "Authorization") String authorization, @RequestBody Map map); - @Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000)) + @Retryable(include = Exception.class,maxAttempts = 2, backoff = @Backoff(delay = 1000)) @PostMapping(value = "v1/workflows/run" , consumes = MediaType.APPLICATION_JSON_VALUE , produces = MediaType.APPLICATION_JSON_VALUE) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java index e639ff2..58836da 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java @@ -18,7 +18,7 @@ public class DiFyRetryImpl { @Autowired private DiFyService diFyService; - @Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000)) + @Retryable(include = Exception.class,maxAttempts = 2, backoff = @Backoff(delay = 1000)) public JSONObject getDiFyRetry(DiFyReq diFyReq) { log.info("diFyService class: {}", diFyService.getClass()); return (JSONObject) diFyService.getDiFyObjectRetry(diFyReq); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java index 42d507a..5ed887e 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java @@ -51,7 +51,7 @@ public class DiFyServiceImpl implements DiFyService{ } @Override - @Retryable(maxAttempts = 1, backoff = @Backoff(delay = 1000)) + @Retryable(include = Exception.class,maxAttempts = 2, backoff = @Backoff(delay = 1000)) public Object getDiFyObjectRetry(DiFyReq diFyReq) { Map map = new HashMap<>(); map.put("inputs",diFyReq.getInputs()); From 726a58df136db100104367b4c68a7ff997b16098 Mon Sep 17 00:00:00 2001 From: lxu75 Date: Wed, 21 May 2025 18:13:46 +0800 Subject: [PATCH 8/8] =?UTF-8?q?retry=E6=9C=BA=E5=88=B6=E6=8A=9B=E5=87=BA?= =?UTF-8?q?=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../center/service/impl/ClaimVerificationServiceImpl.java | 2 +- .../volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java index 2cb0b7a..a0c64d6 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/ClaimVerificationServiceImpl.java @@ -199,7 +199,7 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService { data.put("businessType", claimVerificationFileAnalysisDTO.getBusinessType()); data.put("aiAnalysisRequestId", aiAnalysisRequestId); data.put("fileType", claimVerificationFileAnalysisDTO.getFileType()); - log.info("索赔检核发送异常空MQMQ: {}", data.toString()); + log.info("索赔检核发送异常空MQ: {}", data.toString()); rocketMQTemplate.syncSend(topic, data); } diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java index 58836da..3f5ccd0 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyRetryImpl.java @@ -20,7 +20,7 @@ public class DiFyRetryImpl { private DiFyService diFyService; @Retryable(include = Exception.class,maxAttempts = 2, backoff = @Backoff(delay = 1000)) public JSONObject getDiFyRetry(DiFyReq diFyReq) { - log.info("diFyService class: {}", diFyService.getClass()); + log.info("AI索赔检核调用DIFY（retry）"); return (JSONObject) diFyService.getDiFyObjectRetry(diFyReq); }