ZT_FJ_SJCL/WCS.WorkEngineering/Systems/DataCollectionSysyem.cs

using Microsoft.AspNetCore.DataProtection.KeyManagement;
using ServiceCenter.Extensions;
using ServiceCenter.SqlSugars;
using SqlSugar;
using System.Collections.Concurrent;
using System.ComponentModel;
using System.Data;
using System.Reflection;
using System.Text;
using PlcSiemens.Core.Extension;
using WCS.Core;
using WCS.Entity.Protocol.DataStructure;
using WCS.Entity.Protocol.HUB;
using WCS.Entity.Protocol.Protocol.Robot;
using WCS.Entity.Protocol.RGV;
using WCS.Entity.Protocol.Robot;
using WCS.Entity.Protocol.SRM;
using WCS.Entity.Protocol.Station;
using WCS.Entity.Protocol.Truss;
using WCS.WorkEngineering.Worlds;
using WCS.Entity;

namespace WCS.WorkEngineering.Systems
{
    /// <summary>
    ///  数据处理系统
    /// </summary>
    [BelongTo(typeof(MainWorld))]
    [Description("数据处理系统")]
    public class DataCollectionSysyem : DeviceSystem<Device<IStation520>>
    {
        public static DeviceDataPack pack = new DeviceDataPack();

        private static object locker = new object();

        public DataCollectionSysyem()
        {
        }

        /// <summary>
        ///  所有设备数据
        ///  Key 是不同设备所使用的类型 例如DeviceDataCollection<SRMData>
        ///  value 不同设备的具体数据
        /// </summary>
        public static ConcurrentDictionary<string, DeviceData> AllDatas = new ConcurrentDictionary<string, DeviceData>();

        protected override bool ParallelDo => true;

        public override bool Select(Device dev)
        {
            return dev.Code == "1";
        }

        public override void Do(Device<IStation520> objDev)
        {
            //通过数据条数处理
            var db = new SqlSugarHelper().PLC;
            var plcEx = new SqlSugarHelper().PLCEX;
            var time = DateTime.Now.AddDays(-1).Date;

            //Type parentType = typeof(IProtocol);

            //var childTypes = AppDomain.CurrentDomain.GetAssemblies()
            //    .First(x => x.FullName.Contains("WCS.Entity.Protocol")).GetTypes().Where(x => x.IsClass)
            //    .Where(x => x.GetInterfaces().Any(t => t == parentType)).ToList();

            //foreach (Type childType in childTypes)
            //{
            //    //获取表名
            //    var sugarTablea = childType.GetCustomAttributes(typeof(SugarTable), true).Select(x => (SugarTable)x).FirstOrDefault();
            //    if (sugarTablea != null)
            //    {
            //        var table = db.Queryable<dynamic>().AS("information_schema.tables").Where("table_name=@name", new { name = sugarTablea.TableName }).ToList();

            //        if (table.Count > 0)
            //        {
            //            var sql = $"ALTER TABLE {sugarTablea.TableName} DROP PARTITION WHERE frame < to_timestamp('{time}', 'yyyy-MM-dd:HH:mm:ss')";
            //            db.Ado.ExecuteCommand(sql);
            //        }
            //    }
            //}

            //var sysTypes = AppDomain.CurrentDomain.GetAssemblies().Select(v => v.GetTypes()).SelectMany(v => v)
            //    .Where(v => !v.IsAbstract)
            //    .Where(v => typeof(SystemBase).IsAssignableFrom(v))
            //    .Where(v =>
            //    {
            //        var attr = v.GetCustomAttribute<BelongToAttribute>();
            //        if (attr == null) return GetType() == typeof(World);
            //        if (attr.WorldType == this.GetType()) return true;
            //        return false;
            //    }).ToArray();

            ExRobotRunInfo(db, plcEx);
            ExSrmRunInfo(db, plcEx);
            ExRgvRunInfo(db, plcEx);
            ExTrussRunInfo(db, plcEx);
            //ExRobotAlarmInfo(db, plcEx);
            //ExSrmAlarmInfo(db, plcEx);
            //ExRgvAlarmInfo(db, plcEx);
            //ExTrussAlarmInfo(db, plcEx);
            ExRobotTaskSumRunInfo(db, plcEx);
            ExTrussTaskSumRunInfo(db, plcEx);
        }

        #region 设备运行信息收集

