券后价调整

yujian

2020-06-08 b3da9f82b7740d39742fef1a81a56c22fe1c8b9c

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

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

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.TeamLevelDailyRecordService;

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

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

import com.yeshi.fanli.util.Constant;

@@ -52,9 +51,6 @@
   @Resource

   private UserActiveLogService userActiveLogService;

   

   @Resource

   private TeamLevelDailyRecordService teamLevelDailyRecordService;

	


   @Override

   public Action consume(Message message, ConsumeContext context) {

@@ -80,6 +76,7 @@
                  return Action.CommitMessage;

            }



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

            teamUserLevelStatisticService.updateUserLevel(msg.getUid());

            UserInfo boss = threeSaleSerivce.getBoss(msg.getUid());

@@ -89,23 +86,9 @@
               if (boss != null) {

                  teamUserLevelStatisticService.initData(boss.getId());

               }

					
               // 重新统计粉丝等级数量

               teamLevelDailyRecordService.addStatisticByUid(boss.getId());

            }

            return Action.CommitMessage;

         } else if (tag.equalsIgnoreCase(UserTopicTagEnum.threeSaleSeparate.name())) {// 邀请关系脱离

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

                  ThreeSaleSeparateMQMsg.class);



            // 更新上两级邀请统计

            teamUserLevelStatisticService.initData(msg.getBossUid());

            UserInfo boss = threeSaleSerivce.getBoss(msg.getBossUid());

            if (boss != null) {

               teamUserLevelStatisticService.initData(boss.getId());

            }

            return Action.CommitMessage;

         }

         } 


      } else if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {

         // 订单到账相关