joe/PlatformIO_KitchenPIR
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Change various things including reboot when connection doesn't work and not delaying the loop when motion is detected

Browse Source
This commit is contained in:
Joe Tretter
2025-04-04 19:52:08 -05:00
parent 150a9aae20
commit 9a128704ff
1 changed files with 49 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

91
src/main.cpp
View File

@@ -6,7 +6,7 @@
const int PIR_PIN=23; const int PIR_PIN=23;
const char* ssid = "JoNelsDarlings"; const char* ssid = "JoNelsDarlings";
const char* password = "Paris2016"; const char* password = "Paris2016";
const char* mqtt_server = "mqtt.ddns.kawomi.com"; const char* mqttServerName = "mqtt.ddns.kawomi.com";
WiFiClient espClient; WiFiClient espClient;
PubSubClient mqttClient(espClient); PubSubClient mqttClient(espClient);
@@ -37,45 +37,19 @@ void setup_wifi() {
Serial.println(WiFi.localIP()); Serial.println(WiFi.localIP());
} }
void send_mqtt(String status, long minutes=0) {
void reconnect() {
// Loop until we're reconnected
while (!mqttClient.connected()) {
Serial.print("Attempting MQTT connection...");
// Create a random client ID
String clientId = "ESP32Client-";
clientId += String(random(0xffff), HEX);
// Attempt to connect
if (mqttClient.connect(clientId.c_str())) {
Serial.println("MQTT connected");
// Once connected, publish an announcement...
} else {
Serial.print("MQTT failed, rc=");
Serial.print(mqttClient.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
}
}
void send_mqtt(String status, long time_min=0) {
Serial.print("MQTT Send status "); Serial.print("MQTT Send status ");
Serial.print(status); Serial.print(status);
Serial.print(" mins "); Serial.print(" mins ");
Serial.println(time_min); Serial.println(minutes);
const size_t CAPACITY = JSON_OBJECT_SIZE(1); JsonDocument doc;
StaticJsonDocument<CAPACITY> doc;
// create an object
JsonObject object = doc.to<JsonObject>(); JsonObject object = doc.to<JsonObject>();
object["status"] = status.c_str(); object["status"] = status.c_str();
if (time_min > 0) { if (minutes > 0) {
object["minutes"] = time_min; object["minutes"] = minutes;
} }
// serialize the object and send the result to Serial
static char sensorStatus[150]; static char sensorStatus[150];
serializeJson(doc, sensorStatus); serializeJson(doc, sensorStatus);
Serial.println(sensorStatus); Serial.println(sensorStatus);
@@ -83,6 +57,34 @@ void send_mqtt(String status, long time_min=0) {
mqttClient.publish("Address/Livorno/Kitchen/PIR", sensorStatus, true); mqttClient.publish("Address/Livorno/Kitchen/PIR", sensorStatus, true);
} }
void reconnect() {
int numRetries=0;
while (!mqttClient.connected()) {
numRetries++;
Serial.print("Attempting MQTT connection...");
// Create a random client ID
String clientId = "ESP32Client-";
clientId += String(random(0xffff), HEX);
if (mqttClient.connect(clientId.c_str())) {
Serial.println("MQTT connected");
} else {
Serial.print("MQTT failed, rc=");
Serial.print(mqttClient.state());
Serial.println(" try again in 5 seconds");
if (numRetries>5){
Serial.println("Too many retries, restarting the ESP...");
ESP.restart();
}
delay(5000);
}
}
send_mqtt("ready");
}
void setup() { void setup() {
pinMode(LED_BUILTIN,OUTPUT); pinMode(LED_BUILTIN,OUTPUT);
@@ -90,13 +92,14 @@ void setup() {
Serial.begin(115200); Serial.begin(115200);
setup_wifi(); setup_wifi();
mqttClient.setServer(mqtt_server, 1883); const int mqttPort=1883;
mqttClient.setServer(mqttServerName, mqttPort);
} }
const int millisPerSecond=1000;
long previousMotionMillis=millis(); long previousMotionMillis=millis();
short previousState=digitalRead(PIR_PIN); short previousState=0;
long previousNoMoNotifyMins=0; long previousNoMoNotifyMinutes=0;
void loop() { void loop() {
if (!mqttClient.connected()) { if (!mqttClient.connected()) {
reconnect(); reconnect();
@@ -112,17 +115,21 @@ void loop() {
if (currentState == HIGH) { if (currentState == HIGH) {
send_mqtt("motion"); send_mqtt("motion");
digitalWrite(LED_BUILTIN,HIGH); digitalWrite(LED_BUILTIN,HIGH);
delay(5000);
digitalWrite(LED_BUILTIN,LOW);
previousMotionMillis=millis(); previousMotionMillis=millis();
} }
previousState = currentState; previousState = currentState;
} }
long minsSinceLastMotion=(millis()-previousMotionMillis)/(1000*60); const int secondsPerMinute=60;
if ((previousNoMoNotifyMins != minsSinceLastMotion) && (0 != minsSinceLastMotion)) { long minutesSinceLastMotion=(millis()-previousMotionMillis)/(millisPerSecond*secondsPerMinute);
send_mqtt("no_motion",minsSinceLastMotion); if ((previousNoMoNotifyMinutes != minutesSinceLastMotion) && (0 != minutesSinceLastMotion)) {
previousNoMoNotifyMins = minsSinceLastMotion; send_mqtt("no_motion",minutesSinceLastMotion);
previousNoMoNotifyMinutes = minutesSinceLastMotion;
}
const int ledDelaySeconds=5;
if ((millis()-previousMotionMillis)/(millisPerSecond) >= ledDelaySeconds) {
digitalWrite(LED_BUILTIN,LOW);
} }
delay(20); delay(20);