hotel-analysis/ARCHITECTURE.md

HotelTask - Архитектура системы

Обзор системы

flowchart TB
    subgraph ClientLayer["Client Layer"]
        WebAdmin["Web Admin<br/>(TypeScript, React)"]
        MobileApps["Mobile Apps"]
        TelegramBot["Telegram Bot"]
    end

    subgraph APIGateway["API Gateway Layer"]
        REST["REST API"]
        gRPC["gRPC"]
        WebSocket["WebSocket"]
    end

    subgraph ServiceLayer["Service Layer (Python)"]
        tasks["tasks-service<br/>Управление задачами"]
        users["users-service<br/>Управление пользователями"]
        connections["connections-service<br/>Связи между адаптерами"]
        notification["notification-service<br/>Уведомления"]
        fileStorage["file-storage-service<br/>Файлы"]
        audit["audit-service<br/>Аудит"]
        scheduler["scheduler-service<br/>Расписание"]
        permissions["permissions-service<br/>Права доступа"]
        events["events-service<br/>Мероприятия"]
    end

    subgraph DataLayer["Data Layer"]
        PostgreSQL[(PostgreSQL<br/>Основная БД)]
        Redis[(Redis<br/>Кэш)]
        S3[(S3<br/>Файлы)]
    end

    subgraph MessageBroker["Message Broker"]
        Kafka["Apache Kafka"]
    end

    subgraph AdapterLayer["Adapter Layer (Python)"]
        PMSAdapter["PMS Adapter"]
        ERPAdapter["ERP Adapter"]
        ResonlineAdapter["Resonline Adapter"]
        TelegramAdapter["Telegram Bot Adapter"]
        CustomAdapter["Custom Adapter #N"]
    end

    subgraph ExternalSystems["External Systems"]
        PMS["PMS"]
        ERP["ERP"]
        Resonline["Resonline"]
    end

    %% Client -> API Gateway
    WebAdmin --> REST
    MobileApps --> REST
    MobileApps --> WebSocket
    TelegramBot --> REST

    %% API Gateway -> Services
    REST --> tasks
    REST --> users
    REST --> connections
    gRPC --> tasks
    gRPC --> users
    WebSocket --> notification

    %% Services -> Data
    tasks --> PostgreSQL
    users --> PostgreSQL
    connections --> PostgreSQL
    audit --> PostgreSQL
    scheduler --> PostgreSQL
    permissions --> PostgreSQL
    events --> PostgreSQL

    notification --> Redis
    tasks --> Redis

    fileStorage --> S3

    %% Services <-> Kafka
    tasks <--> Kafka
    notification <--> Kafka
    connections <--> Kafka

    %% Kafka <-> Adapters
    Kafka <--> PMSAdapter
    Kafka <--> ERPAdapter
    Kafka <--> ResonlineAdapter
    Kafka <--> TelegramAdapter
    Kafka <--> CustomAdapter

    %% Adapters -> External Systems
    PMSAdapter --> PMS
    ERPAdapter --> ERP
    ResonlineAdapter --> Resonline

---

Описание сервисов

Сервис	Назначение	Ключевые функции
tasks-service	Ядро системы	CRUD задач, статусы, назначение исполнителей, история изменений
users-service	Управление пользователями	Регистрация, авторизация, профили, привязка к отелям
connections-service	Маршрутизация событий	Настройка связей "событие A → система B", реестр адаптеров
permissions-service	Права доступа	RBAC, роли, проверка разрешений
notification-service	Уведомления	Push, email, SMS, Telegram, in-app
file-storage-service	Файлы	Загрузка/скачивание фото и документов в S3
audit-service	Аудит	Логирование всех действий в системе
scheduler-service	Планировщик	Создание задач по расписанию (cron)
events-service	Мероприятия	Декомпозиция мероприятий на задачи, генерация "функшн"

---

Слои системы

Client Layer

Клиентские приложения для взаимодействия с системой:

