package com.yeshi.fanli.util.rocketmq.consumer.coupon;
|
|
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.order.OrderMoneyRecievedMQMsgDTO;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|
@Component
|
public class SystemCouponMessageListener implements MessageListener {
|
@Override
|
public Action consume(Message message, ConsumeContext context) {
|
LogHelper.mqInfo("consumer-SystemCouponMessageListener", message.getTopic(), message.getTag(),
|
new String(message.getBody()));
|
if (MQTopicName.TOPIC_FANLI.name().equalsIgnoreCase(message.getTopic())) {
|
OrderMoneyRecievedMQMsgDTO orderMoneyRecievedMQMsgDTO = new Gson().fromJson(new String(message.getBody()),
|
OrderMoneyRecievedMQMsgDTO.class);
|
if (orderMoneyRecievedMQMsgDTO != null) {
|
if (orderMoneyRecievedMQMsgDTO.getOrderFirst() != null
|
&& orderMoneyRecievedMQMsgDTO.getOrderFirst() == true) {
|
// 首次到账返利
|
// TODO 业务代码添加
|
|
// 业务代码执行成功后返回
|
return Action.CommitMessage;
|
}
|
}
|
}
|
return Action.CommitMessage;
|
}
|
}
|
