[Frage] Elektroauto Ladestation Steuerung/Überwachung

ehome

So, es läuft soweit – allerdings ist mir folgendes nicht klar.

__Laut Beschreibung sendet die Box via Broadcast Statusänderungen der wichtigsten Lade-Parameter

um unnötig häufiges Pollen zu verhindern.

„The broadcast messages are intended to avoid the permanent polling of the following described reports.

If there is a change of the status, the authorization, the enable input X1, the maximum possible current presets

(temperature reduction), or an increase of the energy value a message is generated for the change.

For a detailed evaluation of the status, the corresponding report can be queried“__

Wenn ich etwas an der Box ändere (z.B. über die HomeMatic den X1 ein bzw. ausschalte) wird von dem Script aber keine Broadcast empfangen.

Ich kann aber auch nicht überprüfen ob eine gesendet wird …..

Die Anfragen die ich polle werden sauber verarbeitet. Eigentlich sollte doch der Socket auch die Broadcasts mitbekommen - oder ??

Hier das komplette receiver-Skript:

var PORT = 7090;
var HOST = '0.0.0.0';
var pfad = 'Wallbox.KEBA.'; 

// report 1

createState(pfad+"Product",       "unset", {name: 'Model name (variant)'});
createState(pfad+"Serial",        "unset", {name: 'Serial number'});
createState(pfad+"Firmware",      "unset", {name: 'Firmware version'});

// report 2

createState(pfad+"State",        0,   {type: 'number', name: 'Current state of the wallbox'});
createState(pfad+"Error1",       0,   {type: 'number', name: 'Detail code for state 4'});
createState(pfad+"Error2",       0,   {type: 'number', name: 'Detail code for state 4 b'});
createState(pfad+"Plug",         0,   {type: 'number', name: 'Current condition of the loading connection'});
createState(pfad+"Enable_sys",   0,   {type: 'number', name: 'Enable state for charging'});
createState(pfad+"Enable_user",  0,   {type: 'number', name: 'Enable condition via UDP'});
createState(pfad+"Max_curr",     0,   {type: 'number', unit: 'mA', name: 'Current preset value via Control pilot'});
createState(pfad+"Max_curr_pct", 0,   {type: 'number', unit: '%', name: 'Current preset value via Control pilot in 0,1% of the PWM value'});
createState(pfad+"Curr_HW",      0,   {type: 'number', unit: 'mA', name: 'Highest possible charging current of the charging connection'});
createState(pfad+"Curr_user",    0,   {type: 'number', unit: 'mA', name: 'Current preset value of the user via UDP'});
createState(pfad+"Curr_FS",      0,   {type: 'number', name: 'Current preset value for the Failsafe function'});
createState(pfad+"Tmo FS",       0,   {type: 'number', unit: 's', name: 'Communication timeout before triggering the Failsafe function'});
createState(pfad+"Output",       0,   {type: 'number', name: 'State of the relay output X2'});
createState(pfad+"Input",        0,   {type: 'number', name: 'State of the potential free Enable input X1'});
createState(pfad+"Sec",          0,   {type: 'number', unit: 's', name: 'Current system clock since restart of the wallbox'});

// report 3

createState(pfad+"U1",      0,   {type: 'number', unit: 'V', name: 'Current voltage in V of phase 1'});
createState(pfad+"U2",      0,   {type: 'number', unit: 'V', name: 'Current voltage in V of phase 2'});
createState(pfad+"U3",      0,   {type: 'number', unit: 'V', name: 'Current voltage in V of phase 3'});
createState(pfad+"I1",      0,   {type: 'number', unit: 'V', name: 'Current voltage in mA of phase 1'});
createState(pfad+"I2",      0,   {type: 'number', unit: 'V', name: 'Current voltage in mA of phase 2'});
createState(pfad+"I3",      0,   {type: 'number', unit: 'V', name: 'Current voltage in mA of phase 3'});
createState(pfad+"P",       0,   {type: 'number', unit: 'mW', name: 'Current power in mW (Real Power)'});
createState(pfad+"PF",      0,   {type: 'number', unit: '%', name: 'Power factor in 0,1% (cosphi)'});
createState(pfad+"E_pres",  0,   {type: 'number', unit: 'Wh', name: 'Power consumption of the current loading session in 0,1Wh'});
createState(pfad+"E_total", 0,   {type: 'number', unit: 'Wh', name: 'Total power consumption (persistent) without current loading session 0,1Wh'});

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

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

