| | |
| | | validateBuiltinCode(builtinCode); |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS.equals(builtinCode)) { |
| | | List<ToolCallback> callbacks = new ArrayList<>(); |
| | | callbacks.addAll(createValidatedCallbacks(rsfWmsStockTools, AiDefaults.MCP_BUILTIN_RSF_WMS_STOCK)); |
| | | callbacks.addAll(createValidatedCallbacks(rsfWmsTaskTools, AiDefaults.MCP_BUILTIN_RSF_WMS_TASK)); |
| | | callbacks.addAll(createValidatedCallbacks(rsfWmsBaseTools, AiDefaults.MCP_BUILTIN_RSF_WMS_BASE)); |
| | | callbacks.addAll(createValidatedCallbacks(rsfWmsStockTools, builtinCode)); |
| | | callbacks.addAll(createValidatedCallbacks(rsfWmsTaskTools, builtinCode)); |
| | | callbacks.addAll(createValidatedCallbacks(rsfWmsBaseTools, builtinCode)); |
| | | return callbacks; |
| | | } |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS_STOCK.equals(builtinCode)) { |
| | | return createValidatedCallbacks(rsfWmsStockTools, builtinCode); |
| | | } |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS_TASK.equals(builtinCode)) { |
| | | return createValidatedCallbacks(rsfWmsTaskTools, builtinCode); |
| | | } |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS_BASE.equals(builtinCode)) { |
| | | return createValidatedCallbacks(rsfWmsBaseTools, builtinCode); |
| | | } |
| | | throw new CoolException("不支持的内置 MCP 编码: " + builtinCode); |
| | | } |
| | |
| | | public List<AiMcpToolPreviewDto> listBuiltinToolCatalog(String builtinCode) { |
| | | validateBuiltinCode(builtinCode); |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS.equals(builtinCode)) { |
| | | List<AiMcpToolPreviewDto> catalog = new ArrayList<>(); |
| | | catalog.addAll(catalogByBuiltinCode(AiDefaults.MCP_BUILTIN_RSF_WMS_STOCK).values()); |
| | | catalog.addAll(catalogByBuiltinCode(AiDefaults.MCP_BUILTIN_RSF_WMS_TASK).values()); |
| | | catalog.addAll(catalogByBuiltinCode(AiDefaults.MCP_BUILTIN_RSF_WMS_BASE).values()); |
| | | return catalog; |
| | | return new ArrayList<>(catalogByBuiltinCode(builtinCode).values()); |
| | | } |
| | | return new ArrayList<>(catalogByBuiltinCode(builtinCode).values()); |
| | | } |
| | |
| | | } |
| | | |
| | | private List<String> supportedBuiltinCodes() { |
| | | return List.of( |
| | | AiDefaults.MCP_BUILTIN_RSF_WMS, |
| | | AiDefaults.MCP_BUILTIN_RSF_WMS_STOCK, |
| | | AiDefaults.MCP_BUILTIN_RSF_WMS_TASK, |
| | | AiDefaults.MCP_BUILTIN_RSF_WMS_BASE |
| | | ); |
| | | return List.of(AiDefaults.MCP_BUILTIN_RSF_WMS); |
| | | } |
| | | |
| | | private Map<String, AiMcpToolPreviewDto> catalogByBuiltinCode(String builtinCode) { |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS_STOCK.equals(builtinCode)) { |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS.equals(builtinCode)) { |
| | | Map<String, AiMcpToolPreviewDto> catalog = new LinkedHashMap<>(); |
| | | catalog.put("rsf_query_available_inventory", buildCatalogItem( |
| | | "rsf_query_available_inventory", |
| | |
| | | "必须提供站点类型列表,类型数量最多 10 个,最多返回 50 个站点。", |
| | | List.of("查询入库和出库作业可用站点", "列出 AGV_PICK 类型的作业站点") |
| | | )); |
| | | return catalog; |
| | | } |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS_TASK.equals(builtinCode)) { |
| | | Map<String, AiMcpToolPreviewDto> catalog = new LinkedHashMap<>(); |
| | | catalog.put("rsf_query_task_list", buildCatalogItem( |
| | | "rsf_query_task_list", |
| | | "任务查询", |
| | |
| | | "必须提供任务 ID 或任务号之一,只返回单个任务。", |
| | | List.of("查询任务 12345 的详情", "根据任务号 TASK24001 查看执行明细") |
| | | )); |
| | | return catalog; |
| | | } |
| | | if (AiDefaults.MCP_BUILTIN_RSF_WMS_BASE.equals(builtinCode)) { |
| | | Map<String, AiMcpToolPreviewDto> catalog = new LinkedHashMap<>(); |
| | | catalog.put("rsf_query_warehouses", buildCatalogItem( |
| | | "rsf_query_warehouses", |
| | | "基础资料", |