From 909d310620e8eec485bca29698bc1914c36ad734 Mon Sep 17 00:00:00 2001
From: liguoyang <Ligy.97@foxmail.com>
Date: Sun, 16 Jun 2024 13:18:41 +0800
Subject: [PATCH] =?UTF-8?q?fix=20=E5=BF=83=E8=B7=B3=E9=97=B4=E9=9A=94?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 Src/Dlhis.ScheduledTask/Jobs/HeartbeatJob.cs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/Src/Dlhis.ScheduledTask/Jobs/HeartbeatJob.cs b/Src/Dlhis.ScheduledTask/Jobs/HeartbeatJob.cs
index cc25cb4e..c2cef7a0 100644
--- a/Src/Dlhis.ScheduledTask/Jobs/HeartbeatJob.cs
+++ b/Src/Dlhis.ScheduledTask/Jobs/HeartbeatJob.cs
@@ -22,17 +22,17 @@ public class HeartbeatJob : BaseJob
     {
         var devices = await DbContext.Queryable<DeviceEntity>().Where(x => x.Enable).Where(x => x.HeartbeatInterval > 0).ToListAsync();
 
-        devices.AsParallel().ForAll(device =>
+        await Parallel.ForEachAsync(devices, async (device, cancellationToken) =>
         {
             try
             {
                 var ipInfo = JsonConvert.DeserializeObject<IPPortDto>(device.ConnectionInfo);
-                new TcpClient().Connect(IPAddress.Parse(ipInfo.IP), ipInfo.Port);
+                await new TcpClient().ConnectAsync(IPAddress.Parse(ipInfo.IP), ipInfo.Port, cancellationToken);
 
-                DbContext.Updateable<DeviceRegistryEntity>()
+                await DbContext.Updateable<DeviceRegistryEntity>()
                     .SetColumns(x => x.LastHeartbeatTime == DateTime.Now)
                     .Where(x => x.DeviceUniqueNo == device.UniqueNo)
-                    .ExecuteCommand();
+                    .ExecuteCommandAsync(cancellationToken);
             }
             catch (Exception)
             {