QFS Finance API

import requests
import json

class AKShareAPI:
    def __init__(self, token):
        self.token = token
        self.base_url = "https://qf.hory-ai.com.com/api"

    def query(self, api_name, params=None):
        data = {
            "api_name": api_name,
            "token": self.token,
            "params": params or {}
        }
        response = requests.post(self.base_url, json=data)
        result = response.json()
        if result["code"] == 0:
            return result["data"]
        else:
            raise Exception(f"API Error: {result['msg']}")

# 使用示例
api = AKShareAPI("your_token_here")
data = api.query("stock_zh_a_spot_em")
print(f"获取到 {len(data['items'])} 条股票数据")

class AKShareAPI {
    constructor(token) {
        this.token = token;
        this.baseUrl = 'https://qf.hory-ai.com.com/api';
    }

    async query(apiName, params = {}) {
        const response = await fetch(this.baseUrl, {
            method: 'POST',
            headers: {
                'Content-Type': 'application/json'
            },
            body: JSON.stringify({
                api_name: apiName,
                token: this.token,
                params
            })
        });

        const result = await response.json();
        if (result.code === 0) {
            return result.data;
        } else {
            throw new Error(`API Error: ${result.msg}`);
        }
    }
}

// 使用示例
const api = new AKShareAPI('your_token_here');
api.query('stock_zh_a_spot_em')
    .then(data => console.log(`获取到 ${data.items.length} 条股票数据`));

package main

import (
    "bytes"
    "encoding/json"
    "fmt"
    "net/http"
)

type AKShareAPI struct {
    Token   string
    BaseURL string
}

type APIRequest struct {
    APIName string                 `json:"api_name"`
    Token   string                 `json:"token"`
    Params  map[string]interface{} `json:"params"`
}

func NewAKShareAPI(token string) *AKShareAPI {
    return &AKShareAPI{
        Token:   token,
        BaseURL: "https://qf.hory-ai.com.com/api",
    }
}

func (api *AKShareAPI) Query(apiName string, params map[string]interface{}) (map[string]interface{}, error) {
    reqData := APIRequest{
        APIName: apiName,
        Token:   api.Token,
        Params:  params,
    }

    jsonData, _ := json.Marshal(reqData)
    resp, err := http.Post(api.BaseURL, "application/json", bytes.NewBuffer(jsonData))
    if err != nil {
        return nil, err
    }
    defer resp.Body.Close()

    var result map[string]interface{}
    json.NewDecoder(resp.Body).Decode(&result)
    return result, nil
}

// 使用示例
func main() {
    api := NewAKShareAPI("your_token_here")
    result, _ := api.Query("stock_zh_a_spot_em", map[string]interface{}{})
    fmt.Printf("获取到数据: %+v\n", result)
}