hotline/src/XF.Domain.Repository/Entity.cs

using SqlSugar;
using XF.Domain.Entities;
using XF.Domain.Events;
using XF.Domain.Extensions;
using XF.Utility.SequentialId;

namespace XF.Domain.Repository;

public abstract class Entity : IEntity<string>, IDomainEvents, IDataPermission, ITable
{
    private List<IAppNotification> _domainEvents = new();

    public string Id { get; set; }

    [SugarColumn(ColumnDescription = "创建人")]
    public string? CreatorId { get; set; }

    public string? CreatorName { get; set; }

    [SugarColumn(ColumnDescription = "组织Id")]
    public string? CreatorOrgId { get; set; }

    public string? CreatorOrgName { get; set; }

    public int CreatorOrgLevel { get; set; } = 0;

    /// <summary>
    /// 一级部门Id
    /// </summary>
    [SugarColumn(ColumnDescription = "数据权限区域Id")]
    public string? AreaId { get; set; }

    public void CreateDataPermission(string creatorId, string? creatorName, string orgId, string? orgName, int orgLevel,
        string? areaId)
    {
        CreatorId = creatorId;
        CreatorName = creatorName;
        CreatorOrgId = orgId;
        CreatorOrgName = orgName;
        CreatorOrgLevel = orgLevel;
        AreaId = areaId;
    }

    public void AddEvent(IAppNotification notification)
    {
        if (_domainEvents.Contains(notification)) return;
        _domainEvents.Add(notification);
    }

    public void ClearEvents() => _domainEvents.Clear();

    public ICollection<IAppNotification> QueryAllEvents() => _domainEvents;
}

/// <summary>
/// 实体（带有创建时间）
/// </summary>
public abstract class CreationEntity : Entity, IHasCreationTime
{
    /// <summary>
    /// 创建时间
    /// </summary>
    [SugarColumn(ColumnDescription = "创建时间")]
    public DateTime CreationTime { get; set; }
}

/// <summary>
/// 实体（带有软删除）
/// </summary>
public abstract class SoftDeleteEntity : Entity, IHasDeletionTime, ISoftDelete
{
    /// <summary>
    /// 删除时间
    /// </summary>
    [SugarColumn(ColumnDescription = "删除时间")]
    public DateTime? DeletionTime { get; set; }

    [SugarColumn(ColumnDescription = "是否删除")]
    public bool IsDeleted { get; set; }

    public void SoftDelete()
    {
        IsDeleted = true;
        DeletionTime = DateTime.Now;
    }
}

/// <summary>
/// 实体（带有创建时间和软删除）
/// </summary>
public abstract class CreationSoftDeleteEntity : CreationEntity, IHasDeletionTime, ISoftDelete
{
    [SugarColumn(ColumnDescription = "是否删除", DefaultValue = "f")]
    public bool IsDeleted { get; set; }

    /// <summary>
    /// 删除时间
    /// </summary>
    [SugarColumn(ColumnDescription = "删除时间")]
    public DateTime? DeletionTime { get; set; }

    public void SoftDelete()
    {
        IsDeleted = true;
        DeletionTime = DateTime.Now;
    }

    public void Recover() => IsDeleted = false;
}

public abstract class CreationModificationEntity : CreationEntity, IHasModificationTime
{
    /// <summary>
    /// 最近更新时间
    /// </summary>
    [SugarColumn(ColumnDescription = "最近更新时间")]
    public DateTime? LastModificationTime { get; set; }

    public void Modified() => LastModificationTime = DateTime.Now;
}

/// <summary>
/// 全状态实体(创建时间、更新时间、软删除)
/// </summary>
public abstract class FullStateEntity : CreationSoftDeleteEntity, IHasModificationTime
{
    /// <summary>
    /// 最近更新时间
    /// </summary>
    [SugarColumn(ColumnDescription = "最近更新时间")]
    public DateTime? LastModificationTime { get; set; }

    public void Modified() => LastModificationTime = DateTime.Now;
}

public abstract class WorkflowEntity : FullStateEntity, IWorkflow
{
    [SugarColumn(IsNullable = true)] public string? WorkflowId { get; set; }

    /// <summary>
    /// 过期时间配置id
    /// </summary>
    [SugarColumn(IsNullable = true)]
    public string? ExpiredTimeConfigId { get; set; }

    [SugarColumn(ColumnDataType = "json", IsJson = true)]
    public List<string>? FlowedOrgIds { get; set; } = new();

    [SugarColumn(ColumnDataType = "json", IsJson = true)]
    public List<string>? FlowedUserIds { get; set; } = new();

