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

refactor(ActionExecutorInput): migrate to Kotlin data class

Browse Source
This commit is contained in:
slhafzjw
2026-02-08 15:12:10 +08:00
parent 98e4d4cf1b
commit d098b28f31
4 changed files with 6 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/ActionDispatcher.java
View File

@@ -57,10 +57,7 @@ public class ActionDispatcher extends PostRunningModule {
immediateActions.add(actionInfo); immediateActions.add(actionInfo);
} }
} }
val actionExecutorInput = ActionExecutorInput.builder() actionExecutor.execute(new ActionExecutorInput(immediateActions));
.actions(immediateActions)
.build();
actionExecutor.execute(actionExecutorInput);
actionScheduler.execute(scheduledActions); actionScheduler.execute(scheduledActions);
}); });
} }

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

@@ -1,16 +1,5 @@
package work.slhaf.partner.module.modules.action.dispatcher.executor.entity; package work.slhaf.partner.module.modules.action.dispatcher.executor.entity
import lombok.Builder; import work.slhaf.partner.core.action.entity.ActionData
import lombok.Data;
import work.slhaf.partner.core.action.entity.ActionData;
import java.util.Set; data class ActionExecutorInput(val actions: Set<ActionData>)
@Data
@Builder
public class ActionExecutorInput {
/**
* 将执行的行动数据列表
*/
private Set<? extends ActionData> actions;
}

5
Partner-Main/src/main/java/work/slhaf/partner/module/modules/action/dispatcher/scheduler/ActionScheduler.kt
View File

@@ -47,10 +47,7 @@ class ActionScheduler : AgentRunningSubModule<Set<ScheduledActionData>, Void>()
.map { actionData -> actionData as ScheduledActionData } .map { actionData -> actionData as ScheduledActionData }
.collect(Collectors.toSet()) .collect(Collectors.toSet())
timeWheel = TimeWheel(actions) { actionDataSet -> timeWheel = TimeWheel(actions) { actionDataSet ->
val input = ActionExecutorInput.builder() actionExecutor.execute(ActionExecutorInput(actionDataSet))
.actions(actionDataSet)
.build()
actionExecutor.execute(input)
} }
} }

4
Partner-Main/src/test/java/work/slhaf/partner/module/modules/action/dispatcher/executor/ActionExecutorTest.java
View File

@@ -369,9 +369,7 @@ class ActionExecutorTest {
} }
private ActionExecutorInput buildInput(String userId, ImmediateActionData actionData) { private ActionExecutorInput buildInput(String userId, ImmediateActionData actionData) {
return ActionExecutorInput.builder() return new ActionExecutorInput(Set.of(actionData));
.actions(Set.of(actionData))
.build();
} }
private ImmediateActionData buildActionData(Map<Integer, List<MetaAction>> actionChain) { private ImmediateActionData buildActionData(Map<Integer, List<MetaAction>> actionChain) {