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

dags/OSV.py

@@ -38,11 +38,11 @@ def read_data_1C(**kwargs):
 	ОстаткиОбороты.Субконто1,
 	ОстаткиОбороты.Субконто2,
 	ОстаткиОбороты.Организация,
-	ДоговорыКонтрагентов.Владелец КАК Контрагент,
-	ДоговорыКонтрагентов.Номер КАК НомерДоговора,
-	ДоговорыКонтрагентов.Дата КАК ДатаДоговора,
-	ДоговорыКонтрагентов.СрокДействия КАК СрокДействияДоговора,
-    ДоговорыКонтрагентов.Инн КАК ИНН,
+    ОстаткиОбороты.Субконто2.Номер КАК НомерДоговора,
+  	ОстаткиОбороты.Субконто2.Дата КАК ДатаДоговора,
+   	ОстаткиОбороты.Субконто2.СрокДействия КАК СрокДействияДоговора,
+    ОстаткиОбороты.Субконто1.Инн КАК ИннСубконто1,
+    ОстаткиОбороты.Организация.Инн КАК ИннОрганизации,
 	ОстаткиОбороты.СуммаОборот,
 	ОстаткиОбороты.СуммаОборотДт,
 	ОстаткиОбороты.СуммаОборотКт,
@@ -80,11 +80,11 @@ def read_data_1C(**kwargs):
         'Субконто1': 'subkonto1',
         'Субконто2': 'subkonto2',
         'Организация': 'organizaciya',
-        'Контрагент': 'kontagent',
         'НомерДоговора': 'nomer',
         'ДатаДоговора': 'date_begin',
         'СрокДействияДоговора': 'date_end',
-        'Инн': 'inn',
+        'ИннСубконто1': 'inn_subkonto1',
+        'ИннОрганизации': 'inn_organizaciya',
         
         # Суммовые остатки и обороты
         'СуммаОборот': 'summa_oborot',
@@ -120,7 +120,8 @@ def read_data_1C(**kwargs):
                 , case when nomer = '' then null else nomer end nomer
                 , case when TO_DATE(date_begin, 'DD.MM.YYYY') = '0001-01-01' then null else date_begin end date_begin
                 , case when TO_DATE(date_end, 'DD.MM.YYYY') = '0001-01-01' then null else date_end end date_end
-                , inn as inn
+                , inn_subkonto1 as inn_subkonto1
+                , inn_organizaciya as inn_organizaciya
                 , summa_oborot
                 , summa_oborot_dt
                 , summa_oborot_kt