Разработка мобильного приложения для BMS-управления зданием

BMS-проекты начинаются одинаково: заказчик показывает схему здания с контроллерами Siemens Desigo CC, Schneider Electric EcoStruxure или Johnson Controls Metasys и говорит «хотим видеть всё это в телефоне». За этим «всё это» скрываются десятки протоколов, polling-циклы от 1 секунды до 15 минут, историческая база на годы назад и требование работать даже когда основной сервер BMS перезагружается. Мы берём такие проекты под ключ: от анализа протоколов до публикации в stores. Наш опыт — 10+ лет в BMS-интеграции и более 50 реализованных объектов. Оцениваем проект за 2 дня и гарантируем стабильную работу при любой нагрузке.

Протоколы и шлюзы

Промышленные BMS говорят на BACnet/IP, Modbus TCP/RTU, KNX/IP и LonWorks. Напрямую из мобильного приложения к ним не ходят — между контроллерами и REST/WebSocket API стоит шлюз или middleware.

Типичный стек интеграции:

Niagara Framework 4 (Tridium) — де-факто стандарт для крупных объектов. Он умеет нормализовать BACnet-объекты в единый REST API (/haystack/api/read?filter=bacnet) и отдавать WebSocket-стрим изменений. Работа с Haystack API через Dart:

class HaystackClient {
  final Dio _dio;
  final String _baseUrl;

  HaystackClient(this._baseUrl, String username, String password)
      : _dio = Dio(
          BaseOptions(
            baseUrl: _baseUrl,
            headers: {
              'Authorization': 'Basic ${base64Encode(utf8.encode('$username:$password'))}',
              'Accept': 'application/json',
            },
          ),
        );

  Future<List<HaystackRow>> read(String filter) async {
    final response = await _dio.get('/haystack/api/read', queryParameters: {'filter': filter});
    final grid = HaystackGrid.fromJson(response.data);
    return grid.rows;
  }

  Future<Map<String, dynamic>> readPoint(String pointId) async {
    final response = await _dio.get('/haystack/api/hisRead', queryParameters: {
      'id': '@$pointId',
      'range': 'today',
    });
    return response.data;
  }
}

Для объектов с MQTT-шлюзом (Node-RED конвертирует BACnet → MQTT JSON) используем mqtt_client в Flutter. Топики организуем по иерархии здания: building/{buildingId}/floor/{floor}/zone/{zone}/{parameter}.

Как мы интегрируемся с существующей BMS?

Процесс всегда начинаем с аудита контроллеров: выясняем, какие протоколы используются, какая версия Niagara или другого middleware, есть ли уже REST/WebSocket API или требуется установка шлюза. Затем проектируем схему потоков данных: какие точки читаем, какие пишем, с какой периодичностью. Сертифицированные инженеры настраивают шлюз и проводят интеграционное тестирование. Результат — единый интерфейс на телефоне вместо нескольких панелей управления.

Архитектура данных реального времени: почему DataHub критичен?

Самый сложный момент в BMS-приложении — не подключение, а управление потоком данных. Температура в 200 зонах обновляется каждые 30 секунд, освещение — по событию, энергопотребление — каждую минуту. Всё это нельзя переподписывать при каждом перерисовывании UI.

Решение — централизованный DataHub на уровне приложения:

class BmsDataHub {
  final MqttClient _mqtt;
  final _streams = <String, BehaviorSubject<BmsPoint>>{};

  Stream<BmsPoint> watchPoint(String pointId) {
    if (!_streams.containsKey(pointId)) {
      _streams[pointId] = BehaviorSubject();
      _mqtt.subscribe('building/+/+/+/$pointId', MqttQos.atLeastOnce);
    }
    return _streams[pointId]!.stream;
  }

  void _onMessage(List<MqttReceivedMessage<MqttMessage>> events) {
    for (final event in events) {
      final topic = event.topic;
      final payload = MqttPublishPayload.bytesToStringAsString(
          (event.payload as MqttPublishMessage).payload.message);
      final point = BmsPoint.fromJson(jsonDecode(payload));
      _streams[point.id]?.add(point);
    }
  }
}

BehaviorSubject из пакета rxdart сохраняет последнее значение — виджет, подписавшийся после прихода данных, сразу получает актуальное состояние без ожидания следующего цикла polling.

Интерактивный план этажа

Заказчики всегда хотят план здания с живыми данными. DXF или SVG-план конвертируем в SVG (через ODA File Converter для DXF), рендерим через flutter_svg + InteractiveViewer. Точки датчиков — overlay поверх SVG с позиционированием по нормализованным координатам:

class FloorPlanWidget extends StatelessWidget {
  final FloorPlan plan;
  final Map<String, BmsPoint> liveData;

  @override
  Widget build(BuildContext context) {
    return LayoutBuilder(
      builder: (context, constraints) {
        return Stack(
          children: [
            SvgPicture.asset(
              'assets/floors/${plan.id}.svg',
              width: constraints.maxWidth,
            ),
            ...plan.sensors.map(
              (sensor) => Positioned(
                left: sensor.x * constraints.maxWidth,
                top: sensor.y * constraints.maxHeight,
                child: SensorMarker(
                  point: liveData[sensor.pointId],
                  type: sensor.type,
                ),
              ),
            ),
          ],
        );
      },
    );
  }
}

Маркеры меняют цвет по порогам: зелёный (норма), жёлтый (предупреждение), красный (авария). Пороги берём из BMS-конфигурации, не хардкодим.

Управление: запись значений в BACnet-точки

Читать проще, чем писать. Для командования BACnet-точками (setpoint температуры, включение/выключение освещения) через REST-шлюз:

Future<void> writePoint(String pointId, dynamic value) async {
  // Оптимистичное обновление UI
  _hub.updateLocally(pointId, value);
  try {
    await _api.put('/haystack/api/pointWrite', data: {
      'id': '@$pointId',
      'level': 8, // приоритет записи BACnet (1-16, ниже = выше приоритет)
      'val': value,
      'who': _authService.currentUser,
      'duration': 'PT0S', // permanent
    });
  } on DioException catch (e) {
    // Откат при ошибке
    _hub.revertLocally(pointId);
    rethrow;
  }
}

BACnet Priority Array — деталь, которую игнорируют и потом не могут понять, почему уставка температуры не меняется: контроллер принимает команды, но они перебиваются более высоким приоритетом из BMS-расписания (уровень 2-4). Уровень 8 — стандартный для ручного оператора.

Алерты и журнал событий

Аварийные события из BMS приходят через MQTT или WebSocket. Локальные push-уведомления генерируем через flutter_local_notifications, серверные push (когда приложение закрыто) — через FCM с высоким приоритетом (priority: high, content_available: true).

Журнал событий: SQLite через drift для офлайн-хранения 30 дней истории, страничная загрузка из API для более старых записей.

Разграничение прав

В реальных объектах разные пользователи видят разные этажи и зоны. Права хранятся на бэкенде, мобильный клиент запрашивает список доступных объектов при логине и не строит маршруты к недоступным ресурсам. Попытка записать в запрещённую точку → HTTP 403 → локальный откат + уведомление пользователю.

Что входит в разработку?

• Анализ протоколов контроллеров и архитектуры BMS.
• Проектирование схемы интеграции и потоков данных.
• Реализация мобильного клиента (iOS/Android на Flutter или нативном стеке).
• Настройка шлюза и интеграционное тестирование.
• Публикация в App Store и Google Play.
• 30 дней технической поддержки после релиза.
• Документация по API и обучение персонала (опционально).

Сроки и стоимость

Стоимость рассчитывается индивидуально после анализа ваших контроллеров и требований. Свяжитесь с нами для оценки — мы подготовим коммерческое предложение за 2 рабочих дня.