package com.yeshi.fanli.util.rocketmq.consumer.user;
|
|
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.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|
/**
|
* 用户粉丝消息
|
*
|
* @author Administrator
|
*
|
*/
|
@Component
|
public class UserTeamMessageListener implements MessageListener {
|
|
@Override
|
public Action consume(Message message, ConsumeContext context) {
|
|
LogHelper.mqInfo("consumer-UserTeamMessageListener", message.getMsgID(), message.getTopic(), message.getTag(),
|
new String(message.getBody()));
|
String tag = message.getTag();
|
if (tag == null)
|
tag = "";
|
|
// 订阅粉丝增加/粉丝成为有效用户 消息,淘宝授权，微信号绑定，最近登录，用户资金增加
|
|
if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
|
if (tag.equalsIgnoreCase(UserTopicTagEnum.userActve.name())) {// 用户活跃
|
// TODO 更改用户活跃时间
|
|
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 用户信息更新
|
|
// TODO 更改微信号绑定
|
|
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.taobaoBindSuccess.name())) {// 淘宝绑定成功
|
|
// TODO 更改淘宝绑定状态与原用户淘宝绑定状态
|
|
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteSuccess.name())) {// 邀请成功
|
|
// TODO 更新粉丝数量
|
|
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.userMoneyAdd.name())) {// 资金到账
|
|
// TODO 更新近60天到账
|
|
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.becomeValidUser.name())) {// 成为有效用户
|
|
// TODO 有效用户标识
|
}
|
}
|
return Action.CommitMessage;
|
}
|
}
|
