YD_Event.Admin/YD_Event.Application/Referee/RefereeService.cs

using EasyCaching.Core;
using YD_Event.Application.Auth;
using YD_Event.Application.Referee.Dtos;
using YD_Event.Core.Entities;
using YD_Event.Core.Enum;

namespace YD_Event.Application.Referee;

/// <summary>裁判库管理。</summary>
public class RefereeService : BaseService<YD_Event.Core.Entities.Referee>, ITransient
{
    private readonly ISqlSugarRepository<YD_Event.Core.Entities.Referee> _repository;
    private readonly ISqlSugarRepository<YD_Event.Core.Entities.AppUser> _userRepository;
    private readonly IEasyCachingProvider _cache;
    private readonly IIdGenerator _idGenerator;
    private readonly AuthManager _authManager;

    public RefereeService(ISqlSugarRepository<YD_Event.Core.Entities.Referee> repository,
        ISqlSugarRepository<YD_Event.Core.Entities.AppUser> userRepository, IEasyCachingProvider cache,
        IIdGenerator idGenerator, AuthManager authManager) : base(repository)
    {
        _repository = repository;
        _userRepository = userRepository;
        _cache = cache;
        _idGenerator = idGenerator;
        _authManager = authManager;
    }

    [DisplayName("裁判分页查询")]
    public async Task<PageResult<RefereeOutput>> Page([FromQuery] RefereeQueryInput input)
    {
        var query = _repository.AsQueryable()
            .WhereIF(!string.IsNullOrWhiteSpace(input.Name), x => x.Name.Contains(input.Name!))
            .WhereIF(!string.IsNullOrWhiteSpace(input.Mobile), x => x.Mobile.Contains(input.Mobile!))
            .WhereIF(!string.IsNullOrWhiteSpace(input.RegionCode), x => x.ProvinceCode == input.RegionCode || x.CityCode == input.RegionCode || x.DistrictCode == input.RegionCode)
            .WhereIF(input.Level.HasValue, x => x.Level == input.Level)
            .WhereIF(input.Role.HasValue, x => (x.Roles & input.Role!.Value) == input.Role.Value)
            .WhereIF(input.AuditStatus.HasValue, x => x.AuditStatus == input.AuditStatus)
            .WhereIF(input.StartTime.HasValue, x => x.CreatedTime >= input.StartTime)
            .WhereIF(input.EndTime.HasValue, x => x.CreatedTime < input.EndTime!.Value.Date.AddDays(1))
            .OrderByDescending(x => x.CreatedTime);
        var page = await query.ToPagedListAsync(input);
        return new PageResult<RefereeOutput>
        {
            PageNo = page.PageNo, PageSize = page.PageSize, Total = page.Total,
            Rows = page.Rows.Select(ToOutput).ToList()
        };
    }

    [DisplayName("新增裁判")]
    public async Task Add([FromBody] SaveRefereeInput input)
    {
        await EnsureMobileAvailable(input.Mobile, null);
        await VerifyCode(input.Mobile, input.VerificationCode);
        var entity = input.Adapt<YD_Event.Core.Entities.Referee>();
        entity.Id = _idGenerator.NextId();
        entity.AuditStatus = AuditStatus.PendingAudit;
        entity.Status = AvailabilityStatus.Enable;
        entity.CreatedUserId = _authManager.UserId;
        entity.CreatedTime = DateTime.Now;
        await _repository.InsertAsync(entity);
        await _cache.RemoveAsync($"sms:code:{input.Mobile}");
    }

    [DisplayName("修改裁判")]
    public async Task Update([FromBody] UpdateRefereeInput input)
    {
        var entity = await _repository.GetByIdAsync(input.Id);
        if (entity == null || entity.DeleteMark) throw Oops.Bah("裁判不存在");
        await EnsureMobileAvailable(input.Mobile, input.Id);
        if (!string.Equals(entity.Mobile, input.Mobile, StringComparison.Ordinal))
        {
            await VerifyCode(input.Mobile, input.VerificationCode);
            await _cache.RemoveAsync($"sms:code:{input.Mobile}");
        }
        input.Adapt(entity);
        entity.UpdatedUserId = _authManager.UserId;
        entity.UpdatedTime = DateTime.Now;
        await _repository.UpdateAsync(entity);
    }

    [DisplayName("审核裁判"), HttpPost("audit")]
    public async Task Audit([FromBody] AuditRefereeInput input)
    {
        if (input.AuditStatus != AuditStatus.Pass && input.AuditStatus != AuditStatus.Reject)
            throw Oops.Bah("审核状态不正确");
        var entity = await _repository.GetByIdAsync(input.Id);
        if (entity == null || entity.DeleteMark) throw Oops.Bah("裁判不存在");
        entity.AuditStatus = input.AuditStatus;
        entity.AuditRemark = input.Remark;
        entity.UpdatedUserId = _authManager.UserId;
        entity.UpdatedTime = DateTime.Now;
        await _repository.UpdateAsync(entity);
    }

    private async Task EnsureMobileAvailable(string mobile, long? exceptId)
    {
        if (await _repository.IsAnyAsync(x => x.Mobile == mobile && (!exceptId.HasValue || x.Id != exceptId.Value)))
            throw Oops.Bah("该手机号已存在于裁判库");
        if (await _userRepository.IsAnyAsync(x => x.Mobile == mobile))
            throw Oops.Bah("该手机号已绑定现有账号");
    }

    private async Task VerifyCode(string mobile, string? code)
    {
        if (string.IsNullOrWhiteSpace(code)) throw Oops.Bah("请输入验证码");
        var cached = await _cache.GetAsync<string>($"sms:code:{mobile}");
        if (!cached.HasValue || cached.Value != code) throw Oops.Bah("验证码错误或已过期");
    }

    private static RefereeOutput ToOutput(YD_Event.Core.Entities.Referee x) => new()
    {
        Id = x.Id, Name = x.Name, Mobile = x.Mobile,
        ProvinceCode = x.ProvinceCode, ProvinceName = x.ProvinceName,
        CityCode = x.CityCode, CityName = x.CityName,
        DistrictCode = x.DistrictCode, DistrictName = x.DistrictName,
        RegionName = $"{x.ProvinceName}/{x.CityName}/{x.DistrictName}",
        Level = x.Level, LevelName = x.Level.Description(), CertificateUrl = x.CertificateUrl,
        Roles = x.Roles,
        RoleNames = Enum.GetValues<RefereeRole>().Where(r => r != RefereeRole.None && x.Roles.HasFlag(r)).Select(r => r.Description()).ToList(),
        AuditStatus = x.AuditStatus, AuditRemark = x.AuditRemark, CreatedTime = x.CreatedTime
    };
}