Update app.py

app.py

@@ -1,67 +1,185 @@
 import os
-import json
 import time
+from datetime import datetime
+import json
 import requests
-from datetime import datetime, timedelta
+import traceback
+import random
+
+
+
+def log(msg,type):
+    if type == 1:#通常ログ
+        time_datetime= datetime.now() 
+        print(f"{time_datetime}[log]:{msg}")
+    elif type == 2: #警告
+        time_datetime= datetime.now() 
+        print(f"{time_datetime}[warn]:{msg}")
+    elif type == 3: #エラー
+        time_datetime= datetime.now() 
+        print(f"{time_datetime}[error]:{msg}")
+        traceback.print_exc()
+
+
+def System_up(time):
+    START_TIME = time
+    while START_TIME > 0:
+        log(f"起動まで、{START_TIME}秒",1)
+        START_TIME = START_TIME - 1
+        time.sleep(1)
+
 
-# ===== 設定 =====
-CHANNEL_ID = "200605"   # チャンネルID
-GROUP_ID = "534997"     # グループID
 
-MESSAGES_URL = (
-    f"https://desk-api.channel.io/desk/channels/"
-    f"{CHANNEL_ID}/groups/{GROUP_ID}/messages"
-)
+System_up(3)
 
-X_ACCOUNT = os.getenv("CHANNEL_IO_TOKEN")
+
+log("起動しました。",1)
+
+
+# ===== Channel.io 設定 =====
+CHANNEL_ID = os.getenv("CHIO_CH_ID")#"200605" チャンネル
+if not CHANNEL_ID:
+    raise RuntimeError("環境変数 CHIO_CH_ID が設定されていません")
+
+GROUP_ID = os.getenv("CHIO_GR_ID")#"534868" グループ
+if not GROUP_ID:
+    raise RuntimeError("環境変数 CHIO_GR_ID が設定されていません")
+
+MESSAGES_URL = f"https://desk-api.channel.io/desk/channels/{CHANNEL_ID}/groups/{GROUP_ID}/messages"
+
+X_ACCOUNT = os.getenv("CHIO_TOKEN") #トークン
 if not X_ACCOUNT:
-    raise RuntimeError("環境変数 CHANNEL_IO_TOKEN が設定されていません")
+    raise RuntimeError("環境変数 CHIO_TOKEN が設定されていません")
 
 HEADERS = {
     "accept": "application/json",
+    "accept-language": "ja",
     "content-type": "application/json",
     "x-account": X_ACCOUNT,
 }
 
-# ===== メッセージ送信関数 =====
-def send_message(text: str):
+PARAMS = {
+    "sortOrder": "desc",
+    "limit": 50,
+}
+
+# ===== Utils =====
+
+def ramdom_msg():
+    date = [
+        {"no":0,"by":"name","text":"message","call":"addres"},#0
+        {"no":1,"by":"name","text":"message","call":"addres"},#0
+        {"no":2,"by":"name","text":"message","call":"addres"},#0
+
+    ]
+    rand = random.randint(0, 1)#ランダム最大値指定。
+    if rand == 0:
+        ramdom_msg()#再起
+        log("辞書の0が指定されたから無視",1)
+    elif rand == 1:
+        try:
+            text = date[1]["text"]
+            by = date[1]["by"]
+            call = date[1]["call"]
+            send_to_channel(f"広告:{text}")
+            send_to_channel(f"{by}様より。call:{call}")
+        except Exception as e:
+            log(f"広告{rand}番エラー:{e}",3)
+    elif rand == 2:
+        try:
+            text = date[2]["text"]
+            by = date[2]["by"]
+            call = date[2]["call"]
+            send_to_channel(f"広告:{text}")
+            send_to_channel(f"{by}様より。call:{call}")
+        except Exception as e:
+            log(f"広告{rand}番エラー:{e}",3)
+   
+
+
+
+
+def get_messages():
+    try:
+        res = requests.get(
+                MESSAGES_URL,
+                headers=HEADERS,
+                params=PARAMS,
+                timeout=30,
+            )
+        res.raise_for_status()
+        return res.json().get("messages", [])
+    
+    except Exception as e:
+        log(f"MSG取得関数に失敗:{e}",3)
+
+def send_to_channel(text):
     try:
         payload = {
             "requestId": f"desk-web-{int(time.time() * 1000)}",
             "blocks": [
                 {
-                    "type": "text",
+                    "type": "text", 
                     "value": text
                 }
-            ]
+            ],
         }
     
         res = requests.post(
             MESSAGES_URL,
             headers=HEADERS,
             data=json.dumps(payload),
-            timeout=30
+            timeout=30,
         )
         res.raise_for_status()
-        print("送信成功")
+        
+    except Exception as e:
+        log(f"MSG送信関数に失敗:{e}",1)
+
+#def send_to_channel_file(file_url):
+#   try:
+#        #get_request送る->https://files.electrohaxz.host/にupする->リンクをfile_urlに入れて送る。
+#        payload = {
+#            "requestId": f"desk-web-{int(time.time() * 1000)}",
+#            "blocks": [
+#                {
+#                    "type": "text", 
+#                    "value": file_url
+#                }
+#            ],
+#        }
+#    
+#        res = requests.post(
+#            MESSAGES_URL,
+#            headers=HEADERS,
+#            data=json.dumps(payload),
+#            timeout=30,
+#        )
+#        res.raise_for_status()
+#        
+#   except Exception as e:
+#        log(f"ファイルアップロード関数に失敗:{e}",1)
+# ===== Main Loop =====
 
-    except requests.RequestException as e:
-        print(f"通信エラー: {e}")
+log("BOTのメインループを開始します。",1)
+def main():
+    while True:
+        try:
+            NEXT_SEND = 180     
+            while NEXT_SEND > 0:
+                log(f"次回まであと、{NEXT_SEND}秒",1)
+                NEXT_SEND = NEXT_SEND - 1
+                time.sleep(1)
+            send_to_channel(f"浮上。つまり、私がｷﾀ━━━━(ﾟ∀ﾟ)━━━━!!。")
+            time_datetime= datetime.now()
+            send_to_channel(f"現在時刻は多分+UTCで{time_datetime}です!")
+            time.sleep(1)
+            ramdom_msg()
+            send_to_channel(f"\(^^)/眠くなったからおやすみ。また時報&宣伝します。\(^^)/")
         
-def wait_until_next_minute():
-    now = datetime.now()
-    next_minute = (now + timedelta(minutes=1)).replace(second=0, microsecond=0)
-    time.sleep((next_minute - now).total_seconds())
+        except Exception as e:
+            log(f"メインループ:{e}",3)
+
 
-# ===== 実行 =====
 if __name__ == "__main__":
-    #time_datetime= datetime.now()
-    #print(f"okay!{time_datetime}") 
-    #send_message(f"起動なう: {time_datetime}")
-    #send_message(f"botですが何か？")
-    wait_until_next_minute()
-    while True:
-        time_datetime= datetime.now()
-        send_message(f"now:{time_datetime}")
-        print(f"送信しました:{time_datetime}")
-        wait_until_next_minute()
+    main()