// frontend/src/services/shiftAssignmentService.ts - WEEKLY PATTERN VERSION import { ShiftPlan, ScheduledShift } from '../models/ShiftPlan'; import { Employee, EmployeeAvailability } from '../models/Employee'; import { authService } from './authService'; import { scheduleWithManager } from './scheduling/shiftScheduler'; import { transformToSchedulingData } from './scheduling/dataAdapter'; import { AssignmentResult, WeeklyPattern } from './scheduling/types'; import { isScheduledShift } from '../models/helpers'; const API_BASE_URL = 'http://localhost:3002/api/scheduled-shifts'; // Helper function to get auth headers const getAuthHeaders = () => { const token = localStorage.getItem('token'); return { 'Content-Type': 'application/json', ...(token && { 'Authorization': `Bearer ${token}` }) }; }; export class ShiftAssignmentService { async updateScheduledShift(id: string, updates: { assignedEmployees: string[] }): Promise { try { console.log('πŸ”„ Updating scheduled shift via API:', { id, updates }); const response = await fetch(`${API_BASE_URL}/${id}`, { method: 'PUT', headers: { 'Content-Type': 'application/json', ...authService.getAuthHeaders() }, body: JSON.stringify(updates) }); // First, check if we got any response if (!response.ok) { // Try to get error message from response const responseText = await response.text(); console.error('❌ Server response:', responseText); let errorMessage = `HTTP ${response.status}: ${response.statusText}`; // Try to parse as JSON if possible try { const errorData = JSON.parse(responseText); errorMessage = errorData.error || errorMessage; } catch (e) { // If not JSON, use the text as is errorMessage = responseText || errorMessage; } throw new Error(errorMessage); } // Try to parse successful response const responseText = await response.text(); let result; try { result = responseText ? JSON.parse(responseText) : {}; } catch (e) { console.warn('⚠️ Response was not JSON, but request succeeded'); result = { message: 'Update successful' }; } console.log('βœ… Scheduled shift updated successfully:', result); } catch (error) { console.error('❌ Error updating scheduled shift:', error); throw error; } } async getScheduledShift(id: string): Promise { try { const response = await fetch(`${API_BASE_URL}/${id}`, { headers: { 'Authorization': `Bearer ${localStorage.getItem('token')}` } }); if (!response.ok) { const responseText = await response.text(); let errorMessage = `HTTP ${response.status}: ${response.statusText}`; try { const errorData = JSON.parse(responseText); errorMessage = errorData.error || errorMessage; } catch (e) { errorMessage = responseText || errorMessage; } throw new Error(errorMessage); } const responseText = await response.text(); return responseText ? JSON.parse(responseText) : {}; } catch (error) { console.error('Error fetching scheduled shift:', error); throw error; } } // New method to get all scheduled shifts for a plan async getScheduledShiftsForPlan(planId: string): Promise { try { const response = await fetch(`${API_BASE_URL}/plan/${planId}`, { headers: { 'Authorization': `Bearer ${localStorage.getItem('token')}` } }); if (!response.ok) { throw new Error(`Failed to fetch scheduled shifts: ${response.status}`); } return await response.json(); } catch (error) { console.error('Error fetching scheduled shifts for plan:', error); throw error; } } static async assignShifts( shiftPlan: ShiftPlan, employees: Employee[], availabilities: EmployeeAvailability[], constraints: any = {} ): Promise { console.log('πŸ”„ Starting enhanced scheduling algorithm...'); // Get defined shifts for the first week const definedShifts = await this.getDefinedShifts(shiftPlan); const firstWeekShifts = this.getFirstWeekShifts(definedShifts); console.log('πŸ“Š First week analysis:', { totalShifts: definedShifts.length, firstWeekShifts: firstWeekShifts.length, employees: employees.length }); // Transform data for scheduling algorithm const { schedulingEmployees, schedulingShifts, managerShifts } = transformToSchedulingData( employees.filter(emp => emp.isActive), firstWeekShifts, availabilities ); console.log('🎯 Transformed data for scheduling:', { employees: schedulingEmployees.length, shifts: schedulingShifts.length, managerShifts: managerShifts.length }); // Run the enhanced scheduling algorithm with better constraints const schedulingResult = scheduleWithManager( schedulingShifts, schedulingEmployees, managerShifts, { enforceNoTraineeAlone: constraints.enforceNoTraineeAlone ?? true, enforceExperiencedWithChef: constraints.enforceExperiencedWithChef ?? true, maxRepairAttempts: constraints.maxRepairAttempts ?? 50, targetEmployeesPerShift: constraints.targetEmployeesPerShift ?? 2 // Flexible target } ); console.log('πŸ“Š Enhanced scheduling completed:', { assignments: Object.keys(schedulingResult.assignments).length, violations: schedulingResult.violations.length, success: schedulingResult.success }); // Apply weekly pattern to all shifts const weeklyPattern: WeeklyPattern = { weekShifts: firstWeekShifts, assignments: schedulingResult.assignments, weekNumber: 1 }; const allAssignments = this.applyWeeklyPattern(definedShifts, weeklyPattern); return { assignments: allAssignments, violations: schedulingResult.violations, success: schedulingResult.violations.length === 0, pattern: weeklyPattern, resolutionReport: schedulingResult.resolutionReport // FΓΌge diese Zeile hinzu }; } private static async createWeeklyPattern( definedShifts: ScheduledShift[], employees: Employee[], availabilities: EmployeeAvailability[], enforceNoTraineeAlone: boolean ): Promise { // Get first week of shifts (7 days from the start) const firstWeekShifts = this.getFirstWeekShifts(definedShifts); console.log('πŸ“… First week analysis:'); console.log('- Shifts in first week:', firstWeekShifts.length); // Fix: Use Array.from instead of spread operator with Set const uniqueDays = Array.from(new Set(firstWeekShifts.map(s => this.getDayOfWeek(s.date)))).sort(); console.log('- Days covered:', uniqueDays); // Build availability map const availabilityMap = this.buildAvailabilityMap(availabilities); const employeeMap = new Map(employees.map(emp => [emp.id, emp])); // Initialize assignment state for first week const weeklyAssignments: { [shiftId: string]: string[] } = {}; const employeeAssignmentCount: { [employeeId: string]: number } = {}; employees.forEach(emp => { employeeAssignmentCount[emp.id] = 0; }); firstWeekShifts.forEach(shift => { weeklyAssignments[shift.id] = []; }); // Sort employees by capacity and experience const sortedEmployees = [...employees].sort((a, b) => { const aCapacity = this.getMaxAssignments(a); const bCapacity = this.getMaxAssignments(b); const aIsManager = a.role === 'admin'; const bIsManager = b.role === 'admin'; if (aIsManager !== bIsManager) return aIsManager ? -1 : 1; if (a.employeeType !== b.employeeType) { if (a.employeeType === 'experienced') return -1; if (b.employeeType === 'experienced') return 1; } return bCapacity - aCapacity; }); // Sort shifts by priority (those with fewer available employees first) const sortedShifts = [...firstWeekShifts].sort((a, b) => { const aAvailable = this.countAvailableEmployees(a, employees, availabilityMap); const bAvailable = this.countAvailableEmployees(b, employees, availabilityMap); return aAvailable - bAvailable; }); // Assign employees to first week shifts for (const employee of sortedEmployees) { const maxAssignments = this.getMaxAssignments(employee); // Get available shifts for this employee in first week const availableShifts = sortedShifts .filter(shift => { if (employeeAssignmentCount[employee.id] >= maxAssignments) return false; if (weeklyAssignments[shift.id].length >= shift.requiredEmployees) return false; const dayOfWeek = this.getDayOfWeek(shift.date); const shiftKey = `${dayOfWeek}-${shift.timeSlotId}`; return this.isEmployeeAvailable(employee, shiftKey, availabilityMap) && this.isAssignmentCompatible(employee, weeklyAssignments[shift.id], employeeMap, enforceNoTraineeAlone); }) .sort((a, b) => { // Prefer shifts with fewer current assignments return weeklyAssignments[a.id].length - weeklyAssignments[b.id].length; }); // Assign to available shifts until capacity is reached for (const shift of availableShifts) { if (employeeAssignmentCount[employee.id] >= maxAssignments) break; weeklyAssignments[shift.id].push(employee.id); employeeAssignmentCount[employee.id]++; console.log(`βœ… Assigned ${employee.name} to weekly pattern shift`); if (employeeAssignmentCount[employee.id] >= maxAssignments) break; } } // Ensure all shifts in first week have at least one employee for (const shift of firstWeekShifts) { if (weeklyAssignments[shift.id].length === 0) { const dayOfWeek = this.getDayOfWeek(shift.date); const shiftKey = `${dayOfWeek}-${shift.timeSlotId}`; const availableEmployees = employees .filter(emp => this.isEmployeeAvailable(emp, shiftKey, availabilityMap) && this.canAssignByContract(emp, employeeAssignmentCount) ) .sort((a, b) => { const aPref = availabilityMap.get(a.id)?.get(shiftKey) || 3; const bPref = availabilityMap.get(b.id)?.get(shiftKey) || 3; const aCount = employeeAssignmentCount[a.id] || 0; const bCount = employeeAssignmentCount[b.id] || 0; if (aPref !== bPref) return aPref - bPref; return aCount - bCount; }); if (availableEmployees.length > 0) { const bestCandidate = availableEmployees[0]; weeklyAssignments[shift.id].push(bestCandidate.id); employeeAssignmentCount[bestCandidate.id]++; console.log(`πŸ†˜ Emergency assigned ${bestCandidate.name} to weekly pattern`); } } } return { weekShifts: firstWeekShifts, assignments: weeklyAssignments, weekNumber: 1 }; } private static applyWeeklyPattern( allShifts: ScheduledShift[], weeklyPattern: WeeklyPattern ): { [shiftId: string]: string[] } { const assignments: { [shiftId: string]: string[] } = {}; // Group all shifts by week const shiftsByWeek = this.groupShiftsByWeek(allShifts); console.log('πŸ“… Applying weekly pattern to', Object.keys(shiftsByWeek).length, 'weeks'); // For each week, apply the pattern from week 1 Object.entries(shiftsByWeek).forEach(([weekKey, weekShifts]) => { const weekNumber = parseInt(weekKey); weekShifts.forEach(shift => { // Find the corresponding shift in the weekly pattern const patternShift = this.findMatchingPatternShift(shift, weeklyPattern.weekShifts); if (patternShift) { // Use the same assignment as the pattern shift assignments[shift.id] = [...weeklyPattern.assignments[patternShift.id]]; } else { // No matching pattern shift, leave empty assignments[shift.id] = []; } }); }); return assignments; } private static groupShiftsByWeek(shifts: ScheduledShift[]): { [weekNumber: string]: ScheduledShift[] } { const weeks: { [weekNumber: string]: ScheduledShift[] } = {}; shifts.forEach(shift => { const weekNumber = this.getWeekNumber(shift.date); if (!weeks[weekNumber]) { weeks[weekNumber] = []; } weeks[weekNumber].push(shift); }); return weeks; } private static getFirstWeekShifts(shifts: ScheduledShift[]): ScheduledShift[] { if (shifts.length === 0) return []; // Sort by date and get the first 7 days const sortedShifts = [...shifts].sort((a, b) => a.date.localeCompare(b.date)); const firstDate = new Date(sortedShifts[0].date); const firstWeekEnd = new Date(firstDate); firstWeekEnd.setDate(firstWeekEnd.getDate() + 6); // 7 days total return sortedShifts.filter(shift => { const shiftDate = new Date(shift.date); return shiftDate >= firstDate && shiftDate <= firstWeekEnd; }); } private static findMatchingPatternShift( shift: ScheduledShift, patternShifts: ScheduledShift[] ): ScheduledShift | null { const shiftDayOfWeek = this.getDayOfWeek(shift.date); const shiftTimeSlot = shift.timeSlotId; return patternShifts.find(patternShift => this.getDayOfWeek(patternShift.date) === shiftDayOfWeek && patternShift.timeSlotId === shiftTimeSlot ) || null; } private static getWeekNumber(dateString: string): number { const date = new Date(dateString); const firstDayOfYear = new Date(date.getFullYear(), 0, 1); const pastDaysOfYear = (date.getTime() - firstDayOfYear.getTime()) / 86400000; return Math.ceil((pastDaysOfYear + firstDayOfYear.getDay() + 1) / 7); } // ========== EXISTING HELPER METHODS ========== static async getDefinedShifts(shiftPlan: ShiftPlan): Promise { let scheduledShifts: ScheduledShift[] = []; try { scheduledShifts = await shiftAssignmentService.getScheduledShiftsForPlan(shiftPlan.id); } catch (err) { console.error("Failed to load scheduled shifts:", err); return []; } if (scheduledShifts.length) return []; const definedShiftPatterns = new Set( shiftPlan.shifts.map(shift => `${shift.dayOfWeek}-${shift.timeSlotId}` ) ); const definedShifts = scheduledShifts.filter(scheduledShift => { const dayOfWeek = this.getDayOfWeek(scheduledShift.date); const pattern = `${dayOfWeek}-${scheduledShift.timeSlotId}`; return definedShiftPatterns.has(pattern); }); return definedShifts; } private static countAvailableEmployees( scheduledShift: ScheduledShift, employees: Employee[], availabilityMap: Map> ): number { const dayOfWeek = this.getDayOfWeek(scheduledShift.date); const shiftKey = `${dayOfWeek}-${scheduledShift.timeSlotId}`; return employees.filter(emp => this.isEmployeeAvailable(emp, shiftKey, availabilityMap) ).length; } private static isAssignmentCompatible( candidate: Employee, currentAssignments: string[], employeeMap: Map, enforceNoTraineeAlone: boolean ): boolean { if (!enforceNoTraineeAlone || currentAssignments.length === 0) return true; const currentEmployees = currentAssignments.map(id => employeeMap.get(id)).filter(Boolean) as Employee[]; if (candidate.employeeType === 'trainee') { const hasExperiencedOrChef = currentEmployees.some(emp => emp.employeeType === 'experienced' || emp.role === 'admin' ); return hasExperiencedOrChef; } return true; } private static buildAvailabilityMap(availabilities: EmployeeAvailability[]): Map> { const map = new Map>(); availabilities.forEach(avail => { if (!map.has(avail.employeeId)) { map.set(avail.employeeId, new Map()); } const shiftKey = `${avail.dayOfWeek}-${avail.timeSlotId}`; map.get(avail.employeeId)!.set(shiftKey, avail.preferenceLevel); }); return map; } private static isEmployeeAvailable( employee: Employee, shiftKey: string, availabilityMap: Map> ): boolean { if (!employee.isActive) return false; const employeeAvailability = availabilityMap.get(employee.id); if (!employeeAvailability) return false; const preference = employeeAvailability.get(shiftKey); return preference !== undefined && preference !== 3; } private static canAssignByContract( employee: Employee, assignmentCount: { [employeeId: string]: number } ): boolean { const currentCount = assignmentCount[employee.id] || 0; const maxAssignments = this.getMaxAssignments(employee); return currentCount < maxAssignments; } private static getMaxAssignments(employee: Employee): number { switch (employee.contractType) { case 'small': return 1; case 'large': return 2; default: return 999; } } private static findViolations( assignments: { [shiftId: string]: string[] }, employees: Employee[], definedShifts: ScheduledShift[], enforceNoTraineeAlone: boolean ): string[] { const violations: string[] = []; const employeeMap = new Map(employees.map(emp => [emp.id, emp])); definedShifts.forEach(scheduledShift => { const assignedEmployeeIds = assignments[scheduledShift.id] || []; if (assignedEmployeeIds.length === 0) { violations.push(`Shift has no assigned employees`); return; } const assignedEmployees = assignedEmployeeIds.map(id => employeeMap.get(id)).filter(Boolean) as Employee[]; if (enforceNoTraineeAlone && assignedEmployees.length === 1) { const soloEmployee = assignedEmployees[0]; if (soloEmployee.employeeType === 'trainee') { violations.push(`Trainee ${soloEmployee.name} is working alone`); } } }); return violations; } private static getDayOfWeek(dateString: string): number { const date = new Date(dateString); return date.getDay() === 0 ? 7 : date.getDay(); } } export const shiftAssignmentService = new ShiftAssignmentService();