บทความ: สร้างระบบวัดระดับน้ำด้วย ESP32 และ Ultrasonic Sensor

// ตั้งค่าขา GPIO สำหรับ Ultrasonic Sensor
const int trigPin = 5;   // Trigger Pin
const int echoPin = 18;  // Echo Pin

// ตั้งค่าความสูงของถังน้ำ (เซนติเมตร)
const float tankHeight = 200.0;  // ปรับตามขนาดถังจริง

// ตั้งค่า threshold สำหรับแจ้งเตือน (เปอร์เซ็นต์)
const int lowLevelThreshold = 20;   // แจ้งเตือนเมื่อน้ำเหลือ 20%
const int highLevelThreshold = 90;  // แจ้งเตือนเมื่อน้ำเกิน 90%

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

// ตัวแปรสำหรับเก็บข้อมูล
float duration, distance;
float waterLevel, waterPercent;
unsigned long lastTime = 0;
const long interval = 60000;  // อ่านค่าทุก 60 วินาที

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

  // ตั้งค่าขา Ultrasonic Sensor
  pinMode(trigPin, OUTPUT);
  pinMode(echoPin, INPUT);

  // เชื่อมต่อ WiFi
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println("\nWiFi connected");
}

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

  // อ่านค่าระยะทางทุก 60 วินาที
  if (currentTime - lastTime >= interval) {
    lastTime = currentTime;

    // ส่งสัญญาณ Trigger
    digitalWrite(trigPin, LOW);
    delayMicroseconds(2);
    digitalWrite(trigPin, HIGH);
    delayMicroseconds(10);
    digitalWrite(trigPin, LOW);

    // อ่านค่า Echo
    duration = pulseIn(echoPin, HIGH);

    // คำนวณระยะทาง (cm)
    distance = duration * 0.034 / 2;

    // คำนวณระดับน้ำ
    waterLevel = tankHeight - distance;
    waterPercent = (waterLevel / tankHeight) * 100;

    // แสดงผลใน Serial Monitor
    Serial.printf("Distance: %.2f cm | Water Level: %.2f%%\n",
                  distance, waterPercent);

    // ตรวจสอบ threshold และแจ้งเตือน
    checkThresholds();

    // TODO: ส่งข้อมูลไปยัง CynoIoT
    // sendToCynoIoT(waterLevel, waterPercent);
  }
}

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

// Line Notify Token
const char* lineToken = "YOUR_LINE_NOTIFY_TOKEN";

// ฟังก์ชันตรวจสอบ threshold และแจ้งเตือน
void checkThresholds() {
  static bool lowAlertSent = false;
  static bool highAlertSent = false;

  // ตรวจสอบระดับน้ำต่ำ
  if (waterPercent <= lowLevelThreshold && !lowAlertSent) {
    String message = "⚠️ แจ้งเตือน: ระดับน้ำในถังเหลือน้อย!\n";
    message += "ระดับน้ำปัจจุบัน: " + String(waterPercent, 1) + "%\n";
    message += "กรุณาเติมน้ำเพิ่ม";

    sendLineNotify(message);
    lowAlertSent = true;
    highAlertSent = false;  // Reset high alert
  }

  // ตรวจสอบระดับน้ำสูง
  if (waterPercent >= highLevelThreshold && !highAlertSent) {
    String message = "✅ แจ้งเตือน: ระดับน้ำในถังเต็มแล้ว!\n";
    message += "ระดับน้ำปัจจุบัน: " + String(waterPercent, 1) + "%\n";
    message += "สามารถหยุดเติมน้ำได้แล้ว";

    sendLineNotify(message);
    highAlertSent = true;
    lowAlertSent = false;  // Reset low alert
  }

  // Reset alerts เมื่อระดับน้ำปกติ
  if (waterPercent > lowLevelThreshold + 10 &&
      waterPercent < highLevelThreshold - 10) {
    lowAlertSent = false;
    highAlertSent = false;
  }
}

// ฟังก์ชันส่งข้อความ Line Notify
void sendLineNotify(String message) {
  HTTPClient http;

  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.print("Line Notify sent. Response code: ");
    Serial.println(httpResponseCode);
  } else {
    Serial.print("Error sending Line Notify. Response code: ");
    Serial.println(httpResponseCode);
  }

  http.end();
}

// ตั้งค่า CynoIoT
const char* cynoiotApiKey = "YOUR_CYNOIOT_API_KEY";
const char* cynoiotDeviceId = "YOUR_DEVICE_ID";
const char* cynoiotServer = "api.cynoiot.com";

// ฟังก์ชันส่งข้อมูลไปยัง CynoIoT
void sendToCynoIoT(float level, float percent) {
  if (WiFi.status() != WL_CONNECTED) {
    Serial.println("WiFi not connected");
    return;
  }

  HTTPClient http;

  // สร้าง URL สำหรับส่งข้อมูล
  String url = String("https://") + cynoiotServer +
               "/api/v1/devices/" + cynoiotDeviceId + "/data";

  http.begin(url);
  http.addHeader("Content-Type", "application/json");
  http.addHeader("Authorization", "Bearer " + String(cynoiotApiKey));

  // สร้าง JSON payload
  String payload = "{";
  payload += "\"water_level\":" + String(level, 2) + ",";
  payload += "\"water_percent\":" + String(percent, 2) + ",";
  payload += "\"distance\":" + String(distance, 2);
  payload += "}";

  // ส่งข้อมูล
  int httpResponseCode = http.POST(payload);

  if (httpResponseCode > 0) {
    Serial.print("CynoIoT data sent. Response: ");
    Serial.println(httpResponseCode);
  } else {
    Serial.print("Error sending to CynoIoT. Response: ");
    Serial.println(httpResponseCode);
  }

  http.end();
}