modify

Helius

2021-04-01 0c50ac5172cdbb5a6449f0286e7d018894355ddd

modify

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

@@ -92,7 +92,7 @@

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void addFollowerOrder(Long id) {
    public void addFollowerOrder(Long id) throws InterruptedException {
        log.info("进入跟单处理逻辑 : {}", id);
        // 查询交易员订单
        ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(id);
@@ -121,18 +121,25 @@
        BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(holdOrderEntity.getSymbol());
        Long tradeMemberId = holdOrderEntity.getMemberId();
        if (CollUtil.isNotEmpty(followerSettings)) {
            List<Object> followerMemberId =  redisUtils.lGet(AppContants.MEMBER_HAS_FOLLOW, 0, -1);
            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("跳出");
                        followerMemberId.add(followerSetting.getMemberId());
                        redisUtils.lSet(AppContants.MEMBER_HAS_FOLLOW, followerMemberId);
                        hasExist.add(followerSetting.getMemberId());
                        redisUtils.lSet(AppContants.MEMBER_HAS_FOLLOW, hasExist);
                        break;
                    }

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

                //更新更新消息提醒的状态

 src/test/java/com/xcong/excoin/RedisTest.java

@@ -36,11 +36,12 @@

    @Test
    public void redisObjectTest() {
        List<Object> test_list = redisUtils.lGet("test_list", 0, -1);

        List<Object> aa = new ArrayList<>();
//        List<Object> test_list = redisUtils.lGet("test_list", 0, -1);
        aa.add(13L);
        Long id = 13L;
        test_list.add(id);
        redisUtils.lSet("test_list", test_list);
//        test_list.add(id);
        redisUtils.lSet("test_list", aa);

        List<Object> test_list1 = redisUtils.lGet("test_list", 0, -1);
        log.info("--->{}", test_list1);