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

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

This commit is contained in:
bn_user 2025-12-08 10:52:18 +00:00
parent ac90de45c3
commit 06516c84da
1 changed files with 1 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
dags/OSV_with_docs.py
View File

@ -365,7 +365,7 @@ def poruchitelstva(**kwargs):
UNION ALL UNION ALL
SELECT SELECT
case when osv.category_name = 'Лизинг' then '76.07.1' else '76.09' end as schet case when osv.category_name = 'Лизинг' then '76.07.1' else '76.09' end as schet
, osv.id::text as uid_dogovor , '00000000-0000-0000-0000-000000000000' as uid_dogovor
, osv.category_name as name , osv.category_name as name
, osv.agreement_num as nomer , osv.agreement_num as nomer
, osv.agreement_date as date_begin , osv.agreement_date as date_begin
@ -373,17 +373,6 @@ def poruchitelstva(**kwargs):
FROM lizingi_garantii osv FROM lizingi_garantii osv
LEFT JOIN poruchitelstva p on p.nomer = osv.agreement_num LEFT JOIN poruchitelstva p on p.nomer = osv.agreement_num
WHERE p.uid_dogovor is null WHERE p.uid_dogovor is null
UNION ALL
SELECT
'009' as schet
, osv.id::text as uid_dogovor
, osv.category_name as name
, osv.agreement_num as nomer
, osv.agreement_date as date_begin
, osv.redemption_date as date_end
FROM zalogi osv
LEFT JOIN poruchitelstva p on p.nomer = osv.agreement_num
WHERE p.uid_dogovor is null
""") """)
df = pd.read_sql(query, engine) df = pd.read_sql(query, engine)
with engine.begin() as conn: with engine.begin() as conn: