From 1e929a27745a71c3d908f51ac8ac03f700bbf13c Mon Sep 17 00:00:00 2001
From: liguoyang <Ligy.97@foxmail.com>
Date: Tue, 8 Apr 2025 14:52:51 +0800
Subject: [PATCH] =?UTF-8?q?fix=20dingtalk=E6=8E=A5=E6=94=B6=E4=BA=BA?=
 =?UTF-8?q?=E6=95=B0=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Jobs/SendMsgToWorkGridLeaderJob.cs              | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

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<WorkGridEntity>()
             .LeftJoin<GainfoEntity>((x, ga) => x.LeaderUserCode == ga.Code)
             .Select((x, ga) => new
@@ -29,10 +28,14 @@ public class SendMsgToWorkGridLeaderJob : BaseJob
             .ToListAsync();
 
         var dingtalkApi = serviceProvider.GetService<IDingTalkApi>();
-        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