删除普通会员等级

admin

2020-04-21 0b57cfd62e842b309d03467b96a331c673ecad7c

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

@@ -10,16 +10,18 @@
import com.aliyun.openservices.ons.api.MessageListener;

import com.google.gson.Gson;

import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;

import com.yeshi.fanli.dto.mq.order.body.OrderConfirmMQMsg;

import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

import com.yeshi.fanli.dto.mq.user.body.ThreeSaleSeparateMQMsg;

import com.yeshi.fanli.dto.mq.user.body.UserInviteMQMsg;

import com.yeshi.fanli.dto.mq.user.body.UserLevelChangedMQMsg;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

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;



/**

@@ -39,6 +41,9 @@


   @Resource

   private ThreeSaleSerivce threeSaleSerivce;

	
   @Resource

   private UserInviteValidNumService userInviteValidNumService;



   @Override

   public Action consume(Message message, ConsumeContext context) {

@@ -49,14 +54,13 @@
      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.inviteSuccess.name())) {

            UserInviteMQMsg msg = new Gson().fromJson(new String(message.getBody()), UserInviteMQMsg.class);

            // 会员等级升级

            userVIPPreInfoService.verifyVipPreInfo(msg.getBossId(), true);

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

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

            UserLevelChangedMQMsg msg = new Gson().fromJson(new String(message.getBody()),

                  UserLevelChangedMQMsg.class);

            // 更新上2级的邀请统计

@@ -89,13 +93,20 @@
                  OrderMoneyRecievedMQMsg.class);

            if (dto != null) {

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

                  // 会员等级升级

                  userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);

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

                  userVIPPreInfoService.upgradeVipByFanLiOrder(dto.getUid());

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

                  // 会员等级升级

                  userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);

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

                  userVIPPreInfoService.upgradeVipByShareOrder(dto.getUid());

               }

            }

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

            OrderConfirmMQMsg dto = new Gson().fromJson(new String(message.getBody()),OrderConfirmMQMsg.class);

            if (dto != null) {

               // 会员等级升级-粉丝数量验证

               userVIPPreInfoService.upgradeVipByTeamNum(dto.getSourceUid());

               userInviteValidNumService.addValidTeamNum(dto.getSourceUid(), dto.getSettleMent(), dto.getPlaceOrderTime());

            }

         }

      }