C端用户

src/NetCorePal.D3Shop.Admin.Shared/Dtos/Identity/CreateDepartmentUserInfoDto.cs

@@ -1,9 +1,4 @@
 using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.AdminUserAggregate;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace NetCorePal.D3Shop.Admin.Shared.Dtos.Identity
 {

src/NetCorePal.D3Shop.Admin.Shared/Dtos/Identity/UpdateDepartmentUserInfoDto.cs

@@ -1,9 +1,4 @@
 using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.AdminUserAggregate;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace NetCorePal.D3Shop.Admin.Shared.Dtos.Identity
 {

src/NetCorePal.D3Shop.Admin.Shared/Requests/CreateDepartmentRequest.cs

@@ -1,7 +1,5 @@
 using NetCorePal.D3Shop.Admin.Shared.Dtos.Identity;
-using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.AdminUserAggregate;
 using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.DepartmentAggregate;
-using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.RoleAggregate;
 using System.ComponentModel.DataAnnotations;
 
 namespace NetCorePal.D3Shop.Admin.Shared.Requests;

src/NetCorePal.D3Shop.Admin.Shared/Requests/UpdateDepartmentInfoRequest.cs

@@ -1,5 +1,4 @@
 using NetCorePal.D3Shop.Admin.Shared.Dtos.Identity;
-using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.AdminUserAggregate;
 using System.ComponentModel.DataAnnotations;
 
 namespace NetCorePal.D3Shop.Admin.Shared.Requests;

src/NetCorePal.D3Shop.Admin.Shared/Responses/DepartmentResponse.cs

@@ -1,5 +1,4 @@
-using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.AdminUserAggregate;
-using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.DepartmentAggregate;
+using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.DepartmentAggregate;
 
 namespace NetCorePal.D3Shop.Admin.Shared.Responses;
 

src/NetCorePal.D3Shop.Domain/AggregatesModel/Identity/AdminUserAggregate/UserDept.cs

@@ -1,10 +1,4 @@
 using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.DepartmentAggregate;
-using NetCorePal.D3Shop.Domain.AggregatesModel.Identity.RoleAggregate;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace NetCorePal.D3Shop.Domain.AggregatesModel.Identity.AdminUserAggregate
 {

src/NetCorePal.D3Shop.Domain/AggregatesModel/Identity/ClientUserAggregate/ClientUser.cs

@@ -0,0 +1,238 @@
+using NetCorePal.D3Shop.Domain.DomainEvents.Identity.Client;
+using NetCorePal.Extensions.Domain;
+using NetCorePal.Extensions.Primitives;
+
+namespace NetCorePal.D3Shop.Domain.AggregatesModel.Identity.ClientUserAggregate;
+
+public partial record ClientUserId : IInt64StronglyTypedId;
+
+public class ClientUser : Entity<ClientUserId>, IAggregateRoot
+{
+    protected ClientUser()
+    {
+    }
+
+    public ClientUser(
+        string nickName,
+        string avatar,
+        string phone,
+        string passwordHash,
+        string passwordSalt,
+        string email)
+    {
+        NickName = nickName;
+        Avatar = avatar;
+        Phone = phone;
+        PasswordHash = passwordHash;
+        PasswordSalt = passwordSalt;
+        Email = email;
+        CreatedAt = DateTime.Now;
+        LastLoginAt = DateTime.Now;
+    }
+
+    public ICollection<UserDeliveryAddress> DeliveryAddresses { get; } = [];
+    public ICollection<UserThirdPartyLogin> ThirdPartyLogins { get; } = [];
+
+    public string NickName { get; private set; } = string.Empty;
+    public string Avatar { get; private set; } = string.Empty;
+    public string Phone { get; private set; } = string.Empty;
+    public string PasswordHash { get; private set; } = string.Empty;
+    public string PasswordSalt { get; private set; } = string.Empty;
+    public string Email { get; private set; } = string.Empty;
+    public DateTime CreatedAt { get; private set; }
+    public DateTime LastLoginAt { get; private set; }
+    public bool IsDisabled { get; private set; }
+    public DateTime? DisabledTime { get; private set; }
+    public string DisabledReason { get; private set; } = string.Empty;
+    public int PasswordFailedTimes { get; private set; }
+    public bool IsTwoFactorEnabled { get; private set; }
+
+    /// <summary>
+    ///     用户登录
+    /// </summary>
+    /// <param name="passwordHash"></param>
+    /// <param name="loginTime"></param>
+    /// <param name="loginMethod"></param>
+    /// <param name="ipAddress"></param>
+    /// <param name="userAgent"></param>
+    public void Login(
+        string passwordHash,
+        DateTime loginTime,
+        string loginMethod,
+        string ipAddress,
+        string userAgent)
+    {
+        if (PasswordHash != passwordHash)
+        {
+            PasswordFailedTimes++;
+            throw new KnownException("用户名或密码错误");
+        }
+
+        PasswordFailedTimes = 0;
+        LastLoginAt = loginTime;
+        AddDomainEvent(new ClientUserLoginEvent(Id, NickName, loginTime, loginMethod, ipAddress, userAgent));
+    }
+
+    /// <summary>
+    ///     禁用用户
+    /// </summary>
+    /// <param name="reason"></param>
+    /// <exception cref="KnownException"></exception>
+    public void Disable(string reason)
+    {
+        if (string.IsNullOrWhiteSpace(reason))
+            throw new KnownException("禁用原因不能为空");
+
+        if (IsDisabled) return;
+        IsDisabled = true;
+        DisabledTime = DateTime.UtcNow;
+        DisabledReason = reason.Trim();
+    }
+
+    /// <summary>
+    ///     启用用户
+    /// </summary>
+    public void Enable()
+    {
+        if (!IsDisabled) return;
+        IsDisabled = false;
+        DisabledTime = null;
+        DisabledReason = string.Empty;
+    }
+
+    /// <summary>
+    ///     修改密码
+    /// </summary>
+    /// <param name="oldPasswordHash"></param>
+    /// <param name="newPasswordHash"></param>
+    public void EditPassword(string oldPasswordHash, string newPasswordHash)
+    {
+        if (PasswordHash != oldPasswordHash) throw new KnownException("旧密码不正确");
+        PasswordHash = newPasswordHash;
+    }
+
+    /// <summary>
+    ///     重置密码
+    /// </summary>
+    /// <param name="newPasswordHash"></param>
+    public void ResetPassword(string newPasswordHash)
+    {
+        PasswordHash = newPasswordHash;
+    }
+
+    /// <summary>
+    ///     新增收货地址
+    /// </summary>
+    /// <param name="address"></param>
+    /// <param name="recipientName"></param>
+    /// <param name="phone"></param>
+    /// <param name="setAsDefault"></param>
+    /// <returns></returns>
+    public DeliveryAddressId AddDeliveryAddress(
+        string address,
+        string recipientName,
+        string phone,
+        bool setAsDefault)
+    {
+        var newAddress = new UserDeliveryAddress(
+            Id,
+            address,
+            recipientName,
+            phone,
+            setAsDefault
+        );
+
+        if (setAsDefault)
+        {
+            // 确保只有一个默认地址
+            var addr = DeliveryAddresses.SingleOrDefault(a => a.IsDefault);
+            addr?.UnsetDefault();
+        }
+
+        DeliveryAddresses.Add(newAddress);
+        return newAddress.Id;
+    }
+
+    /// <summary>
+    ///     更新收货地址
+    /// </summary>
+    /// <param name="deliveryAddressId"></param>
+    /// <param name="address"></param>
+    /// <param name="recipientName"></param>
+    /// <param name="phone"></param>
+    /// <param name="setAsDefault"></param>
+    /// <exception cref="KnownException"></exception>
+    public void UpdateDeliveryAddress(
+        DeliveryAddressId deliveryAddressId,
+        string address,
+        string recipientName,
+        string phone,
+        bool setAsDefault)
+    {
+        var deliveryAddress = DeliveryAddresses.SingleOrDefault(a => a.Id == deliveryAddressId) ??
+                              throw new KnownException("地址不存在");
+        deliveryAddress.UpdateDetails(address, recipientName, phone);
+
+        if (!setAsDefault) return;
+
+        var addr = DeliveryAddresses
+            .SingleOrDefault(a => a.IsDefault && a.Id != deliveryAddressId);
+        addr?.UnsetDefault();
+
+        if (!deliveryAddress.IsDefault)
+            deliveryAddress.SetAsDefault();
+    }
+
+    /// <summary>
+    ///     删除收货地址
+    /// </summary>
+    /// <param name="deliveryAddressId"></param>
+    /// <exception cref="KnownException"></exception>
+    public void RemoveDeliveryAddress(DeliveryAddressId deliveryAddressId)
+    {
+        var deliveryAddress = DeliveryAddresses.SingleOrDefault(a => a.Id == deliveryAddressId) ??
+                              throw new KnownException("地址不存在");
+        DeliveryAddresses.Remove(deliveryAddress);
+    }
+
+    /// <summary>
+    ///     绑定第三方登录
+    /// </summary>
+    /// <param name="provider"></param>
+    /// <param name="appId"></param>
+    /// <param name="openId"></param>
+    /// <returns></returns>
+    /// <exception cref="KnownException"></exception>
+    public ThirdPartyLoginId BindThirdPartyLogin(
+        ThirdPartyProvider provider,
+        string appId,
+        string openId)
+    {
+        // 规则：同一提供商下不允许重复绑定
+        if (ThirdPartyLogins.Any(x => x.Provider == provider && x.AppId == appId))
+            throw new KnownException("该渠道已绑定，请勿重复操作");
+
+        var login = new UserThirdPartyLogin(
+            Id,
+            provider,
+            appId,
+            openId
+        );
+
+        ThirdPartyLogins.Add(login);
+        return login.Id;
+    }
+
+    /// <summary>
+    ///     解绑第三方登录
+    /// </summary>
+    /// <param name="loginId"></param>
+    /// <exception cref="KnownException"></exception>
+    public void UnbindThirdPartyLogin(ThirdPartyLoginId loginId)
+    {
+        var login = ThirdPartyLogins.SingleOrDefault(x => x.Id == loginId) ??
+                    throw new KnownException("登录方式不存在");
+
+        ThirdPartyLogins.Remove(login);
+    }
+}

src/NetCorePal.D3Shop.Domain/AggregatesModel/Identity/ClientUserAggregate/ThirdPartyProvider.cs

@@ -0,0 +1,10 @@
+namespace NetCorePal.D3Shop.Domain.AggregatesModel.Identity.ClientUserAggregate;
+
+/// <summary>
+///   第三方登录提供者
+/// </summary>
+public enum ThirdPartyProvider
+{
+    WeChat = 1,
+    Qq = 2
+}

src/NetCorePal.D3Shop.Domain/AggregatesModel/Identity/ClientUserAggregate/UserDeliveryAddress.cs

@@ -0,0 +1,49 @@
+using NetCorePal.Extensions.Domain;
+
+namespace NetCorePal.D3Shop.Domain.AggregatesModel.Identity.ClientUserAggregate;
+
+public partial record DeliveryAddressId : IInt64StronglyTypedId;
+
+public class UserDeliveryAddress : Entity<DeliveryAddressId>
+{
+    protected UserDeliveryAddress()
+    {
+    }
+
+    public UserDeliveryAddress(
+        ClientUserId userId,
+        string address,
+        string recipientName,
+        string phone,
+        bool isDefault)
+    {
+        UserId = userId;
+        Address = address;
+        RecipientName = recipientName;
+        Phone = phone;
+        IsDefault = isDefault;
+    }
+
+    public ClientUserId UserId { get; private set; } = null!;
+    public string Address { get; private set; } = string.Empty;
+    public string RecipientName { get; private set; } = string.Empty;
+    public string Phone { get; private set; } = string.Empty;
+    public bool IsDefault { get; private set; }
+
+    internal void UpdateDetails(string address, string recipientName, string phone)
+    {
+        Address = address;
+        RecipientName = recipientName;
+        Phone = phone;
+    }
+
+    internal void SetAsDefault()
+    {
+        IsDefault = true;
+    }
+
+    internal void UnsetDefault()
+    {
+        IsDefault = false;
+    }
+}

src/NetCorePal.D3Shop.Domain/AggregatesModel/Identity/ClientUserAggregate/UserThirdPartyLogin.cs

@@ -0,0 +1,40 @@
+using NetCorePal.Extensions.Domain;
+
+namespace NetCorePal.D3Shop.Domain.AggregatesModel.Identity.ClientUserAggregate;
+
+public partial record ThirdPartyLoginId : IInt64StronglyTypedId;
+
+public class UserThirdPartyLogin : Entity<ThirdPartyLoginId>
+{
+    protected UserThirdPartyLogin()
+    {
+    }
+
+    public UserThirdPartyLogin(
+        ClientUserId userId,
+        ThirdPartyProvider provider,
+        string appId,
+        string openId)
+    {
+        UserId = userId;
+        Provider = provider;
+        AppId = appId;
+        OpenId = openId;
+        BindTime = DateTime.UtcNow;
+    }
+
+    public ClientUserId UserId { get; private set; } = null!;
+    public ThirdPartyProvider Provider { get; private set; }
+    public string AppId { get; private set; } = string.Empty;
+    public string OpenId { get; private set; } = string.Empty;
+    public DateTime BindTime { get; private set; }
+
+    /// <summary>
+    ///     更新OpenId（重新授权后获取新标识）
+    /// </summary>
+    /// <param name="newOpenId"></param>
+    internal void UpdateOpenId(string newOpenId)
+    {
+        OpenId = newOpenId;
+    }
+}