diff --git a/src/com/rjconsultores/ventaboletos/service/FiscalService.java b/src/com/rjconsultores/ventaboletos/service/FiscalService.java index fed11f87a..29bce88e4 100644 --- a/src/com/rjconsultores/ventaboletos/service/FiscalService.java +++ b/src/com/rjconsultores/ventaboletos/service/FiscalService.java @@ -1,7 +1,6 @@ package com.rjconsultores.ventaboletos.service; import java.io.File; -import java.sql.Connection; import java.sql.SQLException; import java.util.Date; import java.util.HashMap; @@ -47,12 +46,12 @@ public interface FiscalService { public File buscarArquivoExportacaoRMD(Date value, Date value2, Empresa empresa, Estado estado, String nomeArquivo); - public List getRegistroImpressaoRMDTipoDVB(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio); + public List getRegistroImpressaoRMDTipoDVB(Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio); - public List getRegistroImpressaoRMDTipoECF(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio); + public List getRegistroImpressaoRMDTipoECF(Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio); - public void gravarRMDBoleto(Connection connection, List rmds, Aidf aidf, String folio); + public void gravarRMDBoleto(List rmds, Aidf aidf, String folio); - public void cancelarRMDBoleto(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, Aidf aidf, String folio); + public void cancelarRMDBoleto(Date inicio, Date fim, Empresa empresa, Estado estado, Aidf aidf, String folio); } diff --git a/src/com/rjconsultores/ventaboletos/service/impl/FiscalServiceImpl.java b/src/com/rjconsultores/ventaboletos/service/impl/FiscalServiceImpl.java index 4618dd477..489fff32c 100644 --- a/src/com/rjconsultores/ventaboletos/service/impl/FiscalServiceImpl.java +++ b/src/com/rjconsultores/ventaboletos/service/impl/FiscalServiceImpl.java @@ -91,23 +91,85 @@ public class FiscalServiceImpl implements FiscalService { } @Override - public void gravarRMDBoleto(Connection connection, List rmds, Aidf aidf, String folio) { - fiscalDAO.gravarRMDBoleto(connection, rmds, aidf, folio); + public void gravarRMDBoleto(List rmds, Aidf aidf, String folio) { + Connection connection = null; + try { + connection = getConnection(); + fiscalDAO.gravarRMDBoleto(connection, rmds, aidf, folio); + } catch (Exception e) { + log.error(e.getMessage(), e); + } finally { + try { + if (connection != null && !connection.isClosed()) { + connection.close(); + } + } catch (SQLException e) { + log.error("error fechar conexão", e); + throw new RuntimeException(e); + } + } } @Override - public void cancelarRMDBoleto(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, Aidf aidf, String folio) { - fiscalDAO.cancelarRMDBoleto(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), aidf, folio); + public void cancelarRMDBoleto(Date inicio, Date fim, Empresa empresa, Estado estado, Aidf aidf, String folio) { + Connection connection = null; + try { + connection = getConnection(); + fiscalDAO.cancelarRMDBoleto(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), aidf, folio); + } catch (Exception e) { + log.error(e.getMessage(), e); + } finally { + try { + if (connection != null && !connection.isClosed()) { + connection.close(); + } + } catch (SQLException e) { + log.error("error fechar conexão", e); + throw new RuntimeException(e); + } + } } @Override - public List getRegistroImpressaoRMDTipoDVB(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio) { - return fiscalDAO.getRegistroImpressaoRMDTipoDVB(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), rmd, folio); + public List getRegistroImpressaoRMDTipoDVB(Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio) { + Connection connection = null; + try { + connection = getConnection(); + return fiscalDAO.getRegistroImpressaoRMDTipoDVB(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), rmd, folio); + } catch (Exception e) { + log.error(e.getMessage(), e); + } finally { + try { + if (connection != null && !connection.isClosed()) { + connection.close(); + } + } catch (SQLException e) { + log.error("error fechar conexão", e); + throw new RuntimeException(e); + } + } + return null; } @Override - public List getRegistroImpressaoRMDTipoECF(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio) { - return fiscalDAO.getRegistroImpressaoRMDTipoECF(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), rmd, folio); + public List getRegistroImpressaoRMDTipoECF(Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio) { + Connection connection = null; + try { + connection = getConnection(); + return fiscalDAO.getRegistroImpressaoRMDTipoECF(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), rmd, folio); + } catch (Exception e) { + log.error(e.getMessage(), e); + } finally { + try { + if (connection != null && !connection.isClosed()) { + connection.close(); + } + } catch (SQLException e) { + log.error("error fechar conexão", e); + throw new RuntimeException(e); + } + } + return null; } @Override