package com.yami.trading.huobi.task;

import com.yami.trading.bean.data.domain.Depth;
import com.yami.trading.bean.data.domain.Trade;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.huobi.data.DataCache;
import com.yami.trading.huobi.data.internal.DepthTimeObject;
import com.yami.trading.huobi.data.internal.TradeTimeObject;
import com.yami.trading.huobi.hobi.HobiDataService;
import com.yami.trading.service.item.ItemService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.List;

/**
 * 加密货币 定时器
 *
 * @author Jerry
 * @date 2023/11/12
 */
@Component
@Lazy(value = false)
@Slf4j
public class CryptoCurrencyDataTask {
    @Resource
    ItemService itemService;

    @Resource
    HobiDataService hobiDataService;

    private volatile boolean isHuobiInit = false;

    /**
     * 深度数据、近期交易记录 火币采集任务
     */
    @Async
    @Scheduled(cron = "*/3 * * * * ?")
    public void DepthTradeCollectionTask() {
        try {
            List<Item> items = itemService.findByType(Item.cryptos);
            for (Item item : items) {
                // 暂不使用
//                boolean isOpen = MarketOpenChecker.isMarketOpenByItemCloseType(item.getOpenCloseType());
//                if (isHuobiInit && !isOpen) {
//                    log.warn("---> CryptoCurrencyDataTask.DepthTradeCollectionTask 当前 symbol:{} 对应的股票处于未开盘状态，" +
//                            "忽略采集的深度数据", item.getSymbol());
//                    continue;
//                }

                collection(item);
            }
            isHuobiInit = true;
        } catch (Throwable e) {
            log.error("深度数据、近期交易记录 火币采集任务，异常信息：", e);
        }
    }

    private void collection(Item item) {
        Depth depth = hobiDataService.depthDecorator(item.getRemarks(), 0);
        if (depth != null) {
            DepthTimeObject timeObject = new DepthTimeObject();
            timeObject.setDepth(depth);
            DataCache.putDepth(item.getSymbol(), timeObject);
        }

        Trade trade = hobiDataService.tradeDecorator(item.getRemarks(), 0);
        if (trade != null) {
            TradeTimeObject timeObject = new TradeTimeObject();
            timeObject.put(item.getSymbol(), trade.getData());
            DataCache.putTrade(item.getSymbol(), timeObject);
        }
    }

}