| | |
|---|
| | | 返回: |
|---|
| | | SessionModel: 新创建的会话模型实例，如果会话ID已存在则返回None。 |
|---|
| | | """ |
|---|
| | | logger.error("-------------xieru") |
|---|
| | | existing_session = self.get_session_by_id(session_id) |
|---|
| | | if existing_session: |
|---|
| | | message=existing_session.message |
|---|
| | | message.append({"role": "user", "content": name}) |
|---|
| | | self.update_session(session_id, message=message) |
|---|
| | | |
|---|
| | | logger.error("-------------xieru------------1") |
|---|
| | | new_session = SessionModel( |
|---|
| | | id=session_id, |
|---|
| | | name=name[0:200], |
|---|
| | |
|---|
| | | session = self.db.query(SessionModel).filter_by(id=session_id).first() |
|---|
| | | if session: |
|---|
| | | if "message" in kwargs: |
|---|
| | | |
|---|
| | | message = session.message |
|---|
| | | logger.error(kwargs) |
|---|
| | | message.append(kwargs["message"]) |
|---|
| | | session = message |
|---|
| | | session.message = message |
|---|
| | | logger.error("更新数据--------------------------11111111-") |
|---|
| | | logger.error(message) |
|---|
| | | self.db.commit() |
|---|
| | | self.db.refresh(session) |
|---|
| | | logger.error("更新数据完成--------------------------1111111122222222-") |
|---|
| | | return session |
|---|
| | | |
|---|
| | | def delete_session(self, session_id: str) -> None: |
|---|
