完成事件组合类

This commit is contained in:
彭宇琦 2020-12-31 20:11:03 +08:00
parent d59ab637a2
commit e40ba53b05
1 changed files with 102 additions and 9 deletions

View File

@ -5,6 +5,7 @@ import java.util.Arrays;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import java.util.function.Function;
import java.util.function.Predicate; import java.util.function.Predicate;
/** /**
@ -174,12 +175,7 @@ public class GroupEvent {
* @throws ParamException 原事件组名称未指定或事件组名称不存在时抛出的异常 * @throws ParamException 原事件组名称未指定或事件组名称不存在时抛出的异常
*/ */
public List<Optional<Object>> orderlyAction(String... eventNames) { public List<Optional<Object>> orderlyAction(String... eventNames) {
List<Optional<Object>> resultList = new ArrayList<>(); return orderlyAction(obj -> true, eventNames);
Arrays.stream(Optional.ofNullable(eventNames).filter(names -> names.length != 0)
.orElseThrow(() -> new ParamException("未指定事件名称组"))).map(this::getContinueResult)
.forEach(resultList::add);
return resultList;
} }
/** /**
@ -192,6 +188,11 @@ public class GroupEvent {
* @see #orderlyAction(String...) * @see #orderlyAction(String...)
*/ */
public List<Optional<Object>> orderlyAction(Predicate<Optional<Object>> predicate, String... eventNames) { public List<Optional<Object>> orderlyAction(Predicate<Optional<Object>> predicate, String... eventNames) {
// 对名称组进行判断
eventNames = Optional.ofNullable(eventNames).filter(names -> names.length != 0)
.orElseThrow(() -> new ParamException("未指定事件名称组"));
// 遍历所有事件组名称根据条件进行循环并存储执行结果
List<Optional<Object>> resultList = new ArrayList<>(); List<Optional<Object>> resultList = new ArrayList<>();
for (String name : eventNames) { for (String name : eventNames) {
// 获取相应的执行结果 // 获取相应的执行结果
@ -212,6 +213,7 @@ public class GroupEvent {
* <p> * <p>
* <b>注意</b>无论条件如何设置其事件组都会执行一次 * <b>注意</b>无论条件如何设置其事件组都会执行一次
* </p> * </p>
*
* @param predicate 继续执行条件其参数为上一次事件组执行的一组结果 * @param predicate 继续执行条件其参数为上一次事件组执行的一组结果
* @param eventNames 执行方法名称组 * @param eventNames 执行方法名称组
* @return 最后一次循环方法执行结果集合 * @return 最后一次循环方法执行结果集合
@ -227,6 +229,88 @@ public class GroupEvent {
return resultList; return resultList;
} }
/**
* 执行相应的事件组当事件组抛出指定的异常时则执行相应的事件组
*
* @param mustActionEventName 事件组名称
* @param exception 异常类对象
* @param exceptionActionEventName 产生异常时执行的事件组名称
* @return 产生异常时执行的事件组执行结果
*/
public Optional<Object> exceptionAction(String mustActionEventName, Class<? extends Exception> exceptionClass,
String exceptionActionEventName) {
HashMap<Class<? extends Exception>, String> exceptionMap = new HashMap<>(16);
exceptionMap.put(exceptionClass, exceptionActionEventName);
return exceptionAction(mustActionEventName, exceptionMap);
}
/**
* 执行相应的事件组当事件组抛出指定的异常时则执行相应的事件组使用该方法可指定多个异常并针对 不同的异常执行不同的事件组
* <p>
* <b>注意:</b>若执行事件组抛出的异常不在所传入的捕捉列表中则抛出该异常
* </p>
*
* @param mustActionEventName 事件组名称
* @param exceptionActionEventNameMap 异常类与产生相应异常时执行的事件组名称键值对
* @return 产生异常时执行的事件组执行结果
*/
public Optional<Object> exceptionAction(String mustActionEventName,
HashMap<Class<? extends Exception>, String> exceptionActionEventNameMap) {
try {
return action(mustActionEventName);
} catch (Exception e) {
// 获取异常类对应的执行方法并直接将其进行执行
Optional<Optional<Object>> result = Optional.ofNullable(exceptionActionEventNameMap.get(e.getClass()))
.map(this::action);
// 对执行后的结果进行返回若执行后仍为空对象则表示该异常不在捕捉范围内故再次将其抛出
if (result.isPresent()) {
return result.get();
} else {
throw e;
}
}
}
/**
* 用于执行事件组并将事件组的执行结果传入到下一个事件组中作为执行参数
* 直到执行完毕返回最后一个事件组处理的结果
* @param eventNames 一组事件组名称
* @return 最后一个事件组处理结果
*/
public Optional<Object> mapAction(String... eventNames) {
return mapAction(r -> r, eventNames);
}
/**
* 用于执行事件组并将事件组的执行结果经过预设的处理后传入到下一个事件组中作为执行参数
* 直到执行完毕返回最后一个事件组处理的结果
* <p>
* <b>注意</b>设置的处理方式对第一个事件组的方法传参不生效对最后一个事件组执行结果也不生效即不处理
* 第一个传入事件组的参数和最后一个事件组返回的结果
* </p>
* @param function 参数处理方式
* @param eventNames 一组事件组名称
* @return 最后一个事件组处理结果
*/
public Optional<Object> mapAction(Function<Object, Object> mapper, String... eventNames) {
//获取并遍历事件组
List<String> nameList = Arrays
.asList(Optional.ofNullable(eventNames).orElseThrow(() -> new ParamException("未指定事件名称组")));
Optional<Object> result = Optional.empty();
for (int index = 0; index < nameList.size(); index++) {
//执行事件组存储执行结果
result = action(nameList.get(index));
//若当前元素不是最后一个元素则对结果按照设置进行处理并写入到下一个要执行的事件组的参数中
if (index != nameList.size() - 1) {
eventMap.get(nameList.get(index + 1)).setParam(result.map(mapper));
}
}
return result;
}
/** /**
* 用于判断事件组名称是否存在 * 用于判断事件组名称是否存在
* *
@ -301,6 +385,15 @@ public class GroupEvent {
this.arg = arg; this.arg = arg;
} }
/**
* 用于设置方法的执行参数若设置该参数为非空时则调用带参的方法设置为空对象时则调用无参方法
*
* @param arg 方法执行参数
*/
public void setParam(Optional<Object> arg) {
this.arg = arg;
}
/** /**
* 用于执行指定的方法以Object类的封装类返回执行出参若事件组无出参则返回{@link Optional#empty()} * 用于执行指定的方法以Object类的封装类返回执行出参若事件组无出参则返回{@link Optional#empty()}
* *