change - 设备初始化逻辑修改

Sln.Imm.Daemon.Business/DeviceCollectionBusiness.cs

@@ -68,22 +68,22 @@ public class DeviceCollectionBusiness
             {
                 try
                 {
-                    _serilog.Info($"开始采集{item.deviceName}");
+                    _serilog.Info($"开始采集{item.deviceName}；参数：{JsonConvert.SerializeObject(item.deviceParams)}");
                     var opcItemValues = await this.ReadParam(item, opcua);
 
                     this.SaveParam(item, opcItemValues, out List<BaseDeviceParamVal> paramValues);
 
                     _serilog.Info($"{item.deviceName}数据采集完成：{JsonConvert.SerializeObject(opcItemValues)}");
 
-                    if(i == 10)
-                    {
-
-                        isFlag = false;
-
-                        opcua.DisconnectAsync().Wait();
-
-                        _serilog.Info($"读取完成断开连接");
-                    }
+                    // if(i == 10)
+                    // {
+                    //
+                    //     isFlag = false;
+                    //
+                    //     opcua.DisconnectAsync().Wait();
+                    //
+                    //     _serilog.Info($"读取完成断开连接");
+                    // }
 
                 }
                 catch (Exception e)
@@ -213,7 +213,16 @@ public class DeviceCollectionBusiness
 
                 paramValues.Add(deviceParamVal);
             }
-            _paramValService.Insert(paramValues);
+
+            var isRes = _paramValService.Insert(paramValues);
+            if (isRes)
+            {
+                _serilog.Info(($"{device.deviceName} 设备参数保存成功"));
+            }
+            else
+            {
+                _serilog.Info(($"{device.deviceName} 设备参数保存失败"));
+            }
         }catch (Exception e)
         {
             throw new InvalidOperationException($"设备参数保存异常:{e.Message}");

Sln.Imm.Daemon.Model/dao/BaseDeviceParamVal.cs

@@ -12,10 +12,10 @@ namespace Sln.Imm.Daemon.Model.dao;
 public class BaseDeviceParamVal
 {
     /// <summary>
-    /// 备  注:主键
+    /// 备  注:主键 ，PARAMRECORD_SEQ_ID
     ///</summary>
-    [SugarColumn(ColumnName = "RECORD_ID", IsPrimaryKey = true)]
-    public decimal objId { get; set; }
+    [SugarColumn(ColumnName = "RECORD_ID", OracleSequenceName = "PARAMRECORD_SEQ_ID",IsPrimaryKey = true)]
+    public int objId { get; set; }
 
     /// <summary>
     /// 备  注:参数编号
@@ -33,7 +33,7 @@ public class BaseDeviceParamVal
     /// 备  注:设备ID
     ///</summary>
     [SugarColumn(ColumnName = "DEVICE_ID")]
-    public decimal? deviceId { get; set; }
+    public int deviceId { get; set; }
 
     /// <summary>
     /// 备  注:参数名称

Sln.Imm.Daemon.Opc/OpcDeviceFactorySetup.cs

@@ -40,6 +40,8 @@ namespace Sln.Imm.Daemon.Opc
                             }
 
                             if (opcDev != null)
+                            {
+                                try
                                 {
                                     var res = opcDev.ConnectAsync(item.networkAddress).Result;
 
@@ -50,9 +52,15 @@ namespace Sln.Imm.Daemon.Opc
                                     }
                                     else
                                     {
+                                        Console.WriteLine($"{item.deviceName}设备连接成功");
                                         opcs.Add(item, opcDev);
                                     }
                                 }
+                                catch (Exception ex)
+                                {
+                                    Console.WriteLine($"{item.deviceName}设备连接异常:{ex.Message}");
+                                }
+                            }
                         }
                     }
                 }