diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/exec/ExecCallbackUnitActor.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/exec/ExecCallbackUnitActor.java index 61f19767..472a51ff 100644 --- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/exec/ExecCallbackUnitActor.java +++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/exec/ExecCallbackUnitActor.java @@ -77,12 +77,15 @@ public class ExecCallbackUnitActor extends AbstractActor { retryExecutor.call((Callable>) () -> { Result result = callClient(retryTask, serverNode); - if (StatusEnum.YES.getStatus() != result.getStatus() && StringUtils.isNotBlank(result.getMessage())) { - retryTaskLog.setMessage(result.getMessage()); - } else { - retryTaskLog.setMessage("调度成功"); + String message = "回调客户端成功"; + if (StatusEnum.YES.getStatus() != result.getStatus()) { + if (StringUtils.isNotBlank(result.getMessage())) { + message = result.getMessage(); + } else { + message = "回调客户端失败: 异常信息为空"; + } } - + retryTaskLog.setMessage(message); return result; }); if (context.hasException()) { diff --git a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/exec/ExecUnitActor.java b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/exec/ExecUnitActor.java index 2cb96fa2..cd7e540c 100644 --- a/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/exec/ExecUnitActor.java +++ b/easy-retry-server/src/main/java/com/aizuda/easy/retry/server/support/dispatch/actor/exec/ExecUnitActor.java @@ -73,18 +73,26 @@ public class ExecUnitActor extends AbstractActor { Result result = callClient(retryTask, serverNode); // 回调接口请求成功,处理返回值 - if (StatusEnum.YES.getStatus() != result.getStatus() && StringUtils.isNotBlank(result.getMessage())) { - retryTaskLog.setMessage(result.getMessage()); + if (StatusEnum.YES.getStatus() != result.getStatus()) { + if (StringUtils.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())) { - retryTaskLog.setMessage(String.valueOf(data.getExceptionMsg())); + if (StringUtils.isNotBlank(data.getExceptionMsg())) { + retryTaskLog.setMessage(data.getExceptionMsg()); + } else { + retryTaskLog.setMessage("客户端重试失败: 异常信息为空"); + } } else if (RetryResultStatusEnum.STOP.getStatus().equals(data.getStatusCode())) { retryTaskLog.setMessage("客户端主动停止任务"); } else { - retryTaskLog.setMessage("调度成功"); + retryTaskLog.setMessage("客户端执行成功"); } }