package com.yami.trading.service.etf;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.lang.Tuple;
import cn.hutool.core.util.NumberUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yami.trading.bean.data.domain.Kline;
import com.yami.trading.bean.data.domain.RobotModel;
import com.yami.trading.bean.etf.domain.EtfKLine;
import com.yami.trading.bean.etf.domain.EtfMinuteKLine;
import com.yami.trading.bean.etf.domain.EtfSecKLine;
import com.yami.trading.bean.etf.domain.KlineConfig;
import com.yami.trading.bean.etf.dto.KlineConfigDTO;
import com.yami.trading.bean.etf.mapstruct.EtfMinuteKLineWrapper;
import com.yami.trading.bean.etf.mapstruct.EtfSecKLineWrapper;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.robot.domain.RobotOrder;
import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.dao.data.RobotModelMapper;
import com.yami.trading.dao.etf.mapper.KlineConfigMapper;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.robot.RobotOrderService;
import org.jetbrains.annotations.NotNull;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.Instant;
import java.time.ZoneId;
import java.time.ZonedDateTime;
import java.util.*;
import java.util.stream.Collectors;

/**
 * etfK线图配置表Service
 *
 * @author lucas
 * @version 2023-05-03
 */
@Service
@Transactional
public class KlineConfigService extends ServiceImpl<KlineConfigMapper, KlineConfig> {

    @Autowired
    private RobotModelMapper robotModelMapper;

    @Autowired
    private ItemService itemService;

    @Autowired
    EtfSecKLineService etfSecKLineService;

    @Autowired
    EtfSecKLineWrapper etfSecKLineWrapper;


    @Autowired
    RobotOrderService robotOrderService;

    @Autowired
    EtfMinuteKLineService etfMinuteKLineService;

    @Autowired
    EtfMinuteKLineWrapper etfMinuteKLineWrapper;

    @Lazy
    @Autowired
    MarketService marketService;


    @Transactional(rollbackFor = Exception.class)
    public void deleteByRobotModelId(List<String> ids) {
        long currentTimeMillis = System.currentTimeMillis();
        for (String id : ids) {
            KlineConfig config = this.getBaseMapper().selectById(id);
            if (config != null) {
                if (config.getOpenTimeTs() <= currentTimeMillis && config.getCloseTimeTs() >= currentTimeMillis) {
                    throw new YamiShopBindException("当前为开市时间，不能删除");
                }
                removeById(id);

                etfSecKLineService.remove(new QueryWrapper<EtfSecKLine>().eq("symbol", config.getSymbol()).between("ts", config.getOpenTimeTs(), config.getCloseTimeTs()));

                //etfMinuteKLineService 根据config的开市时间，结束时间，symbol去删除
                etfMinuteKLineService.remove(new QueryWrapper<EtfMinuteKLine>().eq("symbol", config.getSymbol()).between("ts", config.getOpenTimeTs(), config.getCloseTimeTs()));

                marketService.getCacheKline().put(config.getSymbol(), new LinkedHashMap<>());
            }
        }
    }

    public EtfKLine queryKLine(KlineConfigDTO klineConfigDTO) {
        BigDecimal divide = klineConfigDTO.getClosePrice().subtract(klineConfigDTO.getOpenPrice()).divide(klineConfigDTO.getOpenPrice(), 2, BigDecimal.ROUND_HALF_UP).multiply(BigDecimal.valueOf(100));

        List<RobotModel> robotModels = new LambdaQueryChainWrapper<>(robotModelMapper).between(RobotModel::getPercent, divide.subtract(new BigDecimal(0.5)), divide.add(new BigDecimal(0.5))).list();

        if (CollectionUtil.isEmpty(robotModels)) {
            throw new YamiShopBindException("没有满足条件的趋势图");
        }


        //  解析数据库满足条件涨幅的k线图数据
        // 随机获取一个，获取完整一天的分钟k线图
        RobotModel robotModel = robotModels.get(new Random().nextInt(robotModels.size()));
        List<Kline> randomKLine = parseHistoryKLine(robotModel);

        // 获取完整一天的k线图
        randomKLine.sort(Comparator.comparing(Kline::getTs));

        // 生成分钟图返回
        List<Kline> klines = accrodingSecOrign(klineConfigDTO, robotModel, randomKLine, 60);

//        printResult(klines);

        return new EtfKLine(robotModel.getUuid(),klines);

    }

