felipe
/
PyTrustNFe
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

Implementação método de distribuição de documentos fiscais

pull/59/head
Danimar Ribeiro 9 years ago
parent
7cd360c16a
commit
008e4bf205
6 changed files with 45 additions and 50 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 31
      pytrustnfe/Servidores.py
  2. 4
      pytrustnfe/client.py
  3. 19
      pytrustnfe/nfe/__init__.py
  4. 7
      pytrustnfe/nfe/comunicacao.py
  5. 16
      pytrustnfe/nfe/templates/NFeDistribuicaoDFe.xml
  6. 18
      pytrustnfe/nfe/templates/RecepcaoEventoManifesto.xml

31
pytrustnfe/Servidores.py
View File

@ -21,7 +21,6 @@ WS_NFCE_RECEPCAO_EVENTO = 'RecepcaoEventoCarta'
WS_NFCE_QR_CODE = 'NfeQRCode' WS_NFCE_QR_CODE = 'NfeQRCode'
WS_NFCE_RET_AUTORIZACAO = 'NFeRetAutorizacao', WS_NFCE_RET_AUTORIZACAO = 'NFeRetAutorizacao',
WS_NFCE_CONSULTA_DESTINADAS = 'NfeConsultaDest', WS_NFCE_CONSULTA_DESTINADAS = 'NfeConsultaDest',
WS_NFCE_DOWNLOAD = 'NfeDownloadNF',
WS_NFE_CADASTRO = 'NfeConsultaCadastro' WS_NFE_CADASTRO = 'NfeConsultaCadastro'
@ -29,9 +28,7 @@ WS_DPEC_RECEPCAO = 'RecepcaoEventoEPEC'
WS_DPEC_CONSULTA = 8 WS_DPEC_CONSULTA = 8
WS_NFE_RECEPCAO_EVENTO = 'RecepcaoEventoCarta' WS_NFE_RECEPCAO_EVENTO = 'RecepcaoEventoCarta'
WS_NFE_DOWNLOAD = 'NfeDownloadNF'
WS_NFE_CONSULTA_DESTINADAS = 'NfeConsultaDest'
WS_DFE_DISTRIBUICAO = 12
WS_DFE_DISTRIBUICAO = 'NFeDistribuicaoDFe'
NFE_AMBIENTE_PRODUCAO = 1 NFE_AMBIENTE_PRODUCAO = 1
NFE_AMBIENTE_HOMOLOGACAO = 2 NFE_AMBIENTE_HOMOLOGACAO = 2
@ -76,7 +73,7 @@ def localizar_url(servico, estado, mod='55', ambiente=2):
sigla = SIGLA_ESTADO[estado] sigla = SIGLA_ESTADO[estado]
ws = ESTADO_WS[sigla] ws = ESTADO_WS[sigla]
if servico in (WS_NFE_CONSULTA_DESTINADAS, WS_NFE_DOWNLOAD):
if servico in (WS_DFE_DISTRIBUICAO):
ws = AN ws = AN
if mod in ws: if mod in ws:
@ -133,14 +130,6 @@ METODO_WS = {
'webservice': 'RecepcaoEvento', 'webservice': 'RecepcaoEvento',
'metodo': 'nfeRecepcaoEvento', 'metodo': 'nfeRecepcaoEvento',
}, },
WS_NFE_DOWNLOAD: {
'webservice': 'NfeDownloadNF',
'metodo': 'nfeDownloadNF',
},
WS_NFE_CONSULTA_DESTINADAS: {
'webservice': 'NfeConsultaDest',
'metodo': 'nfeConsultaNFDest',
},
WS_DFE_DISTRIBUICAO: { WS_DFE_DISTRIBUICAO: {
'webservice': 'NFeDistribuicaoDFe', 'webservice': 'NFeDistribuicaoDFe',
'metodo': 'nfeDistDFeInteresse' 'metodo': 'nfeDistDFeInteresse'
@ -181,7 +170,6 @@ SVAN = {
WS_NFE_INUTILIZACAO: 'NfeInutilizacao2/NfeInutilizacao2.asmx', WS_NFE_INUTILIZACAO: 'NfeInutilizacao2/NfeInutilizacao2.asmx',
WS_NFE_CONSULTA: 'NfeConsulta2/NfeConsulta2.asmx', WS_NFE_CONSULTA: 'NfeConsulta2/NfeConsulta2.asmx',
WS_NFE_SITUACAO: 'NfeStatusServico2/NfeStatusServico2.asmx', WS_NFE_SITUACAO: 'NfeStatusServico2/NfeStatusServico2.asmx',
WS_NFE_DOWNLOAD: 'NfeDownloadNF/NfeDownloadNF.asmx',
}, },
NFE_AMBIENTE_HOMOLOGACAO: { NFE_AMBIENTE_HOMOLOGACAO: {
'servidor': 'hom.sefazvirtual.fazenda.gov.br', 'servidor': 'hom.sefazvirtual.fazenda.gov.br',
@ -191,7 +179,6 @@ SVAN = {
WS_NFE_INUTILIZACAO: 'NfeInutilizacao2/NfeInutilizacao2.asmx', WS_NFE_INUTILIZACAO: 'NfeInutilizacao2/NfeInutilizacao2.asmx',
WS_NFE_CONSULTA: 'NfeConsulta2/NfeConsulta2.asmx', WS_NFE_CONSULTA: 'NfeConsulta2/NfeConsulta2.asmx',
WS_NFE_SITUACAO: 'NfeStatusServico2/NfeStatusServico2.asmx', WS_NFE_SITUACAO: 'NfeStatusServico2/NfeStatusServico2.asmx',
WS_NFE_DOWNLOAD: 'NfeDownloadNF/NfeDownloadNF.asmx',
} }
} }
@ -269,17 +256,13 @@ DPEC = {
AN = { AN = {
NFE_AMBIENTE_PRODUCAO: { NFE_AMBIENTE_PRODUCAO: {
'servidor': 'www.nfe.fazenda.gov.br',
'servidor': 'www1.nfe.fazenda.gov.br',
WS_NFE_RECEPCAO_EVENTO: 'RecepcaoEvento/RecepcaoEvento.asmx', WS_NFE_RECEPCAO_EVENTO: 'RecepcaoEvento/RecepcaoEvento.asmx',
WS_NFE_CONSULTA_DESTINADAS: 'NFeConsultaDest/NFeConsultaDest.asmx',
WS_NFE_DOWNLOAD: 'NfeDownloadNF/NfeDownloadNF.asmx',
WS_DFE_DISTRIBUICAO: 'NFeDistribuicaoDFe/NFeDistribuicaoDFe.asmx', WS_DFE_DISTRIBUICAO: 'NFeDistribuicaoDFe/NFeDistribuicaoDFe.asmx',
}, },
NFE_AMBIENTE_HOMOLOGACAO: { NFE_AMBIENTE_HOMOLOGACAO: {
'servidor': 'hom.nfe.fazenda.gov.br', 'servidor': 'hom.nfe.fazenda.gov.br',
WS_NFE_RECEPCAO_EVENTO: 'RecepcaoEvento/RecepcaoEvento.asmx', WS_NFE_RECEPCAO_EVENTO: 'RecepcaoEvento/RecepcaoEvento.asmx',
WS_NFE_CONSULTA_DESTINADAS: 'NFeConsultaDest/NFeConsultaDest.asmx',
WS_NFE_DOWNLOAD: 'NfeDownloadNF/NfeDownloadNF.asmx',
WS_DFE_DISTRIBUICAO: 'NFeDistribuicaoDFe/NFeDistribuicaoDFe.asmx', WS_DFE_DISTRIBUICAO: 'NFeDistribuicaoDFe/NFeDistribuicaoDFe.asmx',
}, },
} }
@ -522,8 +505,6 @@ UFRS = {
WS_NFE_AUTORIZACAO: 'ws/NfeAutorizacao/NFeAutorizacao.asmx', WS_NFE_AUTORIZACAO: 'ws/NfeAutorizacao/NFeAutorizacao.asmx',
WS_NFE_RET_AUTORIZACAO: 'ws/NfeRetAutorizacao/NFeRetAutorizacao.asmx', WS_NFE_RET_AUTORIZACAO: 'ws/NfeRetAutorizacao/NFeRetAutorizacao.asmx',
WS_NFE_CADASTRO: 'ws/cadconsultacadastro/cadconsultacadastro2.asmx', WS_NFE_CADASTRO: 'ws/cadconsultacadastro/cadconsultacadastro2.asmx',
WS_NFE_CONSULTA_DESTINADAS: 'ws/nfeConsultaDest/nfeConsultaDest.asmx',
WS_NFE_DOWNLOAD: 'ws/nfeDownloadNF/nfeDownloadNF.asmx',
WS_NFE_INUTILIZACAO: 'ws/NfeInutilizacao/NfeInutilizacao2.asmx', WS_NFE_INUTILIZACAO: 'ws/NfeInutilizacao/NfeInutilizacao2.asmx',
WS_NFE_CONSULTA: 'ws/NfeConsulta/NfeConsulta2.asmx', WS_NFE_CONSULTA: 'ws/NfeConsulta/NfeConsulta2.asmx',
WS_NFE_SITUACAO: 'ws/NfeStatusServico/NfeStatusServico2.asmx', WS_NFE_SITUACAO: 'ws/NfeStatusServico/NfeStatusServico2.asmx',
@ -535,8 +516,6 @@ UFRS = {
WS_NFE_AUTORIZACAO: 'ws/NfeAutorizacao/NFeAutorizacao.asmx', WS_NFE_AUTORIZACAO: 'ws/NfeAutorizacao/NFeAutorizacao.asmx',
WS_NFE_RET_AUTORIZACAO: 'ws/NfeRetAutorizacao/NFeRetAutorizacao.asmx', WS_NFE_RET_AUTORIZACAO: 'ws/NfeRetAutorizacao/NFeRetAutorizacao.asmx',
WS_NFE_CADASTRO: 'ws/cadconsultacadastro/cadconsultacadastro2.asmx', WS_NFE_CADASTRO: 'ws/cadconsultacadastro/cadconsultacadastro2.asmx',
WS_NFE_CONSULTA_DESTINADAS: 'ws/nfeConsultaDest/nfeConsultaDest.asmx',
WS_NFE_DOWNLOAD: 'ws/nfeDownloadNF/nfeDownloadNF.asmx',
WS_NFE_INUTILIZACAO: 'ws/NfeInutilizacao/NfeInutilizacao2.asmx', WS_NFE_INUTILIZACAO: 'ws/NfeInutilizacao/NfeInutilizacao2.asmx',
WS_NFE_CONSULTA: 'ws/NfeConsulta/NfeConsulta2.asmx', WS_NFE_CONSULTA: 'ws/NfeConsulta/NfeConsulta2.asmx',
WS_NFE_SITUACAO: 'ws/NfeStatusServico/NfeStatusServico2.asmx', WS_NFE_SITUACAO: 'ws/NfeStatusServico/NfeStatusServico2.asmx',
@ -550,8 +529,6 @@ UFRS = {
WS_NFCE_AUTORIZACAO: 'ws/NfeAutorizacao/NFeAutorizacao.asmx', WS_NFCE_AUTORIZACAO: 'ws/NfeAutorizacao/NFeAutorizacao.asmx',
WS_NFCE_RET_AUTORIZACAO: 'ws/NfeRetAutorizacao/NFeRetAutorizacao.asmx', WS_NFCE_RET_AUTORIZACAO: 'ws/NfeRetAutorizacao/NFeRetAutorizacao.asmx',
WS_NFCE_CADASTRO: 'ws/cadconsultacadastro/cadconsultacadastro2.asmx', WS_NFCE_CADASTRO: 'ws/cadconsultacadastro/cadconsultacadastro2.asmx',
WS_NFCE_CONSULTA_DESTINADAS: 'ws/nfeConsultaDest/nfeConsultaDest.asmx',
WS_NFCE_DOWNLOAD: 'ws/nfeDownloadNF/nfeDownloadNF.asmx',
WS_NFCE_INUTILIZACAO: 'ws/NfeInutilizacao/NfeInutilizacao2.asmx', WS_NFCE_INUTILIZACAO: 'ws/NfeInutilizacao/NfeInutilizacao2.asmx',
WS_NFCE_CONSULTA: 'ws/NfeConsulta/NfeConsulta2.asmx', WS_NFCE_CONSULTA: 'ws/NfeConsulta/NfeConsulta2.asmx',
WS_NFCE_SITUACAO: 'ws/NfeStatusServico/NfeStatusServico2.asmx', WS_NFCE_SITUACAO: 'ws/NfeStatusServico/NfeStatusServico2.asmx',
@ -564,8 +541,6 @@ UFRS = {
WS_NFCE_AUTORIZACAO: 'ws/NfeAutorizacao/NFeAutorizacao.asmx', WS_NFCE_AUTORIZACAO: 'ws/NfeAutorizacao/NFeAutorizacao.asmx',
WS_NFCE_RET_AUTORIZACAO: 'ws/NfeRetAutorizacao/NFeRetAutorizacao.asmx', WS_NFCE_RET_AUTORIZACAO: 'ws/NfeRetAutorizacao/NFeRetAutorizacao.asmx',
WS_NFCE_CADASTRO: 'ws/cadconsultacadastro/cadconsultacadastro2.asmx', WS_NFCE_CADASTRO: 'ws/cadconsultacadastro/cadconsultacadastro2.asmx',
WS_NFCE_CONSULTA_DESTINADAS: 'ws/nfeConsultaDest/nfeConsultaDest.asmx',
WS_NFCE_DOWNLOAD: 'ws/nfeDownloadNF/nfeDownloadNF.asmx',
WS_NFCE_INUTILIZACAO: 'ws/NfeInutilizacao/NfeInutilizacao2.asmx', WS_NFCE_INUTILIZACAO: 'ws/NfeInutilizacao/NfeInutilizacao2.asmx',
WS_NFCE_CONSULTA: 'ws/NfeConsulta/NfeConsulta2.asmx', WS_NFCE_CONSULTA: 'ws/NfeConsulta/NfeConsulta2.asmx',
WS_NFCE_SITUACAO: 'ws/NfeStatusServico/NfeStatusServico2.asmx', WS_NFCE_SITUACAO: 'ws/NfeStatusServico/NfeStatusServico2.asmx',

4
pytrustnfe/client.py
View File

@ -44,8 +44,8 @@ class HttpClient(object):
def _headers(self, action): def _headers(self, action):
return { return {
u'Content-type': u'application/soap+xml; charset=utf-8; action="http://www.portalfiscal.inf.br/nfe/wsdl/%s"' % action,
u'Accept': u'application/soap+xml; charset=utf-8'
u'Content-type': u'text/xml; charset=utf-8; action="http://www.portalfiscal.inf.br/nfe/wsdl/%s"' % action,
u'Accept': u'application/soap+xml; charset=utf-8',
} }
def post_soap(self, xml_soap, cabecalho): def post_soap(self, xml_soap, cabecalho):

19
pytrustnfe/nfe/__init__.py
View File

@ -24,8 +24,8 @@ def _build_header(method, **kwargs):
'NfeInutilizacao': ('NfeInutilizacao2', '3.10'), 'NfeInutilizacao': ('NfeInutilizacao2', '3.10'),
'RecepcaoEventoCancelamento': ('RecepcaoEvento', '1.00'), 'RecepcaoEventoCancelamento': ('RecepcaoEvento', '1.00'),
'RecepcaoEventoCarta': ('RecepcaoEvento', '1.00'), 'RecepcaoEventoCarta': ('RecepcaoEvento', '1.00'),
'NfeConsultaDest': ('NfeConsultaDest', '3.10'),
'NfeDownloadNF': ('NfeDownloadNF', '3.10'),
'NFeDistribuicaoDFe': ('NFeDistribuicaoDFe/nfeDistDFeInteresse',
'1.00'),
} }
vals = {'estado': kwargs['estado'], vals = {'estado': kwargs['estado'],
'soap_action': action[method][0], 'soap_action': action[method][0],
@ -177,7 +177,12 @@ def _send(certificado, method, sign, **kwargs):
kwargs['ambiente']) kwargs['ambiente'])
cabecalho = _build_header(method, **kwargs) cabecalho = _build_header(method, **kwargs)
response, obj = executar_consulta(certificado, url, cabecalho, xml_send)
send_raw = False
if method == 'NFeDistribuicaoDFe':
send_raw = True
response, obj = executar_consulta(certificado, url, cabecalho, xml_send,
send_raw=send_raw)
return { return {
'sent_xml': xml_send, 'sent_xml': xml_send,
'received_xml': response, 'received_xml': response,
@ -226,9 +231,5 @@ def recepcao_evento_epec(certificado, **kwargs): # Assinar
return _send(certificado, 'RecepcaoEventoEPEC', True, **kwargs) return _send(certificado, 'RecepcaoEventoEPEC', True, **kwargs)
def consulta_nfe_destinada(certificado, **kwargs):
return _send(certificado, 'NfeConsultaDest', False, **kwargs)
def download_nfe(certificado, **kwargs):
return _send(certificado, 'NfeDownloadNF', False, **kwargs)
def consulta_distribuicao_nfe(certificado, **kwargs):
return _send(certificado, 'NFeDistribuicaoDFe', False, **kwargs)

7
pytrustnfe/nfe/comunicacao.py
View File

@ -12,7 +12,7 @@ from ..xml import sanitize_response
def _soap_xml(body, cabecalho): def _soap_xml(body, cabecalho):
xml = '<?xml version="1.0" encoding="utf-8"?>' xml = '<?xml version="1.0" encoding="utf-8"?>'
xml += '<soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope"><soap:Header>' xml += '<soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope"><soap:Header>'
xml += '<nfeCabecMsg xmlns="http://www.portalfiscal.inf.br/nfe/wsdl/'+ cabecalho.soap_action + '">'
xml += '<nfeCabecMsg xmlns="http://www.portalfiscal.inf.br/nfe/wsdl/' + cabecalho.soap_action + '">'
xml += '<cUF>' + cabecalho.estado + '</cUF><versaoDados>' + cabecalho.versao + '</versaoDados></nfeCabecMsg></soap:Header><soap:Body>' xml += '<cUF>' + cabecalho.estado + '</cUF><versaoDados>' + cabecalho.versao + '</versaoDados></nfeCabecMsg></soap:Header><soap:Body>'
xml += '<nfeDadosMsg xmlns="http://www.portalfiscal.inf.br/nfe/wsdl/' + cabecalho.soap_action + '">' xml += '<nfeDadosMsg xmlns="http://www.portalfiscal.inf.br/nfe/wsdl/' + cabecalho.soap_action + '">'
xml += body xml += body
@ -20,12 +20,15 @@ def _soap_xml(body, cabecalho):
return xml.rstrip('\n') return xml.rstrip('\n')
def executar_consulta(certificado, url, cabecalho, xmlEnviar):
def executar_consulta(certificado, url, cabecalho, xmlEnviar, send_raw=False):
cert, key = extract_cert_and_key_from_pfx( cert, key = extract_cert_and_key_from_pfx(
certificado.pfx, certificado.password) certificado.pfx, certificado.password)
cert_path, key_path = save_cert_key(cert, key) cert_path, key_path = save_cert_key(cert, key)
client = HttpClient(url, cert_path, key_path) client = HttpClient(url, cert_path, key_path)
xml_enviar = _soap_xml(xmlEnviar, cabecalho) xml_enviar = _soap_xml(xmlEnviar, cabecalho)
if send_raw:
xml = '<?xml version="1.0" encoding="utf-8"?>' + xmlEnviar.rstrip('\n')
xml_enviar = xml
xml_retorno = client.post_soap(xml_enviar, cabecalho) xml_retorno = client.post_soap(xml_enviar, cabecalho)
return sanitize_response(xml_retorno) return sanitize_response(xml_retorno)

16
pytrustnfe/nfe/templates/NFeDistribuicaoDFe.xml
View File

@ -0,0 +1,16 @@
<Envelope xmlns="http://schemas.xmlsoap.org/soap/envelope/">
<Body>
<nfeDistDFeInteresse xmlns="http://www.portalfiscal.inf.br/nfe/wsdl/NFeDistribuicaoDFe">
<nfeDadosMsg>
<distDFeInt xmlns="http://www.portalfiscal.inf.br/nfe" versao="1.00">
<tpAmb>{{ ambiente }}</tpAmb>
<cUFAutor>{{ estado }}</cUFAutor>
<CNPJ>{{ consulta.cnpj_cpf }}</CNPJ>
<distNSU>
<ultNSU>{{ consulta.ultimo_nsu }}</ultNSU>
</distNSU>
</distDFeInt>
</nfeDadosMsg>
</nfeDistDFeInteresse>
</Body>
</Envelope>

18
pytrustnfe/nfe/templates/RecepcaoEventoManifesto.xml
View File

@ -1,18 +1,18 @@
<envEvento xmlns="http://www.portalfiscal.inf.br/nfe" versao="1.00"> <envEvento xmlns="http://www.portalfiscal.inf.br/nfe" versao="1.00">
<idLote>{{ obj.lote }}</idLote>
<idLote>{{ lote }}</idLote>
<evento xmlns="http://www.portalfiscal.inf.br/nfe" versao="1.00"> <evento xmlns="http://www.portalfiscal.inf.br/nfe" versao="1.00">
<infEvento Id="{{ obj.id }}">
<cOrgao>{{ obj.orgao }}</cOrgao>
<tpAmb>{{ obj.ambiente }}</tpAmb>
<CNPJ>{{ obj.cnpj }}</CNPJ>
<chNFe>{{ obj.chave_nfe }}</chNFe>
<dhEvento>{{ obj.data_hora_evento }}</dhEvento>
<infEvento Id="{{ manifesto.identificador }}">
<cOrgao>{{ manifesto.estado }}</cOrgao>
<tpAmb>{{ ambiente }}</tpAmb>
<CNPJ>{{ manifesto.cnpj_empresa }}</CNPJ>
<chNFe>{{ manifesto.chave_nfe }}</chNFe>
<dhEvento>{{ manifesto.data_hora_evento }}</dhEvento>
<tpEvento>210200</tpEvento> <tpEvento>210200</tpEvento>
<nSeqEvento>{{ obj.sequencia }}</nSeqEvento>
<nSeqEvento>{{ manifesto.numero_sequencial }}</nSeqEvento>
<verEvento>1.00</verEvento> <verEvento>1.00</verEvento>
<detEvento versao="1.00"> <detEvento versao="1.00">
<descEvento>Confirmacao da Operacao</descEvento> <descEvento>Confirmacao da Operacao</descEvento>
</detEvento> </detEvento>
</infEvento> </infEvento>
</evento> </evento>
</envEvento>
</envEvento>
Write Preview
Loading…
Cancel
Save