From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新

---
 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java |   19 ++++++++++++++++---
 1 files changed, 16 insertions(+), 3 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java
index 8101ee1..a791b5c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java
@@ -4,6 +4,7 @@
 
 import com.yeshi.fanli.entity.SystemEnum;
 import com.yeshi.fanli.entity.SystemFunction;
+import com.yeshi.fanli.exception.user.vip.UserVIPUpgradeException;
 import com.yeshi.fanli.service.inter.user.UserInfoService;
 import com.yeshi.fanli.util.SystemInfoUtil;
 import org.springframework.stereotype.Component;
@@ -125,10 +126,18 @@
 
                     if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU) {// 鑷喘鍒拌处
                         // 浼氬憳鍗囩骇-鑷喘璁㈠崟鏁伴噺楠岃瘉
-                        userVIPPreInfoService.upgradeVipByMyOrder(dto.getUid());
+                        try {
+                            userVIPPreInfoService.upgradeVipByMyOrder(dto.getUid());
+                        } catch (UserVIPUpgradeException e) {
+                            e.printStackTrace();
+                        }
                     } else if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {// 鍒嗕韩鍒拌处
                         // 浼氬憳鍗囩骇-鍒嗕韩璁㈠崟鏁伴噺楠岃瘉
-                        userVIPPreInfoService.upgradeVipByMyOrder(dto.getUid());
+                        try {
+                            userVIPPreInfoService.upgradeVipByMyOrder(dto.getUid());
+                        } catch (UserVIPUpgradeException e) {
+                            e.printStackTrace();
+                        }
                     }
                 }
 
@@ -144,7 +153,11 @@
                     }
 
                     // 浼氬憳绛夌骇鍗囩骇-绮変笣鏁伴噺楠岃瘉
-                    userVIPPreInfoService.upgradeVipByTeamNum(dto.getSourceUid());
+                    try {
+                        userVIPPreInfoService.upgradeVipByTeamNum(dto.getSourceUid());
+                    } catch (UserVIPUpgradeException e) {
+                        e.printStackTrace();
+                    }
                     userInviteValidNumService.addValidTeamNum(dto.getSourceUid(), dto.getSettleMent(),
                             dto.getPlaceOrderTime());
                 }

--
Gitblit v1.8.0