diff --git a/dags/OSV.py b/dags/OSV.py index b474258..6bd8225 100644 --- a/dags/OSV.py +++ b/dags/OSV.py @@ -33,7 +33,20 @@ def get_db_engine(): def read_data_1C(**kwargs): params = {"СписокСчетов": ["66","66.01","66.02", "66.03","66.04","66.21","66.22","66.23","66.24", "67","67.01","67.02", "67.03","67.04","67.21","67.22","67.23","67.24"]} - query = """ВЫБРАТЬ * + query = """ВЫБРАТЬ + ОстаткиИОбороты.Счет + ОстаткиИОбороты.Субконто1 + ОстаткиИОбороты.Субконто2 + ОстаткиИОбороты.Субконто3 + ОстаткиИОбороты.Организация + ОстаткиИОбороты.СуммаОборот + ОстаткиИОбороты.СуммаОборотДт + ОстаткиИОбороты.СуммаОборотКт + ОстаткиИОбороты.СуммаКонечныйОстаток + ОстаткиИОбороты.СуммаКонечныйОстатокДт + ОстаткиИОбороты.СуммаКонечныйОстатокКт + ОстаткиИОбороты.СуммаКонечныйРазвернутыйОстатокДт + ОстаткиИОбороты.СуммаКонечныйРазвернутыйОстатокКт ИЗ РегистрБухгалтерии.Хозрасчетный.ОстаткиИОбороты КАК ОстаткиИОбороты ГДЕ @@ -62,14 +75,14 @@ def read_data_1C(**kwargs): 'Субконто2': 'subkonto2', 'Субконто3': 'subkonto3', 'Организация': 'organizaciya', - 'Валюта': 'valyuta', + # 'Валюта': 'valyuta', # Суммовые остатки и обороты - 'СуммаНачальныйОстаток': 'summa_nachalnyy_ostatok', - 'СуммаНачальныйОстатокДт': 'summa_nachalnyy_ostatok_dt', - 'СуммаНачальныйОстатокКт': 'summa_nachalnyy_ostatok_kt', - 'СуммаНачальныйРазвернутыйОстатокДт': 'summa_nachalnyy_razvernutyy_ostatok_dt', - 'СуммаНачальныйРазвернутыйОстатокКт': 'summa_nachalnyy_razvernutyy_ostatok_kt', + # 'СуммаНачальныйОстаток': 'summa_nachalnyy_ostatok', + # 'СуммаНачальныйОстатокДт': 'summa_nachalnyy_ostatok_dt', + # 'СуммаНачальныйОстатокКт': 'summa_nachalnyy_ostatok_kt', + # 'СуммаНачальныйРазвернутыйОстатокДт': 'summa_nachalnyy_razvernutyy_ostatok_dt', + # 'СуммаНачальныйРазвернутыйОстатокКт': 'summa_nachalnyy_razvernutyy_ostatok_kt', 'СуммаОборот': 'summa_oborot', 'СуммаОборотДт': 'summa_oborot_dt', 'СуммаОборотКт': 'summa_oborot_kt', @@ -77,37 +90,37 @@ 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' # Валютные остатки и обороты - 'ВалютнаяСуммаНачальныйОстаток': 'valyutnaya_summa_nachalnyy_ostatok', - 'ВалютнаяСуммаНачальныйОстатокДт': 'valyutnaya_summa_nachalnyy_ostatok_dt', - 'ВалютнаяСуммаНачальныйОстатокКт': 'valyutnaya_summa_nachalnyy_ostatok_kt', - 'ВалютнаяСуммаНачальныйРазвернутыйОстатокДт': 'valyutnaya_summa_nachalnyy_razvernutyy_ostatok_dt', - 'ВалютнаяСуммаНачальныйРазвернутыйОстатокКт': 'valyutnaya_summa_nachalnyy_razvernutyy_ostatok_kt', - 'ВалютнаяСуммаОборот': 'valyutnaya_summa_oborot', - 'ВалютнаяСуммаОборотДт': 'valyutnaya_summa_oborot_dt', - 'ВалютнаяСуммаОборотКт': 'valyutnaya_summa_oborot_kt', - 'ВалютнаяСуммаКонечныйОстаток': 'valyutnaya_summa_konechnyy_ostatok', - 'ВалютнаяСуммаКонечныйОстатокДт': 'valyutnaya_summa_konechnyy_ostatok_dt', - 'ВалютнаяСуммаКонечныйОстатокКт': 'valyutnaya_summa_konechnyy_ostatok_kt', - 'ВалютнаяСуммаКонечныйРазвернутыйОстатокДт': 'valyutnaya_summa_konechnyy_razvernutyy_ostatok_dt', - 'ВалютнаяСуммаКонечныйРазвернутыйОстатокКт': 'valyutnaya_summa_konechnyy_razvernutyy_ostatok_kt', + # 'ВалютнаяСуммаНачальныйОстаток': 'valyutnaya_summa_nachalnyy_ostatok', + # 'ВалютнаяСуммаНачальныйОстатокДт': 'valyutnaya_summa_nachalnyy_ostatok_dt', + # 'ВалютнаяСуммаНачальныйОстатокКт': 'valyutnaya_summa_nachalnyy_ostatok_kt', + # 'ВалютнаяСуммаНачальныйРазвернутыйОстатокДт': 'valyutnaya_summa_nachalnyy_razvernutyy_ostatok_dt', + # 'ВалютнаяСуммаНачальныйРазвернутыйОстатокКт': 'valyutnaya_summa_nachalnyy_razvernutyy_ostatok_kt', + # 'ВалютнаяСуммаОборот': 'valyutnaya_summa_oborot', + # 'ВалютнаяСуммаОборотДт': 'valyutnaya_summa_oborot_dt', + # 'ВалютнаяСуммаОборотКт': 'valyutnaya_summa_oborot_kt', + # 'ВалютнаяСуммаКонечныйОстаток': 'valyutnaya_summa_konechnyy_ostatok', + # 'ВалютнаяСуммаКонечныйОстатокДт': 'valyutnaya_summa_konechnyy_ostatok_dt', + # 'ВалютнаяСуммаКонечныйОстатокКт': 'valyutnaya_summa_konechnyy_ostatok_kt', + # 'ВалютнаяСуммаКонечныйРазвернутыйОстатокДт': 'valyutnaya_summa_konechnyy_razvernutyy_ostatok_dt', + # 'ВалютнаяСуммаКонечныйРазвернутыйОстатокКт': 'valyutnaya_summa_konechnyy_razvernutyy_ostatok_kt', # Количественные остатки и обороты - 'КоличествоНачальныйОстаток': 'kolichestvo_nachalnyy_ostatok', - 'КоличествоНачальныйОстатокДт': 'kolichestvo_nachalnyy_ostatok_dt', - 'КоличествоНачальныйОстатокКт': 'kolichestvo_nachalnyy_ostatok_kt', - 'КоличествоНачальныйРазвернутыйОстатокДт': 'kolichestvo_nachalnyy_razvernutyy_ostatok_dt', - 'КоличествоНачальныйРазвернутыйОстатокКт': 'kolichestvo_nachalnyy_razvernutyy_ostatok_kt', - 'КоличествоОборот': 'kolichestvo_oborot', - 'КоличествоОборотДт': 'kolichestvo_oborot_dt', - 'КоличествоОборотКт': 'kolichestvo_oborot_kt', - 'КоличествоКонечныйОстаток': 'kolichestvo_konechnyy_ostatok', - 'КоличествоКонечныйОстатокДт': 'kolichestvo_konechnyy_ostatok_dt', - 'КоличествоКонечныйОстатокКт': 'kolichestvo_konechnyy_ostatok_kt', - 'КоличествоКонечныйРазвернутыйОстатокДт': 'kolichestvo_konechnyy_razvernutyy_ostatok_dt', - 'КоличествоКонечныйРазвернутыйОстатокКт': 'kolichestvo_konechnyy_razvernutyy_ostatok_kt' + # 'КоличествоНачальныйОстаток': 'kolichestvo_nachalnyy_ostatok', + # 'КоличествоНачальныйОстатокДт': 'kolichestvo_nachalnyy_ostatok_dt', + # 'КоличествоНачальныйОстатокКт': 'kolichestvo_nachalnyy_ostatok_kt', + # 'КоличествоНачальныйРазвернутыйОстатокДт': 'kolichestvo_nachalnyy_razvernutyy_ostatok_dt', + # 'КоличествоНачальныйРазвернутыйОстатокКт': 'kolichestvo_nachalnyy_razvernutyy_ostatok_kt', + # 'КоличествоОборот': 'kolichestvo_oborot', + # 'КоличествоОборотДт': 'kolichestvo_oborot_dt', + # 'КоличествоОборотКт': 'kolichestvo_oborot_kt', + # 'КоличествоКонечныйОстаток': 'kolichestvo_konechnyy_ostatok', + # 'КоличествоКонечныйОстатокДт': 'kolichestvo_konechnyy_ostatok_dt', + # 'КоличествоКонечныйОстатокКт': 'kolichestvo_konechnyy_ostatok_kt', + # 'КоличествоКонечныйРазвернутыйОстатокДт': 'kolichestvo_konechnyy_razvernutyy_ostatok_dt', + # 'КоличествоКонечныйРазвернутыйОстатокКт': 'kolichestvo_konechnyy_razvernutyy_ostatok_kt' } df = df.rename(columns=field_mapping)