package com.yeshi.fanli.util.rocketmq.consumer.redpack;
|
|
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.aliyun.openservices.ons.api.Producer;
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum;
|
import com.yeshi.fanli.dto.mq.order.body.OrderMQMsg;
|
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.UserAccountBindingMQMsg;
|
import com.yeshi.fanli.dto.mq.user.body.UserInviteMQMsg;
|
import com.yeshi.fanli.dto.mq.user.body.UserRedPackGiftMQMsg;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.redpack.RedPackGiveRecordService;
|
import com.yeshi.fanli.service.inter.redpack.RedPackWinInviteService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|
/**
|
* 红包消费
|
*
|
* @author Administrator
|
*
|
*/
|
@Component
|
public class RedPackMessageListener implements MessageListener {
|
|
@Resource
|
private UserSystemCouponService userSystemCouponService;
|
|
@Resource
|
private RedPackWinInviteService redPackWinInviteService;
|
|
@Resource
|
private RedPackGiveRecordService redPackGiveRecordService;
|
|
@Resource(name = "producer")
|
private Producer producer;
|
|
@Override
|
public Action consume(Message message, ConsumeContext context) {
|
LogHelper.mqInfo("consumer-RedPackMessageListener", message.getMsgID(), message.getTopic(), message.getTag(),
|
new String(message.getBody()));
|
String tag = message.getTag();
|
if (tag == null)
|
tag = "";
|
|
if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {
|
if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatistic.name())) {// 订单统计
|
OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);
|
// 发送24小时延时消息
|
// 测试时发送
|
int hour = 24;
|
if (Constant.IS_TEST) {
|
hour = 1;
|
}
|
orderMQMsg.setDelayHour(hour);
|
Message msg = new Message(message.getTopic(), OrderTopicTagEnum.orderStatisticDelay.name(),
|
new Gson().toJson(orderMQMsg).getBytes());
|
if (orderMQMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour > System.currentTimeMillis())// 时间是否已经过了
|
msg.setStartDeliverTime(orderMQMsg.getStaticticDate().getTime() + 1000 * 60 * 60L * hour);
|
else
|
msg.setStartDeliverTime(System.currentTimeMillis() + 1000 * 60);
|
producer.send(msg);
|
return Action.CommitMessage;
|
}
|
} else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatisticDelay.name())) {// 订单统计
|
OrderMQMsg orderMQMsg = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);
|
int hour = 24;
|
if (Constant.IS_TEST) {
|
hour = 1;
|
}
|
|
if (orderMQMsg.getDelayHour() == hour) {
|
try {// 邀请奖励
|
redPackWinInviteService.inviteSucceedReward(orderMQMsg.getUid());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
return Action.CommitMessage;
|
} else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiSeparateByOrderNo.name())) {// 订单到账（按订单号处理）
|
OrderMoneyRecievedMQMsg orderMoneyRecievedMQMsg = new Gson().fromJson(new String(message.getBody()),
|
OrderMoneyRecievedMQMsg.class);
|
if (orderMoneyRecievedMQMsg.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU
|
|| orderMoneyRecievedMQMsg.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {
|
if (!StringUtil.isNullOrEmpty(orderMoneyRecievedMQMsg.getOrderId())
|
&& orderMoneyRecievedMQMsg.getUid() != null) {
|
try {
|
redPackWinInviteService.orderArriveReward(orderMoneyRecievedMQMsg.getUid(), orderMoneyRecievedMQMsg.getSourceType(), orderMoneyRecievedMQMsg.getOrderId());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return Action.CommitMessage;
|
} else if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
|
boolean inviteSucceedReward = false;
|
Long uid = null;
|
if (tag.equalsIgnoreCase(UserTopicTagEnum.userAccountBinding.name())) {// 账号绑定
|
UserAccountBindingMQMsg userAccountBindingMQMsg = new Gson().fromJson(new String(message.getBody()),
|
UserAccountBindingMQMsg.class);
|
Integer type = userAccountBindingMQMsg.getType();
|
if (type == UserAccountBindingMQMsg.TYPE_PHONE || type == UserAccountBindingMQMsg.TYPE_WX
|
|| type == UserAccountBindingMQMsg.TYPE_TAOBAO) {
|
inviteSucceedReward = true;
|
uid = userAccountBindingMQMsg.getUid();
|
}
|
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteSuccess.name())) {// 邀请成功
|
UserInviteMQMsg userInviteMQMsg = new Gson().fromJson(new String(message.getBody()),
|
UserInviteMQMsg.class);
|
inviteSucceedReward = true;
|
uid = userInviteMQMsg.getWorkerId();
|
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.redPackGiftDrawback.name())) {// 红包赠送
|
UserRedPackGiftMQMsg userRedPackGiftMQMsg = new Gson().fromJson(new String(message.getBody()),
|
UserRedPackGiftMQMsg.class);
|
try { // 红包赠送到期未领取
|
redPackGiveRecordService.overdueByPrimaryKey(userRedPackGiftMQMsg.getId());
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return Action.CommitMessage;
|
}
|
|
if (inviteSucceedReward) {
|
try {// 邀请奖励
|
redPackWinInviteService.inviteSucceedReward(uid);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
return Action.CommitMessage;
|
}
|
}
|
