CIzz22
/
be-lcca
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: prediction script

Browse Source
main
MrWaradana 11 months ago
parent b710c5e8da
commit 56abf5bfae
6 changed files with 55 additions and 34 deletions
Show Stats Download Patch File Download Diff File

9
src/modules/equipment/Prediksi.py
Unescape Escape View File

@ -372,7 +372,6 @@ class Prediksi:
try: try:
# Mengambil data dari database # Mengambil data dari database
df = self.__fetch_data_from_db(p_equipment_id) df = self.__fetch_data_from_db(p_equipment_id)
if df is None: if df is None:
print("Data tidak tersedia untuk prediksi.") print("Data tidak tersedia untuk prediksi.")
return return
@ -382,7 +381,6 @@ class Prediksi:
# Tahun proyeksi # Tahun proyeksi
future_years = list(range(df["year"].max() + 1, par_tahun_target + 1)) future_years = list(range(df["year"].max() + 1, par_tahun_target + 1))
# Hasil prediksi # Hasil prediksi
predictions = {"year": future_years} predictions = {"year": future_years}
@ -399,10 +397,15 @@ class Prediksi:
# Fungsi untuk prediksi menggunakan Exponential Smoothing # Fungsi untuk prediksi menggunakan Exponential Smoothing
def exponential_smoothing_predict(column, years): def exponential_smoothing_predict(column, years):
data_series = df[column].fillna(0).values data_series = df[column].fillna(0).values
# Add a small epsilon to avoid zeros in the data if needed
if np.any(data_series == 0):
data_series = data_series + 1e-10
model = ExponentialSmoothing( model = ExponentialSmoothing(
data_series, trend="add", seasonal=None, seasonal_periods=None data_series, trend="add", seasonal=None, seasonal_periods=None
) )
model_fit = model.fit() model_fit = model.fit(optimized=True, use_brute=False)
preds = model_fit.forecast(len(years)) preds = model_fit.forecast(len(years))
return np.abs(preds) return np.abs(preds)

BIN
src/modules/equipment/__pycache__/Prediksi.cpython-311.pyc
View File

Binary file not shown.

BIN
src/modules/equipment/__pycache__/insert_actual_data.cpython-311.pyc
View File

Binary file not shown.

BIN
src/modules/equipment/__pycache__/run.cpython-311.pyc
View File

Binary file not shown.

50
src/modules/equipment/insert_actual_data.py
Unescape Escape View File

