140 lines
4.5 KiB
Python
140 lines
4.5 KiB
Python
from ...core.message import (
|
|
MessageType,
|
|
MessageRequest,
|
|
MessageResponse,
|
|
MessageBody,
|
|
)
|
|
|
|
|
|
class MessageFABase(MessageRequest):
|
|
def __init__(self, device_protocol_version, message_type, body_type):
|
|
super().__init__(
|
|
device_protocol_version=device_protocol_version,
|
|
device_type=0xFA,
|
|
message_type=message_type,
|
|
body_type=body_type
|
|
)
|
|
|
|
@property
|
|
def _body(self):
|
|
raise NotImplementedError
|
|
|
|
|
|
class MessageQuery(MessageFABase):
|
|
def __init__(self, device_protocol_version):
|
|
super().__init__(
|
|
device_protocol_version=device_protocol_version,
|
|
message_type=MessageType.query,
|
|
body_type=None)
|
|
|
|
@property
|
|
def body(self):
|
|
return bytearray([])
|
|
|
|
@property
|
|
def _body(self):
|
|
return bytearray([])
|
|
|
|
|
|
class MessageSet(MessageFABase):
|
|
def __init__(self, device_protocol_version, sub_type):
|
|
super().__init__(
|
|
device_protocol_version=device_protocol_version,
|
|
message_type=MessageType.set,
|
|
body_type=0x00)
|
|
self._sub_type = sub_type
|
|
self.power = None
|
|
self.lock = None
|
|
self.mode = None
|
|
self.fan_speed = None
|
|
self.oscillate = None
|
|
self.oscillation_angle = None
|
|
self.oscillation_mode = None
|
|
self.tilting_angle = None
|
|
|
|
@property
|
|
def _body(self):
|
|
if self._sub_type <= 10 or self._sub_type == 161:
|
|
_body_return = bytearray([
|
|
0x00, 0x00, 0x00, 0x80,
|
|
0x00, 0x00, 0x00, 0x80,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00
|
|
])
|
|
if self._sub_type not in [0, 10]:
|
|
_body_return[13] = 0xFF
|
|
else:
|
|
_body_return = bytearray([
|
|
0x00, 0x00, 0x00, 0x80,
|
|
0x00, 0x00, 0x00, 0x80,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00, 0x00, 0x00, 0x00,
|
|
0x00
|
|
])
|
|
if self.power is not None:
|
|
if self.power:
|
|
_body_return[3] = 1
|
|
else:
|
|
_body_return[3] = 0
|
|
if self.lock is not None:
|
|
if self.lock:
|
|
_body_return[2] = 1
|
|
else:
|
|
_body_return[2] = 2
|
|
if self.mode is not None:
|
|
_body_return[3] = 1 | (((self.mode + 1) << 1) & 0x1E)
|
|
if self.fan_speed is not None and 1 <= self.fan_speed <= 26:
|
|
_body_return[4] = self.fan_speed
|
|
if self.oscillate is not None:
|
|
if self.oscillate:
|
|
_body_return[7] = 1
|
|
else:
|
|
_body_return[7] = 0
|
|
if self.oscillation_angle is not None:
|
|
_body_return[7] = 1 | _body_return[7] | ((self.oscillation_angle << 4) & 0x70)
|
|
if self.oscillation_mode is not None:
|
|
_body_return[7] = 1 | _body_return[7] | ((self.oscillation_mode << 1) & 0x0E)
|
|
if self.tilting_angle is not None and len(_body_return) > 24:
|
|
_body_return[24] = self.tilting_angle
|
|
return _body_return
|
|
|
|
|
|
class FAGeneralMessageBody(MessageBody):
|
|
def __init__(self, body):
|
|
super().__init__(body)
|
|
lock = body[3] & 0x03
|
|
if lock == 1:
|
|
self.child_lock = True
|
|
else:
|
|
self.child_lock = False
|
|
self.power = (body[4] & 0x01) > 0
|
|
mode = ((body[4] & 0x1E) >> 1)
|
|
if mode > 0:
|
|
self.mode = mode - 1
|
|
fan_speed = body[5]
|
|
if 1 <= fan_speed <= 26:
|
|
self.fan_speed = fan_speed
|
|
else:
|
|
self.fan_speed = 0
|
|
self.oscillate = (body[8] & 0x01) > 0
|
|
self.oscillation_angle = (body[8] & 0x70) >> 4
|
|
self.oscillation_mode = (body[8] & 0x0E) >> 1
|
|
self.tilting_angle = body[25] if len(body) > 25 else 0
|
|
|
|
|
|
class MessageFAResponse(MessageResponse):
|
|
def __init__(self, message):
|
|
super().__init__(message)
|
|
if self.message_type in [MessageType.query, MessageType.set, MessageType.notify1]:
|
|
self.set_body(FAGeneralMessageBody(super().body))
|
|
self.set_attr()
|