pommi/python-itho-wpu
1
0
Fork 0
mirror of https://github.com/pommi/python-itho-wpu.git synced 2024-11-21 13:52:15 +01:00
Code Releases Activity

feat(itho-wpu): implement getnodeid action

Browse Source
This commit is contained in:
Pim van den Berg 2020-11-14 15:45:09 +01:00
parent 11ae0978b3
commit 58f35d988e
1 changed files with 24 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
itho-wpu.py
View File

@ -46,7 +46,7 @@ def parse_args():
parser = argparse.ArgumentParser(description='Itho WPU i2c master') parser = argparse.ArgumentParser(description='Itho WPU i2c master')
actions = [ actions = [
"getregelaar", "getnodeid",
"getserial", "getserial",
"getdatatype", "getdatatype",
"getdatalog", "getdatalog",
@ -127,7 +127,7 @@ class I2CMaster:
def execute_action(self, action): def execute_action(self, action):
actions = { actions = {
"getregelaar": [0x80, 0x90, 0xE0, 0x04, 0x00, 0x8A], "getnodeid": [0x80, 0x90, 0xE0, 0x04, 0x00, 0x8A],
"getserial": [0x80, 0x90, 0xE1, 0x04, 0x00, 0x89], "getserial": [0x80, 0x90, 0xE1, 0x04, 0x00, 0x89],
"getdatatype": [0x80, 0xA4, 0x00, 0x04, 0x00, 0x56], "getdatatype": [0x80, 0xA4, 0x00, 0x04, 0x00, 0x56],
"getdatalog": [0x80, 0xA4, 0x01, 0x04, 0x00, 0x55], "getdatalog": [0x80, 0xA4, 0x01, 0x04, 0x00, 0x55],
@ -159,6 +159,28 @@ def process_response(action, response, args):
measurements = process_datalog(response) measurements = process_datalog(response)
if args.export_to_influxdb: if args.export_to_influxdb:
export_to_influxdb(action, measurements) export_to_influxdb(action, measurements)
elif action == "getnodeid":
process_nodeid(response)
def process_nodeid(response):
if int(response[1], 0) != 0x90 and int(response[2], 0) != 0xE0:
logger.error(f"Response MessageClass != 0x90 0xE0 (getnodeid), but {response[1]} {response[2]}")
return
manufacturergroup = ((int(response[5], 0) << 8) + int(response[6], 0))
manufacturer = int(response[7], 0)
hardwaretype = int(response[8], 0)
if hardwaretype == 0x0d:
hardwaretype = "WPU"
elif hardwaretype == 0x0f:
hardwaretype = "AutoTemp"
productversion = int(response[9], 0)
listversion = int(response[10], 0)
logger.info(f"ManufacturerGroup: {manufacturergroup}, Manufacturer: {manufacturer}, "
f"HardwareType: {hardwaretype}, ProductVersion: {productversion}, "
f"ListVersion: {listversion}")
def process_datalog(response): def process_datalog(response):