1

zj

2025-04-11 d869f01aa59927d0b4c93c908dfdfb9ca6fb326f

 src/main/java/project/wallet/internal/WalletServiceImpl.java

@@ -93,11 +93,13 @@
      // 确保余额不会为负数
      double newBalance = Arith.add(wallet.getMoney(), amount);
      if (newBalance < 0) {
         amount = -wallet.getMoney();  // 如果会负余额，调整 amount 使余额为0
         wallet.setMoney(0);
      }else{
         wallet.setMoney(Arith.add(wallet.getMoney(), amount));
      }
      wallet.setMoney(Arith.add(wallet.getMoney(), amount));
      logger.info("----------------tmd钱包的钱为什么不对"+wallet.getMoney());
      redisHandler.setSync(WalletRedisKeys.WALLET_PARTY_ID + wallet.getPartyId().toString(), wallet);
      redisHandler.pushAsyn(WalletRedisKeys.WALLET_QUEUE_UPDATE, new WalletMessage(partyId, amount));
      redisHandler.pushAsyn(WalletRedisKeys.WALLET_QUEUE_UPDATE, new WalletMessage(partyId, wallet.getMoney()));

      //用于计算合约亏损
      redisHandler.setSync("PARTY_ID_MONEY_"+partyId, wallet.getMoney());