From 6e0127a5ec2c62b701180624a75524eebb43b1f3 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Thu, 09 Oct 2025 16:20:58 +0800
Subject: [PATCH] 市场深度数据调整
---
trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java b/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
index 4f9c33b..ac8360f 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/task/IcoTask.java
@@ -13,7 +13,9 @@
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.yami.trading.api.UD.*;
+import com.yami.trading.bean.data.domain.Depth;
import com.yami.trading.bean.data.domain.Kline;
+import com.yami.trading.bean.data.domain.Realtime;
import com.yami.trading.bean.ico.domain.Ico;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.model.ChannelBlockchain;
@@ -24,6 +26,7 @@
import com.yami.trading.common.util.*;
import com.yami.trading.huobi.data.DataCache;
import com.yami.trading.huobi.data.internal.CryptosKlineService;
+import com.yami.trading.huobi.data.internal.DepthTimeObject;
import com.yami.trading.huobi.data.internal.KlineInitService;
import com.yami.trading.huobi.data.internal.KlineTimeObject;
import com.yami.trading.huobi.hobi.HobiDataService;
@@ -89,6 +92,9 @@
@Autowired
KlineDBService klineDBService;
+ @Autowired
+ DepthPushJob depthPushJob;
+
//@Scheduled(cron = "*/5 * * * * ?")
public void test() throws Exception {
/*String symbol ="snekusdt";
@@ -152,6 +158,11 @@
RequestDataHelper.set("symbol", symbol);
klineDBService.saveOrUpdateBatch(list);
RequestDataHelper.clear();*/
+ /*String symbol = "snekusdt";
+ DepthTimeObject depth = DataCache.getDepth().get(symbol);
+ Depth depthData = depth.getDepth();
+ Realtime realtime = DataCache.getRealtime(symbol);
+ depthPushJob.depthRevise(depthData, symbol, realtime.getClose().doubleValue(), true);*/
}
/**
* ico转入产品
--
Gitblit v1.9.3