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

feature(ActionExecutor): complete CorrectorInput

Browse Source
This commit is contained in:
slhafzjw
2026-01-28 23:11:45 +08:00
parent fac6609d6b
commit d1ca1cda7d
2 changed files with 30 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -18,7 +18,6 @@ import work.slhaf.partner.module.modules.action.dispatcher.executor.entity.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Phaser;
@@ -92,8 +91,8 @@ public class ActionExecutor extends AgentRunningSubModule<ActionExecutorInput, V
}
phaser.awaitAdvance(phase);
// TODO 进行行动链修正
val correctorInput = assemblyHelper.buildCorrectorInput();
// 针对行动链进行修正，修正需要传入执行历史、行动目标等内容
val correctorInput = assemblyHelper.buildCorrectorInput(actionData, userId);
actionCorrector.execute(correctorInput);
} while (actionChain.size() > ++stageCount);
@@ -194,8 +193,17 @@ public class ActionExecutor extends AgentRunningSubModule<ActionExecutorInput, V
return input;
}
private CorrectorInput buildCorrectorInput() {
return null;
private CorrectorInput buildCorrectorInput(ImmediateActionData actionData, String userId) {
return CorrectorInput.builder()
.tendency(actionData.getTendency())
.source(actionData.getSource())
.reason(actionData.getReason())
.description(actionData.getDescription())
.history(actionData.getHistory().get(actionData.getExecutingStage()))
.status(actionData.getStatus())
.recentMessages(cognationCapability.getChatMessages())
.activatedSlices(memoryCapability.getActivatedSlices(userId))
.build();
}
}

17
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorInput.java
View File

@@ -1,7 +1,24 @@
package work.slhaf.partner.module.modules.action.dispatcher.executor.entity;
import lombok.Builder;
import lombok.Data;
import work.slhaf.partner.api.chat.pojo.Message;
import work.slhaf.partner.core.action.entity.ActionData;
import work.slhaf.partner.core.memory.pojo.EvaluatedSlice;
import java.util.List;
@Data
@Builder
public class CorrectorInput {
private String tendency;
private String source;
private String reason;
private String description;
private List<HistoryAction> history;
private ActionData.ActionStatus status;
private List<Message> recentMessages;
private List<EvaluatedSlice> activatedSlices;
}