diff --git a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java
index 4687e0af89..51fa695a51 100644
--- a/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java
+++ b/epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java
@@ -56,6 +56,10 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently
 
     private void consumeMessage(String  msg) {
         logger.info("receive customerId:{}", JSON.toJSONString(msg));
+        if (StringUtils.isBlank(msg)){
+            log.warn("consumeMessage msg body is blank");
+            return;
+        }
         ProjectChangedMQMsg msgObj = JSON.parseObject(msg, ProjectChangedMQMsg.class);
 
         DistributedLock distributedLock = null;
diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java
index 8d8d0f3b26..e389d5044e 100644
--- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java
+++ b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java
@@ -48,8 +48,13 @@ public class GroupAchievementCustomListener  implements MessageListenerConcurren
     private void consumeMessage(MessageExt messageExt) {
         logger.info("receive msg:{}", JSON.toJSONString(messageExt));
         String msg = new String(messageExt.getBody());
+        if (StringUtils.isBlank(msg)){
+            log.warn("consumeMessage msg body is blank");
+            return;
+        }
         GroupAchievementMQMsg msgObj = JSON.parseObject(msg, GroupAchievementMQMsg.class);
 
+
         DistributedLock distributedLock = null;
         RLock lock = null;
         try {