From e84b3c45f7ecef39926b582b10d03b30ff77ee95 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 28 Oct 2025 16:36:56 +0800
Subject: [PATCH] 最高最低值优化
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/HighLowHandleJob.java | 31 ++++++++++++++++++++++++-------
1 files changed, 24 insertions(+), 7 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/HighLowHandleJob.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/HighLowHandleJob.java
index 96f3540..e86517a 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/HighLowHandleJob.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/HighLowHandleJob.java
@@ -4,6 +4,8 @@
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.common.util.ThreadUtils;
import com.yami.trading.huobi.data.DataCache;
+import com.yami.trading.huobi.data.internal.DataDBService;
+import com.yami.trading.service.data.DataService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.syspara.SysparaService;
import org.slf4j.Logger;
@@ -15,6 +17,7 @@
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
+import java.util.stream.Collectors;
/**
* 最高最低修正
@@ -34,31 +37,45 @@
private SysparaService sysparaService;
@Autowired
private ItemService itemService;
-
+ @Autowired
+ private DataService dataService;
+ @Autowired
+ DataDBService dataDBService;
+
public void start() {
new Thread(this, "HighLowHandleJob").start();
}
@Override
public void run() {
- ThreadUtils.sleep(1000 * 60 * 3);
+ bulidHighLow();
+ ThreadUtils.sleep(1000 * 60 * 5);
while (true) {
bulidHighLow();
- ThreadUtils.sleep(1000 * 60 * 3);
+ ThreadUtils.sleep(1000 * 60 * 5);
}
}
public void bulidHighLow() {
try {
- if (first) {
+ /*if (first) {
// data数据保存间隔时长(毫秒)
this.interval = this.sysparaService.find("data_interval").getInteger().intValue() / 1000;
first = false;
}
// 秒
- int num = (24 * 60 * 60) / this.interval;
+ int num = (24 * 60 * 60) / this.interval;*/
List<Item> item_list = itemService.findByType(Item.cryptos);
+ item_list = item_list.stream()
+ .filter(x -> x.getAdjustmentValue()!=null && x.getAdjustmentValue().doubleValue()!=0)
+ .collect(Collectors.toList());
for (int i = 0; i < item_list.size(); i++) {
+ String symbol = item_list.get(i).getSymbol();
+ //重新查询缓存
+ dataDBService.cacheBefore24Hour(symbol);
+ }
+
+ /*for (int i = 0; i < item_list.size(); i++) {
Item item = item_list.get(i);
try {
@@ -96,10 +113,10 @@
} catch (Exception e) {
logger.error("run fail", e);
}
- }
+ }*/
} catch (Exception e) {
- logger.error("run fail", e);
+ logger.error("bulidHighLow run fail", e);
}
}
--
Gitblit v1.9.3