admin/src/Oms.SqlSugarCore/Orders/OrderFileRepository.cs

using Fake.DependencyInjection;
using Oms.Domain.OrdersAggregate.Entities;
using Oms.Domain.OrdersAggregate.Repositories;
using Oms.SqlSugarCore.Repositories;

namespace Oms.SqlSugarCore.Orders;

public class OrderFileRepository
    : OmsSqlSugarRepository<OrderFile>,
        IOrderFileRepository,
        IScopedDependency
{
    public Task<List<OrderFile>> GetByOrderIdAsync(int orderId, CancellationToken cancellationToken = default) =>
        GetListAsync(
            x => x.OrderId == orderId,
            cancellationToken: cancellationToken);

    public Task<OrderFile?> GetByOrderAndTypeAsync(
        int orderId,
        string fileType,
        CancellationToken cancellationToken = default) =>
        FirstOrDefaultAsync(
            x => x.OrderId == orderId && x.FileType == fileType,
            cancellationToken);

    public Task<List<OrderFile>> GetByOrderAndTypeListAsync(
        int orderId,
        string fileType,
        CancellationToken cancellationToken = default) =>
        GetListAsync(
            x => x.OrderId == orderId && x.FileType == fileType,
            cancellationToken: cancellationToken);

    public Task<List<OrderFile>> GetByOrderIdsAndTypeAsync(
        IReadOnlyCollection<int> orderIds,
        string fileType,
        CancellationToken cancellationToken = default)
    {
        var ids = orderIds?.Where(x => x > 0).Distinct().ToList() ?? [];
        if (ids.Count == 0)
        {
            return Task.FromResult(new List<OrderFile>());
        }

        return GetListAsync(
            x => ids.Contains(x.OrderId) && x.FileType == fileType,
            cancellationToken: cancellationToken);
    }

    public async Task SoftDeleteByOrderAndTypeAsync(
        int orderId,
        string fileType,
        CancellationToken cancellationToken = default)
    {
        var list = await GetByOrderAndTypeListAsync(orderId, fileType, cancellationToken);
        foreach (var item in list)
        {
            item.IsDeleted = true;
            item.UpdateTime = DateTime.Now;
            await UpdateAsync(item, cancellationToken);
        }
    }
}