package com.yeshi.fanli.util.mq.rabbit.consumer;
|
|
import com.google.gson.Gson;
|
import com.rabbitmq.client.Channel;
|
import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg;
|
import com.yeshi.fanli.entity.dy.DYOrder;
|
import com.yeshi.fanli.entity.jd.JDOrder;
|
import com.yeshi.fanli.entity.pdd.PDDOrder;
|
import com.yeshi.fanli.entity.suning.SuningOrderInfo;
|
import com.yeshi.fanli.entity.vipshop.VipShopOrder;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.order.OrderProcessService;
|
import com.yeshi.fanli.service.inter.order.dy.DYOrderService;
|
import com.yeshi.fanli.service.inter.order.jd.JDOrderService;
|
import com.yeshi.fanli.service.inter.order.pdd.PDDOrderService;
|
import com.yeshi.fanli.service.inter.order.suning.SuningOrderService;
|
import com.yeshi.fanli.service.inter.order.vipshop.VipShopOrderService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.mq.rabbit.RabbitmqMsgConsumeUtil;
|
import org.springframework.amqp.core.Message;
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.JsonUtil;
|
|
import javax.annotation.Resource;
|
import java.nio.charset.StandardCharsets;
|
import java.util.List;
|
|
/**
|
* @author hxh
|
* @title: QueueHelloWorldListener
|
* @description:
|
* @date 2024/9/26 13:47
|
*/
|
@Component
|
public class OrderAllListener {
|
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
|
@Resource
|
private JDOrderService jdOrderService;
|
|
@Resource
|
private PDDOrderService pddOrderService;
|
|
@Resource
|
private VipShopOrderService vipShopOrderService;
|
|
@Resource
|
private SuningOrderService suningOrderService;
|
|
|
@Resource
|
private DYOrderService dyOrderService;
|
|
|
@Resource
|
private OrderProcessService orderProcessService;
|
|
|
@RabbitListener(queues = "order-all-fanli", ackMode = "MANUAL")
|
public void onMessage(Message message, Channel channel) throws Exception {
|
RabbitmqMsgConsumeUtil.processMessage(message, channel, rabbitTemplate, () -> {
|
String result = new String(message.getBody(), StandardCharsets.UTF_8);
|
CommonOrderMQMsg orderMQMsg = JsonUtil.getSimpleGson().fromJson(result, CommonOrderMQMsg.class);
|
try {
|
LogHelper.test("订单消费:" + new Gson().toJson(orderMQMsg));
|
if (orderMQMsg != null) {
|
String orderId = orderMQMsg.getOrderId();
|
switch (orderMQMsg.getSourceType()) {
|
case Constant
|
.SOURCE_TYPE_JD: {
|
JDOrder order = jdOrderService.selectDetailByOrderId(Long.parseLong(orderId));
|
orderProcessService.processJDOrder(order);
|
}
|
break;
|
case Constant
|
.SOURCE_TYPE_PDD: {
|
List<PDDOrder> orderList = pddOrderService.selectByOrderSn(orderId);
|
if (orderList != null)
|
for (PDDOrder order : orderList)
|
orderProcessService.processPDDOrder(order);
|
}
|
break;
|
case Constant
|
.SOURCE_TYPE_VIP: {
|
List<VipShopOrder> orderList = vipShopOrderService.listDetailByOrderSn(orderId);
|
if (orderList != null)
|
for (VipShopOrder order : orderList)
|
orderProcessService.processVipShopOrder(order);
|
}
|
break;
|
case Constant
|
.SOURCE_TYPE_SUNING: {
|
List<SuningOrderInfo> orderList = suningOrderService.listByOrderCode(orderId);
|
if (orderList != null)
|
for (SuningOrderInfo order : orderList)
|
orderProcessService.processSuningOrder(order);
|
}
|
break;
|
case Constant
|
.SOURCE_TYPE_DY: {
|
List<DYOrder> orderList = dyOrderService.listByOrderId(orderId);
|
if (orderList != null)
|
for (DYOrder order : orderList)
|
orderProcessService.processDYOrder(order);
|
}
|
break;
|
}
|
}
|
} catch (Exception e) {
|
LogHelper.errorDetailInfo(e);
|
throw e;
|
}
|
});
|
}
|
}
|
