Kayori_MedusaPluginChargeMachine/MedusaPluginChargeMachine/Handlers/LA9/GetLastLogEaChargeHandler.cs

using Abstractions.Handlers;
using Abstractions.SerializationTypes;
using MedusaPluginChargeMachine.Models.Request;
using MedusaPluginChargeMachine.Models.Response;
using MedusaPluginChargeMachine.Services;
using Microsoft.EntityFrameworkCore;

namespace MedusaPluginChargeMachine.Handlers.LA9;

public class GetLastLogEaChargeHandler(ISessionService sessionService, ChargeMachineDbContext db)
    : Handler<GetLastLogRequest, GetLastLogEaChargeResponse>
{
    public override void Configure()
    {
        Module("eacharge");
        Method("getlastlog");
    }

    public override async Task<GetLastLogEaChargeResponse> HandleAsync(GetLastLogRequest req, string model)
    {
        var today = DateTime.UtcNow.Date;
        var cardId = (string?)null;

        if (req.SessionId is not null)
        {
            var session = sessionService.GetSession(req.SessionId);
            cardId = session.refId;
        }

        var query = db.ChargeHistories.AsQueryable();
        if (cardId is not null)
            query = query.Where(h => h.CardId == cardId);

        var todayTotal = await query
            .Where(h => h.OrderDate.Date == today)
            .SumAsync(h => (int?)h.ChargeAmount) ?? 0;

        var recentItems = await query
            .OrderByDescending(h => h.OrderDate)
            .Take(10)
            .ToListAsync();

        return new GetLastLogEaChargeResponse
        {
            Status = 0,
            Header = new GetLastLogEaChargeHeader
            {
                Chargedaily = new XrpcInt(todayTotal),
                Items = recentItems.Select((h, i) => new GetLastLogChargeItem
                {
                    ChargeId = new XrpcString(h.Id.ToString()),
                    ChargeNum = new XrpcInt(h.ChargeNum),
                    ChargeAmount = new XrpcInt(h.ChargeAmount)
                }).ToList()
            }
        };
    }
}