admin
2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe
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();
                        }
                     }
                  }
               }