From 6bd918f5a26e6023d08095356cef9f85b15422da Mon Sep 17 00:00:00 2001
From: MrWaradana <muhammadridhowaradana@gmail.com>
Date: Tue, 11 Feb 2025 13:35:41 +0700
Subject: [PATCH] fix: raw_cm_interval calculation

---
 .../__pycache__/service.cpython-311.pyc       | Bin 14243 -> 13664 bytes
 src/equipment/service.py                      |  27 +++++++++---------
 2 files changed, 14 insertions(+), 13 deletions(-)

diff --git a/src/equipment/__pycache__/service.cpython-311.pyc b/src/equipment/__pycache__/service.cpython-311.pyc
index eb27d58228839c464f5760b590f89356f2b9874e..ce5c2f7bbf9074b62527c9b09da52cd7bdbf6a8a 100644
GIT binary patch
delta 455
zcmZ3S{~(KZIWI340}w2Gzbd_GBd>rM(>~VC@?v+GMPfI{FflOHa@BIzaMy5_F%&WO
za7`AJie%KDoGqonQp2-Ac(R~~s3dz0Unb)+Mh1q}Knwwl3=mnFWJZz62iZg?cgd)-
z^=zqOSRgvtP*QaA85uW5-N^@Kq&Dly{^np5pRB3YG<m<8JR|?)`)V^diur-YC@3UM
zKBKO|y%@+&1LERhmd*dw{g~NgSgk%V$V?8_4m0EDbYpxVufBrqioE^?#w+qh8?3I#
z+g;$1`5?u>D{-Ai?h=pO1qH(k#?BYyT`uytUg2@Qz~ef(P{)h$!sb0Xvl)3orfaek
zi2<piC6iP1R9II6nYT9g>Pa)%ECY%9fmE;+Ee8p+7pImamXs6~^@DgUWr;<_MFJp2
zU}HET#>j&NmP~$P5Xv<j!~_wKH#-~pGqG+4GJkHKZak4u0HmV`WEWVzX!B$XQ(4A+
ko5M_(GHMkvGRoc%mifR8W~iG%7#|owTof{6vZ{F<0AcKYHvj+t

delta 834
zcmZXPPfQa*6vk&L{l81Qz;2f=y2UIMkd~CHF{HMH1`;{cizo^eNhqWU0@Id=E}D2I
z5gbiOj0QDG10g|s@T>>paktq7XfzNK@AY6}^x{q{CWguEd%yR-H{a|WOuU|^*J;`Y
z^!4f6#<=e-?c^$|%sG+!V&Ilw{Q6J@01LJSyKI-Oa{$3bJ9fCQK@}(6&F(Zy4whHi
zdqe<C)Z$s5g)9yjIlN_c;1~RD+J2<V_FDimh8pO=`&^yb@dg603Gs40Yjn!aRSqu;
zr))ED6fQ6_wd%r5Ei0PkDw(;f|7Q}G$B)b)D9wB@v3S=VgFGe_5*jT_aB)Zmt93X~
z$6{INg=g`s;Ld#&ep{e`_oRol$fTPT45`c%8rKPt2jIa*5mw`SjVt{H*9=O`C8sl~
z;jxkAWCkTt!?T$LnlJFj1zpTcrVH$GMYm5?>&_m}O^?Teg{Efvx?YayU&?6A#hPLU
zlVI%p4g~zF<;sI9>kW7ydb1`?Y~O~O*s<NIiD8AR|6u`)>uLJQoi$qXTu@zM%@tOi
z5zQIdXIziD=d{NAx4l|Ncb@N7nW)A@|MgF2NArA#$^<ngSTqA#D%ybm{Ejb@_eGSh
ztEz86^9?9ovM-j?-$+TjQfNnt=B21A^=ML$BK3V{6sn<U0yMuvoy=1w6;D73MwQ+{
zH8`k<Ln;;5sJKGKvA?wss=4{rXOJcjZmC3^o=_Gyv`NM-9rtp5Z9+w8gLGqL!h|;U
zR4}I!>5+6Ap+}^uoEt$Y<Rn8S8*AA{B#kV7>F>9#5G3L7UHhd9<9nTc<}L@8p`RQ;
z<f@X4h*G)<brb5+!!Ju{YI-y?nFyngxtib_Y@LDd#BNP}(NF^KxiS<1DgTRO`0&jA
EKln`ZmH+?%

diff --git a/src/equipment/service.py b/src/equipment/service.py
index 8b07e35..ede3002 100644
--- a/src/equipment/service.py
+++ b/src/equipment/service.py
@@ -190,20 +190,21 @@ async def generate_transaction(
         api_data = await fetch_api_data(data_in.assetnum, year)
 
         if api_data:
-            # Get current num_fail
+            # # Get current num_fail
             current_num_fail = api_data["data"][0]["num_fail"]
-            
-            # Calculate sum of previous failures for this asset
-            previous_failures_query = (
-                Select(func.sum(MasterRecords.raw_cm_interval))
-                .filter(MasterRecords.assetnum == data_in.assetnum)
-                .filter(MasterRecords.tahun < year)
-            )
-            previous_failures_result = await db_session.execute(previous_failures_query)
-            previous_failures_sum = previous_failures_result.scalar() or 0
-            
-            # Update with current minus sum of previous
-            transaction.update({"raw_cm_interval": current_num_fail - previous_failures_sum})
+
+            # # Calculate sum of previous failures for this asset
+            # previous_failures_query = (
+            #     Select(func.sum(MasterRecords.raw_cm_interval))
+            #     .filter(MasterRecords.assetnum == data_in.assetnum)
+            #     .filter(MasterRecords.tahun < year)
+            # )
+            # previous_failures_result = await db_session.execute(previous_failures_query)
+            # previous_failures_sum = previous_failures_result.scalar() or 0
+
+            # # Update with current minus sum of previous
+            # transaction.update({"raw_cm_interval": current_num_fail - previous_failures_sum})
+            transaction.update({"raw_cm_interval": current_num_fail})
         transaction.update({"tahun": int(year), "seq": int(sequence)})
         transactions.append(MasterRecords(**transaction))