from collections import deque from datetime import datetime from threading import Lock import requests from flask import Flask, jsonify, render_template_string, request app = Flask(__name__) # ========================================================= # KONFIGURASI # ========================================================= ESP32_IP = "192.168.1.15" # Ganti sesuai IP ESP32 ESP32_URL = f"http://{ESP32_IP}" REQUEST_TIMEOUT = 2 HISTORY_LIMIT = 300 # Menyimpan 300 titik data terakhir DEFAULT_MIN_LEVEL = 20 # Pompa ON saat level <= batas minimum (mode AUTO) DEFAULT_MAX_LEVEL = 90 # Pompa OFF saat level >= batas maksimum (mode AUTO) history = deque(maxlen=HISTORY_LIMIT) history_lock = Lock() last_device_data = { "level": 0, "distance": 0, "pump": False, "auto": False, "connected": False, "error": "Belum ada komunikasi dengan ESP32", } thresholds = { "min": DEFAULT_MIN_LEVEL, "max": DEFAULT_MAX_LEVEL, } def esp32_get(endpoint, params=None): """Mengirim request ke ESP32 dan mengembalikan response JSON/text.""" response = requests.get( f"{ESP32_URL}{endpoint}", params=params, timeout=REQUEST_TIMEOUT, ) response.raise_for_status() return response def normalize_data(raw): """Memastikan format dan tipe data dari ESP32 sesuai kebutuhan dashboard.""" level = max(0, min(100, float(raw.get("level", 0)))) distance = float(raw.get("distance", 0)) pump_state = raw.get("pump", False) auto_state = raw.get("auto", False) if isinstance(pump_state, str): pump_state = pump_state.lower() in ("1", "true", "on", "yes") if isinstance(auto_state, str): auto_state = auto_state.lower() in ("1", "true", "auto", "yes") return { "level": round(level, 1), "distance": round(distance, 1), "pump": bool(pump_state), "auto": bool(auto_state), "connected": True, "error": None, } # ========================================================= # HALAMAN DASHBOARD # ========================================================= HTML = r""" Water Tank HMI

WATER TANK CONTROL HMI

Monitoring level air dan kendali pompa berbasis ESP32

MENGHUBUNGKAN...

Monitoring Tangki

--%

Level air--%

Jarak sensor-- cm

Mode operasi--

Koneksi--

Menunggu data sensor...

Kontrol Sistem

POMPA --

Mode Operasi

Kontrol Pompa Manual

Kontrol START/STOP hanya aktif saat mode MANUAL. Pada mode AUTO, keputusan pompa harus dijalankan oleh program ESP32 berdasarkan batas level.

Pengaturan Batas Level Otomatis

Level minimum (%) Level maksimum (%)

Logika yang disarankan: pompa ON ketika level mencapai atau di bawah batas minimum, lalu OFF ketika level mencapai atau di atas batas maksimum. ESP32 perlu mendukung endpoint /thresholds?min=20&max=90.

Status Sistem

Status tangki--

Status pompa--

IP ESP32{{ esp32_ip }}

Pembaruan terakhir--

Jika koneksi terputus, periksa Wi-Fi, alamat IP ESP32, dan endpoint HTTP pada program ESP32.

Grafik Riwayat Level Air

Grafik menampilkan maksimal 300 sampel terakhir selama server Flask berjalan. Data riwayat ini disimpan sementara di memori komputer.

""" # ========================================================= # ROUTE FLASK # ========================================================= @app.route("/") def index(): return render_template_string(HTML, esp32_ip=ESP32_IP) @app.route("/data") def data(): global last_device_data try: response = esp32_get("/data") raw = response.json() normalized = normalize_data(raw) last_device_data = normalized with history_lock: history.append({ "time": datetime.now().strftime("%H:%M:%S"), "level": normalized["level"], }) return jsonify(normalized) except (requests.RequestException, ValueError, TypeError) as exc: last_device_data = { **last_device_data, "connected": False, "error": f"Tidak dapat membaca ESP32: {exc}", } return jsonify(last_device_data), 503 @app.route("/history") def get_history(): with history_lock: samples = list(history) return jsonify({ "labels": [item["time"] for item in samples], "levels": [item["level"] for item in samples], }) @app.route("/pump") def pump(): state = request.args.get("state", "").lower() if state not in ("on", "off"): return jsonify({"ok": False, "error": "state harus on atau off"}), 400 # Pengaman: pompa manual hanya boleh dikendalikan pada mode MANUAL. if last_device_data.get("auto"): return jsonify({"ok": False, "error": "Ubah ESP32 ke mode MANUAL terlebih dahulu."}), 409 try: response = esp32_get("/pump", {"state": state}) return jsonify({"ok": True, "esp32_response": response.text}) except requests.RequestException as exc: return jsonify({"ok": False, "error": str(exc)}), 502 @app.route("/mode") def mode(): value = request.args.get("value", "").lower() if value not in ("auto", "manual"): return jsonify({"ok": False, "error": "value harus auto atau manual"}), 400 try: response = esp32_get("/mode", {"value": value}) return jsonify({"ok": True, "esp32_response": response.text}) except requests.RequestException as exc: return jsonify({"ok": False, "error": str(exc)}), 502 @app.route("/thresholds") def set_thresholds(): try: minimum = int(request.args.get("min", "")) maximum = int(request.args.get("max", "")) except ValueError: return jsonify({"ok": False, "error": "min dan max harus berupa bilangan bulat."}), 400 if not (0 <= minimum < maximum <= 100): return jsonify({"ok": False, "error": "Gunakan 0 <= min < max <= 100."}), 400 try: # Firmware ESP32 harus menyediakan endpoint ini dan menjalankan # logika AUTO secara lokal pada ESP32. response = esp32_get("/thresholds", {"min": minimum, "max": maximum}) thresholds["min"] = minimum thresholds["max"] = maximum return jsonify({ "ok": True, "min": minimum, "max": maximum, "esp32_response": response.text, }) except requests.RequestException as exc: return jsonify({ "ok": False, "error": ( "ESP32 belum menerima pengaturan batas level. " "Tambahkan endpoint /thresholds pada firmware ESP32. " f"Detail: {exc}" ), }), 502 @app.route("/health") def health(): return jsonify({ "flask": "online", "esp32_connected": bool(last_device_data.get("connected")), "esp32_ip": ESP32_IP, }) if __name__ == "__main__": print("=" * 55) print(" WATER TANK CONTROL HMI") print("=" * 55) print("Dashboard: http://127.0.0.1:5000") print("Akses LAN: http://IP-KOMPUTER:5000") print(f"ESP32: {ESP32_URL}") print("Tekan CTRL+C untuk menghentikan server.") app.run(host="0.0.0.0", port=5000, debug=False)