using System.Collections.Concurrent; using System.ComponentModel; using WCS.Core; using WCS.WorkEngineering.Worlds.Logs; using KnownException = WCS.WorkEngineering.Worlds.Logs.KnownException; using LogInfo = WCS.WorkEngineering.Worlds.Logs.LogInfo; namespace WCS.WorkEngineering.Worlds { /// /// 主世界,所有的系统(交互点)默认在该世界下执行。 /// 如有系统需独立,请自行增加对应世界 /// 新增世界应当继承此世界,而不是直接继承World /// [Description("主世界")] public class MainWorld : World { /// /// 构造函数 /// public MainWorld() { } /// /// 日志队列 /// protected ConcurrentQueue Logs = new ConcurrentQueue(); /// /// 世界执行周期间隔 /// 单位:毫秒 /// protected override int Interval => 300; /// /// 更新前执行,重写改方法后请自行添加执行内容 /// 执行内容:清空日志队列 /// protected override void BeforeUpdate() { // 清空日志队列,确保日志队列中只会有当前周期日志 Logs.Clear(); } /// /// 更新后执行,重写改方法后请自行添加执行内容 /// 执行内容:清空日志队列 /// protected override void AfterUpdate() { #region 日志处理 //TODO:暂时仅将日志记录至文本文件 if (Logs.Count() > 0) { var time = $"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:FF")}"; var fst = Logs.First(); var dir = $"Logs\\{DateTime.Now.ToString("yyyy-MM-dd")}\\{fst.Channel.World}\\{fst.Channel.System}\\"; if (!Directory.Exists(dir)) Directory.CreateDirectory(dir); foreach (var log in Logs) { var msg = $"--------------------{log.Time}[{Thread.CurrentThread.ManagedThreadId}]--------------------\n{log}\n"; File.AppendAllText(Path.Combine(dir, $"{log.Log.Message.Split(":")[0]}.txt"), msg); } } #endregion 日志处理 } /// /// 异常处理,重写改方法后请自行添加执行内容 /// 执行内容:Exception as KnownException并添加至日志队列 /// /// /// /// protected override void OnError(Channel channel, Exception exception) { if (exception is KnownException) { var ex = exception as KnownException; var log = new LogInfo { Level = ex.Level, Type = ErrorTypeEnum.Kown, LogUpLoad = ex.logUpLoad, Message = ex.Message }; Logs.Enqueue(new KeyLog { Channel = channel, Log = log, Time = DateTime.Now }); } else { var log = new LogInfo { Level = LogLevelEnum.High, Type = ErrorTypeEnum.Unkown, LogUpLoad = LogUpLoadEnum.NotUpLoad, Message = exception.Message }; Logs.Enqueue(new KeyLog { Channel = channel, Log = log, Time = DateTime.Now }); } } /// /// 日志处理,重写改方法后请自行添加执行内容 /// 执行内容:LogInfo as KeyLog并添加至日志队列 /// /// /// /// protected override void OnLog(Channel channel, object logObj) { var log = (LogInfo)logObj; Logs.Enqueue(new KeyLog { Channel = channel, Log = log, Time = DateTime.Now }); } /// /// 日志处理,重写改方法后请自行添加执行内容 /// /// /// /// protected override void OnInternalLog(Channel channel, string msg) { var log = new LogInfo { Level = LogLevelEnum.Low, Message = msg }; Logs.Enqueue(new KeyLog { Channel = channel, Log = log, Time = DateTime.Now }); } /// /// 获取日志,重写改方法后请自行添加执行内容 /// /// /// /// protected override IEnumerable GetChannelMsg(Channel channel) { return Logs.Where(v => v.Channel.ToString() == channel.ToString()).Select(v => v.Log.ToString()); } } }