MxJSON 代码审查与执行流程

// 前端调用示例
const result = await mxjsonAPI.executeProtocol({
  protocol_id: 'abc123-def456',        // 协议ID
  input_data: {
    work_items: '1. 完成用户模块\n2. 修复登录bug',
    style: 'professional'
  },
  runtime_env: 'Production'             // 运行环境
});

// 实际发送的HTTP请求
POST /mxjson/mxjson/executeprotocol
Content-Type: application/json
{
  "protocol_id": "abc123-def456",
  "input_data": { "work_items": "...", "style": "professional" },
  "runtime_env": "Production"
}

// 后端 executeprotocol() 方法
$validate = Validate::rule([
    'protocol_id' => 'require',
    'input_data'  => 'require|array'
]);

if (!$validate->check($requestData)) {
    return json(['code' => 1, 'msg' => $validate->getError()]);
}

$protocol_id = $requestData['protocol_id'];
$input_data  = $requestData['input_data'];
$runtime_env = $requestData['runtime_env'] ?? 'Production';
$user_id     = $this->getUserId();

// 从数据库加载协议
$protocol = Db::name('mxjson_protocol')
    ->where('id', $protocol_id)
    ->where('status', 1)             // 已启用
    ->where('deleted_at', null)     // 未删除
    ->where(function ($query) use ($user_id) {
        $query->where('is_public', 1)   // 公开
              ->whereOr('user_id', $user_id); // 或自己创建的
    })
    ->find();

if (!$protocol) {
    return json(['code' => 1, 'msg' => '协议不存在或已禁用']);
}

// 解析各项JSON配置
$inputSchema       = !empty($protocol['input_schema']) 
                       ? json_decode($protocol['input_schema'], true) : [];
$aiConfig          = !empty($protocol['ai_config']) 
                       ? json_decode($protocol['ai_config'], true) : [];
$workflowConfig    = !empty($protocol['workflow_config']) 
                       ? json_decode($protocol['workflow_config'], true) : null;
$humanReviewConfig = !empty($protocol['human_review_config']) 
                       ? json_decode($protocol['human_review_config'], true) : null;
$pricingConfig     = !empty($protocol['pricing_config']) 
                       ? json_decode($protocol['pricing_config'], true) : null;
$auditConfig       = !empty($protocol['audit_config']) 
                       ? json_decode($protocol['audit_config'], true) : null;

// validateInputData() 方法
foreach ($inputSchema as $fieldName => $fieldConfig) {
    $value = $inputData[$fieldName] ?? null;
    
    // 必填验证
    if (!empty($fieldConfig['required']) && empty($value)) {
        $errors[] = $fieldConfig['label'] . ' 不能为空';
    }
    
    // 类型验证（number/select/multiselect/json/boolean）
    switch ($fieldConfig['type']) {
        case 'number': // 数字验证
        case 'select': // 选项验证
        case 'json':   // JSON格式验证
    }
    
    // 自定义规则验证（min/max/min_length/max_length/pattern）
    if (isset($fieldConfig['validation'])) { ... }
}

// 生成唯一标识
$execution_uuid = $this->generateUUID();
$trace_id = 'trace_' . date('Ymd') . '_' . bin2hex(random_bytes(8));

// 创建执行记录
$execution_id = Db::name('mxjson_execution')->insertGetId([
    'execution_uuid'  => $execution_uuid,
    'trace_id'        => $trace_id,
    'protocol_id'     => $protocol_id,
    'protocol_version'=> $protocol['version'],
    'runtime_env'     => $runtime_env,
    'input_data'      => json_encode($input_data, JSON_UNESCAPED_UNICODE),
    'status'          => 'running',
    'user_id'         => $user_id,
    'started_at'      => date('Y-m-d H:i:s'),
    'created_at'      => date('Y-m-d H:i:s')
]);

// preprocessInputData() 方法
foreach ($inputData as $fieldName => $value) {
    $type = $inputSchema[$fieldName]['type'] ?? 'text';
    
    switch ($type) {
        case 'file':
            // 提取文件内容
            $processed[$fieldName . '_text'] = $this->extractFileContent($value);
            break;
        case 'multiselect':
            // 数组转文本
            $processed[$fieldName . '_text'] = implode('、', $value);
            break;
        case 'date':
            // 日期格式化
            $processed[$fieldName . '_formatted'] = date('Y年m月d日', strtotime($value));
            break;
        case 'json':
            // JSON解析
            $processed[$fieldName . '_parsed'] = json_decode($value, true);
            break;
    }
}

// 构建完整的执行上下文
$context = [
    'input'        => $input_data,       // 原始输入数据
    'preprocessed' => $processedData,   // 预处理后的数据
    'ai'           => $aiConfig,        // AI配置
    'meta'         => $rawJsonData['meta'] ?? [], // 协议元数据
    'runtime'      => [
        'env'          => $runtime_env,
        'execution_id' => $execution_id,
        'trace_id'     => $trace_id,
        'user_id'      => $user_id
    ]
];

