Delete pictures_handle.cpython-311.pyc

.gitignore

@@ -2,4 +2,6 @@
 .DS_Store
  __pycache__
  venv
-__pycache__/main.cpython-311.pyc
+__pycache__/
+pictures/
+*/__pycache__/

huaweitest.py

@@ -0,0 +1,145 @@
+from fastapi import FastAPI, Query, Request, HTTPException
+from datetime import datetime
+import random
+
+app = FastAPI()
+
+
+@app.get("/")
+async def root(request: Request):
+    # 获取当前时间
+    now = datetime.now()
+
+    # 格式化时间为 年-月-日 时:分:秒 的格式
+    formatted_now = now.strftime("%Y-%m-%d %H:%M:%S")
+    print(f"请求IP地址: {request.client.host},请求时间{formatted_now},请求路径: /")
+    return "welcome to fastAPI!"
+
+
+def random_bool():
+    return "true" if random.random() > 0.5 else "false"
+
+
+@app.get("/script/getscriparam")
+async def getscriparam(request: Request):
+    # 获取当前时间
+    now = datetime.now()
+    # 格式化时间为 年-月-日 时:分:秒 的格式
+    formatted_now = now.strftime("%Y-%m-%d %H:%M:%S")
+    print(f"请求IP地址: {request.client.host},请求时间{formatted_now},请求路径: /script/getscriparam")
+    language_list = ["English (United States)", "Spanish (Mexico)", "English (United Kingdom)", "English (Australia)"]
+    data = {
+        "interaction": {"from": 20, "to": 30},
+        "bounceRate": {"from": 0.3, "to": 0.4},
+        "pagesToViewPerSession": {"from": 2, "to": 3},
+        "sessionsPerUser": {"from": 2, "to": 3},
+        "ctr": {"from": 0.03, "to": 0.05},
+        "shouldDoClick": "true",
+        "shouldExecute": "true",
+        "shouldBounce": "false",
+        "languageFullName": random.choice(language_list),
+    }
+
+    return data
+
+
+@app.get("/script/success")
+async def do_success(request: Request):
+    # 获取当前时间
+    current_time = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+
+    # 获取请求者的IP地址
+    client_host = request.client.host
+
+    # 打印上报成功的时间和IP地址
+    # print(f"请求IP地址: {client_host},上报成功时间: {current_time}")
+    print(f"请求IP地址: {client_host},请求时间{current_time},请求路径: /script/success")
+
+    data = {}
+    return {
+        "code": 0,
+        "msg": "ok",
+        "data": data
+    }
+
+
+@app.get("/script/failed")
+async def do_failed(request: Request, reason: str = None, errortype: str = None):
+    # 获取当前时间
+    now = datetime.now()
+
+    # 格式化时间为 年-月-日 时:分:秒 的格式
+    formatted_now = now.strftime("%Y-%m-%d %H:%M:%S")
+    print(f"请求IP地址: {request.client.host},请求时间{formatted_now},请求路径: /script/failed")
+    # 假设这里记录失败原因到日志或数据库
+    print(f"上报失败,Time: {formatted_now}, 失败原因: {reason},失败类型: {errortype}.")  # 实际应用中应使用更专业的日志记录方式
+    return {
+        "code": 0,
+        "msg": "ok",
+        "data": {}
+    }
+
+
+@app.get("/report/chrome/crash")
+async def report_chrome_crash(id: str, timestamp: str = Query(None)):
+    # 获取当前时间
+    now = datetime.now()
+
+    # 格式化时间为 年-月-日 时:分:秒 的格式
+    formatted_now = now.strftime("%Y-%m-%d %H:%M:%S")
+
+    # 假设这里记录失败原因到日志或数据库
+    print(f"Time: {formatted_now}, ID: {id}, 时间戳: {timestamp}")  # 实际应用中应使用更专业的日志记录方式
+    return {
+        "code": 0,
+        "msg": "ok",
+        "data": {}
+    }
+
+
+@app.get("/script/uploaddata")
+async def upload_ads_status(impressions: str, clicks: str):
+    # 获取当前时间
+    now = datetime.now()
+
+    # 格式化时间为 年-月-日 时:分:秒 的格式
+    formatted_now = now.strftime("%Y-%m-%d %H:%M:%S")
+
+    # 假设这里记录失败原因到日志或数据库
+    print(f"Time: {formatted_now}, impressions: {impressions}, clicks: {clicks}")  # 实际应用中应使用更专业的日志记录方式
+    return {
+        "code": 0,
+        "msg": "ok",
+        "data": {}
+    }
+
+
+@app.post("/api/account/")
+async def get_account(request: Request):
+    server_token = "cT&Ur7AciCgL6P$2u!^mauI05r6jcD$A"
+    accounts = [
+        {"account": "reedavice8@gmail.com", "password": "L906lTeTlpelaq",
+         "auxiliary_mailbox": "tcmuffin56@mailexpire.com"},
+        {"account": "annist95g@gmail.com", "password": "28CUxUmygURereJ",
+         "auxiliary_mailbox": "b1youngster983@yahoo.ie"},
+        {"account": "vr8607864@gmail.com", "password": "J945YgaX", "auxiliary_mailbox": "sbqunmetal3@xtra.co.nz"},
+        {"account": "ShimoGuagliardo537@gmail.com", "password": "94Ss9YYx3",
+         "auxiliary_mailbox": "spigelmyerhalalikyzd185@yawua.us"},
+    ]
+
+    # 从请求头中获取token
+    token = request.headers.get('Authorization')
+    # 获取当前时间
+    now = datetime.now()
+    # 格式化时间
+    formatted_now = now.strftime("%Y-%m-%d %H:%M:%S")
+    print(f"请求IP地址: {request.client.host}, 请求时间: {formatted_now}, 请求token: {token}, 请求路径: /api/account/")
+
+    # 检查token是否存在且匹配
+    if not token or token != server_token:
+        # 如果token不正确，返回401未授权状态
+        raise HTTPException(status_code=401, detail="Unauthorized")
+
+    # 随机选择一个账户信息返回
+    selected_account = random.choice(accounts)
+    return selected_account

