This commit is contained in:
Diego
2025-07-07 15:20:39 +08:00
parent 32fa833736
commit 4155c07269
7 changed files with 16 additions and 16 deletions

View File

@@ -1,11 +1,11 @@
<Project>
<PropertyGroup>
<PluginVersion>10.9.22</PluginVersion>
<ProPluginVersion>10.9.22</ProPluginVersion>
<DefaultVersion>10.9.22</DefaultVersion>
<AuthenticationVersion>2.9.12</AuthenticationVersion>
<SourceGeneratorVersion>10.9.12</SourceGeneratorVersion>
<PluginVersion>10.9.23</PluginVersion>
<ProPluginVersion>10.9.23</ProPluginVersion>
<DefaultVersion>10.9.23</DefaultVersion>
<AuthenticationVersion>2.9.13</AuthenticationVersion>
<SourceGeneratorVersion>10.9.13</SourceGeneratorVersion>
<NET8Version>8.0.17</NET8Version>
<NET9Version>9.0.6</NET9Version>
<SatelliteResourceLanguages>zh-Hans;en-US</SatelliteResourceLanguages>

View File

@@ -78,7 +78,7 @@ public abstract class BusinessBaseWithCacheAlarm : BusinessBaseWithCache
{
if (CurrentDevice?.Pause != false)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
if (AlarmModelEnable) return;
// 如果业务属性的缓存为间隔上传,则不执行后续操作

View File

@@ -248,7 +248,7 @@ public abstract class BusinessBaseWithCacheInterval : BusinessBaseWithCache
{
if (CurrentDevice?.Pause != false)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
if (!AlarmModelEnable) return;
// 如果业务属性的缓存为间隔上传,则不执行后续操作
@@ -305,7 +305,7 @@ public abstract class BusinessBaseWithCacheInterval : BusinessBaseWithCache
{
if (CurrentDevice?.Pause != false)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
if (!DevModelEnable) return;
// 如果业务属性的缓存为间隔上传,则不执行后续操作
//if (_businessPropertyWithCacheInterval?.IsInterval != true)
@@ -326,7 +326,7 @@ public abstract class BusinessBaseWithCacheInterval : BusinessBaseWithCache
if (CurrentDevice?.Pause != false)
return;
if (!VarModelEnable) return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
// 如果业务属性的缓存为间隔上传,则不执行后续操作
//if (_businessPropertyWithCacheInterval?.IsInterval != true)

View File

@@ -248,7 +248,7 @@ public class ModbusSlave : BusinessBase
{
if (CurrentDevice?.Pause != false)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
var address = variableRuntime.GetPropertyValue(DeviceId, nameof(_variablePropertys.ServiceAddress));
if (address != null && variableRuntime.Value != null)
{

View File

@@ -219,7 +219,7 @@ public class OpcDaMaster : CollectBase
{
if (CurrentDevice.Pause)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
if (DisposedValue)
return;
LogMessage?.Trace($"{ToString()} Change:{Environment.NewLine} {values?.ToSystemTextJsonString()}");
@@ -228,7 +228,7 @@ public class OpcDaMaster : CollectBase
{
if (CurrentDevice.Pause)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
if (DisposedValue)
return;
var type = data.Value.GetType();
@@ -242,7 +242,7 @@ public class OpcDaMaster : CollectBase
{
if (CurrentDevice.Pause)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
if (DisposedValue)
return;
var value = data.Value;

View File

@@ -363,7 +363,7 @@ public class OpcUaMaster : CollectBase
return;
if (DisposedValue)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
@@ -387,7 +387,7 @@ public class OpcUaMaster : CollectBase
return;
if (DisposedValue)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
if (isGood)
{

View File

@@ -397,7 +397,7 @@ public partial class OpcUaServer : BusinessBase
{
if (CurrentDevice.Pause)
return;
if (TaskSchedulerLoop.Stoped) return;
if (TaskSchedulerLoop?.Stoped==true) return;
if (DisposedValue) return;
if (IdVariableRuntimes.ContainsKey(variableData.Id))
CollectVariableRuntimes.AddOrUpdate(variableData.Id, id => variableData, (id, addValue) => variableData);