天气查询工具/MCP的接入

@Component
public class DestinationLiveTools {

    /** wttr.in：免费天气 API，无需 API Key，直接按城市名查询 */
    private static final String WEATHER_API_BASE = "https://wttr.in/";

    /** wttr.in 支持的最大预报天数（今天起算） */
    private static final int WEATHER_FORECAST_DAYS = 2;

    /** 天气查询 HTTP 请求超时（秒） */
    private static final int WEATHER_REQUEST_TIMEOUT_SECONDS = 8;

@Tool(name = "query_weather",
      description = "联网查询目的地城市的天气信息（首选工具，免费）。"
              + "支持今天及未来 2 天（共 3 天）的天气预报；"
              + "若 date 超出此范围，工具会返回 beyond_range=true，Agent 应改用 weather-mcp 工具查询。"
              + "不指定 date 则返回当前天气 + 未来 3 天全量预报。"
              + "每日预报包含最高/最低温度和逐 3 小时天气（温度、降雨概率、风速、状况描述）。"
              + "支持中文城市名（如 北京、上海）和英文城市名（如 Tokyo、Paris）。")
public String queryWeather(
        @ToolParam(name = "city", description = "目标城市，如 北京、上海、杭州、Tokyo、Paris") String city,
        @ToolParam(name = "date",
                   description = "查询日期，YYYY-MM-DD 格式，如 2026-07-15；"
                           + "仅支持今天及未来 2 天（wttr.in 限制），超出范围会提示改用 weather-mcp；"
                           + "可选，不填则返回全量 3 天预报",
                   required = false) String date) {

// ── 日期范围预检：超出 today+2 则直接返回 beyond_range 信号 ──────────────
LocalDate targetDate = parseDate(date);
if (targetDate != null) {
    LocalDate maxDate = LocalDate.now().plusDays(WEATHER_FORECAST_DAYS);
    if (targetDate.isAfter(maxDate)) {
        logger.info("[TOOL][query_weather] 日期 {} 超出 wttr.in 范围，提示使用 weather-mcp", date);
        JSONObject beyond = new JSONObject();
        beyond.put("city", city);
        beyond.put("date", date);
        beyond.put("beyond_range", true);
        beyond.put("message",
                date + " 超出 wttr.in 支持范围（仅今天起 3 天内）。"
                        + "请立即改用 maps_weather 工具查询该日期的天气预报。");
        return JSON.toJSONString(beyond);
    }
}

@Configuration
public class WeatherMcpConfig {

    private static final Logger logger = LoggerFactory.getLogger(WeatherMcpConfig.class);

    /** MCP 工具调用请求超时（秒） */
    private static final int MCP_REQUEST_TIMEOUT_SECONDS = 30;
    /** MCP 初始化握手超时（秒） */
    private static final int MCP_INIT_TIMEOUT_SECONDS = 15;

    /**
     * 天气 MCP Streamable HTTP 端点，从配置文件读取。
     * 配置项：app.weather-mcp.endpoint
     */
    @Value("${app.weather-mcp.endpoint}")
    private String weatherMcpEndpoint;

    @Bean(name = "weatherMcpClient")
    public McpClientWrapper weatherMcpClient() {

        logger.info("[WeatherMcp] 初始化 天气 MCP 客户端 (Streamable HTTP)...");

        try {
            McpClientWrapper client = McpClientBuilder.create("weather-mcp")
                    // Streamable HTTP 传输
                    .streamableHttpTransport(weatherMcpEndpoint)
                    // 工具调用请求超时
                    .timeout(Duration.ofSeconds(MCP_REQUEST_TIMEOUT_SECONDS))
                    // MCP 初始化握手超时
                    .initializationTimeout(Duration.ofSeconds(MCP_INIT_TIMEOUT_SECONDS))
                    .buildAsync()
                    .block();

            logger.info("[WeatherMcp] 天气 MCP 客户端初始化成功");
            return client;

        } catch (Exception e) {
            logger.warn("[WeatherMcp] 天气 MCP 客户端初始化失败，超过 3 天的天气查询将不可用。原因：{}",
                    e.getMessage());
            return null;
        }
    }
}

weather-mcp:
  # 天气 MCP 工具白名单（逗号分隔的工具名称）
  # 当前选定 6 个差旅核心工具（省略 POI/经纬度类、长期预报、生活指数等）：
  enabled-tools: 城市天气实况,城市15日预报,城市天气预警,城市空气实况,城市24小时预报,城市40日预报

@Bean(name = "infoAgent")
@Scope("prototype")
public ReActAgent build() {
    Toolkit toolkit = new Toolkit();

    toolkit.createToolGroup(TOOL_CIRCUIT_BREAKER_GROUP, TOOL_CIRCUIT_BREAKER_GROUP, true);

    toolkit.registration().tool(infoQueryTools).apply();
    toolkit.registration().tool(policyTools).apply();
    // 通道一：原生 query_weather 所在的 DestinationLiveTools，放进熔断组
    toolkit.registration().tool(destinationLiveTools).group(TOOL_CIRCUIT_BREAKER_GROUP).apply();
    // 通道二：weather-mcp，按白名单暴露工具
    toolkit.registration().mcpClient(weatherMcpClient).enableTools(weatherMcpEnabledTools).apply();
    toolkit.registration().mcpClient(oriznVisaMcpClient).enableTools(oriznMcpEnabledTools).apply();
    // ...
}

@Autowired(required = false)
@Qualifier("weatherMcpClient")
@Nullable
protected McpClientWrapper weatherMcpClient;

/** 天气 MCP 工具白名单（从 app.weather-mcp.enabled-tools 读取），Spring 自动按逗号拆成 List */
@Value("${app.weather-mcp.enabled-tools:}")
protected List<String> weatherMcpEnabledTools;