openWB Forum

Code: Alles auswählen

import random
import time

from paho.mqtt import client as mqtt_client

broker = 'openwb.adwin.de'
port = 1883
topic = "python/mqtt"
# generate client ID with pub prefix randomly
client_id = f'python-mqtt-{random.randint(0, 1000)}'

power = {}
power['openWB/chargepoint/1/get/power'] = 0
power['openWB/chargepoint/2/get/power'] = 0
power['openWB/chargepoint/3/get/power'] = 0
power['openWB/chargepoint/4/get/power'] = 0
oldchargecount = 5

def connect_mqtt():
    def on_connect(client, userdata, flags, rc):
        if rc == 0:
            print("Connected to MQTT Broker!")
        else:
            print("Failed to connect, return code %d\n", rc)

    client = mqtt_client.Client(client_id)
    client.on_connect = on_connect
    client.connect(broker, port)
    return client

def subscribe(client: mqtt_client):
    def on_message(client, userdata, msg):
        global power
        global oldchargecount
        #print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
        power[msg.topic] = msg.payload.decode()
        newchargecount = 0
        for pwr in power:
            if float(power[pwr]) > 0:
                newchargecount += 1
        if newchargecount != oldchargecount:
            print(f"Parallele Ladungen geändert von {oldchargecount} auf {newchargecount}")
            maxcurrent = 32
            if newchargecount > 1:
                maxcurrent = 16
            if newchargecount > 2:
                maxcurrent = 11
            if newchargecount > 3:
                maxcurrent = 8

            print(f'Setting all Loadpoints to {maxcurrent}')
            for i in range(1,5):
                #print(f'openWB/set/vehicle/template/charge_template/{i}/chargemode/instant_charging/current = {maxcurrent}')
                result = client.publish(f'openWB/set/vehicle/template/charge_template/{i}/chargemode/instant_charging/current', maxcurrent)

            oldchargecount = newchargecount

    client.subscribe('openWB/chargepoint/1/get/power')
    client.subscribe('openWB/chargepoint/2/get/power')
    client.subscribe('openWB/chargepoint/3/get/power')
    client.subscribe('openWB/chargepoint/4/get/power')
    client.on_message = on_message


def run():
    client = connect_mqtt()
    subscribe(client)
    client.loop_forever()

if __name__ == '__main__':
    run()

Code: Alles auswählen

2022-12-07 14:25:20,406 - {soc.modules.update_soc:57} - {ERROR:update_soc} - Fehler im Main-Modul
Traceback (most recent call last):
  File "/var/www/html/openWB/packages/modules/update_soc.py", line 44, in _get_threads
    soc_update_data = self._get_soc_update_data(ev.num)
  File "/var/www/html/openWB/packages/modules/update_soc.py", line 66, in _get_soc_update_data
    cp_data = copy.deepcopy(data.data.cp_data)
  File "/usr/lib/python3.9/copy.py", line 146, in deepcopy
    y = copier(x, memo)
  File "/usr/lib/python3.9/copy.py", line 229, in _deepcopy_dict
    for key, value in x.items():
RuntimeError: dictionary changed size during iteration

Code: Alles auswählen

{
    "request_interval_charging": 5,
    "request_interval_not_charging": 720,
    "request_only_plugged": false
  }

Code: Alles auswählen

#!/bin/bash
tmpFile=/tmp/int.tmp
mosquitto_sub -C 1 -t openWB/vehicle/template/ev_template/3 | jq > $tmpFile

int_ch=`cat $tmpFile | grep interval_charging | awk -F":" '{print $2}' | awk -F"," '{print $1}' | tr -d " "`
int_no_ch=`cat $tmpFile | grep interval_not_charging | awk -F":" '{print $2}' | awk -F"," '{print $1}' | tr -d " "`
echo "interval_charging: $int_ch, enter new value"
read i1
echo "interval_not_charging: $int_no_ch, enter new value"
read i2

new=`sed "
/interval_charging/s/:.*,/:$i1,/
/interval_not_charging/s/:.*,/:$i2,/
" < $tmpFile`
echo "new settings:"
echo $new | jq
echo "publish(Y)?"
read a
if [ "$a" = "Y" ]
then
    mosquitto_pub -t openWB/set/vehicle/template/ev_template/3 -m "$new"
fi
if [ $? -eq 0 ]
then
    echo "publish successful"
else
    echo "publish failed"
fi