admin
2020-04-30 a5fde818ef9969e2e53acfa29b2e6f423bd0c8fc
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/SyncBeforeInfoMessageListener.java
@@ -31,6 +31,7 @@
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;
@@ -79,11 +80,9 @@
         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);
@@ -160,6 +159,14 @@
                           }
                        }
                     }
                  } 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);
                     }
                  }
               }
            }