XTrace.WriteLine

SynPlc/Worker.cs

@@ -34,7 +34,7 @@ public class Worker : BackgroundService
                 XTrace.WriteException(e);
             }
             
-            _logger.LogInformation("Worker running at: {time}", DateTimeOffset.Now);
+            XTrace.WriteLine("Worker running at: {time}", DateTimeOffset.Now);
 
             await Task.Delay(1000, stoppingToken);
         }
@@ -42,47 +42,39 @@ public class Worker : BackgroundService
 
     private async Task SynPlcFromDb(CancellationToken stoppingToken)
     {
-        try
+        var list = await DB.Queryable<EEquipmentStateEntity>().ToListAsync(stoppingToken);
+        foreach(var e in list)
         {
-            var list = await DB.Queryable<EEquipmentStateEntity>().ToListAsync(stoppingToken);
+            var a = await S7.ReadBoolAsync(e.Point);
-            foreach(var e in list)
+            if (a.IsSuccess)
             {
-                var a = await S7.ReadBoolAsync(e.Point);
+                e.UpdateTime = DateTime.Now;
-                if (a.IsSuccess)
+                e.PValue = a.Content;
-                {
+                await DB.Updateable(e).UpdateColumns(x => new { x.UpdateTime, x.PValue }).ExecuteCommandAsync(stoppingToken);
-                    e.UpdateTime = DateTime.Now;
-                    e.PValue = a.Content;
-                    await DB.Updateable(e).UpdateColumns(x => new { x.UpdateTime, x.PValue }).ExecuteCommandAsync(stoppingToken);
-                }
-                else
-                {
-                    XTrace.WriteLine("{0} 读取异常",e.Point );
-                }
             }
-
+            else
-            var listp = await DB.Queryable<EPointsInfoEntity>().ToListAsync(stoppingToken);
-            EPointDataEntity listd = new EPointDataEntity();
-            foreach (var e in listp)
             {
-                var a = await S7.ReadDoubleAsync(e.Point);
+                XTrace.WriteLine("{0} 读取异常",e.Point );
-                if (a.IsSuccess)
-                {
-                    listd.ID = Guid.NewGuid().ToString();
-                    listd.PID = e.ID;
-                    listd.CreateTime = DateTime.Now;
-                    listd.Data = a.Content.ToDecimal();
-                    await DB.Insertable(listd).ExecuteCommandAsync(stoppingToken);
-                }
-                else
-                {
-                    XTrace.WriteLine("{0} 读取异常",e.Point );
-                }
             }
         }
-        catch (Exception e)
+
+        var listp = await DB.Queryable<EPointsInfoEntity>().ToListAsync(stoppingToken);
+        EPointDataEntity listd = new EPointDataEntity();
+        foreach (var e in listp)
         {
-            Console.WriteLine(e);
+            var a = await S7.ReadDoubleAsync(e.Point);
-            throw;
+            if (a.IsSuccess)
+            {
+                listd.ID = Guid.NewGuid().ToString();
+                listd.PID = e.ID;
+                listd.CreateTime = DateTime.Now;
+                listd.Data = a.Content.ToDecimal();
+                await DB.Insertable(listd).ExecuteCommandAsync(stoppingToken);
+            }
+            else
+            {
+                XTrace.WriteLine("{0} 读取异常",e.Point );
+            }
         }
     }
 }