券后价调整

yujian

2020-06-08 b3da9f82b7740d39742fef1a81a56c22fe1c8b9c

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

@@ -20,6 +20,7 @@
import com.yeshi.fanli.dto.mq.user.body.UserLevelChangedMQMsg;

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

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

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

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

import com.yeshi.fanli.log.LogHelper;

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

@@ -96,6 +97,10 @@
            JSONObject json = JSONObject.fromObject(new String(message.getBody()));

            UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(), UserInviteMQMsg.class);

            if (mqMsg != null) {

               ThreeSale ts = threeSaleSerivce.selectByWorkerId(mqMsg.getWorkerId());

               if (ts == null)

                  return Action.ReconsumeLater;



               // 更新上级的粉丝数量

               teamFansInfoService.updateFansNum(mqMsg.getBossId());