fix 目录监控消息重复发送

app/chain/transfer.py

@@ -34,6 +34,7 @@ from app.utils.string import StringUtils
 
 downloader_lock = threading.Lock()
 job_lock = threading.Lock()
+task_lock = threading.Lock()
 
 
 class JobManager:
@@ -460,6 +461,7 @@ class TransferChain(ChainBase, metaclass=Singleton):
 
         # 整理完成且有成功的任务时
         if self.jobview.is_finished(task):
+            with task_lock:
                 # 发送通知
                 if transferinfo.need_notify:
                     se_str = None
@@ -486,6 +488,9 @@ class TransferChain(ChainBase, metaclass=Singleton):
                         'fileitem': transferinfo.target_diritem
                     })
 
+                # 移除已完成的任务
+                self.jobview.remove_job(task)
+
         return True, ""
 
     def put_to_queue(self, task: TransferTask, callback: Optional[Callable] = None):
@@ -497,6 +502,7 @@ class TransferChain(ChainBase, metaclass=Singleton):
         if not task:
             return
         # 维护整理任务视图
+        with task_lock:
             self.jobview.add_task(task)
         # 添加到队列
         self._queue.put(TransferQueue(