| | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void addFollowerOrder(Long id) { |
| | | log.info("进入跟单处理逻辑"); |
| | | log.info("进入跟单处理逻辑 : {}", id); |
| | | // 查询交易员订单 |
| | | ContractHoldOrderEntity holdOrderEntity = contractHoldOrderDao.selectById(id); |
| | | |
| | | while (holdOrderEntity == null) { |
| | | try { |
| | | log.info("等待事务提交:{}", id); |
| | | Thread.sleep(200); |
| | | holdOrderEntity = contractHoldOrderDao.selectById(id); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | List<FollowFollowerSettingEntity> followerSettings = followFollowerSettingDao.selectAllFollowerSettingByTradeMemberId(holdOrderEntity.getMemberId()); |
| | | log.info("进入跟单处理逻辑---跟单人数"+followerSettings.size()); |
| | |
| | | //更新更新消息提醒的状态 |
| | | MemberSettingEntity memberSettingEntity = memberSettingDao.selectMemberSettingByMemberId(memberEntity.getId()); |
| | | if(ObjectUtil.isNotEmpty(memberSettingEntity)){ |
| | | log.info("更新更新消息提醒的状态"); |
| | | memberSettingEntity.setMessageReminder(1); |
| | | memberSettingDao.updateById(memberSettingEntity); |
| | | } |