openhabforum.de

Code: Alles auswählen

    Thing topic sp11101 "Gosund SP111 01"       @ "MQTT2" {
    Channels:
        Type switch : power     "Power "                 [ stateTopic="stat/gosundsp111_01/POWER", commandTopic="cmnd/gosundsp111_01/POWER" ]
        Type number : rssi      "WiFi Signal Strength"   [ stateTopic="tele/gosundsp111_01/STATE", transformationPattern="JSONPATH:$.Wifi.RSSI"]
        Type string : version   "Firmware Version    "   [ stateTopic="stat/gosundsp111_01/STATUS2", transformationPattern="JSONPATH:$.StatusFWR.Version"]
        Type switch : reachable "Reachable"              [ stateTopic="tele/gosundsp111_01/LWT",transformationPattern="MAP:reachable.map" ]
        Type string : hardware  "Chip Set            "   [ stateTopic="stat/gosundsp111_01/STATUS2", transformationPattern="JSONPATH:$.StatusFWR.Hardware"]
        Type string : ipaddress "IP Address          "   [ stateTopic="stat/gosundsp111_01/STATUS5", transformationPattern="JSONPATH:$.StatusNET.IPAddress"]
        Type number : powerload "Power load"             [ stateTopic="tele/gosundsp111_01/SENSOR", transformationPattern="JSONPATH:$.ENERGY.Power"]
        Type number : voltage   "Line voltage"           [ stateTopic="tele/gosundsp111_01/SENSOR", transformationPattern="JSONPATH:$.ENERGY.Voltage"]
        Type number : current   "Line current"           [ stateTopic="tele/gosundsp111_01/SENSOR", transformationPattern="JSONPATH:$.ENERGY.Current"]
        Type number : total     "Total energy "          [ stateTopic="tele/gosundsp111_01/SENSOR", transformationPattern="JSONPATH:$.ENERGY.Total"]
        Type number : totalday  "Total energy today"     [ stateTopic="tele/gosundsp111_01/SENSOR", transformationPattern="JSONPATH:$.ENERGY.Today"]
        Type number : totalyest "Total energy yesterday" [ stateTopic="tele/gosundsp111_01/SENSOR", transformationPattern="JSONPATH:$.ENERGY.Yesterday"]
        Type string : ssid      "WiFi"                   [ stateTopic="tele/gosundsp111_01/STATE", transformationPattern="JSONPATH:$.Wifi.SSId"]
        Type datetime : time    "Time"                   [ stateTopic="tele/gosundsp111_01/STATE", transformationPattern="JSONPATH:$.Time"]
    }

Code: Alles auswählen

