refactor(ActionCore): simplify handleInterventions to use ActionData

This commit is contained in:
2026-02-06 20:41:08 +08:00
parent 277c0d437f
commit 12df938d85
2 changed files with 3 additions and 15 deletions

View File

@@ -51,5 +51,5 @@ public interface ActionCapability {
RunnerClient runnerClient(); RunnerClient runnerClient();
<T> void handleInterventions(List<MetaIntervention> interventions, T data); void handleInterventions(List<MetaIntervention> interventions, ActionData data);
} }

View File

@@ -19,10 +19,7 @@ import work.slhaf.partner.module.modules.action.interventor.entity.MetaIntervent
import java.io.IOException; import java.io.IOException;
import java.util.*; import java.util.*;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.*;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Phaser;
import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantLock;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@@ -263,17 +260,8 @@ public class ActionCore extends PartnerCore<ActionCore> {
} }
@CapabilityMethod @CapabilityMethod
public <T> void handleInterventions(List<MetaIntervention> interventions, T data) { public void handleInterventions(List<MetaIntervention> interventions, ActionData actionData) {
// 加载数据 // 加载数据
Phaser phaser = null;
ActionData actionData = switch (data) {
case PhaserRecord record -> {
phaser = record.phaser();
yield record.actionData();
}
case ActionData tempData -> tempData;
default -> null;
};
if (actionData == null) { if (actionData == null) {
return; return;
} }