bn_user
/
sigma
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Обновить dags/upload_dicts.py

This commit is contained in:
bn_user 2025-11-13 14:54:19 +00:00
parent b3f41563dd
commit 219023c87a
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
dags/upload_dicts.py
View File

@ -62,7 +62,7 @@ def take_dogovor(**kwargs):
field_mapping = {
'Наименование': 'name',
'Номер': 'nomer',
'Дата': 'date_bedin',
'Дата': 'date_begin',
'СрокДействия': 'date_end',
'ИдентификаторДоговора': 'uid_dogovor'
}
@ -79,7 +79,7 @@ def take_dogovor(**kwargs):
)
conn.execute(f"DELETE FROM public.{table_name}")
conn.execute(f"""
INSERT INTO public.{table_name}
INSERT INTO public.{table_name} (name, nomer, date_begin, date_end, uid_dogovor)
SELECT
name,
nomer,
@ -136,7 +136,7 @@ def take_bank(**kwargs):
)
conn.execute(f"DELETE FROM public.{table_name}")
conn.execute(f"""
INSERT INTO public.{table_name}
INSERT INTO public.{table_name} (name, inn, kpp, uid_bank)
SELECT
name,
inn,
@ -176,7 +176,7 @@ def take_organizaciya(**kwargs):
'Наименование': 'name',
'ИНН': 'inn',
'КПП': 'kpp',
'ИдентификаторДоговора': 'uid_organizaciya'
'ИдентификаторОрганизации': 'uid_organizaciya'
}
df = df.rename(columns=field_mapping)
with engine.begin() as conn:
@ -191,7 +191,7 @@ def take_organizaciya(**kwargs):
)
conn.execute(f"DELETE FROM public.{table_name}")
conn.execute(f"""
INSERT INTO public.{table_name}
INSERT INTO public.{table_name} (name, inn, kpp, uid_organizaciya)
SELECT
name,
inn,