fix 转移历史记录

app/chain/subscribe.py

@@ -424,7 +424,7 @@ class SubscribeChain(ChainBase):
                 # 回收资源
                 del torrents
             else:
-                logger.info(f'{indexer.get("name")} 获取到种子')
+                logger.info(f'{indexer.get("name")} 没有获取到种子')
         # 从缓存中匹配订阅
         self.match(torrents_cache)
         # 保存缓存到本地

app/chain/transfer.py

@@ -330,7 +330,7 @@ class TransferChain(ChainBase):
         """
         新增转移成功历史记录
         """
-        self.transferhis.add_force(
+        self.transferhis.add(
             src=str(src_path),
             dest=str(transferinfo.target_path),
             mode=settings.TRANSFER_TYPE,
@@ -356,7 +356,7 @@ class TransferChain(ChainBase):
         新增转移失败历史记录，不能按download_hash判重
         """
         if mediainfo and transferinfo:
-            his = self.transferhis.add_force(
+            his = self.transferhis.add(
                 src=str(src_path),
                 dest=str(transferinfo.target_path),
                 mode=settings.TRANSFER_TYPE,
@@ -377,7 +377,7 @@ class TransferChain(ChainBase):
                 files=json.dumps(transferinfo.file_list)
             )
         else:
-            his = self.transferhis.add_force(
+            his = self.transferhis.add(
                 src=str(src_path),
                 mode=settings.TRANSFER_TYPE,
                 seasons=meta.season,

app/db/transferhistory_oper.py

@@ -35,10 +35,6 @@ class TransferHistoryOper(DbOper):
         """
         新增转移历史
         """
-        if kwargs.get("download_hash"):
-            transferhistory = TransferHistory.get_by_hash(self._db, kwargs.get("download_hash"))
-            if transferhistory:
-                transferhistory.delete(self._db, transferhistory.id)
         kwargs.update({
             "date": time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
         })
@@ -76,7 +72,7 @@ class TransferHistoryOper(DbOper):
 
     def add_force(self, **kwargs):
         """
-        新增转移历史
+        新增转移历史，相同源目录的记录会被删除
         """
         if kwargs.get("src"):
             transferhistory = TransferHistory.get_by_src(self._db, kwargs.get("src"))