消息图标

yujian

2020-04-16 eb8a333be4ff975ef2b7522f9356bc08c1659abc

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

@@ -18,6 +18,7 @@
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.rocketmq.MQTopicName;

@@ -39,6 +40,9 @@


   @Resource

   private ThreeSaleSerivce threeSaleSerivce;

	
   @Resource

   private UserInviteValidNumService userInviteValidNumService;



   @Override

   public Action consume(Message message, ConsumeContext context) {

@@ -89,13 +93,14 @@
               } else if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {// 分享到账

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

                  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());

            }

         }

      }