ref cron

Author: CristianoMafraJunior

l10n_br_fiscal_dfe/data/ir_cron.xml

@@ -11,7 +11,7 @@
         <field name="code">model._cron_search_documents()</field>
         <field name="user_id" ref="base.user_root" />
         <field name="interval_number">1</field>
-        <field name="interval_type">days</field>
+        <field name="interval_type">hours</field>
         <field name="numbercall">-1</field>
         <field name="active" eval="False" />
     </record>

l10n_br_fiscal_dfe/models/dfe_monitor.py

@@ -2,7 +2,7 @@
 # License AGPL-3 or later (http://www.gnu.org/licenses/agpl)
 
 import re
-from datetime import datetime
+from datetime import datetime, timedelta
 
 from erpbrasil.transmissao import TransmissaoSOAP
 from lxml import objectify
@@ -37,6 +37,8 @@ class DFeMonitor(models.Model):
 
     last_nsu = fields.Char(related="company_id.last_nsu", readonly=False)
 
+    max_nsu = fields.Char(readonly=True)
+
     last_query = fields.Datetime(string="Last query")
 
     use_cron = fields.Boolean(
@@ -109,10 +111,17 @@ def _document_distribution(self):
             if self.last_nsu and self.last_nsu.isdigit()
             else "000000000000000"
         )
-        maxNSU = ""
+        maxNSU = self.max_nsu or ""
+        if last_nsu == maxNSU:
+            last_query = self.last_query or fields.Datetime.now() 
+            time_difference = fields.Datetime.now() - last_query
+            if time_difference < timedelta(hours=1):
+                self.message_post(body=_("Waiting 1 hour before making a new request."))
+                return
+
         last_query = fields.Datetime.now()
 
-        while maxNSU != last_nsu:
+        while True:
             try:
                 result = self._get_processor().consultar_distribuicao(
                     cnpj_cpf=re.sub("[^0-9]", "", self.company_id.cnpj_cpf),
@@ -125,18 +134,21 @@ def _document_distribution(self):
                 break
 
             last_nsu = result.resposta.ultNSU
-            last_query = fields.Datetime.now()
+            if not maxNSU:
+                maxNSU = result.resposta.maxNSU
 
             if not self.validate_distribution_response(result):
                 break
 
             self._process_distribution(result)
+            if last_nsu == maxNSU:
+                break
 
-            maxNSU = result.resposta.maxNSU
         self.write(
             {
                 "last_nsu": last_nsu,
                 "last_query": last_query,
+                "max_nsu": maxNSU,
             }
         )