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

feat(3.2.0): 删除无用代码

Browse Source
This commit is contained in:
byteblogs168 2024-04-07 14:49:27 +08:00
parent 543946f214
commit 26e8d3caf1
2 changed files with 1 additions and 53 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
easy-retry-server/easy-retry-server-retry-task/src/main/java/com/aizuda/easy/retry/server/retry/task/support/dispatch/actor/exec/ExecCallbackUnitActor.java
View File

@ -67,34 +67,15 @@ public class ExecCallbackUnitActor extends AbstractActor {
if (Objects.nonNull(serverNode)) {
retryExecutor.call((Callable<Result<Void>>) () -> {
Result<Void> result = callClient(retryTask, serverNode, sceneConfig);
String message = "回调客户端成功";
if (StatusEnum.YES.getStatus() != result.getStatus()) {
if (StrUtil.isNotBlank(result.getMessage())) {
message = result.getMessage();
} else {
message = "回调客户端失败: 异常信息为空";
}
}
// retryTaskLog.setMessage(message);
return result;
});
if (context.hasException()) {
// retryTaskLog.setMessage(context.getException().getMessage());
}
} else {
// retryTaskLog.setMessage("There are currently no available client PODs.");
}
} catch (Exception e) {
RetryLogMetaDTO retryLogMetaDTO = RetryTaskConverter.INSTANCE.toLogMetaDTO(retryTask);
retryLogMetaDTO.setTimestamp(DateUtils.toNowMilli());
EasyRetryLog.REMOTE.error("请求客户端异常. <|>{}<|>", retryTask.getUniqueId(), retryLogMetaDTO, e);// retryTaskLog.setMessage(StringUtils.isBlank(e.getMessage()) ? StrUtil.EMPTY : e.getMessage());
EasyRetryLog.REMOTE.error("请求客户端异常. <|>{}<|>", retryTask.getUniqueId(), retryLogMetaDTO, e);
} finally {
// ActorRef actorRef = ActorGenerator.logActor();
// actorRef.tell(retryTaskLog, actorRef);
getContext().stop(getSelf());
}

33
easy-retry-server/easy-retry-server-retry-task/src/main/java/com/aizuda/easy/retry/server/retry/task/support/dispatch/actor/exec/ExecUnitActor.java
View File

@ -50,10 +50,6 @@ public class ExecUnitActor extends AbstractActor {
RegisterNodeInfo serverNode = context.getServerNode();
SceneConfig sceneConfig = context.getSceneConfig();
// RetryTaskLogDTO retryTaskLog = RetryTaskLogConverter.INSTANCE.toRetryTaskLogDTO(retryTask);
// retryTaskLog.setTriggerTime(LocalDateTime.now());
// retryTaskLog.setClientInfo(ClientInfoUtils.generate(serverNode));
try {
if (Objects.nonNull(serverNode)) {
@ -61,42 +57,16 @@ public class ExecUnitActor extends AbstractActor {
retryExecutor.call((Callable<Result<DispatchRetryResultDTO>>) () -> {
Result<DispatchRetryResultDTO> result = callClient(retryTask, serverNode, sceneConfig);
// 回调接口请求成功，处理返回值
if (StatusEnum.YES.getStatus() != result.getStatus()) {
if (StrUtil.isNotBlank(result.getMessage())) {
// retryTaskLog.setMessage(result.getMessage());
} else {
// retryTaskLog.setMessage("客户端执行失败: 异常信息为空");
}
} else {
DispatchRetryResultDTO data = JsonUtil.parseObject(JsonUtil.toJsonString(result.getData()), DispatchRetryResultDTO.class);
result.setData(data);
if (Objects.nonNull(data)) {
if (RetryResultStatusEnum.FAILURE.getStatus().equals(data.getStatusCode())) {
if (StrUtil.isNotBlank(data.getExceptionMsg())) {
// retryTaskLog.setMessage(data.getExceptionMsg());
} else {
// retryTaskLog.setMessage("客户端重试失败: 异常信息为空");
}
} else if (RetryResultStatusEnum.STOP.getStatus().equals(data.getStatusCode())) {
// retryTaskLog.setMessage("客户端主动停止任务");
} else {
// retryTaskLog.setMessage("客户端执行成功");
}
}
}
return result;
});
// 请求发生异常
if (context.hasException()) {
// retryTaskLog.setMessage(context.getException().getMessage());
}
} else {
// retryTaskLog.setMessage("There are currently no available client PODs.");
}
} catch (Exception e) {
@ -104,9 +74,6 @@ public class ExecUnitActor extends AbstractActor {
retryLogMetaDTO.setTimestamp(DateUtils.toNowMilli());
EasyRetryLog.REMOTE.error("请求客户端异常. <|>{}<|>", retryTask.getUniqueId(), retryLogMetaDTO, e);
} finally {
// ActorRef actorRef = ActorGenerator.logActor();
// actorRef.tell(retryTaskLog, actorRef);
getContext().stop(getSelf());
}