ANTOOZA-BACKEND/Application/Features/Api/Note/SendNote/Handler.cs

using Application.Abstractions.Data;
using Application.Abstractions.Messaging;
using Application.Abstractions.Notification;
using Application.Helpers;
using Domain.Entities.Notifications.ValueObject;
using Domain.Entities.Store.ValueObject;
using Microsoft.EntityFrameworkCore;
using SharedKernel.Results;

namespace Application.Features.Api.Note.SendNote;

internal sealed class Handler(
    IAppDbContext db,
    INotificationService notification
) : ICommandHandler<Command, Result<Response>>
{
    public async Task<Result<Response>> Handle(Command r, CancellationToken ct)
    {
        if (string.IsNullOrWhiteSpace(r.Title) || string.IsNullOrWhiteSpace(r.Content))
        {
            return Result.Failure<Response>(Error.Problem("Note.TitleContentRequired", "제목과 내용을 입력해주세요."));
        }

        var now = DateTime.UtcNow;
        int receiverID = r.ReceiverMemberID;
        bool consumeNotePass = false;

        if (!r.IsSystem)
        {
            // 무작위 수신자 발송 — 쪽지권 필요, 서버가 수신자 선정 (네이버 쪽지 스타일)
            if (r.SendToRandom)
            {
                if (!await MemberItemConsumer.HasAvailableAsync(db, r.SenderMemberID, ItemKind.NotePass, ct))
                {
                    return Result.Failure<Response>(Error.Problem("Note.NotePassRequired", "무작위 쪽지 발송에는 쪽지권이 필요합니다."));
                }

                var candidateCount = await db.Member.CountAsync(m => m.ID != r.SenderMemberID && !m.IsWithdraw && !m.IsDenied, ct);
                if (candidateCount == 0)
                {
                    return Result.Failure<Response>(Error.Problem("Note.NoRandomReceiver", "받을 수 있는 회원이 없습니다."));
                }

                var offset = Random.Shared.Next(candidateCount);
                receiverID = await db.Member
                    .Where(m => m.ID != r.SenderMemberID && !m.IsWithdraw && !m.IsDenied)
                    .OrderBy(m => m.ID)
                    .Skip(offset)
                    .Take(1)
                    .Select(m => m.ID)
                    .FirstAsync(ct);

                consumeNotePass = true;
            }
            else if (r.SenderMemberID == receiverID)
            {
                return Result.Failure<Response>(Error.Problem("Note.SelfSendNotAllowed", "자신에게 쪽지를 보낼 수 없습니다."));
            }

            // 일일 발송 제한 (시스템 쪽지 제외). 한도 초과 시 쪽지권으로 추가 발송 허용.
            var dailyLimit = await db.Config.AsNoTracking()
                .OrderByDescending(c => c.ID)
                .Select(c => c.Basic.NoteDailySendLimit)
                .FirstOrDefaultAsync(ct);

            if (dailyLimit <= 0)
            {
                return Result.Failure<Response>(Error.Problem("Note.SendDisabled", "현재 쪽지 발송이 차단되어 있습니다."));
            }

            if (!consumeNotePass)
            {
                var todayUtc = now.Date;
                var sentToday = await db.Note.AsNoTracking()
                    .CountAsync(n => n.SenderMemberID == r.SenderMemberID && !n.IsSystem && n.CreatedAt >= todayUtc, ct);

                if (sentToday >= dailyLimit)
                {
                    if (await MemberItemConsumer.HasAvailableAsync(db, r.SenderMemberID, ItemKind.NotePass, ct))
                    {
                        consumeNotePass = true;
                    }
                    else
                    {
                        return Result.Failure<Response>(Error.Problem("Note.DailyLimitExceeded", $"하루 최대 {dailyLimit}건까지 발송할 수 있습니다. (쪽지권으로 추가 발송 가능)"));
                    }
                }
            }
        }

        // 수신자 유효성 (탈퇴/차단 회원에게는 발송 차단)
        var receiverValid = await db.Member.AsNoTracking()
            .AnyAsync(m => m.ID == receiverID && !m.IsWithdraw && !m.IsDenied, ct);

        if (!receiverValid)
        {
            return Result.Failure<Response>(Error.NotFound("Note.ReceiverNotFound", "받는 회원을 찾을 수 없습니다."));
        }

        var note = r.IsSystem
            ? Domain.Entities.Notes.Note.CreateSystem(receiverID, r.Title, r.Content, r.RelatedType, r.RelatedID)
            : Domain.Entities.Notes.Note.Create(r.SenderMemberID, receiverID, r.Title, r.Content, false, r.RelatedType, r.RelatedID);

        db.Note.Add(note);

        if (consumeNotePass)
        {
            var passDetail = r.SendToRandom ? "무작위 쪽지 발송" : "쪽지 한도 초과 발송";
            var consumed = await MemberItemConsumer.TryConsumeAsync(db, r.SenderMemberID, ItemKind.NotePass, now, passDetail, ct);
            if (!consumed)
            {
                return Result.Failure<Response>(Error.Problem("Note.NotePassRequired", "쪽지권이 없습니다."));
            }
        }

        await db.SaveChangesAsync(ct);

        // 받는 사람에게 NoteReceived 알림 (시스템 쪽지도 발송 대상에게 알림).
        // 표기 우선순위: 채널명 > 회원 별명. 보조 식별자(@handle / #sid) 도 노출.
        string senderDisplay;
        if (r.IsSystem)
        {
            senderDisplay = "시스템";
        }
        else
        {
            var senderInfo = await db.Member.AsNoTracking()
                .Where(m => m.ID == r.SenderMemberID)
                .Select(m => new {
                    m.Name, m.SID,
                    ChannelName = m.Channel != null ? m.Channel.Name : null,
                    ChannelHandle = m.Channel != null ? m.Channel.Handle : null
                })
                .FirstOrDefaultAsync(ct);

            var primary = senderInfo?.ChannelName ?? senderInfo?.Name ?? "알 수 없는 회원";
            var secondary = !string.IsNullOrEmpty(senderInfo?.ChannelHandle)
                ? $"@{senderInfo.ChannelHandle}"
                : (!string.IsNullOrEmpty(senderInfo?.SID) ? $"#{senderInfo.SID}" : null);
            senderDisplay = secondary is null ? primary : $"{primary} ({secondary})";
        }

        await notification.SendAsync(
            receiverID,
            NotificationType.NoteReceived,
            "새 쪽지가 도착했습니다",
            $"{senderDisplay}: {r.Title}",
            actionUrl: "/note/inbox",
            relatedType: "Note",
            relatedID: note.ID,
            ct: ct
        );

        return Result.Success(new Response(note.ID));
    }
}