สร้างระบบตรวจสอบอุปกรณ์ IoT ที่บ้านด้วย ESP32 และ Node-RED Dashboard

/**
 * ESP32 Multi-Sector IoT Monitoring with MQTT
 * อ่านค่าจาก DHT22, MQ-135 และ LDR แล้วส่งไปยัง MQTT Broker
 *
 * สร้างเมื่อ: 3 เมษายน 2026
 * สำหรับ: CynoIoT Platform + Node-RED Dashboard
 */

#include <WiFi.h>
#include <PubSubClient.h>
#include "DHT.h"

// ===== WiFi Settings =====
const char* ssid = "YOUR_WIFI_SSID";        // ใส่ชื่อ WiFi ของคุณ
const char* password = "YOUR_WIFI_PASSWORD"; // ใส่รหัส WiFi ของคุณ

// ===== MQTT Settings =====
const char* mqtt_server = "192.168.1.100";  // IP Address ของ MQTT Broker (Node-RED)
const int mqtt_port = 1883;                 // MQTT Port (default: 1883)

// ===== Sensor Pins =====
#define DHTPIN 4          // GPIO 4 สำหรับ DHT22
#define DHTTYPE DHT22     // ประเภทเซ็นเซอร์
#define MQ135_PIN 34      // GPIO 34 สำหรับ MQ-135 (Analog)
#define LDR_PIN 35        // GPIO 35 สำหรับ LDR (Analog)

// ===== MQTT Topics =====
#define TEMP_TOPIC "sensors/temperature"
#define HUMIDITY_TOPIC "sensors/humidity"
#define AIR_TOPIC "sensors/air_quality"
#define LIGHT_TOPIC "sensors/light_intensity"

// ===== Objects =====
WiFiClient espClient;
PubSubClient client(espClient);
DHT dht(DHTPIN, DHTTYPE);

// ===== Variables =====
unsigned long lastMsg = 0;
const long interval = 5000;  // ส่งข้อมูลทุก 5 วินาที

// ===== WiFi Connection Function =====
void setup_wifi() {
  Serial.print("🔌 กำลังเชื่อมต่อ WiFi: ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("\n✅ เชื่อมต่อ WiFi สำเร็จ!");
  Serial.print("📡 IP Address: ");
  Serial.println(WiFi.localIP());
}

// ===== MQTT Callback Function =====
void callback(char* topic, byte* message, unsigned int length) {
  // ฟังก์ชันนี้ใช้รับข้อความจาก MQTT (ถ้าต้องการควบคุมจาก Dashboard)
  Serial.print("📨 ได้รับข้อความจาก topic: ");
  Serial.print(topic);
  Serial.print(". ข้อความ: ");
  String messageTemp;

  for (int i = 0; i < length; i++) {
    messageTemp += (char)message[i];
  }
  Serial.println(messageTemp);
}

// ===== Reconnect to MQTT =====
void reconnect() {
  while (!client.connected()) {
    Serial.print("🔄 พยายามเชื่อมต่อ MQTT...");

    // พยายามเชื่อมต่อด้วย Client ID แบบสุ่ม
    String clientId = "ESP32Client-";
    clientId += String(random(0xffff), HEX);

    if (client.connect(clientId.c_str())) {
      Serial.println("✅ เชื่อมต่อ MQTT สำเร็จ!");
    } else {
      Serial.print("❌ ล้มเหลว, rc=");
      Serial.print(client.state());
      Serial.println(" ลองใหม่ใน 5 วินาที");
      delay(5000);
    }
  }
}

// ===== Read DHT22 Sensor =====
float readTemperature() {
  float t = dht.readTemperature();
  if (isnan(t)) {
    Serial.println("⚠️  อ่านค่าอุณหภูมิจาก DHT22 ไม่สำเร็จ!");
    return 0.0;
  }
  return t;
}

float readHumidity() {
  float h = dht.readHumidity();
  if (isnan(h)) {
    Serial.println("⚠️  อ่านค่าความชื้นจาก DHT22 ไม่สำเร็จ!");
    return 0.0;
  }
  return h;
}

// ===== Read MQ-135 Sensor =====
int readAirQuality() {
  int airValue = analogRead(MQ135_PIN);
  // แปลงค่าให้เป็น 0-100 (ค่ายิ่งน้อย อากาศยิ่งดี)
  int airQuality = map(airValue, 0, 4095, 100, 0);
  return airQuality;
}

// ===== Read LDR Sensor =====
int readLightIntensity() {
  int ldrValue = analogRead(LDR_PIN);
  // แปลงค่าให้เป็น 0-100%
  int lightPercent = map(ldrValue, 0, 4095, 0, 100);
  return lightPercent;
}

// ===== Setup Function =====
void setup() {
  Serial.begin(115200);

  // เริ่มต้นเซ็นเซอร์
  dht.begin();

  // ตั้งค่า MQTT
  client.setServer(mqtt_server, mqtt_port);
  client.setCallback(callback);

  // เชื่อมต่อ WiFi
  setup_wifi();

  Serial.println("🚀 เริ่มต้นระบบตรวจสอบ IoT เรียบร้อย!");
}

// ===== Main Loop =====
void loop() {
  // ตรวจสอบการเชื่อมต่อ MQTT
  if (!client.connected()) {
    reconnect();
  }
  client.loop();

  // ส่งข้อมูลทุก 5 วินาที
  unsigned long now = millis();
  if (now - lastMsg > interval) {
    lastMsg = now;

    // อ่านค่าจากเซ็นเซอร์
    float temperature = readTemperature();
    float humidity = readHumidity();
    int airQuality = readAirQuality();
    int lightIntensity = readLightIntensity();

    // แปลงค่าเป็น String
    char tempStr[8];
    char humStr[8];
    char airStr[8];
    char lightStr[8];

    dtostrf(temperature, 1, 2, tempStr);
    dtostrf(humidity, 1, 2, humStr);
    itoa(airQuality, airStr, 10);
    itoa(lightIntensity, lightStr, 10);

    // ส่งข้อมูลไปยัง MQTT Topics
    client.publish(TEMP_TOPIC, tempStr);
    client.publish(HUMIDITY_TOPIC, humStr);
    client.publish(AIR_TOPIC, airStr);
    client.publish(LIGHT_TOPIC, lightStr);

    // แสดงค่าบน Serial Monitor
    Serial.println("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
    Serial.print("🌡️  อุณหภูมิ: ");
    Serial.print(temperature);
    Serial.println(" °C");

    Serial.print("💧 ความชื้น: ");
    Serial.print(humidity);
    Serial.println(" %");

    Serial.print("🌫️  คุณภาพอากาศ: ");
    Serial.print(airQuality);
    Serial.println(" (0-100)");

    Serial.print("☀️  ความเข้มแสง: ");
    Serial.print(lightIntensity);
    Serial.println(" %");
    Serial.println("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
  }
}