Subversion Repositories Integrator Subversion

package br.com.ec.domain.service.impl;

import java.io.ByteArrayOutputStream;

import java.util.List;

import javax.servlet.ServletContext;

import org.apache.poi.openxml4j.opc.OPCPackage;

import org.apache.poi.xwpf.usermodel.XWPFDocument;

import org.apache.poi.xwpf.usermodel.XWPFParagraph;

import org.apache.poi.xwpf.usermodel.XWPFRun;

import org.apache.poi.xwpf.usermodel.XWPFTable;

import org.apache.poi.xwpf.usermodel.XWPFTableCell;

import org.apache.poi.xwpf.usermodel.XWPFTableRow;

import org.primefaces.event.FlowEvent;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import br.com.ec.core.exception.NegocioException;

import br.com.ec.core.generic.AbstractService;

import br.com.ec.core.generic.GenericRepository;

import br.com.ec.core.util.StringUtil;

import br.com.ec.core.util.VerificadorUtil;

import br.com.ec.core.validador.Validador;

import br.com.ec.domain.dto.PessoaDTO;

import br.com.ec.domain.model.Endereco;

import br.com.ec.domain.model.Funcionario;

import br.com.ec.domain.model.Pessoa;

import br.com.ec.domain.model.tipos.TipoComissionamento;

import br.com.ec.domain.model.tipos.TipoDependentes;

import br.com.ec.domain.model.tipos.TipoEscolaridade;

import br.com.ec.domain.model.tipos.TipoEstadoCivil;

import br.com.ec.domain.model.tipos.TipoRacaCor;

import br.com.ec.domain.model.tipos.TipoSexo;

import br.com.ec.domain.service.FuncionarioService;

import br.com.ec.domain.service.PessoaService;

import br.com.ec.repository.PessoaRepository;

@Service

public class PessoaServiceImpl extends AbstractService<Pessoa> implements PessoaService {

        private FuncionarioService funcionarioService;

        private PessoaRepository pessoaRepository;

        @Autowired

        public PessoaServiceImpl(Validador validador, PessoaRepository pessoaRepository, FuncionarioService funcionarioService) {

                super(validador);

                this.pessoaRepository = pessoaRepository;

                this.funcionarioService = funcionarioService;

        }

        @Override

        protected GenericRepository<Pessoa> getRepository() {

                return pessoaRepository;

        }

        @Override

        protected void regrasNegocioCadastrar(Pessoa pessoa) {

                if (VerificadorUtil.estaNulo(pessoa.getCadastroFinalizado())) {

                        pessoa.setCadastroFinalizado(true);

                }

                pessoa.setAtivo(true);

        }

        @Override

        public List<PessoaDTO> consultarPessoasJuridicas(String cnpj) {

                return pessoaRepository.consultarPessoasJuridicas(cnpj);

        }

        @Override

        public Pessoa consultarPessoaPorCpfOuCpnj(String cpfCnpj) {

                return pessoaRepository.consultarPessoaPorCpfOuCpnj(cpfCnpj);

        }

        @Override

