namespace Yw.Server
|
{
|
/// <summary>
|
///
|
/// </summary>
|
public class EMWSRunAnalyChangeTimesHelper
|
{
|
private static ConcurrentDictionary<long, List<Yw.Model.MonitorRealRecord>> _dict = new();//缓存
|
|
/// <summary>
|
/// 设置
|
/// </summary>
|
public static void Set(long configureId, int changeTimes, Yw.Model.MonitorRealRecord record)
|
{
|
_dict.TryAdd(configureId, new List<Yw.Model.MonitorRealRecord>());
|
if (_dict[configureId].Count >= changeTimes)
|
{
|
_dict[configureId].RemoveAt(0);
|
}
|
if (record != null)
|
{
|
_dict[configureId].Add(record);
|
}
|
}
|
|
/// <summary>
|
/// 是否改变
|
/// </summary>
|
public static bool HasChanged(long configureId, int changeTimes)
|
{
|
if (!_dict.ContainsKey(configureId))
|
{
|
return false;
|
}
|
if (_dict[configureId].Count < changeTimes)
|
{
|
return false;
|
}
|
if (_dict[configureId].Select(x => x.DataValue).Distinct().Count() > 1)
|
{
|
return false;
|
}
|
return true;
|
}
|
|
|
|
|
|
|
|
|
|
}
|
}
|
