]iHLdZddlmZddlmZddlmZmZmZddlm Z ddl m Z ddl m Z mZddlmZmZdd lmZdd lmZdd lmZdd lmZmZmZdd lmZmZmZm Z ddl!m"Z"m#Z#m$Z$ddl%m&Z&ddl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0ddl1m2Z2m3Z3d"dZ4d#dZ5 d$dZ6 d%dZ7d&dZ8 d'dZ9 d( d)dZ: d*dZ; d+dZ< d,dZ= d- d.dZ> d/dZ? d0dZ@ d1d ZA d2d!ZBy)3uLPenyetoran service — business logic for the per-shift cash deposit module.) annotations) defaultdict)datedatetimetimezoneDecimal)Optional)funcselect)IntegrityErrorSQLAlchemyError) AsyncSession) selectinload)Expense) LaporanShiftPenjualanNozzle StatusLaporan) PenyetoranPenyetoranBatchStatusPenyetoranStatusPenyetoranBatch)IslandNozzleShift)penyetoran_repository) BatchReviewRequest DailySummaryPenyetoranBatchCreatePenyetoranBatchResponsePenyetoranResponsePenyetoranUpdate ProductTotalShiftProductSummary ShiftSummary) save_upload UploadContextc d}|j6|jj |jjj}tdid|jd|j d|j d|jd|jd|d|jd |jd |jd |jd |jd t|jt r |jn|jj"d|j$d|j&r|j&j(ndd|j*d|j,S)z9Build a PenyetoranResponse from an ORM Penyetoran object.Nidspbu_idlaporan_shift_idtanggalshift_id shift_nama jumlah_kasjumlah_non_kastotal_penjualancatatan bukti_urlstatusbatch_idcreated_by_name created_at updated_at) laporan_shiftshiftnamar!r)r*r+r,r-r/r0r1r2r3 isinstancer4strvaluer5 created_bynamer7r8)pr.s A/var/www/html/spbu.com/backend/app/services/penyetoran_service.py_build_responserD&sI!%J"q'<'<'H__**//   44   ++         << '' ))   ++ &ahh4qxx!((..  ./\\ ))t <<  <r? submitted_byrArK reviewed_byrMrNrOrDr7r8)batchrBs rC_build_batch_responserSAs " 88 ''##'' )%,,:E9c dK|jttjtjt j djt j|k(t j|k(d{}tt|jS7&w)z/Sum all Expense.jumlah for a given SPBU + date.rN) rUr r coalescesumrjumlahrVr*r,r r> scalar_oneras rC_get_daily_expenses_totalrjpsy::t}}TXXgnn5q9: w')7??g+E FF 3v((*+ ,, sBB0B.'B0ctd}|jxsgD]}|j}|r |jnd}|r |jnd}||}||d<|r |j nd|d<|r |j nd|d<|j|d<|jr/|d xx|jz cc<|d xx|jz cc<nH|d xx|j|jz z cc<|d xx|j|jz z cc<|d xx|jz cc<|d xx|jz cc<"|jDcgc]-}t!|d|d|d|d |d |d |d |d /}}t#d|D} t#d|D} t#d|D} t#d|D} t%|j|j&|j(r|j(j ndt+|j,t.r |j,n|j,j0|| | | |  Scc}w)zEBuild a ShiftSummary by aggregating PenjualanNozzle rows per product.c rtdtdtdtdtdddddSN0r)volume_digital volume_manual volume_finalnilai harga_jual produk_nama produk_kode produk_idrr9rErCz"_aggregate_shift..~s3!#,  cl 7rENrrwrorurvrtrprqrrrsrwrurvrprqrrrsrtc34K|]}|jywNrp.0rBs rC z#_aggregate_shift..s6X1##Xc34K|]}|jywr{rqr}s rCrz#_aggregate_shift..s5Hq1??Hrc34K|]}|jywr{rrr}s rCrz#_aggregate_shift..s48a1>>8rc34K|]}|jywr{rsr}s rCrz#_aggregate_shift..s,8a!''8r) r+r-r.r4productstotal_volume_digitaltotal_volume_manualtotal_volume_final total_nilai)rrXrYrZr)r<kodertflag_reset_tellervolumeteller_akhir_digitalteller_awal_digitalteller_akhir_manualteller_awal_manualrsvaluesr$rgr%r-r;r=r4r>r?) laporan per_produkrowrYrZrwentryvrtotal_vdtotal_vmtotal_vftotal_ns rC_aggregate_shiftr{sP#. / #J''-2-"(d!'FIIQ 9%&k.4v{{"m.4v{{"m!nnl   " #szz 1 # / "cjj 0 " " #s'?'?#BYBY'Y Y # / "c&=&=@V@V&V V " n+ g#))#3.L""$ %A  n-(-(-.O,>*G* % 6X66H5H55H4844H,8,,G  !!)07==%%B!+GNNC!@w~~gnnFZFZ%$#  ' s2IcKt|||d{}t|||d{}|Dcgc] }t|}}td}|D]}|jD]} || j } | j | d<| j | d<| j| d<| j| d<| dxx| jz cc<| dxx| jz cc<| d xx| jz cc<| d xx| jz cc<|jD cgc]-} t| d| d| d| d| d| d | d | d /} } td | D} td | D}td| D}td| D}||z }t!j"|||d{}t%||| | ||||||r |j&nd|r|j( Sd S77cc}wcc} w7Kw)z Aggregate all laporan_shift + penjualan_nozzle data for a date into a DailySummary. Also checks for an existing penyetoran record and includes its id/status. Nc rtdtdtdtdtdddddSrmrr9rErCrxz#get_daily_summary..s3!#,  cl 9rErwrurvrtrprqrrrsryc34K|]}|jywr{r|r}s rCrz$get_daily_summary..s<^1##^rc34K|]}|jywr{rr}s rCrz$get_daily_summary..s;Nq1??Nrc34K|]}|jywr{rr}s rCrz$get_daily_summary..s:>a1>>>rc34K|]}|jywr{rr}s rCrz$get_daily_summary..s2>a!''>r) r,shiftsproducts_totalgrand_total_volume_digitalgrand_total_volume_manualgrand_total_volume_finalgrand_total_nilaitotal_expensessuggested_setorexisting_penyetoran_idexisting_penyetoran_status)rdrjrrrrwrurvrtrprqrrrsrr#rgrget_by_tanggalrr)r4)rbr*r, laporan_listrlsr cross_produkr;rBerrgrand_vdgrand_vmgrand_vfgrand_n suggestedexistings rCget_daily_summaryrsA/r7GDDL4R'JJNAM!N2"22"6F!N%0 1 %LAQ[[)A[[AkN }}Am  }}Am llAlO  1#3#3 3  o !// 1  n  /  gJ!'' !J .$$& 'A  n-(-(-.O,>*G* ' <^<::H2>22G.(I+99"gwOOH %#+"*!)!%!.6x{{D6>8??  EI  gEJ!N2 *PsJH G9H G<H G?CH "2HA)H =H >Ktj|||d{}| td|jtj k7r tdi}|j |j |d<|s t|S tj|||d{}|jd{t|S77)7#t$r%|jd{7tdt$r|jd{7wxYww)z%Update catatan on a DRAFT penyetoran.Nrz2Hanya penyetoran berstatus DRAFT yang dapat dieditr2 Constraint error pada penyetoran) rrrr4rDRAFTr2rDupdatecommitr rollbackr)rbr*rbodyrB update_dicts rCupdate_penyetoranr2s$--b-IIAy566xx#)))MNNK ||!% I q!! '..r1kB Biikq!!! J C =kkm;<< kkm sdDCA#DC CC 4C5C DC C D&C)'+DDDDc4Ktj|||d{}| td|jtj k7r tdd}t ||kDr tdd|vr#|jdddjnd }|d vr td d d l m }|||jd{} t| d|j} t||| d{} tj||| d{}|j!d{t#|S77v7L7.7#t$$r%|j'd{7tdt($r|j'd{7wxYww)zLSave proof-of-transfer image/PDF and store the URL on the penyetoran record.Nrz/Bukti hanya bisa diupload pada penyetoran DRAFTiz)Ukuran file melebihi batas maksimum 10 MB.ro>jpgpdfpngjpegz5Tipe file tidak didukung. Gunakan PDF, JPG, atau PNG.r) get_spbu_code penyetoranr)rrrr4rrlenrsplitlowerapp.utils.file_uploadrr*r'r,r& update_buktirrDr rr) rbr*r file_bytesfilenamerB max_bytesextr spbu_codectxurls rC upload_buktirRsq$--b-IIAy566xx#)))JKK I :"DEE14(//#q !" % + + -bC //PQQ3#B 22I  < ;CJ#6 6C '44RC@ @iikq!!+ J3 6 @ =kkm;<< kkm sFD:B(FD=+F2D?3F8EEE*E+E9F=F?FEEF!E$"+F FFFcKtj|||||d{\}}|Dcgc] }t|c}|fS7"cc}ww)z2Return paginated PenyetoranBatch list for an SPBU.)r4N)rget_all_batchesrS)rbr*rrr4rrbs rC list_batchesr|sR.==b'4QV_effKD%.2 3d !! $d 3U ::g 3sA A A AA A c|Ktj|||d{}| tdt|S7w)zIReturn a single PenyetoranBatchResponse, raising ValueError if not found.NBatch tidak ditemukan)rget_batch_by_idrrS)rbr*r5rRs rCget_batch_detailrsA(77HgN NE }011  '' OrcK|js tdg}|jD]|}tj|||d{}|td|d|jt j k7rtd|d|jd|j|~td|D}|j|j||jtj d} tj|||d{} |D]<}tj||| jt j d d{>|j#d{tj$|| j|d{} t'| S7U77W7?7#t($r%|j+d{7td t,$r|j+d{7wxYww) u Create a PenyetoranBatch from a list of DRAFT penyetoran IDs. Validates all penyetoran belong to spbu_id and are DRAFT. Sets their status to SUBMITTED and links them to the new batch. Does NOT set submitted_by_id on the batch — that's set by submit_batch(). zPilih minimal satu penyetoranNzPenyetoran id=z tidak ditemukan di SPBU iniz berstatus z , hanya DRAFT yang bisa di-batchc34K|]}|jywr{)r1r}s rCrzcreate_batch..sB/Qq((/r)rGrHrIr2r4)r5r4z#Constraint error saat membuat batch)penyetoran_idsrrrr4rrappendrgrGrHr2r create_batchrr) SUBMITTEDrrrSr rr) rbr*user_idrpenyetoran_listpidrBrI batch_datarRs rCrrs   899)+O""'11"c7C C 9~cU2NOP P 88'-- - [ :Z[  q!#B/BBL))oo$<<'-- J+88WjQQ!A'..r1!HH*447  ! iik+;;B'RR$U++A D(R  R @kkm>?? kkm sAG8FB'G8.F%F >F%FF%!F!"(F% F# F%G8F%F%!F%#F%%G5G+G5-G0.G55G8c PKtj|||d{}| td|jtj k7r td tj ||tj|tjtjdd{}|jd{t|S77)7#t$r%|jd{7tdt $r|jd{7wxYww)zq Submit a DRAFT batch to Manager for approval. Sets status=SUBMITTED, submitted_by_id, submitted_at. Nrz0Hanya batch berstatus DRAFT yang dapat di-submit)r4submitted_by_idrKz"Constraint error saat submit batch)rrrr4rr update_batchrrnowrutcrrSr rr)rbr*r5rrRs rC submit_batchrs(77HgN NE }011 ||,222KLL +88U+55&$LL6E    iik$U++ O  ?kkm=>> kkm sdD&C 9D&A C%C&C=C>C D&CCD#/C20+D#DD##D&c nKtj|||d{}| td|jtj k7r td|j dk7r td tjtj}tj||tj|||jdd{}|jxsgD]1}tj||dt jid{3|j#d{tj|||d{}t%|S7:77M757#t&$r%|j)d{7tdt*$r|j)d{7wxYww) u Manager approves a SUBMITTED batch. On approve: batch→APPROVED, all linked penyetoran→APPROVED. Only action='approve' is supported (PenyetoranBatch has no REJECTED status). Nrz:Review hanya bisa dilakukan pada batch berstatus SUBMITTEDapprovezAction harus 'approve')r4reviewed_by_idrMrNr4z"Constraint error saat review batch)rrrr4rractionrrrrrAPPROVEDrNrOrrrrSr rr)rbr*r5rrrRrrBs rC review_batchrs(77HgN NE }011 ||,666UVV {{i122ll8<<(+88U+44%"11 E   ""A'..r1*337  # iik+;;B'RR$U++5 O   R ?kkm=>> kkm sF5EAF52AE" E AE"EE"(E)E"E E"F5E"E"E" E""F2>F?+F2*F-+F22F5)rBrreturnr!)rRrrr )rbrr*intr,rrzlist[LaporanShift])rbrr*rr,rrr )rrrr%)rbrr*rr,rrr)r2NNN)rbrr*rrrrrrGOptional[date]rHr r4 Optional[str]rz$tuple[list[PenyetoranResponse], int])rbrr*rrrrr!) rbrr*rrrrr"rr!) rbrr*rrrrbytesrr>rr!)rrN) rbrr*rrrrrr4r rz)tuple[list[PenyetoranBatchResponse], int])rbrr*rr5rrr ) rbrr*rrrrrrr ) rbrr*rr5rrrrr ) rbrr*rr5rrrrrrr )C__doc__ __future__r collectionsrrrrdecimalr typingr sqlalchemyr r sqlalchemy.excr rsqlalchemy.ext.asynciorsqlalchemy.ormrapp.models.expensesrapp.models.operationalrrrapp.models.penyetoranrrrrapp.models.spburrrapp.repositoriesrapp.schemas.penyetoranrrrr r!r"r#r$r%rr&r'rDrSrdrjrrrrrrrrrrrr9rErCrsR"#--#:/''OOff112   =6*11 11 14--"--1- -FZFF"F-1FF`#'!% 55 5 5  5 ! 5  5 5*5&"36     @## ## #  #  #Z ; ;  ;  ;  ;  ; / ;(("(.1((99 99 9  9x    @,, ,, ,  ,  ,rE