| | |
| | | |
| | | boolean flag = false; |
| | | while(true) { |
| | | log.info("----循环更新----"); |
| | | MemberWalletContractEntity updateEntity = new MemberWalletContractEntity(); |
| | | updateEntity.setAvailableBalance(prePaymentAmount.negate()); |
| | | 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()); |
| | | try { |
| | | Thread.sleep(5000); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | if (flag) { |