สร้างระบบดูแลพืชอัจฉริยะด้วย ESP32 และ CynoIoT 🌱

/**
 * Smart Plant Monitoring System with ESP32 & CynoIoT
 * ระบบดูแลพืชอัจฉริยะ: วัดความชื้นดิน, อุณหภูมิ, ความชื้นอากาศ และรดน้ำอัตโนมัติ
 */

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

// ================= WiFi Settings =================
const char* ssid = "YOUR_WIFI_SSID";        // แก้ไข: ชื่อ WiFi
const char* password = "YOUR_WIFI_PASSWORD"; // แก้ไข: รหัส WiFi

// ================= CynoIoT Settings =================
const char* cynoiot_server = "api.cynoiot.com";
const String cynoiot_token = "YOUR_DEVICE_TOKEN"; // แก้ไข: Device Token จาก CynoIoT

// ================= Pin Definitions =================
#define SOIL_MOISTURE_PIN 34   // GPIO34 สำหรับ Soil Moisture Sensor
#define DHT_PIN 4              // GPIO4 สำหรับ DHT22
#define RELAY_PIN 26           // GPIO26 สำหรับ Relay

// ================= Sensor Settings =================
#define DHTTYPE DHT22          // DHT 22  (AM2302), AM2321
#define SOIL_MOISTURE_THRESHOLD 30  // ระดับความชื้นขั้นต่ำที่จะรดน้ำ (%)

DHT dht(DHT_PIN, DHTTYPE);

// ================= Variables =================
unsigned long lastSensorRead = 0;
unsigned long lastCynoIoTUpdate = 0;
const long sensorReadInterval = 2000;      // อ่านค่าทุก 2 วินาที
const long cynoiotUpdateInterval = 10000;  // ส่งข้อมูลทุก 10 วินาที

float soilMoisture = 0;
float temperature = 0;
float humidity = 0;
bool pumpActive = false;

void setup() {
  Serial.begin(115200);
  
  // ตั้งค่า Pin modes
  pinMode(SOIL_MOISTURE_PIN, INPUT);
  pinMode(RELAY_PIN, OUTPUT);
  digitalWrite(RELAY_PIN, HIGH);  // Relay ปกติปิด (HIGH = OFF)
  
  // เริ่มต้น DHT sensor
  dht.begin();
  
  // เชื่อมต่อ WiFi
  connectWiFi();
  
  Serial.println("Smart Plant Monitoring System Started!");
  Serial.println("=====================================");
}

void loop() {
  unsigned long currentMillis = millis();

  // อ่านค่าเซ็นเซอร์ทุก 2 วินาที
  if (currentMillis - lastSensorRead >= sensorReadInterval) {
    lastSensorRead = currentMillis;
    readSensors();
    checkAndWaterPlant();
  }

  // ส่งข้อมูลไป CynoIoT ทุก 10 วินาที
  if (currentMillis - lastCynoIoTUpdate >= cynoiotUpdateInterval) {
    lastCynoIoTUpdate = currentMillis;
    sendToCynoIoT();
  }
}

// ================= ฟังก์ชันเชื่อมต่อ WiFi =================
void connectWiFi() {
  Serial.print("Connecting to WiFi");
  
  WiFi.begin(ssid, password);
  
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  
  Serial.println("\n✓ WiFi connected!");
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());
}

// ================= ฟังก์ชันอ่านค่าเซ็นเซอร์ =================
void readSensors() {
  // อ่านค่า Soil Moisture (ค่าดิบ 0-4095)
  int soilRaw = analogRead(SOIL_MOISTURE_PIN);
  
  // แปลงค่าเป็นเปอร์เซ็นต์ (ยิ่งน้ำมากค่ายิ่งต่ำ ให้กลับค่า)
  // ดินแห้ง = ~3000-3500, ดินเปียก = ~1000-1500
  soilMoisture = map(soilRaw, 1500, 3500, 100, 0);
  soilMoisture = constrain(soilMoisture, 0, 100);
  
  // อ่านค่า DHT22
  temperature = dht.readTemperature();
  humidity = dht.readHumidity();
  
  // ตรวจสอบค่าที่อ่านได้
  if (isnan(temperature) || isnan(humidity)) {
    Serial.println("⚠️  Failed to read from DHT sensor!");
    return;
  }
  
  // แสดงค่าที่อ่านได้
  Serial.println("\n=== Sensor Readings ===");
  Serial.print("🌱 Soil Moisture: ");
  Serial.print(soilMoisture);
  Serial.println("%");
  
  Serial.print("🌡️ Temperature: ");
  Serial.print(temperature);
  Serial.println("°C");
  
  Serial.print("💧 Humidity: ");
  Serial.print(humidity);
  Serial.println("%");
  
  Serial.print("💧 Pump Status: ");
  Serial.println(pumpActive ? "ON (รดน้ำอยู่)" : "OFF");
}

// ================= ฟังก์ชันตรวจสอบและรดน้ำ =================
void checkAndWaterPlant() {
  // ถ้าความชื้นในดินต่ำกว่าค่าที่ตั้งไว้ ให้เปิดปั๊ม
  if (soilMoisture < SOIL_MOISTURE_THRESHOLD) {
    if (!pumpActive) {
      Serial.println("🚰 Soil is dry! Starting watering system...");
      digitalWrite(RELAY_PIN, LOW);  // Relay ON
      pumpActive = true;
    }
  } else {
    // ถ้าความชื้นเพียงพอแล้ว ให้ปิดปั๊ม
    if (pumpActive) {
      Serial.println("✓ Soil is moist enough! Stopping watering...");
      digitalWrite(RELAY_PIN, HIGH);  // Relay OFF
      pumpActive = false;
    }
  }
}

// ================= ฟังก์ชันส่งข้อมูลไป CynoIoT =================
void sendToCynoIoT() {
  if (WiFi.status() != WL_CONNECTED) {
    Serial.println("⚠️ WiFi disconnected! Reconnecting...");
    connectWiFi();
    return;
  }
  
  // สร้าง JSON payload
  String payload = "{";
  payload += "\"soil_moisture\":" + String(soilMoisture) + ",";
  payload += "\"temperature\":" + String(temperature) + ",";
  payload += "\"humidity\":" + String(humidity) + ",";
  payload += "\"pump_status\":" + String(pumpActive ? "true" : "false");
  payload += "}";
  
  // ส่ง HTTP POST request
  HTTPClient http;
  String url = "https://" + String(cynoiot_server) + "/api/v1/devices/data";
  
  http.begin(url);
  http.addHeader("Content-Type", "application/json");
  http.addHeader("Authorization", "Bearer " + cynoiot_token);
  
  int httpResponseCode = http.POST(payload);
  
  if (httpResponseCode > 0) {
    Serial.print("\n📡 Data sent to CynoIoT. Response code: ");
    Serial.println(httpResponseCode);
  } else {
    Serial.print("⚠️ Error sending data: ");
    Serial.println(http.errorToString(httpResponseCode).c_str());
  }
  
  http.end();
}