main.py

@@ -1,6 +1,5 @@
 from fastapi import FastAPI, HTTPException, Request
 from fastapi.responses import FileResponse
-import base64
 import os
 
 app = FastAPI()
@@ -18,7 +17,6 @@ async def login(request: Request):
     username = data.get("username")
     password = data.get("password")
     print(f"username: {username},password: {password}")
-    # Replace with your actual validation logic
     if username == "1" and password == "1":
         data1 = None
         return {"code": "0", "msg": "ok", "data": data1}
@@ -129,3 +127,5 @@ async def get_policy_list():
         "msg": "ok",
         "data": policy_list
     }
+
+

requirements.txt

@@ -14,6 +14,5 @@ sniffio==1.3.0
 starlette==0.32.0.post1
 typing_extensions==4.9.0
 uvicorn==0.25.0
-uvloop==0.19.0
 watchfiles==0.21.0
 websockets==12.0

test_main.http

@@ -1,11 +0,0 @@
-# Test your FastAPI endpoints
-
-GET http://127.0.0.1:8000/
-Accept: application/json
-
-###
-
-GET http://127.0.0.1:8000/hello/User
-Accept: application/json
-
-###

utils/pictures_handle.py

@@ -0,0 +1,34 @@
+import os
+
+
+def get_pictures_info(directory, page, page_size):
+    pictures = []
+    start_index = (page - 1) * page_size
+    end_index = start_index + page_size
+    counter = 0
+
+    for filename in os.listdir(directory):
+        if filename.lower().endswith(('.png', '.jpg', '.jpeg', '.gif', '.bmp')):
+            if start_index <= counter < end_index:
+                file_path = os.path.join(directory, filename)
+                size = os.path.getsize(file_path)
+                size_mb = size / (1024 * 1024)
+                picture_info = {
+                    "id": counter + 1,
+                    "photo_name": filename,
+                    "photo_size": round(size_mb, 2),
+                    "photo_url": file_path
+                }
+                pictures.append(picture_info)
+            counter += 1
+            if counter >= end_index:
+                break
+    return pictures
+
+
+def get_total_pages(directory, page_size):
+    total_photos = 0
+    for filename in os.listdir(directory):
+        if filename.lower().endswith(('.png', '.jpg', '.jpeg', '.gif', '.bmp')):
+            total_photos += 1
+    return (total_photos + page_size - 1) // page_size

website.py

@@ -0,0 +1,72 @@
+import os
+
+from fastapi import FastAPI, Request
+from fastapi.middleware.cors import CORSMiddleware
+from fastapi.responses import FileResponse
+from fastapi.staticfiles import StaticFiles
+
+from utils.pictures_handle import get_pictures_info
+from utils.pictures_handle import get_total_pages
+
+app = FastAPI()
+
+app.mount("/static", StaticFiles(directory="assets/images/pictures/"), name="static")
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["http://localhost:5173"],  # 允许的源列表
+    allow_credentials=True,
+    allow_methods=["*"],  # 允许的方法
+    allow_headers=["*"],  # 允许的头
+)
+
+
+@app.get("/")
+async def root():
+    return "welcome to fastAPI!"
+
+
+@app.get("/api/get-menu")
+async def get_menu():
+    menu_list = [
+        {"id": 1, "menu_name": "首页", "url": "/", "src": "/index.svg"},
+        {"id": 2, "menu_name": "图片", "url": "/photos", "src": "/photo.svg"},
+        {"id": 3, "menu_name": "视频", "url": "/videos", "src": "/videos.svg"},
+        {"id": 4, "menu_name": "关于", "url": "/about", "src": "/about.svg"}
+    ]
+    return {
+        "code": 0,
+        "msg": "ok",
+        "data": menu_list
+    }
+
+
+@app.get("/api/get-photo-list")
+async def get_photo_list(page: int = 1, page_size: int = 10):
+    dir_path = "assets/images/pictures"
+    total_pages = get_total_pages(dir_path, page_size)
+    photo_list = get_pictures_info(dir_path, page, page_size)
+    for photo in photo_list:
+        photo["photo_url"] = f"http://127.0.0.1:8000/static/{photo['photo_name']}"
+    return {
+        "code": 0,
+        "msg": "ok",
+        "data": photo_list,
+        "page_count": total_pages
+    }
+
+
+@app.get("/static/{photo_name}")
+async def get_photo(photo_name: str,request: Request):
+    request_path = str(request.url)
+    dir = "/assets/images/pictures"
+    file_path = os.path.join(dir, photo_name)
+    print(file_path)
+    if os.path.exists(file_path):
+        return FileResponse(file_path)
+    else:
+        print(f"ERROR: {request_path}")
+        return {
+            "code": -1,
+            "msg": "error",
+            "data": None
+        }