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

2025-09-03 09:25:47 +00:00 · 2025-09-03 09:25:47 +00:00 · a8a8d5921d
parent f90fa406c3
commit a8a8d5921d
1 changed files with 15 additions and 1 deletions
--- a/dags/OSV.py
+++ b/dags/OSV.py
@ -136,7 +136,21 @@ def read_data_1C(**kwargs):
            conn.execute(f"DELETE FROM public.{table_name}")
            conn.execute(f"""
            INSERT INTO public.{table_name}
-            SELECT *, CURRENT_DATE::date::timestamp FROM temp_{table_name}
+            SELECT  
+                  schet
+                , subkonto1
+                , subkonto2
+                , organizaciya
+                , summa_oborot
+                , summa_oborot_dt
+                , summa_oborot_kt
+                , summa_konechnyy_ostatok
+                , summa_konechnyy_ostatok_dt
+                , summa_konechnyy_ostatok_kt
+                , summa_konechnyy_razvernutyy_ostatok_dt
+                , summa_konechnyy_razvernutyy_ostatok_kt
+                , CURRENT_DATE::date::timestamp 
+            FROM temp_{table_name}
            --ON CONFLICT (schet, subkonto1, subkonto2, organizaciya)
            """
            )