diff --git a/dags/OSV_with_docs.py b/dags/OSV_with_docs.py index fcef4ce..6e3d1de 100644 --- a/dags/OSV_with_docs.py +++ b/dags/OSV_with_docs.py @@ -401,10 +401,22 @@ def poruchitelstva(**kwargs): # date_begin = EXCLUDED.date_begin, # date_end = EXCLUDED.date_end conn.execute(""" - DELETE FROM public.poruchitelstva fp - WHERE fp.uid_dogovor is null - """ - ) + UPDATE public.poruchitelstva fp + SET id = subquery.new_id + FROM ( + SELECT + id, + -(ROW_NUMBER() OVER (ORDER BY uid_dogovor, schet, nomer)) as new_id + FROM public.poruchitelstva + ) AS subquery + WHERE fp.id = subquery.id; + """) + conn.execute(""" + UPDATE public.poruchitelstva + SET id = -id; + """) + + # conn.commit() return 'Список обновлен.' else: return 'Обновлять нечего.'