add dialog sss

zhaoqingang

2024-12-18 ae88193c5153aa04226a8307e1294a9c75d312bb

 app/models/token_model.py

@@ -4,7 +4,8 @@
from sqlalchemy import Column, Integer, DateTime, Text
from sqlalchemy.orm import Session

from Log import logger
from app.config.const import RAGFLOW
# from Log import logger
from app.models.base_model import Base


@@ -65,16 +66,19 @@
        if db_token:
            # 记录存在，进行更新
            db_token.token = access_token
            for k, v in token.items():
                setattr(db_token, k.replace("app", "token"), v)
            db_token.ragflow_token = token.get(RAGFLOW, "")
            # 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,
                ragflow_token = token.get(RAGFLOW, "")
            )
            for k, v in token.items():
                setattr(db_token, k.replace("app", "token"), v)
            # for k, v in token.items():
            #     setattr(db_token, k.replace("app", "token"), v)
            db.add(db_token)

        # 提交事务
@@ -82,7 +86,7 @@
        db.refresh(db_token)

    except Exception as e:
        logger.error(e)
        # logger.error(e)
        # 异常处理
        db.rollback()  # 回滚事务