新版仿ok交易所-后端
zyy
2025-09-04 ceb187dd1ad07060b8c67a2d6fba933642fcfb0c
trading-order-service/src/main/java/com/yami/trading/service/ico/IcoService.java
@@ -95,21 +95,28 @@
            model.setSubscriptionType(1);
        }
        Wallet wallet = walletService.saveWalletByPartyId(partyId);
        if(wallet.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
            throw new YamiShopBindException("请先缴清待补资金");
        }
        //需要先支付
        if (ico.getIsPayDown() !=null && ico.getIsPayDown() == 1) {
            Wallet wallet = walletService.saveWalletByPartyId(partyId);
            if (amount.compareTo(wallet.getMoney()) > 0) {
            //手续费
            BigDecimal fee = ico.getUnitFee().multiply(new BigDecimal(model.getSubscribeNums()));
            BigDecimal totalAmount = amount.add(fee);
            if (totalAmount.compareTo(wallet.getMoney()) > 0) {
                throw new YamiShopBindException("余额不足");
            }
            walletService.update(partyId, Arith.sub(0, amount.doubleValue()));
            walletService.update(partyId, totalAmount.negate().doubleValue());
            // 保存 资金日志
            MoneyLog moneylog = new MoneyLog();
            moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
            moneylog.setAmountBefore(wallet.getMoney());
            moneylog.setAmount(amount);
            moneylog.setAmountAfter(BigDecimal.valueOf(Arith.sub(wallet.getMoney().doubleValue(), amount.doubleValue())));
            moneylog.setLog("新币购买,申购金额[" + amount + "]");
            moneylog.setAmount(totalAmount);
            moneylog.setAmountAfter(wallet.getMoney().subtract(totalAmount));
            moneylog.setLog("新币购买,申购金额[" + amount + "]" + "手续费金额[" + fee + "]");
            moneylog.setUserId(partyId);
            moneylog.setSymbol(ico.getSymbol());
            moneylog.setWalletType(ico.getSymbol());
@@ -154,6 +161,7 @@
            if (model.getStatus() == 3) { //中签
                //资金账户
                Wallet wallet = walletService.saveWalletByPartyId(userId);
                BigDecimal before = wallet.getMoney();
                //已经预支付
                if(ico.getIsPayDown() !=null && ico.getIsPayDown() == 1) {
                    int applyNumber = userSubscription.getSubscribeNums() - model.getBallotNumber();
@@ -161,15 +169,17 @@
                    if(applyNumber > 0) {
                        //退回资金
                        BigDecimal refundPrice = ico.getUnitAmount().multiply(new BigDecimal(applyNumber));
                        walletService.update(userId, refundPrice.doubleValue());
                        BigDecimal fee = ico.getUnitFee().multiply(new BigDecimal(applyNumber));
                        BigDecimal totalAmount = refundPrice.add(fee);
                        wallet = walletService.updateToBeCovered(wallet, totalAmount, 1);
                        //保存 资金日志
                        MoneyLog moneylog = new MoneyLog();
                        moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
                        moneylog.setAmountBefore(wallet.getMoney());
                        moneylog.setAmount(amount);
                        moneylog.setAmountAfter(wallet.getMoney().add(refundPrice));
                        moneylog.setLog("新币购买,退回购买金额[" + refundPrice + "]");
                        moneylog.setAmountBefore(before);
                        moneylog.setAmount(totalAmount);
                        moneylog.setAmountAfter(wallet.getMoney());
                        moneylog.setLog("新币购买,退回金额[" + refundPrice + "]" + "退回手续费[" + fee + "]");
                        moneylog.setUserId(userId);
                        moneylog.setSymbol(ico.getSymbol());
                        moneylog.setWalletType(ico.getSymbol());
@@ -178,25 +188,17 @@
                    }
                } else {
                    BigDecimal amount = ico.getUnitAmount().multiply(new BigDecimal(model.getBallotNumber()));
                    BigDecimal subtract = amount.subtract(wallet.getMoney());
                    if (subtract.compareTo(BigDecimal.ZERO) > 0) {
                        //放入待补
                        wallet.setMoney(BigDecimal.ZERO);
                        wallet.setAmountToBeCovered(wallet.getAmountToBeCovered().add(subtract));
                        if (!walletService.updateById(wallet)) {
                            throw new YamiShopBindException("操作钱包失败!");
                        }
                    } else {
                        //扣除资金
                        walletService.update(userId, amount.negate().doubleValue());
                    }
                    //手续费
                    BigDecimal fee = ico.getUnitFee().multiply(new BigDecimal(model.getBallotNumber()));
                    BigDecimal totalAmount = amount.add(fee);
                    wallet = walletService.updateToBeCovered(wallet, totalAmount, 2);
                    //保存 资金日志
                    MoneyLog moneylog = new MoneyLog();
                    moneylog.setCategory(Constants.MONEYLOG_CONTENT_NEW_COIN);
                    moneylog.setAmountBefore(wallet.getMoney());
                    moneylog.setAmount(amount);
                    moneylog.setAmountAfter(subtract.compareTo(BigDecimal.ZERO) > 0 ? BigDecimal.ZERO : subtract.negate());
                    moneylog.setLog("新币购买,申购金额[" + amount + "]");
                    moneylog.setAmountBefore(before);
                    moneylog.setAmount(totalAmount);
                    moneylog.setAmountAfter(wallet.getMoney());
                    moneylog.setLog("新币购买,申购金额[" + amount + "]" + "手续费金额[" + fee + "]");
                    moneylog.setUserId(userId);
                    moneylog.setSymbol(ico.getSymbol());
                    moneylog.setWalletType(ico.getSymbol());