feat 最大连续排班控制增加

Src/Dlhis.Basic/WorkGrids/Services/Implements/WorkGridScheduleService.cs

@@ -62,6 +62,9 @@ public class WorkGridScheduleService : IWorkGridScheduleService
 
         await _dbContext.InsertAsync(toInserts);
 
+        var maximumConsecutiveDtos = await MaximumConsecutiveUserCodesAsync(request.UserCodes, 11, request.Date);
+        maximumConsecutiveDtos.ThrowIfExists(maximumConsecutiveDtos.Select(x => $"{x.UserCode}已经连续排班10天({x.Start}-{x.End}),不可继续排班").Join("\r\n"));
+
         await _operateLog.LogAsync(OperateLogType.WorkGrid, $"新增网格({workGrid.Name}){request.Date.ToString("yyyy-M-d")}的{request.PeriodType.GetDescription()}人员:{request.UserCodes.Join(",")}");
     }
 
@@ -206,4 +209,39 @@ public class WorkGridScheduleService : IWorkGridScheduleService
 
         await _operateLog.LogAsync(OperateLogType.WorkGrid, $"重提上传考勤:{requests.Select(x => x.Id).Join(",")}");
     }
+
+    public async Task<List<WorkGridScheduleMaximumConsecutiveDto>> MaximumConsecutiveUserCodesAsync(List<string> userCodes, int days, DateOnly date)
+    {
+        var p = userCodes.Select(x => $"@param{x}").Join(",");
+        var values = userCodes.ToDictionary(x => $"param{x}", x => x);
+
+        values.Add("date", date.ToString("yyyy-MM-dd"));
+        values.Add("days", days.ToString());
+
+        var sql = $@"
+WITH ranked_dates AS (SELECT UserCode,
+                             date,
+                             ROW_NUMBER() OVER (PARTITION BY UserCode ORDER BY date) AS rn
+                      FROM WorkGridSchedules where UserCode in ({p})
+                      GROUP BY UserCode, date),
+     grouped AS (SELECT UserCode,
+                        date,
+                        DATE_SUB(date, INTERVAL rn DAY) AS grp
+                 FROM ranked_dates),
+     streaks AS (SELECT UserCode,
+                        grp,
+                        COUNT(*)  AS streak_days,
+                        MIN(date) AS start_date,
+                        MAX(date) AS end_date
+                 FROM grouped
+                 GROUP BY UserCode, grp
+                 HAVING streak_days >= @days)
+SELECT UserCode, streak_days as Count, start_date as Start, end_date as End
+FROM streaks where @date>= start_date and @date<= end_date;
+
+";
+
+        var data = await _dbContext.Client.Ado.SqlQueryAsync<WorkGridScheduleMaximumConsecutiveDto>(sql, values);
+        return data;
+    }
 }