From 0b12f52142ed93cd5d81245cc622b4e9c90db986 Mon Sep 17 00:00:00 2001
From: MrWaradana <muhammadridhowaradana@gmail.com>
Date: Mon, 24 Feb 2025 14:26:24 +0700
Subject: [PATCH] feat: generate all transaction equipment for all assetnum
 data

---
 .../__pycache__/router.cpython-311.pyc        | Bin 5455 -> 6113 bytes
 .../__pycache__/service.cpython-311.pyc       | Bin 9258 -> 10198 bytes
 src/equipment/router.py                       |  22 +++++++++++++++++-
 src/equipment/service.py                      |  10 ++++++++
 4 files changed, 31 insertions(+), 1 deletion(-)

diff --git a/src/equipment/__pycache__/router.cpython-311.pyc b/src/equipment/__pycache__/router.cpython-311.pyc
index b34a8c74ae94bc7e29487598622e25f9fcf233a4..6ac8b760363f078b67ee7aa11769db2c0f93be0c 100644
GIT binary patch
delta 1840
zcmcIk&u`mQ9Jig=Ns}gZ)2&V8xOS5+nb)P=#5Nd=ZLqe2QWaI87Ui%gjo(T&r!CJ8
zs1?!*+kpc@tKJ{LkWe`cajAqRZHEbgG!AG*+M&t~q)FUJ#1PUB!1w#oH0jC}C+}mw
z_x*gnzuvPS9{Xi9`c)(n65v`LxVJDF+la=+8yndVX3Oz>Toi1<4mkbgL_Sg0@*1B9
zon%?h>-@RH87Lchqip6)J`XvA<y1Z;3X(wlo8a^|dgfO?P13i9HtIbA!48uYiLfat
z!G^?~rrRn>*xf`TNBWy=!H&T^!yM6&vn}Bv5Jo|$u^+^ke00~)BiOxQ5J{$`2a;~+
zb{{dX`0e<OXOpp7KKpllB0WJeK-Uh?j{$uca+i7TY*I3^x}79lwoVKlBWMpC5FH0m
zu2HZ7F;q;+(ruGuK&tLZL-ybS=?F=)n$#zwt`l{GTnD+O4sb{9=v#u7W|O|VVt^_B
zu|ze#K$ZwCdZbWvoPtM-OK!2`EiNx@P5LK9br8Bt(+EQdDRxVKu}_CbOQzhGY7tmn
zw&mk6A7FXqZg><eIfP+m2I7}bz~gf;+z7yL@LLyZiXeBak8#$TG1^QeN8YO}u9V4=
zmupL?DtpUU$x=xIdGqqa!*v*c%(5;y&MtNiT$4Os(<%rbO1AX1ZxbZ9_hirk|Fk7F
z(mx5@wcL0!p4k@9HJka^rduhMi0fXdIL<1~f(G<`aHG5xzLu}*wdh{*1!vLqT+GHa
zO*#zsYI=cqg*~^07PT!dJq66OFx*LiMx*`=3dvJ<*0yJ6x3#&SwYf*y-1gyT|LfC_
z!&-7DqV1>`YO=3WsS5y45Nd)?R%njB9r#<}+jg406Z}HSKmeL${{*c(7DA%{R<Kdc
zX<T>-;T*!t2<H(lAY24+g8)z(zZ&&Lu)e*j=&L{&XCHTbE9ThQkiiO}n_(XQ5*X-7
z_B3ROS(XUv`;HVhjx`w5;r=A=oLZs;Pif2f>%b_n>*1?nZtM4OT+DFK*faV(!V3VF
zzfsI<xUd^E7cu7f76xeymlcEn!Yc?90M$@s#fE5hVSbfwF+B{cmeO#>L$oD{Dh%MF
zr)D?UH<4a>8cpoS$ahfxr_smi6wIr>vb(UGA^WInuwWtSC;<5XuY`Kh-hR$_d>+sT
zCJ5N*y=oJO?Ca1Bm_K8p`niIyp>=|7s-M8QWy9TxH{$3Ozk$_mmzGAL+TwiCB_pL}
zN@xPtRa`Gtymv=jLf>C35vrjkiM9~h%F7VZr8>LWt<B(jPw^G!$CvMX)xWardKCAm
z>RYLJl(z$uqHW&>m_7}j178(~oTo*YiZI-t*k9dWUJi;<P53|HkRZM(Zas`8#Hk(s
zk?k`R_q_*~zF&QGW~Sy7q|Uk^NzxO9nxcrx9jhk5?ZG&|wV)o@N2|rQe(hNl{n+h)
E0Wq+n;s5{u

delta 1323
zcma)5J8aWX6!mLtCrz5vN!xtg*lFp<ZAkeE%C8_)5aKTwK#>5YeXoT!Zo_i|0tPxT
zFdzhaNQ@K-fdorYC6+F%u)xG%7CIm?!peZS*GW;J3^>WryPtFKdDl0qBkzYI&%@!M
z1ka~0FQ#X-2azPnJ{Y)mnn+Zl{&Lbz6;pP)nD*>IIb-WZ-8;9IyX|Z-Ya2zwvx8;R
z&J}Y+YLS@y3<|!)s@_xVVLgkzVwH6GB^qKm78aT>Ee6TPj7~L{qEXhuHl)_lB^m>}
zPgIDZ^fxg(ff)g2M!Y34WuPe%Z$!EcohDe{luVPi|JE=F`4(zWJPl&0#Td|OinY@;
z%hC)prUF!7#~K3GaD&y&aw6h0hIN`{eZbUyGlSGv$IJsW(ZsCyjGV^=b>_P4jWlvb
zvT|a{w?b4=mdBUh$%lw$!c2G%LN7v2nCh;C4o6GjrsqMZCx|O5RffTi3s+qU6)=)V
z7!r&Aq&@;ij5=X}ukcxrzNwPZx-ic3VygA0YJ#6{5;MUkY9Ai^MKoj;u^Ep5Sb=)S
zP3YK;umfQfVJE^agxvs60KjZKd<YCTJk6>X*_GPmip}P#d@uMmi-)1tBrlG(8Gcu(
z&d;(rG1GQGWI~LOA?z1Q*qG^uqb0lYT*+o`aFVl9mC=h6*Lf%AG|$2#?emxbZtL%U
zjsmu)r>;h;S7{P-5E4#`d*NA<U;YtJl715${1CzxgslLUTpz$VIvN5;+l^bEzyOb-
zTSf3A>_IpH;09|Ix~AEiW*2xZwO-6?@uzT(4IHdgA7Mjty-JhjBam@HlElaMH!#LW
z+86CGcwC?DOgBV}yV2bEAUOE|0JQv<#yG~kG5VS$c^Z5W0u8W0-=lHmI9NACTkNrl
zTV)l*tJobe){!`xzzRtKH|p@o0$jE<QF2&ea-K7e|7ur5f2mfzRB#x-dU=xZG;%T+
z3u4Tkr>yL7T`YEFj^UPaTvu;TT)8suR5`vO*H@`kIo_M27~ZtvVEzc~fikr+8{_A}
lB=B=iiMGzC+az+1e2~um|M#<WVmZ>4Cd)VD6GX=A{sJ;ZAgcfX

diff --git a/src/equipment/__pycache__/service.cpython-311.pyc b/src/equipment/__pycache__/service.cpython-311.pyc
index 4194d208c9bc654f98e0bc5e0f53597e10db0ffe..027b2ada1df7603a4e1052be6d1a9ab1d10a622f 100644
GIT binary patch
delta 1111
zcmZ`%O-vI}5Z<?J3oWIvv_O|qx($Dp0x?{aP)R@t_)j1nFjiQ)ul!hAc)K-9N@xTU
zq8ubI#w!<<pa)D(MlX8vMoAUY#Ken<@r2>#$$48;LUi`c_vV{7Z+3Qewgx_3vp+8>
zv2q}M?c0g>P3v|Sdhn|092$!7s<bTJIHi_ims*X>BZBG%?l*Xi!9Bp64PJ{&)EexF
zm{l+M0*23lWw;{)Z&A@O=l7+z5Ouo3>}5=NP&4Qf=%EwQLCHyH9d4daQg1;O-4=cH
zom5AMgi1PVEo~H%LN6DpTQKRxaN$UjrfHVKkR;OW9R1?1qIU(`BI4HSReqUcx1PcI
zi=!xxgHj6SulM5^CW?+_ohUI)3F}kwm>h`{S&2qvJeQc7oxw3(lc!>`K8a;j(UoyU
z!!iR^hS*~<il$*bmY8X~8b(L2S!8<wr~~w{2H*)d!6mtnWdSA8H1NEv^J~^&jtm0x
zBO<Yl&+%=ii4RPTwMdpp4{SfJ!RVBxhvPG|UGpsyN7au)wWG(rpe-1Uhn1+-wFuVl
z@Hv*s4Upn?iaYabqhs|#)>iw6lU_LY7ZFx6u`%#4sAbT|po#&jk5mHq&BO&;&ZNh0
z;}{uWwrwtf$-Pm6wM106=d6DlM0|9x!nx@BU)AI$+-E(}o&tP>C&hiWl|Syt*gRRA
zC)Kwv)$K`vT`92Hmyz1DQu~hM<Vs!M7d?Ao!>-tn5u37N)1DaE6$2TuH7mBJF78)&
zuN-j5bROk#)$-Y1{-`7CXxK=6Z0pY0d$RVPouYrQeWPpJR_IoyxHAh(=uDrj%ppq%
z>Lnup)Z;p18V5s9kGOsy6rz`^8_UPoG4uKbqhBOUm#XVcli>NDep&72gP27af8R_Z
zVCM>9loVYjWQ;N4jzTn2#)6DAmV6pE9FVKPbIU})JWNMC6@1w!^Y$|^{@oaT=xsLZ
zz%7Wr@vflObhq4%f~?s_Hp1#4ECFFrMj6H&<Oi-OI1^VBQQSpV;FJxvww!+L`+(eq
RD7fuE;9xrmPI|v?^B4IEAZ`Ev

delta 364
zcmccSzsiGeIWI340}!laTc7?(bt0bxW8Fq|TSm7O$yA{<mK3QLmMD!B{#1z+X)s>~
z$kzn(Wm9>9V!~-`DRMwDEwGqyssd1tJdm%Q!Whh;sjzt)<7AP|rzNj4a)$yfxy4$N
zpPiaFd8M>DYc!CbwfU*^M@Gib$=7Aogd%_fMIcd4mLdrdJ7zM!oC<3qkojP<g`6~#
zO&mxx0HlJgC>}`NVlPfDNh~QTDgx=f#Zs17R9qwgQUo@J6Jm@aNFZi%zd{^qHjw#p
z^CtySCV_B}s5^*|1rZUG#g(<Va)HeMKwMlg`GAnv<V59cMxD)Pl^q$)K?W9qoKgfb
sqX?uB?2;lE5X%Wj{Nk|5%}*)KNwq7g19BOGxHxmOm+DEz$$IK50EkCfCIA2c

