C2C

zyy

2025-10-20 720eca80dede09d47d3d4c9b3841ff714d04213e

 trading-order-service/src/main/java/com/yami/trading/service/c2c/impl/C2cOrderServiceImpl.java

@@ -131,8 +131,8 @@
        if (C2cOrder.DIRECTION_BUY.equals(c2cOrder.getDirection())) {
            // 买币
            // 给用户账户添加相应的币种数量
            double amountBefore = 0d;
            double amountAfter = 0d;
            double amountBefore;
            double amountAfter;
            if ("usdt".equalsIgnoreCase(c2cOrder.getSymbol())) {
                Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
                amountBefore = wallet.getMoney().doubleValue();
@@ -147,9 +147,9 @@
            // 保存资金日志
            MoneyLog moneyLog = new MoneyLog();
            moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
            moneyLog.setAmount_before(new BigDecimal(amountBefore));
            moneyLog.setAmountBefore(new BigDecimal(amountBefore));
            moneyLog.setAmount(new BigDecimal(c2cOrder.getCoinAmount()));
            moneyLog.setAmount_after(new BigDecimal(amountAfter));
            moneyLog.setAmountAfter(new BigDecimal(amountAfter));
            moneyLog.setLog("c2c订单购买放行，订单号[" + c2cOrder.getOrderNo() + "]");
            moneyLog.setUserId(c2cOrder.getPartyId());
            moneyLog.setWallet_type(c2cOrder.getSymbol());
@@ -310,9 +310,9 @@
        if ("3".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("该订单已完成");
        }
        if ("recharge".equals(c2cOrder.getDirection())) {
        if ("buy".equals(c2cOrder.getDirection())) {
            // 充值
        } else if ("withdraw".equals(c2cOrder.getDirection())) {
        } else if ("sell".equals(c2cOrder.getDirection())) {
            // 提现
            // 用户钱包退还
            Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
@@ -321,11 +321,11 @@
            this.walletService.update(c2cOrder.getPartyId().toString(), c2cOrder.getCoinAmount());
            // 保存 资金日志
            MoneyLog moneyLog = new MoneyLog();
            moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_BANK_CARD);
            moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
            moneyLog.setAmountBefore(new BigDecimal(amountBefore));
            moneyLog.setAmount(new BigDecimal(c2cOrder.getCoinAmount()));
            moneyLog.setAmountAfter(new BigDecimal(amountAfter));
            moneyLog.setLog("银行卡订单取消，订单号[" + c2cOrder.getOrderNo() + "]");
            moneyLog.setLog("C2C订单取消，订单号[" + c2cOrder.getOrderNo() + "]");
            moneyLog.setUserId(c2cOrder.getPartyId());
            moneyLog.setWalletType(c2cOrder.getSymbol());
            moneyLog.setSymbol(c2cOrder.getSymbol());
@@ -333,7 +333,7 @@
            this.moneyLogService.save(moneyLog);
            // 保存 充提记录
            WalletLog walletLog = new WalletLog();
            walletLog.setCategory(Constants.MONEYLOG_CATEGORY_BANK_CARD_WITHDRAW);
            walletLog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
            walletLog.setPartyId(c2cOrder.getPartyId());
            walletLog.setOrderNo(c2cOrder.getOrderNo());
            walletLog.setStatus(Integer.valueOf(c2cOrder.getState()).intValue());
@@ -638,14 +638,14 @@
        RealNameAuthRecord party_kyc = realNameAuthRecordService.getByUserId(partyId);
        Object objKyc = this.sysparaService.find("c2c_sell_by_kyc");
        if (null != objKyc) {
            if (!(party_kyc.getStatus() == 2) && "true".equals(this.sysparaService.find("c2c_sell_by_kyc").getSvalue())) {
            if ("true".equals(this.sysparaService.find("c2c_sell_by_kyc").getSvalue()) && !(party_kyc.getStatus() == 2)) {
                throw new BusinessException(401, "无权限");
            }
        }
        HighLevelAuthRecord  party_kycHighLevel = highLevelAuthRecordService.findByUserId(partyId);
        Object objKycHigh = this.sysparaService.find("c2c_sell_by_high_kyc");
        if (null != objKycHigh) {
            if (!(party_kycHighLevel.getStatus() == 2) && "true".equals(this.sysparaService.find("c2c_sell_by_high_kyc").getSvalue())) {
            if ("true".equals(this.sysparaService.find("c2c_sell_by_high_kyc").getSvalue()) && !(party_kycHighLevel.getStatus() == 2)) {
                throw new BusinessException(1, "请先通过高级认证");
            }
        }
@@ -675,8 +675,8 @@
            throw new YamiShopBindException("金额不在购买区间");
        }

        double amountBefore = 0d;
        double amountAfter = 0d;
        double amountBefore ;
        double amountAfter ;

        if ("usdt".equalsIgnoreCase(c2cAdvert.getSymbol())) {

@@ -704,9 +704,9 @@
        // 保存资金日志
        MoneyLog moneylog = new MoneyLog();
        moneylog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
        moneylog.setAmount_before(new BigDecimal(amountBefore));
        moneylog.setAmountBefore(new BigDecimal(amountBefore));
        moneylog.setAmount(new BigDecimal(Arith.sub(0, c2cOrder.getCoinAmount())));
        moneylog.setAmount_after(new BigDecimal(amountAfter));
        moneylog.setAmountAfter(new BigDecimal(amountAfter));
        moneylog.setLog("c2c卖币，币种[" + c2cOrder.getSymbol() + "]，订单号[" + c2cOrder.getOrderNo() + "]");
        moneylog.setUserId(c2cOrder.getPartyId());
        moneylog.setWalletType(c2cOrder.getSymbol());