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

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

This commit is contained in:
bn_user 2025-11-19 11:34:56 +00:00
parent d9dfa6e0fb
commit e9715168a1
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dags/OSV.py
View File

@ -63,6 +63,7 @@ def read_data_1C(**kwargs):
# Проходим циклом по каждому дню # Проходим циклом по каждому дню
print("\nПрохождение по дням календаря:") print("\nПрохождение по дням календаря:")
for i, date in enumerate(date_range): for i, date in enumerate(date_range):
print(f'{date}')
query = f"""ВЫБРАТЬ query = f"""ВЫБРАТЬ
ОстаткиОбороты.Счет, ОстаткиОбороты.Счет,
ОстаткиОбороты.Субконто1, ОстаткиОбороты.Субконто1,
@ -226,7 +227,7 @@ def read_data_1C(**kwargs):
, uid_subkonto2 , uid_subkonto2
, uid_subkonto1 , uid_subkonto1
, uid_organizaciya , uid_organizaciya
, CURRENT_DATE::date::timestamp , get_date::date::timestamp
FROM temp_{table_name} FROM temp_{table_name}
ON CONFLICT (schet, uid_subkonto2, uid_subkonto1, uid_organizaciya, get_date) ON CONFLICT (schet, uid_subkonto2, uid_subkonto1, uid_organizaciya, get_date)
DO UPDATE SET DO UPDATE SET