From c6ff127860bfcb53e87836f0aa36e92f9a1dd756 Mon Sep 17 00:00:00 2001
From: julio <julio@d1611594-4594-4d17-8e1d-87c2c4800839>
Date: Mon, 29 May 2017 12:05:57 +0000
Subject: [PATCH] bug #8977

git-svn-id: http://desenvolvimento.rjconsultores.com.br/repositorio/sco/AdmVenta/Model/trunk/modelWeb@69389 d1611594-4594-4d17-8e1d-87c2c4800839
---
 .../ventaboletos/service/FiscalService.java   |  9 +--
 .../service/impl/FiscalServiceImpl.java       | 78 +++++++++++++++++--
 2 files changed, 74 insertions(+), 13 deletions(-)

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<ImpressaoRMD> getRegistroImpressaoRMDTipoDVB(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio);
+	public List<ImpressaoRMD> getRegistroImpressaoRMDTipoDVB(Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio);
 
-	public List<ImpressaoRMD> getRegistroImpressaoRMDTipoECF(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio);
+	public List<ImpressaoRMD> getRegistroImpressaoRMDTipoECF(Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio);
 
-	public void gravarRMDBoleto(Connection connection, List<ImpressaoRMD> rmds, Aidf aidf, String folio);
+	public void gravarRMDBoleto(List<ImpressaoRMD> 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<ImpressaoRMD> rmds, Aidf aidf, String folio) {
-		fiscalDAO.gravarRMDBoleto(connection, rmds, aidf, folio);
+	public void gravarRMDBoleto(List<ImpressaoRMD> 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<ImpressaoRMD> 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<ImpressaoRMD> 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<ImpressaoRMD> 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<ImpressaoRMD> 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