Update dmsender.py

dmsender.py

@@ -4,6 +4,7 @@ import os
 
 BASE_URL = "https://desk-api.channel.io/desk/channels/200605"
 TARGET_FORWARD_CHAT_ID = "463667"
+SKIP_PERSON_ID = 604730
 
 HEADERS = {
     "Content-Type": "application/json",
@@ -61,6 +62,12 @@ def get_messages(chat_id):
     return r.json()
 
 
+def mark_messages_read(chat_id):
+    url = f"{BASE_URL}/direct-chats/{chat_id}/messages/read"
+    r = requests.put(url, headers=HEADERS)
+    r.raise_for_status()
+
+
 def find_latest_message(messages):
     """
     messages 配列の中から updatedAt が最大の message を返す
@@ -76,31 +83,43 @@ def main_loop():
 
             for session in sessions:
                 unread = session.get("unread", 0)
-                if unread >= 1:
-                    chat_id = session.get("chatId")
-                    if not chat_id:
-                        continue
-
-                    # ① unread があるチャットに「送信しました」を送信
-                    post_message(chat_id, SEND_BODY_TEMPLATE)
-
-                    # ② そのチャットの messages を取得
-                    msg_data = get_messages(chat_id)
-                    messages = msg_data.get("messages", [])
-                    if not messages:
-                        continue
-
-                    # ③ updatedAt が最大の message を取得
-                    latest = find_latest_message(messages)
-                    blocks = latest.get("blocks")
-                    files = latest.get("files")
-
-                    # ④ 固定チャットID(463667)へ転送
-                    forward_body = FORWARD_BODY_TEMPLATE.copy()
-                    forward_body["blocks"] = blocks
-                    forward_body["files"] = files if files else None
-
-                    post_message(TARGET_FORWARD_CHAT_ID, forward_body)
+                if unread < 1:
+                    continue
+
+                chat_id = session.get("chatId")
+                if not chat_id:
+                    continue
+
+                # messages を取得
+                msg_data = get_messages(chat_id)
+                messages = msg_data.get("messages", [])
+                if not messages:
+                    continue
+
+                # 最新メッセージ取得
+                latest = find_latest_message(messages)
+
+                # personId が 604730 の場合はスキップ
+                person_id = latest.get("personId")
+                if person_id == SKIP_PERSON_ID:
+                    mark_messages_read(chat_id)
+                    continue
+
+                # ① unread があるチャットに「送信しました」を送信
+                post_message(chat_id, SEND_BODY_TEMPLATE)
+
+                blocks = latest.get("blocks")
+                files = latest.get("files")
+
+                # ② 固定チャットIDへ転送
+                forward_body = FORWARD_BODY_TEMPLATE.copy()
+                forward_body["blocks"] = blocks
+                forward_body["files"] = files if files else None
+
+                post_message(TARGET_FORWARD_CHAT_ID, forward_body)
+
+                # ③ 元チャットを既読にする
+                mark_messages_read(chat_id)
 
         except Exception as e:
             print("Error:", e)