[增加] 增加同时请求创建对象的时候的重复激活问题

#44

Author: AlianBlank

GameFrameX.Core/Abstractions/Agent/IComponentAgent.cs

@@ -45,15 +45,15 @@ public interface IComponentAgent : IWorker
     /// <remarks>
     /// 在组件开始激活流程前执行，可以用于进行一些预处理操作
     /// </remarks>
-    Task BeforeActivation();
+    Task<bool> BeforeActivation();
 
     /// <summary>
     /// 激活组件代理
     /// <remarks>
     /// 用于初始化并启用组件代理的功能
     /// </remarks>
     /// </summary>
-    Task Active();
+    Task<bool> Active();
 
     /// <summary>
     /// 组件激活后的回调方法
@@ -62,7 +62,7 @@ public interface IComponentAgent : IWorker
     /// <remarks>
     /// 在组件完成激活流程后执行，可以用于处理一些初始化后的逻辑
     /// </remarks>
-    Task AfterActivation();
+    Task<bool> AfterActivation();
 
     /// <summary>
     /// 组件反激活前的回调方法
@@ -71,7 +71,7 @@ public interface IComponentAgent : IWorker
     /// <remarks>
     /// 在组件开始反激活流程前执行，可以用于保存状态或清理资源
     /// </remarks>
-    Task BeforeInActivation();
+    Task<bool> BeforeInActivation();
 
     /// <summary>
     /// 反激活组件代理
@@ -89,7 +89,7 @@ public interface IComponentAgent : IWorker
     /// <remarks>
     /// 在组件完成反激活流程后执行，可以用于确认清理完成或执行最终操作
     /// </remarks>
-    Task AfterInActivation();
+    Task<bool> AfterInActivation();
 
     /// <summary>
     /// 根据代理类型获取代理组件

GameFrameX.Core/Components/BaseComponent.cs

@@ -73,6 +73,11 @@ public void ClearCacheAgent()
     /// <returns>激活任务</returns>
     public virtual Task Active()
     {
+        if (IsActive)
+        {
+            return Task.CompletedTask;
+        }
+
         IsActive = true;
         return Task.CompletedTask;
     }

GameFrameX.Core/Hotfix/Agent/BaseComponentAgent.cs

@@ -68,47 +68,142 @@ public void SetOwner(IComponent owner)
         Owner = owner;
     }
 
+    /// <summary>
+    /// 标记组件是否已执行过激活前预处理
+    /// </summary>
+    protected bool IsInvokedBeforeActivation { get; private set; }
+
     /// <summary>
     /// 组件激活前的预处理操作
     /// </summary>
-    /// <returns>一个已完成的任务</returns>
-    public virtual Task BeforeActivation() => Task.CompletedTask;
+    /// <returns>
+    /// 返回一个 Task&lt;bool&gt; 对象：
+    /// - true：表示预处理成功且是首次执行
+    /// - false：表示已经执行过预处理
+    /// </returns>
+    public virtual Task<bool> BeforeActivation()
+    {
+        if (IsInvokedBeforeActivation)
+        {
+            return Task.FromResult(false);
+        }
+
+        IsInvokedBeforeActivation = true;
+
+        return Task.FromResult(true);
+    }
+
+    /// <summary>
+    /// 标记组件是否已执行过激活操作
+    /// </summary>
+    protected bool IsInvokedActivation { get; private set; }
 
     /// <summary>
     /// 激活组件
     /// </summary>
-    /// <returns>一个已完成的任务</returns>
-    public virtual Task Active()
+    /// <returns>
+    /// 返回一个 Task&lt;bool&gt; 对象：
+    /// - true：表示激活成功且是首次执行
+    /// - false：表示组件已经被激活过
+    /// </returns>
+    public virtual Task<bool> Active()
     {
-        return Task.CompletedTask;
+        if (IsInvokedActivation)
+        {
+            return Task.FromResult(false);
+        }
+
+        IsInvokedActivation = true;
+
+        return Task.FromResult(true);
     }
 
