From 876569bbb05dda96f4d971c7d971c0d4642a3917 Mon Sep 17 00:00:00 2001
From: lxu75 <liang.xu.4@volvocars.com>
Date: Tue, 13 May 2025 17:29:01 +0800
Subject: [PATCH] =?UTF-8?q?=E8=88=86=E6=83=85=E8=87=AA=E5=8A=A8=E5=8C=96?=
 =?UTF-8?q?=E5=85=A5=E5=8F=82=E6=A0=A1=E9=AA=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../center/service/impl/MqMessageRecordServiceImpl.java    | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
index 7f9cf4b..5e2ce92 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
@@ -106,8 +106,11 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
     public boolean processMessageByMQ(String message) {
         log.info("communityProcessMessageByMQ message: {}", message);
         CommunityTargetDTO communityTargetDTO = JSON.parseObject(message, CommunityTargetDTO.class);
-        if (communityTargetDTO == null) {
-            log.error("communityProcessMessageByMQ message is null");
+        if (communityTargetDTO == null
+                || StringUtils.isBlank(communityTargetDTO.getTargetId())
+                || StringUtils.isBlank(communityTargetDTO.getTargetType())
+                || communityTargetDTO.getContent().isEmpty()) {
+            log.error("社区舆情自动化校验失败入参异常：{}",JSON.toJSONString(communityTargetDTO));
             return false;
         }
         // 生成ai分析请求id