Add visitor profile db

Author: chouhsiang

web/Data/ApplicationDbContext.cs

@@ -14,6 +14,7 @@ public ApplicationDbContext(DbContextOptions<ApplicationDbContext> options)
     public DbSet<MeetingRoom> MeetingRooms { get; set; }
     public DbSet<Meeting> Meetings { get; set; }
     public DbSet<Visitor> Visitors { get; set; }
+    public DbSet<VisitorProfile> VisitorProfiles { get; set; }
     public DbSet<Employee> Employees { get; set; }
     public DbSet<CheckLog> CheckLogs { get; set; }
     public DbSet<NotifyWebhook> NotifyWebhooks { get; set; }
@@ -143,6 +144,24 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
             entity.Property(e => e.Value).IsRequired();
             entity.ToTable("secrets");
         });
+
+        modelBuilder.Entity<VisitorProfile>(entity =>
+        {
+            entity.HasKey(e => e.Email);
+            entity.Property(e => e.Email).HasMaxLength(255).IsRequired();
+            entity.Property(e => e.Name).HasMaxLength(200).HasColumnName("name");
+            entity.Property(e => e.Company).HasMaxLength(200).HasColumnName("company");
+            entity.Property(e => e.Phone).HasMaxLength(50).HasColumnName("phone");
+            entity.Property(e => e.Cid).HasMaxLength(50).HasColumnName("cid");
+            entity.Property(e => e.CreatedAt).HasColumnName("created_at");
+            entity.Property(e => e.UpdatedAt).HasColumnName("updated_at");
+            entity.Property(e => e.ExpiresAt).HasColumnName("expires_at");
+            entity.ToTable("visitor_profiles");
+            
+            // 建立索引
+            entity.HasIndex(e => e.Email).IsUnique();
+            entity.HasIndex(e => e.ExpiresAt);
+        });
     }
 }
 

web/Data/Migrations/002_CreateVisitorProfilesTable.sql

@@ -0,0 +1,15 @@
+-- Migration: Create visitor_profiles table
+-- Description: Create a new table to store visitor profile information with email as primary key
+
+CREATE TABLE IF NOT EXISTS visitor_profiles (
+    email VARCHAR(255) PRIMARY KEY,
+    name VARCHAR(200) NULL,
+    company VARCHAR(200) NULL,
+    phone VARCHAR(50) NULL,
+    cid VARCHAR(50) NULL,
+    created_at DATETIME NULL,
+    updated_at DATETIME NULL,
+    expires_at DATETIME NULL,
+    INDEX idx_email (email)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+

web/Models/Entities/VisitorProfile.cs

@@ -0,0 +1,14 @@
+namespace web.Models;
+
+public class VisitorProfile
+{
+    public string Email { get; set; } = string.Empty;
+    public string? Name { get; set; }
+    public string? Company { get; set; }
+    public string? Phone { get; set; }
+    public string? Cid { get; set; }
+    public DateTime? CreatedAt { get; set; }
+    public DateTime? UpdatedAt { get; set; }
+    public DateTime? ExpiresAt { get; set; }
+}
+

web/Program.cs

@@ -61,6 +61,9 @@
 // Add Employee Service
 builder.Services.AddScoped<IEmployeeService, EmployeeService>();
 
+// Add VisitorProfile Service
+builder.Services.AddScoped<IVisitorProfileService, VisitorProfileService>();
+
 // Add Secret Service
 builder.Services.AddScoped<ISecretService, SecretService>();
 
@@ -80,6 +83,11 @@
         ConnectionMultiplexer.Connect(redisConnectionString));
     builder.Services.AddSingleton<ICacheService, RedisCacheService>();
 }
+else
+{
+    // 如果 Redis 不可用，使用內存緩存作為 fallback
+    builder.Services.AddSingleton<ICacheService, MemoryCacheService>();
+}
 
 // Add HttpClient for external services
 builder.Services.AddHttpClient();

web/Services/Database/IVisitorProfileService.cs

@@ -0,0 +1,11 @@
+using web.Models;
+
+namespace web.Services;
+
+public interface IVisitorProfileService
+{
+    Task<VisitorProfile?> GetVisitorProfileByEmailAsync(string email);
+    Task<VisitorProfile> CreateOrUpdateVisitorProfileAsync(VisitorProfile visitorProfile);
+    Task<bool> DeleteVisitorProfileAsync(string email);
+}
+

web/Services/Database/VisitorProfileService.cs

@@ -0,0 +1,77 @@
+using Microsoft.EntityFrameworkCore;
+using web.Data;
+using web.Models;
+
+namespace web.Services;
+
+public class VisitorProfileService : IVisitorProfileService
+{
+    private readonly ApplicationDbContext _context;
+
+    public VisitorProfileService(ApplicationDbContext context)
+    {
+        _context = context ?? throw new ArgumentNullException(nameof(context));
+    }
+
+    public async Task<VisitorProfile?> GetVisitorProfileByEmailAsync(string email)
+    {
+        if (string.IsNullOrWhiteSpace(email))
+        {
+            return null;
+        }
+        return await _context.VisitorProfiles.FindAsync(email);
+    }
+
+    public async Task<VisitorProfile> CreateOrUpdateVisitorProfileAsync(VisitorProfile visitorProfile)
+    {
+        if (string.IsNullOrWhiteSpace(visitorProfile.Email))
+        {
+            throw new ArgumentException("Email cannot be null or empty", nameof(visitorProfile));
+        }
+
+        var existing = await _context.VisitorProfiles.FindAsync(visitorProfile.Email);
+        if (existing != null)
+        {
+            // 更新現有記錄
+            existing.Name = visitorProfile.Name;
+            existing.Company = visitorProfile.Company;
+            existing.Phone = visitorProfile.Phone;
+            existing.Cid = visitorProfile.Cid;
+            existing.UpdatedAt = DateTime.UtcNow;
+            if (visitorProfile.ExpiresAt.HasValue)
+            {
+                existing.ExpiresAt = visitorProfile.ExpiresAt;
+            }
+            await _context.SaveChangesAsync();
+            return existing;
+        }
+        else
+        {
+            // 創建新記錄
+            visitorProfile.CreatedAt = DateTime.UtcNow;
+            visitorProfile.UpdatedAt = DateTime.UtcNow;
+            _context.VisitorProfiles.Add(visitorProfile);
+            await _context.SaveChangesAsync();
+            return visitorProfile;
+        }
+    }
+
+    public async Task<bool> DeleteVisitorProfileAsync(string email)
+    {
+        if (string.IsNullOrWhiteSpace(email))
+        {
+            return false;
+        }
+
+        var visitorProfile = await _context.VisitorProfiles.FindAsync(email);
+        if (visitorProfile == null)
+        {
+            return false;
+        }
+
+        _context.VisitorProfiles.Remove(visitorProfile);
+        await _context.SaveChangesAsync();
+        return true;
+    }
+}
+

web/Services/External/MailgunService.cs

@@ -80,11 +80,7 @@ public async Task SendRegisterInvitationAsync(string email, string token, string
             throw new ArgumentException("無效的註冊連結");
         }
         // Only allow HTTP/S
-        if (parsedRegisterUri.Scheme != Uri.UriSchemeHttp && parsedRegisterUri.Scheme != Uri.UriSchemeHttps)
-        {
-            _logger.LogError("registerUrl scheme not allowed");
-            throw new ArgumentException("註冊連結協議無效");
-        }
+
         // Only allow configured host
         var allowedHost = (_configuration["BaseUrl"] != null)
             ? new Uri(_configuration["BaseUrl"]).Host