Nun zur Abrundung dieser Serie ein einfaches preiswertes Gerät auf Basis ESP8266 mit einem oder zwei DS18B20 Temperatursensoren. Da das Gerät nur alle 5 Minuten für wenige Millisekunden aktiv ist, kann es sehr gut mit Batterien betrieben werden. Die Batterie auf der Abbildung ist symbolisch. Wenn man den +5V Pin des D1-Mini benutzt um den eingebauten Spannungsregler auf 3.3 V zu nutzen, braucht man mindestens 3 Batterien mit je 1.5 V.
Achtung! Die orangfarbene Drahtverbindung dient zum Wecken aus dem Schlafmodus und muss zum Flashen entfernt werden.
Nun der Code:
Für die endgültige Version, die man mit Batterie betreiben möchte, sollte das DEBUG Flag auf false gesetzt werden.
/* WLAN Temperatursensor ESP Now zum MQTT-Gateway Wenn noch keine MAC Adresse ermittelt wurde sucht der Sensor ein WLAN mit SSID MQTTGateway Wenn er den AP gefunden hat, merkt er sich die MAC Adresse solange die Stromversorgung nicht unterbrochen wurde Das ESP Now Protokoll ist sehr schnell sodass nur sehr kurze Zeit (us) höherer Strom fließt. Der Sensor sendet Temperaturdaten und geht dann für 5 Minuten in den Tiefschlaf sodass nur ganz wenig Energie verbraucht wird und der Sensor daher mit Batterien betrieben werden kann. */ //Bibliothek für WiFi #include <ESP8266WiFi.h> //Bibliotheken für Temperatursensor DS18B20 #include <OneWire.h> #include <DallasTemperature.h> #include <CayenneLPP.h> //Bibliothek für ESP Now extern "C" { #include <espnow.h> } //SSID des Gateways #define GW_SSID "MQTTGateway" //Debug Flag wenn false werden alle Debug Meldungen unterdrückt //um zusätzlich Strom zu sparen #define DEBUG true //Konstanten für WiFi #define SEND_TIMEOUT 2000 // 2 Sekunden timeout //Kanalzuordnung #define CHANNEL_TEMPI 1 #define CHANNEL_TEMPE 2 //Pins für Temperatursensoren const byte bus_int = 2; //GPIO2 const byte bus_ext = 4; //GPIO4 //Datenstruktur für das Rtc Memory mit Prüfsumme um die Gültigkeit //zu überprüfen damit wird die MAC Adresse gespeichert struct MEMORYDATA { uint32_t crc32; uint8_t mac[6]; uint32_t channel; }; //Globale daten volatile bool callbackCalled; //Speicher für Temperaturwerte float temp_int = 0; float temp_ext = 0; boolean has_int = 0; boolean has_ext = 0; //MAC Adresse und WLAN Kanal MEMORYDATA statinfo; //buffer für daten im LPP Format CayenneLPP lpp(64); //Bus zu den Sensoren OneWire oneWire_int(bus_int); OneWire oneWire_ext(bus_ext); DallasTemperature sensoren_int(&oneWire_int); DallasTemperature sensoren_ext(&oneWire_ext); //Array um Sensoradressen zu speichern DeviceAddress adressen_int; DeviceAddress adressen_ext; //Unterprogramm zum Berechnen der Prüfsumme uint32_t calculateCRC32(const uint8_t *data, size_t length) { uint32_t crc = 0xffffffff; while (length--) { uint8_t c = *data++; for (uint32_t i = 0x80; i > 0; i >>= 1) { bool bit = crc & 0x80000000; if (c & i) { bit = !bit; } crc <<= 1; if (bit) { crc ^= 0x04c11db7; } } } return crc; } //Schreibt die Datenstruktur statinfo mit korrekter Prüfsumme in das RTC Memory void UpdateRtcMemory() { uint32_t crcOfData = calculateCRC32(((uint8_t*) &statinfo) + 4, sizeof(statinfo) - 4); statinfo.crc32 = crcOfData; ESP.rtcUserMemoryWrite(0,(uint32_t*) &statinfo, sizeof(statinfo)); } //sucht nach einem geeigneten AccessPoint void ScanForSlave() { bool slaveFound = 0; int8_t scanResults = WiFi.scanNetworks(); // reset on each scan if (DEBUG) Serial.println("Scan done"); if (scanResults == 0) { if (DEBUG) Serial.println("No WiFi devices in AP Mode found"); } else { if (DEBUG) Serial.print("Found "); if (DEBUG) Serial.print(scanResults); if (DEBUG) Serial.println(" devices "); for (int i = 0; i < scanResults; ++i) { // Print SSID and RSSI for each device found String SSID = WiFi.SSID(i); int32_t RSSI = WiFi.RSSI(i); int32_t chl = WiFi.channel(i); String BSSIDstr = WiFi.BSSIDstr(i); if (DEBUG) { Serial.print(i + 1); Serial.print(": "); Serial.print(SSID); Serial.print(" /"); Serial.print(chl); Serial.print(" ("); Serial.print(RSSI); Serial.print(")"); Serial.println(""); } delay(10); // Check if the current device starts with `Thermometer` if (SSID == GW_SSID) { // SSID of interest if (DEBUG) { Serial.println("Found a Slave."); Serial.print(i + 1); Serial.print(": "); Serial.print(SSID); Serial.print(" ["); Serial.print(BSSIDstr); Serial.print("]"); Serial.print(" ("); Serial.print(RSSI); Serial.print(")"); Serial.println(""); } int mac[6]; // wir ermitteln die MAC Adresse und speichern sie im RTC Memory if ( 6 == sscanf(BSSIDstr.c_str(), "%x:%x:%x:%x:%x:%x%c", &mac[0], &mac[1], &mac[2], &mac[3], &mac[4], &mac[5] ) ) { for (int ii = 0; ii < 6; ++ii ) { statinfo.mac[ii] = (uint8_t) mac[ii]; } statinfo.channel = chl; UpdateRtcMemory(); } slaveFound = 1; //Nachdem der AP gefunden wurde können wir abbrechen break; } } } if (DEBUG) { if (slaveFound) { Serial.println("Slave Found, processing.."); } else { Serial.println("Slave Not Found, trying again."); } } // RAM freigeben WiFi.scanDelete(); } // function um eine Sensoradresse zu drucken void printAddress(DeviceAddress adressen) { for (uint8_t i = 0; i < 8; i++) { if (adressen[i] < 16) Serial.print("0"); Serial.print(adressen[i], HEX); } } //Unterprogramm zum Initialisieren der DS18B20 Sensoren boolean initDS18B20(uint8_t pin, DallasTemperature sensor, DeviceAddress address ) { boolean found = 0; pinMode(pin,INPUT_PULLUP); sensoren_int.begin(); if (DEBUG) { Serial.print(sensor.getDeviceCount(), DEC); Serial.println(" Sensoren gefunden."); } //Nun prüfen wir ob einer der Sensoren am Bus ein Temperatur Sensor ist if (!sensor.getAddress(address,0)) { if (DEBUG) Serial.println("Kein Temperatursensor vorhanden!"); } else { //adressen anzeigen if (DEBUG) { Serial.print("Adresse: "); printAddress(address); Serial.println(); } //Nun setzen wir noch die gewünschte Auflösung (9, 10, 11 oder 12 bit) sensor.setResolution(address,10); //Zur Kontrolle lesen wir den Wert wieder aus if (DEBUG) { Serial.print("Auflösung = "); Serial.print(sensor.getResolution(address), DEC); Serial.println(); } //Temperaturmessung starten sensor.requestTemperatures(); // Commando um die Temperaturen auszulesen found = 1; } return found; } void setup() { uint8_t buf[70]; //sendebuffer if (DEBUG) { Serial.begin(115200); Serial.println("Start"); } //eigene MAC Adresse ermitteln und als Geräte-Id im Sendespeicher ablegen String strmac = WiFi.macAddress(); if (DEBUG) { Serial.print("Meine MAC Adresse = "); Serial.println(strmac); } int imac[6]; sscanf(strmac.c_str(), "%x:%x:%x:%x:%x:%x%c", &imac[0], &imac[1], &imac[2], &imac[3], &imac[4], &imac[5] ); for (uint8_t ii = 0; ii<6; ii++) buf[ii]=imac[ii]; if (DEBUG) { Serial.println("Interne Sensoren"); } has_int = initDS18B20(bus_int,sensoren_int,adressen_int); if (DEBUG) { Serial.println("Externe Sensoren"); } has_ext = initDS18B20(bus_ext,sensoren_ext,adressen_ext); //Wir lesen aus dem RTC Memory ESP.rtcUserMemoryRead(0, (uint32_t*) &statinfo, sizeof(statinfo)); if (DEBUG) Serial.println("RTC Done"); uint32_t crcOfData = calculateCRC32(((uint8_t*) &statinfo) + 4, sizeof(statinfo) - 4); WiFi.mode(WIFI_STA); // Station mode for esp-now sensor node if (DEBUG) Serial.println("WifiMode"); if (statinfo.crc32 != crcOfData) { //wir haben keine gültige MAC Adresse if (DEBUG) Serial.println("Scan vor Slave"); ScanForSlave(); //for (uint8_t i = 0; i<6;i++) statinfo.mac[i] = gwmac[i]; if (DEBUG) { Serial.printf("This mac: %s, ", WiFi.macAddress().c_str()); Serial.printf("target mac: %02x%02x%02x%02x%02x%02x", statinfo.mac[0], statinfo.mac[1], statinfo.mac[2], statinfo.mac[3], statinfo.mac[4], statinfo.mac[5]); Serial.printf(", channel: %i\n", statinfo.channel); } } if (esp_now_init() != 0) { if (DEBUG) Serial.println("*** ESP_Now init failed"); ESP.restart(); } //ESP Now Controller WiFi.setAutoConnect(false); esp_now_set_self_role(ESP_NOW_ROLE_CONTROLLER); uint8_t ch = esp_now_get_peer_channel(statinfo.mac); Serial.printf("Channel = %i\r\n",ch); //Peer Daten initialisieren int res = esp_now_add_peer(statinfo.mac, ESP_NOW_ROLE_CONTROLLER, 1, NULL, 0); if (res==0) Serial.println("Erfolgreich gepaart"); //wir registrieren die Funktion, die nach dem Senden aufgerufen werden soll esp_now_register_send_cb([](uint8_t* mac, uint8_t sendStatus) { if (DEBUG) { Serial.print("send_cb, status = "); Serial.print(sendStatus); Serial.print(", to mac: "); char macString[50] = {0}; sprintf(macString,"%02X:%02X:%02X:%02X:%02X:%02X", statinfo.mac[0], statinfo.mac[1], statinfo.mac[2], statinfo.mac[3], statinfo.mac[4], statinfo.mac[5]); Serial.println(macString); } callbackCalled = true; }); //Flag auf false setzen callbackCalled = false; //Temperaturmessung starten if (has_int) sensoren_int.requestTemperatures(); if (has_ext) sensoren_ext.requestTemperatures(); delay(750); //750 ms warten bis die Messung fertig ist //Temperaturwert holen und in Datenstruktur zum Senden speichern if (has_int) temp_int = sensoren_int.getTempC(adressen_int); if (has_ext) temp_ext = sensoren_ext.getTempC(adressen_ext); //Buffer löschen lpp.reset(); //Datenpakete in den Buffer schreiben if (has_int) lpp.addTemperature(CHANNEL_TEMPI, temp_int); if (has_ext) lpp.addTemperature(CHANNEL_TEMPE, temp_ext); uint8_t sz = lpp.getSize(); //Datenstruktur in den Sendebuffer kopieren memcpy(&buf[6], lpp.getBuffer(), sz); //Daten an Thermometer senden esp_now_send(NULL, buf, sz+6); // NULL means send to all peers if (DEBUG) { Serial.print("Interne Temperatur: "); Serial.print(temp_int); Serial.println("°C"); Serial.print("Externe Temperatur: "); Serial.print(temp_ext); Serial.println("°C"); } } void loop() { //warten bis Daten gesendet wurden if (callbackCalled || (millis() > SEND_TIMEOUT)) { if (DEBUG) Serial.println("Sleep"); delay(100); //Für 300 Sekunden in den Tiefschlafmodus //dann erfolgt ein Reset und der ESP8266 wird neu gestartet //Daten im RTC Memory werden beim Reset nicht gelöscht. ESP.deepSleep(300E6); } }
Nachdem Das Gerät gestartet wurde, sollten wir es auf der Web-Seite des Gateways sehen.
Wir können dem Gerät einen Namen geben und es registrieren.
Das Gerät hat die Gerätenummer 1 erhalten daher die Kanäle 8 bis 15. Der Kanal 1 des Gerätes ist also Kanal 9. Nach kurzer Zeit sollten wir im Cayenne Dashboard die beiden neuen Kanäle (oder nur einen wenn nur ein Temperatursensor angeschlossen wurde) sehen.
Nun kann man die beiden Widgets für Kanal 9 und Kanal 10 hinzufügen und nach Wunsch anpassen.
Viel Spaß beim Nachbau
