package com.yami.trading.huobi.hobi.internal;

import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.base.Splitter;
import com.google.common.collect.Lists;
import com.yami.trading.bean.data.domain.*;
import com.yami.trading.bean.data.respDto.TradeTickResp;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.common.util.Arith;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.common.util.ThreadUtils;
import com.yami.trading.common.util.UTCDateUtils;
import com.yami.trading.huobi.data.internal.KlineConstant;
import com.yami.trading.huobi.data.internal.KlineService;
import com.yami.trading.huobi.data.model.AllticktradeResult;
import com.yami.trading.huobi.data.model.TimeseriesResult;
import com.yami.trading.huobi.data.websocket.model.market.MarketDepthEvent;
import com.yami.trading.huobi.data.websocket.model.market.MarketTrade;
import com.yami.trading.huobi.data.websocket.model.market.MarketTradeEvent;
import com.yami.trading.huobi.data.websocket.model.market.PriceLevel;
import com.yami.trading.huobi.hobi.Config;
import com.yami.trading.huobi.hobi.HobiDataService;
import com.yami.trading.huobi.hobi.constant.AllticktradeMadeOptions;
import com.yami.trading.huobi.hobi.constant.TraderMadeOptions;
import com.yami.trading.huobi.hobi.http.HttpHelper;
import com.yami.trading.huobi.hobi.http.HttpMethodType;
import com.yami.trading.service.item.ItemService;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.*;

@Component
public class HobiDataServiceImpl implements HobiDataService {
    private static Logger logger = LoggerFactory.getLogger(HobiDataServiceImpl.class);

    @Autowired
    private XueQiuDataServiceImpl xueQiuDataService;
    @Autowired
    private XinLangDataServiceImpl xinLangDataService;
    @Autowired
    private ItemService itemService;
    @Autowired
    private KlineService klineService;

    @Value("${alltick.trade-kline}")
    private String tradeKline;
    /**
     * 接口调用间隔（毫秒）
     */
    private int interval = 100;

    private int sleep = 100;
    /**
     * 最后一次访问接口时间
     */
    private volatile Date last_time = new Date();

    private volatile boolean lock = false;

    public static void main(String[] args) {
        HobiDataServiceImpl huobi = new HobiDataServiceImpl();
        Map<String, List<Kline>> etcusd = huobi.getDailyWeekMonthHistory("ETCUSD");
        System.out.println(etcusd);
    }

