| | |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Isolation; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import javax.annotation.Resource; |
| | |
| | | private RedisUtils redisUtils; |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | @Transactional(rollbackFor = Exception.class, isolation = Isolation.READ_COMMITTED) |
| | | public void addFollowerOrder(Long id) { |
| | | log.info("进入跟单处理逻辑 : {}", id); |
| | | // 查询交易员订单 |
| | |
| | | updateEntity.setTotalBalance(openFeePrice.negate()); |
| | | updateEntity.setId(walletContract.getId()); |
| | | updateEntity.setVersion(walletContract.getVersion()); |
| | | log.info("==={}, {}===", walletContract.getAvailableBalance(), walletContract.getVersion()); |
| | | int i = memberWalletContractDao.updateWalletContractWithVersion(updateEntity); |
| | | if (i > 0) { |
| | | break; |
| | |
| | | flag = true; |
| | | break; |
| | | } |
| | | |
| | | log.info("---{}, {}--", walletContract.getAvailableBalance(), walletContract.getVersion()); |
| | | } |
| | | |
| | | if (flag) { |