        /// <summary>
        /// 机械臂
        /// </summary>
        /// <param name="db"></param>
        public void ExRobotRunInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, WCS_Robot521>> robot521 = new List<IGrouping<string, WCS_Robot521>>();
            var type = DevType.SRM.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevRunInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var runInfo = plcEx.Queryable<DevRunInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = runInfo.Frame.AddHours(+1);//后一个小时
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<WCS_Robot521>().Any()) return;
                startTime = db.Queryable<WCS_Robot521>().OrderBy(x => x.Frame).First().Frame;
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);
            }
            //取上一小时的第一秒
            var now = DateTime.Now;
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 0, 0);
            var nowEndTime = new DateTime(endTime.Year, endTime.Month, endTime.Day, endTime.Hour, 0, 0);
            if (endTime > now) return; //当前时间之前
            if (nowEndTime == now) return; //是当前这一个小时
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 10, 0);
            if (DateTime.Now < now) return;// 每个小时的前十分钟不进行数据分析处理，仅在每小时的10-59之内进行处理

            if (plcEx.Queryable<DevRunInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            robot521 = db.Queryable<WCS_Robot521>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!robot521.Any())
            {
                plcEx.Insertable(new DevRunInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    RunMode = "当前时段无有效数据",
                    RunStatus = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(robot521, infos =>
            {
                // 获取第一条数据与最后一条数据
                var start = infos.OrderBy(x => x.Frame).First();
                var end = infos.OrderByDescending(x => x.Frame).First();
                //通过是否有最后一条数据来确定当前数据是否有分析存储过
                if (plcEx.Queryable<DevRunInfo>().Any(x => x.Code == infos.Key && x.EndTime == end.Frame)) return;
                //获取前一天最后的一条数据
                var yesterEnd = plcEx.Queryable<DevRunInfo>().Where(x => x.Code == infos.Key && x.Frame < endTime).OrderByDescending(x => x.Frame).First();
                List<DevRunInfo> runInfos = new List<DevRunInfo>();
                foreach (var info in infos.OrderBy(x => x.Frame))
                {
                    if (info.Frame == start.Frame) //当天的第一条数据
                    {
                        if (yesterEnd == null) //如果没有前一天的最后一条数据，就有用当天的第一条数据状态做计算
                        {
                            runInfos.Add(new DevRunInfo()
                            {
                                Frame = info.Frame,
                                Code = info.Code,
                                RunMode = info.RobotMode.GetDescription(),
                                RunStatus = info.RunStatus.GetDescription(),
                                StartTime = startTime,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - startTime).TotalMilliseconds),
                                Type = type
                            });
                        }
                        else //如果有就用前一天的最后一条数据做计算
                        {
                            runInfos.Add(new DevRunInfo()
                            {
                                Frame = info.Frame,
                                Code = info.Code,
                                RunMode = yesterEnd.RunMode,
                                RunStatus = yesterEnd.RunStatus,
                                StartTime = startTime,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - startTime).TotalMilliseconds),
                                Type = type
                            });
                        }
                    }
                    else if (info.Frame == end.Frame) //当天的最后一条数据
                    {
                        runInfos.Add(new DevRunInfo()
                        {
                            Frame = info.Frame,
                            Code = info.Code,
                            RunMode = info.RobotMode.GetDescription(),
                            RunStatus = info.RunStatus.GetDescription(),
                            StartTime = info.Frame,
                            EndTime = endTime,
                            Duration = Convert.ToInt64((endTime - info.Frame).TotalMilliseconds),
                            Type = type
                        });
                    }
                    else //中间数据
                    {
                        if (start.RobotMode == info.RobotMode && start.RunStatus == info.RunStatus) continue;
                        runInfos.Add(new DevRunInfo()
                        {
                            Frame = info.Frame,
                            Code = info.Code,
                            RunMode = start.RobotMode.GetDescription(),
                            RunStatus = start.RunStatus.GetDescription(),
                            StartTime = start.Frame,
                            EndTime = info.Frame,
                            Duration = Convert.ToInt64((info.Frame - start.Frame).TotalMilliseconds),
                            Type = type
                        });
                        start = info;
                    }
                }

                var sql = plcEx.Insertable(runInfos).ToSqlString();
                plcEx.Ado.ExecuteCommand(GetString(sql));
            });
        }

        /// <summary>
        /// 堆垛机
        /// </summary>
        /// <param name="db"></param>
        public void ExSrmRunInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, WCS_SRM521>> srm521 = new List<IGrouping<string, WCS_SRM521>>();
            var type = DevType.SRM.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevRunInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var runInfo = plcEx.Queryable<DevRunInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = runInfo.Frame.AddHours(+1);//后一个小时
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<WCS_SRM521>().Any()) return;
                startTime = db.Queryable<WCS_SRM521>().OrderBy(x => x.Frame).First().Frame;
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);
            }
            //取上一小时的第一秒
            var now = DateTime.Now;
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 0, 0);
            var nowEndTime = new DateTime(endTime.Year, endTime.Month, endTime.Day, endTime.Hour, 0, 0);
            if (endTime > now) return; //当前时间之前
            if (nowEndTime == now) return; //是当前这一个小时
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 10, 0);
            if (DateTime.Now < now) return;// 每个小时的前十分钟不进行数据分析处理，仅在每小时的10-59之内进行处理

            if (plcEx.Queryable<DevRunInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            srm521 = db.Queryable<WCS_SRM521>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!srm521.Any())
            {
                plcEx.Insertable(new DevRunInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    RunMode = "当前时段无有效数据",
                    RunStatus = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(srm521, infos =>
            {
                // 获取第一条数据与最后一条数据
                var start = infos.OrderBy(x => x.Frame).First();
                var end = infos.OrderByDescending(x => x.Frame).First();
                //通过是否有最后一条数据来确定当前数据是否有分析存储过
                if (plcEx.Queryable<DevRunInfo>().Any(x => x.Code == infos.Key && x.EndTime == end.Frame)) return;
                //获取前一天最后的一条数据
                var yesterEnd = plcEx.Queryable<DevRunInfo>().Where(x => x.Code == infos.Key && x.Frame < endTime).OrderByDescending(x => x.Frame).First();
                List<DevRunInfo> runInfos = new List<DevRunInfo>();
                foreach (var info in infos.OrderBy(x => x.Frame))
                {
                    if (info.Frame == start.Frame) //当天的第一条数据
                    {
                        if (yesterEnd == null) //如果没有前一天的最后一条数据，就有用当天的第一条数据状态做计算
                        {
                            runInfos.Add(new DevRunInfo()
                            {
                                Frame = info.Frame,
                                Code = info.Code,
                                RunMode = info.AutoStatus.GetDescription(),
                                RunStatus = info.RunStatus.GetDescription(),
                                StartTime = startTime,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - startTime).TotalMilliseconds),
                                Type = type
                            });
                        }
                        else //如果有就用前一天的最后一条数据做计算
                        {
                            runInfos.Add(new DevRunInfo()
                            {
                                Frame = info.Frame,
                                Code = info.Code,
                                RunMode = yesterEnd.RunMode,
                                RunStatus = yesterEnd.RunStatus,
                                StartTime = startTime,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - startTime).TotalMilliseconds),
                                Type = type
                            });
                        }
                    }
                    else if (info.Frame == end.Frame) //当天的最后一条数据
                    {
                        runInfos.Add(new DevRunInfo()
                        {
                            Frame = info.Frame,
                            Code = info.Code,
                            RunMode = info.AutoStatus.GetDescription(),
                            RunStatus = info.RunStatus.GetDescription(),
                            StartTime = info.Frame,
                            EndTime = endTime,
                            Duration = Convert.ToInt64((endTime - info.Frame).TotalMilliseconds),
                            Type = type
                        });
                    }
                    else //中间数据
                    {
                        if (start.AutoStatus == info.AutoStatus && start.RunStatus == info.RunStatus) continue;
                        runInfos.Add(new DevRunInfo()
                        {
                            Frame = info.Frame,
                            Code = info.Code,
                            RunMode = start.AutoStatus.GetDescription(),
                            RunStatus = start.RunStatus.GetDescription(),
                            StartTime = start.Frame,
                            EndTime = info.Frame,
                            Duration = Convert.ToInt64((info.Frame - start.Frame).TotalMilliseconds),
                            Type = type
                        });
                        start = info;
                    }
                }

                var sql = plcEx.Insertable(runInfos).ToSqlString();
                plcEx.Ado.ExecuteCommand(GetString(sql));
            });
        }

        /// <summary>
        /// rgv
        /// </summary>
        /// <param name="db"></param>
        public void ExRgvRunInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, WCS_RGV521>> rgv521 = new List<IGrouping<string, WCS_RGV521>>();
            var type = DevType.SRM.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevRunInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var runInfo = plcEx.Queryable<DevRunInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = runInfo.Frame.AddHours(+1);//后一个小时
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<WCS_RGV521>().Any()) return;
                startTime = db.Queryable<WCS_RGV521>().OrderBy(x => x.Frame).First().Frame;
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);
            }
            //取上一小时的第一秒
            var now = DateTime.Now;
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 0, 0);
            var nowEndTime = new DateTime(endTime.Year, endTime.Month, endTime.Day, endTime.Hour, 0, 0);
            if (endTime > now) return; //当前时间之前
            if (nowEndTime == now) return; //是当前这一个小时
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 10, 0);
            if (DateTime.Now < now) return;// 每个小时的前十分钟不进行数据分析处理，仅在每小时的10-59之内进行处理

            if (plcEx.Queryable<DevRunInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            rgv521 = db.Queryable<WCS_RGV521>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!rgv521.Any())
            {
                plcEx.Insertable(new DevRunInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    RunMode = "当前时段无有效数据",
                    RunStatus = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(rgv521, infos =>
            {
                // 获取第一条数据与最后一条数据
                var start = infos.OrderBy(x => x.Frame).First();
                var end = infos.OrderByDescending(x => x.Frame).First();
                //通过是否有最后一条数据来确定当前数据是否有分析存储过
                if (plcEx.Queryable<DevRunInfo>().Any(x => x.Code == infos.Key && x.EndTime == end.Frame)) return;
                //获取前一天最后的一条数据
                var yesterEnd = plcEx.Queryable<DevRunInfo>().Where(x => x.Code == infos.Key && x.Frame < endTime).OrderByDescending(x => x.Frame).First();
                List<DevRunInfo> runInfos = new List<DevRunInfo>();
                foreach (var info in infos.OrderBy(x => x.Frame))
                {
                    if (info.Frame == start.Frame) //当天的第一条数据
                    {
                        if (yesterEnd == null) //如果没有前一天的最后一条数据，就有用当天的第一条数据状态做计算
                        {
                            runInfos.Add(new DevRunInfo()
                            {
                                Frame = info.Frame,
                                Code = info.Code,
                                RunMode = info.WorkMode.GetDescription(),
                                RunStatus = info.SystemStatus.GetDescription(),
                                StartTime = startTime,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - startTime).TotalMilliseconds),
                                Type = type
                            });
                        }
                        else //如果有就用前一天的最后一条数据做计算
                        {
                            runInfos.Add(new DevRunInfo()
                            {
                                Frame = info.Frame,
                                Code = info.Code,
                                RunMode = yesterEnd.RunMode,
                                RunStatus = yesterEnd.RunStatus,
                                StartTime = startTime,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - startTime).TotalMilliseconds),
                                Type = type
                            });
                        }
                    }
                    else if (info.Frame == end.Frame) //当天的最后一条数据
                    {
                        runInfos.Add(new DevRunInfo()
                        {
                            Frame = info.Frame,
                            Code = info.Code,
                            RunMode = info.WorkMode.GetDescription(),
                            RunStatus = info.SystemStatus.GetDescription(),
                            StartTime = info.Frame,
                            EndTime = endTime,
                            Duration = Convert.ToInt64((endTime - info.Frame).TotalMilliseconds),
                            Type = type
                        });
                    }
                    else //中间数据
                    {
                        if (start.WorkMode == info.WorkMode && start.SystemStatus == info.SystemStatus) continue;
                        runInfos.Add(new DevRunInfo()
                        {
                            Frame = info.Frame,
                            Code = info.Code,
                            RunMode = start.WorkMode.GetDescription(),
                            RunStatus = start.SystemStatus.GetDescription(),
                            StartTime = start.Frame,
                            EndTime = info.Frame,
                            Duration = Convert.ToInt64((info.Frame - start.Frame).TotalMilliseconds),
                            Type = type
                        });
                        start = info;
                    }
                }

                var sql = plcEx.Insertable(runInfos).ToSqlString();
                plcEx.Ado.ExecuteCommand(GetString(sql));
            });
        }

        /// <summary>
        /// 桁架
        /// </summary>
        /// <param name="db"></param>
        public void ExTrussRunInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, WCS_Truss521>> truss521 = new List<IGrouping<string, WCS_Truss521>>();
            var type = DevType.SRM.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevRunInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var runInfo = plcEx.Queryable<DevRunInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = runInfo.Frame.AddHours(+1);//后一个小时
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<WCS_Truss521>().Any()) return;
                startTime = db.Queryable<WCS_Truss521>().OrderBy(x => x.Frame).First().Frame;
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);
            }
            //取上一小时的第一秒
            var now = DateTime.Now;
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 0, 0);
            var nowEndTime = new DateTime(endTime.Year, endTime.Month, endTime.Day, endTime.Hour, 0, 0);
            if (endTime > now) return; //当前时间之前
            if (nowEndTime == now) return; //是当前这一个小时
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 10, 0);
            if (DateTime.Now < now) return;// 每个小时的前十分钟不进行数据分析处理，仅在每小时的10-59之内进行处理

            if (plcEx.Queryable<DevRunInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            truss521 = db.Queryable<WCS_Truss521>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!truss521.Any())
            {
                plcEx.Insertable(new DevRunInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    RunMode = "当前时段无有效数据",
                    RunStatus = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(truss521, infos =>
            {
                // 获取第一条数据与最后一条数据
                var start = infos.OrderBy(x => x.Frame).First();
                var end = infos.OrderByDescending(x => x.Frame).First();
                //通过是否有最后一条数据来确定当前数据是否有分析存储过
                if (plcEx.Queryable<DevRunInfo>().Any(x => x.Code == infos.Key && x.EndTime == end.Frame)) return;
                //获取前一天最后的一条数据
                var yesterEnd = plcEx.Queryable<DevRunInfo>().Where(x => x.Code == infos.Key && x.Frame < endTime).OrderByDescending(x => x.Frame).First();
                List<DevRunInfo> runInfos = new List<DevRunInfo>();
                foreach (var info in infos.OrderBy(x => x.Frame))
                {
                    if (info.Frame == start.Frame) //当天的第一条数据
                    {
                        if (yesterEnd == null) //如果没有前一天的最后一条数据，就有用当天的第一条数据状态做计算
                        {
                            runInfos.Add(new DevRunInfo()
                            {
                                Frame = info.Frame,
                                Code = info.Code,
                                RunMode = info.Status.GetDescription(),
                                StartTime = startTime,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - startTime).TotalMilliseconds),
                                Type = type
                            });
                        }
                        else //如果有就用前一天的最后一条数据做计算
                        {
                            runInfos.Add(new DevRunInfo()
                            {
                                Frame = info.Frame,
                                Code = info.Code,
                                RunMode = yesterEnd.RunMode,
                                RunStatus = yesterEnd.RunStatus,
                                StartTime = startTime,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - startTime).TotalMilliseconds),
                                Type = type
                            });
                        }
                    }
                    else if (info.Frame == end.Frame) //当天的最后一条数据
                    {
                        runInfos.Add(new DevRunInfo()
                        {
                            Frame = info.Frame,
                            Code = info.Code,
                            RunMode = info.Status.GetDescription(),
                            StartTime = info.Frame,
                            EndTime = endTime,
                            Duration = Convert.ToInt64((endTime - info.Frame).TotalMilliseconds),
                            Type = type
                        });
                    }
                    else //中间数据
                    {
                        if (start.Status == info.Status) continue;
                        runInfos.Add(new DevRunInfo()
                        {
                            Frame = info.Frame,
                            Code = info.Code,
                            RunMode = start.Status.GetDescription(),
                            StartTime = start.Frame,
                            EndTime = info.Frame,
                            Duration = Convert.ToInt64((info.Frame - start.Frame).TotalMilliseconds),
                            Type = type
                        });
                        start = info;
                    }
                }

                var sql = plcEx.Insertable(runInfos).ToSqlString();
                plcEx.Ado.ExecuteCommand(GetString(sql));
            });
        }

        #endregion 设备运行信息收集

        #region 异常报警信息

        /// <summary>
        /// 机械臂
        /// </summary>
        /// <param name="db"></param>
        public void ExRobotAlarmInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, QuestDb_Robot522>> robot522 = new List<IGrouping<string, QuestDb_Robot522>>();
            var type = DevType.Robot.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var alarmInfo = plcEx.Queryable<DevAlarmInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = alarmInfo.Frame.AddDays(+1).Date;//后一天的初始时间
                endTime = startTime.AddDays(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<QuestDb_Robot522>().Any()) return;
                startTime = db.Queryable<QuestDb_Robot522>().OrderBy(x => x.Frame).First().Frame.Date;
                endTime = startTime.AddDays(+1).AddMilliseconds(-1);
            }
            if (endTime > DateTime.Now.AddHours(1)) return; //一次处理24小时的数据
            if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            robot522 = db.Queryable<QuestDb_Robot522>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!robot522.Any())
            {
                plcEx.Insertable(new DevAlarmInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    Alarm = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(robot522, infos =>
            {
                // 获取第一条数据与最后一条数据
                var start = infos.OrderBy(x => x.Frame).First();
                var end = infos.OrderByDescending(x => x.Frame).First();
                //通过是否有最后一条数据来确定当前数据是否有分析存储过
                if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.Code == infos.Key && x.EndTime == end.Frame)) return;
                //获取前一天最后的一条数据
                var yesterEnd = plcEx.Queryable<DevAlarmInfo>().Where(x => x.Code == infos.Key && x.Frame < endTime).OrderByDescending(x => x.Frame).First();
                List<DevAlarmInfo> runInfos = new List<DevAlarmInfo>();//需要保存的数据
                var alarmList = new List<EquipmentAlarm>();//未结束的报警信息
                foreach (var info in infos.OrderBy(x => x.Frame))
                {
                    if (info.Frame == end.Frame) //最后一条数据
                    {
                        if (info.Alarm != "无")
                        {
                            //先判断是否有没有记录的报警信息
                            var alarmMsg = Convert.ToString(info.Alarm).Split(",").Select(x => x.Split("，")).SelectMany(x => x).ToList();
                            var msgList = alarmList.Select(x => x.Msg);

                            //将未记录的报警信息增加到缓存中
                            alarmList.AddRange(alarmMsg.Where(msg => !msgList.Contains(msg)).Select(msg => new EquipmentAlarm() { Time = info.Frame, Msg = msg }));
                        }

                        if (!alarmList.Any()) continue;
                        runInfos.AddRange(alarmList.Select(alarm => new DevAlarmInfo()
                        {
                            Frame = alarm.Time,
                            Code = info.Code,
                            Alarm = alarm.Msg,
                            StartTime = alarm.Time,
                            EndTime = endTime,
                            Duration = Convert.ToInt64((endTime - alarm.Time).TotalMilliseconds),
                            Type = type
                        }));
                    }
                    else
                    {
                        if (info.Alarm == "无" && alarmList.Any()) //代表报警全部清空了
                        {
                            runInfos.AddRange(alarmList.Select(alarm => new DevAlarmInfo()
                            {
                                Frame = alarm.Time,
                                Code = info.Code,
                                Alarm = alarm.Msg,
                                StartTime = alarm.Time,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - alarm.Time).TotalMilliseconds),
                                Type = type
                            }));

                            alarmList = new List<EquipmentAlarm>(); //清空现有报警信息
                        }
                        else if (info.Alarm != "无")
                        {
                            var alarmMsg = Convert.ToString(info.Alarm).Split(",").Select(x => x.Split("，")).SelectMany(x => x).ToList();
                            var msgList = alarmList.Select(x => x.Msg);

                            //将未记录的报警信息增加到缓存中
                            alarmList.AddRange(alarmMsg.Where(msg => !msgList.Contains(msg)).Select(msg => new EquipmentAlarm() { Time = info.Frame, Msg = msg }));
                            var treatedAlarm = new List<string>();
                            //将已记录，但当前信息中没有的报警结束
                            foreach (var alarm in alarmList.Where(x => !alarmMsg.Contains(x.Msg)))
                            {
                                runInfos.Add(new DevAlarmInfo()
                                {
                                    Frame = alarm.Time,
                                    Code = info.Code,
                                    Alarm = alarm.Msg,
                                    StartTime = alarm.Time,
                                    EndTime = info.Frame,
                                    Duration = Convert.ToInt64((info.Frame - alarm.Time).TotalMilliseconds),
                                    Type = type
                                });
                                treatedAlarm.Add(alarm.Msg);
                            }

                            alarmList = alarmList.Where(x => !treatedAlarm.Contains(x.Msg)).ToList();
                        }
                    }
                }

                if (runInfos.Any())
                {
                    var sql = plcEx.Insertable(runInfos).ToSqlString();
                    plcEx.Ado.ExecuteCommand(GetString(sql));
                }
                else
                {
                    plcEx.Insertable(new DevAlarmInfo()
                    {
                        Frame = endTime,
                        Code = infos.Key,
                        Alarm = "当前时段无有效数据",
                        StartTime = startTime,
                        EndTime = endTime,
                        Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                        Type = type
                    }).ExecuteCommand();
                }
            });
        }

        /// <summary>
        /// 堆垛机
        /// </summary>
        /// <param name="db"></param>
        public void ExSrmAlarmInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, QuestDb_SRM523>> srm523 = new List<IGrouping<string, QuestDb_SRM523>>();
            var type = DevType.SRM.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var alarmInfo = plcEx.Queryable<DevAlarmInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = alarmInfo.Frame.AddDays(+1).Date;//后一天的初始时间
                endTime = startTime.AddDays(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<QuestDb_SRM523>().Any()) return;
                startTime = db.Queryable<QuestDb_SRM523>().OrderBy(x => x.Frame).First().Frame.Date;
                endTime = startTime.AddDays(+1).AddMilliseconds(-1);
            }
            if (endTime > DateTime.Now.AddHours(1)) return; //一次处理24小时的数据
            if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            srm523 = db.Queryable<QuestDb_SRM523>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!srm523.Any())
            {
                plcEx.Insertable(new DevAlarmInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    Alarm = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(srm523, infos =>
            {
                // 获取第一条数据与最后一条数据
                var start = infos.OrderBy(x => x.Frame).First();
                var end = infos.OrderByDescending(x => x.Frame).First();
                //通过是否有最后一条数据来确定当前数据是否有分析存储过
                if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.Code == infos.Key && x.EndTime == end.Frame)) return;
                //获取前一天最后的一条数据
                var yesterEnd = plcEx.Queryable<DevAlarmInfo>().Where(x => x.Code == infos.Key && x.Frame < endTime).OrderByDescending(x => x.Frame).First();
                List<DevAlarmInfo> runInfos = new List<DevAlarmInfo>();//需要保存的数据
                var alarmList = new List<EquipmentAlarm>();//未结束的报警信息
                foreach (var info in infos.OrderBy(x => x.Frame))
                {
                    if (info.Frame == end.Frame) //最后一条数据
                    {
                        if (info.Alarm != "无，无")
                        {
                            //先判断是否有没有记录的报警信息
                            var alarmMsg = Convert.ToString(info.Alarm).Split(",").Select(x => x.Split("，")).SelectMany(x => x).Where(x => x != "无").ToList();
                            var msgList = alarmList.Select(x => x.Msg);

                            //将未记录的报警信息增加到缓存中
                            alarmList.AddRange(alarmMsg.Where(msg => !msgList.Contains(msg)).Select(msg => new EquipmentAlarm() { Time = info.Frame, Msg = msg }));
                        }

                        if (!alarmList.Any()) continue;
                        runInfos.AddRange(alarmList.Select(alarm => new DevAlarmInfo()
                        {
                            Frame = alarm.Time,
                            Code = info.Code,
                            Alarm = alarm.Msg,
                            StartTime = alarm.Time,
                            EndTime = endTime,
                            Duration = Convert.ToInt64((endTime - alarm.Time).TotalMilliseconds),
                            Type = type
                        }));
                    }
                    else
                    {
                        if (info.Alarm == "无，无" && alarmList.Any()) //代表报警全部清空了
                        {
                            runInfos.AddRange(alarmList.Select(alarm => new DevAlarmInfo()
                            {
                                Frame = alarm.Time,
                                Code = info.Code,
                                Alarm = alarm.Msg,
                                StartTime = alarm.Time,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - alarm.Time).TotalMilliseconds),
                                Type = type
                            }));

                            alarmList = new List<EquipmentAlarm>(); //清空现有报警信息
                        }
                        else if (info.Alarm != "无，无")
                        {
                            var alarmMsg = Convert.ToString(info.Alarm).Split(",").Select(x => x.Split("，")).SelectMany(x => x).Where(x => x != "无").ToList();
                            var msgList = alarmList.Select(x => x.Msg);

                            //将未记录的报警信息增加到缓存中
                            alarmList.AddRange(alarmMsg.Where(msg => !msgList.Contains(msg)).Select(msg => new EquipmentAlarm() { Time = info.Frame, Msg = msg }));
                            var treatedAlarm = new List<string>();
                            //将已记录，但当前信息中没有的报警结束
                            foreach (var alarm in alarmList.Where(x => !alarmMsg.Contains(x.Msg)))
                            {
                                runInfos.Add(new DevAlarmInfo()
                                {
                                    Frame = alarm.Time,
                                    Code = info.Code,
                                    Alarm = alarm.Msg,
                                    StartTime = alarm.Time,
                                    EndTime = info.Frame,
                                    Duration = Convert.ToInt64((info.Frame - alarm.Time).TotalMilliseconds),
                                    Type = type
                                });
                                treatedAlarm.Add(alarm.Msg);
                            }

                            alarmList = alarmList.Where(x => !treatedAlarm.Contains(x.Msg)).ToList();
                        }
                    }
                }

                if (runInfos.Any())
                {
                    var sql = plcEx.Insertable(runInfos).ToSqlString();
                    plcEx.Ado.ExecuteCommand(GetString(sql));
                }
                else
                {
                    plcEx.Insertable(new DevAlarmInfo()
                    {
                        Frame = endTime,
                        Code = infos.Key,
                        Alarm = "当前时段无有效数据",
                        StartTime = startTime,
                        EndTime = endTime,
                        Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                        Type = type
                    }).ExecuteCommand();
                }
            });
        }

        /// <summary>
        /// rgv
        /// </summary>
        /// <param name="db"></param>
        public void ExRgvAlarmInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, QuestDb_RGV523>> rgv523 = new List<IGrouping<string, QuestDb_RGV523>>();
            var type = DevType.RGV.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var alarmInfo = plcEx.Queryable<DevAlarmInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = alarmInfo.Frame.AddDays(+1).Date;//后一天的初始时间
                endTime = startTime.AddDays(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<QuestDb_RGV523>().Any()) return;
                startTime = db.Queryable<QuestDb_RGV523>().OrderBy(x => x.Frame).First().Frame.Date;
                endTime = startTime.AddDays(+1).AddMilliseconds(-1);
            }
            if (endTime > DateTime.Now.AddHours(1)) return; //一次处理24小时的数据
            if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            rgv523 = db.Queryable<QuestDb_RGV523>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!rgv523.Any())
            {
                plcEx.Insertable(new DevAlarmInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    Alarm = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(rgv523/*.Where(x => x.Key == "RGV4")*/, infos =>
            {
                // 获取第一条数据与最后一条数据
                var start = infos.OrderBy(x => x.Frame).First();
                var end = infos.OrderByDescending(x => x.Frame).First();
                //通过是否有最后一条数据来确定当前数据是否有分析存储过
                if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.Code == infos.Key && x.EndTime == end.Frame)) return;
                //获取前一天最后的一条数据
                var yesterEnd = plcEx.Queryable<DevAlarmInfo>().Where(x => x.Code == infos.Key && x.Frame < endTime).OrderByDescending(x => x.Frame).First();
                List<DevAlarmInfo> runInfos = new List<DevAlarmInfo>();//需要保存的数据
                var alarmList = new List<EquipmentAlarm>();//未结束的报警信息
                foreach (var info in infos.OrderBy(x => x.Frame))
                {
                    if (info.Frame == end.Frame) //最后一条数据
                    {
                        if (info.Alarm != "无")
                        {
                            //先判断是否有没有记录的报警信息
                            var alarmMsg = Convert.ToString(info.Alarm).Split(",").Select(x => x.Split("，")).SelectMany(x => x).ToList();
                            var msgList = alarmList.Select(x => x.Msg);

                            //将未记录的报警信息增加到缓存中
                            alarmList.AddRange(alarmMsg.Where(msg => !msgList.Contains(msg)).Select(msg => new EquipmentAlarm() { Time = info.Frame, Msg = msg }));
                        }

                        if (!alarmList.Any()) continue;
                        runInfos.AddRange(alarmList.Select(alarm => new DevAlarmInfo()
                        {
                            Frame = alarm.Time,
                            Code = info.Code,
                            Alarm = alarm.Msg,
                            StartTime = alarm.Time,
                            EndTime = endTime,
                            Duration = Convert.ToInt64((endTime - alarm.Time).TotalMilliseconds),
                            Type = type
                        }));
                    }
                    else
                    {
                        if (info.Alarm == "无" && alarmList.Any()) //代表报警全部清空了
                        {
                            runInfos.AddRange(alarmList.Select(alarm => new DevAlarmInfo()
                            {
                                Frame = alarm.Time,
                                Code = info.Code,
                                Alarm = alarm.Msg,
                                StartTime = alarm.Time,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - alarm.Time).TotalMilliseconds),
                                Type = type
                            }));

                            alarmList = new List<EquipmentAlarm>(); //清空现有报警信息
                        }
                        else if (info.Alarm != "无")
                        {
                            var alarmMsg = Convert.ToString(info.Alarm).Split(",").Select(x => x.Split("，")).SelectMany(x => x).ToList();
                            var msgList = alarmList.Select(x => x.Msg);

                            //将未记录的报警信息增加到缓存中
                            alarmList.AddRange(alarmMsg.Where(msg => !msgList.Contains(msg)).Select(msg => new EquipmentAlarm() { Time = info.Frame, Msg = msg }));
                            var treatedAlarm = new List<string>();
                            //将已记录，但当前信息中没有的报警结束
                            foreach (var alarm in alarmList.Where(x => !alarmMsg.Contains(x.Msg)))
                            {
                                runInfos.Add(new DevAlarmInfo()
                                {
                                    Frame = alarm.Time,
                                    Code = info.Code,
                                    Alarm = alarm.Msg,
                                    StartTime = alarm.Time,
                                    EndTime = info.Frame,
                                    Duration = Convert.ToInt64((info.Frame - alarm.Time).TotalMilliseconds),
                                    Type = type
                                });
                                treatedAlarm.Add(alarm.Msg);
                            }

                            alarmList = alarmList.Where(x => !treatedAlarm.Contains(x.Msg)).ToList();
                        }
                    }
                }

                if (runInfos.Any())
                {
                    plcEx.Insertable(runInfos).ExecuteCommand();
                }
                else
                {
                    plcEx.Insertable(new DevAlarmInfo()
                    {
                        Frame = endTime,
                        Code = infos.Key,
                        Alarm = "当前时段无有效数据",
                        StartTime = startTime,
                        EndTime = endTime,
                        Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                        Type = type
                    }).ExecuteCommand();
                }
            });
        }

        /// <summary>
        /// Truss
        /// </summary>
        /// <param name="db"></param>
        public void ExTrussAlarmInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, QuestDb_Truss523>> rgv523 = new List<IGrouping<string, QuestDb_Truss523>>();
            var type = DevType.Truss.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var alarmInfo = plcEx.Queryable<DevAlarmInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = alarmInfo.Frame.AddDays(+1).Date;//后一天的初始时间
                endTime = startTime.AddDays(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<QuestDb_Truss523>().Any()) return;
                startTime = db.Queryable<QuestDb_Truss523>().OrderBy(x => x.Frame).First().Frame.Date;
                endTime = startTime.AddDays(+1).AddMilliseconds(-1);
            }
            if (endTime > DateTime.Now.AddHours(1)) return; //一次处理24小时的数据
            if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            rgv523 = db.Queryable<QuestDb_Truss523>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!rgv523.Any())
            {
                plcEx.Insertable(new DevAlarmInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    Alarm = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(rgv523/*.Where(x => x.Key == "RGV4")*/, infos =>
            {
                // 获取第一条数据与最后一条数据
                var start = infos.OrderBy(x => x.Frame).First();
                var end = infos.OrderByDescending(x => x.Frame).First();
                //通过是否有最后一条数据来确定当前数据是否有分析存储过
                if (plcEx.Queryable<DevAlarmInfo>().Any(x => x.Code == infos.Key && x.EndTime == end.Frame)) return;
                //获取前一天最后的一条数据
                var yesterEnd = plcEx.Queryable<DevAlarmInfo>().Where(x => x.Code == infos.Key && x.Frame < endTime).OrderByDescending(x => x.Frame).First();
                List<DevAlarmInfo> runInfos = new List<DevAlarmInfo>();//需要保存的数据
                var alarmList = new List<EquipmentAlarm>();//未结束的报警信息
                foreach (var info in infos.OrderBy(x => x.Frame))
                {
                    if (info.Frame == end.Frame) //最后一条数据
                    {
                        if (info.Alarm != "无")
                        {
                            //先判断是否有没有记录的报警信息
                            var alarmMsg = Convert.ToString(info.Alarm).Split(",").Select(x => x.Split("，")).SelectMany(x => x).ToList();
                            var msgList = alarmList.Select(x => x.Msg);

                            //将未记录的报警信息增加到缓存中
                            alarmList.AddRange(alarmMsg.Where(msg => !msgList.Contains(msg)).Select(msg => new EquipmentAlarm() { Time = info.Frame, Msg = msg }));
                        }

                        if (!alarmList.Any()) continue;
                        runInfos.AddRange(alarmList.Select(alarm => new DevAlarmInfo()
                        {
                            Frame = alarm.Time,
                            Code = info.Code,
                            Alarm = alarm.Msg,
                            StartTime = alarm.Time,
                            EndTime = endTime,
                            Duration = Convert.ToInt64((endTime - alarm.Time).TotalMilliseconds),
                            Type = type
                        }));
                    }
                    else
                    {
                        if (info.Alarm == "无" && alarmList.Any()) //代表报警全部清空了
                        {
                            runInfos.AddRange(alarmList.Select(alarm => new DevAlarmInfo()
                            {
                                Frame = alarm.Time,
                                Code = info.Code,
                                Alarm = alarm.Msg,
                                StartTime = alarm.Time,
                                EndTime = info.Frame,
                                Duration = Convert.ToInt64((info.Frame - alarm.Time).TotalMilliseconds),
                                Type = type
                            }));

                            alarmList = new List<EquipmentAlarm>(); //清空现有报警信息
                        }
                        else if (info.Alarm != "无")
                        {
                            var alarmMsg = Convert.ToString(info.Alarm).Split(",").Select(x => x.Split("，")).SelectMany(x => x).ToList();
                            var msgList = alarmList.Select(x => x.Msg);

                            //将未记录的报警信息增加到缓存中
                            alarmList.AddRange(alarmMsg.Where(msg => !msgList.Contains(msg)).Select(msg => new EquipmentAlarm() { Time = info.Frame, Msg = msg }));
                            var treatedAlarm = new List<string>();
                            //将已记录，但当前信息中没有的报警结束
                            foreach (var alarm in alarmList.Where(x => !alarmMsg.Contains(x.Msg)))
                            {
                                runInfos.Add(new DevAlarmInfo()
                                {
                                    Frame = alarm.Time,
                                    Code = info.Code,
                                    Alarm = alarm.Msg,
                                    StartTime = alarm.Time,
                                    EndTime = info.Frame,
                                    Duration = Convert.ToInt64((info.Frame - alarm.Time).TotalMilliseconds),
                                    Type = type
                                });
                                treatedAlarm.Add(alarm.Msg);
                            }

                            alarmList = alarmList.Where(x => !treatedAlarm.Contains(x.Msg)).ToList();
                        }
                    }
                }

                if (runInfos.Any())
                {
                    plcEx.Insertable(runInfos).ExecuteCommand();
                }
                else
                {
                    plcEx.Insertable(new DevAlarmInfo()
                    {
                        Frame = endTime,
                        Code = infos.Key,
                        Alarm = "当前时段无有效数据",
                        StartTime = startTime,
                        EndTime = endTime,
                        Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                        Type = type
                    }).ExecuteCommand();
                }
            });
        }

        #endregion 异常报警信息

        #region 任务状态分析

        /// <summary>
        /// 机械臂分析单双爪任务占比，需要按照任务类型分类
        /// </summary>
        /// <param name="db"></param>
        public void ExRobotTaskSumRunInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, WCS_Robot520>> robot520 = new List<IGrouping<string, WCS_Robot520>>();
            var type = DevType.SRM.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevRunInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var runInfo = plcEx.Queryable<DevRunInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = runInfo.Frame.AddHours(+1);//后一个小时
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<WCS_Robot520>().Any()) return;
                startTime = db.Queryable<WCS_Robot520>().OrderBy(x => x.Frame).First().Frame;
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);
            }
            //取上一小时的第一秒
            var now = DateTime.Now;
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 0, 0);
            var nowEndTime = new DateTime(endTime.Year, endTime.Month, endTime.Day, endTime.Hour, 0, 0);
            if (endTime > now) return; //当前时间之前
            if (nowEndTime == now) return; //是当前这一个小时
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 10, 0);
            if (DateTime.Now < now) return;// 每个小时的前十分钟不进行数据分析处理，仅在每小时的10-59之内进行处理

            if (plcEx.Queryable<DevRunInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            robot520 = db.Queryable<WCS_Robot520>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!robot520.Any())
            {
                plcEx.Insertable(new DevRunInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    RunMode = "当前时段无有效数据",
                    RunStatus = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(robot520, infos =>
            {
                var infoList = infos.Where(x => x.TaskNumber1 != 0 || x.TaskNumber2 != 0).ToList().DistinctItemBy(x => x.VoucherNo);

                List<DevRunInfo> runInfos = new List<DevRunInfo>();
                foreach (var info in infoList.OrderBy(x => x.Frame))
                {
                    var taskSum = 0;
                    if (info.TaskNumber1 != 0) taskSum += 1;
                    if (info.TaskNumber2 != 0) taskSum += 1;
                    runInfos.Add(new DevRunInfo()
                    {
                        Frame = info.Frame,
                        Code = info.Code,
                        RunMode = taskSum.ToString(),
                        RunStatus = $"{info.TaskNumber1}--{info.TaskNumber2}--{info.TaskType}",
                        Duration = 0,
                        Type = type
                    });
                }

                var sql = plcEx.Insertable(runInfos).ToSqlString();
                plcEx.Ado.ExecuteCommand(GetString(sql));
            });
        }

        /// <summary>
        /// 机械臂分析单双爪任务占比，需要按照任务类型分类
        /// </summary>
        /// <param name="db"></param>
        public void ExTrussTaskSumRunInfo(SqlSugarScopeProvider db, SqlSugarScopeProvider plcEx)
        {
            var startTime = DateTime.Now;
            var endTime = DateTime.Now;
            IEnumerable<IGrouping<string, WCS_Truss520>> truss520 = new List<IGrouping<string, WCS_Truss520>>();
            var type = DevType.SRM.ToString();
            //查看rgv类型是否存在运行信息，用于系统被第一次启用时进行初始化
            if (plcEx.Queryable<DevRunInfo>().Any(x => x.Type == type))
            {
                //已有信息，查找最后一条信息用于获取开始时间,最后一条通常是前一天的最后条数据
                var runInfo = plcEx.Queryable<DevRunInfo>().Where(x => x.Type == type).OrderByDescending(x => x.Frame).First();
                startTime = runInfo.Frame.AddHours(+1);//后一个小时
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);//
            }
            else
            {
                if (!db.Queryable<WCS_Truss520>().Any()) return;
                startTime = db.Queryable<WCS_Truss520>().OrderBy(x => x.Frame).First().Frame;
                startTime = new DateTime(startTime.Year, startTime.Month, startTime.Day, startTime.Hour, 0, 0); //后一个小时的开始时间
                endTime = startTime.AddHours(+1).AddMilliseconds(-1);
            }
            //取上一小时的第一秒
            var now = DateTime.Now;
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 0, 0);
            var nowEndTime = new DateTime(endTime.Year, endTime.Month, endTime.Day, endTime.Hour, 0, 0);
            if (endTime > now) return; //当前时间之前
            if (nowEndTime == now) return; //是当前这一个小时
            now = new DateTime(now.Year, now.Month, now.Day, now.Hour, 10, 0);
            if (DateTime.Now < now) return;// 每个小时的前十分钟不进行数据分析处理，仅在每小时的10-59之内进行处理

            if (plcEx.Queryable<DevRunInfo>().Any(x => x.EndTime == endTime && x.Type == type)) return;

            truss520 = db.Queryable<WCS_Truss520>().Where(x => x.Frame > startTime && x.Frame <= endTime).ToList().GroupBy(x => x.Code).ToList();

            if (!truss520.Any())
            {
                plcEx.Insertable(new DevRunInfo()
                {
                    Frame = endTime,
                    Code = "当前时段无有效数据",
                    RunMode = "当前时段无有效数据",
                    RunStatus = "当前时段无有效数据",
                    StartTime = startTime,
                    EndTime = endTime,
                    Duration = Convert.ToInt64((endTime - startTime).TotalMilliseconds),
                    Type = type
                }).ExecuteCommand();
            }

            Parallel.ForEach(truss520, infos =>
            {
                var infoList = infos.Where(x => x.Task1_1 != 0 || x.Task1_2 != 0 || x.Task1_3 != 0 || x.Task1_4 != 0 || x.Task1_5 != 0
                                                || x.Task2_1 != 0 || x.Task2_2 != 0 || x.Task2_3 != 0 || x.Task2_4 != 0 || x.Task2_5 != 0).ToList().DistinctItemBy(x => x.VoucherNo);

                List<DevRunInfo> runInfos = new List<DevRunInfo>();
                foreach (var info in infoList.OrderBy(x => x.Frame))
                {
                    var taskSum = 0;
                    if (info.Task1_1 != 0) taskSum += 1;
                    if (info.Task1_2 != 0) taskSum += 1;
                    if (info.Task1_3 != 0) taskSum += 1;
                    if (info.Task1_4 != 0) taskSum += 1;
                    if (info.Task1_5 != 0) taskSum += 1;
                    if (info.Task2_1 != 0) taskSum += 1;
                    if (info.Task2_2 != 0) taskSum += 1;
                    if (info.Task2_3 != 0) taskSum += 1;
                    if (info.Task2_4 != 0) taskSum += 1;
                    if (info.Task2_5 != 0) taskSum += 1;
                    runInfos.Add(new DevRunInfo()
                    {
                        Frame = info.Frame,
                        Code = info.Code,
                        RunMode = taskSum.ToString(),
                        RunStatus = $"{info.Task1_1}--{info.Task1_2}--{info.Task1_3}--{info.Task1_4}--{info.Task1_5}--{info.Task2_1}--{info.Task2_2}--{info.Task2_3}--{info.Task2_4}--{info.Task2_5}",
                        Duration = 0,
                        Type = type
                    });
                }

                var sql = plcEx.Insertable(runInfos).ToSqlString();
                plcEx.Ado.ExecuteCommand(GetString(sql));
            });
        }

        #endregion 任务状态分析

        public string GetString(string value)
        {
            return value.Replace(",N'", ",'")
                .Replace("\0", "")
                .Replace("(N'", "('") + "\r";
        }
    }

    /// <summary>
    ///  设备报警
    /// </summary>
    public class EquipmentAlarm
    {
        /// <summary>
        ///  内容
        /// </summary>
        public string Msg { get; set; }

        /// <summary>
        ///  时间
        /// </summary>
        public DateTime Time { get; set; }
    }

    /// <summary>
    ///  设备状态信息
    /// </summary>
    public class EquipmentStatus
    {
        /// <summary>
        ///  设备号
        /// </summary>
        public string Code { get; set; }

        /// <summary>
        ///  内容
        /// </summary>
        public string con { get; set; }

        /// <summary>
        ///  内容
        /// </summary>
        public int Status { get; set; }

        /// <summary>
        ///  时间
        /// </summary>
        public DateTime Time { get; set; }
    }

    /// <summary>
    ///
    /// </summary>
    /// <typeparam name="T"></typeparam>
    public class Quest<T>
    {
        public T Data { get; set; }
    }

    public class KeyValue
    {
        public string key { get; set; }

        public string value { get; set; }
    }
}