OrangePi R2S: Строим Linux-роутер на доступном восьмиядерном RISC-V одноплатнике с портами 2.5G

# Интерфейс локальной сети
interface=br0

# Внешние DNS-серверы
server=1.1.1.1
server=1.0.0.1
server=8.8.8.8

# Не пересылать адреса без доменной части и локальные запросы на внешние DNS
domain-needed
bogus-priv

# Диапазон DHCP (от .100 до .200, время аренды 12 часов)
dhcp-range=192.168.1.100,192.168.1.200,255.255.255.0,12h

# Параметры DHCP для клиентов: Шлюз (192.168.1.1) и DNS (192.168.1.1)
dhcp-option=option:router,192.168.1.1
dhcp-option=option:dns-server,192.168.1.1

# ---------------------------------------------------------
# Статические IP-адреса клиентов (MAC, Имя, IP)
# ---------------------------------------------------------
dhcp-host=aa:bb:cc:dd:ee:ff,pc,192.168.1.2

Затем, чтобы встроенный systemd-resolved не перехватывал 53 порт (DNS), я направил символической ссылкой /etc/resolv.conf на работающий DNS:

sudo rm /etc/resolv.conf
sudo ln -s /run/systemd/resolve/resolv.conf /etc/resolv.conf
sudo systemctl restart systemd-resolved
sudo systemctl restart dnsmasq
sudo systemctl enable dnsmasq

Шаг 1. Установка Flask и создание структуры

Установите минимальные библиотеки Python:

Bash

sudo apt update

sudo apt install -y python3-flask

Создайте папку для веб-сервиса:

mkdir -p /opt/dnsmasq-web/templates

cd /opt/dnsmasq-web

Шаг 2. Создание файла скрипта app.py

Откройте app.py:

Bash

sudo nano /opt/dnsmasq-web/app.py

И вставьте следующий текст:

import json
import re
import subprocess
from flask import Flask, render_template, request, redirect, url_for, jsonify

app = Flask(__name__)
CONFIG_PATH = '/etc/dnsmasq.conf'
LEASES_PATH = '/var/lib/misc/dnsmasq.leases'
PBR_RULES_PATH = '/etc/pbr-rules.json'

CYR_TO_LAT = {
    'а': 'a', 'б': 'b', 'в': 'v', 'г': 'g', 'д': 'd', 'е': 'e', 'ё': 'yo',
    'ж': 'zh', 'з': 'z', 'и': 'i', 'й': 'y', 'к': 'k', 'л': 'l', 'м': 'm',
    'н': 'n', 'о': 'o', 'п': 'p', 'р': 'r', 'с': 's', 'т': 't', 'у': 'u',
    'ф': 'f', 'х': 'h', 'ц': 'ts', 'ч': 'ch', 'ш': 'sh', 'щ': 'sch', 'ъ': '',
    'ы': 'y', 'ь': '', 'э': 'e', 'ю': 'yu', 'я': 'ya'
}

def sanitize_hostname(name):
    name = name.strip().lower()
    res = [CYR_TO_LAT.get(char, char) for char in name]
    name = "".join(res)
    name = re.sub(r'[\s_]+', '-', name)
    name = re.sub(r'[^a-z0-9\-]', '', name)
    return name.strip('-') if name.strip('-') else "device"

def get_pbr_modes():
    try:
        with open(PBR_RULES_PATH, 'r') as f:
            return json.load(f)
    except Exception:
        return {}

def save_pbr_modes(modes):
    try:
        with open(PBR_RULES_PATH, 'w') as f:
            json.dump(modes, f, indent=2)
    except Exception as e:
        print(f"Error saving PBR rules: {e}")

def apply_pbr_rule(ip, mode):
    # Очищаем правила для данного IP из обеих таблиц
    subprocess.run(['ip', 'rule', 'del', 'from', ip, 'table', '100'], stderr=subprocess.DEVNULL)
    subprocess.run(['ip', 'rule', 'del', 'from', ip, 'table', '101'], stderr=subprocess.DEVNULL)

    # Применяем нужную таблицу
    if mode == 'ORACLE':
        subprocess.run(['ip', 'rule', 'add', 'from', ip, 'table', '100'])
    elif mode == 'WARP':
        subprocess.run(['ip', 'rule', 'add', 'from', ip, 'table', '101'])
    # При DIRECT (No VPN) никаких правил не нужно — трафик идёт через стандартный дефолтный шлюз системы

