using Dpz.Core.Service.Mediator.Features.Account.Internal;
using Dpz.Core.Service.Mediator.Features.Account.Queries;

namespace Dpz.Core.Service.Mediator.Features.Account.Commands;

/// <summary>
/// 处理修改账号头像请求
/// </summary>
public class UpdateAccountAvatarHandler(
    IRepository<User> userRepository,
    IRepository<UserHistory> userHistoryRepository,
    IMediator mediator,
    IFusionCache fusionCache
) : IRequestHandler<UpdateAccountAvatarRequest, ResponseResult<VmUserInfo?>>
{
    /// <summary>
    /// 修改头像并返回最新用户信息
    /// </summary>
    public async ValueTask<ResponseResult<VmUserInfo?>> Handle(
        UpdateAccountAvatarRequest request,
        CancellationToken cancellationToken
    )
    {
        var user = await AccountRepositoryHelper.GetUserAsync(
            userRepository,
            request.Account,
            cancellationToken
        );
        if (user == null)
        {
            return ResponseResult<VmUserInfo?>.Fail($"账号【{request.Account}】不存在");
        }

        await AccountRepositoryHelper.SaveUserHistoryAsync(
            userHistoryRepository,
            user.Id,
            [AccountRepositoryHelper.Change(nameof(user.Avatar), user.Avatar, request.Avatar)],
            cancellationToken
        );

        var update = Builders<User>
            .Update.Set(x => x.Avatar, request.Avatar)
            .Set(x => x.LastUpdateTime, DateTime.Now);
        await userRepository.UpdateAsync(x => x.Id == user.Id, update, cancellationToken);
        var userInfo = await mediator.Send(
            new GetUserInfoRequest { Account = request.Account },
            cancellationToken
        );
        await fusionCache.SetAsync(
            UserSessionKeys.ChangedAtKey(request.Account),
            DateTime.Now,
            TimeSpan.FromDays(30),
            token: cancellationToken
        );
        return ResponseResult<VmUserInfo?>.Ok(userInfo);
    }
}