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