同步老用户等级数据

admin

2020-04-26 f99d8098b0aee17c09be5dfee8b4f72a6f4071b1

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java

@@ -21,6 +21,7 @@
import com.yeshi.fanli.service.inter.user.invite.UserInviteValidNumService;

import com.yeshi.fanli.service.inter.user.vip.TeamUserLevelStatisticService;

import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.rocketmq.MQTopicName;



/**

@@ -53,6 +54,10 @@
      if (tag == null)

         tag = "";



      if (java.lang.System.currentTimeMillis() <= Constant.NEW_ORDER_FANLI_RULE_TIME) {

         return Action.CommitMessage;

      }

		
      // 邀请相关

      if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {

         if (tag.equalsIgnoreCase(UserTopicTagEnum.userLevelChanged.name())) {// 用户等级发生变化

@@ -89,10 +94,10 @@
            if (dto != null) {

               if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU) {// 自购到账

                  // 会员升级-自购订单数量验证

                  userVIPPreInfoService.upgradeVipByFanLiOrder(dto.getUid());

                  userVIPPreInfoService.upgradeVipByMyOrder(dto.getUid());

               } else if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {// 分享到账

                  // 会员升级-分享订单数量验证

                  userVIPPreInfoService.upgradeVipByShareOrder(dto.getUid());

                  userVIPPreInfoService.upgradeVipByMyOrder(dto.getUid());

               }

            }

         } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderConfirm.name())) {