diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java
index 8f7c0fa..70f1864 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java
@@ -117,19 +117,28 @@ public class CorpusFailJob {
 
                                     oldAiAnalysisRequestLogs.setDifyResponse(JSON.toJSONString(execDifyFlow));
                                     updateDiFyRequest(oldAiAnalysisRequestLogs, oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
-                                    aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount() + 1);
                                     aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
-                                    updateAiAnalysisErrors(aiAnalysisErrors, oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
-
                                 }
+                                aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount() + 1);
+                                updateAiAnalysisErrors(aiAnalysisErrors, oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
                             } else if(null != corpusReportDTO && corpusReportDTO.getAnalysisScene() == 3){
                                 log.info(" corpusFailTask 铭牌数据重试：{},aiId:{}", corpusReportDTO.getCustomerFlowId(), oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
                                 JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyReq, oldAiAnalysisRequestLogs.getAiAnalysisRequestType(), JSONObject.toJSONString(corpusReportDTO),oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
                                 List<TmNameplateCorpus>  nameplateCorpusList =  tmNameplateCorpusService.queryTelephoneCorpusByCustomerFlowId( Arrays.asList(corpusReportDTO.getCustomerFlowId()));
-                                if(CollectionUtils.isNotEmpty(nameplateCorpusList)) {
-                                    TmNameplateCorpus nameplateCorpus = nameplateCorpusList.get(0);
-                                    tmNameplateCorpusService.sendNameplateLto(execDifyFlow,oldAiAnalysisRequestLogs.getAiAnalysisRequestId(), nameplateCorpus);
+                                if (null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")) {
+                                    JSONObject text = execDifyFlow.getJSONObject("outputs");
+                                    if(CollectionUtils.isNotEmpty(nameplateCorpusList)) {
+                                        TmNameplateCorpus nameplateCorpus = nameplateCorpusList.get(0);
+                                        tmNameplateCorpusService.sendNameplateLto(execDifyFlow,oldAiAnalysisRequestLogs.getAiAnalysisRequestId(), nameplateCorpus);
+                                    }
+                                    oldAiAnalysisRequestLogs.setBusinessResponse( text.toJSONString());
+
+                                    oldAiAnalysisRequestLogs.setDifyResponse(JSON.toJSONString(execDifyFlow));
+                                    updateDiFyRequest(oldAiAnalysisRequestLogs, oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
+                                    aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
                                 }
+                                aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount() + 1);
+                                updateAiAnalysisErrors(aiAnalysisErrors, oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
                             }else {
                                 List<AicorpusTelephoneDTO>  dccDtoList =  tmTelephoneCorpusMapper.queryTelephoneCorpusBySourceIds( Arrays.asList(corpusReportDTO.getRecordId()));
                                 if(CollectionUtils.isNotEmpty(dccDtoList)){
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
index 081b7d4..5ab97fc 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
@@ -205,7 +205,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 
 	@Override
 	public void sendMq(String tag, String message) {
-		rocketMqTemplate.asyncSend(topic+":"+ tag, MessageBuilder.withPayload(message).build(),
+		rocketMqTemplate.asyncSend(topic+":"+ tag, message,
 				new SendCallback() {
 					@Override
 					public void onSuccess(SendResult sendResult) {