feat: 增强错误管理功能，添加操作名称以便于日志记录

db/base/index.ts

@@ -47,13 +47,21 @@ class PbToolBase<T extends RecordModel> {
    *
    * @template R - 返回结果类型
    * @param fn - 需要执行的异步函数
+   * @param operation - 操作名称，用于日志记录
    * @returns 成功时返回执行结果，失败时返回 null 并记录错误
    */
-  protected managePbError = async <R>(fn: () => Promise<R>) => {
+  protected managePbError = async <R>(
+    fn: () => Promise<R>,
+    operation: string
+  ) => {
     try {
-      return await fn()
+      const result = await fn()
+      this.logger.debug(`PocketBase ${operation} 成功 [${this.dbName}]`)
+      return result
     } catch (err: any) {
-      this.logger.error(`pocketbase error: ${err.message}`)
+      this.logger.error(
+        `PocketBase ${operation} 失败 [${this.dbName}]: ${err.message}`
+      )
       return null
     }
   }
@@ -70,8 +78,10 @@ class PbToolBase<T extends RecordModel> {
    * ```
    */
   public create = async (data: Partial<T>) => {
-    return this.managePbError<T>(() =>
-      this.pbClient.collection(this.dbName).create(data)
+    this.logger.info(`创建${this.dbName}记录`)
+    return this.managePbError<T>(
+      () => this.pbClient.collection(this.dbName).create(data),
+      "create"
     )
   }
 
@@ -89,8 +99,10 @@ class PbToolBase<T extends RecordModel> {
    * ```
    */
   public get = async <R extends T = T>(id: string, options?: RecordOptions) => {
-    return this.managePbError<R>(() =>
-      this.pbClient.collection(this.dbName).getOne(id, options)
+    this.logger.info(`获取${this.dbName}记录 [ID: ${id}]`)
+    return this.managePbError<R>(
+      () => this.pbClient.collection(this.dbName).getOne(id, options),
+      "get"
     )
   }
 
@@ -113,8 +125,10 @@ class PbToolBase<T extends RecordModel> {
     data: Partial<T>,
     options?: RecordOptions
   ) => {
-    return this.managePbError<R>(() =>
-      this.pbClient.collection(this.dbName).update(id, data, options)
+    this.logger.info(`更新${this.dbName}记录 [ID: ${id}]`)
+    return this.managePbError<R>(
+      () => this.pbClient.collection(this.dbName).update(id, data, options),
+      "update"
     )
   }
 
@@ -131,8 +145,10 @@ class PbToolBase<T extends RecordModel> {
    * ```
    */
   public delete = async (id: string, options?: CommonOptions) => {
-    return this.managePbError(() =>
-      this.pbClient.collection(this.dbName).delete(id, options)
+    this.logger.info(`删除${this.dbName}记录 [ID: ${id}]`)
+    return this.managePbError(
+      () => this.pbClient.collection(this.dbName).delete(id, options),
+      "delete"
     )
   }
 
@@ -152,8 +168,12 @@ class PbToolBase<T extends RecordModel> {
    * ```
    */
   public list = async <R extends T = T>(options?: RecordFullListOptions) => {
-    return this.managePbError<R[]>(() =>
-      this.pbClient.collection(this.dbName).getFullList(options)
+    const filterInfo = options?.filter ? ` [过滤: ${options.filter}]` : ""
+    const sortInfo = options?.sort ? ` [排序: ${options.sort}]` : ""
+    this.logger.info(`获取${this.dbName}记录列表${filterInfo}${sortInfo}`)
+    return this.managePbError<R[]>(
+      () => this.pbClient.collection(this.dbName).getFullList(options),
+      "list"
     )
   }
 
@@ -174,8 +194,11 @@ class PbToolBase<T extends RecordModel> {
     filter: string,
     options?: RecordListOptions
   ) => {
-    return this.managePbError<R>(() =>
-      this.pbClient.collection(this.dbName).getFirstListItem(filter, options)
+    this.logger.info(`获取${this.dbName}第一条匹配记录 [过滤: ${filter}]`)
+    return this.managePbError<R>(
+      () =>
+        this.pbClient.collection(this.dbName).getFirstListItem(filter, options),
+      "getFirstOne"
     )
   }
 }