บทความ: สร้างระบบบันทึกข้อมูลหลาย Sensor ด้วย ESP32 และ SD Card

/**
 * ESP32 Multi-Sensor Data Logger
 * บันทึกข้อมูลอุณหภูมิ ความชื้น และความดันลง SD Card
 * และส่งข้อมูลไป CynoIoT Platform
 *
 * Hardware:
 * - ESP32 Board
 * - DHT22 Sensor (GPIO 4)
 * - BMP280 Sensor (I2C: SCL=GPIO 22, SDA=GPIO 21)
 * - SD Card Module (SPI: CS=5, MOSI=23, MISO=19, SCK=18)
 */

#include <DHT.h>
#include <Adafruit_BMP280.h>
#include <SD.h>
#include <WiFi.h>
#include <HTTPClient.h>

// === ตั้งค่า Sensor ===
#define DHTPIN 4           // DHT22 Data pin
#define DHTTYPE DHT22      // DHT 22

DHT dht(DHTPIN, DHTTYPE);
Adafruit_BMP280 bmp;      // I2C

// === ตั้งค่า SD Card ===
#define SD_CS 5            // CS pin สำหรับ SD Card

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

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

// === ตั้งค่าการบันทึก ===
#define LOG_INTERVAL 60000  // บันทึกทุกๆ 60 วินาที
unsigned long lastLogTime = 0;

void setup() {
  Serial.begin(115200);
  Serial.println("\n=== ESP32 Multi-Sensor Data Logger ===");

  // เริ่มต้น DHT22
  dht.begin();
  Serial.println("✓ DHT22 started");

  // เริ่มต้น BMP280
  if (!bmp.begin(0x76)) {
    Serial.println("✗ BMP280 not found!");
    while (1);
  }
  Serial.println("✓ BMP280 started");

  // เริ่มต้น SD Card
  if (!SD.begin(SD_CS)) {
    Serial.println("✗ SD Card initialization failed!");
    while (1);
  }
  Serial.println("✓ SD Card initialized");

  // สร้างไฟล์ CSV ถ้ายังไม่มี
  if (!SD.exists("/datalog.csv")) {
    File dataFile = SD.open("/datalog.csv", FILE_WRITE);
    if (dataFile) {
      dataFile.println("Timestamp,Temperature_DHT,Temperature_BMP,Humidity,Pressure");
      dataFile.close();
      Serial.println("✓ Created datalog.csv");
    }
  }

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

  Serial.println("\n=== System Ready ===\n");
}

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

  // บันทึกข้อมูลทุกๆ ที่กำหนด
  if (currentTime - lastLogTime >= LOG_INTERVAL) {
    lastLogTime = currentTime;

    // อ่านค่าจาก DHT22
    float tempDHT = dht.readTemperature();
    float humidity = dht.readHumidity();

    // ตรวจสอบการอ่านค่า DHT22
    if (isnan(tempDHT) || isnan(humidity)) {
      Serial.println("✗ Failed to read from DHT sensor!");
      return;
    }

    // อ่านค่าจาก BMP280
    float tempBMP = bmp.readTemperature();
    float pressure = bmp.readPressure() / 100.0;  // แปลงเป็น hPa

    // สร้าง timestamp
    String timestamp = getTimestamp();

    // แสดงผลบน Serial Monitor
    Serial.println("=== Sensor Readings ===");
    Serial.print("Timestamp: ");
    Serial.println(timestamp);
    Serial.print("Temperature (DHT): ");
    Serial.print(tempDHT);
    Serial.println(" °C");
    Serial.print("Temperature (BMP): ");
    Serial.print(tempBMP);
    Serial.println(" °C");
    Serial.print("Humidity: ");
    Serial.print(humidity);
    Serial.println(" %");
    Serial.print("Pressure: ");
    Serial.print(pressure);
    Serial.println(" hPa");

    // บันทึกลง SD Card
    if (logToSD(timestamp, tempDHT, tempBMP, humidity, pressure)) {
      Serial.println("✓ Data saved to SD Card");
    } else {
      Serial.println("✗ Failed to save to SD Card");
    }

    // ส่งข้อมูลไป CynoIoT
    if (sendToCynoIoT(tempDHT, humidity, pressure)) {
      Serial.println("✓ Data sent to CynoIoT");
    } else {
      Serial.println("✗ Failed to send to CynoIoT");
    }

    Serial.println();
  }
}

// ฟังก์ชันสร้าง timestamp
String getTimestamp() {
  char timestamp[20];
  sprintf(timestamp, "%04d-%02d-%02d %02d:%02d:%02d",
          year(), month(), day(), hour(), minute(), second());
  return String(timestamp);
}

// ฟังก์ชันบันทึกลง SD Card
bool logToSD(String timestamp, float tempDHT, float tempBMP, float humidity, float pressure) {
  File dataFile = SD.open("/datalog.csv", FILE_APPEND);
  if (!dataFile) {
    return false;
  }

  // เขียนข้อมูลในรูปแบบ CSV
  dataFile.print(timestamp);
  dataFile.print(",");
  dataFile.print(tempDHT);
  dataFile.print(",");
  dataFile.print(tempBMP);
  dataFile.print(",");
  dataFile.print(humidity);
  dataFile.print(",");
  dataFile.println(pressure);

  dataFile.close();
  return true;
}

// ฟังก์ชันส่งข้อมูลไป CynoIoT
bool sendToCynoIoT(float temperature, float humidity, float pressure) {
  if (WiFi.status() != WL_CONNECTED) {
    return false;
  }

  HTTPClient http;
  http.begin(cynoiot_server);
  http.addHeader("Content-Type", "application/json");
  http.addHeader("X-API-Key", api_key);

  // สร้าง JSON payload
  String payload = "{\"device_id\":\"" + String(device_id) + "\",";
  payload += "\"data\":{";
  payload += "\"temperature\":" + String(temperature) + ",";
  payload += "\"humidity\":" + String(humidity) + ",";
  payload += "\"pressure\":" + String(pressure);
  payload += "}}";

  int httpResponseCode = http.POST(payload);
  http.end();

  return (httpResponseCode == 200);
}