    // 针对虚拟货币的
    @Override
    public List<Realtime> realtime(int maximum) {
        List<Realtime> list = new ArrayList<Realtime>();
        boolean current_lock = false;
        if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
            ThreadUtils.sleep(sleep);
            if (maximum >= 100) {
                return list;
            } else {
                return realtime(++maximum);
            }

        } else {
            try {
                current_lock = true;
                lock = true;
                Map<String, Object> param = new HashMap<String, Object>();
                String result = HttpHelper.getJSONFromHttp(Config.url + Config.tickers, param, HttpMethodType.GET);
                JSONObject resultJson = JSON.parseObject(result);
                String status = resultJson.getString("status");
                if ("ok".equals(status)) {
                    JSONArray dataArray = resultJson.getJSONArray("data");
                    Long ts = resultJson.getLongValue("ts");
                    for (int i = 0; i < dataArray.size(); i++) {
                        JSONObject realtimeJson = dataArray.getJSONObject(i);
                        Realtime realtime = new Realtime();
                        Item item = itemService.findBySymbol(realtimeJson.getString("symbol"));
                        if (item == null) {
                            continue;
                        }
                        realtime.setSymbol(item.getSymbol());
                        realtime.setName(item.getName());
                        realtime.setTs(ts);
                        realtime.setOpen(realtimeJson.getBigDecimal("open"));
                        realtime.setClose(realtimeJson.getBigDecimal("close"));
                        realtime.setHigh(realtimeJson.getBigDecimal("high"));
                        realtime.setLow(realtimeJson.getBigDecimal("low"));
                        realtime.setAmount(realtimeJson.getBigDecimal("amount"));
                        realtime.setVolume(realtimeJson.getBigDecimal("vol"));
                        list.add(realtime);
                    }

                } else {
                    logger.error(" realtime()error, resultJson [ " + resultJson.toJSONString() + " ]");
                }
            } catch (Exception e) {
                logger.error("error", e);
            } finally {
                if (current_lock) {
                    lock = false;
                    last_time = new Date();
                }

            }
        }
        return list;
    }

    @Override
    public List<Kline> kline(String symbol, String period, Integer num, int maximum) {
        List<Kline> list = new ArrayList<Kline>();
        Item item = itemService.findBySymbol(symbol);
        if (item == null) {
            return list;
        }
        boolean current_lock = false;
        if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
            ThreadUtils.sleep(sleep);
            if (maximum >= 500) {
                return list;
            } else {
                return this.kline(symbol, period, num, ++maximum);
            }

        } else {
            try {
                current_lock = true;
                lock = true;
                Map<String, Object> param = new HashMap<String, Object>();
                param.put("symbol", symbol);
                param.put("period", period);
                if (num == null) {
                    if (Kline.PERIOD_1MIN.equals(period)) {
                        param.put("size", 1440);
                    }
                    if (Kline.PERIOD_5MIN.equals(period)) {
                        param.put("size", 576);
                    }
                    if (Kline.PERIOD_15MIN.equals(period)) {
                        param.put("size", 576);
                    }
                    if (Kline.PERIOD_30MIN.equals(period)) {
                        param.put("size", 576);
                    }
                    if (Kline.PERIOD_60MIN.equals(period)) {
                        param.put("size", 576);
                    }

                    if (Kline.PERIOD_4HOUR.equals(period)) {
                        param.put("size", 576);
                    }
                    if (Kline.PERIOD_1DAY.equals(period)) {
                        param.put("size", 500);
                    }
                    if (Kline.PERIOD_1MON.equals(period)) {
                        param.put("size", 500);
                    }
                    if (Kline.PERIOD_1WEEK.equals(period)) {
                        param.put("size", 500);
                    }

                } else {
                    param.put("size", num);
                }

                String result = HttpHelper.getJSONFromHttp(Config.url + Config.kline, param, HttpMethodType.GET);
                JSONObject resultJson = JSON.parseObject(result);
                String status = resultJson.getString("status");
                if ("ok".equals(status)) {
                    JSONArray dataArray = resultJson.getJSONArray("data");
                    /**
                     * 丢弃第一行数据
                     */
                    int start = 1;
                    if (num != null && num == 1) start = 0;
                    for (int i = start; i < dataArray.size(); i++) {
                        JSONObject realtimeJson = dataArray.getJSONObject(i);
                        Kline kline = new Kline();
                        kline.setSymbol(item.getSymbol());
                        kline.setPeriod(period);
                        kline.setTs(Long.valueOf(realtimeJson.getString("id") + "000"));
                        kline.setOpen(realtimeJson.getBigDecimal("open"));
                        kline.setClose(realtimeJson.getBigDecimal("close"));
                        kline.setHigh(realtimeJson.getBigDecimal("high"));
                        kline.setLow(realtimeJson.getBigDecimal("low"));
                        kline.setVolume(realtimeJson.getBigDecimal("vol"));
                        list.add(kline);
                    }

                }
            } catch (Exception e) {
                logger.error("error", e);
            } finally {
                if (current_lock) {
                    lock = false;
                    last_time = new Date();
                }

            }
        }
        return list;
    }

    /**
     * 市场深度数据（20档）,包装，数据本地化处理
     */
    public Depth depthDecorator(String symbol, int maximum) {
        Depth depth = this.depth(symbol, maximum);
        Item item = itemService.findBySymbol(symbol);
        if ((depth == null || item.getAdjustmentValue() == null || item.getAdjustmentValue().intValue() == 0) && (item.getMultiple().intValue() == 0 || item.getMultiple().intValue() == 1)) {
            return depth;
        }
        if(CollectionUtil.isNotEmpty(depth.getAsks()) ){
            List<DepthEntry> asks = depth.getAsks();
            for (int i = 0; i < asks.size(); i++) {
                DepthEntry depthEntry = asks.get(i);

                /**
                 * 调整交易量倍数和 行情值
                 */
                if (item.getMultiple().doubleValue() > 0) {
                    depthEntry.setAmount(Arith.mul(depthEntry.getAmount(), item.getMultiple().doubleValue()));
                } else {
                    depthEntry.setAmount(depthEntry.getAmount());
                }
                depthEntry.setPrice(Arith.add(depthEntry.getPrice(), item.getAdjustmentValue().doubleValue()));
            }
        }

        if(CollectionUtil.isNotEmpty(depth.getBids())){
            List<DepthEntry> bids = depth.getBids();
            for (int i = 0; i < bids.size(); i++) {
                DepthEntry depthEntry = bids.get(i);
                /**
                 * 调整交易量倍数和 行情值
                 */
                if (item.getMultiple().doubleValue() > 0) {
                    depthEntry.setAmount(Arith.mul(depthEntry.getAmount(), item.getMultiple().doubleValue()));
                } else {
                    depthEntry.setAmount(depthEntry.getAmount());
                }
                depthEntry.setPrice(Arith.add(depthEntry.getPrice(), item.getAdjustmentValue().doubleValue()));
            }
        }
        return depth;
    }

    /**
     * 市场深度数据（20档）,包装，数据本地化处理
     */
    public Depth depthDecorator(MarketDepthEvent event, Item item) {
        Depth depth = new Depth();
        depth.setSymbol(item.getSymbol());
        depth.setTs(event.getTs());

        double multiple = item.getMultiple().doubleValue() == 0 ? 1 : item.getMultiple().doubleValue();
        double adjustmentValue = item.getAdjustmentValue() == null ? 0 : item.getMultiple().doubleValue();

        for (PriceLevel priceLevel : event.getDepth().getAsks()) {
            DepthEntry depthEntry = new DepthEntry();
            depthEntry.setPrice(Arith.add(depthEntry.getPrice(), adjustmentValue));
            depthEntry.setAmount(Arith.mul(priceLevel.getAmount().doubleValue(), multiple));
            depth.getAsks().add(depthEntry);
        }

        for (PriceLevel priceLevel : event.getDepth().getBids()) {
            DepthEntry depthEntry = new DepthEntry();
            depthEntry.setPrice(Arith.add(depthEntry.getPrice(), adjustmentValue));
            depthEntry.setAmount(Arith.mul(priceLevel.getAmount().doubleValue(), multiple));
            depth.getBids().add(depthEntry);
        }

        return depth;
    }

    @Override
    public Depth depth(String symbol, int maximum) {
        boolean current_lock = false;
        if (StringUtils.isNullOrEmpty(symbol)) {
            return null;
        }
        if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
            ThreadUtils.sleep(sleep);
            if (maximum >= 100) {
                return null;
            } else {
                return this.depth(symbol, ++maximum);
            }
        } else {
            try {
                current_lock = true;
                lock = true;
                Map<String, Object> param = new HashMap<String, Object>();
                param.put("symbol", symbol);
                param.put("type", "step2");

                String result = HttpHelper.getJSONFromHttp(Config.url + Config.depth, param, HttpMethodType.GET);
                JSONObject resultJson = JSON.parseObject(result);
                String status = resultJson.getString("status");
                if ("ok".equals(status)) {
                    JSONObject dataJson = resultJson.getJSONObject("tick");
                    Long ts = resultJson.getLongValue("ts");
                    Depth depth = new Depth();

                    Item item = itemService.findBySymbol(symbol);
                    if (item == null) {
                        return null;
                    }
                    depth.setSymbol(item.getSymbol());
                    depth.setTs(ts);

                    JSONArray bidsArray = dataJson.getJSONArray("bids");
                    for (int i = 0; i < bidsArray.size(); i++) {

                        JSONArray object = (JSONArray) bidsArray.get(i);
                        DepthEntry depthEntry = new DepthEntry();
                        depthEntry.setPrice(object.getDouble(0));
                        depthEntry.setAmount(object.getDouble(1));
                        depth.getBids().add(depthEntry);

                    }

                    JSONArray asksArray = dataJson.getJSONArray("asks");
                    for (int i = 0; i < asksArray.size(); i++) {
                        JSONArray object = (JSONArray) asksArray.get(i);
                        DepthEntry depthEntry = new DepthEntry();
                        depthEntry.setPrice(object.getDouble(0));
                        depthEntry.setAmount(object.getDouble(1));
                        depth.getAsks().add(depthEntry);

                    }

                    return depth;
                }

            } catch (Exception e) {
                logger.error("error", e);
            } finally {
                if (current_lock) {
                    lock = false;
                    last_time = new Date();
                }

            }
        }
        return null;
    }

    /**
     * 获得近期交易记录,包装，数据本地化处理
     */
    public Trade tradeDecorator(String symbol, int maximum) {
        Trade trade = this.trade(symbol, maximum);
        Item item = itemService.findBySymbol(symbol);
        if ((trade == null || item.getAdjustmentValue() == null || item.getAdjustmentValue().doubleValue() == 0) && (item.getMultiple().doubleValue() == 0 || item.getMultiple().doubleValue() == 1)) {
            return trade;
        }
        if(CollectionUtil.isNotEmpty(trade.getData())){
            List<TradeEntry> data = trade.getData();
            for (int i = 0; i < data.size(); i++) {
                TradeEntry tradeEntry = data.get(i);

                /**
                 * 调整交易量倍数和 行情值
                 */
                if (item.getMultiple().doubleValue() > 0) {
                    tradeEntry.setAmount(Arith.mul(tradeEntry.getAmount(), item.getMultiple().doubleValue()));
                } else {
                    tradeEntry.setAmount(tradeEntry.getAmount());
                }
                tradeEntry.setPrice(Arith.add(tradeEntry.getPrice(), item.getAdjustmentValue().doubleValue()));
            }
        }
        return trade;

    }

    /**
     * 获得近期交易记录,包装，数据本地化处理
     */
    public Trade tradeDecorator(MarketTradeEvent event, Item item) {
        Trade trade = new Trade();
        trade.setSymbol(item.getSymbol());
        trade.setTs(event.getTs());
        double multiple = item.getMultiple().doubleValue() == 0 ? 1 : item.getMultiple().doubleValue();
        double adjustmentValue = item.getAdjustmentValue() == null ? 0 : item.getMultiple().doubleValue();
        for (MarketTrade value : event.getList()) {
            TradeEntry entry = new TradeEntry();
            entry.setAmount(Arith.mul(value.getAmount().doubleValue(), multiple));
            entry.setPrice(Arith.add(value.getPrice().doubleValue(), adjustmentValue));
            entry.setTs(value.getTs());
            entry.setPrice(value.getPrice().doubleValue());
            entry.setAmount(value.getAmount().doubleValue());
            entry.setDirection(value.getDirection());
            trade.getData().add(entry);
        }
        return trade;
    }

    @Override
    public Trade trade(String symbol, int maximum) {
        boolean current_lock = false;
        if (StringUtils.isNullOrEmpty(symbol)) {
            return null;
        }
        if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
            ThreadUtils.sleep(sleep);
            if (maximum >= 100) {

                return null;
            } else {
                return this.trade(symbol, ++maximum);
            }
        } else {
            try {
                current_lock = true;
                lock = true;
                Map<String, Object> param = new HashMap<String, Object>();
                param.put("symbol", symbol);

                String result = HttpHelper.getJSONFromHttp(Config.url + Config.trade, param, HttpMethodType.GET);
                JSONObject resultJson = JSON.parseObject(result);
                String status = resultJson.getString("status");
                if ("ok".equals(status)) {
                    JSONObject dataJson = resultJson.getJSONObject("tick");
                    Long ts = resultJson.getLongValue("ts");

                    Trade trade = new Trade();

                    Item item = itemService.findBySymbol(symbol);
                    if (item == null) {
                        return null;
                    }
                    trade.setSymbol(item.getSymbol());
                    trade.setTs(ts);

                    JSONArray dataArray = dataJson.getJSONArray("data");
                    for (int i = 0; i < dataArray.size(); i++) {
                        JSONObject object = dataArray.getJSONObject(i);
                        TradeEntry tradeEntry = new TradeEntry();
                        tradeEntry.setTs(object.getLong("ts"));
                        tradeEntry.setPrice(object.getDouble("price"));
                        tradeEntry.setAmount(object.getDouble("amount"));
                        tradeEntry.setDirection(object.getString("direction"));
                        trade.getData().add(tradeEntry);

                    }
                    return trade;
                }

            } catch (Exception e) {
                logger.error("error", e);
            } finally {
                if (current_lock) {
                    lock = false;
                    last_time = new Date();
                }

            }
        }
        return null;
    }

    @Override
    public List<Symbols> symbols() {
        List<Symbols> list = new ArrayList<Symbols>();
        boolean current_lock = false;
        if (lock || (new Date().getTime() - last_time.getTime()) < interval) {

            return list;
        } else {
            try {
                current_lock = true;
                lock = true;
                Map<String, Object> param = new HashMap<String, Object>();
                String result = HttpHelper.getJSONFromHttp(Config.url + Config.symbols, param, HttpMethodType.GET);
                JSONObject resultJson = JSON.parseObject(result);
                String status = resultJson.getString("status");
                if ("ok".equals(status)) {
                    JSONArray dataArray = resultJson.getJSONArray("data");
                    for (int i = 0; i < dataArray.size(); i++) {
                        JSONObject realtimeJson = dataArray.getJSONObject(i);
                        Symbols symbols = new Symbols();
                        symbols.setBaseCurrency(realtimeJson.getString("base-currency"));
                        symbols.setQuoteCurrency(realtimeJson.getString("quote-currency"));
                        symbols.setLeverageRatio(realtimeJson.getBigDecimal("leverage-ratio"));
                        symbols.setPricePrecision(realtimeJson.getIntValue("price-precision"));
                        symbols.setState(realtimeJson.getString("state"));
                        symbols.setSymbol(realtimeJson.getString("symbol"));
                        list.add(symbols);
                    }

                } else {
                    logger.error(" symbols()error, resultJson [ " + resultJson.toJSONString() + " ]");
                }
            } catch (Exception e) {
                logger.error("error", e);
            } finally {
                if (current_lock) {
                    lock = false;
                    last_time = new Date();
                }

            }
        }
        return list;
    }

    public void setItemService(ItemService itemService) {
        this.itemService = itemService;
    }

    public boolean isXueQiu(String symbol) {
        String type = itemService.findBySymbol(symbol).getType();
        return type.contains("stock") || (type.equalsIgnoreCase(Item.indices));
    }

    public boolean isXinlang(String symbol) {
        if("XAUUSD,XAGUSD,OIL".contains(symbol)){
            return false;

        }
        Item bySymbol = itemService.findBySymbol(symbol);
        String type = bySymbol.getType();
        return Item.forex.contains(type) && Item.forex.equals(bySymbol.getCategory());
    }

    public List<Realtime> realtimeSingle(String symbol) {
        if (isXueQiu(symbol)) {
            return xueQiuDataService.realtimeSingle(symbol);
        }
        if (isXinlang(symbol)) {
            return xinLangDataService.realtimeSingle(symbol);
        }
        List<Realtime> list = new ArrayList<Realtime>();
        try {
            Map<String, String> param = new HashMap<>();
            param.put("currency", symbol);
            String result = HttpHelper.getJSONFromHttpNew(TraderMadeOptions.live, param, HttpMethodType.GET);
            JSONObject resultJson = JSON.parseObject(result);
            String code = resultJson.getString("code");
            if ("ok".equals(code)) {
                JSONArray dataArray = resultJson.getJSONArray("data");
                for (int i = 0; i < dataArray.size(); i++) {
                    JSONObject realtimeJson = dataArray.getJSONObject(i);
                    Realtime realtime = new Realtime();
                    String currency = symbol;
                    currency = realtimeJson.getString("currency");
                    int decimal = itemService.getDecimal(currency);
                    realtime.setSymbol(currency);
                    realtime.setName(currency);
                    realtime.setTs(realtimeJson.getLong("timestamp"));
                    realtime.setOpen(realtimeJson.getBigDecimal("open").setScale(decimal, RoundingMode.HALF_UP));
                    realtime.setClose(realtimeJson.getBigDecimal("mid").setScale(decimal, RoundingMode.HALF_UP));
                    realtime.setHigh(realtimeJson.getBigDecimal("high").setScale(decimal, RoundingMode.HALF_UP));
                    realtime.setLow(realtimeJson.getBigDecimal("low").setScale(decimal, RoundingMode.HALF_UP));
                    realtime.setAmount(BigDecimal.ZERO);
                    realtime.setVolume(BigDecimal.ZERO);
                    realtime.setAsk(realtimeJson.getBigDecimal("ask").setScale(decimal, RoundingMode.HALF_UP));
                    realtime.setBid(realtimeJson.getBigDecimal("bid").setScale(decimal, RoundingMode.HALF_UP));
                    list.add(realtime);
                }
            } else {
                logger.error(" realtime()error, resultJson [ " + resultJson.toJSONString() + " ]");
            }
        } catch (Exception e) {
            logger.error("error", e);
        }
        return list;
    }

    public List<Realtime> realtime(String symbols) {
        List<Realtime> realtimeList = Collections.synchronizedList(new ArrayList<Realtime>());
        Splitter.on(",").omitEmptyStrings().splitToList(symbols).parallelStream().map(this::realtimeSingle).forEach(realtimeList::addAll);
        return realtimeList;
    }

    @Override
    public List<Realtime> realtimeXueQiu(String symbols) {
        return xueQiuDataService.realtimeSingle(symbols);
    }

    @Override
    public List<Realtime> realtimeXinLang(String symbols) {
        return xinLangDataService.realtimeSingle(symbols);
    }
    @Override
    public List<Realtime> realtimeNewPrice(String symbols,List<Realtime> realtimes) {
        return xinLangDataService.realtimeNewPrice(symbols,realtimes);
    }

    /**
     * 1day       历史数据  ： 周期 1年
     * 1week,1mon 历史数据  ： 周期 5年
     * 请求 350次
     */
    public Map<String, List<Kline>> getDailyWeekMonthHistory(String symbol) {
        Map<String, List<Kline>> map = new HashMap<>();
        SimpleDateFormat f = new SimpleDateFormat("yyyy-MM-dd");
        f.setTimeZone(TimeZone.getTimeZone(UTCDateUtils.GMT_TIME_ZONE));
        Date now = new Date();
        // 每次只能取一年的数据，需要遍历5年
        for (int i = 0; i < AllticktradeMadeOptions.dayKlineCountPeriod; i++) {
            String resultStr = null;
            try {
                resultStr = getTradeKline(symbol,AllticktradeMadeOptions.dayPeriod,AllticktradeMadeOptions.dayKlineNumPeriod);
            } catch (Exception e) {
                logger.error("采集外汇k线图失败:{} " , e);
                continue;
            }
            JSONObject resultJson = JSON.parseObject(resultStr);
            if(200 != resultJson.getInteger("ret")){
                logger.error("采集外汇k线图失败，返回:{} ", resultStr);
            }
            JSONObject tempdata = resultJson.getJSONObject("data");
            JSONArray dataArray = tempdata.getJSONArray("kline_list");
            if (dataArray.size() > 0) {
                List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
                map.put(Kline.PERIOD_1DAY, buildOneDayPeriod(list, symbol));
            }
        }
        try {
            List<Kline> dayList = map.get(Kline.PERIOD_1DAY);
            if (CollectionUtil.isNotEmpty(dayList)) {
                map.put(Kline.PERIOD_5DAY, klineService.calculateKline(symbol, 5, Kline.PERIOD_5DAY, dayList));
            }
            List<Kline> montList = map.get(Kline.PERIOD_1MON);

            if (CollectionUtil.isNotEmpty(montList)) {
                map.put(Kline.PERIOD_QUARTER, klineService.calculateKline(symbol, 3, Kline.PERIOD_1MON, montList));
            }

        } catch (Exception e) {
            logger.error("外汇计算 5日和季度k线图失败", e);
        }


        return map;
    }


    /**
     * 获取分钟数据
     */
    public Map<String, List<Kline>> getHourlyAndMinuteHistory(String symbol) {
        Map<String, List<Kline>> map = new HashMap<>();

        List<Kline> monthList = getTimeseries(symbol,KlineConstant.PERIOD_1MON,AllticktradeMadeOptions.monthPeriod);
        map.put(KlineConstant.PERIOD_1MON, monthList);

        List<Kline> weekList = getTimeseries(symbol,KlineConstant.PERIOD_1WEEK,AllticktradeMadeOptions.weekPeriod);
        map.put(KlineConstant.PERIOD_1WEEK, weekList);

        List<Kline> dayList = getTimeseries(symbol,KlineConstant.PERIOD_1DAY,AllticktradeMadeOptions.dayPeriod);
        map.put(KlineConstant.PERIOD_1DAY, dayList);

        List<Kline> towHourlyList = getTimeseries(symbol,KlineConstant.PERIOD_2HOUR,AllticktradeMadeOptions.towHourPeriod);
        map.put(KlineConstant.PERIOD_2HOUR, towHourlyList);

        List<Kline> oneHourlyList = getTimeseries(symbol,KlineConstant.PERIOD_60MIN,AllticktradeMadeOptions.hourPeriod);
        map.put(KlineConstant.PERIOD_60MIN, oneHourlyList);

        List<Kline> thirtyMinuteList = getTimeseries(symbol,KlineConstant.PERIOD_30MIN,AllticktradeMadeOptions.thirtyPeriod);
        map.put(KlineConstant.PERIOD_30MIN, thirtyMinuteList);

        List<Kline> fifteenMinuteList = getTimeseries(symbol,KlineConstant.PERIOD_15MIN,AllticktradeMadeOptions.fifteenPeriod);
        map.put(KlineConstant.PERIOD_15MIN, fifteenMinuteList);

        List<Kline> fiveMinuteList = getTimeseries(symbol,KlineConstant.PERIOD_5MIN,AllticktradeMadeOptions.fivePeriod);
        map.put(KlineConstant.PERIOD_5MIN, fiveMinuteList);

        List<Kline> oneMinuteList = getTimeseries(symbol,KlineConstant.PERIOD_1MIN,AllticktradeMadeOptions.minutePeriod);
        map.put(KlineConstant.PERIOD_1MIN, oneMinuteList);

        //昨日收盘价
        BigDecimal yesterdayLastPrice = realtimeSingleZdf(symbol);
        Item item = itemService.findBySymbol(symbol);
        item.setYesterdayLastPrice(yesterdayLastPrice);
        itemService.updateById(item);
        return map;
    }
    public BigDecimal realtimeSingleZdf(String symbol){
        //计算24小时涨跌幅
        BigDecimal yesterdayLastPrice = BigDecimal.ZERO;
        List<Kline> dayklines = getTimeseries(symbol,KlineConstant.PERIOD_OTHER,AllticktradeMadeOptions.dayPeriod);
        int decimal = itemService.getDecimal(symbol);
        long minTimestamp = Long.MAX_VALUE;
        for (Kline kline : dayklines) {
            long currentTimestamp = kline.getTs();
            if (currentTimestamp < minTimestamp) {
                minTimestamp = currentTimestamp;
                yesterdayLastPrice = kline.getClose().setScale(decimal, RoundingMode.HALF_UP);
            }
        }
        return yesterdayLastPrice;
    }

    @Override
    public List<Kline> getTimeseries(String symbol,String period,int periodType){
        List<Kline> resList = new ArrayList<>();
        int klineCount;
        if (KlineConstant.PERIOD_1MIN.equals(period)) {
//            klineCount = 1440; // 当天的1分钟K线
            klineCount = 1000;
        } else if (KlineConstant.PERIOD_5MIN.equals(period)) {
            klineCount = 288; // 当天的5分钟K线
        } else if (KlineConstant.PERIOD_15MIN.equals(period)) {
            klineCount = 192; // 2天的15分钟K线，15分钟间隔
        } else if (KlineConstant.PERIOD_30MIN.equals(period)) {
            klineCount = 480; // 10天的30分钟K线
        } else if (KlineConstant.PERIOD_60MIN.equals(period)) {
            klineCount = 720; // 1个月的60分钟K线
        } else if (KlineConstant.PERIOD_2HOUR.equals(period)) {
            klineCount = 12; // 2个月的120分钟K线
        } else if (KlineConstant.PERIOD_4HOUR.equals(period)) {
            klineCount = 540; // 3个月的4小时K线
        } else if (KlineConstant.PERIOD_1DAY.equals(period)) {
            klineCount = 1 * 365; // 1年的日K线，1天 * 12个月 = 540
        } else if (KlineConstant.PERIOD_1WEEK.equals(period)) {
            klineCount = 52 * 5; // 5年的1周K线 (1年52周，5年共260周)
        } else if (KlineConstant.PERIOD_1MON.equals(period)) {
            klineCount = 12 * 5; // 5年的1个月K线，12个月每年，乘以5年 = 60
        }else if(KlineConstant.PERIOD_ONE.equals(period)){
            klineCount = 1;
        }else{
            klineCount = 2;
        }
        String resultStr = null;
        try {
            resultStr = getTradeKline(symbol, periodType, klineCount);
        } catch (Exception e) {
            logger.error("采集外汇k线图失败:{} ", e);
        }

        JSONObject resultJson = JSON.parseObject(resultStr);
        if (null == resultJson || 200 != resultJson.getInteger("ret")) {
            logger.error("采集外汇k线图失败，--"+period+"--返回:{} ", resultStr);
        }

        JSONObject tempdata = resultJson.getJSONObject("data");
        JSONArray dataArray = tempdata.getJSONArray("kline_list");
        if (dataArray.size() > 0) {
            List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
            for (AllticktradeResult result : list) {
                Kline kline = new Kline();
                kline.setSymbol(symbol);
                kline.setPeriod(period);
                // 毫秒
                kline.setTs(Long.valueOf(result.getTimestamp() + "000"));
                kline.setOpen(result.getOpen_price());
                kline.setClose(result.getClose_price());
                kline.setHigh(result.getHigh_price());
                kline.setLow(result.getLow_price());
                kline.setVolume(result.getTurnover());
                kline.setAmount(result.getVolume());
                resList.add(kline);
            }
        }
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            logger.error("延时中断: {}", e);
        }
        return resList;
    }

    @Override
    public List<Realtime> realtime24HoruData(String symbols, List<Realtime> realtimes) {
        List<String> strings = Arrays.asList(symbols.split(","));
        for (int i = 0; i < strings.size(); i++) {
            List<Kline> dayList = getTimeseries(strings.get(i), KlineConstant.PERIOD_ONE, AllticktradeMadeOptions.dayPeriod);
            if(dayList.size()>0){
                Kline kline = dayList.get(0);
                for (Realtime realtime : realtimes){
                    if(realtime.getSymbol().equals(strings.get(i))){
                        int decimal = itemService.getDecimal(realtime.getSymbol());
                        realtime.setOpen(kline.getOpen().setScale(decimal, RoundingMode.HALF_UP));
                        realtime.setHigh(kline.getHigh().setScale(decimal, RoundingMode.HALF_UP));
                        realtime.setLow(kline.getLow().setScale(decimal, RoundingMode.HALF_UP));
                        realtime.setAmount(kline.getAmount().setScale(decimal, RoundingMode.HALF_UP));
                        realtime.setVolume(kline.getVolume().setScale(decimal, RoundingMode.HALF_UP));
                    }
                }
            }
        }
        return realtimes;
    }

    public List<Kline> buildOneDayPeriod(List<AllticktradeResult> list, String currency) {
        List<Kline> resList = new ArrayList<>();
        for (AllticktradeResult result : list) {
            Kline kline = new Kline();
            kline.setSymbol(currency);
            kline.setPeriod(Kline.PERIOD_1DAY);
            kline.setTs(Long.parseLong(result.getTimestamp()));
            kline.setOpen(result.getOpen_price());
            kline.setClose(result.getClose_price());
            kline.setHigh(result.getHigh_price());
            kline.setLow(result.getLow_price());
            kline.setVolume(result.getVolume());
            resList.add(kline);
        }
        return resList;
    }



    public List<Kline> buildOneWeekPeriod(Map<String, List<TimeseriesResult>> weekMap, String currency) {
        if (isXueQiu(currency)) {
            return xueQiuDataService.buildOneWeekPeriod(currency);
        }

        List<Kline> resList = new ArrayList<>();
        for (List<TimeseriesResult> list : weekMap.values()) {
            BigDecimal high = list.stream().map(TimeseriesResult::getHigh).filter(Objects::nonNull).max(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
            BigDecimal low = list.stream().map(TimeseriesResult::getLow).filter(Objects::nonNull).min(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
            Kline kline = new Kline();
            kline.setSymbol(currency);
            kline.setPeriod(Kline.PERIOD_1WEEK);
            // 毫秒
            kline.setTs(UTCDateUtils.toDate(list.get(list.size() - 1).getDate()).getTime());
            kline.setOpen(list.get(0).getOpen());
            kline.setClose(list.get(list.size() - 1).getClose());
            kline.setHigh(high);
            kline.setLow(low);
            kline.setVolume(BigDecimal.ZERO);
            resList.add(kline);
        }
        return resList;
    }

    public List<Kline> buildOneMonthPeriod(Map<String, List<TimeseriesResult>> monthMap, String currency) {
        if (isXueQiu(currency)) {
            return xueQiuDataService.buildOneMonthPeriod(currency);
        }
        List<Kline> resList = new ArrayList<>();
        for (List<TimeseriesResult> list : monthMap.values()) {
            BigDecimal high = list.stream().map(TimeseriesResult::getHigh).filter(Objects::nonNull).max(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
            BigDecimal low = list.stream().map(TimeseriesResult::getLow).filter(Objects::nonNull).min(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
            Kline kline = new Kline();
            kline.setSymbol(currency);
            kline.setPeriod(Kline.PERIOD_1MON);
            // 毫秒
            kline.setTs(UTCDateUtils.toDate(list.get(list.size() - 1).getDate()).getTime());
            kline.setOpen(list.get(0).getOpen());
            kline.setClose(list.get(list.size() - 1).getClose());
            kline.setHigh(high);
            kline.setLow(low);
            kline.setVolume(BigDecimal.ZERO);
            resList.add(kline);
        }
        return resList;
    }

    public List<Kline> buildQuarterPeriod(Map<String, List<TimeseriesResult>> quarterMap, String currency) {
        if (isXueQiu(currency)) {
            return xueQiuDataService.buildOneMonthPeriod(currency);
        }
        List<Kline> resList = new ArrayList<>();
        for (List<TimeseriesResult> list : quarterMap.values()) {
            BigDecimal high = list.stream().map(TimeseriesResult::getHigh).filter(Objects::nonNull).max(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
            BigDecimal low = list.stream().map(TimeseriesResult::getLow).filter(Objects::nonNull).min(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
            Kline kline = new Kline();
            kline.setSymbol(currency);
            kline.setPeriod(Kline.PERIOD_QUARTER);
            // 毫秒
            kline.setTs(UTCDateUtils.toDate(list.get(list.size() - 1).getDate()).getTime());
            kline.setOpen(list.get(0).getOpen());
            kline.setClose(list.get(list.size() - 1).getClose());
            kline.setHigh(high);
            kline.setLow(low);
            kline.setVolume(BigDecimal.ZERO);
            resList.add(kline);
        }
        return resList;
    }

    public List<Kline> buildYearPeriod(Map<String, List<TimeseriesResult>> yearMap, String currency) {
        if (isXueQiu(currency)) {
            return xueQiuDataService.buildOneMonthPeriod(currency);
        }
        List<Kline> resList = new ArrayList<>();
        for (List<TimeseriesResult> list : yearMap.values()) {
            BigDecimal high = list.stream().map(TimeseriesResult::getHigh).filter(Objects::nonNull).max(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
            BigDecimal low = list.stream().map(TimeseriesResult::getLow).filter(Objects::nonNull).min(BigDecimal::compareTo).orElse(BigDecimal.ZERO);
            Kline kline = new Kline();
            kline.setSymbol(currency);
            kline.setPeriod(Kline.PERIOD_YEAR);
            // 毫秒
            kline.setTs(UTCDateUtils.toDate(list.get(list.size() - 1).getDate()).getTime());
            kline.setOpen(list.get(0).getOpen());
            kline.setClose(list.get(list.size() - 1).getClose());
            kline.setHigh(high);
            kline.setLow(low);
            kline.setVolume(BigDecimal.ZERO);
            resList.add(kline);
        }
        return resList;
    }

    /**
     * Hourly
     * 4hourly 3月
     */
    public List<Kline> getTimeseriesForFourHourly(String currency) {
        List<Kline> resList = new ArrayList<>();
        // 每次只能取一个月的数据，需要遍历3个月
        for (int i = 0; i < TraderMadeOptions.fourHourlyPeriod; i++) {
            String resultStr = null;
            try {
                resultStr = getTradeKline(currency,AllticktradeMadeOptions.fourHourPeriod,AllticktradeMadeOptions.dayKlineNumPeriod);
            } catch (Exception e) {
                logger.error("采集外汇k线图失败:{} ", e);
                continue;
            }
            JSONObject resultJson = JSON.parseObject(resultStr);
            if(null == resultJson || 200 != resultJson.getInteger("ret")){
                logger.error("采集外汇k线图失败，返回:{} ", resultStr);
            }
            JSONObject tempdata = resultJson.getJSONObject("data");
            JSONArray dataArray = tempdata.getJSONArray("kline_list");
            if (dataArray.size() > 0) {
                List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
                for (AllticktradeResult result : list) {
                    Kline kline = new Kline();
                    kline.setSymbol(currency);
                    kline.setPeriod(Kline.PERIOD_4HOUR);
                    // 毫秒
                    kline.setTs(Long.parseLong(result.getTimestamp()));
                    kline.setOpen(result.getOpen_price());
                    kline.setClose(result.getClose_price());
                    kline.setHigh(result.getHigh_price());
                    kline.setLow(result.getLow_price());
                    kline.setVolume(result.getVolume());
                    resList.add(kline);
                }
            }
        }
        return resList;
    }

    /**
     * Hourly
     * 1hourly 1月
     */
    public List<Kline> getTimeseriesForOneHourly(String currency) {
        List<Kline> resList = new ArrayList<>();
        String resultStr = null;
        try {
            resultStr = getTradeKline(currency,AllticktradeMadeOptions.hourPeriod,AllticktradeMadeOptions.dayKlineNumPeriod);
        } catch (Exception e) {
            logger.error("采集外汇k线图失败:{} ", e);
        }
        JSONObject resultJson = JSON.parseObject(resultStr);
        if(null == resultJson || 200 != resultJson.getInteger("ret")){
            logger.error("采集外汇k线图失败，返回:{} ", resultStr);
        }
        JSONObject tempdata = resultJson.getJSONObject("data");
        JSONArray dataArray = tempdata.getJSONArray("kline_list");
        if (dataArray.size() > 0) {
            List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
            for (AllticktradeResult result : list) {
                Kline kline = new Kline();
                kline.setSymbol(currency);
                kline.setPeriod(Kline.PERIOD_60MIN);
                // 毫秒
                kline.setTs(Long.parseLong(result.getTimestamp()));
                kline.setOpen(result.getOpen_price());
                kline.setClose(result.getClose_price());
                kline.setHigh(result.getHigh_price());
                kline.setLow(result.getLow_price());
                kline.setVolume(result.getVolume());
                resList.add(kline);
            }
        }
        return resList;
    }

    @Override
    public List<Kline> getTimeseriesForTwoHourly(String currency) {
        List<Kline> resList = new ArrayList<>();
        String resultStr = null;
        for (int i = 0; i < TraderMadeOptions.fifteenMinutePeriod; i++) {
            try {
                resultStr = getTradeKline(currency, AllticktradeMadeOptions.towHourPeriod, AllticktradeMadeOptions.dayKlineNumPeriod);
            } catch (Exception e) {
                logger.error("采集外汇k线图失败:{} ", e);
            }
            JSONObject resultJson = JSON.parseObject(resultStr);
            if (null == resultJson || 200 != resultJson.getInteger("ret")) {
                logger.error("采集外汇k线图失败，返回:{} ", resultStr);
            }
            JSONObject tempdata = resultJson.getJSONObject("data");
            JSONArray dataArray = tempdata.getJSONArray("kline_list");
            if (dataArray.size() > 0) {
                List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
                for (AllticktradeResult result : list) {
                    Kline kline = new Kline();
                    kline.setSymbol(currency);
                    kline.setPeriod(Kline.PERIOD_2HOUR);
                    // 毫秒
                    kline.setTs(Long.parseLong(result.getTimestamp()));
                    kline.setOpen(result.getOpen_price());
                    kline.setClose(result.getClose_price());
                    kline.setHigh(result.getHigh_price());
                    kline.setLow(result.getLow_price());
                    kline.setVolume(result.getVolume());
                    resList.add(kline);
                }
            }
        }
        return resList;
    }

    /**
     * Minute
     * 30minute 10天
     * 15minute 5天
     * 5minute  2天
     * 1minute  1天
     */
    public List<Kline> getTimeseriesOneMinute(String currency) {
        List<Kline> resList = new ArrayList<>();
        String resultStr = null;
        for (int i = 0; i < TraderMadeOptions.fifteenMinutePeriod; i++) {
            try {
                resultStr = getTradeKline(currency, AllticktradeMadeOptions.minutePeriod, AllticktradeMadeOptions.dayKlineNumPeriod);
            } catch (Exception e) {
                logger.error("采集外汇k线图失败:{} ", e);
            }
            JSONObject resultJson = JSON.parseObject(resultStr);
            if (null == resultJson || 200 != resultJson.getInteger("ret")) {
                logger.error("采集外汇k线图失败，返回:{} ", resultStr);
            }
            JSONObject tempdata = resultJson.getJSONObject("data");
            JSONArray dataArray = tempdata.getJSONArray("kline_list");
            if (dataArray.size() > 0) {
                List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
                for (AllticktradeResult result : list) {
                    Kline kline = new Kline();
                    kline.setSymbol(currency);
                    kline.setPeriod(Kline.PERIOD_1MIN);
                    // 毫秒
                    kline.setTs(Long.parseLong(result.getTimestamp()));
                    kline.setOpen(result.getOpen_price());
                    kline.setClose(result.getClose_price());
                    kline.setHigh(result.getHigh_price());
                    kline.setLow(result.getLow_price());
                    kline.setVolume(result.getVolume());
                    resList.add(kline);
                }
            }
        }
        return resList;
    }

    /**
     * Minute
     * 30minute 10天
     * 15minute 5天
     * 5minute  2天
     * 1minute  1天
     */
    public List<Kline> getTimeseriesFiveMinute(String currency) {
        List<Kline> resList = new ArrayList<>();
        String resultStr = null;
        for (int i = 0; i < TraderMadeOptions.fifteenMinutePeriod; i++) {
            try {
                resultStr = getTradeKline(currency, AllticktradeMadeOptions.fivePeriod, AllticktradeMadeOptions.dayKlineNumPeriod);
            } catch (Exception e) {
                logger.error("采集外汇k线图失败:{} ", e);
            }
            JSONObject resultJson = JSON.parseObject(resultStr);
            if (null == resultJson || 200 != resultJson.getInteger("ret")) {
                logger.error("采集外汇k线图失败，返回:{} ", resultStr);
            }
            JSONObject tempdata = resultJson.getJSONObject("data");
            JSONArray dataArray = tempdata.getJSONArray("kline_list");
            if (dataArray.size() > 0) {
                List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
                for (AllticktradeResult result : list) {
                    Kline kline = new Kline();
                    kline.setSymbol(currency);
                    kline.setPeriod(Kline.PERIOD_5MIN);
                    // 毫秒
                    kline.setTs(Long.parseLong(result.getTimestamp()));
                    kline.setOpen(result.getOpen_price());
                    kline.setClose(result.getClose_price());
                    kline.setHigh(result.getHigh_price());
                    kline.setLow(result.getLow_price());
                    kline.setVolume(result.getVolume());
                    resList.add(kline);
                }
            }
        }
        return resList;
    }

    /**
     * Minute
     * 30minute 10天
     * 15minute 5天
     * 5minute  2天
     * 1minute  1天
     */
    public List<Kline> getTimeseriesFifteenMinute(String currency) {
        List<Kline> resList = new ArrayList<>();
        String resultStr = null;
        for (int i = 0; i < TraderMadeOptions.fifteenMinutePeriod; i++) {
            try {
                resultStr = getTradeKline(currency, AllticktradeMadeOptions.fifteenPeriod, AllticktradeMadeOptions.dayKlineNumPeriod);
            } catch (Exception e) {
                logger.error("采集外汇k线图失败:{} ", e);
            }
            JSONObject resultJson = JSON.parseObject(resultStr);
            if (null == resultJson || 200 != resultJson.getInteger("ret")) {
                logger.error("采集外汇k线图失败，返回:{} ", resultStr);
            }
            JSONObject tempdata = resultJson.getJSONObject("data");
            JSONArray dataArray = tempdata.getJSONArray("kline_list");
            if (dataArray.size() > 0) {
                List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
                for (AllticktradeResult result : list) {
                    Kline kline = new Kline();
                    kline.setSymbol(currency);
                    kline.setPeriod(Kline.PERIOD_15MIN);
                    // 毫秒
                    kline.setTs(Long.parseLong(result.getTimestamp()));
                    kline.setOpen(result.getOpen_price());
                    kline.setClose(result.getClose_price());
                    kline.setHigh(result.getHigh_price());
                    kline.setLow(result.getLow_price());
                    kline.setVolume(result.getVolume());
                    resList.add(kline);
                }
            }
        }
        return resList;
    }

    /**
     * Minute
     * 30minute 10天
     * 15minute 5天
     * 5minute  2天
     * 1minute  1天
     */
    public List<Kline> getTimeseriesThirtyMinute(String currency) {
        List<Kline> resList = new ArrayList<>();
        String resultStr = null;
        for (int i = 0; i < TraderMadeOptions.thirtyMinutePeriod; i++) {
            try {
                resultStr = getTradeKline(currency,AllticktradeMadeOptions.thirtyPeriod,AllticktradeMadeOptions.dayKlineNumPeriod);
            } catch (Exception e) {
                logger.error("采集外汇k线图失败:{} ", e);
            }
            JSONObject resultJson = JSON.parseObject(resultStr);
            if(null == resultJson || 200 != resultJson.getInteger("ret")){
                logger.error("采集外汇k线图失败，返回:{} ", resultStr);
            }
            JSONObject tempdata = resultJson.getJSONObject("data");
            JSONArray dataArray = tempdata.getJSONArray("kline_list");
            if (dataArray.size() > 0) {
                List<AllticktradeResult> list = JSONObject.parseArray(JSONObject.toJSONString(dataArray), AllticktradeResult.class);
                for (AllticktradeResult result : list) {
                    Kline kline = new Kline();
                    kline.setSymbol(currency);
                    kline.setPeriod(Kline.PERIOD_30MIN);
                    // 毫秒
                    kline.setTs(Long.parseLong(result.getTimestamp()));
                    kline.setOpen(result.getOpen_price());
                    kline.setClose(result.getClose_price());
                    kline.setHigh(result.getHigh_price());
                    kline.setLow(result.getLow_price());
                    kline.setVolume(result.getVolume());
                    resList.add(kline);
                }
            }
        }
        return resList;
    }

    public String getTradeKline(String symbol,int type,int num){
        JSONObject json = new JSONObject();
        json.put("trace", UUID.randomUUID().toString());
        JSONObject data = new JSONObject();
        data.put("code", symbol);
        data.put("kline_type", type);
        data.put("kline_timestamp_end", 0);
        data.put("query_kline_num", num);
        json.put("data", data);
        try {
            String url = tradeKline.replace("{1}", URLEncoder.encode(json.toString(), "UTF-8"));
            HttpGet request = new HttpGet(url);
            HttpResponse response = HttpHelper.getHttpclient().execute(request);
            return HttpHelper.responseProc(response);
        } catch (Exception e) {
            logger.error("采集外汇k线图失败:==={} ", symbol);
        }
        return null;
    }
}