        public Pessoa cadastroExterno(FlowEvent evento, Pessoa pessoa, Funcionario funcionario, Endereco endereco) {

                if (VerificadorUtil.estaNulo(evento)) {

                        pessoa.setCpfCnpj(StringUtil.retornarApenasNumeros(pessoa.getCpfCnpj()));

                        Pessoa pessoaConsultada = consultarPessoaPorCpfOuCpnj(StringUtil.retornarApenasNumeros(pessoa.getCpfCnpj()));

                        if (VerificadorUtil.estaNulo(pessoaConsultada)) {

                                pessoa.setCadastroFinalizado(false);

                                this.cadastrar(pessoa);

                                Funcionario funcionarioNovo = new Funcionario(pessoa, TipoComissionamento.COMISSSIONAMENTO_ESPACO_CASE.getValor(), true);

                                funcionarioService.cadastrar(funcionarioNovo);

                                pessoa.setFuncionario(funcionarioNovo);

                                this.alterar(pessoa);

                                return pessoa;

                        }

                        Funcionario funcionarioPessoa = funcionarioService.consultarFuncionarioPelaPessoa(pessoaConsultada.getSequencial());

                        if (VerificadorUtil.estaNulo(funcionarioPessoa)) {

                                Funcionario funcionarioNovo = new Funcionario(pessoaConsultada, TipoComissionamento.COMISSSIONAMENTO_ESPACO_CASE.getValor(), true);

                                funcionarioService.cadastrar(funcionarioNovo);

                                pessoaConsultada.setFuncionario(funcionarioNovo);

                        } else {

                                pessoaConsultada.setFuncionario(funcionarioPessoa);

                        }

                        if (pessoaConsultada.getCadastroFinalizado()) {

                                throw new NegocioException("CADASTRO INDISPONÍVEL");

                        }

                        return pessoaConsultada;

                }

                if (VerificadorUtil.naoEstaNulo(endereco)) {

                        if (VerificadorUtil.naoEstaNuloOuVazio(endereco.getCep())) {

                                pessoa.atualizarEndereco(endereco);

                        }

                }

                this.alterar(pessoa);

                funcionario.setPessoa(pessoa);

                funcionarioService.alterar(funcionario);

                pessoa = detalharPessoa(pessoa.getSequencial());

                pessoa.setFuncionario(funcionarioService.consultarFuncionarioPelaPessoa(pessoa.getSequencial()));

                return pessoa;

        }

        @Override

        public Pessoa detalharPessoa(Long sequencialPessoa) {

                return pessoaRepository.detalharPessoa(sequencialPessoa);

        }

        @Override

        public byte[] emitirFichaColaboradorEsocial(ServletContext contexto, Long sequencialPessoa) {

                Pessoa pessoa = pessoaRepository.detalharPessoa(sequencialPessoa);

                return replaceTextosArquivos("/arquivos/modelos/modelo_formulario_esocial.doc", contexto, pessoa);

        }

        @Override

        public byte[] emitirSolicitacaoExameAdmissional(ServletContext contexto, Long sequencialPessoa) {

                Pessoa pessoa = pessoaRepository.detalharPessoa(sequencialPessoa);

                return replaceTextosArquivos("/arquivos/modelos/modelo_exame_admissional.docx", contexto, pessoa);

        }

        @Override

        public byte[] emitirSolicitacaoExameDemissional(ServletContext contexto, Long sequencialPessoa) {

                Pessoa pessoa = pessoaRepository.detalharPessoa(sequencialPessoa);

                return replaceTextosArquivos("/arquivos/modelos/modelo_exame_demissional.docx", contexto, pessoa);

        }

        @Override

        public byte[] emitirSolicitacaoExamePeriodico(ServletContext contexto, Long sequencialPessoa) {

                Pessoa pessoa = pessoaRepository.detalharPessoa(sequencialPessoa);

                return replaceTextosArquivos("/arquivos/modelos/modelo_exame_periodico.docx", contexto, pessoa);

        }

        @Override

        public byte[] emitirSolicitacaoAberturaContaBancaria(ServletContext contexto, Long sequencialPessoa) {

                Pessoa pessoa = pessoaRepository.detalharPessoa(sequencialPessoa);

                return replaceTextosArquivos("/arquivos/modelos/modelo_abertura_conta.docx", contexto, pessoa);

        }

        @Override

        public byte[] emitirAdesaoValeTransporte(ServletContext contexto, Long sequencialPessoa) {

                Pessoa pessoa = pessoaRepository.detalharPessoa(sequencialPessoa);

                return replaceTextosArquivos("/arquivos/modelos/modelo_adesao_vale_transporte.docx", contexto, pessoa);

        }

        @SuppressWarnings("resource")

