导师消息消费订阅用户活跃

admin

2020-04-27 cc44f797c5a0a2f462c3426f477c00737fbf79b2

导师消息消费订阅用户活跃

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

@@ -15,6 +15,7 @@
import com.google.gson.Gson;

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

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

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

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

import com.yeshi.fanli.entity.bus.user.vip.TearcherInfo;

import com.yeshi.fanli.log.LogHelper;

@@ -65,32 +66,42 @@
                        InviteCodeActiveMQMsg.class);

                if (inviteCodeActiveMQMsg != null) {

                    // 顶级为测试用户的全部分配官方导师微信



                    // 获取顶级boss

                    Long bossId = threeSaleSerivce.getTopBoss(inviteCodeActiveMQMsg.getUid());

                    if (bossId != null) {



                        if (officialUids == null) {

                            officialUids = new HashSet<>();

                            List<UserInfo> userList = userInfoService.listByType(1, 1, 10000);



                            for (UserInfo user : userList)

                                officialUids.add(user.getId());

                        }



                        if (officialUids.contains(bossId)) {

                            List<TearcherInfo> tearcherList = tearcherService.listByType(TearcherInfo.TYPE_OFFICIAL, 1,

                                    1);

                            if (tearcherList != null && tearcherList.size() > 0) {

                                tearcherService.addUserTearcherMap(tearcherList.get(0).getId(),

                                        inviteCodeActiveMQMsg.getUid());

                            }

                        }

                    }

                    initTearcher(inviteCodeActiveMQMsg.getUid());

                }

            } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userActve.name())) {

                UserActiveMQMsg userActiveMQMsg = new Gson().fromJson(new String(message.getBody()),

                        UserActiveMQMsg.class);

                if (userActiveMQMsg != null) {

                    initTearcher(userActiveMQMsg.getUid());

                }

            }

        }



        return Action.CommitMessage;

    }



    private void initTearcher(Long uid) {

        if (tearcherService.selectByUid(uid) != null)

            return;



        // 获取顶级boss

        Long bossId = threeSaleSerivce.getTopBoss(uid);

        if (bossId != null) {



            if (officialUids == null) {

                officialUids = new HashSet<>();

                List<UserInfo> userList = userInfoService.listByType(1, 1, 10000);



                for (UserInfo user : userList)

                    officialUids.add(user.getId());

            }



            if (officialUids.contains(bossId)) {

                List<TearcherInfo> tearcherList = tearcherService.listByType(TearcherInfo.TYPE_OFFICIAL, 1, 1);

                if (tearcherList != null && tearcherList.size() > 0) {

                    tearcherService.addUserTearcherMap(tearcherList.get(0).getId(), uid);

                }

            }

        }

    }

}


 fanli/src/main/resource/rocket/consumer.xml

@@ -305,7 +305,7 @@
                    <key>

                        <bean class="com.aliyun.openservices.ons.api.bean.Subscription">

                            <property name="topic" value="TOPIC_USER" />

                            <property name="expression" value="inviteCodeActive" />

                            <property name="expression" value="inviteCodeActive||userActve" />

                        </bean>

                    </key>

                </entry>