coelner/hoymiles-wifi
1
0
Fork 0
mirror of https://github.com/suaveolent/hoymiles-wifi.git synced 2024-09-20 03:10:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

communication with inverter working

Browse Source
This commit is contained in:
suaveolent 2023-12-06 15:39:40 +01:00
parent 4e5a5d986e
commit 29f106b7db
1 changed files with 14 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
hoymiles_wifi/inverter.py
View File

@ -2,10 +2,11 @@ import socket
import struct import struct
from hoymiles_wifi import logger from hoymiles_wifi import logger
from hoymiles_wifi.protos.RealData_pb2 import RealDataResDTO, HMSStateResponse from hoymiles_wifi.protos.RealData_pb2 import RealDataResDTO, HMSStateResponse
import crcmod from crcmod import mkCrcFun
from datetime import datetime from datetime import datetime
import time import time
INVERTER_PORT = 10081 INVERTER_PORT = 10081
class NetworkState: class NetworkState:
@ -34,37 +35,32 @@ class Inverter:
# request.cp = 23 + self.sequence # request.cp = 23 + self.sequence
# request.offset = 0 # request.offset = 0
# request.time = int(time.time()) # request.time = int(time.time())
header = b"\x48\x4d\xa3\x03" header = b"\x48\x4d\xa3\x03"
request_as_bytes = request.SerializeToString() request_as_bytes = request.SerializeToString()
crc16_func = crcmod.predefined.Crc('modbus') crc16 = mkCrcFun(0x18005, rev=True, initCrc=0xFFFF, xorOut=0x0000)(request_as_bytes)
crc16_func.update(request_as_bytes) length = len(request_as_bytes) + 10
crc16 = crc16_func.crcValue & 0xFFFF
len_bytes = struct.pack('>H', len(request_as_bytes) + 10) # compose request message
message = header + struct.pack('>HHHH', self.sequence, crc16, length, 0) + request_as_bytes
message = header + struct.pack('>HHH', self.sequence, crc16, len_bytes) + request_as_bytes
ip = socket.gethostbyname(self.host)
address = (ip, INVERTER_PORT)
address = (self.host, INVERTER_PORT)
try: try:
with socket.create_connection(address, timeout=0.5) as stream: with socket.create_connection(address, timeout=0.5) as stream:
stream.settimeout(5)
stream.sendall(message) stream.sendall(message)
buf = stream.recv(1024) buf = stream.recv(1024)
except socket.error as e: except (socket.error, socket.timeout) as e:
logger.error(str(e)) logger.debug(f"{e}")
self.set_state(NetworkState.Offline) self.set_state(NetworkState.Offline)
return None return None
read_length = struct.unpack('>H', buf[6:8])[0] read_length = struct.unpack('>H', buf[6:8])[0]
parsed = HMSStateResponse.FromString(buf[10:10 + read_length]) parsed = HMSStateResponse.FromString(buf[10:10+read_length])
if parsed is None: if not parsed:
logger.error("Error parsing response") logger.debug(f"Failed to parse response")
self.set_state(NetworkState.Offline) self.set_state(NetworkState.Offline)
return None return None
self.set_state(NetworkState.Online) self.set_state(NetworkState.Online)
return parsed return parsed