server.on('message', function (message, remote) {
    // log('Meldung von der Wall Box: ' + message);
        var obj = JSON.parse(message);
        if(obj.ID === '3') {
            // werte report 3
            // log("Obj id:"+obj.ID);
            setState(pfad+"E_pres", 0.1 * obj["E pres"]);  // aktuelle Energiemenge in Wh
            setState(pfad+"U1",     obj.U1);      
            setState(pfad+"U2",     obj.U2);
            setState(pfad+"U3",     obj.U3);
            setState(pfad+"I1",     obj.I1);
            setState(pfad+"I2",     obj.I2);
            setState(pfad+"I3",     obj.I3);
            setState(pfad+"P",      obj.P);
            setState(pfad+"PF",     obj.PF);  
            setState(pfad+"E_pres", obj['E pres']);
            setState(pfad+"E_total",obj['E total']);

        } else if(obj.ID === '2') {
            // werte report 2
            // log("Obj id:"+obj.ID);
            setState(pfad+"State",        obj.State);      
            setState(pfad+"Error1",       obj.Error1);     
            setState(pfad+"Error2",       obj.Error1);     
            setState(pfad+"Plug",         obj.Plug);       
            setState(pfad+"Enable_sys",   obj['Enable sys']); 
            setState(pfad+"Enable_user",  obj['Enable usr']);
            setState(pfad+"Max_curr",     obj['Max curr']);   
            setState(pfad+"Max_curr_pct", obj['Max curr %']);
            setState(pfad+"Curr_HW",      obj['Curr HW']);    
            setState(pfad+"Curr_user",    obj['Curr user']);  
            setState(pfad+"Curr_FS",      obj['Curr FS']);    
            setState(pfad+"Tmo FS",       obj['Tmo FS']);     
            setState(pfad+"Output",       obj.Output);     
            setState(pfad+"Input",        obj.Input);       
            setState(pfad+"Sec",          obj.Sec);        
        } else if(obj.ID === '1') {
            // report 1
            // log("Obj id:"+obj.ID);
            setState(pfad+"Product", obj.Product);
            setState(pfad+"Serial", obj.Serial);
            setState(pfad+"Firmware", obj.Firmware);
        } else {

            //The broadcast messages are intended to avoid the permanent polling of the following described reports.
            //If there is a change of the status, the authorization, the enable input X1, the maximum possible current presets
            //(temperature reduction), or an increase of the energy value a message is generated for the change.
            //For a detailed evaluation of the status, the corresponding report can be queried.

            log('Broadcast from Wallbox: ' + message);
            if (obj.State) {
               setState(pfad+"State",        obj.State);
            }
            if (obj.Plug) {
               setState(pfad+"Plug",         obj.Plug);
            }
            if (obj.Input) {
               setState(pfad+"Input",        obj.Input);
            }
            if (obj['Enable sys']) {
                setState(pfad+"Enable_sys",   obj['Enable sys']);
            }
            if (obj['Max curr']) {
                setState(pfad+"Max_curr",     obj['Max curr']);
            }
            if (obj['E pres']) {
                setState(pfad+"E_pres", obj['E pres']);
            }
        }
});

server.bind(PORT, HOST);

paul53

PF, E_pres und E_total würde ich mit 0.1 multiplizieren, damit der Wert zur Maßeinheit des Datenpunktes passt.
~~@ehome:~~

