From f25deabed601ce878d7dc286215499863732c1f1 Mon Sep 17 00:00:00 2001
From: liguoyang <Ligy.97@foxmail.com>
Date: Tue, 17 Dec 2024 17:47:46 +0800
Subject: [PATCH] =?UTF-8?q?fix=20deviceRegister=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Services/Implements/DeviceService.cs      | 36 ++++++++++++++-----
 1 file changed, 28 insertions(+), 8 deletions(-)

diff --git a/Src/Dlhis.Basic/Device/Services/Implements/DeviceService.cs b/Src/Dlhis.Basic/Device/Services/Implements/DeviceService.cs
index 10b0a5d4..6830d0ce 100644
--- a/Src/Dlhis.Basic/Device/Services/Implements/DeviceService.cs
+++ b/Src/Dlhis.Basic/Device/Services/Implements/DeviceService.cs
@@ -74,7 +74,7 @@ public class DeviceService : IDeviceService
                 entity.Code = Guid.NewGuid();
                 await _dbContext.InsertAsync(entity);
                 //同时保存注册信息
-                var registry = await _dbContext.Queryable<DeviceRegistryEntity>().Where(x => x.DeviceUniqueNo == request.UniqueNo).FirstAsync();
+                var registry = await _dbContext.Queryable<DeviceRegistryEntity>().Where(x => x.DeviceUniqueNo == request.UniqueNo).SingleAsync();
                 if (registry == null)
                 {
                     registry = new DeviceRegistryEntity
@@ -106,6 +106,20 @@ public class DeviceService : IDeviceService
 
                 request.Adapt(entity);
                 await _dbContext.UpdateAsync(entity);
+                
+                var registry = await _dbContext.Queryable<DeviceRegistryEntity>().Where(x => x.DeviceUniqueNo == request.UniqueNo).SingleAsync();
+                if (registry == null)
+                {
+                    registry = new DeviceRegistryEntity
+                    {
+                        DeviceUniqueNo = request.UniqueNo,
+                        LastHeartbeatTime = DateTime.Now,
+                        RegisterTime = DateTime.Now,
+                        BusinessPlaceCode = null,
+                    };
+
+                    await _dbContext.InsertAsync(registry);
+                }
             }
 
             await GenerateUploadRecordLogForBeginTimeAsync(entity);
@@ -271,19 +285,25 @@ public class DeviceService : IDeviceService
         var deviceUniqueNos = devices.Select(x => x.UniqueNo).ToList();
 
         var deviceRegistries = await _dbContext.Queryable<DeviceRegistryEntity>()
-            .LeftJoin<DeviceEntity>((x, d) => x.DeviceUniqueNo == d.UniqueNo)
             .Where(x => deviceUniqueNos.Contains(x.DeviceUniqueNo))
-            .Select((x, d) => new
+            .Select(x => new
             {
-                d.UniqueNo,
-                d.HeartbeatInterval,
+                x.DeviceUniqueNo,
                 x.LastHeartbeatTime
             })
             .ToListAsync();
 
-        var offlineUniqueNos = deviceRegistries
-            .Where(x => x.HeartbeatInterval > 0 && x.LastHeartbeatTime.AddSeconds(x.HeartbeatInterval) < now)
-            .Select(x => x.UniqueNo);
+        var offlineUniqueNos = devices.Where(x =>
+        {
+            var item = deviceRegistries.FirstOrDefault(p => p.DeviceUniqueNo == x.UniqueNo);
+
+            if (item == null)
+            {
+                return true;
+            }
+
+            return x.HeartbeatInterval > 0 && item.LastHeartbeatTime.AddSeconds(x.HeartbeatInterval) < now;
+        }).Select(x => x.UniqueNo);
 
         return devices.Where(x => offlineUniqueNos.Contains(x.UniqueNo)).Select(x => x.Id).ToList();
     }