NFeDistribuicaoDFe - Ambiente de Produção

JavaC Membro Membro desde: 08/07/2013 09:41:16 Mensagens: 52 Offline

tiagoberga

Consegui resolver utilizando o consNSU, segue abaixo:

Alguém teria o arquivo nfeWs.jar, gerado no axis2 1.6.2 ?

JavaC Membro Membro desde: 08/07/2013 09:41:16 Mensagens: 52 Offline

Encontrei..

http://www.javac.com.br/jc/posts/list/1867-nfe-nfce-310-projetos-atualizados.page

JavaC Membro Membro desde: 08/07/2013 09:41:16 Mensagens: 52 Offline

Olá, alguém por favor teria o arquivo DownloadNFe.jar gerado no axis2 1.6.2 ? Se sim poderia postar ?

Eu tentei gerar pelo NfeDownloadNF.wsdl, mas não traz o Stub....

JavaC Membro Membro desde: 08/07/2013 09:41:16 Mensagens: 52 Offline

Segui um tutorial aqui no forum e descobri....

http://www.javac.com.br/jc/posts/list/125-como-gerar-os-arquivos-wsld.page

Para quem quiser, segue arquivo gerado.

JavaC Membro Membro desde: 04/05/2012 14:47:03 Mensagens: 37 Offline

Pessoal, bom dia.

Tenho um aplicativo que faz o download das notas destinadas utilizando o Webservice NfeConsultaDest.

Pela NT 2014/002, ele será substituído pelo Webservice NFeDistribuicaoDFe.

Até aí, tudo bem pois consegui fazer o download usando NfeDistDFeInteresse do JAR disponibilizado aqui no site.

No webservice anterior tínhamos os seguintes eventos:

1 - Consulta destinadas => NFeConsultaDestStub;
2 - Evento de Ciência de Operação (para liberar o download) => RecepcaoEventoStub;
3 - Download do documento => NfeDownloadNFStub.

Para o novo webservice, serão necessários esses passos?
Tipo, primeiro consulta, depois ciência e somente depois o download através do NFeDistribuicaoDFe?

Estou meio perdido aqui pois, ao executar o método do NfeDistDFeInteresse, ele disponibilizou os documentos GZip com NSU.

O meu aplicativo é um pouco complexo pois ele consultava as notas destinadas e o retorno era disponibilizado em uma Grid com os dados e o usuário efetuaria o download somente das que ele quisesse. No momento do download, ele automaticamente fazia a ciência da operação e então o download.

Preciso saber se estes são os passos também para o novo webservice pois o documento não deixa isso muito claro.

Obrigado.

JavaC Membro Membro desde: 13/02/2014 16:12:10 Mensagens: 37 Offline

sauloneves,

Como o seu funciono, poderia compartilha as libs necessárias?

Estou com erro nas libs axis2, estou usando a mesma do projeto anterior, porém sem sucesso.

Cheguei a baixa a ultima versão e também não funcionou.

Att.

Bruno

JavaC Membro Membro desde: 08/07/2013 09:41:16 Mensagens: 52 Offline

brunofilao,

Post toda a mensagem de erro.

Moderador Membro desde: 11/03/2014 10:10:20 Mensagens: 449 Offline

Pessoal, talvez estes arquivos possam ajudá-los:

http://www.javac.com.br/jc/posts/list/2058-schemasxml-e-stubswebservice-download-aqui.page

JavaC Membro Membro desde: 13/02/2014 16:12:10 Mensagens: 37 Offline

Boa Tarde,

O erro que está ocorrendo é esse.

Obrigado.

JavaC Membro Membro desde: 13/02/2014 16:12:10 Mensagens: 37 Offline

Boa Noite,

Consegui resolve meus problemas, utilizei as lib atualizadas postada pelo maciel, o jar postado pelo sauloneves e o link postado pelo tiagoberga.

Segue as 3 classes que utilizei e fiz funcionar a conexão e obtive o retorno com os arquivos compactados.

import java.io.FileInputStream;  
import java.io.IOException;  
import java.net.InetAddress;  
import java.net.InetSocketAddress;  
import java.net.Socket;  
import java.net.SocketAddress;  
import java.net.UnknownHostException;  
import java.security.KeyManagementException;  
import java.security.KeyStore;  
import java.security.KeyStoreException;  
import java.security.NoSuchAlgorithmException;  
import java.security.Principal;  
import java.security.PrivateKey;  
import java.security.cert.CertificateException;  
import java.security.cert.X509Certificate;  
  
import javax.net.SocketFactory;  
import javax.net.ssl.KeyManager;  
import javax.net.ssl.SSLContext;  
import javax.net.ssl.TrustManager;  
import javax.net.ssl.TrustManagerFactory;  
import javax.net.ssl.X509KeyManager;  
  
import org.apache.commons.httpclient.ConnectTimeoutException;  
import org.apache.commons.httpclient.params.HttpConnectionParams;  
import org.apache.commons.httpclient.protocol.ProtocolSocketFactory;

public class SocketFactoryDinamico implements ProtocolSocketFactory {  
    private SSLContext ssl = null;  
    private X509Certificate certificate;  
    private PrivateKey privateKey;  
    private String fileCacerts;  
  
    public SocketFactoryDinamico(X509Certificate certificate,  
            PrivateKey privateKey) {  
        this.certificate = certificate;  
        this.privateKey = privateKey;  
    }  
  
    private SSLContext createSSLContext() {  
        try {  
            KeyManager[] keyManagers = createKeyManagers();  
            TrustManager[] trustManagers = createTrustManagers();  
            SSLContext sslContext = SSLContext.getInstance("TLS");  
            sslContext.init(keyManagers, trustManagers, null);  
  
            return sslContext;  
        } catch (KeyManagementException e) {  
            error(e.toString());  
        } catch (KeyStoreException e) {  
            error(e.toString());  
        } catch (NoSuchAlgorithmException e) {  
            error(e.toString());  
        } catch (CertificateException e) {  
            error(e.toString());  
        } catch (IOException e) {  
            error(e.toString());  
        }  
        return null;  
    }  
  
    private SSLContext getSSLContext() {  
        if (ssl == null) {  
            ssl = createSSLContext();  
        }  
        return ssl;  
    }  
  
    public Socket createSocket(String host, int port, InetAddress localAddress,  
            int localPort, HttpConnectionParams params) throws IOException,  
            UnknownHostException, ConnectTimeoutException {  
        if (params == null) {  
            throw new IllegalArgumentException("Parameters may not be null");  
        }  
        int timeout = params.getConnectionTimeout();  
        SocketFactory socketfactory = getSSLContext().getSocketFactory();  
        if (timeout == 0) {  
            return socketfactory.createSocket(host, port, localAddress,  
                    localPort);  
        }  
  
        Socket socket = socketfactory.createSocket();  
        SocketAddress localaddr = new InetSocketAddress(localAddress, localPort);  
        SocketAddress remoteaddr = new InetSocketAddress(host, port);  
        socket.bind(localaddr);  
        try {  
            socket.connect(remoteaddr, timeout);  
        } catch (Exception e) {  
            error(e.toString());  
            throw new ConnectTimeoutException("Possível timeout de conexão", e);  
        }  
  
        return socket;  
    }  
  
    public Socket createSocket(String host, int port, InetAddress clientHost,  
            int clientPort) throws IOException, UnknownHostException {  
        return getSSLContext().getSocketFactory().createSocket(host, port,  
                clientHost, clientPort);  
    }  
  
    public Socket createSocket(String host, int port) throws IOException,  
            UnknownHostException {  
        return getSSLContext().getSocketFactory().createSocket(host, port);  
    }  
  
    public Socket createSocket(Socket socket, String host, int port,  
            boolean autoClose) throws IOException, UnknownHostException {  
        return getSSLContext().getSocketFactory().createSocket(socket, host,  
                port, autoClose);  
    }  
  
    public KeyManager[] createKeyManagers() {  
        HSKeyManager keyManager = new HSKeyManager(certificate, privateKey);  
  
        return new KeyManager[] { keyManager };  
    }  
  
    public TrustManager[] createTrustManagers() throws KeyStoreException,  
            NoSuchAlgorithmException, CertificateException, IOException {  
        KeyStore trustStore = KeyStore.getInstance("JKS");  
  
        trustStore.load(new FileInputStream(fileCacerts), "changeit".toCharArray());  
        TrustManagerFactory trustManagerFactory = TrustManagerFactory  
                .getInstance(TrustManagerFactory.getDefaultAlgorithm());  
        trustManagerFactory.init(trustStore);  
        return trustManagerFactory.getTrustManagers();  
    }  
  
    class HSKeyManager implements X509KeyManager {  
  
        private X509Certificate certificate;  
        private PrivateKey privateKey;  
  
        public HSKeyManager(X509Certificate certificate, PrivateKey privateKey) {  
            this.certificate = certificate;  
            this.privateKey = privateKey;  
        }  
  
        public String chooseClientAlias(String[] arg0, Principal[] arg1,  
                Socket arg2) {  
            return certificate.getIssuerDN().getName();  
        }  
  
        public String chooseServerAlias(String arg0, Principal[] arg1,  
                Socket arg2) {  
            return null;  
        }  
  
        public X509Certificate[] getCertificateChain(String arg0) {  
            return new X509Certificate[] { certificate };  
        }  
  
        public String[] getClientAliases(String arg0, Principal[] arg1) {  
            return new String[] { certificate.getIssuerDN().getName() };  
        }  
  
        public PrivateKey getPrivateKey(String arg0) {  
            return privateKey;  
        }  
  
        public String[] getServerAliases(String arg0, Principal[] arg1) {  
            return null;  
        }  
    }  
  
    public void setFileCacerts(String fileCacerts) {  
        this.fileCacerts = fileCacerts;  
    }  
  
    /** 
     * Log Error. 
     * @param log 
     */  
    private static void error(String log) {  
        System.out.println("ERROR: " + log);  
    }  
  
}

import java.io.File;  
import java.io.FileInputStream;  
import java.io.FileOutputStream;  
import java.io.InputStream;  
import java.io.OutputStream;  
import java.security.KeyStore;  
import java.security.MessageDigest;  
import java.security.cert.CertificateException;  
import java.security.cert.X509Certificate;  
  
import javax.net.ssl.SSLContext;  
import javax.net.ssl.SSLException;  
import javax.net.ssl.SSLHandshakeException;  
import javax.net.ssl.SSLSocket;  
import javax.net.ssl.SSLSocketFactory;  
import javax.net.ssl.TrustManager;  
import javax.net.ssl.TrustManagerFactory;  
import javax.net.ssl.X509TrustManager;  
  
public class NFeBuildAllCacerts {  
    private static final String JSSECACERTS = "C:/Cacerts/NFeCacerts";  
    private static final int TIMEOUT_WS = 30;  
  
