66 lines
1.9 KiB
C#
66 lines
1.9 KiB
C#
|
using Infrastructure.Attribute;
|
|||
|
|
using MDM.Model.Plant;
|
|||
|
|
using MDM.Services.IPlantService;
|
|||
|
|
using System.Collections.Concurrent;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
|
|||
|
|
namespace MDM.Services.Plant
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 用于缓存 PlantPlcIoPoint 数据的服务
|
|||
|
|
/// </summary>
|
|||
|
|
|
|||
|
|
[AppService(ServiceType = typeof(PlcIoPointCacheService), ServiceLifetime = LifeTime.Singleton)]
|
|||
|
|
public class PlcIoPointCacheService
|
|||
|
|
{
|
|||
|
|
// 使用线程安全的字典缓存所有点位，Key 是点位 ID
|
|||
|
|
private readonly ConcurrentDictionary<int, PlantPlcIoPoint> _pointsById = new();
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 初始化缓存（由 IHostedService 调用）
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="points">从数据库加载的点位集合</param>
|
|||
|
|
public void InitializeCache(IEnumerable<PlantPlcIoPoint> points)
|
|||
|
|
{
|
|||
|
|
if (points == null) return;
|
|||
|
|
|
|||
|
|
// 清空旧数据
|
|||
|
|
_pointsById.Clear();
|
|||
|
|
|
|||
|
|
// 只缓存有效的点位（IsActive == 1）
|
|||
|
|
foreach (var point in points.Where(p => p.IsActive == 1))
|
|||
|
|
{
|
|||
|
|
if (point.Id > 0)
|
|||
|
|
{
|
|||
|
|
_pointsById[point.Id] = point;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 根据 ID 获取点位
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id">点位 ID</param>
|
|||
|
|
/// <returns>点位对象，如果不存在返回 null</returns>
|
|||
|
|
public PlantPlcIoPoint? GetPointById(int id)
|
|||
|
|
{
|
|||
|
|
_pointsById.TryGetValue(id, out var point);
|
|||
|
|
return point;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取所有已缓存的点位
|
|||
|
|
/// </summary>
|
|||
|
|
public IEnumerable<PlantPlcIoPoint> GetAllCachedPoints()
|
|||
|
|
{
|
|||
|
|
return _pointsById.Values;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 可根据需要添加更多方法，如：
|
|||
|
|
// - 按 工站 + 设备 分组查询
|
|||
|
|
// - 按 点位类型、工艺参数等过滤
|
|||
|
|
}
|
|||
|
|
}
|