    public List<Kline> generateSecKLine(KlineConfigDTO klineConfigDTO) {


        RobotModel robotModel = robotModelMapper.selectById(klineConfigDTO.getRobot_model_uuid());

        // 假图的分钟图
        List<Kline> klines = parseHistoryKLine(robotModel);

        // 生成分钟图
        List<Kline> minute = accrodingSecOrign(klineConfigDTO, robotModel, klines, 60);

        etfMinuteKLineService.saveBatch(etfMinuteKLineWrapper.toDTO(minute),500);

        saveRobotOrder(klineConfigDTO, minute);

        // 生成的秒图
        return getRecentWholwSecKline(klineConfigDTO.getSymbol(), minute);
    }

    private void saveRobotOrder(KlineConfigDTO klineConfigDTO, List<Kline> minute) {
        Random random = new Random();
        Item item = itemService.findBySymbol(klineConfigDTO.getSymbol());

        List<RobotOrder> robotOrders = new ArrayList<>(minute.size());
        for (Kline kline : minute) {
            RobotOrder robotOrder = new RobotOrder();
            robotOrder.setSymbol(klineConfigDTO.getSymbol());
            robotOrder.setPrice(NumberUtil.roundDown(randomBigDecimal(kline.getHigh(), kline.getLow(),random),item.getDecimals()).doubleValue());
            // 设置订单状态挂单中
            robotOrder.setStatus(1);
            robotOrder.setOrderType(random.nextInt(2) + 1);
            robotOrder.setDirection(random.nextInt(2) + 1);
            robotOrder.setOrderQuantity(NumberUtil.roundDown(randomBigDecimal(kline.getVolume(), kline.getVolume().multiply(new BigDecimal(0.8)), random),item.getDecimals()).doubleValue());
            robotOrder.setTurnover(0d);
            robotOrder.setTs(kline.getTs());
            robotOrder.setUuid(UUID.randomUUID().toString().replaceAll("-", ""));
            robotOrder.setUid(UUID.randomUUID().toString().replaceAll("-", ""));
            robotOrders.add(robotOrder);
        }
        robotOrderService.saveBatch(robotOrders);
    }

