AI 智能分析API

包含 API 接口文档（SSE 流式输出 / JSON 返回）与在线测试工具。

🤖 核心分析能力矩阵：

多维度个股诊股：从技术面（趋势/指标）、资金面（主力/外资动向）、基本面（财报/估值）、消息面（政策/公告）四个维度输出结构化研报。
量化策略辅助：支持辅助编写配对交易策略、Z-score 计算模型、均值回归等量化策略代码与逻辑解读。
市场情绪洞察：结合最新财经资讯、宏观政策及行业动态，解读板块轮动逻辑与市场整体情绪。
财务数据提炼：快速提取财报核心指标（如 ROE、毛利率、净利润增速），并与同行业竞品进行横向对比分析。
投资风险预警：自动识别潜在的解禁风险、业绩暴雷风险、监管函件等利空因素，提供客观的风险提示。
行业赛道对标：深挖产业链上下游关系，对比同行业龙头企业的核心竞争力与护城河差异。
买卖点辅助判断：结合 MACD、KDJ、BOLL 等常见技术指标，给出偏左侧或右侧的阻力/支撑位参考建议。
重大事件解读：快速总结美联储加息、非农数据发布、突发地缘政治等宏观事件对 A 股具体板块的传导影响。

SSE 流式输出

https://www.stockapi.com.cn/v1/ai/chat/stream

💡 适用场景说明

SSE 流式输出 适用于直接面向终端用户的 Web 或移动端页面。它可以像打字机一样实时输出 AI 的分析过程，大幅降低用户的等待焦虑感，是目前 AI 对话应用最主流的接入方式。

返回示例

data: {"type":"meta","sessionId":"chat_001"}

data: {"type":"tool_calling","tools":["news_search","financial_statement"]}

data: {"type":"content","text":"一、技术面看，股价当前"}

data: {"type":"content","text":"处于 20 日均线附近震荡，成交量"}

data: {"type":"content","text":"较前一交易周有所放大。"}

data: {"type":"done"}

多语言调用示例

当前展示流式接口代码

依赖包

浏览器环境直接可用。流式接口通过 ReadableStream 读取 SSE 内容。

浏览器原生 fetch无需额外依赖

调用示例

const payload = {
  token: '替换为你的真实Token，可在左侧菜单获取',
  sessionId: '替换为唯一ID，如 UUID',
  message: '请分析比亚迪'
}

const response = await fetch('https://www.stockapi.com.cn/v1/ai/chat/stream', {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify(payload)
})

const reader = response.body.getReader()
const decoder = new TextDecoder()
let buffer = ''

while (true) {
  const { done, value } = await reader.read()
  if (done) break
  buffer += decoder.decode(value, { stream: true })
  const lines = buffer.split('\n')
  buffer = lines.pop() || ''

  for (const line of lines) {
    if (!line.startsWith('data:')) continue
    const event = JSON.parse(line.slice(5))
    if (event.type === 'content') {
      console.log(event.text)
    }
  }
}

依赖包

推荐用 OkHttp 处理 HTTP 与流式读取，Jackson 用于 JSON 序列化。

<dependency>
  <groupId>com.squareup.okhttp3</groupId>
  <artifactId>okhttp</artifactId>
  <version>4.10.0</version>
</dependency>
<dependency>
  <groupId>com.fasterxml.jackson.core</groupId>
  <artifactId>jackson-databind</artifactId>
  <version>2.15.2</version>
</dependency>

调用示例

OkHttpClient client = new OkHttpClient();
ObjectMapper mapper = new ObjectMapper();

Map<String, Object> payload = new HashMap<>();
payload.put("token", "替换为你的真实Token，可在左侧菜单获取");
payload.put("sessionId", "替换为唯一ID，如 UUID");
payload.put("message", "请分析中际旭创");

RequestBody body = RequestBody.create(
    mapper.writeValueAsString(payload),
    MediaType.parse("application/json; charset=utf-8")
);

Request request = new Request.Builder()
    .url("https://www.stockapi.com.cn/v1/ai/chat/stream")
    .post(body)
    .build();

try (Response response = client.newCall(request).execute();
     BufferedReader reader = new BufferedReader(response.body().charStream())) {
  String line;
  while ((line = reader.readLine()) != null) {
    if (line.startsWith("data:")) {
      System.out.println(line.substring(5).trim());
    }
  }
}

依赖包

使用 requests 即可同时覆盖普通 POST 和流式迭代读取。

pip install requests

调用示例

import json
import requests

payload = {
    "token": "替换为你的真实Token，可在左侧菜单获取",
    "sessionId": "替换为唯一ID，如 UUID",
    "message": "请分析寒武纪"
}

with requests.post(
    "https://www.stockapi.com.cn/v1/ai/chat/stream",
    json=payload,
    stream=True,
    timeout=120
) as response:
    response.raise_for_status()
    for line in response.iter_lines(decode_unicode=True):
        if line and line.startswith("data:"):
            event = json.loads(line[5:].strip())
            if event.get("type") == "content":
                print(event.get("text", ""), end="")

依赖包

Node 18+ 已自带 fetch，可直接读取 Web Stream。

Node.js 18+原生 fetch，无需额外依赖

调用示例

const payload = {
  token: '替换为你的真实Token，可在左侧菜单获取',
  sessionId: '替换为唯一ID，如 UUID',
  message: '请分析工业富联'
}

const response = await fetch('https://www.stockapi.com.cn/v1/ai/chat/stream', {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify(payload)
})

