mirror of
https://github.com/andvikt/mega_hacs.git
synced 2025-12-12 01:24:29 +05:00
Compare commits
30 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
80e43888b9 | ||
|
|
ba41cbb100 | ||
|
|
0b5b9744ba | ||
|
|
9746311f38 | ||
|
|
38a525f2f5 | ||
|
|
6503d6bddd | ||
|
|
4af40c29a7 | ||
|
|
75a41c9667 | ||
|
|
4f8f38fde6 | ||
|
|
7e02797be8 | ||
|
|
035bdebf64 | ||
|
|
8d92bbdfb3 | ||
|
|
0c43e61c59 | ||
|
|
0a71be693e | ||
|
|
8146148d0c | ||
|
|
e0eaafd0fa | ||
|
|
51f3eb3b19 | ||
|
|
1716651497 | ||
|
|
a87e8139a7 | ||
|
|
358d29f8fd | ||
|
|
fcce9dcfc1 | ||
|
|
4fe2469a01 | ||
|
|
9fab4fce62 | ||
|
|
3c28cf4598 | ||
|
|
af2360b0a0 | ||
|
|
8f7604c9f6 | ||
|
|
f70d72bf39 | ||
|
|
896e02a457 | ||
|
|
bb95c9d312 | ||
|
|
7ba1562f12 |
8
.github/ISSUE_TEMPLATE/bug-report.md
vendored
8
.github/ISSUE_TEMPLATE/bug-report.md
vendored
@@ -24,10 +24,4 @@ megad firmware version:
|
||||
If applicable, add screenshots to help explain your problem.
|
||||
|
||||
**LOG**
|
||||
Просьба прикладывать детальный лог, который можно включить в конфиге так:
|
||||
```yaml
|
||||
logger:
|
||||
default: info
|
||||
logs:
|
||||
custom_components.mega: debug
|
||||
```
|
||||
Просьба прикладывать детальный лог, подробная инструкция как включать отладку по [ссылке](https://github.com/andvikt/mega_hacs/wiki/Отладка)
|
||||
|
||||
@@ -17,14 +17,14 @@ from homeassistant.components import mqtt
|
||||
from homeassistant.config_entries import ConfigEntry
|
||||
from .const import DOMAIN, CONF_INVERT, CONF_RELOAD, PLATFORMS, CONF_PORTS, CONF_CUSTOM, CONF_SKIP, CONF_PORT_TO_SCAN, \
|
||||
CONF_MQTT_INPUTS, CONF_HTTP, CONF_RESPONSE_TEMPLATE, CONF_ACTION, CONF_GET_VALUE, CONF_ALLOW_HOSTS, \
|
||||
CONF_CONV_TEMPLATE, CONF_ALL, CONF_FORCE_D
|
||||
CONF_CONV_TEMPLATE, CONF_ALL, CONF_FORCE_D, CONF_DEF_RESPONSE
|
||||
from .hub import MegaD
|
||||
from .config_flow import ConfigFlow
|
||||
from .http import MegaView
|
||||
|
||||
_LOGGER = logging.getLogger(__name__)
|
||||
|
||||
CUSTOMIZE_PORT = vol.Schema({
|
||||
CUSTOMIZE_PORT = {
|
||||
vol.Optional(CONF_SKIP, description='исключить порт из сканирования', default=False): bool,
|
||||
vol.Optional(CONF_INVERT, default=False): bool,
|
||||
vol.Optional(CONF_NAME): vol.Any(str, {
|
||||
@@ -42,18 +42,22 @@ CUSTOMIZE_PORT = vol.Schema({
|
||||
vol.Optional(CONF_ACTION): cv.script_action, # пока не реализовано
|
||||
vol.Optional(CONF_GET_VALUE, default=True): bool,
|
||||
vol.Optional(CONF_CONV_TEMPLATE): cv.template
|
||||
})
|
||||
CUSTOMIZE_DS2413 = vol.Schema({
|
||||
}
|
||||
CUSTOMIZE_DS2413 = {
|
||||
vol.Optional(str.lower, description='адрес и индекс устройства'): CUSTOMIZE_PORT
|
||||
})
|
||||
}
|
||||
|
||||
CONFIG_SCHEMA = vol.Schema(
|
||||
{
|
||||
DOMAIN: {
|
||||
vol.Optional(CONF_ALLOW_HOSTS): [str],
|
||||
# vol.Optional(CONF_FORCE_D, description='Принудительно слать d после срабатывания входа', default=False): bool,
|
||||
vol.Required(str, description='id меги из веб-интерфейса'): {
|
||||
vol.Optional(CONF_FORCE_D, description='Принудительно слать d после срабатывания входа', default=False): bool,
|
||||
vol.Optional(
|
||||
CONF_DEF_RESPONSE,
|
||||
description='Ответ по умолчанию',
|
||||
default=None
|
||||
): vol.Any(cv.template, None),
|
||||
vol.Optional(int, description='номер порта'): vol.Any(
|
||||
CUSTOMIZE_PORT,
|
||||
CUSTOMIZE_DS2413,
|
||||
|
||||
@@ -57,7 +57,7 @@ async def validate_input(hass: core.HomeAssistant, data):
|
||||
class ConfigFlow(config_entries.ConfigFlow, domain=DOMAIN):
|
||||
"""Handle a config flow for mega."""
|
||||
|
||||
VERSION = 5
|
||||
VERSION = 10
|
||||
CONNECTION_CLASS = config_entries.CONN_CLASS_ASSUMED
|
||||
|
||||
async def async_step_user(self, user_input=None):
|
||||
|
||||
@@ -28,6 +28,7 @@ CONF_ALLOW_HOSTS = 'allow_hosts'
|
||||
CONF_CONV_TEMPLATE = 'conv_template'
|
||||
CONF_POLL_OUTS = 'poll_outs'
|
||||
CONF_FORCE_D = 'force_d'
|
||||
CONF_DEF_RESPONSE = 'def_response'
|
||||
PLATFORMS = [
|
||||
"light",
|
||||
"switch",
|
||||
|
||||
@@ -48,6 +48,9 @@ class BaseMegaEntity(CoordinatorEntity, RestoreEntity):
|
||||
index=None,
|
||||
):
|
||||
super().__init__(mega.updater)
|
||||
|
||||
self.http_cmd = http_cmd
|
||||
|
||||
self._state: State = None
|
||||
self.port = port
|
||||
self.config_entry = config_entry
|
||||
@@ -60,9 +63,10 @@ class BaseMegaEntity(CoordinatorEntity, RestoreEntity):
|
||||
self._name = name or f"{mega.id}_{port}" + \
|
||||
(f"_{id_suffix}" if id_suffix else "")
|
||||
self._customize: dict = None
|
||||
self.http_cmd = http_cmd
|
||||
self.index = index
|
||||
self.addr = addr
|
||||
if self.http_cmd == 'ds2413':
|
||||
self.mega.ds2413_ports |= {self.port}
|
||||
|
||||
@property
|
||||
def customize(self):
|
||||
@@ -125,7 +129,8 @@ class BaseMegaEntity(CoordinatorEntity, RestoreEntity):
|
||||
_task_set_ev_on = asyncio.create_task(_set_events_on())
|
||||
|
||||
async def get_state(self):
|
||||
if self.mega.mqtt is None:
|
||||
self.lg.debug(f'state is %s', self.state)
|
||||
if not self.mega.mqtt_inputs:
|
||||
self.async_write_ha_state()
|
||||
|
||||
|
||||
@@ -218,8 +223,9 @@ class MegaOutPort(MegaPushEntity):
|
||||
self._is_on = None
|
||||
self.dimmer = dimmer
|
||||
|
||||
def assumed_state(self) -> bool:
|
||||
return True if self.index is not None or self.mega.mqtt is None else False
|
||||
# @property
|
||||
# def assumed_state(self) -> bool:
|
||||
# return True if self.index is not None or self.mega.mqtt is None else False
|
||||
|
||||
@property
|
||||
def invert(self):
|
||||
@@ -247,21 +253,25 @@ class MegaOutPort(MegaPushEntity):
|
||||
return self._state == 'ON'
|
||||
elif val is not None:
|
||||
val = val.get("value")
|
||||
if self.index and self.addr:
|
||||
_val = val.get(self.addr)
|
||||
if not isinstance(val, str):
|
||||
self.mega.lg.warning(f'{self} has wrong state: {val}')
|
||||
if not isinstance(val, str) and self.index is not None and self.addr is not None:
|
||||
if not isinstance(val, dict):
|
||||
self.mega.lg.warning(f'{self.entity_id}: {val} is not a dict')
|
||||
return
|
||||
_val = val.get(self.addr, val.get(self.addr.lower(), val.get(self.addr.upper())))
|
||||
if not isinstance(_val, str):
|
||||
self.mega.lg.warning(f'{self.entity_id}: can not get {self.addr} from {val}, recieved {_val}')
|
||||
return
|
||||
_val = _val.split('/')
|
||||
if len(_val) >= 2:
|
||||
val = val[self.index]
|
||||
self.mega.lg.debug('%s parsed values: %s[%s]="%s"', self.entity_id, _val, self.index, _val)
|
||||
val = _val[self.index]
|
||||
else:
|
||||
self.mega.lg.warning(f'{self} has wrong state: {val}')
|
||||
self.mega.lg.warning(f'{self.entity_id}: {_val} has wrong length')
|
||||
return
|
||||
elif self.index and self.addr is None:
|
||||
self.mega.lg.warning(f'{self} does not has addr')
|
||||
elif self.index is not None and self.addr is None:
|
||||
self.mega.lg.warning(f'{self.entity_id} does not has addr')
|
||||
return
|
||||
|
||||
self.mega.lg.debug('%s.state = %s', self.entity_id, val)
|
||||
if not self.invert:
|
||||
return val == 'ON' or str(val) == '1' or (safe_int(val) is not None and safe_int(val) > 0)
|
||||
else:
|
||||
@@ -283,18 +293,18 @@ class MegaOutPort(MegaPushEntity):
|
||||
cmd = brightness
|
||||
else:
|
||||
cmd = 1 if not self.invert else 0
|
||||
cmd = {"cmd": f"{self.cmd_port}:{cmd}"}
|
||||
_cmd = {"cmd": f"{self.cmd_port}:{cmd}"}
|
||||
if self.addr:
|
||||
cmd['addr'] = self.addr
|
||||
await self.mega.request(**cmd)
|
||||
_cmd['addr'] = self.addr
|
||||
await self.mega.request(**_cmd)
|
||||
if self.index is not None:
|
||||
# обновление текущего стейта для ds2413
|
||||
self.hass.async_create_task(self.mega.get_port(
|
||||
await self.mega.get_port(
|
||||
port=self.port,
|
||||
force_http=True,
|
||||
conv=False,
|
||||
http_cmd='list',
|
||||
))
|
||||
)
|
||||
else:
|
||||
self.mega.values[self.port] = {'value': cmd}
|
||||
await self.get_state()
|
||||
@@ -302,18 +312,18 @@ class MegaOutPort(MegaPushEntity):
|
||||
async def async_turn_off(self, **kwargs) -> None:
|
||||
|
||||
cmd = "0" if not self.invert else "1"
|
||||
cmd = {"cmd": f"{self.cmd_port}:{cmd}"}
|
||||
_cmd = {"cmd": f"{self.cmd_port}:{cmd}"}
|
||||
if self.addr:
|
||||
cmd['addr'] = self.addr
|
||||
await self.mega.request(**cmd)
|
||||
_cmd['addr'] = self.addr
|
||||
await self.mega.request(**_cmd)
|
||||
if self.index is not None:
|
||||
# обновление текущего стейта для ds2413
|
||||
self.hass.async_create_task(self.mega.get_port(
|
||||
await self.mega.get_port(
|
||||
port=self.port,
|
||||
force_http=True,
|
||||
conv=False,
|
||||
http_cmd='list',
|
||||
))
|
||||
)
|
||||
else:
|
||||
self.mega.values[self.port] = {'value': cmd}
|
||||
await self.get_state()
|
||||
|
||||
@@ -66,23 +66,27 @@ class MegaView(HomeAssistantView):
|
||||
update_all = False
|
||||
data['value'] = data.pop('v')
|
||||
data['mega_id'] = hub.id
|
||||
ret = 'd'
|
||||
ret = 'd' if hub.force_d else ''
|
||||
if port is not None:
|
||||
hub.values[port] = data
|
||||
for cb in self.callbacks[hub.id][port]:
|
||||
cb(data)
|
||||
template: Template = self.templates.get(hub.id, {}).get(port)
|
||||
template: Template = self.templates.get(hub.id, {}).get(port, hub.def_response)
|
||||
if hub.update_all and update_all:
|
||||
asyncio.create_task(self.later_update(hub))
|
||||
if template is not None:
|
||||
template.hass = hass
|
||||
ret = template.async_render(data)
|
||||
_LOGGER.debug('response %s', ret)
|
||||
ret = Response(body=ret or 'd', content_type='text/plain', headers={'Server': 's', 'Date': 'n'})
|
||||
Response(body='', content_type='text/plain', headers={'Server': 's', 'Date': 'n'})
|
||||
if 'd' in ret:
|
||||
await hub.request(pt=port, cmd=ret)
|
||||
else:
|
||||
await hub.request(cmd=ret)
|
||||
return ret
|
||||
|
||||
async def later_update(self, hub):
|
||||
_LOGGER.debug('force update')
|
||||
await asyncio.sleep(1)
|
||||
_LOGGER.debug('force update')
|
||||
await hub.updater.async_refresh()
|
||||
|
||||
|
||||
@@ -19,7 +19,7 @@ from homeassistant.helpers.update_coordinator import DataUpdateCoordinator
|
||||
from .const import (
|
||||
TEMP, HUM, PRESS,
|
||||
LUX, PATT_SPLIT, DOMAIN,
|
||||
CONF_HTTP, EVENT_BINARY_SENSOR, CONF_CUSTOM, CONF_FORCE_D
|
||||
CONF_HTTP, EVENT_BINARY_SENSOR, CONF_CUSTOM, CONF_FORCE_D, CONF_DEF_RESPONSE
|
||||
)
|
||||
from .entities import set_events_off, BaseMegaEntity
|
||||
from .exceptions import CannotConnect, NoPort
|
||||
@@ -101,6 +101,7 @@ class MegaD:
|
||||
self.cnd = asyncio.Condition()
|
||||
self.online = True
|
||||
self.entities: typing.List[BaseMegaEntity] = []
|
||||
self.ds2413_ports = set()
|
||||
self.poll_interval = scan_interval
|
||||
self.subs = None
|
||||
self.lg: logging.Logger = lg.getChild(self.id)
|
||||
@@ -170,6 +171,10 @@ class MegaD:
|
||||
def force_d(self):
|
||||
return self.customize.get(CONF_FORCE_D, False)
|
||||
|
||||
@property
|
||||
def def_response(self):
|
||||
return self.customize.get(CONF_DEF_RESPONSE, None)
|
||||
|
||||
@property
|
||||
def is_online(self):
|
||||
return (datetime.now() - self.last_update).total_seconds() < (self.poll_interval + 10)
|
||||
@@ -191,20 +196,25 @@ class MegaD:
|
||||
)
|
||||
self.online = True
|
||||
|
||||
async def _get_ds2413(self):
|
||||
"""
|
||||
обновление ds2413 устройств
|
||||
:return:
|
||||
"""
|
||||
for x in self.ds2413_ports:
|
||||
self.lg.debug(f'poll ds2413 for %s', x)
|
||||
await self.get_port(
|
||||
port=x,
|
||||
force_http=True,
|
||||
http_cmd='list',
|
||||
conv=False
|
||||
)
|
||||
|
||||
async def poll(self):
|
||||
"""
|
||||
Polling ports
|
||||
"""
|
||||
self.lg.debug('poll')
|
||||
for x in self.entities:
|
||||
# обновление ds2413 устройств
|
||||
if x.http_cmd == 'ds2413':
|
||||
await self.get_port(
|
||||
port=x.port,
|
||||
force_http=True,
|
||||
http_cmd='list',
|
||||
conv=False
|
||||
)
|
||||
if self.mqtt is None:
|
||||
await self.get_all_ports()
|
||||
await self.get_sensors(only_list=True)
|
||||
@@ -214,6 +224,7 @@ class MegaD:
|
||||
await self.get_sensors()
|
||||
else:
|
||||
await self.get_port(self.port_to_scan)
|
||||
await self._get_ds2413()
|
||||
return self.values
|
||||
|
||||
async def get_mqtt_id(self):
|
||||
@@ -247,13 +258,18 @@ class MegaD:
|
||||
async def save(self):
|
||||
await self.send_command(cmd='s')
|
||||
|
||||
def parse_response(self, ret):
|
||||
def parse_response(self, ret, cmd='get'):
|
||||
if ret is None:
|
||||
raise NoPort()
|
||||
if 'busy' in ret:
|
||||
return None
|
||||
if ':' in ret:
|
||||
ret = PATT_SPLIT.split(ret)
|
||||
if ';' in ret:
|
||||
ret = ret.split(';')
|
||||
elif '/' in ret and not cmd == 'list':
|
||||
ret = ret.split('/')
|
||||
else:
|
||||
ret = [ret]
|
||||
ret = {'value': dict([
|
||||
x.split(':') for x in ret if x.count(':') == 1
|
||||
])}
|
||||
@@ -275,7 +291,7 @@ class MegaD:
|
||||
if http_cmd == 'list' and conv:
|
||||
await self.request(pt=port, cmd='conv')
|
||||
await asyncio.sleep(1)
|
||||
ret = self.parse_response(await self.request(pt=port, cmd=http_cmd))
|
||||
ret = self.parse_response(await self.request(pt=port, cmd=http_cmd), cmd=http_cmd)
|
||||
ntry = 0
|
||||
while http_cmd == 'list' and ret is None and ntry < 3:
|
||||
await asyncio.sleep(1)
|
||||
@@ -308,6 +324,8 @@ class MegaD:
|
||||
if not self.mqtt_inputs:
|
||||
ret = await self.request(cmd='all')
|
||||
for port, x in enumerate(ret.split(';')):
|
||||
if port in self.ds2413_ports:
|
||||
continue
|
||||
if check_skip and not port in self.ports:
|
||||
continue
|
||||
ret = self.parse_response(x)
|
||||
@@ -455,17 +473,22 @@ class MegaD:
|
||||
self.lg.warning(f'can not add ds2413 on port {port}, it has wrong data: {_data}')
|
||||
continue
|
||||
for addr, state in data.items():
|
||||
ret['light'][port].append([
|
||||
ret['light'][port].extend([
|
||||
{"index": 0, "addr": addr, "id_suffix": f'{addr}_a', "http_cmd": 'ds2413'},
|
||||
{"index": 1, "addr": addr, "id_suffix": f'{addr}_b', "http_cmd": 'ds2413'},
|
||||
])
|
||||
elif pty in ('3', '2', '4'):
|
||||
try:
|
||||
http_cmd = 'get'
|
||||
values = await self.get_port(port, force_http=True)
|
||||
if values is None or (isinstance(values, dict) and str(values.get('value')) in ('', 'None')):
|
||||
if m == '5' and pty == '3':
|
||||
# 1-wire bus
|
||||
values = await self.get_port(port, force_http=True, http_cmd='list')
|
||||
http_cmd = 'list'
|
||||
else:
|
||||
values = await self.get_port(port, force_http=True)
|
||||
if values is None or (isinstance(values, dict) and str(values.get('value')) in ('', 'None')):
|
||||
values = await self.get_port(port, force_http=True, http_cmd='list')
|
||||
http_cmd = 'list'
|
||||
except asyncio.TimeoutError:
|
||||
self.lg.warning(f'timout on port {port}')
|
||||
continue
|
||||
|
||||
@@ -15,5 +15,5 @@
|
||||
"@andvikt"
|
||||
],
|
||||
"issue_tracker": "https://github.com/andvikt/mega_hacs/issues",
|
||||
"version": "v0.4.1b"
|
||||
"version": "v0.4.1b7"
|
||||
}
|
||||
235
readme.md
235
readme.md
@@ -10,6 +10,11 @@
|
||||
интеграция очень понравилась - еще приятнее, если вы воспользуетесь кнопкой доната )
|
||||
|
||||
Обновление прошивки MegaD можно делать прямо из HA с помощью [аддона](https://github.com/andvikt/mega_addon.git)
|
||||
|
||||
Подробная документация по [ссылке](https://github.com/andvikt/mega_hacs/wiki)
|
||||
|
||||
Предложения по доработкам просьба писать в [discussions](https://github.com/andvikt/mega_hacs/discussions), о проблемах
|
||||
создавать [issue](https://github.com/andvikt/mega_hacs/issues/new/choose)
|
||||
## Основные особенности:
|
||||
- Настройка в веб-интерфейсе + yaml
|
||||
- Все порты автоматически добавляются как устройства (для обычных релейных выходов создается
|
||||
@@ -28,6 +33,13 @@
|
||||
|
||||
HACS - Integrations - Explore, в поиске ищем MegaD.
|
||||
|
||||
Чтобы включить возможность использования бета-версий, зайдите в HACS, найдите интеграцию MegaD, нажмите три точки,
|
||||
там кнопка "переустановить" или reinstall, дальше нужно нажать галку "показывать бета-версии"
|
||||
|
||||
Обновления выполняются так же в меню HACS.
|
||||
Информация об обновлениях приходит с некоторым интервалом, чтобы вручную проверить наличие обновлений
|
||||
нажмите три точки возле интеграции в меню HACS и нажмите `обновить информацию`
|
||||
|
||||
Альтернативный способ установки:
|
||||
```shell
|
||||
# из папки с конфигом
|
||||
@@ -40,226 +52,7 @@ wget -q -O - https://raw.githubusercontent.com/andvikt/mega_hacs/master/install.
|
||||
|
||||
Все имеющиеся у вас порты будут настроены автоматически. Вы можете менять названия, иконки и entity_id так же из интерфейса.
|
||||
|
||||
#### Кастомизация устройств с помощью yaml:
|
||||
```yaml
|
||||
# configuration.yaml
|
||||
|
||||
mega:
|
||||
hello: # ID меги, как в UI
|
||||
7: # номер порта
|
||||
domain: switch # тип устройства (switch или light, по умолчанию для цифровых выходов используется light)
|
||||
invert: true # инвертировать или нет (по умолчанию false)
|
||||
name: Насос # имя устройства
|
||||
8:
|
||||
# исключить из сканирования
|
||||
skip: true
|
||||
10:
|
||||
skip: false # если нужен skip, то он работает только целиком для всего порта
|
||||
# в случае если порт настроен как ds2413
|
||||
address_a: #address - это адрес ds2413
|
||||
# здесь внутри работают все стандартные поля конфигурирования порта
|
||||
invert: true
|
||||
domain: switch
|
||||
c6c439000000_b:
|
||||
name: какое-то имя
|
||||
33:
|
||||
# для датчиков можно кастомизировать только имя и unit_of_measurement
|
||||
# для температуры и влажность unit определяется автоматически, для остальных юнита нет
|
||||
name:
|
||||
hum: "влажность"
|
||||
temp: "температура"
|
||||
unit_of_measurement:
|
||||
hum: "%" # если датчиков несколько, то можно указывать юниты по их ключам
|
||||
temp: "°C"
|
||||
# можно так же указать шаблон для конвертации значения, может быть полезно для ацп-входа
|
||||
# текущее значение порта передается в шаблон в переменной "value"
|
||||
conv_template: "{{(value|float)/100}}"
|
||||
14:
|
||||
name: какой-то датчик
|
||||
unit_of_measurement: "°C" # если датчик один, то просто строчкой
|
||||
```
|
||||
|
||||
## Зависимости
|
||||
Для совместимости c mqtt необходимо настроить интеграцию [mqtt](https://www.home-assistant.io/integrations/mqtt/)
|
||||
в HomeAssistant, а так же обновить ваш контроллер до последней версии, тк были важные обновления в части mqtt
|
||||
|
||||
## HTTP in
|
||||
Начиная с версии `0.3.1` интеграция стала поддерживать обратную связь без mqtt, используя http-сервер. Для этого в настройках
|
||||
интеграции необходимо снять галку с `использовать mqtt`
|
||||
|
||||
**Внимание!** Не используйте srv loop на контроллере, это может приводить к ложным срабатываниям входов. Вместо srv loop
|
||||
интеграция будет сама обновлять все состояния портов с заданным интервалом
|
||||
|
||||
В самой меге необходимо прописать настройки:
|
||||
```yaml
|
||||
srv: "192.168.1.4:8123" # ip:port вашего HA
|
||||
script: "mega" # это api интеграции, к которому будет обращаться контроллер
|
||||
```
|
||||
|
||||
#### Ответ на входящие события от контроллера
|
||||
Контроллер ожидает ответ от сервера, который может быть сценарием (по умолчанию интеграция отвечает `d`, что означает
|
||||
запустить то что прописано в поле act в настройках порта).
|
||||
|
||||
Поддерживаются шаблоны HA. Это может быть использовано, например, для запоминания яркости (тк сам контроллер этого не
|
||||
умеет). В шаблоне можно использовать параметры, которые передает контроллер (m, click, pt, mdid, mega_id)
|
||||
|
||||
Примеры:
|
||||
```yaml
|
||||
mega:
|
||||
mega1: # id меги, который вы сами придумываете в конфиге в UI
|
||||
4: # номер порта, с которого ожидаются события
|
||||
response_template: "5:2" # простейший пример без шаблона. Каждый раз когда будет приходить сообщение на этот порт,
|
||||
# будем менять состояние на противоположное
|
||||
5:
|
||||
# пример с использованием шаблона, порт 1 будет выключен если он сейчас включен и включен с последней сохраненной
|
||||
# яркостью если он сейчас выключен
|
||||
response_template: >-
|
||||
{% if is_state('light.some_port_1', 'on') %}
|
||||
1:0
|
||||
{% else %}
|
||||
1:{{state_attr('light.some_port_1', 'brightness')}}
|
||||
{% endif %}
|
||||
6:
|
||||
# в шаблон так же передаются все параметры, которые передает контроллер (pt, cnt, m, click)
|
||||
# эти параметры можно использовать в условиях или непосредственно в шаблоне в виде {{pt}}
|
||||
response_template: >-
|
||||
{% if m==2 %}1:0{% else %}d{% endif %}
|
||||
```
|
||||
|
||||
Начиная с версии v0.3.17 ответ можно слать так же и в режиме MQTT. Аналогично, темплейт должен возвращать готовую команду
|
||||
такую же как требует команда cmd, так же можно использовать d, но d не отправляется по умолчанию, это сделано чтобы не
|
||||
сломать текущую логику у пользователей предыдущих версий. Чтобы включить для всех входов в режиме mqtt отправку команды
|
||||
d необходимо в конфиге прописать следующее:
|
||||
```yaml
|
||||
mega:
|
||||
mega1:
|
||||
force_d: true
|
||||
```
|
||||
**Внимание!** Нельзя использовать чекбокс напротив поля act если планируется использовать ответ сервера - у вас и
|
||||
сработает act и команда от сервера, а вслучае ответа d сработает act два раза.
|
||||
|
||||
Так же следует понимать, что это не "ответ" в нормальном понимании - это вызов следом за полученным mqtt-сообщением
|
||||
http команды такого вида `http://megaurl/?pt=port&cmd=rendered_template`, где `port` - это номер порта сработавшего входа,
|
||||
а `cmd` - текст команды, который получен из темплейта. Те это имитация ответа. У этого подхода есть минус - задержка в
|
||||
исполнении будет значительно выше чем при ответе в режиме http, но тем не менее эта задержка скорее всего не будет
|
||||
сильно заметна.
|
||||
|
||||
## binary_sensor и события
|
||||
|
||||
Входы будут доступны как binary_sensor, а так же в виде событий `mega.sensor` и `mega.binary`.
|
||||
Для корректной работы binary_sensor имеет смысл использовать режим P&R, для остальных режимов - лучше пользоваться
|
||||
событиями.
|
||||
|
||||
События можно использовать в автоматизациях, например так:
|
||||
```yaml
|
||||
# Пример события с полями как есть прямо из меги
|
||||
- alias: some double click
|
||||
trigger:
|
||||
- platform: event
|
||||
event_type: mega.sensor
|
||||
event_data:
|
||||
pt: 1
|
||||
click: 2
|
||||
action:
|
||||
- service: light.toggle
|
||||
entity_id: light.some_light
|
||||
```
|
||||
События могут содержать следующие поля:
|
||||
- `mega_id`: id как в конфиге HA
|
||||
- `pt`: номер порта
|
||||
- `cnt`: счетчик срабатываний
|
||||
- `mdid`: if как в конфиге контроллера
|
||||
- `click`: клик (подробнее в документации меги)
|
||||
- `value`: текущее значение (только для mqtt)
|
||||
- `port`: номер порта
|
||||
|
||||
Начиная с версии 0.3.7 появилось так же событие типа `mega.binary`:
|
||||
```yaml
|
||||
# Пример события с полями как есть прямо из меги
|
||||
- alias: some long click
|
||||
trigger:
|
||||
- platform: event
|
||||
event_type: mega.binary
|
||||
event_data:
|
||||
entity_id: binary_sensor.some_id
|
||||
type: long
|
||||
action:
|
||||
- service: light.toggle
|
||||
entity_id: light.some_light
|
||||
```
|
||||
Возможные варианты поля `type`:
|
||||
- `long`: долгое нажатие
|
||||
- `release`: размыкание (с гарантией** что не было долгого нажатия)
|
||||
- `long_release`: размыкание после долгого нажатия
|
||||
- `press`: замыкание
|
||||
- `single`: одинарный клик (в режиме кликов)
|
||||
- `double`: двойной клик
|
||||
|
||||
**гарантия есть только при использовании http-метода синхронизации, mqtt не гарантирует порядок доставки сообщений, хотя
|
||||
маловероятно, что порядок будет нарушен, но все же сам протокол не дает таких гарантий.
|
||||
|
||||
Чтобы понять, какие события происходят, лучше всего воспользоваться панелью разработчика и подписаться
|
||||
на вкладке события на событие `mega.sensor`, понажимать кнопки.
|
||||
|
||||
## Сервисы
|
||||
Все сервисы доступны в меню разработчика с описанием и примерами использования
|
||||
```yaml
|
||||
mega.save:
|
||||
description: Сохраняет текущее состояние портов (?cmd=s)
|
||||
fields:
|
||||
mega_id:
|
||||
description: ID меги, можно оставить пустым, тогда будут сохранены все зарегистрированные меги
|
||||
example: "mega"
|
||||
|
||||
mega.get_port:
|
||||
description: Запросить текущий статус порта (или всех)
|
||||
fields:
|
||||
mega_id:
|
||||
description: ID меги, можно оставить пустым, тогда будут порты всех зарегистрированных мег
|
||||
example: "mega"
|
||||
port:
|
||||
description: Номер порта (если не заполнять, будут запрошены все порты сразу)
|
||||
example: 1
|
||||
|
||||
mega.run_cmd:
|
||||
description: Выполнить любую произвольную команду
|
||||
fields:
|
||||
mega_id:
|
||||
description: ID меги
|
||||
example: "mega"
|
||||
port:
|
||||
description: Номер порта (это не порт, которым мы управляем, а порт с которого шлем команду)
|
||||
example: 1
|
||||
cmd:
|
||||
description: Любая поддерживаемая мегой команда
|
||||
example: "1:0"
|
||||
```
|
||||
|
||||
## Отладка
|
||||
Интеграция находится в активной разработке, при возникновении проблем [заводите issue](https://github.com/andvikt/mega_hacs/issues/new/choose)
|
||||
|
||||
Просьба прикладывать детальный лог, который можно включить в конфиге так:
|
||||
```yaml
|
||||
logger:
|
||||
default: info
|
||||
logs:
|
||||
custom_components.mega: debug
|
||||
```
|
||||
|
||||
#### Отладка ответов http-сервера
|
||||
Для отладки ответов сервера можно самим имитировать запросы контроллера, если у вас есть доступ к консоли
|
||||
HA:
|
||||
```shell
|
||||
curl -v -X GET 'http://localhost:8123/mega?pt=5&m=1'
|
||||
```
|
||||
Если доступа нет, нужно в файл конфигурации добавить ip, с которого вы хотите делать запросы, например:
|
||||
```yaml
|
||||
mega:
|
||||
allow_hosts:
|
||||
- 192.168.1.1
|
||||
```
|
||||
И тогда можно с локальной машины делать запросы на ваш сервер HA:
|
||||
```shell
|
||||
curl -v -X GET 'http://192.168.88.1.4:8123/mega?pt=5&m=1'
|
||||
```
|
||||
В ответ будет приходить либо `d`, либо скрипт, который вы настроили
|
||||
в HomeAssistant, а так же обновить ваш контроллер до последней версии, обновление прошивки MegaD можно делать прямо
|
||||
из HA с помощью [аддона](https://github.com/andvikt/mega_addon.git)
|
||||
|
||||
Reference in New Issue
Block a user