Beiträge von Schwarzermann

/***** Markise – Sonnen/Wetter-Logik (Shelly Plus 2PM, InfluxDB = wunderweather)
 * Datum: 2025-10-06
 *****/

/*** Ersatz für encodeURIComponent (da Shelly JS 1.71 das nicht kennt) ***/
function encodeURIComponent(str) {
  let map = {' ':'%20','"':'%22','%':'%25','&':'%26','\'':'%27','(':'%28',')':'%29','+':'%2B',',':'%2C','/':'%2F',':':'%3A',';':'%3B','<':'%3C','=':'%3D','>':'%3E','?':'%3F','@':'%40','[':'%5B',']':'%5D'};
  let out=""; for (let i=0;i<str.length;i++){let c=str[i]; out+=map[c]?map[c]:c;} return out;
}

/*** === Konfiguration === ***/
let CFG = {
  IPCOVER_SELF: "192.168.178.131",
  IPCOVER_BATH: "192.168.178.195",
  INFLUX: {
    url: "http://192.168.178.54:8086/query",
    db:  "wunderweather",             // ✅ Korrigiert
    meas: "weather",
    fields: {
      irradiance: "Sonnenstrahlung",
      temperature: "Temperatur",
      wind: "Windgeschwindigkeit",
      humidity: "Luftfeuchtigkeit"
    }
  },
  POLL_MS: 60000,
  IRR_ON:  300,
  IRR_OFF: 200,
  T_MIN:   20.0,
  W_MID:   8.0,
  W_HIGH: 10.0,
  HUMI_RAIN: 90.0,
  STAB_SUN_SEC:   120,
  STAB_TEMP_SEC:  120,
  STAB_WMID_SEC:  120,
  STAB_WHIGH_SEC: 120,
  STAB_RAIN_SEC:  120,
  STAB_NIGHT_SEC: 120,
  POS_FULL_OUT: 100,
  POS_HALF:     50,
  POS_IN:        0,
  CMD_COOLDOWN_MS: 30000
};

/*** === Helper === ***/
function nowMs() { return Date.now(); }
function log() { let s=""; for(let i=0;i<arguments.length;i++){s+=(i>0?" ":"")+arguments[i];} print("[Markise] "+s); }

/*** === Debouncer === ***/
function Debouncer(sec){this.stabMs=sec*1000;this.sinceTrue=null;this.update=function(v){if(v){if(this.sinceTrue===null)this.sinceTrue=nowMs();}else this.sinceTrue=null;};this.stableTrue=function(){return this.sinceTrue!==null&&(nowMs()-this.sinceTrue)>=this.stabMs;};}
let DB={sunOn:new Debouncer(CFG.STAB_SUN_SEC),sunOff:new Debouncer(CFG.STAB_SUN_SEC),tOk:new Debouncer(CFG.STAB_TEMP_SEC),wMid:new Debouncer(CFG.STAB_WMID_SEC),wHigh:new Debouncer(CFG.STAB_WHIGH_SEC),rain:new Debouncer(CFG.STAB_RAIN_SEC),night:new Debouncer(CFG.STAB_NIGHT_SEC)};
let state={lastCmdAt:0,lastTargetPos:null,coverPos:null,irr:null,temp:null,wind:null,humi:null,isDay:null};

/*** === Cover === ***/
function refreshSelfCover(){Shelly.call("Cover.GetStatus",{id:0},function(r,e,c){if(c===200&&r){state.coverPos=r.current_pos;}});}
function setCoverPos(target){let t=nowMs();if(t-state.lastCmdAt<CFG.CMD_COOLDOWN_MS)return;if(state.lastTargetPos!==null&&Math.abs(state.lastTargetPos-target)<2)return;state.lastCmdAt=t;state.lastTargetPos=target;log("→ Fahre Markise auf",target,"%");Shelly.call("Cover.GoToPosition",{id:0,pos:target});}

/*** === HTTP Wrapper === ***/
function httpGet(url,cb){Shelly.call("HTTP.GET",{url:url,timeout:8},function(r,e,m){if(e===0&&r&&r.code===200){cb(r);}else{log("❌ HTTP Fehler",e,m);cb(null);}});}

/*** === Bad-Rollo Tag/Nacht === ***/
function fetchBathDayNight(cb){let url="http://"+CFG.IPCOVER_BATH+"/rpc/Cover.GetStatus?id=0";log("HTTP →",url);httpGet(url,function(r){if(!r){log("❌ Keine Antwort vom Bad-Rollo");cb(false);return;}log("← Bad-Rollo:",r.body);try{let j=JSON.parse(r.body);let pos=j.current_pos;let isDay=(pos>=100);DB.night.update(!isDay);state.isDay=isDay;cb(true);}catch(e){log("❌ JSON Fehler Bad-Rollo",e);cb(false);}});}

/*** === Influx Abfrage === ***/
function buildInfluxQuery(){let f=CFG.INFLUX.fields,m=CFG.INFLUX.meas;return 'SELECT last("'+f.irradiance+'") AS irr, last("'+f.temperature+'") AS temp, last("'+f.wind+'") AS wind, last("'+f.humidity+'") AS humi FROM "'+m+'" WHERE time > now() - 10m';}
function fetchInflux(cb){let query=buildInfluxQuery();let url=CFG.INFLUX.url+"?db="+CFG.INFLUX.db+"&q="+encodeURIComponent(query);log("HTTP →",url);httpGet(url,function(r){if(!r){log("❌ Keine Antwort von Influx");cb(false);return;}log("← Influx:",r.body);try{let d=JSON.parse(r.body);let s=d.results[0].series[0];let cols=s.columns;let vals=s.values[0];let map={};for(let i=0;i<cols.length;i++)map[cols[i]]=vals[i];state.irr=map.irr;state.temp=map.temp;state.wind=map.wind;state.humi=map.humi;log("→ Werte:",state.irr,state.temp,state.wind,state.humi);cb(true);}catch(e){log("❌ JSON Fehler Influx",e);cb(false);}});}

/*** === Entscheidungslogik === ***/
function decideAndAct(){let sunOn=(state.irr!==null&&state.irr>=CFG.IRR_ON);let sunOff=(state.irr!==null&&state.irr<=CFG.IRR_OFF);DB.sunOn.update(sunOn);DB.sunOff.update(sunOff);DB.tOk.update(state.temp>=CFG.T_MIN);DB.wHigh.update(state.wind>=CFG.W_HIGH);DB.wMid.update(state.wind>=CFG.W_MID&&state.wind<CFG.W_HIGH);DB.rain.update(state.humi>=CFG.HUMI_RAIN);let night=DB.night.stableTrue();log("Check:",state.isDay,state.irr,state.temp,state.wind,state.humi);if(night){log("→ Nacht ⇒ 0%");setCoverPos(CFG.POS_IN);return;}if(DB.rain.stableTrue()){log("→ Regen ⇒ 0%");setCoverPos(CFG.POS_IN);return;}if(DB.wHigh.stableTrue()){log("→ Wind hoch ⇒ 0%");setCoverPos(CFG.POS_IN);return;}if(DB.wMid.stableTrue()){log("→ Wind mittel ⇒ 50%");setCoverPos(CFG.POS_HALF);return;}if(DB.sunOn.stableTrue()&&DB.tOk.stableTrue()&&state.isDay){log("→ Sonne & Temp OK ⇒ 100%");setCoverPos(CFG.POS_FULL_OUT);return;}if((DB.sunOff.stableTrue()||!DB.tOk.stableTrue())&&state.isDay){log("→ Sonne weg / kalt ⇒ 0%");setCoverPos(CFG.POS_IN);return;}log("→ Keine stabile Änderung – wartet…");}

/*** === Loop === ***/
function loop(){refreshSelfCover();fetchBathDayNight(function(){fetchInflux(function(){decideAndAct();});});}
log("Script gestartet – Poll =",CFG.POLL_MS,"ms");loop();Timer.set(CFG.POLL_MS,true,loop);

// ###########################################################
// Shelly 1PM / 1 Plus (Gen4) – Mastersteuerung
// folgt 3 Toren (Shelly 2PM) + mehreren Licht-Shellys (1PM/1)
// Nachtmodus wird vom Bad-Rollo (IP 192.168.178.195) bestimmt
// ###########################################################

// === KONFIGURATION =========================================

// Tore (Shelly 2PM)
let garageDoors = [
  "192.168.178.109", // Tor 1 – Garage links
  "192.168.178.110", // Tor 2 – Garage rechts
  "192.168.178.104"  // Tor 3 – Hebebühne
];

// Externe Licht-Shellys
let linkedLights = [
  { ip: "192.168.178.201", active: true },   // Außenlicht Haus
  { ip: "192.168.178.202", active: true },   // Außenlicht Haustüre
  { ip: "192.168.178.xxx", active: false }   // Reserviert (Einfahrt)
];

// Referenz-Rollo für Sonnenstand (Bad)
let refRollo = "192.168.178.195";

// Abfrageintervalle & Zeiten
let interval = 30000;        // 30 s – Torabfrage
let lightCheckInterval = 20000; // 20 s – Lichtabfrage
let holdTimeOpen = 240;      // s – Lichtdauer bei 100 %
let holdTimeClose = 120;     // s – Nachlauf bei Schließen

// Zustände
let lastOn = false;
let holdTimer = null;
let delayOffTimer = null;
let holdActive = false;
let lastPos = { "192.168.178.109": null, "192.168.178.110": null, "192.168.178.104": null };
let lastLightCheck = 0;

// === FUNKTIONEN ============================================

