feat(cqrs): 添加CQRS模式的抽象处理器基类

- 实现了抽象命令处理器基类，支持带返回值和无返回值两种类型
- 创建了抽象通知处理器基类，提供统一的通知处理功能
- 添加了抽象查询处理器基类，支持泛型查询和结果类型
- 实现了抽象请求处理器基类，处理有响应和无响应的请求场景
- 集成了ContextAwareBase基类以提供上下文感知功能
- 使用Mediator库接口实现标准化的CQRS处理模式

GFramework.Core/cqrs/command/AbstractCommandHandler.cs

@@ -0,0 +1,55 @@
+// Copyright (c) 2026 GeWuYou
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// 
+//     http://www.apache.org/licenses/LICENSE-2.0
+// 
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using GFramework.Core.rule;
+using Mediator;
+
+namespace GFramework.Core.cqrs.command;
+
+/// <summary>
+/// 抽象命令处理器基类
+/// 继承自ContextAwareBase并实现ICommandHandler接口，为具体的命令处理器提供基础功能
+/// </summary>
+/// <typeparam name="TCommand">命令类型</typeparam>
+public abstract class AbstractCommandHandler<TCommand> : ContextAwareBase, ICommandHandler<TCommand>
+    where TCommand : ICommand<Unit>
+{
+    /// <summary>
+    /// 处理指定的命令
+    /// 由具体的命令处理器子类实现命令处理逻辑
+    /// </summary>
+    /// <param name="command">要处理的命令对象</param>
+    /// <param name="cancellationToken">取消令牌，用于取消操作</param>
+    /// <returns>表示异步操作完成的ValueTask，返回Unit类型表示无返回值</returns>
+    public abstract ValueTask<Unit> Handle(TCommand command, CancellationToken cancellationToken);
+}
+
+/// <summary>
+/// 抽象命令处理器基类（带返回值版本）
+/// 继承自ContextAwareBase并实现ICommandHandler接口，为具体的命令处理器提供基础功能
+/// 支持泛型命令和结果类型，实现CQRS模式中的命令处理
+/// </summary>
+/// <typeparam name="TCommand">命令类型，必须实现ICommand接口</typeparam>
+/// <typeparam name="TResult">命令执行结果类型</typeparam>
+public abstract class AbstractCommandHandler<TCommand, TResult> : ContextAwareBase, ICommandHandler<TCommand, TResult>
+    where TCommand : ICommand<TResult>
+{
+    /// <summary>
+    /// 处理指定的命令并返回结果
+    /// 由具体的命令处理器子类实现命令处理逻辑
+    /// </summary>
+    /// <param name="command">要处理的命令对象</param>
+    /// <param name="cancellationToken">取消令牌，用于取消操作</param>
+    /// <returns>表示异步操作完成的ValueTask，包含命令执行结果</returns>
+    public abstract ValueTask<TResult> Handle(TCommand command, CancellationToken cancellationToken);
+}

GFramework.Core/cqrs/notification/AbstractNotificationHandler.cs

@@ -0,0 +1,36 @@
+// Copyright (c) 2026 GeWuYou
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// 
+//     http://www.apache.org/licenses/LICENSE-2.0
+// 
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using GFramework.Core.rule;
+using Mediator;
+
+namespace GFramework.Core.cqrs.notification;
+
+/// <summary>
+/// 抽象通知处理器基类
+/// 继承自ContextAwareBase并实现INotificationHandler接口，为具体的通知处理器提供基础功能
+/// 用于处理CQRS模式中的通知消息，支持异步处理
+/// </summary>
+/// <typeparam name="TNotification">通知类型，必须实现INotification接口</typeparam>
+public abstract class AbstractNotificationHandler<TNotification> : ContextAwareBase, INotificationHandler<TNotification>
+    where TNotification : INotification
+{
+    /// <summary>
+    /// 处理指定的通知消息
+    /// 由具体的通知处理器子类实现通知处理逻辑
+    /// </summary>
+    /// <param name="notification">要处理的通知对象</param>
+    /// <param name="cancellationToken">取消令牌，用于取消操作</param>
+    /// <returns>表示异步操作完成的ValueTask</returns>
+    public abstract ValueTask Handle(TNotification notification, CancellationToken cancellationToken);
+}

