diff --git a/src/com/rjconsultores/ventaboletos/dao/ConferenciaComissaoDAO.java b/src/com/rjconsultores/ventaboletos/dao/ConferenciaComissaoDAO.java index 6d8a62104..a2ecb66f8 100644 --- a/src/com/rjconsultores/ventaboletos/dao/ConferenciaComissaoDAO.java +++ b/src/com/rjconsultores/ventaboletos/dao/ConferenciaComissaoDAO.java @@ -48,14 +48,16 @@ public interface ConferenciaComissaoDAO extends GenericDAO { public List carregarLogConferencia(Long conferenciaId) throws BusinessException; - public boolean isConferenciaCompetenciaEncerrada(String competencia, Empresa empresa, Integer puntoVenta) throws BusinessException; + public boolean isConferenciaCompetenciaEncerrada(String competencia, Empresa empresa, PuntoVenta puntoVenta) throws BusinessException; public BigDecimal carregarValorDepositoContaCorrente(Integer empresaId, Integer puntoventaId, Date datamovimento); - public DiaConferenciaComissaoVO carregarConferenciaRegistrada(Date datamovimento, Empresa empresa, Integer puntoVenta) throws BusinessException; + public DiaConferenciaComissaoVO carregarConferenciaRegistrada(Date datamovimento, Empresa empresa, PuntoVenta puntoVenta) throws BusinessException; public Conferencia cancelarChegadaMalote(Conferencia conferencia); public boolean isConferidoVenta(BoletoComissao boletoComissao); + + public void borrarLogConferenciaTransacaoId(Long transacaoId) throws BusinessException; } diff --git a/src/com/rjconsultores/ventaboletos/dao/hibernate/ConferenciaComissaoHibernateDAO.java b/src/com/rjconsultores/ventaboletos/dao/hibernate/ConferenciaComissaoHibernateDAO.java index d0cd9d30a..1300b003d 100644 --- a/src/com/rjconsultores/ventaboletos/dao/hibernate/ConferenciaComissaoHibernateDAO.java +++ b/src/com/rjconsultores/ventaboletos/dao/hibernate/ConferenciaComissaoHibernateDAO.java @@ -46,6 +46,7 @@ import com.rjconsultores.ventaboletos.enums.comissao.StatusLogConferencia; import com.rjconsultores.ventaboletos.exception.BusinessException; import com.rjconsultores.ventaboletos.utilerias.ApplicationProperties; import com.rjconsultores.ventaboletos.utilerias.DateUtil; +import com.rjconsultores.ventaboletos.utilerias.UsuarioLogado; import com.rjconsultores.ventaboletos.vo.comissao.BoletoComissao; import com.rjconsultores.ventaboletos.vo.comissao.ConferenciaComissaoVO; import com.rjconsultores.ventaboletos.vo.comissao.DiaConferenciaComissaoVO; @@ -81,26 +82,16 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO lsConferenciasFiltro = new ArrayList(); - carregarPuntoVentas(lsConferenciasFiltro, competencia, empresa, puntoVenta, dataMovimento); - List lsConferenciasTodos = new ArrayList(); + List lsConferencias = new ArrayList(); - for (ConferenciaComissaoVO lsConferenciasTmp : lsConferenciasFiltro) { - List lsConferencias = new ArrayList(); - lsConferencias.add(lsConferenciasTmp); - - ConferenciaComissaoVO vo = lsConferencias.get(0); - carregarConferenciasRegistradas(lsConferencias, competencia, empresa, vo.getPuntoventaId(), dataMovimento, null); - carregarMovimentoVendas(con, lsConferencias, competencia, empresa, vo.getPuntoventaId(), dataMovimento, null, null); - carregarDiasSemMovimento(lsConferencias, competencia, empresa, vo.getPuntoventaId(), dataMovimento); - - lsConferenciasTodos.addAll(lsConferencias); - } - - - Collections.sort(lsConferenciasTodos); + carregarPuntoVentas(lsConferencias, competencia, empresa, puntoVenta, dataMovimento); + carregarConferenciasRegistradas(lsConferencias, competencia, empresa, puntoVenta, dataMovimento, null); + carregarMovimentoVendas(con, lsConferencias, competencia, empresa, puntoVenta, dataMovimento, null, null); + carregarDiasSemMovimento(lsConferencias, competencia, empresa, puntoVenta, dataMovimento); - return lsConferenciasTodos; + Collections.sort(lsConferencias); + + return lsConferencias; } catch (Exception e) { log.error(e.getMessage(), e); throw new BusinessException(e.getMessage(), e); @@ -122,15 +113,15 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO lsConferencias = new ArrayList(); - Map parametros = carregarParametros(dataInicial, dataFinal, null, empresa, puntoVenta.getPuntoventaId(), dataMovimento, false); + Map parametros = carregarParametros(dataInicial, dataFinal, null, empresa, puntoVenta, dataMovimento, false); SimpleDateFormat format = new SimpleDateFormat("MM/yyyy"); String competencia = format.format(dataInicial); carregarPuntoVentas(lsConferencias, dataInicial, dataFinal, empresa, puntoVenta, dataMovimento); - carregarConferenciasRegistradas(lsConferencias, null, empresa, puntoVenta.getPuntoventaId(), dataMovimento, parametros); - carregarMovimentoVendas(con, lsConferencias, null, empresa, puntoVenta.getPuntoventaId(), dataMovimento, dataInicial, dataFinal); - carregarDiasSemMovimento(lsConferencias, competencia, empresa, puntoVenta.getPuntoventaId(), dataMovimento); + carregarConferenciasRegistradas(lsConferencias, null, empresa, puntoVenta, dataMovimento, parametros); + carregarMovimentoVendas(con, lsConferencias, null, empresa, puntoVenta, dataMovimento, dataInicial, dataFinal); + carregarDiasSemMovimento(lsConferencias, competencia, empresa, puntoVenta, dataMovimento); return lsConferencias; } catch (Exception e) { @@ -212,7 +203,7 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO lsConferencias, - String competencia, Empresa empresa, Integer puntoVenta, Date dataMovimento, Map parametros) throws BusinessException { + String competencia, Empresa empresa, PuntoVenta puntoVenta, Date dataMovimento, Map parametros) throws BusinessException { try { if (parametros == null) { parametros = carregarParametros(null, null, competencia, empresa, puntoVenta, dataMovimento, false); @@ -255,7 +246,7 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO lsConferencias, - String competencia, Empresa empresa, Integer puntoVenta, Date dataMovimento, Date dataInicialDate, Date dataFinalDate) + String competencia, Empresa empresa, PuntoVenta puntoVenta, Date dataMovimento, Date dataInicialDate, Date dataFinalDate) throws BusinessException, SQLException { PreparedStatement stmt = null; ResultSet rset = null; @@ -448,7 +439,7 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO lsConferencias, - String competencia, Empresa empresa, Integer puntoVenta, Date dataMovimento) throws ParseException { + String competencia, Empresa empresa, PuntoVenta puntoVenta, Date dataMovimento) throws ParseException { for (ConferenciaComissaoVO conferenciaComissao : lsConferencias) { for (Integer diaSemMovimento : conferenciaComissao.getDiasSemMovimentos()) { DiaConferenciaComissaoVO diaConferenciaComissao = new DiaConferenciaComissaoVO(); @@ -470,7 +461,7 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO carregarParametros(Date dataInicial, Date dataFinal, String competencia, Empresa empresa, - Integer puntoVenta, Date datamovimento, boolean formatoDataSemHora) throws ParseException { + PuntoVenta puntoVenta, Date datamovimento, boolean formatoDataSemHora) throws ParseException { Map parametros = new HashMap(); String formatoData = (formatoDataSemHora ? "dd/MM/yyyy" : "dd/MM/yyyy HH:mm"); @@ -478,8 +469,8 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO -1) { - parametros.put("puntoventaId", puntoVenta); + if (puntoVenta != null && puntoVenta.getPuntoventaId() > -1) { + parametros.put("puntoventaId", puntoVenta.getPuntoventaId()); } if (datamovimento != null) { @@ -563,7 +554,7 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO parametros = carregarParametros(null, null, null, conferencia.getEmpresa(), conferencia.getPuntoVenta().getPuntoventaId(), null, false); + Map parametros = carregarParametros(null, null, null, conferencia.getEmpresa(), conferencia.getPuntoVenta(), null, false); StringBuilder sQuery = new StringBuilder() .append("SELECT FECHAMENTOCNTCORRENTE_ID ") .append("FROM FECHAMENTO_CNTCORRENTE ") @@ -602,7 +593,7 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO parametros = carregarParametros(null, null, conferencia.getCompetencia(), conferencia.getEmpresa(), - conferencia.getPuntoVenta().getPuntoventaId(), conferencia.getDatamovimento(), true); + conferencia.getPuntoVenta(), conferencia.getDatamovimento(), true); StringBuilder sQuery = new StringBuilder() .append("SELECT EE.BOLETO_ID AS \"boletoId\", EE.EVENTOEXTRA_ID AS \"eventoextraId\", EE.NUMDOCUMENTO AS \"numdocumento\", ") .append("CFP.IMPORTE AS \"impingreso\", TEE.DESCTIPOEVENTO AS \"desctipoevento\", EE.DESCINFO AS \"descinfo\", ") @@ -750,6 +741,10 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO parametros = carregarParametros(null, null, conferencia.getCompetencia(), conferencia.getEmpresa(), - conferencia.getPuntoVenta().getPuntoventaId(), conferencia.getDatamovimento(), true); + conferencia.getPuntoVenta(), conferencia.getDatamovimento(), true); StringBuilder sQuery = new StringBuilder() .append("SELECT C.CAJA_ID AS \"cajaId\", C.NUMASIENTO AS \"numAsiento\", C.NUMASIENTOVINCULADO AS \"numAsientoVinculado\", C.NUMOPERACION AS \"numoperacion\", C.NUMFOLIOSISTEMA AS \"numFolioSistema\", ") @@ -810,8 +810,8 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO carregarOcds(Conferencia conferencia) throws BusinessException { try { Map parametros = carregarParametros(null, null, null, conferencia.getEmpresa(), - conferencia.getPuntoVenta().getPuntoventaId(), conferencia.getDatamovimento(), false); + conferencia.getPuntoVenta(), conferencia.getDatamovimento(), false); StringBuilder sQuery = new StringBuilder() .append("SELECT DISTINCT O.OCD_ID AS \"ocdId\", O.NUMOPERACION AS \"numoperacion\", O.FECINC AS \"fecinc\", O.FECPAGAR AS \"fecpagar\", O.FECPAGO AS \"fecpago\", ") @@ -1121,7 +1122,7 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO lsConferencias = new ArrayList(); @@ -1163,7 +1164,7 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO parametros = carregarParametros(null, null, competencia, empresa, puntoVenta, datamovimento, false); @@ -1233,5 +1234,30 @@ public class ConferenciaComissaoHibernateDAO extends GenericHibernateDAO logConferencias = qr.list(); + for (LogConferencia logConferencia : logConferencias) { + borrarLogConferencia(logConferencia); + } + } catch (Exception e) { + log.error(e.getMessage(), e); + throw new BusinessException(e.getMessage(), e); + } + } } diff --git a/src/com/rjconsultores/ventaboletos/service/ConferenciaComissaoService.java b/src/com/rjconsultores/ventaboletos/service/ConferenciaComissaoService.java index 779326909..cb12fb3c3 100644 --- a/src/com/rjconsultores/ventaboletos/service/ConferenciaComissaoService.java +++ b/src/com/rjconsultores/ventaboletos/service/ConferenciaComissaoService.java @@ -89,5 +89,7 @@ public interface ConferenciaComissaoService extends GenericService carregarBilhetesComissao(List boletoComissaos, List conferencias, BoletoStatusComissao boletoStatusComissao, boolean carregarDadosFaltantes) throws BusinessException { @@ -730,7 +722,7 @@ public class ConferenciaComissaoServiceImpl implements ConferenciaComissaoServic @Override public boolean isConferenciaCompetenciaEncerrada(String competencia, Empresa empresa, PuntoVenta puntoVenta) throws BusinessException { - return conferenciaComissaoDAO.isConferenciaCompetenciaEncerrada(competencia, empresa, puntoVenta.getPuntoventaId()); + return conferenciaComissaoDAO.isConferenciaCompetenciaEncerrada(competencia, empresa, puntoVenta); } @Override @@ -745,7 +737,7 @@ public class ConferenciaComissaoServiceImpl implements ConferenciaComissaoServic @Override public DiaConferenciaComissaoVO carregarConferenciaRegistrada(Date datamovimento, Empresa empresa, PuntoVenta puntoVenta) throws BusinessException { - return conferenciaComissaoDAO.carregarConferenciaRegistrada(datamovimento, empresa, puntoVenta.getPuntoventaId()); + return conferenciaComissaoDAO.carregarConferenciaRegistrada(datamovimento, empresa, puntoVenta); } @Override @@ -977,4 +969,10 @@ public class ConferenciaComissaoServiceImpl implements ConferenciaComissaoServic public boolean isConferidoVenta(BoletoComissao boletoComissao) { return conferenciaComissaoDAO.isConferidoVenta(boletoComissao); } + + @Override + public void borrarLogConferenciaTransacaoId(Long transacaoId) throws BusinessException { + conferenciaComissaoDAO.borrarLogConferenciaTransacaoId(transacaoId); + } + } diff --git a/src/com/rjconsultores/ventaboletos/vo/comissao/BoletoComissao.java b/src/com/rjconsultores/ventaboletos/vo/comissao/BoletoComissao.java index 307141763..0cf95e1e1 100644 --- a/src/com/rjconsultores/ventaboletos/vo/comissao/BoletoComissao.java +++ b/src/com/rjconsultores/ventaboletos/vo/comissao/BoletoComissao.java @@ -89,6 +89,8 @@ public class BoletoComissao { private Conferencia conferencia; private Date feccorte; + + private Long transacaoId; public Integer getEmpresaId() { return empresaId; @@ -1050,4 +1052,12 @@ public class BoletoComissao { this.valorbase = valorbase; } + public Long getTransacaoId() { + return transacaoId; + } + + public void setTransacaoId(Long transacaoId) { + this.transacaoId = transacaoId; + } + }