From 4acc9936db7f91c6f6fc9cb1db40a720ee9a6cda Mon Sep 17 00:00:00 2001
From: Jerry <JerryTech.Y@outlook.com>
Date: Fri, 11 Apr 2025 13:55:12 +0800
Subject: [PATCH] redis

---
 .idea/codeStyles/Project.xml |  1 +
 src/services/redis/redis.ts  | 29 ++++++++++++++++++++++-------
 2 files changed, 23 insertions(+), 7 deletions(-)

diff --git a/.idea/codeStyles/Project.xml b/.idea/codeStyles/Project.xml
index af5ea2e..79e151b 100644
--- a/.idea/codeStyles/Project.xml
+++ b/.idea/codeStyles/Project.xml
@@ -14,6 +14,7 @@
     </JSCodeStyleSettings>
     <TypeScriptCodeStyleSettings version="0">
       <option name="FORCE_SEMICOLON_STYLE" value="true" />
+      <option name="FILE_NAME_STYLE" value="CAMEL_CASE" />
       <option name="SPACE_BEFORE_FUNCTION_LEFT_PARENTH" value="false" />
       <option name="USE_PUBLIC_MODIFIER" value="true" />
       <option name="USE_DOUBLE_QUOTES" value="false" />
diff --git a/src/services/redis/redis.ts b/src/services/redis/redis.ts
index 429f7f0..467802a 100644
--- a/src/services/redis/redis.ts
+++ b/src/services/redis/redis.ts
@@ -108,12 +108,25 @@ class RedisService {
     return redisTool.reviveDates(deserialized);
   }
 
+  public async updateUser(qq: string, updates: Partial<IUser>): Promise<IUser> {
+    const existing = await this.getObject<IUser>(`user:${qq}`);
+    if (!existing) {
+      throw new Error(`用户 ${qq} 不存在`);
+    }
+    const updatedUser = { ...existing, ...updates, updatedAt: new Date() };
+    await this.persistUser(updatedUser);
+    return updatedUser;
+  }
+
   public async persistUser<T extends IUser>(user: T): Promise<void> {
     try {
-      await this.setObject(`user:${user.qq}`, user);
-      await Persistence.writeDataLocal(user.name, user);
+      await Promise.all([
+        this.setObject(`user:${user.qq}`, user),
+        Persistence.writeDataLocal(user.name, user),
+      ]);
     } catch (err) {
       logger.error(err);
+      throw err;
     }
   }
 
@@ -124,15 +137,18 @@ class RedisService {
     try {
       const fromRedis = await this.getObject<IUser>(`user:${qq}`);
       if (fromRedis) return fromRedis;
+
       const fromLocal = await Persistence.readDataLocal<IUser>(username);
       if (fromLocal) {
         await this.setObject(`user:${qq}`, fromLocal);
         return fromLocal;
       }
+
       logger.error(`用户${username},qq${qq}不存在！`);
       return undefined;
     } catch (err) {
       logger.error(err);
+      throw err;
     }
   }
 
@@ -144,11 +160,10 @@ class RedisService {
       password: '114514',
       createdAt: new Date(),
     };
-    let test = redisTool.reviveDates(testData);
-    logger.debug(test);
-    await this.setObject('test', test);
-    const push = await this.getObject('test');
-    logger.debug(push);
+
+    await this.persistUser(testData);
+    const user = await this.fetchUser('114514', 'Jerry');
+    logger.debug(user);
   }
 }