send StatusReq additionally every 30 minutes
This commit is contained in:
@@ -36,16 +36,12 @@ class Schedule:
|
|||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
async def regular_modbus_cmds(cls):
|
async def regular_modbus_cmds(cls):
|
||||||
# logging.info("Regular Modbus requests")
|
|
||||||
if 0 == (cls.count % 30):
|
|
||||||
# logging.info("Regular Modbus Status request")
|
|
||||||
addr, len = 0x2007, 2
|
|
||||||
else:
|
|
||||||
addr, len = 0x3008, 21
|
|
||||||
cls.count += 1
|
|
||||||
|
|
||||||
for m in Message:
|
for m in Message:
|
||||||
if m.server_side:
|
if m.server_side:
|
||||||
fnc = getattr(m, "send_modbus_cmd", None)
|
fnc = getattr(m, "send_modbus_cmd", None)
|
||||||
if callable(fnc):
|
if callable(fnc):
|
||||||
await fnc(Modbus.READ_REGS, addr, len)
|
await fnc(Modbus.READ_REGS, 0x3008, 21)
|
||||||
|
if 0 == (cls.count % 30):
|
||||||
|
# logging.info("Regular Modbus Status request")
|
||||||
|
await fnc(Modbus.READ_REGS, 0x2007, 2)
|
||||||
|
cls.count += 1
|
||||||
|
|||||||
Reference in New Issue
Block a user