]i-dZddlmZddlmZddlmZmZmZm Z m Z m Z m Z ddl mZddlmZddlmZmZddlmZdd lmZdd lmZmZmZmZmZmZmZdd l m!Z!ed d gZ"de#e$zde fdZ%e"jMde'e de de dde dde dddeeeefde(dedzde(dzd edzd!e(d"e(d#ed$ede'fd%Z)e"jMd&e'eeeefde(d#ed$ede'fd'Z*e"jMd(e'e d)e d)eeeefde(d*e(d+ed#ed$ede'f d,Z+e"jYde'e jZ-eeeee d.d/0fde(d1ed#ed$ed2e.de'f d3Z/e"jMd4e'eeeefde(d5e(d#ed$ede'f d6Z0e"jcd4e'eeeefde(d5e(d1ed#ed$ede'f d7Z2e"jcd8e'eeeefde(d5e(d#ed$ede'f d9Z3e"jcd:e'eeeefde(d5e(d#ed$ede'f d;Z4e"jcde'eeeefde(d5e(d1ed#ed$ede'f d?Z6e"jYd@e'e jZ-e d)dA0ed)eeeefde(d5e(dBe(dCe7dDe d#ed$ede'fdEZ8e"jsdFe'eeeefde(d5e(dBe(dGe(d#ed$ede'fdHZ:e"jMdIeeeefde(d5e(d#ed$efdJZ;y)Kz1Router for stock adjustment (sounding) endpoints.)date)Decimal) APIRouterDependsFile HTTPExceptionQuery UploadFilestatus) AsyncSession)get_db)get_current_userget_spbu_access) StatusLaporan)User)StockAdjustmentCreateStockAdjustmentDetailResponseStockAdjustmentResponseStockAdjustmentUpdateStockInitResponse ReviewRequest UnlockRequest) stock_servicez!/spbus/{spbu_id}/stock-adjustmentstock)prefixtagsereturnct|tr$ttjt |Sttj t |S)uEConvert service-layer ValueError → 400 and PermissionError → 403.) status_codedetail) isinstancePermissionErrorrr HTTP_403_FORBIDDENstrHTTP_400_BAD_REQUEST)rs >/var/www/html/spbu.com/backend/app/routers/stock_adjustment.py_service_errorr(s:!_%)B)B3q6RR V%@%@Q PP)response_modelN)defaultr )r,alias)r,ged)r,r.lespbu_idtanggalshift_id adj_statusskiplimitdb current_userc K tj|||||||d{\}} |D cgc]} | j c} | ||zdz|ddS72#ttf$r} t | d} ~ wwxYwcc} ww)zh List stock adjustments for an SPBU with optional filters. Requires: stock:view permission. Nr0)totalpageper_page)datameta)rlist_adjustments ValueErrorr#r( model_dump) r3r4r5r6r7r8r9r:adj_listr<ras r'rArA%s - > > (Je!  % *22A2):N     ( Q 3sBA>AAAA>A9A>AA6& A11A66A>z /stock-initcK tj||d{}tj|||d{}|Dcgc]}|j c}|dS7D7'#ttf$r}t |d}~wwxYwcc}ww)z Return pre-fill data (last known volume/dipstick) for all active tanks of an SPBU. Also returns can_approve flag so the frontend can show "Simpan & Approve" vs "Simpan & Submit". Requires: stock:view permission. N)r? can_approve)rget_stock_initcheck_user_can_approverBr#r(rC)r3r9r:rowsrGrrs r'rHrH@s "11"g>>)@@\SZ[[ .22TQ\\^T2; OO ?[  ( Q 2sTB A&A"A&A$A&B BB "A&$A&&B5 BBB z/calculate-volume. tangki_id height_mmcK tj||||d{}ddt |iiS7#ttf$r}t |d}~wwxYww)z Calculate volume (litres) from a dipstick height (mm) using the tank's calibration table. Returns error detail if height is out of calibration range. Nr? volume_liter)rcalculate_volume_for_tankrBr#r(r%)r3rLrMr9r:volumers r'calculate_volumerRSs` $>>r7IW`aa ^S[1 22b  ( Q s1A535A5A AAA)r+r Fz?Dev only: skip auto-approve even if user has approve permission) descriptionr? force_draftc *K tj|||j|j|j||d{}|jdk(rdnd}|jd|dS7-#t t f$r}t|d}~wwxYww)zh Create a new stock adjustment (starts in DRAFT status). Requires: stock:create permission. )rTNapprovedzdibuat & disetujuizdisimpan sebagai draftStock adjustment berhasil r?message) rcreate_adjustmentr5r4itemsrBr#r(r rC)r3r?r9r:rTadjractions r'rZrZfs !33  djj,#   &)ZZ:%= !C[FNN$3MfX1V WW   ( Q s:B=A1A/A1)B/A11B B  BBz /{adj_id}adj_idcK tj|||d{}d|j iS7#ttf$r}t |d}~wwxYww)zx Return full detail for a single stock adjustment including all tank rows. Requires: stock:view permission. Nr?)r get_detailrBr#r(rCr3r^r9r:r\rs r'get_adjustment_detailrb}s[ !,,R&AA CNN$ %%B  ( Q s1A757A7A AAAcK tj||||jd{}|j ddS7#ttf$r}t |d}~wwxYww)z] Replace tank rows on a DRAFT stock adjustment. Requires: stock:edit permission. Nz"Stock adjustment berhasil diupdaterX)rupdate_adjustmentr[rBr#r(rCr3r^r?r9r:r\rs r'rdrdsb !33BTTNN$1U VVU  ( Q 7A%%AAAA%AA" AA""A%z/{adj_id}/submitcK tj||||jd{}|j ddS7#ttf$r}t |d}~wwxYww)z Submit a DRAFT stock adjustment for review. Validates all active tanks have digital readings before allowing submit. Requires: stock:create permission. Nz#Stock adjustment berhasil di-submitrX)rsubmit_adjustmentidrBr#r(rCras r'rhrhsb !33BYYNN$1V WWZ  ( Q rfz/{adj_id}/recallcK tj||||jd{}|j ddS7#ttf$r}t |d}~wwxYww)z Recall a SUBMITTED stock adjustment back to DRAFT (operator only). Only valid while status is still SUBMITTED (admin has not acted yet). Requires: stock:create permission. Nz2Stock adjustment berhasil ditarik kembali ke DraftrX)rrecall_adjustmentrirBr#r(rCras r'rkrksb !33BYYNN$1e ffZ  ( Q rfz/{adj_id}/reviewc&K tj||||j|j|jd{}|jdk(rdnd}|jd|dS7-#t t f$r}t|d}~wwxYww)za Approve or reject a SUBMITTED stock adjustment. Requires: stock:approve permission. Napprove disetujuiditolakrWrX) rreview_adjustmentrir]catatanrBr#r(rC)r3r^r?r9r:r\r action_labels r'rprps !33 $++t||   #'++":; LNN$3Ml^1\ ]]    ( Q s9B;A/A-A/)B-A//B> B  BBz/{adj_id}/unlockcK tj||||j|jd{}|jddS7#tt f$r}t |d}~wwxYww)z Unlock an APPROVED or LOCKED stock adjustment back to DRAFT, recording the reason. Requires: stock:approve permission. Nz#Stock adjustment berhasil di-unlockrX)runlock_adjustmentrialasanrBr#r(rCres r'rtrtsn !33 $++   NN$1V WW    ( Q s7A00AA AA0 AA- A((A--A0z/{adj_id}/items/{item_id}/fotosz"Tipe foto: 'manual' atau 'digital'item_idtipefilec K|jd{} tj|||||||jxsdd{}|jddS7I7#tt f$r} t | d} ~ wwxYww)z Upload photo evidence for a tank sounding item (manual stick or digital display). Requires: stock:create permission. Nzfoto.jpgzFoto berhasil diuploadrX)readrupload_item_fotofilenamerBr#r(rC) r3r^rvrwrxr9r: file_bytesr\rs r'r{r{syy{"J !22 $ DMM>BBz)/{adj_id}/items/{item_id}/fotos/{foto_id}foto_idcK tj|||||d{}|j ddS7#ttf$r}t |d}~wwxYww)zX Delete a photo from a tank sounding item. Requires: stock:edit permission. NzFoto berhasil dihapusrX)rdelete_item_fotorBr#r(rC)r3r^rvr~r9r:r\rs r'rr sf !22 '   NN$1H II    ( Q s1A:8:A:A AAAz/{adj_id}/bast-pdfc RKddlm}ddlm} t j |||d{}|jdvr tdddd l m }dd l m} |j| |j!|j"|k(d{j%} | r | j&nd |} d t)|j*fd |j,xsdfdt)t/|j0fg} |d|| t)|j*|j2xsd|j4|j6xsd|j8|  } d|d|j*d|j:d}|| ddd|diS7U#t tf$r}t|d}~wwxYw7w)zTDownload BAST PDF for an approved stock adjustment. Requires: stock:view permission.r)Response) generate_bastN)rViz>BAST hanya tersedia untuk stock adjustment yang sudah Approved)r!)Spbu)selectzSPBU TanggalShift-z Jumlah TangkizStock Adjustment) modul record_id spbu_namer4submitter_name submitter_at approver_name approver_atdetailszBAST-StockAdjustment-z-shiftz.pdfzapplication/pdfzContent-Dispositionzattachment; filename="")content media_typeheaders)fastapi.responsesrapp.utils.bast_pdfrrr`rBr#r(r rapp.models.spbur sqlalchemyrexecutewhereriscalar_one_or_nonenamer%r4 shift_namalenr[submitted_by_name submitted_atreviewed_by_name reviewed_atr5)r3r^r9r:FastAPIResponserr\rr sa_selectspburr pdf_bytesr|s r'download_bast_adjustmentr!s>0 !,,R&AA zz&C(hii$.**Yt_22477g3EFG G [ [ ]D! wi'8I C $% #..'C( #c#))n-.G  FS%5,,3%%**1cOOI'wiq VCLL>QUVH 99J26LXJVW4XY [[1B  ( Q HsE F'FE?FAF' F$ C2F'?FF! FF!!F')<__doc__datetimerdecimalrfastapirrrrr r r sqlalchemy.ext.asyncior app.core.databaser app.dependenciesrrapp.models.operationalrapp.models.userrapp.schemas.stockrrrrrrr app.servicesrrouterrBr#r(getdictintrArHrRpostHTTP_201_CREATEDboolrZrbpatchrdrhrkrprtr%r{deleterrr)r'rs7VVV/$>0 '  .   Qj?2Q}QBt$!. .',T'JaA&raC0v 1  D[Dj$       %4M$/v 1P PPP P0P$ 53Zsv 1 3 333  3  3  363$R&2I2IJv 1e1rs X X X X X  X  XKX,K-v 1 & & & & &  &.&"k$/ v 1 W W W W  W  W  W0W$ 6v 1 X X X X X  X7X$ 6v 1 g g g g g  g7g$ 6 v 1 ^ ^ ^ ^  ^  ^  ^7^* 6 v 1 X X X X  X  X  X7X( .tQWQhQhi c'KLCyv 1K K KK  K  K  KK KjK.:4P v 1 J J JJ J  J  J JQJ* !v 1 $[ $[ $[ $[ $["$[r)