WcsFramework/ServiceCenter/Logs/LogHub.cs

using Newtonsoft.Json;
using ServiceCenter.Extensions;
using ServiceCenter.Redis;
using System.Collections.Concurrent;

namespace ServiceCenter.Logs
{
    public class LogHub
    {
        /// <summary>
        ///  日志队列
        /// </summary>
        public static ConcurrentQueue<KeyLog> Logs = new ConcurrentQueue<KeyLog>();

        /// <summary>
        ///  发布一条世界交互日志
        /// </summary>
        /// <param name="logs"></param>
        public static void WorldPublish(ConcurrentQueue<KeyLog> logs)
        {
            if (logs.Count > 0)
            {
                foreach (var log in Logs)
                {
                    var dir = $"D:\\WCSLogs\\{DateTime.Now.yyyyMMdd()}\\{log.Channel.World}\\{log.Channel.System}\\{log.Channel.Item}\\";
                    var msg = $"{log.Time.yyyyMMddhhmmssf()}--[{Thread.CurrentThread.ManagedThreadId}]--{log}\n";
                    RedisHub.Default.RPush("LogHub", JsonConvert.SerializeObject(new LogModel
                    {
                        path = dir,
                        Title = $"{log.Log.Message.Split(":")[0]}.txt",
                        Con = msg
                    }));
                }
                List<BusinessAlarm> businesses = logs.Select(v => new BusinessAlarm()
                {
                    BusinessName = v.Channel.System,
                    DevNo = v.Channel.Item,
                    Con = v.ToString(),
                    Time = DateTime.Now
                }).ToList();
                RedisHub.Default.Set($"{nameof(BusinessAlarm)}", JsonConvert.SerializeObject(businesses));
            }
        }

        /// <summary>
        ///   增加一条处理日志
        /// </summary>
        /// <param name="title">文件名</param>
        /// <param name="con">内容</param>
        public static void InterfaceProcessLog(string title, string con)
        {
            RedisHub.Default.RPush("LogHub", JsonConvert.SerializeObject(new LogModel
            {
                path = $"D:\\WCSLogs\\{DateTime.Now.yyyyMMdd()}\\接口处理日志",
                Title = $"{title}.txt",
                Con = $"{DateTime.Now.yyyyMMddhhmmssf()}--[{Thread.CurrentThread.ManagedThreadId}]--{con}\n"
            }));
        }

        public static void init()
        {
            while (true)
            {
                var logHub = RedisHub.Default.LPop("LogHub");
                LogModel log = new LogModel();

                try
                {
                    if (logHub != null)
                    {
                        log = JsonConvert.DeserializeObject<LogModel>(logHub);
                        if (log != null)
                        {
                            if (!Directory.Exists(log.path)) Directory.CreateDirectory(log.path);
                            File.AppendAllText(Path.Combine(log.path, log.Title), log.Con);
                        }
                    }
                }
                catch (Exception ex)
                {
                    var path = $"D:\\WCSLogs\\{DateTime.Now.yyyyMMdd()}\\日志处理进程";
                    if (!Directory.Exists(path)) Directory.CreateDirectory(path);
                    File.AppendAllText(Path.Combine($"D:\\WCSLogs\\{DateTime.Now.yyyyMMdd()}\\日志处理进程", "Error.txt"), $"{JsonConvert.SerializeObject(log)}--{ex.Message}--{ex.StackTrace}\n");
                }
            }
        }
    }

    public class LogModel
    {
        public string path { get; set; }
        public string Title { get; set; }

        public string Con { get; set; }
    }

    /// <summary>
    ///  业务报警
    /// </summary>
    public class BusinessAlarm
    {
        /// <summary>
        ///  业务名称
        /// </summary>
        public string BusinessName { get; set; }

        /// <summary>
        ///  设备号
        /// </summary>
        public string DevNo { get; set; }

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

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