Subversion Repositories Integrator Subversion

Rev

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
}