@ -21,7 +21,7 @@ async def fetch_api_data(
# ) # )
try: try:
response = await client.get( response = await client.get(
f"{url}/main/number-of-failures/{assetnum}/{int(year)}/{int(year)}", f"{url}/main/failures/{assetnum}/{int(year)}/{int(year)}",
timeout=30.0, timeout=30.0,
headers={"Authorization": f"Bearer {token}"}, headers={"Authorization": f"Bearer {token}"},
) )
@ -32,9 +32,9 @@ async def fetch_api_data(
return {} return {}
def get_recursive_query(cursor, equipment_id, worktype="CM"): def get_recursive_query(cursor, assetnum, worktype="CM"):
""" """
Fungsi untuk menjalankan query rekursif berdasarkan equipment_id dan worktype. Fungsi untuk menjalankan query rekursif berdasarkan assetnum dan worktype.
worktype memiliki nilai default 'CM'. worktype memiliki nilai default 'CM'.
""" """
query = f""" query = f"""
@ -68,7 +68,7 @@ def get_recursive_query(cursor, equipment_id, worktype="CM"):
) AS tbl ) AS tbl
WHERE WHERE
tbl.worktype = '{worktype}' tbl.worktype = '{worktype}'
AND tbl.assetnum = '{equipment_id}' AND tbl.assetnum = '{assetnum}'
ORDER BY ORDER BY
tbl.assetnum, tbl.assetnum,
tbl.year, tbl.year,
@ -114,26 +114,26 @@ async def query_data(RELIABILITY_APP_URL: str, token: str):
# Tahun sekarang # Tahun sekarang
current_year = datetime.now().year current_year = datetime.now().year
# Looping untuk setiap equipment_id # Looping untuk setiap assetnum
for row in results: for row in results:
equipment_id = row["assetnum"] # Mengambil equipment_id dari hasil query assetnum = row["assetnum"] # Mengambil assetnum dari hasil query
forecasting_start_year = row["forecasting_start_year"] - 1 forecasting_start_year = row["forecasting_start_year"] - 1
# CM # CM
recursive_results = get_recursive_query( recursive_results = get_recursive_query(
cursor_wo, equipment_id, worktype="CM" cursor_wo, assetnum, worktype="CM"
) )
# PM # PM
data_pm = get_recursive_query(cursor_wo, equipment_id, worktype="PM") data_pm = get_recursive_query(cursor_wo, assetnum, worktype="PM")
# OH # OH
data_oh = get_recursive_query(cursor_wo, equipment_id, worktype="OH") data_oh = get_recursive_query(cursor_wo, assetnum, worktype="OH")
# Data Tahun # Data Tahun
data_tahunan = get_data_tahun(cursor) data_tahunan = get_data_tahun(cursor)
seq = 0 seq = 0
# Looping untuk setiap tahun # Looping untuk setiap tahun
for year in range(forecasting_start_year, current_year + 1): for year in range(forecasting_start_year, current_year + 1):
# print(f"Processing equipment_id {equipment_id} in year {year}") # print(f"Processing assetnum {assetnum} in year {year}")
# Filter data berdasarkan tahun # Filter data berdasarkan tahun
recursive_row = next( recursive_row = next(
(r for r in recursive_results if r["year"] == year), None (r for r in recursive_results if r["year"] == year), None
@ -151,15 +151,15 @@ async def query_data(RELIABILITY_APP_URL: str, token: str):
""" """
try: try:
cursor.execute(check_query, (equipment_id, year)) cursor.execute(check_query, (assetnum, year))
data_exists = cursor.fetchone()[0] data_exists = cursor.fetchone()[0]
# print("Data exists for equipment_id", equipment_id) # print("Data exists for assetnum", assetnum)
except Exception as e: except Exception as e:
print(f"Error checking data for equipment_id {equipment_id}: {e}") print(f"Error checking data for assetnum {assetnum}: {e}")
continue continue
if not data_exists: if not data_exists:
print("Data not exists for equipment_id", equipment_id) print("Data not exists for assetnum", assetnum)
# Insert data jika belum ada # Insert data jika belum ada
if not recursive_row and not data_pm_row and not data_oh_row: if not recursive_row and not data_pm_row and not data_oh_row:
# Jika data recursive_row tidak ada # Jika data recursive_row tidak ada
@ -178,13 +178,14 @@ async def query_data(RELIABILITY_APP_URL: str, token: str):
) )
""" """
api_data = await fetch_api_data( api_data = await fetch_api_data(
equipment_id, year, RELIABILITY_APP_URL, token assetnum, year, RELIABILITY_APP_URL, token
) )
print(api_data)
cursor.execute( cursor.execute(
insert_query, insert_query,
( (
str(uuid4()), # id str(uuid4()), # id
equipment_id, # equipment_id assetnum, # assetnum
year, # tahun year, # tahun
seq, # seq seq, # seq
1, # is_actual 1, # is_actual
@ -215,14 +216,14 @@ async def query_data(RELIABILITY_APP_URL: str, token: str):
), ),
), ),
) )
print(f"Data inserted for {equipment_id} in year {year}") print(f"Data inserted for {assetnum} in year {year}")
else: else:
print("Data exists for equipment_id", equipment_id) print("Data exists for assetnum", assetnum)
# Jika data recursive_row ada # Jika data recursive_row ada
# raw_cm_interval ambil dari reliability predict # raw_cm_interval ambil dari reliability predict
insert_query = """ insert_query = """
INSERT INTO lcc_equipment_tr_data ( INSERT INTO lcc_equipment_tr_data (
id, equipment_id, tahun, seq, is_actual, id, assetnum, tahun, seq, is_actual,
raw_cm_interval, raw_cm_material_cost, raw_cm_interval, raw_cm_material_cost,
raw_cm_labor_time, raw_cm_labor_human raw_cm_labor_time, raw_cm_labor_human
, raw_pm_interval, raw_pm_material_cost, raw_pm_labor_time, raw_pm_labor_human , raw_pm_interval, raw_pm_material_cost, raw_pm_labor_time, raw_pm_labor_human
@ -235,17 +236,20 @@ async def query_data(RELIABILITY_APP_URL: str, token: str):
) )
""" """
api_data = await fetch_api_data( api_data = await fetch_api_data(
equipment_id, year, RELIABILITY_APP_URL, token assetnum, year, RELIABILITY_APP_URL, token
) )
print(api_data)
if api_data and "data" in api_data and api_data["data"]: if api_data and "data" in api_data and api_data["data"]:
print("API data:", api_data["data"][0]["actual_fail"]) print("API data:", api_data["data"][0]["actual_fail"])
else: else:
print(f"No API data available for {equipment_id} in year {year}") print(
f"No API data available for {assetnum} in year {year}"
)
cursor.execute( cursor.execute(
insert_query, insert_query,
( (
str(uuid4()), # id str(uuid4()), # id
equipment_id, # equipment_id assetnum, # assetnum
year, # tahun year, # tahun
seq, # seq seq, # seq
1, # is_actual 1, # is_actual
@ -354,7 +358,7 @@ async def query_data(RELIABILITY_APP_URL: str, token: str):
), ),
), ),
) )
print(f"Data inserted for {equipment_id} in year {year}") print(f"Data inserted for {assetnum} in year {year}")
seq = seq + 1 seq = seq + 1

30
src/modules/equipment/run.py
Unescape Escape View File

@ -9,14 +9,28 @@ import time
async def main(assetnum, token, RELIABILITY_APP_URL): async def main(assetnum, token, RELIABILITY_APP_URL):
start_time = time.time() start_time = time.time()
await query_data(RELIABILITY_APP_URL, token) try:
prediksi = Prediksi(RELIABILITY_APP_URL) await query_data(RELIABILITY_APP_URL, token)
await prediksi.predict_equipment_data( except Exception as e:
assetnum, print(f"Error in query_data: {str(e)}")
token=token, return
)
eac = Eac() try:
eac.hitung_eac_equipment(assetnum) prediksi = Prediksi(RELIABILITY_APP_URL)
await prediksi.predict_equipment_data(
assetnum,
token=token,
)
except Exception as e:
print(f"Error in predict_equipment_data: {str(e)}")
return
try:
eac = Eac()
eac.hitung_eac_equipment(assetnum)
except Exception as e:
print(f"Error in hitung_eac_equipment: {str(e)}")
return
end_time = time.time() end_time = time.time()
execution_time = end_time - start_time execution_time = end_time - start_time

Write Preview
Loading…
Cancel
Save