From ac90de45c36fe2c01b10782e248ac0b01797372c Mon Sep 17 00:00:00 2001
From: bn_user <user@example.com>
Date: Mon, 8 Dec 2025 10:46:43 +0000
Subject: [PATCH] =?UTF-8?q?=D0=9E=D0=B1=D0=BD=D0=BE=D0=B2=D0=B8=D1=82?=
 =?UTF-8?q?=D1=8C=20dags/OSV=5Fwith=5Fdocs.py?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dags/OSV_with_docs.py | 20 ++++++++++++++++----
 1 file changed, 16 insertions(+), 4 deletions(-)

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 'Обновлять нечего.'