NikitaShipilov/PIBD-21_Shipilov_N.S._ProjectGasStation
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Правки

Browse Source
This commit is contained in:
Никита Шипилов 2024-12-08 21:00:44 +04:00
parent dcaac2153e
commit 2cde8b4735
2 changed files with 4 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ProjectGasStation/ProjectGasStation/Repositories/IShiftRepository.cs
View File

@ -4,7 +4,7 @@ namespace ProjectGasStation.Repositories;
public interface IShiftRepository public interface IShiftRepository
{ {
IEnumerable<Shift> ReadShifts(DateTime? dateFrom = null, DateTime? dateTo = null); IEnumerable<Shift> ReadShifts();
Shift ReadShiftById(int id); Shift ReadShiftById(int id);
void CreateShift(Shift shift); void CreateShift(Shift shift);
void UpdateShift(Shift shift); void UpdateShift(Shift shift);

15
ProjectGasStation/ProjectGasStation/Repositories/Implementations/ShiftRepository.cs
View File

@ -78,23 +78,14 @@ public class ShiftRepository : IShiftRepository
} }
} }
public IEnumerable<Shift> ReadShifts(DateTime? dateFrom = null, DateTime? dateTo = null) public IEnumerable<Shift> ReadShifts()
{ {
_logger.LogInformation("Получение всех объектов"); _logger.LogInformation("Получение всех объектов");
try try
{ {
var builder = new QueryBuilder();
if (dateFrom.HasValue)
{
builder.AddCondition("Date >= @dateFrom");
}
if (dateTo.HasValue)
{
builder.AddCondition("Date <= @dateTo");
}
using var connection = new NpgsqlConnection(_connectionString.ConnectionString); using var connection = new NpgsqlConnection(_connectionString.ConnectionString);
var querySelect = $"SELECT * FROM Shift {builder.Build()}"; var querySelect = "SELECT * FROM Shift";
var shifts = connection.Query<Shift>(querySelect, new { dateFrom, dateTo }); var shifts = connection.Query<Shift>(querySelect);
_logger.LogDebug("Полученные объекты: {json}", _logger.LogDebug("Полученные объекты: {json}",
JsonConvert.SerializeObject(shifts)); JsonConvert.SerializeObject(shifts));
return shifts; return shifts;