From a5fde818ef9969e2e53acfa29b2e6f423bd0c8fc Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 30 四月 2020 19:02:51 +0800 Subject: [PATCH] 小米推送bug修改,增加用户团队信息消费 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java | 7 +++++++ 1 files changed, 7 insertions(+), 0 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java index 93c893d..167059e 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java @@ -34,6 +34,7 @@ import com.yeshi.fanli.service.inter.user.invite.UserInviteMsgNotificationService; import com.yeshi.fanli.service.inter.user.invite.UserInviteValidNumService; import com.yeshi.fanli.service.inter.user.msg.UserAccountMsgNotificationService; +import com.yeshi.fanli.service.inter.user.vip.TeamUserLevelStatisticService; import com.yeshi.fanli.service.inter.user.vip.UserLevelUpgradedNotifyService; import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService; import com.yeshi.fanli.service.inter.user.vip.UserVipConfigService; @@ -43,6 +44,7 @@ import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService; import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory; import com.yeshi.fanli.util.rocketmq.MQTopicName; +import com.yeshi.fanli.util.user.UserLevelUtil; @Service public class UserVIPPreInfoServiceImpl implements UserVIPPreInfoService { @@ -89,6 +91,9 @@ @Resource(name = "producer") private Producer producer; + @Resource + private TeamUserLevelStatisticService teamUserLevelStatisticService; + @Override public void addUserVIPPreInfo(UserVIPPreInfo info) throws UserVIPPreInfoException { if (info == null || info.getUid() == null || info.getProcess() == null) @@ -104,6 +109,8 @@ if (info.getCreateTime() == null) info.setCreateTime(new Date()); userVIPPreInfoMapper.insertSelective(info); + // 璁剧疆缁熻鏁版嵁 + teamUserLevelStatisticService.setUserLevel(info.getUid(), UserLevelUtil.getByLevel(info.getProcess())); } @Override -- Gitblit v1.8.0