zhaoqingang
2024-12-31 6b4093952e555e1eb2713bd85133a5f697cda1e0
app/service/session.py
@@ -1,3 +1,4 @@
import json
from typing import Type
from sqlalchemy.orm import Session
@@ -38,8 +39,8 @@
            name=name[0:50],
            agent_id=agent_id,
            agent_type=agent_type,
            tenant_id = user_id,
            message=[{"role": "user", "content": name}]
            tenant_id=user_id,
            message=json.dumps([{"role": "user", "content": name}])
        )
        self.db.add(new_session)
        self.db.commit()
@@ -57,7 +58,7 @@
            SessionModel: 查找到的会话模型实例,如果未找到则返回None。
        """
        session = self.db.query(SessionModel).filter_by(id=session_id).first()
        if session.message is None:
        if  session and session.message is None:
            session.message = '[]'
        return session
@@ -87,6 +88,7 @@
                self.db.commit()
                self.db.refresh(session)
            except Exception as e:
                logger.error(e)
                self.db.rollback()
        return session