def read_data():
    saved_hosts = []
    dns_redirects = []
    saved_macs = set()
    pbr_modes = get_pbr_modes()

    try:
        with open(CONFIG_PATH, 'r') as f:
            for line in f:
                line = line.strip()
                if line.startswith('dhcp-host='):
                    parts = line.replace('dhcp-host=', '').split(',')
                    if len(parts) >= 3:
                        mac = parts[0].strip().lower()
                        ip = parts[2].strip()
                        saved_hosts.append({
                            'mac': mac,
                            'name': parts[1].strip(),
                            'ip': ip,
                            'mode': pbr_modes.get(ip, 'DIRECT')
                        })
                        saved_macs.add(mac)
                elif line.startswith('address=/'):
                    parts = line.replace('address=/', '').split('/')
                    if len(parts) >= 2:
                        # Убираем ведущую точку при чтении для чистого отображения
                        domain_clean = parts[0].strip().lstrip('.')
                        dns_redirects.append({
                            'domain': domain_clean,
                            'ip': parts[1].strip()
                        })
    except Exception as e:
        print(f"Error reading config: {e}")

    leases = []
    try:
        with open(LEASES_PATH, 'r') as f:
            for line in f:
                parts = line.strip().split()
                if len(parts) >= 4:
                    mac = parts[1].strip().lower()
                    ip = parts[2].strip()
                    hostname = parts[3].strip()
                    if hostname == '*':
                        hostname = 'new-device'

                    if mac not in saved_macs:
                        leases.append({
                            'mac': mac,
                            'ip': ip,
                            'name': hostname
                        })
    except Exception as e:
        print(f"Error reading leases: {e}")

    return saved_hosts, dns_redirects, leases

@app.route('/')
def index():
    hosts, dns_redirects, new_devices = read_data()
    return render_template('index.html', hosts=hosts, dns_redirects=dns_redirects, new_devices=new_devices)

@app.route('/save', methods=['POST'])
def save():
    macs = request.form.getlist('mac')
    names = request.form.getlist('name')
    ips = request.form.getlist('ip')
    modes = request.form.getlist('mode')

    domains = request.form.getlist('dns_domain')
    dns_ips = request.form.getlist('dns_ip')

    non_managed_lines = []
    try:
        with open(CONFIG_PATH, 'r') as f:
            for line in f:
                sline = line.strip()
                if not sline.startswith('dhcp-host=') and not sline.startswith('address=/'):
                    non_managed_lines.append(line)
    except Exception as e:
        print(f"Error reading original config: {e}")

    new_host_lines = []
    pbr_dict = {}

    for mac, name, ip, mode in zip(macs, names, ips, modes):
        if mac.strip() and ip.strip():
            clean_name = sanitize_hostname(name)
            clean_ip = ip.strip()
            new_host_lines.append(f"dhcp-host={mac.strip()},{clean_name},{clean_ip}\n")
            
            apply_pbr_rule(clean_ip, mode)
            pbr_dict[clean_ip] = mode

    save_pbr_modes(pbr_dict)

    new_dns_lines = []
    for domain, dns_ip in zip(domains, dns_ips):
        d_clean = domain.strip().lstrip('*').strip('.')
        if d_clean and dns_ip.strip():
            # Записываем без принудительной точки перед доменом
            new_dns_lines.append(f"address=/{d_clean}/{dns_ip.strip()}\n")

    with open(CONFIG_PATH, 'w') as f:
        f.writelines(non_managed_lines)
        if non_managed_lines and not non_managed_lines[-1].endswith('\n'):
            f.write('\n')
        
        f.write('# --- Wildcard & Specific DNS Redirects ---\n')
        f.writelines(new_dns_lines)
        
        f.write('# --- Static DHCP Hosts ---\n')
        f.writelines(new_host_lines)

    subprocess.run(['systemctl', 'restart', 'dnsmasq'])
    return redirect(url_for('index'))

