slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 08:43:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(ActionExecutor): remove useless method getHistoryActionResults

Browse Source
This commit is contained in:
slhafzjw
2026-01-28 23:00:53 +08:00
parent dce8825e58
commit fac6609d6b
1 changed files with 4 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java
View File

@@ -117,8 +117,9 @@ public class ActionExecutor extends AgentRunningSubModule<ActionExecutorInput, V
val result = metaAction.getResult(); val result = metaAction.getResult();
do { do {
val actionData = phaserRecord.actionData(); val actionData = phaserRecord.actionData();
val historyActionResults = assemblyHelper.getHistoryActionResults(actionData); val executingStage = actionData.getExecutingStage();
val additionalContext = actionData.getAdditionalContext().get(actionData.getExecutingStage()); val historyActionResults = actionData.getHistory().get(executingStage);
val additionalContext = actionData.getAdditionalContext().get(executingStage);
val extractorInput = assemblyHelper.buildExtractorInput(metaAction, userId, historyActionResults, additionalContext); val extractorInput = assemblyHelper.buildExtractorInput(metaAction, userId, historyActionResults, additionalContext);
val extractorResult = paramsExtractor.execute(extractorInput); val extractorResult = paramsExtractor.execute(extractorInput);
@@ -130,7 +131,7 @@ public class ActionExecutor extends AgentRunningSubModule<ActionExecutorInput, V
historyAction.setDescription(actionCapability.loadMetaActionInfo(actionKey).getDescription()); historyAction.setDescription(actionCapability.loadMetaActionInfo(actionKey).getDescription());
historyAction.setResult(metaAction.getResult().getData()); historyAction.setResult(metaAction.getResult().getData());
actionData.getHistory() actionData.getHistory()
.computeIfAbsent(actionData.getExecutingStage(), integer -> new ArrayList<>()) .computeIfAbsent(executingStage, integer -> new ArrayList<>())
.add(historyAction); .add(historyAction);
} else { } else {
val repairerInput = assemblyHelper.buildRepairerInput(historyActionResults, metaAction, userId); val repairerInput = assemblyHelper.buildRepairerInput(historyActionResults, metaAction, userId);
@@ -193,25 +194,6 @@ public class ActionExecutor extends AgentRunningSubModule<ActionExecutorInput, V
return input; return input;
} }
private List<HistoryAction> getHistoryActionResults(ActionData actionData) {
int executingStage = actionData.getExecutingStage();
if (executingStage <= 0) {
return new ArrayList<>();
}
Map<Integer, List<MetaAction>> actionChain = actionData.getActionChain();
// executingStage 是当前正在执行的阶段，所以只需要获取到前一阶段的结果
return actionChain.get(executingStage - 1).stream()
.map(metaAction -> {
HistoryAction historyAction = new HistoryAction();
historyAction.setActionKey(metaAction.getKey());
historyAction
.setDescription(
actionCapability.loadMetaActionInfo(metaAction.getKey()).getDescription());
historyAction.setResult(metaAction.getResult().getData());
return historyAction;
}).toList();
}
private CorrectorInput buildCorrectorInput() { private CorrectorInput buildCorrectorInput() {
return null; return null;
} }