พลิกโฉมมิเตอร์ไฟบ้าน! สร้างระบบ Smart Grid IoT ด้วย Arduino UNO R4 WiFi ⚡📊

#include <WiFiS3.h>
#include <Wire.h>
#include <Adafruit_GFX.h>
#include <Adafruit_SSD1306.h>
#include <ThingSpeak.h>
#include <PZEM004Tv40_R4.h>

// WiFi credentials
const char* ssid = "Semicon Media";
const char* password = "cracksen1605";

// ThingSpeak settings
unsigned long myChannelNumber = 3238257;
const char* myWriteAPIKey = "CRXGU545EOA6Z8R9";

// OLED Display settings
#define SCREEN_WIDTH 128
#define SCREEN_HEIGHT 64
#define OLED_RESET -1
#define SCREEN_ADDRESS 0x3C

// Button settings
#define BUTTON_PIN 4

Adafruit_SSD1306 display(SCREEN_WIDTH, SCREEN_HEIGHT, &Wire, OLED_RESET);
PZEM004Tv40_R4 pzem(&Serial1);
WiFiClient client;

// Timing variables (non-blocking)
unsigned long lastReadTime = 0;
unsigned long lastUploadTime = 0;
unsigned long lastSerialPrintTime = 0;
unsigned long lastDisplayUpdateTime = 0;
unsigned long lastDisplaySwitchTime = 0;
unsigned long wifiConnectStartTime = 0;
unsigned long lastButtonPressTime = 0;

const unsigned long readInterval = 1000;
const unsigned long serialPrintInterval = 1000;
const unsigned long displayUpdateInterval = 500;
const unsigned long displaySwitchInterval = 5000;
const unsigned long uploadInterval = 16000;
const unsigned long wifiTimeout = 10000;
const unsigned long debounceDelay = 200;

// Display mode and states
int displayMode = 0;
bool rollingEnabled = false;
bool lastButtonState = HIGH;
bool buttonState = HIGH;

enum WiFiState { WIFI_IDLE, WIFI_CONNECTING, WIFI_CONNECTED, WIFI_FAILED };
WiFiState wifiState = WIFI_IDLE;

// Data storage
float voltage = 0.0;
float current = 0.0;
float power = 0.0;
float energy = 0.0;
float frequency = 0.0;
float powerFactor = 0.0;
bool dataValid = false;

void setup() {
  Serial.begin(115200);
  Serial.println("PZEM-004T Energy Monitor with ThingSpeak");
  
  if (!display.begin(SSD1306_SWITCHCAPVCC, SCREEN_ADDRESS)) {
    Serial.println(F("SSD1306 allocation failed"));
    while (1);
  }
  display.clearDisplay();
  display.setTextColor(SSD1306_WHITE);
  display.setTextSize(1);
  display.setCursor(0, 0);
  display.println("PZEM Monitor Init...");
  display.display();

  pinMode(BUTTON_PIN, INPUT_PULLUP);
  pzem.begin();
  ThingSpeak.begin(client);

  wifiState = WIFI_CONNECTING;
  WiFi.begin(ssid, password);
  wifiConnectStartTime = millis();
}

void loop() {
  unsigned long currentMillis = millis();
  
  handleButton(currentMillis);
  handleWiFi(currentMillis);
  
  if (currentMillis - lastReadTime >= readInterval) {
    lastReadTime = currentMillis;
    readPZEMData();
  }
  
  if (currentMillis - lastSerialPrintTime >= serialPrintInterval && dataValid) {
    lastSerialPrintTime = currentMillis;
    printToSerial();
  }
  
  if (rollingEnabled && (currentMillis - lastDisplaySwitchTime >= displaySwitchInterval)) {
    lastDisplaySwitchTime = currentMillis;
    displayMode++;
    if (displayMode > 6) displayMode = 1;
  }
  
  if (currentMillis - lastDisplayUpdateTime >= displayUpdateInterval) {
    lastDisplayUpdateTime = currentMillis;
    updateDisplay();
  }
  
  if (currentMillis - lastUploadTime >= uploadInterval && dataValid) {
    if (wifiState == WIFI_CONNECTED) {
      lastUploadTime = currentMillis;
      uploadToThingSpeak();
    }
  }
}

// Helper functions (readPZEMData, uploadToThingSpeak, updateDisplay, etc. are defined here)
void readPZEMData() {
  if (pzem.readAll()) {
    voltage = pzem.getVoltage();
    current = pzem.getCurrent() * 1000;
    power = pzem.getPower();
    energy = pzem.getEnergy();
    frequency = pzem.getFrequency();
    powerFactor = pzem.getPowerFactor();
    dataValid = true;
  } else {
    dataValid = false;
    Serial.println("Error reading PZEM!");
  }
}

void uploadToThingSpeak() {
  ThingSpeak.setField(1, voltage);
  ThingSpeak.setField(2, current);
  ThingSpeak.setField(3, power);
  ThingSpeak.setField(4, energy);
  ThingSpeak.setField(5, frequency);
  ThingSpeak.setField(6, powerFactor);
  
  int statusCode = ThingSpeak.writeFields(myChannelNumber, myWriteAPIKey);
  if (statusCode == 200) {
    Serial.println("Channel update successful!");
  }
}

/* For full helper functions including Display formatting and WiFi State Machine, 
   please refer to the GitHub repository below */