初步完成历史记录(未完成)

DMS.Application/Interfaces/IVariableAppService.cs

@@ -70,4 +70,11 @@ public interface IVariableAppService
     /// <param name="variableToCheck">要检查的变量。</param>
     /// <returns>如果变量已存在则返回该变量，否则返回null。</returns>
     Task<VariableDto?> FindExistingVariableAsync(VariableDto variableToCheck);
+    
+    /// <summary>
+    /// 异步获取指定变量的历史记录。
+    /// </summary>
+    /// <param name="variableId">变量ID</param>
+    /// <returns>变量历史记录列表</returns>
+    Task<List<VariableHistoryDto>> GetVariableHistoriesAsync(int variableId);
 }

DMS.Application/Services/Processors/MqttPublishProcessor.cs

@@ -36,6 +36,11 @@ public class MqttPublishProcessor : IVariableProcessor
         // 遍历所有关联的MQTT配置，并将其推入发送队列
         foreach (var variableMqttAliasDto in variable.MqttAliases)
         {
+            if (!variableMqttAliasDto.MqttServer.IsActive)
+            {
+                continue;
+            }
+            
             // 发布变量数据到MQTT服务器
            var variableMqttAlias = _mapper.Map<VariableMqttAlias>(variableMqttAliasDto);
            variableMqttAlias.Variable.DataValue=variable.DataValue;

DMS.Application/Services/VariableAppService.cs

@@ -285,4 +285,15 @@ public class VariableAppService : IVariableAppService
         // 如果找到了匹配的变量，返回第一个（也是唯一一个）
         return existingVariables.FirstOrDefault();
     }
+    
+    /// <summary>
+    /// 异步获取指定变量的历史记录。
+    /// </summary>
+    /// <param name="variableId">变量ID</param>
+    /// <returns>变量历史记录列表</returns>
+    public async Task<List<VariableHistoryDto>> GetVariableHistoriesAsync(int variableId)
+    {
+        var histories = await _repoManager.VariableHistories.GetByVariableIdAsync(variableId);
+        return _mapper.Map<List<VariableHistoryDto>>(histories);
+    }
 }