| | |
| | | log.info("=============111111===>"+walletType); |
| | | walletExtend.setAmount(Arith.add(walletExtend.getAmount(), amount)); |
| | | if (!walletExtendService.updateById(walletExtend)) { |
| | | throw new YamiShopBindException("操作钱包失败!"); |
| | | throw new YamiShopBindException("Wallet operation failed!"); |
| | | } |
| | | redisTemplate.opsForValue().set(WalletRedisKeys.WALLET_EXTEND_PARTY_ID + partyId.toString() + walletType, walletExtend); |
| | | |
| | |
| | | |
| | | wallet.setMoney(wallet.getMoney().add(money)); |
| | | if(wallet.getMoney().compareTo(BigDecimal.ZERO) < 0){ |
| | | throw new YamiShopBindException("余额不足"); |
| | | throw new YamiShopBindException("Insufficient balance"); |
| | | } |
| | | wallet.setUpdateTime(now); |
| | | /*if (wallet.getMoney().doubleValue() < 0) { |
| | | throw new YamiShopBindException("余额不足"); |
| | | throw new YamiShopBindException("Insufficient balance"); |
| | | }*/ |
| | | updateById(wallet); |
| | | // 账变日志 |
| | |
| | | close = realtimes.get(0).getClose().doubleValue(); |
| | | } else { |
| | | close = 0; |
| | | //throw new YamiShopBindException("参数错误"); |
| | | //throw new YamiShopBindException("Invalid parameters"); |
| | | } |
| | | return close; |
| | | } |
| | |
| | | Wallet wallet = findByUserId(userId); |
| | | wallet.setMoney(new BigDecimal(Arith.add(wallet.getMoney().doubleValue(), amount))); |
| | | if (!updateById(wallet)) { |
| | | throw new YamiShopBindException("操作钱包失败!"); |
| | | throw new YamiShopBindException("Wallet operation failed!"); |
| | | } |
| | | |
| | | } |
| | |
| | | } |
| | | } |
| | | if (!updateById(wallet)) { |
| | | throw new YamiShopBindException("操作钱包失败!"); |
| | | throw new YamiShopBindException("Wallet operation failed!"); |
| | | } |
| | | return wallet; |
| | | } |