julio 2017-05-29 12:05:57 +00:00
parent db0b6b31ad
commit c6ff127860
2 changed files with 74 additions and 13 deletions

View File

@ -1,7 +1,6 @@
package com.rjconsultores.ventaboletos.service; package com.rjconsultores.ventaboletos.service;
import java.io.File; import java.io.File;
import java.sql.Connection;
import java.sql.SQLException; import java.sql.SQLException;
import java.util.Date; import java.util.Date;
import java.util.HashMap; 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 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);
} }

View File

@ -91,23 +91,85 @@ public class FiscalServiceImpl implements FiscalService {
} }
@Override @Override
public void gravarRMDBoleto(Connection connection, List<ImpressaoRMD> rmds, Aidf aidf, String folio) { public void gravarRMDBoleto(List<ImpressaoRMD> rmds, Aidf aidf, String folio) {
Connection connection = null;
try {
connection = getConnection();
fiscalDAO.gravarRMDBoleto(connection, rmds, aidf, folio); 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 @Override
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) {
Connection connection = null;
try {
connection = getConnection();
fiscalDAO.cancelarRMDBoleto(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), aidf, folio); 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 @Override
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) {
Connection connection = null;
try {
connection = getConnection();
return fiscalDAO.getRegistroImpressaoRMDTipoDVB(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), rmd, folio); 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 @Override
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) {
Connection connection = null;
try {
connection = getConnection();
return fiscalDAO.getRegistroImpressaoRMDTipoECF(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), rmd, folio); 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 @Override