From bb020bc9f8c6edca7125229e10d1ea279726fc8c Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 21 Oct 2025 13:36:36 +0800
Subject: [PATCH] 1

---
 trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/AbstractGetDataJob.java |   22 ++++++++++++++++++++--
 1 files changed, 20 insertions(+), 2 deletions(-)

diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/AbstractGetDataJob.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/AbstractGetDataJob.java
index 27a1238..579aa4b 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/AbstractGetDataJob.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/job/AbstractGetDataJob.java
@@ -6,6 +6,7 @@
 import com.yami.trading.common.util.Arith;
 import com.yami.trading.huobi.data.AdjustmentValueCache;
 import com.yami.trading.huobi.data.DataCache;
+import com.yami.trading.huobi.data.RandomNumbersGenerator;
 import com.yami.trading.huobi.data.internal.DataDBService;
 import com.yami.trading.huobi.data.model.AdjustmentValue;
 import com.yami.trading.huobi.hobi.HobiDataService;
@@ -87,7 +88,15 @@
 
                         // 首次执行:生成含正负值的调整序列
                         if (adjustments == null || currentIndex == null) {
-                            adjustments = generateRandomAdjustments(delayValue.getValue(), frequency, decimal);
+                            //分几段执行
+                            int nums = Math.max(10, frequency / 10);
+                            List<BigDecimal> result = RandomNumbersGenerator.generateNumbers(delayValue.getValue(), nums, decimal + 4);
+                            for (int i = 0; i < result.size(); i++) {
+                                if (adjustments == null) {
+                                    adjustments = new ArrayList<>();
+                                }
+                                adjustments.addAll(generateRandomAdjustments(result.get(i), frequency / 10, decimal));
+                            }
                             currentIndex = 0;
                             AdjustmentValueCache.getPreAllocatedAdjustments().put(symbol, adjustments);
                             AdjustmentValueCache.getCurrentAdjustmentIndex().put(symbol, currentIndex);
@@ -299,7 +308,16 @@
 
     public static void main(String[] args) {
         AbstractGetDataJob abstractGetDataJob = new CryptosGetDataJob();
-        List<BigDecimal> list = abstractGetDataJob.generateRandomAdjustments(new BigDecimal(0.002), 300, 8);
+        List<BigDecimal> list = new ArrayList<>();
+        int frequency = 200;
+        int decimal = 6;
+        //分几段执行
+        int nums = Math.max(10, frequency / 10);
+        List<BigDecimal> result = RandomNumbersGenerator.generateNumbers(BigDecimal.valueOf(0.02), nums, decimal + 4);
+        for (int i = 0; i < result.size(); i++) {
+            list.addAll(abstractGetDataJob.generateRandomAdjustments(result.get(i), frequency / 10, decimal));
+        }
+
         BigDecimal sum = BigDecimal.ZERO;
         int num = 0;
         int dmt = 1;

--
Gitblit v1.9.3