Rev 669 | Rev 721 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed
| Rev | Author | Line No. | Line |
|---|---|---|---|
| 259 | espaco | 1 | package br.com.ec.repository.jpa; |
| 2 | |||
| 282 | espaco | 3 | import java.util.Date; |
| 4 | import java.util.List; |
||
| 5 | |||
| 610 | blopes | 6 | import javax.persistence.NoResultException; |
| 296 | espaco | 7 | import javax.persistence.Query; |
| 282 | espaco | 8 | import javax.persistence.TypedQuery; |
| 9 | |||
| 259 | espaco | 10 | import org.springframework.stereotype.Repository; |
| 11 | |||
| 296 | espaco | 12 | import br.com.ec.core.consulta.ParametrosConsulta; |
| 282 | espaco | 13 | import br.com.ec.core.util.VerificadorUtil; |
| 296 | espaco | 14 | import br.com.ec.domain.dto.FormaPagamentoDTO; |
| 282 | espaco | 15 | import br.com.ec.domain.dto.ParcelaDTO; |
| 296 | espaco | 16 | import br.com.ec.domain.dto.consulta.ParametrosConsultaLancamentosDTO; |
| 282 | espaco | 17 | import br.com.ec.domain.dto.consulta.ParametrosConsultaParcelasDTO; |
| 383 | espaco | 18 | import br.com.ec.domain.model.FormaPagamento; |
| 259 | espaco | 19 | import br.com.ec.domain.model.Parcela; |
| 20 | import br.com.ec.repository.ParcelaRepository; |
||
| 21 | import br.com.ec.repository.SistemaAbstractRepository; |
||
| 22 | |||
| 23 | @Repository |
||
| 24 | public class ParcelaRepositoryJpaImpl extends SistemaAbstractRepository<Parcela> implements ParcelaRepository { |
||
| 25 | |||
| 26 | @Override |
||
| 27 | protected String getColunaOrdenadora() { |
||
| 28 | return "sequencial"; |
||
| 29 | } |
||
| 282 | espaco | 30 | |
| 31 | @Override |
||
| 439 | espaco | 32 | protected void setarStringParametrosConsulta(StringBuilder sql, ParametrosConsulta<Parcela> parametrosConsulta) { |
| 33 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta)) { |
||
| 34 | if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getVigencia())) { |
||
| 35 | if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getVigencia().getSequencial().equals(new Long(-1))) { |
||
| 36 | sql.append("AND e.conta.vigencia IS NULL "); |
||
| 37 | } else { |
||
| 38 | sql.append("AND e.conta.vigencia.sequencial = :sequencialVigencia "); |
||
| 39 | } |
||
| 40 | } |
||
| 41 | |||
| 42 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO) parametrosConsulta).getCentroDeCustos())) { |
||
| 43 | if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getCentroDeCustos().getSequencial().equals(new Long(-1))) { |
||
| 44 | sql.append("AND e.conta.loja IS NULL "); |
||
| 45 | } else { |
||
| 46 | sql.append("AND e.conta.loja.sequencial = :sequencialCentroDeCustos "); |
||
| 47 | } |
||
| 48 | } |
||
| 49 | |||
| 50 | if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getIndicadorDre())) { |
||
| 51 | sql.append("AND e.conta.categoria.indicadorDRE.codigo = :codigoIndicadorDre "); |
||
| 52 | } else if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getPagamentoRealizado()) { |
||
| 53 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataInicialDoPeriodo()) && |
||
| 54 | VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataFinalDoPeriodo())) { |
||
| 55 | sql.append("AND e.dataPagamento is not null "); |
||
| 56 | sql.append("AND e.dataPagamento >= :dataInicial AND e.dataPagamento <= :dataFinal "); |
||
| 57 | } |
||
| 58 | } else { |
||
| 59 | sql.append("AND e.dataPagamento is null "); |
||
| 60 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataVencimento())) { |
||
| 61 | sql.append("AND e.dataVencimento = :dataVencimento "); |
||
| 62 | } |
||
| 63 | /* |
||
| 64 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoFormaDePagamento())) { |
||
| 65 | if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoFormaDePagamento().equals(TipoCartao.DEBITO.getValor())) { |
||
| 66 | sql.append("AND e.conta.formaDePagamento.formaPagamento.codigo = 2 "); |
||
| 67 | } else if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoFormaDePagamento().equals(TipoCartao.CREDITO.getValor())) { |
||
| 68 | sql.append("AND e.conta.formaDePagamento.formaPagamento.codigo in (3, 4, 5, 7, 8, 9, 10, 11, 12, 13) "); |
||
| 69 | } |
||
| 70 | } |
||
| 71 | */ |
||
| 72 | } |
||
| 73 | /* |
||
| 74 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getContaBancaria())) { |
||
| 75 | sql.append("AND e.contaBancaria.sequencial = :sequencialContaBancaria "); |
||
| 76 | } |
||
| 77 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoBusca())) { |
||
| 78 | if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoBusca().equals("R")) { |
||
| 79 | sql.append("AND e.conta.tipoConta = 'R' "); |
||
| 80 | } |
||
| 81 | if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getTipoBusca().equals("P")) { |
||
| 82 | sql.append("AND e.conta.tipoConta = 'P' "); |
||
| 83 | } |
||
| 84 | } |
||
| 85 | |||
| 86 | |||
| 87 | |||
| 88 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getCategoria())) { |
||
| 89 | sql.append("AND e.conta.categoria.sequencial = :sequencialCategoria "); |
||
| 90 | } |
||
| 91 | |||
| 92 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getFavorecido())) { |
||
| 93 | sql.append("AND e.conta.pessoa.sequencial = :sequencialPessoa "); |
||
| 94 | } |
||
| 95 | |||
| 96 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getFavorecido())) { |
||
| 97 | sql.append("AND e.conta.pessoa.sequencial = :sequencialPessoa "); |
||
| 98 | } |
||
| 99 | if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getObservacao())) { |
||
| 100 | sql.append("AND upper(e.observacao) like upper(:observacao) "); |
||
| 101 | } |
||
| 102 | |||
| 103 | if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getOficial())) { |
||
| 104 | if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getOficial()) { |
||
| 105 | sql.append("AND e.indicadorOficial IS TRUE "); |
||
| 106 | } else { |
||
| 107 | sql.append("AND e.indicadorOficial IS FALSE "); |
||
| 108 | } |
||
| 109 | } |
||
| 110 | */ |
||
| 111 | } |
||
| 112 | } |
||
| 113 | |||
| 114 | @Override |
||
| 115 | protected void setarQueryParametrosConsulta(Query query, ParametrosConsulta<Parcela> parametrosConsulta) { |
||
| 116 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta)) { |
||
| 117 | if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getVigencia())) { |
||
| 118 | if (!((ParametrosConsultaLancamentosDTO)parametrosConsulta).getVigencia().getSequencial().equals(new Long(-1))) { |
||
| 119 | query.setParameter("sequencialVigencia", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getVigencia().getSequencial()); |
||
| 120 | } |
||
| 121 | } |
||
| 122 | |||
| 123 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO) parametrosConsulta).getCentroDeCustos())) { |
||
| 124 | if (!((ParametrosConsultaLancamentosDTO)parametrosConsulta).getCentroDeCustos().getSequencial().equals(new Long(-1))) { |
||
| 125 | query.setParameter("sequencialCentroDeCustos", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getCentroDeCustos().getSequencial()); |
||
| 126 | } |
||
| 127 | } |
||
| 128 | |||
| 129 | if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getIndicadorDre())) { |
||
| 130 | query.setParameter("codigoIndicadorDre", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getIndicadorDre().getCodigo()); |
||
| 131 | } |
||
| 132 | |||
| 133 | if (((ParametrosConsultaLancamentosDTO)parametrosConsulta).getPagamentoRealizado()) { |
||
| 134 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataInicialDoPeriodo()) && |
||
| 135 | VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataFinalDoPeriodo())) { |
||
| 136 | query.setParameter("dataInicial", ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataInicialDoPeriodo()); |
||
| 137 | query.setParameter("dataFinal", ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataFinalDoPeriodo()); |
||
| 138 | } |
||
| 139 | } else if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataVencimento())) { |
||
| 140 | query.setParameter("dataVencimento", ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getDataVencimento()); |
||
| 141 | } |
||
| 142 | } |
||
| 143 | /* |
||
| 144 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta)) { |
||
| 145 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getContaBancaria())) { |
||
| 146 | query.setParameter("sequencialContaBancaria", ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getContaBancaria().getSequencial()); |
||
| 147 | } |
||
| 148 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getCategoria())) { |
||
| 149 | query.setParameter("sequencialCategoria", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getCategoria().getSequencial()); |
||
| 150 | } |
||
| 151 | |||
| 152 | if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getFavorecido())) { |
||
| 153 | query.setParameter("sequencialPessoa", ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getFavorecido().getSequencial()); |
||
| 154 | } |
||
| 155 | |||
| 156 | if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaLancamentosDTO)parametrosConsulta).getObservacao())) { |
||
| 157 | query.setParameter("observacao", "%" + ((ParametrosConsultaLancamentosDTO) parametrosConsulta).getObservacao() + "%"); |
||
| 158 | } |
||
| 159 | } |
||
| 160 | */ |
||
| 161 | } |
||
| 162 | |||
| 163 | @Override |
||
| 164 | protected void setarStringParametrosConsultar(StringBuilder sql, Parcela parcela) { |
||
| 165 | /* |
||
| 166 | if (VerificadorUtil.naoEstaNulo(parcela)) { |
||
| 167 | if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getConta())) { |
||
| 168 | if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getConta().getSequencial())) { |
||
| 169 | sql.append("AND e.conta.sequencial = :sequencialConta "); |
||
| 170 | } |
||
| 171 | } |
||
| 172 | if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getIndicadorAtivo())) { |
||
| 173 | sql.append("AND e.indicadorAtivo = :indicadorAtivo "); |
||
| 174 | } |
||
| 175 | } |
||
| 176 | */ |
||
| 177 | } |
||
| 178 | |||
| 179 | @Override |
||
| 180 | protected void setarQueryParametrosConsultar(Query query, Parcela parcela) { |
||
| 181 | /* |
||
| 182 | if (VerificadorUtil.naoEstaNulo(parcela)) { |
||
| 183 | if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getConta())) { |
||
| 184 | if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getConta().getSequencial())) { |
||
| 185 | query.setParameter("sequencialConta", parcela.getConta().getSequencial()); |
||
| 186 | } |
||
| 187 | } |
||
| 188 | if (VerificadorUtil.naoEstaNuloOuVazio(parcela.getIndicadorAtivo())) { |
||
| 189 | query.setParameter("indicadorAtivo", parcela.getIndicadorAtivo()); |
||
| 190 | } |
||
| 191 | } |
||
| 192 | */ |
||
| 193 | } |
||
| 194 | |||
| 195 | @Override |
||
| 282 | espaco | 196 | public List<ParcelaDTO> consultarParcelas(ParametrosConsultaParcelasDTO parametrosConsultaParcelasDTO) { |
| 197 | StringBuilder sql = new StringBuilder(); |
||
| 319 | espaco | 198 | sql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO("); |
| 199 | sql.append(ParcelaDTO.CONSULTA_COMPLETA_DTO); |
||
| 200 | sql.append(") FROM Parcela e "); |
||
| 343 | espaco | 201 | sql.append("WHERE e.indicadorAtivo is true "); |
| 282 | espaco | 202 | if (VerificadorUtil.naoEstaNulo(parametrosConsultaParcelasDTO.getTipoBusca())) { |
| 319 | espaco | 203 | sql.append("AND e.conta.tipoConta = :tipoConta "); |
| 282 | espaco | 204 | } |
| 294 | espaco | 205 | if (VerificadorUtil.naoEstaNulo(parametrosConsultaParcelasDTO.getSequencialCategoria())) { |
| 319 | espaco | 206 | sql.append("AND e.conta.categoria.sequencial = :sequencialCategoria "); |
| 294 | espaco | 207 | } |
| 282 | espaco | 208 | if (parametrosConsultaParcelasDTO.getPagamentoRealizado()) { |
| 209 | if (VerificadorUtil.naoEstaNulo(parametrosConsultaParcelasDTO.getDataInicial()) && |
||
| 210 | VerificadorUtil.naoEstaNulo(parametrosConsultaParcelasDTO.getDataFinal())) { |
||
| 319 | espaco | 211 | sql.append("AND e.dataPagamento is not null "); |
| 212 | sql.append("AND e.dataPagamento >= :dataInicial AND e.dataPagamento <= :dataFinal "); |
||
| 282 | espaco | 213 | } |
| 214 | } |
||
| 319 | espaco | 215 | sql.append("ORDER BY e.dataVencimento "); |
| 282 | espaco | 216 | try { |
| 217 | TypedQuery<ParcelaDTO> query = getEntityManager().createQuery(sql.toString(), ParcelaDTO.class); |
||
| 218 | if (VerificadorUtil.naoEstaNulo(parametrosConsultaParcelasDTO.getTipoBusca())) { |
||
| 219 | query.setParameter("tipoConta", parametrosConsultaParcelasDTO.getTipoBusca()); |
||
| 220 | } |
||
| 294 | espaco | 221 | if (VerificadorUtil.naoEstaNulo(parametrosConsultaParcelasDTO.getSequencialCategoria())) { |
| 222 | query.setParameter("sequencialCategoria", parametrosConsultaParcelasDTO.getSequencialCategoria()); |
||
| 223 | } |
||
| 282 | espaco | 224 | if (parametrosConsultaParcelasDTO.getPagamentoRealizado()) { |
| 225 | if (VerificadorUtil.naoEstaNulo(parametrosConsultaParcelasDTO.getDataInicial()) && |
||
| 226 | VerificadorUtil.naoEstaNulo(parametrosConsultaParcelasDTO.getDataFinal())) { |
||
| 227 | query.setParameter("dataInicial", parametrosConsultaParcelasDTO.getDataInicial()); |
||
| 228 | query.setParameter("dataFinal", parametrosConsultaParcelasDTO.getDataFinal()); |
||
| 229 | } |
||
| 230 | } |
||
| 231 | return query.getResultList(); |
||
| 232 | } catch(Exception ex) { |
||
| 233 | ex.printStackTrace(); |
||
| 234 | return null; |
||
| 235 | } |
||
| 236 | } |
||
| 237 | |||
| 238 | @Override |
||
| 382 | espaco | 239 | public List<ParcelaDTO> consultarParcelas(Long sequencialContaBancaria, Date dataRecebimento, List<FormaPagamentoDTO> formasDePagamento) { |
| 240 | StringBuilder sql = new StringBuilder(); |
||
| 241 | sql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO("); |
||
| 242 | sql.append(ParcelaDTO.CONSULTA_SEM_CATEGORIA_DTO); |
||
| 243 | sql.append(") FROM Parcela e "); |
||
| 244 | sql.append("WHERE e.contaBancaria.sequencial = :sequencialContaBancaria "); |
||
| 245 | sql.append("AND e.dataVencimento = :dataVencimento "); |
||
| 246 | sql.append("AND (e.dataPagamento is null OR e.dataPagamento = :dataVencimento) "); |
||
| 247 | sql.append(setarParametrosFormasDePagamento("e", formasDePagamento)); |
||
| 248 | sql.append("AND e.indicadorAtivo is true "); |
||
| 249 | sql.append("ORDER BY e.dataVencimento "); |
||
| 250 | try { |
||
| 251 | return getEntityManager().createQuery(sql.toString(), ParcelaDTO.class) |
||
| 252 | .setParameter("sequencialContaBancaria", sequencialContaBancaria) |
||
| 253 | .setParameter("dataVencimento", dataRecebimento) |
||
| 254 | .getResultList(); |
||
| 255 | } catch(Exception ex) { |
||
| 256 | ex.printStackTrace(); |
||
| 257 | return null; |
||
| 258 | } |
||
| 259 | } |
||
| 260 | |||
| 261 | @Override |
||
| 669 | blopes | 262 | public List<ParcelaDTO> consultarParcelas(String sqlConsulta) { |
| 263 | try { |
||
| 264 | return getEntityManager().createQuery(sqlConsulta, ParcelaDTO.class).getResultList(); |
||
| 265 | } catch(Exception ex) { |
||
| 266 | ex.printStackTrace(); |
||
| 267 | return null; |
||
| 268 | } |
||
| 269 | } |
||
| 270 | |||
| 271 | @Override |
||
| 296 | espaco | 272 | public List<ParcelaDTO> consultarParcelasAReceber(Long sequencialContaBancaria, Date dataRecebimento, List<FormaPagamentoDTO> formasDePagamento) { |
| 282 | espaco | 273 | StringBuilder sql = new StringBuilder(); |
| 319 | espaco | 274 | sql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO("); |
| 275 | sql.append(ParcelaDTO.CONSULTA_SEM_CATEGORIA_DTO); |
||
| 276 | sql.append(") FROM Parcela e "); |
||
| 277 | sql.append("WHERE e.contaBancaria.sequencial = :sequencialContaBancaria "); |
||
| 278 | sql.append("AND e.dataVencimento = :dataVencimento "); |
||
| 279 | sql.append(setarParametrosFormasDePagamento("e", formasDePagamento)); |
||
| 280 | sql.append("AND e.dataPagamento is null "); |
||
| 343 | espaco | 281 | sql.append("AND e.indicadorAtivo is true "); |
| 319 | espaco | 282 | sql.append("ORDER BY e.dataVencimento "); |
| 282 | espaco | 283 | try { |
| 284 | return getEntityManager().createQuery(sql.toString(), ParcelaDTO.class) |
||
| 285 | .setParameter("sequencialContaBancaria", sequencialContaBancaria) |
||
| 286 | .setParameter("dataVencimento", dataRecebimento) |
||
| 287 | .getResultList(); |
||
| 288 | } catch(Exception ex) { |
||
| 289 | ex.printStackTrace(); |
||
| 290 | return null; |
||
| 291 | } |
||
| 292 | } |
||
| 293 | |||
| 294 | @Override |
||
| 296 | espaco | 295 | public List<ParcelaDTO> consultarParcelasRecebidas(Long sequencialContaBancaria, Date dataRecebimento, List<FormaPagamentoDTO> formasDePagamento) { |
| 282 | espaco | 296 | StringBuilder sql = new StringBuilder(); |
| 319 | espaco | 297 | sql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO("); |
| 298 | sql.append(ParcelaDTO.CONSULTA_SEM_CATEGORIA_DTO); |
||
| 299 | sql.append(") FROM Parcela e "); |
||
| 300 | sql.append("WHERE e.contaBancaria.sequencial = :sequencialContaBancaria "); |
||
| 301 | sql.append("AND e.dataPagamento = :dataPagamento "); |
||
| 343 | espaco | 302 | sql.append("AND e.indicadorAtivo is true "); |
| 319 | espaco | 303 | sql.append(setarParametrosFormasDePagamento("e", formasDePagamento)); |
| 304 | sql.append("ORDER BY e.dataVencimento "); |
||
| 282 | espaco | 305 | try { |
| 306 | return getEntityManager().createQuery(sql.toString(), ParcelaDTO.class) |
||
| 307 | .setParameter("sequencialContaBancaria", sequencialContaBancaria) |
||
| 294 | espaco | 308 | .setParameter("dataPagamento", dataRecebimento) |
| 282 | espaco | 309 | .getResultList(); |
| 310 | } catch(Exception ex) { |
||
| 311 | ex.printStackTrace(); |
||
| 312 | return null; |
||
| 313 | } |
||
| 314 | } |
||
| 315 | |||
| 610 | blopes | 316 | @Override |
| 317 | public List<ParcelaDTO> consultarParcelasDaPessoaEeCategoriaEeVigencia(Long sequencialPessoa, Long sequencialCategoria, Long sequencialVigencia) { |
||
| 318 | try { |
||
| 319 | StringBuilder jpql = new StringBuilder(); |
||
| 320 | jpql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO(p.sequencial, p.valor, p.dataPagamento, p.dataVencimento) "); |
||
| 321 | jpql.append("FROM Parcela p " ); |
||
| 322 | jpql.append("WHERE p.conta.pessoa.sequencial = :sequencialPessoa " ); |
||
| 323 | jpql.append("AND p.conta.categoria.sequencial = :sequencialCategoria " ); |
||
| 324 | jpql.append("AND p.conta.vigencia.sequencial = :sequencialVigencia " ); |
||
| 325 | return getEntityManager().createQuery(jpql.toString(), br.com.ec.domain.dto.ParcelaDTO.class) |
||
| 326 | .setParameter("sequencialPessoa", sequencialPessoa) |
||
| 327 | .setParameter("sequencialCategoria", sequencialCategoria) |
||
| 328 | .setParameter("sequencialVigencia", sequencialVigencia) |
||
| 329 | .getResultList(); |
||
| 330 | } catch (NoResultException e) { |
||
| 331 | return null; |
||
| 332 | } |
||
| 333 | } |
||
| 334 | |||
| 296 | espaco | 335 | private String setarParametrosFormasDePagamento(String nomeTabela, List<FormaPagamentoDTO> formasPagamento) { |
| 336 | StringBuilder sql = new StringBuilder(); |
||
| 337 | if (VerificadorUtil.isListaComElementos(formasPagamento)) { |
||
| 338 | sql.append("AND "); |
||
| 339 | sql.append(nomeTabela); |
||
| 340 | sql.append(".formaPagamento.codigo IN ("); |
||
| 341 | for (FormaPagamentoDTO formaPagamento : formasPagamento) { |
||
| 342 | sql.append(formaPagamento.getCodigo() + ","); |
||
| 343 | } |
||
| 344 | sql.append(") "); |
||
| 345 | } |
||
| 346 | return sql.toString().replace(",)", ")"); |
||
| 347 | } |
||
| 348 | |||
| 349 | @Override |
||
| 383 | espaco | 350 | public void conciliarParcelas(Date dataConciliacao, List<ParcelaDTO> parcelasSelecionadas) { |
| 296 | espaco | 351 | StringBuilder sql = new StringBuilder(); |
| 383 | espaco | 352 | sql.append("UPDATE Parcela parcela SET parcela.dataPagamento = :dataPagamento, parcela.indicadorConciliado = true "); |
| 353 | sql.append("WHERE parcela.sequencial IN ("); |
||
| 354 | StringBuilder sqlParcelas = new StringBuilder(""); |
||
| 355 | for (ParcelaDTO parcelaDTO : parcelasSelecionadas) { |
||
| 356 | sqlParcelas.append(parcelaDTO.getSequencial() + ","); |
||
| 357 | } |
||
| 358 | sqlParcelas.append(") "); |
||
| 359 | sql.append(sqlParcelas.toString().replace(",)", ")")); |
||
| 296 | espaco | 360 | try { |
| 361 | getEntityManager().createQuery(sql.toString()) |
||
| 383 | espaco | 362 | .setParameter("dataPagamento", dataConciliacao) |
| 296 | espaco | 363 | .executeUpdate(); |
| 364 | getEntityManager().flush(); |
||
| 365 | } catch(Exception ex) { |
||
| 366 | ex.printStackTrace(); |
||
| 367 | } |
||
| 368 | } |
||
| 369 | |||
| 370 | @Override |
||
| 402 | espaco | 371 | public void alterarObservacao(Long sequencial, String observacao) { |
| 372 | StringBuilder sql = new StringBuilder(); |
||
| 373 | sql.append("UPDATE Parcela p SET p.observacao = :observacao "); |
||
| 374 | sql.append("WHERE p.sequencial = :sequencial "); |
||
| 375 | try { |
||
| 376 | getEntityManager().createQuery(sql.toString()) |
||
| 377 | .setParameter("sequencial", sequencial) |
||
| 378 | .setParameter("observacao", observacao) |
||
| 379 | .executeUpdate(); |
||
| 380 | getEntityManager().flush(); |
||
| 381 | } catch(Exception ex) { |
||
| 382 | ex.printStackTrace(); |
||
| 383 | } |
||
| 384 | } |
||
| 385 | |||
| 386 | @Override |
||
| 296 | espaco | 387 | public Double obterValorPassandoParametrosConsulta(ParametrosConsulta<Parcela> parametrosConsulta) { |
| 388 | StringBuilder sql = new StringBuilder(); |
||
| 389 | sql.append("SELECT DISTINCT SUM(e.valor) FROM Parcela e "); |
||
| 390 | sql.append("WHERE e.indicadorAtivo is true "); |
||
| 391 | try { |
||
| 392 | setarStringParametrosConsulta(sql, parametrosConsulta); |
||
| 393 | TypedQuery<Double> query = getEntityManager().createQuery(sql.toString(), Double.class); |
||
| 394 | setarQueryParametrosConsulta(query, parametrosConsulta); |
||
| 395 | return query.getSingleResult(); |
||
| 396 | } catch(Exception ex) { |
||
| 397 | ex.printStackTrace(); |
||
| 398 | return null; |
||
| 399 | } |
||
| 400 | } |
||
| 401 | |||
| 402 | @Override |
||
| 297 | espaco | 403 | public List<ParcelaDTO> consultarParcelasPassandoParametrosConsulta(ParametrosConsulta<Parcela> parametrosConsulta) { |
| 404 | StringBuilder sql = new StringBuilder(); |
||
| 319 | espaco | 405 | sql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO("); |
| 406 | sql.append(ParcelaDTO.CONSULTA_COMPLETA_DTO); |
||
| 407 | sql.append(") FROM Parcela e "); |
||
| 297 | espaco | 408 | // sql.append("SELECT DISTINCT SUM(e.valor) FROM Parcela e "); |
| 409 | sql.append("WHERE e.indicadorAtivo is true "); |
||
| 410 | try { |
||
| 411 | setarStringParametrosConsulta(sql, parametrosConsulta); |
||
| 412 | TypedQuery<ParcelaDTO> query = getEntityManager().createQuery(sql.toString(), ParcelaDTO.class); |
||
| 413 | setarQueryParametrosConsulta(query, parametrosConsulta); |
||
| 414 | return query.getResultList(); |
||
| 415 | } catch(Exception ex) { |
||
| 416 | ex.printStackTrace(); |
||
| 417 | return null; |
||
| 418 | } |
||
| 419 | } |
||
| 420 | |||
| 421 | @Override |
||
| 439 | espaco | 422 | public Boolean verificarPossuiParcelaEmAberta(Long sequencialConta, Long sequencialVenda) { |
| 423 | StringBuilder sql = new StringBuilder(); |
||
| 424 | sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.dataPagamento is null AND p.indicadorAtivo = true "); |
||
| 425 | if (VerificadorUtil.naoEstaNulo(sequencialConta)) { |
||
| 426 | sql.append("AND p.conta.sequencial = :sequencialConta "); |
||
| 296 | espaco | 427 | } |
| 439 | espaco | 428 | if (VerificadorUtil.naoEstaNulo(sequencialVenda)) { |
| 429 | sql.append("AND p.conta.venda.sequencial = :sequencialVenda "); |
||
| 296 | espaco | 430 | } |
| 439 | espaco | 431 | TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class); |
| 432 | if (VerificadorUtil.naoEstaNulo(sequencialConta)) { |
||
| 433 | query.setParameter("sequencialConta", sequencialConta); |
||
| 296 | espaco | 434 | } |
| 439 | espaco | 435 | if (VerificadorUtil.naoEstaNulo(sequencialVenda)) { |
| 436 | query.setParameter("sequencialVenda", sequencialVenda); |
||
| 296 | espaco | 437 | } |
| 439 | espaco | 438 | return query.getSingleResult().intValue() > 0; |
| 296 | espaco | 439 | } |
| 440 | |||
| 441 | @Override |
||
| 439 | espaco | 442 | public List<Parcela> consultarParcelasDaConta(Long sequencialConta) { |
| 443 | StringBuilder sql = new StringBuilder(); |
||
| 444 | sql.append("SELECT p FROM Parcela p WHERE p.indicadorAtivo = true "); |
||
| 445 | sql.append("AND p.conta.sequencial = :sequencialConta "); |
||
| 446 | return getEntityManager().createQuery(sql.toString(), Parcela.class).setParameter("sequencialConta", sequencialConta).getResultList(); |
||
| 296 | espaco | 447 | } |
| 448 | |||
| 610 | blopes | 449 | @Override |
| 450 | public void atualizarValorParcela(ParcelaDTO parcelaDTO) { |
||
| 451 | StringBuilder sql = new StringBuilder(); |
||
| 452 | sql.append("UPDATE Parcela parcela SET parcela.valor = :valorNovo "); |
||
| 453 | sql.append("WHERE parcela.sequencial = :sequencialParcela "); |
||
| 454 | try { |
||
| 455 | getEntityManager().createQuery(sql.toString()) |
||
| 456 | .setParameter("sequencialParcela", parcelaDTO.getSequencial()) |
||
| 457 | .setParameter("valorNovo", parcelaDTO.getValor()) |
||
| 458 | .executeUpdate(); |
||
| 459 | getEntityManager().flush(); |
||
| 460 | } catch(Exception ex) { |
||
| 461 | ex.printStackTrace(); |
||
| 462 | } |
||
| 463 | } |
||
| 464 | |||
| 679 | blopes | 465 | @Override |
| 466 | public void efetivarConciliacaoAntecipacao(String sqlAtualizacaoParcelas) { |
||
| 467 | try { |
||
| 468 | getEntityManager().createNativeQuery(sqlAtualizacaoParcelas).executeUpdate(); |
||
| 469 | getEntityManager().flush(); |
||
| 470 | } catch(Exception ex) { |
||
| 471 | ex.printStackTrace(); |
||
| 472 | } |
||
| 473 | } |
||
| 474 | |||
| 259 | espaco | 475 | /* |
| 476 | @Override |
||
| 477 | public List<Parcela> consultarParcelas(ParametrosConsultaLancamentosDTO parametrosConsulta) { |
||
| 478 | StringBuilder sql = new StringBuilder(); |
||
| 479 | sql.append("SELECT p FROM Parcela p "); |
||
| 480 | sql.append("WHERE ((p.dataPagamento IS NOT NULL AND p.dataPagamento >= :dataInicial AND p.dataPagamento <= :dataFinal) "); |
||
| 481 | sql.append("OR (p.dataPagamento IS NULL AND p.dataVencimento <= :dataFinal)) "); |
||
| 482 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getTipoBusca())) { |
||
| 483 | sql.append("AND p.conta.tipoConta = :tipoConta "); |
||
| 484 | } |
||
| 485 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCentroDeCustos())) { |
||
| 486 | if (parametrosConsulta.getCentroDeCustos().getSequencial().equals(new Long(-1))) { |
||
| 487 | sql.append("AND p.conta.loja IS NULL "); |
||
| 488 | } else { |
||
| 489 | sql.append("AND p.conta.loja.sequencial = :sequencialCentroDeCustos "); |
||
| 490 | } |
||
| 491 | } |
||
| 492 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria())) { |
||
| 493 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria().getSequencial())) { |
||
| 494 | sql.append("AND p.conta.categoria.sequencial = :sequencialCategoria "); |
||
| 495 | } else { |
||
| 496 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoriaPai().getSequencial())) { |
||
| 497 | sql.append("AND p.conta.categoria.sequencial = :sequencialCategoriaPai "); |
||
| 498 | } else { |
||
| 499 | sql.append("AND p.conta.categoria IS NULL "); |
||
| 500 | } |
||
| 501 | } |
||
| 502 | } |
||
| 503 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getOficial())) { |
||
| 504 | if (parametrosConsulta.getOficial()) { |
||
| 505 | sql.append("AND p.indicadorOficial IS TRUE "); |
||
| 506 | } else { |
||
| 507 | sql.append("AND p.indicadorOficial IS FALSE "); |
||
| 508 | } |
||
| 509 | } |
||
| 510 | sql.append("ORDER BY p.dataVencimento "); |
||
| 511 | try { |
||
| 512 | TypedQuery<Parcela> query = getEntityManager().createQuery(sql.toString(), Parcela.class) |
||
| 513 | .setParameter("dataInicial", parametrosConsulta.getDataInicial()) |
||
| 514 | .setParameter("dataFinal", parametrosConsulta.getDataFinal()); |
||
| 515 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getTipoBusca())) { |
||
| 516 | query.setParameter("tipoConta", parametrosConsulta.getTipoBusca()); |
||
| 517 | } |
||
| 518 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCentroDeCustos())) { |
||
| 519 | if (!parametrosConsulta.getCentroDeCustos().getSequencial().equals(new Long(-1))) { |
||
| 520 | query.setParameter("sequencialCentroDeCustos", parametrosConsulta.getCentroDeCustos().getSequencial()); |
||
| 521 | } |
||
| 522 | } |
||
| 523 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria())) { |
||
| 524 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria().getSequencial())) { |
||
| 525 | query.setParameter("sequencialCategoria", parametrosConsulta.getCategoria().getSequencial()); |
||
| 526 | } else { |
||
| 527 | if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoriaPai().getSequencial())) { |
||
| 528 | query.setParameter("sequencialCategoriaPai", parametrosConsulta.getCategoriaPai().getSequencial()); |
||
| 529 | } |
||
| 530 | } |
||
| 531 | } |
||
| 532 | return query.getResultList(); |
||
| 533 | } catch(Exception ex) { |
||
| 534 | ex.printStackTrace(); |
||
| 535 | return null; |
||
| 536 | } |
||
| 537 | } |
||
| 538 | |||
| 539 | @Override |
||
| 540 | public List<Parcela> consultarParcelasAVencer(Conta conta) { |
||
| 541 | StringBuilder sql = new StringBuilder(); |
||
| 542 | sql.append("SELECT p FROM Parcela p "); |
||
| 543 | sql.append("WHERE p.conta.sequencial = :sequencialConta "); |
||
| 544 | sql.append("AND p.dataPagamento is null "); |
||
| 545 | sql.append("ORDER BY p.sequencial "); |
||
| 546 | try { |
||
| 547 | return getEntityManager().createQuery(sql.toString(), Parcela.class) |
||
| 548 | .setParameter("sequencialConta", conta.getSequencial()) |
||
| 549 | .getResultList(); |
||
| 550 | } catch(Exception ex) { |
||
| 551 | ex.printStackTrace(); |
||
| 552 | return null; |
||
| 553 | } |
||
| 554 | } |
||
| 555 | |||
| 556 | @Override |
||
| 557 | public List<Parcela> consultarParcelasRecebidas(Date dataRecebimento, TipoCartao tipoCartao) { |
||
| 558 | StringBuilder sql = new StringBuilder(); |
||
| 559 | sql.append("SELECT p FROM Parcela p "); |
||
| 560 | sql.append("WHERE p.dataVencimento = :dataVencimento "); |
||
| 561 | sql.append("AND p.observacao like UPPER(:observacao) "); |
||
| 562 | sql.append("AND p.dataPagamento is not null "); |
||
| 563 | sql.append("ORDER BY p.dataVencimento "); |
||
| 564 | try { |
||
| 565 | return getEntityManager().createQuery(sql.toString(), Parcela.class) |
||
| 566 | .setParameter("dataVencimento", dataRecebimento) |
||
| 567 | .setParameter("observacao", StringUtil.setarUpperCase("%" + tipoCartao.getDescricao() + "%")) |
||
| 568 | .getResultList(); |
||
| 569 | } catch(Exception ex) { |
||
| 570 | ex.printStackTrace(); |
||
| 571 | return null; |
||
| 572 | } |
||
| 573 | } |
||
| 574 | |||
| 575 | @Override |
||
| 576 | public List<Parcela> consultarPassandoParametrosConsulta(ParametrosConsulta<Parcela> parametrosConsulta, |
||
| 577 | Integer primeiroRegistro, Integer tamanhoPagina, String sortField, String sortOrder, |
||
| 578 | Map<String, Object> filters) { |
||
| 579 | StringBuilder sql = new StringBuilder(); |
||
| 580 | sql.append("SELECT DISTINCT e FROM Parcela e "); |
||
| 581 | sql.append("WHERE e.indicadorAtivo is true "); |
||
| 582 | try { |
||
| 583 | setarStringParametrosConsulta(sql, parametrosConsulta); |
||
| 584 | sql.append("ORDER BY " + ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getOrdenacao()); |
||
| 585 | TypedQuery<Parcela> query = getEntityManager().createQuery(sql.toString(), Parcela.class); |
||
| 586 | setarQueryParametrosConsulta(query, parametrosConsulta); |
||
| 587 | return query.setFirstResult(primeiroRegistro).setMaxResults(tamanhoPagina).getResultList(); |
||
| 588 | } catch(Exception ex) { |
||
| 589 | ex.printStackTrace(); |
||
| 590 | return null; |
||
| 591 | } |
||
| 592 | } |
||
| 593 | |||
| 594 | @Override |
||
| 595 | public List<Parcela> consultarParcelasDaVenda(Long sequencialVenda) { |
||
| 596 | StringBuilder sql = new StringBuilder(); |
||
| 597 | sql.append("SELECT p FROM Parcela p "); |
||
| 598 | sql.append("WHERE p.conta.venda.sequencial = :sequencialVenda "); |
||
| 599 | sql.append("ORDER BY p.dataVencimento "); |
||
| 600 | try { |
||
| 601 | return getEntityManager().createQuery(sql.toString(), Parcela.class).setParameter("sequencialVenda", sequencialVenda).getResultList(); |
||
| 602 | } catch(Exception ex) { |
||
| 603 | ex.printStackTrace(); |
||
| 604 | return null; |
||
| 605 | } |
||
| 606 | } |
||
| 607 | |||
| 608 | @Override |
||
| 609 | public Boolean verificarPossuiParcelaAbertaParaPagamento(Conta conta) { |
||
| 610 | StringBuilder sql = new StringBuilder(); |
||
| 611 | sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.dataPagamento is null AND p.indicadorAtivo = true "); |
||
| 612 | sql.append("AND p.conta.sequencial = :sequencialConta "); |
||
| 613 | TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class); |
||
| 614 | query.setParameter("sequencialConta", conta.getSequencial()); |
||
| 615 | return query.getSingleResult().intValue()>0; |
||
| 616 | } |
||
| 617 | |||
| 618 | @Override |
||
| 619 | public Boolean verificarPossuiParcela(Venda venda) { |
||
| 620 | StringBuilder sql = new StringBuilder(); |
||
| 621 | sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.indicadorAtivo = true "); |
||
| 622 | sql.append("AND p.conta.venda.sequencial = :sequencialVenda "); |
||
| 623 | TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class); |
||
| 624 | query.setParameter("sequencialVenda", venda.getSequencial()); |
||
| 625 | return query.getSingleResult().intValue()>0; |
||
| 626 | } |
||
| 627 | |||
| 628 | |||
| 629 | */ |
||
| 630 | } |