270 lines
8.8 KiB
C++
270 lines
8.8 KiB
C++
#include <WiFi.h>
|
|
#include <WiFiClientSecure.h>
|
|
#include <HTTPClient.h>
|
|
#include <PubSubClient.h>
|
|
#include <DHT.h>
|
|
#include <time.h>
|
|
|
|
// ================= SUPABASE =================
|
|
const char* supabase_url = "https://hpmicdhjyboyeofphgae.supabase.co";
|
|
const char* supabase_key = "sb_publishable_OB8e9y1OO0z3Y5xQ828YvA_T3jD16zT";
|
|
|
|
// ================= WIFI =================
|
|
const char* ssid = "Ozie 1";
|
|
const char* password = "followkami";
|
|
|
|
// ================= TIME (NTP) =================
|
|
const char* ntpServer = "pool.ntp.org";
|
|
const long gmtOffset_sec = 7 * 3600; // WIB (GMT+7)
|
|
const int daylightOffset_sec = 0;
|
|
|
|
// ================= MQTT =================
|
|
const char* mqtt_server = "broker.hivemq.com";
|
|
WiFiClient espClient;
|
|
PubSubClient client(espClient);
|
|
|
|
// ================= DHT =================
|
|
#define DHTPIN 4
|
|
#define DHTTYPE DHT22
|
|
DHT dht(DHTPIN, DHTTYPE);
|
|
|
|
// ================= RELAY =================
|
|
#define RELAY1 27
|
|
#define RELAY2 26
|
|
|
|
// Relay aktif LOW
|
|
#define RELAY_ON LOW
|
|
#define RELAY_OFF HIGH
|
|
|
|
// ================= THRESHOLD =================
|
|
float batasPanas = 70.0;
|
|
float batasLembab = 90.0;
|
|
|
|
// ================= GLOBAL STATE =================
|
|
unsigned long lastMsg = 0;
|
|
String statusRelay = "INIT";
|
|
bool isAutoMode = true;
|
|
bool manualPump = false;
|
|
bool manualLight = false;
|
|
|
|
// State Tracking for Upload
|
|
bool prevPump = false;
|
|
bool prevLight = false;
|
|
unsigned long lastPeriodicUpload = 0;
|
|
|
|
// ================= SUPABASE UPLOAD =================
|
|
void uploadToSupabase(float hum, String status, String lamp, String pump) {
|
|
if (WiFi.status() == WL_CONNECTED) {
|
|
// Ambil waktu saat ini
|
|
struct tm timeinfo;
|
|
String timeStr = "";
|
|
|
|
if (getLocalTime(&timeinfo)) {
|
|
char timeStringBuff[50];
|
|
strftime(timeStringBuff, sizeof(timeStringBuff), "%H:%M:%S", &timeinfo);
|
|
timeStr = String(timeStringBuff);
|
|
}
|
|
|
|
WiFiClientSecure clientSecure;
|
|
clientSecure.setInsecure();
|
|
HTTPClient http;
|
|
|
|
String url = String(supabase_url) + "/rest/v1/humidity";
|
|
http.begin(clientSecure, url);
|
|
http.addHeader("Content-Type", "application/json");
|
|
http.addHeader("apikey", supabase_key);
|
|
http.addHeader("Authorization", "Bearer " + String(supabase_key));
|
|
http.addHeader("Prefer", "return=minimal");
|
|
|
|
String json = "{\"kelembapan\":" + String(hum) +
|
|
(timeStr != "" ? ",\"tanggal_upload\":\"" + timeStr + "\"" : "") +
|
|
",\"status\":\"" + status + "\"" +
|
|
",\"status_lampu\":\"" + lamp + "\"" +
|
|
",\"status_pompa\":\"" + pump + "\"}";
|
|
|
|
Serial.println("[Supabase] Uploading data...");
|
|
int httpCode = http.POST(json);
|
|
|
|
if (httpCode >= 200 && httpCode < 300) {
|
|
Serial.printf("[Supabase] Berhasil Terkirim! Status: %d\n", httpCode);
|
|
} else if (httpCode > 0) {
|
|
String response = http.getString();
|
|
Serial.printf("[Supabase] Gagal Mengirim. HTTP Code: %d\n", httpCode);
|
|
Serial.printf("[Supabase] Alasan: %s\n", response.c_str());
|
|
} else {
|
|
Serial.printf("[Supabase] Gagal Koneksi. Error: %s\n", http.errorToString(httpCode).c_str());
|
|
}
|
|
|
|
http.end();
|
|
} else {
|
|
Serial.println("[Supabase] Gagal: WiFi tidak terhubung!");
|
|
}
|
|
}
|
|
|
|
// ================= WIFI =================
|
|
void setup_wifi() {
|
|
delay(10);
|
|
Serial.println("Connecting to WiFi...");
|
|
WiFi.begin(ssid, password);
|
|
|
|
while (WiFi.status() != WL_CONNECTED) {
|
|
delay(500);
|
|
Serial.print(".");
|
|
}
|
|
Serial.println("\nWiFi connected!");
|
|
}
|
|
|
|
// ================= MQTT CALLBACK =================
|
|
void callback(char* topic, byte* payload, unsigned int length) {
|
|
String message = "";
|
|
for (int i = 0; i < length; i++) {
|
|
message += (char)payload[i];
|
|
}
|
|
|
|
Serial.print("Message arrived [");
|
|
Serial.print(topic);
|
|
Serial.print("] ");
|
|
Serial.println(message);
|
|
|
|
if (String(topic) == "esp32/statusiqbal/mode") {
|
|
isAutoMode = (message == "auto");
|
|
Serial.println(isAutoMode ? "Mode: AUTO" : "Mode: MANUAL");
|
|
}
|
|
else if (String(topic) == "esp32/statusiqbal/pump") {
|
|
manualPump = (message == "on");
|
|
Serial.println(manualPump ? "Manual Pump: ON" : "Manual Pump: OFF");
|
|
}
|
|
else if (String(topic) == "esp32/statusiqbal/light") {
|
|
manualLight = (message == "on");
|
|
Serial.println(manualLight ? "Manual Light: ON" : "Manual Light: OFF");
|
|
}
|
|
}
|
|
|
|
// ================= MQTT RECONNECT =================
|
|
void reconnect() {
|
|
while (!client.connected()) {
|
|
Serial.print("Connecting MQTT...");
|
|
// Unique client ID using MAC address
|
|
String clientId = "ESP32MJ-" + WiFi.macAddress();
|
|
|
|
if (client.connect(clientId.c_str(), "esp32/statusiqbal", 0, true, "offline")) {
|
|
Serial.println("CONNECTED to MQTT ✅");
|
|
client.publish("esp32/statusiqbal", "online", true);
|
|
|
|
// Subscribe to control topics
|
|
client.subscribe("esp32/statusiqbal/mode");
|
|
client.subscribe("esp32/statusiqbal/pump");
|
|
client.subscribe("esp32/statusiqbal/light");
|
|
} else {
|
|
Serial.print("FAILED, rc=");
|
|
Serial.print(client.state());
|
|
Serial.println(" trying again in 5s...");
|
|
delay(5000);
|
|
}
|
|
}
|
|
}
|
|
|
|
void setup() {
|
|
Serial.begin(115200);
|
|
pinMode(RELAY1, OUTPUT);
|
|
pinMode(RELAY2, OUTPUT);
|
|
digitalWrite(RELAY1, RELAY_OFF);
|
|
digitalWrite(RELAY2, RELAY_OFF);
|
|
|
|
dht.begin();
|
|
setup_wifi();
|
|
|
|
// Konfigurasi waktu dari NTP
|
|
configTime(gmtOffset_sec, daylightOffset_sec, ntpServer);
|
|
|
|
client.setServer(mqtt_server, 1883);
|
|
client.setCallback(callback);
|
|
}
|
|
|
|
void loop() {
|
|
if (!client.connected()) {
|
|
reconnect();
|
|
}
|
|
client.loop();
|
|
|
|
unsigned long now = millis();
|
|
if (now - lastMsg > 2000) {
|
|
lastMsg = now;
|
|
|
|
float suhu = dht.readTemperature();
|
|
float kelembapan = dht.readHumidity();
|
|
|
|
if (isnan(suhu) || isnan(kelembapan)) {
|
|
Serial.println("Gagal baca DHT!");
|
|
return;
|
|
}
|
|
|
|
// ================= CONTROL LOGIC =================
|
|
if (isAutoMode) {
|
|
// Logic: <70% Pump ON, Lamp OFF | >90% Lamp ON, Pump OFF | 70-90% NORMAL (OFF/OFF)
|
|
if (kelembapan < 70.0) {
|
|
digitalWrite(RELAY1, RELAY_ON); // Pompa Hidup
|
|
digitalWrite(RELAY2, RELAY_OFF); // Lampu Mati
|
|
statusRelay = "KERING / PENYIRAMAN";
|
|
}
|
|
else if (kelembapan > 90.0) {
|
|
digitalWrite(RELAY1, RELAY_OFF); // Pompa Mati
|
|
digitalWrite(RELAY2, RELAY_ON); // Lampu Nyala
|
|
statusRelay = "TERLALU LEMBAB";
|
|
}
|
|
else {
|
|
digitalWrite(RELAY1, RELAY_OFF); // Pompa Mati
|
|
digitalWrite(RELAY2, RELAY_OFF); // Lampu Mati
|
|
statusRelay = "NORMAL";
|
|
}
|
|
} else {
|
|
// Manual Mode (App Based)
|
|
digitalWrite(RELAY1, manualPump ? RELAY_ON : RELAY_OFF);
|
|
digitalWrite(RELAY2, manualLight ? RELAY_ON : RELAY_OFF);
|
|
statusRelay = "MANUAL";
|
|
}
|
|
|
|
// ================= STATUS REPORTING =================
|
|
bool currentPump = (digitalRead(RELAY1) == RELAY_ON);
|
|
bool currentLight = (digitalRead(RELAY2) == RELAY_ON);
|
|
|
|
// Upload logic: Action transition OR Periodic (30 mins) if Normal
|
|
unsigned long nowMillis = millis();
|
|
bool actionDetected = (currentPump != prevPump || currentLight != prevLight);
|
|
|
|
// Interval 30 menit = 1800000 ms
|
|
bool isPeriodicTime = (nowMillis - lastPeriodicUpload >= 1800000);
|
|
|
|
if (actionDetected) {
|
|
Serial.println("[Reporting] Deteksi Perubahan Status!");
|
|
}
|
|
|
|
if (actionDetected || (statusRelay == "NORMAL" && isPeriodicTime)) {
|
|
String statusLampuUpload = currentLight ? (isAutoMode ? "MENYALA - OTOMATIS" : "MENYALA - MANUAL") : "MATI";
|
|
String statusPompaUpload = currentPump ? (isAutoMode ? "MENYALA - OTOMATIS" : "MENYALA - MANUAL") : "MATI";
|
|
|
|
Serial.println("[Reporting] Memulai Upload ke Supabase...");
|
|
uploadToSupabase(kelembapan, statusRelay, statusLampuUpload, statusPompaUpload);
|
|
lastPeriodicUpload = nowMillis;
|
|
}
|
|
|
|
// MQTT Reporting
|
|
client.publish("esp32/dht/suhu", String(suhu).c_str());
|
|
client.publish("esp32/dht/kelembapan", String(kelembapan).c_str());
|
|
client.publish("esp32/relay/status", statusRelay.c_str());
|
|
client.publish("esp32/statusiqbal/pump", currentPump ? "on" : "off", true);
|
|
client.publish("esp32/statusiqbal/light", currentLight ? "on" : "off", true);
|
|
client.publish("esp32/statusiqbal/mode", isAutoMode ? "auto" : "manual", true);
|
|
|
|
// Save states for next comparison
|
|
prevPump = currentPump;
|
|
prevLight = currentLight;
|
|
|
|
// Serial Debug
|
|
Serial.print("Mode: "); Serial.print(isAutoMode ? "AUTO" : "MANUAL");
|
|
Serial.print(" | Hum: "); Serial.print(kelembapan);
|
|
Serial.print("% | Pump: "); Serial.print(currentPump ? "ON" : "OFF");
|
|
Serial.print(" | Light: "); Serial.print(currentLight ? "ON" : "OFF");
|
|
Serial.print(" | Status: "); Serial.println(statusRelay);
|
|
}
|
|
} |