| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | //记录转账状态，定时任务定时获取状态并更新钱包交易记录表信息 |
|---|
| | | walletBillRecordDO.setTransferDetailId(Constants.TRANSFER_STATUS.ACCEPTED.name()); |
|---|
| | | walletBillRecordMapper.insert(walletBillRecordDO); |
|---|
| | | //不需要更新结算单了，此时提现的金额和计算单上的金额不一致 |
|---|
| | | } |
|---|
| | |
|---|
| | | if (Constants.WALLET_APPROVE_STATE.REJECT.name().equals(walletWithdrawRecordDTO.getApproveState())) { |
|---|
| | | //更新钱包 |
|---|
| | | Supplier s = supplierMapper.selectById(withdrawRecordDO.getSupplierId()); |
|---|
| | | |
|---|
| | | WalletDO walletDO = walletService.getBySupplierId(s.getId()); |
|---|
| | | RLock lock = redissonClient.getLock(String.format(LockConstants.WALLET_ID_KEY, walletDO.getId())); |
|---|
| | | try { |
|---|
| | | if (lock.tryLock(10, 30, TimeUnit.SECONDS)) { |
|---|
| | | try { |
|---|
| | | if(!ObjectUtils.isEmpty(walletDO)){ |
|---|
| | | //提现中金额:审核失败体现中金额扣减 |
|---|
| | | walletDO.setWithdrawingAmount(walletDO.getWithdrawingAmount().subtract(withdrawRecordDO.getAmount())); |
|---|
| | |
|---|
| | | walletDO.setWithdrawableAmount(walletDO.getWithdrawableAmount().add(withdrawRecordDO.getAmount())); |
|---|
| | | walletMapper.updateById(walletDO); |
|---|
| | | } |
|---|
| | | } finally { |
|---|
| | | lock.unlock(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | throw new RuntimeException(e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | public String format(LocalDateTime dateTime, String format) { |
|---|