Eigentlich sollte doch der Socket auch die Broadcasts mitbekommen - oder ?? `
Vielleicht muss man dazu den Sende-Socket nach dem Senden des letzten Kommandos schließen ?

function sendcmd(cmd, close) {
    socket.send(cmd, 0, cmd.length, PORT, HOST, function(err, result) {
        if(err) log('Fehler Senden ' + cmd, 'error');
        if(close) socket.close();
    });
}

sendcmd(buf2, false);
setTimeout(function() {
    sendcmd(buf3, true);
}, 1000);

ehome

hmm, ich habe das Empfangs-Script momentan ohne die Sende Skripts laufen, dann sollte ja irgendetwas von der Wallbox kommen.

Der KEBA Adapter von openhab scheint darauf zu reagieren - allerdings kann es auch sein, dass er ständig pollt …..

paul53

~~@ehome:~~

Der KEBA Adapter von openhab scheint darauf zu reagieren - allerdings kann es auch sein, dass er ständig pollt ….. `
Wenn es sich tatsächlich um Broadcast handelt, sollte jeder Lauscher es mitbekommen.

paul53

Vielleicht muss man auch das Broadcast freigeben ?

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

ehome

schade keine Änderung. Aber immerhin auch keine Fehlermeldung ;)

paul53

Dann gibt es noch das setMulticastLoopback(flag)

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

ehome

nein, keine Änderung.

Ich versuche jetzt erst einmal über irgendein Tool herauzufinden, ob die Box überhaupt broadcastet ….

ehome

so, whireshark zeigt folgendes nach Einschalten der x1 Schnittstelle folgendes an:

~~![](</s><URL url=)<link_text text="http://www.fotos-hochladen.net/uploads/ ... jgoxqe.png">http://www.fotos-hochladen.net/uploads/wallboxwhireshv7yhjgoxqe.png</link_text>" />

ein Broadcast geht also raus ….~~

paul53

~~@ehome:~~