@app.route('/api/pbr', methods=['GET'])
def api_get_pbr():
    ip = request.args.get('ip')
    if not ip:
        return jsonify({'error': 'Missing ip parameter'}), 400
    pbr_modes = get_pbr_modes()
    mode = pbr_modes.get(ip, 'DIRECT')
    return jsonify({'ip': ip, 'mode': mode})

@app.route('/api/pbr', methods=['POST'])
def api_set_pbr():
    data = request.get_json() or {}
    ip = data.get('ip') or request.form.get('ip')
    mode = data.get('mode') or request.form.get('mode')

    if not ip or mode not in ['DIRECT', 'ORACLE', 'WARP']:
        return jsonify({'error': 'Invalid ip or mode'}), 400

    apply_pbr_rule(ip, mode)

    pbr_modes = get_pbr_modes()
    pbr_modes[ip] = mode
    save_pbr_modes(pbr_modes)

    return jsonify({'status': 'ok', 'ip': ip, 'mode': mode})

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=3030)

И сам веб-интерфейс (index.html)

Введите код:

sudo nano /opt/dnsmasq-web/templates/index.html

Вставьте следующий текст:

<!DOCTYPE html>
<html lang="ru">
<head>
    <meta charset="UTF-8">
    <title>DNSMasq & Routing Manager</title>
    <style>
        body { font-family: system-ui, -apple-system, sans-serif; background: #121212; color: #e0e0e0; padding: 20px; }
        .container { max-width: 1000px; margin: 0 auto; background: #1e1e1e; padding: 20px; border-radius: 8px; box-shadow: 0 4px 10px rgba(0,0,0,0.5); }
        h2 { margin-top: 0; color: #4caf50; }
        h3 { color: #2196f3; margin-top: 30px; border-bottom: 1px solid #333; padding-bottom: 5px; }
        .h3-new { color: #ff9800; border: none; margin-top: 0; }
        table { width: 100%; border-collapse: collapse; margin-bottom: 15px; }
        th, td { padding: 8px 12px; text-align: left; border-bottom: 1px solid #333; }
        th { cursor: pointer; background: #2a2a2a; user-select: none; }
        th:hover { background: #333; }
        input[type="text"], select { width: 95%; padding: 6px; background: #2b2b2b; border: 1px solid #444; color: #fff; border-radius: 4px; }
        select { cursor: pointer; font-weight: bold; }
        .btn { padding: 8px 16px; border: none; border-radius: 4px; cursor: pointer; font-weight: bold; }
        .btn-save { background: #4caf50; color: white; font-size: 16px; }
        .btn-add { background: #2196f3; color: white; margin-right: 10px; }
        .btn-del { background: #f44336; color: white; padding: 4px 10px; }
        .btn-claim { background: #ff9800; color: #121212; padding: 4px 10px; font-weight: bold; }
        .actions { display: flex; justify-content: space-between; align-items: center; margin-top: 25px; }
        .new-box { background: #262118; border: 1px solid #523b12; padding: 15px; border-radius: 6px; margin-top: 25px; }
        .hint { font-size: 12px; color: #888; margin-top: -5px; margin-bottom: 10px; }
    </style>
</head>
<body>
    <div class="container">
        <h2>DNSMasq & Routing Manager</h2>
        
        <form action="/save" method="post" id="mainForm">
            <!-- СЕКЦИЯ 1: DHCP HOSTS -->
            <h3>1. Статические DHCP Клиенты и Маршрутизация</h3>
            <table id="hostsTable">
                <thead>
                    <tr>
                        <th onclick="sortTable('hostsTable', 0, false)">Имя &#x25B2;&#x25BC;</th>
                        <th onclick="sortTable('hostsTable', 1, false)">MAC Адрес &#x25B2;&#x25BC;</th>
                        <th onclick="sortTable('hostsTable', 2, true)">IP Адрес &#x25B2;&#x25BC;</th>
                        <th style="width: 160px;">Маршрут</th>
                        <th style="width: 50px;"></th>
                    </tr>
                </thead>
                <tbody>
                    {% for host in hosts %}
                    <tr>
                        <td><input type="text" name="name" value="{{ host.name }}"></td>
                        <td><input type="text" name="mac" value="{{ host.mac }}"></td>
                        <td><input type="text" name="ip" value="{{ host.ip }}"></td>
                        <td>
                            <select name="mode">
                                <option value="DIRECT" {% if host.mode == 'DIRECT' %}selected{% endif %}>⚪ Direct (No VPN)</option>
                                <option value="ORACLE" {% if host.mode == 'ORACLE' %}selected{% endif %}> VPN Oracle (wg0)</option>
                                <option value="WARP" {% if host.mode == 'WARP' %}selected{% endif %}>⚡ WARP (wg-warp)</option>
                            </select>
                        </td>
                        <td><button type="button" class="btn btn-del" onclick="deleteRow(this)">X</button></td>
                    </tr>
                    {% endfor %}
                </tbody>
            </table>
            <button type="button" class="btn btn-add" onclick="addHostRow()">+ Устройство</button>

            <!-- СЕКЦИЯ 2: WILDCARD DNS -->
            <h3>2. DNS Перенаправления (DNS Records / Wildcard)</h3>
            <p class="hint">Укажите доменную зону (например, <code>local</code> для всех *.local) или конкретный хост (например, <code>orangepi.local</code>).</p>
            <table id="dnsTable">
                <thead>
                    <tr>
                        <th onclick="sortTable('dnsTable', 0, false)">Домен / Зона &#x25B2;&#x25BC;</th>
                        <th onclick="sortTable('dnsTable', 1, true)">Целевой IP &#x25B2;&#x25BC;</th>
                        <th style="width: 50px;"></th>
                    </tr>
                </thead>
                <tbody>
                    {% for dns in dns_redirects %}
                    <tr>
                        <td><input type="text" name="dns_domain" value="{{ dns.domain }}" placeholder="local или pc.local"></td>
                        <td><input type="text" name="dns_ip" value="{{ dns.ip }}" placeholder="192.168.1.X"></td>
                        <td><button type="button" class="btn btn-del" onclick="deleteRow(this)">X</button></td>
                    </tr>
                    {% endfor %}
                </tbody>
            </table>
            <button type="button" class="btn btn-add" onclick="addDnsRow()">+ DNS Зону</button>

            <!-- СЕКЦИЯ 3: НОВЫЕ УСТРОЙСТВА -->
            {% if new_devices %}
            <div class="new-box">
                <h3 class="h3-new">Обнаружены новые устройства в сети</h3>
                <table>
                    <thead>
                        <tr>
                            <th>Имя</th>
                            <th>MAC Адрес</th>
                            <th>Текущий IP</th>
                            <th>Действие</th>
                        </tr>
                    </thead>
                    <tbody>
                        {% for dev in new_devices %}
                        <tr>
                            <td>{{ dev.name }}</td>
                            <td><code>{{ dev.mac }}</code></td>
                            <td>{{ dev.ip }}</td>
                            <td>
                                <button type="button" class="btn btn-claim" onclick="claimDevice('{{ dev.name }}', '{{ dev.mac }}', '{{ dev.ip }}', this)">
                                    + Закрепить IP
                                </button>
                            </td>
                        </tr>
                        {% endfor %}
                    </tbody>
                </table>
            </div>
            {% endif %}

            <div class="actions">
                <div></div>
                <button type="submit" class="btn btn-save">Сохранить и применить маршруты</button>
            </div>
        </form>
    </div>

    <script>
        function claimDevice(name, mac, ip, btn) {
            const tbody = document.querySelectorAll('#hostsTable tbody')[0];
            const tr = document.createElement('tr');
            tr.innerHTML = `
                <td><input type="text" name="name" value="${name}"></td>
                <td><input type="text" name="mac" value="${mac}"></td>
                <td><input type="text" name="ip" value="${ip}"></td>
                <td>
                    <select name="mode">
                        <option value="DIRECT" selected>⚪ Direct (No VPN)</option>
                        <option value="ORACLE"> VPN Oracle (wg0)</option>
                        <option value="WARP">⚡ WARP (wg-warp)</option>
                    </select>
                </td>
                <td><button type="button" class="btn btn-del" onclick="deleteRow(this)">X</button></td>
            `;
            tbody.appendChild(tr);
            btn.parentNode.parentNode.remove();
        }

        function addHostRow() {
            const tbody = document.querySelectorAll('#hostsTable tbody')[0];
            const tr = document.createElement('tr');
            tr.innerHTML = `
                <td><input type="text" name="name" placeholder="new-device"></td>
                <td><input type="text" name="mac" placeholder="00:00:00:00:00:00"></td>
                <td><input type="text" name="ip" placeholder="192.168.1.X"></td>
                <td>
                    <select name="mode">
                        <option value="DIRECT" selected>⚪ Direct (No VPN)</option>
                        <option value="ORACLE"> VPN Oracle (wg0)</option>
                        <option value="WARP">⚡ WARP (wg-warp)</option>
                    </select>
                </td>
                <td><button type="button" class="btn btn-del" onclick="deleteRow(this)">X</button></td>
            `;
            tbody.appendChild(tr);
        }

        function addDnsRow() {
            const tbody = document.querySelectorAll('#dnsTable tbody')[0];
            const tr = document.createElement('tr');
            tr.innerHTML = `
                <td><input type="text" name="dns_domain" placeholder="local или pc.local"></td>
                <td><input type="text" name="dns_ip" placeholder="192.168.1.X"></td>
                <td><button type="button" class="btn btn-del" onclick="deleteRow(this)">X</button></td>
            `;
            tbody.appendChild(tr);
        }

        function deleteRow(btn) {
            btn.parentNode.parentNode.remove();
        }

        function ipToNumArray(ip) {
            return ip.split('.').map(num => parseInt(num, 10) || 0);
        }

        function sortTable(tableId, colIndex, isIpColumn) {
            const table = document.getElementById(tableId);
            let rows = Array.from(table.rows).slice(1);
            let dir = table.getAttribute("data-sort-dir") === "asc" ? "desc" : "asc";
            table.setAttribute("data-sort-dir", dir);

            rows.sort((a, b) => {
                let inputA = a.cells[colIndex].querySelector('input');
                let valA = inputA ? inputA.value.trim() : a.cells[colIndex].innerText.trim();
                let inputB = b.cells[colIndex].querySelector('input');
                let valB = inputB ? inputB.value.trim() : b.cells[colIndex].innerText.trim();

                if (isIpColumn) {
                    let numA = ipToNumArray(valA);
                    let numB = ipToNumArray(valB);

                    for (let i = 0; i < 4; i++) {
                        if (numA[i] !== numB[i]) {
                            return dir === "asc" ? numA[i] - numB[i] : numB[i] - numA[i];
                        }
                    }
                    return 0;
                } else {
                    valA = valA.toLowerCase();
                    valB = valB.toLowerCase();
                    if (valA < valB) return dir === "asc" ? -1 : 1;
                    if (valA > valB) return dir === "asc" ? 1 : -1;
                    return 0;
                }
            });

            rows.forEach(row => table.tBodies[0].appendChild(row));
        }
    </script>
</body>
</html>

Применяем изменения

Bash

sudo systemctl restart dnsmasq-web

sudo nano /etc/network-optimization.sh

#!/bin/bash
# Небольшая пауза при старте системы, чтобы сетевые интерфейсы успели подняться
sleep 3

# 1. Отключаем GRO/LRO/TSO/GSO для снижения нагрузки на 1-е ядро
for dev in enP1p1s0 enP2p1s0 end0 end1 br0; do
    ethtool -K $dev gro off lro off tso off gso off 2>/dev/null
done

# 2. Увеличиваем таблицу RFS
echo 65536 > /proc/sys/net/core/rps_sock_flow_entries

# 3. Настраиваем RPS строго на Ядра 3-8 (маска fc = 11111100)
for dev in /sys/class/net/*/queues/rx-*/rps_cpus; do
    echo "fc" > "$dev" 2>/dev/null
done

# 4. Прописываем лимит потоков на очередь
for dev in /sys/class/net/*/queues/rx-*/rps_flow_cnt; do
    echo 2048 > "$dev" 2>/dev/null
done

# 5. Переносим исходящий трафик (XPS) на Ядра 3-8
for dev in /sys/class/net/*/queues/tx-*/xps_cpus; do
    echo "fc" > "$dev" 2>/dev/null
done

Делаем файл исполняемым.

sudo chmod +x /etc/network-optimization.sh

Автозапуск (создание службы):
sudo nano /etc/systemd/system/network-optimization.service

[Unit]
Description=Network Stack Optimization (RPS/RFS/Offload)
After=network-online.target
Wants=network-online.target

[Service]
Type=oneshot
ExecStart=/etc/network-optimization.sh
RemainAfterExit=yes

[Install]
WantedBy=multi-user.target

И включить автозапуск службы:
sudo systemctl daemon-reload
sudo systemctl enable network-optimization.service

import socket
import subprocess
import threading
import json
import time
import logging
from threading import Timer
from datetime import datetime
import paho.mqtt.client as mqtt

# --- НАСТРОЙКИ ПОДКЛЮЧЕНИЯ ---
MQTT_BROKER = "127.0.0.1"
MQTT_PORT = 1883
MQTT_USER = "login"
MQTT_PASS = "password"

logging.basicConfig(level=logging.INFO, format='%(asctime)s [%(levelname)s] %(message)s')

# Global variables
corridor_timer = None
boiler_on_triggered = False
boiler_off_triggered = False

# --- ADB ---
ANDROID_TV_IP = "192.168.1.6"
tv_last_state = "UNKNOWN"

# =====================================================================
# ВСПОМОГАТЕЛЬНЫЕ ФУНКЦИИ
# =====================================================================

def publish(client, topic, payload):
    """Отправка JSON или обычных команд в MQTT"""
    if isinstance(payload, dict):
        client.publish(topic, json.dumps(payload))
    else:
        client.publish(topic, str(payload))

def turn_off_corridor_light(client):
    """Таймаут: Выключение света в коридоре"""
    logging.info("Автоматизация -> Таймаут коридора (90с) -> Выключение света")
    publish(client, "zigbee2mqtt/Свет коридор/set", {"state": "OFF"})

def restart_corridor_timer(client):
    """Сброс и запуск таймера коридора на 90 секунд"""
    global corridor_timer
    if corridor_timer is not None:
        corridor_timer.cancel()
    corridor_timer = Timer(90.0, turn_off_corridor_light, [client])
    corridor_timer.start()

# =====================================================================
# БЛОК 1: ПРЯМОЕ УПРАВЛЕНИЕ (DIRECT CONTROLS)
# (Кнопки, выключатели, пульты — реагируют сразу без сложных условий)
# =====================================================================

def handle_direct_controls(client, topic, action):
    
    # --- ВЫКЛЮЧАТЕЛЬ ЗАЛ ---
    if topic == "zigbee2mqtt/Выключатель зал":
        if action == "1_single":
            logging.info("Прямое управление -> Зал 1 / 1 нажатие -> Свет зал")
            publish(client, "zigbee2mqtt/Свет зал/set", {"state": "TOGGLE"})
        elif action == "3_double":
            logging.info("Прямое управление -> Зал 3 / 2 нажатия -> AIR 25 cool")
            publish(client, "esphome/45/button/ac_25c_cool/command", "PRESS")

    # --- ВЫКЛЮЧАТЕЛЬ КОРИДОР ---
    elif topic == "zigbee2mqtt/Выключатель коридор":
        if action == "1_single":
            logging.info("Прямое управление -> Коридор 1 / 1 нажатие -> Свет коридор")
            publish(client, "zigbee2mqtt/Свет коридор/set", {"state": "TOGGLE"})

# =====================================================================
# БЛОК 2: АВТОМАТИЗАЦИИ (AUTOMATIONS)
# (Датчики, сценарии по времени, логика таймеров и умных событий)
# =====================================================================

def handle_automations(client, topic, payload):
    # 1. Открытие входной двери -> Свет в коридоре на 1.5 мин
    if topic == "zigbee2mqtt/Сенсор двери входной" and "contact" in payload:
        is_open = not payload["contact"]
        if is_open:
            logging.info("Автоматизация -> Входная дверь открыта -> Свет в коридоре на 90 сек")
            publish(client, "zigbee2mqtt/Свет коридор/set", {"state": "ON"})
            restart_corridor_timer(client)

def check_scheduled_automations(client):
    """Автоматизации по строгому времени (бойлер, ночные режимы)"""
    global boiler_on_triggered, boiler_off_triggered
    now = datetime.now()

    # --- Бойлер: Включение в 00:00:00 ---
    if now.hour == 0 and now.minute == 0 and now.second == 0:
        if not boiler_on_triggered:
            logging.info("Автоматизация времени -> Ночной тариф (00:00) -> Включение бойлера")
            publish(client, "zigbee2mqtt/Бойлер/set", {"state": "ON"})
            boiler_on_triggered = True
    else:
        boiler_on_triggered = False

    # --- Бойлер: Выключение в 06:50:00 ---
    if now.hour == 6 and now.minute == 50 and now.second == 0:
        if not boiler_off_triggered:
            logging.info("Автоматизация времени -> Конец ночного тарифа (06:50) -> Выключение бойлера")
            publish(client, "zigbee2mqtt/Бойлер/set", {"state": "OFF"})
            boiler_off_triggered = True
    else:
        boiler_off_triggered = False

# =====================================================================
# МОДУЛЬ ANDROID TV (ADB Мониторинг)
# =====================================================================

def get_android_tv_state(ip):
    """Проверка питания экрана Android TV через ADB"""
    try:
        # Быстрый коннект
        subprocess.run(f"adb connect {ip}:5555", shell=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL, timeout=2)
        
        # Запрос состояния экрана
        cmd = f"adb -s {ip}:5555 shell dumpsys power | grep 'mHoldingDisplaySuspendBlocker'"
        result = subprocess.check_output(cmd, shell=True, timeout=2).decode('utf-8')
        
        if "true" in result:
            return "ON"
        else:
            return "OFF"
    except Exception:
        return "OFFLINE"

def monitor_android_tv(client):
    """Фоновый цикл слежения за ТВ"""
    global tv_last_state
    while True:
        current_state = get_android_tv_state(ANDROID_TV_IP)
        
        if current_state != tv_last_state and current_state != "OFFLINE":
            logging.info(f"Android TV изменил статус: {tv_last_state} -> {current_state}")
            
            if current_state == "ON":
                logging.info("Автоматизация ADB -> Включение 'ТВ Кухня'")
                publish(client, "zigbee2mqtt/ТВ Кухня/set", {"state": "ON"})
                
            elif current_state == "OFF":
                logging.info("Автоматизация ADB -> Выключение 'ТВ Кухня'")
                publish(client, "zigbee2mqtt/ТВ Кухня/set", {"state": "OFF"})

            tv_last_state = current_state

        time.sleep(4)  # Опрос каждые 4 секунды


# =====================================================================
# ЯДРО СИСТЕМЫ (MQTT CLIENT LOOP)
# =====================================================================

def on_connect(client, userdata, flags, rc):
    if rc == 0:
        logging.info("Соединение с MQTT Брокером установлено успешно!")
        topics = [
            "zigbee2mqtt/Выключатель зал",
            "zigbee2mqtt/Выключатель коридор",
            "zigbee2mqtt/Сенсор двери входной"
        ]
        for t in topics:
            client.subscribe(t)
    else:
        logging.error(f"Ошибка подключения, код: {rc}")

def on_message(client, userdata, msg):
    try:
        topic = msg.topic
        payload = json.loads(msg.payload.decode('utf-8'))

        # Разводка событий по блокам
        if "action" in payload:
            handle_direct_controls(client, topic, payload["action"])
        
        handle_automations(client, topic, payload)

    except Exception as e:
        logging.error(f"Ошибка обработки пакета: {e}")

# Инициализация и запуск
client = mqtt.Client()
client.username_pw_set(MQTT_USER, MQTT_PASS)
client.on_connect = on_connect
client.on_message = on_message

client.connect(MQTT_BROKER, MQTT_PORT, 60)
client.loop_start()

# Запуск фонового отслеживания Android TV
threading.Thread(target=monitor_android_tv, args=(client,), daemon=True).start()

try:
    while True:
        check_scheduled_automations(client)
        time.sleep(0.5)

except KeyboardInterrupt:
    logging.info("Остановка службы...")
    client.loop_stop()
    client.disconnect()