Subversion Repositories Integrator Subversion

package br.com.ec.repository.jpa;

import org.springframework.stereotype.Repository;

import br.com.ec.domain.model.Parcela;
import br.com.ec.repository.ParcelaRepository;
import br.com.ec.repository.SistemaAbstractRepository;

@Repository
public class ParcelaRepositoryJpaImpl extends SistemaAbstractRepository<Parcela> implements ParcelaRepository {

        @Override
        protected String getColunaOrdenadora() {
                return "sequencial";
        }
        /*
        @Override
        public List<Parcela> consultarParcelas(ParametrosConsultaLancamentosDTO parametrosConsulta) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT p FROM Parcela p ");
                sql.append("WHERE ((p.dataPagamento IS NOT NULL AND p.dataPagamento >= :dataInicial AND p.dataPagamento <= :dataFinal) ");
                sql.append("OR (p.dataPagamento IS NULL AND p.dataVencimento <= :dataFinal)) ");
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getTipoBusca())) {
                        sql.append("AND p.conta.tipoConta = :tipoConta ");
                }
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCentroDeCustos())) {
                        if (parametrosConsulta.getCentroDeCustos().getSequencial().equals(new Long(-1))) {
                                sql.append("AND p.conta.loja IS NULL ");
                        } else {
                                sql.append("AND p.conta.loja.sequencial = :sequencialCentroDeCustos ");
                        }
                }
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria())) {
                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria().getSequencial())) {
                                sql.append("AND p.conta.categoria.sequencial = :sequencialCategoria ");
                        } else {
                                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoriaPai().getSequencial())) {
                                        sql.append("AND p.conta.categoria.sequencial = :sequencialCategoriaPai ");
                                } else {
                                        sql.append("AND p.conta.categoria IS NULL ");
                                }
                        }
                }
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getOficial())) {
                        if (parametrosConsulta.getOficial()) {
                                sql.append("AND p.indicadorOficial IS TRUE ");
                        } else {
                                sql.append("AND p.indicadorOficial IS FALSE ");
                        }
                }
                sql.append("ORDER BY p.dataVencimento ");
                try {
                        TypedQuery<Parcela> query = getEntityManager().createQuery(sql.toString(), Parcela.class)
                                .setParameter("dataInicial", parametrosConsulta.getDataInicial())
                                .setParameter("dataFinal", parametrosConsulta.getDataFinal());
                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getTipoBusca())) {
                                query.setParameter("tipoConta", parametrosConsulta.getTipoBusca());
                        }
                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCentroDeCustos())) {
                                if (!parametrosConsulta.getCentroDeCustos().getSequencial().equals(new Long(-1))) {
                                        query.setParameter("sequencialCentroDeCustos", parametrosConsulta.getCentroDeCustos().getSequencial());
                                }
                        }
                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria())) {
                                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria().getSequencial())) {
                                        query.setParameter("sequencialCategoria", parametrosConsulta.getCategoria().getSequencial());
                                } else {
                                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoriaPai().getSequencial())) {
                                                query.setParameter("sequencialCategoriaPai", parametrosConsulta.getCategoriaPai().getSequencial());
                                        }
                                }
                        }
                        return query.getResultList();
                } catch(Exception ex) {
                        ex.printStackTrace();
                        return null;
                }
        }
       
        @Override
        public List<Parcela> consultarParcelasAVencer(Conta conta) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT p FROM Parcela p ");
                sql.append("WHERE p.conta.sequencial = :sequencialConta ");
                sql.append("AND p.dataPagamento is null ");
                sql.append("ORDER BY p.sequencial ");
                try {
                        return getEntityManager().createQuery(sql.toString(), Parcela.class)
                                        .setParameter("sequencialConta", conta.getSequencial())
                                        .getResultList();
                } catch(Exception ex) {
                        ex.printStackTrace();
                        return null;
                }
        }
       
        @Override
        public List<Parcela> consultarParcelasAReceber(Date dataRecebimento, TipoCartao tipoCartao) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT p FROM Parcela p ");
                sql.append("WHERE p.dataVencimento = :dataVencimento ");
                sql.append("AND p.observacao like UPPER(:observacao) ");
                sql.append("AND p.dataPagamento is null ");
                sql.append("ORDER BY p.dataVencimento ");
                try {
                        return getEntityManager().createQuery(sql.toString(), Parcela.class)
                                        .setParameter("dataVencimento", dataRecebimento)
                                        .setParameter("observacao", StringUtil.setarUpperCase("%" + tipoCartao.getDescricao() + "%"))
                                        .getResultList();
                } catch(Exception ex) {
                        ex.printStackTrace();
                        return null;
                }
        }
       
        @Override
        public List<Parcela> consultarParcelasRecebidas(Date dataRecebimento, TipoCartao tipoCartao) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT p FROM Parcela p ");
                sql.append("WHERE p.dataVencimento = :dataVencimento ");
                sql.append("AND p.observacao like UPPER(:observacao) ");
                sql.append("AND p.dataPagamento is not null ");
                sql.append("ORDER BY p.dataVencimento ");
                try {
                        return getEntityManager().createQuery(sql.toString(), Parcela.class)
                                        .setParameter("dataVencimento", dataRecebimento)
                                        .setParameter("observacao", StringUtil.setarUpperCase("%" + tipoCartao.getDescricao() + "%"))
                                        .getResultList();
                } catch(Exception ex) {
                        ex.printStackTrace();
                        return null;
                }
        }
       
        @Override
        public List<Parcela> consultarPassandoParametrosConsulta(ParametrosConsulta<Parcela> parametrosConsulta,
                        Integer primeiroRegistro, Integer tamanhoPagina, String sortField, String sortOrder,
                        Map<String, Object> filters) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT DISTINCT e FROM Parcela e ");
                sql.append("WHERE e.indicadorAtivo is true ");
                try {
                        setarStringParametrosConsulta(sql, parametrosConsulta);
                        sql.append("ORDER BY " + ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getOrdenacao());
                        TypedQuery<Parcela> query = getEntityManager().createQuery(sql.toString(), Parcela.class);
                        setarQueryParametrosConsulta(query, parametrosConsulta);
                        return query.setFirstResult(primeiroRegistro).setMaxResults(tamanhoPagina).getResultList();
                } catch(Exception ex) {
                        ex.printStackTrace();
                        return null;
                }
        }
       
        @Override
        public List<Parcela> consultarParcelasDaVenda(Long sequencialVenda) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT p FROM Parcela p ");
                sql.append("WHERE p.conta.venda.sequencial = :sequencialVenda ");
                sql.append("ORDER BY p.dataVencimento ");
                try {
                        return getEntityManager().createQuery(sql.toString(), Parcela.class).setParameter("sequencialVenda", sequencialVenda).getResultList();
                } catch(Exception ex) {
                        ex.printStackTrace();
                        return null;
                }
        }
       
        @Override
        public Boolean verificarPossuiParcelaAberta(Venda venda) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.dataPagamento is null AND p.indicadorAtivo = true ");
                sql.append("AND p.conta.venda.sequencial = :sequencialVenda ");
                TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class);
                query.setParameter("sequencialVenda", venda.getSequencial());
                return query.getSingleResult().intValue()>0;
        }

        @Override
        public Boolean verificarPossuiParcelaAbertaParaPagamento(Conta conta) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.dataPagamento is null AND p.indicadorAtivo = true ");
                sql.append("AND p.conta.sequencial = :sequencialConta ");
                TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class);
                query.setParameter("sequencialConta", conta.getSequencial());
                return query.getSingleResult().intValue()>0;
        }
       
        @Override
        public List<Parcela> consultarParcelasDaConta(Conta conta) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT p FROM Parcela p WHERE p.indicadorAtivo = true ");
                sql.append("AND p.conta.sequencial = :sequencialConta ");
                return getEntityManager().createQuery(sql.toString(), Parcela.class).setParameter("sequencialConta", conta.getSequencial()).getResultList();
        }
       
        @Override
        public Boolean verificarPossuiParcela(Venda venda) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.indicadorAtivo = true ");
                sql.append("AND p.conta.venda.sequencial = :sequencialVenda ");
                TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class);
                query.setParameter("sequencialVenda", venda.getSequencial());
                return query.getSingleResult().intValue()>0;
        }
       
        @Override
        public Double obterValorPassandoParametrosConsulta(ParametrosConsulta<Parcela> parametrosConsulta) {
                StringBuilder sql = new StringBuilder();
                sql.append("SELECT DISTINCT SUM(e.valor) FROM Parcela e ");
                sql.append("WHERE e.indicadorAtivo is true ");
                try {
                        setarStringParametrosConsulta(sql, parametrosConsulta);
                        TypedQuery<Double> query = getEntityManager().createQuery(sql.toString(), Double.class);
                        setarQueryParametrosConsulta(query, parametrosConsulta);
                        return query.getSingleResult();
                } catch(Exception ex) {
                        ex.printStackTrace();
                        return null;
                }
        }
       
        @Override
        protected void setarStringParametrosConsulta(StringBuilder sql, ParametrosConsulta<Parcela> parametrosConsulta) {
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta)) {
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getContaBancaria())) {
                                sql.append("AND e.contaBancaria.sequencial = :sequencialContaBancaria ");
                        }
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoBusca())) {
                                if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoBusca().equals("R")) {
                                        sql.append("AND e.conta.tipoConta = 'R' ");
                                }
                                if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoBusca().equals("P")) {
                                        sql.append("AND e.conta.tipoConta = 'P' ");
                                }
                        }
                       
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO) parametrosConsulta).getCentroDeCustos())) {
                                if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getCentroDeCustos().getSequencial().equals(new Long(-1))) {
                                        sql.append("AND e.conta.loja IS NULL ");
                                } else {
                                        sql.append("AND e.conta.loja.sequencial = :sequencialCentroDeCustos ");
                                }
                        }
                       
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getCategoria())) {
                                sql.append("AND e.conta.categoria.sequencial = :sequencialCategoria ");
                        }
                       
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getFavorecido())) {
                                sql.append("AND e.conta.pessoa.sequencial = :sequencialPessoa ");
                        }
                       
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getFavorecido())) {
                                sql.append("AND e.conta.pessoa.sequencial = :sequencialPessoa ");
                        }
                        if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getObservacao())) {
                                sql.append("AND upper(e.observacao) like upper(:observacao) ");
                        }
                        if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getVigencia())) {
                                if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getVigencia().getSequencial().equals(new Long(-1))) {
                                        sql.append("AND e.conta.vigencia IS NULL ");
                                } else {
                                        sql.append("AND e.conta.vigencia = :vigencia ");
                                }
                        }
                        if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getOficial())) {
                                if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getOficial()) {
                                        sql.append("AND e.indicadorOficial IS TRUE ");
                                } else {
                                        sql.append("AND e.indicadorOficial IS FALSE ");
                                }
                        }
                       
                        if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getIndicadorDRE())) {
                                sql.append("AND e.conta.categoria.indicadorDRE = :indicadorDRE ");
                        } else if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getPagamentoRealizado()) {
                                if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataInicial()) &&
                                                VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataFinal())) {
                                        sql.append("AND e.dataPagamento is not null ");
                                        sql.append("AND e.dataPagamento >= :dataInicial AND e.dataPagamento <= :dataFinal ");
                                }
                        } else {
                                sql.append("AND e.dataPagamento is null ");
                                if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataVencimento())) {
                                        sql.append("AND e.dataVencimento = :dataVencimento ");
                                }
                                if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoFormaDePagamento())) {
                                        if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoFormaDePagamento().equals(TipoCartao.DEBITO.getValor())) {
                                                sql.append("AND e.conta.formaDePagamento.formaPagamento.codigo = 2 ");
                                        } else if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoFormaDePagamento().equals(TipoCartao.CREDITO.getValor())) {
                                                sql.append("AND e.conta.formaDePagamento.formaPagamento.codigo in (3, 4, 5, 7, 8, 9, 10, 11, 12, 13) ");
                                        }
                                }
                        }
                }
        }
       
        @Override
        protected void setarQueryParametrosConsulta(Query query, ParametrosConsulta<Parcela> parametrosConsulta) {
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta)) {
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getContaBancaria())) {
                                query.setParameter("sequencialContaBancaria", ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getContaBancaria().getSequencial());
                        }
                       
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO) parametrosConsulta).getCentroDeCustos())) {
                                if (!((ParametrosConsultaLancamentosDTO)parametrosConsulta).getCentroDeCustos().getSequencial().equals(new Long(-1))) {
                                        query.setParameter("sequencialCentroDeCustos", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getCentroDeCustos().getSequencial());
                                }
                        }
                       
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getCategoria())) {
                                query.setParameter("sequencialCategoria", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getCategoria().getSequencial());
                        }
                       
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getFavorecido())) {
                                query.setParameter("sequencialPessoa", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getFavorecido().getSequencial());
                        }
                       
                        if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getObservacao())) {
                                query.setParameter("observacao", "%" + ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getObservacao() + "%");
                        }
                        if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getVigencia())) {
                                if (!((ParametrosConsultaLancamentosDTO)parametrosConsulta).getVigencia().getSequencial().equals(new Long(-1))) {
                                        query.setParameter("vigencia", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getVigencia());
                                }
                        }
                        if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getIndicadorDRE())) {
                                query.setParameter("indicadorDRE", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getIndicadorDRE());
                        }
                       
                        if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getPagamentoRealizado()) {
                                if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataInicial()) &&
                                                VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataFinal())) {
                                        query.setParameter("dataInicial", ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataInicial());
                                        query.setParameter("dataFinal", ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataFinal());
                                }
                        } else if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataVencimento())) {
                                query.setParameter("dataVencimento", ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataVencimento());
                        }
                }
               
        }
       
        @Override
        protected void setarStringParametrosConsultar(StringBuilder sql, Parcela parcela) {
                if (VerificadorUtil.naoEstaNulo(parcela)) {
                        if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getConta())) {
                                if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getConta().getSequencial())) {
                                        sql.append("AND e.conta.sequencial = :sequencialConta ");
                                }
                        }
                        if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getIndicadorAtivo())) {
                                sql.append("AND e.indicadorAtivo = :indicadorAtivo ");
                        }
                }
        }
       
        @Override
        protected void setarQueryParametrosConsultar(Query query, Parcela parcela) {
                if (VerificadorUtil.naoEstaNulo(parcela)) {
                        if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getConta())) {
                                if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getConta().getSequencial())) {
                                        query.setParameter("sequencialConta", parcela.getConta().getSequencial());
                                }
                        }
                        if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getIndicadorAtivo())) {
                                query.setParameter("indicadorAtivo", parcela.getIndicadorAtivo());
                        }
                }
        }
        */
}