YD_Event.Admin/YD_Event.Application/Event/EventRecordService.cs

using YD_Event.Application.Event.Dtos;
using YD_Event.Core.Entities;
using YD_Event.Core.Enum;
using AppUserEntity = YD_Event.Core.Entities.AppUser;
using SysUserEntity = YD_Event.Core.Entities.SysUser;
using MerchantEntity = YD_Event.Core.Entities.Merchant;

namespace YD_Event.Application.Event;

/// <summary>
/// 参赛记录管理
/// </summary>
public class EventRecordService : BaseService<EventRegistration>, ITransient
{
    private readonly ISqlSugarRepository<EventRegistration> _registrationRep;
    private readonly ISqlSugarRepository<EventInfo> _eventRep;
    private readonly ISqlSugarRepository<EventCertificate> _certificateRep;
    private readonly ISqlSugarRepository<AppUserEntity> _appUserRep;
    private readonly ISqlSugarRepository<SysUserEntity> _sysUserRep;
    private readonly ISqlSugarRepository<MerchantEntity> _merchantRep;

    public EventRecordService(ISqlSugarRepository<EventRegistration> registrationRep,
        ISqlSugarRepository<EventInfo> eventRep,
        ISqlSugarRepository<EventCertificate> certificateRep,
        ISqlSugarRepository<AppUserEntity> appUserRep,
        ISqlSugarRepository<SysUserEntity> sysUserRep,
        ISqlSugarRepository<MerchantEntity> merchantRep) : base(registrationRep)
    {
        _registrationRep = registrationRep;
        _eventRep = eventRep;
        _certificateRep = certificateRep;
        _appUserRep = appUserRep;
        _sysUserRep = sysUserRep;
        _merchantRep = merchantRep;
    }

    /// <summary>
    /// 分页查询参赛记录
    /// </summary>
    [HttpGet("page")]
    public async Task<PageResult<EventRecordOutput>> Page([FromQuery] EventRecordPageInput input)
    {
        // 参数验证
        ValidateInput(input);

        // Join EventRegistration and EventInfo
        var query = _registrationRep.AsQueryable()
            .LeftJoin<EventInfo>((r, e) => r.EventId == e.Id)
            .LeftJoin<AppUserEntity>((r, e, u) => r.CreatedUserId == u.Id)
            .LeftJoin<SysUserEntity>((r, e, u, s) => r.CreatedUserId == s.Id)
            .LeftJoin<MerchantEntity>((r, e, u, s, m) => r.CreatedUserId == m.CreatedUserId)
            .WhereIF(!string.IsNullOrWhiteSpace(input.EventName), (r, e, u, s, m) => e.EventName.Contains(input.EventName))
            .WhereIF(input.StartTime.HasValue, (r, e, u, s, m) => e.MatchStartTime >= input.StartTime)
            .WhereIF(input.EndTime.HasValue, (r, e, u, s, m) => e.MatchStartTime <= input.EndTime)
            .WhereIF(input.PaymentStatus.HasValue, (r, e, u, s, m) => r.PaymentStatus == input.PaymentStatus)
            // Filter by User ID (AppUser, SysUser, or Merchant)
            .WhereIF(input.AppUserId.HasValue, (r, e, u, s, m) => u.Id == input.AppUserId)
            .WhereIF(input.SysUserId.HasValue, (r, e, u, s, m) => s.Id == input.SysUserId)
            .WhereIF(input.MerchantId.HasValue, (r, e, u, s, m) => m.CreatedUserId == input.MerchantId)
            .OrderByDescending((r, e, u, s, m) => r.CreatedTime)
            .Select((r, e, u, s, m) => new EventRecordOutput
            {
                Id = r.Id,
                EventName = e.EventName,
                EventType = e.EventType.ToString(), 
                StartTime = e.MatchStartTime,
                EndTime = e.MatchEndTime,
                PaymentStatus = r.PaymentStatus,
                EventId = e.Id,
                ContactName = r.ContactName,
                ContactPhone = r.ContactPhone,
                TeamName = r.TeamName
            });

        return await query.ToPagedListAsync(input);
    }

    /// <summary>
    /// 验证输入参数
    /// </summary>
    private void ValidateInput(EventRecordPageInput input)
    {
        // 检查是否同时提供了多个用户ID类型
        var userTypeCount = 0;
        if (input.AppUserId.HasValue) userTypeCount++;
        if (input.SysUserId.HasValue) userTypeCount++;
        if (input.MerchantId.HasValue) userTypeCount++;

        if (userTypeCount > 1)
        {
            throw Oops.Bah("只能提供一种用户类型ID参数（AppUserId、SysUserId或MerchantId）");
        }

        // 验证用户ID有效性
        if (input.AppUserId.HasValue && input.AppUserId.Value <= 0)
        {
            throw Oops.Bah("普通用户ID无效");
        }

        if (input.SysUserId.HasValue && input.SysUserId.Value <= 0)
        {
            throw Oops.Bah("系统用户ID无效");
        }

        if (input.MerchantId.HasValue && input.MerchantId.Value <= 0)
        {
            throw Oops.Bah("商户ID无效");
        }
    }

    /// <summary>
    /// 获取证书列表
    /// </summary>
    [HttpGet("{registrationId}/certificates")]
    public async Task<List<CertificateOutput>> GetCertificates([FromRoute] long registrationId)
    {
        var certs = await _certificateRep.AsQueryable()
            .Where(c => c.RegistrationId == registrationId)
            .ToListAsync();

        return certs.Select(c => new CertificateOutput
        {
            Id = c.Id,
            Name = c.ParticipantName,
            AwardLevel = GetAwardLevelName(c.AwardLevel),
            CertificateType = GetCertificateTypeName(c.CertificateType),
            ImageUrl = c.CertificateUrl
        }).ToList();
    }

    private string GetAwardLevelName(int level)
    {
        return level switch
        {
            1 => "特等奖",
            2 => "一等奖",
            3 => "二等奖",
            4 => "三等奖",
            5 => "优秀奖",
            _ => "未知"
        };
    }

    private string GetCertificateTypeName(int type)
    {
        return type switch
        {
            1 => "冠军证书",
            2 => "亚军证书",
            3 => "季军证书",
            4 => "优胜证书",
            5 => "参与证书",
            _ => "未知"
        };
    }
}