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