diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/ClaimVerificationConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/ClaimVerificationConsumer.java
index d3d9e34..04252f8 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/ClaimVerificationConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/ClaimVerificationConsumer.java
@@ -10,8 +10,8 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer..group}",
-        topic = "${rocketmq.consumer.topic}",
+@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.claimVerification.group}",
+        topic = "${rocketmq.consumer.claimVerification.topic}",
         enableMsgTrace = true)
 public class ClaimVerificationConsumer implements RocketMQListener<MessageExt>{
 
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 7996260..cfd4937 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
@@ -49,9 +49,6 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
     @Autowired
     private DiFyService diFyService;
 
-    @Value("${dify.claimVerification.user}")
-    private String claimVerificationUser;
-
     @Value("${dify.claimVerification.fileToken}")
     private String fileToken;
 
@@ -160,6 +157,7 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
                 data.put("businessType", claimVerificationFileAnalysisDTO.getBusinessType());
                 data.put("fileType", claimVerificationFileAnalysisDTO.getFileType());
                 data.put("fileData",difyToAfter);
+                data.put("aiAnalysisRequestId",aiAnalysisRequestId);
                 //返回结果推送到Newbie的MQ
                 rocketMQTemplate.syncSend(topic, data);
                 log.info("索赔检核文件分析发送回调MQ完成: {}", data);
@@ -206,9 +204,12 @@ public class ClaimVerificationServiceImpl implements ClaimVerificationService {
                 data.put("newBieAfterSalesId", claimVerificationFileAnalysisDTO.getNewBieAfterSalesId());
                 data.put("businessType", claimVerificationFileAnalysisDTO.getBusinessType());
                 data.put("warrantyAuditReport",audiResToAfter);
+                data.put("aiAnalysisRequestId",aiAnalysisRequestId);
                 //返回结果推送到Newbie的MQ
                 rocketMQTemplate.syncSend(topic, data);
                 log.info("索赔检核审计报告发送回调MQ完成: {}", data);
+                //异步更新请求日志表的difyResponse字段
+                syncUpdateDiFyResponse(diFyObject, aiAnalysisRequestId);
             }
         }else {
             throw new RuntimeException("售后索赔检核业务类型错误");