zengzy / hhrcs_service · Files

using Microsoft.EntityFrameworkCore;
using Rcs.Domain.Entities;
using Rcs.Domain.Repositories;
using Rcs.Infrastructure.DB.MsSql;

namespace Rcs.Infrastructure.DB.Repositories
{
    /// <summary>
    /// 充电桩仓储实现。
    /// </summary>
    public class ChargingPileRepository : Repository<ChargingPile>, IChargingPileRepository
    {
        public ChargingPileRepository(AppDbContext context) : base(context)
        {
        }

        public async Task<ChargingPile?> GetByPileCodeAsync(string pileCode, CancellationToken cancellationToken = default)
        {
            return await _dbSet.FirstOrDefaultAsync(p => p.PileCode == pileCode, cancellationToken);
        }

        public async Task<ChargingPile?> GetByIpAndPortAsync(string ipAddress, int port, CancellationToken cancellationToken = default)
        {
            return await _dbSet.FirstOrDefaultAsync(p => p.IpAddress == ipAddress && p.Port == port, cancellationToken);
        }
    }
}