import requests
import gzip
import base64
from io import BytesIO

# API 基础 URL
BASE_URL = "http://down.l2api.cn:9090"

def login(user_name, user_pwd):
    url = f"{BASE_URL}/Login"
    payload = {"userName": user_name, "userPwd": user_pwd}
    response = requests.post(url, json=payload)
    result = response.json()
    
    if result["Code"] == 200 and result["Data"]["code"] == 0:
        return response.cookies.get('__beetlex_token')
    return None

def get_data_and_save(token, data_type, stock):
    url = f"{BASE_URL}/GetData"
    headers = {'Cookie': f'__beetlex_token={token}'}
    payload = {"type": data_type, "stock": stock}
    
    res = requests.post(url, json=payload, headers=headers).json()
    if res["Code"] == 200:
        gzip_data = res["Data"]["data"]
        date_str = res["Data"]["time"]
        
        # 解码与解压引擎直送的 Gzip Base64 内存流
        compressed = base64.b64decode(gzip_data)
        with BytesIO(compressed) as bs, gzip.GzipFile(fileobj=bs, mode="rb") as gf:
            csv_text = gf.read().decode("utf-8-sig").rstrip("\r\n")
            
        file_name = f"{date_str}_{data_type}_{stock}.csv"
        with open(file_name, "w", encoding="utf-8") as f:
            f.write(csv_text)
        print(f"[*] 数据极速落盘成功: {file_name}")

if __name__ == "__main__":
    token = login("your_username", "your_password")
    if token:
        get_data_and_save(token, "Market", "000001.SZ")