Rename Manager

2026-10-20 20:25:01 +03:00 · 2025-08-17 17:31:55 +08:00
parent 2060ac18fd
commit d5c50ef27c
74 changed files with 383 additions and 383 deletions
@@ -0,0 +1,181 @@
+using System.Collections.Concurrent;
+
+//using System.Reactive.Linq;
+
+namespace ServiceLib.Manager;
+
+public class ProfileExManager
+{
+    private static readonly Lazy<ProfileExManager> _instance = new(() => new());
+    private ConcurrentBag<ProfileExItem> _lstProfileEx = [];
+    private readonly Queue<string> _queIndexIds = new();
+    public static ProfileExManager Instance => _instance.Value;
+    private static readonly string _tag = "ProfileExHandler";
+
+    public ProfileExManager()
+    {
+        //Init();
+    }
+
+    public async Task Init()
+    {
+        await InitData();
+    }
+
+    public async Task<ConcurrentBag<ProfileExItem>> GetProfileExs()
+    {
+        return await Task.FromResult(_lstProfileEx);
+    }
+
+    private async Task InitData()
+    {
+        await SQLiteHelper.Instance.ExecuteAsync($"delete from ProfileExItem where indexId not in ( select indexId from ProfileItem )");
+
+        _lstProfileEx = new(await SQLiteHelper.Instance.TableAsync<ProfileExItem>().ToListAsync());
+    }
+
+    private void IndexIdEnqueue(string indexId)
+    {
+        if (indexId.IsNotEmpty() && !_queIndexIds.Contains(indexId))
+        {
+            _queIndexIds.Enqueue(indexId);
+        }
+    }
+
+    private async Task SaveQueueIndexIds()
+    {
+        var cnt = _queIndexIds.Count;
+        if (cnt > 0)
+        {
+            var lstExists = await SQLiteHelper.Instance.TableAsync<ProfileExItem>().ToListAsync();
+            List<ProfileExItem> lstInserts = [];
+            List<ProfileExItem> lstUpdates = [];
+
+            for (var i = 0; i < cnt; i++)
+            {
+                var id = _queIndexIds.Dequeue();
+                var item = lstExists.FirstOrDefault(t => t.IndexId == id);
+                var itemNew = _lstProfileEx?.FirstOrDefault(t => t.IndexId == id);
+                if (itemNew is null)
+                {
+                    continue;
+                }
+
+                if (item is not null)
+                {
+                    lstUpdates.Add(itemNew);
+                }
+                else
+                {
+                    lstInserts.Add(itemNew);
+                }
+            }
+
+            try
+            {
+                if (lstInserts.Count > 0)
+                {
+                    await SQLiteHelper.Instance.InsertAllAsync(lstInserts);
+                }
+
+                if (lstUpdates.Count > 0)
+                {
+                    await SQLiteHelper.Instance.UpdateAllAsync(lstUpdates);
+                }
+            }
+            catch (Exception ex)
+            {
+                Logging.SaveLog(_tag, ex);
+            }
+        }
+    }
+
+    private ProfileExItem AddProfileEx(string indexId)
+    {
+        var profileEx = new ProfileExItem()
+        {
+            IndexId = indexId,
+            Delay = 0,
+            Speed = 0,
+            Sort = 0,
+            Message = string.Empty
+        };
+        _lstProfileEx.Add(profileEx);
+        IndexIdEnqueue(indexId);
+        return profileEx;
+    }
+
+    private ProfileExItem GetProfileExItem(string? indexId)
+    {
+        return _lstProfileEx.FirstOrDefault(t => t.IndexId == indexId) ?? AddProfileEx(indexId);
+    }
+
+    public async Task ClearAll()
+    {
+        await SQLiteHelper.Instance.ExecuteAsync($"delete from ProfileExItem ");
+        _lstProfileEx = new();
+    }
+
+    public async Task SaveTo()
+    {
+        try
+        {
+            await SaveQueueIndexIds();
+        }
+        catch (Exception ex)
+        {
+            Logging.SaveLog(_tag, ex);
+        }
+    }
+
+    public void SetTestDelay(string indexId, int delay)
+    {
+        var profileEx = GetProfileExItem(indexId);
+
+        profileEx.Delay = delay;
+        IndexIdEnqueue(indexId);
+    }
+
+    public void SetTestSpeed(string indexId, decimal speed)
+    {
+        var profileEx = GetProfileExItem(indexId);
+
+        profileEx.Speed = speed;
+        IndexIdEnqueue(indexId);
+    }
+
+    public void SetTestMessage(string indexId, string message)
+    {
+        var profileEx = GetProfileExItem(indexId);
+
+        profileEx.Message = message;
+        IndexIdEnqueue(indexId);
+    }
+
+    public void SetSort(string indexId, int sort)
+    {
+        var profileEx = GetProfileExItem(indexId);
+
+        profileEx.Sort = sort;
+        IndexIdEnqueue(indexId);
+    }
+
+    public int GetSort(string indexId)
+    {
+        var profileEx = _lstProfileEx.FirstOrDefault(t => t.IndexId == indexId);
+        if (profileEx == null)
+        {
+            return 0;
+        }
+        return profileEx.Sort;
+    }
+
+    public int GetMaxSort()
+    {
+        if (_lstProfileEx.Count <= 0)
+        {
+            return 0;
+        }
+        return _lstProfileEx.Max(t => t == null ? 0 : t.Sort);
+    }
+}