ทำระบบเฝ้าสังเกตพืชอัจฉริยะด้วย ESP32 - วัดความชื้นดิน อุณหภูมิ และความชื้นอากาศ

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

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

// ===== ตั้งค่า LINE Notify =====
const char* lineToken = "YOUR_LINE_NOTIFY_TOKEN";

// ===== ตั้งค่า CynoIoT MQTT =====
const char* mqttServer = "mqtt.cynoiot.com";
const int mqttPort = 1883;
const char* mqttUser = "YOUR_CYNOIOT_TOKEN";
const char* mqttPass = "";
const char* deviceId = "plant-monitor-001";

// ===== ตั้งค่าเซ็นเซอร์ =====
#define SOIL_PIN 34        // GPIO สำหรับ Soil Moisture
#define DHT_PIN 4          // GPIO สำหรับ DHT22
#define DHT_TYPE DHT22

DHT dht(DHT_PIN, DHT_TYPE);

WiFiClient espClient;
PubSubClient mqttClient(espClient);

// ตัวแปรสำหรับเก็บค่าเก่า
float lastSoilMoisture = 100;
bool notified = false;

void setup() {
  Serial.begin(115200);
  
  // เริ่มต้นเซ็นเซอร์
  dht.begin();
  
  // เริ่มต้น WiFi
  WiFi.begin(ssid, password);
  Serial.print("กำลังเชื่อมต่อ WiFi");
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  
  Serial.println("\nWiFi เชื่อมต่อแล้ว!");
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());
  
  // ตั้งค่า MQTT
  mqttClient.setServer(mqttServer, mqttPort);
  
  delay(2000);
}

void loop() {
  // ตรวจสอบการเชื่อมต่อ MQTT
  if (!mqttClient.connected()) {
    reconnectMQTT();
  }
  mqttClient.loop();
  
  // อ่านค่าจากเซ็นเซอร์
  float soilMoisture = readSoilMoisture();
  float temperature = dht.readTemperature();
  float humidity = dht.readHumidity();
  
  // ตรวจสอบว่าอ่านค่าสำเร็จหรือไม่
  if (isnan(temperature) || isnan(humidity)) {
    Serial.println("ไม่สามารถอ่านค่าจาก DHT22 ได้!");
    delay(2000);
    return;
  }
  
  // แสดงค่าบน Serial Monitor
  Serial.println("===== ข้อมูลเซ็นเซอร์ =====");
  Serial.printf("ความชื้นในดิน: %.1f%%\n", soilMoisture);
  Serial.printf("อุณหภูมิ: %.1f°C\n", temperature);
  Serial.printf("ความชื้นอากาศ: %.1f%%\n", humidity);
  Serial.println("=====================");
  
  // ส่งข้อมูลไปยัง CynoIoT
  sendToCynoIoT(soilMoisture, temperature, humidity);
  
  // แจ้งเตือนผ่าน LINE ถ้าดินแห้งเกิน 30%
  if (soilMoisture < 30 && !notified) {
    sendLineAlert(soilMoisture, temperature, humidity);
    notified = true;
  }
  
  // รีเซ็ตการแจ้งเตือนเมื่อดินชื้นกลับมา
  if (soilMoisture > 50) {
    notified = false;
  }
  
  delay(60000); // อ่านทุกๆ 1 นาที
}

// ฟังก์ชันอ่านค่าความชื้นในดิน
float readSoilMoisture() {
  int rawValue = analogRead(SOIL_PIN);
  // แปลงค่า ADC (0-4095) เป็นเปอร์เซ็นต์
  // Capacitive sensor: แห้ง = ค่าต่ำ, ชื้น = ค่าสูง
  float moisture = map(rawValue, 0, 4095, 0, 100);
  return moisture;
}

// ฟังก์ชันส่งข้อมูลไปยัง CynoIoT
void sendToCynoIoT(float soil, float temp, float hum) {
  String payload = "{";
  payload += "\"soil_moisture\":" + String(soil) + ",";
  payload += "\"temperature\":" + String(temp) + ",";
  payload += "\"humidity\":" + String(hum);
  payload += "}";
  
  char topic[100];
  sprintf(topic, "device/%s/data", deviceId);
  
  mqttClient.publish(topic, payload.c_str());
  Serial.println("ส่งข้อมูลไปยัง CynoIoT แล้ว");
}

// ฟังก์ชันแจ้งเตือนผ่าน LINE
void sendLineAlert(float soil, float temp, float hum) {
  HTTPClient http;
  
  String message = "\\n⚠️ แจ้งเตือน: ดินของพืขแห้งแล้ว!\\n";
  message += String("━━━━━━━━━━━━━━━\\n");
  message += String("🌱 ความชื้นในดิน: ") + soil + "%\\n";
  message += String("🌡️ อุณหภูมิ: ") + temp + "°C\\n";
  message += String("💧 ความชื้นอากาศ: ") + hum + "%\\n";
  message += String("━━━━━━━━━━━━━━━\\n");
  message += String("⏰ เวลา: ") + getTimeString();
  
  http.begin("https://notify-api.line.me/api/notify");
  http.addHeader("Content-Type", "application/x-www-form-urlencoded");
  http.addHeader("Authorization", "Bearer " + String(lineToken));
  
  String httpRequestData = "message=" + message;
  int httpResponseCode = http.POST(httpRequestData);
  
  if (httpResponseCode > 0) {
    Serial.println("ส่งการแจ้งเตือน LINE สำเร็จ!");
  } else {
    Serial.print("Error ส่ง LINE: ");
    Serial.println(httpResponseCode);
  }
  
  http.end();
}

// ฟังก์ชันเชื่อมต่อ MQTT ใหม่
void reconnectMQTT() {
  while (!mqttClient.connected()) {
    Serial.print("กำลังเชื่อมต่อ MQTT...");
    
    if (mqttClient.connect(deviceId, mqttUser, mqttPass)) {
      Serial.println("เชื่อมต่อสำเร็จ!");
    } else {
      Serial.print("ล้มเหลว, rc=");
      Serial.print(mqttClient.state());
      Serial.println(" ลองใหม่ใน 5 วินาที");
      delay(5000);
    }
  }
}

// ฟังก์ชันเวลา (simple version)
String getTimeString() {
  return "เมื่อสักครู่นี้";
}