import requests import streamlit as st import joblib import pandas as pd import numpy as np import os # Tambahan untuk manajemen file from sklearn.preprocessing import MinMaxScaler from tensorflow.keras.models import load_model from datetime import date, timedelta from pathlib import Path import matplotlib.pyplot as plt import matplotlib.dates as mdates from matplotlib import rcParams # Set font untuk mendukung karakter Indonesia rcParams['font.family'] = 'DejaVu Sans' # --- Konfigurasi Halaman --- st.set_page_config( page_title="Prediksi Harga Ethereum (GRU)", page_icon="๐ช", layout="wide" # Opsional: agar tampilan lebih luas ) # --- KONFIGURASI FILE ADMIN --- DATA_FOLDER = 'dataset' DATA_FILE = 'databackup_eth.csv' DATA_PATH = os.path.join(DATA_FOLDER, DATA_FILE) # Pastikan folder dataset ada if not os.path.exists(DATA_FOLDER): os.makedirs(DATA_FOLDER) # --- GLOBAL STYLES (UI only) --- st.markdown(""" """, unsafe_allow_html=True) # --- Fungsi-fungsi Bantuan (JANGAN UBAH LOGIKA UTAMA) --- @st.cache_data(ttl="1h") def load_eth_data(): """ """ # Cek apakah file admin ada if os.path.exists(DATA_PATH): try: df = pd.read_csv(DATA_PATH) # --- PEMBERSIHAN DATA AGAR SESUAI FORMAT MODEL --- # 1. Hapus kolom index lama jika ada if "Unnamed: 0" in df.columns: df = df.drop(columns=["Unnamed: 0"]) # 2. Standarisasi nama kolom Date if "Date" not in df.columns: # Coba cari kolom yang mirip 'date' found = False for col in df.columns: if col.lower() == "date": df = df.rename(columns={col: "Date"}) found = True break if not found: # Jika tidak ada header Date, asumsikan kolom pertama adalah Date df = df.rename(columns={df.columns[0]: 'Date'}) # 3. Konversi ke datetime df["Date"] = pd.to_datetime(df["Date"]) # Hapus timezone jika ada agar kompatibel dengan matplotlib/numpy if df["Date"].dt.tz is not None: df["Date"] = df["Date"].dt.tz_localize(None) return df, "admin_file" except Exception as e: return None, f"error_read: {str(e)}" else: return None, "no_file" def validate_scaler(scaler): """Validasi scaler agar konsisten dengan training.""" issues = [] warnings = [] if not isinstance(scaler, MinMaxScaler): warnings.append(f"Scaler bukan MinMaxScaler (terdeteksi: {type(scaler).__name__}). Pastikan ini scaler training.") required_attrs = ["n_features_in_", "data_min_", "data_max_", "scale_", "min_"] for a in required_attrs: if not hasattr(scaler, a): issues.append(f"Scaler belum ter-fit atau tidak valid (atribut '{a}' tidak ada).") if hasattr(scaler, "n_features_in_"): if int(scaler.n_features_in_) != 1: issues.append(f"Scaler mengharapkan {scaler.n_features_in_} fitur, tapi aplikasi hanya pakai 1 fitur ('Close').") ok = (len(issues) == 0) return ok, issues, warnings def validate_model_input(model): """Pastikan input model bentuknya (None, time_step, 1).""" issues = [] try: shape = model.input_shape # biasanya (None, time_step, 1) if not (isinstance(shape, (list, tuple)) and len(shape) == 3): issues.append(f"input_shape tidak sesuai harapan: {shape} (harus 3 dimensi).") else: if shape[2] != 1: issues.append(f"Jumlah fitur input model = {shape[2]}, tapi aplikasi membentuk fitur=1.") if shape[1] is None or int(shape[1]) <= 1: issues.append(f"time_step tidak valid: {shape[1]}.") except Exception as e: issues.append(f"Gagal membaca input_shape model: {e}") ok = (len(issues) == 0) return ok, issues @st.cache_resource def load_gru_assets(): """Load model & scaler hasil training.""" model_path = Path("gru_model.h5") scaler_path = Path("scaler_gru.pkl") if not model_path.exists() or not scaler_path.exists(): return None, None try: model = load_model(model_path, compile=False) scaler = joblib.load(scaler_path) return model, scaler except Exception as e: st.error(f"Gagal load aset: {e}") return None, None def predict_from_sequence_pure(model, initial_sequence_scaled, n_days): seq = np.array(initial_sequence_scaled, dtype="float32").reshape(-1) # (time_step,) preds = [] for _ in range(n_days): x = seq.reshape(1, -1, 1) # (1, time_step, 1) y = float(model.predict(x, verbose=0)[0, 0]) # output model (scaled) preds.append(y) seq = np.append(seq[1:], y) # autoregressive (murni) return np.array(preds, dtype="float32").reshape(-1, 1) def create_combined_chart(df, start_date, future_dates, future_predictions): """Membuat grafik gabungan.""" context_start_date = start_date - timedelta(days=60) recent_df = df[(df["Date"] >= context_start_date) & (df["Date"] <= start_date)].copy() window_size = 7 recent_df["Trend_Aktual"] = recent_df["Close"].rolling(window=window_size).mean() predictions_flat = future_predictions.flatten() fig, ax = plt.subplots(figsize=(14, 8)) ax.plot( recent_df["Date"], recent_df["Close"], color="gray", linewidth=1.0, label="Harga Aktual (Harian)", alpha=0.5 ) ax.plot( recent_df["Date"], recent_df["Trend_Aktual"], color="#1f77b4", linewidth=2.5, label="Tren Harga Aktual", alpha=0.9 ) ax.plot( future_dates, predictions_flat, color="#d62728", linewidth=2.5, label="Harga Prediksi (GRU)", alpha=0.9, marker="o", markersize=4 ) ax.scatter( recent_df["Date"], recent_df["Close"], color="black", s=15, alpha=0.6, zorder=5, label="Data Harian Aktual" ) try: last_trend_date = recent_df["Date"].iloc[-1] last_trend_price = recent_df["Trend_Aktual"].dropna().iloc[-1] first_prediction_date = future_dates[0] first_prediction_price = predictions_flat[0] ax.plot( [last_trend_date, first_prediction_date], [last_trend_price, first_prediction_price], color="#d62728", linestyle="--", linewidth=2.0, alpha=0.7 ) except Exception: pass ax.set_xlabel("Waktu", fontsize=12, fontweight="bold") ax.set_ylabel("Harga (USD)", fontsize=12, fontweight="bold") ax.set_title("Analisis Tren Historis dan Prediksi Harga Ethereum", fontsize=16, fontweight="bold", pad=20) ax.xaxis.set_major_formatter(mdates.DateFormatter("%b %d, %Y")) plt.xticks(rotation=45) ax.grid(True, alpha=0.3, linestyle="--") handles, labels = ax.get_legend_handles_labels() order = [2, 0, 1, 3] if len(handles) == 4: ax.legend([handles[idx] for idx in order], [labels[idx] for idx in order], loc="upper left", fontsize=11) else: ax.legend(loc="upper left", fontsize=11) plt.tight_layout() ax.set_facecolor("#f8f9fa") fig.patch.set_facecolor("white") return fig # --- HALAMAN: DASHBOARD PUBLIK (Landing Page) --- def show_dashboard(): st.markdown("