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 51fa695a51..ecc2d38a9b 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,12 +56,11 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently
 
     private void consumeMessage(String  msg) {
         logger.info("receive customerId:{}", JSON.toJSONString(msg));
-        if (StringUtils.isBlank(msg)){
+        ProjectChangedMQMsg msgObj = JSON.parseObject(msg, ProjectChangedMQMsg.class);
+        if (msgObj == null){
             log.warn("consumeMessage msg body is blank");
             return;
         }
-        ProjectChangedMQMsg msgObj = JSON.parseObject(msg, ProjectChangedMQMsg.class);
-
         DistributedLock distributedLock = null;
         RLock lock = null;
         try {
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 e389d5044e..33c0ff7c63 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,12 +48,12 @@ 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)){
+
+        GroupAchievementMQMsg msgObj = JSON.parseObject(msg, GroupAchievementMQMsg.class);
+        if (msgObj == null){
             log.warn("consumeMessage msg body is blank");
             return;
         }
-        GroupAchievementMQMsg msgObj = JSON.parseObject(msg, GroupAchievementMQMsg.class);
-
 
         DistributedLock distributedLock = null;
         RLock lock = null;