diff --git a/apps/web-client-base-net/Dockerfile b/apps/web-client-base-net/Dockerfile new file mode 100644 index 00000000..567f5364 --- /dev/null +++ b/apps/web-client-base-net/Dockerfile @@ -0,0 +1,66 @@ +# ═══════════════════════════════════════════════════════════════════════════════ +# WebClientBase Dockerfile +# EN: Multi-stage build for Blazor WebAssembly Hosted +# VI: Multi-stage build cho Blazor WebAssembly Hosted +# ═══════════════════════════════════════════════════════════════════════════════ + +# ═══════════════════════════════════════════════════════════════════════════════ +# Stage 1: Build +# ═══════════════════════════════════════════════════════════════════════════════ +FROM mcr.microsoft.com/dotnet/sdk:10.0-alpine AS build +WORKDIR /src + +# EN: Copy solution and project files for layer caching +# VI: Copy solution và project files để cache layers +COPY WebClientBase.slnx ./ +COPY src/WebClientBase.Shared/WebClientBase.Shared.csproj ./src/WebClientBase.Shared/ +COPY src/WebClientBase.Client/WebClientBase.Client.csproj ./src/WebClientBase.Client/ +COPY src/WebClientBase.Server/WebClientBase.Server.csproj ./src/WebClientBase.Server/ + +# EN: Restore dependencies +# VI: Restore dependencies +RUN dotnet restore + +# EN: Copy source code +# VI: Copy source code +COPY . . + +# EN: Build and publish +# VI: Build và publish +RUN dotnet publish src/WebClientBase.Server/WebClientBase.Server.csproj \ + -c Release \ + -o /app/publish \ + --no-restore + +# ═══════════════════════════════════════════════════════════════════════════════ +# Stage 2: Runtime +# ═══════════════════════════════════════════════════════════════════════════════ +FROM mcr.microsoft.com/dotnet/aspnet:10.0-alpine AS runtime +WORKDIR /app + +# EN: Create non-root user for security +# VI: Tạo user không phải root để bảo mật +RUN adduser -D -u 1000 appuser && chown -R appuser /app +USER appuser + +# EN: Copy published output +# VI: Copy output đã publish +COPY --from=build /app/publish . + +# EN: Expose port +# VI: Expose port +EXPOSE 8080 + +# EN: Health check +# VI: Health check +HEALTHCHECK --interval=30s --timeout=3s --start-period=5s --retries=3 \ + CMD wget --no-verbose --tries=1 --spider http://localhost:8080/health || exit 1 + +# 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: Run the application +# VI: Chạy ứng dụng +ENTRYPOINT ["dotnet", "WebClientBase.Server.dll"] diff --git a/apps/web-client-base-net/README.md b/apps/web-client-base-net/README.md new file mode 100644 index 00000000..b75aaebd --- /dev/null +++ b/apps/web-client-base-net/README.md @@ -0,0 +1,116 @@ +# WebClientBase - Blazor Web App .NET 10 + +Base frontend web application cho GoodGo Platform được xây dựng với Blazor WebAssembly Hosted. + +## Features / Tính năng + +- **Blazor WebAssembly Hosted** - Client chạy trong browser, Server host API +- **Shared Library Pattern** - DTOs và Validation được chia sẻ giữa Client và Server +- **Data Annotations Validation** - Viết 1 lần, dùng chung cả 2 đầu +- **[ApiController] Auto-Validation** - Server tự động validate, không cần `if (!ModelState.IsValid)` +- **Dark/Light Mode** - CSS variables với theme toggle +- **Glassmorphism UI** - Modern design với backdrop blur và shadows + +## Tech Stack + +| Layer | Technology | +|-------|------------| +| Client | Blazor WebAssembly (.NET 10) | +| Server | ASP.NET Core Web API (.NET 10) | +| Shared | Class Library với Data Annotations | +| Styling | CSS Variables, Dark Mode | + +## Project Structure / Cấu trúc dự án + +``` +web-client-base-net/ +├── WebClientBase.slnx # Solution file +├── src/ +│ ├── WebClientBase.Client/ # Blazor WebAssembly +│ │ ├── Layout/ # MainLayout, NavMenu +│ │ ├── Pages/ # Razor pages (Products, Auth) +│ │ └── wwwroot/css/ # Design System CSS +│ ├── WebClientBase.Server/ # ASP.NET Core Host +│ │ └── Controllers/ # API Controllers +│ └── WebClientBase.Shared/ # Shared Library +│ └── DTOs/ # Data Transfer Objects +└── Dockerfile +``` + +## Getting Started / Bắt đầu + +```bash +# Navigate to project +cd apps/web-client-base-net + +# Restore packages +dotnet restore + +# Run Server (hosts both API and Blazor client) +dotnet run --project src/WebClientBase.Server + +# Open browser +# https://localhost:5001 hoặc http://localhost:5000 +``` + +## Shared Validation Pattern / Mẫu Validation Chia Sẻ + +### 1. Define DTO with Validation (một lần) +```csharp +// WebClientBase.Shared/DTOs/ProductDto.cs +public class ProductDto +{ + [Required(ErrorMessage = "Tên là bắt buộc / Name is required")] + [StringLength(100, MinimumLength = 3)] + public string Name { get; set; } = string.Empty; + + [Range(0.01, 1_000_000)] + public decimal Price { get; set; } +} +``` + +### 2. Server (Auto-validation với [ApiController]) +```csharp +[ApiController] +[Route("api/[controller]")] +public class ProductsController : ControllerBase +{ + [HttpPost] + public IActionResult Create(ProductDto request) + { + // Không cần if (!ModelState.IsValid) - [ApiController] đã làm hộ + return Ok(ApiResponse.Ok(request)); + } +} +``` + +### 3. Client (DataAnnotationsValidator) +```razor + + + + + + + + + +``` + +## API Endpoints + +| Method | Endpoint | Description | +|--------|----------|-------------| +| GET | `/api/products` | Get all products | +| POST | `/api/products` | Create product | +| PUT | `/api/products` | Update product | +| POST | `/api/auth/register` | Register user | +| POST | `/api/auth/login` | Login | +| GET | `/api/auth/profile/{id}` | Get profile | +| GET | `/health` | Health check | + +## Related Skills + +- [React Enterprise Architect](../../.agent/skills/react-enterprise-architect/SKILL.md) +- [Tailwind Design System](../../.agent/skills/tailwind-design-system/SKILL.md) +- [Project Rules](../../.agent/skills/project-rules/SKILL.md) diff --git a/apps/web-client-base-net/src/WebClientBase.Client/Layout/MainLayout.razor b/apps/web-client-base-net/src/WebClientBase.Client/Layout/MainLayout.razor index 76eb7252..ecd27001 100644 --- a/apps/web-client-base-net/src/WebClientBase.Client/Layout/MainLayout.razor +++ b/apps/web-client-base-net/src/WebClientBase.Client/Layout/MainLayout.razor @@ -1,16 +1,60 @@ @inherits LayoutComponentBase -
-
+@inject IJSRuntime JS + +@* + EN: Main layout with sidebar navigation and theme toggle. + VI: Layout chính với sidebar navigation và theme toggle. +*@ + +
+
+
-
- About -
+
+ +
-
+
@Body
+ +@code { + private string currentTheme = "light"; + + protected override async Task OnAfterRenderAsync(bool firstRender) + { + if (firstRender) + { + // EN: Load saved theme from localStorage + // VI: Tải theme đã lưu từ localStorage + var savedTheme = await JS.InvokeAsync("localStorage.getItem", "theme"); + if (!string.IsNullOrEmpty(savedTheme)) + { + currentTheme = savedTheme; + StateHasChanged(); + } + } + } + + private async Task ToggleTheme() + { + currentTheme = currentTheme == "dark" ? "light" : "dark"; + + // EN: Save theme to localStorage + // VI: Lưu theme vào localStorage + await JS.InvokeVoidAsync("localStorage.setItem", "theme", currentTheme); + } +} diff --git a/apps/web-client-base-net/src/WebClientBase.Client/Layout/NavMenu.razor b/apps/web-client-base-net/src/WebClientBase.Client/Layout/NavMenu.razor index fb102416..b11f212f 100644 --- a/apps/web-client-base-net/src/WebClientBase.Client/Layout/NavMenu.razor +++ b/apps/web-client-base-net/src/WebClientBase.Client/Layout/NavMenu.razor @@ -1,39 +1,30 @@ -
-
- WebClientBase.Client - -
+@* + EN: Navigation menu with Products and Auth links. + VI: Menu navigation với các link Products và Auth. +*@ + +
+ GoodGo
-
- -
- -@code { - private bool collapseNavMenu = true; - - private string? NavMenuCssClass => collapseNavMenu ? "collapse" : null; - - private void ToggleNavMenu() - { - collapseNavMenu = !collapseNavMenu; - } -} + diff --git a/apps/web-client-base-net/src/WebClientBase.Client/Pages/Auth.razor b/apps/web-client-base-net/src/WebClientBase.Client/Pages/Auth.razor new file mode 100644 index 00000000..e7c4ec5d --- /dev/null +++ b/apps/web-client-base-net/src/WebClientBase.Client/Pages/Auth.razor @@ -0,0 +1,201 @@ +@page "/auth" +@inject HttpClient Http +@inject NavigationManager Navigation + +@* + EN: Authentication page with Register and Login forms. + VI: Trang xác thực với form Đăng ký và Đăng nhập. +*@ + +Authentication / Xác thực + +
+
+ + +
+ + @* ═══════════════════════════════════════════════════════════════════════════════ + EN: Login Form + VI: Form đăng nhập + ═══════════════════════════════════════════════════════════════════════════════ *@ + @if (activeTab == "login") + { +
+

Welcome Back / Chào mừng trở lại

+

Sign in to your account / Đăng nhập vào tài khoản

+ + + + +
+ + + +
+ +
+ + + +
+ +
+ + +
+ + + +
+ } + + @* ═══════════════════════════════════════════════════════════════════════════════ + EN: Register Form + VI: Form đăng ký + ═══════════════════════════════════════════════════════════════════════════════ *@ + @if (activeTab == "register") + { +
+

Create Account / Tạo tài khoản

+

Join us today / Tham gia với chúng tôi

+ + + + + +
+ + + +
+ +
+ + + +
+ +
+ + + + Min 8 chars, uppercase, lowercase, digit / Tối thiểu 8 ký tự, chữ hoa, chữ thường, số +
+ +
+ + + +
+ + + +
+ } + + @if (!string.IsNullOrEmpty(message)) + { +
+ @message +
+ } +
+ +@code { + private string activeTab = "login"; + private LoginDto loginModel = new(); + private RegisterDto registerModel = new(); + private bool isSubmitting = false; + private string message = ""; + private bool success = false; + + private async Task HandleLogin() + { + isSubmitting = true; + message = ""; + + try + { + var response = await Http.PostAsJsonAsync("api/Auth/login", loginModel); + + if (response.IsSuccessStatusCode) + { + var result = await response.Content.ReadFromJsonAsync>(); + if (result?.Success == true) + { + success = true; + message = $"Welcome back, {result.Data?.DisplayName}! / Chào mừng trở lại, {result.Data?.DisplayName}!"; + } + } + else + { + success = false; + message = "Login failed. Please check your credentials. / Đăng nhập thất bại."; + } + } + catch (Exception ex) + { + success = false; + message = $"Error: {ex.Message}"; + } + finally + { + isSubmitting = false; + } + } + + private async Task HandleRegister() + { + isSubmitting = true; + message = ""; + + try + { + var response = await Http.PostAsJsonAsync("api/Auth/register", registerModel); + + if (response.IsSuccessStatusCode) + { + var result = await response.Content.ReadFromJsonAsync>(); + if (result?.Success == true) + { + success = true; + message = "Account created successfully! / Tạo tài khoản thành công!"; + activeTab = "login"; + registerModel = new(); + } + } + else + { + success = false; + var content = await response.Content.ReadAsStringAsync(); + message = $"Registration failed: {content}"; + } + } + catch (Exception ex) + { + success = false; + message = $"Error: {ex.Message}"; + } + finally + { + isSubmitting = false; + } + } +} diff --git a/apps/web-client-base-net/src/WebClientBase.Client/Pages/Products.razor b/apps/web-client-base-net/src/WebClientBase.Client/Pages/Products.razor new file mode 100644 index 00000000..c34c0d8d --- /dev/null +++ b/apps/web-client-base-net/src/WebClientBase.Client/Pages/Products.razor @@ -0,0 +1,201 @@ +@page "/products" +@inject HttpClient Http + +@* + EN: Products page demonstrating shared validation between Client and Server. + VI: Trang sản phẩm demo validation được chia sẻ giữa Client và Server. +*@ + +Products / Sản phẩm + +
+

Products Management / Quản lý sản phẩm

+ + @* ═══════════════════════════════════════════════════════════════════════════════ + EN: Create Product Form with shared validation + VI: Form tạo sản phẩm với validation được chia sẻ + ═══════════════════════════════════════════════════════════════════════════════ *@ +
+

Create Product / Tạo sản phẩm

+ + + @* EN: DataAnnotationsValidator uses the same validation rules as the Server + VI: DataAnnotationsValidator sử dụng cùng validation rules với Server *@ + + + @* EN: Display all validation errors + VI: Hiển thị tất cả lỗi validation *@ + + +
+ + + +
+ +
+ + + +
+ +
+
+ + + +
+ +
+ + + +
+
+ +
+ + + +
+ +
+ + +
+ + + @if (!string.IsNullOrEmpty(submitMessage)) + { +
+ @submitMessage +
+ } +
+ + @* ═══════════════════════════════════════════════════════════════════════════════ + EN: Product List + VI: Danh sách sản phẩm + ═══════════════════════════════════════════════════════════════════════════════ *@ +
+

Product List / Danh sách sản phẩm

+ + @if (products == null) + { +

Loading products... / Đang tải sản phẩm...

+ } + else if (!products.Any()) + { +

No products found. / Không tìm thấy sản phẩm.

+ } + else + { +
+ @foreach (var product in products) + { +
+

@product.Name

+

@(product.Description ?? "No description")

+
+ @product.Price.ToString("C") + Stock: @product.Quantity +
+
+ } +
+ } +
+
+ +@code { + private CreateProductDto newProduct = new(); + private List? products; + private bool isSubmitting = false; + private string submitMessage = ""; + private bool submitSuccess = false; + private string categoryIdString = ""; + + protected override async Task OnInitializedAsync() + { + await LoadProducts(); + } + + private async Task LoadProducts() + { + try + { + var response = await Http.GetFromJsonAsync>>("api/Products"); + if (response?.Success == true) + { + products = response.Data ?? new List(); + } + } + catch (Exception ex) + { + Console.WriteLine($"Error loading products: {ex.Message}"); + products = new List(); + } + } + + private async Task HandleSubmit() + { + isSubmitting = true; + submitMessage = ""; + + // Parse category ID + if (Guid.TryParse(categoryIdString, out var categoryId)) + { + newProduct.CategoryId = categoryId; + } + + try + { + var response = await Http.PostAsJsonAsync("api/Products", newProduct); + + if (response.IsSuccessStatusCode) + { + submitSuccess = true; + submitMessage = "Product created successfully! / Tạo sản phẩm thành công!"; + ResetForm(); + await LoadProducts(); + } + else + { + submitSuccess = false; + var content = await response.Content.ReadAsStringAsync(); + submitMessage = $"Error: {response.StatusCode} - {content}"; + } + } + catch (Exception ex) + { + submitSuccess = false; + submitMessage = $"Error: {ex.Message}"; + } + finally + { + isSubmitting = false; + } + } + + private void HandleInvalid() + { + submitMessage = "Please fix the validation errors. / Vui lòng sửa các lỗi validation."; + submitSuccess = false; + } + + private void ResetForm() + { + newProduct = new CreateProductDto(); + categoryIdString = ""; + } +} diff --git a/apps/web-client-base-net/src/WebClientBase.Client/_Imports.razor b/apps/web-client-base-net/src/WebClientBase.Client/_Imports.razor index 47f34606..592bcb8c 100644 --- a/apps/web-client-base-net/src/WebClientBase.Client/_Imports.razor +++ b/apps/web-client-base-net/src/WebClientBase.Client/_Imports.razor @@ -8,3 +8,6 @@ @using Microsoft.JSInterop @using WebClientBase.Client @using WebClientBase.Client.Layout +@using WebClientBase.Shared +@using WebClientBase.Shared.DTOs + diff --git a/apps/web-client-base-net/src/WebClientBase.Client/wwwroot/css/app.css b/apps/web-client-base-net/src/WebClientBase.Client/wwwroot/css/app.css index fe44b1d2..df578f35 100644 --- a/apps/web-client-base-net/src/WebClientBase.Client/wwwroot/css/app.css +++ b/apps/web-client-base-net/src/WebClientBase.Client/wwwroot/css/app.css @@ -1,115 +1,553 @@ -html, body { - font-family: 'Helvetica Neue', Helvetica, Arial, sans-serif; +/* ═══════════════════════════════════════════════════════════════════════════════ + WebClientBase Design System + EN: GoodGo branding with Dark/Light mode support + VI: GoodGo branding với hỗ trợ Dark/Light mode + ═══════════════════════════════════════════════════════════════════════════════ */ + +/* ═══════════════════════════════════════════════════════════════════════════════ + CSS Variables / Biến CSS + ═══════════════════════════════════════════════════════════════════════════════ */ +:root { + /* Light Mode Colors */ + --bg-primary: #ffffff; + --bg-secondary: #f5f5f7; + --bg-tertiary: #e5e5ea; + --bg-elevated: #ffffff; + + --text-primary: #1d1d1f; + --text-secondary: #6e6e73; + --text-tertiary: #8e8e93; + + --accent-primary: #3b82f6; + --accent-primary-hover: #2563eb; + --accent-success: #22c55e; + --accent-warning: #f59e0b; + --accent-error: #ef4444; + + --border-default: rgba(0, 0, 0, 0.1); + --border-strong: rgba(0, 0, 0, 0.2); + + /* Glass Effects */ + --glass-bg: rgba(255, 255, 255, 0.7); + --glass-border: rgba(255, 255, 255, 0.3); + --glass-blur: 20px; + --glass-shadow: 0 8px 32px rgba(0, 0, 0, 0.1); + + /* Brand */ + --brand-gradient: linear-gradient(135deg, #3b82f6 0%, #8b5cf6 100%); + + /* Typography */ + --font-sans: 'Inter', -apple-system, BlinkMacSystemFont, 'Segoe UI', Roboto, sans-serif; + --font-mono: 'JetBrains Mono', 'SF Mono', monospace; + + --text-xs: 0.75rem; + --text-sm: 0.875rem; + --text-base: 1rem; + --text-lg: 1.125rem; + --text-xl: 1.25rem; + --text-2xl: 1.5rem; + --text-3xl: 1.875rem; + + /* Spacing */ + --space-1: 0.25rem; + --space-2: 0.5rem; + --space-3: 0.75rem; + --space-4: 1rem; + --space-6: 1.5rem; + --space-8: 2rem; + --space-12: 3rem; + + /* Border Radius */ + --radius-sm: 0.25rem; + --radius-md: 0.5rem; + --radius-lg: 0.75rem; + --radius-xl: 1rem; + --radius-full: 9999px; + + /* Transitions */ + --transition-fast: 150ms ease; + --transition-normal: 250ms ease; + + /* Sidebar */ + --sidebar-width: 280px; } -h1:focus { - outline: none; +/* Dark Mode */ +[data-theme="dark"] { + --bg-primary: #000000; + --bg-secondary: #1c1c1e; + --bg-tertiary: #2c2c2e; + --bg-elevated: #1c1c1e; + + --text-primary: #f5f5f7; + --text-secondary: #a1a1a6; + --text-tertiary: #6e6e73; + + --border-default: rgba(255, 255, 255, 0.1); + --border-strong: rgba(255, 255, 255, 0.2); + + --glass-bg: rgba(28, 28, 30, 0.8); + --glass-border: rgba(255, 255, 255, 0.1); + --glass-shadow: 0 8px 32px rgba(0, 0, 0, 0.4); } -a, .btn-link { - color: #0071c1; +/* ═══════════════════════════════════════════════════════════════════════════════ + Base Styles + ═══════════════════════════════════════════════════════════════════════════════ */ +*, +*::before, +*::after { + box-sizing: border-box; } -.btn-primary { - color: #fff; - background-color: #1b6ec2; - border-color: #1861ac; +html { + font-size: 16px; + -webkit-font-smoothing: antialiased; + -moz-osx-font-smoothing: grayscale; } -.btn:focus, .btn:active:focus, .btn-link.nav-link:focus, .form-control:focus, .form-check-input:focus { - box-shadow: 0 0 0 0.1rem white, 0 0 0 0.25rem #258cfb; +body { + font-family: var(--font-sans); + background: var(--bg-primary); + color: var(--text-primary); + margin: 0; + padding: 0; + line-height: 1.5; + transition: background-color var(--transition-normal), color var(--transition-normal); +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Layout + ═══════════════════════════════════════════════════════════════════════════════ */ +.page { + display: flex; + min-height: 100vh; +} + +.sidebar { + width: var(--sidebar-width); + background: var(--bg-secondary); + border-right: 1px solid var(--border-default); + display: flex; + flex-direction: column; +} + +main { + flex: 1; + display: flex; + flex-direction: column; +} + +.top-row { + background: var(--bg-elevated); + border-bottom: 1px solid var(--border-default); + padding: var(--space-4); + display: flex; + justify-content: flex-end; + align-items: center; + gap: var(--space-4); } .content { - padding-top: 1.1rem; + flex: 1; + padding: var(--space-6); + overflow-y: auto; } -.valid.modified:not([type=checkbox]) { - outline: 1px solid #26b050; +.container { + max-width: 1200px; + margin: 0 auto; } -.invalid { - outline: 1px solid red; +/* ═══════════════════════════════════════════════════════════════════════════════ + Navigation + ═══════════════════════════════════════════════════════════════════════════════ */ +.nav-brand { + padding: var(--space-6) var(--space-4); + font-size: var(--text-xl); + font-weight: 700; + background: var(--brand-gradient); + -webkit-background-clip: text; + -webkit-text-fill-color: transparent; + background-clip: text; } -.validation-message { - color: red; +.nav-menu { + padding: var(--space-4); } -#blazor-error-ui { - color-scheme: light only; - background: lightyellow; - bottom: 0; - box-shadow: 0 -1px 2px rgba(0, 0, 0, 0.2); - box-sizing: border-box; - display: none; - left: 0; - padding: 0.6rem 1.25rem 0.7rem 1.25rem; - position: fixed; - width: 100%; - z-index: 1000; +.nav-link { + display: flex; + align-items: center; + gap: var(--space-3); + padding: var(--space-3) var(--space-4); + color: var(--text-secondary); + text-decoration: none; + border-radius: var(--radius-lg); + transition: all var(--transition-fast); } - #blazor-error-ui .dismiss { - cursor: pointer; - position: absolute; - right: 0.75rem; - top: 0.5rem; - } +.nav-link:hover { + background: var(--bg-tertiary); + color: var(--text-primary); +} -.blazor-error-boundary { - background: url(data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iNTYiIGhlaWdodD0iNDkiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgeG1sbnM6eGxpbms9Imh0dHA6Ly93d3cudzMub3JnLzE5OTkveGxpbmsiIG92ZXJmbG93PSJoaWRkZW4iPjxkZWZzPjxjbGlwUGF0aCBpZD0iY2xpcDAiPjxyZWN0IHg9IjIzNSIgeT0iNTEiIHdpZHRoPSI1NiIgaGVpZ2h0PSI0OSIvPjwvY2xpcFBhdGg+PC9kZWZzPjxnIGNsaXAtcGF0aD0idXJsKCNjbGlwMCkiIHRyYW5zZm9ybT0idHJhbnNsYXRlKC0yMzUgLTUxKSI+PHBhdGggZD0iTTI2My41MDYgNTFDMjY0LjcxNyA1MSAyNjUuODEzIDUxLjQ4MzcgMjY2LjYwNiA1Mi4yNjU4TDI2Ny4wNTIgNTIuNzk4NyAyNjcuNTM5IDUzLjYyODMgMjkwLjE4NSA5Mi4xODMxIDI5MC41NDUgOTIuNzk1IDI5MC42NTYgOTIuOTk2QzI5MC44NzcgOTMuNTEzIDI5MSA5NC4wODE1IDI5MSA5NC42NzgyIDI5MSA5Ny4wNjUxIDI4OS4wMzggOTkgMjg2LjYxNyA5OUwyNDAuMzgzIDk5QzIzNy45NjMgOTkgMjM2IDk3LjA2NTEgMjM2IDk0LjY3ODIgMjM2IDk0LjM3OTkgMjM2LjAzMSA5NC4wODg2IDIzNi4wODkgOTMuODA3MkwyMzYuMzM4IDkzLjAxNjIgMjM2Ljg1OCA5Mi4xMzE0IDI1OS40NzMgNTMuNjI5NCAyNTkuOTYxIDUyLjc5ODUgMjYwLjQwNyA1Mi4yNjU4QzI2MS4yIDUxLjQ4MzcgMjYyLjI5NiA1MSAyNjMuNTA2IDUxWk0yNjMuNTg2IDY2LjAxODNDMjYwLjczNyA2Ni4wMTgzIDI1OS4zMTMgNjcuMTI0NSAyNTkuMzEzIDY5LjMzNyAyNTkuMzEzIDY5LjYxMDIgMjU5LjMzMiA2OS44NjA4IDI1OS4zNzEgNzAuMDg4N0wyNjEuNzk1IDg0LjAxNjEgMjY1LjM4IDg0LjAxNjEgMjY3LjgyMSA2OS43NDc1QzI2Ny44NiA2OS43MzA5IDI2Ny44NzkgNjkuNTg3NyAyNjcuODc5IDY5LjMxNzkgMjY3Ljg3OSA2Ny4xMTgyIDI2Ni40NDggNjYuMDE4MyAyNjMuNTg2IDY2LjAxODNaTTI2My41NzYgODYuMDU0N0MyNjEuMDQ5IDg2LjA1NDcgMjU5Ljc4NiA4Ny4zMDA1IDI1OS43ODYgODkuNzkyMSAyNTkuNzg2IDkyLjI4MzcgMjYxLjA0OSA5My41Mjk1IDI2My41NzYgOTMuNTI5NSAyNjYuMTE2IDkzLjUyOTUgMjY3LjM4NyA5Mi4yODM3IDI2Ny4zODcgODkuNzkyMSAyNjcuMzg3IDg3LjMwMDUgMjY2LjExNiA4Ni4wNTQ3IDI2My41NzYgODYuMDU0N1oiIGZpbGw9IiNGRkU1MDAiIGZpbGwtcnVsZT0iZXZlbm9kZCIvPjwvZz48L3N2Zz4=) no-repeat 1rem/1.8rem, #b32121; - padding: 1rem 1rem 1rem 3.7rem; +.nav-link.active { + background: var(--accent-primary); color: white; } - .blazor-error-boundary::after { - content: "An error has occurred." - } +/* ═══════════════════════════════════════════════════════════════════════════════ + Glass Card + ═══════════════════════════════════════════════════════════════════════════════ */ +.glass-card { + background: var(--glass-bg); + backdrop-filter: blur(var(--glass-blur)); + -webkit-backdrop-filter: blur(var(--glass-blur)); + border: 1px solid var(--glass-border); + border-radius: var(--radius-xl); + padding: var(--space-6); + box-shadow: var(--glass-shadow); + margin-bottom: var(--space-6); +} -.loading-progress { - position: absolute; +.glass-card h2 { + margin: 0 0 var(--space-4); + font-size: var(--text-xl); + font-weight: 600; +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Forms + ═══════════════════════════════════════════════════════════════════════════════ */ +.form-group { + margin-bottom: var(--space-4); +} + +.form-group label { display: block; - width: 8rem; - height: 8rem; - inset: 20vh 0 auto 0; - margin: 0 auto 0 auto; + margin-bottom: var(--space-2); + font-size: var(--text-sm); + font-weight: 500; + color: var(--text-secondary); } - .loading-progress circle { - fill: none; - stroke: #e0e0e0; - stroke-width: 0.6rem; - transform-origin: 50% 50%; - transform: rotate(-90deg); - } +.form-input { + width: 100%; + padding: var(--space-3) var(--space-4); + font-size: var(--text-base); + font-family: var(--font-sans); + background: var(--bg-primary); + border: 1px solid var(--border-default); + border-radius: var(--radius-md); + color: var(--text-primary); + transition: border-color var(--transition-fast), box-shadow var(--transition-fast); +} - .loading-progress circle:last-child { - stroke: #1b6ec2; - stroke-dasharray: calc(3.141 * var(--blazor-load-percentage, 0%) * 0.8), 500%; - transition: stroke-dasharray 0.05s ease-in-out; - } +.form-input:focus { + outline: none; + border-color: var(--accent-primary); + box-shadow: 0 0 0 3px rgba(59, 130, 246, 0.2); +} -.loading-progress-text { - position: absolute; +.form-input::placeholder { + color: var(--text-tertiary); +} + +.form-input.invalid, +.form-input:invalid { + border-color: var(--accent-error); +} + +.form-row { + display: grid; + grid-template-columns: repeat(2, 1fr); + gap: var(--space-4); +} + +.form-hint { + display: block; + margin-top: var(--space-1); + font-size: var(--text-xs); + color: var(--text-tertiary); +} + +.form-actions { + display: flex; + gap: var(--space-3); + margin-top: var(--space-6); +} + +.checkbox-group { + display: flex; + align-items: center; + gap: var(--space-2); +} + +.checkbox-group label { + margin: 0; +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Buttons + ═══════════════════════════════════════════════════════════════════════════════ */ +.btn { + display: inline-flex; + align-items: center; + justify-content: center; + gap: var(--space-2); + padding: var(--space-3) var(--space-6); + font-size: var(--text-base); + font-weight: 500; + font-family: var(--font-sans); + border: none; + border-radius: var(--radius-md); + cursor: pointer; + transition: all var(--transition-fast); +} + +.btn:disabled { + opacity: 0.6; + cursor: not-allowed; +} + +.btn-primary { + background: var(--brand-gradient); + color: white; +} + +.btn-primary:hover:not(:disabled) { + transform: translateY(-1px); + box-shadow: 0 4px 12px rgba(59, 130, 246, 0.4); +} + +.btn-secondary { + background: var(--bg-tertiary); + color: var(--text-primary); +} + +.btn-secondary:hover:not(:disabled) { + background: var(--bg-secondary); +} + +.btn-full { + width: 100%; +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Validation + ═══════════════════════════════════════════════════════════════════════════════ */ +.validation-summary { + background: rgba(239, 68, 68, 0.1); + border: 1px solid var(--accent-error); + border-radius: var(--radius-md); + padding: var(--space-4); + margin-bottom: var(--space-4); + color: var(--accent-error); +} + +.validation-summary ul { + margin: 0; + padding-left: var(--space-4); +} + +.validation-message { + display: block; + margin-top: var(--space-1); + font-size: var(--text-xs); + color: var(--accent-error); +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Alerts + ═══════════════════════════════════════════════════════════════════════════════ */ +.alert { + padding: var(--space-4); + border-radius: var(--radius-md); + margin-top: var(--space-4); +} + +.alert-success { + background: rgba(34, 197, 94, 0.1); + border: 1px solid var(--accent-success); + color: var(--accent-success); +} + +.alert-error { + background: rgba(239, 68, 68, 0.1); + border: 1px solid var(--accent-error); + color: var(--accent-error); +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Product Grid + ═══════════════════════════════════════════════════════════════════════════════ */ +.product-grid { + display: grid; + grid-template-columns: repeat(auto-fill, minmax(280px, 1fr)); + gap: var(--space-4); +} + +.product-card { + background: var(--bg-elevated); + border: 1px solid var(--border-default); + border-radius: var(--radius-lg); + padding: var(--space-4); + transition: all var(--transition-fast); +} + +.product-card:hover { + transform: translateY(-2px); + box-shadow: var(--glass-shadow); +} + +.product-card h3 { + margin: 0 0 var(--space-2); + font-size: var(--text-lg); +} + +.product-card .description { + color: var(--text-secondary); + font-size: var(--text-sm); + margin-bottom: var(--space-3); +} + +.product-details { + display: flex; + justify-content: space-between; + align-items: center; +} + +.product-details .price { + font-weight: 600; + color: var(--accent-primary); +} + +.product-details .quantity { + font-size: var(--text-sm); + color: var(--text-tertiary); +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Auth + ═══════════════════════════════════════════════════════════════════════════════ */ +.auth-container { + max-width: 400px; + margin: var(--space-12) auto; +} + +.auth-tabs { + display: flex; + gap: var(--space-2); + margin-bottom: var(--space-4); +} + +.tab-btn { + flex: 1; + padding: var(--space-3); + font-size: var(--text-base); + font-weight: 500; + background: var(--bg-tertiary); + border: none; + border-radius: var(--radius-md); + color: var(--text-secondary); + cursor: pointer; + transition: all var(--transition-fast); +} + +.tab-btn.active { + background: var(--accent-primary); + color: white; +} + +.auth-card .subtitle { + color: var(--text-secondary); + margin-bottom: var(--space-6); +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Page Title + ═══════════════════════════════════════════════════════════════════════════════ */ +.page-title { + font-size: var(--text-2xl); + font-weight: 700; + margin-bottom: var(--space-6); + background: var(--brand-gradient); + -webkit-background-clip: text; + -webkit-text-fill-color: transparent; + background-clip: text; +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Theme Toggle + ═══════════════════════════════════════════════════════════════════════════════ */ +.theme-toggle { + padding: var(--space-2) var(--space-3); + background: var(--bg-tertiary); + border: 1px solid var(--border-default); + border-radius: var(--radius-full); + color: var(--text-primary); + cursor: pointer; + transition: all var(--transition-fast); +} + +.theme-toggle:hover { + background: var(--bg-secondary); +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Loading & States + ═══════════════════════════════════════════════════════════════════════════════ */ +.loading { text-align: center; - font-weight: bold; - inset: calc(20vh + 3.25rem) 0 auto 0.2rem; + color: var(--text-secondary); + padding: var(--space-8); } - .loading-progress-text:after { - content: var(--blazor-load-percentage-text, "Loading"); +.empty-state { + text-align: center; + color: var(--text-tertiary); + padding: var(--space-8); +} + +.spinner { + display: inline-block; + width: 1rem; + height: 1rem; + border: 2px solid currentColor; + border-right-color: transparent; + border-radius: 50%; + animation: spin 0.75s linear infinite; +} + +@keyframes spin { + to { + transform: rotate(360deg); + } +} + +/* ═══════════════════════════════════════════════════════════════════════════════ + Responsive + ═══════════════════════════════════════════════════════════════════════════════ */ +@media (max-width: 768px) { + .sidebar { + position: fixed; + left: -100%; + top: 0; + bottom: 0; + z-index: 100; + transition: left var(--transition-normal); } -code { - color: #c02d76; -} + .sidebar.open { + left: 0; + } -.form-floating > .form-control-plaintext::placeholder, .form-floating > .form-control::placeholder { - color: var(--bs-secondary-color); - text-align: end; -} + .form-row { + grid-template-columns: 1fr; + } -.form-floating > .form-control-plaintext:focus::placeholder, .form-floating > .form-control:focus::placeholder { - text-align: start; + .content { + padding: var(--space-4); + } } \ No newline at end of file diff --git a/apps/web-client-base-net/src/WebClientBase.Client/wwwroot/index.html b/apps/web-client-base-net/src/WebClientBase.Client/wwwroot/index.html index 90f7165a..c6eef2ae 100644 --- a/apps/web-client-base-net/src/WebClientBase.Client/wwwroot/index.html +++ b/apps/web-client-base-net/src/WebClientBase.Client/wwwroot/index.html @@ -4,31 +4,51 @@ - WebClientBase.Client + GoodGo Web Client Base - - + + + + + + + + + -
- - - - -
+ + +
+ + + + + +

Loading GoodGo... / Đang tải...

+
+ +
-
- An unhandled error has occurred. - Reload - 🗙 + - + + diff --git a/services/mkt-x-service-net/src/MktXService.API/Application/Commands/CampaignCommandHandlers.cs b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/CampaignCommandHandlers.cs new file mode 100644 index 00000000..cf58788b --- /dev/null +++ b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/CampaignCommandHandlers.cs @@ -0,0 +1,214 @@ +using MediatR; +using MktXService.Domain.AggregatesModel.CampaignAggregate; + +namespace MktXService.API.Application.Commands; + +/// +/// EN: Handler for CreateCampaignCommand. +/// VI: Handler cho CreateCampaignCommand. +/// +public class CreateCampaignCommandHandler : IRequestHandler +{ + private readonly ICampaignRepository _campaignRepository; + private readonly ILogger _logger; + + public CreateCampaignCommandHandler( + ICampaignRepository campaignRepository, + ILogger logger) + { + _campaignRepository = campaignRepository; + _logger = logger; + } + + public async Task Handle( + CreateCampaignCommand request, + CancellationToken cancellationToken) + { + _logger.LogInformation("Creating campaign {Name} for merchant {MerchantId}", + request.Name, request.MerchantId); + + try + { + var campaign = new Campaign( + request.MerchantId, + request.Name, + request.Type, + request.TemplateId); + + // EN: Add segments to campaign + // VI: Thêm segments vào chiến dịch + foreach (var segmentId in request.SegmentIds) + { + campaign.AddSegment(segmentId); + } + + // EN: Set schedule if provided + // VI: Thiết lập lịch trình nếu có + if (request.Schedule != null) + { + campaign.SetSchedule(request.Schedule); + } + + _campaignRepository.Add(campaign); + await _campaignRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Campaign {CampaignId} created successfully", campaign.Id); + return new CreateCampaignResult(true, campaign.Id, null); + } + catch (Exception ex) + { + _logger.LogError(ex, "Failed to create campaign {Name}", request.Name); + return new CreateCampaignResult(false, null, ex.Message); + } + } +} + +/// +/// EN: Handler for StartCampaignCommand. +/// VI: Handler cho StartCampaignCommand. +/// +public class StartCampaignCommandHandler : IRequestHandler +{ + private readonly ICampaignRepository _campaignRepository; + private readonly ILogger _logger; + + public StartCampaignCommandHandler( + ICampaignRepository campaignRepository, + ILogger logger) + { + _campaignRepository = campaignRepository; + _logger = logger; + } + + public async Task Handle(StartCampaignCommand request, CancellationToken cancellationToken) + { + var campaign = await _campaignRepository.GetByIdAsync(request.CampaignId); + if (campaign == null) return false; + + campaign.Start(); + await _campaignRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Campaign {CampaignId} started", request.CampaignId); + return true; + } +} + +/// +/// EN: Handler for PauseCampaignCommand. +/// VI: Handler cho PauseCampaignCommand. +/// +public class PauseCampaignCommandHandler : IRequestHandler +{ + private readonly ICampaignRepository _campaignRepository; + private readonly ILogger _logger; + + public PauseCampaignCommandHandler( + ICampaignRepository campaignRepository, + ILogger logger) + { + _campaignRepository = campaignRepository; + _logger = logger; + } + + public async Task Handle(PauseCampaignCommand request, CancellationToken cancellationToken) + { + var campaign = await _campaignRepository.GetByIdAsync(request.CampaignId); + if (campaign == null) return false; + + campaign.Pause(); + await _campaignRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Campaign {CampaignId} paused", request.CampaignId); + return true; + } +} + +/// +/// EN: Handler for ResumeCampaignCommand. +/// VI: Handler cho ResumeCampaignCommand. +/// +public class ResumeCampaignCommandHandler : IRequestHandler +{ + private readonly ICampaignRepository _campaignRepository; + private readonly ILogger _logger; + + public ResumeCampaignCommandHandler( + ICampaignRepository campaignRepository, + ILogger logger) + { + _campaignRepository = campaignRepository; + _logger = logger; + } + + public async Task Handle(ResumeCampaignCommand request, CancellationToken cancellationToken) + { + var campaign = await _campaignRepository.GetByIdAsync(request.CampaignId); + if (campaign == null) return false; + + campaign.Resume(); + await _campaignRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Campaign {CampaignId} resumed", request.CampaignId); + return true; + } +} + +/// +/// EN: Handler for CancelCampaignCommand. +/// VI: Handler cho CancelCampaignCommand. +/// +public class CancelCampaignCommandHandler : IRequestHandler +{ + private readonly ICampaignRepository _campaignRepository; + private readonly ILogger _logger; + + public CancelCampaignCommandHandler( + ICampaignRepository campaignRepository, + ILogger logger) + { + _campaignRepository = campaignRepository; + _logger = logger; + } + + public async Task Handle(CancelCampaignCommand request, CancellationToken cancellationToken) + { + var campaign = await _campaignRepository.GetByIdAsync(request.CampaignId); + if (campaign == null) return false; + + campaign.Cancel(); + await _campaignRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Campaign {CampaignId} cancelled: {Reason}", + request.CampaignId, request.Reason); + return true; + } +} + +/// +/// EN: Handler for UpdateCampaignMetricsCommand. +/// VI: Handler cho UpdateCampaignMetricsCommand. +/// +public class UpdateCampaignMetricsCommandHandler : IRequestHandler +{ + private readonly ICampaignRepository _campaignRepository; + + public UpdateCampaignMetricsCommandHandler(ICampaignRepository campaignRepository) + { + _campaignRepository = campaignRepository; + } + + public async Task Handle(UpdateCampaignMetricsCommand request, CancellationToken cancellationToken) + { + var campaign = await _campaignRepository.GetByIdAsync(request.CampaignId); + if (campaign == null) return false; + + var metrics = new CampaignMetrics( + request.Sent, request.Delivered, request.Opened, + request.Clicked, request.Replied, request.Failed); + + campaign.UpdateMetrics(metrics); + await _campaignRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + return true; + } +} diff --git a/services/mkt-x-service-net/src/MktXService.API/Application/Commands/CampaignCommands.cs b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/CampaignCommands.cs new file mode 100644 index 00000000..03739847 --- /dev/null +++ b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/CampaignCommands.cs @@ -0,0 +1,57 @@ +using MediatR; +using MktXService.Domain.AggregatesModel.CampaignAggregate; + +namespace MktXService.API.Application.Commands; + +/// +/// EN: Command to create a new campaign. +/// VI: Command để tạo chiến dịch mới. +/// +public record CreateCampaignCommand( + Guid MerchantId, + string Name, + string Type, + Guid? TemplateId, + List SegmentIds, + CampaignSchedule? Schedule = null +) : IRequest; + +public record CreateCampaignResult(bool Success, Guid? CampaignId, string? Error); + +/// +/// EN: Command to start a campaign. +/// VI: Command để bắt đầu chiến dịch. +/// +public record StartCampaignCommand(Guid CampaignId) : IRequest; + +/// +/// EN: Command to pause a running campaign. +/// VI: Command để tạm dừng chiến dịch đang chạy. +/// +public record PauseCampaignCommand(Guid CampaignId) : IRequest; + +/// +/// EN: Command to resume a paused campaign. +/// VI: Command để tiếp tục chiến dịch đã tạm dừng. +/// +public record ResumeCampaignCommand(Guid CampaignId) : IRequest; + +/// +/// EN: Command to cancel a campaign. +/// VI: Command để hủy chiến dịch. +/// +public record CancelCampaignCommand(Guid CampaignId, string? Reason = null) : IRequest; + +/// +/// EN: Command to update campaign metrics. +/// VI: Command để cập nhật metrics chiến dịch. +/// +public record UpdateCampaignMetricsCommand( + Guid CampaignId, + int Sent, + int Delivered, + int Opened, + int Clicked, + int Replied, + int Failed +) : IRequest; diff --git a/services/mkt-x-service-net/src/MktXService.API/Application/Commands/ConversationCommandHandlers.cs b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/ConversationCommandHandlers.cs new file mode 100644 index 00000000..6e3ecb1d --- /dev/null +++ b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/ConversationCommandHandlers.cs @@ -0,0 +1,188 @@ +using MediatR; +using MktXService.Domain.AggregatesModel.ConversationAggregate; +using MktXService.Domain.AggregatesModel.ContactAggregate; +using MktXService.Infrastructure.ExternalServices.Twitter; + +namespace MktXService.API.Application.Commands; + +/// +/// EN: Handler for SendMessageCommand. +/// VI: Handler cho SendMessageCommand. +/// +public class SendMessageCommandHandler : IRequestHandler +{ + private readonly IConversationRepository _conversationRepository; + private readonly IContactRepository _contactRepository; + private readonly ITwitterApiClient _twitterClient; + private readonly ILogger _logger; + + public SendMessageCommandHandler( + IConversationRepository conversationRepository, + IContactRepository contactRepository, + ITwitterApiClient twitterClient, + ILogger logger) + { + _conversationRepository = conversationRepository; + _contactRepository = contactRepository; + _twitterClient = twitterClient; + _logger = logger; + } + + public async Task Handle( + SendMessageCommand request, + CancellationToken cancellationToken) + { + var conversation = await _conversationRepository.GetByIdAsync(request.ConversationId); + if (conversation == null) + return new SendMessageResult(false, null, null, "Conversation not found"); + + try + { + // EN: Get contact to find Twitter ID + // VI: Lấy contact để tìm Twitter ID + var contact = await _contactRepository.GetByIdAsync(conversation.ContactId); + if (contact == null) + return new SendMessageResult(false, null, null, "Contact not found"); + + // EN: Send message via Twitter API + // VI: Gửi tin nhắn qua Twitter API + var twitterResult = await _twitterClient.SendDirectMessageAsync( + contact.TwitterUserId, + request.Content, + cancellationToken); + + if (!twitterResult.Success) + return new SendMessageResult(false, null, null, twitterResult.Error); + + // EN: Add message to conversation + // VI: Thêm tin nhắn vào hội thoại + var message = conversation.AddMessage( + "outbound", + "text", + request.Content, + request.IsFromBot, + twitterResult.MessageId); + + await _conversationRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Message {MessageId} sent in conversation {ConversationId}", + message.Id, request.ConversationId); + + return new SendMessageResult(true, message.Id, twitterResult.MessageId, null); + } + catch (Exception ex) + { + _logger.LogError(ex, "Failed to send message in conversation {ConversationId}", request.ConversationId); + return new SendMessageResult(false, null, null, ex.Message); + } + } +} + +/// +/// EN: Handler for CloseConversationCommand. +/// VI: Handler cho CloseConversationCommand. +/// +public class CloseConversationCommandHandler : IRequestHandler +{ + private readonly IConversationRepository _conversationRepository; + private readonly ILogger _logger; + + public CloseConversationCommandHandler( + IConversationRepository conversationRepository, + ILogger logger) + { + _conversationRepository = conversationRepository; + _logger = logger; + } + + public async Task Handle(CloseConversationCommand request, CancellationToken cancellationToken) + { + var conversation = await _conversationRepository.GetByIdAsync(request.ConversationId); + if (conversation == null) return false; + + conversation.Close(request.Reason); + await _conversationRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Conversation {ConversationId} closed", request.ConversationId); + return true; + } +} + +/// +/// EN: Handler for AssignConversationCommand. +/// VI: Handler cho AssignConversationCommand. +/// +public class AssignConversationCommandHandler : IRequestHandler +{ + private readonly IConversationRepository _conversationRepository; + private readonly ILogger _logger; + + public AssignConversationCommandHandler( + IConversationRepository conversationRepository, + ILogger logger) + { + _conversationRepository = conversationRepository; + _logger = logger; + } + + public async Task Handle(AssignConversationCommand request, CancellationToken cancellationToken) + { + var conversation = await _conversationRepository.GetByIdAsync(request.ConversationId); + if (conversation == null) return false; + + conversation.AssignTo(request.UserId); + await _conversationRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Conversation {ConversationId} assigned to {UserId}", + request.ConversationId, request.UserId); + return true; + } +} + +/// +/// EN: Handler for ReopenConversationCommand. +/// VI: Handler cho ReopenConversationCommand. +/// +public class ReopenConversationCommandHandler : IRequestHandler +{ + private readonly IConversationRepository _conversationRepository; + + public ReopenConversationCommandHandler(IConversationRepository conversationRepository) + { + _conversationRepository = conversationRepository; + } + + public async Task Handle(ReopenConversationCommand request, CancellationToken cancellationToken) + { + var conversation = await _conversationRepository.GetByIdAsync(request.ConversationId); + if (conversation == null) return false; + + conversation.Reopen(); + await _conversationRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + return true; + } +} + +/// +/// EN: Handler for MarkConversationPendingCommand. +/// VI: Handler cho MarkConversationPendingCommand. +/// +public class MarkConversationPendingCommandHandler : IRequestHandler +{ + private readonly IConversationRepository _conversationRepository; + + public MarkConversationPendingCommandHandler(IConversationRepository conversationRepository) + { + _conversationRepository = conversationRepository; + } + + public async Task Handle(MarkConversationPendingCommand request, CancellationToken cancellationToken) + { + var conversation = await _conversationRepository.GetByIdAsync(request.ConversationId); + if (conversation == null) return false; + + conversation.MarkAsPending(); + await _conversationRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + return true; + } +} diff --git a/services/mkt-x-service-net/src/MktXService.API/Application/Commands/ConversationCommands.cs b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/ConversationCommands.cs new file mode 100644 index 00000000..ed4a6ff7 --- /dev/null +++ b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/ConversationCommands.cs @@ -0,0 +1,46 @@ +using MediatR; + +namespace MktXService.API.Application.Commands; + +/// +/// EN: Command to send a message in a conversation. +/// VI: Command để gửi tin nhắn trong hội thoại. +/// +public record SendMessageCommand( + Guid ConversationId, + string Content, + bool IsFromBot = false, + List? MediaUrls = null +) : IRequest; + +public record SendMessageResult(bool Success, Guid? MessageId, string? TwitterMessageId, string? Error); + +/// +/// EN: Command to close a conversation. +/// VI: Command để đóng hội thoại. +/// +public record CloseConversationCommand( + Guid ConversationId, + string? Reason = null +) : IRequest; + +/// +/// EN: Command to assign a conversation to an agent. +/// VI: Command để gán hội thoại cho agent. +/// +public record AssignConversationCommand( + Guid ConversationId, + Guid UserId +) : IRequest; + +/// +/// EN: Command to reopen a closed conversation. +/// VI: Command để mở lại hội thoại đã đóng. +/// +public record ReopenConversationCommand(Guid ConversationId) : IRequest; + +/// +/// EN: Command to mark conversation as pending. +/// VI: Command để đánh dấu hội thoại đang chờ. +/// +public record MarkConversationPendingCommand(Guid ConversationId) : IRequest; diff --git a/services/mkt-x-service-net/src/MktXService.API/Application/Commands/TwitterAccountCommandHandlers.cs b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/TwitterAccountCommandHandlers.cs new file mode 100644 index 00000000..f3d00d41 --- /dev/null +++ b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/TwitterAccountCommandHandlers.cs @@ -0,0 +1,136 @@ +using MediatR; +using MktXService.Domain.AggregatesModel.TwitterAccountAggregate; +using MktXService.Infrastructure.ExternalServices.Twitter; + +namespace MktXService.API.Application.Commands; + +/// +/// EN: Handler for ConnectTwitterAccountCommand. +/// VI: Handler cho ConnectTwitterAccountCommand. +/// +public class ConnectTwitterAccountCommandHandler : IRequestHandler +{ + private readonly ITwitterAccountRepository _accountRepository; + private readonly ITwitterApiClient _twitterClient; + private readonly ILogger _logger; + + public ConnectTwitterAccountCommandHandler( + ITwitterAccountRepository accountRepository, + ITwitterApiClient twitterClient, + ILogger logger) + { + _accountRepository = accountRepository; + _twitterClient = twitterClient; + _logger = logger; + } + + public async Task Handle( + ConnectTwitterAccountCommand request, + CancellationToken cancellationToken) + { + _logger.LogInformation("Connecting Twitter account {Username} for merchant {MerchantId}", + request.Username, request.MerchantId); + + try + { + // EN: Check if account already exists + // VI: Kiểm tra xem tài khoản đã tồn tại chưa + var existingAccount = await _accountRepository.GetByTwitterUserIdAsync(request.TwitterUserId); + if (existingAccount != null) + { + return new ConnectTwitterAccountResult(false, null, "Twitter account already connected"); + } + + // EN: Create new account + // VI: Tạo tài khoản mới + var account = new TwitterAccount( + request.MerchantId, + request.TwitterUserId, + request.Username, + request.OAuthToken, + request.OAuthTokenSecret, + request.DisplayName, + request.ProfileImageUrl); + + _accountRepository.Add(account); + await _accountRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Twitter account {AccountId} connected successfully", account.Id); + return new ConnectTwitterAccountResult(true, account.Id, null); + } + catch (Exception ex) + { + _logger.LogError(ex, "Failed to connect Twitter account {Username}", request.Username); + return new ConnectTwitterAccountResult(false, null, ex.Message); + } + } +} + +/// +/// EN: Handler for DisconnectTwitterAccountCommand. +/// VI: Handler cho DisconnectTwitterAccountCommand. +/// +public class DisconnectTwitterAccountCommandHandler : IRequestHandler +{ + private readonly ITwitterAccountRepository _accountRepository; + private readonly ILogger _logger; + + public DisconnectTwitterAccountCommandHandler( + ITwitterAccountRepository accountRepository, + ILogger logger) + { + _accountRepository = accountRepository; + _logger = logger; + } + + public async Task Handle( + DisconnectTwitterAccountCommand request, + CancellationToken cancellationToken) + { + _logger.LogInformation("Disconnecting Twitter account {AccountId}", request.AccountId); + + var account = await _accountRepository.GetByIdAsync(request.AccountId); + if (account == null) + { + _logger.LogWarning("Account {AccountId} not found", request.AccountId); + return false; + } + + account.Disconnect(); + await _accountRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + _logger.LogInformation("Twitter account {AccountId} disconnected", request.AccountId); + return true; + } +} + +/// +/// EN: Handler for RefreshTwitterAccountTokensCommand. +/// VI: Handler cho RefreshTwitterAccountTokensCommand. +/// +public class RefreshTwitterAccountTokensCommandHandler : IRequestHandler +{ + private readonly ITwitterAccountRepository _accountRepository; + private readonly ILogger _logger; + + public RefreshTwitterAccountTokensCommandHandler( + ITwitterAccountRepository accountRepository, + ILogger logger) + { + _accountRepository = accountRepository; + _logger = logger; + } + + public async Task Handle( + RefreshTwitterAccountTokensCommand request, + CancellationToken cancellationToken) + { + var account = await _accountRepository.GetByIdAsync(request.AccountId); + if (account == null) return false; + + account.UpdateCredentials(request.NewOAuthToken, request.NewOAuthTokenSecret); + await _accountRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken); + + return true; + } +} diff --git a/services/mkt-x-service-net/src/MktXService.API/Application/Commands/TwitterAccountCommands.cs b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/TwitterAccountCommands.cs new file mode 100644 index 00000000..3997ea6b --- /dev/null +++ b/services/mkt-x-service-net/src/MktXService.API/Application/Commands/TwitterAccountCommands.cs @@ -0,0 +1,41 @@ +using MediatR; + +namespace MktXService.API.Application.Commands; + +/// +/// EN: Command to connect a Twitter account via OAuth. +/// VI: Command để kết nối tài khoản Twitter qua OAuth. +/// +public record ConnectTwitterAccountCommand( + Guid MerchantId, + string TwitterUserId, + string Username, + string OAuthToken, + string OAuthTokenSecret, + string? DisplayName = null, + string? ProfileImageUrl = null +) : IRequest; + +public record ConnectTwitterAccountResult( + bool Success, + Guid? AccountId, + string? Error); + +/// +/// EN: Command to disconnect a Twitter account. +/// VI: Command để ngắt kết nối tài khoản Twitter. +/// +public record DisconnectTwitterAccountCommand( + Guid AccountId, + string? Reason = null +) : IRequest; + +/// +/// EN: Command to refresh OAuth tokens for a Twitter account. +/// VI: Command để làm mới OAuth tokens cho tài khoản Twitter. +/// +public record RefreshTwitterAccountTokensCommand( + Guid AccountId, + string NewOAuthToken, + string NewOAuthTokenSecret +) : IRequest; diff --git a/services/mkt-x-service-net/src/MktXService.API/Application/Queries/MktXQueries.cs b/services/mkt-x-service-net/src/MktXService.API/Application/Queries/MktXQueries.cs new file mode 100644 index 00000000..37b329ab --- /dev/null +++ b/services/mkt-x-service-net/src/MktXService.API/Application/Queries/MktXQueries.cs @@ -0,0 +1,166 @@ +using MediatR; + +namespace MktXService.API.Application.Queries; + +#region Twitter Account Queries + +public record GetTwitterAccountsQuery(Guid MerchantId) : IRequest>; + +public record GetTwitterAccountQuery(Guid AccountId) : IRequest; + +public record TwitterAccountDto( + Guid Id, + Guid MerchantId, + string TwitterUserId, + string Username, + string? DisplayName, + string? ProfileImageUrl, + string Status, + DateTime ConnectedAt); + +#endregion + +#region Campaign Queries + +public record GetCampaignsQuery( + Guid MerchantId, + string? Status = null, + int Skip = 0, + int Take = 20 +) : IRequest>; + +public record GetCampaignQuery(Guid CampaignId) : IRequest; + +public record CampaignDto( + Guid Id, + string Name, + string Type, + string Status, + int TotalSent, + int TotalDelivered, + DateTime CreatedAt); + +public record CampaignDetailDto( + Guid Id, + string Name, + string Type, + string Status, + Guid? TemplateId, + List SegmentIds, + CampaignMetricsDto Metrics, + CampaignScheduleDto? Schedule, + DateTime CreatedAt); + +public record CampaignMetricsDto(int Sent, int Delivered, int Opened, int Clicked, int Replied, int Failed); + +public record CampaignScheduleDto(DateTime? StartAt, DateTime? EndAt, string? Recurrence); + +#endregion + +#region Conversation Queries + +public record GetConversationsQuery( + Guid AccountId, + string? Status = null, + Guid? AssignedToUserId = null, + int Skip = 0, + int Take = 20 +) : IRequest>; + +public record GetConversationQuery(Guid ConversationId, bool IncludeMessages = true) + : IRequest; + +public record ConversationDto( + Guid Id, + Guid ContactId, + string ContactUsername, + string Status, + int MessageCount, + DateTime StartedAt, + DateTime? LastMessageAt); + +public record ConversationDetailDto( + Guid Id, + Guid ContactId, + ContactSummaryDto Contact, + string Status, + Guid? AssignedToUserId, + List Messages, + DateTime StartedAt, + DateTime? ClosedAt); + +public record ContactSummaryDto( + Guid Id, + string TwitterUserId, + string Username, + string? DisplayName, + string? ProfileImageUrl); + +public record MessageDto( + Guid Id, + string Direction, + string Type, + string Content, + bool IsFromBot, + DateTime SentAt); + +#endregion + +#region Contact Queries + +public record GetContactsQuery( + Guid AccountId, + string? SearchTerm = null, + List? Tags = null, + int Skip = 0, + int Take = 20 +) : IRequest>; + +public record GetContactQuery(Guid ContactId) : IRequest; + +public record ContactDto( + Guid Id, + string TwitterUserId, + string Username, + string? DisplayName, + List Tags, + DateTime? LastInteractionAt); + +public record ContactDetailDto( + Guid Id, + string TwitterUserId, + string Username, + string? DisplayName, + string? ProfileImageUrl, + string Source, + Dictionary Attributes, + List Tags, + DateTime FirstInteractionAt, + DateTime? LastInteractionAt); + +#endregion + +#region Template Queries + +public record GetTemplatesQuery( + Guid MerchantId, + string? Type = null +) : IRequest>; + +public record GetTemplateQuery(Guid TemplateId) : IRequest; + +public record TemplateDto( + Guid Id, + string Name, + string Type, + DateTime CreatedAt); + +public record TemplateDetailDto( + Guid Id, + string Name, + string Type, + string Content, + List Variables, + DateTime CreatedAt); + +#endregion diff --git a/services/mkt-x-service-net/src/MktXService.API/Application/Queries/MktXQueryHandlers.cs b/services/mkt-x-service-net/src/MktXService.API/Application/Queries/MktXQueryHandlers.cs new file mode 100644 index 00000000..4e109e6b --- /dev/null +++ b/services/mkt-x-service-net/src/MktXService.API/Application/Queries/MktXQueryHandlers.cs @@ -0,0 +1,263 @@ +using MediatR; +using MktXService.Domain.AggregatesModel.TwitterAccountAggregate; +using MktXService.Domain.AggregatesModel.CampaignAggregate; +using MktXService.Domain.AggregatesModel.ConversationAggregate; +using MktXService.Domain.AggregatesModel.ContactAggregate; +using MktXService.Domain.AggregatesModel.TemplateAggregate; + +namespace MktXService.API.Application.Queries; + +#region Twitter Account Query Handlers + +public class GetTwitterAccountsQueryHandler : IRequestHandler> +{ + private readonly ITwitterAccountRepository _repository; + + public GetTwitterAccountsQueryHandler(ITwitterAccountRepository repository) => _repository = repository; + + public async Task> Handle(GetTwitterAccountsQuery request, CancellationToken ct) + { + var accounts = await _repository.GetByMerchantIdAsync(request.MerchantId); + return accounts.Select(a => new TwitterAccountDto( + a.Id, a.MerchantId, a.TwitterUserId, a.Username, + a.DisplayName, a.ProfileImageUrl, a.Status.Name, a.ConnectedAt)); + } +} + +public class GetTwitterAccountQueryHandler : IRequestHandler +{ + private readonly ITwitterAccountRepository _repository; + + public GetTwitterAccountQueryHandler(ITwitterAccountRepository repository) => _repository = repository; + + public async Task Handle(GetTwitterAccountQuery request, CancellationToken ct) + { + var a = await _repository.GetByIdAsync(request.AccountId); + if (a == null) return null; + return new TwitterAccountDto( + a.Id, a.MerchantId, a.TwitterUserId, a.Username, + a.DisplayName, a.ProfileImageUrl, a.Status.Name, a.ConnectedAt); + } +} + +#endregion + +#region Campaign Query Handlers + +public class GetCampaignsQueryHandler : IRequestHandler> +{ + private readonly ICampaignRepository _repository; + + public GetCampaignsQueryHandler(ICampaignRepository repository) => _repository = repository; + + public async Task> Handle(GetCampaignsQuery request, CancellationToken ct) + { + IEnumerable campaigns; + if (!string.IsNullOrEmpty(request.Status)) + { + var status = CampaignStatus.FromName(request.Status); + campaigns = await _repository.GetByStatusAsync(request.MerchantId, status); + } + else + { + campaigns = await _repository.GetByMerchantIdAsync(request.MerchantId, request.Skip, request.Take); + } + + return campaigns.Select(c => new CampaignDto( + c.Id, c.Name, c.Type, c.Status.Name, + c.Metrics.TotalSent, c.Metrics.Delivered, c.CreatedAt)); + } +} + +public class GetCampaignQueryHandler : IRequestHandler +{ + private readonly ICampaignRepository _repository; + + public GetCampaignQueryHandler(ICampaignRepository repository) => _repository = repository; + + public async Task Handle(GetCampaignQuery request, CancellationToken ct) + { + var c = await _repository.GetByIdAsync(request.CampaignId); + if (c == null) return null; + + return new CampaignDetailDto( + c.Id, c.Name, c.Type, c.Status.Name, c.TemplateId, c.SegmentIds.ToList(), + new CampaignMetricsDto(c.Metrics.TotalSent, c.Metrics.Delivered, c.Metrics.Opened, + c.Metrics.Clicked, c.Metrics.Replied, c.Metrics.Failed), + c.Schedule != null ? new CampaignScheduleDto(c.Schedule.StartAt, c.Schedule.EndAt, c.Schedule.Recurrence) : null, + c.CreatedAt); + } +} + +#endregion + +#region Conversation Query Handlers + +public class GetConversationsQueryHandler : IRequestHandler> +{ + private readonly IConversationRepository _repository; + private readonly IContactRepository _contactRepository; + + public GetConversationsQueryHandler(IConversationRepository repository, IContactRepository contactRepository) + { + _repository = repository; + _contactRepository = contactRepository; + } + + public async Task> Handle(GetConversationsQuery request, CancellationToken ct) + { + IEnumerable conversations; + + if (request.AssignedToUserId.HasValue) + { + conversations = await _repository.GetByAssignedUserAsync(request.AssignedToUserId.Value, request.Skip, request.Take); + } + else if (!string.IsNullOrEmpty(request.Status)) + { + var status = ConversationStatus.FromName(request.Status); + conversations = await _repository.GetByStatusAsync(request.AccountId, status, request.Skip, request.Take); + } + else + { + conversations = await _repository.GetByAccountIdAsync(request.AccountId, request.Skip, request.Take); + } + + var results = new List(); + foreach (var c in conversations) + { + var contact = await _contactRepository.GetByIdAsync(c.ContactId); + results.Add(new ConversationDto( + c.Id, c.ContactId, contact?.Username ?? "unknown", c.Status.Name, + c.Messages.Count, c.StartedAt, c.Messages.Any() ? c.Messages.Max(m => m.SentAt) : null)); + } + + return results; + } +} + +public class GetConversationQueryHandler : IRequestHandler +{ + private readonly IConversationRepository _repository; + private readonly IContactRepository _contactRepository; + + public GetConversationQueryHandler(IConversationRepository repository, IContactRepository contactRepository) + { + _repository = repository; + _contactRepository = contactRepository; + } + + public async Task Handle(GetConversationQuery request, CancellationToken ct) + { + var c = request.IncludeMessages + ? await _repository.GetByIdWithMessagesAsync(request.ConversationId) + : await _repository.GetByIdAsync(request.ConversationId); + + if (c == null) return null; + + var contact = await _contactRepository.GetByIdAsync(c.ContactId); + var contactDto = contact != null + ? new ContactSummaryDto(contact.Id, contact.TwitterUserId, contact.Username, + contact.DisplayName, contact.ProfileImageUrl) + : new ContactSummaryDto(Guid.Empty, "", "unknown", null, null); + + return new ConversationDetailDto( + c.Id, c.ContactId, contactDto, c.Status.Name, c.AssignedToUserId, + c.Messages.Select(m => new MessageDto(m.Id, m.Direction, m.Type, m.Content, m.IsFromBot, m.SentAt)).ToList(), + c.StartedAt, c.ClosedAt); + } +} + +#endregion + +#region Contact Query Handlers + +public class GetContactsQueryHandler : IRequestHandler> +{ + private readonly IContactRepository _repository; + + public GetContactsQueryHandler(IContactRepository repository) => _repository = repository; + + public async Task> Handle(GetContactsQuery request, CancellationToken ct) + { + IEnumerable contacts; + + if (request.Tags?.Any() == true) + { + contacts = await _repository.GetByTagsAsync(request.AccountId, request.Tags, request.Skip, request.Take); + } + else if (!string.IsNullOrEmpty(request.SearchTerm)) + { + contacts = await _repository.SearchAsync(request.AccountId, request.SearchTerm, request.Skip, request.Take); + } + else + { + contacts = await _repository.GetByAccountIdAsync(request.AccountId, request.Skip, request.Take); + } + + return contacts.Select(c => new ContactDto( + c.Id, c.TwitterUserId, c.Username, c.DisplayName, + c.Tags.Select(t => t.Name).ToList(), c.LastInteractionAt)); + } +} + +public class GetContactQueryHandler : IRequestHandler +{ + private readonly IContactRepository _repository; + + public GetContactQueryHandler(IContactRepository repository) => _repository = repository; + + public async Task Handle(GetContactQuery request, CancellationToken ct) + { + var c = await _repository.GetByIdAsync(request.ContactId); + if (c == null) return null; + + return new ContactDetailDto( + c.Id, c.TwitterUserId, c.Username, c.DisplayName, c.ProfileImageUrl, c.Source, + c.Attributes.ToDictionary(k => k.Key, v => v.Value), + c.Tags.Select(t => t.Name).ToList(), c.FirstInteractionAt, c.LastInteractionAt); + } +} + +#endregion + +#region Template Query Handlers + +public class GetTemplatesQueryHandler : IRequestHandler> +{ + private readonly ITemplateRepository _repository; + + public GetTemplatesQueryHandler(ITemplateRepository repository) => _repository = repository; + + public async Task> Handle(GetTemplatesQuery request, CancellationToken ct) + { + IEnumerable