สร้างระบบ Smart Monitoring ด้วย ESP32: ติดตามสภาพแวดล้อมแบบเรียลไทม์

# Libraries ที่ต้องติดตั้ง
1. DHT sensor library by Adafruit
2. Adafruit Unified Sensor
3. PubSubClient (สำหรับ MQTT)
4. ArduinoJson (สำหรับจัดการ JSON)

#include <WiFi.h>
#include <DHT.h>
#include <PubSubClient.h>
#include <ArduinoJson.h>
#include <HTTPClient.h>

// ========== ตั้งค่า WiFi ==========
const char* ssid = "YOUR_WIFI_SSID";
const char* password = "YOUR_WIFI_PASSWORD";

// ========== ตั้งค่า CynoIoT ==========
const char* cynoiot_server = "api.cynoiot.com";
const int cynoiot_port = 1883;
const char* device_id = "YOUR_DEVICE_ID";
const char* api_key = "YOUR_API_KEY";

// ========== ตั้งค่า Sensors ==========
#define DHTPIN 4
#define DHTTYPE DHT22
#define PIR_PIN 27

// ตั้งค่า threshold สำหรับการแจ้งเตือน
const float TEMP_HIGH_THRESHOLD = 35.0;  // อุณหภูมิสูงเกินไป (°C)
const float TEMP_LOW_THRESHOLD = 18.0;   // อุณหภูมิต่ำเกินไป (°C)
const float HUMIDITY_HIGH_THRESHOLD = 70.0;  // ความชื้นสูงเกินไป (%)

// ตั้งค่า Deep Sleep (วินาที)
#define SLEEP_INTERVAL 60  // ส่งข้อมูลทุก 1 นาที

DHT dht(DHTPIN, DHTTYPE);
WiFiClient espClient;
PubSubClient client(espClient);
HTTPClient http;

// Variables สำหรับเก็บค่า
float temperature = 0.0;
float humidity = 0.0;
bool motionDetected = false;
unsigned long lastMotionTime = 0;

// ฟังก์ชันเชื่อมต่อ WiFi
void connectToWiFi() {
  Serial.println("\n📡 Connecting to WiFi...");
  
  WiFi.begin(ssid, password);
  
  int attempts = 0;
  while (WiFi.status() != WL_CONNECTED && attempts < 20) {
    delay(500);
    Serial.print(".");
    attempts++;
  }
  
  if (WiFi.status() == WL_CONNECTED) {
    Serial.println("\n✅ WiFi connected!");
    Serial.println("IP address: " + WiFi.localIP().toString());
  } else {
    Serial.println("\n❌ WiFi connection failed!");
  }
}

// ฟังก์ชันเชื่อมต่อ CynoIoT MQTT
void connectToCynoIoT() {
  while (!client.connected()) {
    Serial.print("🔗 Connecting to CynoIoT...");
    
    if (client.connect("ESP32Client", device_id, api_key)) {
      Serial.println(" ✅");
      client.subscribe("cynoiot/" + String(device_id) + "/commands");
    } else {
      Serial.print(" failed, rc=");
      Serial.print(client.state());
      Serial.println(" retrying in 5 seconds");
      delay(5000);
    }
  }
}

// ฟังก์ชันอ่านค่าจากเซ็นเซอร์
void readSensors() {
  Serial.println("\n📖 Reading sensors...");
  
  // อ่าน DHT22
  temperature = dht.readTemperature();
  humidity = dht.readHumidity();
  
  if (isnan(temperature) || isnan(humidity)) {
    Serial.println("❌ Failed to read from DHT sensor!");
    return;
  }
  
  Serial.printf("🌡️ Temperature: %.2f°C\n", temperature);
  Serial.printf("💧 Humidity: %.2f%%\n", humidity);
  
  // อ่าน PIR Motion Sensor
  motionDetected = digitalRead(PIR_PIN);
  if (motionDetected) {
    lastMotionTime = millis();
    Serial.println("🚶 Motion detected!");
  }
}

// ฟังก์ชันสร้าง JSON payload
String createSensorPayload() {
  StaticJsonDocument<256> doc;
  
  doc["device_id"] = device_id;
  doc["timestamp"] = millis();
  doc["temperature"] = temperature;
  doc["humidity"] = humidity;
  doc["motion"] = motionDetected;
  
  String payload;
  serializeJson(doc, payload);
  return payload;
}

// ฟังก์ชันส่งข้อมูลไปยัง CynoIoT
void sendToCynoIoT() {
  String payload = createSensorPayload();
  String topic = "cynoiot/" + String(device_id) + "/sensors";
  
  Serial.println("📤 Sending data to CynoIoT...");
  Serial.println("Payload: " + payload);
  
  if (client.publish(topic.c_str(), payload.c_str())) {
    Serial.println("✅ Data sent successfully!");
  } else {
    Serial.println("❌ Failed to send data");
  }
}

// ฟังก์ชันตรวจสอบและแจ้งเตือน
void checkThresholds() {
  String alertMsg = "";
  
  if (temperature > TEMP_HIGH_THRESHOLD) {
    alertMsg = "⚠️ อุณหภูมิสูงเกินกำหนด! " + String(temperature) + "°C";
  } else if (temperature < TEMP_LOW_THRESHOLD) {
    alertMsg = "❄️ อุณหภูมิต่ำเกินกำหนด! " + String(temperature) + "°C";
  }
  
  if (humidity > HUMIDITY_HIGH_THRESHOLD) {
    alertMsg += " | 💧 ความชื้นสูงเกินกำหนด! " + String(humidity) + "%";
  }
  
  if (alertMsg != "") {
    Serial.println("🚨 " + alertMsg);
    
    // ส่งแจ้งเตือนไปยัง CynoIoT
    String alertTopic = "cynoiot/" + String(device_id) + "/alerts";
    client.publish(alertTopic.c_str(), alertMsg.c_str());
  }
}

// MQTT callback function
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("📩 Message arrived [");
  Serial.print(topic);
  Serial.print("]: ");
  
  for (unsigned int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
}

void setup() {
  Serial.begin(115200);
  delay(1000);
  
  Serial.println("\n====================================");
  Serial.println("🚀 CynoIoT Smart Monitoring System");
  Serial.println("====================================\n");
  
  // ตั้งค่า pin modes
  pinMode(PIR_PIN, INPUT);
  dht.begin();
  
  // เชื่อมต่อ WiFi
  connectToWiFi();
  
  // ตั้งค่า MQTT
  client.setServer(cynoiot_server, cynoiot_port);
  client.setCallback(callback);
  
  // เชื่อมต่อ CynoIoT
  connectToCynoIoT();
  
  Serial.println("✅ Setup complete! Starting monitoring...\n");
}

void loop() {
  // ตรวจสอบการเชื่อมต่อ MQTT
  if (!client.connected()) {
    connectToCynoIoT();
  }
  client.loop();
  
  // อ่านค่าเซ็นเซอร์
  readSensors();
  
  // ส่งข้อมูลไปยัง CynoIoT
  sendToCynoIoT();
  
  // ตรวจสอบ threshold และแจ้งเตือน
  checkThresholds();
  
  Serial.println("\n⏰ Going to deep sleep for " + String(SLEEP_INTERVAL) + " seconds...\n");
  
  // เข้าสู่โหมด Deep Sleep
  ESP32.deepSleep(SLEEP_INTERVAL * 1000000);
}