| | |
|---|
| | | 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
|
|---|
| | | public Action consume(Message message, ConsumeContext context) {
|
|---|
| | |
|---|
| | | if (boss != null) {
|
|---|
| | | teamUserLevelStatisticService.initData(boss.getId());
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | // 重新统计粉丝等级数量
|
|---|
| | | teamLevelDailyRecordService.addStatisticByUid(boss.getId());
|
|---|
| | | }
|
|---|
| | | return Action.CommitMessage;
|
|---|
| | | } else if (tag.equalsIgnoreCase(UserTopicTagEnum.threeSaleSeparate.name())) {// 邀请关系脱离
|
|---|
