增加邀请关系详细表同步

admin

2020-05-12 654b2ed3f9ee289ae4be884ddde7f8d1da28cbf3

增加邀请关系详细表同步

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

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

import com.yeshi.fanli.log.LogHelper;

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

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

import com.yeshi.fanli.util.rocketmq.MQTopicName;



import net.sf.json.JSONObject;

@@ -35,6 +36,8 @@
    @Resource

    private TeamFansInfoService teamFansInfoService;

    

    @Resource

    private ThreeSaleDetailService threeSaleDetailService;

    

    @Override

    public Action consume(Message message, ConsumeContext context) {

@@ -83,7 +86,7 @@
                UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(),UserInviteMQMsg.class);

                if (mqMsg != null) {

                    teamFansInfoService.updateFansNum(mqMsg.getBossId());

					
                    threeSaleDetailService.addByWorkerUid(mqMsg.getWorkerId());

                }

            } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userMoneyAdd.name())) {// 资金到账

                // 更新近60天到账