andrey.cunha/trm_rem_saggezza
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

att

Browse Source
This commit is contained in:
Cunha 2026-06-23 16:33:53 -03:00
parent cdf5aad1c8
commit a9ddcecdcc
3 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
__pycache__/installments_reader.cpython-313.pyc
View File

Binary file not shown.

19
recebiveis_report_importer.py
View File

@ -376,11 +376,22 @@ WHERE TABLE_SCHEMA='dbo' AND TABLE_NAME='Grgb_vendas_report'
return safe_cols return safe_cols
def _is_already_imported(cur, file_name: str) -> bool: def _is_already_imported(cur, file_name: str, start_date: str = "", end_date: str = "") -> bool:
cur.execute( cur.execute(
"SELECT 1 FROM dbo.Grgb_vendas_import_log WHERE FileName = ?", file_name "SELECT 1 FROM dbo.Grgb_vendas_import_log WHERE FileName = ?", file_name
) )
return cur.fetchone() is not None if cur.fetchone() is not None:
return True
# bloqueia se o período já está coberto por outro arquivo
if start_date and end_date:
cur.execute(
"SELECT 1 FROM dbo.Grgb_vendas_import_log "
"WHERE PeriodoInicio <= ? AND PeriodoFim >= ?",
end_date, start_date,
)
if cur.fetchone() is not None:
return True
return False
def _import_csv( def _import_csv(
@ -402,8 +413,8 @@ def _import_csv(
safe_cols = _ensure_tables(cur, csv_cols) safe_cols = _ensure_tables(cur, csv_cols)
cn.commit() cn.commit()
if _is_already_imported(cur, file_name): if _is_already_imported(cur, file_name, start_date, end_date):
print(f"[skip] {file_name} ja importado anteriormente") print(f"[skip] {file_name} periodo {start_date}..{end_date} ja importado anteriormente")
cur.close(); cn.close() cur.close(); cn.close()
return 0 return 0

2
vendas_watermark.json
View File

@ -1 +1 @@
{"last_end_date": "2026-05-24"} {"last_end_date": "2026-06-22"}