From f73ceb9e23a5e42bfa79ef555224efaa70c1962a Mon Sep 17 00:00:00 2001
From: yyb <1416014977@qq.com>
Date: Thu, 29 Jan 2026 12:03:51 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E8=AE=BE=E7=BD=AEttl=E8=B6=85?=
 =?UTF-8?q?=E6=97=B6=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../m2pool/lease/service/impl/LeaseShopServiceImpl.java    | 7 +++++--
 .../m2pool/lease/service/impl/LeaseUserServiceImpl.java    | 7 +++++--
 2 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/m2pool/lease/service/impl/LeaseShopServiceImpl.java b/src/main/java/com/m2pool/lease/service/impl/LeaseShopServiceImpl.java
index 8215e8a..9d3beed 100644
--- a/src/main/java/com/m2pool/lease/service/impl/LeaseShopServiceImpl.java
+++ b/src/main/java/com/m2pool/lease/service/impl/LeaseShopServiceImpl.java
@@ -726,8 +726,11 @@ public class LeaseShopServiceImpl extends ServiceImpl<LeaseShopMapper, LeaseShop
                     .user_email(username+"--"+authId)
                     .build();
             try {
-                //发送提现消息
-                rabbitTemplate.convertAndSend(PAY_WITHDRAW_QUEUE,message);
+                //发送提现消息，设置 8 分钟 TTL
+                rabbitTemplate.convertAndSend(PAY_WITHDRAW_QUEUE, message, msg -> {
+                    msg.getMessageProperties().setExpiration(String.valueOf(480 * 1000));
+                    return msg;
+                });
                 OperationLogAspect.addExtraLogParam("提现金额", balanceVo.getAmount());
                 OperationLogAspect.addExtraLogParam("手续费", serviceCharge.toString());
                 OperationLogAspect.addExtraLogParam("消息ID", queueId);
diff --git a/src/main/java/com/m2pool/lease/service/impl/LeaseUserServiceImpl.java b/src/main/java/com/m2pool/lease/service/impl/LeaseUserServiceImpl.java
index caa6374..42e281f 100644
--- a/src/main/java/com/m2pool/lease/service/impl/LeaseUserServiceImpl.java
+++ b/src/main/java/com/m2pool/lease/service/impl/LeaseUserServiceImpl.java
@@ -1305,8 +1305,11 @@ public class LeaseUserServiceImpl extends ServiceImpl<LeaseUserMapper, LeaseUser
                     .build();
             try {
 
-                //发送 提现 消息
-                rabbitTemplate.convertAndSend(PAY_WITHDRAW_QUEUE,message);
+                //发送 提现 消息，设置 8 分钟 TTL
+                rabbitTemplate.convertAndSend(PAY_WITHDRAW_QUEUE, message, msg -> {
+                    msg.getMessageProperties().setExpiration(String.valueOf(480 *1000));
+                    return msg;
+                });
                 OperationLogAspect.addExtraLogParam("提现金额", balanceVo.getAmount().toString());
                 OperationLogAspect.addExtraLogParam("手续费", serviceCharge.toString());
                 OperationLogAspect.addExtraLogParam("消息ID", queueId);