From e93004ef9deed93d0283e07ef85ad1e2fa4d645a Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Mon, 20 Apr 2026 11:30:59 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/task/CryptoCurrencyDataTask.java | 4 +++-
1 files changed, 3 insertions(+), 1 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/CryptoCurrencyDataTask.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/CryptoCurrencyDataTask.java
index 0665bec..57e65ab 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/CryptoCurrencyDataTask.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/task/CryptoCurrencyDataTask.java
@@ -16,6 +16,7 @@
import javax.annotation.Resource;
import java.util.List;
+import java.util.stream.Collectors;
/**
* 加密货币 定时器
@@ -39,10 +40,11 @@
* 深度数据、近期交易记录 火币采集任务
*/
@Async
- @Scheduled(cron = "*/3 * * * * ?")
+ @Scheduled(cron = "*/4 * * * * ?")
public void DepthTradeCollectionTask() {
try {
List<Item> items = itemService.findByType(Item.cryptos);
+ items = items.stream().filter(item -> item.getDelFlag() == 0).collect(Collectors.toList());
for (Item item : items) {
// 暂不使用
// boolean isOpen = MarketOpenChecker.isMarketOpenByItemCloseType(item.getOpenCloseType());
--
Gitblit v1.9.3