111 lines
2.8 KiB
JavaScript
111 lines
2.8 KiB
JavaScript
/**
|
||
* 意图路由中间件 · 自然语言 → 操作映射
|
||
*
|
||
* 核心逻辑：
|
||
* 1. 接收模型输出的 function_call
|
||
* 2. 验证权限
|
||
* 3. 调用对应的后端 API
|
||
* 4. 返回结果
|
||
*
|
||
* 版权：国作登字-2026-A-00037559
|
||
*/
|
||
|
||
'use strict';
|
||
|
||
var tools = require('../config/function-tools.json');
|
||
|
||
/**
|
||
* 意图路由核心
|
||
*
|
||
* @param {Object} functionCall - { name, parameters }
|
||
* @param {Object} user - 当前用户信息（含 permissions, environment, modules）
|
||
* @param {Function} apiClient - API 调用函数 (method, path, body) => result
|
||
* @returns {Object} 执行结果
|
||
*/
|
||
async function routeIntent(functionCall, user, apiClient) {
|
||
var tool = null;
|
||
for (var i = 0; i < tools.tools.length; i++) {
|
||
if (tools.tools[i].name === functionCall.name) {
|
||
tool = tools.tools[i];
|
||
break;
|
||
}
|
||
}
|
||
|
||
if (!tool) {
|
||
return {
|
||
success: false,
|
||
reply: '❓ 我不认识这个操作：' + functionCall.name + '。你可以问我能做什么。'
|
||
};
|
||
}
|
||
|
||
// 权限检查
|
||
if (!user.permissions.includes(tool.permission)) {
|
||
return {
|
||
success: false,
|
||
reply: '🔒 你没有执行「' + tool.description + '」的权限。当前权限等级：' + user.permissionLabel
|
||
};
|
||
}
|
||
|
||
// 危险操作二次确认
|
||
if (tool.dangerous && !functionCall.parameters.confirmToken) {
|
||
return {
|
||
success: false,
|
||
requireConfirmation: true,
|
||
reply: '⚠️ 这是一个**危险操作**。请说「确认执行」来确认。'
|
||
};
|
||
}
|
||
|
||
// 预览环境检查
|
||
if (user.environment === 'preview' && tool.permission.includes('production')) {
|
||
return {
|
||
success: false,
|
||
reply: '🔒 你目前在**预览环境**，不能执行正式站操作。在预览站充分练习后，由冰朔开放正式站权限。'
|
||
};
|
||
}
|
||
|
||
// 解析 API 路径
|
||
var apiDef = tool.api.split(' ');
|
||
var method = apiDef[0];
|
||
var path = apiDef[1];
|
||
|
||
// 替换路径中的变量
|
||
path = path.replace('{devId}', user.devId);
|
||
var params = functionCall.parameters || {};
|
||
for (var key in params) {
|
||
path = path.replace('{' + key + '}', encodeURIComponent(params[key]));
|
||
}
|
||
|
||
// 调用 API
|
||
try {
|
||
var result = await apiClient(method, path, Object.assign({}, params, { devId: user.devId }));
|
||
return result;
|
||
} catch (e) {
|
||
return {
|
||
success: false,
|
||
reply: '❌ 操作失败：' + e.message
|
||
};
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取用户可用的工具列表（已根据权限过滤）
|
||
*/
|
||
function getAvailableTools(user) {
|
||
return tools.tools.filter(function(tool) {
|
||
return user.permissions.includes(tool.permission);
|
||
});
|
||
}
|
||
|
||
/**
|
||
* 获取全部工具定义
|
||
*/
|
||
function getAllTools() {
|
||
return tools.tools;
|
||
}
|
||
|
||
module.exports = {
|
||
routeIntent: routeIntent,
|
||
getAvailableTools: getAvailableTools,
|
||
getAllTools: getAllTools
|
||
};
|