Subversion Repositories Integrator Subversion

package br.com.ec.controller;

import java.io.IOException;
import java.io.Serializable;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.ArrayList;
import java.util.List;
import java.util.List;

import javax.annotation.PostConstruct;
import javax.faces.bean.ViewScoped;
import javax.inject.Named;

import br.com.kronus.core.Candle;
import br.com.kronus.core.DetectorGatilhos;
import br.com.kronus.core.PadraoGatilho;
import br.com.kronus.fibo.FibonacciService;
import br.com.kronus.strategy.EstrategiaGatilhoTipo3;
import br.com.kronus.strategy.ResultadoEstrategiaGatilho3;
import br.com.robo.sim.CandleExcelReader;

@Named
@ViewScoped
public class AnaliseTempoRealBean implements Serializable {

    private static final long serialVersionUID = 1L;

    // Lista completa de candles lidos do Excel (histórico)
    private List<Candle> candlesExcel;

    // Lista dos candles já "liberados" na simulação em tempo real
    private List<Candle> candlesProcessados;

    // Controle de índice do próximo candle a ser analisado
    private int proximoIndice;

    // Detector de padrões de gatilhos (GR, G1, G2, G3, G4)
    private DetectorGatilhos detector;

    // Estratégia específica do Gatilho Tipo 3
    private EstrategiaGatilhoTipo3 estrategiaGatilhoTipo3;

    // Resultados das operações/ simulações da estratégia
    private List<ResultadoEstrategiaGatilho3> resultadosEstrategia;

    // Mensagem de status para exibir no dashboard
    private String statusMensagem;

    // Flag para saber se já terminou de analisar todo o arquivo
    private boolean analiseConcluida;

    // Caminho ou nome do recurso do Excel
    private String caminhoExcel = "/dados.xls";

    @PostConstruct
    public void init() {
        this.candlesProcessados = new ArrayList<>();
        this.resultadosEstrategia = new ArrayList<>();
        this.proximoIndice = 0;
        this.analiseConcluida = false;

        // Detector com logs ativados (se quiser desligar, use false)
        this.detector = new DetectorGatilhos(true);

        // Estratégia do gatilho 3
        FibonacciService fiboService = new FibonacciService();
        this.estrategiaGatilhoTipo3 = new EstrategiaGatilhoTipo3(fiboService);

        carregarCandlesDoExcel();
    }

    /**
     * Lê todos os candles do Excel (histórico completo).
     * Aqui você ajusta o LeitorExcelCandles conforme sua implementação.
     */
    private void carregarCandlesDoExcel() {
        try {
                CandleExcelReader reader = new CandleExcelReader();
            try {
                List<Candle> candles = reader.lerCandles(caminhoExcel);
                System.out.println("Qtd candles lidos: " + candles.size());
                this.candlesExcel = candles;
            } catch (IOException e) {
                e.printStackTrace();
            }

            if (candlesExcel == null || candlesExcel.isEmpty()) {
                statusMensagem = "Nenhum candle encontrado no Excel.";
                analiseConcluida = true;
            } else {
                statusMensagem = "Arquivo carregado. Total de candles: " + candlesExcel.size();
            }
        } catch (Exception e) {
            e.printStackTrace();
            statusMensagem = "Erro ao carregar candles do Excel: " + e.getMessage();
            analiseConcluida = true;
        }
    }

    /**
     * Método chamado a cada minuto (via p:poll, scheduler, botão, etc.)
     * Simula a chegada de UM novo candle do mercado,
     * executa o detector em modo tempo real,
     * e, ao encontrar um G3, dispara a EstrategiaGatilhoTipo3.
     */
    public void analisarEmTempoReal() {
        if (analiseConcluida) {
            // Já processou tudo
            return;
        }

        if (candlesExcel == null || candlesExcel.isEmpty()) {
            statusMensagem = "Sem candles para analisar.";
            analiseConcluida = true;
            return;
        }

        if (proximoIndice >= candlesExcel.size()) {
            statusMensagem = "Todos os candles do arquivo já foram analisados.";
            analiseConcluida = true;
            return;
        }

        // "Chegou" um candle novo
        Candle novoCandle = candlesExcel.get(proximoIndice);
        candlesProcessados.add(novoCandle);
        proximoIndice++;

        statusMensagem = String.format(
                "Novo candle lido: %s | Total processado: %d/%d",
                novoCandle.getTime(),
                proximoIndice,
                candlesExcel.size()
        );

        // Chama o detector em modo tempo real
        PadraoGatilho padrao = detector.processarCandleTempoReal(candlesProcessados);

        if (padrao != null) {
            // Só nos interessa quando tiver Gatilho 3 identificado
            if (padrao.getGatilho3() != null) {
                try {
                    ResultadoEstrategiaGatilho3 resultado =
                            estrategiaGatilhoTipo3.executarEstrategia(padrao, candlesProcessados);

                    resultadosEstrategia.add(resultado);

                    statusMensagem = String.format(
                            "Padrão encontrado! GR: %s | G1: %s | G2: %s | G3: %s | Operação executada.",
                            padrao.getReferencia().getTime(),
                            padrao.getGatilho1().getTime(),
                            padrao.getGatilho2().getTime(),
                            padrao.getGatilho3().getTime()
                    );
                } catch (Exception e) {
                    e.printStackTrace();
                    statusMensagem = "Erro ao executar EstrategiaGatilhoTipo3: " + e.getMessage();
                }
            } else {
                // Encontrou padrão sem G3 (ex: padrão que morre antes de completar)
                statusMensagem = "Padrão identificado sem G3 completo. Aguardando próximo candle.";
            }
        }
    }

    // ============================================================
    // GETTERS / SETTERS para o JSF
    // ============================================================

    public List<Candle> getCandlesProcessados() {
        return candlesProcessados;
    }

    public List<ResultadoEstrategiaGatilho3> getResultadosEstrategia() {
        return resultadosEstrategia;
    }

    public String getStatusMensagem() {
        return statusMensagem;
    }

    public boolean isAnaliseConcluida() {
        return analiseConcluida;
    }

    public String getCaminhoExcel() {
        return caminhoExcel;
    }

    public void setCaminhoExcel(String caminhoExcel) {
        this.caminhoExcel = caminhoExcel;
    }
   
}