]i dZddlmZmZmZmZmZddlmZddl m Z ddl m Z m Z ddlmZddlmZmZddlmZed d g Zd eezd efdZej3deededdeddedddee ee fdededzdedzdededed ed efd!Zej=deej>"ee ee fded#eded ed ef d$Z ej3d%eee ee fded&eded ed ef d'Z!ejEd(eee ee fded&ed#eded ed ef d)Z#y)*z/Router for End-to-End reconciliation endpoints.) APIRouterDepends HTTPExceptionQuerystatus) AsyncSession)get_db)get_current_userget_spbu_access)User) EndToEndCloseEndToEndCreate)end_to_end_servicez/spbus/{spbu_id}/end-to-end rekonsiliasi)prefixtagsereturnct|tr$ttjt |Sttj t |S)uEConvert service-layer ValueError → 400 and PermissionError → 403.) status_codedetail) isinstancePermissionErrorrrHTTP_403_FORBIDDENstrHTTP_400_BAD_REQUEST)rs 8/var/www/html/spbu.com/backend/app/routers/end_to_end.py_service_errorrs:!_%)B)B3q6RR V%@%@Q PP)response_modelN)defaultr)r"alias)r"ge2)r"r$lespbu_id tangki_id status_filterskiplimitdb current_usercK tj||||||d{\}}|D cgc]} | j c} |||zdz|ddS72#ttf$r} t | d} ~ wwxYwcc} ww)zFList E2E cycles for an SPBU, optionally filtered by tangki and status.)r*rr,r-Nr&)totalpageper_page)datameta)r list_cycles ValueErrorrr model_dump) r)r*r+r,r-r.r/rowsr1rrs rr6r6s .:: 9]U  e*..A.):N     ( Q /sBA>AAAA>A9A>AA6& A11A66A>)r!rr4cK tj|||j|d{}|j ddS7#ttf$r}t |d}~wwxYww)zLStart a new E2E cycle for a tank. Tank must not have an existing open cycle.Nz"Siklus End-to-End berhasil dimulair4message)r start_cycleidr7rrr8)r)r4r.r/cyclers rr>r>1se (44R,//SWXX$$&3W XXY  ( Q s7A%%AAAA%AA" AA""A%z /{cycle_id}cycle_idcK tj|||d{}d|j iS7#ttf$r}t |d}~wwxYww)zDGet detail of an E2E cycle. Open cycles include live running totals.Nr4)rget_cycle_detailr7rrr8)r)rAr.r/rrs rrCrC@s] )::2wQQ F%%' ((R  ( Q s1A757A7A AAAz/{cycle_id}/closecK tj||||j|d{}|j ddS7#ttf$r}t |d}~wwxYww)zEClose an open E2E cycle. Freezes totals and calculates actual losses.Nz"Siklus End-to-End berhasil ditutupr<)r close_cycler?r7rrr8)r)rAr4r.r/rrs rrErEOsl )55 rCpatchrErrrVs?5DD/$> @+  (    Qj?2Q}QBt$"$/ %d( CaA&raC0v 1 Tz:       %.R&2I2IJv 1 Y  Y  Y  Y Y  YK YM$/v 1 )  ) )  ) )  )0 )!$7 v 1 Z ZZ Z  Z  Z  Z8Zr