nfe
nfe copied to clipboard
wmixvideo
[DUVIDA] Estou com dificuldade de fazer a integração do NFE com meu projeto quarkus
Montei a base da implementação:
package com.divinavia;
import org.eclipse.microprofile.reactive.messaging.Incoming;
import org.jboss.logging.Logger;
import com.divinavia.config.ConfigSefaz;
import com.divinavia.model.NFEModel;
import com.fincatto.documentofiscal.DFModelo;
import com.fincatto.documentofiscal.DFUnidadeFederativa;
import com.fincatto.documentofiscal.nfe400.classes.statusservico.consulta.NFStatusServicoConsultaRetorno;
import com.fincatto.documentofiscal.nfe400.webservices.WSFacade;
import io.smallrye.mutiny.Uni;
import io.smallrye.reactive.messaging.kafka.Record;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
/**
* Um bean consumindo dados do tópico "nfe-in" do Kafka e processando as NFEs de forma assíncrona.
*/
@ApplicationScoped
public class NFEProcessor {
// Exemplo: se houver um serviço para envio de NFE, poderá ser injetado aqui
// @Inject
// NFEService nfeService;
@Inject
Logger logger;
@Incoming("nfe-in")
public Uni<Void> process(Record<String, NFEModel> record) {
// Exemplo de processamento assíncrono utilizando o Mutiny
return Uni.createFrom().item(record)
.onItem().invoke(rec -> {
logger.info("Processando envio da NFE: " + rec.key());
})
// Realiza a chamada bloqueante em um contexto assíncrono apropriado
.onItem().transformToUni(rec ->
Uni.createFrom().item(() -> {
NFEModel nfe = rec.value();
// Simulação do processamento da NFE
nfe.status = "Enviado";
// Configuração e chamada do endpoint SOAP
ConfigSefaz config = new ConfigSefaz(DFUnidadeFederativa.SP);
try {
NFStatusServicoConsultaRetorno retorno = new WSFacade(config)
.consultaStatus(config.getCUF(), DFModelo.NFE);
logger.info("Status SOAP: " + retorno.getStatus());
logger.info("Motivo SOAP: " + retorno.getMotivo());
} catch (Exception e) {
logger.error("Erro ao enviar NFE: " + e.getLocalizedMessage());
}
return rec;
})
// Se necessário, execute essa operação em um executor específico para evitar bloqueios
.runSubscriptionOn(io.smallrye.mutiny.infrastructure.Infrastructure.getDefaultWorkerPool())
)
.replaceWithVoid();
}
}
porem mesmo assim nunca está funcionando na hora que vai fazer a primeira request a parte do ConfigSefaz:
package com.divinavia.config;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.security.KeyStore;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.CertificateException;
import com.fincatto.documentofiscal.DFUnidadeFederativa;
import com.fincatto.documentofiscal.nfe.NFeConfig;
public class ConfigSefaz extends NFeConfig {
private static final String CERTIFICADO_SENHA = "senha";
private KeyStore keyStoreCertificado = null;
private KeyStore keyStoreCadeia = null;
private final DFUnidadeFederativa cUF;
public ConfigSefaz(DFUnidadeFederativa cUF) {
this.cUF = cUF;
}
@Override
public DFUnidadeFederativa getCUF() {
return cUF;
}
@Override
public String getCertificadoSenha() {
return CERTIFICADO_SENHA;
}
@Override
public String getCadeiaCertificadosSenha() {
return CERTIFICADO_SENHA;
}
@Override
public KeyStore getCertificadoKeyStore() throws KeyStoreException {
if (this.keyStoreCertificado == null) {
this.keyStoreCertificado = KeyStore.getInstance("PKCS12");
try (InputStream certificadoStream = new FileInputStream("./temp/certificado.pfx")) {
this.keyStoreCertificado.load(certificadoStream, this.getCertificadoSenha().toCharArray());
} catch (CertificateException | NoSuchAlgorithmException | IOException e) {
this.keyStoreCertificado = null;
throw new KeyStoreException("Não foi possível montar o KeyStore com o certificado", e);
}
}
System.out.println("keyStoreCertificado: " + this.keyStoreCertificado);
return this.keyStoreCertificado;
}
@Override
public KeyStore getCadeiaCertificadosKeyStore() throws KeyStoreException {
if (this.keyStoreCadeia == null) {
this.keyStoreCadeia = KeyStore.getInstance("JKS");
try (InputStream cadeia = new FileInputStream("./temp/cadeia.jks")) {
this.keyStoreCadeia.load(cadeia, this.getCadeiaCertificadosSenha().toCharArray());
} catch (CertificateException | NoSuchAlgorithmException | IOException e) {
this.keyStoreCadeia = null;
throw new KeyStoreException("Não foi possível montar o KeyStore com a cadeia de certificados", e);
}
}
System.out.println("keyStoreCadeia: " + this.keyStoreCadeia);
return this.keyStoreCadeia;
}
}
O erro do retornando:
2025-02-04 21:51:58,921 INFO [io.sma.rea.mes.kafka] (vert.x-eventloop-thread-0) SRMSG18256: Initialize record store for topic-partition 'nfe-0' at position 25.
2025-02-04 21:51:58,951 INFO [com.div.NFEProcessor] (vert.x-eventloop-thread-0) Processando envio da NFE: "hml-21"
2025-02-04 21:51:58,951 INFO [com.div.NFEProcessor] (vert.x-eventloop-thread-0) Chave: 00000000000000000000000000000000000000000000
2025-02-04 21:51:58,951 INFO [com.div.NFEProcessor] (vert.x-eventloop-thread-0) Emitente: Empresa XYZ LTDA
2025-02-04 21:51:58,952 INFO [com.div.NFEProcessor] (vert.x-eventloop-thread-0) Destinatário: Cliente ABC
2025-02-04 21:51:58,952 INFO [com.div.NFEProcessor] (vert.x-eventloop-thread-0) Data: 2024-02-04
2025-02-04 21:51:58,952 INFO [com.div.NFEProcessor] (vert.x-eventloop-thread-0) Valor: 1500.00
2025-02-04 21:51:58,952 INFO [com.div.NFEProcessor] (vert.x-eventloop-thread-0) Status: Autorizada
keyStoreCertificado: java.security.KeyStore@20906d5d
keyStoreCadeia: java.security.KeyStore@7c01fff9
2025-02-04 21:51:59,148 WARNING [org.apa.axi.uti.sta.dia.StAXDialectDetector] (executor-thread-1) Unable to determine dialect of the StAX implementation at jar:file:///Users/rodrigosouza/.m2/repository/com/fasterxml/woodstox/woodstox-core/6.6.0/woodstox-core-6.6.0.jar!/
2025-02-04 21:51:59,230 WARNING [org.apa.axi.dep.AxisConfigBuilder] (executor-thread-1) Unable to instantiate deployer org.apache.axis2.deployment.ServiceDeployer; see debug logs for more details
2025-02-04 21:51:59,493 INFO [org.apa.com.htt.HttpMethodDirector] (executor-thread-1) I/O exception (org.apache.axis2.AxisFault) caught when processing request: Connection or outbound has closed
2025-02-04 21:51:59,494 INFO [org.apa.com.htt.HttpMethodDirector] (executor-thread-1) Retrying request
2025-02-04 21:51:59,610 INFO [org.apa.com.htt.HttpMethodDirector] (executor-thread-1) I/O exception (org.apache.axis2.AxisFault) caught when processing request: Connection or outbound has closed
2025-02-04 21:51:59,610 INFO [org.apa.com.htt.HttpMethodDirector] (executor-thread-1) Retrying request
2025-02-04 21:51:59,717 INFO [org.apa.com.htt.HttpMethodDirector] (executor-thread-1) I/O exception (org.apache.axis2.AxisFault) caught when processing request: Connection or outbound has closed
2025-02-04 21:51:59,718 INFO [org.apa.com.htt.HttpMethodDirector] (executor-thread-1) Retrying request
2025-02-04 21:51:59,828 INFO [org.apa.axi.tra.htt.imp.htt.HTTPSenderImpl] (executor-thread-1) Unable to sendViaPost to url[https://homologacao.nfe.fazenda.sp.gov.br/ws/nfestatusservico4.asmx]
Exception in NFEProcessor.java:57
55 try {
56 NFStatusServicoConsultaRetorno retorno = new WSFacade(config)
→ 57 .consultaStatus(config.getCUF(), DFModelo.NFE);
58
59
Exception in NFEProcessor.java:57
55 try {
56 NFStatusServicoConsultaRetorno retorno = new WSFacade(config)
→ 57 .consultaStatus(config.getCUF(), DFModelo.NFE);
58
59
: org.apache.axis2.AxisFault: Connection or outbound has closed
at org.apache.axis2.AxisFault.makeFault(AxisFault.java:430)
at org.apache.axis2.transport.http.SOAPMessageFormatter.writeTo(SOAPMessageFormatter.java:78)
at org.apache.axis2.transport.http.AxisRequestEntity.writeRequest(AxisRequestEntity.java:85)
at org.apache.commons.httpclient.methods.EntityEnclosingMethod.writeRequestBody(EntityEnclosingMethod.java:499)
at org.apache.commons.httpclient.HttpMethodBase.writeRequest(HttpMethodBase.java:2114)
at org.apache.commons.httpclient.HttpMethodBase.execute(HttpMethodBase.java:1096)
at org.apache.commons.httpclient.HttpMethodDirector.executeWithRetry(HttpMethodDirector.java:398)
at org.apache.commons.httpclient.HttpMethodDirector.executeMethod(HttpMethodDirector.java:171)
at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:397)
at org.apache.axis2.transport.http.impl.httpclient3.HTTPSenderImpl.executeMethod(HTTPSenderImpl.java:872)
at org.apache.axis2.transport.http.impl.httpclient3.HTTPSenderImpl.sendViaPost(HTTPSenderImpl.java:212)
at org.apache.axis2.transport.http.HTTPSender.send(HTTPSender.java:121)
at org.apache.axis2.transport.http.CommonsHTTPTransportSender.writeMessageWithCommons(CommonsHTTPTransportSender.java:403)
at org.apache.axis2.transport.http.CommonsHTTPTransportSender.invoke(CommonsHTTPTransportSender.java:234)
at org.apache.axis2.engine.AxisEngine.send(AxisEngine.java:431)
at org.apache.axis2.description.OutInAxisOperationClient.send(OutInAxisOperation.java:399)
at org.apache.axis2.description.OutInAxisOperationClient.executeImpl(OutInAxisOperation.java:225)
at org.apache.axis2.client.OperationClient.execute(OperationClient.java:150)
at com.fincatto.documentofiscal.nfe400.webservices.statusservico.consulta.NfeStatusServico4Stub.nfeStatusServicoNF(NfeStatusServico4Stub.java:110)
at com.fincatto.documentofiscal.nfe400.webservices.WSStatusConsulta.efetuaConsultaStatus(WSStatusConsulta.java:53)
at com.fincatto.documentofiscal.nfe400.webservices.WSStatusConsulta.consultaStatus(WSStatusConsulta.java:29)
at com.fincatto.documentofiscal.nfe400.webservices.WSFacade.consultaStatus(WSFacade.java:137)
at com.divinavia.NFEProcessor.lambda$2(NFEProcessor.java:57)
at io.smallrye.context.impl.wrappers.SlowContextualSupplier.get(SlowContextualSupplier.java:21)
at io.smallrye.mutiny.operators.uni.builders.UniCreateFromItemSupplier.subscribe(UniCreateFromItemSupplier.java:28)
at io.smallrye.mutiny.operators.AbstractUni.subscribe(AbstractUni.java:36)
at io.smallrye.mutiny.operators.uni.UniRunSubscribeOn.lambda$subscribe$0(UniRunSubscribeOn.java:27)
at io.quarkus.vertx.core.runtime.VertxCoreRecorder$15.runWith(VertxCoreRecorder.java:639)
at org.jboss.threads.EnhancedQueueExecutor$Task.doRunWith(EnhancedQueueExecutor.java:2675)
at org.jboss.threads.EnhancedQueueExecutor$Task.run(EnhancedQueueExecutor.java:2654)
at org.jboss.threads.EnhancedQueueExecutor.runThreadBody(EnhancedQueueExecutor.java:1627)
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1594)
at org.jboss.threads.DelegatingRunnable.run(DelegatingRunnable.java:11)
at org.jboss.threads.ThreadLocalResettingRunnable.run(ThreadLocalResettingRunnable.java:11)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: com.ctc.wstx.exc.WstxIOException: Connection or outbound has closed
at com.ctc.wstx.sw.BaseStreamWriter.flush(BaseStreamWriter.java:262)
at org.apache.axiom.om.impl.MTOMXMLStreamWriter.flush(MTOMXMLStreamWriter.java:231)
at org.apache.axiom.om.impl.MTOMXMLStreamWriter.close(MTOMXMLStreamWriter.java:223)
at org.apache.axiom.om.impl.common.AxiomContainerSupport.ajc$interMethod$org_apache_axiom_om_impl_common_AxiomContainerSupport$org_apache_axiom_om_impl_intf_AxiomContainer$serializeAndConsume(AxiomContainerSupport.aj:324)
at org.apache.axiom.om.impl.llom.OMElementImpl.serializeAndConsume(OMElementImpl.java:1)
at org.apache.axis2.transport.http.SOAPMessageFormatter.writeTo(SOAPMessageFormatter.java:74)
... 34 more
2025-02-04 21:51:59,844 ERROR [com.div.NFEProcessor] (executor-thread-1) Erro ao enviar NFE: Connection or outbound has closed
Eu estava com o mesmo problema, forçar uma versão mais nova do axis2 (que é usado internamente pelo projeto) corrigiu:
<dependency>
<groupId>org.apache.axis2</groupId>
<artifactId>axis2-kernel</artifactId>
<version>1.8.2</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.axis2</groupId>
<artifactId>axis2-adb</artifactId>
<version>1.8.2</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.axis2</groupId>
<artifactId>axis2-transport-local</artifactId>
<version>1.8.2</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.axis2</groupId>
<artifactId>axis2-transport-http</artifactId>
<version>1.8.2</version>
<scope>compile</scope>
</dependency>
Edit: E também adicionar o client http da apache
<dependency>
<groupId>commons-httpclient</groupId>
<artifactId>commons-httpclient</artifactId>
<version>3.1</version>
</dependency>
