package com.xcong.excoin.modules.okxNewPrice.okxpi.trade;

import com.xcong.excoin.modules.okxNewPrice.utils.FebsException;
import com.xcong.excoin.modules.okxNewPrice.okxpi.config.OKXAccount;
import com.xcong.excoin.modules.okxNewPrice.okxpi.trade.impl.TradeServiceBuy;
import com.xcong.excoin.modules.okxNewPrice.okxpi.trade.impl.TradeServiceClosePosition;
import com.xcong.excoin.modules.okxNewPrice.okxpi.trade.impl.TradeServiceSell;

import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * 交易事件运行类，用于根据不同的事件点选择相应的交易策略并执行
 */
public class TradeEventRunner {

    // 使用线程安全的ConcurrentHashMap存储交易事件和对应的策略服务
    private static final Map<String, TradeService> TRADE_EVENT_MAP = new ConcurrentHashMap<>();

    static {
        // 初始化策略
        List<TradeService> tradeServices = Arrays.asList(
                new TradeServiceBuy(), // 买入策略
                new TradeServiceSell(), // 卖出策略
                new TradeServiceClosePosition() // 平仓策略
        );

        // 将策略放入ConcurrentHashMap中，确保线程安全
        for (TradeService service : tradeServices) {
            TRADE_EVENT_MAP.put(service.tradeEvent(), service);
        }
    }

    /**
     * 根据事件点选择并执行相应的交易策略
     *
     * @param eventPoint 事件点，用于匹配相应的交易策略
     * @param tradeRequest 包含交易请求信息的LinkedHashMap
     * @param okxAccount OKX账户信息，用于执行交易
     * @return 交易执行的结果
     * @throws FebsException 如果找不到对应的交易策略，则抛出异常
     */
    public static String runTradeEvent(String eventPoint, LinkedHashMap<String, Object> tradeRequest, OKXAccount okxAccount) {
        TradeService tradeService = TRADE_EVENT_MAP.get(eventPoint);
        if (tradeService == null) {
            throw new FebsException("交易EVENT异常");
        }

        return tradeService.doTrade(tradeRequest,okxAccount);
    }

}