EmailBill/Service/Message/MessageService.cs

namespace Service.Message;

public interface IMessageService
{
    Task<(IEnumerable<MessageRecord> List, long Total)> GetPagedListAsync(int pageIndex, int pageSize);
    Task<MessageRecord?> GetByIdAsync(long id);
    Task<bool> AddAsync(MessageRecord message);
    Task<bool> AddAsync(string title, string content, MessageType type = MessageType.Text, string? url = null);
    Task<bool> MarkAsReadAsync(long id);
    Task<bool> MarkAllAsReadAsync();
    Task<bool> DeleteAsync(long id);
    Task<long> GetUnreadCountAsync();
}

public class MessageService(IMessageRecordRepository messageRepo, INotificationService notificationService) : IMessageService
{
    public async Task<(IEnumerable<MessageRecord> List, long Total)> GetPagedListAsync(int pageIndex, int pageSize)
    {
        return await messageRepo.GetPagedListAsync(pageIndex, pageSize);
    }

    public async Task<MessageRecord?> GetByIdAsync(long id)
    {
        return await messageRepo.GetByIdAsync(id);
    }

    public async Task<bool> AddAsync(MessageRecord message)
    {
        return await messageRepo.AddAsync(message);
    }

    public async Task<bool> AddAsync(
        string title, 
        string content, 
        MessageType type = MessageType.Text, 
        string? url = null
    )
    {
        var message = new MessageRecord
        {
            Title = title,
            Content = content,
            MessageType = type,
            Url = url,
            IsRead = false
        };
        var result = await messageRepo.AddAsync(message);
        if (result)
        {
            await notificationService.SendNotificationAsync(title, url);
        }
        return result;
    }

    public async Task<bool> MarkAsReadAsync(long id)
    {
        var message = await messageRepo.GetByIdAsync(id);
        if (message == null) return false;
    
        message.IsRead = true;
        message.UpdateTime = DateTime.Now;
        return await messageRepo.UpdateAsync(message);
    }

    public async Task<bool> MarkAllAsReadAsync()
    {
        return await messageRepo.MarkAllAsReadAsync();
    }

    public async Task<bool> DeleteAsync(long id)
    {
        return await messageRepo.DeleteAsync(id);
    }

    public async Task<long> GetUnreadCountAsync()
    {
        var list = await messageRepo.GetAllAsync();
        return list.Count(x => !x.IsRead);
    }
}