App_V2.3/SourceCode/WeApp.Core/CommonManager/AppGuids/RecordIdManager.cs

using System;
using System.Collections.Concurrent;
using System.Configuration;
using System.IO;
using System.Timers;
using System.Xml;

using Abp.UI;

using IwbZero.ToolCommon.LogHelpers;
using IwbZero.ToolCommon.StringModel;

using WeApp.BaseInfo;
using WeApp.Configuration;

namespace WeApp.CommonManager.AppGuids
{
    public static class RecordIdManager
    {
        private static readonly decimal Interval = ConfigurationManager.AppSettings["WeApp.RecordId.TimerInterval"]?.ValD() ?? (decimal)1;
        private static bool HasChanged = true;

        /// <summary>
        /// 定时器
        /// </summary>
        private static Timer Timer;

        private static string FileName => Path.Combine(AppDomain.CurrentDomain.BaseDirectory, IwbConsts.ResourceBasePath, "Guids.iwbx");

        //分钟
        private static ConcurrentDictionary<AppGuidType, RecordId> RecordIddDictionary { get; set; }

        /// <summary>
        /// 获取下一记录ID
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public static int GetNextRecordId(AppGuidType type)
        {
            HasChanged = true;
            if (RecordIddDictionary.TryGetValue(type, out var record))
            {
                return record.GetNextId();
            }
            throw new UserFriendlyException("获取下一记录ID失败！");
        }

        /// <summary>
        /// 加载文件数据
        /// </summary>
        public static void LoadDictionary()
        {
            if (!File.Exists(FileName))
            {
                throw new Exception("未查询到Guid文件，请检查配置！");
            }
            RecordIddDictionary = new ConcurrentDictionary<AppGuidType, RecordId>();
            try
            {
                var xDoc = new XmlDocument();
                xDoc.Load(FileName);
                XmlNode xmlNode = xDoc.LastChild;
                if (xmlNode != null && xmlNode.HasChildNodes)
                {
                    foreach (XmlNode node in xmlNode.ChildNodes)
                    {
                        var record = new RecordId
                        {
                            IdType = (node.Attributes?["type"] != null ? node.Attributes["type"].Value : "")
                                .GetEnumByName<AppGuidType>(),
                            Step = (node.Attributes?["step"] != null ? node.Attributes["step"].Value : "").ValI(),
                            LastId = (node.Attributes?["last-id"] != null ? node.Attributes["last-id"].Value : "")
                                .ValI(),
                            LastDate = (node.Attributes?["last-date"] != null
                                ? node.Attributes["last-date"].Value
                                : "").StrToDt()
                        };
                        if (!RecordIddDictionary.ContainsKey(record.IdType))
                        {
                            RecordIddDictionary.TryAdd(record.IdType, record);
                        }
                    }
                }
                //触发定时器执行
                ExecuteTimer();
            }
            catch (Exception e)
            {
                typeof(RecordIdManager).LogError(e);
                throw new Exception($"Guid文件解析失败，请检查配置！（{e.Message}）");
            }
        }

        /// <summary>
        /// 执行定时器
        /// </summary>
        private static void ExecuteTimer()
        {
            if (Timer != null)
            {
                Timer.Stop();
                Timer.Close();
                Timer = null;
            }
            //分钟转换成毫秒
            var interval = Convert.ToDouble(Interval * 60 * 1000);
            Timer = new Timer(interval);
            Timer.Elapsed += Save;
            Timer.Enabled = true;
            Timer.AutoReset = true;
            Timer.Start();
            typeof(RecordIdManager).LogDebug("GUID保存定时器已执行");

        }

        /// <summary>
        /// 定时保存数据
        /// </summary>
        /// <param name="source"></param>
        /// <param name="ev"></param>
        private static void Save(object source, ElapsedEventArgs ev)
        {
            if (!HasChanged)
                return;
            if (RecordIddDictionary == null)
                return;

            var str = "";
            foreach (var dic in RecordIddDictionary)
            {
                var record = dic.Value;
                str += $"<Guid type=\"{record.IdType}\" step=\"{record.Step}\" last-id=\"{record.LastId}\" last-date=\"{record.LastDate}\"></Guid>";
            }
            str = $"<Guids>{str}</Guids>";
            try
            {
                typeof(RecordIdManager).LogDebug($"保存GUID文件：{FileName}");
                var xDoc = new XmlDocument { InnerXml = str };
                xDoc.Save(FileName);
            }
            catch (Exception e)
            {
                typeof(RecordIdManager).LogDebug($"保存失败！");
                typeof(RecordIdManager).LogError(e);
            }

            HasChanged = false;
        }
    }
}