ww

apis/newbot.py

@@ -5,7 +5,7 @@ import linebot
 import linebot.models as linebotModels
 import suggests
 from GoogleNews import GoogleNews
-
+import dataset
 #
 
 from linebot.models import (
@@ -59,6 +59,20 @@ handler = WebhookHandler('5b05fed81cd9f6f1e75dbf7dda388479')
 #line_bot_api = LineBotApi('YOUR_CHANNEL_ACCESS_TOKEN')
 #handler = WebhookHandler('YOUR_CHANNEL_SECRET')
 
+def get_aws():
+    result=''
+    db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/hhh?charset=utf8mb4')
+    cursor=db.query('SELECT from_unixtime(eventtime) as dt,area FROM hhh.aws_monitor order by eventtime desc limit 3;')
+    for c in cursor:
+        result+=c['dt']+"/"+c['area']+","
+    return result
+
+@app.get("/msg/{item_id}")
+async def coffee_msg(item_id):
+    True
+    line_bot_api.push_message(item_id, TextSendMessage(text='開啟下方完整券樣（密碼9888）至櫃台掃碼兌換。https://txp.rs/v/EvX69b4Xq9'))
+    return {"code":"ok" }
+
 
 @app.post('/callback')
 async def callback(request: fastapi.Request):
@@ -87,6 +101,11 @@ def get_news_by_kw(keyword):
 #        print(r['link'])
 #        print(r['datetime'])
 
+@handler.add(FollowEvent)
+def handle_follow(event):
+    print(event.source.user_id)
+    
+    # do something
 
 @handler.add(linebotModels.MessageEvent, message=linebotModels.TextMessage)
 def message_text(event):
@@ -98,12 +117,22 @@ def message_text(event):
 # #                   TextSendMessage(text='PUSH!'),
 #                ]
 #            )
+
     if event.message.text == 's_news':
         s_news=True
         line_bot_api.reply_message(
             event.reply_token,
             TextSendMessage(text='請輸入要搜尋新聞的關鍵字:'))
         return
+
+    if event.message.text == 's_aws':
+        s_news=True
+        line_bot_api.reply_message(
+            event.reply_token,
+            TextSendMessage(text=get_aws()))
+        return
+
+
     if event.message.text == 'seo':
         seo=True
         return
@@ -115,7 +144,7 @@ def message_text(event):
     if event.message.text=='ok':
         line_bot_api.reply_message(
             event.reply_token,
-            TextSendMessage(text='ChoozMo 的FastAPI LINE Bot'))
+            TextSendMessage(text='最欣賞ChoozMo團隊說OK的人!!'))
     if event.message.text=='c' or event.message.text=='C' :
         line_bot_api.reply_message(
                     event.reply_token,
@@ -127,7 +156,7 @@ def message_text(event):
                                     action=MessageAction(label="按我測試", text="text2")
                                 ),
                                 QuickReplyButton(
-                                    action=MessageAction(label="查新聞", text="s_news")
+                                    action=MessageAction(label="查AWS", text="q_aws")
                                 ),
 
                             ])))