[修改]1. 修改将查询单个数据接口。查询不到的时候。会返回一个新的对象

Author: AlianBlank

GameFrameX.DataBase/GameDB.cs

@@ -131,6 +131,7 @@ public static Task<List<TState>> FindSortAscendingAsync<TState>(Expression<Func<
 
     /// <summary>
     /// 根据ID加载指定的文档
+    /// 当没有找到指定ID的文档时，会创建一个新的文档返回
     /// </summary>
     /// <typeparam name="TState">文档的类型,必须继承自BaseCacheState且有无参构造函数</typeparam>
     /// <param name="id">要查找的文档ID</param>
@@ -144,11 +145,12 @@ public static Task<List<TState>> FindSortAscendingAsync<TState>(Expression<Func<
 
     /// <summary>
     /// 查找与指定过滤器匹配的单个文档
+    /// 当没有找到指定ID的文档时，会创建一个新的文档返回
     /// </summary>
     /// <typeparam name="TState">文档的类型,必须继承自BaseCacheState</typeparam>
     /// <param name="filter">用于筛选文档的Lambda表达式</param>
     /// <returns>找到的第一个匹配文档,如果没有匹配项则返回null</returns>
-    public static Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState
+    public static Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState, new()
     {
         ArgumentNullException.ThrowIfNull(_dbServiceImplementation, nameof(_dbServiceImplementation));
         return _dbServiceImplementation.FindAsync(filter);

GameFrameX.DataBase/Mongo/MongoDbService.Query.cs

@@ -25,49 +25,55 @@ public sealed partial class MongoDbService
     {
         var findExpression = GetDefaultFindExpression(filter);
         var state = await _mongoDbContext.Find<TState>().Match(findExpression).OneAsync(id);
-        state?.LoadFromDbPostHandler(false);
-
         var isNew = state == null;
 
         if (state == null)
         {
-            state = new TState { Id = id, };
+            state = new TState { Id = id, CreateTime = TimeHelper.TimeMilliseconds(), };
         }
 
         state.LoadFromDbPostHandler(isNew);
         return state;
     }
 
     /// <summary>
-    /// 异步查找满足指定条件的缓存状态列表。
+    /// 异步查找满足指定条件的缓存状态。
+    /// 当没有找到时，会创建一个
     /// </summary>
     /// <typeparam name="TState">缓存状态的类型。</typeparam>
     /// <param name="filter">查询条件。</param>
-    /// <returns>满足条件的缓存状态列表。</returns>
-    public async Task<List<TState>> FindListAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState
+    /// <returns>满足条件的缓存状态。</returns>
+    public async Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState, new()
     {
         var findExpression = GetDefaultFindExpression(filter);
-        var result = await _mongoDbContext.Queryable<TState>().Where(findExpression).ToListAsync();
-        foreach (var state in result)
+        var state = await _mongoDbContext.Queryable<TState>().Where(findExpression).SingleOrDefaultAsync();
+        var isNew = state == null;
+
+        if (state == null)
         {
-            state?.LoadFromDbPostHandler(false);
+            state = new TState { Id = IdGenerator.GetNextUniqueId(), CreateTime = TimeHelper.TimeMilliseconds(), };
         }
 
-        return result;
+        state.LoadFromDbPostHandler(isNew);
+        return state;
     }
 
     /// <summary>
-    /// 异步查找满足指定条件的缓存状态。
+    /// 异步查找满足指定条件的缓存状态列表。
     /// </summary>
     /// <typeparam name="TState">缓存状态的类型。</typeparam>
     /// <param name="filter">查询条件。</param>
-    /// <returns>满足条件的缓存状态。</returns>
-    public async Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState
+    /// <returns>满足条件的缓存状态列表。</returns>
+    public async Task<List<TState>> FindListAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState, new()
     {
         var findExpression = GetDefaultFindExpression(filter);
-        var state = await _mongoDbContext.Queryable<TState>().Where(findExpression).SingleOrDefaultAsync();
-        state?.LoadFromDbPostHandler(false);
-        return state;
+        var result = await _mongoDbContext.Queryable<TState>().Where(findExpression).ToListAsync();
+        foreach (var state in result)
+        {
+            state?.LoadFromDbPostHandler(false);
+        }
+
+        return result;
     }
 
     /// <summary>