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