feat: 完成去抖动响应接口

taais-modules/taais-biz/src/main/java/com/taais/biz/constant/BizConstant.java

@@ -10,6 +10,7 @@ public class BizConstant {
         public static final String NOT_START = "0";
         public static final String RUNNING = "1";
         public static final String END = "2";
+        public static final String FAILED = "3";
     }
 
     public static final String TASK_FOLDER_PATH_HEAD = "/task/";

taais-modules/taais-biz/src/main/java/com/taais/biz/domain/bo/VideoStableStartResultBo.java

@@ -2,6 +2,7 @@ package com.taais.biz.domain.bo;
 
 import jakarta.validation.constraints.NotNull;
 import lombok.*;
+import net.bytebuddy.implementation.bind.annotation.Empty;
 
 /**
  * @Datetime : 2023/12/5 12:13
@@ -9,7 +10,6 @@ import lombok.*;
  * @Email : 1686617586@qq.com
  * @File : VideoStableStartResult.java
  * @Brief :
- * Copyright 2023 WANGKANG, All Rights Reserved.
  */
 
 @Builder
@@ -19,8 +19,8 @@ import lombok.*;
 @EqualsAndHashCode()
 public class VideoStableStartResultBo {
     @NotNull(message = "status不能为空")
-    private int status;
+    private String status;
     private String msg;
-    private String bizType;
-    private String bizId;
+    @NotNull(message = "id不能为空")
+    private String id;
 }

taais-modules/taais-biz/src/main/java/com/taais/biz/service/impl/VideoStableServiceImpl.java

@@ -6,6 +6,7 @@ import java.util.List;
 import cn.hutool.core.util.ObjectUtil;
 import com.mybatisflex.core.paginate.Page;
 import com.mybatisflex.core.query.QueryWrapper;
+import com.taais.biz.constant.BizConstant;
 import com.taais.biz.domain.bo.VideoStableStartBo;
 import com.taais.biz.domain.bo.VideoStableStartResultBo;
 import com.taais.common.core.core.domain.CommonResult;
@@ -172,6 +173,8 @@ public class VideoStableServiceImpl extends BaseServiceImpl<VideoStableMapper, V
         videoStable.setLklevel(videoStable.getLklevel());
         videoStable.setLkwinSiz(videoStable.getLkwinSiz());
 
+        videoStable.setStatus(BizConstant.VideoStatus.RUNNING);
+
         save(videoStable);
         System.out.println(videoStable.getId());
 
@@ -189,6 +192,8 @@ public class VideoStableServiceImpl extends BaseServiceImpl<VideoStableMapper, V
                 return CommonResult.success("start video_stable success");
             }
         } catch (Exception e) {
+            videoStable.setStatus(BizConstant.VideoStatus.FAILED);
+            updateById(videoStable);
             e.printStackTrace();
             return CommonResult.fail("start video_stable error -> " + e.getMessage());
         }
@@ -196,6 +201,13 @@ public class VideoStableServiceImpl extends BaseServiceImpl<VideoStableMapper, V
 
     @Override
     public CommonResult getResult(VideoStableStartResultBo videoStableStartResultBo) {
-        return null;
+        Long id = Long.valueOf(videoStableStartResultBo.getId());
+        String status = videoStableStartResultBo.getStatus();
+        String msg = videoStableStartResultBo.getMsg();
+        VideoStable videoStable = getById(id);
+        videoStable.setLog(msg);
+        videoStable.setStatus("200".equals(status) ? BizConstant.VideoStatus.END : BizConstant.VideoStatus.FAILED);
+        updateById(videoStable);
+        return CommonResult.success();
     }
 }