package com.yeshi.fanli.util.rocketmq.consumer.order;
|
|
import java.util.Date;
|
|
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.aliyun.openservices.ons.api.SendResult;
|
import com.google.gson.Gson;
|
import com.yeshi.fanli.dto.mq.BaseMQMsgBody;
|
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.UserSystemCouponUseMQMsg;
|
import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;
|
import com.yeshi.fanli.entity.mq.MQUnSendInfo;
|
import com.yeshi.fanli.entity.system.SystemCoupon;
|
import com.yeshi.fanli.exception.money.OrderMoneySettleException;
|
import com.yeshi.fanli.exception.mq.MQUnSendInfoException;
|
import com.yeshi.fanli.exception.order.InviteOrderSubsidyException;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService;
|
import com.yeshi.fanli.service.inter.order.InviteOrderSubsidyService;
|
import com.yeshi.fanli.service.inter.order.OrderMoneySettleService;
|
import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|
/**
|
* 邀请订单补贴消息消费
|
*
|
* @author Administrator
|
*
|
*/
|
@Component
|
public class InviteOrderSubsidyMessageListener implements MessageListener {
|
@Resource
|
private InviteOrderSubsidyService inviteOrderSubsidyService;
|
|
@Resource
|
private UserSystemCouponRecordService userSystemCouponRecordService;
|
|
@Resource(name = "producer")
|
private Producer producer;
|
|
@Resource
|
private MQUnSendInfoService mqUnSendInfoService;
|
|
@Resource
|
private OrderMoneySettleService orderMoneySettleService;
|
|
public InviteOrderSubsidyMessageListener() {
|
|
}
|
|
@Override
|
public Action consume(Message message, ConsumeContext context) {
|
LogHelper.mqInfo("consumer:InviteOrderSubsidyMessageListener", message.getMsgID(),message.getTopic(), message.getTag(),
|
new String(message.getBody()));
|
String tag = message.getTag();
|
|
if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) {
|
if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderStatistic.name())
|
|| tag.equalsIgnoreCase(OrderTopicTagEnum.orderUpdate.name())) {
|
// 查询上级红包
|
OrderMQMsg dto = new Gson().fromJson(new String(message.getBody()), OrderMQMsg.class);
|
if (dto != null) {
|
try {
|
inviteOrderSubsidyService.addOrUpdateByOrder(dto.getOrderId(), dto.getType());
|
} catch (InviteOrderSubsidyException e) {
|
return Action.ReconsumeLater;
|
}
|
}
|
} else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {
|
OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(message.getBody()),
|
OrderMoneyRecievedMQMsg.class);
|
if (dto != null) {
|
if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU) {// 自购到账
|
// 判断订单号是否在补贴中
|
long count = inviteOrderSubsidyService.countByOrderIdAndSourceType(dto.getOrderId(),
|
dto.getSourceType());
|
if (count > 0) {// 延时消息发送
|
sendOrderSubsidyUpdateLater(dto, 5);
|
}
|
} else if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_INVITE) {// 邀请到账
|
// 补贴到账
|
try {
|
orderMoneySettleService.inviteSubsidySettle(dto.getUid(), message.getKey());
|
return Action.CommitMessage;
|
} catch (OrderMoneySettleException e) {
|
return Action.ReconsumeLater;
|
}
|
}
|
}
|
} else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiDelay.name())) {
|
OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(message.getBody()),
|
OrderMoneyRecievedMQMsg.class);
|
if (dto != null) {
|
if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU) {// 延时时间已到
|
// 判断订单号是否在补贴中
|
long count = inviteOrderSubsidyService.countByOrderIdAndSourceType(dto.getOrderId(),
|
dto.getSourceType());
|
if (count > 0) {
|
// 判断是否要使用奖励券
|
UserSystemCouponRecord record = userSystemCouponRecordService
|
.getRecordByOrderNo(dto.getOrderId(), UserSystemCouponRecord.STATE_SUCCESS);
|
if (record != null
|
&& record.getCouponType()
|
.equalsIgnoreCase(SystemCoupon.CouponTypeEnum.rebatePercentCoupon.name())
|
&& record.getGoodSource() == dto.getSourceType()) {// 成功使用了奖励券
|
inviteOrderSubsidyService.invalidByOrderIdAndSourceType(dto.getOrderId(),
|
dto.getSourceType());
|
} else {
|
// 使数据有效
|
inviteOrderSubsidyService.validByOrderIdAndSourceType(dto.getOrderId(),
|
dto.getSourceType());
|
}
|
}
|
}
|
}
|
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.useSystemCoupon.name())) {
|
UserSystemCouponUseMQMsg dto = new Gson().fromJson(new String(message.getBody()),
|
UserSystemCouponUseMQMsg.class);
|
if (dto != null && dto.getCouponType()
|
.equalsIgnoreCase(SystemCoupon.CouponTypeEnum.rebatePercentCoupon.name())) {// 返利奖励券的使用
|
long count = inviteOrderSubsidyService.countByOrderIdAndSourceType(dto.getOrderId(),
|
dto.getSourceType());
|
if (count > 0) {
|
// 使相关订单失效
|
inviteOrderSubsidyService.invalidByOrderIdAndSourceType(dto.getOrderId(), dto.getSourceType());
|
}
|
return Action.CommitMessage;
|
}
|
}
|
}
|
return Action.CommitMessage;
|
}
|
|
/**
|
* 发送订单延时消息
|
*
|
* @param day
|
*/
|
private boolean sendOrderSubsidyUpdateLater(OrderMoneyRecievedMQMsg dto, int day) {
|
|
Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderFanLiDelay,
|
dto);
|
msg.setKey(dto.getSourceType() + "_" + dto.getOrderId());
|
long delayTime = System.currentTimeMillis() + (Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 60 * 24L * day);
|
msg.setStartDeliverTime(delayTime);
|
SendResult sendResult = producer.send(msg);
|
if (sendResult != null) {
|
return true;
|
} else {
|
MQUnSendInfo info = new MQUnSendInfo();
|
info.setBody(new String(msg.getBody()));
|
if (msg.getStartDeliverTime() > 0)
|
info.setDeliverTime(new Date(msg.getStartDeliverTime()));
|
info.setKey(msg.getKey());
|
info.setTag(msg.getTag());
|
info.setTopic(msg.getTopic());
|
try {
|
mqUnSendInfoService.addMQUnSendInfo(info);
|
} catch (MQUnSendInfoException e) {
|
e.printStackTrace();
|
}
|
return false;
|
}
|
}
|
|
}
|
