diff --git a/dags/OSV.py b/dags/OSV.py index d787d98..f030511 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -42,6 +42,7 @@ def read_data_1C(**kwargs): ДоговорыКонтрагентов.Номер КАК НомерДоговора, ДоговорыКонтрагентов.Дата КАК ДатаДоговора, ДоговорыКонтрагентов.СрокДействия КАК СрокДействияДоговора, + ДоговорыКонтрагентов.Инн КАК ИНН ОстаткиОбороты.СуммаОборот, ОстаткиОбороты.СуммаОборотДт, ОстаткиОбороты.СуммаОборотКт, @@ -83,6 +84,7 @@ def read_data_1C(**kwargs): 'НомерДоговора': 'nomer', 'ДатаДоговора': 'date_begin', 'СрокДействияДоговора': 'date_end', + 'Инн': 'inn' # Суммовые остатки и обороты 'СуммаОборот': 'summa_oborot', @@ -118,6 +120,7 @@ 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 , summa_oborot , summa_oborot_dt , summa_oborot_kt