Update join.py

join.py

@@ -155,33 +155,36 @@ def process():
     )
 
     join_targets = []
-
+    
     for m in messages:
         log = m.get("log") or {}
         if log.get("action") != "join":
             continue
-
+    
         created_at = int(m.get("createdAt", 0))
         person_id = str(m.get("personId", ""))
-
+    
+        # ===== ここを追加 =====
+        # CHECK_PERSON_ID の最新発言より前なら無視
+        if created_at <= latest_check_person:
+            continue
+    
         # ===== ブラックリスト判定（accountIdベース）=====
         try:
             account_id = get_manager_account_id(person_id)
         except Exception as e:
             print(f"[ERROR] manager取得失敗 personId={person_id} : {e}")
             continue
-
+    
         if account_id and account_id in BLACKLIST_ACCOUNT_IDS:
             try:
                 blacklist_manager(person_id)
             except Exception as e:
                 print(f"[ERROR] 削除失敗 personId={person_id} : {e}")
             continue
-
+    
         # ===== 通常処理 =====
-        if created_at > latest_check_person:
-            join_targets.append(person_id)
-
+        join_targets.append(person_id)
     if not join_targets:
         return