From c268540881fe493bc40e76ba82793a63c0897c91 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 16 May 2024 10:41:12 +0800
Subject: [PATCH] 滑点监控
---
src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java | 72 ++++++++++++++++++------------------
1 files changed, 36 insertions(+), 36 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java b/src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java
index db87fae..c5c41f5 100644
--- a/src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java
+++ b/src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java
@@ -1,36 +1,36 @@
-package cc.mrbird.febs.job;
-
-import cc.mrbird.febs.common.contants.AppContants;
-import cc.mrbird.febs.common.utils.RedisUtils;
-import com.huobi.client.SubscriptionClient;
-import com.huobi.client.SubscriptionOptions;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.PostConstruct;
-
-/**
- * @author wzy
- * @date 2022-03-24
- **/
-@Slf4j
-@Component
-public class NewPriceUpdateJob{
-
- @Autowired
- private RedisUtils redisUtils;
-
- @PostConstruct
- public void initNewPriceUpdate() {
- log.info("#最新价更新启动#");
- redisUtils.set(AppContants.REDIS_KEY_CHANGE_FEE, 30);
- SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
- subscriptionOptions.setConnectionDelayOnFailure(5);
- subscriptionOptions.setUri("wss://api.hadax.com/ws");
- SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
- subscriptionClient.subscribeTradeEvent("ethusdt", tradeEvent -> {
- redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, tradeEvent.getTradeList().get(0).getPrice());
- });
- }
-}
+//package cc.mrbird.febs.job;
+//
+//import cc.mrbird.febs.common.contants.AppContants;
+//import cc.mrbird.febs.common.utils.RedisUtils;
+//import com.huobi.client.SubscriptionClient;
+//import com.huobi.client.SubscriptionOptions;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.stereotype.Component;
+//
+//import javax.annotation.PostConstruct;
+//
+///**
+// * @author
+// * @date 2022-03-24
+// **/
+//@Slf4j
+//@Component
+//public class NewPriceUpdateJob{
+//
+// @Autowired
+// private RedisUtils redisUtils;
+//
+// @PostConstruct
+// public void initNewPriceUpdate() {
+//// log.info("#最新价更新启动#");
+//// redisUtils.set(AppContants.REDIS_KEY_CHANGE_FEE, 30);
+//// SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
+//// subscriptionOptions.setConnectionDelayOnFailure(5);
+//// subscriptionOptions.setUri("wss://api.hadax.com/ws");
+//// SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
+//// subscriptionClient.subscribeTradeEvent("ethusdt", tradeEvent -> {
+//// redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, tradeEvent.getTradeList().get(0).getPrice());
+//// });
+// }
+//}
--
Gitblit v1.9.1