用户请求    ↓Java（Spring Boot）接口层 → 鉴权、审计、限流    ↓Agent智能体调度 → 决定是否需要计算    ↓Java 调用 PythonScriptExecutor    ↓独立进程启动Python → 执行金融计算脚本    ↓Python 输出JSON结果    ↓Java 接收结果 → 拼装回答 → 流式返回用户    ↓全链路日志 + 金融合规审计

┌─────────────────────────────────┐│           Agent 智能体层          ││  （决策、调度、对话、上下文管理）   │└───────────┬─────────────────────┘            │┌───────────▼─────────────────────┐│      Java 业务与工具封装层        ││     @Tool 注解、参数校验、异常     │└───────────┬─────────────────────┘            │┌───────────▼─────────────────────┐│     PythonScriptExecutor 桥接层  ││    进程管理、编码、超时、隔离     │└───────────┬─────────────────────┘            │┌───────────▼─────────────────────┐│        Python 计算引擎层          ││ DCF / VaR / 技术指标 / 组合优化  │└─────────────────────────────────┘

@Slf4j@Componentpublic class PythonScriptExecutor {    private final String pythonCommand;    private static final String SKILLS_BASE_PATH = "sk-agent-agents/src/main/resources/skills";    private static final String PYTHON_IO_ENCODING = "utf-8";    private static final long DEFAULT_TIMEOUT_MS = 10000;    public PythonScriptExecutor() {        this.pythonCommand = detectPythonCommand();    }    /**     * 自动检测 python / python3     */    private String detectPythonCommand() {        try {            if (new ProcessBuilder("python3", "--version").start().waitFor() == 0) {                return "python3";            }        } catch (Exception ignored) {}        try {            if (new ProcessBuilder("python", "--version").start().waitFor() == 0) {                return "python";            }        } catch (Exception ignored) {}        log.warn("⚠️ 未检测到Python环境，金融计算工具将不可用");        return null;    }    /**     * 执行Python脚本     * @param skillPath 技能目录：如 super-financial-advisor/investment-analysis     * @param scriptName 脚本名：dcf_calculator.py     * @param args 参数JSON     */    public ScriptResult executeScript(String skillPath, String scriptName, String... args) {        if (pythonCommand == null) {            return ScriptResult.error("Python环境未配置");        }        try {            // 构建脚本路径            Path scriptPath = Paths.get(SKILLS_BASE_PATH, skillPath, "scripts", scriptName);            if (!Files.exists(scriptPath)) {                return ScriptResult.error("脚本不存在：" + scriptPath);            }            // 构建命令            List<String> command = new ArrayList<>();            command.add(pythonCommand);            command.add("-u"); // 无缓冲输出            command.add(scriptPath.toString());            Collections.addAll(command, args);            // 启动进程            ProcessBuilder pb = new ProcessBuilder(command);            pb.environment().put("PYTHONIOENCODING", PYTHON_IO_ENCODING);            pb.redirectErrorStream(true); // 合并错误流            Process process = pb.start();            String output = readInputStream(process.getInputStream());            int exitCode = process.waitFor();            if (exitCode == 0) {                return ScriptResult.success(output.trim());            } else {                return ScriptResult.error("执行失败(" + exitCode + ")：" + output);            }        } catch (Exception e) {            log.error("Python执行异常", e);            return ScriptResult.error("执行异常：" + e.getMessage());        }    }    /**     * 读取流并按UTF-8编码     */    private String readInputStream(InputStream is) throws IOException {        try (BufferedReader reader = new BufferedReader(                new InputStreamReader(is, StandardCharsets.UTF_8))) {            StringBuilder sb = new StringBuilder();            String line;            while ((line = reader.readLine()) != null) {                sb.append(line).append("\n");            }            return sb.toString();        }    }    /**     * 执行结果封装     */    @Data    @AllArgsConstructor    public static class ScriptResult {        private boolean success;        private String output;        private String error;        public static ScriptResult success(String output) {            return new ScriptResult(true, output, null);        }        public static ScriptResult error(String error) {            return new ScriptResult(false, null, error);        }    }}

@Tool(description = "DCF现金流折现估值，参数：cashFlows未来现金流、discountRate折现率、terminalGrowth永续增长率、sharesOutstanding总股本")public String calculateDcf(        double[] cashFlows,        double discountRate,        double terminalGrowth,        double sharesOutstanding) {    log.info("📊 工具调用：DCF估值计算");    String json = String.format(            "{\"cash_flows\":[%s],\"discount_rate\":%.4f,\"terminal_growth\":%.4f,\"shares\":%.2f}",            arrayToString(cashFlows), discountRate, terminalGrowth, sharesOutstanding);    PythonScriptExecutor.ScriptResult result = executor.executeScript(            "super-financial-advisor/investment-analysis",            "dcf_calculator.py",            json);    return result.isSuccess() ? result.getOutput() : "计算失败：" + result.getError();}

@Tool(description = "计算股票技术指标：MA、RSI、MACD，参数：prices收盘价数组")public String calculateTechnicalIndicators(double[] prices) {    log.info("📊 工具调用：技术指标计算");    String json = String.format("{\"prices\":[%s]}", arrayToString(prices));    var result = executor.executeScript(            "super-financial-advisor/investment-analysis",            "technical_indicators.py",            json);    return result.isSuccess() ? result.getOutput() : "计算失败：" + result.getError();}

@Tool(description = "投资组合VaR风险计算，参数：portfolioValue组合价值、meanReturn收益率、stdDev标准差、confidenceLevel置信度")public String calculateVar(        double portfolioValue,        double meanReturn,        double stdDev,        double confidenceLevel) {    log.info("📊 工具调用：VaR风险计算");    String json = String.format(            "{\"portfolio_value\":%.2f,\"mean_return\":%.6f,\"std_dev\":%.6f,\"confidence\":%.2f}",            portfolioValue, meanReturn, stdDev, confidenceLevel);    var result = executor.executeScript(            "super-financial-advisor/risk-management",            "var_calculator.py",            json);    return result.isSuccess() ? result.getOutput() : "计算失败：" + result.getError();}

@Tool(description = "投资组合优化，最大化夏普比率，参数：assets资产代码、expectedReturns预期收益、riskFreeRate无风险利率")public String optimizePortfolio(        String[] assets,        double[] expectedReturns,        double riskFreeRate) {    log.info("📊 工具调用：投资组合优化");    String assetsJson = "[\"" + String.join("\",\"", assets) + "\"]";    String returnsJson = arrayToString(expectedReturns);    String json = String.format(            "{\"assets\":%s,\"returns\":[%s],\"risk_free\":%.4f}",            assetsJson, returnsJson, riskFreeRate);    var result = executor.executeScript(            "super-financial-advisor/risk-management",            "portfolio_optimizer.py",            json);    return result.isSuccess() ? result.getOutput() : "计算失败：" + result.getError();}

private String arrayToString(double[] arr) {    StringBuilder sb = new StringBuilder();    for (int i = 0; i < arr.length; i++) {        if (i > 0) sb.append(",");        sb.append(arr[i]);    }    return sb.toString();}

import sysimport jsondef dcf_valuation(cash_flows, discount_rate, terminal_growth, shares):    if len(cash_flows) == 0:        return {"error": "现金流不能为空"}    pv = 0    for i, cf in enumerate(cash_flows):        pv += cf / ((1 + discount_rate) ** (i + 1))    last_cf = cash_flows[-1]    terminal_value = last_cf * (1 + terminal_growth) / (discount_rate - terminal_growth)    pv += terminal_value / ((1 + discount_rate) ** len(cash_flows))    value_per_share = pv / shares    return {        "total_value": round(pv, 2),        "value_per_share": round(value_per_share, 2),        "terminal_value": round(terminal_value, 2)    }if __name__ == "__main__":    data = json.loads(sys.argv[1])    result = dcf_valuation(        cash_flows=data["cash_flows"],        discount_rate=data["discount_rate"],        terminal_growth=data["terminal_growth"],        shares=data["shares"]    )    print(json.dumps(result, ensure_ascii=False))

// 可在executeScript中增加超时boolean finished = process.waitFor(5, TimeUnit.SECONDS);if (!finished) {    process.destroyForcibly();    return ScriptResult.error("执行超时");}