@mickym

Und Dein letzter Satz stimmt einfach nicht - bei mir geht das ohne Probleme.

Tja, nach meiner heutigen Erfahrung hat Du mit der letzten Aussage wohl recht - es geht.

Ich habe jetzt nochmal probiert - auf einmal ging es obwohl ich mir mehr wie sicher bin, es bereits am Wochenende probiert zu haben. Keine Ahnung, was zwischen evtl. Tippfehlern und nicht gemachten Neustarts des Adapters nicht korrekt war.

Also, der Trick ist: Man muss in dem Objekt, welches den Topic repräsentieren soll, unter dem Reiter NATIV einen Paramter topic anlegen, welcher als Inhalt genau den Topic hat , den man senden möchte. In meinem Beispiel also:

Dieser Topic wird dann vom MQTT Adapter genauso veröffentlicht. Puh, ich könnte schwören, das hatte ich das am Wochenende genauso getestet hatte.

Der MQTT Adapter muss dann nur diesen (oder auch noch andere) Objektbaum abonnieren, wie hier:

Dann veröffentlicht er das bei jeder Änderung im Objekt ohne irgendwelche Zusätze.
Und da ich den Objekt-Baum des Adapers selbst nicht abonniere, ist es auch egal, was sich dort ändert.

Nebenbei, ich konnte jetzt keine negativen Effekte erkennen, im Adapter Publish bei Änderungen und Bekanntgabe eigene States beim Verbinden anzukreuzen.
Und diese beiden Funktionen benötige ich ja auch. Oder?

Das Einzige, was mich jetzt noch stört, hat scheinbar was mit Mosquitto zu tun oder ist ein Thema des MQTT Protokolls:
Da der MQTT Adapter alles abonniert, was mit instar anfängt, sendet der Mosquitto Broker auch immer die Veröffentlichung des MQTT Adapters wieder zurück an diesen. Warum, verstehe ich noch nicht ganz. Liegt aber einfach nur daran, dass der Adapter eben alles zu diesem Präfix-Topic abonniert hat. Auch die eigenen Meldungen

Bin jetzt sehr zufrieden, habe einen MQTT Broker der unabhängig vom ioBroker funktioniert, was später evtl. eine Spielwiese für andere Projekte öffnet

@uli977
Gut, dann war es doch die fehlende "1"

Hier als Startpunkt mal meine Registereinstellungen. Hatte lange gebraucht zu kapieren, wie es funktioniert.

@hank-0
Bist Du dir sicher, dass der Wert im SM überhaupt zur Verfügung steht?

Ich berechne ihn innerhalb von ioBroker, da der Wert nicht zur Verfüguing steht.

Marc

Hallo zusammen,

ich setze gerade meinen Raspi neu auf und komme da an ein paar Dingen vorbei.

Mir ist aufgefallen, dass Grafana von Backitup garnie gesichert wurde (keine Ahnung, war mir keiner Meldung bewusst).
Aber egal, es liegt daran, dass ich ein eignes Zertifikat nutze. Dafür wurde ab 2.5.x ja die Option zum Zulassen selbst signierter Zertifikate hinzugefügt. Wenn ich diese nutze, funktioniert das Backup

Aber: Ich habe ein selbst signiertes Zertifikat, habe aber mein CA überall wo mir bekannt hinterlegt (also Raspis, PCs, Smartphnes etc.)

Trotzdem wird Grafana nur gesichert, wenn ich die Prüfung deaktiviere.
Daher meine Frage: Wo prüft der Backitup Adapter, ob das Zertifikat signiert ist? D.h. welche CA Liste nutzt er?

Danke

Marc

@chefkoch009
Habe diesen Verzögerungseffekt zB auch beim Senden von Datum / Uhrzeit aus ioBroker an KNX. In Version 2.0.13 passiert das nicht.

@e-s
Ah, danke!
Interessant, hätte ich nie gefunden

