Implement transport time improvements: departure station display and break time logic (#17)
* Initial plan * Implement transport time improvements: departure station display and break time logic Co-authored-by: clayschaad <11883505+clayschaad@users.noreply.github.com> * Enhance code --------- Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com> Co-authored-by: clayschaad <11883505+clayschaad@users.noreply.github.com> Co-authored-by: Claudio Schaad <c.schaad@pog.ch>
This commit is contained in:
parent
45fa364368
commit
2530e729ce
9 changed files with 64 additions and 129 deletions
|
|
@ -112,7 +112,7 @@ namespace ShiftScheduler.Client.Pages
|
||||||
var response = await HttpClient.PostAsJsonAsync("api/shift/export_pdf", shiftsWithTransportList);
|
var response = await HttpClient.PostAsJsonAsync("api/shift/export_pdf", shiftsWithTransportList);
|
||||||
var bytes = await response.Content.ReadAsByteArrayAsync();
|
var bytes = await response.Content.ReadAsByteArrayAsync();
|
||||||
var base64 = Convert.ToBase64String(bytes);
|
var base64 = Convert.ToBase64String(bytes);
|
||||||
await JSRuntime.InvokeVoidAsync("downloadFile", $"Schedule {EditYear}-{EditMonth:00}.pdf", "application/pdf", base64);
|
await JSRuntime.InvokeVoidAsync("downloadFile", $"Schedule {EditYear}-{EditMonth:D2}.pdf", "application/pdf", base64);
|
||||||
}
|
}
|
||||||
|
|
||||||
private async Task SaveScheduleToStorage()
|
private async Task SaveScheduleToStorage()
|
||||||
|
|
|
||||||
|
|
@ -12,20 +12,20 @@ namespace ShiftScheduler.Server.Controllers
|
||||||
private readonly IcsExportService _icsService;
|
private readonly IcsExportService _icsService;
|
||||||
private readonly PdfExportService _pdfExportService;
|
private readonly PdfExportService _pdfExportService;
|
||||||
private readonly TransportService _transportService;
|
private readonly TransportService _transportService;
|
||||||
private readonly ShiftEnrichmentService _enrichmentService;
|
private readonly TransportConfiguration _transportConfig;
|
||||||
|
|
||||||
public ShiftController(
|
public ShiftController(
|
||||||
ShiftService shiftService,
|
ShiftService shiftService,
|
||||||
IcsExportService icsService,
|
IcsExportService icsService,
|
||||||
PdfExportService pdfExportService,
|
PdfExportService pdfExportService,
|
||||||
TransportService transportService,
|
TransportService transportService,
|
||||||
ShiftEnrichmentService enrichmentService)
|
TransportConfiguration transportConfig)
|
||||||
{
|
{
|
||||||
_shiftService = shiftService;
|
_shiftService = shiftService;
|
||||||
_icsService = icsService;
|
_icsService = icsService;
|
||||||
_pdfExportService = pdfExportService;
|
_pdfExportService = pdfExportService;
|
||||||
_transportService = transportService;
|
_transportService = transportService;
|
||||||
_enrichmentService = enrichmentService;
|
_transportConfig = transportConfig;
|
||||||
}
|
}
|
||||||
|
|
||||||
[HttpGet("shifts")]
|
[HttpGet("shifts")]
|
||||||
|
|
@ -34,13 +34,6 @@ namespace ShiftScheduler.Server.Controllers
|
||||||
return Ok(_shiftService.GetShifts());
|
return Ok(_shiftService.GetShifts());
|
||||||
}
|
}
|
||||||
|
|
||||||
[HttpPost("transport_connection")]
|
|
||||||
public async Task<IActionResult> GetTransportConnection([FromBody] TransportConnectionRequest request)
|
|
||||||
{
|
|
||||||
var connection = await _transportService.GetConnectionAsync(request.ArrivalTime, request.EndStation);
|
|
||||||
return Ok(connection);
|
|
||||||
}
|
|
||||||
|
|
||||||
[HttpPost("shift_transport")]
|
[HttpPost("shift_transport")]
|
||||||
public async Task<IActionResult> GetShiftTransport([FromBody] ShiftTransportRequest request)
|
public async Task<IActionResult> GetShiftTransport([FromBody] ShiftTransportRequest request)
|
||||||
{
|
{
|
||||||
|
|
@ -64,7 +57,25 @@ namespace ShiftScheduler.Server.Controllers
|
||||||
}
|
}
|
||||||
|
|
||||||
// Get transport for afternoon shift if it has afternoon time
|
// Get transport for afternoon shift if it has afternoon time
|
||||||
|
// But only if the break between morning and afternoon is long enough
|
||||||
if (!string.IsNullOrEmpty(shift.AfternoonTime))
|
if (!string.IsNullOrEmpty(shift.AfternoonTime))
|
||||||
|
{
|
||||||
|
var shouldLoadAfternoonTransport = true;
|
||||||
|
|
||||||
|
// If both morning and afternoon shifts exist, check break duration
|
||||||
|
if (!string.IsNullOrEmpty(shift.MorningTime) && !string.IsNullOrEmpty(shift.AfternoonTime))
|
||||||
|
{
|
||||||
|
var morningEndTime = ParseShiftEndTime(request.Date, shift.MorningTime);
|
||||||
|
var afternoonStartTime = ParseShiftTime(request.Date, shift.AfternoonTime);
|
||||||
|
|
||||||
|
if (morningEndTime.HasValue && afternoonStartTime.HasValue)
|
||||||
|
{
|
||||||
|
var breakDurationMinutes = (afternoonStartTime.Value - morningEndTime.Value).TotalMinutes;
|
||||||
|
shouldLoadAfternoonTransport = breakDurationMinutes >= _transportConfig.MinBreakMinutes;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (shouldLoadAfternoonTransport)
|
||||||
{
|
{
|
||||||
var afternoonStartTime = ParseShiftTime(request.Date, shift.AfternoonTime);
|
var afternoonStartTime = ParseShiftTime(request.Date, shift.AfternoonTime);
|
||||||
if (afternoonStartTime.HasValue)
|
if (afternoonStartTime.HasValue)
|
||||||
|
|
@ -72,13 +83,14 @@ namespace ShiftScheduler.Server.Controllers
|
||||||
afternoonTransport = await _transportService.GetConnectionAsync(afternoonStartTime.Value);
|
afternoonTransport = await _transportService.GetConnectionAsync(afternoonStartTime.Value);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
var shiftWithTransport = new ShiftWithTransport
|
var shiftWithTransport = new ShiftWithTransport
|
||||||
{
|
{
|
||||||
Date = request.Date,
|
Date = request.Date,
|
||||||
Shift = shift,
|
Shift = shift,
|
||||||
MorningTransport = morningTransport,
|
MorningTransport = morningTransport,
|
||||||
AfternoonTransport = afternoonTransport
|
AfternoonTransport = afternoonTransport,
|
||||||
};
|
};
|
||||||
|
|
||||||
return Ok(shiftWithTransport);
|
return Ok(shiftWithTransport);
|
||||||
|
|
@ -101,6 +113,23 @@ namespace ShiftScheduler.Server.Controllers
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private static DateTime? ParseShiftEndTime(DateTime date, string timeRange)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var times = timeRange.Split('-');
|
||||||
|
if (times.Length > 1 && TimeSpan.TryParse(times[1], out var endTime))
|
||||||
|
{
|
||||||
|
return date.Add(endTime);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch
|
||||||
|
{
|
||||||
|
// Ignore parsing errors
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
[HttpPost("export_ics")]
|
[HttpPost("export_ics")]
|
||||||
public IActionResult ExportIcsWithTransport([FromBody] List<ShiftWithTransport> shiftsWithTransport)
|
public IActionResult ExportIcsWithTransport([FromBody] List<ShiftWithTransport> shiftsWithTransport)
|
||||||
{
|
{
|
||||||
|
|
@ -116,12 +145,6 @@ namespace ShiftScheduler.Server.Controllers
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public class TransportConnectionRequest
|
|
||||||
{
|
|
||||||
public DateTime ArrivalTime { get; set; }
|
|
||||||
public string? EndStation { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class ShiftTransportRequest
|
public class ShiftTransportRequest
|
||||||
{
|
{
|
||||||
public string ShiftName { get; set; } = string.Empty;
|
public string ShiftName { get; set; } = string.Empty;
|
||||||
|
|
|
||||||
|
|
@ -15,7 +15,6 @@ builder.Services.AddSingleton<ShiftService>();
|
||||||
builder.Services.AddSingleton<IcsExportService>();
|
builder.Services.AddSingleton<IcsExportService>();
|
||||||
builder.Services.AddSingleton<PdfExportService>();
|
builder.Services.AddSingleton<PdfExportService>();
|
||||||
builder.Services.AddSingleton<TransportService>();
|
builder.Services.AddSingleton<TransportService>();
|
||||||
builder.Services.AddSingleton<ShiftEnrichmentService>();
|
|
||||||
|
|
||||||
builder.Services.AddControllersWithViews();
|
builder.Services.AddControllersWithViews();
|
||||||
builder.Services.AddRazorPages();
|
builder.Services.AddRazorPages();
|
||||||
|
|
|
||||||
|
|
@ -11,7 +11,8 @@
|
||||||
"StartStation": "Zurich",
|
"StartStation": "Zurich",
|
||||||
"EndStation": "Basel",
|
"EndStation": "Basel",
|
||||||
"ApiBaseUrl": "http://transport.opendata.ch/v1",
|
"ApiBaseUrl": "http://transport.opendata.ch/v1",
|
||||||
"SafetyBufferMinutes": 30
|
"SafetyBufferMinutes": 30,
|
||||||
|
"MinBreakMinutes": 60
|
||||||
},
|
},
|
||||||
|
|
||||||
"Shifts": [
|
"Shifts": [
|
||||||
|
|
|
||||||
|
|
@ -1,77 +0,0 @@
|
||||||
using ShiftScheduler.Shared.Models;
|
|
||||||
|
|
||||||
namespace ShiftScheduler.Services
|
|
||||||
{
|
|
||||||
public class ShiftEnrichmentService
|
|
||||||
{
|
|
||||||
private readonly TransportService _transportService;
|
|
||||||
|
|
||||||
public ShiftEnrichmentService(TransportService transportService)
|
|
||||||
{
|
|
||||||
_transportService = transportService;
|
|
||||||
}
|
|
||||||
|
|
||||||
public async Task<List<ShiftTransport>> EnrichShiftsWithTransportAsync(List<Shift> shifts, Dictionary<DateTime, string> schedule)
|
|
||||||
{
|
|
||||||
var shiftTransports = new List<ShiftTransport>();
|
|
||||||
|
|
||||||
foreach (var shift in shifts)
|
|
||||||
{
|
|
||||||
var shiftTransport = new ShiftTransport
|
|
||||||
{
|
|
||||||
ShiftName = shift.Name
|
|
||||||
};
|
|
||||||
|
|
||||||
// Find dates where this shift is scheduled
|
|
||||||
var scheduledDates = schedule.Where(kvp => kvp.Value == shift.Name).Select(kvp => kvp.Key).ToList();
|
|
||||||
|
|
||||||
if (scheduledDates.Count > 0)
|
|
||||||
{
|
|
||||||
// Use the first scheduled date to calculate transport times
|
|
||||||
var sampleDate = scheduledDates.First();
|
|
||||||
|
|
||||||
// Get transport for morning shift
|
|
||||||
if (!string.IsNullOrEmpty(shift.MorningTime))
|
|
||||||
{
|
|
||||||
var morningStartTime = ParseShiftTime(sampleDate, shift.MorningTime);
|
|
||||||
if (morningStartTime.HasValue)
|
|
||||||
{
|
|
||||||
shiftTransport.MorningTransport = await _transportService.GetConnectionAsync(morningStartTime.Value);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get transport for afternoon shift
|
|
||||||
if (!string.IsNullOrEmpty(shift.AfternoonTime))
|
|
||||||
{
|
|
||||||
var afternoonStartTime = ParseShiftTime(sampleDate, shift.AfternoonTime);
|
|
||||||
if (afternoonStartTime.HasValue)
|
|
||||||
{
|
|
||||||
shiftTransport.AfternoonTransport = await _transportService.GetConnectionAsync(afternoonStartTime.Value);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
shiftTransports.Add(shiftTransport);
|
|
||||||
}
|
|
||||||
|
|
||||||
return shiftTransports;
|
|
||||||
}
|
|
||||||
|
|
||||||
private DateTime? ParseShiftTime(DateTime date, string timeRange)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
var times = timeRange.Split('-');
|
|
||||||
if (times.Length > 0 && TimeSpan.TryParse(times[0], out var startTime))
|
|
||||||
{
|
|
||||||
return date.Add(startTime);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
catch
|
|
||||||
{
|
|
||||||
// Ignore parsing errors
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -23,13 +23,12 @@ namespace ShiftScheduler.Services
|
||||||
// Calculate the latest acceptable arrival time (shift start time - safety buffer)
|
// Calculate the latest acceptable arrival time (shift start time - safety buffer)
|
||||||
var latestArrivalTime = shiftStartTime.AddMinutes(-_config.SafetyBufferMinutes);
|
var latestArrivalTime = shiftStartTime.AddMinutes(-_config.SafetyBufferMinutes);
|
||||||
|
|
||||||
// Search for connections starting from a reasonable time before the latest acceptable arrival
|
// Search for arrival time
|
||||||
// Start searching from 90 minutes before the latest acceptable time
|
var searchTime = shiftStartTime;
|
||||||
var searchTime = latestArrivalTime.AddMinutes(-90);
|
|
||||||
var searchTimeStr = searchTime.ToString("yyyy-MM-dd");
|
var searchTimeStr = searchTime.ToString("yyyy-MM-dd");
|
||||||
var searchHourStr = searchTime.ToString("HH:mm");
|
var searchHourStr = searchTime.ToString("HH:mm");
|
||||||
|
|
||||||
var url = $"{_config.ApiBaseUrl}/connections?from={Uri.EscapeDataString(_config.StartStation)}&to={Uri.EscapeDataString(endStation)}&date={searchTimeStr}&time={searchHourStr}&limit=15";
|
var url = $"{_config.ApiBaseUrl}/connections?from={Uri.EscapeDataString(_config.StartStation)}&to={Uri.EscapeDataString(endStation)}&date={searchTimeStr}&time={searchHourStr}&isArrivalTime=1&limit=5";
|
||||||
|
|
||||||
var response = await _httpClient.GetStringAsync(url);
|
var response = await _httpClient.GetStringAsync(url);
|
||||||
var apiResponse = JsonSerializer.Deserialize<TransportApiResponse>(response, new JsonSerializerOptions
|
var apiResponse = JsonSerializer.Deserialize<TransportApiResponse>(response, new JsonSerializerOptions
|
||||||
|
|
@ -121,25 +120,11 @@ namespace ShiftScheduler.Services
|
||||||
|
|
||||||
if (validConnections.Count > 0)
|
if (validConnections.Count > 0)
|
||||||
{
|
{
|
||||||
// Sort by arrival time (earliest first) and take the one that arrives
|
|
||||||
// with reasonable margin but not too early
|
|
||||||
var sortedValid = validConnections
|
var sortedValid = validConnections
|
||||||
.OrderBy(c => DateTime.Parse(c.To?.Arrival ?? "00:00"))
|
.OrderBy(c => DateTime.Parse(c.To?.Arrival ?? "00:00"))
|
||||||
.ToList();
|
.ToList();
|
||||||
|
|
||||||
// Prefer a connection that arrives with 10-45 minutes margin
|
return sortedValid.Last();
|
||||||
var preferredMarginMin = 10;
|
|
||||||
var preferredMarginMax = 45;
|
|
||||||
|
|
||||||
var idealConnection = sortedValid.LastOrDefault(c =>
|
|
||||||
{
|
|
||||||
var arrivalTime = DateTime.Parse(c.To?.Arrival ?? "00:00");
|
|
||||||
var marginMinutes = (latestArrivalTime - arrivalTime).TotalMinutes;
|
|
||||||
return marginMinutes >= preferredMarginMin && marginMinutes <= preferredMarginMax;
|
|
||||||
});
|
|
||||||
|
|
||||||
// If we found an ideal connection, use it; otherwise use the latest valid one
|
|
||||||
return idealConnection ?? sortedValid.Last();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// If no valid connections, return the earliest available
|
// If no valid connections, return the earliest available
|
||||||
|
|
|
||||||
|
|
@ -18,7 +18,7 @@ namespace ShiftScheduler.Shared.Models
|
||||||
return AfternoonTransport != null ? FormatTransportSummary(AfternoonTransport) : string.Empty;
|
return AfternoonTransport != null ? FormatTransportSummary(AfternoonTransport) : string.Empty;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static string FormatTransportSummary(TransportConnection connection)
|
private string FormatTransportSummary(TransportConnection connection)
|
||||||
{
|
{
|
||||||
if (string.IsNullOrEmpty(connection.DepartureTime)) return string.Empty;
|
if (string.IsNullOrEmpty(connection.DepartureTime)) return string.Empty;
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,18 +1,12 @@
|
||||||
namespace ShiftScheduler.Shared.Models
|
namespace ShiftScheduler.Shared.Models
|
||||||
{
|
{
|
||||||
public class ShiftTransport
|
|
||||||
{
|
|
||||||
public string ShiftName { get; set; } = string.Empty;
|
|
||||||
public TransportConnection? MorningTransport { get; set; }
|
|
||||||
public TransportConnection? AfternoonTransport { get; set; }
|
|
||||||
}
|
|
||||||
|
|
||||||
public class TransportConfiguration
|
public class TransportConfiguration
|
||||||
{
|
{
|
||||||
public string StartStation { get; set; } = string.Empty;
|
public string StartStation { get; set; } = string.Empty;
|
||||||
public string EndStation { get; set; } = string.Empty;
|
public string EndStation { get; set; } = string.Empty;
|
||||||
public string ApiBaseUrl { get; set; } = string.Empty;
|
public string ApiBaseUrl { get; set; } = string.Empty;
|
||||||
public int SafetyBufferMinutes { get; set; } = 30;
|
public int SafetyBufferMinutes { get; set; } = 30;
|
||||||
|
public int MinBreakMinutes { get; set; } = 60;
|
||||||
}
|
}
|
||||||
|
|
||||||
public class TransportConnection
|
public class TransportConnection
|
||||||
|
|
@ -64,6 +58,11 @@ namespace ShiftScheduler.Shared.Models
|
||||||
public TransportApiCheckpoint? To { get; set; }
|
public TransportApiCheckpoint? To { get; set; }
|
||||||
public string Duration { get; set; } = string.Empty;
|
public string Duration { get; set; } = string.Empty;
|
||||||
public List<TransportApiSection> Sections { get; set; } = new();
|
public List<TransportApiSection> Sections { get; set; } = new();
|
||||||
|
|
||||||
|
public override string ToString()
|
||||||
|
{
|
||||||
|
return $"{From} - {To}";
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public class TransportApiCheckpoint
|
public class TransportApiCheckpoint
|
||||||
|
|
@ -72,6 +71,11 @@ namespace ShiftScheduler.Shared.Models
|
||||||
public string Departure { get; set; } = string.Empty;
|
public string Departure { get; set; } = string.Empty;
|
||||||
public string Arrival { get; set; } = string.Empty;
|
public string Arrival { get; set; } = string.Empty;
|
||||||
public string Platform { get; set; } = string.Empty;
|
public string Platform { get; set; } = string.Empty;
|
||||||
|
|
||||||
|
public override string ToString()
|
||||||
|
{
|
||||||
|
return $"{Station?.Name}: {Departure} - {Arrival}";
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public class TransportApiStation
|
public class TransportApiStation
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue