Merge branch 'DataLinkDC:dev' into dev

gaoyan1998 · Apr 18, 2024 · 5b9822e · 5b9822e
2 parents 956e5f8 + 7b08828
commit 5b9822e
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 22 deletions.
diff --git 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
@@ -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
@@ -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 |
 
 ### 短信