PV-Überschussfunktion bei mehreren Zählern Pro 3 EM mit Relais Pro 3

// Verbrauchszähler
var meters = [
  { name: "UG+EG",   url: "http://XXX.XXX.X.XXX/rpc/Shelly.GetStatus" },
  { name: "DG",      url: "http://XXX.XXX.X.XXX/rpc/Shelly.GetStatus" },
  { name: "Garage",  url: "http://XXX.XXX.X.XXX/rpc/Shelly.GetStatus" }
];

// PV-Zähler
var pvMeter = { name: "PV-Anlage", url: "http://XXX.XXX.X.XXX/rpc/Shelly.GetStatus" };

// Shelly Relais (Kanal 0)
var relayUrl = "http://XXX.XXX.X.XXX/rpc/Switch.Set";

// Steuerungsvariablen
var meterIndex = 0;
var totalSystemPower = 0;
var pvPower = null;
var garagePower = 0;
var relayState = null;

var surplusCounter = 0;
var deficitCounter = 0;
var REQUIRED_MINUTES = 5;
var POWER_DELTA = 200;

// Mindestlaufzeit: 10 Minuten
var MIN_ON_TIME_MS = 10 * 60 * 1000;
var relayOnTimestamp = null;

// Tageszähler für aktive Relaiszeit
var dailyOnTimeSec = 0;

function getPowerFromMeter(index) {
  if (index >= meters.length) {
    print("▶ Haus-Gesamtleistung (inkl. Garage): " + Math.round(totalSystemPower) + " Watt");
    getPVPower();
    return;
  }

  var meter = meters[index];
  Shelly.call("http.get", { url: meter.url }, function(result, error_code) {
    if (error_code !== 0) {
      print("Zählerfehler (" + meter.name + "): Fehlercode " + error_code);
      getPowerFromMeter(index + 1);
      return;
    }

    try {
      var data = JSON.parse(result.body);
      var em0 = data["em:0"];
      var total = 0;

      if (em0) {
        if ("total_act_power" in em0) {
          total = em0.total_act_power;
        } else {
          total = (em0.a_act_power || 0) + (em0.b_act_power || 0) + (em0.c_act_power || 0);
        }

        if (meter.name === "Garage") {
          garagePower = total;
        }

        totalSystemPower += total;
        print("[" + meter.name + "] Gesamtleistung: " + Math.round(total) + " W");
      }
    } catch (e) {
      print("Fehler beim Parsen von " + meter.name + ": " + e);
    }

    getPowerFromMeter(index + 1);
  });
}

function getPVPower() {
  Shelly.call("http.get", { url: pvMeter.url }, function(result, error_code) {
    if (error_code !== 0) {
      print("PV-Zählerfehler (" + pvMeter.name + "): Fehlercode " + error_code);
      return;
    }

    try {
      var data = JSON.parse(result.body);
      var em0 = data["em:0"];
      var total = 0;

      if (em0) {
        if ("total_act_power" in em0) {
          total = em0.total_act_power;
        } else {
          total = (em0.a_act_power || 0) + (em0.b_act_power || 0) + (em0.c_act_power || 0);
        }

        pvPower = total;
        print("▶ PV-Leistung: " + Math.round(pvPower) + " W");
        checkSurplusLogic();
      }
    } catch (e) {
      print("Fehler beim Parsen der PV-Daten: " + e);
    }
  });
}

function checkSurplusLogic() {
  if (pvPower === null || totalSystemPower === null || garagePower === null) return;

  var correctedConsumption = totalSystemPower - pvPower;
  print("📊 Korrigierter Hausverbrauch (Garage ohne PV): " + Math.round(correctedConsumption) + " W");

  var pvInput = Math.abs(pvPower);
  var diff = pvInput - correctedConsumption;

  if (diff >= POWER_DELTA) {
    surplusCounter++;
    deficitCounter = 0;
    print("🟢 Überschuss erkannt: " + Math.round(diff) + " W (" + surplusCounter + "/" + REQUIRED_MINUTES + ")");
    if (surplusCounter >= REQUIRED_MINUTES) {
      surplusCounter = 0;
      switchRelay(true);
    }
  } else if (diff <= -POWER_DELTA) {
    deficitCounter++;
    surplusCounter = 0;
    print("🔴 Defizit erkannt: " + Math.round(Math.abs(diff)) + " W (" + deficitCounter + "/" + REQUIRED_MINUTES + ")");
    if (deficitCounter >= REQUIRED_MINUTES) {
      deficitCounter = 0;
      switchRelay(false);
    }
  } else {
    print("⚪ Kein signifikanter Unterschied (" + Math.round(diff) + " W)");
    surplusCounter = 0;
    deficitCounter = 0;
  }
}

function switchRelay(state) {
  if (relayState === state) {
    print("ℹ️ Relais bereits im Zustand: " + (state ? "EIN" : "AUS"));
    return;
  }

  if (!state && relayState === true && relayOnTimestamp !== null) {
    Shelly.call("Shelly.GetStatus", {}, function(res) {
      var now = (res.sys.uptime || 0) * 1000;
      var elapsed = now - relayOnTimestamp;

      if (elapsed < MIN_ON_TIME_MS) {
        print("⏳ Mindestlaufzeit nicht erreicht (" + Math.round(elapsed / 1000) + "s), Ausschalten abgebrochen.");
        return;
      }

      sendRelayCommand(false);
    });
  } else if (state) {
    Shelly.call("Shelly.GetStatus", {}, function(res) {
      relayOnTimestamp = (res.sys.uptime || 0) * 1000;
      sendRelayCommand(true);
    });
  } else {
    sendRelayCommand(false);
  }
}

function sendRelayCommand(state) {
  Shelly.call("http.post", {
    url: relayUrl,
    body: JSON.stringify({ id: 0, on: state }),
    timeout: 5
  }, function(res, err) {
    if (err !== 0) {
      print("⚠️ Fehler beim Schalten des Relais: Code " + err);
      return;
    }

    relayState = state;
    if (state) {
      print("✅ Relais geschaltet: EIN");
    } else {
      print("❌ Relais geschaltet: AUS");
      relayOnTimestamp = null;
    }
  });
}

// Hauptfunktion alle 60 Sekunden
Timer.set(60000, true, function() {
  getTotalPowerAllMeters();
});

function getTotalPowerAllMeters() {
  meterIndex = 0;
  totalSystemPower = 0;
  pvPower = null;
  garagePower = 0;
  getPowerFromMeter(0);
}

// Tageszähler erhöhen
Timer.set(1000, true, function() {
  if (relayState === true) {
    dailyOnTimeSec++;
  }
});

// Anzeige der Tageszeit + Relaisstatus alle 1 Minute (60000 ms)
Timer.set(60000, true, function() {
  var hours = Math.floor(dailyOnTimeSec / 3600);
  var minutes = Math.floor((dailyOnTimeSec % 3600) / 60);
  print("⏱ Überschussfunktion heute aktiv: " + hours + "h " + minutes + "min");
  print("🔌 Relaisstatus: " + (relayState ? "EIN" : "AUS"));
});

// Tageszähler um Mitternacht zurücksetzen (86400000 ms = 24 h)
Timer.set(86400000, true, function() {
  dailyOnTimeSec = 0;
  print("🔄 Tageszähler zurückgesetzt.");
});

// Direkt beim Start ausführen
getTotalPowerAllMeters();