• Web Admin (React, TypeScript) — админка для управления системой
• Mobile Apps — мобильные приложения для сотрудников
• Telegram Bot — бот для управления задачами

API Gateway Layer

Точки входа для клиентов:

• REST API — основной API для веб и мобильных клиентов
• gRPC — высокопроизводительное межсервисное взаимодействие
• WebSocket — real-time уведомления

Service Layer

Микросервисы на Python (FastAPI), каждый отвечает за свою domain-область.

Data Layer

• PostgreSQL — основное хранилище данных
• Redis — кэширование, сессии
• S3 — файловое хранилище (фото, документы)

Message Broker

Apache Kafka — асинхронный обмен сообщениями между сервисами и адаптерами.

Adapter Layer

Адаптеры для интеграции с внешними системами. Каждый адаптер:

• Преобразует данные внешней системы в стандартный формат
• Работает как по push, так и по pull модели
• Изолирует логику интеграции от бизнес-логики

External Systems

Внешние системы отеля: PMS, ERP, системы управления уборкой и другие.

---

Потоки данных

Клиенты → API Gateway

Источник	Назначение	Данные
Web Admin	REST API	Запросы на управление задачами, пользователями, настройками
Mobile Apps	REST API	Запросы на работу с задачами, профилем
Mobile Apps	WebSocket	Подписка на real-time уведомления
Telegram Bot	REST API	Команды от пользователей бота

API Gateway → Сервисы

Источник	Назначение	Данные
REST API	tasks-service	CRUD операции с задачами
REST API	users-service	Авторизация, управление профилями
REST API	connections-service	Настройка связей между адаптерами
gRPC	tasks-service, users-service	Межсервисные синхронные вызовы
WebSocket	notification-service	Подключения клиентов для push-уведомлений

Сервисы → Хранилища данных

Источник	Назначение	Данные
tasks-service	PostgreSQL	Задачи, статусы, история изменений
users-service	PostgreSQL	Пользователи, профили, привязки к отелям
connections-service	PostgreSQL	Правила маршрутизации, реестр адаптеров
permissions-service	PostgreSQL	Роли, права доступа
audit-service	PostgreSQL	Журнал действий
scheduler-service	PostgreSQL	Расписания, шаблоны задач
events-service	PostgreSQL	Мероприятия, шаблоны декомпозиции
notification-service	Redis	Очереди уведомлений, статусы доставки
tasks-service	Redis	Кэш часто запрашиваемых задач
file-storage-service	S3	Фотографии, документы, вложения

Сервисы ↔ Kafka

Сервис	Публикует	Подписан на
tasks-service	События задач (создание, изменение статуса)	Команды на создание задач от адаптеров
notification-service	—	События задач для отправки уведомлений
connections-service	Маршрутизированные события	Входящие события от адаптеров

Kafka ↔ Адаптеры

Адаптер	В Kafka	Из Kafka
PMS Adapter	Бронирования, статусы номеров, данные гостей	Запросы на изменение статуса номера
ERP Adapter	Данные о материалах, заявки	Списания, обновления остатков
Resonline Adapter	Статусы уборки	Задачи на уборку
Telegram Bot Adapter	Сообщения от гостей	Уведомления для отправки

Адаптеры → Внешние системы

Адаптер	Внешняя система	Данные
PMS Adapter	PMS	Синхронизация бронирований и статусов номеров
ERP Adapter	ERP	Синхронизация складских данных
Resonline Adapter	Resonline	Синхронизация задач уборки

---

Технологический стек

Компонент	Технология
Backend	Python 3.11+ (FastAPI)
Frontend	TypeScript, React
База данных	PostgreSQL 15+
Кэш	Redis 7+
Файловое хранилище	S3-compatible (AWS S3 / MinIO)
Message Broker	Apache Kafka
API	REST, gRPC, WebSocket
Аутентификация	JWT / OAuth2
Контейнеризация	Docker
Оркестрация	Kubernetes