package com.xcong.excoin.modules.okxNewPrice.indicator.strategy;

import com.xcong.excoin.modules.okxNewPrice.okxWs.param.TradeRequestParam;
import com.xcong.excoin.modules.okxNewPrice.utils.WsMapBuild;
import lombok.Getter;
import lombok.Setter;
import lombok.extern.slf4j.Slf4j;

import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;

/**
 * 技术指标策略抽象基类，提供通用功能
 */
@Slf4j
@Getter
@Setter
public abstract class AbstractTechnicalIndicatorStrategy implements TechnicalIndicatorStrategy {

    protected static final int MAX_PRICE_HISTORY = 100; // 最大价格历史记录数量
    protected List<BigDecimal> priceHistory = new ArrayList<>();
    protected boolean initialized = false;
    protected String strategyName = ""; // 策略名称

    @Override
    public void initialize() {
        priceHistory.clear();
        initialized = true;
        log.info("策略初始化完成: {}", strategyName);
    }

    @Override
    public void updatePrices(List<BigDecimal> prices) {
        if (!initialized) {
            initialize();
        }
        
        if (prices == null || prices.isEmpty()) {
            return;
        }
        
        // 更新价格历史记录
        priceHistory.addAll(prices);
        
        // 限制价格历史记录数量
        if (priceHistory.size() > MAX_PRICE_HISTORY) {
            priceHistory = priceHistory.subList(priceHistory.size() - MAX_PRICE_HISTORY, priceHistory.size());
        }
        
        log.debug("价格历史记录更新完成，当前数量: {}", priceHistory.size());
    }

    @Override
    public boolean isValid() {
        return initialized;
    }

    /**
     * 创建交易请求参数
     * @param accountName 账户名称
     * @param markPx 当前标记价格
     * @param posSide 仓位方向
     * @param signal 交易信号
     * @return 交易请求参数
     */
    protected TradeRequestParam createTradeRequestParam(String accountName, String markPx, String posSide, TradeSignal signal) {
        TradeRequestParam param = new TradeRequestParam();
        param.setAccountName(accountName);
        param.setMarkPx(markPx);
        param.setPosSide(posSide);
        
        log.info("账户: {}, 价格: {}, 仓位方向: {}, 信号: {}", 
                accountName, markPx, posSide, signal.getName());
        
        return param;
    }

    /**
     * 日志记录交易信号
     * @param accountName 账户名称
     * @param markPx 当前标记价格
     * @param signal 交易信号
     */
    protected void logSignal(String accountName, String markPx, TradeSignal signal) {
        log.info("策略: {}, 账户: {}, 价格: {}, 信号: {}", 
                strategyName, accountName, markPx, signal.getName());
    }
}