WebSVN - Integrator Subversion - Diff - Rev 771 and 775 - /projeto-trade/stocklifepro/src/main/java/br/com/sl/core/ExcelProfitHistoricoDataProvider.java

 package br.com.sl.core;
+import java.io.BufferedReader;
 import java.io.FileInputStream;
 import java.io.IOException;
-import java.io.InputStream;
 import java.math.BigDecimal;
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
 import java.nio.file.Path;
-import java.text.SimpleDateFormat;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
-import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Collections;
-import java.util.Date;
 import java.util.List;
 import java.util.Locale;
 import java.util.Map;
+import java.util.stream.Stream;
 import org.apache.poi.EncryptedDocumentException;
-import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
 import org.apache.poi.ss.usermodel.Cell;
-import org.apache.poi.ss.usermodel.CellType;
-import org.apache.poi.ss.usermodel.DateUtil;
 import org.apache.poi.ss.usermodel.Row;
 import org.apache.poi.ss.usermodel.Sheet;
 import org.apache.poi.ss.usermodel.Workbook;
-import org.apache.poi.ss.usermodel.WorkbookFactory;
 import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import br.com.kronus.core.Timeframe;
 import br.com.sl.domain.dto.robo.ProfitTick;
 import br.com.sl.domain.model.Candle;
