| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private UserActiveLogService userActiveLogService;
|
|---|
| | | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public Action consume(Message message, ConsumeContext context) {
|
|---|
| | |
|---|
| | | if (boss != null) {
|
|---|
| | | teamUserLevelStatisticService.initData(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())) {
|
|---|
| | | // 订单到账相关
|
|---|