+    /// <summary>
+    /// 标记组件是否已执行过激活后处理
+    /// </summary>
+    protected bool IsInvokedAfterActivation { get; private set; }
+
     /// <summary>
     /// 组件激活后的后处理操作
     /// </summary>
-    /// <returns>一个已完成的任务</returns>
-    public virtual Task AfterActivation() => Task.CompletedTask;
+    /// <returns>
+    /// 返回一个 Task&lt;bool&gt; 对象：
+    /// - true：表示后处理成功且是首次执行
+    /// - false：表示已经执行过后处理
+    /// </returns>
+    public virtual Task<bool> AfterActivation()
+    {
+        if (IsInvokedAfterActivation)
+        {
+            return Task.FromResult(false);
+        }
+
+        IsInvokedAfterActivation = true;
+
+        return Task.FromResult(true);
+    }
+
+    /// <summary>
+    /// 标记组件是否已执行过反激活前预处理
+    /// </summary>
+    protected bool IsInvokedBeforeInActivation { get; private set; }
 
     /// <summary>
     /// 组件反激活前的预处理操作
     /// </summary>
-    /// <returns>一个已完成的任务</returns>
-    public virtual Task BeforeInActivation() => Task.CompletedTask;
+    /// <returns>
+    /// 返回一个 Task&lt;bool&gt; 对象：
+    /// - true：表示预处理成功且是首次执行
+    /// - false：表示已经执行过预处理
+    /// </returns>
+    public virtual Task<bool> BeforeInActivation()
+    {
+        if (IsInvokedBeforeInActivation)
+        {
+            return Task.FromResult(false);
+        }
+
+        IsInvokedBeforeInActivation = true;
+
+        return Task.FromResult(true);
+    }
 
     /// <summary>
     /// 反激活组件
     /// </summary>
-    /// <returns>一个已完成的任务</returns>
+    /// <returns>
+    /// 返回一个已完成的 Task 对象。
+    /// 注意：此方法不检查执行状态，可以多次调用
+    /// </returns>
     public virtual Task Inactive()
     {
         return Task.CompletedTask;
     }
 
+    /// <summary>
+    /// 标记组件是否已执行过反激活后处理
+    /// </summary>
+    protected bool IsInvokedAfterInActivation { get; private set; }
+
     /// <summary>
     /// 组件反激活后的后处理操作
     /// </summary>
-    /// <returns>一个已完成的任务</returns>
-    public virtual Task AfterInActivation() => Task.CompletedTask;
+    /// <returns>
+    /// 返回一个 Task&lt;bool&gt; 对象：
+    /// - true：表示后处理成功且是首次执行
+    /// - false：表示已经执行过后处理
+    /// </returns>
+    public virtual Task<bool> AfterInActivation()
+    {
+        if (IsInvokedAfterInActivation)
+        {
+            return Task.FromResult(false);
+        }
+
+        IsInvokedAfterInActivation = true;
+
+        return Task.FromResult(true);
+    }
 
     /// <summary>
     /// 根据代理类型获取组件代理实例

GameFrameX.Hotfix/Logic/Server/ServerComponentAgent.cs

@@ -9,15 +9,21 @@ namespace GameFrameX.Hotfix.Logic.Server;
 
 public class ServerComponentAgent : StateComponentAgent<ServerComponent, ServerState>
 {
-    public override async Task Active()
+    public override async Task<bool> Active()
     {
-        // 跨天定时器
-        WithCronExpression<CrossDayTimeHandler>("0 0 0 * * ? *");
-        if (State.FirstStartTime == default)
+        var isContinue = await base.Active();
+        if (isContinue)
         {
-            State.FirstStartTime = TimeHelper.UnixTimeSeconds();
-            await OwnerComponent.WriteStateAsync();
+            // 跨天定时器
+            WithCronExpression<CrossDayTimeHandler>("0 0 0 * * ? *");
+            if (State.FirstStartTime == default)
+            {
+                State.FirstStartTime = TimeHelper.UnixTimeSeconds();
+                await OwnerComponent.WriteStateAsync();
+            }
         }
+
+        return isContinue;
     }
 
     [Service]