添加判断解决异常

epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/AbstractStatsAchievementService.java

@@ -80,6 +80,9 @@ public abstract class AbstractStatsAchievementService {
             throw new RenException("小组人数都到10000啦？");
         }
         ResiGroupAchievementConfigEntity lastOne = achievementConfigService.getLastOne(achievementType);
+        if (lastOne == null){
+            throw new RenException("小组成就配置有误，type:{}",achievementType);
+        }
         List<ResiGroupAchievementConfigEntity> newConfigList = new ArrayList<>();
         Integer nextTargetValue = null;
         int preValue = lastOne.getTargetValue();

epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/type1/GroupAchievementCustomListener.java

@@ -3,7 +3,6 @@ package com.epmet.mq.type1;
 import com.alibaba.fastjson.JSON;
 import com.epmet.commons.rocketmq.messages.GroupAchievementMQMsg;
 import com.epmet.commons.tools.distributedlock.DistributedLock;
-import com.epmet.commons.tools.exception.ExceptionUtils;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.utils.SpringContextUtils;
 import com.epmet.modules.group.service.StatsAchievementService;
@@ -63,10 +62,10 @@ public class GroupAchievementCustomListener implements MessageListenerConcurrent
             logger.info("consumer msg success,{}",aBoolean);
         } catch (RenException e) {
             // 如果是我们手动抛出的异常，说明在业务可控范围内。目前不需要MQ重试
-            logger.error("【RocketMQ】初始化客户组织失败:".concat(ExceptionUtils.getErrorStackTrace(e)));
+            logger.error("【RocketMQ】消费小组成就消息失败:",e);
         } catch (Exception e) {
             // 不是我们自己抛出的异常，可以让MQ重试
-            logger.error("【RocketMQ】初始化客户组织失败:".concat(ExceptionUtils.getErrorStackTrace(e)));
+            logger.error("【RocketMQ】消费小组成就消息失败:",e);
             throw e;
         } finally {
             if (distributedLock != null){