        private byte[] replaceTextosArquivos(String caminhoArquivo, ServletContext contexto, Pessoa pessoa) {

                ByteArrayOutputStream baos = new ByteArrayOutputStream();

                XWPFDocument doc;

        try {

                Funcionario funcionario = funcionarioService.consultarFuncionarioPelaPessoa(pessoa.getSequencial());

                        doc = new XWPFDocument(OPCPackage.open(contexto.getResourceAsStream(caminhoArquivo)));

                        for (XWPFParagraph paragrafo : doc.getParagraphs()) {

                                replaceParagrafo(pessoa, funcionario, paragrafo);

                        }

                        for (XWPFTable tbl : doc.getTables()) {

                                for (XWPFTableRow row : tbl.getRows()) {

                                        for (XWPFTableCell cell : row.getTableCells()) {

                                                for (XWPFParagraph p : cell.getParagraphs()) {

                                                        replaceParagrafo(pessoa, funcionario, p);

                                                }

                                        }

                                }

                        }

                doc.write(baos);

                return baos.toByteArray();

                } catch (Exception e) {

                        e.printStackTrace();

                }

        return null;

        }

        private void replaceParagrafo(Pessoa pessoa, Funcionario funcionario, XWPFParagraph paragrafo) {

                String textoParagrafo = "";

                Integer posicao = 0;

                for (XWPFRun r : paragrafo.getRuns()) {

                        if (VerificadorUtil.naoEstaNuloOuVazio(r.text())) {

                                textoParagrafo = textoParagrafo + r.text();

                        }

                        posicao++;

                }

                posicao = 0;

                if (textoParagrafo.contains("#")) {

                        for (XWPFRun r : paragrafo.getRuns()) {

                                if (posicao == 0) {

                                        r.setText(replaceTextos(textoParagrafo, pessoa, funcionario), 0);

                                } else {

                                        r.setText("", 0);

                                }

                                posicao++;

                        }

                }

        }

