codfrm/MoviePilot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix NAStool数据同步插件

Browse Source
This commit is contained in:
thsrite 2023-08-31 14:47:21 +08:00
parent 9f0bd2b933
commit 3943a7a793
1 changed files with 23 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
app/plugins/nastoolsync/__init__.py
View File

@ -255,29 +255,32 @@ class NAStoolSync(_PluginBase):
# 转种后种子hash # 转种后种子hash
transfer_hash = [] transfer_hash = []
qb_torrents = []
tr_torrents = []
tr_torrents_all = []
if self._supp:
# 获取所有的转种数据
transfer_datas = self._plugindata.get_data_all("TorrentTransfer")
if transfer_datas:
if not isinstance(transfer_datas, list):
transfer_datas = [transfer_datas]
# 获取所有的转种数据 for transfer_data in transfer_datas:
transfer_datas = self._plugindata.get_data_all("TorrentTransfer") if not transfer_data or not isinstance(transfer_data, PluginData):
if transfer_datas: continue
if not isinstance(transfer_datas, list): # 转移后种子hash
transfer_datas = [transfer_datas] transfer_value = transfer_data.value
for transfer_data in transfer_datas:
if not transfer_data or not isinstance(transfer_data, PluginData):
continue
# 转移后种子hash
transfer_value = transfer_data.value
transfer_value = json.loads(transfer_value)
if not isinstance(transfer_value, dict):
transfer_value = json.loads(transfer_value) transfer_value = json.loads(transfer_value)
to_hash = transfer_value.get("to_download_id") if not isinstance(transfer_value, dict):
# 转移前种子hash transfer_value = json.loads(transfer_value)
transfer_hash.append(to_hash) to_hash = transfer_value.get("to_download_id")
# 转移前种子hash
transfer_hash.append(to_hash)
# 获取tr、qb所有种子 # 获取tr、qb所有种子
qb_torrents, _ = self.qb.get_torrents() qb_torrents, _ = self.qb.get_torrents()
tr_torrents, _ = self.tr.get_torrents(ids=transfer_hash) tr_torrents, _ = self.tr.get_torrents(ids=transfer_hash)
tr_torrents_all, _ = self.tr.get_torrents() tr_torrents_all, _ = self.tr.get_torrents()
# 处理数据，存入mp数据库 # 处理数据，存入mp数据库
for history in transfer_history: for history in transfer_history: