diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisDifyServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisDifyServiceImpl.java
index 6caef50..1c8820e 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisDifyServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/AiAnalysisDifyServiceImpl.java
@@ -69,7 +69,7 @@ public class AiAnalysisDifyServiceImpl implements AiAnalysisDifyService {
 		if(StringUtils.isNotEmpty(message)){
 			AnalysisDifyResultDTO analysisResp = JSONObject.parseObject(message, AnalysisDifyResultDTO.class);
 
- 			Optional.ofNullable(aiAnalysisRequestLogsService.queryByAiAnalysisRequestId(analysisResp.getAiAnalysisRequestId()))
+			AiAnalysisRequestLogs oldAiAnalysisRequestLogs =	Optional.ofNullable(aiAnalysisRequestLogsService.queryByAiAnalysisRequestId(analysisResp.getAiAnalysisRequestId()))
 					.orElseThrow(() -> new IllegalArgumentException("AiAnalysisRequestId查询对象为空！"));
 
 			AiAnalysisRequestLogs aiAnalysisRequestLogs = new AiAnalysisRequestLogs();
@@ -83,8 +83,10 @@ public class AiAnalysisDifyServiceImpl implements AiAnalysisDifyService {
 			aiAnalysisRequestLogs.setBusinessResponse(difyJson.getString("outputs"));
 			aiAnalysisRequestLogsService.saveAiAnalysisRequestLogs(aiAnalysisRequestLogs);
 
-			// 发送 mq
-			sendMq(callbackTopic, analysisResp);
+			if(StringUtils.isNotEmpty(oldAiAnalysisRequestLogs.getCallbackUrl())){
+				// 发送 mq
+				sendMq(callbackTopic, analysisResp);
+			}
 			return true;
 		}