From 0d3dfdcbda0af90d420df9e4a8b07200946c8de6 Mon Sep 17 00:00:00 2001
From: jxxghp <jxxghp@gmail.com>
Date: Tue, 31 Oct 2023 10:32:56 +0800
Subject: [PATCH] =?UTF-8?q?feat=20=E6=9C=8D=E5=8A=A1=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?=E6=B8=85=E7=90=86=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/api/endpoints/system.py |  5 +----
 app/scheduler.py            | 16 ++++++++++++++++
 2 files changed, 17 insertions(+), 4 deletions(-)

diff --git a/app/api/endpoints/system.py b/app/api/endpoints/system.py
index 66c815f5..7602a00d 100644
--- a/app/api/endpoints/system.py
+++ b/app/api/endpoints/system.py
@@ -219,8 +219,5 @@ def execute_command(jobid: str,
     """
     if not jobid:
         return schemas.Response(success=False, message="命令不能为空！")
-    if jobid == "subscribe_search":
-        Scheduler().start(jobid, state='R')
-    else:
-        Scheduler().start(jobid)
+    Scheduler().start(jobid)
     return schemas.Response(success=True)
diff --git a/app/scheduler.py b/app/scheduler.py
index 9b062517..798d90d2 100644
--- a/app/scheduler.py
+++ b/app/scheduler.py
@@ -71,6 +71,10 @@ class Scheduler(metaclass=Singleton):
             "transfer": {
                 "func": TransferChain().process,
                 "running": False,
+            },
+            "clear_cache": {
+                "func": SchedulerChain().clear_cache,
+                "running": False,
             }
         }
 
@@ -202,6 +206,18 @@ class Scheduler(metaclass=Singleton):
             minutes=10
         )
 
+        # 缓存清理服务，每隔24小时
+        self._scheduler.add_job(
+            self.start,
+            "interval",
+            id="clear_cache",
+            name="缓存清理",
+            hours=24,
+            kwargs={
+                'job_id': 'clear_cache'
+            }
+        )
+
         # 打印服务
         logger.debug(self._scheduler.print_jobs())