modify

Helius

2021-04-02 67b98b86a95f5d180657a2c6cda7f9924217c5bb

modify

 src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java

@@ -123,22 +123,24 @@
        if (CollUtil.isNotEmpty(followerSettings)) {
            List<Object> hasExist = new ArrayList<>();
            for (FollowFollowerSettingEntity followerSetting : followerSettings) {
                // 加redis锁，同一个用户不能同时触发两个跟单任务，否则会出现金额问题
                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())) {
                        log.info("跳出");
                        hasExist.add(followerSetting.getMemberId());
                        redisUtils.lSet(AppContants.MEMBER_HAS_FOLLOW, hasExist);
                        break;
                    }
                synchronized (this) {
                    // 加redis锁，同一个用户不能同时触发两个跟单任务，否则会出现金额问题
                    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())) {
                            log.info("跳出");
                            hasExist.add(followerSetting.getMemberId());
                            redisUtils.lSet(AppContants.MEMBER_HAS_FOLLOW, hasExist);
                            break;
                        }

                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                        try {
                            Thread.sleep(1000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }