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

dags/OSV.py

@@ -36,13 +36,13 @@ def read_data_1C(**kwargs):
     query = """ВЫБРАТЬ
 	ОстаткиОбороты.Счет,
 	ОстаткиОбороты.Субконто1,
-	ОстаткиОбороты.Субконто2,
-	ОстаткиОбороты.Организация,
+    ОстаткиОбороты.Субконто2,
+    ОстаткиОбороты.Организация,
     ОстаткиОбороты.Субконто2.Номер КАК НомерДоговора,
   	ОстаткиОбороты.Субконто2.Дата КАК ДатаДоговора,
    	ОстаткиОбороты.Субконто2.СрокДействия КАК СрокДействияДоговора,
-    ОстаткиОбороты.Субконто1.Инн КАК ИннСубконто1,
-    ОстаткиОбороты.Организация.Инн КАК ИннОрганизации,
+    ОстаткиОбороты.Субконто1.Инн КАК ИннКонтрагента,
+    ОстаткиОбороты.Организация.Инн КАК ИннКлиента,
 	ОстаткиОбороты.СуммаОборот,
 	ОстаткиОбороты.СуммаОборотДт,
 	ОстаткиОбороты.СуммаОборотКт,
@@ -50,11 +50,12 @@ def read_data_1C(**kwargs):
 	ОстаткиОбороты.СуммаКонечныйОстатокДт,
 	ОстаткиОбороты.СуммаКонечныйОстатокКт,
 	ОстаткиОбороты.СуммаКонечныйРазвернутыйОстатокДт,
-	ОстаткиОбороты.СуммаКонечныйРазвернутыйОстатокКт
+	ОстаткиОбороты.СуммаКонечныйРазвернутыйОстатокКт,
+    UUID(ОстаткиОбороты.Субконто2.Ссылка) КАК ИдентификаторДоговора,
+    UUID(ОстаткиОбороты.Субконто1.Ссылка) КАК ИдентификаторКонтрагента,
+    UUID(ОстаткиОбороты.Организация.Ссылка) КАК ИдентификаторКлиента
 ИЗ 
 	РегистрБухгалтерии.Хозрасчетный.ОстаткиИОбороты КАК ОстаткиОбороты
-	ЛЕВОЕ СОЕДИНЕНИЕ Справочник.ДоговорыКонтрагентов КАК ДоговорыКонтрагентов
-	ПО ОстаткиОбороты.Субконто2 = ДоговорыКонтрагентов.Ссылка
 ГДЕ
 	ОстаткиОбороты.Счет.Код В (&СписокСчетов)
     """
@@ -62,7 +63,7 @@ def read_data_1C(**kwargs):
     auth = HTTPBasicAuth('obmen', 'bOR2W7w4')
     response = requests.post(
         # http://адрес сервера/название БД/hs/services/query?ProcessPostedRequest
-        #
+
         url=r'http://192.168.1.75/chupd/hs/services/query?ProcessPostedRequest', 
         json={"query":query, "params": params},
         auth=auth,
@@ -83,8 +84,8 @@ def read_data_1C(**kwargs):
         'НомерДоговора': 'nomer',
         'ДатаДоговора': 'date_begin',
         'СрокДействияДоговора': 'date_end',
-        'ИннСубконто1': 'inn_subkonto1',
-        'ИннОрганизации': 'inn_organizaciya',
+        'ИннКонтрагента': 'inn_subkonto1',
+        'ИннКлиента': 'inn_organizaciya',
         
         # Суммовые остатки и обороты
         'СуммаОборот': 'summa_oborot',
@@ -94,7 +95,12 @@ def read_data_1C(**kwargs):
         'СуммаКонечныйОстатокДт': 'summa_konechnyy_ostatok_dt',
         'СуммаКонечныйОстатокКт': 'summa_konechnyy_ostatok_kt',
         'СуммаКонечныйРазвернутыйОстатокДт': 'summa_konechnyy_razvernutyy_ostatok_dt',
-        'СуммаКонечныйРазвернутыйОстатокКт': 'summa_konechnyy_razvernutyy_ostatok_kt'
+        'СуммаКонечныйРазвернутыйОстатокКт': 'summa_konechnyy_razvernutyy_ostatok_kt',
+
+        #ID
+        'ИдентификаторДоговора': 'uid_subkonto2',
+        'ИдентификаторКонтрагента': 'uid_subkonto1',
+        'ИдентификаторКлиента': 'uid_organizaciya'
     }
 
     df = df.rename(columns=field_mapping)
@@ -129,9 +135,12 @@ def read_data_1C(**kwargs):
                 , summa_konechnyy_ostatok_kt
                 , summa_konechnyy_razvernutyy_ostatok_dt
                 , summa_konechnyy_razvernutyy_ostatok_kt
+                , uid_subkonto2 
+                , uid_subkonto1
+                , uid_organizaciya
                 , CURRENT_DATE::date::timestamp 
             FROM temp_{table_name}
-            --ON CONFLICT (schet, subkonto1, subkonto2, organizaciya)
+            --ON CONFLICT (schet, uid_subkonto2, uid_subkonto1, uid_organizaciya)
             """
             )