GFramework.Core/cqrs/query/AbstractQueryHandler.cs

@@ -0,0 +1,37 @@
+// Copyright (c) 2026 GeWuYou
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// 
+//     http://www.apache.org/licenses/LICENSE-2.0
+// 
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using GFramework.Core.rule;
+using Mediator;
+
+namespace GFramework.Core.cqrs.query;
+
+/// <summary>
+/// 抽象查询处理器基类
+/// 继承自ContextAwareBase并实现IQueryHandler接口，为具体的查询处理器提供基础功能
+/// 支持泛型查询和结果类型，实现CQRS模式中的查询处理
+/// </summary>
+/// <typeparam name="TQuery">查询类型，必须实现IQuery接口</typeparam>
+/// <typeparam name="TResult">查询结果类型</typeparam>
+public abstract class AbstractQueryHandler<TQuery, TResult> : ContextAwareBase, IQueryHandler<TQuery, TResult>
+    where TQuery : IQuery<TResult>
+{
+    /// <summary>
+    /// 处理指定的查询并返回结果
+    /// 由具体的查询处理器子类实现查询处理逻辑
+    /// </summary>
+    /// <param name="query">要处理的查询对象</param>
+    /// <param name="cancellationToken">取消令牌，用于取消操作</param>
+    /// <returns>表示异步操作完成的ValueTask，包含查询结果</returns>
+    public abstract ValueTask<TResult> Handle(TQuery query, CancellationToken cancellationToken);
+}

GFramework.Core/cqrs/request/AbstractRequestHandler.cs

@@ -0,0 +1,52 @@
+// Copyright (c) 2026 GeWuYou
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// 
+//     http://www.apache.org/licenses/LICENSE-2.0
+// 
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+using GFramework.Core.rule;
+using Mediator;
+
+namespace GFramework.Core.cqrs.request;
+
+/// <summary>
+/// 抽象请求处理器基类，用于处理不返回具体响应的请求
+/// 继承自ContextAwareBase并实现IRequestHandler接口
+/// </summary>
+/// <typeparam name="TRequest">请求类型，必须实现IRequest[Unit]接口</typeparam>
+public abstract class AbstractRequestHandler<TRequest> : ContextAwareBase, IRequestHandler<TRequest>
+    where TRequest : IRequest<Unit>
+{
+    /// <summary>
+    /// 处理请求的核心方法
+    /// </summary>
+    /// <param name="request">要处理的请求对象</param>
+    /// <param name="cancellationToken">取消令牌，用于取消操作</param>
+    /// <returns>表示异步操作的ValueTask，完成时返回Unit值</returns>
+    public abstract ValueTask<Unit> Handle(TRequest request, CancellationToken cancellationToken);
+}
+
+/// <summary>
+/// 抽象请求处理器基类，用于处理需要返回具体响应的请求
+/// 继承自ContextAwareBase并实现IRequestHandler接口
+/// </summary>
+/// <typeparam name="TRequest">请求类型，必须实现IRequest[TResponse]接口</typeparam>
+/// <typeparam name="TResponse">响应类型</typeparam>
+public abstract class AbstractRequestHandler<TRequest, TResponse> : ContextAwareBase,
+    IRequestHandler<TRequest, TResponse> where TRequest : IRequest<TResponse>
+{
+    /// <summary>
+    /// 处理请求并返回响应的核心方法
+    /// </summary>
+    /// <param name="request">要处理的请求对象</param>
+    /// <param name="cancellationToken">取消令牌，用于取消操作</param>
+    /// <returns>表示异步操作的ValueTask，完成时返回处理结果</returns>
+    public abstract ValueTask<TResponse> Handle(TRequest request, CancellationToken cancellationToken);
+}