diff --git a/src/main/java/com/yn/bftl/thirdparty/modules/unionpay/service/impl/UnionpayAccountServiceImpl.java b/src/main/java/com/yn/bftl/thirdparty/modules/unionpay/service/impl/UnionpayAccountServiceImpl.java index f023417..026990b 100644 --- a/src/main/java/com/yn/bftl/thirdparty/modules/unionpay/service/impl/UnionpayAccountServiceImpl.java +++ b/src/main/java/com/yn/bftl/thirdparty/modules/unionpay/service/impl/UnionpayAccountServiceImpl.java @@ -159,15 +159,17 @@ lock = stringRedisTemplate.opsForValue().setIfAbsent(lockKey, lockKey); i++; } - + log.info("accountUpdate lock:{}", lock); stringRedisTemplate.expire(lockKey, 5, TimeUnit.SECONDS); try { // 获取账户信息 Optional accountOptional = accountRepository.findById(accountUpdateDTO.getId()); + log.info("accountUpdate accountOptional:{}", accountOptional); if (BooleanUtils.isFalse(accountOptional.isPresent())) { throw new YnceErrorException(YnceError.YNCE_205004); } Account account = accountOptional.get(); + log.info("accountUpdate account:{}", account); // 更新账户数据 if (accountUpdateDTO.getChangeDirection().equals(ChangeDirection.ADD)) { account.setBalance(account.getBalance().add(accountUpdateDTO.getMoveAmount())); @@ -177,12 +179,14 @@ } account.setBalance(account.getBalance().subtract(accountUpdateDTO.getMoveAmount())); } + log.info("accountUpdate account:{}", account); accountRepository.saveAndFlush(account); Company sourceCompany = null; if (accountUpdateDTO.getSourceCompanyId() != null) { Optional companyOpt = companyRepository.findById(accountUpdateDTO.getSourceCompanyId()); sourceCompany = companyOpt.get(); } + log.info("accountUpdate sourceCompany:{}", sourceCompany); // 生成对应异动记录 this.createChangeRecord(account, accountUpdateDTO.getChangeDirection(), accountUpdateDTO.getAccountChangeType(), accountUpdateDTO.getMoveAmount(), accountUpdateDTO.getSourceNo(), accountUpdateDTO.getRemark(), sourceCompany);