From d1ca1cda7d422f5b2bf3ecf9bf42a15060adaab0 Mon Sep 17 00:00:00 2001
From: slhafzjw <slhafzjw@slhaf.work>
Date: Wed, 28 Jan 2026 23:11:45 +0800
Subject: [PATCH] feature(ActionExecutor): complete CorrectorInput

---
 .../dispatcher/executor/ActionExecutor.java    | 18 +++++++++++++-----
 .../executor/entity/CorrectorInput.java        | 17 +++++++++++++++++
 2 files changed, 30 insertions(+), 5 deletions(-)

diff --git a/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java b/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java
index 71ef3e4a..bc24a781 100644
--- a/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java
+++ b/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutor.java
@@ -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();
         }
     }
 
diff --git a/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorInput.java b/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorInput.java
index aad21e36..1c2c9af8 100644
--- a/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorInput.java
+++ b/Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/executor/entity/CorrectorInput.java
@@ -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;
 }