diff --git a/Src/Dlhis.ScheduledTask/Jobs/SendMsgToWorkGridLeaderJob.cs b/Src/Dlhis.ScheduledTask/Jobs/SendMsgToWorkGridLeaderJob.cs index 2adfdfd7..938e9ac5 100644 --- a/Src/Dlhis.ScheduledTask/Jobs/SendMsgToWorkGridLeaderJob.cs +++ b/Src/Dlhis.ScheduledTask/Jobs/SendMsgToWorkGridLeaderJob.cs @@ -17,7 +17,6 @@ public class SendMsgToWorkGridLeaderJob : BaseJob protected override async Task RunAsync(IServiceProvider serviceProvider) { - // var infos = await DbContext.Queryable() .LeftJoin((x, ga) => x.LeaderUserCode == ga.Code) .Select((x, ga) => new @@ -29,10 +28,14 @@ public class SendMsgToWorkGridLeaderJob : BaseJob .ToListAsync(); var dingtalkApi = serviceProvider.GetService(); - await dingtalkApi.SendWorkMessageAsync(new JinkoSendWorkMessageRequest + + foreach (var items in infos.Chunk(20)) { - Content = "你好,网格长,请看到消息后,前往人脸应用平台,执行明天的排班,已排班的请忽略!", - WorkCodes = infos.Select(x => x.LeaderUserCode).ToList() - }); + await dingtalkApi.SendWorkMessageAsync(new JinkoSendWorkMessageRequest + { + Content = "你好,网格长,请看到消息后,前往人脸应用平台,执行明天的排班,已排班的请忽略!", + WorkCodes = items.Select(x => x.LeaderUserCode).ToList() + }); + } } } \ No newline at end of file