update

live_status_ntf.py

@@ -12,8 +12,8 @@ path = "logs"
 room_id_re = re.compile(rf"{path}/(\d+).jsonl$")
 
 notify_qq_group = {
-    "12571885": ["831867573", "138981147"],
-    "147482": ["175545447"],
+    "12571885": lambda msg: notify_group(msg, ["831867573", "138981147"]),
+    "147482": lambda msg: notify_group(msg, ["175545447"]),
     "20571": ["891117762"],
 }
 
@@ -41,6 +41,28 @@ class Room:
 _rooms: dict[str, Room] = {}
 
 
+def notify_group(room: Room, groups: list[str]):
+    msg = "\n".join([
+        f"{room.db_room.liver_name} 下锅了！",
+        f"https://live.bilibili.com/{room.room_id}"
+    ])
+    for qq_group_id in groups:
+        seng_qq_group_msg(qq_group_id, msg)
+
+
+def notify_group_and_mc(room: Room, groups: list[str]):
+    msg = "\n".join([
+        f"{room.db_room.liver_name} 开锅了！",
+        f"https://live.bilibili.com/{room.room_id}"
+    ])
+    try:
+        requests.post("http://mc1:5000/msg", json={"msg": msg})
+    except BaseException as e:
+        print(f"notify mc error: {e}")
+    for qq_group_id in groups:
+        seng_qq_group_msg(qq_group_id, msg)
+
+
 def get_room(src_path):
     room_id = room_id_re.findall(src_path)[0]
     room = _rooms.get(room_id, None)
@@ -149,8 +171,7 @@ class MyHandler(FileSystemEventHandler):
             ])
             requests.post("http://turntf:18846/notify", json={"msg": msg})
 
-            for notify_group in notify_qq_group.get(room.room_id, []):
-                seng_qq_group_msg(notify_group, msg)
+            notify_qq_group.get(room.room_id, lambda msg: None)(room)
 
 
 def seng_qq_group_msg(group_id: str, msg: str):