Update server/dao.py

server/dao.py

@@ -99,6 +99,34 @@ class tableStore:
         except Exception as e:
             raise customError("userSignUp 失败",e)
 
+    def userDelete(self,email,password)->"user info or throw error":
+        self.getUserInfo(email)  # 检测登录前先获取用户信息
+        primary_key = [
+            ['email', email],
+        ]
+        if self.checkInit():
+            # 都存在说明正常初始化
+            try:
+                if not (self.email==email and self.stored_password==password):
+                    raise customError("用户或密码不正确")
+
+                # 删除用户信息
+                self.ots_client.delete_row(
+                    table_name=self.table_name,
+                    primary_key=primary_key,
+                    condition=Condition(RowExistenceExpectation.EXPECT_EXIST)  # 只有存在的行才能删除
+                )
+
+                return {"ec": 200, "message": "用户删除成功", "email": email}
+            except Exception as e:
+                raise customError("userDelete 失败", e)
+        else:
+            raise customError("login调用时发现用户信息没有正常初始化")
+
+
+
+
+
     def updateColumnByPrimaryKey(self,key:str,key_value:'dynamic',
                                  update_column:str,update_column_value:'dynamic')\
             -> "bool or throw error":
@@ -148,10 +176,10 @@ if __name__ == '__main__':
         instance_name=instance_name
     )
     tablestore = tableStore(ots_client=ots_client,table_name=table_name)
-    tablestore.updateColumnByPrimaryKey(key='email',key_value='user@example.com',
-                                        update_column='balance',update_column_value=1728877808)
-
-
+    # tablestore.updateColumnByPrimaryKey(key='email',key_value='user@example.com',
+    #                                     update_column='balance',update_column_value=1728877808)
+    resp = tablestore.userDelete('1234567891011@qq.com','12345678910')
+    print(resp)