    // 生成秒级的假图
    private List<Kline> accrodingSecOrign(KlineConfigDTO klineConfigDTO,RobotModel robotModel, List<Kline> originalSecKline, int sec) {

        Item item = itemService.findBySymbol(klineConfigDTO.getSymbol());

        BigDecimal todayVolume = BigDecimal.valueOf(randomBigDecimal(klineConfigDTO.getTurnoverHigh(), klineConfigDTO.getTurnoverLow(), new Random()));
        BigDecimal todayAmount = todayVolume.divide(klineConfigDTO.getOpenPrice().add(klineConfigDTO.getClosePrice()).divide(BigDecimal.valueOf(2)), item.getDecimals(), BigDecimal.ROUND_HALF_UP);



        double totalVolume = originalSecKline.stream()
                .mapToDouble(klien -> klien.getVolume().doubleValue())
                .sum();


        Tuple startAndEnd = getStartAndEnd(klineConfigDTO.getOpenTimeTs());

        klineConfigDTO.setOpenTimeTs(startAndEnd.get(0));
        klineConfigDTO.setCloseTimeTs(startAndEnd.get(1));

        Kline finalSecondKline;
        BigDecimal open = klineConfigDTO.getOpenPrice();
        BigDecimal secHigh;
        BigDecimal secLow;
        BigDecimal secVolume;
        BigDecimal secAmount;
        boolean isOver = false;
        List<Kline> finalResult = new ArrayList<>(originalSecKline.size());
        Random random = new Random();
        for (int i = 0; i < originalSecKline.size(); i++) {
            Kline kline = originalSecKline.get(i);
            finalSecondKline = new Kline();
            finalSecondKline.setTs(klineConfigDTO.getOpenTimeTs() + i * sec * 1000);
            finalSecondKline.setSymbol(item.getSymbol());

            // 设置开仓价
            finalSecondKline.setOpen(open);

            // 分钟级最高价  model.high / model.open * 分钟的open
            secHigh = kline.getHigh().divide(kline.getOpen(), 10, BigDecimal.ROUND_HALF_UP).multiply(finalSecondKline.getOpen()).setScale(item.getDecimals(), BigDecimal.ROUND_HALF_UP);
            finalSecondKline.setHigh(secHigh);

            // 分钟级最低价
            secLow = kline.getLow().divide(kline.getOpen(), 10, BigDecimal.ROUND_HALF_UP).multiply(finalSecondKline.getOpen()).setScale(item.getDecimals(), BigDecimal.ROUND_HALF_UP);
            finalSecondKline.setLow(secLow);

            // 分钟级成交量
            if (kline.getVolume() == null ||kline.getVolume().longValue() == 0) {
                secVolume = BigDecimal.ZERO;
            } else {
                secVolume = kline.getVolume().divide(BigDecimal.valueOf(totalVolume),10, BigDecimal.ROUND_HALF_UP).multiply(todayVolume).setScale(item.getDecimals(), BigDecimal.ROUND_HALF_UP);
            }
            finalSecondKline.setVolume(secVolume);

            if (kline.getAmount() == null || kline.getAmount().longValue() == 0) {
                secAmount = BigDecimal.ZERO;
            } else {
                // 分钟级成交手数
                secAmount = kline.getAmount().divide(BigDecimal.valueOf(robotModel.getAmount()),10, BigDecimal.ROUND_HALF_UP).multiply(todayAmount).setScale(item.getDecimals(), BigDecimal.ROUND_HALF_UP);
            }

            finalSecondKline.setAmount(secAmount);


            // 收盘价
            if (finalSecondKline.getTs() > klineConfigDTO.getCloseTimeTs() || i == originalSecKline.size() - 1) {
                finalSecondKline.setClose(klineConfigDTO.getClosePrice().setScale(item.getDecimals(), BigDecimal.ROUND_HALF_UP));
                isOver = true;
            } else {
                double close = randomBigDecimal(secHigh, secLow, random);
                finalSecondKline.setClose(BigDecimal.valueOf(close).setScale(item.getDecimals(), BigDecimal.ROUND_HALF_UP));
            }


            open = finalSecondKline.getClose();
            finalResult.add(finalSecondKline);
            if (isOver) {
                break;
            }
        }
        return finalResult;
    }

