Subversion Repositories Integrator Subversion

package br.com.sl.core;

import java.io.File;

import java.io.FileWriter;

import java.io.IOException;

import java.math.BigDecimal;

import java.text.SimpleDateFormat;

import java.util.List;

import br.com.sl.domain.dto.OrdemBinanceDTO;

import br.com.sl.domain.dto.robo.SinalTradeGatilho3;

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

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

public class ExportadorSinalBinance {

    // Ajuste a pasta como preferir

    private static final String PASTA_SINAIS = "D:/Dropbox/BLP/INVESTIMENTOS/DAYTRADE/sinais";

    // Se quiser usar em algum momento para quantidade padrão

    private static final BigDecimal QTDE_PADRAO = BigDecimal.ONE;

    /**

     * Exporta todos os sinais para arquivos CSV,

     * 1 arquivo por sinal, pronto para ser lido por outro serviço.

     */

    public static void exportarSinaisParaPasta(List<SinalTradeGatilho3> sinais) {

        if (sinais == null || sinais.isEmpty()) {

            System.out.println("[BinanceSignalExporter] Nenhum sinal para exportar.");

            return;

        }

        File pasta = new File(PASTA_SINAIS);

        if (!pasta.exists()) {

            boolean ok = pasta.mkdirs();

            if (!ok) {

                System.err.println("[BinanceSignalExporter] Não foi possível criar a pasta: " + PASTA_SINAIS);

                return;

            }

        }

        for (SinalTradeGatilho3 sinal : sinais) {

            try {

                OrdemBinanceDTO payload = converterParaPayloadBinance(sinal);

                String csv = converterParaCsv(payload);

                String nomeArquivo = montarNomeArquivoCsv(pasta, payload, sinal);

                gravarArquivo(nomeArquivo, csv);

            } catch (Exception e) {

                System.err.println("[BinanceSignalExporter] Erro ao exportar sinal: " + e.getMessage());

                e.printStackTrace();

            }

        }

    }

    /**

     * Converte um SinalTradeGatilho3 para o payload de ordem "modelo Binance".

     */

    private static OrdemBinanceDTO converterParaPayloadBinance(SinalTradeGatilho3 sinal) {

        OrdemBinanceDTO p = new OrdemBinanceDTO();

        // 1) Symbol da Binance

        String symbol = mapearParaSymbolBinance(sinal);

        // 2) Side -> BUY ou SELL

        String side = sinal.getTipoOperacao() == TipoSinal.COMPRA_C ? "BUY" : "SELL";

        // 3) Tipo de ordem – exemplo LIMIT padrão

        String type = "LIMIT";

        String timeInForce = "GTC";

        // 4) Quantidade – usa contratosTotais, mas pode ajustar

        BigDecimal quantity = BigDecimal.valueOf(sinal.getContratosTotais());

        // 5) Preço de entrada – Entrada 1 como principal

        BigDecimal price = sinal.getPrecoEntrada1();

        // 6) Stops e Targets

        BigDecimal stopLoss = sinal.getStopMenos100();

        BigDecimal tp1 = sinal.getAlvo1();

        BigDecimal tp2 = sinal.getAlvo2();

        // 7) ClientOrderId – algo identificável

        Candle g3 = sinal.getGatilho3();

        String dataHora = "";

        if (g3 != null && g3.getDataHora() != null) {

            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd_HHmmss");

            dataHora = sdf.format(g3.getDataHora());   // aqui getDataHora() é Date

        }

        String clientOrderId = "G3_" + symbol + "_" + dataHora + "_c" + sinal.getGatilho3().getContadorCandle();

        p.setSymbol(symbol);

        p.setSide(side);

        p.setType(type);

        p.setTimeInForce(timeInForce);

        p.setQuantity(quantity);

        p.setPrice(price);

        p.setStopLoss(stopLoss);

        p.setTakeProfit1(tp1);

        p.setTakeProfit2(tp2);

        p.setClientOrderId(clientOrderId);

        return p;

    }

    /**

     * Mapeia o ativo interno para o símbolo da Binance.

     */

    private static String mapearParaSymbolBinance(SinalTradeGatilho3 sinal) {

        String nomeAtivo = null;

        if (sinal.getReferencia() != null && sinal.getReferencia().getAtivo() != null) {

            nomeAtivo = sinal.getReferencia().getAtivo().getNome();

        } else if (sinal.getReferencia() != null) {

            nomeAtivo = sinal.getReferencia().getNomeAtivo();

        }

        if (nomeAtivo == null) {

            return "BTCUSDT";

        }

        if (nomeAtivo.equalsIgnoreCase("BTC") || nomeAtivo.equalsIgnoreCase("BTCUSDT")) {

            return "BTCUSDT";

        }

        if (nomeAtivo.equalsIgnoreCase("ETH") || nomeAtivo.equalsIgnoreCase("ETHUSDT")) {

            return "ETHUSDT";

        }

        return nomeAtivo.toUpperCase() + "USDT";

    }

    /**

     * Gera o conteúdo CSV (cabeçalho + linha única).

     * Novo campo: status = "P" (pendente)

     */

    private static String converterParaCsv(OrdemBinanceDTO p) {

        StringBuilder sb = new StringBuilder();

        // Cabeçalho

        sb.append("symbol,side,type,timeInForce,quantity,price,stopLoss,takeProfit1,takeProfit2,clientOrderId,status\n");

        // Linha de dados

        sb.append(escapeCsv(p.getSymbol())).append(",");

        sb.append(escapeCsv(p.getSide())).append(",");

        sb.append(escapeCsv(p.getType())).append(",");

        sb.append(escapeCsv(p.getTimeInForce())).append(",");

        sb.append(p.getQuantity()).append(",");

        sb.append(p.getPrice()).append(",");

        sb.append(p.getStopLoss()).append(",");

        sb.append(p.getTakeProfit1()).append(",");

        sb.append(p.getTakeProfit2()).append(",");

        sb.append(escapeCsv(p.getClientOrderId())).append(",");

        sb.append("P"); // status pendente

        sb.append("\n");

        return sb.toString();

    }

    /**

     * Escapa campos texto para CSV básico.

     */

    private static String escapeCsv(String s) {

        if (s == null) return "";

        // Se tiver vírgula, aspas ou quebra de linha, envolve em aspas e escapa aspas

        boolean precisaAspas = s.contains(",") || s.contains("\"") || s.contains("\n") || s.contains("\r");

        String valor = s.replace("\"", "\"\"");

        return precisaAspas ? "\"" + valor + "\"" : valor;

    }

    /**

     * Monta nome de arquivo: BINANCE_SIGNAL_<symbol>_<clientOrderId>.csv

     */

    private static String montarNomeArquivoCsv(File pasta, OrdemBinanceDTO payload, SinalTradeGatilho3 sinal) {

        String symbol = payload.getSymbol();

        String clientId = payload.getClientOrderId();

        String nome = "BINANCE_SIGNAL_" + symbol + "_" + clientId + ".csv";

        return new File(pasta, nome).getAbsolutePath();

    }

    private static void gravarArquivo(String caminho, String conteudo) throws IOException {

        try (FileWriter fw = new FileWriter(caminho, false)) {

            fw.write(conteudo);

        }

        System.out.println("[BinanceSignalExporter] Arquivo CSV criado: " + caminho);

    }

}