diff --git a/dags/OSV.py b/dags/OSV.py index 310a9c6..7bb0e9e 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -115,9 +115,9 @@ def read_data_1C(**kwargs): , subkonto2 , organizaciya , kontagent - , nomer - , date_bedin - , date_end + , case when nomer = '' then null else nomer end nomer + , case when TO_DATE(date_bedin, 'DD.MM.YYYY') = '0001-01-01' then null else osv.date_end end date_bedin + , case when TO_DATE(date_end, 'DD.MM.YYYY') = '0001-01-01' then null else osv.date_end end date_end , summa_oborot , summa_oborot_dt , summa_oborot_kt