function switchLight(on) {
  Shelly.call("Switch.Set", { id: 0, on: on });
  lastOn = on;
  print("Master-Licht", on ? "EIN" : "AUS");
}

function cancelTimers() {
  if (holdTimer !== null) { Timer.clear(holdTimer); holdTimer = null; }
  if (delayOffTimer !== null) { Timer.clear(delayOffTimer); delayOffTimer = null; }
}

// --- Prüft, ob Nacht ist (Rollo geschlossen)
function isNight(callback) {
  let url = "http://" + refRollo + "/rpc/Cover.GetStatus?id=0";
  Shelly.call("HTTP.GET", { url: url }, function(res) {
    if (!res || res.code !== 200) {
      print("Fehler beim Rollo-Check:", res ? res.code : "n/a");
      callback(true); // Fallback: Nacht
      return;
    }
    try {
      let data = JSON.parse(res.body);
      let pos = parseFloat(data.current_pos);
      let night = (pos <= 0.5); // 0 % = geschlossen ⇒ Nacht
      print("Rollo (Bad):", pos, "% →", night ? "NACHT" : "TAG");
      callback(night);
    } catch (e) {
      print("Parsing-Fehler beim Rollo-Check:", e);
      callback(true);
    }
  });
}

// --- Prüft externe Licht-Shellys
function checkExternalLights(callback) {
  let index = 0;
  function next() {
    if (index >= linkedLights.length) { if (callback) callback(); return; }
    let dev = linkedLights[index++];
    if (!dev.active) return next();
    let url = "http://" + dev.ip + "/rpc/Switch.GetStatus?id=0";
    Shelly.call("HTTP.GET", { url: url }, function(res) {
      if (res && res.code === 200) {
        let data = JSON.parse(res.body);
        if (data.output && !lastOn) {
          switchLight(true);
          print("Master EIN (externer Shelly", dev.ip, "ist EIN)");
        }
      }
      next();
    });
  }
  next();
}

// --- Prüft Tore nacheinander
function checkCoversSequentially(i) {
  if (i >= garageDoors.length) return;
  let ip = garageDoors[i];
  let url = "http://" + ip + "/rpc/Cover.GetStatus?id=0";

  Shelly.call("HTTP.GET", { url: url }, function(res) {
    if (res && res.code === 200) {
      try {
        let data = JSON.parse(res.body);
        let pos = parseFloat(data.current_pos);
        print("Tor", ip, "Position:", pos, "%");

        if (pos >= 100) {
          if (!holdActive) {
            holdActive = true;
            switchLight(true);
            cancelTimers();
            holdTimer = Timer.set(holdTimeOpen * 1000, false, function() {
              switchLight(false);
              print("Licht AUS (240 s abgelaufen)");
            });
            print("Licht EIN (Tor", ip, "100%)");
          }
          lastPos[ip] = pos;
          return checkCoversSequentially(i + 1);
        }

        if (lastPos[ip] !== null && lastPos[ip] >= 100 && pos < 100) {
          switchLight(true);
          holdActive = false;
          cancelTimers();
          print("Licht EIN (Start Schließen Tor", ip, ")");
        }

        if (lastPos[ip] !== null && lastPos[ip] < 20 && pos >= 20) {
          switchLight(true);
          print("Licht EIN (Tor", ip, "öffnet über 20 %)");
        }

        let allClosed = true;
        lastPos[ip] = pos;
        for (let j = 0; j < garageDoors.length; j++) {
          if (lastPos[garageDoors[j]] !== null && lastPos[garageDoors[j]] > 20) {
            allClosed = false;
            break;
          }
        }

        if (allClosed && !delayOffTimer) {
          print("Alle Tore geschlossen – starte 120 s Nachlauf");
          delayOffTimer = Timer.set(holdTimeClose * 1000, false, function() {
            switchLight(false);
            print("Licht AUS (120 s Nachlauf)");
          });
        } else if (!allClosed && delayOffTimer) {
          Timer.clear(delayOffTimer);
          delayOffTimer = null;
          print("Nachlauf abgebrochen (ein Tor wieder aktiv)");
        }

      } catch (e) {
        print("Fehler beim Parsen Tor", ip);
      }
    }
    checkCoversSequentially(i + 1);
  });
}

// --- Hauptsteuerung
function checkSystem() {
  isNight(function(nightMode) {
    if (!nightMode) {
      if (lastOn) switchLight(false);
      print("Tag erkannt – Lichtsteuerung gesperrt");
      return;
    }

    let now = (new Date()).getTime();
    if (now - lastLightCheck > lightCheckInterval) {
      lastLightCheck = now;
      checkExternalLights(function() {
        checkCoversSequentially(0);
      });
    } else {
      checkCoversSequentially(0);
    }
  });
}

// === TIMER STARTEN =========================================
Timer.set(interval, true, checkSystem);
print("Skript gestartet – Nachtmodus über Rollo", refRollo);