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 5410794265..af9624d5ca 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 @@ -58,6 +58,12 @@ public class GroupAchievementCustomListener implements MessageListenerConcurrent logger.error("consumer fail,msg:{}",msgObj); return; } + //消息被消费太快 业务数据还没有完成 歇一会先 + try { + Thread.sleep(200L); + } catch (InterruptedException e) { + logger.error("consumeMessage sleep",e); + } Boolean aBoolean = SpringContextUtils.getBean(StatsAchievementService.class).calculateAcm(msgObj.getCustomerId(), msgObj.getGroupId(), msgObj.getAchievementType()); logger.info("consumer msg success,{}",aBoolean); } catch (RenException e) {