Switch    Gosund_socket_01              "Gosund Switch 01 [MAP(de.map):%s]"              <light>                  (gGosunds,gPlugSwitch)          { channel="mqtt:topic:hans:sp11101:power"}        
Number    Gosund_socket_01_RSSI         "Gosund Switch 01 RSSI [%s]"                     <qualityofservice>       (gGosunds,gRSSI)                { channel="mqtt:topic:hans:sp11101:rssi" }         
String    Gosund_socket_01_Version      "Gosund Switch 01 Version 69[%s]"                <gosundsp111>            (gGosunds,gVer)                 { channel="mqtt:topic:hans:sp11101:version" }       
Switch    Gosund_socket_01_Unreach      "Gosund Switch 01 Erreichbarkeit [%s]"           <siren1>                 (gGosunds,gLWT)                 { channel="mqtt:topic:hans:sp11101:reachable" }     
String    Gosund_socket_01_Hardware     "Gosund Switch 01 Hardware 69[%s]"               <gosundsp111>            (gGosunds,gHard)                { channel="mqtt:topic:hans:sp11101:hardware" }       
String    Gosund_socket_01_IPAddress    "Gosund Switch 01 IP-Address [%s]"               <gosundsp111>            (gGosunds,gHard)                { channel="mqtt:topic:hans:sp11101:ipaddress" }       
//*       For Fun and Test            
Number    Gosund_socket_01_Verb         "Gosund 01 Verbrauch Total[%.2f kWh]"            <gosundsp111>            (gGosunds)                      { channel="mqtt:topic:hans:sp11101:total" }   
Number    Gosund_socket_01_VerbHeute    "Gosund 01 Verbrauch Heute[%.2f kWh]"            <gosundsp111>            (gGosunds)                      { channel="mqtt:topic:hans:sp11101:totalday" }   
Number    Gosund_socket_01_VerbGestern  "Gosund 01 Verbrauch Gestern[%.2f kWh]"          <gosundsp111>            (gGosunds)                      { channel="mqtt:topic:hans:sp11101:totalyest" }   
Number    Gosund_socket_01_Strom        "Gosund 01 Stromaufnahme [%.2f A]"               <gosundsp111>            (gGosunds)                      { channel="mqtt:topic:hans:sp11101:current" }  
Number    Gosund_socket_01_Spannung     "Gosund 01 Spannung[%.2f Volt]"                  <gosundsp111>            (gGosunds)                      { channel="mqtt:topic:hans:sp11101:voltage" }    
Number    Gosund_socket_01_Leisung      "Gosund 01 Leistung[%.2f W]"                     <gosundsp111>            (gGosunds)                      { channel="mqtt:topic:hans:sp11101:powerload" }  
String    Gosund_socket_01_SSID         "Gosund 01 Wlan [%s]"                            <gosundsp111>            (gGosunds)                      { channel="mqtt:topic:hans:sp11101:ssid" }         
DateTime  Gosund_socket_01_Date         "Gosund 01 Refresh [%1$tH:%1$tM]"                <gosundsp111>            (gGosunds)                      { channel="mqtt:topic:hans:sp11101:time" }         

Code: Alles auswählen

