mlx

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/mapper/TaskMapper.java

@@ -54,4 +54,9 @@ public interface TaskMapper {
             "values (#{task.id},#{task.pId},#{task.sceneId},#{task.sceneName},#{task.sceneType},#{task.runState},\n" +
             "#{task.runResult},#{task.createTime},#{task.createUserId},#{task.modifyTime},#{modifyUserId},#{task.isDeleted})")
     void insert(@RequestParam("task") TaskPO task);
+
+    @Select("select run_state\n" +
+            "from simulation_manual_project_task\n" +
+            "where id = #{id}")
+    String selectStateById(@Param("id") String id);
 }

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/service/TaskService.java

@@ -102,8 +102,8 @@ public class TaskService {
 
 
     public Boolean taskConfirm(String taskId) {
-        // 将 taskId 存储到 redis，并刷新过期时间
-//        commonService.set(new RedisParameter(taskId,));
+        // 查询 task 如果不是 pending 则不执行
+        String state = taskMapper.selectStateById(taskId);
         return null;
     }