ein Broadcast geht also raus …. `
Ja, an Dst Port 7092.

ehome

Au-ha, das stimmt natürlich :shock: - wäre in der UDP Anleitung von KEBA ja auch mal eine Erwähnung wert gewesen …..

Ok dank Paul53 geht es nun wieder weiter.

Habe nun sowohl die Client-Code-Schnipsel als auch beide Server (Port 7090 & 7092) in ein Skript gepackt,

läuft auch soweit ich das beurteilen kann (richtiger Test erst möglich, wenn mein eAuto dann mal geliefert wird)

Alle 5 Minuten werden Report 2&3 gepollt, jede Stunde Report 1. Kommt zwischendurch ein Broadcast werden Report 2&3 sofort gepollt

var pfad  = 'Wallbox.KEBA.'; 
var PORT  = 7090;
var PORT2 = 7092;
var HOST  = '0.0.0.0';
var BOX   = '192.168.0.11';
var buf1 = new Buffer('report 1');
var buf2 = new Buffer('report 2');
var buf3 = new Buffer('report 3');

var dgram = require('dgram');
var dgram2 = require('dgram');
var dgramc = require('dgram');

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

// report 1

createState(pfad+"Product",       "unset", {name: 'Model name (variant)'});
createState(pfad+"Serial",        "unset", {name: 'Serial number'});
createState(pfad+"Firmware",      "unset", {name: 'Firmware version'});

// report 2

createState(pfad+"State",        0,   {type: 'number', name: 'Current state of the wallbox'});
createState(pfad+"Error1",       0,   {type: 'number', name: 'Detail code for state 4'});
createState(pfad+"Error2",       0,   {type: 'number', name: 'Detail code for state 4 b'});
createState(pfad+"Plug",         0,   {type: 'number', name: 'Current condition of the loading connection'});
createState(pfad+"Enable_sys",   0,   {type: 'number', name: 'Enable state for charging'});
createState(pfad+"Enable_user",  0,   {type: 'number', name: 'Enable condition via UDP'});
createState(pfad+"Max_curr",     0,   {type: 'number', unit: 'mA', name: 'Current preset value via Control pilot'});
createState(pfad+"Max_curr_pct", 0,   {type: 'number', unit: '%', name: 'Current preset value via Control pilot in 0,1% of the PWM value'});
createState(pfad+"Curr_HW",      0,   {type: 'number', unit: 'mA', name: 'Highest possible charging current of the charging connection'});
createState(pfad+"Curr_user",    0,   {type: 'number', unit: 'mA', name: 'Current preset value of the user via UDP'});
createState(pfad+"Curr_FS",      0,   {type: 'number', name: 'Current preset value for the Failsafe function'});
createState(pfad+"Tmo FS",       0,   {type: 'number', unit: 's', name: 'Communication timeout before triggering the Failsafe function'});
createState(pfad+"Output",       0,   {type: 'number', name: 'State of the relay output X2'});
createState(pfad+"Input",        0,   {type: 'number', name: 'State of the potential free Enable input X1'});
createState(pfad+"Sec",          0,   {type: 'number', unit: 's', name: 'Current system clock since restart of the wallbox'});

// report 3

createState(pfad+"U1",      0,   {type: 'number', unit: 'V', name: 'Current voltage in V of phase 1'});
createState(pfad+"U2",      0,   {type: 'number', unit: 'V', name: 'Current voltage in V of phase 2'});
createState(pfad+"U3",      0,   {type: 'number', unit: 'V', name: 'Current voltage in V of phase 3'});
createState(pfad+"I1",      0,   {type: 'number', unit: 'V', name: 'Current voltage in mA of phase 1'});
createState(pfad+"I2",      0,   {type: 'number', unit: 'V', name: 'Current voltage in mA of phase 2'});
createState(pfad+"I3",      0,   {type: 'number', unit: 'V', name: 'Current voltage in mA of phase 3'});
createState(pfad+"P",       0,   {type: 'number', unit: 'mW', name: 'Current power in mW (Real Power)'});
createState(pfad+"PF",      0,   {type: 'number', unit: '%', name: 'Power factor in 0,1% (cosphi)'});
createState(pfad+"E_pres",  0,   {type: 'number', unit: 'Wh', name: 'Power consumption of the current loading session in 0,1Wh'});
createState(pfad+"E_total", 0,   {type: 'number', unit: 'Wh', name: 'Total power consumption (persistent) without current loading session 0,1Wh'});

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

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 auf Abfrage

server.on('message', function (message, remote) {
    log('Meldung von der Wall Box: ' + message);
    var obj = JSON.parse(message);

    if(obj.ID === '3') {

       // werte report 3

       setState(pfad+"U1",     obj.U1);      
       setState(pfad+"U2",     obj.U2);
       setState(pfad+"U3",     obj.U3);
       setState(pfad+"I1",     obj.I1);
       setState(pfad+"I2",     obj.I2);
       setState(pfad+"I3",     obj.I3);
       setState(pfad+"P",      obj.P);
       setState(pfad+"PF",     0.1*obj.PF);  
       setState(pfad+"E_pres", 0.1*obj['E pres']);
       setState(pfad+"E_total", 0.1*obj['E total']);

    } else if(obj.ID === '2') {

        // werte report 2

        setState(pfad+"State",        obj.State);      
        setState(pfad+"Error1",       obj.Error1);     
        setState(pfad+"Error2",       obj.Error1);     
        setState(pfad+"Plug",         obj.Plug);       
        setState(pfad+"Enable_sys",   obj['Enable sys']); 
        setState(pfad+"Enable_user",  obj['Enable user']);
        setState(pfad+"Max_curr",     obj['Max curr']);   
        setState(pfad+"Max_curr_pct", obj['Max curr %']);
        setState(pfad+"Curr_HW",      obj['Curr HW']);    
        setState(pfad+"Curr_user",    obj['Curr user']);  
        setState(pfad+"Curr_FS",      obj['Curr FS']);    
        setState(pfad+"Tmo FS",       obj['Tmo FS']);     
        setState(pfad+"Output",       obj.Output);     
        setState(pfad+"Input",        obj.Input);       
        setState(pfad+"Sec",          obj.Sec);        

    } else if(obj.ID === '1') {

        // report 1

        setState(pfad+"Product", obj.Product);
        setState(pfad+"Serial", obj.Serial);
        setState(pfad+"Firmware", obj.Firmware);

    } else {

          log('unexpected message: ' + message); 

        }
});

// starten der Abfragen nach Empfang von Broadcasts

server2.on('message', function (message, remote) {
       log('Broadcast from Wallbox: ' + message);
       var obj = JSON.parse(message);
       sendcmd(buf2);
       timer = setTimeout(function() {
           sendcmd(buf3);
       }, 1000);
});

function sendcmd(cmd) {
    socket.send(cmd, 0, cmd.length,PORT, BOX, function(err, result) {
        if (err) log('Fehler Senden ' + cmd, 'error');
        else {
            log('Kommando gesendet: ' + cmd );
        }
    });
}

var timer = null;
schedule('*/5 * * * *', function() {  // jede Minute
    if(timer) clearTimeout(timer);
        sendcmd(buf2);
        timer = setTimeout(function() {
            sendcmd(buf3);
        }, 1000);
});

schedule("2 * * * *", function() {  // jede Stunde
    sendcmd(buf1);
});

Könnte man daraus jetzt einfach einen Adapter bauen :?:

paul53

~~@ehome:~~

var dgram = require('dgram');
var dgram2 = require('dgram');
var dgramc = require('dgram');

var socket = dgramc.createSocket('udp4');
var server = dgram.createSocket('udp4');
var server2 = dgram.createSocket('udp4');
```` `

