| | |
|---|
| | | List<Object> hasExist = new ArrayList<>(); |
|---|
| | | for (FollowFollowerSettingEntity followerSetting : followerSettings) { |
|---|
| | | // 加redis锁，同一个用户不能同时触发两个跟单任务，否则会出现金额问题 |
|---|
| | | while(true) { |
|---|
| | | List<Object> followerMemberId = redisUtils.lGet(AppContants.MEMBER_HAS_FOLLOW, 0, -1); |
|---|
| | | while (true) { |
|---|
| | | List<Object> followerMemberId = redisUtils.lGet(AppContants.MEMBER_HAS_FOLLOW, 0, -1); |
|---|
| | | log.info("#跟单用户任务已存在:{}, 当前:{}#", followerMemberId, followerSetting.getMemberId()); |
|---|
| | | log.info("#------->{}#", followerMemberId.contains(followerSetting.getMemberId().intValue())); |
|---|
| | | if (CollUtil.isEmpty(followerMemberId) || !followerMemberId.contains(followerSetting.getMemberId().intValue())) { |
|---|
