gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

Merge branch 'master' into dev_2.1.0

Browse Source 
# Conflicts:
#	pom.xml
This commit is contained in:
byteblogs168 2023-07-18 21:34:44 +08:00
commit 428793c209
4 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/enums/TaskTypeEnum.java
View File

@ -5,6 +5,8 @@ import com.aizuda.easy.retry.server.akka.ActorGenerator;
import lombok.AllArgsConstructor;
import lombok.Getter;
import java.util.function.Supplier;
/**
* @author www.byteblogs.com
* @date 2023-06-04
@ -13,9 +15,10 @@ import lombok.Getter;
@AllArgsConstructor
@Getter
public enum TaskTypeEnum {
RETRY(1, ActorGenerator.scanGroupActor()),
CALLBACK(2, ActorGenerator.scanCallbackGroupActor());
RETRY(1, ActorGenerator::scanGroupActor),
CALLBACK(2, ActorGenerator::scanCallbackGroupActor);
private final Integer type;
private final ActorRef actorRef;
private final Supplier<ActorRef> actorRef;
}

4
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/persistence/support/access/config/MybatisConfigAccess.java
View File

@ -69,6 +69,10 @@ public class MybatisConfigAccess extends AbstractConfigAccess {
LambdaQueryWrapper<SceneConfig> sceneConfigLambdaQueryWrapper = new LambdaQueryWrapper<SceneConfig>()
.eq(SceneConfig::getSceneName, groupName);
if (Objects.isNull(groupConfig)) {
return Collections.EMPTY_SET;
}
if (StatusEnum.YES.getStatus().equals(groupConfig.getGroupStatus())) {
sceneConfigLambdaQueryWrapper.eq(SceneConfig::getSceneStatus, StatusEnum.NO.getStatus());
}

2
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/DispatchService.java
View File

@ -134,7 +134,7 @@ public class DispatchService implements Lifecycle {
private ActorRef cacheActorRef(String groupName, TaskTypeEnum typeEnum) {
ActorRef scanActorRef = CacheGroupScanActor.get(groupName, typeEnum);
if (Objects.isNull(scanActorRef)) {
scanActorRef = typeEnum.getActorRef();
scanActorRef = typeEnum.getActorRef().get();
// 缓存扫描器actor
CacheGroupScanActor.put(groupName, typeEnum, scanActorRef);
}

3
easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/retry/RetryExecutor.java
View File

@ -40,6 +40,9 @@ public class RetryExecutor<V> {
for (FilterStrategy filterStrategy : filterStrategies) {
if (!filterStrategy.filter(retryContext)) {
log.warn("当前任务不满足执行条件. groupName:[{}] uniqueId:[{}], filter:[{}]",
retryContext.getRetryTask().getGroupName(),
retryContext.getRetryTask().getUniqueId(), filterStrategy.getClass().getName());
return false;
}
}