Bridge mqtt:broker:JojoBroker [
host="192.168.189.27", username="XXX", password ="YYYYY", secure="false" ]{

Thing topic Temperaturen "Temperaturen" @ "JojoBroker" {
  Channels:
  Type string : Terasse "Terasse"           [stateTopic="/home/data/ESP/Terasse/" ]
  Type string : Kellerabgang "Kellerabgang" [stateTopic="/home/data/ESP/Kellerabgang/"]
  Type string : Wohnzimmer "Wohnzimmer"     [stateTopic="/home/data/ESP/Wohnzimmer/"]
 
}

Code: Alles auswählen

String Kellerabgang "Kellerabgang  [%s°C]"    {channel="mqtt:topic:JojoBroker:Temperaturen:Kellerabgang"}
String Terasse "Terasse            [%s°C]"    {channel="mqtt:topic:JojoBroker:Temperaturen:Terasse"}
String Wohnzimmer "Wohnzimmer      [%s°C]"    {channel="mqtt:topic:JojoBroker:Temperaturen:Wohnzimmer"}

Code: Alles auswählen

 Frame label="Temperaturen" {
          Text item=Wohnzimmer icon="temperature"
          Text item=Kellerabgang icon="temperature"
          Text item=Terasse icon="temperature"
    }

Code: Alles auswählen

//https://openhabforum.de/viewtopic.php?f=15&t=970&start=20   // from Udo
//Bridge mqtt:broker:MosquittoMqttBroker "Mosquitto MQTT Broker" @ "MQTT2" 
//       ^    ^      ^                    ^                      ^ Zeige diese Bridge auf der Unterseite "MQTT" in Paper UI Control
//       ^    ^      ^                    ^ Label der Bridge
//       ^    ^      ^ Name der Bridge
//       ^    ^ Art der Bridge
//       ^ Binding

Bridge mqtt:broker:hans "Mosquitto" [ host="localhost", port=1883, secure=false, clientID="OH2_hans" ]  
{

Code: Alles auswählen

    Thing topic esp_mini02 "ESP8266 Mini Nr 02" @ "MQTT2" {
    Channels:
        Type switch : reachable   "Mini Reachable"   [ stateTopic="esp_mini_2/status/LWT" ]
        Type switch : motion      "Mini Bewegung T1" [ stateTopic="esp_mini_2/hc-sr501/State" ]
        Type number : temp        "Temp. BME280 T2"  [ stateTopic="esp_mini_2/bme280/Temperature"]
        Type number : hum         "Hum.  BME280 T2"  [ stateTopic="esp_mini_2/bme280/Humidity"]
        Type number : pres        "Pres. BME280 T2"  [ stateTopic="esp_mini_2/bme280/Pressure"]
        Type string : ipaddress   "IP Address"       [ stateTopic="esp_mini_2/IPAdress"]
        Type string : ssid        "WiFi"             [ stateTopic="esp_mini_2/wifi_name"]
    }

Code: Alles auswählen

Switch    esp_mini_02_Unreach         "ESP8266_Mini-2 LWT-Erreichbarkeit [%s]"           <siren1>                (gAmica,gLWTesp,gLWT)          { channel="mqtt:topic:hans:esp_mini02:reachable"}          // persisted in mapDB
Switch    esp_mini_02_motion          "ESP8266_Mini-2 Bewegung[%s]"                      <siren>                 (gAmica,EG_Buro,gMotion)       { channel="mqtt:topic:hans:esp_mini02:motion"}               
Number    esp_mini_02_temp            "ESP8266_Mini-2 BME280 Temperatur[%.1f °C]"        <temperature>           (gAmica,EG_Buro,gRtIstI)       { channel="mqtt:topic:hans:esp_mini02:temp"}               
Number    esp_mini_02_hum             "ESP8266_Mini-2 BME280 Luftfeuchtigkeit[%.1f %%]"  <humidity>              (gAmica,EG_Buro)               { channel="mqtt:topic:hans:esp_mini02:hum"}               
Number    esp_mini_02_pres            "ESP8266_Mini-2 BME280 LuftDruck[%.1f hPa]"        <pressure>              (gAmica,EG_Buro)               { channel="mqtt:topic:hans:esp_mini02:pres"}               
String    esp_mini_02_Version         "ESP8266_Mini-2 Version [%s]"                      <sonoff_pow>            (gAmica,gVer)                  { http="<[http://192.168.178.84/json:3600000:JSONPATH($.System.['Git Build'])]" }  
String    esp_mini_02_IPAddress       "ESP8266_Mini-2 IP-Address [%s]"                   <sonoff_pow>            (gAmica,gHard)                 { channel="mqtt:topic:hans:esp_mini02:ipaddress" }            
String    esp_mini_02_SSID            "ESP8266_Mini-2 Wlan [%s]"                         <sonoff_pow>            (gAmica)                       { channel="mqtt:topic:hans:esp_mini02:ssid" }         

Code: Alles auswählen

/*
 * Send temperature from ESP8266 with multiple DS18B20 to MQTT server.
 * A simple Sketch to read the Temperature from multiple DS18B20 and publish them to a MQTT-Server using a ESP8266. 
 * Compiles in the Arduino IDE for the ESP8266
 * 
 * For deep sleep support uncomment 'deep sleep' part
 * For DHT22 support uncomment 'dht22' part
 * OTA currently does not work.
 * 
 * 
 */
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <OneWire.h>
#include <DallasTemperature.h>
#include <Streaming.h>
#include <ESP8266HTTPUpdateServer.h>
#include <ESP8266WebServer.h>
#include <ESP8266mDNS.h>
//#include "SSD1306.h" // alias for `#include "SSD1306Wire.h"`

//SSD1306 display(0x3C,D1, D2);

/* dht22
#include <DHT.h>
*/

/* deep sleep
#define SLEEP_DELAY_IN_SECONDS  30
*/

// data cable connected to D4 pin
#define ONE_WIRE_BUS D4

//wifi
const char* ssid = "HAL9000Gast";
const char* password = "WGSHAL9000";

//mqtt
const char* mqtt_server = "192.168.189.27";
//
const char* mqtt_username = "";
const char* mqtt_password = "";
const char* host = "/home/data/out";

WiFiClient espClient;
PubSubClient client(espClient);

OneWire oneWire(ONE_WIRE_BUS);
DallasTemperature DS18B20(&oneWire);


void setup_wifi() {
  delay(10);
  // We start by connecting to a WiFi network
  Serial.println();
  Serial.print("Connecting to ");
  Serial.println(ssid);

  WiFi.begin(ssid, password);

  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
  delay (500);
 
}

void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message arrived [");
  Serial.print(topic);
  Serial.print("] ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();
}

void setup() {
  // setup serial port
  Serial.begin(115200);

  // setup WiFi
  setup_wifi();
  client.setServer(mqtt_server, 1883);
  client.setCallback(callback);

  // setup OneWire bus
  DS18B20.begin();
}

void reconnect() {
  // Loop until we're reconnected
  while (!client.connected()) {
    Serial.print("Attempting MQTT connection...");
    // Attempt to connect
    //if (client.connect("ESP8266Client", mqtt_username, mqtt_password)) {
    if (client.connect("ESP8266Client")) {
      Serial.println("connected");
    } else {
      Serial.print("failed, rc=");
      Serial.print(client.state());
      Serial.println(" try again in 5 seconds");
      // Wait 5 seconds before retrying
      delay(5000);
    }
  }
}

/*void displayData() {
    display.clear();
    display.setTextAlignment(TEXT_ALIGN_CENTER);
    display.setFont(ArialMT_Plain_10);
    display.drawString(64, 0, "Office Temp/Humidty");   
    display.setFont(ArialMT_Plain_24);
    
    display.display();
}*/

void loop() {
  if (!client.connected()) {
    reconnect();
  }
  client.loop();

  
      
// ds18b20

  byte i;
  byte present = 0;
  byte type_s;
  byte data[12];
  byte addr[8];
  

//Loop through all DS1820

while(oneWire.search(addr))
{ 
  //Serial.print("ROM =");

//Topic is built from a static String plus the ID of the DS18B20
  String romcode = "/home/data/ESP8266_3";
  String Nummer = "Nummer";
  //Serial.print( addr[i]);
  for( i = 0; i < 8; i++) {
    //Serial.write(' ');
    //Serial.print(addr[i], HEX);
    //romcode = romcode + String(addr[i], HEX);
    Nummer = Nummer + String(addr[i]);
  }

  if (OneWire::crc8(addr, 7) != addr[7]) {
      Serial.println("CRC is not valid!");
      return;
  }
  Serial.println();
 
// the first ROM byte indicates which chip
  switch (addr[0]) {
    case 0x10:
      //Serial.println("  Chip = DS18S20");  // or old DS1820
      type_s = 1;
      break;
    case 0x28:
      //Serial.println("  Chip = DS18B20");
      type_s = 0;
      break;
    case 0x22:
      //Serial.println("  Chip = DS1822");
      type_s = 0;
      break;
    default:
      //Serial.println("Device is not a DS18x20 family device.");
      return;
  } 
  //oneWire.depower();
  oneWire.reset();
  oneWire.select(addr);
  oneWire.write(0x44, 1);        // start conversion, with parasite power on at the end
  
  delay(1000);     // maybe 750ms is enough, maybe not
  // we might do a oneWire.depower() here, but the reset will take care of it.
  
  present = oneWire.reset();
  oneWire.select(addr);    
  oneWire.write(0xBE);         // Read Scratchpad

 

  //Serial.print("  Data = ");
  //Serial.print(present, HEX);
  //Serial.print(" ");
  for ( i = 0; i < 9; i++) {           // we need 9 bytes
    data[i] = oneWire.read();
    //Serial.print(data[i], HEX);
    //Serial.print(" ");
  }
  //Serial.print(" CRC=");
  //Serial.print(OneWire::crc8(data, 8), HEX);
  Serial.println();


   int16_t raw = (data[1] << 8) | data[0];
  if (type_s) {
    raw = raw << 3; // 9 bit resolution default
    if (data[7] == 0x10) {
      // "count remain" gives full 12 bit resolution
      raw = (raw & 0xFFF0) + 12 - data[6];
    }
  } else {
    byte cfg = (data[4] & 0x60);
    // at lower res, the low bits are undefined, so let's zero them
    if (cfg == 0x00) raw = raw & ~7;  // 9 bit resolution, 93.75 ms
    else if (cfg == 0x20) raw = raw & ~3; // 10 bit res, 187.5 ms
    else if (cfg == 0x40) raw = raw & ~1; // 11 bit res, 375 ms
    //// default is 12 bit resolution, 750 ms conversion time
  }

//convert RAW Temperature to String
String raw_temp = String(raw, DEC);
//convert RAW Temperature to celsius
double temp = raw * 0.0625;
Serial.print(temp);
//convert to string
char tempString[6];
dtostrf(temp, 2, 2, tempString);

  
    if (client.publish((char*) romcode.c_str(), tempString)) {
        client.publish (host,tempString);
//      client.publish((char*) romcode.c_str(), romcode);
//      display.drawString(66, 13, tempString );
//      display.drawString(66, 40, display_humid + "%");
      Serial.println();
      Serial.println("Publish ok  : ");

     }
    else {
      Serial.println("Publish failed");
    }
  
}


//End of the OneWire-Devices, reset Loop
Serial.println("End of Onewire Bus");
//oneWire.depower();
oneWire.reset_search();
delay(10000);  

return;

  // deep sleep
  //Serial << "Closing MQTT connection..." << endl;
  //client.disconnect();
  //Serial << "Closing WiFi connection..." << endl;
  //WiFi.disconnect();
  
 
  delay(100);
  // deep sleep
  //Serial << "Entering deep sleep mode for " << SLEEP_DELAY_IN_SECONDS << " seconds..." << endl;
  //ESP.deepSleep(SLEEP_DELAY_IN_SECONDS * 1000000, WAKE_RF_DEFAULT);
  //ESP.deepSleep(10 * 1000, WAKE_NO_RFCAL);
  //delay(500); 
}

Code: Alles auswählen

#!/usr/bin/python
# -*- coding: utf-8 -*-
 
import paho.mqtt.client as mqtt
import paho.mqtt.publish as publish 
import time

def on_message(client, userdata, message):
    msg = str(message.payload.decode("utf-8"))
    print("message received: ", msg)
    print("message topic: ", message.topic)
    if message.topic == ("/home/data/ESP8266_2"):
       msg2 = ":  "+ msg
       msg3 = time.strftime("%H:%M ") + msg2
       print (msg3)
       publish.single("/home/data/ESP/Buero", msg3)
    elif message.topic == ("/home/data/ESP8266_1"):
       msg2 = ":  " + msg
       msg3 = time.strftime("%H:%M ") +msg2
       print (msg3)
       publish.single("/home/data/ESP/Terasse", msg3)
    elif message.topic == ("/home/data/ESP8266_3"):
       msg2 = ":  " + msg
       msg3 = time.strftime("%H:%M ") +msg2
       print (msg3)
       publish.single("/home/data/ESP/Kellerabgang", msg3)
    elif message.topic == ("/home/data/ESP8266_6a"):
       msg2 = ":  " + msg
       msg3 = time.strftime("%H:%M ") + msg2
       print (msg3)
       publish.single("/home/data/ESP/Esszimmer", msg3)
    elif message.topic == ("/home/data/ESP8266_6b"):
       msg2 = ":  " + msg
       msg3 = time.strftime("%H:%M ") + msg2
       print (msg3)
       publish.single("/home/data/ESP/Esszimmer", msg3)
    elif message.topic == ("/home/data/feuchte"):
        msg2 =":  " +msg
        msg3 = time.strftime("%H:%M ") + msg2 
        publish.single("/home/data/ESP/feuchte" , msg3)
    else:
       #print("Sacklzement")
       print (msg)
       #publish.single("home/data/temp/",msg2)
       #print(message.topic)
#publish.single("home/data/","msg2")
#print (msg2)x

def on_publish(mosq, obj, mid):
       print("mid: " + str(msg2))
 
def on_connect(client, userdata, flags, rc):
    client.subscribe('/home/data/#')
 
BROKER_ADDRESS = "192.168.189.27"
 
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
 
client.connect(BROKER_ADDRESS)
 
print("Connected to MQTT Broker: " + BROKER_ADDRESS)
 
client.loop_forever()