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/SyncBeforeInfoMessageListener.java |   25 +++++++++++++++++++++----
 1 files changed, 21 insertions(+), 4 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java
index 991cb0d..ee8c91e 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java
@@ -6,6 +6,7 @@
 
 import javax.annotation.Resource;
 
+import com.yeshi.fanli.exception.user.vip.UserVIPUpgradeException;
 import org.springframework.stereotype.Component;
 
 import com.aliyun.openservices.ons.api.Action;
@@ -151,8 +152,16 @@
 						UserVIPPreInfo vipInfo = userVIPPreInfoService.getLatestProcessInfo(uid);
 						if (vipInfo == null) {
 							// 璁$畻绛夌骇
-							userVIPPreInfoService.upgradeVipByMyOrder(uid);
-							userVIPPreInfoService.upgradeVipByTeamNum(uid);
+							try {
+								userVIPPreInfoService.upgradeVipByMyOrder(uid);
+							} catch (UserVIPUpgradeException e) {
+								e.printStackTrace();
+							}
+							try {
+								userVIPPreInfoService.upgradeVipByTeamNum(uid);
+							} catch (UserVIPUpgradeException e) {
+								e.printStackTrace();
+							}
 							vipInfo = userVIPPreInfoService.getLatestProcessInfo(uid);
 							if (vipInfo == null) {// 娌℃湁鐢熸垚楂樼骇鍙婁互涓婁細鍛�
 								UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(uid);
@@ -175,8 +184,16 @@
 									&& vipInfo.getCreateTime().getTime() < TimeUtil
 											.convertToTimeTemp("2020-04-30 14:10:00", "yyyy-MM-dd HH:mm:ss")) {
 								// 璁$畻绛夌骇
-								userVIPPreInfoService.upgradeVipByMyOrder(uid);
-								userVIPPreInfoService.upgradeVipByTeamNum(uid);
+								try {
+									userVIPPreInfoService.upgradeVipByMyOrder(uid);
+								} catch (UserVIPUpgradeException e) {
+									e.printStackTrace();
+								}
+								try {
+									userVIPPreInfoService.upgradeVipByTeamNum(uid);
+								} catch (UserVIPUpgradeException e) {
+									e.printStackTrace();
+								}
 							}
 						}
 					}

--
Gitblit v1.8.0