    @NotNull
    private List<Kline> getRecentWholwSecKline(String symbol, List<Kline> collect) {
        Item bySymbol = itemService.findBySymbol(symbol);

        List<Kline> originalSecKline = new ArrayList<>(collect.size());
        Kline originalSecondKline = null;
        Random random = new Random();
        for (Kline kline : collect) {

            // 将这一分钟成交量拆分成60份
            List<BigDecimal> volumes = splitData(kline.getVolume().doubleValue(), 60, 30);
            List<BigDecimal> amounts = splitData(kline.getAmount().doubleValue(), 60, 30);

            BigDecimal open = originalSecondKline == null ? kline.getOpen() : originalSecondKline.getClose();

            for (int i = 0; i < 60; i++) {
                originalSecondKline = new Kline();
                originalSecondKline.setSymbol(symbol);
                originalSecondKline.setTs(kline.getTs() + i * 1000);

                originalSecondKline.setOpen(open.setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));
                double close = 0;
                if (i == 59) {
                    originalSecondKline.setClose(kline.getClose().setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));
                } else {
                    close = randomBigDecimal(kline.getOpen(), kline.getClose(), random);
                    originalSecondKline.setClose(BigDecimal.valueOf(close).setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));
                }
                double high = randomBigDecimal(kline.getLow(), kline.getHigh(), random);
                originalSecondKline.setHigh(BigDecimal.valueOf(high).setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));
                double low = randomBigDecimal(kline.getLow(), originalSecondKline.getClose(), random);
                originalSecondKline.setLow(BigDecimal.valueOf(low).min(originalSecondKline.getOpen()).setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));
                originalSecondKline.setVolume(volumes.get(i).setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));
                originalSecondKline.setAmount(amounts.get(i).setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));


                // 重新调整K线图数据
                adjustKline(originalSecondKline);


                // 重新打散
                while (originalSecondKline.getHigh().doubleValue() == originalSecondKline.getLow().doubleValue()) {
                    // 收盘价在最高和最低之间 当最高价最低价相同时, close = random ( high * random(1,1.01) ,  low * random(1,1.01) )

                    // 随机最高价 为当前分钟最高价的1.005倍
                    BigDecimal tempHigh = kline.getHigh().multiply(getRandomBigDecimal(1));
                    // 随机最低价 为当前分钟最低价的0.995倍
                    BigDecimal tempLow = kline.getLow().multiply(getRandomBigDecimal(-1));
                    
                    originalSecondKline.setClose(BigDecimal.valueOf(randomBigDecimal(tempHigh,tempLow, random)).setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));

                    // 最高价在收盘价和这一分钟的最高价之间
                    originalSecondKline.setHigh(BigDecimal.valueOf(randomBigDecimal(originalSecondKline.getClose(), kline.getHigh(), random)).setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));

                    // 最低价在收盘价和这一分钟的最低价之间
                    originalSecondKline.setLow(BigDecimal.valueOf(randomBigDecimal(kline.getLow(), originalSecondKline.getClose(), random)).setScale(bySymbol.getDecimals(), BigDecimal.ROUND_HALF_UP));

                    adjustKline(originalSecondKline);
                }

                open = originalSecondKline.getClose();
                originalSecKline.add(originalSecondKline);
            }
        }
        return originalSecKline;
    }


    public static Kline adjustKline(Kline kline) {
        BigDecimal[] values = {kline.getHigh(), kline.getOpen(), kline.getClose(), kline.getLow()};
        Arrays.sort(values);
        kline.setHigh(values[3]);
        kline.setLow(values[0]);
        return kline;
    }


    public static BigDecimal getRandomBigDecimal(int input) {
        BigDecimal lowerBound;
        BigDecimal upperBound;

        if (input == 1) {
            lowerBound = BigDecimal.ONE;
            upperBound = new BigDecimal("1.005");
        } else if (input == -1) {
            lowerBound = new BigDecimal("0.995");
            upperBound = BigDecimal.ONE;
        } else {
            throw new IllegalArgumentException("Invalid input value. Expected 1 or -1.");
        }

        BigDecimal range = upperBound.subtract(lowerBound);
        BigDecimal randomValue = range.multiply(BigDecimal.valueOf(Math.random())).add(lowerBound);
        return randomValue.setScale(3, RoundingMode.HALF_UP);
    }

    private void printResult(List<Kline> originalSecKline) {
        // 输出到echarts
        List<List<Object>> result = new ArrayList<>();
        List<String> time = new ArrayList<>();
        // 格式化时间
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("HH:mm:ss");

        for (Kline kline : originalSecKline) {
            List<Object> tmp = new ArrayList<>();
            time.add(simpleDateFormat.format(new Date(kline.getTs())));
            tmp.add(kline.getOpen().setScale(5, BigDecimal.ROUND_HALF_UP));
            tmp.add(kline.getClose().setScale(5, BigDecimal.ROUND_HALF_UP));
            tmp.add(kline.getLow().setScale(5, BigDecimal.ROUND_HALF_UP));
            tmp.add(kline.getHigh().setScale(5, BigDecimal.ROUND_HALF_UP));
//            tmp.add(kline.getVolume().setScale(5, BigDecimal.ROUND_HALF_UP));
            result.add(tmp);
        }


        System.err.println(JSON.toJSONString(time));
        System.err.println(JSON.toJSONString(result));
    }

    /**
     * 传入时间字符串获取当天第一个时间戳
     */
    private Long getTodayFirstTimestamp(String time) {
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
        Date date = null;
        try {
            date = dateFormat.parse(time);
        } catch (ParseException e) {
            e.printStackTrace();
        }
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date);
        calendar.set(Calendar.HOUR_OF_DAY, 0);
        calendar.set(Calendar.MINUTE, 0);
        calendar.set(Calendar.SECOND, 0);
        return calendar.getTimeInMillis();
    }

    /**
     * 传入时间字符串获取当天最后一个时间戳
     */
    private Long getTodayLastTimestamp(String time) {
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
        Date date = null;
        try {
            date = dateFormat.parse(time);
        } catch (ParseException e) {
            e.printStackTrace();
        }
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date);
        calendar.set(Calendar.HOUR_OF_DAY, 23);
        calendar.set(Calendar.MINUTE, 59);
        calendar.set(Calendar.SECOND, 59);
        return calendar.getTimeInMillis();
    }

    @NotNull
    private List<Kline> parseHistoryKLine(RobotModel robotModel) {
        JSONArray jsonArray = JSON.parseArray(robotModel.getKLineData());
        List<Kline> klines = new ArrayList<>(jsonArray.size());
        for (int i = 0; i < jsonArray.size(); i++) {
            JSONObject item = jsonArray.getJSONObject(i);
            Kline kline = new Kline();
            kline.setTs(item.getLong("ts"));
            kline.setVolume(item.getBigDecimal("volume"));
            kline.setAmount(item.getBigDecimal("amount"));
            kline.setOpen(item.getBigDecimal("open"));
            kline.setHigh(item.getBigDecimal("high"));
            kline.setLow(item.getBigDecimal("low"));
            kline.setClose(item.getBigDecimal("close"));
            klines.add(kline);
        }
        return klines;
    }

    public static double randomBigDecimal(BigDecimal a, BigDecimal b, Random random) {
        double diff = b.doubleValue() - a.doubleValue();
        double randNum = diff * random.nextDouble();
        return a.doubleValue() + randNum;
    }


