From 66bec656a44494e9a5c7e3b1e9f0c5b2891caa1a Mon Sep 17 00:00:00 2001 From: Pim van den Berg Date: Thu, 5 Nov 2020 14:49:38 +0100 Subject: [PATCH] feat(itho-wpu): process getdatalog --- itho-wpu.py | 64 ++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 file changed, 63 insertions(+), 1 deletion(-) diff --git a/itho-wpu.py b/itho-wpu.py index 89970c1..d93932f 100755 --- a/itho-wpu.py +++ b/itho-wpu.py @@ -7,6 +7,7 @@ import pigpio import queue import sys import time +from collections import namedtuple consolelogformatter = logging.Formatter("%(asctime)-15s %(levelname)s: %(message)s") logger = logging.getLogger('stdout') @@ -114,6 +115,64 @@ class I2CMaster: self.i.close() +def process_response(action, response): + if action == "getdatalog" and int(response[1], 0) == 0xA4 and int(response[2], 0) == 0x01: + measurements = process_datalog(response) + + +def process_datalog(response): + # 0 = Byte + # 1 = UnsignedInt + # 2 = SignedIntDec2 + Field = namedtuple('Field', 'index type label description') + datalog = [ + Field(0, 2, "t_out", "Buitentemperatuur"), + Field(2, 2, "t_boiltop", "Boiler laag"), + Field(4, 2, "t_boildwn", "Boiler hoog"), + Field(6, 2, "t_evap", "Verdamper temperatuur"), + Field(8, 2, "t_suct", "Zuiggas temperatuur"), + Field(10, 2, "t_disc", "Persgas temperatuur"), + Field(12, 2, "t_cond", "Vloeistof temperatuur"), + Field(14, 2, "t_source_r", "Naar bron"), + Field(16, 2, "t_source_s", "Van bron"), + Field(18, 2, "t_ch_supp", "CV aanvoer"), + Field(20, 2, "t_ch_ret", "CV retour"), + Field(22, 2, "p_sens", "Druksensor (Bar)"), + Field(24, 2, "i_tr1", "Stroom trafo 1 (A)"), + Field(26, 2, "i_tr2", "Stroom trafo 2 (A)"), + Field(34, 1, "in_flow", "Flow sensor bron (l/h)"), + Field(37, 0, "out_ch", "Snelheid cv pomp (%)"), + Field(38, 0, "out_src", "Snelheid bron pomp (%)"), + Field(39, 0, "out_dhw", "Snelheid boiler pomp (%)"), + Field(44, 0, "out_c1", "Compressor aan/uit"), + Field(45, 0, "out_ele", "Elektrisch element aan/uit"), + Field(46, 0, "out_trickle", "Trickle heating aan/uit"), + Field(47, 0, "out_fault", "Fout aanwezig (0=J, 1=N)"), + Field(48, 0, "out_fc", "Vrijkoelen actief (0=uit, 1=aan)"), + Field(51, 2, "ot_room", "Kamertemperatuur"), + Field(55, 0, "ot_mod", "Warmtevraag (%)"), + Field(56, 0, "state", "State (0=init,1=uit,2=CV,3=boiler,4=vrijkoel,5=ontluchten)"), + Field(57, 0, "sub_state", "Substatus (255=geen)"), + Field(67, 0, "fault_reported", "Fout gevonden (foutcode)"), + Field(92, 1, "tr_fc", "Vrijkoelen interval (sec)"), + ] + message = response[5:] + measurements = {} + for d in datalog: + if d.type == 0: + m = message[d.index:d.index+1] + num = int(m[0], 0) + elif d.type == 1: + m = message[d.index:d.index+2] + num = ((int(m[0], 0) << 8) + int(m[1], 0)) + elif d.type == 2: + m = message[d.index:d.index+2] + num = round(((int(m[0], 0) << 8) + int(m[1], 0)) / 100.0, 2) + logger.info(f"{d.description}: {num}") + measurements[d.label] = num + return measurements + + if __name__ == "__main__": args = parse_args() @@ -132,8 +191,11 @@ if __name__ == "__main__": master = I2CMaster(address=0x41, bus=1, queue=q) if args.action: result = master.execute_action(args.action) - logger.info(f"Response: {result}") + logger.debug(f"Response: {result}") master.close() + if result is not None: + process_response(args.action, result) + if not args.master_only: slave.close()