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

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

This commit is contained in:
bn_user 2025-09-10 08:21:45 +00:00
parent 898b63450d
commit 2708c60fea
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dags/fin_porfel.py
View File

@ -41,7 +41,7 @@ def upsert_list_fin_portfel(**kwargs):
, null as summa_dogovora , null as summa_dogovora
, null as percent_value , null as percent_value
from public.oborotno_salbdovaya_vedomostb osv from public.oborotno_salbdovaya_vedomostb osv
left join public.fin_portfel fp left join public.fin_porfel fp
on fp.schet = osv.schet on fp.schet = osv.schet
and fp.subkonto2 = osv.subkonto2 and fp.subkonto2 = osv.subkonto2
where (osv.schet like '%%01%%' or osv.schet like '%%03%%') where (osv.schet like '%%01%%' or osv.schet like '%%03%%')
@ -51,17 +51,17 @@ def upsert_list_fin_portfel(**kwargs):
with engine.begin() as conn: with engine.begin() as conn:
if not df.empty: if not df.empty:
conn.execute("CREATE TEMP TABLE temp_fin_portfel as SELECT * FROM public.fin_portfel WHERE 1=0") conn.execute("CREATE TEMP TABLE temp_fin_porfel as SELECT * FROM public.fin_porfel WHERE 1=0")
df.to_sql('temp_fin_portfel', con=conn, if_exists='append', index=False, method='multi') df.to_sql('temp_fin_portfel', con=conn, if_exists='append', index=False, method='multi')
conn.execute conn.execute
(""" ("""
INSERT INTO public.fin_portfel INSERT INTO public.fin_porfel
SELECT SELECT
schet schet
, subkonto2 , subkonto2
, summa_dogovora , summa_dogovora
, percent_value , percent_value
FROM temp_fin_portfel FROM temp_fin_porfel
""") """)
return 'Список обновлен.' return 'Список обновлен.'
else: else: