加强判断

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;

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 {