From 9c8f2d141e88b18c289523d4fa777bb55886525c Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Mon, 21 Jul 2025 14:49:27 +0800
Subject: [PATCH] fix(clothesType): 修复订单列表选择提示信息
---
src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java | 18 ++++++++++++++++++
1 files changed, 18 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java b/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java
index 1efdee6..ddceb98 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java
@@ -62,6 +62,17 @@
});
}
+ public void sendClothesOrderCancelDelayMsg(Long id, Long times) {
+ log.info("发送自动取消订单消息:{}, {}", id, times);
+ rabbitTemplate.convertAndSend(RabbitQueueEnum.ORDER_CANCEL_DELAY_TTL.getExchange(), RabbitQueueEnum.ORDER_CANCEL_DELAY_TTL.getRoute(), id, new MessagePostProcessor() {
+ @Override
+ public Message postProcessMessage(Message message) throws AmqpException {
+ message.getMessageProperties().setExpiration(String.valueOf(times));
+ return message;
+ }
+ });
+ }
+
/**
* 发送代理自动升级消息
*
@@ -98,6 +109,13 @@
rabbitTemplate.convertAndSend(RabbitQueueEnum.VIP_LEVEL_UP.getExchange(), RabbitQueueEnum.VIP_LEVEL_UP.getRoute(), orderId, correlationData);
}
+ public void sendSaleLevelUp(Long orderId) {
+ log.info("发送团长升级:{}", orderId);
+
+ CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
+ rabbitTemplate.convertAndSend(RabbitQueueEnum.SALE_LEVEL_UP.getExchange(), RabbitQueueEnum.SALE_LEVEL_UP.getRoute(), orderId, correlationData);
+ }
+
public void sendCheckActivityItem(Long orderId) {
log.info("核销活动门票:{}", orderId);
--
Gitblit v1.9.1