WcsFramework/WCS.Core/System.cs

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.ComponentModel;
using System.Diagnostics;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks; 

namespace WCS.Core
{
    public abstract class SystemBase: DescriptionClass
    {
        public World World { get; private set; }
        public SystemBase()
        {
            var attr = this.GetType().GetCustomAttribute<BelongToAttribute>(); 
            if (attr != null)
            {
                var wt = attr.WorldType;
                this.World = World.Worlds.Where(v => v.GetType() == wt).First();
            }
        }

        public abstract List<object> GetObjects();
        public abstract void Update(List<WorkTimes> list);
         
    }

   

    public abstract class SystemBase<T> : SystemBase
    { 
        public List<T> Objects { get; set; }
        
        /// <summary>
        /// 对所有Objects并行循环执行Do
        /// </summary>
        protected abstract bool ParallelDo { get; }

        /// <summary>
        /// 保存日志到文件
        /// </summary>
        protected abstract bool SaveLogsToFile { get; }

        public SystemBase()
        {
            Objects = Create();//.Select(v=>Activator.CreateInstance(typeof(T),v)).OfType<T>().ToList();
        }

        public override void Update(List<WorkTimes> list)
        {
            var logs = new List<LogInfo>();
            if (ParallelDo)
            {
                Parallel.ForEach(Objects, new ParallelOptions { MaxDegreeOfParallelism = 256 }, obj =>
                {
                    var sw= new Stopwatch();
                    sw.Start();
                    InvokeDo(obj);
                    sw.Stop();
                    list.AddSafe(new WorkTimes { Key = $"{obj?.ToString()}", Total = sw.ElapsedMilliseconds });
                    //var log = Ltc.GetLogStr();
                    logs.AddSafe(Ltc.GetLogInfo());
                });
            }
            else
            {
                foreach (var obj in Objects)
                {
                    var sw = new Stopwatch();
                    sw.Start();
                    InvokeDo(obj);
                    sw.Stop();
                    list.AddSafe(new WorkTimes { Key = $"{obj?.ToString()}", Total = sw.ElapsedMilliseconds });
                    //var log = Ltc.GetLogStr();
                    logs.AddSafe(Ltc.GetLogInfo());
                }
            }
            if (SaveLogsToFile)
            { 
                //var arr = logs.GroupBy(v => v.Channel).Select(v => new LogInfo { Channel = v.Key, Level = v.Max(d => d.Level), Type = v.Any(d => d.Type == ErrorType.Unkown) ? ErrorType.Unkown : ErrorType.Kown, Message = "\n"+string.Join('\n', v.Select(d => d.Message)) }).ToArray(); 
                Configs.OnLog?.Invoke(logs);
            }
        }
         
        void InvokeDo(T obj)
        {
            var channel = new Channel
            {
                World = World.Description,
                Stage = "DoLogics",
                System = Description,
                Item = obj.ToString()
            };
            try
            { 
                Ltc.SetChannel(channel); 
                Ltc.Log("开始", LogLevel.Low, ErrorType.Kown);
                Do(obj);
            }
            catch (KnownException ex)
            {
                Ltc.Log(ex.Message, ex.Level, ErrorType.Kown);
            }
            catch (Exception ex)
            {
                //Console.WriteLine($"{channel}:\n{ex.GetBaseException().Message}");
                Ltc.Log(ex.GetBaseException().Message, LogLevel.High, ErrorType.Unkown);
                World.OnError(channel, ex);
            }
            finally
            {
                Ltc.Log("结束", LogLevel.Low, ErrorType.Kown);
                Ltc.Publish(this.World);
            }
        }

        public abstract List<T> Create();
        public abstract void Do(T obj);
        public override List<object> GetObjects()
        {
            return Objects.OfType<object>().ToList();
        } 
    }

    public abstract class DeviceSystem<T> : SystemBase<T> where T : EntityEx<Device>
    {
        public override List<T> Create()
        {
            var types = typeof(T).GetGenericArguments();
            var list= World.Devices.Where(v => types.All(d => v.HasProtocol(d)))
                .Where(v => Select(v))
                .Select(v => Activator.CreateInstance(typeof(T), v)).OfType<T>().ToList();//此时才实例化Protocol            
            return list;
        }

        /// <summary>
        /// 筛选出需要实例化Protocol的Device
        /// </summary>
        /// <param name="dev"></param>
        /// <returns></returns>
        public abstract bool Select(Device dev);

        //public abstract List<Device> CreateDevices();
    }


    public abstract class ServiceSystem<T, TR> : SystemBase
    {
        ConcurrentQueue<Action<List<WorkTimes>>> Actions = new ConcurrentQueue<Action<List<WorkTimes>>>();
        public TR Invoke(T obj)
        {
            var flag = false;
            TR result = default(TR);
            Actions.Enqueue(list =>
            {
                var sw = new Stopwatch();
                sw.Start();
                try
                { 
                    result = InvokeDo(obj);
                }
                finally
                {
                    sw.Stop(); 
                    list.AddSafe(new WorkTimes { Key = $"{obj?.ToString()}", Total = sw.ElapsedMilliseconds });
                    flag = true;
                }
            });
            SpinWait.SpinUntil(() => flag);
            return result;
        }
        protected abstract TR Do(T obj);
        public override List<object> GetObjects()
        {
            return new List<object>();
        }

        public override void Update(List<WorkTimes> list)
        {
            var logs = new List<LogInfo>();
            while (Actions.TryDequeue(out var act))
            {
                act(list);
                logs.AddSafe(Ltc.GetLogInfo());
            }
            if (logs.Count > 0)
            {
                //var arr = logs.GroupBy(v => v.Channel).Select(v => new LogInfo { Channel = v.Key, Level = v.Max(d => d.Level), Type = v.Any(d => d.Type == ErrorType.Unkown) ? ErrorType.Unkown : ErrorType.Kown, Message = "\n" + string.Join('\n', v.Select(d => d.Message)) }).ToArray();
                Configs.OnLog?.Invoke(logs);
            }
        }
         
        TR InvokeDo(T obj)
        {
            var channel = new Channel
            {
                World = World.Description,
                Stage = "DoLogics",
                System = Description,
                Item = obj.ToString()
            };
            try
            {
                Ltc.SetChannel(channel); 
                Ltc.Log("开始", LogLevel.Low, ErrorType.Kown);
                return Do(obj);
            }
            catch (KnownException ex)
            { 
                Ltc.Log(ex.Message, ex.Level, ErrorType.Kown);
                throw;
            }
            catch (Exception ex)
            {
                //Console.WriteLine($"{channel}:\n{ex.GetBaseException().Message}");
                Ltc.Log(ex.GetBaseException().Message, LogLevel.High, ErrorType.Unkown);
                throw;
            }
            finally
            {
                Ltc.Log("结束", LogLevel.Low, ErrorType.Kown);
                Ltc.Publish(this.World);
            }
        }
    } 
}