Sieht auf den ersten Blick noch rudimentär aus aber werde ich bei Gelegenheit mal testen.
Mit dem Skript läuft es ganz gut. Lediglich der Erfolg, die Lautstärke automatisch anzupassen, wenn das Radio (z.B. spät Abends) eingeschaltet wird, ist vom Zeitpunkt des Befehls abhängig, ob es klappt.
Naja, gut zu wissen.

@martybr
Gerne:

@uli977
Gut, dann war es doch die fehlende "1"

Hier als Startpunkt mal meine Registereinstellungen. Hatte lange gebraucht zu kapieren, wie es funktioniert.

@uli977
Falls es hilft: Nutze die gleichen Einstellungen in Verbindung mit dem KSEM und einem PIKO 12.
Das einzige, was mir auffällt, ist das Abfrageintervall (habe 2000ms), denke aber das ist nicht das Problem.
Z.Info, am Piko habe ich die Modbus Adresse 1 eingestellt.
Erinnere mich, habe lange mit den Registereinstellungen herumgemacht, bis es funktioniert hat.

@crunchip @CKO

ja, so ist es (wohl). Habe diese Korrektur bei mir bereits vorgenommen, daher hier gerne zum C&P.

Und wirklich, funktioniert prima als Skript! Aber ein Adapter wäre auch etwas schönes

Off topic: Seit iOS15 ist die Busch Jäger App nicht mal mehr aufrufbar am Telefon

/* Change history:
v1.2
- added ack: true to setstates() command when states are updated by the radio

v1.1
- comment of line var RadioIpaddress as no longer used due to multi radio support
- found bug: if IP address not correct, the jscript adapter crashes; has to be fixed. How?
- added function onClose to relese the socket binding when script ist stopped / restarted
  otherwise restart throws an error due to binding to port not possible as still blocked

v1.0 script copy of ioBroker forum from user intruder7
*/

var pfad = 'Geraete.BuschJaeger.RadioINet.';
var pfad2 = 'javascript.0.' + pfad
 // vollständiger id Pfad wird: pfad2 + radio.pfad

var UDPListenPort = 4242; //nicht ändern 
var UDPPort = 4244; //nicht ändern 
// var RadioIPadress = '192.168.2.67' // IP Adresse des Radios
var HOST = '0.0.0.0'; //nicht ändern 

var logging = false;
 
/* ToDo: 
- wenn IP nicht korrekt, stürzt der komplette jscript Adapter ab!
  Grund: Das sende-Kommando kann nicht gebaut werden: radio.path ist undefined für die IP
- Prüfen, ob sendcmd und sendcmdToIP vereinheitlicht werden kann
  sendcmd: sendet an alle Radios
  sendcmdToIP: sendet nur an ein bestimmtes Radio
*/

const radios =  [
     {
             IP: '192.168.2.67',
             pfad: 'Bad'
     }/*,
    {
             IP: '192.168.100.74',
             pfad: 'Keller'
            }        */
];


// ab hier nichts mehr ändern 

var dgram = require('dgram');
var socket = dgram.createSocket('udp4');
var server = dgram.createSocket('udp4');
//var server2 = dgram.createSocket('udp4');
 

const getRadioForIP= (IP)=>{
    return radios.find(radio=>radio.IP == IP )
}

const createAllStates = ()=>{    
    radios.forEach((radio)=>{createRadioState(radio);});    
};

