]iOdZddlmZddlmZddlmZmZddlm Z m Z ddl m Z ddl mZddlmZmZdd lmZmZdd lmZdd lmZmZdd lmZmZmZmZmZm Z dd l!m"Z"de dededefdZ#de de$ede%de$e&fdZ'dedefdZ(defdZ)dedefdZ*de de%de+fdZ,de de%de$efdZ- d;de de%de%dzdedzde%d e%de.e$ee%ffd!Z/de de%d"e%defd#Z0 dz#--8HIJ J >>W $z#--8PQR R  , , 8 >>N#8VSE\E\#]]N  ! ! -"7FCDZDZ"[[M)6(A}~  "%"8"8#0#&#:#:$2".   =L KI $^ \s8B0F62F03B F6=F2>,F6*F4+AF62F64F6adjc|jxsg}td|Dtd}tdid|jd|j d|j d|jr|jjndd|jd |jd |jr|jjnd d |jd |jr|jjnd d|jd|j d|j"d|j$r|j$jnd d|j&d|j(r|j(jnd d|j*dt-|d|S)z;Build a summary StockAdjustmentResponse from an ORM object.c3NK|]}|j|jywN)r0).0items r# z"_build_response..gs"ZUTd6M6M6Y Us%%0r3r&shift_id shift_namatanggalstatussubmitted_by_nameN submitted_atreviewed_by_name reviewed_atcatatan_review unlock_reasonrecalled_by_name recalled_atunlocked_by_name unlocked_at item_counttotal_volume_final)itemssumrrr3r&rJshiftr rMrN submitted_bynamerP reviewed_byrRrSrT recalled_byrV unlocked_byrXlen)rBr\ total_volumes r#_build_responserfcs~ IIOEZUZ L #  66    &)YY399>>B      zz  473C3C#**// %% 25--d OO )) '' 25--d OO 25--d  OO! "u:# $(% c |j}|r |jnd}|jxsgDcgc]9}t|j|j |j |j;}}t|j|j|r |jnd|r |jnd|r |jn td|j|j|j|j |j"| Scc}w)zQBuild an enriched StockAdjustmentItemResponse from a StockAdjustmentItem ORM row.N)r3stock_adjustment_item_idtipeurlrLrI) r3r+ tangki_nama produk_namakapasitas_literr,r-r.r/r0fotos)rr7rorr3rirjrkrr+r rnrr,r-r.r/r0)rGrr7fros r#_build_item_responserqs [[F$V]]$F**"" #A tt%&%?%?  #   ' 77..#)FKKr#)FKKr28..gcl22 44 44!6622   s>C>ct|}|jxsgDcgc] }t|}}tdi|j d|iScc}w)zCBuild a full StockAdjustmentDetailResponse including all item rows.r\r[)rfr\rqr model_dump)rBsummaryrGitem_responsess r#_build_detail_responservs\c"G>Aiio2oOoT*40oNO (       PsAcK|jrytfd|jxsgDd}|ytj||j t jtjd{S7w)z?Return True if user has stock:approve permission for this SPBU.Tc3BK|]}|jk(s|ywrE)r&)rFar&s r#rHz$_user_can_approve..sS#9Qaii7>Rq#9sNF) is_superadminnext assignmentsrhas_permissionrole_idrstockr approve)ruserr& assignments ` r#_user_can_approverss S4#3#3#9r#9SUYZJ // J   1A1A  sA5A?8A=9A?c Ktj||d{}|Dcgc])}t|d|d|d|d|d|d|d +c}S79cc}ww) zRReturn pre-fill data (last known volume/dipstick) for all active tanks in an SPBU.Nr+rlrmrnlast_volume_finallast_dipstick_digital_mm is_first_time)r+rlrmrnrrr)rget_stock_initr)rr&r;rs r#rrs"00W= =D A  n-(-(/0 34%&'A%BO,    > s AAA.AAANrJrNskiplimitc Ktj|||||||d{\}}|D cgc] } t| c} |fS7"cc} ww)z?Return a paginated list of StockAdjustmentResponse for an SPBU.N)rget_allrf) rr&rMrJrNrradj_listtotalrys r#list_adjustmentsrsV-44R'8U[]achiiOHe(0 11OA  15 88j 1sA A A AA A adj_idc|Ktj|||d{}| tdt|S7w)z6Return a fully enriched StockAdjustmentDetailResponse.N Stock adjustment tidak ditemukan)r get_by_idrrv)rr&rrBs r# get_detailrsA!**2vw? ?C {;<< !# && @s <:<rMsubmitter_user force_draftc K|jttjt tj |k(tj |k(tj|k(d{}|jtd|d|dt|||d{} tj|||||d{} t|||d{xr| } | rsddlm} m} |j | _| j%| j&| _tj*|| t,j.|j dd{} |j1d{t9| S7777707#t2$r,|j5d{7td|d|dt6$r|j5d{7wxYww) u  Create a new StockAdjustment. - Operators → saved as DRAFT - Admins (stock:approve permission) → immediately APPROVED in one step Raises ValueError if a record for the same spbu+shift+tanggal already exists, or on any tank/interpolation validation failure. Nz Stock adjustment untuk shift_id=z pada tanggal z sudah adardatetimetimezonez#Auto-approved oleh admin saat inputuser_idcatatan)r1rr r2rr&rJrMr8rrArcreaterrrr3submitted_by_idnowutcrP update_statusr APPROVEDcommitrrollbackrrv) rr&rJrMr%rrdup item_rowsrB can_approverrs r#create_adjustmentrs$ %% ''72((H4''72   C +.xjwiz Z  %Rg>>I$++B7IVV.r>7KK`U`Q`  3"0"3"3C '||HLL9C (66C//&))=C iik "# &&S ?WK    kkm.xjwiz Z   kkm sA/G(1F26G((F)G(.F F FF A9FF F1F 2F6 G(G(FF F FG%*F-+2G%G G%%G(cLKtj|||d{}| td|j|k7r td|jt j k7r tdt|||d{} tj|||d{}|jd{t|S77I7+7#t$r%|jd{7tdt$r|jd{7wxYww)z.Replace tank rows on a DRAFT stock adjustment.Nrz(Stock adjustment tidak termasuk SPBU iniz8Hanya stock adjustment berstatus DRAFT yang dapat dieditz/Gagal menyimpan perubahan item stock adjustment)rrrr&rNr DRAFTrA update_itemsrrrrrv)rr&rr%rBrs r#update_adjustmentrs !**2vw? ?C {;<< {{gCDD zz](((STT$Rg>>I$11"c9EEiik "# &&) @?F LkkmJKK kkm svD$C A#D$C D$C!C "C9C:C> D$ D$ CCD!-C0.+D!DD!!D$rc &Ktj|||d{}| td|jtj k7r td|j ttjtj|k(tjjdtjjdd{}t|jj!}|Dchc]}|j"}}|j$xsgD chc]} | j&} } || z } | rE|Dcgc]}|j"| vs|j(} }tddj+| |j$xsgD]3} | j, | j.td| j&d tj0||tj2| d{}|j5d{t=|S77Tcc}wcc} wcc}w7<7&#t6$r%|j9d{7td t:$r|j9d{7wxYww) z Transition a DRAFT adjustment to SUBMITTED. Validates that all active tanks in the SPBU have items AND all digital readings are filled. Nrz;Hanya stock adjustment berstatus DRAFT yang dapat di-submitTzYSemua tangki aktif harus memiliki data sounding sebelum submit. Tangki yang belum diisi: z, r(z.: pembacaan digital wajib diisi sebelum submit)rzGagal submit stock adjustment)rrrrNr rr1rrr2r& is_activer5r4listscalarsallr3r\r+r joinr.r/r SUBMITTEDrrrrrv) rr&rrrB tanks_result active_tankstactive_tank_idsrG item_tank_idsmissing missing_namess r#submit_adjustmentr=sR!**2vw? ?C {;<< zz](((VWWv  NNg %     &    ! !$ ' L ,,.2245L%12\qtt\O214bBT^^MB -G)5IA I((, -(@'A C  b  # # +t/H/H/PT^^,,Z[ ! $22 ],,g  iik "# &&[ @3BJ   :kkm899 kkm sJH%B6JH(/JH+J+H0> J H5H5-A J8J*H>=H:>H>H<H> J(J+J:H><H>>JI+JJ JJc Ktj|||d{}| td|jtj k7r td tj ||tj|dd{}|jd{t|S77)7#t$r%|jd{7tdt$r|jd{7wxYww)z''MDZDZJ $22 Z'  iik "# &&) @   JkkmHII kkm sdDCAD=CCC2C3C7 DCCD$C'%+DDDDalasancKtj|||d{}| td|jtj tj fvr td ddlm}m}tj||tj|d{}||_ |j|j|_|jd{|j!|d{t)|S77i7,7#t"$r%|j%d{7tdt&$r|j%d{7wxYww)zLReopen an APPROVED or LOCKED adjustment back to DRAFT, recording the reason.NrzJHanya stock adjustment berstatus APPROVED atau LOCKED yang dapat di-unlockrr)rTzGagal unlock stock adjustment)rrrrNr rLOCKEDrrrrunlocked_by_idrrrXrrefreshrrrrv)rr&rrrrBrrs r#unlock_adjustmentrs)!**2vw? ?C {;<< zz-00-2F2FGGeff/$22 ]((  %",,x||4iikjjo "# &&- @  :kkm899 kkm svEDAE'2D D>D DD 1D2D 6 ED D D E%D(&+EEEEr+cK|jttjtj|k(tj j djttjd{}|j}|td|d|j|k7rtd|dt|||d{S7X7w)zJLookup volume for a given dipstick height from a tank's calibration table.Nr(r)r*)r1rrr2r3r4r5r6r rr8rr&r$)rr&r+rr=rs r#calculate_volume_for_tankrs::v vyyI%v'8'8'<'s%BC%C! AC%C#C%#C%c8Kt|||d{S7w)uTPublic wrapper — returns True if user can approve stock adjustments for this SPBU.N)r)rrr&s r#check_user_can_approvers"2tW5 55 5s item_idrj file_bytesfilenamec<Kddlm}m}tj|||d{} | t d| j tjk7r t dtj|||d{} | t d|dvr t ddd lm } | ||d{} || d | j} |||| d{} tj||||d{|jd{tj|||d{} t#| S7777n7O79#t$r%|jd{7t d t $r|jd{7wxYw7ow) z~ Save a photo for a StockAdjustmentItem (tipe: 'manual' | 'digital'). Returns the refreshed full detail response. r) save_upload UploadContextNrz__doc__rrdecimalr sqlalchemyrrsqlalchemy.excrrsqlalchemy.ext.asyncior sqlalchemy.ormr app.models.operationalr r app.models.roler rapp.models.spburapp.repositoriesrrapp.schemas.stockrrrrrrapp.utils.kalibrasirr$rintdictrArfrqrvboolrrtuplerrobjectrrrrstrrrrrbytesrrr[rgr#rsY#:/'A/">3 @L @& @W @Y` @55./55 $Z 5p-D:"=84Q  S T  " , #' 9 9  9Dj 9 D 9  9  9 4' (# -. 9''"',/'"'";';' ;';' ;' ./ ;'  ;';'#;'|'' ' './ ' # '<4'4'"4',/4':=4'"4'n''"',/':='"'2'' ' ' '  ' 4Z '#'@''"',/':='GJ'"':>>">/2>?F> >"6\6#6$6 .'.' .' .' .'  .'  .'.'#.'b'''' '' '' ''  '' # ''rg