]iU1 dZddlmZmZddlmZmZddlmZddlm Z ddl m Z m Z m Z mZmZmZmZmZ d?ded ed ed eedzd eeeeff d Zdeded edzfdZded efdZdeded efdZd@dededed dfdZdeded eefdZdeded edzfdZdeded efdZdeded efdZ d@dededed dfdZ!deded ee fdZ"deded e dzfdZ#deded e fdZ$ded e d e fd!Z%d@ded e ded dfd"Z&ded#ed edzfd$Z'deded efd%Z(ded&ed efd'Z)d@ded&eded dfd(Z*deded eefd)Z+ded*ed edzfd+Z,deded efd,Z-ded-ed efd.Z.d@ded-eded dfd/Z/ded*ed0ee0d ee fd1Z1deded eefd2Z2ded3ed edzfd4Z3deded efd5Z4ded6ed efd7Z5d@ded6eded dfd8Z6ded9ed e dzfd:Z7ded3ed e fd;Z8dedZ:y)AuzSPBU repository — all DB queries for SPBU and its sub-resources (shifts, islands, nozzles, tangkis, tenants, contracts).)datetimetimezone)funcselect) AsyncSession) selectinload)IslandKalibrasiTangki KontrakSewaNozzleShiftSpbuTangkiTenantNdbskiplimitspbu_idsreturncKttjtjj dj t tjjtj}|.|jtjj|}|jttjj|j!d{}|j#}|j|j%|j'|d{}t)|j+j-|fS7t7/w)z9Fetch paginated SPBUs. Optionally filter to a set of IDs.N)rrwhere deleted_atis_optionsrshiftsorder_bynameidin_executercount select_fromsubquery scalar_oneoffsetrlistscalarsall)rrrrquerycount_qtotalresults B/var/www/html/spbu.com/backend/app/repositories/spbu_repository.pyget_allr. s t t""4( ) dkk* + $))    DGGKK12JJvdjjl3??@PQRRG    E::ell4066u=> >F  $$& ' ..S >s%C;E6=E2>AE6E4.E64E6spbu_idcBK|jttjtj|k(tj j djttjd{}|jS7w)z?Fetch a single SPBU by primary key, eagerly loading its shifts.N) r rrrrrrrrrscalar_one_or_nonerr/r,s r- get_by_idr3!sm::t tww'!4??#6#6t#< = dkk* +F  $ $ && BBB BchK|jdg}tdi|}|j||jd{|D](}|jt dd|j i|*|jd{t ||j d{S7g7$7w)uRCreate a new SPBU together with its initial shifts. Flush only — caller commits.rNr/)popraddflushr rr3)rkwargs shifts_dataspbu shift_datas r-creater>+s**Xr*K >&>DFF4L ((*!  u3TWW3 34" ((*2tww' ''  's7AB2B,AB2 B. B2'B0(B2.B20B2r<cK|jD]\}}t||||jd{t||jd{S7"7w)uHUpdate scalar fields on an existing SPBU. Flush only — caller commits.N)itemssetattrr9r3r)rr<r:keyvalues r-updaterD7sRlln Uc5!% ((*2tww' '' '!9A"AA"A A" A" hard_deletecK|r|j|d{n(tjtj|_|j d{y7F7w)u5Delete an SPBU record. Flush only — caller commits.Ndeleternowrutcrr9)rr<rFs r- delete_spburL?sHiio",,x||4 ((* "A$A AA$A"A$"A$c^K|jttjtj|k(tj j djtjd{}t|jjS7+w)z:Return all shifts for a given SPBU, ordered by start time.N) r rr rr/rrr jam_mulair&r'r(r2s r- get_shiftsrPJsv::u u}}')9)9)=)=d)C D %// "F  $$& '' sA=B-?B+,B-shift_idcK|jttjtj|k(tj j dd{}|jS7w)z$Fetch a single shift by primary key.N)r rr rrrrr1)rrQr,s r-get_shift_by_idrSTs]::u EHH0%2B2B2F2Ft2LMF  $ $ &&A A9"A7#A9cKtdd|i|}|j||jd{|j|d{|S77w)uECreate a new shift for the given SPBU. Flush only — caller commits.r/Nr6)r r8r9refresh)rr/r:shifts r- create_shiftrX\sR  ,' ,V ,EFF5M ((* **U  L!2AAA AAArWcK|jD]\}}t||||jd{|j|d{|S77w)uIUpdate scalar fields on an existing shift. Flush only — caller commits.Nr@rAr9rV)rrWr:rBrCs r- update_shiftr\esUlln UsE"% ((* **U  L!9AAAAAAcK|r|j|d{n(tjtj|_|j d{y7F7w)u5Delete a shift record. Flush only — caller commits.NrH)rrWrFs r- delete_shiftr_nsJii#<< 5 ((* rMcNK|jttjtj|k(tj j djttjjtjttjjtjjtjd{}t|j!j#S7+w)zMReturn all islands for a given SPBU, with nested nozzle relationships loaded.N)r rr rr/rrrrnozzlesr produktangkirurutanr&r'r(r2s r- get_islandsreys::v v~~(&*;*;*?*?*E F   ( 5 5fmm D  ( 5 5fmm D  &-- F  $$& ''sC5D%7D#8,D% island_idcK|jttjtj|k(tj j djttjjtjttjjtjd{}|jS7w)zGFetch a single island by primary key, with nozzle relationships loaded.N)r rr rrrrrrrar rbrcr1)rrfr,s r-get_island_by_idrhs::v vyyI%v'8'8'<',C+ tangki_idcrK|jttjtj|k(tj j djttjttjd{}|jS7w)zGFetch a single tangki by primary key, with kalibrasi and produk loaded.N) r rrrrrrrrrrbr1)rrr,s r-get_tangki_by_idrs|::v vyyI%v'8'8'<'C ? C C&CCC CCcK|jttjtj|k(tj j djttjjtjd{}t|jjS7+w)zAReturn all tenants for a given SPBU, with their contracts loaded.N)r rrrr/rrrrkontrakrrr&r'r(r2s r- get_tenantsrs::v v~~(&*;*;*?*?*E F fnn- . &++  F  $$& '' sB#C%C&,C tenant_idcBK|jttjtj|k(tj j djttjd{}|jS7w)z @V@V@Z@Z[_@`aF  $ $ &&rTcKtdd|i|}|j||jd{|j|d{|S77w)uPCreate a new lease contract for the given tenant. Flush only — caller commits.rNr6)r r8r9rV)rrr:rs r-create_kontrakrIsR8I88GFF7O ((* **W  NrYrcK|jD]\}}t||||jd{|j|d{|S77w)uRUpdate scalar fields on an existing lease contract. Flush only — caller commits.Nr[)rrr:rBrCs r-update_kontrakrRsUlln Ue$% ((* **W  Nr]cK|r|j|d{n(tjtj|_|j d{y7F7w)u>Delete a lease contract record. Flush only — caller commits.NrH)rrrFs r-delete_kontrakr[sJii   %\\(,,7 ((* !rM)r2N)T);__doc__rr sqlalchemyrrsqlalchemy.ext.asynciorsqlalchemy.ormrapp.models.spbur r r r r rrrintsettupler&r.r3r>rDboolrLrPrSrXr\r_rerhrkrorrrvrzr|r~rrrrrdictrrrrrrrrrrr6r-rs@A'#/'eee  $ // / /#ho /  4:s? /*' 's'td{' (\ ( ((\((D(,dQU(((U ('l'c'edl'<#E<E<DTX (, ( (f ( '| ' ' '1L131V11L1&1v1L&tW['|'' '1L1S1v11L1&1v1L&tW[(,((f('|'' '1L131V11L1&1v1L&tW[  !$ ,0J  / "(,((f('|'' '1L131V11L1&1v1L&tW[' '#'+PTBT'\c \Kk\Kd^br