//Version 13.6
//nachbearbeitet von ticaki
/*
*/
/* ************************************************************************* */
/* Script zum Übertragen der DWD-Wetterwarnungen über */
/* Telegram, Pushover, Home24-Mediaplayer oder SayIt */
/* mit freundlicher Unterstützung von Paul53 (Tausend Dank nochmals) */
/* Stand: 130022017 PrinzEisenherz1 */
/* */
/* */
/* */
/* ************************************************************************* */
/* ************************************************************************* */
/* NICHT EDITIEREN */
var konstanten = [
{"name":'telegram',"value":1},
{"name":'pushover',"value":2},
{"name":'email',"value":4},
{"name":'sayit',"value":8},
{"name":'home24',"value":16},
{"name":'alexa',"value":32},
{"name":'state',"value":64},
{"name":'iogo',"value":128}
];
const TELEGRAM = konstanten[0].value;
const PUSHOVER = konstanten[1].value;
const EMAIL = konstanten[2].value;
const SAYIT = konstanten[3].value;
const HOMETWO = konstanten[4].value;
const ALEXA = konstanten[5].value;
const STATE = konstanten[6].value;
const IOGO = konstanten[7].value;
var pushdienst=0;
/* ************************************************************************* */
/* Konfiguration ab hier */
/* ************************************************************************* */
/* Konfiguration der zu nutzenden Ausgabe um //pushdienst+= PUSHOVER; zu aktivieren, bitte die // enfernen, also pushdienst+= PUSHOVER; */
//pushdienst+= TELEGRAM; // Auskommentieren zum aktivieren
//pushdienst+= PUSHOVER; // Auskommentieren zum aktivieren
//pushdienst+= EMAIL; // Auskommentieren zum aktivieren. Einstellungen nicht vergessen
//pushdienst+= SAYIT; // Auskommentieren zum aktivieren. Einstellungen nicht vergessen
//pushdienst+= HOMETWO; // Auskommentieren zum aktivieren. Einstellungen nicht vergessen
//pushdienst+= ALEXA; // Auskommentieren zum aktivieren. Einstellungen nicht vergessen
//pushdienst+= STATE; // Auskommentieren zum aktivieren. State befindet sich unter onClickMessageState.message
//pushdienst+= IOGO; // Auskommentieren zum aktivieren. Einstellungen nicht vergessen
/* Einstellungen zur Emailbenachrichtigung*/
var senderEmailID = ""; // mit Sender Emailadresse füllen. email Adapter muß installiert sein
var empfaengerEmailID = "";// mit Empfänger Emailadresse füllen.
/* Konfiguration Sprachausgabe über Home24-Mediaplayer */
var idMediaplayer = "192.168.178.68:50000"; // Eingabe IP-Adresse incl. Port für Home24-Mediaplayer
/* Konfiguration Sprachausgabe über SayIt */
var idSayIt = "sayit.0.tts.text";
var lautstaerke = 60;
//Konfiguration Sprachausgabe über Alexa
var idAlexaSerial =''; // die reine Seriennummer des Echos z.B.: var idAlexaSerial ='G090RV32984110Y';
var alexaVolumen = 40; // Lautstärke 0-100 (denke ich :) )
//Konfiguration von ioGo
var ioGoUser = ''; // Einzelnutzer 'Hans'; Multinutzer ['Hans','Peter']; Nutzer vom Adapter übernehmen '';
//StatePfad um Mitteilungen auszulösen darunter werden jeweils Punkte für jede Ausgabemöglichkeit erstellt.
var onClickMessageState = 'javascript.0.DWD_Script.'; // abschließender Punkt . nicht vergessen
// Filtereinstellungen
const minlevel = 0 // Warnungen gleich oder unterhalb dieses Levels nicht senden;
const maxhoehe = 1410 // Warnung für eine Höhe oberhalb dieses Wertes nicht senden
//Formatierungsstring für Datum/Zeit Alternative "TT.MM.YYYY SS:mm" KEINE Anpassung nötig
const formatierungString = "TT.MM.YYYY SS:mm";
// Sprachausgabe Zeiten
// Für durchgehende Sprachausgabe die Einstellung der Zeiten auf '' setzen. z.B. var startTimeSpeak = '';
var startTimeSpeak = '6:45';// Zeiten mo-fr ab der Sprachausgaben ok sind. Nicht unter 6 Uhr gehen oder den Schedule ändern
var startTimeSpeakWeekend = '9:00';// sa + so Bemerkung siehe oben
var endTimeSpeak = '22:30'; // ab diesem Zeitpunkt gibt es keine Sprachausgabe
// Automatikmodus auschalten
var autoMode = true;
//Auslösen der Pushnachricht über States ignoriert Sprachausgabezeiten
var forcedSpeak = false;
// ignoriere Warnmeldungen von geringerer Schwere, wenn ansonsten vergleichbare Warnmeldungen vorliegen.
var SkipDuplicates = true;
/* ************************************************************************* */
/* ************************************************************************* */
/* ************************************************************************* */
/* Konfiguration Ende */
/* ************************************************************************* */
/* Keine Anpassungen ab hier, außer du weißt was du tuest */
/* ************************************************************************* */
/* ************************************************************************* */
/* ************************************************************************* */
var idAlexa = 'alexa2.0.Echo-Devices.'+idAlexaSerial+'.Commands.announcement';
var idAlexaVolumen = 'alexa2.0.Echo-Devices.'+idAlexaSerial+'.Commands.speak-volume';
var forceSpeak = false;
/* Arrays festlegen */
const InitArrayLenght = 9;
var newDescriptions = [InitArrayLenght];
var oldDescriptions = [InitArrayLenght];
var newHeadlines = [InitArrayLenght];
var oldHeadlines = [InitArrayLenght];
var newBegins = [InitArrayLenght];
var oldBegins = [InitArrayLenght];
var newEnds = [InitArrayLenght];
var oldEnds = [InitArrayLenght];
var newInstruction = [InitArrayLenght];
var oldData = [InitArrayLenght];
var newData = [InitArrayLenght];
var timer = null;
/* erstmaliges Befüllen der arrays */
for (let a=0;a<InitArrayLenght;a++) {
var id = "dwd.0.warning";
if (a!=0) id+=a.toString();
id+='.object';
var warn = {};
if (existsState(id)) warn = JSON.parse(getState(id).val);
warn = convertJsonDWD(warn);
newDescriptions[a] = warn.description;
oldDescriptions[a] = warn.description;
newHeadlines[a] = warn.headline;
oldHeadlines[a] = warn.headline;
newBegins[a] = warn.start;
oldBegins[a] = warn.start;
newEnds[a] = warn.end;
oldEnds[a] = warn.end;
newData[a] = {"level":warn.level,"type":warn.type};
oldData[a] = {"level":warn.level,"type":warn.type};
}
// State der Pushnachrichten über pushover/telegram spiegelt
const mirrorMessageState = onClickMessageState+'message';
if (!existsState(mirrorMessageState)) {
createState(mirrorMessageState,'', {
read: true,
write: false,
desc: "Beschreibung",
type: "string",
});
}
// State über den man gesonderte Aktionen auslösen kann, gibt die höchste Warnstufe aus.
const AlertState = onClickMessageState+'alertlevel';
if (!existsState(AlertState)) {
createState(AlertState,0, {
read: true,
write: false,
desc: "Beschreibung",
type: "number"
});
} else {
let AlertLevel = -1;
newData.forEach((item, i) => {if (AlertLevel<item.level) AlertLevel = item.level;});
oldData.forEach((item, i) => {if (AlertLevel<item.level) AlertLevel = item.level;});
setState(AlertState,AlertLevel);
}
// Nachrichtenversand per Click States erzeugen und subscript
for (var a=0;a<konstanten.length;a++){
if (!existsState(onClickMessageState+'Commands.'+konstanten[a].name)) {
createState(onClickMessageState+'Commands.'+konstanten[a].name,false, {
read: true,
write: true,
desc: "Beschreibung",
type: "boolean",
def: false
});
}
if (existsState(onClickMessageState+'Commands.'+konstanten[a].name)){
subscribe({id: onClickMessageState+'Commands.'+konstanten[a].name},function(obj){
if (!obj.state.val) return;
setState(obj.id,false,true);
let b = obj.id.split('.');
let d = konstanten.findIndex(function(c){return (c.name===b[b.length-1]);})
if (d == -1) {log('Fehler. State nicht in Konstanten enthalten','error'); return;}
if ((pushdienst & konstanten[d].value) == 0) return;
let oldPushdienst = pushdienst;
pushdienst = konstanten[d].value*1;
let tempHeadlines = oldHeadlines.slice();
let tempDescriptions = oldDescriptions.slice();
let tempBegins = oldBegins.slice();
let tempEnds = oldEnds.slice();
for (let i=0;i<oldDescriptions.length;i++) {
oldHeadlines[i] = '';
oldDescriptions[i] = '';
oldBegins[i] = '';
oldEnds[i] = '';
}
forceSpeak = forcedSpeak;
check();
forceSpeak = false;
pushdienst = oldPushdienst;
// sollte überflüssig sein
//oldHeadlines = tempHeadlines.slice();
//oldDescriptions = tempDescriptions.slice();
//oldBegins = tempBegins.slice();
//oldEnds = tempEnds.slice();
})
}
}
// Zeitsteuerung für SayIt & Alexa
var START = new Date();
var ENDE = new Date();
setWeekend();
function setWeekend()
{
if (forceSpeak) return;
let date = new Date();
let n = date.getDay();
let weekend = 0;
weekend = (n === 0 || n == 6) ? 1 : 0;
let d = new Date();
if(weekend == 1){ // wenn Wochenende, dann setze Start auf 9h, sonst 6:45h
var e = startTimeSpeakWeekend.split(':');
d.setHours(e[0]);
d.setMinutes(e[1]);
d.setSeconds(0);
START = d;
}
else{
var e = startTimeSpeak.split(':');
d.setHours(e[0]);
d.setMinutes(e[1]);
d.setSeconds(0);
START = d;
}
var e = endTimeSpeak.split(':');
ENDE = new Date();
ENDE.setHours(e[0]);
ENDE.setMinutes(e[1]);
ENDE.setSeconds(0);
}
function check() {
if (!forcedSpeak) forceSpeak = (!startTimeSpeakWeekend||!startTimeSpeak||!endTimeSpeak);
setWeekend();
// Werfe doppelte Nachrichten raus
if(SkipDuplicates && newDescriptions.findIndex(function(a){return (!a);})!=-1 ) {
for (let a=0; a<newData.length;a++) {
if (newData[a].type==-1) continue;
for (let b=0; b<newData.length;b++) {
if (newData[b].type==-1) continue;
if (
(
a!=b
&& newData[b].type!=-1 // vergleiche neue Daten mit neuen Daten
&& newData[a].type == newData[b].type
&& newData[a].level <= newData[b].level
&& newBegins[a] >= newBegins[b]
&& newEnds[a] <= newEnds[b]
)||(
oldData[b].type!=-1 // vergleiche neue Daten mit alten Daten
&& newData[a].type == oldData[b].type
&& newData[a].level <= oldData[b].level
&& newEnds[a] < oldEnds[b]
)
) { // lösche Daten da diese eine niedrigeres level haben
newDescriptions[a] = '';
newHeadlines[a] = '';
newBegins[a] = '';
newEnds[a] = '';
newData[a].type = -1;
newData[a].level = -1;
}
}
}
}
let AlertLevel = -1;
newData.forEach((item, i) => {if (AlertLevel<item.level) AlertLevel = item.level;});
oldData.forEach((item, i) => {if (AlertLevel<item.level) AlertLevel = item.level;});
setState(AlertState,AlertLevel);
/* Bereich für 'Alle Wetterwarnungen wurden aufgehoben' */
if(newDescriptions.findIndex(function(a){return (!!a);})==-1 && oldDescriptions.findIndex(function(a){return (!!a);})!=-1) {
MeldungSpracheDWD = 'Achtung' + ' . ' + 'Alle Warnmeldungen des DWD wurden aufgehoben';
/* Bereich für Sprachausgabe über SayIt & Alexa & Home24*/
if ( forceSpeak || compareTime(START, ENDE, 'between')){ // Ansage über Sayit nur im definierten Zeitbereich
if ((pushdienst & SAYIT)!=0) {
setState(idSayIt, lautstaerke + ";" + MeldungSpracheDWD);
}
if ((pushdienst & ALEXA)!=0) {
setState(idAlexaVolumen, alexaVolumen);
setState(idAlexa, MeldungSpracheDWD);
}
if((pushdienst & HOMETWO)!=0 ){
var Url = "http://" + idMediaplayer + "/track=4fachgong.mp3|tts=" + MeldungSpracheDWD;
request(Url);
}
}
let pushmsg = 'Alle Warnmeldungen des DWD wurden aufgehoben';
if ((pushdienst & TELEGRAM)!=0 ) {
sendTo ("telegram.0", pushmsg);
}
if ((pushdienst & PUSHOVER)!=0 ) {
sendTo("pushover.0", pushmsg);
}
if ((pushdienst & IOGO)!=0 ) {
sendioGo('Wetterentwarnung', pushmsg);
}
if ((pushdienst & STATE)!=0 ) {
setState(mirrorMessageState, pushmsg);
}
if ((pushdienst & EMAIL)!=0 && senderEmailID != '' && empfaengerEmailID !='') {
sendEmail('Wetterentwarnung des DWD(iobroker)',pushmsg);
}
/* alle Sicherungen Wetterwarnung löschen */
oldHeadlines = newHeadlines.slice();
oldDescriptions = newDescriptions.slice();
oldBegins = newBegins.slice();
oldEnds = newEnds.slice();
oldData = newData.slice();
return;
}
/* Variablen für Meldungen Text */
var MeldungNew = '';
/* Variablen für Meldungen Sprache */
var MeldungSpracheDWD = '';
var MeldungNewSprache = '';
var MeldungOldSprache = '';
var AllEmailMsg = '';
var AllEmailMsgDelete = '';
var headline;
var description;
var begin;
var end;
var i;
var warn;
/* Bereich für 'Wetterwarnung gültig bis wurde aufgehoben' */
for(i = 0; i < newDescriptions.length; i++) {
headline = oldHeadlines[i];
description = oldDescriptions[i];
begin = oldBegins[i];
end = oldEnds[i];
if(description !== undefined && headline !== undefined && description !== '' && newDescriptions.indexOf(description) == -1 ) {
MeldungOldSprache = headline + ' gültig bis ' + getFormatDateSpeak(end) + ' Uhr wurde aufgehoben' + ' . ';
let pushmsg = "Die Wetterwarnung " +"'"+ headline + " gültig bis " + end + "'" + " des DWD wurde aufgehoben";
if ((pushdienst & TELEGRAM)!=0) {
sendTo ("telegram.0", pushmsg);
}
if ((pushdienst & PUSHOVER)!=0) {
sendTo("pushover.0", pushmsg);
}
if ((pushdienst & IOGO)!=0) {
sendioGo('Wetterentwarnung',pushmsg);
}
if ((pushdienst & STATE)!=0 ) {
setState(mirrorMessageState, pushmsg);
}
if ((pushdienst & EMAIL)!=0 && senderEmailID!= '' && empfaengerEmailID!='') {
AllEmailMsgDelete+=pushmsg+'\n\n';
}
/* Verknüpfen aller aufgehobenen Wetterwarnungen */
if(MeldungOldSprache !== "" && MeldungOldSprache !== undefined){
MeldungSpracheDWD = MeldungSpracheDWD + MeldungOldSprache;
}
}
}
/* Bereich für 'Neue Amtliche Wetterwarnung' */
for(i = 0; i < newDescriptions.length; i++) {
headline = newHeadlines[i];
description = newDescriptions[i];
begin = newBegins[i];
end = newEnds[i];
var instruction = newInstruction[i];
if(description !== undefined && description !== "" && oldDescriptions.indexOf(description) == -1 ) {
MeldungNew = headline + "\ngültig vom " + begin + " Uhr bis " + end + " Uhr\n" + description;
if (!!instruction && typeof instruction === 'string' && instruction.length > 2) MeldungNew+='\nHandlungsanweisungen: '+instruction;
/* Entfernen °C für Sprachausgabe */
var replaceDescription0 = entferneDatenpunkt(description);
MeldungNewSprache = headline + " gültig vom " + getFormatDateSpeak(begin) + " Uhr, bis " + getFormatDateSpeak(end) + " Uhr. " + replaceDescription0 + ' . ';
if (!!instruction && typeof instruction === 'string' && instruction.length > 2) MeldungNewSprache+='Handlungsanweisungen: '+instruction;
if ((pushdienst & TELEGRAM)!=0) {
sendTo ("telegram.0", MeldungNew);
}
if ((pushdienst & PUSHOVER)!=0) {
sendTo("pushover.0", MeldungNew);
}
if ((pushdienst & IOGO)!=0) {
sendioGo('Wetterwarnung',MeldungNew);
}
if ((pushdienst & STATE)!=0 ) {
setState(mirrorMessageState,MeldungNew);
}
if ((pushdienst & EMAIL)!=0 && senderEmailID!= '' && empfaengerEmailID!='') {
AllEmailMsg+=MeldungNew+'\n\n';
}
/* Verknüpfen aller neuen Warnmeldungen */
if(MeldungNewSprache !== "" && MeldungNewSprache !== undefined){
MeldungSpracheDWD = MeldungSpracheDWD + MeldungNewSprache;
}
}
}
/* Verknüpfen aller neuen und abgelaufenen Warnmeldungen */
MeldungSpracheDWD = 'Achtung . ' + MeldungSpracheDWD;
/* Bereich für Sprachausgabe über Home24-Mediaplayer */
if((forceSpeak || compareTime(START, ENDE, 'between') ) && (pushdienst & HOMETWO)!=0 && (MeldungSpracheDWD !== "" )){
var Url2 = "http://" + idMediaplayer + "/track=4fachgong.mp3|tts=" + MeldungSpracheDWD;
log('Url2 :' + Url2);
request(Url2);
}
/* Bereich für Sprachausgabe über SayIt + Alexa */
if (MeldungSpracheDWD !== "" && (forceSpeak || compareTime(START, ENDE, 'between'))){
if ((pushdienst & SAYIT)!=0) setState(idSayIt, lautstaerke + ";" + MeldungSpracheDWD);
if ((pushdienst & ALEXA)!=0) {
setState(idAlexaVolumen, alexaVolumen);
setState(idAlexa, MeldungSpracheDWD);
}
}
AllEmailMsg+=AllEmailMsgDelete;
if ((pushdienst & EMAIL)!=0 && senderEmailID != '' && empfaengerEmailID != '' && AllEmailMsg != '') {
sendEmail("Wetterwarnungen des DWD(iobroker)",AllEmailMsg);
}
/* Neue Werte sichern */
oldHeadlines = newHeadlines.slice();
oldDescriptions = newDescriptions.slice();
oldBegins = newBegins.slice();
oldEnds = newEnds.slice();
oldData = newData.slice();
}
/* Entfernt "°C" aus Sprachmeldung und ersetzt es durch "Grad" */
function entferneDatenpunkt(beschreibung) {
var rueckgabe;
rueckgabe = beschreibung;
try {
rueckgabe = rueckgabe.replace(/\°C/g, "Grad");
rueckgabe = rueckgabe.replace(/\km\/h/g, "Kilometer pro Stunde");
rueckgabe = rueckgabe.replace(/\kn/g, " Knoten");
rueckgabe = rueckgabe.replace(/\bft/g, " Windstärke");
rueckgabe = rueckgabe.replace(/\m\/s/g, " Meter pro Sekunde");
}
catch(e) {}
return rueckgabe;
}
on(/^dwd\.0\..*\.object$/, function(dp) {
let i = getIdIndex(dp.id);
var warn = null;
if (dp.state.val != '') warn = JSON.parse(dp.state.val);
warn = convertJsonDWD(warn);
newDescriptions[i] = warn.description ;
newHeadlines[i] = warn.headline;
newBegins[i] = warn.start;
newEnds[i] = warn.end;
newInstruction[i] = warn.instruction;
newData[i].level = warn.level;
newData[i].type = warn.type;
if(timer) clearTimeout(timer);
if (autoMode) timer = setTimeout(check, 10000);
});
function convertJsonDWD(warn) {
warn = (!warn || warn === ''? {} : warn);
if (warn != {} && (warn.altitudeStart>maxhoehe || warn.level < minlevel)) warn = {};
let a = warn.description === undefined ? '' : warn.description;
let b = warn.headline === undefined ? '' : warn.headline;
let c = warn.start === undefined ? '' : getFormatDate(new Date(warn.start));
let d = warn.end === undefined ? '' : getFormatDate(new Date(warn.end));
let e = warn.instruction === undefined ? '' : warn.instruction;
let f = warn.type === undefined ? -1 : warn.type;
let g = warn.level === undefined ? -1 : warn.level;
return {"description":a,"headline":b,"start":c,"end":d,"instruction":e,"type":f,"level":g};
}
function getIdIndex(a) {
a = a.split('.');
if (a[2].length == 7) return 0
return a[2][7];
}
function getFormatDate(a) {
if (!a || a === '') return '';
return formatDate(a.getTime(), formatierungString);
}
// @PARAM Rückgabe von getFormatDate
function getFormatDateSpeak(a) {
if (!a || a === '') return '';
let b = a.split('.');
let m = '';
switch (b[1]) {
case '01': m='Januar';break;
case '02': m='Februar';break;
case '03': m='März';break;
case '04': m='April';break;
case '05': m='Mai';break;
case '06': m='Juni';break;
case '07': m='Juli';break;
case '08': m='August';break;
case '09': m='September';break;
case '10': m='Oktober';break;
case '11': m='November';break;
case '12': m='Dezember';break;
default: m='';
}
b[1]=m; // setze Monatsname
// entferne Jahr
let c = b[2].split(' ');
c[0]='';
b[2] = c.join(' ');
return b.join(' ');
}
function sendEmail(topic, msg) {
if (senderEmailID=='') {
log('senderEmailID ist nicht definiert!','warn');
return;
}
if (empfaengerEmailID=='') {
log('empfaengerEmailID ist nicht definiert!','warn');
return;
}
sendTo("email", {
from: senderEmailID,
to: empfaengerEmailID,
subject: topic,
text: msg
});
}
function sendioGo(topic, msg) {
if ((pushdienst & IOGO)!=0) {
if (ioGoUser) {
sendTo('iogo.0', "send", {
user: ioGoUser,
text: topic,
title: msg
});
} else {
sendTo('iogo.0', "send", {
text: topic,
title: msg
});
}
}
}
Hab die als Beispiel drin, weil ich denke das nicht jeder weiß was ich meine. Ist aber verwirrend hast recht. In der nächsten Version steht die als Beispiel in den Kommentaren.
