send

app.py

@@ -1,5 +1,5 @@
 from typing import Union
-from fastapi import FastAPI, Header,BackgroundTasks
+from fastapi import FastAPI, Header, BackgroundTasks
 from urllib.parse import unquote
 from flashSMS import sendFlash
 from tgMesaage import sendTg
@@ -55,7 +55,7 @@ def findPhoneNum(text):
         return None
 
 
-def resData(inputArguments,uid):
+def resData(inputArguments, uid):
     print("inputArguments", inputArguments)
     # uid:唯一标识用户的openid
     # print("appid", appid, "bid", bid, "requestid", requestid, "uid", uid)
@@ -83,6 +83,22 @@ def resData(inputArguments,uid):
         print(f"用户输入:{inputArguments},手机号不正确,或者uid参数异常")
         # sendTg(f"用户输入:{inputArguments},手机号不正确,或者uid参数异常")
 
+def urlSend(num):
+    try:
+        inputArguments = unquote(num, "utf-8")
+    except:
+        inputArguments = ""
+    # 正则获取11位手机号
+    phonenumber = findPhoneNum(inputArguments)
+    print("phonenumber", phonenumber)
+    # # phonenumber='13243889782'
+    if phonenumber is not None:
+        warntext = "[异度世界],微信加群验证码:3399"
+        sendFlash(phonenumber, warntext)
+    else:
+        print(f"用户输入:{inputArguments},手机号不正确")
+        # sendTg(f"用户输入:{inputArguments},手机号不正确,或者uid参数异常")
+
 
 @app.get("/")
 # def read_root():
@@ -97,17 +113,32 @@ def read_items(
     return {"appid": appid, "bid": bid, "requestid": requestid, "uid": uid}
 
 
+@app.get("/send")
+# def read_root():
+# return {"Hello": "World"}
+def read_items(
+    background_tasks: BackgroundTasks,
+    num: Union[str, None] = None,
+):
+    print("num", num)
+    background_tasks.add_task(urlSend,num)
+    content = {"err_code": 0, "data_list": [{"outputArguments": "test"}]}
+    headers = {"Content-Type": "application/json"}
+    return JSONResponse(content=content, headers=headers)
+
+
 # 微信对话-用户输入
-@app.get("/input",)
+@app.get(
+    "/input",
+)
 async def getphonenum(
     background_tasks: BackgroundTasks,
     inputArguments: Union[str, None] = None,
     appid: Union[str, None] = Header(default=None),
     bid: Union[str, None] = Header(default=None),
     requestid: Union[str, None] = Header(default=None),
-    uid: Union[str, None] = Header(default=None)
+    uid: Union[str, None] = Header(default=None),
 ):
-
     # err_code=0
     # outputArguments=''
     # print("inputArguments", inputArguments)
@@ -153,6 +184,6 @@ async def getphonenum(
     # content = {"err_code": err_code,"data_list": [{"outputArguments":outputArguments}]}
 
     # background_tasks.add_task(resData,inputArguments,uid)
-    content = {"err_code": 0,"data_list": [{"outputArguments":"test"}]}
+    content = {"err_code": 0, "data_list": [{"outputArguments": "test"}]}
     headers = {"Content-Type": "application/json"}
     return JSONResponse(content=content, headers=headers)