feat: Add new unit tests, domain exceptions, documentation, and various build artifacts across multiple services.

2026-01-17 23:04:15 +07:00
parent 29a70f5b64
commit 19c0acfe0f
321 changed files with 18414 additions and 1479 deletions
--- a/services/fnb-engine-net/.env.example
+++ b/services/fnb-engine-net/.env.example
@@ -0,0 +1,40 @@
+# Environment / Môi Trường
+ASPNETCORE_ENVIRONMENT=Development
+
+# Database / Cơ Sở Dữ Liệu
+# PostgreSQL connection string (Neon or local)
+DATABASE_URL=Host=localhost;Port=5432;Database=myservice_db;Username=postgres;Password=postgres
+
+# Redis Cache
+REDIS_URL=localhost:6379
+REDIS_PASSWORD=
+
+# JWT Authentication / Xác Thực JWT
+JWT_SECRET=your-secret-key-min-32-characters-long-here
+JWT_ISSUER=goodgo-platform
+JWT_AUDIENCE=goodgo-services
+JWT_ACCESS_TOKEN_EXPIRY_MINUTES=15
+JWT_REFRESH_TOKEN_EXPIRY_DAYS=7
+
+# API Configuration / Cấu Hình API
+API_PORT=5000
+API_BASE_PATH=/api/v1/myservice
+
+# Observability / Quan Sát
+OTEL_EXPORTER_OTLP_ENDPOINT=http://localhost:4317
+OTEL_SERVICE_NAME=myservice
+
+# Logging
+LOG_LEVEL=Information
+SEQ_URL=http://localhost:5341
+
+# Feature Flags
+FEATURE_SWAGGER_ENABLED=true
+FEATURE_DETAILED_ERRORS=true
+
+# Rate Limiting
+RATE_LIMIT_PERMITS_PER_MINUTE=100
+RATE_LIMIT_QUEUE_LIMIT=10
+
+# Health Checks
+HEALTHCHECK_TIMEOUT_SECONDS=5
--- a/services/fnb-engine-net/.gitignore
+++ b/services/fnb-engine-net/.gitignore
@@ -0,0 +1,75 @@
+# Build results
+[Bb]in/
+[Oo]bj/
+[Ll]og/
+[Ll]ogs/
+
+# Visual Studio
+.vs/
+*.user
+*.userosscache
+*.suo
+*.userprefs
+*.sln.docstates
+
+# Rider
+.idea/
+*.sln.iml
+
+# Visual Studio Code
+.vscode/
+
+# NuGet
+*.nupkg
+*.snupkg
+.nuget/
+packages/
+project.lock.json
+project.fragment.lock.json
+
+# MSTest test Results
+[Tt]est[Rr]esult*/
+[Bb]uild[Ll]og.*
+
+# Coverage
+TestResults/
+*.coverage
+*.coveragexml
+coverage*.json
+coverage*.xml
+
+# Publish output
+publish/
+out/
+
+# Environment files
+.env
+.env.local
+.env.*.local
+*.env
+
+# Secrets
+appsettings.*.json
+!appsettings.json
+!appsettings.Development.json
+
+# macOS
+.DS_Store
+
+# Windows
+Thumbs.db
+ehthumbs.db
+
+# JetBrains
+*.resharper
+
+# dotnet tools
+.config/dotnet-tools.json
+
+# Migration scripts (only keep structure)
+Migrations/
+
+# Temp files
+*.tmp
+*.temp
+~$*
--- a/services/fnb-engine-net/Directory.Build.props
+++ b/services/fnb-engine-net/Directory.Build.props
@@ -0,0 +1,22 @@
+<Project>
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <LangVersion>14.0</LangVersion>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <TreatWarningsAsErrors>true</TreatWarningsAsErrors>
+    <GenerateDocumentationFile>true</GenerateDocumentationFile>
+    <NoWarn>$(NoWarn);1591;CA2017</NoWarn>
+  </PropertyGroup>
+
+  <PropertyGroup>
+    <Authors>GoodGo Team</Authors>
+    <Company>GoodGo</Company>
+    <Copyright>© 2026 GoodGo. All rights reserved.</Copyright>
+    <RepositoryType>git</RepositoryType>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.SourceLink.GitHub" Version="8.0.0" PrivateAssets="All" />
+  </ItemGroup>
+</Project>
--- a/services/fnb-engine-net/Dockerfile
+++ b/services/fnb-engine-net/Dockerfile
@@ -0,0 +1,66 @@
+# Build stage / Giai đoạn build
+FROM mcr.microsoft.com/dotnet/sdk:10.0 AS build
+WORKDIR /src
+
+# EN: Copy project files for layer caching
+# VI: Sao chép các file project để tận dụng layer caching
+COPY ["src/MyService.API/MyService.API.csproj", "src/MyService.API/"]
+COPY ["src/MyService.Domain/MyService.Domain.csproj", "src/MyService.Domain/"]
+COPY ["src/MyService.Infrastructure/MyService.Infrastructure.csproj", "src/MyService.Infrastructure/"]
+COPY ["Directory.Build.props", "./"]
+
+# EN: Restore dependencies
+# VI: Khôi phục dependencies
+RUN dotnet restore "src/MyService.API/MyService.API.csproj"
+
+# EN: Copy all source code
+# VI: Sao chép toàn bộ source code
+COPY src/ ./src/
+
+# EN: Build the application
+# VI: Build ứng dụng
+WORKDIR "/src/src/MyService.API"
+RUN dotnet build "MyService.API.csproj" -c Release -o /app/build --no-restore
+
+# Publish stage / Giai đoạn publish
+FROM build AS publish
+RUN dotnet publish "MyService.API.csproj" -c Release -o /app/publish /p:UseAppHost=false --no-restore
+
+# Runtime stage / Giai đoạn runtime
+FROM mcr.microsoft.com/dotnet/aspnet:10.0 AS final
+WORKDIR /app
+
+# EN: Create non-root user for security
+# VI: Tạo user non-root cho bảo mật
+RUN groupadd -g 1001 dotnetuser && \
+    useradd -u 1001 -g dotnetuser -s /bin/sh dotnetuser
+
+# EN: Copy published application
+# VI: Sao chép ứng dụng đã publish
+COPY --from=publish /app/publish .
+
+# EN: Change ownership to non-root user
+# VI: Thay đổi quyền sở hữu sang user non-root
+RUN chown -R dotnetuser:dotnetuser /app
+
+# EN: Switch to non-root user
+# VI: Chuyển sang user non-root
+USER dotnetuser
+
+# EN: Expose port
+# VI: Mở cổng
+EXPOSE 8080
+
+# EN: Set environment variables
+# VI: Thiết lập biến môi trường
+ENV ASPNETCORE_URLS=http://+:8080
+ENV ASPNETCORE_ENVIRONMENT=Production
+
+# EN: Health check
+# VI: Kiểm tra health
+HEALTHCHECK --interval=30s --timeout=3s --start-period=10s --retries=3 \
+    CMD curl -f http://localhost:8080/health/live || exit 1
+
+# EN: Start the application
+# VI: Khởi động ứng dụng
+ENTRYPOINT ["dotnet", "MyService.API.dll"]
--- a/services/fnb-engine-net/FnbEngine.slnx
+++ b/services/fnb-engine-net/FnbEngine.slnx
@@ -0,0 +1,11 @@
+<Solution>
+  <Folder Name="/src/">
+    <Project Path="src/FnbEngine.API/FnbEngine.API.csproj" />
+    <Project Path="src/FnbEngine.Domain/FnbEngine.Domain.csproj" />
+    <Project Path="src/FnbEngine.Infrastructure/FnbEngine.Infrastructure.csproj" />
+  </Folder>
+  <Folder Name="/tests/">
+    <Project Path="tests/FnbEngine.FunctionalTests/FnbEngine.FunctionalTests.csproj" />
+    <Project Path="tests/FnbEngine.UnitTests/FnbEngine.UnitTests.csproj" />
+  </Folder>
+</Solution>
--- a/services/fnb-engine-net/docker-compose.yml
+++ b/services/fnb-engine-net/docker-compose.yml
@@ -0,0 +1,72 @@
+version: '3.8'
+
+# EN: Docker Compose for local development
+# VI: Docker Compose cho phát triển local
+
+services:
+  myservice-api:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    container_name: myservice-api
+    ports:
+      - "5000:8080"
+    environment:
+      - ASPNETCORE_ENVIRONMENT=Development
+      - DATABASE_URL=Host=postgres;Port=5432;Database=myservice_db;Username=postgres;Password=postgres
+      - REDIS_URL=redis:6379
+    depends_on:
+      postgres:
+        condition: service_healthy
+      redis:
+        condition: service_healthy
+    networks:
+      - myservice-network
+    healthcheck:
+      test: ["CMD", "curl", "-f", "http://localhost:8080/health/live"]
+      interval: 30s
+      timeout: 10s
+      retries: 3
+      start_period: 10s
+
+  postgres:
+    image: postgres:16-alpine
+    container_name: myservice-postgres
+    environment:
+      POSTGRES_USER: postgres
+      POSTGRES_PASSWORD: postgres
+      POSTGRES_DB: myservice_db
+    ports:
+      - "5432:5432"
+    volumes:
+      - postgres_data:/var/lib/postgresql/data
+    networks:
+      - myservice-network
+    healthcheck:
+      test: ["CMD-SHELL", "pg_isready -U postgres"]
+      interval: 10s
+      timeout: 5s
+      retries: 5
+
+  redis:
+    image: redis:7-alpine
+    container_name: myservice-redis
+    ports:
+      - "6379:6379"
+    volumes:
+      - redis_data:/data
+    networks:
+      - myservice-network
+    healthcheck:
+      test: ["CMD", "redis-cli", "ping"]
+      interval: 10s
+      timeout: 5s
+      retries: 5
+
+volumes:
+  postgres_data:
+  redis_data:
+
+networks:
+  myservice-network:
+    driver: bridge
--- a/services/fnb-engine-net/docs/en/ARCHITECTURE.md
+++ b/services/fnb-engine-net/docs/en/ARCHITECTURE.md
@@ -0,0 +1,107 @@
+# F&B Engine Architecture
+
+> Architecture documentation for F&B Engine.
+
+## Architecture Overview
+
+```mermaid
+graph TB
+    subgraph "API Layer"
+        TC[TableController]
+        SC[SessionController]
+        KC[KitchenController]
+    end
+    
+    subgraph "Domain Layer"
+        T[Table]
+        S[Session]
+        KT[KitchenTicket]
+    end
+    
+    subgraph "Infrastructure"
+        DB[(PostgreSQL)]
+        EB[Event Bus]
+    end
+    
+    TC --> T
+    SC --> S
+    KC --> KT
+    S --> T
+    KT --> S
+    T --> DB
+    KT --> EB
+    
+    style T fill:#50c878,stroke:#2d8659,color:#fff
+    style S fill:#3498db,stroke:#2980b9,color:#fff
+```
+
+## Database Schema
+
+```mermaid
+erDiagram
+    tables {
+        uuid id PK
+        uuid shop_id FK
+        varchar table_number
+        int capacity
+        varchar zone
+        varchar status
+    }
+    
+    sessions {
+        uuid id PK
+        uuid table_id FK
+        timestamp started_at
+        timestamp closed_at
+        int guest_count
+        varchar status
+    }
+    
+    kitchen_tickets {
+        uuid id PK
+        uuid session_id FK
+        uuid order_item_id FK
+        varchar station
+        int priority
+        varchar status
+        timestamp created_at
+    }
+    
+    tables ||--o{ sessions : has
+    sessions ||--o{ kitchen_tickets : contains
+```
+
+## Kitchen Display Flow
+
+```mermaid
+sequenceDiagram
+    participant Order as Order Service
+    participant FnB as F&B Engine
+    participant KDS as Kitchen Display
+    
+    Order->>FnB: KitchenTicketCreated Event
+    FnB->>FnB: Save Ticket
+    KDS->>FnB: Poll Pending Tickets
+    FnB-->>KDS: Ticket List
+    
+    Note over KDS: Chef prepares order
+    
+    KDS->>FnB: Update Status (Done)
+    FnB->>Order: TicketCompleted Event
+```
+
+## Table State Machine
+
+```mermaid
+stateDiagram-v2
+    [*] --> Available
+    Available --> Occupied: Open Session
+    Occupied --> Available: Close Session
+    Available --> Reserved: Reserve
+    Reserved --> Occupied: Guest Arrived
+    Reserved --> Available: Cancel
+```
+
+## References
+
+- [Multi-vertical Architecture](../../../../docs/en/architecture/multi-vertical-architecture.md)
--- a/services/fnb-engine-net/docs/en/README.md
+++ b/services/fnb-engine-net/docs/en/README.md
@@ -0,0 +1,115 @@
+# F&B Engine
+
+> Table management, sessions, and kitchen display for Food & Beverage operations.
+
+## Overview
+
+F&B Engine handles the unique requirements of restaurants and cafes: table layouts, dining sessions, and kitchen display system (KDS) for order preparation.
+
+### Key Features
+
+- **Table Management** - Floor plan, table status, capacity
+- **Session Tracking** - Guest sessions per table
+- **Kitchen Display System** - Order tickets to kitchen stations
+- **Table Operations** - Merge, split, transfer tables
+
+## Architecture Context
+
+```mermaid
+graph LR
+    ORDER["📝 Order Service"] --> FNB["🍳 F&B Engine"]
+    FNB --> INVENTORY["🏭 Inventory Service"]
+    POS["POS"] --> FNB
+    KDS["Kitchen Display"] --> FNB
+    
+    style FNB fill:#f39c12,stroke:#d68910,color:#fff
+```
+
+## Quick Start
+
+```bash
+cd services/fnb-engine-net
+cp .env.example .env
+dotnet run --project src/FnbEngine.API
+```
+
+## API Endpoints
+
+### Table Management
+
+| Method | Endpoint | Description |
+|--------|----------|-------------|
+| `GET` | `/api/v1/tables` | List tables by shop |
+| `POST` | `/api/v1/tables` | Create table |
+| `PUT` | `/api/v1/tables/{id}` | Update table |
+| `PATCH` | `/api/v1/tables/{id}/status` | Change status |
+| `POST` | `/api/v1/tables/merge` | Merge tables |
+| `POST` | `/api/v1/tables/split` | Split merged tables |
+
+### Sessions
+
+| Method | Endpoint | Description |
+|--------|----------|-------------|
+| `POST` | `/api/v1/sessions` | Open session |
+| `GET` | `/api/v1/sessions/{id}` | Get session details |
+| `POST` | `/api/v1/sessions/{id}/close` | Close session |
+| `POST` | `/api/v1/sessions/{id}/transfer` | Transfer to another table |
+
+### Kitchen Display
+
+| Method | Endpoint | Description |
+|--------|----------|-------------|
+| `GET` | `/api/v1/kitchen/tickets` | List pending tickets |
+| `PATCH` | `/api/v1/kitchen/tickets/{id}/status` | Update ticket status |
+| `GET` | `/api/v1/kitchen/stations` | List kitchen stations |
+
+## Domain Model
+
+### Table
+
+```csharp
+public class Table : Entity, IAggregateRoot
+{
+    public Guid ShopId { get; private set; }
+    public string TableNumber { get; private set; }
+    public int Capacity { get; private set; }
+    public string Zone { get; private set; }
+    public TableStatus Status { get; private set; } // Available, Occupied, Reserved
+}
+```
+
+### Session
+
+```csharp
+public class Session : Entity, IAggregateRoot
+{
+    public Guid TableId { get; private set; }
+    public DateTime StartedAt { get; private set; }
+    public DateTime? ClosedAt { get; private set; }
+    public int GuestCount { get; private set; }
+    public SessionStatus Status { get; private set; }
+}
+```
+
+### KitchenTicket
+
+```csharp
+public class KitchenTicket : Entity
+{
+    public Guid SessionId { get; private set; }
+    public Guid OrderItemId { get; private set; }
+    public string Station { get; private set; } // Bar, Kitchen, Grill
+    public int Priority { get; private set; }
+    public TicketStatus Status { get; private set; } // Pending, InProgress, Done
+}
+```
+
+## Related Services
+
+- [Order Service](../../order-service-net/docs/en/README.md) - Uses FnbStrategy
+- [Inventory Service](../../inventory-service-net/docs/en/README.md) - Ingredient deduction
+- [Catalog Service](../../catalog-service-net/docs/en/README.md) - Menu items
+
+## License
+
+Proprietary - GoodGo Platform
--- a/services/fnb-engine-net/docs/vi/ARCHITECTURE.md
+++ b/services/fnb-engine-net/docs/vi/ARCHITECTURE.md
@@ -0,0 +1,107 @@
+# Kiến Trúc F&B Engine
+
+> Tài liệu kiến trúc cho F&B Engine.
+
+## Tổng Quan Kiến Trúc
+
+```mermaid
+graph TB
+    subgraph "Tầng API"
+        TC[TableController]
+        SC[SessionController]
+        KC[KitchenController]
+    end
+    
+    subgraph "Tầng Domain"
+        T[Table]
+        S[Session]
+        KT[KitchenTicket]
+    end
+    
+    subgraph "Infrastructure"
+        DB[(PostgreSQL)]
+        EB[Event Bus]
+    end
+    
+    TC --> T
+    SC --> S
+    KC --> KT
+    S --> T
+    KT --> S
+    T --> DB
+    KT --> EB
+    
+    style T fill:#50c878,stroke:#2d8659,color:#fff
+    style S fill:#3498db,stroke:#2980b9,color:#fff
+```
+
+## Database Schema
+
+```mermaid
+erDiagram
+    tables {
+        uuid id PK
+        uuid shop_id FK
+        varchar table_number
+        int capacity
+        varchar zone
+        varchar status
+    }
+    
+    sessions {
+        uuid id PK
+        uuid table_id FK
+        timestamp started_at
+        timestamp closed_at
+        int guest_count
+        varchar status
+    }
+    
+    kitchen_tickets {
+        uuid id PK
+        uuid session_id FK
+        uuid order_item_id FK
+        varchar station
+        int priority
+        varchar status
+        timestamp created_at
+    }
+    
+    tables ||--o{ sessions : has
+    sessions ||--o{ kitchen_tickets : contains
+```
+
+## Luồng Hiển Thị Bếp
+
+```mermaid
+sequenceDiagram
+    participant Order as Order Service
+    participant FnB as F&B Engine
+    participant KDS as Màn Hình Bếp
+    
+    Order->>FnB: KitchenTicketCreated Event
+    FnB->>FnB: Lưu Phiếu
+    KDS->>FnB: Lấy Phiếu Chờ
+    FnB-->>KDS: Danh Sách Phiếu
+    
+    Note over KDS: Đầu bếp chuẩn bị đơn
+    
+    KDS->>FnB: Cập Nhật Trạng Thái (Xong)
+    FnB->>Order: TicketCompleted Event
+```
+
+## Table State Machine
+
+```mermaid
+stateDiagram-v2
+    [*] --> Available
+    Available --> Occupied: Mở Phiên
+    Occupied --> Available: Đóng Phiên
+    Available --> Reserved: Đặt Trước
+    Reserved --> Occupied: Khách Đến
+    Reserved --> Available: Hủy
+```
+
+## Tài Nguyên
+
+- [Kiến Trúc Đa Ngành Hàng](../../../../docs/vi/architecture/multi-vertical-architecture.md)
--- a/services/fnb-engine-net/docs/vi/README.md
+++ b/services/fnb-engine-net/docs/vi/README.md
@@ -0,0 +1,115 @@
+# F&B Engine
+
+> Quản lý bàn, phiên ăn uống và hiển thị bếp cho ngành thực phẩm và đồ uống.
+
+## Tổng Quan
+
+F&B Engine xử lý các yêu cầu đặc thù của nhà hàng và quán cafe: bố trí bàn, phiên khách hàng, và hệ thống hiển thị bếp (KDS) để chuẩn bị đơn hàng.
+
+### Tính Năng Chính
+
+- **Quản lý Bàn** - Sơ đồ, trạng thái bàn, sức chứa
+- **Theo dõi Phiên** - Phiên khách hàng theo bàn
+- **Hệ thống Hiển thị Bếp** - Phiếu đơn hàng tới các trạm bếp
+- **Thao tác Bàn** - Gộp, tách, chuyển bàn
+
+## Bối Cảnh Kiến Trúc
+
+```mermaid
+graph LR
+    ORDER["📝 Order Service"] --> FNB["🍳 F&B Engine"]
+    FNB --> INVENTORY["🏭 Inventory Service"]
+    POS["POS"] --> FNB
+    KDS["Màn Hình Bếp"] --> FNB
+    
+    style FNB fill:#f39c12,stroke:#d68910,color:#fff
+```
+
+## Bắt Đầu Nhanh
+
+```bash
+cd services/fnb-engine-net
+cp .env.example .env
+dotnet run --project src/FnbEngine.API
+```
+
+## API Endpoints
+
+### Quản Lý Bàn
+
+| Method | Endpoint | Mô tả |
+|--------|----------|-------|
+| `GET` | `/api/v1/tables` | Danh sách bàn theo shop |
+| `POST` | `/api/v1/tables` | Tạo bàn |
+| `PUT` | `/api/v1/tables/{id}` | Cập nhật bàn |
+| `PATCH` | `/api/v1/tables/{id}/status` | Đổi trạng thái |
+| `POST` | `/api/v1/tables/merge` | Gộp bàn |
+| `POST` | `/api/v1/tables/split` | Tách bàn |
+
+### Phiên
+
+| Method | Endpoint | Mô tả |
+|--------|----------|-------|
+| `POST` | `/api/v1/sessions` | Mở phiên |
+| `GET` | `/api/v1/sessions/{id}` | Chi tiết phiên |
+| `POST` | `/api/v1/sessions/{id}/close` | Đóng phiên |
+| `POST` | `/api/v1/sessions/{id}/transfer` | Chuyển bàn |
+
+### Hiển Thị Bếp
+
+| Method | Endpoint | Mô tả |
+|--------|----------|-------|
+| `GET` | `/api/v1/kitchen/tickets` | Danh sách phiếu chờ |
+| `PATCH` | `/api/v1/kitchen/tickets/{id}/status` | Cập nhật trạng thái phiếu |
+| `GET` | `/api/v1/kitchen/stations` | Danh sách trạm bếp |
+
+## Domain Model
+
+### Table
+
+```csharp
+public class Table : Entity, IAggregateRoot
+{
+    public Guid ShopId { get; private set; }
+    public string TableNumber { get; private set; }
+    public int Capacity { get; private set; }
+    public string Zone { get; private set; }
+    public TableStatus Status { get; private set; } // Available, Occupied, Reserved
+}
+```
+
+### Session
+
+```csharp
+public class Session : Entity, IAggregateRoot
+{
+    public Guid TableId { get; private set; }
+    public DateTime StartedAt { get; private set; }
+    public DateTime? ClosedAt { get; private set; }
+    public int GuestCount { get; private set; }
+    public SessionStatus Status { get; private set; }
+}
+```
+
+### KitchenTicket
+
+```csharp
+public class KitchenTicket : Entity
+{
+    public Guid SessionId { get; private set; }
+    public Guid OrderItemId { get; private set; }
+    public string Station { get; private set; } // Bar, Kitchen, Grill
+    public int Priority { get; private set; }
+    public TicketStatus Status { get; private set; } // Pending, InProgress, Done
+}
+```
+
+## Services Liên Quan
+
+- [Order Service](../../order-service-net/docs/vi/README.md) - Sử dụng FnbStrategy
+- [Inventory Service](../../inventory-service-net/docs/vi/README.md) - Trừ nguyên liệu
+- [Catalog Service](../../catalog-service-net/docs/vi/README.md) - Mặt hàng menu
+
+## License
+
+Proprietary - GoodGo Platform
--- a/services/fnb-engine-net/global.json
+++ b/services/fnb-engine-net/global.json
@@ -0,0 +1,7 @@
+{
+    "sdk": {
+        "version": "10.0.101",
+        "rollForward": "latestMinor",
+        "allowPrerelease": false
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Behaviors/LoggingBehavior.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Behaviors/LoggingBehavior.cs
@@ -0,0 +1,58 @@
+using System.Diagnostics;
+using MediatR;
+
+namespace MyService.API.Application.Behaviors;
+
+/// <summary>
+/// EN: MediatR behavior for logging request handling.
+/// VI: MediatR behavior để logging việc xử lý request.
+/// </summary>
+/// <typeparam name="TRequest">EN: Request type / VI: Loại request</typeparam>
+/// <typeparam name="TResponse">EN: Response type / VI: Loại response</typeparam>
+public class LoggingBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
+    where TRequest : IRequest<TResponse>
+{
+    private readonly ILogger<LoggingBehavior<TRequest, TResponse>> _logger;
+
+    public LoggingBehavior(ILogger<LoggingBehavior<TRequest, TResponse>> logger)
+    {
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+    }
+
+    public async Task<TResponse> Handle(
+        TRequest request,
+        RequestHandlerDelegate<TResponse> next,
+        CancellationToken cancellationToken)
+    {
+        var requestName = typeof(TRequest).Name;
+
+        _logger.LogInformation(
+            "Handling {RequestName} / Đang xử lý {RequestName}",
+            requestName);
+
+        var stopwatch = Stopwatch.StartNew();
+
+        try
+        {
+            var response = await next();
+
+            stopwatch.Stop();
+
+            _logger.LogInformation(
+                "Handled {RequestName} in {ElapsedMs}ms / Đã xử lý {RequestName} trong {ElapsedMs}ms",
+                requestName, stopwatch.ElapsedMilliseconds);
+
+            return response;
+        }
+        catch (Exception ex)
+        {
+            stopwatch.Stop();
+
+            _logger.LogError(ex,
+                "Error handling {RequestName} after {ElapsedMs}ms / Lỗi xử lý {RequestName} sau {ElapsedMs}ms",
+                requestName, stopwatch.ElapsedMilliseconds);
+
+            throw;
+        }
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Behaviors/TransactionBehavior.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Behaviors/TransactionBehavior.cs
@@ -0,0 +1,84 @@
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using MyService.Infrastructure;
+
+namespace MyService.API.Application.Behaviors;
+
+/// <summary>
+/// EN: MediatR behavior for handling database transactions.
+/// VI: MediatR behavior để xử lý database transactions.
+/// </summary>
+/// <typeparam name="TRequest">EN: Request type / VI: Loại request</typeparam>
+/// <typeparam name="TResponse">EN: Response type / VI: Loại response</typeparam>
+public class TransactionBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
+    where TRequest : IRequest<TResponse>
+{
+    private readonly MyServiceContext _dbContext;
+    private readonly ILogger<TransactionBehavior<TRequest, TResponse>> _logger;
+
+    public TransactionBehavior(
+        MyServiceContext dbContext,
+        ILogger<TransactionBehavior<TRequest, TResponse>> logger)
+    {
+        _dbContext = dbContext ?? throw new ArgumentNullException(nameof(dbContext));
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+    }
+
+    public async Task<TResponse> Handle(
+        TRequest request,
+        RequestHandlerDelegate<TResponse> next,
+        CancellationToken cancellationToken)
+    {
+        var requestName = typeof(TRequest).Name;
+
+        // EN: Skip transaction for queries (read operations)
+        // VI: Bỏ qua transaction cho queries (các thao tác đọc)
+        if (requestName.EndsWith("Query"))
+        {
+            return await next();
+        }
+
+        // EN: Skip if already in a transaction
+        // VI: Bỏ qua nếu đã trong transaction
+        if (_dbContext.HasActiveTransaction)
+        {
+            return await next();
+        }
+
+        var strategy = _dbContext.Database.CreateExecutionStrategy();
+
+        return await strategy.ExecuteAsync(async () =>
+        {
+            await using var transaction = await _dbContext.BeginTransactionAsync();
+
+            _logger.LogInformation(
+                "Begin transaction {TransactionId} for {RequestName} / Bắt đầu transaction {TransactionId} cho {RequestName}",
+                transaction?.TransactionId, requestName);
+
+            try
+            {
+                var response = await next();
+
+                if (transaction != null)
+                {
+                    await _dbContext.CommitTransactionAsync(transaction);
+
+                    _logger.LogInformation(
+                        "Committed transaction {TransactionId} for {RequestName} / Đã commit transaction {TransactionId} cho {RequestName}",
+                        transaction.TransactionId, requestName);
+                }
+
+                return response;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex,
+                    "Error during transaction {TransactionId} for {RequestName} / Lỗi trong transaction {TransactionId} cho {RequestName}",
+                    transaction?.TransactionId, requestName);
+
+                _dbContext.RollbackTransaction();
+                throw;
+            }
+        });
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Behaviors/ValidatorBehavior.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Behaviors/ValidatorBehavior.cs
@@ -0,0 +1,63 @@
+using FluentValidation;
+using MediatR;
+
+namespace MyService.API.Application.Behaviors;
+
+/// <summary>
+/// EN: MediatR behavior for FluentValidation integration.
+/// VI: MediatR behavior để tích hợp FluentValidation.
+/// </summary>
+/// <typeparam name="TRequest">EN: Request type / VI: Loại request</typeparam>
+/// <typeparam name="TResponse">EN: Response type / VI: Loại response</typeparam>
+public class ValidatorBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
+    where TRequest : IRequest<TResponse>
+{
+    private readonly IEnumerable<IValidator<TRequest>> _validators;
+    private readonly ILogger<ValidatorBehavior<TRequest, TResponse>> _logger;
+
+    public ValidatorBehavior(
+        IEnumerable<IValidator<TRequest>> validators,
+        ILogger<ValidatorBehavior<TRequest, TResponse>> logger)
+    {
+        _validators = validators ?? throw new ArgumentNullException(nameof(validators));
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+    }
+
+    public async Task<TResponse> Handle(
+        TRequest request,
+        RequestHandlerDelegate<TResponse> next,
+        CancellationToken cancellationToken)
+    {
+        var requestName = typeof(TRequest).Name;
+
+        if (!_validators.Any())
+        {
+            return await next();
+        }
+
+        _logger.LogDebug(
+            "Validating {RequestName} / Đang validate {RequestName}",
+            requestName);
+
+        var context = new ValidationContext<TRequest>(request);
+
+        var validationResults = await Task.WhenAll(
+            _validators.Select(v => v.ValidateAsync(context, cancellationToken)));
+
+        var failures = validationResults
+            .SelectMany(r => r.Errors)
+            .Where(f => f != null)
+            .ToList();
+
+        if (failures.Count != 0)
+        {
+            _logger.LogWarning(
+                "Validation failed for {RequestName} with {ErrorCount} errors / Validation thất bại cho {RequestName} với {ErrorCount} lỗi",
+                requestName, failures.Count);
+
+            throw new ValidationException(failures);
+        }
+
+        return await next();
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/ChangeSampleStatusCommand.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/ChangeSampleStatusCommand.cs
@@ -0,0 +1,14 @@
+using MediatR;
+
+namespace MyService.API.Application.Commands;
+
+/// <summary>
+/// EN: Command to change status of a Sample.
+/// VI: Command để thay đổi trạng thái của Sample.
+/// </summary>
+/// <param name="SampleId">EN: Sample ID / VI: ID sample</param>
+/// <param name="NewStatus">EN: New status (activate, complete, cancel) / VI: Trạng thái mới (activate, complete, cancel)</param>
+public record ChangeSampleStatusCommand(
+    Guid SampleId,
+    string NewStatus
+) : IRequest<bool>;
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/ChangeSampleStatusCommandHandler.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/ChangeSampleStatusCommandHandler.cs
@@ -0,0 +1,70 @@
+using MediatR;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.API.Application.Commands;
+
+/// <summary>
+/// EN: Handler for ChangeSampleStatusCommand.
+/// VI: Handler cho ChangeSampleStatusCommand.
+/// </summary>
+public class ChangeSampleStatusCommandHandler : IRequestHandler<ChangeSampleStatusCommand, bool>
+{
+    private readonly ISampleRepository _sampleRepository;
+    private readonly ILogger<ChangeSampleStatusCommandHandler> _logger;
+
+    public ChangeSampleStatusCommandHandler(
+        ISampleRepository sampleRepository,
+        ILogger<ChangeSampleStatusCommandHandler> logger)
+    {
+        _sampleRepository = sampleRepository ?? throw new ArgumentNullException(nameof(sampleRepository));
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+    }
+
+    public async Task<bool> Handle(
+        ChangeSampleStatusCommand request,
+        CancellationToken cancellationToken)
+    {
+        _logger.LogInformation(
+            "Changing status of sample {SampleId} to {NewStatus} / Thay đổi trạng thái sample {SampleId} thành {NewStatus}",
+            request.SampleId, request.NewStatus);
+
+        // EN: Get existing sample / VI: Lấy sample đã tồn tại
+        var sample = await _sampleRepository.GetAsync(request.SampleId);
+
+        if (sample is null)
+        {
+            _logger.LogWarning(
+                "Sample {SampleId} not found / Sample {SampleId} không tìm thấy",
+                request.SampleId);
+            return false;
+        }
+
+        // EN: Change status based on action / VI: Thay đổi trạng thái dựa trên action
+        switch (request.NewStatus.ToLowerInvariant())
+        {
+            case "activate":
+                sample.Activate();
+                break;
+            case "complete":
+                sample.Complete();
+                break;
+            case "cancel":
+                sample.Cancel();
+                break;
+            default:
+                _logger.LogWarning(
+                    "Invalid status action: {NewStatus} / Action trạng thái không hợp lệ: {NewStatus}",
+                    request.NewStatus);
+                return false;
+        }
+
+        // EN: Save changes / VI: Lưu thay đổi
+        await _sampleRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken);
+
+        _logger.LogInformation(
+            "Sample {SampleId} status changed to {NewStatus} / Trạng thái sample {SampleId} đã đổi thành {NewStatus}",
+            request.SampleId, request.NewStatus);
+
+        return true;
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/CreateSampleCommand.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/CreateSampleCommand.cs
@@ -0,0 +1,21 @@
+using MediatR;
+
+namespace MyService.API.Application.Commands;
+
+/// <summary>
+/// EN: Command to create a new Sample.
+/// VI: Command để tạo một Sample mới.
+/// </summary>
+/// <param name="Name">EN: Sample name / VI: Tên sample</param>
+/// <param name="Description">EN: Optional description / VI: Mô tả tùy chọn</param>
+public record CreateSampleCommand(
+    string Name,
+    string? Description
+) : IRequest<CreateSampleCommandResult>;
+
+/// <summary>
+/// EN: Result of CreateSampleCommand.
+/// VI: Kết quả của CreateSampleCommand.
+/// </summary>
+/// <param name="Id">EN: Created sample ID / VI: ID sample đã tạo</param>
+public record CreateSampleCommandResult(Guid Id);
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/CreateSampleCommandHandler.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/CreateSampleCommandHandler.cs
@@ -0,0 +1,46 @@
+using MediatR;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.API.Application.Commands;
+
+/// <summary>
+/// EN: Handler for CreateSampleCommand.
+/// VI: Handler cho CreateSampleCommand.
+/// </summary>
+public class CreateSampleCommandHandler : IRequestHandler<CreateSampleCommand, CreateSampleCommandResult>
+{
+    private readonly ISampleRepository _sampleRepository;
+    private readonly ILogger<CreateSampleCommandHandler> _logger;
+
+    public CreateSampleCommandHandler(
+        ISampleRepository sampleRepository,
+        ILogger<CreateSampleCommandHandler> logger)
+    {
+        _sampleRepository = sampleRepository ?? throw new ArgumentNullException(nameof(sampleRepository));
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+    }
+
+    public async Task<CreateSampleCommandResult> Handle(
+        CreateSampleCommand request,
+        CancellationToken cancellationToken)
+    {
+        _logger.LogInformation(
+            "Creating new sample with name: {Name} / Tạo sample mới với tên: {Name}",
+            request.Name);
+
+        // EN: Create domain entity / VI: Tạo domain entity
+        var sample = new Sample(request.Name, request.Description);
+
+        // EN: Add to repository / VI: Thêm vào repository
+        _sampleRepository.Add(sample);
+
+        // EN: Save changes (dispatches domain events) / VI: Lưu thay đổi (dispatch domain events)
+        await _sampleRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken);
+
+        _logger.LogInformation(
+            "Sample created successfully with ID: {SampleId} / Sample đã tạo thành công với ID: {SampleId}",
+            sample.Id);
+
+        return new CreateSampleCommandResult(sample.Id);
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/DeleteSampleCommand.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/DeleteSampleCommand.cs
@@ -0,0 +1,10 @@
+using MediatR;
+
+namespace MyService.API.Application.Commands;
+
+/// <summary>
+/// EN: Command to delete a Sample.
+/// VI: Command để xóa một Sample.
+/// </summary>
+/// <param name="SampleId">EN: Sample ID to delete / VI: ID sample cần xóa</param>
+public record DeleteSampleCommand(Guid SampleId) : IRequest<bool>;
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/DeleteSampleCommandHandler.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/DeleteSampleCommandHandler.cs
@@ -0,0 +1,54 @@
+using MediatR;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.API.Application.Commands;
+
+/// <summary>
+/// EN: Handler for DeleteSampleCommand.
+/// VI: Handler cho DeleteSampleCommand.
+/// </summary>
+public class DeleteSampleCommandHandler : IRequestHandler<DeleteSampleCommand, bool>
+{
+    private readonly ISampleRepository _sampleRepository;
+    private readonly ILogger<DeleteSampleCommandHandler> _logger;
+
+    public DeleteSampleCommandHandler(
+        ISampleRepository sampleRepository,
+        ILogger<DeleteSampleCommandHandler> logger)
+    {
+        _sampleRepository = sampleRepository ?? throw new ArgumentNullException(nameof(sampleRepository));
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+    }
+
+    public async Task<bool> Handle(
+        DeleteSampleCommand request,
+        CancellationToken cancellationToken)
+    {
+        _logger.LogInformation(
+            "Deleting sample {SampleId} / Xóa sample {SampleId}",
+            request.SampleId);
+
+        // EN: Get existing sample / VI: Lấy sample đã tồn tại
+        var sample = await _sampleRepository.GetAsync(request.SampleId);
+
+        if (sample is null)
+        {
+            _logger.LogWarning(
+                "Sample {SampleId} not found / Sample {SampleId} không tìm thấy",
+                request.SampleId);
+            return false;
+        }
+
+        // EN: Delete sample / VI: Xóa sample
+        _sampleRepository.Delete(sample);
+
+        // EN: Save changes / VI: Lưu thay đổi
+        await _sampleRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken);
+
+        _logger.LogInformation(
+            "Sample {SampleId} deleted successfully / Sample {SampleId} đã xóa thành công",
+            request.SampleId);
+
+        return true;
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/UpdateSampleCommand.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/UpdateSampleCommand.cs
@@ -0,0 +1,16 @@
+using MediatR;
+
+namespace MyService.API.Application.Commands;
+
+/// <summary>
+/// EN: Command to update an existing Sample.
+/// VI: Command để cập nhật một Sample đã tồn tại.
+/// </summary>
+/// <param name="SampleId">EN: Sample ID to update / VI: ID sample cần cập nhật</param>
+/// <param name="Name">EN: New name / VI: Tên mới</param>
+/// <param name="Description">EN: New description / VI: Mô tả mới</param>
+public record UpdateSampleCommand(
+    Guid SampleId,
+    string Name,
+    string? Description
+) : IRequest<bool>;
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/UpdateSampleCommandHandler.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Commands/UpdateSampleCommandHandler.cs
@@ -0,0 +1,54 @@
+using MediatR;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.API.Application.Commands;
+
+/// <summary>
+/// EN: Handler for UpdateSampleCommand.
+/// VI: Handler cho UpdateSampleCommand.
+/// </summary>
+public class UpdateSampleCommandHandler : IRequestHandler<UpdateSampleCommand, bool>
+{
+    private readonly ISampleRepository _sampleRepository;
+    private readonly ILogger<UpdateSampleCommandHandler> _logger;
+
+    public UpdateSampleCommandHandler(
+        ISampleRepository sampleRepository,
+        ILogger<UpdateSampleCommandHandler> logger)
+    {
+        _sampleRepository = sampleRepository ?? throw new ArgumentNullException(nameof(sampleRepository));
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+    }
+
+    public async Task<bool> Handle(
+        UpdateSampleCommand request,
+        CancellationToken cancellationToken)
+    {
+        _logger.LogInformation(
+            "Updating sample {SampleId} / Cập nhật sample {SampleId}",
+            request.SampleId);
+
+        // EN: Get existing sample / VI: Lấy sample đã tồn tại
+        var sample = await _sampleRepository.GetAsync(request.SampleId);
+
+        if (sample is null)
+        {
+            _logger.LogWarning(
+                "Sample {SampleId} not found / Sample {SampleId} không tìm thấy",
+                request.SampleId);
+            return false;
+        }
+
+        // EN: Update sample using domain method / VI: Cập nhật sample sử dụng domain method
+        sample.Update(request.Name, request.Description);
+
+        // EN: Save changes / VI: Lưu thay đổi
+        await _sampleRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken);
+
+        _logger.LogInformation(
+            "Sample {SampleId} updated successfully / Sample {SampleId} đã cập nhật thành công",
+            request.SampleId);
+
+        return true;
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Queries/GetSampleQuery.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Queries/GetSampleQuery.cs
@@ -0,0 +1,23 @@
+using MediatR;
+
+namespace MyService.API.Application.Queries;
+
+/// <summary>
+/// EN: Query to get a Sample by ID.
+/// VI: Query để lấy một Sample theo ID.
+/// </summary>
+/// <param name="SampleId">EN: Sample ID / VI: ID sample</param>
+public record GetSampleQuery(Guid SampleId) : IRequest<SampleViewModel?>;
+
+/// <summary>
+/// EN: Sample view model for API responses.
+/// VI: Sample view model cho API responses.
+/// </summary>
+public record SampleViewModel(
+    Guid Id,
+    string Name,
+    string? Description,
+    string Status,
+    DateTime CreatedAt,
+    DateTime? UpdatedAt
+);
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Queries/GetSampleQueryHandler.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Queries/GetSampleQueryHandler.cs
@@ -0,0 +1,39 @@
+using MediatR;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.API.Application.Queries;
+
+/// <summary>
+/// EN: Handler for GetSampleQuery.
+/// VI: Handler cho GetSampleQuery.
+/// </summary>
+public class GetSampleQueryHandler : IRequestHandler<GetSampleQuery, SampleViewModel?>
+{
+    private readonly ISampleRepository _sampleRepository;
+
+    public GetSampleQueryHandler(ISampleRepository sampleRepository)
+    {
+        _sampleRepository = sampleRepository ?? throw new ArgumentNullException(nameof(sampleRepository));
+    }
+
+    public async Task<SampleViewModel?> Handle(
+        GetSampleQuery request,
+        CancellationToken cancellationToken)
+    {
+        var sample = await _sampleRepository.GetAsync(request.SampleId);
+
+        if (sample is null)
+        {
+            return null;
+        }
+
+        return new SampleViewModel(
+            sample.Id,
+            sample.Name,
+            sample.Description,
+            sample.Status.Name,
+            sample.CreatedAt,
+            sample.UpdatedAt
+        );
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Queries/GetSamplesQuery.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Queries/GetSamplesQuery.cs
@@ -0,0 +1,9 @@
+using MediatR;
+
+namespace MyService.API.Application.Queries;
+
+/// <summary>
+/// EN: Query to get all Samples.
+/// VI: Query để lấy tất cả Samples.
+/// </summary>
+public record GetSamplesQuery : IRequest<IEnumerable<SampleViewModel>>;
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Queries/GetSamplesQueryHandler.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Queries/GetSamplesQueryHandler.cs
@@ -0,0 +1,34 @@
+using MediatR;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.API.Application.Queries;
+
+/// <summary>
+/// EN: Handler for GetSamplesQuery.
+/// VI: Handler cho GetSamplesQuery.
+/// </summary>
+public class GetSamplesQueryHandler : IRequestHandler<GetSamplesQuery, IEnumerable<SampleViewModel>>
+{
+    private readonly ISampleRepository _sampleRepository;
+
+    public GetSamplesQueryHandler(ISampleRepository sampleRepository)
+    {
+        _sampleRepository = sampleRepository ?? throw new ArgumentNullException(nameof(sampleRepository));
+    }
+
+    public async Task<IEnumerable<SampleViewModel>> Handle(
+        GetSamplesQuery request,
+        CancellationToken cancellationToken)
+    {
+        var samples = await _sampleRepository.GetAllAsync();
+
+        return samples.Select(sample => new SampleViewModel(
+            sample.Id,
+            sample.Name,
+            sample.Description,
+            sample.Status.Name,
+            sample.CreatedAt,
+            sample.UpdatedAt
+        ));
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Validations/CreateSampleCommandValidator.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Validations/CreateSampleCommandValidator.cs
@@ -0,0 +1,25 @@
+using FluentValidation;
+using MyService.API.Application.Commands;
+
+namespace MyService.API.Application.Validations;
+
+/// <summary>
+/// EN: Validator for CreateSampleCommand.
+/// VI: Validator cho CreateSampleCommand.
+/// </summary>
+public class CreateSampleCommandValidator : AbstractValidator<CreateSampleCommand>
+{
+    public CreateSampleCommandValidator()
+    {
+        RuleFor(x => x.Name)
+            .NotEmpty()
+            .WithMessage("Name is required / Tên là bắt buộc")
+            .MaximumLength(200)
+            .WithMessage("Name must be less than 200 characters / Tên phải ít hơn 200 ký tự");
+
+        RuleFor(x => x.Description)
+            .MaximumLength(1000)
+            .WithMessage("Description must be less than 1000 characters / Mô tả phải ít hơn 1000 ký tự")
+            .When(x => x.Description != null);
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Application/Validations/UpdateSampleCommandValidator.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Application/Validations/UpdateSampleCommandValidator.cs
@@ -0,0 +1,29 @@
+using FluentValidation;
+using MyService.API.Application.Commands;
+
+namespace MyService.API.Application.Validations;
+
+/// <summary>
+/// EN: Validator for UpdateSampleCommand.
+/// VI: Validator cho UpdateSampleCommand.
+/// </summary>
+public class UpdateSampleCommandValidator : AbstractValidator<UpdateSampleCommand>
+{
+    public UpdateSampleCommandValidator()
+    {
+        RuleFor(x => x.SampleId)
+            .NotEmpty()
+            .WithMessage("Sample ID is required / ID sample là bắt buộc");
+
+        RuleFor(x => x.Name)
+            .NotEmpty()
+            .WithMessage("Name is required / Tên là bắt buộc")
+            .MaximumLength(200)
+            .WithMessage("Name must be less than 200 characters / Tên phải ít hơn 200 ký tự");
+
+        RuleFor(x => x.Description)
+            .MaximumLength(1000)
+            .WithMessage("Description must be less than 1000 characters / Mô tả phải ít hơn 1000 ký tự")
+            .When(x => x.Description != null);
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/Controllers/SamplesController.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Controllers/SamplesController.cs
@@ -0,0 +1,200 @@
+using Asp.Versioning;
+using MediatR;
+using Microsoft.AspNetCore.Mvc;
+using MyService.API.Application.Commands;
+using MyService.API.Application.Queries;
+
+namespace MyService.API.Controllers;
+
+/// <summary>
+/// EN: Controller for Sample CRUD operations using CQRS pattern.
+/// VI: Controller cho các thao tác CRUD Sample sử dụng pattern CQRS.
+/// </summary>
+[ApiController]
+[ApiVersion("1.0")]
+[Route("api/v{version:apiVersion}/[controller]")]
+[Produces("application/json")]
+public class SamplesController : ControllerBase
+{
+    private readonly IMediator _mediator;
+    private readonly ILogger<SamplesController> _logger;
+
+    public SamplesController(IMediator mediator, ILogger<SamplesController> logger)
+    {
+        _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));
+        _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+    }
+
+    /// <summary>
+    /// EN: Get all samples.
+    /// VI: Lấy tất cả samples.
+    /// </summary>
+    /// <returns>EN: List of samples / VI: Danh sách samples</returns>
+    [HttpGet]
+    [ProducesResponseType(typeof(IEnumerable<SampleViewModel>), StatusCodes.Status200OK)]
+    public async Task<IActionResult> GetSamples()
+    {
+        var samples = await _mediator.Send(new GetSamplesQuery());
+        return Ok(new { success = true, data = samples });
+    }
+
+    /// <summary>
+    /// EN: Get a sample by ID.
+    /// VI: Lấy một sample theo ID.
+    /// </summary>
+    /// <param name="id">EN: Sample ID / VI: ID sample</param>
+    /// <returns>EN: Sample details / VI: Chi tiết sample</returns>
+    [HttpGet("{id:guid}")]
+    [ProducesResponseType(typeof(SampleViewModel), StatusCodes.Status200OK)]
+    [ProducesResponseType(StatusCodes.Status404NotFound)]
+    public async Task<IActionResult> GetSample(Guid id)
+    {
+        var sample = await _mediator.Send(new GetSampleQuery(id));
+
+        if (sample is null)
+        {
+            return NotFound(new
+            {
+                success = false,
+                error = new
+                {
+                    code = "SAMPLE_NOT_FOUND",
+                    message = $"Sample with ID {id} not found / Sample với ID {id} không tìm thấy"
+                }
+            });
+        }
+
+        return Ok(new { success = true, data = sample });
+    }
+
+    /// <summary>
+    /// EN: Create a new sample.
+    /// VI: Tạo một sample mới.
+    /// </summary>
+    /// <param name="request">EN: Create request / VI: Request tạo</param>
+    /// <returns>EN: Created sample ID / VI: ID sample đã tạo</returns>
+    [HttpPost]
+    [ProducesResponseType(typeof(CreateSampleCommandResult), StatusCodes.Status201Created)]
+    [ProducesResponseType(StatusCodes.Status400BadRequest)]
+    public async Task<IActionResult> CreateSample([FromBody] CreateSampleRequest request)
+    {
+        var command = new CreateSampleCommand(request.Name, request.Description);
+        var result = await _mediator.Send(command);
+
+        return CreatedAtAction(
+            nameof(GetSample),
+            new { id = result.Id },
+            new { success = true, data = result });
+    }
+
+    /// <summary>
+    /// EN: Update an existing sample.
+    /// VI: Cập nhật một sample đã tồn tại.
+    /// </summary>
+    /// <param name="id">EN: Sample ID / VI: ID sample</param>
+    /// <param name="request">EN: Update request / VI: Request cập nhật</param>
+    /// <returns>EN: Success status / VI: Trạng thái thành công</returns>
+    [HttpPut("{id:guid}")]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    [ProducesResponseType(StatusCodes.Status404NotFound)]
+    public async Task<IActionResult> UpdateSample(Guid id, [FromBody] UpdateSampleRequest request)
+    {
+        var command = new UpdateSampleCommand(id, request.Name, request.Description);
+        var result = await _mediator.Send(command);
+
+        if (!result)
+        {
+            return NotFound(new
+            {
+                success = false,
+                error = new
+                {
+                    code = "SAMPLE_NOT_FOUND",
+                    message = $"Sample with ID {id} not found / Sample với ID {id} không tìm thấy"
+                }
+            });
+        }
+
+        return Ok(new { success = true, message = "Sample updated successfully / Sample đã cập nhật thành công" });
+    }
+
+    /// <summary>
+    /// EN: Delete a sample.
+    /// VI: Xóa một sample.
+    /// </summary>
+    /// <param name="id">EN: Sample ID / VI: ID sample</param>
+    /// <returns>EN: Success status / VI: Trạng thái thành công</returns>
+    [HttpDelete("{id:guid}")]
+    [ProducesResponseType(StatusCodes.Status204NoContent)]
+    [ProducesResponseType(StatusCodes.Status404NotFound)]
+    public async Task<IActionResult> DeleteSample(Guid id)
+    {
+        var command = new DeleteSampleCommand(id);
+        var result = await _mediator.Send(command);
+
+        if (!result)
+        {
+            return NotFound(new
+            {
+                success = false,
+                error = new
+                {
+                    code = "SAMPLE_NOT_FOUND",
+                    message = $"Sample with ID {id} not found / Sample với ID {id} không tìm thấy"
+                }
+            });
+        }
+
+        return NoContent();
+    }
+
+    /// <summary>
+    /// EN: Change sample status.
+    /// VI: Thay đổi trạng thái sample.
+    /// </summary>
+    /// <param name="id">EN: Sample ID / VI: ID sample</param>
+    /// <param name="request">EN: Status change request / VI: Request thay đổi trạng thái</param>
+    /// <returns>EN: Success status / VI: Trạng thái thành công</returns>
+    [HttpPatch("{id:guid}/status")]
+    [ProducesResponseType(StatusCodes.Status200OK)]
+    [ProducesResponseType(StatusCodes.Status400BadRequest)]
+    [ProducesResponseType(StatusCodes.Status404NotFound)]
+    public async Task<IActionResult> ChangeSampleStatus(Guid id, [FromBody] ChangeStatusRequest request)
+    {
+        var command = new ChangeSampleStatusCommand(id, request.Status);
+        var result = await _mediator.Send(command);
+
+        if (!result)
+        {
+            return BadRequest(new
+            {
+                success = false,
+                error = new
+                {
+                    code = "STATUS_CHANGE_FAILED",
+                    message = "Failed to change sample status / Thay đổi trạng thái sample thất bại"
+                }
+            });
+        }
+
+        return Ok(new { success = true, message = "Sample status changed successfully / Trạng thái sample đã thay đổi thành công" });
+    }
+}
+
+/// <summary>
+/// EN: Request model for creating a sample.
+/// VI: Model request để tạo sample.
+/// </summary>
+public record CreateSampleRequest(string Name, string? Description);
+
+/// <summary>
+/// EN: Request model for updating a sample.
+/// VI: Model request để cập nhật sample.
+/// </summary>
+public record UpdateSampleRequest(string Name, string? Description);
+
+/// <summary>
+/// EN: Request model for changing sample status.
+/// VI: Model request để thay đổi trạng thái sample.
+/// </summary>
+public record ChangeStatusRequest(string Status);
--- a/services/fnb-engine-net/src/FnbEngine.API/FnbEngine.API.csproj
+++ b/services/fnb-engine-net/src/FnbEngine.API/FnbEngine.API.csproj
@@ -0,0 +1,43 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <AssemblyName>MyService.API</AssemblyName>
+    <RootNamespace>MyService.API</RootNamespace>
+    <Description>Web API layer with CQRS pattern</Description>
+    <UserSecretsId>myservice-api</UserSecretsId>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <!-- EN: MediatR for CQRS / VI: MediatR cho CQRS -->
+    <PackageReference Include="MediatR" Version="12.4.1" />
+    
+    <!-- EN: FluentValidation for request validation / VI: FluentValidation cho validation request -->
+    <PackageReference Include="FluentValidation" Version="11.11.0" />
+    <PackageReference Include="FluentValidation.DependencyInjectionExtensions" Version="11.11.0" />
+    
+    <!-- EN: Swagger/OpenAPI / VI: Swagger/OpenAPI -->
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="7.2.0" />
+    
+    <!-- EN: API Versioning / VI: API Versioning -->
+    <PackageReference Include="Asp.Versioning.Mvc" Version="8.1.0" />
+    <PackageReference Include="Asp.Versioning.Mvc.ApiExplorer" Version="8.1.0" />
+    
+    <!-- EN: Health checks / VI: Health checks -->
+    <PackageReference Include="AspNetCore.HealthChecks.NpgSql" Version="8.0.2" />
+    <PackageReference Include="AspNetCore.HealthChecks.Redis" Version="8.0.1" />
+    
+    <!-- EN: Problem Details (RFC 7807) / VI: Problem Details (RFC 7807) -->
+    <PackageReference Include="Hellang.Middleware.ProblemDetails" Version="6.5.1" />
+    
+    <!-- EN: Serilog for structured logging / VI: Serilog cho structured logging -->
+    <PackageReference Include="Serilog.AspNetCore" Version="8.0.3" />
+    <PackageReference Include="Serilog.Sinks.Console" Version="6.0.0" />
+    <PackageReference Include="Serilog.Sinks.Seq" Version="8.0.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\MyService.Domain\MyService.Domain.csproj" />
+    <ProjectReference Include="..\MyService.Infrastructure\MyService.Infrastructure.csproj" />
+  </ItemGroup>
+
+</Project>
--- a/services/fnb-engine-net/src/FnbEngine.API/Program.cs
+++ b/services/fnb-engine-net/src/FnbEngine.API/Program.cs
@@ -0,0 +1,144 @@
+using Asp.Versioning;
+using FluentValidation;
+using Hellang.Middleware.ProblemDetails;
+using MyService.API.Application.Behaviors;
+using MyService.Infrastructure;
+using Serilog;
+
+// EN: Configure Serilog early / VI: Cấu hình Serilog sớm
+Log.Logger = new LoggerConfiguration()
+    .WriteTo.Console()
+    .CreateBootstrapLogger();
+
+try
+{
+    Log.Information("Starting MyService API / Khởi động MyService API");
+
+    var builder = WebApplication.CreateBuilder(args);
+
+    // EN: Configure Serilog / VI: Cấu hình Serilog
+    builder.Host.UseSerilog((context, services, configuration) => configuration
+        .ReadFrom.Configuration(context.Configuration)
+        .ReadFrom.Services(services)
+        .Enrich.FromLogContext()
+        .WriteTo.Console());
+
+    // EN: Add Infrastructure services / VI: Thêm Infrastructure services
+    builder.Services.AddInfrastructure(builder.Configuration);
+
+    // EN: Add MediatR with behaviors / VI: Thêm MediatR với behaviors
+    builder.Services.AddMediatR(cfg =>
+    {
+        cfg.RegisterServicesFromAssemblyContaining<Program>();
+        cfg.AddOpenBehavior(typeof(LoggingBehavior<,>));
+        cfg.AddOpenBehavior(typeof(ValidatorBehavior<,>));
+        cfg.AddOpenBehavior(typeof(TransactionBehavior<,>));
+    });
+
+    // EN: Add FluentValidation / VI: Thêm FluentValidation
+    builder.Services.AddValidatorsFromAssemblyContaining<Program>();
+
+    // EN: Add API versioning / VI: Thêm API versioning
+    builder.Services.AddApiVersioning(options =>
+    {
+        options.DefaultApiVersion = new ApiVersion(1, 0);
+        options.AssumeDefaultVersionWhenUnspecified = true;
+        options.ReportApiVersions = true;
+        options.ApiVersionReader = ApiVersionReader.Combine(
+            new UrlSegmentApiVersionReader(),
+            new HeaderApiVersionReader("X-Api-Version"));
+    })
+    .AddApiExplorer(options =>
+    {
+        options.GroupNameFormat = "'v'VVV";
+        options.SubstituteApiVersionInUrl = true;
+    });
+
+    // EN: Add controllers / VI: Thêm controllers
+    builder.Services.AddControllers();
+
+    // EN: Add ProblemDetails middleware (RFC 7807) / VI: Thêm ProblemDetails middleware
+    builder.Services.AddProblemDetails(options =>
+    {
+        options.IncludeExceptionDetails = (ctx, ex) =>
+            builder.Environment.IsDevelopment();
+    });
+
+    // EN: Add Swagger / VI: Thêm Swagger
+    builder.Services.AddEndpointsApiExplorer();
+    builder.Services.AddSwaggerGen(options =>
+    {
+        options.SwaggerDoc("v1", new()
+        {
+            Title = "MyService API",
+            Version = "v1",
+            Description = "MyService microservice API / API microservice MyService"
+        });
+    });
+
+    // EN: Add health checks / VI: Thêm health checks
+    builder.Services.AddHealthChecks()
+        .AddNpgSql(
+            builder.Configuration.GetConnectionString("DefaultConnection")
+                ?? builder.Configuration["DATABASE_URL"]
+                ?? "",
+            name: "postgresql",
+            tags: ["db", "postgresql"]);
+
+    // EN: Add CORS / VI: Thêm CORS
+    builder.Services.AddCors(options =>
+    {
+        options.AddDefaultPolicy(policy =>
+        {
+            policy.AllowAnyOrigin()
+                  .AllowAnyMethod()
+                  .AllowAnyHeader();
+        });
+    });
+
+    var app = builder.Build();
+
+    // EN: Configure middleware pipeline / VI: Cấu hình middleware pipeline
+    app.UseSerilogRequestLogging();
+    app.UseProblemDetails();
+
+    if (app.Environment.IsDevelopment())
+    {
+        app.UseSwagger();
+        app.UseSwaggerUI(c =>
+        {
+            c.SwaggerEndpoint("/swagger/v1/swagger.json", "MyService API v1");
+            c.RoutePrefix = "swagger";
+        });
+    }
+
+    app.UseCors();
+    app.UseRouting();
+
+    // EN: Map health check endpoints / VI: Map health check endpoints
+    app.MapHealthChecks("/health");
+    app.MapHealthChecks("/health/live", new()
+    {
+        Predicate = _ => false // EN: Just checks app is running / VI: Chỉ kiểm tra app đang chạy
+    });
+    app.MapHealthChecks("/health/ready");
+
+    // EN: Map controllers / VI: Map controllers
+    app.MapControllers();
+
+    // EN: Run the application / VI: Chạy ứng dụng
+    app.Run();
+}
+catch (Exception ex)
+{
+    Log.Fatal(ex, "Application terminated unexpectedly / Ứng dụng kết thúc bất ngờ");
+    throw;
+}
+finally
+{
+    Log.CloseAndFlush();
+}
+
+// EN: Make Program class accessible for integration tests
+// VI: Làm cho class Program có thể truy cập cho integration tests
+public partial class Program { }
--- a/services/fnb-engine-net/src/FnbEngine.API/Properties/launchSettings.json
+++ b/services/fnb-engine-net/src/FnbEngine.API/Properties/launchSettings.json
@@ -0,0 +1,15 @@
+{
+    "$schema": "http://json.schemastore.org/launchsettings.json",
+    "profiles": {
+        "http": {
+            "commandName": "Project",
+            "dotnetRunMessages": true,
+            "launchBrowser": true,
+            "launchUrl": "swagger",
+            "applicationUrl": "http://localhost:5000",
+            "environmentVariables": {
+                "ASPNETCORE_ENVIRONMENT": "Development"
+            }
+        }
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/appsettings.Development.json
+++ b/services/fnb-engine-net/src/FnbEngine.API/appsettings.Development.json
@@ -0,0 +1,19 @@
+{
+    "Logging": {
+        "LogLevel": {
+            "Default": "Debug",
+            "Microsoft.AspNetCore": "Information",
+            "Microsoft.EntityFrameworkCore.Database.Command": "Information"
+        }
+    },
+    "Serilog": {
+        "MinimumLevel": {
+            "Default": "Debug",
+            "Override": {
+                "Microsoft": "Information",
+                "Microsoft.EntityFrameworkCore.Database.Command": "Information",
+                "System": "Information"
+            }
+        }
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.API/appsettings.json
+++ b/services/fnb-engine-net/src/FnbEngine.API/appsettings.json
@@ -0,0 +1,46 @@
+{
+    "Logging": {
+        "LogLevel": {
+            "Default": "Information",
+            "Microsoft.AspNetCore": "Warning",
+            "Microsoft.EntityFrameworkCore": "Warning"
+        }
+    },
+    "Serilog": {
+        "MinimumLevel": {
+            "Default": "Information",
+            "Override": {
+                "Microsoft": "Warning",
+                "Microsoft.EntityFrameworkCore": "Warning",
+                "System": "Warning"
+            }
+        },
+        "WriteTo": [
+            {
+                "Name": "Console",
+                "Args": {
+                    "outputTemplate": "[{Timestamp:HH:mm:ss} {Level:u3}] {Message:lj} {Properties:j}{NewLine}{Exception}"
+                }
+            }
+        ],
+        "Enrich": [
+            "FromLogContext",
+            "WithMachineName",
+            "WithThreadId"
+        ]
+    },
+    "ConnectionStrings": {
+        "DefaultConnection": "Host=localhost;Port=5432;Database=myservice_db;Username=postgres;Password=postgres"
+    },
+    "Redis": {
+        "ConnectionString": "localhost:6379"
+    },
+    "Jwt": {
+        "Secret": "your-super-secret-key-min-32-characters",
+        "Issuer": "goodgo-platform",
+        "Audience": "goodgo-services",
+        "AccessTokenExpiryMinutes": 15,
+        "RefreshTokenExpiryDays": 7
+    },
+    "AllowedHosts": "*"
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/AggregatesModel/SampleAggregate/ISampleRepository.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/AggregatesModel/SampleAggregate/ISampleRepository.cs
@@ -0,0 +1,61 @@
+using MyService.Domain.SeedWork;
+
+namespace MyService.Domain.AggregatesModel.SampleAggregate;
+
+/// <summary>
+/// EN: Repository interface for Sample aggregate.
+/// VI: Interface repository cho Sample aggregate.
+/// </summary>
+/// <remarks>
+/// EN: Following repository pattern, this interface defines the contract
+/// for data access operations on Sample aggregate.
+/// VI: Theo pattern repository, interface này định nghĩa contract
+/// cho các thao tác truy cập dữ liệu trên Sample aggregate.
+/// </remarks>
+public interface ISampleRepository : IRepository<Sample>
+{
+    /// <summary>
+    /// EN: Get a sample by its ID.
+    /// VI: Lấy một sample theo ID.
+    /// </summary>
+    /// <param name="sampleId">EN: The sample ID / VI: ID của sample</param>
+    /// <returns>EN: The sample or null if not found / VI: Sample hoặc null nếu không tìm thấy</returns>
+    Task<Sample?> GetAsync(Guid sampleId);
+
+    /// <summary>
+    /// EN: Get all samples.
+    /// VI: Lấy tất cả samples.
+    /// </summary>
+    /// <returns>EN: List of samples / VI: Danh sách samples</returns>
+    Task<IEnumerable<Sample>> GetAllAsync();
+
+    /// <summary>
+    /// EN: Add a new sample.
+    /// VI: Thêm một sample mới.
+    /// </summary>
+    /// <param name="sample">EN: The sample to add / VI: Sample cần thêm</param>
+    /// <returns>EN: The added sample / VI: Sample đã thêm</returns>
+    Sample Add(Sample sample);
+
+    /// <summary>
+    /// EN: Update an existing sample.
+    /// VI: Cập nhật một sample đã tồn tại.
+    /// </summary>
+    /// <param name="sample">EN: The sample to update / VI: Sample cần cập nhật</param>
+    void Update(Sample sample);
+
+    /// <summary>
+    /// EN: Delete a sample.
+    /// VI: Xóa một sample.
+    /// </summary>
+    /// <param name="sample">EN: The sample to delete / VI: Sample cần xóa</param>
+    void Delete(Sample sample);
+
+    /// <summary>
+    /// EN: Get samples by status.
+    /// VI: Lấy samples theo trạng thái.
+    /// </summary>
+    /// <param name="statusId">EN: The status ID / VI: ID trạng thái</param>
+    /// <returns>EN: List of samples with given status / VI: Danh sách samples với trạng thái cho trước</returns>
+    Task<IEnumerable<Sample>> GetByStatusAsync(int statusId);
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/AggregatesModel/SampleAggregate/Sample.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/AggregatesModel/SampleAggregate/Sample.cs
@@ -0,0 +1,158 @@
+using MyService.Domain.Events;
+using MyService.Domain.Exceptions;
+using MyService.Domain.SeedWork;
+
+namespace MyService.Domain.AggregatesModel.SampleAggregate;
+
+/// <summary>
+/// EN: Sample aggregate root demonstrating DDD patterns.
+/// VI: Sample aggregate root minh họa các pattern DDD.
+/// </summary>
+public class Sample : Entity, IAggregateRoot
+{
+    // EN: Private fields for encapsulation
+    // VI: Fields private để đóng gói
+    private string _name = null!;
+    private string? _description;
+    private SampleStatus _status = null!;
+    private DateTime _createdAt;
+    private DateTime? _updatedAt;
+
+    /// <summary>
+    /// EN: Sample name (required).
+    /// VI: Tên sample (bắt buộc).
+    /// </summary>
+    public string Name => _name;
+
+    /// <summary>
+    /// EN: Optional description.
+    /// VI: Mô tả tùy chọn.
+    /// </summary>
+    public string? Description => _description;
+
+    /// <summary>
+    /// EN: Current status.
+    /// VI: Trạng thái hiện tại.
+    /// </summary>
+    public SampleStatus Status => _status;
+
+    /// <summary>
+    /// EN: Status ID for EF Core mapping.
+    /// VI: ID trạng thái cho EF Core mapping.
+    /// </summary>
+    public int StatusId { get; private set; }
+
+    /// <summary>
+    /// EN: Creation timestamp.
+    /// VI: Thời gian tạo.
+    /// </summary>
+    public DateTime CreatedAt => _createdAt;
+
+    /// <summary>
+    /// EN: Last update timestamp.
+    /// VI: Thời gian cập nhật cuối.
+    /// </summary>
+    public DateTime? UpdatedAt => _updatedAt;
+
+    /// <summary>
+    /// EN: Private constructor for EF Core.
+    /// VI: Constructor private cho EF Core.
+    /// </summary>
+    protected Sample()
+    {
+    }
+
+    /// <summary>
+    /// EN: Create a new Sample with required information.
+    /// VI: Tạo một Sample mới với thông tin bắt buộc.
+    /// </summary>
+    /// <param name="name">EN: Sample name / VI: Tên sample</param>
+    /// <param name="description">EN: Optional description / VI: Mô tả tùy chọn</param>
+    public Sample(string name, string? description = null) : this()
+    {
+        if (string.IsNullOrWhiteSpace(name))
+            throw new SampleDomainException("Sample name cannot be empty");
+
+        Id = Guid.NewGuid();
+        _name = name;
+        _description = description;
+        _status = SampleStatus.Draft;
+        StatusId = SampleStatus.Draft.Id;
+        _createdAt = DateTime.UtcNow;
+
+        // EN: Add domain event for creation
+        // VI: Thêm domain event cho việc tạo
+        AddDomainEvent(new SampleCreatedDomainEvent(this));
+    }
+
+    /// <summary>
+    /// EN: Update sample information.
+    /// VI: Cập nhật thông tin sample.
+    /// </summary>
+    public void Update(string name, string? description)
+    {
+        if (string.IsNullOrWhiteSpace(name))
+            throw new SampleDomainException("Sample name cannot be empty");
+
+        if (_status == SampleStatus.Cancelled)
+            throw new SampleDomainException("Cannot update a cancelled sample");
+
+        _name = name;
+        _description = description;
+        _updatedAt = DateTime.UtcNow;
+    }
+
+    /// <summary>
+    /// EN: Activate the sample.
+    /// VI: Kích hoạt sample.
+    /// </summary>
+    public void Activate()
+    {
+        if (_status != SampleStatus.Draft)
+            throw new SampleDomainException("Only draft samples can be activated");
+
+        var previousStatus = _status;
+        _status = SampleStatus.Active;
+        StatusId = SampleStatus.Active.Id;
+        _updatedAt = DateTime.UtcNow;
+
+        AddDomainEvent(new SampleStatusChangedDomainEvent(Id, previousStatus, _status));
+    }
+
+    /// <summary>
+    /// EN: Complete the sample.
+    /// VI: Hoàn thành sample.
+    /// </summary>
+    public void Complete()
+    {
+        if (_status != SampleStatus.Active)
+            throw new SampleDomainException("Only active samples can be completed");
+
+        var previousStatus = _status;
+        _status = SampleStatus.Completed;
+        StatusId = SampleStatus.Completed.Id;
+        _updatedAt = DateTime.UtcNow;
+
+        AddDomainEvent(new SampleStatusChangedDomainEvent(Id, previousStatus, _status));
+    }
+
+    /// <summary>
+    /// EN: Cancel the sample.
+    /// VI: Hủy sample.
+    /// </summary>
+    public void Cancel()
+    {
+        if (_status == SampleStatus.Completed)
+            throw new SampleDomainException("Cannot cancel a completed sample");
+
+        if (_status == SampleStatus.Cancelled)
+            throw new SampleDomainException("Sample is already cancelled");
+
+        var previousStatus = _status;
+        _status = SampleStatus.Cancelled;
+        StatusId = SampleStatus.Cancelled.Id;
+        _updatedAt = DateTime.UtcNow;
+
+        AddDomainEvent(new SampleStatusChangedDomainEvent(Id, previousStatus, _status));
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/AggregatesModel/SampleAggregate/SampleStatus.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/AggregatesModel/SampleAggregate/SampleStatus.cs
@@ -0,0 +1,77 @@
+using MyService.Domain.SeedWork;
+
+namespace MyService.Domain.AggregatesModel.SampleAggregate;
+
+/// <summary>
+/// EN: Sample status enumeration following type-safe enum pattern.
+/// VI: Enumeration trạng thái Sample theo pattern enum an toàn kiểu.
+/// </summary>
+public class SampleStatus : Enumeration
+{
+    /// <summary>
+    /// EN: Draft status - initial state
+    /// VI: Trạng thái nháp - trạng thái ban đầu
+    /// </summary>
+    public static SampleStatus Draft = new(1, nameof(Draft));
+
+    /// <summary>
+    /// EN: Active status - ready for use
+    /// VI: Trạng thái hoạt động - sẵn sàng sử dụng
+    /// </summary>
+    public static SampleStatus Active = new(2, nameof(Active));
+
+    /// <summary>
+    /// EN: Completed status - finished processing
+    /// VI: Trạng thái hoàn thành - đã xử lý xong
+    /// </summary>
+    public static SampleStatus Completed = new(3, nameof(Completed));
+
+    /// <summary>
+    /// EN: Cancelled status - cancelled by user
+    /// VI: Trạng thái đã hủy - bị hủy bởi người dùng
+    /// </summary>
+    public static SampleStatus Cancelled = new(4, nameof(Cancelled));
+
+    public SampleStatus(int id, string name) : base(id, name)
+    {
+    }
+
+    /// <summary>
+    /// EN: Get all available statuses.
+    /// VI: Lấy tất cả các trạng thái có sẵn.
+    /// </summary>
+    public static IEnumerable<SampleStatus> List() => GetAll<SampleStatus>();
+
+    /// <summary>
+    /// EN: Parse status from name.
+    /// VI: Parse trạng thái từ tên.
+    /// </summary>
+    public static SampleStatus FromName(string name)
+    {
+        var status = List().SingleOrDefault(s => 
+            string.Equals(s.Name, name, StringComparison.CurrentCultureIgnoreCase));
+
+        if (status is null)
+        {
+            throw new ArgumentException($"Possible values for SampleStatus: {string.Join(",", List().Select(s => s.Name))}");
+        }
+
+        return status;
+    }
+
+    /// <summary>
+    /// EN: Parse status from ID.
+    /// VI: Parse trạng thái từ ID.
+    /// </summary>
+    public static SampleStatus From(int id)
+    {
+        var status = List().SingleOrDefault(s => s.Id == id);
+
+        if (status is null)
+        {
+            throw new ArgumentException($"Possible values for SampleStatus: {string.Join(",", List().Select(s => s.Name))}");
+        }
+
+        return status;
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/Events/SampleCreatedDomainEvent.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/Events/SampleCreatedDomainEvent.cs
@@ -0,0 +1,22 @@
+using MediatR;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.Domain.Events;
+
+/// <summary>
+/// EN: Domain event raised when a new Sample is created.
+/// VI: Domain event được phát ra khi một Sample mới được tạo.
+/// </summary>
+public class SampleCreatedDomainEvent : INotification
+{
+    /// <summary>
+    /// EN: The newly created sample.
+    /// VI: Sample mới được tạo.
+    /// </summary>
+    public Sample Sample { get; }
+
+    public SampleCreatedDomainEvent(Sample sample)
+    {
+        Sample = sample;
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/Events/SampleStatusChangedDomainEvent.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/Events/SampleStatusChangedDomainEvent.cs
@@ -0,0 +1,39 @@
+using MediatR;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.Domain.Events;
+
+/// <summary>
+/// EN: Domain event raised when Sample status changes.
+/// VI: Domain event được phát ra khi trạng thái Sample thay đổi.
+/// </summary>
+public class SampleStatusChangedDomainEvent : INotification
+{
+    /// <summary>
+    /// EN: The sample ID.
+    /// VI: ID của sample.
+    /// </summary>
+    public Guid SampleId { get; }
+
+    /// <summary>
+    /// EN: Previous status before the change.
+    /// VI: Trạng thái trước khi thay đổi.
+    /// </summary>
+    public SampleStatus PreviousStatus { get; }
+
+    /// <summary>
+    /// EN: New status after the change.
+    /// VI: Trạng thái mới sau khi thay đổi.
+    /// </summary>
+    public SampleStatus NewStatus { get; }
+
+    public SampleStatusChangedDomainEvent(
+        Guid sampleId,
+        SampleStatus previousStatus,
+        SampleStatus newStatus)
+    {
+        SampleId = sampleId;
+        PreviousStatus = previousStatus;
+        NewStatus = newStatus;
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/Exceptions/DomainException.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/Exceptions/DomainException.cs
@@ -0,0 +1,21 @@
+namespace MyService.Domain.Exceptions;
+
+/// <summary>
+/// EN: Base exception for domain errors.
+/// VI: Exception cơ sở cho các lỗi domain.
+/// </summary>
+public class DomainException : Exception
+{
+    public DomainException()
+    {
+    }
+
+    public DomainException(string message) : base(message)
+    {
+    }
+
+    public DomainException(string message, Exception innerException) 
+        : base(message, innerException)
+    {
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/Exceptions/SampleDomainException.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/Exceptions/SampleDomainException.cs
@@ -0,0 +1,21 @@
+namespace MyService.Domain.Exceptions;
+
+/// <summary>
+/// EN: Exception for Sample aggregate domain errors.
+/// VI: Exception cho các lỗi domain của Sample aggregate.
+/// </summary>
+public class SampleDomainException : DomainException
+{
+    public SampleDomainException()
+    {
+    }
+
+    public SampleDomainException(string message) : base(message)
+    {
+    }
+
+    public SampleDomainException(string message, Exception innerException) 
+        : base(message, innerException)
+    {
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/FnbEngine.Domain.csproj
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/FnbEngine.Domain.csproj
@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <AssemblyName>MyService.Domain</AssemblyName>
+    <RootNamespace>MyService.Domain</RootNamespace>
+    <Description>Domain layer containing core business logic and entities</Description>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <!-- EN: MediatR for domain events / VI: MediatR cho domain events -->
+    <PackageReference Include="MediatR.Contracts" Version="2.0.1" />
+  </ItemGroup>
+
+</Project>
--- a/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/Entity.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/Entity.cs
@@ -0,0 +1,102 @@
+using MediatR;
+
+namespace MyService.Domain.SeedWork;
+
+/// <summary>
+/// EN: Base class for all domain entities.
+/// VI: Lớp cơ sở cho tất cả các entity trong domain.
+/// </summary>
+public abstract class Entity
+{
+    private int? _requestedHashCode;
+    private Guid _id;
+    private List<INotification> _domainEvents = new();
+
+    /// <summary>
+    /// EN: Unique identifier for the entity.
+    /// VI: Định danh duy nhất cho entity.
+    /// </summary>
+    public virtual Guid Id
+    {
+        get => _id;
+        protected set => _id = value;
+    }
+
+    /// <summary>
+    /// EN: Domain events raised by this entity.
+    /// VI: Các domain event được phát ra bởi entity này.
+    /// </summary>
+    public IReadOnlyCollection<INotification> DomainEvents => _domainEvents.AsReadOnly();
+
+    /// <summary>
+    /// EN: Add a domain event to be dispatched.
+    /// VI: Thêm một domain event để dispatch.
+    /// </summary>
+    public void AddDomainEvent(INotification eventItem)
+    {
+        _domainEvents.Add(eventItem);
+    }
+
+    /// <summary>
+    /// EN: Remove a domain event.
+    /// VI: Xóa một domain event.
+    /// </summary>
+    public void RemoveDomainEvent(INotification eventItem)
+    {
+        _domainEvents.Remove(eventItem);
+    }
+
+    /// <summary>
+    /// EN: Clear all domain events.
+    /// VI: Xóa tất cả domain events.
+    /// </summary>
+    public void ClearDomainEvents()
+    {
+        _domainEvents.Clear();
+    }
+
+    /// <summary>
+    /// EN: Check if entity is transient (not persisted yet).
+    /// VI: Kiểm tra xem entity có phải là transient (chưa lưu) không.
+    /// </summary>
+    public bool IsTransient()
+    {
+        return Id == default;
+    }
+
+    public override bool Equals(object? obj)
+    {
+        if (obj is not Entity item)
+            return false;
+
+        if (ReferenceEquals(this, item))
+            return true;
+
+        if (GetType() != item.GetType())
+            return false;
+
+        if (item.IsTransient() || IsTransient())
+            return false;
+
+        return item.Id == Id;
+    }
+
+    public override int GetHashCode()
+    {
+        if (IsTransient())
+            return base.GetHashCode();
+
+        _requestedHashCode ??= Id.GetHashCode() ^ 31;
+        return _requestedHashCode.Value;
+    }
+
+    public static bool operator ==(Entity? left, Entity? right)
+    {
+        return left?.Equals(right) ?? right is null;
+    }
+
+    public static bool operator !=(Entity? left, Entity? right)
+    {
+        return !(left == right);
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/Enumeration.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/Enumeration.cs
@@ -0,0 +1,95 @@
+using System.Reflection;
+
+namespace MyService.Domain.SeedWork;
+
+/// <summary>
+/// EN: Base class for enumeration classes (type-safe enum pattern).
+/// VI: Lớp cơ sở cho các lớp enumeration (pattern enum an toàn kiểu).
+/// </summary>
+/// <remarks>
+/// EN: This provides a type-safe alternative to enums with additional functionality
+/// like validation, parsing, and rich behavior.
+/// VI: Cung cấp một thay thế an toàn kiểu cho enums với các chức năng bổ sung
+/// như validation, parsing, và hành vi phong phú.
+/// </remarks>
+public abstract class Enumeration : IComparable
+{
+    /// <summary>
+    /// EN: The name of the enumeration value.
+    /// VI: Tên của giá trị enumeration.
+    /// </summary>
+    public string Name { get; private set; }
+
+    /// <summary>
+    /// EN: The unique identifier of the enumeration value.
+    /// VI: Định danh duy nhất của giá trị enumeration.
+    /// </summary>
+    public int Id { get; private set; }
+
+    protected Enumeration(int id, string name) => (Id, Name) = (id, name);
+
+    public override string ToString() => Name;
+
+    /// <summary>
+    /// EN: Get all enumeration values of a given type.
+    /// VI: Lấy tất cả các giá trị enumeration của một kiểu cho trước.
+    /// </summary>
+    public static IEnumerable<T> GetAll<T>() where T : Enumeration =>
+        typeof(T).GetFields(BindingFlags.Public | BindingFlags.Static | BindingFlags.DeclaredOnly)
+            .Select(f => f.GetValue(null))
+            .Cast<T>();
+
+    public override bool Equals(object? obj)
+    {
+        if (obj is not Enumeration otherValue)
+            return false;
+
+        var typeMatches = GetType() == obj.GetType();
+        var valueMatches = Id.Equals(otherValue.Id);
+
+        return typeMatches && valueMatches;
+    }
+
+    public override int GetHashCode() => Id.GetHashCode();
+
+    /// <summary>
+    /// EN: Get absolute difference between two enumeration values.
+    /// VI: Lấy sự khác biệt tuyệt đối giữa hai giá trị enumeration.
+    /// </summary>
+    public static int AbsoluteDifference(Enumeration firstValue, Enumeration secondValue)
+    {
+        return Math.Abs(firstValue.Id - secondValue.Id);
+    }
+
+    /// <summary>
+    /// EN: Parse an integer ID to the corresponding enumeration value.
+    /// VI: Parse một ID integer thành giá trị enumeration tương ứng.
+    /// </summary>
+    public static T FromValue<T>(int value) where T : Enumeration
+    {
+        var matchingItem = Parse<T, int>(value, "value", item => item.Id == value);
+        return matchingItem;
+    }
+
+    /// <summary>
+    /// EN: Parse a display name to the corresponding enumeration value.
+    /// VI: Parse một tên hiển thị thành giá trị enumeration tương ứng.
+    /// </summary>
+    public static T FromDisplayName<T>(string displayName) where T : Enumeration
+    {
+        var matchingItem = Parse<T, string>(displayName, "display name", item => item.Name == displayName);
+        return matchingItem;
+    }
+
+    private static T Parse<T, TValue>(TValue value, string description, Func<T, bool> predicate) where T : Enumeration
+    {
+        var matchingItem = GetAll<T>().FirstOrDefault(predicate);
+
+        if (matchingItem is null)
+            throw new InvalidOperationException($"'{value}' is not a valid {description} in {typeof(T)}");
+
+        return matchingItem;
+    }
+
+    public int CompareTo(object? other) => Id.CompareTo(((Enumeration)other!).Id);
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/IAggregateRoot.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/IAggregateRoot.cs
@@ -0,0 +1,15 @@
+namespace MyService.Domain.SeedWork;
+
+/// <summary>
+/// EN: Marker interface for aggregate roots.
+/// VI: Interface đánh dấu cho aggregate roots.
+/// </summary>
+/// <remarks>
+/// EN: Aggregate roots are the entry points to aggregates and are the only objects
+/// that outside code should hold references to.
+/// VI: Aggregate roots là điểm vào của aggregates và là đối tượng duy nhất
+/// mà code bên ngoài nên giữ tham chiếu đến.
+/// </remarks>
+public interface IAggregateRoot
+{
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/IRepository.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/IRepository.cs
@@ -0,0 +1,15 @@
+namespace MyService.Domain.SeedWork;
+
+/// <summary>
+/// EN: Generic repository interface for aggregate roots.
+/// VI: Interface repository generic cho aggregate roots.
+/// </summary>
+/// <typeparam name="T">EN: The aggregate root type / VI: Kiểu aggregate root</typeparam>
+public interface IRepository<T> where T : IAggregateRoot
+{
+    /// <summary>
+    /// EN: The unit of work for this repository.
+    /// VI: Unit of work cho repository này.
+    /// </summary>
+    IUnitOfWork UnitOfWork { get; }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/IUnitOfWork.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/IUnitOfWork.cs
@@ -0,0 +1,30 @@
+namespace MyService.Domain.SeedWork;
+
+/// <summary>
+/// EN: Unit of Work pattern interface.
+/// VI: Interface cho Unit of Work pattern.
+/// </summary>
+/// <remarks>
+/// EN: Maintains a list of objects affected by a business transaction
+/// and coordinates the writing out of changes.
+/// VI: Duy trì danh sách các đối tượng bị ảnh hưởng bởi một transaction nghiệp vụ
+/// và điều phối việc ghi các thay đổi.
+/// </remarks>
+public interface IUnitOfWork : IDisposable
+{
+    /// <summary>
+    /// EN: Save all changes made in this unit of work.
+    /// VI: Lưu tất cả các thay đổi được thực hiện trong unit of work này.
+    /// </summary>
+    /// <param name="cancellationToken">EN: Cancellation token / VI: Token hủy</param>
+    /// <returns>EN: Number of entities written / VI: Số entity đã ghi</returns>
+    Task<int> SaveChangesAsync(CancellationToken cancellationToken = default);
+
+    /// <summary>
+    /// EN: Save all changes and dispatch domain events.
+    /// VI: Lưu tất cả thay đổi và dispatch domain events.
+    /// </summary>
+    /// <param name="cancellationToken">EN: Cancellation token / VI: Token hủy</param>
+    /// <returns>EN: True if successful / VI: True nếu thành công</returns>
+    Task<bool> SaveEntitiesAsync(CancellationToken cancellationToken = default);
+}
--- a/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/ValueObject.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Domain/SeedWork/ValueObject.cs
@@ -0,0 +1,53 @@
+namespace MyService.Domain.SeedWork;
+
+/// <summary>
+/// EN: Base class for Value Objects following DDD patterns.
+/// VI: Lớp cơ sở cho Value Objects theo mẫu DDD.
+/// </summary>
+/// <remarks>
+/// EN: Value objects are immutable and compared by their values, not identity.
+/// VI: Value objects là bất biến và được so sánh theo giá trị, không phải định danh.
+/// </remarks>
+public abstract class ValueObject
+{
+    /// <summary>
+    /// EN: Get the atomic values that make up this value object.
+    /// VI: Lấy các giá trị nguyên tử tạo nên value object này.
+    /// </summary>
+    protected abstract IEnumerable<object?> GetEqualityComponents();
+
+    public override bool Equals(object? obj)
+    {
+        if (obj is null || obj.GetType() != GetType())
+            return false;
+
+        var other = (ValueObject)obj;
+        return GetEqualityComponents().SequenceEqual(other.GetEqualityComponents());
+    }
+
+    public override int GetHashCode()
+    {
+        return GetEqualityComponents()
+            .Select(x => x?.GetHashCode() ?? 0)
+            .Aggregate((x, y) => x ^ y);
+    }
+
+    public static bool operator ==(ValueObject? left, ValueObject? right)
+    {
+        return left?.Equals(right) ?? right is null;
+    }
+
+    public static bool operator !=(ValueObject? left, ValueObject? right)
+    {
+        return !(left == right);
+    }
+
+    /// <summary>
+    /// EN: Create a copy of this value object with modifications.
+    /// VI: Tạo bản sao của value object này với các thay đổi.
+    /// </summary>
+    protected ValueObject GetCopy()
+    {
+        return (ValueObject)MemberwiseClone();
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/DependencyInjection.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/DependencyInjection.cs
@@ -0,0 +1,57 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+using MyService.Infrastructure.Idempotency;
+using MyService.Infrastructure.Repositories;
+
+namespace MyService.Infrastructure;
+
+/// <summary>
+/// EN: Dependency injection extensions for Infrastructure layer.
+/// VI: Extensions dependency injection cho lớp Infrastructure.
+/// </summary>
+public static class DependencyInjection
+{
+    /// <summary>
+    /// EN: Add infrastructure services to the DI container.
+    /// VI: Thêm các services infrastructure vào DI container.
+    /// </summary>
+    public static IServiceCollection AddInfrastructure(
+        this IServiceCollection services,
+        IConfiguration configuration)
+    {
+        // EN: Add DbContext with PostgreSQL / VI: Thêm DbContext với PostgreSQL
+        services.AddDbContext<MyServiceContext>(options =>
+        {
+            var connectionString = configuration.GetConnectionString("DefaultConnection")
+                ?? configuration["DATABASE_URL"]
+                ?? throw new InvalidOperationException("Connection string not configured");
+
+            options.UseNpgsql(connectionString, npgsqlOptions =>
+            {
+                npgsqlOptions.MigrationsAssembly(typeof(MyServiceContext).Assembly.FullName);
+                npgsqlOptions.EnableRetryOnFailure(
+                    maxRetryCount: 5,
+                    maxRetryDelay: TimeSpan.FromSeconds(30),
+                    errorCodesToAdd: null);
+            });
+
+            // EN: Enable sensitive data logging in development only
+            // VI: Chỉ bật sensitive data logging trong development
+            if (Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT") == "Development")
+            {
+                options.EnableSensitiveDataLogging();
+                options.EnableDetailedErrors();
+            }
+        });
+
+        // EN: Register repositories / VI: Đăng ký repositories
+        services.AddScoped<ISampleRepository, SampleRepository>();
+
+        // EN: Register idempotency services / VI: Đăng ký idempotency services
+        services.AddScoped<IRequestManager, RequestManager>();
+
+        return services;
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/EntityConfigurations/SampleEntityTypeConfiguration.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/EntityConfigurations/SampleEntityTypeConfiguration.cs
@@ -0,0 +1,61 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.Infrastructure.EntityConfigurations;
+
+/// <summary>
+/// EN: EF Core configuration for Sample entity.
+/// VI: Cấu hình EF Core cho entity Sample.
+/// </summary>
+public class SampleEntityTypeConfiguration : IEntityTypeConfiguration<Sample>
+{
+    public void Configure(EntityTypeBuilder<Sample> builder)
+    {
+        // EN: Table name / VI: Tên bảng
+        builder.ToTable("samples");
+
+        // EN: Primary key / VI: Khóa chính
+        builder.HasKey(s => s.Id);
+
+        // EN: Ignore domain events (not persisted)
+        // VI: Bỏ qua domain events (không lưu)
+        builder.Ignore(s => s.DomainEvents);
+
+        // EN: Properties / VI: Các thuộc tính
+        builder.Property(s => s.Id)
+            .HasColumnName("id")
+            .IsRequired();
+
+        builder.Property<string>("_name")
+            .HasColumnName("name")
+            .HasMaxLength(200)
+            .IsRequired();
+
+        builder.Property<string?>("_description")
+            .HasColumnName("description")
+            .HasMaxLength(1000);
+
+        builder.Property<DateTime>("_createdAt")
+            .HasColumnName("created_at")
+            .IsRequired();
+
+        builder.Property<DateTime?>("_updatedAt")
+            .HasColumnName("updated_at");
+
+        // EN: Status relationship / VI: Quan hệ với Status
+        builder.Property(s => s.StatusId)
+            .HasColumnName("status_id")
+            .IsRequired();
+
+        builder.HasOne(s => s.Status)
+            .WithMany()
+            .HasForeignKey(s => s.StatusId)
+            .OnDelete(DeleteBehavior.Restrict);
+
+        // EN: Indexes / VI: Các index
+        builder.HasIndex("_name");
+        builder.HasIndex(s => s.StatusId);
+        builder.HasIndex("_createdAt");
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/EntityConfigurations/SampleStatusEntityTypeConfiguration.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/EntityConfigurations/SampleStatusEntityTypeConfiguration.cs
@@ -0,0 +1,39 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+
+namespace MyService.Infrastructure.EntityConfigurations;
+
+/// <summary>
+/// EN: EF Core configuration for SampleStatus enumeration.
+/// VI: Cấu hình EF Core cho enumeration SampleStatus.
+/// </summary>
+public class SampleStatusEntityTypeConfiguration : IEntityTypeConfiguration<SampleStatus>
+{
+    public void Configure(EntityTypeBuilder<SampleStatus> builder)
+    {
+        // EN: Table name / VI: Tên bảng
+        builder.ToTable("sample_statuses");
+
+        // EN: Primary key / VI: Khóa chính
+        builder.HasKey(s => s.Id);
+
+        builder.Property(s => s.Id)
+            .HasColumnName("id")
+            .ValueGeneratedNever()
+            .IsRequired();
+
+        builder.Property(s => s.Name)
+            .HasColumnName("name")
+            .HasMaxLength(50)
+            .IsRequired();
+
+        // EN: Seed initial data / VI: Seed dữ liệu ban đầu
+        builder.HasData(
+            SampleStatus.Draft,
+            SampleStatus.Active,
+            SampleStatus.Completed,
+            SampleStatus.Cancelled
+        );
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/FnbEngine.Infrastructure.csproj
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/FnbEngine.Infrastructure.csproj
@@ -0,0 +1,36 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <AssemblyName>MyService.Infrastructure</AssemblyName>
+    <RootNamespace>MyService.Infrastructure</RootNamespace>
+    <Description>Infrastructure layer for data access and external services</Description>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <!-- EN: Entity Framework Core with PostgreSQL / VI: Entity Framework Core với PostgreSQL -->
+    <PackageReference Include="Microsoft.EntityFrameworkCore" Version="10.0.0" />
+    <PackageReference Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="10.0.0" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="10.0.0">
+      <PrivateAssets>all</PrivateAssets>
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+    </PackageReference>
+    
+    <!-- EN: MediatR for dispatching domain events / VI: MediatR để dispatch domain events -->
+    <PackageReference Include="MediatR" Version="12.4.1" />
+    
+    <!-- EN: Dapper for read-optimized queries / VI: Dapper cho queries tối ưu đọc -->
+    <PackageReference Include="Dapper" Version="2.1.35" />
+    
+    <!-- EN: Resilience with Polly / VI: Resilience với Polly -->
+    <PackageReference Include="Microsoft.Extensions.Http.Polly" Version="9.0.0" />
+    <PackageReference Include="Polly" Version="8.5.0" />
+    
+    <!-- EN: Redis cache / VI: Redis cache -->
+    <PackageReference Include="StackExchange.Redis" Version="2.8.16" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\MyService.Domain\MyService.Domain.csproj" />
+  </ItemGroup>
+
+</Project>
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/Idempotency/ClientRequest.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/Idempotency/ClientRequest.cs
@@ -0,0 +1,26 @@
+namespace MyService.Infrastructure.Idempotency;
+
+/// <summary>
+/// EN: Entity for tracking client requests to ensure idempotency.
+/// VI: Entity để theo dõi các requests từ client đảm bảo idempotency.
+/// </summary>
+public class ClientRequest
+{
+    /// <summary>
+    /// EN: Unique request identifier.
+    /// VI: Định danh request duy nhất.
+    /// </summary>
+    public Guid Id { get; set; }
+
+    /// <summary>
+    /// EN: Name of the command/request type.
+    /// VI: Tên của loại command/request.
+    /// </summary>
+    public string Name { get; set; } = null!;
+
+    /// <summary>
+    /// EN: Timestamp when the request was received.
+    /// VI: Thời điểm request được nhận.
+    /// </summary>
+    public DateTime Time { get; set; }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/Idempotency/IRequestManager.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/Idempotency/IRequestManager.cs
@@ -0,0 +1,24 @@
+namespace MyService.Infrastructure.Idempotency;
+
+/// <summary>
+/// EN: Interface for managing client request idempotency.
+/// VI: Interface để quản lý idempotency của client requests.
+/// </summary>
+public interface IRequestManager
+{
+    /// <summary>
+    /// EN: Check if a request with the given ID exists.
+    /// VI: Kiểm tra xem request với ID cho trước có tồn tại không.
+    /// </summary>
+    /// <param name="id">EN: Request ID / VI: ID của request</param>
+    /// <returns>EN: True if exists / VI: True nếu tồn tại</returns>
+    Task<bool> ExistAsync(Guid id);
+
+    /// <summary>
+    /// EN: Create a new request record for tracking.
+    /// VI: Tạo bản ghi request mới để theo dõi.
+    /// </summary>
+    /// <typeparam name="T">EN: Command type / VI: Loại command</typeparam>
+    /// <param name="id">EN: Request ID / VI: ID của request</param>
+    Task CreateRequestForCommandAsync<T>(Guid id);
+}
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/Idempotency/RequestManager.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/Idempotency/RequestManager.cs
@@ -0,0 +1,45 @@
+using Microsoft.EntityFrameworkCore;
+
+namespace MyService.Infrastructure.Idempotency;
+
+/// <summary>
+/// EN: Implementation of request manager for idempotency.
+/// VI: Triển khai request manager cho idempotency.
+/// </summary>
+public class RequestManager : IRequestManager
+{
+    private readonly MyServiceContext _context;
+
+    public RequestManager(MyServiceContext context)
+    {
+        _context = context ?? throw new ArgumentNullException(nameof(context));
+    }
+
+    /// <inheritdoc/>
+    public async Task<bool> ExistAsync(Guid id)
+    {
+        var request = await _context
+            .FindAsync<ClientRequest>(id);
+
+        return request != null;
+    }
+
+    /// <inheritdoc/>
+    public async Task CreateRequestForCommandAsync<T>(Guid id)
+    {
+        var exists = await ExistAsync(id);
+
+        var request = exists
+            ? throw new InvalidOperationException($"Request with {id} already exists")
+            : new ClientRequest
+            {
+                Id = id,
+                Name = typeof(T).Name,
+                Time = DateTime.UtcNow
+            };
+
+        _context.Add(request);
+
+        await _context.SaveChangesAsync();
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/MyServiceContext.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/MyServiceContext.cs
@@ -0,0 +1,160 @@
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Storage;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+using MyService.Domain.SeedWork;
+using MyService.Infrastructure.EntityConfigurations;
+
+namespace MyService.Infrastructure;
+
+/// <summary>
+/// EN: EF Core DbContext for MyService.
+/// VI: EF Core DbContext cho MyService.
+/// </summary>
+public class MyServiceContext : DbContext, IUnitOfWork
+{
+    private readonly IMediator _mediator;
+    private IDbContextTransaction? _currentTransaction;
+
+    /// <summary>
+    /// EN: Samples table.
+    /// VI: Bảng Samples.
+    /// </summary>
+    public DbSet<Sample> Samples => Set<Sample>();
+
+    /// <summary>
+    /// EN: Read-only access to current transaction.
+    /// VI: Truy cập chỉ đọc đến transaction hiện tại.
+    /// </summary>
+    public IDbContextTransaction? CurrentTransaction => _currentTransaction;
+
+    /// <summary>
+    /// EN: Check if there is an active transaction.
+    /// VI: Kiểm tra xem có transaction đang hoạt động không.
+    /// </summary>
+    public bool HasActiveTransaction => _currentTransaction != null;
+
+    public MyServiceContext(DbContextOptions<MyServiceContext> options) : base(options)
+    {
+        _mediator = null!;
+    }
+
+    public MyServiceContext(DbContextOptions<MyServiceContext> options, IMediator mediator) : base(options)
+    {
+        _mediator = mediator ?? throw new ArgumentNullException(nameof(mediator));
+
+        System.Diagnostics.Debug.WriteLine("MyServiceContext::ctor - " + GetHashCode());
+    }
+
+    protected override void OnModelCreating(ModelBuilder modelBuilder)
+    {
+        // EN: Apply entity configurations
+        // VI: Áp dụng các cấu hình entity
+        modelBuilder.ApplyConfiguration(new SampleEntityTypeConfiguration());
+        modelBuilder.ApplyConfiguration(new SampleStatusEntityTypeConfiguration());
+    }
+
+    /// <summary>
+    /// EN: Save entities and dispatch domain events.
+    /// VI: Lưu entities và dispatch domain events.
+    /// </summary>
+    public async Task<bool> SaveEntitiesAsync(CancellationToken cancellationToken = default)
+    {
+        // EN: Dispatch domain events before saving (side effects)
+        // VI: Dispatch domain events trước khi lưu (side effects)
+        await DispatchDomainEventsAsync();
+
+        // EN: Save changes to database
+        // VI: Lưu thay đổi vào database
+        await base.SaveChangesAsync(cancellationToken);
+
+        return true;
+    }
+
+    /// <summary>
+    /// EN: Begin a new transaction if none is active.
+    /// VI: Bắt đầu một transaction mới nếu không có transaction nào đang hoạt động.
+    /// </summary>
+    public async Task<IDbContextTransaction?> BeginTransactionAsync()
+    {
+        if (_currentTransaction != null) return null;
+
+        _currentTransaction = await Database.BeginTransactionAsync(System.Data.IsolationLevel.ReadCommitted);
+
+        return _currentTransaction;
+    }
+
+    /// <summary>
+    /// EN: Commit the current transaction.
+    /// VI: Commit transaction hiện tại.
+    /// </summary>
+    public async Task CommitTransactionAsync(IDbContextTransaction transaction)
+    {
+        ArgumentNullException.ThrowIfNull(transaction);
+
+        if (transaction != _currentTransaction)
+            throw new InvalidOperationException($"Transaction {transaction.TransactionId} is not current");
+
+        try
+        {
+            await SaveChangesAsync();
+            await transaction.CommitAsync();
+        }
+        catch
+        {
+            RollbackTransaction();
+            throw;
+        }
+        finally
+        {
+            if (_currentTransaction != null)
+            {
+                _currentTransaction.Dispose();
+                _currentTransaction = null;
+            }
+        }
+    }
+
+    /// <summary>
+    /// EN: Rollback the current transaction.
+    /// VI: Rollback transaction hiện tại.
+    /// </summary>
+    public void RollbackTransaction()
+    {
+        try
+        {
+            _currentTransaction?.Rollback();
+        }
+        finally
+        {
+            if (_currentTransaction != null)
+            {
+                _currentTransaction.Dispose();
+                _currentTransaction = null;
+            }
+        }
+    }
+
+    /// <summary>
+    /// EN: Dispatch all domain events from tracked entities.
+    /// VI: Dispatch tất cả domain events từ các entities đang được track.
+    /// </summary>
+    private async Task DispatchDomainEventsAsync()
+    {
+        var domainEntities = ChangeTracker
+            .Entries<Entity>()
+            .Where(x => x.Entity.DomainEvents.Any())
+            .ToList();
+
+        var domainEvents = domainEntities
+            .SelectMany(x => x.Entity.DomainEvents)
+            .ToList();
+
+        domainEntities.ForEach(entity => entity.Entity.ClearDomainEvents());
+
+        foreach (var domainEvent in domainEvents)
+        {
+            await _mediator.Publish(domainEvent);
+        }
+    }
+}
--- a/services/fnb-engine-net/src/FnbEngine.Infrastructure/Repositories/SampleRepository.cs
+++ b/services/fnb-engine-net/src/FnbEngine.Infrastructure/Repositories/SampleRepository.cs
@@ -0,0 +1,72 @@
+using Microsoft.EntityFrameworkCore;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+using MyService.Domain.SeedWork;
+
+namespace MyService.Infrastructure.Repositories;
+
+/// <summary>
+/// EN: Repository implementation for Sample aggregate.
+/// VI: Triển khai repository cho Sample aggregate.
+/// </summary>
+public class SampleRepository : ISampleRepository
+{
+    private readonly MyServiceContext _context;
+
+    /// <summary>
+    /// EN: Unit of work for transaction management.
+    /// VI: Unit of work cho quản lý transaction.
+    /// </summary>
+    public IUnitOfWork UnitOfWork => _context;
+
+    public SampleRepository(MyServiceContext context)
+    {
+        _context = context ?? throw new ArgumentNullException(nameof(context));
+    }
+
+    /// <inheritdoc/>
+    public async Task<Sample?> GetAsync(Guid sampleId)
+    {
+        var sample = await _context.Samples
+            .Include(s => s.Status)
+            .FirstOrDefaultAsync(s => s.Id == sampleId);
+
+        return sample;
+    }
+
+    /// <inheritdoc/>
+    public async Task<IEnumerable<Sample>> GetAllAsync()
+    {
+        return await _context.Samples
+            .Include(s => s.Status)
+            .OrderByDescending(s => s.CreatedAt)
+            .ToListAsync();
+    }
+
+    /// <inheritdoc/>
+    public Sample Add(Sample sample)
+    {
+        return _context.Samples.Add(sample).Entity;
+    }
+
+    /// <inheritdoc/>
+    public void Update(Sample sample)
+    {
+        _context.Entry(sample).State = EntityState.Modified;
+    }
+
+    /// <inheritdoc/>
+    public void Delete(Sample sample)
+    {
+        _context.Samples.Remove(sample);
+    }
+
+    /// <inheritdoc/>
+    public async Task<IEnumerable<Sample>> GetByStatusAsync(int statusId)
+    {
+        return await _context.Samples
+            .Include(s => s.Status)
+            .Where(s => s.StatusId == statusId)
+            .OrderByDescending(s => s.CreatedAt)
+            .ToListAsync();
+    }
+}
--- a/services/fnb-engine-net/tests/FnbEngine.FunctionalTests/Controllers/SamplesControllerTests.cs
+++ b/services/fnb-engine-net/tests/FnbEngine.FunctionalTests/Controllers/SamplesControllerTests.cs
@@ -0,0 +1,80 @@
+using System.Net;
+using System.Net.Http.Json;
+using FluentAssertions;
+using Microsoft.AspNetCore.Mvc.Testing;
+using Xunit;
+
+namespace MyService.FunctionalTests.Controllers;
+
+/// <summary>
+/// EN: Functional tests for Samples API endpoints.
+/// VI: Functional tests cho các endpoints API Samples.
+/// </summary>
+public class SamplesControllerTests : IClassFixture<CustomWebApplicationFactory>
+{
+    private readonly HttpClient _client;
+
+    public SamplesControllerTests(CustomWebApplicationFactory factory)
+    {
+        _client = factory.CreateClient(new WebApplicationFactoryClientOptions
+        {
+            AllowAutoRedirect = false
+        });
+    }
+
+    [Fact]
+    public async Task GetSamples_ShouldReturnOkWithEmptyList()
+    {
+        // Act
+        var response = await _client.GetAsync("/api/v1/samples");
+
+        // Assert
+        response.StatusCode.Should().Be(HttpStatusCode.OK);
+        var content = await response.Content.ReadFromJsonAsync<ApiResponse<List<object>>>();
+        content?.Success.Should().BeTrue();
+    }
+
+    [Fact]
+    public async Task CreateSample_WithValidData_ShouldReturnCreated()
+    {
+        // Arrange
+        var request = new { Name = "Test Sample", Description = "Test Description" };
+
+        // Act
+        var response = await _client.PostAsJsonAsync("/api/v1/samples", request);
+
+        // Assert
+        response.StatusCode.Should().Be(HttpStatusCode.Created);
+        var content = await response.Content.ReadFromJsonAsync<ApiResponse<CreateSampleResult>>();
+        content?.Success.Should().BeTrue();
+        content?.Data?.Id.Should().NotBeEmpty();
+    }
+
+    [Fact]
+    public async Task GetSample_WithInvalidId_ShouldReturnNotFound()
+    {
+        // Arrange
+        var invalidId = Guid.NewGuid();
+
+        // Act
+        var response = await _client.GetAsync($"/api/v1/samples/{invalidId}");
+
+        // Assert
+        response.StatusCode.Should().Be(HttpStatusCode.NotFound);
+    }
+
+    [Fact]
+    public async Task HealthCheck_ShouldReturnHealthy()
+    {
+        // Act
+        var response = await _client.GetAsync("/health/live");
+
+        // Assert
+        response.StatusCode.Should().Be(HttpStatusCode.OK);
+    }
+
+    // EN: Helper DTOs for deserialization
+    // VI: Helper DTOs để deserialize
+    private record ApiResponse<T>(bool Success, T? Data);
+    private record CreateSampleResult(Guid Id);
+}
--- a/services/fnb-engine-net/tests/FnbEngine.FunctionalTests/CustomWebApplicationFactory.cs
+++ b/services/fnb-engine-net/tests/FnbEngine.FunctionalTests/CustomWebApplicationFactory.cs
@@ -0,0 +1,56 @@
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.AspNetCore.Mvc.Testing;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.DependencyInjection;
+using MyService.Infrastructure;
+
+namespace MyService.FunctionalTests;
+
+/// <summary>
+/// EN: Custom WebApplicationFactory for functional tests.
+/// VI: WebApplicationFactory tùy chỉnh cho functional tests.
+/// </summary>
+public class CustomWebApplicationFactory : WebApplicationFactory<Program>
+{
+    protected override void ConfigureWebHost(IWebHostBuilder builder)
+    {
+        builder.UseEnvironment("Testing");
+        
+        builder.ConfigureServices(services =>
+        {
+            // EN: Remove the existing DbContext registration
+            // VI: Xóa đăng ký DbContext hiện tại
+            var descriptor = services.SingleOrDefault(
+                d => d.ServiceType == typeof(DbContextOptions<MyServiceContext>));
+
+            if (descriptor != null)
+            {
+                services.Remove(descriptor);
+            }
+
+            // EN: Remove DbContext service
+            // VI: Xóa DbContext service
+            var dbContextDescriptor = services.SingleOrDefault(
+                d => d.ServiceType == typeof(MyServiceContext));
+
+            if (dbContextDescriptor != null)
+            {
+                services.Remove(dbContextDescriptor);
+            }
+
+            // EN: Add in-memory database for testing
+            // VI: Thêm in-memory database để test
+            services.AddDbContext<MyServiceContext>(options =>
+            {
+                options.UseInMemoryDatabase("TestDatabase_" + Guid.NewGuid().ToString());
+            });
+
+            // EN: Ensure database is created with seed data
+            // VI: Đảm bảo database được tạo với seed data
+            var sp = services.BuildServiceProvider();
+            using var scope = sp.CreateScope();
+            var db = scope.ServiceProvider.GetRequiredService<MyServiceContext>();
+            db.Database.EnsureCreated();
+        });
+    }
+}
--- a/services/fnb-engine-net/tests/FnbEngine.FunctionalTests/MyService.FunctionalTests.csproj
+++ b/services/fnb-engine-net/tests/FnbEngine.FunctionalTests/MyService.FunctionalTests.csproj
@@ -0,0 +1,38 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <AssemblyName>MyService.FunctionalTests</AssemblyName>
+    <RootNamespace>MyService.FunctionalTests</RootNamespace>
+    <IsPackable>false</IsPackable>
+    <IsTestProject>true</IsTestProject>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <!-- EN: Test framework / VI: Test framework -->
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.12.0" />
+    <PackageReference Include="xunit" Version="2.9.2" />
+    <PackageReference Include="xunit.runner.visualstudio" Version="2.8.2">
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+      <PrivateAssets>all</PrivateAssets>
+    </PackageReference>
+    
+    <!-- EN: Integration testing / VI: Integration testing -->
+    <PackageReference Include="Microsoft.AspNetCore.Mvc.Testing" Version="10.0.0" />
+    <PackageReference Include="Microsoft.EntityFrameworkCore.InMemory" Version="10.0.0" />
+    <PackageReference Include="FluentAssertions" Version="6.12.2" />
+    
+    <!-- EN: Test containers for database / VI: Test containers cho database -->
+    <PackageReference Include="Testcontainers.PostgreSql" Version="4.1.0" />
+    
+    <!-- EN: Coverage / VI: Coverage -->
+    <PackageReference Include="coverlet.collector" Version="6.0.2">
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+      <PrivateAssets>all</PrivateAssets>
+    </PackageReference>
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\src\MyService.API\MyService.API.csproj" />
+  </ItemGroup>
+
+</Project>
--- a/services/fnb-engine-net/tests/FnbEngine.UnitTests/Application/CreateSampleCommandHandlerTests.cs
+++ b/services/fnb-engine-net/tests/FnbEngine.UnitTests/Application/CreateSampleCommandHandlerTests.cs
@@ -0,0 +1,65 @@
+using FluentAssertions;
+using Microsoft.Extensions.Logging;
+using Moq;
+using MyService.API.Application.Commands;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+using MyService.Domain.SeedWork;
+using Xunit;
+
+namespace MyService.UnitTests.Application;
+
+/// <summary>
+/// EN: Unit tests for CreateSampleCommandHandler.
+/// VI: Unit tests cho CreateSampleCommandHandler.
+/// </summary>
+public class CreateSampleCommandHandlerTests
+{
+    private readonly Mock<ISampleRepository> _mockRepository;
+    private readonly Mock<ILogger<CreateSampleCommandHandler>> _mockLogger;
+    private readonly CreateSampleCommandHandler _handler;
+
+    public CreateSampleCommandHandlerTests()
+    {
+        _mockRepository = new Mock<ISampleRepository>();
+        _mockLogger = new Mock<ILogger<CreateSampleCommandHandler>>();
+
+        var mockUnitOfWork = new Mock<IUnitOfWork>();
+        mockUnitOfWork.Setup(u => u.SaveEntitiesAsync(It.IsAny<CancellationToken>()))
+            .ReturnsAsync(true);
+
+        _mockRepository.SetupGet(r => r.UnitOfWork).Returns(mockUnitOfWork.Object);
+
+        _handler = new CreateSampleCommandHandler(_mockRepository.Object, _mockLogger.Object);
+    }
+
+    [Fact]
+    public async Task Handle_WithValidCommand_ShouldCreateSampleAndReturnId()
+    {
+        // Arrange
+        var command = new CreateSampleCommand("Test Sample", "Test Description");
+
+        _mockRepository.Setup(r => r.Add(It.IsAny<Sample>()))
+            .Returns((Sample s) => s);
+
+        // Act
+        var result = await _handler.Handle(command, CancellationToken.None);
+
+        // Assert
+        result.Should().NotBeNull();
+        result.Id.Should().NotBeEmpty();
+        _mockRepository.Verify(r => r.Add(It.IsAny<Sample>()), Times.Once);
+    }
+
+    [Fact]
+    public async Task Handle_WithValidCommand_ShouldCallSaveEntities()
+    {
+        // Arrange
+        var command = new CreateSampleCommand("Test Sample", null);
+
+        // Act
+        await _handler.Handle(command, CancellationToken.None);
+
+        // Assert
+        _mockRepository.Verify(r => r.UnitOfWork.SaveEntitiesAsync(It.IsAny<CancellationToken>()), Times.Once);
+    }
+}
--- a/services/fnb-engine-net/tests/FnbEngine.UnitTests/Domain/SampleAggregateTests.cs
+++ b/services/fnb-engine-net/tests/FnbEngine.UnitTests/Domain/SampleAggregateTests.cs
@@ -0,0 +1,151 @@
+using FluentAssertions;
+using MyService.Domain.AggregatesModel.SampleAggregate;
+using MyService.Domain.Exceptions;
+using Xunit;
+
+namespace MyService.UnitTests.Domain;
+
+/// <summary>
+/// EN: Unit tests for Sample aggregate.
+/// VI: Unit tests cho Sample aggregate.
+/// </summary>
+public class SampleAggregateTests
+{
+    [Fact]
+    public void CreateSample_WithValidName_ShouldCreateWithDraftStatus()
+    {
+        // Arrange
+        var name = "Test Sample";
+        var description = "Test Description";
+
+        // Act
+        var sample = new Sample(name, description);
+
+        // Assert
+        sample.Name.Should().Be(name);
+        sample.Description.Should().Be(description);
+        sample.Status.Should().Be(SampleStatus.Draft);
+        sample.Id.Should().NotBeEmpty();
+        sample.DomainEvents.Should().ContainSingle(); // SampleCreatedDomainEvent
+    }
+
+    [Fact]
+    public void CreateSample_WithEmptyName_ShouldThrowException()
+    {
+        // Arrange
+        var name = "";
+
+        // Act
+        var act = () => new Sample(name);
+
+        // Assert
+        act.Should().Throw<SampleDomainException>()
+            .WithMessage("Sample name cannot be empty");
+    }
+
+    [Fact]
+    public void Activate_WhenDraft_ShouldChangeToActive()
+    {
+        // Arrange
+        var sample = new Sample("Test Sample");
+        sample.ClearDomainEvents();
+
+        // Act
+        sample.Activate();
+
+        // Assert
+        sample.Status.Should().Be(SampleStatus.Active);
+        sample.DomainEvents.Should().ContainSingle(); // SampleStatusChangedDomainEvent
+    }
+
+    [Fact]
+    public void Activate_WhenNotDraft_ShouldThrowException()
+    {
+        // Arrange
+        var sample = new Sample("Test Sample");
+        sample.Activate();
+
+        // Act
+        var act = () => sample.Activate();
+
+        // Assert
+        act.Should().Throw<SampleDomainException>()
+            .WithMessage("Only draft samples can be activated");
+    }
+
+    [Fact]
+    public void Complete_WhenActive_ShouldChangeToCompleted()
+    {
+        // Arrange
+        var sample = new Sample("Test Sample");
+        sample.Activate();
+        sample.ClearDomainEvents();
+
+        // Act
+        sample.Complete();
+
+        // Assert
+        sample.Status.Should().Be(SampleStatus.Completed);
+    }
+
+    [Fact]
+    public void Cancel_WhenDraftOrActive_ShouldChangeToCancelled()
+    {
+        // Arrange
+        var sample = new Sample("Test Sample");
+
+        // Act
+        sample.Cancel();
+
+        // Assert
+        sample.Status.Should().Be(SampleStatus.Cancelled);
+    }
+
+    [Fact]
+    public void Cancel_WhenCompleted_ShouldThrowException()
+    {
+        // Arrange
+        var sample = new Sample("Test Sample");
+        sample.Activate();
+        sample.Complete();
+
+        // Act
+        var act = () => sample.Cancel();
+
+        // Assert
+        act.Should().Throw<SampleDomainException>()
+            .WithMessage("Cannot cancel a completed sample");
+    }
+
+    [Fact]
+    public void Update_WhenNotCancelled_ShouldUpdateNameAndDescription()
+    {
+        // Arrange
+        var sample = new Sample("Original Name", "Original Description");
+        var newName = "Updated Name";
+        var newDescription = "Updated Description";
+
+        // Act
+        sample.Update(newName, newDescription);
+
+        // Assert
+        sample.Name.Should().Be(newName);
+        sample.Description.Should().Be(newDescription);
+        sample.UpdatedAt.Should().NotBeNull();
+    }
+
+    [Fact]
+    public void Update_WhenCancelled_ShouldThrowException()
+    {
+        // Arrange
+        var sample = new Sample("Test Sample");
+        sample.Cancel();
+
+        // Act
+        var act = () => sample.Update("New Name", null);
+
+        // Assert
+        act.Should().Throw<SampleDomainException>()
+            .WithMessage("Cannot update a cancelled sample");
+    }
+}
--- a/services/fnb-engine-net/tests/FnbEngine.UnitTests/MyService.UnitTests.csproj
+++ b/services/fnb-engine-net/tests/FnbEngine.UnitTests/MyService.UnitTests.csproj
@@ -0,0 +1,35 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <AssemblyName>MyService.UnitTests</AssemblyName>
+    <RootNamespace>MyService.UnitTests</RootNamespace>
+    <IsPackable>false</IsPackable>
+    <IsTestProject>true</IsTestProject>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <!-- EN: Test framework / VI: Test framework -->
+    <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.12.0" />
+    <PackageReference Include="xunit" Version="2.9.2" />
+    <PackageReference Include="xunit.runner.visualstudio" Version="2.8.2">
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+      <PrivateAssets>all</PrivateAssets>
+    </PackageReference>
+    
+    <!-- EN: Assertions and mocking / VI: Assertions và mocking -->
+    <PackageReference Include="FluentAssertions" Version="6.12.2" />
+    <PackageReference Include="Moq" Version="4.20.72" />
+    
+    <!-- EN: Coverage / VI: Coverage -->
+    <PackageReference Include="coverlet.collector" Version="6.0.2">
+      <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
+      <PrivateAssets>all</PrivateAssets>
+    </PackageReference>
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\src\MyService.Domain\MyService.Domain.csproj" />
+    <ProjectReference Include="..\..\src\MyService.API\MyService.API.csproj" />
+  </ItemGroup>
+
+</Project>