Shelly Pro 3em und richtig saldieren bzw. richtige Werte in HA

Allgemein
30

Sorry, ich habe momentan etwas Stress auf der Arbeit.
Ein Yaml kann ich dir leider nicht (mehr) zu Verfügung stellen, da ich mit meinen beiden 3EMpro´s auf ein internal script umgestiegen bin.

Hast du einen EM oder EM Pro?
Bei einem EM Pro kannst du ein Script direkt im Shelly einbinden, was im Prinzip das Gleiche wie HA macht, nur lokal halt. Das hat den Vorteil, dass die Werte auch dann korrekt gezählt werden, wenn die Verbindung zu HA mal nicht da ist. Zb. bei einem Neustart von HA. Darüber hinaus ist die berechnung etwas genauer, da kein Zeitversatz besteht.

Da das ganze über MQTT übermittelt wird, benötigst du dann noch zwei MQTT Sensoren in HA…

    - name: shellypro3em-steuve-diff_total_energy-consumed
      unique_id:shellypro3em-abcdedf-c
      state_topic: "shellypro3em-abcdedf/energy_counter/consumed"
      unit_of_measurement: "kWh"
      state_class: total_increasing
      device_class: energy
    - name: shellypro3em-steuve-diff_total_energy-returned
      unique_id: shellypro3em-abcdedf-r
      state_topic: "shellypro3em-abcdedf/energy_counter/returned"
      unit_of_measurement: "kWh"
      state_class: total_increasing
      device_class: energy

Anbei das Shelly 3EM Pro Script

let energyReturnedWs = 0.0;
let energyConsumedWs = 0.0;

let energyReturnedKWh = 0.0;
let energyConsumedKWh = 0.0;

let log = 0;

// set this to false to stop publishing on MQTT
let MQTTpublish = true;

// set this to false if you DONT want to update the name
// (the updated name is necessary to read the data with the iobroker shelly plugin)
let updateName = false;

// query the MQTT prefix on startup
let SHELLY_ID = undefined;
Shelly.call("Mqtt.GetConfig", "", function (res, err_code, err_msg, ud) {
  SHELLY_ID = res["topic_prefix"];
});

function SetKVS(key, value)
{
 Shelly.call(
   "KVS.Set", {
     "key": key,
     "value": value,
   },
   function(result) {
     if (log > 0)
       print("KVS Saved, rev:", result.rev);
   }
 );
}
 
function SaveCounters()
{
  SetKVS("EnergyConsumedKWh", energyConsumedKWh );
  SetKVS("EnergyReturnedKWh", energyReturnedKWh );
}
     
Shelly.call(
   "KVS.Get", {
     "key": "EnergyReturnedKWh",
   },
  function callback(result, error_code, error_message, userdata) {
     if (error_code === 0) 
     {
       energyReturnedKWh = Number(result.value);
       print("Loaded returned energy: ", energyReturnedKWh, " KWh");
     }       
   }
 );
 
 Shelly.call(
   "KVS.Get", {
     "key": "EnergyConsumedKWh",
   },
  function callback(result, error_code, error_message, userdata) {
     if (error_code === 0) 
     {
       energyConsumedKWh = Number(result.value);
       print("Loaded consumed energy: ", energyConsumedKWh, " KWh");
     }       
   }
 );

let counter3600 = 0;
let counter20 = 18;

let lastPublishedMQTTConsumed = "";
let lastPublishedMQTTReturned = "";

function timerHandler(user_data)
{
  let em = Shelly.getComponentStatus("em", 0);
  if (typeof em.total_act_power !== 'undefined') {
    let power = em.total_act_power;
    
    if (power >= 0)
    {
        energyConsumedWs = energyConsumedWs + power * 0.5;
    }
    else
    {
        energyReturnedWs = energyReturnedWs - power * 0.5;
    }
    
    // once a full Wh is accumulated, move it to the KWh counter
    let fullWh = Math.floor((energyConsumedWs / 3600));
    if (fullWh > 0)
    {
      energyConsumedKWh += fullWh / 1000;
      energyConsumedWs -= fullWh * 3600;
      if (log > 0)
        print("Changed consumed KWh: ",energyConsumedKWh);
    }
    
    fullWh = Math.floor((energyReturnedWs / 3600));
    if (fullWh > 0)
    {
      energyReturnedKWh += fullWh / 1000;
      energyReturnedWs -= fullWh * 3600;
      if (log > 0)
        print("Changed returned KWh: ",energyReturnedKWh);
    }
    
    if (log > 0)
      print(power , "W");
      
    counter3600 = counter3600 + 1;
    if (counter3600 > 3600)      
    {
      counter3600 = 0;     
      SaveCounters();
    }
    
    counter20 = counter20 + 1;
    if ( counter20 > 20)
    {
      counter20 = 0;  
      if (updateName)
      {
        Shelly.call(
          "Sys.SetConfig", {
             config: {device:{name:energyConsumedKWh.toFixed(3)+" KWh ; "+(energyReturnedKWh+energyReturnedWs / 3600000).toFixed(5)+" KWh"}},
          },
          function(result, error_code, error_message, userdata) {
             //print("error ", error_code, " : ", error_message);
             //print("result", JSON.stringify(result));
          }
        );
      }
             
      if (typeof SHELLY_ID !== "undefined" && MQTTpublish === true) 
      {         
        let value = energyConsumedKWh.toFixed(3);
        if (value !== lastPublishedMQTTConsumed)
        {
          MQTT.publish(
            SHELLY_ID + "/energy_counter/consumed",
            value,
            0,
            false
          );
          lastPublishedMQTTConsumed = value;
        }
        
        let value = energyReturnedKWh.toFixed(3);
        if (value !== lastPublishedMQTTReturned)
        {
          MQTT.publish(
            SHELLY_ID + "/energy_counter/returned",
            value,
            0,
            false
          );
          lastPublishedMQTTReturned = value;
        }           
      }
    }
  };
}

Timer.set(500, true, timerHandler, null);

function httpServerHandler(request, response) {
    response.code = 200;

    // create JSON object 
    const energyData = {
        energyConsumed: energyConsumedKWh.toFixed(3) + " KWh",
        energyReturned: (energyReturnedKWh+(energyReturnedWs / 3600000)).toFixed(5) + " KWh"
    };

    // convert JSON object to string and send it as reply
    response.body = JSON.stringify(energyData);
    response.send();
    return;
}
HTTPServer.registerEndpoint("energy_counter", httpServerHandler);

Quelle:GitHub - sicanins/shelly-pro3EM-energycounter

1 „Gefällt mir“