2024-01-31 22:04:09 +00:00
|
|
|
#!/usr/bin/python
|
|
|
|
# -*- coding:utf-8 -*-
|
2024-02-01 07:49:53 +00:00
|
|
|
import sys
|
|
|
|
import os
|
|
|
|
picdir = os.path.join(os.path.dirname(os.path.dirname(os.path.realpath(__file__))), 'pic')
|
|
|
|
libdir = os.path.join(os.path.dirname(os.path.dirname(os.path.realpath(__file__))), 'lib')
|
|
|
|
if os.path.exists(libdir):
|
|
|
|
sys.path.append(libdir)
|
2024-01-31 22:04:09 +00:00
|
|
|
|
|
|
|
import logging
|
2024-02-01 07:49:14 +00:00
|
|
|
from waveshare_epd import epd2in13b_V3
|
|
|
|
#import waveshare-epaper
|
2024-01-31 22:04:09 +00:00
|
|
|
import time
|
|
|
|
from PIL import Image,ImageDraw,ImageFont
|
|
|
|
import traceback
|
|
|
|
|
2024-01-31 23:03:19 +00:00
|
|
|
# Import MQTT client.
|
2024-01-31 23:13:14 +00:00
|
|
|
from paho.mqtt import client as mqtt_client
|
|
|
|
|
2024-01-31 23:03:19 +00:00
|
|
|
|
2024-01-31 22:04:09 +00:00
|
|
|
logging.basicConfig(level=logging.DEBUG)
|
|
|
|
|
2024-01-31 23:03:19 +00:00
|
|
|
# MQTT credentials
|
|
|
|
#mqtt_username = 'homeassistant' # MQTT client username
|
|
|
|
#mqtt_password = '3355' # MQTT client password
|
|
|
|
client_id = 'solarmonitor' # unique client_id
|
|
|
|
mqtt_broker = "openwb-2" # broker address, usually your HASS IP address
|
2024-01-31 23:28:40 +00:00
|
|
|
port = 1883
|
2024-01-31 23:03:19 +00:00
|
|
|
|
2024-01-31 23:17:30 +00:00
|
|
|
#set topics
|
2024-01-31 23:03:19 +00:00
|
|
|
topic_house_battery_soc = "openWB/bat/get/soc"
|
|
|
|
topic_house_battery_power = "openWB/bat/get/power"
|
|
|
|
|
|
|
|
topic_power_import_export = "openWB/counter/7/get/power"
|
|
|
|
topic_pv_power = "openWB/pv/8/get/power"
|
|
|
|
|
|
|
|
topic_house_power = "openWB/graph/lastlivevaluesJson" #house-power
|
|
|
|
|
|
|
|
topic_car_soc = "openWB/vehicle/4/get/soc"
|
|
|
|
topic_charge_point_power = "openWB/internal_chargepoint/0/get/powers"
|
|
|
|
|
|
|
|
|
2024-01-31 23:27:26 +00:00
|
|
|
def connect_mqtt():
|
|
|
|
def on_connect(client, userdata, flags, rc):
|
|
|
|
if rc == 0:
|
|
|
|
logging.info("Connected to MQTT Broker!")
|
|
|
|
else:
|
|
|
|
logging.info("Failed to connect, return code %d\n", rc)
|
|
|
|
|
|
|
|
client = mqtt_client.Client(client_id)
|
|
|
|
# client.username_pw_set(username, password)
|
|
|
|
client.on_connect = on_connect
|
2024-01-31 23:28:40 +00:00
|
|
|
client.connect(mqtt_broker, port)
|
2024-01-31 23:27:26 +00:00
|
|
|
return client
|
|
|
|
|
|
|
|
|
|
|
|
def subscribe(client: mqtt_client, topic):
|
|
|
|
def on_message(client, userdata, msg):
|
|
|
|
print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
|
|
|
|
|
2024-02-01 07:31:15 +00:00
|
|
|
client.loop_start()
|
2024-01-31 23:27:26 +00:00
|
|
|
client.subscribe(topic)
|
|
|
|
client.on_message = on_message
|
2024-02-01 07:31:15 +00:00
|
|
|
client.loop_stop()
|
2024-01-31 23:27:26 +00:00
|
|
|
|
2024-02-01 07:16:37 +00:00
|
|
|
def monitor(charge_point_power):
|
2024-02-01 08:18:07 +00:00
|
|
|
|
|
|
|
logging.info("epd2in13b_V3 Demo")
|
2024-02-01 08:20:03 +00:00
|
|
|
logging.info(libdir)
|
|
|
|
logging.info(picdir)
|
2024-02-01 08:18:07 +00:00
|
|
|
|
|
|
|
epd = epd2in13b_V3.EPD()
|
|
|
|
#epd = epaper.epaper('epd2in13b_V3').EPD()
|
|
|
|
#logging.info("init and Clear")
|
|
|
|
#epd.init()
|
|
|
|
#epd.Clear()
|
|
|
|
|
|
|
|
# Drawing on the image
|
|
|
|
logging.info("Drawing")
|
|
|
|
font16 = ImageFont.truetype(os.path.join(picdir, 'Font.ttc'), 16)
|
|
|
|
font18 = ImageFont.truetype(os.path.join(picdir, 'Font.ttc'), 18)
|
|
|
|
|
|
|
|
# Drawing on the Horizontal image
|
|
|
|
logging.info("1.Drawing on the Horizontal image...")
|
|
|
|
HBlackimage = Image.new('1', (epd.height, epd.width), 255) # 298*126
|
|
|
|
HRYimage = Image.new('1', (epd.height, epd.width), 255) # 298*126 ryimage: red or yellow image
|
|
|
|
drawblack = ImageDraw.Draw(HBlackimage)
|
|
|
|
drawry = ImageDraw.Draw(HRYimage)
|
|
|
|
drawblack.text((2, 0), 'PV Production', font = font16, fill = 0)
|
|
|
|
drawblack.text((2, 16), 'Hausverbrauch', font = font16, fill = 0)
|
|
|
|
drawblack.text((2, 32), 'Strom Import', font = font16, fill = 0)
|
|
|
|
drawblack.text((2, 48), 'Batterie', font = font16, fill = 0)
|
|
|
|
drawblack.text((2, 64), 'Batterie Entladen', font = font16, fill = 0)
|
|
|
|
drawblack.text((2, 80), 'Auto Laden', font = font16, fill = 0)
|
|
|
|
|
|
|
|
#drawblack.text((100, 80), str(charge_point_power), font = font16, fill = 0)
|
|
|
|
|
2024-01-31 23:44:30 +00:00
|
|
|
try:
|
|
|
|
epd.display(epd.getbuffer(HBlackimage), epd.getbuffer(HRYimage))
|
|
|
|
|
|
|
|
#logging.info("Clear...")
|
|
|
|
#epd.init()
|
|
|
|
#epd.Clear()
|
|
|
|
|
|
|
|
logging.info("Goto Sleep...")
|
|
|
|
epd.sleep()
|
|
|
|
|
|
|
|
except IOError as e:
|
|
|
|
logging.info(e)
|
|
|
|
|
|
|
|
except KeyboardInterrupt:
|
|
|
|
logging.info("ctrl + c:")
|
|
|
|
epd2in13b_V3.epdconfig.module_exit()
|
|
|
|
exit()
|
2024-01-31 23:38:25 +00:00
|
|
|
|
2024-01-31 23:39:30 +00:00
|
|
|
#client.loop_forever()
|
2024-01-31 23:27:26 +00:00
|
|
|
|
|
|
|
|
2024-02-01 07:16:37 +00:00
|
|
|
def run():
|
|
|
|
client = connect_mqtt()
|
|
|
|
house_battery_soc = subscribe(client, topic_house_battery_soc)
|
|
|
|
house_battery_power = subscribe(client, topic_house_battery_power)
|
|
|
|
power_import_export = subscribe(client, topic_power_import_export)
|
|
|
|
pv_power = subscribe(client, topic_pv_power)
|
|
|
|
house_power = subscribe(client, topic_house_power)
|
|
|
|
car_soc = subscribe(client, topic_car_soc)
|
|
|
|
charge_point_power = subscribe(client, topic_charge_point_power)
|
2024-02-01 07:25:47 +00:00
|
|
|
|
|
|
|
logging.info("house battery soc: " + str(house_battery_soc))
|
|
|
|
logging.info("house battery power: " + str(house_battery_power))
|
|
|
|
logging.info("power import export: " + str(power_import_export))
|
|
|
|
logging.info("pv power: " + str(pv_power))
|
|
|
|
logging.info("house power: " + str(house_power))
|
|
|
|
logging.info("car soc: " + str(car_soc))
|
2024-02-01 07:22:53 +00:00
|
|
|
logging.info("charge point power: " + str(charge_point_power))
|
2024-02-01 07:33:51 +00:00
|
|
|
monitor(charge_point_power)
|
2024-02-01 07:16:37 +00:00
|
|
|
|
|
|
|
|
2024-01-31 23:27:26 +00:00
|
|
|
if __name__ == '__main__':
|
2024-01-31 23:33:08 +00:00
|
|
|
run()
|