| | |
|---|
| | | package cc.mrbird.febs.rabbit.consumer; |
|---|
| | | |
|---|
| | | import cc.mrbird.febs.mall.service.IApiMallOrderInfoService; |
|---|
| | | import cc.mrbird.febs.rabbit.constants.QueueConstants; |
|---|
| | | import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum; |
|---|
| | | import com.rabbitmq.client.Channel; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.amqp.core.Message; |
|---|
| | | import org.springframework.amqp.rabbit.annotation.RabbitListener; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import java.util.Date; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @author wzy |
|---|
| | |
|---|
| | | @Component |
|---|
| | | public class AgentConsumer { |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IApiMallOrderInfoService orderInfoService; |
|---|
| | | |
|---|
| | | @RabbitListener(queues = QueueConstants.QUEUE_DEFAULT) |
|---|
| | | public void agentReturn(Message message, Channel channel) { |
|---|
| | | log.info("消费者:{}", new String(message.getBody())); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @RabbitListener(queues = "queue_order_delay") |
|---|
| | | public void orderCancelDelay(String id) { |
|---|
| | | log.info("订单超时支付自动取消:{}", id); |
|---|
| | | orderInfoService.autoCancelOrder(Long.parseLong(id)); |
|---|
| | | } |
|---|
| | | } |
|---|
