add 数据共享开关

app/core/config.py

@@ -242,6 +242,10 @@ class Settings(BaseSettings):
     DOH_ENABLE: bool = True
     # 搜索多个名称
     SEARCH_MULTIPLE_NAME: bool = False
+    # 订阅数据共享
+    SUBSCRIBE_STATISTIC_SHARE: bool = True
+    # 插件安装数据共享
+    PLUGIN_STATISTIC_SHARE: bool = True
 
     @validator("SUBSCRIBE_RSS_INTERVAL",
                "COOKIECLOUD_INTERVAL",

app/helper/plugin.py

@@ -30,9 +30,10 @@ class PluginHelper(metaclass=Singleton):
 
     def __init__(self):
         self.systemconfig = SystemConfigOper()
-        if not self.systemconfig.get(SystemConfigKey.PluginInstallReport):
-            if self.install_report():
-                self.systemconfig.set(SystemConfigKey.PluginInstallReport, "1")
+        if settings.PLUGIN_STATISTIC_SHARE:
+            if not self.systemconfig.get(SystemConfigKey.PluginInstallReport):
+                if self.install_report():
+                    self.systemconfig.set(SystemConfigKey.PluginInstallReport, "1")
 
     @cached(cache=TTLCache(maxsize=1000, ttl=1800))
     def get_plugins(self, repo_url: str) -> Dict[str, dict]:
@@ -89,6 +90,8 @@ class PluginHelper(metaclass=Singleton):
         """
         安装插件统计
         """
+        if not settings.PLUGIN_STATISTIC_SHARE:
+            return False
         if not pid:
             return False
         res = RequestUtils(timeout=5).get_res(self._install_reg % pid)
@@ -100,6 +103,8 @@ class PluginHelper(metaclass=Singleton):
         """
         上报存量插件安装统计
         """
+        if not settings.PLUGIN_STATISTIC_SHARE:
+            return False
         plugins = self.systemconfig.get(SystemConfigKey.UserInstalledPlugins)
         if not plugins:
             return False

app/helper/subscribe.py

@@ -3,6 +3,7 @@ from typing import List
 
 from cachetools import TTLCache, cached
 
+from app.core.config import settings
 from app.db.subscribe_oper import SubscribeOper
 from app.db.systemconfig_oper import SystemConfigOper
 from app.schemas.types import SystemConfigKey
@@ -23,9 +24,10 @@ class SubscribeHelper(metaclass=Singleton):
 
     def __init__(self):
         self.systemconfig = SystemConfigOper()
-        if not self.systemconfig.get(SystemConfigKey.SubscribeReport):
-            if self.sub_report():
-                self.systemconfig.set(SystemConfigKey.SubscribeReport, "1")
+        if settings.SUBSCRIBE_STATISTIC_SHARE:
+            if not self.systemconfig.get(SystemConfigKey.SubscribeReport):
+                if self.sub_report():
+                    self.systemconfig.set(SystemConfigKey.SubscribeReport, "1")
 
     @cached(cache=TTLCache(maxsize=10, ttl=1800))
     def get_statistic(self, stype: str, page: int = 1, count: int = 30) -> List[dict]:
@@ -45,6 +47,8 @@ class SubscribeHelper(metaclass=Singleton):
         """
         新增订阅统计
         """
+        if not settings.SUBSCRIBE_STATISTIC_SHARE:
+            return False
         res = RequestUtils(timeout=5, headers={
             "Content-Type": "application/json"
         }).post_res(self._sub_reg, json=sub)
@@ -64,6 +68,8 @@ class SubscribeHelper(metaclass=Singleton):
         """
         上报存量订阅统计
         """
+        if not settings.SUBSCRIBE_STATISTIC_SHARE:
+            return False
         subscribes = SubscribeOper().list()
         if not subscribes:
             return True