bn_user
/
sigma
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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

This commit is contained in:
bn_user 2025-09-01 14:52:42 +00:00
parent b0d7e16df1
commit 25cc42459e
1 changed files with 47 additions and 34 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
dags/OSV.py
View File

@ -33,7 +33,20 @@ def get_db_engine():
def read_data_1C(**kwargs): 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"]} 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', 'Субконто2': 'subkonto2',
'Субконто3': 'subkonto3', 'Субконто3': 'subkonto3',
'Организация': 'organizaciya', 'Организация': 'organizaciya',
'Валюта': 'valyuta', # 'Валюта': 'valyuta',
# Суммовые остатки и обороты # Суммовые остатки и обороты
'СуммаНачальныйОстаток': 'summa_nachalnyy_ostatok', # 'СуммаНачальныйОстаток': 'summa_nachalnyy_ostatok',
'СуммаНачальныйОстатокДт': 'summa_nachalnyy_ostatok_dt', # 'СуммаНачальныйОстатокДт': 'summa_nachalnyy_ostatok_dt',
'СуммаНачальныйОстатокКт': 'summa_nachalnyy_ostatok_kt', # 'СуммаНачальныйОстатокКт': 'summa_nachalnyy_ostatok_kt',
'СуммаНачальныйРазвернутыйОстатокДт': 'summa_nachalnyy_razvernutyy_ostatok_dt', # 'СуммаНачальныйРазвернутыйОстатокДт': 'summa_nachalnyy_razvernutyy_ostatok_dt',
'СуммаНачальныйРазвернутыйОстатокКт': 'summa_nachalnyy_razvernutyy_ostatok_kt', # 'СуммаНачальныйРазвернутыйОстатокКт': 'summa_nachalnyy_razvernutyy_ostatok_kt',
'СуммаОборот': 'summa_oborot', 'СуммаОборот': 'summa_oborot',
'СуммаОборотДт': 'summa_oborot_dt', 'СуммаОборотДт': 'summa_oborot_dt',
'СуммаОборотКт': 'summa_oborot_kt', 'СуммаОборотКт': 'summa_oborot_kt',
@ -77,37 +90,37 @@ def read_data_1C(**kwargs):
'СуммаКонечныйОстатокДт': 'summa_konechnyy_ostatok_dt', 'СуммаКонечныйОстатокДт': 'summa_konechnyy_ostatok_dt',
'СуммаКонечныйОстатокКт': 'summa_konechnyy_ostatok_kt', 'СуммаКонечныйОстатокКт': 'summa_konechnyy_ostatok_kt',
'СуммаКонечныйРазвернутыйОстатокДт': 'summa_konechnyy_razvernutyy_ostatok_dt', 'СуммаКонечныйРазвернутыйОстатокДт': 'summa_konechnyy_razvernutyy_ostatok_dt',
'СуммаКонечныйРазвернутыйОстатокКт': 'summa_konechnyy_razvernutyy_ostatok_kt', 'СуммаКонечныйРазвернутыйОстатокКт': 'summa_konechnyy_razvernutyy_ostatok_kt'
# Валютные остатки и обороты # Валютные остатки и обороты
'ВалютнаяСуммаНачальныйОстаток': 'valyutnaya_summa_nachalnyy_ostatok', # 'ВалютнаяСуммаНачальныйОстаток': 'valyutnaya_summa_nachalnyy_ostatok',
'ВалютнаяСуммаНачальныйОстатокДт': 'valyutnaya_summa_nachalnyy_ostatok_dt', # 'ВалютнаяСуммаНачальныйОстатокДт': 'valyutnaya_summa_nachalnyy_ostatok_dt',
'ВалютнаяСуммаНачальныйОстатокКт': 'valyutnaya_summa_nachalnyy_ostatok_kt', # 'ВалютнаяСуммаНачальныйОстатокКт': 'valyutnaya_summa_nachalnyy_ostatok_kt',
'ВалютнаяСуммаНачальныйРазвернутыйОстатокДт': 'valyutnaya_summa_nachalnyy_razvernutyy_ostatok_dt', # 'ВалютнаяСуммаНачальныйРазвернутыйОстатокДт': 'valyutnaya_summa_nachalnyy_razvernutyy_ostatok_dt',
'ВалютнаяСуммаНачальныйРазвернутыйОстатокКт': 'valyutnaya_summa_nachalnyy_razvernutyy_ostatok_kt', # 'ВалютнаяСуммаНачальныйРазвернутыйОстатокКт': 'valyutnaya_summa_nachalnyy_razvernutyy_ostatok_kt',
'ВалютнаяСуммаОборот': 'valyutnaya_summa_oborot', # 'ВалютнаяСуммаОборот': 'valyutnaya_summa_oborot',
'ВалютнаяСуммаОборотДт': 'valyutnaya_summa_oborot_dt', # 'ВалютнаяСуммаОборотДт': 'valyutnaya_summa_oborot_dt',
'ВалютнаяСуммаОборотКт': 'valyutnaya_summa_oborot_kt', # 'ВалютнаяСуммаОборотКт': 'valyutnaya_summa_oborot_kt',
'ВалютнаяСуммаКонечныйОстаток': 'valyutnaya_summa_konechnyy_ostatok', # 'ВалютнаяСуммаКонечныйОстаток': 'valyutnaya_summa_konechnyy_ostatok',
'ВалютнаяСуммаКонечныйОстатокДт': 'valyutnaya_summa_konechnyy_ostatok_dt', # 'ВалютнаяСуммаКонечныйОстатокДт': 'valyutnaya_summa_konechnyy_ostatok_dt',
'ВалютнаяСуммаКонечныйОстатокКт': 'valyutnaya_summa_konechnyy_ostatok_kt', # 'ВалютнаяСуммаКонечныйОстатокКт': 'valyutnaya_summa_konechnyy_ostatok_kt',
'ВалютнаяСуммаКонечныйРазвернутыйОстатокДт': 'valyutnaya_summa_konechnyy_razvernutyy_ostatok_dt', # 'ВалютнаяСуммаКонечныйРазвернутыйОстатокДт': 'valyutnaya_summa_konechnyy_razvernutyy_ostatok_dt',
'ВалютнаяСуммаКонечныйРазвернутыйОстатокКт': 'valyutnaya_summa_konechnyy_razvernutyy_ostatok_kt', # 'ВалютнаяСуммаКонечныйРазвернутыйОстатокКт': 'valyutnaya_summa_konechnyy_razvernutyy_ostatok_kt',
# Количественные остатки и обороты # Количественные остатки и обороты
'КоличествоНачальныйОстаток': 'kolichestvo_nachalnyy_ostatok', # 'КоличествоНачальныйОстаток': 'kolichestvo_nachalnyy_ostatok',
'КоличествоНачальныйОстатокДт': 'kolichestvo_nachalnyy_ostatok_dt', # 'КоличествоНачальныйОстатокДт': 'kolichestvo_nachalnyy_ostatok_dt',
'КоличествоНачальныйОстатокКт': 'kolichestvo_nachalnyy_ostatok_kt', # 'КоличествоНачальныйОстатокКт': 'kolichestvo_nachalnyy_ostatok_kt',
'КоличествоНачальныйРазвернутыйОстатокДт': 'kolichestvo_nachalnyy_razvernutyy_ostatok_dt', # 'КоличествоНачальныйРазвернутыйОстатокДт': 'kolichestvo_nachalnyy_razvernutyy_ostatok_dt',
'КоличествоНачальныйРазвернутыйОстатокКт': 'kolichestvo_nachalnyy_razvernutyy_ostatok_kt', # 'КоличествоНачальныйРазвернутыйОстатокКт': 'kolichestvo_nachalnyy_razvernutyy_ostatok_kt',
'КоличествоОборот': 'kolichestvo_oborot', # 'КоличествоОборот': 'kolichestvo_oborot',
'КоличествоОборотДт': 'kolichestvo_oborot_dt', # 'КоличествоОборотДт': 'kolichestvo_oborot_dt',
'КоличествоОборотКт': 'kolichestvo_oborot_kt', # 'КоличествоОборотКт': 'kolichestvo_oborot_kt',
'КоличествоКонечныйОстаток': 'kolichestvo_konechnyy_ostatok', # 'КоличествоКонечныйОстаток': 'kolichestvo_konechnyy_ostatok',
'КоличествоКонечныйОстатокДт': 'kolichestvo_konechnyy_ostatok_dt', # 'КоличествоКонечныйОстатокДт': 'kolichestvo_konechnyy_ostatok_dt',
'КоличествоКонечныйОстатокКт': 'kolichestvo_konechnyy_ostatok_kt', # 'КоличествоКонечныйОстатокКт': 'kolichestvo_konechnyy_ostatok_kt',
'КоличествоКонечныйРазвернутыйОстатокДт': 'kolichestvo_konechnyy_razvernutyy_ostatok_dt', # 'КоличествоКонечныйРазвернутыйОстатокДт': 'kolichestvo_konechnyy_razvernutyy_ostatok_dt',
'КоличествоКонечныйРазвернутыйОстатокКт': 'kolichestvo_konechnyy_razvernutyy_ostatok_kt' # 'КоличествоКонечныйРазвернутыйОстатокКт': 'kolichestvo_konechnyy_razvernutyy_ostatok_kt'
} }
df = df.rename(columns=field_mapping) df = df.rename(columns=field_mapping)