市场深度数据调整

zyy

2025-10-09 6e0127a5ec2c62b701180624a75524eebb43b1f3

市场深度数据调整

 trading-order-admin/src/main/java/com/yami/trading/admin/task/DepthPushJob.java

@@ -97,6 +97,7 @@


                        }

                    } else {
                        Item item = bySymbol;
                        HandleObject handleObject = new HandleObject();
@@ -393,25 +394,25 @@
//                }
//            }
            if (valueLength <= 4) {
                addValue = RandomUtil.randomFloat(0.001, 0.003, 3);
                addValue = RandomUtil.randomFloat(0.001, 0.009, 3);
                return addValue;
            }

            if (4 < valueLength && valueLength <= 6) {
                addValue = RandomUtil.randomFloat(0.00001, 0.00003, 5);
                addValue = RandomUtil.randomFloat(0.00001, 0.00009, 5);
                return addValue;
            }

            if (6 < valueLength && valueLength <= 8) {
                addValue = RandomUtil.randomFloat(0.0000001, 0.0000003, 7);
                addValue = RandomUtil.randomFloat(0.0000001, 0.0000009, 7);
                return addValue;
            }

            if (8 < valueLength && valueLength <= 10) {
                addValue = RandomUtil.randomFloat(0.0000001, 0.0000003, 9);
                addValue = RandomUtil.randomFloat(0.0000001, 0.0000009, 9);
                return addValue;
            } else {
                addValue = RandomUtil.randomFloat(0.0000000001, 0.0000000003, 10);
                addValue = RandomUtil.randomFloat(0.0000000001, 0.0000000009, 10);
                return addValue;
            }
            // addValue = RandomUtil.randomFloat(0.01, 0.2999, 4);

 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转入产品