Subversion Repositories Integrator Subversion

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

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.util.List;

import java.util.zip.ZipEntry;

import java.util.zip.ZipOutputStream;

import javax.inject.Inject;

import javax.servlet.ServletContext;

import org.primefaces.model.DefaultStreamedContent;

import org.primefaces.model.StreamedContent;

import org.springframework.stereotype.Service;

import br.com.ec.controller.util.PdfUtil;

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.TipoExtensao;

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

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

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

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

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

import br.com.ec.domain.service.arquivo.ArquivoService;

import br.com.ec.domain.service.email.impl.GerenciadorEmailImpl;

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

@Service

public class ArquivoServiceImpl extends AbstractService<ArquivoDTO> implements ArquivoService {

        private FuncionarioService funcionarioService;

        @Inject

        public ArquivoServiceImpl(Validador validador, FuncionarioService funcionarioService) {

                super(validador);

                this.funcionarioService = funcionarioService;

        }

        @Override

        protected GenericRepository<ArquivoDTO> getRepository() {

                return null;

        }

        @Override

        public StreamedContent gerarRecibos(ArquivoDTO arquivoDTO, ServletContext contexto) {

                ByteArrayInputStream input = new ByteArrayInputStream(gerarAquivos(arquivoDTO, contexto));

                return new DefaultStreamedContent(input, "application/zip", "recibos.zip");

        }

        private byte[] gerarAquivos(ArquivoDTO arquivoDTO, ServletContext contexto) {

                ByteArrayOutputStream bytesOut = new ByteArrayOutputStream();

                ZipOutputStream out = new ZipOutputStream(bytesOut);

                try {

                        List<byte[]> arquivos = PdfUtil.separarPDF(arquivoDTO.getArquivo());

                        int numeroArquivo = 1;

                        for (byte[] arquivo : arquivos) {

                                adicionarPaginaNoZip(arquivo, "recibo_" + numeroArquivo, ".pdf", out);

                                numeroArquivo++;

                        }

                } catch (IOException e) {

                        e.printStackTrace();

                } finally {

                        try {

                                out.close();

                        } catch (IOException e) {

                                e.printStackTrace();

                        }

        }

                return bytesOut.toByteArray();

        }

        private void adicionarPaginaNoZip(byte[] input, String nomeArquivo, String extensaoArquivo, ZipOutputStream out) {

                try {

                        ZipEntry newEntry = new ZipEntry(nomeArquivo + extensaoArquivo);

                out.putNextEntry(newEntry);

                out.write(input, 0, input.length);

                out.closeEntry();

                } catch (Exception e) {

                        e.printStackTrace();

                }

        }

        @Override

        public ArquivoDTO separarRecibos(ArquivoDTO arquivoDTO, String empresa, ServletContext servletContext) {

                List<byte[]> arquivos;

                try {

                        if (VerificadorUtil.estaNulo(empresa)) {

                                throw new NegocioException("SELECIONE A EMPRESA");

                        }

                        arquivos = PdfUtil.separarPDF(arquivoDTO.getArquivo());

                        int i = 1;

                        for (byte[] arquivo : arquivos) {

                                Funcionario funcionario = funcionarioService.consultarPorCodigoContabilidade(recuperarCodigoContabilidadeEmTexto(arquivo), empresa);

                                if (VerificadorUtil.naoEstaNulo(funcionario)) {

                                        funcionario.setValorLiquido(recuperarValorLiquidoEmTexto(arquivo));

                                        ArquivoFuncionarioDTO arquivoFuncionarioDTO = new ArquivoFuncionarioDTO();

                                        arquivoFuncionarioDTO.setArquivo(arquivo);

                                        arquivoFuncionarioDTO.setExtensao(TipoExtensao.PDF.getValue());

                                        arquivoFuncionarioDTO.setFuncionario(funcionario);

                                        arquivoDTO.getArquivosFuncionarios().add(arquivoFuncionarioDTO);

                                }

                                i++;

                        }

                } catch (IOException e) {

                        e.printStackTrace();

                        throw new NegocioException(e.getMessage());

                }

                return arquivoDTO;

        }

        @Override