-import br.com.sl.domain.model.tipos.TipoPeriodo;
 import br.com.sl.domain.model.tipos.TipoPeriodoCandle;
 import br.com.sl.shared.ExcelDataUtils;
 public class ExcelProfitHistoricoDataProvider implements ProfitDataProvider {
-        private final Path excelFile;
+    private final Path excelFile; // agora pode ser arquivo OU pasta
     private final String sheetName;
-        private static final DateTimeFormatter STRING_DATA_FORMATTER = DateTimeFormatter.ofPattern("dd/MM/yyyy HH:mm:ss");
-    private static final DateTimeFormatter STRING_DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("dd-MM-yyyy HH:mm:ss");
+    private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern("dd/MM/yyyy");
+    private static final DateTimeFormatter TIME_FORMAT = DateTimeFormatter.ofPattern("HH:mm:ss");
     public ExcelProfitHistoricoDataProvider(Path excelFile, String sheetName) {
         this.excelFile = excelFile;
         this.sheetName = sheetName;
+    }
     @Override
     public Map<String, ProfitTick> readCurrentTicks() {
-        // TODO Auto-generated method stub
-        return null;
+        // TODO Auto-generated method stub
+        return null;
+    }
     /**
-     * Lê o arquivo Excel dentro do resources.
-     * Exemplo de uso:
-     *    lerCandles("/dados/Dados Trade 20251117.xlsx");
-     * @throws IOException
+     * Lê um ou vários arquivos:
+     * - Se excelFile for um arquivo: lê apenas esse arquivo (.xlsx, .xls ou .csv)
+     * - Se excelFile for uma pasta: lê todos os .xlsx, .xls e .csv da pasta.
      */
     public List<Candle> lerCandles() throws IOException {
         List<Candle> candles = new ArrayList<>();
-        try (FileInputStream fis = new FileInputStream(excelFile.toFile()); Workbook workbook = new XSSFWorkbook(fis)) {
+        if (Files.isDirectory(excelFile)) {
+            // Percorre todos os arquivos da pasta
+            try (Stream<Path> stream = Files.list(excelFile)) {
+                stream
+                    .filter(Files::isRegularFile)
+                    .filter(p -> {
+                        String name = p.getFileName().toString().toLowerCase(Locale.ROOT);
+                        return name.endsWith(".xlsx") || name.endsWith(".xls") || name.endsWith(".csv");
+                    })
+                    .forEach(path -> {
+                        try {
+                            lerCandlesDeArquivo(path, candles);
+                        } catch (IOException e) {
+                            // aqui você pode trocar por log
+                            e.printStackTrace();
+                        }
+                    });
+            }
+        } else {
+            // Apenas um arquivo
+            lerCandlesDeArquivo(excelFile, candles);
+        }
+        return adicionarContadores(inverterLista(candles));
+    }
+    /**
+     * Decide se o arquivo é Excel ou CSV e delega para o método correto.
+     */
+    private void lerCandlesDeArquivo(Path arquivo, List<Candle> candles) throws IOException {
+        String name = arquivo.getFileName().toString().toLowerCase(Locale.ROOT);
+        if (name.endsWith(".xlsx") || name.endsWith(".xls")) {
+            lerCandlesDeArquivoExcel(arquivo, candles);
+        } else if (name.endsWith(".csv")) {
+            lerCandlesDeArquivoCsv(arquivo, candles);
+        } else {
+            // Tipo não suportado, ignora ou loga
+        }
+    }
+    /**
+     * Lê os candles de UM arquivo Excel e adiciona na lista passada.
+     * (É basicamente o seu código original, só movido para cá)
+     */
+    private void lerCandlesDeArquivoExcel(Path arquivoExcel, List<Candle> candles) throws IOException {
+        try (FileInputStream fis = new FileInputStream(arquivoExcel.toFile());
+             Workbook workbook = new XSSFWorkbook(fis)) {
             int numberOfSheets = workbook.getNumberOfSheets();
             for (int i = 0; i < numberOfSheets; i++) {
                 Sheet sheet = workbook.getSheetAt(i);
                 for (Row row : sheet) {
                     // 0 = Ativo
                     // 1 = Dia
                     // 2 = Hora
                     Cell maximaCell     = row.getCell(4);
                     Cell minimaCell     = row.getCell(5);
                     Cell fechamentoCell = row.getCell(6);
                     if (!ExcelDataUtils.isNumeric(aberturaCell) || !ExcelDataUtils.isNumeric(maximaCell)
-                                || !ExcelDataUtils.isNumeric(minimaCell) || !ExcelDataUtils.isNumeric(fechamentoCell)) {
+                            || !ExcelDataUtils.isNumeric(minimaCell) || !ExcelDataUtils.isNumeric(fechamentoCell)) {
                         continue;
+                    }
                     LocalDate data = ExcelDataUtils.lerData(dataCell);
                     LocalTime hora = ExcelDataUtils.lerHora(horaCell);
                     hora = hora.plusMinutes(6).plusSeconds(28);
                     LocalDateTime dataHora = LocalDateTime.of(data, hora);
                     String ativoDescricao = ativoCell.getStringCellValue();
                     BigDecimal abertura = BigDecimal.valueOf(aberturaCell.getNumericCellValue());
                     BigDecimal topo = BigDecimal.valueOf(maximaCell.getNumericCellValue());
                     BigDecimal fundo = BigDecimal.valueOf(minimaCell.getNumericCellValue());
                     BigDecimal fechamento = BigDecimal.valueOf(fechamentoCell.getNumericCellValue());
-                    Candle candle = new Candle(null, ativoDescricao, dataHora, abertura, topo, fundo, fechamento, TipoPeriodoCandle.M1.getValor());
-                        candles.add(candle);
+                    Candle candle = new Candle(
+                            null,
+                            ativoDescricao,
+                            dataHora,
+                            abertura,
+                            topo,
+                            fundo,
+                            fechamento,
+                            TipoPeriodoCandle.M1.getValor()
+                    );
+                    candles.add(candle);
+                }
+            }
         } catch (EncryptedDocumentException e) {
-                        // TODO Auto-generated catch block
-                        e.printStackTrace();
+            e.printStackTrace();
+        }
-        return adicionarContadores(inverterLista(candles));
+    }
+    /**
+     * Lê os candles de UM arquivo CSV e adiciona na lista passada.
+     * Espera layout:
+     * 0 = Ativo
+     * 1 = Dia  (dd/MM/yyyy)
+     * 2 = Hora (HH:mm:ss)
+     * 3 = Abertura
+     * 4 = Máxima
+     * 5 = Mínima
+     * 6 = Fechamento
+     */
+    private void lerCandlesDeArquivoCsv(Path arquivoCsv, List<Candle> candles) throws IOException {
+        try (BufferedReader br = Files.newBufferedReader(arquivoCsv, StandardCharsets.UTF_8)) {
+            String line;
+            while ((line = br.readLine()) != null) {
+                // Substitui line.isBlank() por trim().isEmpty()
+                String trimmed = line.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 = parts[0].trim();
+                String dataStr        = parts[1].trim();
+                String horaStr        = parts[2].trim();
+                String aberturaStr    = parts[3].trim();
+                String maximaStr      = parts[4].trim();
+                String minimaStr      = parts[5].trim();
+                String fechamentoStr  = parts[6].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   = parseBigDecimal(aberturaStr);
+                BigDecimal topo       = parseBigDecimal(maximaStr);
+                BigDecimal fundo      = parseBigDecimal(minimaStr);
+                BigDecimal fechamento = parseBigDecimal(fechamentoStr);
+                Candle candle = new Candle(
+                        null,
+                        ativoDescricao,
+                        dataHora,
+                        abertura,
+                        topo,
+                        fundo,
+                        fechamento,
+                        TipoPeriodoCandle.M1.getValor()
+                );
+                candles.add(candle);
+            }
+        }
+    }
+    private BigDecimal parseBigDecimal(String value) {
+        if (value == null) return null;
+        String normalized = value.trim().replace(".", "").replace(",", ".");
+        // Se o Profit já exportar com ponto como separador decimal, remova o replace(".","")
+        // e deixe apenas: value.trim().replace(",", ".")
+        if (normalized.isEmpty()) return null;
+        return new BigDecimal(normalized);
+    }
+    private 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;
+        }
+    }
     public static List<Candle> inverterLista(List<Candle> candles) {
         List<Candle> invertida = new ArrayList<>(candles);
         Collections.reverse(invertida);
         return invertida;
+    }
     public static List<Candle> adicionarContadores(List<Candle> candles) {
         Integer contador = 1;
-        List<Candle> comContadores = new ArrayList<>();
+        List<Candle> comContadores = new ArrayList<>();
         for (Candle candle : candles) {
-                candle.setContadorCandle(contador);
-                comContadores.add(candle);
-                contador++;
+            candle.setContadorCandle(contador);
+            comContadores.add(candle);
+            contador++;
+        }
         return comContadores;
+    }
     /**
      * 1 minuto = 1, 5 minutos = 2, 15 minutos = 3, 1 dia = 4
      */
     private Timeframe resolveTipoTemporizador(String sheetName) {
         if (sheetName == null) return null;
         if (name.startsWith("1 DIA"))  return Timeframe.D1;
         return null;
+    }
 }

Subversion Repositories Integrator Subversion

(root)/projeto-trade/stocklifepro/src/main/java/br/com/sl/core/ExcelProfitHistoricoDataProvider.java - Rev 771 → 775