From 5a0c918b13c9bb48af816594c7770bee376fac5c Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Fri, 09 Aug 2024 17:16:37 +0800
Subject: [PATCH] 1
---
websocketSerivce/src/main/java/org/example/server/impl/CurrencySerivceImpl.java | 4 ++--
websocketSerivce/src/main/java/org/example/task/MexcStock.java | 2 +-
websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java | 7 ++-----
3 files changed, 5 insertions(+), 8 deletions(-)
diff --git a/websocketSerivce/src/main/java/org/example/server/impl/CurrencySerivceImpl.java b/websocketSerivce/src/main/java/org/example/server/impl/CurrencySerivceImpl.java
index b35cf96..070a357 100644
--- a/websocketSerivce/src/main/java/org/example/server/impl/CurrencySerivceImpl.java
+++ b/websocketSerivce/src/main/java/org/example/server/impl/CurrencySerivceImpl.java
@@ -242,8 +242,8 @@
marketDataOut.setSpread(profitPercentage.setScale(4, RoundingMode.DOWN).toPlainString()); // 设置利润百分比
marketDataOut.setBuyPrice(buyPrice.toPlainString()); // 设置买入价格
marketDataOut.setSellPrice(sellPrice.toPlainString()); // 设置卖出价格
- marketDataOut.setBuyNumber(markets1.getBids().getV().toPlainString()); // 设置买入数量
- marketDataOut.setSellNumber(markets2.getAsks().getV().toPlainString()); // 设置卖出数量
+ marketDataOut.setBuyNumber(markets1.getBids().getV().setScale(4, RoundingMode.HALF_UP).toPlainString()); // 设置买入数量
+ marketDataOut.setSellNumber(markets2.getAsks().getV().setScale(4, RoundingMode.HALF_UP).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); // 设置服务时间
diff --git a/websocketSerivce/src/main/java/org/example/task/MexcStock.java b/websocketSerivce/src/main/java/org/example/task/MexcStock.java
index fb68ce6..43db090 100644
--- a/websocketSerivce/src/main/java/org/example/task/MexcStock.java
+++ b/websocketSerivce/src/main/java/org/example/task/MexcStock.java
@@ -40,7 +40,7 @@
/**
* 同步mexc交易所交易对
*/
-// @Scheduled(cron = "0 0/30 * * * ?")
+ @Scheduled(cron = "0 0/30 * * * ?")
// @Scheduled(cron = "0/10 * * * * ?")
public void syncCurrency() {
// 使用Lock来确保同步
diff --git a/websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java b/websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java
index 8ced992..d100a29 100644
--- a/websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java
+++ b/websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java
@@ -216,10 +216,7 @@
// log.info("距离上次发送消息时间未达到指定间隔，不发送消息。");
}
}else{
- Map<String,Integer> map = new HashMap<>();
- map.put("status",1);
- pushMessage(session,JSONUtil.toJsonStr(map));
- closeSession(session,"没有订阅消息");
+ pushMessage(session,"没有订阅消息");
}
}
private static final Gson gson = new Gson();
@@ -363,6 +360,6 @@
log.error("强制断开连接----异常: {}", e.getMessage());
}
wsServers.remove(this);
- log.info("客户端未及时发送订阅消息，断开连接");
+ log.info(reason);
}
}
--
Gitblit v1.9.3