Subversion Repositories Integrator Subversion

package br.com.sl.core;

import java.io.BufferedReader;

import java.io.InputStream;

import java.math.BigDecimal;

import java.time.LocalDate;

import java.time.LocalDateTime;

import java.time.LocalTime;

import java.time.format.DateTimeFormatter;

import java.util.ArrayList;

import java.util.Collections;

import java.util.List;

import java.util.Map;

import br.com.sl.domain.model.Candle;

import br.com.sl.domain.model.tipos.TipoPeriodoCandle;

import br.com.sl.domain.util.BigDecimalUtils;

public class ProfitDataProviderUtil {

        private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("dd/MM/yyyy");

    private static final DateTimeFormatter TIME_FORMAT = DateTimeFormatter.ofPattern("HH:mm:ss");

    public ProfitDataProviderUtil() {}

    public static List<Candle> lerCandlesDeArquivo(BufferedReader reader, String nomeArquivo) throws Exception {

        if (nomeArquivo.toLowerCase().endsWith(".csv")) {

            return lerCsv(reader);

        } else if (nomeArquivo.toLowerCase().endsWith(".xlsm") || nomeArquivo.toLowerCase().endsWith(".xlsx") || nomeArquivo.toLowerCase().endsWith(".xls")) {

                return null;

//              return lerExcel(reader);

        } else {

            throw new IllegalArgumentException("Formato não suportado: " + nomeArquivo);

        }

    }

    private static List<Candle> lerCsv(BufferedReader reader) throws Exception {

        List<Candle> candles = new ArrayList<>();

        String linha;

        while ((linha = reader.readLine()) != null) {

            // Substitui line.isBlank() por trim().isEmpty()

            String trimmed = linha.trim();

            if (trimmed.isEmpty()) {

                continue;

            }

            // Ajuste aqui se o separador do seu CSV for vírgula

            String[] parts = trimmed.split(";", -1);

            if (parts.length < 7) {

                continue;

            }

            String ativoDescricao = "";

            String dataStr        = "";

            String horaStr        = "";

            String aberturaStr    = "";

            String maximaStr      = "";

            String minimaStr      = "";

            String fechamentoStr  = "";

            ativoDescricao = parts[0].trim();

            dataStr        = parts[1].trim();

            if (parts.length >= 9) {

                horaStr        = parts[2].trim();

                aberturaStr    = parts[3].trim();

                maximaStr      = parts[4].trim();

                minimaStr      = parts[5].trim();

                fechamentoStr  = parts[6].trim();

            } else {

                horaStr        = "18:00:00";

                aberturaStr    = parts[2].trim();

                maximaStr      = parts[3].trim();

                minimaStr      = parts[4].trim();

                fechamentoStr  = parts[5].trim();

            }

            // Ignora header, caso exista

            if (ativoDescricao.equalsIgnoreCase("ativo")) {

                continue;

            }

            if (!isNumericString(aberturaStr) ||

                !isNumericString(maximaStr)   ||

                !isNumericString(minimaStr)   ||

                !isNumericString(fechamentoStr)) {

                continue;

            }

            LocalDate data = LocalDate.parse(dataStr, DATE_FORMAT);

            LocalTime hora = LocalTime.parse(horaStr, TIME_FORMAT);

            LocalDateTime dataHora = LocalDateTime.of(data, hora);

            BigDecimal abertura   = BigDecimalUtils.converterStringEmBigDecimal(aberturaStr);

            BigDecimal topo       = BigDecimalUtils.converterStringEmBigDecimal(maximaStr);

            BigDecimal fundo      = BigDecimalUtils.converterStringEmBigDecimal(minimaStr);

            BigDecimal fechamento = BigDecimalUtils.converterStringEmBigDecimal(fechamentoStr);

            Candle candle = new Candle(

                    null,

                    ativoDescricao,

                    dataHora,

                    abertura,

                    topo,

                    fundo,

                    fechamento,

                    TipoPeriodoCandle.M1.getValor()

            );

            candles.add(candle);

        }

        return adicionarContadores(inverterLista(candles));

    }

    private static boolean isNumericString(String value) {

        if (value == null) return false;

        String normalized = value.trim().replace(".", "").replace(",", ".");

        if (normalized.isEmpty()) return false;

        try {

            new BigDecimal(normalized);

            return true;

        } catch (NumberFormatException e) {

            return false;

        }

    }

    // Contador separado para cada ativo

    public static List<Candle> adicionarContadores(List<Candle> candles) {

        Map<String, Integer> contadorPorAtivo = new java.util.HashMap<>();

        List<Candle> comContadores = new ArrayList<>();

        for (Candle candle : candles) {

            // Ajuste aqui o getter conforme estiver na sua classe Candle

            // Ex.: getAtivo(), getAtivoDescricao(), getTicker()...

            String ativo = candle.getNomeAtivo();

            Integer contadorAtual = contadorPorAtivo.get(ativo);

            if (contadorAtual == null) {

                contadorAtual = 0;

            }

            contadorAtual++;

            contadorPorAtivo.put(ativo, contadorAtual);

            candle.setContadorCandle(contadorAtual);

            comContadores.add(candle);

        }

        return comContadores;

    }

    public static List<Candle> inverterLista(List<Candle> candles) {

        List<Candle> invertida = new ArrayList<>(candles);

        Collections.reverse(invertida);

        return invertida;

    }

    private static List<Candle> lerExcel(InputStream is) throws Exception {

        /*

        List<Candle> candles = new ArrayList<>();

        Workbook wb = WorkbookFactory.create(is);

        for (int s = 0; s < wb.getNumberOfSheets(); s++) {

            Sheet planilha = wb.getSheetAt(s);

            boolean primeira = true;

            for (Row row : planilha) {

                if (row == null) continue;

                if (primeira) {

                    primeira = false;

                    continue;

                }

                int cols = row.getLastCellNum();

                String[] col = new String[cols];

                for (int i = 0; i < cols; i++) {

                    Cell cell = row.getCell(i);

                    col[i] = (cell == null ? "" : formatarCelula(cell));

                }

                Candle c = converterLinhaEmCandle(col);

                if (c != null) candles.add(c);

            }

        }

        return candles;

        */

        return null;

    }

}