From 36be00e0f3cbe0d559c646fd2977e6e3a74aa6f9 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 30 Sep 2024 16:57:22 +0800
Subject: [PATCH] Merge branch 'bea' of http://120.27.238.55:7000/r/exchange into bea
---
lib/huobi-client-2.0.3-SNAPSHOT.jar | 0
src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java | 4 +++-
pom.xml | 8 ++++++++
3 files changed, 11 insertions(+), 1 deletions(-)
diff --git a/lib/huobi-client-2.0.3-SNAPSHOT.jar b/lib/huobi-client-2.0.3-SNAPSHOT.jar
new file mode 100644
index 0000000..1119d96
--- /dev/null
+++ b/lib/huobi-client-2.0.3-SNAPSHOT.jar
Binary files differ
diff --git a/pom.xml b/pom.xml
index fe1248b..80d7548 100644
--- a/pom.xml
+++ b/pom.xml
@@ -294,6 +294,14 @@
<systemPath>${basedir}/lib/huobi-client-1.0.8-SNAPSHOT.jar</systemPath>
</dependency>
+<!-- <dependency>-->
+<!-- <groupId>com.huobi.sdk</groupId>-->
+<!-- <artifactId>huobi-client</artifactId>-->
+<!-- <version>2.0.3-SNAPSHOT</version>-->
+<!-- <scope>system</scope>-->
+<!-- <systemPath>${basedir}/lib/huobi-client-2.0.3-SNAPSHOT.jar</systemPath>-->
+<!-- </dependency>-->
+
<!-- submail邮件 start -->
<dependency>
<groupId>commons-logging</groupId>
diff --git a/src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java b/src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java
index 875932a..777d042 100644
--- a/src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java
+++ b/src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java
@@ -42,7 +42,8 @@
log.info("#=======价格更新开启=======#");
SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
subscriptionOptions.setConnectionDelayOnFailure(5);
- subscriptionOptions.setUri("wss://api.hadax.com/ws");
+// subscriptionOptions.setUri("wss://api.hadax.com/ws");
+ subscriptionOptions.setUri("wss://api.huobi.pro/ws");
SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
subscriptionClient.subscribeTradeEvent("btcusdt,ethusdt,xrpusdt,ltcusdt,bchusdt,eosusdt,etcusdt", tradeEvent -> {
String symbol = tradeEvent.getSymbol();
@@ -50,6 +51,7 @@
symbol = CoinTypeConvert.convert(symbol);
if (null != symbol) {
String price = tradeEvent.getTradeList().get(0).getPrice().toPlainString();
+ System.out.println(price);
// TODO 测试环境关闭这个插入redis
redisUtils.set(CoinTypeConvert.convertToKey(symbol), price);
// 比较
--
Gitblit v1.9.1