优化运行分析，运行记录结构更改，运行服务新增监测中断判断

lixiaojun

2024-04-30 b4db153d2e28d451592811fea29c6d1bab71887b

 Yw.Server.Run/02-emws/02-single/EMWSRunAnalyChangeTimesHelper.cs

@@ -1,26 +1,48 @@
namespace Yw.Server
using Yw.Service.Basic;
using Yw.Service.Monitor;

namespace Yw.Server
{
    /// <summary>
    /// 
    /// </summary>
    public class EMWSRunAnalyChangeTimesHelper
    {
        private static ConcurrentDictionary<long, List<Yw.Model.MonitorRealRecord>> _dict = new();//缓存
        private static readonly ConcurrentDictionary<long, List<int>> _dict = new();//缓存

        /// <summary>
        /// 设置
        /// </summary>
        public static void Set(long configureId, int changeTimes, Yw.Model.MonitorRealRecord record)
        public static void Set(long configureId, int changeTimes, Yw.Model.MonitorPoint monitor, Yw.Model.MonitorRealRecord record)
        {
            _dict.TryAdd(configureId, new List<Yw.Model.MonitorRealRecord>());
            _dict.TryAdd(configureId, new List<int>());
            if (_dict[configureId].Count >= changeTimes)
            {
                _dict[configureId].RemoveAt(0);
            }
            if (record != null)
            var rsa = Yw.Run.RunStatus.Shut;
            if (monitor != null)
            {
                _dict[configureId].Add(record);
                if (record != null)
                {
                    if (int.TryParse(record.DataValue, out int intDataValue))
                    {
                        if (intDataValue > Yw.Monitor.RunStatus.Shut)
                        {
                            rsa = Yw.Run.RunStatus.Run;
                        }
                    }
                }
                var config_interrupt = Yw.Run.SysParas.EnableMonitorInterruptJudgement.GetPValue<bool?>();
                if (config_interrupt.HasValue && config_interrupt.Value)
                {
                    if (monitor.IsInterrupt(record))
                    {
                        rsa = Yw.Run.RunStatus.Shut;
                    }
                }
            }
            _dict[configureId].Add(rsa);
        }

        /// <summary>
@@ -36,7 +58,7 @@
            {
                return false;
            }
            if (_dict[configureId].Select(x => x.DataValue).Distinct().Count() > 1)
            if (_dict[configureId].Distinct().Count() > 1)
            {
                return false;
            }