Predictive Analytics
Kualitas Udara Berbasis IoT

// ── Ganti dengan data WiFi dan IP server kalian ──
const char* WIFI_SSID     = "NAMA_WIFI_ANDA";
const char* WIFI_PASSWORD = "PASSWORD_WIFI_ANDA";
const char* SERVER_URL    = "http://192.168.1.100/goiot/api/sensor.php";
//                                  ^^^^^^^^^^^
//                      Ganti dengan IP komputer kalian
//                      Cek dengan: ipconfig (Windows)

// ── Pin & Interval ──
#define MQ135_PIN   34    // ADC Pin
#define DHT_PIN     4     // Data Pin DHT11
const unsigned long SEND_INTERVAL = 10000; // 10 detik

void readAndSendData() {
  // Baca MQ135 — ADC 12-bit: nilai 0 sampai 4095
  int rawMQ135 = analogRead(MQ135_PIN);
  
  // Konversi ke ppm (kalibrasi linear sederhana)
  float mq135 = map(rawMQ135, 0, 4095, 0, 500);

  // Baca suhu dan kelembaban dari DHT11
  float suhu       = dht.readTemperature();
  float kelembaban = dht.readHumidity();

  // Validasi — DHT11 kadang gagal baca
  if (isnan(suhu) || isnan(kelembaban)) {
    Serial.println("[ERROR] Gagal baca DHT11!");
    return;
  }

  // Kirim ke server PHP
  sendToServer(mq135, suhu, kelembaban);
}

void sendToServer(float mq135, float suhu, float kelembaban) {
  // Buat JSON payload
  StaticJsonDocument<200> doc;
  doc["mq135"]      = mq135;
  doc["suhu"]       = suhu;
  doc["kelembaban"] = kelembaban;

  String payload;
  serializeJson(doc, payload); // → {"mq135":85.2,"suhu":28.0,"kelembaban":65.0}

  // HTTP POST
  HTTPClient http;
  http.begin(SERVER_URL);
  http.addHeader("Content-Type", "application/json");
  int httpCode = http.POST(payload);
}

CREATE TABLE sensor_data (
  id          INT AUTO_INCREMENT PRIMARY KEY,
  mq135       FLOAT NOT NULL,    -- Nilai polutan (ppm)
  suhu        FLOAT NOT NULL,    -- Suhu Celsius
  kelembaban  FLOAT NOT NULL,    -- Kelembaban %
  prediksi    VARCHAR(20),       -- Baik / Sedang / Buruk
  timestamp   DATETIME DEFAULT CURRENT_TIMESTAMP
);

define('DB_HOST', 'localhost');
define('DB_USER', 'root');   // default XAMPP
define('DB_PASS', '');       // default XAMPP (kosong)
define('DB_NAME', 'goiot');

// 1. Terima JSON dari ESP32
$body       = json_decode(file_get_contents('php://input'), true);
$mq135      = (float) $body['mq135'];
$suhu       = (float) $body['suhu'];
$kelembaban = (float) $body['kelembaban'];

// 2. Jalankan Decision Tree → dapat label prediksi
$prediksi = DecisionTree::predict($mq135, $suhu, $kelembaban);

// 3. Simpan ke database
$model->insert($mq135, $suhu, $kelembaban, $prediksi['label']);

// 4. Kirim response JSON ke ESP32
echo json_encode(['status' => 'success', 'prediksi' => $prediksi]);

public static function predict(float $mq135, float $suhu, float $kelembaban): array {

  if ($mq135 < 100) {
    // Polutan rendah — cek suhu sebagai faktor sekunder
    if ($suhu < 30) {
      return self::result('Baik', 95.0, 'MQ135 rendah dan suhu normal');
    } else {
      return self::result('Sedang', 80.0, 'MQ135 rendah tapi suhu tinggi');
    }

  } elseif ($mq135 < 130) {
    // Polutan sedang — kelembaban memperburuk kondisi
    if ($kelembaban < 70) {
      return self::result('Sedang', 85.0, 'MQ135 sedang, kelembaban normal');
    } else {
      return self::result('Sedang', 70.0, 'MQ135 sedang + kelembaban tinggi');
    }

  } else {
    // Polutan tinggi — langsung Buruk
    return self::result('Buruk', 95.0, 'MQ135 melewati batas aman');
  }
}

document.addEventListener('DOMContentLoaded', () => {
  initCharts();              // Buat chart kosong dulu
  fetchAll();                // Fetch data pertama kali
  setInterval(fetchAll, 5000); // Ulangi setiap 5 detik
});

async function fetchAll() {
  // Jalankan semua fetch secara paralel (lebih cepat)
  await Promise.all([
    fetchLatest(),
    fetchStats(),
    fetchChartData(),
    fetchTableData(),
    fetchAnalysis(),
  ]);
}

async function fetchLatest() {
  try {
    // Panggil API — async/await lebih mudah dibaca dari .then()
    const res  = await fetch(`${API_BASE}/data.php?type=latest`);
    const json = await res.json();

    if (json.status !== 'success' || !json.data) return;

    const d = json.data;

    // Update elemen HTML berdasarkan id
    document.getElementById('val-mq135').textContent = parseFloat(d.mq135).toFixed(1);
    document.getElementById('val-suhu').textContent  = parseFloat(d.suhu).toFixed(1);

  } catch (e) {
    console.error('fetchLatest error:', e);
  }
}

# Kirim data simulasi ke server
curl -X POST http://localhost/goiot/api/sensor.php \
  -H "Content-Type: application/json" \
  -d '{"mq135": 145, "suhu": 32, "kelembaban": 78}'