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

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

This commit is contained in:
bn_user 2025-09-09 14:21:45 +00:00
parent 861653dc51
commit fb730103f0
1 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
dags/split_subkonto2.py
View File

@ -244,22 +244,29 @@ def parse_contract_cell(cell_text):
def read_dict_subkonto2_db(**kwargs):
engine = get_db_engine()
df = pd.read_sql(
"""
select distinct
# Using triple quotes for better readability
query = """
SELECT DISTINCT
osv.schet as schet
, osv.subkonto2 as subkonto2
, osv.nomer as nomer
, osv.date_begin as date_begin
, osv.date_end as date_end
from public.oborotno_salbdovaya_vedomostb osv
left join public.dict_subkonto_two as dst
on dst.subkonto2 = osv.subkonto2
where osv.subkonto2 not in (select dst2.subkonto2 from public.dict_subkonto_two dst2)
and (osv.nomer is null or osv.date_begin is null or osv.date_end is null)
and (osv.schet like \'%01%\' or osv.schet like \'%03%\')
""", engine)
return df.to_dict(orient='records')
FROM public.oborotno_salbdovaya_vedomostb osv
LEFT JOIN public.dict_subkonto_two as dst
ON dst.subkonto2 = osv.subkonto2
WHERE osv.subkonto2 NOT IN (SELECT dst2.subkonto2 FROM public.dict_subkonto_two dst2)
AND (osv.nomer IS NULL OR osv.date_begin IS NULL OR osv.date_end IS NULL)
AND (osv.schet LIKE '%01%' OR osv.schet LIKE '%03%')
"""
try:
df = pd.read_sql(query, engine)
return df.to_dict(orient='records')
except Exception as e:
print(f"Error executing SQL query: {e}")
raise
def split_subkonto_from_1C(**kwargs):
engine = get_db_engine()