Browse Source

Remove bug que fazia domínios hospedados no Interlegis fossem processados como delegados

pull/163/head 3.0.28
Sesostris Vieira 2 years ago
parent
commit
3f206fa6f3
  1. 53
      sigi/apps/servicos/jobs/daily/sincroniza_dns.py

53
sigi/apps/servicos/jobs/daily/sincroniza_dns.py

@ -65,11 +65,16 @@ class Job(JobReportMixin, DailyJob):
user=self.sys_user, user=self.sys_user,
) )
# Remove arquivo ZONES, desnecessário para este processo #
zones_file = settings.REGISTRO_PATH / "ZONES"
if zones_file.exists() and zones_file.is_file():
zones_file.unlink()
for uf in UnidadeFederativa.objects.all(): for uf in UnidadeFederativa.objects.all():
self.report_data[uf] = get_log_entry() self.report_data[uf] = get_log_entry()
self.processa_uf(uf) self.processa_uf(uf)
self.processa_zones() # self.processa_zones()
self.processa_files() self.processa_files()
try: try:
@ -224,29 +229,29 @@ class Job(JobReportMixin, DailyJob):
# Remove arquivo da UF # # Remove arquivo da UF #
file_path.unlink() file_path.unlink()
def processa_zones(self): # def processa_zones(self):
zones_file = settings.REGISTRO_PATH / "ZONES" # zones_file = settings.REGISTRO_PATH / "ZONES"
if not zones_file.exists() or not zones_file.is_file(): # if not zones_file.exists() or not zones_file.is_file():
self.error( # self.error(
_( # _(
f"Arquivo de zonas {zones_file} não encontrado ou " # f"Arquivo de zonas {zones_file} não encontrado ou "
"não é arquivo" # "não é arquivo"
) # )
) # )
return # return
data = json.loads(zones_file.read_text()) # data = json.loads(zones_file.read_text())
for rec in data: # for rec in data:
dominio = rec["name"][:-1] # dominio = rec["name"][:-1]
self.processa_rec(rec) # self.processa_rec(rec)
detail_file = settings.REGISTRO_PATH / f"{dominio}." # detail_file = settings.REGISTRO_PATH / f"{dominio}."
if ( # if (
detail_file != zones_file # detail_file != zones_file
and detail_file.exists() # and detail_file.exists()
and detail_file.is_file() # and detail_file.is_file()
): # ):
detail_file.unlink() # detail_file.unlink()
zones_file.unlink() # zones_file.unlink()
def processa_files(self): def processa_files(self):
file_list = list(settings.REGISTRO_PATH.iterdir()) file_list = list(settings.REGISTRO_PATH.iterdir())

Loading…
Cancel
Save