From 6846a4c98a793e74ae17b47f04a0ff8b210aeb24 Mon Sep 17 00:00:00 2001
From: zhaoqingang <zhaoqg0118@163.com>
Date: 星期二, 01 四月 2025 16:52:51 +0800
Subject: [PATCH] 授权license

---
 app/models/token_model.py |   56 +++++++++-----------------------------------------------
 1 files changed, 9 insertions(+), 47 deletions(-)

diff --git a/app/models/token_model.py b/app/models/token_model.py
index febe111..bfd088d 100644
--- a/app/models/token_model.py
+++ b/app/models/token_model.py
@@ -1,13 +1,7 @@
 from datetime import datetime
-from typing import Type
-
-from sqlalchemy import Column, Integer, DateTime, Text
+from sqlalchemy import Column, Integer, DateTime, Text, String
 from sqlalchemy.orm import Session
-
-from Log import logger
-from app.config.const import RAGFLOW
 from app.models.base_model import Base
-from app.service.auth import UserAppDao
 
 
 class TokenModel(Base):
@@ -55,43 +49,11 @@
         db.rollback()  # 鍥炴粴浜嬪姟
 
 
-async def update_token(db: Session, user_id: int, access_token: str, token: dict):
-    # 鍙傛暟楠岃瘉
-    if not isinstance(user_id, int) or user_id <= 0:
-        return
-    db_token = None
-    # print(token)
-    try:
-        # 鏌ヨ鐜版湁璁板綍
-        db_token = db.query(TokenModel).filter_by(user_id=user_id).first()
-        if db_token:
-            # 璁板綍瀛樺湪锛岃繘琛屾洿鏂�
-            db_token.token = access_token
-            for k, v in token.items():
-                setattr(db_token, k.replace("app", "token"), v)
-        else:
-            # 璁板綍涓嶅瓨鍦紝杩涜鎻掑叆
-            db_token = TokenModel(
-                user_id=user_id,
-                token=access_token,
-            )
-            for k, v in token.items():
-                setattr(db_token, k.replace("app", "token"), v)
-            db.add(db_token)
-
-        # 鎻愪氦浜嬪姟
-        db.commit()
-        db.refresh(db_token)
-
-    except Exception as e:
-        logger.error(e)
-        # 寮傚父澶勭悊
-        db.rollback()  # 鍥炴粴浜嬪姟
-
-
-async def get_token(db: Session, user_id: int):
-    res = {i.app_type.replace("app", "token"): i.access_token for i in await UserAppDao(db).get_user_datas(user_id)}
-    if not res:
-        token = db.query(TokenModel).filter_by(user_id=user_id).first()
-        res = {"ragflow_token": token.ragflow_token, "bisheng_token": token.bisheng_token}
-    return res
+class ApiTokenModel(Base):
+    __tablename__ = "chat_api_tokens"
+    id = Column(String(36), primary_key=True)
+    app_id = Column(String(36), index=True)
+    type = Column(String(16))
+    token = Column(String(255))
+    created_at = Column(DateTime, default=datetime.now())
+    last_used_at = Column(DateTime, default=datetime.now())

--
Gitblit v1.8.0