        private String replaceTextos(String texto, Pessoa pessoa, Funcionario funcionario) {

                texto = replaceTexto(texto, "#NOME", pessoa.getNome());

                texto = replaceTexto(texto, "#CPF", pessoa.getCpfCnpjFormatado());

                texto = replaceTexto(texto, "#RG_NUMERO", pessoa.getRg());

                texto = replaceTexto(texto, "#RG_DATAEXPEDICAO", pessoa.getRgDataExpedicaoFormatada());

                texto = replaceTexto(texto, "#RG_ORGAOEMISSOR", pessoa.getRgOrgaoEmissor());

                texto = replaceTexto(texto, "#NACIONALIDADE", pessoa.getNacionalidade());

                texto = replaceTexto(texto, "#PAI_NOME", pessoa.getNomePai());

                texto = replaceTexto(texto, "#MAE_NOME", pessoa.getNomeMae());

                texto = replaceTexto(texto, "#NASCIMENTO_DATA", pessoa.getDataNascimentoFormatada());

                texto = replaceTexto(texto, "#NASCIMENTO_LOCAL", pessoa.getLocalNascimento());

                texto = replaceTexto(texto, "#NASCIMENTO_UF", pessoa.getUfNascimento());

                texto = replaceTexto(texto, "#EMAIL", pessoa.getEmail());

                texto = replaceTexto(texto, "#TELEFONE", pessoa.getTelefone());

                texto = replaceTexto(texto, "#DEFICIENCIA_MOTORA_SIM", VerificadorUtil.naoEstaNulo(pessoa.getPessoaDeficienteMotora())? pessoa.getPessoaDeficienteMotora()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEFICIENCIA_MOTORA_NAO", VerificadorUtil.naoEstaNulo(pessoa.getPessoaDeficienteMotora())? !pessoa.getPessoaDeficienteMotora()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEFICIENCIA_VISUAL_SIM", VerificadorUtil.naoEstaNulo(pessoa.getPessoaDeficienteMotora())? pessoa.getPessoaDeficienteVisual()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEFICIENCIA_VISUAL_NAO", VerificadorUtil.naoEstaNulo(pessoa.getPessoaDeficienteMotora())? !pessoa.getPessoaDeficienteVisual()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEFICIENCIA_AUDITIVA_SIM", VerificadorUtil.naoEstaNulo(pessoa.getPessoaDeficienteMotora())? pessoa.getPessoaDeficienteAuditiva()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEFICIENCIA_AUDITIVA_NAO", VerificadorUtil.naoEstaNulo(pessoa.getPessoaDeficienteMotora())? !pessoa.getPessoaDeficienteAuditiva()? "X" : " " : " ");

                texto = replaceTexto(texto, "#REABILITADO_SIM", VerificadorUtil.naoEstaNulo(pessoa.getPessoaDeficienteMotora())? pessoa.getPessoaReabilitado()? "X" : " " : " ");

                texto = replaceTexto(texto, "#REABILITADO_NAO", VerificadorUtil.naoEstaNulo(pessoa.getPessoaDeficienteMotora())? !pessoa.getPessoaReabilitado()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEFICIENCIA_OBSERVACOES", pessoa.getPessoaDeficienteObservacao());

                for (TipoDependentes tipoDependente : TipoDependentes.values()) {

                        texto = replaceTexto(texto, "#TIPO_DEPENDENTE[" + tipoDependente.getValor() + "]", VerificadorUtil.naoEstaNulo(pessoa.getTipoEstadoCivil())?

                                        pessoa.getTipoEstadoCivil().equals(tipoDependente.getValor())? "X" : " " : " ");

                }

                texto = replaceTexto(texto, "#DEPENDENTES_DADOS", pessoa.getDadosDependentes());

                texto = replaceTexto(texto, "#DEPENDENTES_IRRF_SIM", VerificadorUtil.naoEstaNulo(pessoa.getDependentesFinsIRRF())? pessoa.getDependentesFinsIRRF()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEPENDENTES_IRRF_NAO", VerificadorUtil.naoEstaNulo(pessoa.getDependentesFinsIRRF())? !pessoa.getDependentesFinsIRRF()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEPENDENTES_SAL_FAMILIA_SIM", VerificadorUtil.naoEstaNulo(pessoa.getDependentesFinsSalarioFamilia())? pessoa.getDependentesFinsSalarioFamilia()? "X" : " " : " ");

                texto = replaceTexto(texto, "#DEPENDENTES_SAL_FAMILIA_NAO", VerificadorUtil.naoEstaNulo(pessoa.getDependentesFinsSalarioFamilia())? !pessoa.getDependentesFinsSalarioFamilia()? "X" : " " : " ");

                for (TipoEstadoCivil estadoCivil : TipoEstadoCivil.values()) {

                        texto = replaceTexto(texto, "#ESTADOCIVIL[" + estadoCivil.getValor() + "]", VerificadorUtil.naoEstaNulo(pessoa.getTipoEstadoCivil())?

                                        pessoa.getTipoEstadoCivil().equals(estadoCivil.getValor())? "X" : " " : " ");

                }

                for (TipoSexo sexo : TipoSexo.values()) {

                        texto = replaceTexto(texto, "#SEXO[" + sexo.getValor() + "]", VerificadorUtil.naoEstaNulo(pessoa.getSexo())?

                                        pessoa.getSexo().equals(sexo.getValor())? "X" : " " : " ");

                }

                for (TipoRacaCor racaCor : TipoRacaCor.values()) {

                        texto = replaceTexto(texto, "#RACA_" + racaCor.getValor(), VerificadorUtil.naoEstaNulo(pessoa.getTipoRacaCor())?

                                        pessoa.getTipoRacaCor().equals(racaCor.getValor())? "X" : " " : " ");

                }

                for (TipoEscolaridade escolaridade : TipoEscolaridade.values()) {

                        texto = replaceTexto(texto, "#ESCOLARIDADE[" + escolaridade.getValor() + "]", VerificadorUtil.naoEstaNulo(pessoa.getTipoEscolaridade())?

                                        pessoa.getTipoEscolaridade().equals(escolaridade.getValor())? "X" : " " : " ");

                }

                if (VerificadorUtil.naoEstaNulo(pessoa.getEnderecoPrincipal())) {

                        texto = replaceTexto(texto, "#ENDERECO_LOGRADOURO", pessoa.getEnderecoPrincipal().getLogradouro());

                        texto = replaceTexto(texto, "#ENDERECO_NUMERO", pessoa.getEnderecoPrincipal().getNumero());

                        texto = replaceTexto(texto, "#ENDERECO_BAIRRO", pessoa.getEnderecoPrincipal().getBairro());

                        texto = replaceTexto(texto, "#ENDERECO_COMPLEMENTO", pessoa.getEnderecoPrincipal().getComplemento());

                        texto = replaceTexto(texto, "#ENDERECO_CIDADE", pessoa.getEnderecoPrincipal().getMunicipio());

                        texto = replaceTexto(texto, "#ENDERECO_CEP", pessoa.getEnderecoPrincipal().getCepFormatado());

                        texto = replaceTexto(texto, "#ENDERECO_PAIS", "BRASIL");

                        texto = replaceTexto(texto, "#ENDERECO_PROPRIA", VerificadorUtil.naoEstaNulo(pessoa.getEnderecoPrincipal().getIndicadorPropria())?

                                        pessoa.getEnderecoPrincipal().getIndicadorPropria()? "X" : " " : " ");

                        texto = replaceTexto(texto, "#ENDERECO_NAOPROPRIA", VerificadorUtil.naoEstaNulo(pessoa.getEnderecoPrincipal().getIndicadorPropria())?

                                        !pessoa.getEnderecoPrincipal().getIndicadorPropria()? "X" : " " : " ");

                        texto = replaceTexto(texto, "#ENDERECO_COM_FGTS", VerificadorUtil.naoEstaNulo(pessoa.getEnderecoPrincipal().getIndicadorUsoFgts())?

                                        !pessoa.getEnderecoPrincipal().getIndicadorUsoFgts()? "X" : " " : " ");

                        texto = replaceTexto(texto, "#ENDERECO_SEM_FGTS", VerificadorUtil.naoEstaNulo(pessoa.getEnderecoPrincipal().getIndicadorUsoFgts())?

                                        !pessoa.getEnderecoPrincipal().getIndicadorUsoFgts()? "X" : " " : " ");

                }

                if (VerificadorUtil.naoEstaNulo(funcionario)) {

                        texto = replaceTexto(texto, "#PIS", funcionario.getPis());

                        texto = replaceTexto(texto, "#CTPS_NUMERO", funcionario.getCtps());

                        texto = replaceTexto(texto, "#CTPS_SERIE", funcionario.getCtpsSerie());

                        texto = replaceTexto(texto, "#CTPS_UF", funcionario.getCtpsUf());

                        texto = replaceTexto(texto, "#PRIMEIRO_EMPREGO_SIM", VerificadorUtil.naoEstaNulo(funcionario.getPrimeiroEmprego())? funcionario.getPrimeiroEmprego()? "X" : " " : " ");

                        texto = replaceTexto(texto, "#PRIMEIRO_EMPREGO_NAO", VerificadorUtil.naoEstaNulo(funcionario.getPrimeiroEmprego())? !funcionario.getPrimeiroEmprego()? "X" : " " : " ");

                        texto = replaceTexto(texto, "#OPTANTE_FGTS_SIM", VerificadorUtil.naoEstaNulo(funcionario.getOptantePeloFGTS())? funcionario.getOptantePeloFGTS()? "X" : " " : " ");

                        texto = replaceTexto(texto, "#OPTANTE_FGTS_NAO", VerificadorUtil.naoEstaNulo(funcionario.getOptantePeloFGTS())? !funcionario.getOptantePeloFGTS()? "X" : " " : " ");

                }

                return texto;

        }

        private String replaceTexto(String texto, String codigo, String campo) {

                if (texto != null && texto.contains(codigo)) {

                        if (VerificadorUtil.naoEstaNulo(campo)) {

                                return texto.replace(codigo, campo);

                        } else {

                                return texto.replace(codigo, " ");

                        }

        }

                return texto;

        }

        /*

        @Override

        public List<Pessoa> consultarPessoasJuridicas() {

                return pessoaRepository.consultarPessoasJuridicas();

        }

        */

}