-
Notifications
You must be signed in to change notification settings - Fork 8
/
Copy pathMQTTDevice4.ino
179 lines (157 loc) · 6.08 KB
/
MQTTDevice4.ino
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
// Author: Innuendo
//
// Kommunikation via MQTT mit CraftBeerPi v4
// Unterstützung für DS18B20 Sensoren
// Unterstützung für PT100/PT1000 Sensoren
// Unterstützung für GPIO Aktoren
// Unterstützung für GGM IDS2 Induktionskochfeld
// Unterstützung für Web Update
// Unterstützung für Nextion Touchdisplay
#if defined(ESP8266)
#pragma message "/// ESP8266 ///"
#elif defined(ESP32)
#pragma message "/// ESP32 ///"
#endif
#include <OneWire.h> // OneWire Bus Kommunikation
#include <DallasTemperature.h> // Vereinfachte Benutzung der DS18B20 Sensoren
#include <Adafruit_MAX31865.h>
#ifdef ESP32
#include <WiFi.h> // Generelle WiFi Funktionalität
#include <WebServer.h> // Unterstützung Webserver
#include <HTTPUpdateServer.h> // DateiUpdate
#include <ESPmDNS.h> // mDNS
#include <HTTPClient.h>
#include <HTTPUpdate.h>
// #include <WiFiClientSecure.h>
#elif ESP8266
#include <ESP8266WiFi.h> // Generelle WiFi Funktionalität
#include <ESP8266WebServer.h> // Unterstützung Webserver
#include <ESP8266HTTPUpdateServer.h> // DateiUpdate
#include <ESP8266mDNS.h> // mDNS
#include <ESP8266HTTPClient.h>
#include <ESP8266httpUpdate.h>
#include <WiFiClientSecure.h>
#endif
#include <WiFiUdp.h> // WiFi
#include <WiFiManager.h> // WiFiManager zur Einrichtung
#include <DNSServer.h> // Benötigt für WiFiManager
#include <LittleFS.h> // Dateisystem
#include <FS.h> // Files
#include <ArduinoJson.h> // Lesen und schreiben von JSON Dateien
#include <NTPClient.h> // Uhrzeit
#include <Ticker.h>
#include <PubSubClient.h> // MQTT Kommunikation
#include <SoftwareSerial.h> // Serieller Port für Display
#include "InnuTicker.h" // Bibliothek für Hintergrund Aufgaben (Tasks)
#include "NextionX2.h" // Display Nextion
#include "index_htm.h"
#include "edit_htm.h"
#include "MQTTDevice.h"
// Sensoren
OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature DS18B20(&oneWire);
// IDS2 Interrupt
volatile uint8_t newError = 0; // Fehlercode IDS als Integer
uint8_t oldError = 0;
// portMUX_TYPE errCode = portMUX_INITIALIZER_UNLOCKED;
// WiFi und MQTT
#ifdef ESP32
WebServer server(80);
HTTPUpdateServer httpUpdateServer; // DateiUpdate
#elif ESP8266
WiFiEventHandler wifiConnectHandler, wifiDisconnectHandler;
ESP8266WebServer server(80);
MDNSResponder mdns;
ESP8266HTTPUpdateServer httpUpdate; // DateiUpdate
#endif
WiFiManager wifiManager;
WiFiClient espClient;
PubSubClient pubsubClient(espClient);
#define SSE_MAX_CHANNELS 8 // 8 SSE clients subscription erlaubt
#define PORT 80
struct SSESubscription
{
IPAddress clientIP;
WiFiClient client;
Ticker keepAliveTimer;
bool check = false;
} subscription[SSE_MAX_CHANNELS];
uint8_t subscriptionCount = 0;
// Variablen
#ifdef ESP32
#define NUMBEROFSENSORSMAX 6 // Maximale Anzahl an Sensoren
#define NUMBEROFACTORSMAX 15 // Maximale Anzahl an Aktoren
#elif ESP8266
#define NUMBEROFSENSORSMAX 3 // Maximale Anzahl an Sensoren
#define NUMBEROFACTORSMAX 10 // Maximale Anzahl an Aktoren
#endif
int64_t DUTYCYLCE = 5000; // Aktoren und HLT
uint16_t SENCYLCE = 1; // Aktoren und HLT
bool senRes = false;
bool startSPI = false;
uint8_t numberOfActors = 0; // Gesamtzahl der Aktoren
uint8_t numberOfSensors = 0; // Gesamtzahl der Sensoren
unsigned char addressesFound[NUMBEROFSENSORSMAX][8];
#define DEF_DELAY_IND 120000 // Standard Nachlaufzeit nach dem Ausschalten Induktionskochfeld
#define maxHostSign 20
#define maxUserSign 10
#define maxPassSign 10
char mqtthost[maxHostSign]; // MQTT Server
char mqttuser[maxUserSign];
char mqttpass[maxPassSign];
int mqttport;
char mqtt_clientid[maxHostSign]; // AP-Mode und Gerätename
// Zeitserver Einstellungen
#define NTP_OFFSET 60 * 60 // Offset Winterzeit in Sekunden
#define NTP_INTERVAL 60 * 60 * 1000 // Aktualisierung NTP in ms
#define NTP_ADDRESS "europe.pool.ntp.org" // NTP Server
char ntpServer[maxHostSign] = NTP_ADDRESS;
WiFiUDP ntpUDP;
NTPClient timeClient(ntpUDP, NTP_ADDRESS, NTP_OFFSET, NTP_INTERVAL);
// Event handling Status Variablen
bool StopOnMQTTError = false; // Event handling für MQTT Fehler
unsigned long mqttconnectlasttry; // Zeitstempel bei Fehler MQTT
bool mqtt_state = true; // Status MQTT
uint8_t wlanStatus = 0;
// Ticker Objekte
InnuTicker TickerSen;
InnuTicker TickerAct;
InnuTicker TickerInd;
InnuTicker TickerMQTT;
InnuTicker TickerDisp;
InnuTicker TickerPUBSUB;
// Event handling Standard Verzögerungen
unsigned long wait_on_error_mqtt = 120000; // How long should device wait between tries to reconnect WLAN - approx in ms
unsigned long wait_on_Sensor_error_actor = 120000; // How long should actors wait between tries to reconnect sensor - approx in ms
unsigned long wait_on_Sensor_error_induction = 120000; // How long should induction wait between tries to reconnect sensor - approx in ms
// Systemstart
bool startMDNS = true; // Standard mDNS Name ist ESP8266- mit mqtt_chip_key
char nameMDNS[maxHostSign] = "MQTTDevice";
bool shouldSaveConfig = false; // WiFiManager
bool alertState = false; // WebUpdate Status
bool devBranch = false; // Check out development branch
unsigned long lastSenAct = 0; // Timestap actors on sensor error
unsigned long lastSenInd = 0; // Timestamp induction on sensor error
int8_t sensorsStatus = 0;
int8_t actorsStatus = 0;
bool inductionStatus = false;
bool fermenterStatus = false;
// bool startBuzzer = false; // Aktiviere Buzzer
bool mqttBuzzer = false; // MQTTBuzzer für CBPi4
int8_t selLang = 0; // Sprache
// Display Next
#define NUMBEROFPAGES 3
bool useDisplay = false;
bool useFerm = false;
int startPage = 0; // Startseite: BrewPage = 0 Kettlepage = 1 InductionPage = 2
int activePage = 0; // die aktuell angezeigte Seite
int tempPage = -1; // die aktuell angezeigte Seite
// FSBrowser
File fsUploadFile; // a File object to temporarily store the received file
void configModeCallback(WiFiManager *myWiFiManager)
{
Serial.print("*** SYSINFO: MQTTDevice in AP mode ");
Serial.println(WiFi.softAPIP());
Serial.print("*** SYSINFO: Start configuration portal ");
Serial.println(myWiFiManager->getConfigPortalSSID());
}