mirror of
https://github.com/jxxghp/MoviePilot.git
synced 2026-09-07 08:26:53 +08:00
fix
This commit is contained in:
@@ -486,7 +486,7 @@ class ChainBase(metaclass=ABCMeta):
|
|||||||
# 发送事件
|
# 发送事件
|
||||||
self.eventmanager.send_event(etype=EventType.NoticeMessage, data=message.dict())
|
self.eventmanager.send_event(etype=EventType.NoticeMessage, data=message.dict())
|
||||||
# 保存消息
|
# 保存消息
|
||||||
self.messagehelper.put(message, role="user")
|
self.messagehelper.put(message, role="user", title=message.title)
|
||||||
self.messageoper.add(**message.dict())
|
self.messageoper.add(**message.dict())
|
||||||
# 发送
|
# 发送
|
||||||
self.run_module("post_message", message=message)
|
self.run_module("post_message", message=message)
|
||||||
@@ -499,7 +499,7 @@ class ChainBase(metaclass=ABCMeta):
|
|||||||
:return: 成功或失败
|
:return: 成功或失败
|
||||||
"""
|
"""
|
||||||
note_list = [media.to_dict() for media in medias]
|
note_list = [media.to_dict() for media in medias]
|
||||||
self.messagehelper.put(message, role="user", note=note_list)
|
self.messagehelper.put(message, role="user", note=note_list, title=message.title)
|
||||||
self.messageoper.add(**message.dict(), note=note_list)
|
self.messageoper.add(**message.dict(), note=note_list)
|
||||||
return self.run_module("post_medias_message", message=message, medias=medias)
|
return self.run_module("post_medias_message", message=message, medias=medias)
|
||||||
|
|
||||||
@@ -511,7 +511,7 @@ class ChainBase(metaclass=ABCMeta):
|
|||||||
:return: 成功或失败
|
:return: 成功或失败
|
||||||
"""
|
"""
|
||||||
note_list = [torrent.torrent_info.to_dict() for torrent in torrents]
|
note_list = [torrent.torrent_info.to_dict() for torrent in torrents]
|
||||||
self.messagehelper.put(message, role="user", note=note_list)
|
self.messagehelper.put(message, role="user", note=note_list, title=message.title)
|
||||||
self.messageoper.add(**message.dict(), note=note_list)
|
self.messageoper.add(**message.dict(), note=note_list)
|
||||||
return self.run_module("post_torrents_message", message=message, torrents=torrents)
|
return self.run_module("post_torrents_message", message=message, torrents=torrents)
|
||||||
|
|
||||||
|
|||||||
@@ -147,6 +147,10 @@ class Base:
|
|||||||
|
|
||||||
@db_update
|
@db_update
|
||||||
def create(self, db: Session):
|
def create(self, db: Session):
|
||||||
|
# 如果是对象,转换为json字符串
|
||||||
|
for key, value in self.__dict__.items():
|
||||||
|
if ObjectUtils.is_obj(value):
|
||||||
|
setattr(self, key, json.dumps(value))
|
||||||
db.add(self)
|
db.add(self)
|
||||||
|
|
||||||
@classmethod
|
@classmethod
|
||||||
|
|||||||
Reference in New Issue
Block a user