liuwei_x_x/abot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

加入斗鱼开播下播提醒

Browse Source
This commit is contained in:
liuwei
2026-01-22 17:19:03 +08:00
parent 9e81e7e035
commit 1b7eb5ac44
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
plugins/douyu/main.py
View File

@@ -114,6 +114,7 @@ class DouyuPlugin(MessagePluginInterface):
self._api_template = "https://www.douyu.com/betard/{room_id}" self._api_template = "https://www.douyu.com/betard/{room_id}"
self._user_agent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36" self._user_agent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36"
self._check_interval = 5 self._check_interval = 5
async_job.every_minutes(self._check_interval)(self._scheduled_check_job)
def initialize(self, context: Dict[str, Any]) -> bool: def initialize(self, context: Dict[str, Any]) -> bool:
try: try:
@@ -124,7 +125,6 @@ class DouyuPlugin(MessagePluginInterface):
self._api_template = cfg.get("api_url_template", self._api_template) self._api_template = cfg.get("api_url_template", self._api_template)
self._user_agent = cfg.get("user_agent", self._user_agent) self._user_agent = cfg.get("user_agent", self._user_agent)
self._check_interval = int(cfg.get("check_interval_minutes", self._check_interval)) self._check_interval = int(cfg.get("check_interval_minutes", self._check_interval))
async_job.every_minutes(self._check_interval)(self._scheduled_check_job)
return True return True
except Exception as e: except Exception as e:
logger.error(f"{self.name} 初始化失败: {e}") logger.error(f"{self.name} 初始化失败: {e}")
@@ -148,7 +148,6 @@ class DouyuPlugin(MessagePluginInterface):
return False return False
@plugin_stats_decorator(plugin_name="斗鱼直播") @plugin_stats_decorator(plugin_name="斗鱼直播")
@plugin_points_cost(1, "斗鱼提醒消耗积分", FEATURE_KEY)
async def process_message(self, message: Dict[str, Any]) -> Tuple[bool, Optional[str]]: async def process_message(self, message: Dict[str, Any]) -> Tuple[bool, Optional[str]]:
content = str(message.get("content", "")).strip() content = str(message.get("content", "")).strip()
sender = message.get("sender") sender = message.get("sender")