diff --git a/src/equipment/router.py b/src/equipment/router.py
index 83100ba..e559ccb 100644
--- a/src/equipment/router.py
+++ b/src/equipment/router.py
@@ -9,7 +9,15 @@ from .schema import (
     EquipmentCreate,
     EquipmentUpdate,
 )
-from .service import get_master_by_assetnum, get_by_id, get_all, create, update, delete
+from .service import (
+    get_master_by_assetnum,
+    get_by_id,
+    get_all,
+    create,
+    update,
+    delete,
+    generate_all_transaction,
+)
 
 from src.database.service import CommonParameters, search_filter_sort_paginate
 from src.database.core import DbSession
@@ -46,6 +54,18 @@ async def get_equipment_tree():
     pass
 
 
+@router.get(
+    "/generate-equipment-transaction", response_model=StandardResponse[List[str]]
+)
+async def get_generated_equipment_transaction(db_session: DbSession, token: Token):
+    equipment_list = await generate_all_transaction(db_session=db_session, token=token)
+
+    return StandardResponse(
+        data=equipment_list,
+        message="Equipment transactions generated successfully",
+    )
+
+
 @router.get("/{assetnum}", response_model=StandardResponse[EquipmentRead])
 async def get_equipment(db_session: DbSession, assetnum: str):
     (
diff --git a/src/equipment/service.py b/src/equipment/service.py
index 0cf29bf..9961631 100644
--- a/src/equipment/service.py
+++ b/src/equipment/service.py
@@ -103,6 +103,16 @@ async def get_all(
     return result
 
 
+async def generate_all_transaction(*, db_session: DbSession, token):
+    """Generate transaction for all equipments in the database based on equipments assetnum."""
+    query = Select(Equipment)
+    query_result = await db_session.execute(query)
+    equipments = query_result.scalars().all()
+    for equipment in equipments:
+        await main(equipment.assetnum, token, RELIABILITY_APP_URL)
+    return [equipment.assetnum for equipment in equipments]
+
+
 async def generate_transaction(
     *, db_session: DbSession, data_in: EquipmentCreate, token
 ):