Subversion Repositories Integrator Subversion

Rev

Rev 439 | Rev 669 | 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
296 espaco 262
        public List<ParcelaDTO> consultarParcelasAReceber(Long sequencialContaBancaria, Date dataRecebimento, List<FormaPagamentoDTO> formasDePagamento) {
282 espaco 263
                StringBuilder sql = new StringBuilder();
319 espaco 264
                sql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO(");
265
                sql.append(ParcelaDTO.CONSULTA_SEM_CATEGORIA_DTO);
266
                sql.append(") FROM Parcela e ");
267
                sql.append("WHERE e.contaBancaria.sequencial = :sequencialContaBancaria ");
268
                sql.append("AND e.dataVencimento = :dataVencimento ");
269
                sql.append(setarParametrosFormasDePagamento("e", formasDePagamento));
270
                sql.append("AND e.dataPagamento is null ");
343 espaco 271
                sql.append("AND e.indicadorAtivo is true ");
319 espaco 272
                sql.append("ORDER BY e.dataVencimento ");
282 espaco 273
                try {
274
                        return getEntityManager().createQuery(sql.toString(), ParcelaDTO.class)
275
                                        .setParameter("sequencialContaBancaria", sequencialContaBancaria)
276
                                        .setParameter("dataVencimento", dataRecebimento)
277
                                        .getResultList();
278
                } catch(Exception ex) {
279
                        ex.printStackTrace();
280
                        return null;
281
                }
282
        }
283
 
284
        @Override
296 espaco 285
        public List<ParcelaDTO> consultarParcelasRecebidas(Long sequencialContaBancaria, Date dataRecebimento, List<FormaPagamentoDTO> formasDePagamento) {
282 espaco 286
                StringBuilder sql = new StringBuilder();
319 espaco 287
                sql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO(");
288
                sql.append(ParcelaDTO.CONSULTA_SEM_CATEGORIA_DTO);
289
                sql.append(") FROM Parcela e ");
290
                sql.append("WHERE e.contaBancaria.sequencial = :sequencialContaBancaria ");
291
                sql.append("AND e.dataPagamento = :dataPagamento ");
343 espaco 292
                sql.append("AND e.indicadorAtivo is true ");
319 espaco 293
                sql.append(setarParametrosFormasDePagamento("e", formasDePagamento));
294
                sql.append("ORDER BY e.dataVencimento ");
282 espaco 295
                try {
296
                        return getEntityManager().createQuery(sql.toString(), ParcelaDTO.class)
297
                                        .setParameter("sequencialContaBancaria", sequencialContaBancaria)
294 espaco 298
                                        .setParameter("dataPagamento", dataRecebimento)
282 espaco 299
                                        .getResultList();
300
                } catch(Exception ex) {
301
                        ex.printStackTrace();
302
                        return null;
303
                }
304
        }
305
 
610 blopes 306
        @Override
307
        public List<ParcelaDTO> consultarParcelasDaPessoaEeCategoriaEeVigencia(Long sequencialPessoa, Long sequencialCategoria, Long sequencialVigencia) {
308
                try {
309
                        StringBuilder jpql = new StringBuilder();
310
                        jpql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO(p.sequencial, p.valor, p.dataPagamento, p.dataVencimento) ");
311
                        jpql.append("FROM Parcela p " );
312
                        jpql.append("WHERE p.conta.pessoa.sequencial = :sequencialPessoa " );
313
                        jpql.append("AND p.conta.categoria.sequencial = :sequencialCategoria " );
314
                        jpql.append("AND p.conta.vigencia.sequencial = :sequencialVigencia " );
315
                        return getEntityManager().createQuery(jpql.toString(), br.com.ec.domain.dto.ParcelaDTO.class)
316
                                        .setParameter("sequencialPessoa", sequencialPessoa)
317
                                        .setParameter("sequencialCategoria", sequencialCategoria)
318
                                        .setParameter("sequencialVigencia", sequencialVigencia)
319
                                        .getResultList();
320
                } catch (NoResultException e) {
321
                        return null;
322
                }
323
        }
324
 
296 espaco 325
        private String setarParametrosFormasDePagamento(String nomeTabela, List<FormaPagamentoDTO> formasPagamento) {
326
                StringBuilder sql = new StringBuilder();
327
                if (VerificadorUtil.isListaComElementos(formasPagamento)) {
328
                        sql.append("AND ");
329
                        sql.append(nomeTabela);
330
                        sql.append(".formaPagamento.codigo IN (");
331
                        for (FormaPagamentoDTO formaPagamento : formasPagamento) {
332
                                sql.append(formaPagamento.getCodigo() + ",");
333
                        }
334
                        sql.append(") ");
335
                }
336
                return sql.toString().replace(",)", ")");
337
        }
338
 
339
        @Override
383 espaco 340
        public void conciliarParcelas(Date dataConciliacao, List<ParcelaDTO> parcelasSelecionadas) {
296 espaco 341
                StringBuilder sql = new StringBuilder();
383 espaco 342
                sql.append("UPDATE Parcela parcela SET parcela.dataPagamento = :dataPagamento, parcela.indicadorConciliado = true ");
343
                sql.append("WHERE parcela.sequencial IN (");
344
                StringBuilder sqlParcelas = new StringBuilder("");
345
                for (ParcelaDTO parcelaDTO : parcelasSelecionadas) {
346
                        sqlParcelas.append(parcelaDTO.getSequencial() + ",");
347
                }
348
                sqlParcelas.append(") ");
349
                sql.append(sqlParcelas.toString().replace(",)", ")"));
296 espaco 350
                try {
351
                        getEntityManager().createQuery(sql.toString())
383 espaco 352
                                .setParameter("dataPagamento", dataConciliacao)
296 espaco 353
                                .executeUpdate();
354
                        getEntityManager().flush();
355
                } catch(Exception ex) {
356
                        ex.printStackTrace();
357
                }
358
        }
359
 
360
        @Override
402 espaco 361
        public void alterarObservacao(Long sequencial, String observacao) {
362
                StringBuilder sql = new StringBuilder();
363
                sql.append("UPDATE Parcela p SET p.observacao = :observacao ");
364
                sql.append("WHERE p.sequencial = :sequencial ");
365
                try {
366
                        getEntityManager().createQuery(sql.toString())
367
                                .setParameter("sequencial", sequencial)
368
                                .setParameter("observacao", observacao)
369
                                .executeUpdate();
370
                        getEntityManager().flush();
371
                } catch(Exception ex) {
372
                        ex.printStackTrace();
373
                }
374
        }
375
 
376
        @Override
296 espaco 377
        public Double obterValorPassandoParametrosConsulta(ParametrosConsulta<Parcela> parametrosConsulta) {
378
                StringBuilder sql = new StringBuilder();
379
                sql.append("SELECT DISTINCT SUM(e.valor) FROM Parcela e ");
380
                sql.append("WHERE e.indicadorAtivo is true ");
381
                try {
382
                        setarStringParametrosConsulta(sql, parametrosConsulta);
383
                        TypedQuery<Double> query = getEntityManager().createQuery(sql.toString(), Double.class);
384
                        setarQueryParametrosConsulta(query, parametrosConsulta);
385
                        return query.getSingleResult();
386
                } catch(Exception ex) {
387
                        ex.printStackTrace();
388
                        return null;
389
                }
390
        }
391
 
392
        @Override
297 espaco 393
        public List<ParcelaDTO> consultarParcelasPassandoParametrosConsulta(ParametrosConsulta<Parcela> parametrosConsulta) {
394
                StringBuilder sql = new StringBuilder();
319 espaco 395
                sql.append("SELECT new br.com.ec.domain.dto.ParcelaDTO(");
396
                sql.append(ParcelaDTO.CONSULTA_COMPLETA_DTO);
397
                sql.append(") FROM Parcela e ");
297 espaco 398
//              sql.append("SELECT DISTINCT SUM(e.valor) FROM Parcela e ");
399
                sql.append("WHERE e.indicadorAtivo is true ");
400
                try {
401
                        setarStringParametrosConsulta(sql, parametrosConsulta);
402
                        TypedQuery<ParcelaDTO> query = getEntityManager().createQuery(sql.toString(), ParcelaDTO.class);
403
                        setarQueryParametrosConsulta(query, parametrosConsulta);
404
                        return query.getResultList();
405
                } catch(Exception ex) {
406
                        ex.printStackTrace();
407
                        return null;
408
                }
409
        }
410
 
411
        @Override
439 espaco 412
        public Boolean verificarPossuiParcelaEmAberta(Long sequencialConta, Long sequencialVenda) {
413
                StringBuilder sql = new StringBuilder();
414
                sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.dataPagamento is null AND p.indicadorAtivo = true ");
415
                if (VerificadorUtil.naoEstaNulo(sequencialConta)) {
416
                        sql.append("AND p.conta.sequencial = :sequencialConta ");
296 espaco 417
                }
439 espaco 418
                if (VerificadorUtil.naoEstaNulo(sequencialVenda)) {
419
                        sql.append("AND p.conta.venda.sequencial = :sequencialVenda ");
296 espaco 420
                }
439 espaco 421
                TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class);
422
                if (VerificadorUtil.naoEstaNulo(sequencialConta)) {
423
                        query.setParameter("sequencialConta", sequencialConta);
296 espaco 424
                }
439 espaco 425
                if (VerificadorUtil.naoEstaNulo(sequencialVenda)) {
426
                        query.setParameter("sequencialVenda", sequencialVenda);
296 espaco 427
                }
439 espaco 428
                return query.getSingleResult().intValue() > 0;
296 espaco 429
        }
430
 
431
        @Override
439 espaco 432
        public List<Parcela> consultarParcelasDaConta(Long sequencialConta) {
433
                StringBuilder sql = new StringBuilder();
434
                sql.append("SELECT p FROM Parcela p WHERE p.indicadorAtivo = true ");
435
                sql.append("AND p.conta.sequencial = :sequencialConta ");
436
                return getEntityManager().createQuery(sql.toString(), Parcela.class).setParameter("sequencialConta", sequencialConta).getResultList();
296 espaco 437
        }
438
 
610 blopes 439
        @Override
440
        public void atualizarValorParcela(ParcelaDTO parcelaDTO) {
441
                StringBuilder sql = new StringBuilder();
442
                sql.append("UPDATE Parcela parcela SET parcela.valor = :valorNovo ");
443
                sql.append("WHERE parcela.sequencial = :sequencialParcela ");
444
                try {
445
                        getEntityManager().createQuery(sql.toString())
446
                                .setParameter("sequencialParcela", parcelaDTO.getSequencial())
447
                                .setParameter("valorNovo", parcelaDTO.getValor())
448
                                .executeUpdate();
449
                        getEntityManager().flush();
450
                } catch(Exception ex) {
451
                        ex.printStackTrace();
452
                }
453
        }
454
 
259 espaco 455
        /*
456
        @Override
457
        public List<Parcela> consultarParcelas(ParametrosConsultaLancamentosDTO parametrosConsulta) {
458
                StringBuilder sql = new StringBuilder();
459
                sql.append("SELECT p FROM Parcela p ");
460
                sql.append("WHERE ((p.dataPagamento IS NOT NULL AND p.dataPagamento >= :dataInicial AND p.dataPagamento <= :dataFinal) ");
461
                sql.append("OR (p.dataPagamento IS NULL AND p.dataVencimento <= :dataFinal)) ");
462
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getTipoBusca())) {
463
                        sql.append("AND p.conta.tipoConta = :tipoConta ");
464
                }
465
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCentroDeCustos())) {
466
                        if (parametrosConsulta.getCentroDeCustos().getSequencial().equals(new Long(-1))) {
467
                                sql.append("AND p.conta.loja IS NULL ");
468
                        } else {
469
                                sql.append("AND p.conta.loja.sequencial = :sequencialCentroDeCustos ");
470
                        }
471
                }
472
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria())) {
473
                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria().getSequencial())) {
474
                                sql.append("AND p.conta.categoria.sequencial = :sequencialCategoria ");
475
                        } else {
476
                                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoriaPai().getSequencial())) {
477
                                        sql.append("AND p.conta.categoria.sequencial = :sequencialCategoriaPai ");
478
                                } else {
479
                                        sql.append("AND p.conta.categoria IS NULL ");
480
                                }
481
                        }
482
                }
483
                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getOficial())) {
484
                        if (parametrosConsulta.getOficial()) {
485
                                sql.append("AND p.indicadorOficial IS TRUE ");
486
                        } else {
487
                                sql.append("AND p.indicadorOficial IS FALSE ");
488
                        }
489
                }
490
                sql.append("ORDER BY p.dataVencimento ");
491
                try {
492
                        TypedQuery<Parcela> query = getEntityManager().createQuery(sql.toString(), Parcela.class)
493
                                .setParameter("dataInicial", parametrosConsulta.getDataInicial())
494
                                .setParameter("dataFinal", parametrosConsulta.getDataFinal());
495
                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getTipoBusca())) {
496
                                query.setParameter("tipoConta", parametrosConsulta.getTipoBusca());
497
                        }
498
                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCentroDeCustos())) {
499
                                if (!parametrosConsulta.getCentroDeCustos().getSequencial().equals(new Long(-1))) {
500
                                        query.setParameter("sequencialCentroDeCustos", parametrosConsulta.getCentroDeCustos().getSequencial());
501
                                }
502
                        }
503
                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria())) {
504
                                if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoria().getSequencial())) {
505
                                        query.setParameter("sequencialCategoria", parametrosConsulta.getCategoria().getSequencial());
506
                                } else {
507
                                        if (VerificadorUtil.naoEstaNulo(parametrosConsulta.getCategoriaPai().getSequencial())) {
508
                                                query.setParameter("sequencialCategoriaPai", parametrosConsulta.getCategoriaPai().getSequencial());
509
                                        }
510
                                }
511
                        }
512
                        return query.getResultList();
513
                } catch(Exception ex) {
514
                        ex.printStackTrace();
515
                        return null;
516
                }
517
        }
518
 
519
        @Override
520
        public List<Parcela> consultarParcelasAVencer(Conta conta) {
521
                StringBuilder sql = new StringBuilder();
522
                sql.append("SELECT p FROM Parcela p ");
523
                sql.append("WHERE p.conta.sequencial = :sequencialConta ");
524
                sql.append("AND p.dataPagamento is null ");
525
                sql.append("ORDER BY p.sequencial ");
526
                try {
527
                        return getEntityManager().createQuery(sql.toString(), Parcela.class)
528
                                        .setParameter("sequencialConta", conta.getSequencial())
529
                                        .getResultList();
530
                } catch(Exception ex) {
531
                        ex.printStackTrace();
532
                        return null;
533
                }
534
        }
535
 
536
        @Override
537
        public List<Parcela> consultarParcelasRecebidas(Date dataRecebimento, TipoCartao tipoCartao) {
538
                StringBuilder sql = new StringBuilder();
539
                sql.append("SELECT p FROM Parcela p ");
540
                sql.append("WHERE p.dataVencimento = :dataVencimento ");
541
                sql.append("AND p.observacao like UPPER(:observacao) ");
542
                sql.append("AND p.dataPagamento is not null ");
543
                sql.append("ORDER BY p.dataVencimento ");
544
                try {
545
                        return getEntityManager().createQuery(sql.toString(), Parcela.class)
546
                                        .setParameter("dataVencimento", dataRecebimento)
547
                                        .setParameter("observacao", StringUtil.setarUpperCase("%" + tipoCartao.getDescricao() + "%"))
548
                                        .getResultList();
549
                } catch(Exception ex) {
550
                        ex.printStackTrace();
551
                        return null;
552
                }
553
        }
554
 
555
        @Override
556
        public List<Parcela> consultarPassandoParametrosConsulta(ParametrosConsulta<Parcela> parametrosConsulta,
557
                        Integer primeiroRegistro, Integer tamanhoPagina, String sortField, String sortOrder,
558
                        Map<String, Object> filters) {
559
                StringBuilder sql = new StringBuilder();
560
                sql.append("SELECT DISTINCT e FROM Parcela e ");
561
                sql.append("WHERE e.indicadorAtivo is true ");
562
                try {
563
                        setarStringParametrosConsulta(sql, parametrosConsulta);
564
                        sql.append("ORDER BY " + ((ParametrosConsultaLancamentosDTO)parametrosConsulta).getOrdenacao());
565
                        TypedQuery<Parcela> query = getEntityManager().createQuery(sql.toString(), Parcela.class);
566
                        setarQueryParametrosConsulta(query, parametrosConsulta);
567
                        return query.setFirstResult(primeiroRegistro).setMaxResults(tamanhoPagina).getResultList();
568
                } catch(Exception ex) {
569
                        ex.printStackTrace();
570
                        return null;
571
                }
572
        }
573
 
574
        @Override
575
        public List<Parcela> consultarParcelasDaVenda(Long sequencialVenda) {
576
                StringBuilder sql = new StringBuilder();
577
                sql.append("SELECT p FROM Parcela p ");
578
                sql.append("WHERE p.conta.venda.sequencial = :sequencialVenda ");
579
                sql.append("ORDER BY p.dataVencimento ");
580
                try {
581
                        return getEntityManager().createQuery(sql.toString(), Parcela.class).setParameter("sequencialVenda", sequencialVenda).getResultList();
582
                } catch(Exception ex) {
583
                        ex.printStackTrace();
584
                        return null;
585
                }
586
        }
587
 
588
        @Override
589
        public Boolean verificarPossuiParcelaAbertaParaPagamento(Conta conta) {
590
                StringBuilder sql = new StringBuilder();
591
                sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.dataPagamento is null AND p.indicadorAtivo = true ");
592
                sql.append("AND p.conta.sequencial = :sequencialConta ");
593
                TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class);
594
                query.setParameter("sequencialConta", conta.getSequencial());
595
                return query.getSingleResult().intValue()>0;
596
        }
597
 
598
        @Override
599
        public Boolean verificarPossuiParcela(Venda venda) {
600
                StringBuilder sql = new StringBuilder();
601
                sql.append("SELECT COUNT(p) FROM Parcela p WHERE p.indicadorAtivo = true ");
602
                sql.append("AND p.conta.venda.sequencial = :sequencialVenda ");
603
                TypedQuery<Long> query = getEntityManager().createQuery(sql.toString(), Long.class);
604
                query.setParameter("sequencialVenda", venda.getSequencial());
605
                return query.getSingleResult().intValue()>0;
606
        }
607
 
608
 
609
        */
610
}