    public static void main(String[] args) {  
        try {  
            char[] passphrase = "changeit".toCharArray();  
  
            File file = new File(JSSECACERTS);  
            if (file.isFile() == false) {  
                char SEP = File.separatorChar;  
                File dir = new File(System.getProperty("java.home") + SEP + "lib" + SEP + "security");  
                file = new File(dir, JSSECACERTS);  
                if (file.isFile() == false) {  
                    file = new File(dir, "cacerts");  
                }  
            }  
  
            info("| Loading KeyStore " + file + "...");  
            InputStream in = new FileInputStream(file);  
            KeyStore ks = KeyStore.getInstance(KeyStore.getDefaultType());  
            ks.load(in, passphrase);  
            in.close();  
           
            get("www1.nfe.fazenda.gov.br", 443, ks);  
  
            File cafile = new File(JSSECACERTS);  
            OutputStream out = new FileOutputStream(cafile);  
            ks.store(out, passphrase);  
            out.close();  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
  
    public static void get(String host, int port, KeyStore ks) throws Exception {  
        SSLContext context = SSLContext.getInstance("TLS");  
        TrustManagerFactory tmf = TrustManagerFactory.getInstance(  
                TrustManagerFactory.getDefaultAlgorithm());  
        tmf.init(ks);  
        X509TrustManager defaultTrustManager = (X509TrustManager) tmf.getTrustManagers()[0];  
        SavingTrustManager tm = new SavingTrustManager(defaultTrustManager);  
        context.init(null, new TrustManager[] { tm }, null);  
        SSLSocketFactory factory = context.getSocketFactory();  
       
        info("| Opening connection to " + host + ":" + port + "...");  
        SSLSocket socket = (SSLSocket) factory.createSocket(host, port);  
        socket.setSoTimeout(TIMEOUT_WS * 1000);  
        try {  
            info("| Starting SSL handshake...");  
            socket.startHandshake();  
            socket.close();  
            info("| No errors, certificate is already trusted");  
        } catch (SSLHandshakeException e) {  
            /** 
             * PKIX path building failed:  
             * sun.security.provider.certpath.SunCertPathBuilderException:  
             * unable to find valid certification path to requested target 
             * Não tratado, pois sempre ocorre essa exceção quando o cacerts 
             * nao esta gerado. 
             */  
        } catch (SSLException e) {  
            error("| " + e.toString());  
        }  
          
        X509Certificate[] chain = tm.chain;  
        if (chain == null) {  
            info("| Could not obtain server certificate chain");  
        }  
  
        info("| Server sent " + chain.length + " certificate(s):");  
        MessageDigest sha1 = MessageDigest.getInstance("SHA1");  
        MessageDigest md5 = MessageDigest.getInstance("MD5");  
        for (int i = 0; i < chain.length; i++) {  
            X509Certificate cert = chain[i];  
            sha1.update(cert.getEncoded());  
            md5.update(cert.getEncoded());  
              
            String alias = host + "-" + (i);  
            ks.setCertificateEntry(alias, cert);  
            info("| Added certificate to keystore '" + JSSECACERTS + "' using alias '" + alias + "'");            
        }  
    }  
  
    private static class SavingTrustManager implements X509TrustManager {  
        private final X509TrustManager tm;  
        private X509Certificate[] chain;  
       
        SavingTrustManager(X509TrustManager tm) {  
            this.tm = tm;  
        }  
       
        public X509Certificate[] getAcceptedIssuers() {  
            throw new UnsupportedOperationException();  
        }  
       
        public void checkClientTrusted(X509Certificate[] chain, String authType)  
            throws CertificateException {  
            throw new UnsupportedOperationException();  
        }  
       
        public void checkServerTrusted(X509Certificate[] chain, String authType)  
            throws CertificateException {  
            this.chain = chain;  
            tm.checkServerTrusted(chain, authType);  
        }  
    }  
      
    private static void info(String log) {  
        System.out.println("INFO: " + log);  
    }  
  
    private static void error(String log) {  
        System.out.println("ERROR: " + log);  
    }  
  
}

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
import java.security.KeyStore;
import java.security.PrivateKey;
import java.security.cert.X509Certificate;
import java.util.Enumeration;

import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.util.AXIOMUtil;
import org.apache.commons.httpclient.protocol.Protocol;

import br.inf.portalfiscal.www.nfe.wsdl.nfedistribuicaodfe.*;
import br.inf.portalfiscal.www.nfe.wsdl.nfedistribuicaodfe.NFeDistribuicaoDFeStub.NfeDadosMsg_type0;
import br.inf.portalfiscal.www.nfe.wsdl.nfedistribuicaodfe.NFeDistribuicaoDFeStub.NfeDistDFeInteresse;
import br.inf.portalfiscal.www.nfe.wsdl.nfedistribuicaodfe.NFeDistribuicaoDFeStub.NfeDistDFeInteresseResponse;

public class DistribuicaoNFE {
	private static final int SSL_PORT = 443;

public static void main(String[] args) {
		try {
			URL url = new URL("https://www1.nfe.fazenda.gov.br/NFeDistribuicaoDFe/NFeDistribuicaoDFe.asmx");

String caminhoDoCertificadoDoCliente = "";
			String senhaDoCertificado = "";
			String arquivoCacertsGeradoTodosOsEstados = "";

InputStream entrada = new FileInputStream(caminhoDoCertificadoDoCliente);
			KeyStore ks = KeyStore.getInstance("pkcs12");
			try {
				ks.load(entrada, senhaDoCertificado.toCharArray());
			} catch (IOException e) {
				throw new Exception(
						"Senha do Certificado Digital esta incorreta ou Certificado inválido.");
			}

String alias = "";
			Enumeration<String> aliasesEnum = ks.aliases();
			while (aliasesEnum.hasMoreElements()) {
				alias = (String) aliasesEnum.nextElement();
				if (ks.isKeyEntry(alias))
					break;
			}
			X509Certificate certificate = (X509Certificate) ks.getCertificate(alias);
			PrivateKey privateKey = (PrivateKey) ks.getKey(alias,senhaDoCertificado.toCharArray());
			SocketFactoryDinamico socketFactoryDinamico = new SocketFactoryDinamico(certificate, privateKey);
			socketFactoryDinamico.setFileCacerts(arquivoCacertsGeradoTodosOsEstados);

Protocol protocol = new Protocol("https", socketFactoryDinamico,SSL_PORT);
			Protocol.registerProtocol("https", protocol);

String dados = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>"
					+ "<distDFeInt xmlns=\"http://www.portalfiscal.inf.br/nfe\" versao=\"1.00\">"
					+ "<tpAmb>1</tpAmb>" 
					+ "<cUFAutor>35</cUFAutor>"
					+ "<CNPJ>07116722000155</CNPJ>" 
					+ "<distNSU>"
					+ "<ultNSU>000000000000000</ultNSU>" 
					+ "</distNSU>" 
					+ "</distDFeInt>";

NfeDistDFeInteresseResponse result = new NfeDistDFeInteresseResponse();
			OMElement ome = AXIOMUtil.stringToOM(dados.trim());
			NfeDadosMsg_type0 dadosMsg = new NfeDadosMsg_type0();
			dadosMsg.setExtraElement(ome);
			NfeDistDFeInteresse distDFeInteresse = new NfeDistDFeInteresse();
			distDFeInteresse.setNfeDadosMsg(dadosMsg);
			NFeDistribuicaoDFeStub stub = new NFeDistribuicaoDFeStub(url.toString());
			result = stub.nfeDistDFeInteresse(distDFeInteresse);
			System.out.println(result);
			System.out.println(result.getNfeDistDFeInteresseResult()
					.getExtraElement().toString());
		} catch (Exception e) {
			System.out.println(e);
		}
		
	}
}

JavaC Membro Membro desde: 13/02/2014 16:12:10 Mensagens: 37 Offline

Bom Dia,

Alguém conseguiu extrair o DocZip do arquivo xml?

Fiz esse metodo, porém sempre está vindo a Lista vazia e no xml contem uns 30 arquivos dentro das tags doczip.

JavaC Membro Membro desde: 04/12/2014 15:03:26 Mensagens: 17 Offline

Olá

Não estou conseguindo baixar o NFeDistribuicaoDFe.wsdl. Alguém poderia compartilhar.

Obrigado