diff --git a/dags/OSV.py b/dags/OSV.py index 26db153..2c8443d 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -81,7 +81,7 @@ def read_data_1C(**kwargs): 'Организация': 'organizaciya', 'Контрагент': 'kontagent', 'НомерДоговора': 'nomer', - 'ДатаДоговора': 'date_bedin', + 'ДатаДоговора': 'date_begin', 'СрокДействияДоговора': 'date_end', # Суммовые остатки и обороты @@ -116,7 +116,7 @@ def read_data_1C(**kwargs): , organizaciya , kontagent , case when nomer = '' then null else nomer end nomer - , case when TO_DATE(date_bedin, 'DD.MM.YYYY') = '0001-01-01' then null else date_end end date_bedin + , case when TO_DATE(date_begin, 'DD.MM.YYYY') = '0001-01-01' then null else date_end end date_begin , case when TO_DATE(date_end, 'DD.MM.YYYY') = '0001-01-01' then null else date_end end date_end , summa_oborot , summa_oborot_dt