//    public static List<BigDecimal> splitBigDecimal(BigDecimal value, int numOfParts, double maxDifferencePercentage) {
//        List<BigDecimal> parts = new ArrayList<>(numOfParts);
//        Random random = new Random();
//
//        BigDecimal remaining = value;
//        BigDecimal minAllowedValue = value.multiply(BigDecimal.valueOf(1 - maxDifferencePercentage / 100)).divide(BigDecimal.valueOf(numOfParts), value.scale(), BigDecimal.ROUND_HALF_UP);
//        BigDecimal maxAllowedValue = value.multiply(BigDecimal.valueOf(1 + maxDifferencePercentage / 100)).divide(BigDecimal.valueOf(numOfParts), value.scale(), BigDecimal.ROUND_HALF_UP);
//
//        for (int i = 0; i < numOfParts - 1; i++) {
//            BigDecimal part = getRandomBigDecimal(minAllowedValue, maxAllowedValue, random);
//            while (remaining.subtract(part).compareTo(minAllowedValue.multiply(BigDecimal.valueOf(numOfParts - i - 1))) < 0) {
//                part = getRandomBigDecimal(minAllowedValue, maxAllowedValue, random);
//            }
//            parts.add(part);
//            remaining = remaining.subtract(part);
//        }
//
//        parts.add(remaining);
//        return parts;
//    }

    public static List<BigDecimal> splitData(double data, int n, double maxDeviationPercent) {
        // 计算每份的理论平均值
        double avg = data / n;
        // 计算允许的最大偏差
        double maxDeviation = avg * maxDeviationPercent / 100;

        // 创建一个存储每份数据的列表
        List<Double> splits = new ArrayList<>();

        Random random = new Random();
        double remainingData = data;

        // 按照N-1份进行随机拆分
        for (int i = 0; i < n - 1; i++) {
            // 生成一个随机数，表示当前份数据的比例（0到1之间）
            double ratio = random.nextDouble();
            // 计算当前份数据的大小
            double currentSplit = avg + (ratio - 0.5) * 2 * maxDeviation;
            // 将当前份数据加入列表
            splits.add(currentSplit);
            // 更新剩余数据量
            remainingData -= currentSplit;
        }

        // 最后一份数据即为剩余数据量
        splits.add(remainingData);

        // 打乱列表中数据的顺序
        Collections.shuffle(splits);



        return splits.stream().map(BigDecimal::valueOf).collect(Collectors.toList());
    }

    private static BigDecimal getRandomBigDecimal(BigDecimal min, BigDecimal max, Random random) {
        double range = max.doubleValue() - (min.doubleValue());
        double randomValue = range * random.nextDouble();
        return BigDecimal.valueOf(min.doubleValue() + randomValue).setScale(min.scale(), BigDecimal.ROUND_HALF_UP);
    }

    /**
     * 查询秒级K线图
     *
     * @param symbol
     * @return
     */
    public List<Kline> querySecKlineBySymbol(String symbol) {

        Tuple startAndEnd = getStartAndEnd();

        List<EtfSecKLine> list = etfSecKLineService.list(new QueryWrapper<EtfSecKLine>().eq("symbol", symbol).between("ts", startAndEnd.get(0), startAndEnd.get(1)).orderByAsc("ts"));

        return etfSecKLineWrapper.toEntity(list);
    }

    public Tuple getStartAndEnd() {
        // 获取当前时间的时间戳（毫秒级）
        long currentTimestamp = System.currentTimeMillis();

        // 转换为ZonedDateTime对象，使用系统默认时区
        ZonedDateTime currentDateTime = Instant.ofEpochMilli(currentTimestamp)
                .atZone(ZoneId.systemDefault());

        // 获取当天的21:30时间点
        ZonedDateTime targetDateTime;
        if (currentDateTime.getHour() >= 4 && currentDateTime.getHour() <= 23) {
            // 当前时间在4点到21点之间，获取当天的21:30时间点
            targetDateTime = currentDateTime.withHour(23).withMinute(59).withSecond(59).withNano(0);
        } else {
            // 当前时间在0点到4点之间，获取前一天的21:30时间点
            targetDateTime = currentDateTime.minusDays(1).withHour(21).withMinute(30).withSecond(0).withNano(0);
        }


        // 获取第二天凌晨4点时间点
        ZonedDateTime nextDayDateTime = targetDateTime.plusDays(1).withHour(4).withMinute(0);
        // 转换为毫秒时间戳
        long start = targetDateTime.toInstant().toEpochMilli();
        long end = nextDayDateTime.toInstant().toEpochMilli();
        return new Tuple(start, end);
    }


    public Tuple getStartAndEnd(long ts) {
        // 转换为ZonedDateTime对象，使用系统默认时区
        ZonedDateTime inputDateTime = Instant.ofEpochMilli(ts)
                .atZone(ZoneId.systemDefault());

        // 获取当天的21:30时间点
        ZonedDateTime targetDateTime = inputDateTime.withHour(21).withMinute(30).withSecond(0).withNano(0);

        // 获取第二天的4:00时间点
        ZonedDateTime nextDayDateTime = targetDateTime.plusDays(1).withHour(4).withMinute(0);

        // 转换为毫秒时间戳
        long start = targetDateTime.toInstant().toEpochMilli();
        long end = nextDayDateTime.toInstant().toEpochMilli();

        return new Tuple(start, end);
    }



    /**
     * 查询所有秒级K线图
     *
     * @param symbol
     * @return
     */
    public List<Kline> querySecKlineBySymbolAllData(String symbol) {
        long currentTime = System.currentTimeMillis();

//        QueryWrapper<KlineConfig> queryWrapper = new QueryWrapper<>();
//        queryWrapper.eq("symbol", symbol).le("open_time_ts", currentTime).ge("close_time_ts", currentTime);
//        List<KlineConfig> klineConfigs = this.baseMapper.selectList(queryWrapper);
//
//        if (CollectionUtils.isEmpty(klineConfigs)) {
//            throw new YamiShopBindException("未查询到当天配置的秒级K线图");
//        }
//
//        if (klineConfigs.size() > 1) {
//            throw new YamiShopBindException("查询到多个当天配置的秒级K线图");
//        }
//
//        KlineConfig klineConfig = klineConfigs.get(0);

        List<EtfSecKLine> list = etfSecKLineService.list(new QueryWrapper<EtfSecKLine>().eq("symbol", symbol).orderBy(true, true, "ts"));

        return etfSecKLineWrapper.toEntity(list);
    }
}