mirror of
https://github.com/uhi22/pyPLC.git
synced 2024-11-20 01:13:58 +00:00
27 lines
1.2 KiB
Python
27 lines
1.2 KiB
Python
|
import paho.mqtt.client as mqtt
|
||
|
|
from configmodule import getConfigValue, getConfigValueBool
|
||
|
|
|
||
|
|
def mqtt_on_connect(client, userdata, flags, rc):
|
||
|
|
client.subscribe(getConfigValue("mqtt_topic") + "/#")
|
||
|
|
|
||
|
|
def mqtt_on_message(client, userdata, msg):
|
||
|
|
global simulatedInletVoltage
|
||
|
|
if msg.topic == getConfigValue("mqtt_topic") + "/fsm_state":
|
||
|
|
if "CableCheck" in msg.payload.decode("utf-8"):
|
||
|
|
simulatedInletVoltage = 0
|
||
|
|
if "PreCharging" in msg.payload.decode("utf-8"):
|
||
|
|
client.publish(getConfigValue("mqtt_topic") + "/inlet_voltage", simulatedInletVoltage)
|
||
|
|
simulatedInletVoltage = simulatedInletVoltage + 15
|
||
|
|
elif msg.topic == getConfigValue("mqtt_topic") + "/pev_voltage":
|
||
|
|
client.publish(getConfigValue("mqtt_topic") + "/inlet_voltage", msg.payload)
|
||
|
|
elif msg.topic == getConfigValue("mqtt_topic") + "/pev_current":
|
||
|
|
client.publish(getConfigValue("mqtt_topic") + "/target_current", msg.payload)
|
||
|
|
|
||
|
|
simulatedInletVoltage = 0
|
||
|
|
mqttclient = mqtt.Client()
|
||
|
|
mqttclient.on_connect = mqtt_on_connect
|
||
|
|
mqttclient.on_message = mqtt_on_message
|
||
|
|
mqttclient.connect(getConfigValue("mqtt_broker"), 1883, 60)
|
||
|
|
|
||
|
|
mqttclient.loop_forever()
|