fix: 策略执行器中先判断类型，再判断 supports 方法

1. 防止在各策略实现中，强转到自己的 context 类报错

Author: cadecode

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/strategy/AbstractStrategyExecutor.java

@@ -1,6 +1,7 @@
 package com.github.cadecode.uniboot.common.core.extension.strategy;
 
 import java.util.List;
+import java.util.Optional;
 
 /**
  * 策略执行器抽象类
@@ -10,5 +11,7 @@
  */
 public abstract class AbstractStrategyExecutor implements StrategyExecutor {
 
+    public abstract <S> Optional<S> selectService(Class<S> clazz, StrategyContext context);
+
     public abstract <S> List<S> selectServices(Class<S> clazz, StrategyContext context);
 }

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/strategy/StrategyExecutor.java

@@ -18,6 +18,6 @@ public interface StrategyExecutor {
 
     <R, S extends StrategyService> R submit(Class<S> clazz, StrategyContext context, Function<S, R> function);
 
-    <S extends StrategyService> List<Object> submitAll(Class<S> clazz, StrategyContext context, Function<S, Object> function);
+    <R, S extends StrategyService> List<R> submitAll(Class<S> clazz, StrategyContext context, Function<S, R> function);
 
 }

common/core/src/main/java/com/github/cadecode/uniboot/common/core/extension/strategy/StrategySelectorExecutor.java

@@ -8,6 +8,7 @@
 import org.springframework.stereotype.Component;
 
 import java.util.List;
+import java.util.Optional;
 import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.stream.Collectors;
@@ -35,9 +36,9 @@ public class StrategySelectorExecutor extends AbstractStrategyExecutor {
      */
     @Override
     public <S extends StrategyService> void execute(Class<S> clazz, StrategyContext context, Consumer<S> consumer) {
-        List<S> services = selectServices(clazz, context);
-        if (ObjUtil.isNotEmpty(services)) {
-            consumer.accept(services.get(0));
+        Optional<S> serviceOpt = selectService(clazz, context);
+        if (serviceOpt.isPresent()) {
+            consumer.accept(serviceOpt.get());
             return;
         }
         throw new ExtException("Strategy service not found");
@@ -70,9 +71,9 @@ public <S extends StrategyService> void executeAll(Class<S> clazz, StrategyConte
      */
     @Override
     public <R, S extends StrategyService> R submit(Class<S> clazz, StrategyContext context, Function<S, R> function) {
-        List<S> services = selectServices(clazz, context);
-        if (ObjUtil.isNotEmpty(services)) {
-            return function.apply(services.get(0));
+        Optional<S> serviceOpt = selectService(clazz, context);
+        if (serviceOpt.isPresent()) {
+            return function.apply(serviceOpt.get());
         }
         throw new ExtException("Strategy service not found");
     }
@@ -86,7 +87,7 @@ public <R, S extends StrategyService> R submit(Class<S> clazz, StrategyContext c
      * @return 返回值
      */
     @Override
-    public <S extends StrategyService> List<Object> submitAll(Class<S> clazz, StrategyContext context, Function<S, Object> function) {
+    public <R, S extends StrategyService> List<R> submitAll(Class<S> clazz, StrategyContext context, Function<S, R> function) {
         List<S> services = selectServices(clazz, context);
         if (ObjUtil.isNotEmpty(services)) {
             return services.stream()
@@ -96,12 +97,21 @@ public <S extends StrategyService> List<Object> submitAll(Class<S> clazz, Strate
         throw new ExtException("Strategy service not found");
     }
 
+    @SuppressWarnings("unchecked")
+    @Override
+    public <S> Optional<S> selectService(Class<S> clazz, StrategyContext context) {
+        return (Optional<S>) pluginRegistry.getPlugins()
+                .stream()
+                .filter(o -> clazz.isAssignableFrom(o.getClass()) && o.supports(context))
+                .findFirst();
+    }
+
     @SuppressWarnings("unchecked")
     @Override
     public <S> List<S> selectServices(Class<S> clazz, StrategyContext context) {
-        return (List<S>) pluginRegistry.getPluginsFor(context)
+        return (List<S>) pluginRegistry.getPlugins()
                 .stream()
-                .filter(o -> clazz.isAssignableFrom(o.getClass()))
+                .filter(o -> clazz.isAssignableFrom(o.getClass()) && o.supports(context))
                 .collect(Collectors.toList());
     }
 }