diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/AbstractStatsAchievementService.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/AbstractStatsAchievementService.java index 818937dcf6..82b0e2afdb 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/AbstractStatsAchievementService.java +++ b/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 newConfigList = new ArrayList<>(); Integer nextTargetValue = null; int preValue = lastOne.getTargetValue(); diff --git a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/type1/GroupAchievementCustomListener.java b/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/type1/GroupAchievementCustomListener.java index 1e63735ad3..5410794265 100644 --- a/epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/type1/GroupAchievementCustomListener.java +++ b/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){