1

zj

2024-08-07 8ed60795a7c278f9699616f72eb05ce49800ba6f

 websocketSerivce/src/main/java/org/example/server/impl/CurrencySerivceImpl.java

@@ -244,8 +244,8 @@
        marketDataOut.setSellPrice(sellPrice.toPlainString()); // 设置卖出价格
        marketDataOut.setBuyNumber(markets1.getBids().getV().toPlainString()); // 设置买入数量
        marketDataOut.setSellNumber(markets2.getAsks().getV().toPlainString()); // 设置卖出数量
        marketDataOut.setBuyTotalPrice((markets1.getBids().getP().multiply(markets1.getBids().getV())).setScale(0,RoundingMode.DOWN).toPlainString()); // 设置买入总价
        marketDataOut.setSellTotalPrice((markets2.getAsks().getP().multiply(markets2.getAsks().getV())).setScale(0,RoundingMode.DOWN).toPlainString()); // 设置卖出总价
        marketDataOut.setBuyTotalPrice((markets1.getBids().getP().multiply(markets1.getBids().getV())).setScale(0, RoundingMode.HALF_UP).toPlainString()); // 设置买入总价
        marketDataOut.setSellTotalPrice((markets2.getAsks().getP().multiply(markets2.getAsks().getV())).setScale(0,RoundingMode.HALF_UP).toPlainString()); // 设置卖出总价
        marketDataOut.setServceTime(formattedDateTime); // 设置服务时间
        marketDataOut.setBuyAndSell(marketDataOut.getBaseAsset()+marketDataOut.getBuyingPlatform()+marketDataOut.getSellPlatform());
        marketDataOuts.add(marketDataOut); // 添加到输出列表
@@ -267,17 +267,8 @@
    }

    public void quotationCalculation(){
        long startExtracted = System.nanoTime();
        extracted();
        long endExtracted = System.nanoTime();
        double executionTimeExtracted = (endExtracted - startExtracted) / 1e9; // 转换为秒
        System.out.println("extracted 方法执行时间: " + executionTimeExtracted + " 秒");

        long startFindPairs = System.nanoTime();
        findProfitablePairs(mexcList, gateList, bitgetList, kucoinList); // 请确保这些变量有定义和赋值
        long endFindPairs = System.nanoTime();
        double executionTimeFindPairs = (endFindPairs - startFindPairs) / 1e9; // 转换为秒
        System.out.println("findProfitablePairs 方法执行时间: " + executionTimeFindPairs + " 秒");
    }

    public void scheduler(){