| | |
|---|
| | | 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;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserActiveLogService userActiveLogService;
|
|---|
| | | |
|---|
| | | @Resource
|
|---|
| | | private TeamLevelDailyRecordService teamLevelDailyRecordService;
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | |
|---|
| | | 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())) {
|
|---|
| | | // 订单到账相关
|
|---|
