สร้างระบบตรวจจับฝนและปิดหน้าต่างอัตโนมัติด้วย ESP32 และ CynoIoT

/*
 * โปรเจกต์: ระบบตรวจจับฝนและปิดหน้าต่างอัตโนมัติ
 * บอร์ด: ESP32 DevKit V1
 * Rain Sensor: GPIO 34 (Analog)
 * Servo Motor: GPIO 18
 * แพลตฟอร์ม: CynoIoT
 */

#include <WiFi.h>
#include <ESP32Servo.h>
#include <HTTPClient.h>

// ================== การตั้งค่า WiFi ==================
const char* ssid = "YOUR_WIFI_SSID";        // แทนที่ด้วยชื่อ WiFi ของคุณ
const char* password = "YOUR_WIFI_PASSWORD"; // แทนที่ด้วยรหัส WiFi

// ================== การตั้งค่า CynoIoT ==================
const char* cynoiotServer = "api.cynoiot.com"; // เปลี่ยนตามความจริง
const char* deviceApiKey = "YOUR_DEVICE_API_KEY"; // API Key จาก CynoIoT

// ================== การตั้งค่า Hardware ==================
const int RAIN_SENSOR_PIN = 34;  // GPIO 34 สำหรับ Rain Sensor (Analog)
const int SERVO_PIN = 18;         // GPIO 18 สำหรับ Servo Motor

const int RAIN_THRESHOLD = 2000; // ค่า threshold (ปรับได้ 0-4095)
                                 // ค่าต่ำ = ไม่มีฝน, ค่าสูง = มีฝน
                                 // เซนเซอร์บางตัวให้ค่าตรงกันข้าม!

const int SERVO_OPEN_ANGLE = 0;   // มุมเปิดหน้าต่าง (องศา)
const int SERVO_CLOSE_ANGLE = 90; // มุมปิดหน้าต่าง (องศา)

// ================== ตัวแปร ==================
Servo windowServo;
bool isRaining = false;
bool windowIsClosed = false;
unsigned long lastCheckTime = 0;
const unsigned long CHECK_INTERVAL = 2000; // ตรวจสอบทุก 2 วินาที
unsigned long lastSendTime = 0;
const unsigned long SEND_INTERVAL = 30000; // ส่งข้อมูลทุก 30 วินาที

void setup() {
  Serial.begin(115200);
  delay(1000);

  Serial.println("\n=== 🌧️ เริ่มต้นระบบตรวจจับฝน ===");

  // ตั้งค่า Servo
  windowServo.attach(SERVO_PIN);
  windowServo.write(SERVO_OPEN_ANGLE); // เริ่มต้นด้วยการเปิดหน้าต่าง
  Serial.println("✅ Servo Motor เริ่มทำงานแล้ว");

  // ตั้งค่า Rain Sensor (ESP32 ไม่ต้อง pinMode สำหรับ analog input)
  Serial.println("✅ Rain Sensor พร้อมใช้งาน");

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

  Serial.println("✅ เริ่มทำงานเรียบร้อย รอตรวจจับฝน...\n");
}

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

  // ตรวจสอบฝนทุก 2 วินาที
  if (currentTime - lastCheckTime >= CHECK_INTERVAL) {
    lastCheckTime = currentTime;
    checkRainSensor();
  }

  // ส่งข้อมูลไป CynoIoT ทุก 30 วินาที
  if (currentTime - lastSendTime >= SEND_INTERVAL) {
    lastSendTime = currentTime;
    sendToCynoIoT();
  }
}

// ================== ฟังก์ชันตรวจสอบ Rain Sensor ==================
void checkRainSensor() {
  int rainValue = analogRead(RAIN_SENSOR_PIN);

  Serial.print("🌧️ ค่า Rain Sensor: ");
  Serial.print(rainValue);
  Serial.print(" | Threshold: ");
  Serial.print(RAIN_THRESHOLD);

  // ตรวจสอบว่ามีฝนหรือไม่
  // *** สำคัญ: เซนเซอร์บางตัวให้ค่าสูงเมื่อแห้ง และต่ำเมื่อเปียก ***
  // ถ้าเซนเซอร์ของคุณทำงานตรงกันข้าม ให้เปลี่ยนเครื่องหมาย > เป็น <
  bool raining = (rainValue > RAIN_THRESHOLD);

  if (raining && !isRaining) {
    // เริ่มฝนตก
    isRaining = true;
    Serial.println(" -> ⛈️ ตรวจพบฝน! กำลังปิดหน้าต่าง...");
    closeWindow();
  } else if (!raining && isRaining) {
    // ฝนหยุดตก
    isRaining = false;
    Serial.println(" -> ☀️ ฝนหยุดตก หน้าต่างยังคงปิดอยู่");
    // ถ้าต้องการให้เปิดหน้าต่างอัตโนมัติเมื่อฝนหยุด ให้เปิด comment บรรทัดถัดไป
    // openWindow();
  } else {
    Serial.println();
  }
}

// ================== ฟังก์ชันปิดหน้าต่าง ==================
void closeWindow() {
  Serial.println("🔒 กำลังปิดหน้าต่าง...");
  windowServo.write(SERVO_CLOSE_ANGLE);
  windowIsClosed = true;
  delay(1000);
  Serial.println("✅ ปิดหน้าต่างเรียบร้อย!");
}

// ================== ฟังก์ชันเปิดหน้าต่าง ==================
void openWindow() {
  Serial.println("🔓 กำลังเปิดหน้าต่าง...");
  windowServo.write(SERVO_OPEN_ANGLE);
  windowIsClosed = false;
  delay(1000);
  Serial.println("✅ เปิดหน้าต่างเรียบร้อย!");
}

// ================== ฟังก์ชันเชื่อมต่อ WiFi ==================
void connectToWiFi() {
  Serial.print("📡 เชื่อมต่อ WiFi: ");
  Serial.println(ssid);

  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 สำเร็จ!");
    Serial.print("📌 IP Address: ");
    Serial.println(WiFi.localIP());
  } else {
    Serial.println("\n❌ ไม่สามารถเชื่อมต่อ WiFi ได้");
    Serial.println("⚠️ ระบบจะทำงานในโหมด offline (ไม่ส่งข้อมูลไป CynoIoT)");
  }
}

// ================== ฟังก์ชันส่งข้อมูลไป CynoIoT ==================
void sendToCynoIoT() {
  if (WiFi.status() != WL_CONNECTED) {
    Serial.println("⚠️ WiFi ไม่ได้เชื่อมต่อ ข้ามการส่งข้อมูล");
    return;
  }

  HTTPClient http;
  String url = String("http://") + cynoiotServer + "/api/devices/data";

  http.begin(url);
  http.addHeader("Content-Type", "application/json");
  http.addHeader("X-API-Key", deviceApiKey);

  // สร้าง JSON payload
  String payload = "{\"raining\":" + String(isRaining ? "true" : "false") +
                   ",\"window_closed\":" + String(windowIsClosed ? "true" : "false") +
                   ",\"rain_value\":" + String(analogRead(RAIN_SENSOR_PIN)) +
                   "}";

  int httpResponseCode = http.POST(payload);

  if (httpResponseCode > 0) {
    Serial.print("📤 ส่งข้อมูลไป CynoIoT: ");
    Serial.println(httpResponseCode);
  } else {
    Serial.print("❌ ส่งข้อมูลไม่สำเร็จ: ");
    Serial.println(http.errorToString(httpResponseCode));
  }

  http.end();
}