Subversion Repositories Integrator Subversion

Rev

Rev 265 | Rev 299 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 265 Rev 297
Line 2... Line 2...
2
2
3
import java.util.List;
3
import java.util.List;
-
 
4
-
 
5
import javax.persistence.Query;
4
6
5
import org.springframework.stereotype.Repository;
7
import org.springframework.stereotype.Repository;
6
8
-
 
9
import br.com.ec.core.consulta.ParametrosConsulta;
-
 
10
import br.com.ec.core.util.VerificadorUtil;
7
import br.com.ec.domain.dto.PessoaDTO;
11
import br.com.ec.domain.dto.PessoaDTO;
-
 
12
import br.com.ec.domain.dto.consulta.ParametrosConsultaPessoasDTO;
8
import br.com.ec.domain.model.Pessoa;
13
import br.com.ec.domain.model.Pessoa;
9
import br.com.ec.repository.PessoaRepository;
14
import br.com.ec.repository.PessoaRepository;
10
import br.com.ec.repository.SistemaAbstractRepository;
15
import br.com.ec.repository.SistemaAbstractRepository;
11
16
12
@Repository
17
@Repository
Line 15... Line 20...
15
        @Override
20
        @Override
16
        protected String getColunaOrdenadora() {
21
        protected String getColunaOrdenadora() {
17
                return "nome";
22
                return "nome";
18
        }
23
        }
19
       
24
       
20
        @Override
-
 
21
        public List<PessoaDTO> consultarPessoasJuridicas(String cnpj) {
-
 
22
                StringBuilder jpql = new StringBuilder();
-
 
23
                jpql.append("SELECT new br.com.ec.domain.dto.PessoaDTO(p.sequencial, p.nome, p.tipoPessoa, p.cpfCnpj) ");
-
 
24
                jpql.append("FROM Pessoa p ");
-
 
25
                jpql.append("WHERE p.cpfCnpj LIKE :cnpj ");
-
 
26
                jpql.append("ORDER BY p.cpfCnpj ");
-
 
27
                try {
-
 
28
                        return getEntityManager().createQuery(jpql.toString(), PessoaDTO.class).setParameter("cnpj", cnpj).getResultList();
-
 
29
                } catch(Exception ex) {
-
 
30
                        ex.printStackTrace();
-
 
31
                        return null;
-
 
32
                }
-
 
33
        }
-
 
34
       
-
 
35
        /*
-
 
36
        @Override
25
        @Override
37
        protected void setarStringParametrosConsulta(StringBuilder sql, ParametrosConsulta<Pessoa> parametros) {
26
        protected void setarStringParametrosConsulta(StringBuilder sql, ParametrosConsulta<Pessoa> parametros) {
38
                if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaPessoaDTO)parametros).getEntidade())) {
-
 
39
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaPessoaDTO)parametros).getEntidade().getNome())) {
-
 
-
 
27
                if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaPessoasDTO)parametros).getEntidade())) {
-
 
28
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaPessoasDTO)parametros).getEntidade().getNome())) {
40
                                sql.append("AND ");
29
                                sql.append("AND ");
41
                                sql.append(sqlConsultarSemAcento("e.nome"));
30
                                sql.append(sqlConsultarSemAcento("e.nome"));
42
                                sql.append(" like upper(:nomePessoa) ");
31
                                sql.append(" like upper(:nomePessoa) ");
43
                        }
32
                        }
44
                }
33
                }
45
                if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaPessoaDTO)parametros).getConsultarColaboradores())) {
-
 
46
                        if (((ParametrosConsultaPessoaDTO)parametros).getConsultarColaboradores().equals(ConstantesSEC.Pessoa.CONSULTAR_COLABORADORES_C)) {
-
 
-
 
34
                /*
-
 
35
                if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaPessoasDTO)parametros).getConsultarColaboradores())) {
-
 
36
                        if (((ParametrosConsultaPessoasDTO)parametros).getConsultarColaboradores().equals(ConstantesSEC.Pessoa.CONSULTAR_COLABORADORES_C)) {
47
                                sql.append("AND EXISTS (SELECT f FROM Funcionario f WHERE f.pessoa.sequencial = e.sequencial AND (f.admissao != null OR f.demissao != null)) ");
37
                                sql.append("AND EXISTS (SELECT f FROM Funcionario f WHERE f.pessoa.sequencial = e.sequencial AND (f.admissao != null OR f.demissao != null)) ");
48
                        } else if (((ParametrosConsultaPessoaDTO)parametros).getConsultarColaboradores().equals(ConstantesSEC.Pessoa.CONSULTAR_COLABORADORES_ADMITIDOS_A)) {
38
                        } else if (((ParametrosConsultaPessoaDTO)parametros).getConsultarColaboradores().equals(ConstantesSEC.Pessoa.CONSULTAR_COLABORADORES_ADMITIDOS_A)) {
49
                                sql.append("AND EXISTS (SELECT f FROM Funcionario f WHERE f.pessoa.sequencial = e.sequencial AND f.admissao != null AND f.demissao is null) ");
39
                                sql.append("AND EXISTS (SELECT f FROM Funcionario f WHERE f.pessoa.sequencial = e.sequencial AND f.admissao != null AND f.demissao is null) ");
50
                        } else if (((ParametrosConsultaPessoaDTO)parametros).getConsultarColaboradores().equals(ConstantesSEC.Pessoa.CONSULTAR_COLABORADORES_DEMITIDOS_D)) {
40
                        } else if (((ParametrosConsultaPessoaDTO)parametros).getConsultarColaboradores().equals(ConstantesSEC.Pessoa.CONSULTAR_COLABORADORES_DEMITIDOS_D)) {
51
                                sql.append("AND EXISTS (SELECT f FROM Funcionario f WHERE f.pessoa.sequencial = e.sequencial AND f.admissao != null AND f.demissao != null) ");
41
                                sql.append("AND EXISTS (SELECT f FROM Funcionario f WHERE f.pessoa.sequencial = e.sequencial AND f.admissao != null AND f.demissao != null) ");
52
                        }
42
                        }
53
                }
43
                }
-
 
44
                */