const createRadioState = (radio)=>{
createState(pfad+ radio.pfad +"."+ "Command", '', { type: 'string', name: 'Last command', write: false });
createState(pfad+ radio.pfad +"."+ "WLAN_STRENGTH", '', { type: 'string', name: 'WLAN strength', write: false, unit: 'dBm' });
createState(pfad+ radio.pfad +"."+ "NAME", '', { type: 'string', name: 'Name of radio', write: false });
createState(pfad+ radio.pfad +"."+ "ID", '', { type: 'string', name: 'UDP ID', write: false });
createState(pfad+ radio.pfad +"."+ "IPADDR", '', { type: 'string', name: 'IP adress', write: false });
createState(pfad+ radio.pfad +"."+ "IPMASK", '', { type: 'string', name: 'IP Mask', write: false });
createState(pfad+ radio.pfad +"."+ "IPMODE", '', { type: 'string', name: 'IP  Mode', write: false });
createState(pfad+ radio.pfad +"."+ "GATEWAY", '', { type: 'string', name: 'Gateway', write: false });
createState(pfad+ radio.pfad +"."+ "SSID", '', { type: 'string', name: 'SSID', write: false });
createState(pfad+ radio.pfad +"."+ "MAC_ADRESS", '', { type: 'string', name: 'MAC adress', write: false });
createState(pfad+ radio.pfad +"."+ "COUNTRY", '', { type: 'string', name: 'Country', write: false });
createState(pfad+ radio.pfad +"."+ "SERIAL_NR", '', { type: 'string', name: 'Serial Nr', write: false });
createState(pfad+ radio.pfad +"."+ "SW-VERSION", '', { type: 'string', name: 'Software version', write: false });
createState(pfad+ radio.pfad +"."+ "WLAN-FW", '', { type: 'string', name: 'WLAN Firmware', write: false });

createState(pfad +radio.pfad+ "." + "POWER", '', { type: 'string', name: 'Current state of radio', write: false });
createState(pfad +radio.pfad+ "." + "ENERGY_MODE", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "VOLUME", '', { type: 'number', name: 'VOLUME', write: false });
createState(pfad +radio.pfad+ "." + "PLAYING_MODE", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "PLAYING", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATION_ID_PLAYING", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATION_URL_PLAYING", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATION_PLAYING", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "TUNEIN_ID", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "TUNEIN_SNR", '', { type: 'string', name: '', write: false });

createState(pfad +radio.pfad+ "." + "STATIONS.STATION_1_NAME", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_1_URL", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_2_NAME", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_2_URL", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_3_NAME", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_3_URL", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_4_NAME", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_4_URL", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_5_NAME", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_5_URL", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_6_NAME", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_6_URL", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_7_NAME", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_7_URL", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_8_NAME", '', { type: 'string', name: '', write: false });
createState(pfad +radio.pfad+ "." + "STATIONS.STATION_8_URL", '', { type: 'string', name: '', write: false });

createState(pfad + radio.pfad +"." + "COMMAND.VOLUME_INC", false, { type: 'boolean', name: '', read: false, write: true, role: 'button' });
createState(pfad + radio.pfad +"." + "COMMAND.VOLUME_DEC", false, { type: 'boolean', name: '', read: false, write: true, role: 'button' });
createState(pfad + radio.pfad +"." + "COMMAND.VOLUME_MUTE", false, { type: 'boolean', name: '', read: false, write: true, role: 'switch' });
createState(pfad + radio.pfad +"." + "COMMAND.RADIO_ON", false, { type: 'boolean', name: '', read: false, write: true, role: 'switch' });
createState(pfad + radio.pfad +"." + "COMMAND.PLAY_STATION", 1, { type: 'number', name: 'PLAYING STATION 1-8', read: false, write: true });
createState(pfad + radio.pfad +"." + "COMMAND.VOLUME_SET", 1, { type: 'number', name: 'SET VOLUME 0-31', read: false, write: true });
};

createAllStates();
 server.on('error', (err) => {
    log(`server error:\n${err.stack}`);
    server.close();
});

server.on('listening', function () {
    var address = server.address();
    log('UDP Server listening on ' + address.address + ":" + address.port);
});

try{
server.bind(UDPListenPort);
}

catch(error){console.log(error);}
 

/* server2.on('listening', function () {

    server2.setBroadcast(true);

    server2.setMulticastLoopback(true);

    var address = server2.address();

   log('UDP Server 2 listening on ' + address.address + ":" + address.port);

});

server2.bind(PORT2, HOST); */

 

// Antworten vom Radio auf Abfragen

server.on('message', function (message, remote) {   
    if (logging) log('(148) Meldung vom RADIO: ' + message);
    const radio = getRadioForIP(remote.address);
    var command = findstr("COMMAND:", message);
    if (command == "GET") {

    if (message.indexOf("INFO_BLOCK") >= 0) {

        setState(pfad + radio.pfad + "." + "Command", findstr("COMMAND:", message),true);

        setState(pfad + radio.pfad + "." + "WLAN_STRENGTH", findstr("WLAN STRENGTH:", message),true);

        setState(pfad + radio.pfad + "." + "NAME", findstr("NAME:", message),true);

        setState(pfad + radio.pfad + "." + "ID", findstr("ID:", message),true);

        setState(pfad + radio.pfad + "." + "IPADDR", findstr("IPADDR:", message),true);

        setState(pfad + radio.pfad + "." + "IPMASK", findstr("IPMASK:", message),true);

        setState(pfad + radio.pfad + "." + "IPMODE", findstr("IPMODE:", message),true);

        setState(pfad + radio.pfad + "." + "GATEWAY", findstr("GATEWAY:", message),true);

        setState(pfad + radio.pfad + "." + "SSID", findstr("SSID:", message),true);

        setState(pfad + radio.pfad + "." + "MAC_ADRESS", findstr("MAC:", message),true);

        setState(pfad + radio.pfad + "." + "COUNTRY", findstr("COUNTRY:", message),true);

        setState(pfad + radio.pfad + "." + "SERIAL_NR", findstr("SERNO:", message),true);

        setState(pfad + radio.pfad + "." + "SW-VERSION", findstr("SW-VERSION:", message),true);

        setState(pfad + radio.pfad + "." + "WLAN-FW", findstr("WLAN-FW:", message),true);

    } else if (message.indexOf("VOLUME") >= 0) {

        setState(pfad + radio.pfad + "." + "Command", findstr("COMMAND:", message),true);

        setState(pfad + radio.pfad + "." + "ID", findstr("ID:", message),true);

        setState(pfad + radio.pfad + "." + "VOLUME", parseInt(findstr("VOLUME_SET:", message)),true);

        if (parseInt(findstr("VOLUME_SET:", message)) >= 0 && parseInt(findstr("VOLUME_SET:", message)) <= 31 && message.indexOf("RESPONSE:ACK") >= 0) {

            setState(pfad + radio.pfad + "." + "COMMAND.VOLUME_SET", parseInt(findstr("VOLUME_SET:", message)), true);

        }

    } else if (message.indexOf("POWER_STATUS") >= 0) {

        setState(pfad + radio.pfad + "." + "Command", findstr("COMMAND:", message),true);

        setState(pfad + radio.pfad + "." + "ID", findstr("ID:", message),true);

        setState(pfad + radio.pfad + "." + "POWER", findstr("POWER:", message),true);

        if (findstr("POWER:", message) == "ON") {

            setState(pfad + radio.pfad + "." + "COMMAND.RADIO_ON", true, true)

        } else if (findstr("POWER:", message) == "OFF") {

            setState(pfad + radio.pfad + "." + "COMMAND.RADIO_ON", false, true)

        };

        setState(pfad + radio.pfad + "." + "ENERGY_MODE", findstr("ENERGY_MODE:", message),true);

    } else if (message.indexOf("TUNEIN_PARTNER_ID") >= 0) {

        setState(pfad + radio.pfad + "." + "Command", findstr("COMMAND:", message),true);

        setState(pfad + radio.pfad + "." + "ID", findstr("ID:", message),true);

        setState(pfad + radio.pfad + "." + "TUNEIN_ID", findstr("PARTNERID:", message),true);

        setState(pfad + radio.pfad + "." + "TUNEIN_SNR", findstr("SERNO:", message),true);

    } else if (message.indexOf("ALL_STATION_INFO") >= 0) {

        setState(pfad + radio.pfad + "." + "Command", findstr("COMMAND:", message),true);

        setState(pfad + radio.pfad + "." + "ID", findstr("ID:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_1_NAME", findstr("1\r\nNAME:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_1_URL", findstr(findstr("1\r\nNAME:", message) + '\r\nURL:', message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_2_NAME", findstr("2\r\nNAME:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_2_URL", findstr(findstr("2\r\nNAME:", message) + '\r\nURL:', message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_3_NAME", findstr("3\r\nNAME:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_3_URL", findstr(findstr("3\r\nNAME:", message) + '\r\nURL:', message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_4_NAME", findstr("4\r\nNAME:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_4_URL", findstr(findstr("4\r\nNAME:", message) + '\r\nURL:', message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_5_NAME", findstr("5\r\nNAME:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_5_URL", findstr(findstr("5\r\nNAME:", message) + '\r\nURL:', message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_6_NAME", findstr("6\r\nNAME:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_6_URL", findstr(findstr("6\r\nNAME:", message) + '\r\nURL:', message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_7_NAME", findstr("7\r\nNAME:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_7_URL", findstr(findstr("7\r\nNAME:", message) + '\r\nURL:', message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_8_NAME", findstr("8\r\nNAME:", message),true);

        setState(pfad + radio.pfad + "." + "STATIONS.STATION_8_URL", findstr(findstr("8\r\nNAME:", message) + '\r\nURL:', message),true);

    } else if (message.indexOf("PLAYING_MODE") >= 0) {

        setState(pfad + radio.pfad + "." + "Command", findstr("COMMAND:", message),true);

        setState(pfad + radio.pfad + "." + "ID", findstr("ID:", message),true);

        setState(pfad + radio.pfad + "." + "PLAYING_MODE", findstr("MODE:", message),true);

        setState(pfad + radio.pfad + "." + "PLAYING", findstr("PLAYING:", message),true);

        setState(pfad + radio.pfad + "." + "STATION_ID_PLAYING", findstr("N\r\nID:", message),true);

        setState(pfad + radio.pfad + "." + "STATION_URL_PLAYING", findstr("URL:", message),true);

        setState(pfad + radio.pfad + "." + "STATION_PLAYING", findstr("NAME:", message),true);

    };

} else if (command == "NOTIFICATION") {

    var event = findstr("EVENT:", message);

    setState(pfad + radio.pfad + "." + "Command", findstr("COMMAND:", message),true);

    setState(pfad + radio.pfad + "." + "IPADDR", findstr("IP:", message),true);

    setState(pfad + radio.pfad + "." + "NAME", findstr("NAME:", message),true);

    if (logging) log("Event = '" + event + "'");

   

    if (event == 'POWER_OFF' || event == 'POWER_ON') {

        sendcmd('COMMAND:GET\r\nPOWER_STATUS\r\nID:ioBroker\r\n\r\n');

    };

    if (event == "VOLUME_CHANGED") {

        sendcmd('COMMAND:GET\r\nVOLUME\r\nID:ioBroker\r\n\r\n');

    };

    if (event == 'STATION_CHANGED') {

    };

} else if (command == "SET") {

    if (message.indexOf("VOLUME_ABSOLUTE") >= 0 && message.indexOf("RESPONSE:ACK") >= 0) {

        setState(pfad + radio.pfad + "." + "VOLUME", parseInt(findstr("VOLUME_SET:", message)), true);

        setState(pfad + radio.pfad + "." + "COMMAND.VOLUME_SET", parseInt(findstr("VOLUME_SET:", message)), true)

    }

    if (message.indexOf("VOLUME_DEC") >= 0 && message.indexOf("RESPONSE:ACK") >= 0) {

        setState(pfad + radio.pfad + "." + "VOLUME", parseInt(findstr("VOLUME_SET:", message)), true);

        setState(pfad + radio.pfad + "." + "COMMAND.VOLUME_SET", parseInt(findstr("VOLUME_SET:", message)), true)

    }

    if (message.indexOf("VOLUME_INC") >= 0 && message.indexOf("RESPONSE:ACK") >= 0) {

        setState(pfad + radio.pfad + "." + "VOLUME", parseInt(findstr("VOLUME_SET:", message)), true);

        setState(pfad + radio.pfad + "." + "COMMAND.VOLUME_SET", parseInt(findstr("VOLUME_SET:", message)), true)

    }

    if (message.indexOf("VOLUME_UNMUTE") >= 0 && message.indexOf("RESPONSE:ACK") >= 0) {

        setState(pfad + radio.pfad + "." + "COMMAND.VOLUME_MUTE", false, true)

    }

    if (message.indexOf("VOLUME_MUTE") >= 0 && message.indexOf("RESPONSE:ACK") >= 0) {

        setState(pfad + radio.pfad + "." + "COMMAND.VOLUME_MUTE", true, true)

    }

    if (message.indexOf("RADIO_OFF") >= 0 && message.indexOf("RESPONSE:ACK") >= 0) {

        setState(pfad + radio.pfad + "." + "COMMAND.RADIO_ON", false, true);

        setState(pfad + radio.pfad + "." + "POWER", "OFF",true);

    }

    if (message.indexOf("RADIO_ON") >= 0 && message.indexOf("RESPONSE:ACK") >= 0) {

        setState(pfad + radio.pfad + "." + "COMMAND.RADIO_ON", true, true);

        setState(pfad + radio.pfad + "." + "POWER", "ON",true);

    }

} else if (command == "PLAY") {

    if (message.indexOf("STATION") >= 0 && message.indexOf("RESPONSE:ACK") >= 0) {

        setState(pfad + radio.pfad + "." + "COMMAND.PLAY_STATION", parseInt(findstr("STATION:", message)), true);

        setState(pfad + radio.pfad + "." + "STATION_ID_PLAYING", parseInt(findstr("STATION:", message)), true);

        setState(pfad + radio.pfad + "." + "STATION_PLAYING", findstr("PLAYING:", message), true);

    }

} else {

 

    if (logging) log('unexpected message: ' + message);

 

}

});

 

// starten der Abfragen nach Empfang von Broadcasts

/* var timer = null;

 

server2.on('message', function (message, remote) {

    if (timer) clearTimeout(timer);

    if (logging) log('Broadcast vom Radio: ' + message);

    if (logging) log(JSON.stringify(message));

    //var obj = JSON.parse('{'+message+'}');

    sendcmd(buf2);

    timer = setTimeout(function () {

        sendcmd(buf3);

    }, 1000);

}); */

function findstr(name, str) {

    var suchstring = String(name);

    var teststring = String(str);

    var pos = (teststring.indexOf(suchstring) + suchstring.length);

    var zaehler = (pos) + 1;

    //log("String: " + suchstring + "befindet sich an " + pos + " Stelle")

    do {

        var Zeichen = String(teststring).charCodeAt(zaehler);

        //log ("Zeichen: " + Zeichen + " Zähler: " + (zaehler - pos));

        zaehler = zaehler + 1;

    } while (Zeichen != 13 && zaehler - pos <= 100);

 

 

    //log("Start: " + pos + "Ende: " + zaehler);

    var ergebnis = String(str).substring(pos, zaehler - 1);

    if (teststring.indexOf(suchstring) == -1) {

        ergebnis = ""

    };

 

    //log("Objekt: " + name + " Wert: '" + ergebnis + "'");

    return ergebnis

}

 

 

function sendcmd(cmd) {

    radios.forEach(radio=>{       

    socket.send(cmd, 0, cmd.length, UDPPort, radio.IP, function (err, result) {

        if (err) log('Fehler Senden ' + cmd, 'error');

        else {

            if (logging) log('(477) Kommando gesendet: ' + cmd);

        }

    });})   

}

 

function sendcmdToIp(cmd,IP) {    

    socket.send(cmd, 0, cmd.length, UDPPort, IP, function (err, result) {

        if (err) log('Fehler Senden ' + cmd, 'error');

        else {

            if (logging) log('(495) Kommando gesendet: ' + cmd);

        }

    });   

}

 

//einmalige Ausführung beim  Starten des Skriptes

sendcmd('COMMAND:GET\r\nPOWER_STATUS\r\nID:ioBroker\r\n\r\n');

sendcmd('COMMAND:GET\r\nVOLUME\r\nID:ioBroker\r\n\r\n');

sendcmd('COMMAND:GET\r\nINFO_BLOCK\r\nID:ioBroker\r\n\r\n');

sendcmd('COMMAND:GET\r\nPLAYING_MODE\r\nID:ioBroker\r\n\r\n');

sendcmd('COMMAND:GET\r\nALL_STATION_INFO\r\nID:ioBroker\r\n\r\n');

 

 

var timer1 = null;

var timer2 = null;

var timer3 = null;

var timer4 = null;

schedule('*/1 * * * *', function () {  // jede Minute die wichtigsten Infos aktualisieren

 

    if (timer1) clearTimeout(timer1);

    timer1 = setTimeout(function () {

        sendcmd('COMMAND:GET\r\nPOWER_STATUS\r\nID:ioBroker\r\n\r\n');

    }, 1000);

    if (timer2) clearTimeout(timer2);

    timer2 = setTimeout(function () {

        sendcmd('COMMAND:GET\r\nVOLUME\r\nID:ioBroker\r\n\r\n');

    }, 2000);

    if (timer3) clearTimeout(timer3);

    timer3 = setTimeout(function () {

        sendcmd('COMMAND:GET\r\nINFO_BLOCK\r\nID:ioBroker\r\n\r\n');

    }, 3000);

    if (timer4) clearTimeout(timer4);

    timer4 = setTimeout(function () {

        sendcmd('COMMAND:GET\r\nPLAYING_MODE\r\nID:ioBroker\r\n\r\n');

    }, 4000);

});

 

schedule('*/30 * * * *', function () {  // alle 30 Minuten die Stationsliste aktualisieren

    sendcmd('COMMAND:GET\r\nALL_STATION_INFO\r\nID:ioBroker\r\n\r\n');

});

 

const initOnForAllRadios =()=>{

    radios.forEach(radio=>

    {

      on({ id: pfad2 + radio.pfad + ".COMMAND.VOLUME_INC", val: true }, function (obj) {                        

            

                 sendcmdToIp('COMMAND:SET\r\nVOLUME_INC\r\nID:ioBroker\r\n\r\n',radio.IP);

                 sendcmdToIp('COMMAND:GET\r\nVOLUME\r\nID:ioBroker\r\n\r\n',radio.IP);

             });                                                                         

 

       on({ id: pfad2 + radio.pfad + ".COMMAND.VOLUME_DEC", val: true }, function (obj) {        

         sendcmdToIp('COMMAND:SET\r\nVOLUME_DEC\r\nID:ioBroker\r\n\r\n',radio.IP);

         sendcmdToIp('COMMAND:GET\r\nVOLUME\r\nID:ioBroker\r\n\r\n',radio.IP);});

       on({ id: pfad2  + radio.pfad + ".COMMAND.VOLUME_MUTE", change: "ne" }, function (obj) {            

            if (obj.state.val === true) {

                sendcmdToIp('COMMAND:SET\r\nVOLUME_MUTE\r\nID:ioBroker\r\n\r\n',radio.IP);}

            if (obj.state.val === false) {

              sendcmdToIp('COMMAND:SET\r\nVOLUME_UNMUTE\r\nID:ioBroker\r\n\r\n',radio.IP);

            }

         sendcmdToIp('COMMAND:GET\r\nVOLUME\r\nID:ioBroker\r\n\r\n',radio.IP);

         });

       on({ id: pfad2 +radio.pfad+ ".COMMAND.RADIO_ON", change: "ne", ack: false }, function (obj) {    

                if (obj.state.val === true) 

                    sendcmdToIp('COMMAND:SET\r\nRADIO_ON\r\nID:ioBroker\r\n\r\n',radio.IP);                

                if (obj.state.val === false) 

                    sendcmdToIp('COMMAND:SET\r\nRADIO_OFF\r\nID:ioBroker\r\n\r\n',radio.IP);    

                sendcmdToIp('COMMAND:GET\r\nPOWER_STATUS\r\nID:ioBroker\r\n\r\n',radio.IP);});

      on({ id: pfad2 +radio.pfad+ ".COMMAND.PLAY_STATION", change: "ne", ack: false }, function (obj) {    

        if (obj.state.val <= 8 && obj.state.val > 0) {

            sendcmdToIp('COMMAND:PLAY\r\nSTATION:' + obj.state.val + '\r\nID:ioBroker\r\n\r\n',radio.IP);}}); 

      on({ id: pfad2+radio.pfad + ".COMMAND.VOLUME_SET", change: "ne", ack: false }, function (obj) {    

        if (obj.state.val <= 31 && obj.state.val >= 0) {

            sendcmdToIp('COMMAND:SET\r\nVOLUME_ABSOLUTE:' + obj.state.val + '\r\nID:ioBroker\r\n\r\n',radio.IP);}});         

    });

};

initOnForAllRadios();

onStop(() => { 

    socket.close();
    server.close();

});

Guten Abend,
ich experimentiere noch relativ frisch (seit 5 Tagen) mit dem modbus Adapter (version 3.4.14). Ich möchte den Kostal Smart Meter (KSM) auslesen. Immerhin bekomme ich schon mal Werte.

Zum Problem:
Beim KSM steht z.B. an Adresse 40020 der Name des Gerätes. Laut Beschreibung von Kostal ist das Register vom Typ string mit size 16:

Das habe ich in der modbus instanz dann eingetragen (Zeile 3):

Dies wirft mir Fehler im Log:

modbus.0 2021-12-14 18:38:45.693	warn	Poll error count: 1 code: {"errorCode":131,"exceptionCode":3,"message":"ILLEGAL DATA VALUE"}
modbus.0 2021-12-14 18:38:45.691	debug	Received pdu describes an error.
modbus.0 2021-12-14 18:38:45.165	debug	[DevID_1/holdingRegs] Poll address 62 - 39974 registers
modbus.0 2021-12-14 18:38:45.163	debug	[DevID_1/holdingRegs] Poll address 26 DONE
modbus.0 2021-12-14 18:38:45.135	debug	[DevID_1/holdingRegs] Poll address 26 - 2 registers
modbus.0 2021-12-14 18:38:45.135	debug	Initialization of scale factors done!
modbus.0 2021-12-14 18:38:45.133	debug	[DevID_1] Poll start ---------------------

Wenn ich nun bei Länge eine 8 Eintrage, funktioniert es. Aber im Objekt fehlt Text (was zu erwarten war)

modbus.0	2021-12-14 19:08:41.709	debug	[DevID_1/holdingRegs] Poll address 40020 DONE
modbus.0	2021-12-14 19:08:41.703	debug	[DevID_1/holdingRegs] Poll address 40020 - 8 registers
modbus.0	2021-12-14 19:08:41.700	debug	[DevID_1/holdingRegs] Poll address 62 DONE
modbus.0	2021-12-14 19:08:41.694	debug	[DevID_1/holdingRegs] Poll address 62 - 2 registers
modbus.0	2021-12-14 19:08:41.691	debug	[DevID_1/holdingRegs] Poll address 26 DONE
modbus.0	2021-12-14 19:08:41.684	debug	[DevID_1/holdingRegs] Poll address 26 - 2 registers
modbus.0	2021-12-14 19:08:41.683	debug	[DevID_1] Poll start ---------------------

Wo ist mein Denkfehler? Und wie muss ich die Ausgabe

address 62 - 39974 registers

im ersten Log interpretieren?

Danke,
Weissnicht

@homoran said in Status vom Kostal Wechselrichter auslesen?:

ach was?

Naja, soll wieder ein Unbedarfter erraten, dass hier die IP ohne http:// angegebn werden soll? Warum ist das dann schon mal so vorbelegt? Frage nach der IP und dann http:// im Feld führt nun mal zu der von mir gemachten Eingabe.