openWB Forum

Code: Alles auswählen

#!/usr/bin/env python3

import syslog
import time
from datetime import datetime, timedelta, timezone
from paho.mqtt import client as mqtt_client
from suntimes import SunTimes

#### config

# hier ortswerte eintragen
latitude = 51
longitude = 11

# welche ladeprofile gesetzt werden sollen
profiles = [ 0 ]

#### end config

mqtthost = "localhost"
mqttport = 1886
mqttclient = "pv-min-adjust"


min_current = None
charge_power = 0.0
client = None

def get_current_start_time() -> float:
    now = datetime.now(timezone.utc)
    now = now.replace(hour = 7, minute = 0, second = 0, microsecond = 0) # start at 7:00 UTC
    return now.timestamp()

def get_current_end_time() -> float:
    try:
        sun = SunTimes(longitude, latitude)
        now = datetime.now(timezone.utc)
        ss = sun.setutc(now).replace(tzinfo=timezone.utc)
        return ss.timestamp()
    except Exception as ex:
        syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: Konnte Sonnenuntergang nicht ermitteln, setze 18 Uhr UTC: "+str(ex))
        now = datetime.now(timezone.utc)
        now = now.replace(hour = 18, minute = 0, second = 0, microsecond = 0)
        return now.timestamp()

def connect_mqtt() -> mqtt_client:
    FIRST_RECONNECT_DELAY = 1
    RECONNECT_RATE = 2
    MAX_RECONNECT_COUNT = 12
    MAX_RECONNECT_DELAY = 60
    def on_connect(client, userdata, flags, rc):
        if rc != 0:
            syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: konnte nicht mit MQTT broker verbinden" +str(rc))
    def on_disconnect(client, userdata, rc):
        syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: Disconnected with result code: "+str(rc))
        reconnect_count, reconnect_delay = 0, FIRST_RECONNECT_DELAY
        while reconnect_count < MAX_RECONNECT_COUNT:
            syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: Reconnecting in "+str(reconnect_delay)+" seconds...")
            time.sleep(reconnect_delay)
            try:
                client.reconnect()
                syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: Reconnected successfully!")
                return
            except Exception as err:
                syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: "+str(err)+". Reconnect failed. Retrying...")

            reconnect_delay *= RECONNECT_RATE
            reconnect_delay = min(reconnect_delay, MAX_RECONNECT_DELAY)
            reconnect_count += 1
        syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: Reconnect failed after "+str(reconnect_count)+" attempts. Exiting...")

    client = mqtt_client.Client(mqttclient)
    client.on_connect = on_connect
    client.on_disconnect = on_disconnect
    client.connect(mqtthost, mqttport)
    return client

def reveice_msg(client, userdata, msg):
    if msg.topic == "openWB/chargepoint/get/power":
        charge_power = float(msg.payload.decode())

def set_min_current(c: int):
    for p in profiles:
        r = client.publish("openWB/set/vehicle/template/charge_template/"+str(p)+"/chargemode/pv_charging/min_current", c)
        if r[0] == 0:
            min_current = c
        else:
            syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: Konnte Mindeststrom über MQTT nicht setzen")


client = connect_mqtt()
client.subscribe("openWB/chargepoint/get/power")
client.on_message = reveice_msg
client.loop_start()

while True:
    try:
        t_start = get_current_start_time()
        t_end = get_current_end_time()
        t_now = time.time()

        if charge_power > 0.0 and t_now < t_end and min_current != 6:
            set_min_current(6)
        elif t_now > t_start and t_now < t_end and min_current != 6:
            set_min_current(6)
        elif t_now >= t_end and min_current != 0:
            set_min_current(0)
        time.sleep(120)
    except Exception as err:
        syslog.syslog(syslog.LOG_NOTICE, "pv-min-adjust: problem occured: "+str(err)+". Restarting...")
        break

client.loop_stop()

Code: Alles auswählen

[Unit]
Description=openWB PV charging minimum adjust
After=syslog.target network.target multi-user.target mosquitto.service

[Service]
ExecStart=/usr/local/bin/pv-min-adjust.py
User=openwb
Restart=on-failure
KillMode=mixed

[Install]
WantedBy=multi-user.target