package com.yeshi.fanli.util.mq.rabbit.consumer;
|
|
import com.rabbitmq.client.Channel;
|
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.order.OrderProcessService;
|
import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;
|
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.NumberUtil;
|
|
import javax.annotation.Resource;
|
import java.nio.charset.StandardCharsets;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author hxh
|
* @title: QueueHelloWorldListener
|
* @description:
|
* @date 2024/9/26 13:47
|
*/
|
@Component
|
public class FanliOrderListener {
|
@Resource
|
private RabbitTemplate rabbitTemplate;
|
|
@Resource
|
private TaoBaoOrderService taoBaoOrderService;
|
|
@Resource
|
private OrderProcessService orderProcessService;
|
|
@RabbitListener(queues = "fanli-order-fanli", ackMode = "MANUAL")
|
public void onMessage(Message message, Channel channel) throws Exception {
|
RabbitmqMsgConsumeUtil.processMessage(message, channel, rabbitTemplate, () -> {
|
String orderId = new String(message.getBody(), StandardCharsets.UTF_8);
|
if (NumberUtil.isNumeric(orderId.trim())) {
|
Map<String, List<TaoBaoOrder>> map = new HashMap<>();
|
List<TaoBaoOrder> orderList = taoBaoOrderService
|
.getTaoBaoOrderByOrderId(orderId);
|
map.put(orderId, orderList);
|
LogHelper.orderInfo("开始处理订单:" + orderId);
|
orderProcessService.processOrder(map);
|
LogHelper.orderInfo("结束处理订单:" + orderId);
|
}
|
});
|
}
|
}
|
