Subversion Repositories Integrator Subversion

Rev

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