package com.yeshi.fanli.util.rocketmq.consumer.user;
|
|
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.order.OrderTopicTagEnum;
|
import com.yeshi.fanli.dto.mq.order.body.OrderConfirmMQMsg;
|
import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;
|
import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
|
import com.yeshi.fanli.dto.mq.user.body.UserLevelChangedMQMsg;
|
import com.yeshi.fanli.dto.mq.user.body.UserMoneyChangeMQMsg;
|
import com.yeshi.fanli.entity.SystemEnum;
|
import com.yeshi.fanli.entity.SystemFunction;
|
import com.yeshi.fanli.entity.bus.user.UserActiveLog;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.money.UserMoneyDebtService;
|
import com.yeshi.fanli.service.inter.user.UserActiveLogService;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
|
import com.yeshi.fanli.service.inter.user.invite.UserInviteValidNumService;
|
import com.yeshi.fanli.service.inter.user.vip.TeamUserLevelStatisticService;
|
import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.SystemInfoUtil;
|
import com.yeshi.fanli.util.VersionUtil;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
/**
|
* 用户超级会员
|
*
|
* @author Administrator
|
*/
|
@Component
|
public class UserMoneyDebtMessageListener implements MessageListener {
|
@Resource
|
private UserMoneyDebtService userMoneyDebtService;
|
|
|
@Override
|
public Action consume(Message message, ConsumeContext context) {
|
|
LogHelper.mqInfo("consumer-UserMoneyMessageListener", 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.userMoneyAdd.name())) {//用户资金增加
|
UserMoneyChangeMQMsg msg = new Gson().fromJson(new String(message.getBody()),
|
UserMoneyChangeMQMsg.class);
|
userMoneyDebtService.repayDebt(msg.getUid());
|
return Action.CommitMessage;
|
}
|
}
|
return Action.CommitMessage;
|
}
|
}
|
