feat: 渠道智力检测、题库管理与图片判分

apps/desktop/src-tauri/src/lib.rs

@@ -879,6 +879,19 @@ async fn delete_service(
     manager.delete_service(&service_id, &etag).await
 }
 
+#[tauri::command]
+async fn intelligence(
+    operation: String,
+    service_id: Option<String>,
+    run_id: Option<String>,
+    input: Option<serde_json::Value>,
+    manager: State<'_, Arc<CoreManager>>,
+) -> Result<serde_json::Value, String> {
+    manager
+        .intelligence(&operation, service_id.as_deref(), run_id.as_deref(), input)
+        .await
+}
+
 #[tauri::command]
 async fn pricing(
     operation: String,
@@ -1442,6 +1455,7 @@ pub fn run() {
             delete_service,
             get_service_usage,
             pricing,
+            intelligence,
             reset_service_usage,
             test_service,
             probe_service_models,

apps/desktop/src-tauri/src/sidecar.rs

@@ -1659,6 +1659,46 @@ impl CoreManager {
         Ok(())
     }
 
+    pub async fn intelligence(
+        &self,
+        operation: &str,
+        service_id: Option<&str>,
+        run_id: Option<&str>,
+        input: Option<serde_json::Value>,
+    ) -> Result<serde_json::Value, String> {
+        let base = "/control/v1/intelligence";
+        let (method, path) = match operation {
+            "settings" => (Method::GET, format!("{base}/settings")),
+            "save_settings" => (Method::PUT, format!("{base}/settings")),
+            "channel" | "save_channel" | "history" | "start" => {
+                let id = service_id.ok_or("service ID is required")?;
+                validate_resource_id(id)?;
+                let path = format!("{base}/channels/{id}");
+                match operation {
+                    "channel" => (Method::GET, path),
+                    "save_channel" => (Method::PUT, path),
+                    "history" => (Method::GET, format!("{path}/runs")),
+                    _ => (Method::POST, format!("{path}/runs")),
+                }
+            }
+            "run" | "render" | "cancel" => {
+                let id = run_id.ok_or("run ID is required")?;
+                validate_intelligence_run_id(id)?;
+                let path = format!("{base}/runs/{id}");
+                if operation == "run" {
+                    (Method::GET, path)
+                } else {
+                    (Method::POST, format!("{path}/{operation}"))
+                }
+            }
+            _ => return Err("unsupported intelligence operation".into()),
+        };
+        let (_, body) = self
+            .authenticated_control(method, &path, input, None)
+            .await?;
+        serde_json::from_slice(&body).map_err(|_| "intelligence returned invalid JSON".into())
+    }
+
     pub async fn pricing(
         &self,
         operation: &str,
@@ -4329,6 +4369,32 @@ fn validate_exact_object_keys(
     Ok(())
 }
 
+fn validate_intelligence_run_id(value: &str) -> Result<(), String> {
+    if value.len() == 32 && value.bytes().all(|b| b.is_ascii_hexdigit()) {
+        Ok(())
+    } else {
+        Err("intelligence run ID is invalid".into())
+    }
+}
+
+#[cfg(test)]
+mod intelligence_id_tests {
+    use super::validate_intelligence_run_id;
+    #[test]
+    fn accepts_generated_numeric_run_ids_but_rejects_path_injection() {
+        assert!(validate_intelligence_run_id("12c54b9cbf126f6ced65663760326f6a").is_ok());
+        assert!(validate_intelligence_run_id("a2c54b9cbf126f6ced65663760326f6a").is_ok());
+        for invalid in [
+            "../settings",
+            "12c54b9cbf126f6ced65663760326f6a/render",
+            "",
+            "zzzzzzzzzzzzzzzzzzzzzzzzzzzzzzzz",
+        ] {
+            assert!(validate_intelligence_run_id(invalid).is_err());
+        }
+    }
+}
+
 fn validate_resource_id(value: &str) -> Result<(), String> {
     if !(3..=96).contains(&value.len())
         || !value.bytes().enumerate().all(|(index, byte)| match byte {

apps/desktop/src/App.tsx

@@ -1,5 +1,6 @@
 import { useCallback, useEffect, useMemo, useRef, useState } from "react";
 import { isTauri } from "@tauri-apps/api/core";
+import { resumeIntelligenceRuns } from "./intelligence-background";
 import { listen, type UnlistenFn } from "@tauri-apps/api/event";
 import {
   Activity,
@@ -566,6 +567,14 @@ export default function App() {
     [snapshot?.capabilities?.protocols],
   );
 
+  const intelligenceServices = catalog.items
+    .map((service) => service.id)
+    .join(",");
+  useEffect(() => {
+    if (intelligenceServices)
+      void resumeIntelligenceRuns(intelligenceServices.split(","));
+  }, [intelligenceServices]);
+
   return (
     <AppShell
       sidebar={