    //[SugarColumn(ColumnDataType = "varchar(600)", IsJson = true)]
    //public List<string> AssignRoles { get; set; } = new();

    public void Assign(EFlowAssignType type, string handler)
    {
        handler = handler.ToLower();
        switch (type)
        {
            case EFlowAssignType.Org:
                var orgCodes = handler.GetHigherOrgCodes(true).ToList();
                FlowedOrgIds.AddRange(orgCodes);
                FlowedOrgIds = FlowedOrgIds.Distinct().ToList();
                break;
            case EFlowAssignType.User:
                if (!FlowedUserIds.Exists(d => d == handler))
                    FlowedUserIds.Add(handler);
                break;
            default:
                throw new ArgumentOutOfRangeException(nameof(type), type, null);
        }
    }

    public void Assign(EFlowAssignType type, IEnumerable<string> handlers)
    {
        handlers = handlers.Select(d => d.ToLower());
        switch (type)
        {
            case EFlowAssignType.Org:
                var orgCodes = handlers.SelectMany(d => d.GetHigherOrgCodes(true)).ToList();
                FlowedOrgIds.AddRange(orgCodes);
                FlowedOrgIds = FlowedOrgIds.Distinct().ToList();
                break;
            case EFlowAssignType.User:
                FlowedUserIds.AddRange(handlers);
                FlowedUserIds = FlowedUserIds.Distinct().ToList();
                break;
            default:
                throw new ArgumentOutOfRangeException(nameof(type), type, null);
        }
    }
}

public abstract class PositionEntity : FullStateEntity
{
    public PositionEntity()
    {
        FullAddress ??= $"{Address}{Street}";
    }

    /// <summary>
    /// 经度
    /// </summary>
    [SugarColumn(ColumnDescription = "经度")]
    public double? Longitude { get; set; }

    /// <summary>
    /// 维度
    /// </summary>
    [SugarColumn(ColumnDescription = "纬度")]
    public double? Latitude { get; set; }

    /// <summary>
    /// 行政区划编码
    /// </summary>
    [SugarColumn(ColumnDescription = "行政区划编码", IsNullable = true)]
    public string? AreaCode { get; set; }

    /// <summary>
    /// 行政区划地址
    /// </summary>
    public string? Address { get; set; }

    /// <summary>
    /// 详细街道
    /// </summary>
    public string? Street { get; set; }

    /// <summary>
    /// 完整地址
    /// </summary>
    public string? FullAddress { get; set; }
}

public abstract class PositionWorkflowEntity : PositionEntity, IWorkflow
{
    [SugarColumn(IsNullable = true)] public string? WorkflowId { get; set; }

    /// <summary>
    /// 过期时间配置id
    /// </summary>
    [SugarColumn(IsNullable = true)]
    public string? ExpiredTimeConfigId { get; set; }

    [SugarColumn(ColumnDataType = "json", IsJson = true)]
    public List<string>? FlowedOrgIds { get; set; } = new();

    [SugarColumn(ColumnDataType = "json", IsJson = true)]
    public List<string>? FlowedUserIds { get; set; } = new();

    //[SugarColumn(ColumnDataType = "varchar(600)", IsJson = true)]
    //public List<string> AssignRoles { get; set; } = new();

    public void Assign(EFlowAssignType type, string handler)
    {
        handler = handler.ToLower();
        switch (type)
        {
            case EFlowAssignType.Org:
                var orgCodes = handler.GetHigherOrgCodes(true).ToList();
                FlowedOrgIds.AddRange(orgCodes);
                FlowedOrgIds = FlowedOrgIds.Distinct().ToList();
                break;
            case EFlowAssignType.User:
                if (!FlowedUserIds.Exists(d => d == handler))
                    FlowedUserIds.Add(handler);
                break;
            default:
                throw new ArgumentOutOfRangeException(nameof(type), type, null);
        }
    }

    public void Assign(EFlowAssignType type, IEnumerable<string> handlers)
    {
        handlers = handlers.Select(d => d.ToLower());
        switch (type)
        {
            case EFlowAssignType.Org:
                var orgCodes = handlers.SelectMany(d => d.GetHigherOrgCodes(true)).ToList();
                FlowedOrgIds.AddRange(orgCodes);
                FlowedOrgIds = FlowedOrgIds.Distinct().ToList();
                break;
            case EFlowAssignType.User:
                FlowedUserIds.AddRange(handlers);
                FlowedUserIds = FlowedUserIds.Distinct().ToList();
                break;
            default:
                throw new ArgumentOutOfRangeException(nameof(type), type, null);
        }
    }

    public void InitId() => Id = SequentialStringGenerator.Create();
}