┌─────────────────────────────────────────────────────────┐
│                      API Server (Core)                  │
│                                                         │
│   /jobs ──────► /services ──────► /repositories        │
│   (Cron)        (Business Logic)   (DB Access)          │
│                      │                    │             │
│                  /nats                 MySQL DB          │
│                 (Message Handler)                       │
└──────────────────────┬──────────────────────────────────┘
                       │  NATS Messaging
          ┌────────────┼────────────┐
          ▼            ▼            ▼
       Worker 1     Worker 2    Worker N

src/
├── api/
│   ├── jobs/           ← Cron Jobs: gọi Service định kỳ theo lịch
│   ├── services/       ← Business Logic: xử lý nghiệp vụ chính
│   ├── repositories/   ← Data Access Layer: tất cả câu query MySQL đều ở đây
│   ├── nats/           ← Gửi message lên NATS, lắng nghe kết quả từ Worker
│   ├── models/         ← Định nghĩa schema bảng DB bằng Drizzle ORM
│   ├── controllers/    ← Nhận HTTP request từ Frontend, gọi Service tương ứng
│   ├── routes/         ← Khai báo REST API endpoints (URL mapping)
│   ├── middleware/      ← Auth JWT, logging, phân quyền — chạy trước mọi request
│   └── errors/         ← Class lỗi tùy chỉnh, format thông báo lỗi trả về client
├── utils/              ← Hàm tiện ích dùng chung (Date, JSON, tạo Device Profile...)
└── types/              ← TypeScript Interface & Type — không có logic, chỉ khai báo kiểu

HTTP Request
    │
    ▼
Controller  ← Chỉ validate input, không viết business logic ở đây
    │
    ▼
Service     ← Toàn bộ logic nghiệp vụ nằm ở đây
    │
    ├──► Repository  ← Chỉ query DB, không xử lý logic
    │
    └──► NATS Module ← Chỉ đóng gói và gửi message

[Giai đoạn 1]          [Giai đoạn 2]           [Giai đoạn 3]
 Lập lịch               Điều phối               Thực thi & Kết quả
 (Task Creation)  ───►  (Task Dispatch)  ───►   (Result Handling)

 CampaignJob            CampaignTask            NatsReceiver
 AutomationService      ProcessorService        Service
 (chạy mỗi 1 phút)     (chạy mỗi 30s–2p)      (event-driven, liên tục)

[Cron kích hoạt mỗi 1 phút]
        │
        ▼
Quét bảng campaigns
→ Lọc: active=true, start_date ≤ now()
        │
        ▼
Quét bảng campaign_platforms
→ Lọc: status='pending', is_tasks_created=false
        │
        ▼
Đọc metadata_json của từng platform
→ Giải nén ra: danh sách accounts[], danh sách target links[], nội dung comment mẫu
        │
        ▼
Vòng lặp: với mỗi (account × target_link)
→ INSERT một row vào bảng campaign_platform_tasks
→ Gán: action_type, proxy_id, server_id, priority, status='PENDING'
        │
        ▼
Cập nhật campaign_platforms:
→ status = 'running'
→ is_tasks_created = true

[Cron kích hoạt mỗi 30s – 2 phút]
        │
        ▼
Lấy batch task từ campaign_platform_tasks
→ Lọc: status='PENDING', start_date ≤ now()
→ Giới hạn số lượng mỗi lần để tránh quá tải
        │
        ▼
Với mỗi task, chuẩn bị payload:

  ┌── Tài khoản (từ bảng accounts):
  │   - Cookie string (đã giải mã nếu cần)
  │   - User-Agent header
  │   - Device viewport size
  │
  ├── Proxy (từ bảng proxies):
  │   - IP:Port
  │   - Username/Password
  │   - Protocol (http/socks5)
  │
  └── Nội dung:
      - URL bài viết cần thao tác
      - Template comment (nếu là action COMMENT)
      - Các tham số hành động khác
        │
        ▼
Đóng gói thành một Payload object
Publish lên NATS subject: "task.request.create"
        │
        ▼
NATS tự động điều phối tới Worker đang idle
(API không cần biết Worker nào nhận)

Worker gửi kết quả lên "task.completed"
        │
        ▼
NatsReceiverService nhận message
        │
        ▼
Cập nhật campaign_platform_tasks:
→ status = 'COMPLETED'
→ Lưu result_data (link bài đã like, timestamp...)
        │
        ▼
Tăng counter thống kê cho campaign

Worker gửi kết quả lên "task.failed" (kèm error_code)
        │
        ▼
Cập nhật campaign_platform_tasks:
→ status = 'FAILED'
→ Lưu error_reason
        │
        ▼
Kiểm tra nguyên nhân lỗi:

  ├── error_code = COOKIE_EXPIRED
  │     → Đánh dấu account: session_status = 'expired'
  │     → Tìm account dự phòng trong cùng chiến dịch
  │     → Tạo task mới với account thay thế (nếu có)
  │
  ├── error_code = PROXY_ERROR
  │     → Đánh dấu proxy: is_available = false
  │     → Log lý do để admin kiểm tra
  │
  └── Lỗi khác (network timeout, captcha, v.v.)
        → Ghi log chi tiết
        → Tùy config: retry hoặc bỏ qua

[Người dùng Dashboard]
        │
        │  POST /api/campaigns  (HTTP)
        ▼
[Controller]
→ Validate request body
→ Gọi CampaignService.create()
        │
        ▼
[CampaignService]
→ INSERT vào bảng campaigns
→ INSERT vào bảng campaign_platforms
→ Lưu metadata_json (accounts[], target_links[], content_template)
        │
        │  (Đợi tối đa 1 phút...)
        ▼
[Cron: campaignJobAutomation]
→ Phát hiện platform mới với is_tasks_created=false
→ Đọc metadata_json
→ Tạo 100 task PENDING (100 accounts × 1 link mỗi)
→ SET is_tasks_created=true
        │
        │  (Đợi tối đa 30 giây...)
        ▼
[Cron: campaignTaskAutomation]
→ Lấy batch 50 task PENDING đầu tiên
→ Với mỗi task: lấy cookie + proxy
→ Đẩy 50 payload lên NATS subject "task.request.create"
        │
        ▼
[NATS]
→ Load balancing: phân phối đều cho các Worker đang idle
        │
        ├──► Worker 1 nhận 17 task
        ├──► Worker 2 nhận 17 task
        └──► Worker 3 nhận 16 task
        │
        ▼  (Song song, mỗi Worker...)
[Tool]
→ Nhận payload từ NATS
→ Khởi tạo Puppeteer/Playwright session
→ Nạp cookie vào browser
→ Route traffic qua proxy
→ Mở URL bài viết
→ Click nút Like
→ Verify like thành công
→ Publish "task.completed" lên NATS
        │
        ▼
[NatsReceiverService]
→ Nhận "task.completed"
→ UPDATE campaign_platform_tasks SET status='COMPLETED'
→ Lưu timestamp thành công
        │
        │  (Mỗi 5 phút...)
        ▼
[Cron: campaignStatistics]
→ Đếm số task COMPLETED trong mỗi chiến dịch
→ Cập nhật bảng thống kê
→ Dashboard hiển thị: "87/100 Likes thành công"

{
  "success": false,
  "error": {
    "code": "CAMPAIGN_NOT_FOUND",
    "message": "Chiến dịch không tồn tại hoặc đã bị xóa",
    "details": {}
  }
}