package com.yeshi.fanli.util.rocketmq.consumer.user;
|
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Set;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Component;
|
|
import com.aliyun.openservices.ons.api.Action;
|
import com.aliyun.openservices.ons.api.ConsumeContext;
|
import com.aliyun.openservices.ons.api.Message;
|
import com.aliyun.openservices.ons.api.MessageListener;
|
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.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.bus.user.vip.TearcherInfo;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
|
import com.yeshi.fanli.service.inter.user.vip.TearcherService;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|
import net.sf.json.JSONObject;
|
|
/**
|
* 用户超级会员
|
*
|
* @author Administrator
|
*
|
*/
|
@Component
|
public class TearcherMessageListener implements MessageListener {
|
|
@Resource
|
private ThreeSaleSerivce threeSaleSerivce;
|
|
@Resource
|
private TearcherService tearcherService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
private static Set<Long> officialUids = null;
|
|
@Override
|
public Action consume(Message message, ConsumeContext context) {
|
LogHelper.mqInfo("consumer-TearcherMessageListener", message.getMsgID(), message.getTopic(), message.getTag(),
|
new String(message.getBody()));
|
String tag = message.getTag();
|
if (tag == null)
|
tag = "";
|
String topic = message.getTopic();
|
|
if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(topic)) {
|
|
// 邀请激活
|
if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteCodeActive.name())) {
|
|
JSONObject json = JSONObject.fromObject(new String(message.getBody()));
|
|
InviteCodeActiveMQMsg inviteCodeActiveMQMsg = new Gson().fromJson(json.toString(),
|
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());
|
}
|
}
|
}
|
}
|
}
|
}
|
|
return Action.CommitMessage;
|
}
|
}
|
