添加天使动漫签到签到词：街声每日歌曲；添加 apschduler 立即运行参数 next_run

_playwright/tsdm.py

@@ -8,7 +8,7 @@ from playwright.async_api import async_playwright
 
 sys.path.append(join(dirname(abspath(__file__)), "../"))
 
-from utils import push_msg
+from utils import push_msg, get_streevoice_today_song
 from __init__ import (
     browser_headless,
     browser_proxy,
@@ -51,12 +51,12 @@ async def sign(page):
         tsdm_logger.info(sign_res)
         msg.append(sign_res)
     else:
-        mind = random.choice(list(tsdm_minds.values()))
-        tsdm_logger.info(f"签到心情选择：{mind}")
-        await page.locator(
-            "#ct > div > div.bm.mtn > div.bm_c > form > select"
-        ).select_option(label=mind)
-        await page.get_by_label("不想填写").check()
+        mind = random.choice(list(tsdm_minds.keys()))
+        tsdm_logger.info(f"签到心情选择：{tsdm_minds[mind]}")
+        await page.get_by_role("combobox").select_option(mind)
+        await page.get_by_label("自己填写").check()  # 不想填写
+        song = await get_streevoice_today_song(page)
+        await page.locator("#todaysay").type(song, delay=200)
         await page.get_by_text("点我签到!").click()
         sign_res = "签到成功"
         tsdm_logger.info(sign_res)

api.py

@@ -26,17 +26,17 @@ def tick():
 def run_scheduler(loop):
     asyncio.set_event_loop(loop)
     # add task
-    sign_scheduler = AsyncIOScheduler()
-    sign_scheduler.configure(timezone=pytz.timezone("Asia/Shanghai"))
-    # sign_scheduler.add_job(tick, "cron", second="*/59")
-    sign_scheduler.add_job(bilibili_sign, "cron", hour=6, minute=1)
-    sign_scheduler.add_job(v2ex_sign, "cron", hour=6, minute=2)
-    sign_scheduler.add_job(tsdm_sign, "cron", hour="*/6", minute=3)
-    sign_scheduler.add_job(wuaipojie_sign, "cron", hour=6, minute=4)
-    sign_scheduler.add_job(vits_sign, "cron", hour="0, 12", minute=6)
-    sign_scheduler.add_job(aliyundrive_sign, "cron", hour="*/6", minute=7)
-    sign_scheduler.add_job(validate_access_token, "cron", hour="*/2")
-    sign_scheduler.start()
+    scheduler = AsyncIOScheduler()
+    scheduler.configure(timezone=pytz.timezone("Asia/Shanghai"))
+    # scheduler.add_job(tick, "cron", second="*/59")
+    scheduler.add_job(bilibili_sign, "cron", hour=6, minute=1, next_run_time=datetime.now())
+    scheduler.add_job(v2ex_sign, "cron", hour=6, minute=2, next_run_time=datetime.now())
+    scheduler.add_job(tsdm_sign, "cron", hour="*/6", minute=3, next_run_time=datetime.now())
+    scheduler.add_job(wuaipojie_sign, "cron", hour=6, minute=4, next_run_time=datetime.now())
+    scheduler.add_job(vits_sign, "cron", hour="0, 12", minute=6, next_run_time=datetime.now())
+    scheduler.add_job(aliyundrive_sign, "cron", hour="*/6", minute=7, next_run_time=datetime.now())
+    scheduler.add_job(validate_access_token, "cron", hour="*/2", next_run_time=datetime.now())
+    scheduler.start()
     try:
         asyncio.get_event_loop().run_forever()
     except (KeyboardInterrupt, SystemExit):
@@ -44,9 +44,7 @@ def run_scheduler(loop):
 
 
 def start_daemon_scheduler(loop):
-    t = threading.Thread(
-        target=run_scheduler, args=(loop,), name="schedule", daemon=True
-    )
+    t = threading.Thread(target=run_scheduler, args=(loop,), name="schedule", daemon=True)
     t.start()
 
 

utils.py

@@ -97,9 +97,7 @@ def get_pi_ip(host: str) -> str:
 
 
 # gotify 推送
-def push_msg(
-    title: str = "无标题", message: str = "无内容", img_url: str = gotify_img
-) -> dict:
+def push_msg(title: str = "无标题", message: str = "无内容", img_url: str = gotify_img) -> dict:
     gotify_ip = get_pi_ip(gotify_host)
     url = f"http://{gotify_ip}:{gotify_port}/message?token={gotify_token}"
     data = {
@@ -162,6 +160,15 @@ async def read_logfile(log_file: str) -> str:
         return data
 
 
+# 获取每日歌曲用于天使动漫签到
+async def get_streevoice_today_song(page):
+    await page.goto("https://streetvoice.com/")
+    song = await page.locator("#player-collapse h4").get_by_role("link").text_content()
+    logger.info(f"街声今日歌曲：{song}")
+    await page.go_back()
+    return song
+
+
 async def main():
     # await init_page()
     # res = await get_bilibili_live_rooms_from_pi()