Es genügt sicherlich einmal require.

var dgram = require('dgram');

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

Das Timerobjekt sollte vor einer erneuten Verwendung gelöscht werden (glaub ich).

var timer = null;

server2.on('message', function (message, remote) {
       log('Broadcast from Wallbox: ' + message);
       var obj = JSON.parse(message);
       sendcmd(buf2);
       if(timer) clearTimeout(timer);
       timer = setTimeout(function() {
           sendcmd(buf3);
       }, 1000);
});

Ist das zyklische Senden noch erforderlich, wenn nach jeder Broadcast-Message gesendet wird ? Es ändert sich ja zwischendurch kein Wert.

ehome

Jo, da hast du recht.

Habs rausgenommen - läuft jetzt auch so wie ich es möchte.

Vielen Dank nochmal!

Gesendet von iPad mit Tapatalk

hylamayn.de

~~@ehome:~~

Hallo zusammen,

ich spiele mit dem Gedanken, mir ein eAuto zuzulegen. Das schreit natürlich nach Integration in die Hausautomatisation.

Als Wall-Box habe ich die „KEBA 98.101 KeContact P30 x-series, WLAN“ in die engere Auswahl gezogen.

[…]

Also, vielleicht hat jemand von euch ein ähnliches Projekt in Angriff genommen oder speilt mit dem Gedanken so etwas zu realisieren.

Bin für jede Anregung dankbar. `

Hi,

ähnliche Konfiguration hier: ZoE ;), Keba P30 RFID und LAN und der Wunsch danach, das zu verbinden …

Meine Homeautomation läuft allerdings über Domoticz (auf einem RaspberryPi) ...

Ich hab das gemacht, was Du in einem anderen Thread angesprochen hast: mit einem Wemos mini Modul

(ESP8266) ein Gateway geschaffen, das per WLAN die Wallbox-Reports abfragt, das Abgefragte dann parsed und an

Domoticz weitersendet. Der Grund für diese Vorgehensweise war, dass ich mir das mit dem Skripten nicht

zutraute. Insofern ist Dein Thread hier echt interessant...

Ganz funktionieren will das bei mir noch nicht: Ich bekomme in Domoticz nur einen Teil meiner Werte angezeigt,

warum weiss ich noch nicht. Ausserdem habe ich mich noch nicht wirklich damit beschäftigt, wie man das Ganze

in Domoticz schön darstellen kann.

Grüße,

Christoph

fuchs1978

Ich habe mir nicht den ganzen Beitrag durchgelesen, aber ihr kennt diesen Adapter:

https://github.com/UncleSamSwiss/ioBroker.kecontact

Homoran

~~@fuchs1978:~~

aber ihr kennt diesen Adapter: `
Yepp, siehe:

http://forum.iobroker.net/viewtopic.php … sam#p70685

Gruß

Rainer

Community Forum

NEWS

[Frage] Elektroauto Ladestation Steuerung/Überwachung

Support us

622

32.7k

82.5k

1.3m