        public void enviarRecibos(ArquivoDTO arquivoDTO, String empresa, ServletContext servletContext) {

                for (ArquivoFuncionarioDTO arquivoFuncionario : arquivoDTO.getArquivosFuncionarios()) {

                        Funcionario funcionario = funcionarioService.consultarPorCodigoContabilidade(recuperarCodigoContabilidadeEmTexto(arquivoFuncionario.getArquivo()), empresa);

                        if (VerificadorUtil.naoEstaNulo(funcionario) && arquivoFuncionario.getEnviarEmail()) {

                                if (VerificadorUtil.naoEstaNuloOuVazio(funcionario.getEmailDaPessoa())) {

                                        new GerenciadorEmailImpl()

                                                .comEmailsDestino(funcionario.getEmailDaPessoa())

                                                .comAssunto(arquivoDTO.getTituloEmail())

                                                .comConteudoHtml("RECIBO DE PAGAMENTO EM ANEXO.")

                                                .adicionarAnexo("Recibo de Pagamento - " + funcionario.getNomeDaPessoa() + "." + TipoExtensao.PDF.getValue(), arquivoFuncionario.getArquivo(), arquivoFuncionario.getExtensao())

                                                .enviar();

//                                      GerenciadorEmailImpl gerenciadorEmail = new GerenciadorEmailImpl();

//                                      gerenciadorEmail.setDestinatarios(funcionario.getEmailDaPessoa());

//                                      gerenciadorEmail.setAssunto(arquivoDTO.getTituloEmail());

//                                      gerenciadorEmail.setConteudo("Em anexo.");

//                                      gerenciadorEmail.setNomeArquivo("Recibo de Pagamento - " + funcionario.getNomeDaPessoa() + "." + TipoExtensao.PDF.getValue());

//                                      gerenciadorEmail.setArquivoAnexo(arquivoFuncionario.getArquivo());

//                                      gerenciadorEmail.setContentTypeAnexo(arquivoFuncionario.getExtensao());

//                                      gerenciadorEmail.enviarEmail();

                                }

                        }

                }

        }

        @Override

        public void separarEnviarRecibos(ArquivoDTO arquivoDTO, String empresa, ServletContext servletContext) {

                List<byte[]> arquivos;

                try {

                        arquivos = PdfUtil.separarPDF(arquivoDTO.getArquivo());

                        int i = 1;

                        for (byte[] arquivo : arquivos) {

                                Funcionario funcionario = funcionarioService.consultarPorCodigoContabilidade(recuperarCodigoContabilidadeEmTexto(arquivo), empresa);

                                if (VerificadorUtil.naoEstaNulo(funcionario)) {

                                        if (VerificadorUtil.naoEstaNuloOuVazio(funcionario.getEmailDaPessoa())) {

                                                // enviarEmailComArquivoEmAnexo

                                                System.out.println(funcionario.getNomeDaPessoa());

                                                System.out.println(funcionario.getEmailDaPessoa());

                                        }

                                }

                                i++;

                        }

                } catch (IOException e) {

                        e.printStackTrace();

                }

        }

        private Integer recuperarCodigoContabilidadeEmTexto(byte[] arquivo) {

                String codigo = recuperarTexto("CC:", arquivo);

                return VerificadorUtil.naoEstaNuloOuVazio(codigo)? new Integer(codigo) : null;

        }

        private Double recuperarValorLiquidoEmTexto(byte[] arquivo) {

                try {

                        String valorLiquido = recuperarTexto(3, arquivo);

                        valorLiquido = valorLiquido.replace(".", "").replace(",", ".");

                        return Double.parseDouble(valorLiquido);

                } catch (Exception e) {}

                return null;

        }

        private String recuperarNomeEmTexto(byte[] arquivo) {

                return recuperarTexto("Código", arquivo);

        }

        private String recuperarTexto(Integer capturarLinha, byte[] arquivo) {

                try {

                        Integer numeroLinha = 1;

                        String[] linhas = PdfUtil.extrairPDFEmLinhas(arquivo);

                        for (String linha : linhas) {

                                if (capturarLinha == numeroLinha) {

                                        return linha.trim();

                                }

                                numeroLinha++;

                        }

                } catch (IOException e) {

                        e.printStackTrace();

                }

                return "";

        }

        private String recuperarTexto(String contemLinha, byte[] arquivo) {

                try {

                        String[] linhas = PdfUtil.extrairPDFEmLinhas(arquivo);

                        boolean capturar = false;

                        for (String linha : linhas) {

                                if (capturar) {

                                        return linha.trim();

                                }

                                if (linha.contains(contemLinha)) {

                                        capturar = true;

                                }

                        }

                } catch (IOException e) {

                        e.printStackTrace();

                }

                return "";

        }

}