Agent Workflow子流程与场景流程的上下文管理——从爆炸到有序的设计哲学

Main Process Context
├── Input: user query, session info, system config
├── Step 1 Result: intent, entities, confidence
├── Step 2 Result: componentType, fields, layout config
├── Sub-Process A Context (inherited)
│   ├── Parent Context (read-only)
│   ├── Step A1 Result: design metadata
│   ├── Step A2 Result: generated code
│   └── Sub-Sub-Process Context...
├── Scene Flow B Context (injected)
│   ├── Knowledge Repository Query
│   ├── Scene-specific config
│   └── Runtime accumulated data
└── ...exponential growth

// 初始化上下文的配置驱动模式
public class NlpResolutionContext {
    private String query;           // 用户输入
    private String workMode;        // 从application.properties注入
    private String sceneGroupId;    // 从流程定义继承
    private List<String> fields;    // 运行期填充

    public static NlpResolutionContext initialize(SceneConfig config) {
        NlpResolutionContext ctx = new NlpResolutionContext();
        ctx.setWorkMode(config.getWorkMode());
        ctx.setSceneGroupId(config.getSceneGroupId());
        return ctx;
    }
}

// 避免null覆盖的安全合并
public void mergeAccumulatedData(Map<String, Object> newData) {
    for (Map.Entry<String, Object> entry : newData.entrySet()) {
        String key = entry.getKey();
        Object value = entry.getValue();
        // 只在当前值不存在或为null时覆盖
        if (!this.accumulatedData.containsKey(key) || this.accumulatedData.get(key) == null) {
            this.accumulatedData.put(key, value);
        }
    }
}

// VFS持久化接口
public interface NlpResolutionContextVfsHelper {
    void save(String processInstId, NlpResolutionContext ctx);
    NlpResolutionContext load(String processInstId);
    boolean exists(String processInstId);
}

// 子流程上下文继承
public ProcessContext inheritFromParent(ProcessContext parentCtx) {
    ProcessContext childCtx = new ProcessContext();
    // 浅拷贝accumulatedData（只读）
    childCtx.setAccumulatedData(new HashMap<>(parentCtx.getAccumulatedData()));
    // 继承系统级配置
    childCtx.setWorkMode(parentCtx.getWorkMode());
    childCtx.setSceneGroupId(parentCtx.getSceneGroupId());
    return childCtx;
}

// 场景流程上下文注入
public ProcessContext injectForScene(SceneConfig sceneConfig, 
                                       KnowledgeRepository repo,
                                       ProcessContext triggerCtx) {
    ProcessContext sceneCtx = new ProcessContext();

    // 1. 注入场景配置
    sceneCtx.setSceneGroupId(sceneConfig.getSceneGroupId());
    sceneCtx.setCapabilities(sceneConfig.getRequiredCapabilities());

    // 2. 注入知识库数据
    KnowledgeEntry knowledge = repo.query(sceneConfig.getKnowledgeGroupId());
    sceneCtx.setDomainKnowledge(knowledge.getMetadata());

    // 3. 注入触发上下文的关键字段（选择性注入，非全量继承）
    sceneCtx.setQuery(triggerCtx.getQuery());
    sceneCtx.setIntent(triggerCtx.getIntent());

    return sceneCtx;
}

/**
 * 实体解析结果上下文Bean
 * 替代散列Map传播，提供实体Bean同源处理
 */
public class NlpResolutionContext {
    private String query;
    private String intent;
    private String componentType;
    private String moduleName;
    private List<String> fields;
    private List<String> fieldEnglishNames;
    private Map<String, String> fieldTypes;

    // 从PipelineResult构建
    public static NlpResolutionContext fromPipelineResult(
            PipelineResult result, String query) {
        NlpResolutionContext ctx = new NlpResolutionContext();
        ctx.setQuery(query);
        ctx.setIntent(result.getIntent());
        ctx.setComponentType(result.getComponentType());
        ctx.setModuleName(result.getModuleName());
        ctx.setFields(result.getFields());
        ctx.setFieldEnglishNames(result.getEntityResult().getFieldEnglishNames());
        ctx.setFieldTypes(result.getEntityResult().getFieldTypes());
        return ctx;
    }

    // 判断是否包含Grid所需字段
    public boolean hasGridFields() {
        return fields != null && !fields.isEmpty() 
            && fieldEnglishNames != null && !fieldEnglishNames.isEmpty();
    }
}

// nlp-skill-field-mapping.json
{
  "pipelineContextFields": [
    {"mapKey": "query", "beanProperty": "query", "type": "String"},
    {"mapKey": "workMode", "beanProperty": "workMode", "type": "String"},
    {"mapKey": "sceneGroupId", "beanProperty": "sceneGroupId", "type": "String"}
  ],
  "pipelineResultEntityFields": [
    {"mapKey": "moduleName", "beanProperty": "moduleName", "type": "String"},
    {"mapKey": "fields", "beanProperty": "fields", "type": "List<String>"},
    {"mapKey": "fieldEnglishNames", "beanProperty": "fieldEnglishNames", "type": "List<String>"}
  ]
}

public static PipelineContext toPipelineContext(Map<String, Object> context) {
    // CONFIG验证: 检测未注册的Map key
    Set<String> unmapped = detectUnmappedKeys(context);
    if (!unmapped.isEmpty()) {
        log.debug("[NlpSkillContextHelper] 未注册Map key={}", unmapped);
    }
    // ... 字段映射逻辑
}

Main Process (architect-pipeline)
├── Sub-Process: understand-subflow (继承)
│   ├── Activity: intent_classification
│   ├── Activity: entity_extraction
│   └── Activity: entity_resolution
├── Scene Flow: rad-scene (注入)
│   ├── Knowledge: component-type-registry
│   └── Capability: nlp.design
└── Sub-Process: quality-validation (继承)
    ├── Activity: llm_fallback
    └── Activity: cls_audit