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

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

This commit is contained in:
bn_user 2025-12-12 08:20:50 +00:00
parent 71a0f96d8e
commit fcff09597f
1 changed files with 14 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
dags/OSV_with_docs.py
View File

@ -332,17 +332,20 @@ def pogasheniya(**kwargs):
# date_begin = EXCLUDED.date_begin, # date_begin = EXCLUDED.date_begin,
# date_end = EXCLUDED.date_end # date_end = EXCLUDED.date_end
conn.execute(""" conn.execute("""
UPDATE public.pogasheniya fp UPDATE public.pogasheniya fp
SET id = subquery.new_id SET id = subquery.new_id
FROM ( FROM (
SELECT SELECT
id, id,
ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer) as new_id -(ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer)) as new_id
FROM public.pogasheniya FROM public.pogasheniya
) AS subquery ) AS subquery
WHERE fp.id = subquery.id; WHERE fp.id = subquery.id;
""" """)
) conn.execute("""
UPDATE public.pogasheniya
SET id = -id;
""")
return 'Список обновлен.' return 'Список обновлен.'
else: else:
return 'Обновлять нечего.' return 'Обновлять нечего.'