[IMP] Consulta status NF-e antes do cancelamento.

Implementa consulta do status da NF-e antes de realizar o cancelamento, para evitar erro de duplicidade de evento.

Implementa adequações nos testes de cancelamento de NF-e.

br_nfe/models/invoice_eletronic.py

@@ -20,6 +20,7 @@
     from pytrustnfe.nfe import xml_autorizar_nfe
     from pytrustnfe.nfe import retorno_autorizar_nfe
     from pytrustnfe.nfe import recepcao_evento_cancelamento
+    from pytrustnfe.nfe import consultar_protocolo_nfe
     from pytrustnfe.certificado import Certificado
     from pytrustnfe.utils import ChaveNFe, gerar_chave, gerar_nfeproc
     from pytrustnfe.nfe.danfe import danfe
@@ -888,40 +889,60 @@ def action_cancel_document(self, context=None, justificativa=None):
         cert_pfx = base64.decodestring(cert)
         certificado = Certificado(cert_pfx, self.company_id.nfe_a1_password)
 
-        id_canc = "ID110111%s%02d" % (self.chave_nfe, self.sequencial_evento)
-        cancelamento = {
-            'idLote': self.id,
+        consulta = {
             'estado': self.company_id.state_id.ibge_code,
             'ambiente': 2 if self.ambiente == 'homologacao' else 1,
-            'eventos': [{
-                'Id': id_canc,
-                'cOrgao': self.company_id.state_id.ibge_code,
-                'tpAmb': 2 if self.ambiente == 'homologacao' else 1,
-                'CNPJ': re.sub('[^0-9]', '', self.company_id.cnpj_cpf),
-                'chNFe': self.chave_nfe,
-                'dhEvento': datetime.utcnow().strftime(
-                    '%Y-%m-%dT%H:%M:%S-00:00'),
-                'nSeqEvento': self.sequencial_evento,
-                'nProt': self.protocolo_nfe,
-                'xJust': justificativa
-            }],
-            'modelo': self.model,
+            'chave_nfe': self.chave_nfe,
         }
-        resp = recepcao_evento_cancelamento(certificado, **cancelamento)
-        resposta = resp['object'].Body.nfeRecepcaoEventoResult.retEnvEvento
-        if resposta.cStat == 128 and \
-           resposta.retEvento.infEvento.cStat in (135, 136, 155):
+
+        resp = consultar_protocolo_nfe(certificado, **consulta)
+
+        retorno_consulta = \
+            resp['object'].Body.nfeConsultaNF2Result.retConsSitNFe
+
+        if retorno_consulta.cStat == 101:
             self.state = 'cancel'
-            self.codigo_retorno = resposta.retEvento.infEvento.cStat
-            self.mensagem_retorno = resposta.retEvento.infEvento.xMotivo
+            self.codigo_retorno = retorno_consulta.cStat
+            self.mensagem_retorno = retorno_consulta.xMotivo
             self.sequencial_evento += 1
+            resp['received_xml'] = etree.tostring(retorno_consulta.retCancNFe)
+            resp['sent_xml'] = etree.tostring(retorno_consulta.procEventoNFe)
         else:
-            if resposta.cStat == 128:
+            id_canc = "ID110111%s%02d" % (
+                self.chave_nfe, self.sequencial_evento)
+            cancelamento = {
+                'idLote': self.id,
+                'estado': self.company_id.state_id.ibge_code,
+                'ambiente': 2 if self.ambiente == 'homologacao' else 1,
+                'eventos': [{
+                    'Id': id_canc,
+                    'cOrgao': self.company_id.state_id.ibge_code,
+                    'tpAmb': 2 if self.ambiente == 'homologacao' else 1,
+                    'CNPJ': re.sub('[^0-9]', '', self.company_id.cnpj_cpf),
+                    'chNFe': self.chave_nfe,
+                    'dhEvento': datetime.utcnow().strftime(
+                        '%Y-%m-%dT%H:%M:%S-00:00'),
+                    'nSeqEvento': self.sequencial_evento,
+                    'nProt': self.protocolo_nfe,
+                    'xJust': justificativa
+                }],
+                'modelo': self.model,
+            }
+            resp = recepcao_evento_cancelamento(certificado, **cancelamento)
+            resposta = resp['object'].Body.nfeRecepcaoEventoResult.retEnvEvento
+            if resposta.cStat == 128 and \
+                    resposta.retEvento.infEvento.cStat in (135, 136, 155):
+                self.state = 'cancel'
                 self.codigo_retorno = resposta.retEvento.infEvento.cStat
                 self.mensagem_retorno = resposta.retEvento.infEvento.xMotivo
+                self.sequencial_evento += 1
             else:
-                self.codigo_retorno = resposta.cStat
-                self.mensagem_retorno = resposta.xMotivo
+                if resposta.cStat == 128:
+                    self.codigo_retorno = resposta.retEvento.infEvento.cStat
+                    self.mensagem_retorno = resposta.retEvento.infEvento.xMotivo
+                else:
+                    self.codigo_retorno = resposta.cStat
+                    self.mensagem_retorno = resposta.xMotivo
 
         self.env['invoice.eletronic.event'].create({
             'code': self.codigo_retorno,

br_nfe/tests/test_nfe.py

@@ -430,7 +430,8 @@ def test_nfe_with_concept_error(self, autorizar, ret_autorizar, validar):
 
     @patch('odoo.addons.br_nfe.models.invoice_eletronic.valida_nfe')
     @patch('odoo.addons.br_nfe.models.invoice_eletronic.recepcao_evento_cancelamento')  # noqa
-    def test_nfe_cancelamento_ok(self, cancelar, validar):
+    @patch('odoo.addons.br_nfe.models.invoice_eletronic.consultar_protocolo_nfe') # noqa
+    def test_nfe_cancelamento_ok(self, consulta, cancelar, validar):
         validar.return_value = ''
         for invoice in self.invoices:
             # Confirmando a fatura deve gerar um documento eletrônico
@@ -446,6 +447,17 @@ def test_nfe_cancelamento_ok(self, cancelar, validar):
                 'received_xml': xml_recebido
             }
 
+            # Consulta realizada
+            xml_recebido = open(os.path.join(
+                self.caminho, 'xml/consulta.xml'), 'r').read()
+            resp_consulta = sanitize_response(xml_recebido)
+
+            consulta.return_value = {
+                'object': resp_consulta[1],
+                'sent_xml': '<xml />',
+                'received_xml': xml_recebido
+            }
+
             invoice_eletronic = self.env['invoice.eletronic'].search(
                 [('invoice_id', '=', invoice.id)])
             invoice_eletronic.action_cancel_document(

br_nfe/tests/xml/consulta.xml

@@ -0,0 +1,39 @@
+<soap:Envelope 
+    xmlns:soap="http://www.w3.org/2003/05/soap-envelope" 
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
+    xmlns:xsd="http://www.w3.org/2001/XMLSchema">
+    <soap:Header>
+        <nfeCabecMsg 
+            xmlns="http://www.portalfiscal.inf.br/nfe/wsdl/NfeConsulta2">
+            <cUF>53</cUF>
+            <versaoDados>3.10</versaoDados>
+        </nfeCabecMsg>
+    </soap:Header>
+    <soap:Body>
+        <nfeConsultaNF2Result 
+            xmlns="http://www.portalfiscal.inf.br/nfe/wsdl/NfeConsulta2">
+            <retConsSitNFe versao="3.10" 
+                xmlns="http://www.portalfiscal.inf.br/nfe">
+                <tpAmb>2</tpAmb>
+                <verAplic>SVRS201710241713</verAplic>
+                <cStat>100</cStat>
+                <xMotivo>Autorizado o uso da NF-e</xMotivo>
+                <cUF>53</cUF>
+                <dhRecbto>2018-03-19T17:02:12-03:00</dhRecbto>
+                <chNFe>53180301929144000190550010000000111425608529</chNFe>
+                <protNFe versao="3.10">
+                    <infProt Id="ID353180000120999">
+                        <tpAmb>2</tpAmb>
+                        <verAplic>SVRS201803141609</verAplic>
+                        <chNFe>53180301929144000190550010000000111425608529</chNFe>
+                        <dhRecbto>2018-03-19T15:53:13-03:00</dhRecbto>
+                        <nProt>353180000120999</nProt>
+                        <digVal>R+4GfYd0MKpxbaLk0hRG30BD5oc=</digVal>
+                        <cStat>100</cStat>
+                        <xMotivo>Autorizado o uso da NF-e</xMotivo>
+                    </infProt>
+                </protNFe>
+            </retConsSitNFe>
+        </nfeConsultaNF2Result>
+    </soap:Body>
+</soap:Envelope>