// 工作流执行时，上下文会动态扩展
// 例如: $context['step1_result'] = ... // 前置步骤的输出

// 判断执行模式
if ($workflowConfig && !empty($workflowConfig['steps'])) {
    // 工作流模式：支持 sequential/parallel/dag 三种
    $result = $this->executeWorkflow(
        $execution_id, 
        $workflowConfig,  // 工作流配置
        $context,         // 执行上下文
        $aiConfig,        // AI配置
        $humanReviewConfig,
        $trace_id,
        $auditConfig
    );
} else {
    // 简单AI调用模式：直接调用AI
    $result = $this->executeSimpleAI(
        $execution_id, 
        $aiConfig,        // AI配置
        $context,         // 执行上下文
        $trace_id,
        $auditConfig
    );
}

// injectVariables() 方法 - 变量注入引擎
private function injectVariables(string $template, array $context): string {
    return preg_replace_callback(
        '/\{\{([^}]+)\}\}/',
        function ($matches) use ($context) {
            $expression = trim($matches[1]);
            
            // 支持过滤器语法: {{variable|filter(args)}}
            if (strpos($expression, '|') !== false) {
                $parts = explode('|', $expression, 2);
                $value = $this->getValueByPath($context, trim($parts[0]));
                return $this->applyFilter($value, trim($parts[1]));
            }
            
            return $this->getValueByPath($context, $expression);
        },
        $template
    );
}

// 示例：
// 模板: "请生成{{input.style}}风格的周报：{{input.work_items}}"
// 结果: "请生成professional风格的周报：1. 完成用户模块..."

// 支持的过滤器：join/upper/lower/trim/length/first/last/default/truncate/json/date/number_format/replace

// 获取AI提供商和模型配置
$provider = $this->getProviderByName($aiConfig['provider'] ?? 'openai');
$model = $this->getModelByName($aiConfig['model'] ?? 'gpt-4o', $provider['id']);

// 构建消息
$messages = [];
if (!empty($systemPrompt)) {
    $messages[] = ['role' => 'system', 'content' => $systemPrompt];
}
$messages[] = ['role' => 'user', 'content' => $userPrompt];

// 调用AI服务
$aiService = new AiService();
$response = $aiService->chatCompletion(
    $provider['id'],
    $model['id'],
    $messages,
    [
        'temperature' => 0.7,
        'max_tokens'  => 2000,
        'top_p'       => 1.0
    ]
);

// extractJsonFromResponse() - 从响应中提取JSON
$parsedOutput = $response['content'];

// 尝试提取JSON（支持代码块格式）
$jsonOutput = $this->extractJsonFromResponse($response['content']);
if ($jsonOutput !== null) {
    $parsedOutput = $jsonOutput;
    
    // 如果配置了输出Schema，进行验证
    if (isset($outputFormat['schema'])) {
        $validation = $this->validateOutputSchema(
            $jsonOutput, 
            $outputFormat['schema']
        );
        if (!$validation['valid']) {
            $this->logExecution($execution_id, null, 'warning', 
                'schema_validation', 'AI输出Schema验证失败');
        }
    }
}

// 人工审核判断
if ($humanReviewConfig && !empty($humanReviewConfig['enabled'])) {
    $needReview = $this->evaluateHumanReviewCondition(
        $humanReviewConfig, $result, $context
    );
    if ($needReview) {
        $this->createHumanReview($execution_id, $humanReviewConfig, $result, $context);
        // 状态变为 'reviewing'，等待人工处理
    }
}

// 计费处理 - 支持8种模式
$billingResult = $this->processBilling($execution_id, $pricingConfig, $result, $user_id);

// 计费模式: free/per_call/per_token/per_minute/subscription/tiered/usage_based/hybrid

// 更新执行状态
Db::name('mxjson_execution')->where('id', $execution_id)->update([
    'status'            => 'completed',
    'ai_response'       => $result['raw_response'],
    'parsed_output'     => json_encode($result['parsed_output']),
    'final_output'      => json_encode($result['final_output']),
    'execution_time_ms' => $executionTimeMs,
    'tokens_used'       => $result['tokens_used'],
    'completed_at'      => date('Y-m-d H:i:s')
]);

// 更新协议使用次数
Db::name('mxjson_protocol')->where('id', $protocol_id)->inc('usage_count')->update();

// 记录审计日志
$this->auditLog('execution_completed', 'info', '协议执行完成', [...], $trace_id);

// 返回结果给前端
return json([
    'code' => 0,
    'msg'  => '执行成功',
    'data' => [
        'execution_id'   => $execution_id,
        'execution_uuid' => $execution_uuid,
        'trace_id'       => $trace_id,
        'status'         => 'completed',
        'result'         => $result,      // {raw_response, parsed_output, final_output, tokens_used}
        'billing'        => $billingResult // {bill_id, mode, amount, currency, tokens_used}
    ]
]);