const decoder = new TextDecoder()
for await (const chunk of response.body) {
  const text = decoder.decode(chunk, { stream: true })
  process.stdout.write(text)
}

依赖包

PHP 无需 Composer 额外安装；使用 curl 即可完成同步与流式读取。

// 确保 php.ini 中启用了 curl 扩展
extension=curl

调用示例

<?php
$payload = json_encode([
  "token" => "替换为你的真实Token，可在左侧菜单获取",
  "sessionId" => "替换为唯一ID，如 UUID",
  "message" => "请分析赛力斯"
]);

$ch = curl_init("https://www.stockapi.com.cn/v1/ai/chat/stream");
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_HTTPHEADER, ["Content-Type: application/json"]);
curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
curl_setopt($ch, CURLOPT_WRITEFUNCTION, function ($ch, $data) {
    echo $data;
    return strlen($data);
});
curl_exec($ch);
curl_close($ch);

依赖包

Go 原生 net/http 就能完成请求和 SSE 按行读取。

Go 标准库，无需额外依赖

调用示例

package main

import (
  "bufio"
  "bytes"
  "fmt"
  "net/http"
)

func main() {
  body := []byte(`{"token":"替换为你的真实Token，可在左侧菜单获取","sessionId":"替换为唯一ID，如 UUID","message":"请分析紫金矿业"}`)
  req, _ := http.NewRequest("POST", "https://www.stockapi.com.cn/v1/ai/chat/stream", bytes.NewBuffer(body))
  req.Header.Set("Content-Type", "application/json")

  resp, _ := http.DefaultClient.Do(req)
  defer resp.Body.Close()

  scanner := bufio.NewScanner(resp.Body)
  for scanner.Scan() {
    line := scanner.Text()
    if len(line) > 5 && line[:5] == "data:" {
      fmt.Println(line[5:])
    }
  }
}

依赖包

C 环境推荐用 libcurl；若需要 JSON 解析可自行补充 cJSON。

sudo apt-get install libcurl4-openssl-dev

调用示例

#include <curl/curl.h>
#include <stdio.h>
#include <string.h>

static size_t on_data(void *ptr, size_t size, size_t nmemb, void *userdata) {
  fwrite(ptr, size, nmemb, stdout);
  return size * nmemb;
}

int main() {
  CURL *curl = curl_easy_init();
  const char *json = "{\"token\":\"替换为你的真实Token，可在左侧菜单获取\",\"sessionId\":\"替换为唯一ID，如 UUID\",\"message\":\"请分析中国中车\"}";
  struct curl_slist *headers = NULL;
  headers = curl_slist_append(headers, "Content-Type: application/json");

  curl_easy_setopt(curl, CURLOPT_URL, "https://www.stockapi.com.cn/v1/ai/chat/stream");
  curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
  curl_easy_setopt(curl, CURLOPT_POSTFIELDS, json);
  curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, on_data);
  curl_easy_perform(curl);

  curl_slist_free_all(headers);
  curl_easy_cleanup(curl);
  return 0;
}

依赖包

使用 HttpClient 即可完成标准 JSON 请求与流式逐行读取。

// .NET 6+ 默认自带，无需额外安装
using System.Net.Http;
using System.Text.Json;

调用示例

using System;
using System.IO;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;

var client = new HttpClient();
var json = """
{"token":"替换为你的真实Token，可在左侧菜单获取","sessionId":"替换为唯一ID，如 UUID","message":"请分析中国平安"}
""";

var request = new HttpRequestMessage(HttpMethod.Post, "https://www.stockapi.com.cn/v1/ai/chat/stream")
{
    Content = new StringContent(json, Encoding.UTF8, "application/json")
};

using var response = await client.SendAsync(request, HttpCompletionOption.ResponseHeadersRead);
using var stream = await response.Content.ReadAsStreamAsync();
using var reader = new StreamReader(stream);

while (!reader.EndOfStream)
{
    var line = await reader.ReadLineAsync();
    if (!string.IsNullOrWhiteSpace(line) && line.StartsWith("data:"))
    {
        Console.WriteLine(line.Substring(5).Trim());
    }
}

依赖包

最稳妥的是 libcurl 直接读返回；如需对象化处理再加 nlohmann/json。

sudo apt-get install libcurl4-openssl-dev
# 如果需要 nlohmann/json 解析
sudo apt-get install nlohmann-json3-dev

调用示例

#include <curl/curl.h>
#include <iostream>
#include <string>

size_t writeCallback(void* contents, size_t size, size_t nmemb, void* userp) {
  std::cout << std::string((char*)contents, size * nmemb);
  return size * nmemb;
}

int main() {
  CURL* curl = curl_easy_init();
  std::string payload = R"({"token":"替换为你的真实Token，可在左侧菜单获取","sessionId":"替换为唯一ID，如 UUID","message":"请分析美的集团"})";
  struct curl_slist* headers = nullptr;
  headers = curl_slist_append(headers, "Content-Type: application/json");

  curl_easy_setopt(curl, CURLOPT_URL, "https://www.stockapi.com.cn/v1/ai/chat/stream");
  curl_easy_setopt(curl, CURLOPT_HTTPHEADER, headers);
  curl_easy_setopt(curl, CURLOPT_POSTFIELDS, payload.c_str());
  curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, writeCallback);
  curl_easy_perform(curl);

  curl_slist_free_all(headers);
  curl_easy_cleanup(curl);
  return 0;
}