| | |
| | | import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
|
| | | import com.yeshi.fanli.util.Constant;
|
| | | import com.yeshi.fanli.util.StringUtil;
|
| | | import com.yeshi.fanli.util.TimeUtil;
|
| | | import com.yeshi.fanli.util.VersionUtil;
|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
| | |
|
| | |
| | | if (tag.equalsIgnoreCase(UserTopicTagEnum.userActve.name())) {
|
| | | UserActiveMQMsg msg = new Gson().fromJson(new String(message.getBody()), UserActiveMQMsg.class);
|
| | | Long uid = msg.getUid();
|
| | |
|
| | | // 老用户同步绑定信息
|
| | | |
| | | userInfoModifyRecordService.syncBeforeInfo(uid);
|
| | |
|
| | |
|
| | | // 低版本全部升级普通会员
|
| | |
|
| | | List<ThreeSale> threeSaleList = threeSaleSerivce.getMyBossDeepList(uid, 2);
|
| | |
| | | }
|
| | | }
|
| | | }
|
| | | } else {//之前老版本处理为普通会员的用户升级新版本
|
| | | if (vipInfo.getProcess() == UserVIPPreInfo.PROCESS_1
|
| | | && vipInfo.getCreateTime().getTime() < TimeUtil
|
| | | .convertToTimeTemp("2020-04-30 14:10:00", "yyyy-MM-dd HH:mm:ss")) {
|
| | | // 计算等级
|
| | | userVIPPreInfoService.upgradeVipByMyOrder(uid);
|
| | | userVIPPreInfoService.upgradeVipByTeamNum(uid);
|
| | | }
|
| | | }
|
| | | }
|
| | | }
|