Xiaomi Mijia lywsd03mmc
Aus sichardt
Version vom 29. August 2023, 20:14 Uhr von Gabriel (Diskussion | Beiträge)
Xiaomi Mijia lywsd03mmc
ESP32 Code:
//#include <BLEDevice.h>
#include "NimBLEDevice.h"//needs about 50% ROM of std BLEDevice.h include
#include <SimpleTimer.h>
#include <WiFi.h>
#include <WiFiClientSecure.h>
#include <HTTPClient.h>
#define ssid "yourSSID"
#define password "yourPSK"
const char* host = "https://yourserver.net/folder/";
String post_request;
unsigned int wifi_start;
unsigned int t_sleep;
float temp,humi;
String addr="00:00:00:00:00:00";
BLEClient* pClient;
bool connectionSuccessful = false;
// The remote service we wish to connect to.
static BLEUUID serviceUUID("ebe0ccb0-7a0a-4b0c-8a1a-6ff2997da3a6");
// The characteristic of the remote service we are interested in.
static BLEUUID charUUID("ebe0ccc1-7a0a-4b0c-8a1a-6ff2997da3a6");
//prototypes
int wifi_getAddr(int id);
void ble();
int wifi_post(int id);
//wifi functions
void initWiFi() {
WiFi.mode(WIFI_STA);
wifi_start=millis();
WiFi.begin(ssid, password);
Serial.print("Connecting to WiFi ..");
while (WiFi.status() != WL_CONNECTED) {
Serial.print('.');
delay(1000);
}
Serial.println(WiFi.localIP());
}
//ESP main functions
void setup() {
Serial.begin(9600);
}
void loop() {
for (int id=1;id<99;id++){
wifi_getAddr(id);
if(addr=="end" or addr=="00:00:00:00:00:00"){
Serial.println("no valid MIJIA address...");
break;
}
Serial.println(id);
ble();
delay(15000);
if(connectionSuccessful == true){
wifi_post(id);
}else{
Serial.print("could not get data from ");Serial.println(addr);
}
}
Serial.println("sleeping for approx. 25 minutes.");
delay(25*60*1000);
}
//Bluetooth functions
void ble(){
connectionSuccessful = false;
//ble_addr_t baddr = ble_addr_t(addr);
static BLEAddress htSensorAddress(addr.c_str());
Serial.print("Starting MJ client. addr: "); Serial.println(addr);
delay(750);
BLEDevice::init("ESP32");
createBleClientWithCallbacks();
delay(750);
connectSensor(htSensorAddress);
registerNotification();
}
class MyClientCallback : public BLEClientCallbacks {
void onConnect(BLEClient* pclient) {
Serial.println("Connected");
}
void onDisconnect(BLEClient* pclient) {
Serial.println("Disconnected");
if (!connectionSuccessful) {
Serial.println("RESTART");
ESP.restart();
}
}
};
void createBleClientWithCallbacks() {
pClient = BLEDevice::createClient();
pClient->setClientCallbacks(new MyClientCallback());
}
void connectSensor(BLEAddress htSensorAddress) {
pClient->connect(htSensorAddress);
//connectionSuccessful = true;
}
static void notifyCallback(
BLERemoteCharacteristic* pBLERemoteCharacteristic,
uint8_t* pData,
size_t length,
bool isNotify) {
Serial.print("Notify callback for characteristic ");
Serial.println(pBLERemoteCharacteristic->getUUID().toString().c_str());
temp = (pData[0] | (pData[1] << 8)) * 0.01; //little endian
humi = pData[2];
Serial.printf("temp = %.1f : humidity = %.1f \n", temp, humi);
connectionSuccessful = true;
pClient->disconnect();
// BLEDevice::deinit();
}
void registerNotification() {
// Obtain a reference to the service we are after in the remote BLE server.
BLERemoteService* pRemoteService = pClient->getService(serviceUUID);
if (pRemoteService == nullptr) {
Serial.print("Failed to find our service UUID: ");
Serial.println(serviceUUID.toString().c_str());
pClient->disconnect();
return;
}
Serial.println(" - Found our service");
// Obtain a reference to the characteristic in the service of the remote BLE server.
BLERemoteCharacteristic* pRemoteCharacteristic = pRemoteService->getCharacteristic(charUUID);
if (pRemoteCharacteristic == nullptr) {
Serial.print("Failed to find our characteristic UUID: ");
Serial.println(charUUID.toString().c_str());
pClient->disconnect();
return;
}
Serial.println(" - Found our characteristic");
pRemoteCharacteristic->registerForNotify(notifyCallback);
}
//server connection functions
int wifi_post(int id){
WiFiClientSecure wificlient;
initWiFi();
HTTPClient https;
wificlient.setInsecure();//do not check certificate fingerprint
bool dbg_serial=true;
bool error = false;
while (WiFi.status() != WL_CONNECTED) { //No WIFI yet? Wait.
if (WiFi.status() == WL_CONNECT_FAILED) {
error = true;
break;
}
if (millis() - wifi_start > 30000) {
error = true;
break;
}
delay(500); if (dbg_serial) {
Serial.print(".");HTTPClient https;
}
}
if (dbg_serial) {
if (WiFi.status() == WL_CONNECTED) {
Serial.println("");
Serial.println("Connected to " + String(ssid) + " with IP address " + WiFi.localIP().toString() );
}
if (WiFi.status() != WL_CONNECTED) {
Serial.println("");
Serial.println("Error: No WIFI connection");
}
}
if (error) {
return 0;
}
post_request="t_rh.php?dummy=0&t="+String(temp)+"&rh="+String(humi)+"&id="+String(id);
https.begin(wificlient, host+post_request); //request destination
https.addHeader("Content-Type", "application/x-www-form-urlencoded"); //content-type header
int httpCode = https.POST(post_request); //send request
delay(150); //wait for ack packet
if ( httpCode != 200 ) {
error = true;
// warn = true;
}
if (dbg_serial) {
Serial.println("requesting: " + post_request);
Serial.println("HTTP Status: " + httpCode );
String response = https.getString();
response.trim();//I get a leading linebreak, therefore trim the results (removes leading and trailing whitespaces)
Serial.println("response: " + response ); //Print request response payload
}
https.end(); //close connection
return httpCode;
}
//=================GET NEW MIJIA ADDRESS FROM SERVER =========================================
int wifi_getAddr(int id){
//new address, so reset t and rh
temp=-99; humi=-99;
addr="00:00:00:00:00:00";
WiFiClientSecure wificlient;
initWiFi();
HTTPClient https;
wificlient.setInsecure();//do not check certificate fingerprint
bool dbg_serial=true;
bool error = false;
while (WiFi.status() != WL_CONNECTED) { //No WIFI yet? Wait.
if (WiFi.status() == WL_CONNECT_FAILED) {
error = true;
break;
}
if (millis() - wifi_start > 30000) {
error = true;
break;
}
delay(500); if (dbg_serial) {
Serial.print(".");HTTPClient https;
}
}
if (dbg_serial) {
if (WiFi.status() == WL_CONNECTED) {
Serial.println("");
Serial.println("Connected to " + String(ssid) + " with IP address " + WiFi.localIP().toString() );
}
if (WiFi.status() != WL_CONNECTED) {
Serial.println("");
Serial.println("Error: No WIFI connection");
}
}
if (error) {
return 1;
}
post_request="sensoren.php?dummy=0&id="+String(id)+"&type=addr";
https.begin(wificlient, host+post_request); //request destination
https.addHeader("Content-Type", "application/x-www-form-urlencoded"); //content-type header
int httpCode = https.POST(post_request); //send request
delay(150); //wait for ack packet
if ( httpCode != 200 ) {
error = true;
// warn = true;
}
if (dbg_serial) {
Serial.println("requesting: " + post_request);
Serial.println("HTTP Status: " + httpCode );
String response = https.getString();
response.trim();//I get a leading linebreak, therefore trim the results (removes leading and trailing whitespaces)
Serial.println("response: " + response ); //Print request response payload
addr=response.c_str();
}
https.end(); //close connection
return httpCode;
}
boolean isInteger(String str) {
for (byte i = 0; i < str.length(); i++)
{
Serial.println("char " + String(i) + ": " + String(str.charAt(i)));
if (!isDigit(str.charAt(i))) return false;
}
return true;
}
Database structure:
Current database: innenklima
mysql> show tables;
+----------------------+
| Tables_in_innenklima |
+----------------------+
| Bad |
| Dachboden |
| Gaestezimmer |
...
+----------------------+
12 rows in set (0,01 sec)
mysql> describe Bad;
+-------------+-------+------+-----+---------+-------+
| Field | Type | Null | Key | Default | Extra |
+-------------+-------+------+-----+---------+-------+
| timestamp | int | NO | PRI | NULL | |
| temperature | float | YES | | NULL | |
| humidity | float | YES | | NULL | |
| abshumidity | float | YES | | NULL | |
+-------------+-------+------+-----+---------+-------+
4 rows in set (0,05 sec)
webserver files:
sensoren.php
<?php
require_once __DIR__ . '/dicts.php';
#for t_rh.php
function nameFromID($id){
return $names[$id];
}
function readNextId(){
$filename = 'next.txt';
return intval(file_get_contents($filename));
}
function incrementId($id,$addr){
$filename = 'next.txt';
$f = fopen($filename, 'w');
if($addr[$id]=="end" or count($addr)<=($id)){
$n=1;
}else{
$n=$id+1;
}
fwrite($f,$n);
fclose($f);
}
#for ESP32 https call
if($_POST["type"]=="addr"){
$id=readNextId();
echo ($addr[$id]);
incrementId($id,$addr);
}else{
echo($names[$_GET["id"]]);
echo "<br>";
echo($addr[$_GET["id"]]);
}
?>
dicts.php:
<?php
$names=array(
1=>"Dachboden",
2=>"Wintergarten",
3=>"Bad",
4=>"Wohnzimmer",
5=>"Gaestezimmer",
6=>"Naehzimmer",
7=>"Schlafzimmer",
8=>"Waschkueche",
9=>"Kueche",
10=>"KuecheUnten",
11=>"Garage",
12=>"end"
);
$addr=array(
1=>"A4:C1:38:EB:2C:14",
2=>"A4:C1:38:FF:28:B4",
3=>"A4:C1:38:2A:CE:FE",
4=>"A4:C1:38:B1:21:FD",
5=>"A4:C1:38:98:C1:16",
6=>"A4:C1:38:CE:B6:5D",
7=>"A4:C1:38:B6:80:4C",
8=>"A4:C1:38:5E:55:5E",
9=>"A4:C1:38:09:5C:AF",
10=>"A4:C1:38:AE:ED:3C",
11=>"A4:C1:38:0D:0B:54",
12=>"end"
);
#for t_rh.php
#for ESP32 https call
if($_POST["type"]=="addr"){
echo ($addr[$_POST["id"]]);
}else{
#echo($names[$_GET["id"]]);
#echo "<br>";
#echo($addr[$_GET["id"]]);
}
?>
abshum.php:
<?php
function saturationpressure($T){
return 611.2*exp(17.62*$T/(243.12+$T));//in Pascal. T in °C
}
function abshum($rh, $T){
$gasconst=8.314462618;//J/mol/K
$molweight=18.01528;//g/mol
$vaporpressure=$rh/100.0*saturationpressure($T);
$abshum=$molweight/$gasconst*$vaporpressure/($T+273.15);
return ($abshum);//g/m³
}
?>
t_rh.php:
<?php
function createTable($sensorname){
$statement = "CREATE TABLE IF NOT EXISTS ".$sensorname." (timestamp int NOT NULL, temperature float, humidity float, abshumidity float, PRIMARY KEY (timestamp));";
execSQL($statement);
}
require_once("abshum.php");
function insertValues($sensorname, $timestamp, $temperature, $humidity){
if($temperature < -988888888 ){
return;
}
$statement = "INSERT INTO ".$sensorname." (timestamp, temperature, humidity, abshumidity) VALUES (".$timestamp.", ".$temperature.", ".$humidity.", ".abshum($humidity,$temperature).");";
execSQL($statement);
}
function execSQL($statement){
$mysqli= new mysqli("host", "user", "password", "DB");
$result=$mysqli->query($statement);
}
$tstamp=time();
require_once __DIR__ . '/dicts.php';
$filename = 'next.txt';
$id=intval(file_get_contents($filename));
$sensorname=$names[$id-1];
if($sensorname != "end"){
createTable($sensorname);
insertValues($sensorname, $tstamp, $_POST["t"], $_POST["rh"]);
}
#echo($_POST["rh"]);
#echo($_POST["addr"]);
?>
