From 2669c4426d418e534a2d682c12a219eb1382de15 Mon Sep 17 00:00:00 2001 From: jianjun Date: Fri, 23 Apr 2021 16:48:01 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=88=A4=E6=96=AD=E8=A7=A3?= =?UTF-8?q?=E5=86=B3=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../group/service/AbstractStatsAchievementService.java | 3 +++ .../com/epmet/mq/type1/GroupAchievementCustomListener.java | 5 ++--- 2 files changed, 5 insertions(+), 3 deletions(-) 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){