package com.yami.trading.huobi.task;

import com.yami.trading.huobi.task.contract.ContractApplyOrderHandleJob;
import com.yami.trading.huobi.task.contract.ContractOrderCalculationJob;
import com.yami.trading.huobi.task.future.FuturesOrderCalculationJob;
import com.yami.trading.huobi.task.future.consumer.FuturesRecomConsumeServer;
import com.yami.trading.bean.data.domain.Realtime;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.huobi.data.AdjustmentValueCache;
import com.yami.trading.huobi.data.DataCache;
import com.yami.trading.huobi.data.internal.DataDBService;
import com.yami.trading.huobi.data.internal.KlineInitService;
import com.yami.trading.huobi.data.internal.KlineService;
import com.yami.trading.huobi.data.job.*;
import com.yami.trading.huobi.task.summary.SummaryCrawl;
import com.yami.trading.service.contract.ContractOrderCalculationService;
import com.yami.trading.service.exchange.ExchangeLeverApplyOrderService;
import com.yami.trading.service.exchange.job.ExchangeApplyOrderHandleJob;
import com.yami.trading.service.exchange.job.ExchangeLeverApplyOrderHandleJob;
import com.yami.trading.service.finance.loadcache.FinanceLoadCacheService;
import com.yami.trading.service.future.FuturesLoadCacheService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.system.TipService;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

@Slf4j
@Data
@Component
public class InitHandle implements CommandLineRunner {
    @Autowired
    private KlineInitService klineInitService;
    @Autowired
    protected ItemService itemService;
    @Autowired
    protected SummaryCrawl summaryCrawl;
    @Autowired
    protected DataDBService dataDBService;
    @Autowired
    protected KlineService klineService;
    @Autowired
    protected HighLowHandleJob highLowHandleJob;
    @Autowired
    private KlineCacheJob klineCacheJob;
    @Autowired
    protected StockGetDataJob stockGetDataJob;
    @Autowired
    protected ForexGetDataJob forexGetDataJob;
    @Autowired
    protected CryptosGetDataJob cryptosGetDataJob;
    @Autowired
    protected FakeSymbolGetDataJob fakeSymbolGetDataJob;
    @Autowired
    protected SaveRealtimeServer saveRealtimeServer;
    @Autowired
    private FuturesLoadCacheService futuresLoadCacheService;
    @Autowired
    private FuturesRecomConsumeServer futuresRecomConsumeServer;
    @Autowired
    protected ContractOrderCalculationService contractOrderCalculationService;
    @Autowired
    protected ContractApplyOrderHandleJob contractApplyOrderHandleJob;
    @Autowired
    protected ContractOrderCalculationJob contractOrderCalculationJob;
    @Autowired
    protected SysparaService sysparaService;
    @Autowired
    private RealtimePushJob realtimePushJob;
    @Autowired
    private CleanDataJob cleanDataJob;
    @Autowired
    private StockGetMarketJob stockGetMarketJob;
    /**
     * 交割合约持仓单盈亏计算线程启动
     */
    @Autowired
    private FuturesOrderCalculationJob futuresOrderCalculationJob;
    @Autowired
    protected DepthPushJob depthPushJob;
    @Autowired
    protected TradePushJob tradePushJob;
    @Autowired
    protected DataFrequencyServer dataFrequencyServer;
    @Autowired
    private KlineLoadCache klineLoadCache;

    @Autowired
    ExchangeApplyOrderHandleJob exchangeApplyOrderHandleJob;

    @Autowired
    ExchangeLeverApplyOrderHandleJob exchangeLeverApplyOrderHandleJob;
    @Autowired
    TipService tipService;

    @Autowired
    FinanceLoadCacheService financeLoadCacheService;
    @Override
    public void run(String... args) {
        // 初始化缓存
        //loadCacheService.loadcache();
        tipService.init();
        futuresLoadCacheService.loadcache();
        financeLoadCacheService.loadcache();
        // 已经加了注解
//        minerLoadCacheService.loadcache();
        // todo 先注释观察报错
//		futuresRecomConsumeServer.start();
        log.info("开始Data初始化........");
        List<Item> items = new ArrayList<>(itemService.listWithOutCache());
        for (Item item : items) {
            AdjustmentValueCache.getCurrentValue().put(item.getSymbol(), item.getAdjustmentValue());
        }

        for (Item item : items) {
            Realtime realtime = dataDBService.get(item.getSymbol());
            if (realtime != null) {
                DataCache.putRealtime(item.getSymbol(), realtime);
            }
        }

        for (Item item : items) {
            if(Item.cryptos.equalsIgnoreCase(item.getType())){
                List<Realtime> list = this.dataDBService.findRealtimeOneDay(item.getSymbol());
                DataCache.putCryptosRealtimeHistory(item.getSymbol(), list);
            }

        }

        klineLoadCache.loadCache();
        // 高低修正
        highLowHandleJob.start();
        highLowHandleJob.bulidHighLow();

        stockGetMarketJob.start();
        // 获取realtime实时数据
        stockGetDataJob.start();
        forexGetDataJob.start();
        cryptosGetDataJob.start();
        //fakeSymbolGetDataJob.start();
        // 实时数据批量保存线程
        saveRealtimeServer.start();
        klineCacheJob.start();

        /**
         * 委托单处理线程启动
         */
        contractApplyOrderHandleJob.start();
        /**
         * 持仓单盈亏计算线程启动
         */
        contractOrderCalculationService.setOrder_close_line(this.sysparaService.find("order_close_line").getBigDecimal());
        contractOrderCalculationService.setOrder_close_line_type(this.sysparaService.find("order_close_line_type").getInteger());
        contractOrderCalculationJob.start();

        // todo 做模块判断,后续打开
        futuresOrderCalculationJob.start();

        realtimePushJob.start();
        depthPushJob.start();
        tradePushJob.start();
        dataFrequencyServer.start();
        cleanDataJob.taskJob();
        log.info("完成Data初始化。");

        /**
         * 币币委托单处理线程启动
         */
        exchangeApplyOrderHandleJob.start();
        exchangeLeverApplyOrderHandleJob.start();
        //klineService.clean();
    }
}