fix 优化查询null值,注释

Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateGetAttendanceJob.cs

@@ -2,57 +2,57 @@
 using Dlhis.Entity.Device.Entities;
 using Dlhis.Entity.Device.Enums;
 using Kurisu.AspNetCore.Utils.Extensions;
+using Kurisu.Core.DataAccess.Entity;
 using Kurisu.SqlSugar.Services;
 
-namespace Dlhis.ScheduledTask.TaskAssignment.Job
+namespace Dlhis.ScheduledTask.TaskAssignment.Job;
+
+public class CreateGetAttendanceJob
 {
-    public class CreateGetAttendanceJob
+    private readonly IDbContext _dbContext;
+    private readonly ILogger<CreateSyncServerDateTimeJob> _logger;
+
+    public CreateGetAttendanceJob(IDbContext dbContext, ILogger<CreateSyncServerDateTimeJob> logger)
     {
-        private readonly IDbContext _dbContext;
-        private readonly ILogger<CreateSyncServerDateTimeJob> _logger;
+        _logger = logger;
+        _dbContext = dbContext;
+    }
 
-        public CreateGetAttendanceJob(IDbContext dbContext, ILogger<CreateSyncServerDateTimeJob> logger)
+    public async Task RunAsync()
+    {
+        _dbContext.Client.QueryFilter.ClearAndBackup<ITenantId>();
+        try
         {
-            _logger = logger;
-            _dbContext = dbContext;
+            var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync();
+            devices = devices.Where(x => x.Funcs.Contains(DeviceFuncEnumType.Attendance)).ToList();
+
+            var tasks = devices.Select(x => new DeviceTaskEntity
+            {
+                DeviceUniqueNo = x.UniqueNo,
+                Status = DeviceTaskStatusEnumType.Wait,
+
+                TenantId = x.TenantId,
+                Version = 0,
+                UserNo = string.Empty,
+                UserCode = string.Empty,
+                Type = DeviceTaskEnumType.UploadRecord,
+
+                CreatedBy = 1,
+                CreateTime = DateTime.Now,
+                ModifiedBy = 1,
+                ModifiedTime = DateTime.Now,
+
+            }).ToList();
+
+            await _dbContext.InsertAsync(tasks);
         }
-
-        public async Task RunAsync()
+        catch (Exception ex)
         {
-            _dbContext.Client.QueryFilter.ClearAndBackup();
-            try
-            {
-                var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync();
-                devices = devices.Where(x => x.Funcs.Contains(DeviceFuncEnumType.Attendance)).ToList();
-
-                var tasks = devices.Select(x => new DeviceTaskEntity
-                {
-                    DeviceUniqueNo = x.UniqueNo,
-                    Status = DeviceTaskStatusEnumType.Wait,
-
-                    TenantId = x.TenantId,
-                    Version = 0,
-                    UserNo = string.Empty,
-                    UserCode = string.Empty,
-                    Type = DeviceTaskEnumType.UploadRecord,
-
-                    CreatedBy = 1,
-                    CreateTime = DateTime.Now,
-                    ModifiedBy = 1,
-                    ModifiedTime = DateTime.Now,
-
-                }).ToList();
-
-                await _dbContext.InsertAsync(tasks);
-            }
-            catch (Exception ex)
-            {
-                _logger.LogError(ex, $"生成{DeviceTaskEnumType.UploadRecord.GetDescription()}任务失败:" + ex.Message);
-            }
-            finally
-            {
-                _dbContext.Client.QueryFilter.Restore();
-            }
+            _logger.LogError(ex, "生成{type}任务失败:{message}", DeviceTaskEnumType.UploadRecord.GetDescription(), ex.Message);
+        }
+        finally
+        {
+            _dbContext.Client.QueryFilter.Restore();
         }
     }
 }