diff --git a/dinky-admin/src/main/java/org/dinky/context/ConsoleContextHolder.java b/dinky-admin/src/main/java/org/dinky/context/ConsoleContextHolder.java index b38aae76ca..f28f1e1990 100644 --- a/dinky-admin/src/main/java/org/dinky/context/ConsoleContextHolder.java +++ b/dinky-admin/src/main/java/org/dinky/context/ConsoleContextHolder.java @@ -165,11 +165,6 @@ public void registerProcess(ProcessType type, String processName) throws Runtime */ public ProcessStepEntity registerProcessStep(ProcessStepType type, String processName, String parentStepPid) throws RuntimeException { - if (!logPross.containsKey(processName)) { - throw new BusException(StrFormatter.format("Process {} does not exist", type)); - } - ProcessEntity process = logPross.get(processName); - process.setStatus(ProcessStatus.RUNNING); ProcessStepEntity processStepEntity = ProcessStepEntity.builder() .key(UUID.fastUUID().toString()) .status(ProcessStatus.RUNNING) @@ -180,6 +175,12 @@ public ProcessStepEntity registerProcessStep(ProcessStepType type, String proces .children(new CopyOnWriteArrayList<>()) .build(); + if (!logPross.containsKey(processName)) { + log.error(StrFormatter.format("Process {} does not exist", type)); + return processStepEntity; + } + ProcessEntity process = logPross.get(processName); + process.setStatus(ProcessStatus.RUNNING); if (TextUtils.isEmpty(parentStepPid)) { // parentStep为空表示为顶级节点 process.getChildren().add(processStepEntity); @@ -202,10 +203,10 @@ public ProcessStepEntity registerProcessStep(ProcessStepType type, String proces * @param e exception object, optional */ public void finishedProcess(String processName, ProcessStatus status, Throwable e) { - if (!logPross.containsKey(processName)) { + ProcessEntity process = logPross.remove(processName); + if (process == null) { return; } - ProcessEntity process = logPross.get(processName); process.setStatus(status); process.setEndTime(LocalDateTime.now()); process.setTime( @@ -219,7 +220,6 @@ public void finishedProcess(String processName, ProcessStatus status, Throwable } FileUtil.writeUtf8String(JSONObject.toJSONString(process), filePath); appendLog(processName, null, StrFormatter.format("Process {} exit with status:{}", processName, status), true); - logPross.remove(processName); } /** diff --git a/dinky-admin/src/main/java/org/dinky/controller/APIController.java b/dinky-admin/src/main/java/org/dinky/controller/APIController.java index eba78256ea..1d58b27cf5 100644 --- a/dinky-admin/src/main/java/org/dinky/controller/APIController.java +++ b/dinky-admin/src/main/java/org/dinky/controller/APIController.java @@ -47,7 +47,6 @@ import com.fasterxml.jackson.databind.node.ObjectNode; -import cn.dev33.satoken.annotation.SaCheckLogin; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiOperation; @@ -63,7 +62,6 @@ @Api(tags = "OpenAPI & Task API Controller") @RequestMapping("/openapi") @RequiredArgsConstructor -@SaCheckLogin public class APIController { private final TaskService taskService; diff --git a/docs/docs/user_guide/register_center/alert/alert_instance.md b/docs/docs/user_guide/register_center/alert/alert_instance.md index 671ffa5c97..8f3d2775f2 100644 --- a/docs/docs/user_guide/register_center/alert/alert_instance.md +++ b/docs/docs/user_guide/register_center/alert/alert_instance.md @@ -116,18 +116,19 @@ title: 告警实例 ### 邮箱 -| 字段 | 说明 | 是否必填 | 默认值 | 示例 | -|:---------:|:--------------------------:|:----:|:-----:|:--:| -| 邮箱地址 | 邮箱地址 | 是 | 无 | 无 | -| 邮件服务器Port | 邮件服务器端口 | 是 | 无 | 无 | -| 发送者昵称 | 发送者昵称 | 是 | 无 | 无 | -| 收件人邮箱 | 收件人邮箱 | 是 | 无 | 无 | -| 抄送人邮箱 | 抄送人邮箱 | 是 | 无 | 无 | -| 是否开启邮箱验证 | 是否开启邮箱验证 | 否 | false | 无 | -| 邮箱用户名 | 邮箱用户名 | 是 | 无 | 无 | -| 邮箱密码 | 邮箱密码 ,注意:部分邮箱需要自行获取授权码而非密码 | 是 | 无 | 无 | -| 开启tls证书 | 开启tls证书 | 否 | false | 无 | -| 开启SSL | 开启SSL证书 | 否 | false | 无 | +| 字段 | 说明 | 是否必填 | 默认值 | 示例 | +|:---------:|:-----------------------------:|:----:|:-----:|:------------:| +| 邮箱地址 | 邮箱地址 | 是 | 无 | 无 | +| 邮件服务器Port | 邮件服务器端口 | 是 | 无 | 无 | +| 发送者昵称 | 发送者昵称 | 是 | 无 | 无 | +| 收件人邮箱 | 收件人邮箱 | 是 | 无 | 无 | +| 抄送人邮箱 | 抄送人邮箱 | 是 | 无 | 无 | +| 是否开启邮箱验证 | 是否开启邮箱验证 | 否 | false | 无 | +| 邮箱用户名 | 邮箱用户名 | 是 | 无 | 无 | +| 邮箱密码 | 邮箱密码 ,注意:部分邮箱需要自行获取授权码而非密码 | 是 | 无 | 无 | +| 开启tls证书 | 开启tls证书 | 否 | false | 无 | +| 开启SSL | 开启SSL证书 | 否 | false | 无 | +| 受信任域 | 如果开启了SSL,必填(一半情况和邮箱服务器保持一致即可) | 是 | 无 | stmp.126.com | ### 短信