博度AI-超1000万+ 知识库检索接口 KnowledgeSearch

curl -X POST "https://ailg666.top/api/v2/KnowledgeSearch" \
  -H "Authorization: Bearer sk_lg-你的Key" \
  -H "Content-Type: application/json" \
  -d '{
    "function_code": "lg01_lg_ai_QA",
    "query": "AI 如何落地到企业",
    "limit": 5
  }'

/**
 * 博度AI 知识库检索 · Java + OkHttp
 * 依赖：com.squareup.okhttp3:okhttp:4.12.0
 *      com.google.code.gson:gson:2.10.1
 */
import okhttp3.*;
import com.google.gson.*;
import java.io.IOException;

public class BoduKnowledgeSearch {
    private static final String BASE_URL = "https://ailg666.top";
    private static final String API_URL  = BASE_URL + "/api/v2/KnowledgeSearch";
    private static final String API_KEY  = "sk_lg-你的Key";

    private static final OkHttpClient CLIENT = new OkHttpClient.Builder().build();
    private static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");

    public static void main(String[] args) throws IOException {
        JsonObject payload = new JsonObject();
        payload.addProperty("function_code", "lg01_lg_ai_QA");
        payload.addProperty("query", "AI 如何落地到企业");
        payload.addProperty("limit", 5);

        Request request = new Request.Builder()
            .url(API_URL)
            .addHeader("Authorization", "Bearer " + API_KEY)
            .post(RequestBody.create(payload.toString(), JSON))
            .build();

        try (Response response = CLIENT.newCall(request).execute()) {
            String body = response.body().string();
            JsonObject resp = JsonParser.parseString(body).getAsJsonObject();
            if (resp.get("success").getAsBoolean()) {
                System.out.println("✅ 成功，返回：" + body);
            } else {
                System.out.println("⚠️ 失败：" + resp.get("message"));
            }
        }
    }
}

/** 博度AI 知识库检索 · Node.js 18+（原生 fetch） */
const BASE_URL = "https://ailg666.top";
const API_URL  = `${BASE_URL}/api/v2/KnowledgeSearch`;
const API_KEY  = "sk_lg-你的Key";

async function search(function_code, query, limit = 5) {
  const resp = await fetch(API_URL, {
    method: "POST",
    headers: {
      "Authorization": `Bearer ${API_KEY}`,
      "Content-Type":  "application/json",
    },
    body: JSON.stringify({ function_code, query, limit }),
  });
  const data = await resp.json();

  if (data.success) {
    // 真实结构：data.search_results.{coll_name} = [hits]
    for (const [coll, hits] of Object.entries(data.data.search_results)) {
      console.log(`📚 ${coll} 命中 ${hits.length} 条`);
      hits.forEach(h => console.log(`  · ${h.rerank_score.toFixed(4)} ${h.content.slice(0,80)}...`));
    }
  } else {
    console.error("❌ 失败：", data.message);
  }
}

search("lg01_lg_ai_QA", "AI 如何落地到企业");

# -*- coding: utf-8 -*-
"""博度AI 多库并发查询 · v2.1 核心新增"""
from concurrent.futures import ThreadPoolExecutor, as_completed
import requests

API_URL = "https://ailg666.top/api/v2/KnowledgeSearch"
API_KEY = "sk_lg-你的Key"
HEADERS = {"Authorization": f"Bearer {API_KEY}", "Content-Type": "application/json"}

def search_one(code, query, limit=5):
    resp = requests.post(API_URL, headers=HEADERS,
                         json={"function_code": code, "query": query, "limit": limit},
                         timeout=30).json()
    hits = []
    if resp.get("success"):
        for _coll, items in resp["data"]["search_results"].items():
            hits.extend(items)
    return code, hits

def search_multi(codes, query, limit=5):
    """一次并发查多个库，返回扁平化合并结果（带 from 标注）"""
    codes = list(dict.fromkeys(codes))[:6]    # 去重，最多 6 个
    merged = []
    with ThreadPoolExecutor(max_workers=len(codes)) as ex:
        futures = {ex.submit(search_one, c, query, limit): c for c in codes}
        for fut in as_completed(futures):
            code, hits = fut.result()
            for h in hits:
                merged.append({"from": code, "content": h})
    # 按 rerank_score 倒序
    merged.sort(key=lambda x: x["content"].get("rerank_score", 0), reverse=True)
    return merged

# 用法：AI 落地三库联查
if __name__ == "__main__":
    hits = search_multi(
        codes=["lg01_lg_ai_QA",
               "lg25_liuge_ip_thinking_style_doing_methodology",
               "lg11_company_team_management_strategy_growth"],
        query="企业怎么落地 AI",
        limit=3,
    )
    for h in hits[:10]:
        print(f"[{h['from']}] {h['content']['rerank_score']:.4f}")
        print(f"  {h['content']['content'][:100]}...")