namespace IStation.Server
{
    /// <summary>
    /// 
    /// </summary>
    public class EquipmentRunAnalyChangeTimesHelper
    {
        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;
        }









    }
}