54
        }
45
        }
55

46
56
        @Override
47
        @Override
57
        protected void setarQueryParametrosConsulta(Query query, ParametrosConsulta<Pessoa> parametros) {
48
        protected void setarQueryParametrosConsulta(Query query, ParametrosConsulta<Pessoa> parametros) {
58
                if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaPessoaDTO)parametros).getEntidade())) {
-
 
59
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaPessoaDTO)parametros).getEntidade().getNome())) {
-
 
60
                                query.setParameter("nomePessoa", "%" + removerAcentuacao(((ParametrosConsultaPessoaDTO)parametros).getEntidade().getNome()) + "%");
-
 
-
 
49
                if (VerificadorUtil.naoEstaNuloOuVazio(((ParametrosConsultaPessoasDTO)parametros).getEntidade())) {
-
 
50
                        if (VerificadorUtil.naoEstaNulo(((ParametrosConsultaPessoasDTO)parametros).getEntidade().getNome())) {
-
 
51
                                query.setParameter("nomePessoa", "%" + removerAcentuacao(((ParametrosConsultaPessoasDTO)parametros).getEntidade().getNome()) + "%");
61
                        }
52
                        }
62
                }
53
                }
63
        }
54
        }
64
       
55
       
-
 
56
        /************************************************************************************/
-
 
57
       
-
 
58
        @Override
-
 
59
        public List<PessoaDTO> consultarPessoasJuridicas(String cnpj) {
-
 
60
                StringBuilder jpql = new StringBuilder();
-
 
61
                jpql.append("SELECT new br.com.ec.domain.dto.PessoaDTO(p.sequencial, p.nome, p.tipoPessoa, p.cpfCnpj) ");
-
 
62
                jpql.append("FROM Pessoa p ");
-
 
63
                jpql.append("WHERE p.cpfCnpj LIKE :cnpj ");
-
 
64
                jpql.append("ORDER BY p.cpfCnpj ");
-
 
65
                try {
-
 
66
                        return getEntityManager().createQuery(jpql.toString(), PessoaDTO.class).setParameter("cnpj", cnpj).getResultList();
-
 
67
                } catch(Exception ex) {
-
 
68
                        ex.printStackTrace();
-
 
69
                        return null;
-
 
70
                }
-
 
71
        }
-
 
72
       
-
 
73
        /************************************************************************************/
-
 
74
       
-
 
75
        /*
65
        @Override
76
        @Override
66
        public Pessoa detalharPessoa(Pessoa pessoa) {
77
        public Pessoa detalharPessoa(Pessoa pessoa) {
67
                StringBuilder jpql = new StringBuilder();
78
                StringBuilder jpql = new StringBuilder();
68
                jpql.append("SELECT p FROM Pessoa p ");
79
                jpql.append("SELECT p FROM Pessoa p ");
69
                jpql.append("LEFT JOIN FETCH p.papeis pp ");
80
                jpql.append("LEFT JOIN FETCH p.papeis pp ");