| | |
|---|
| | | |
|---|
| | | @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); |
|---|
| | |
|---|
| | | BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(holdOrderEntity.getSymbol()); |
|---|
| | | Long tradeMemberId = holdOrderEntity.getMemberId(); |
|---|
| | | if (CollUtil.isNotEmpty(followerSettings)) { |
|---|
| | | List<Long> hasExists = new ArrayList<>(); |
|---|
| | | 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("跳出"); |
|---|
| | | hasExists.add(followerSetting.getMemberId()); |
|---|
| | | redisUtils.lSet(AppContants.MEMBER_HAS_FOLLOW, hasExists); |
|---|
| | | hasExist.add(followerSetting.getMemberId()); |
|---|
| | | redisUtils.lSet(AppContants.MEMBER_HAS_FOLLOW, hasExist); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | |
|---|
| | | try { |
|---|
| | | Thread.sleep(1000); |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | //更新更新消息提醒的状态 |
|---|
