夜得朦胧 1 vuosi sitten
vanhempi
commit
380752e8a0

+ 3 - 0
api-common/src/main/java/api/common/pojo/po/project/MultiSimulationProjectTaskRecordPO.java

@@ -29,4 +29,7 @@ public class MultiSimulationProjectTaskRecordPO implements Serializable {
 
     private Timestamp createTime;
     private Timestamp updateTime;
+
+    private Long startTime;
+    private Long endTime;
 }

+ 10 - 2
simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/infra/db/mysql/mapper/MultiSimulationProjectTaskRecordMapper.java

@@ -28,10 +28,18 @@ public interface MultiSimulationProjectTaskRecordMapper {
         "where id = #{taskId}")
     int updateMultiSimulationProjectTaskRecordStatus(@Param("status") Integer status, @Param("taskId") String taskId, @Param("deleted") Integer deleted);
 
-    @Select("select id,project_id as projectId,scene_id as sceneId,task_body as taskBody,status,sort from multi_simulation_project_task_record where project_id = #{projectId} and deleted = 0")
+    @Update("update multi_simulation_project_task_record set status = #{status},deleted = #{deleted},start_time = #{startTime} " +
+        "where id = #{taskId}")
+    int updateMultiSimulationProjectTaskRecordStatusAndStart(@Param("status") Integer status, @Param("taskId") String taskId, @Param("deleted") Integer deleted, @Param("startTime") Long startTime);
+
+    @Update("update multi_simulation_project_task_record set status = #{status},deleted = #{deleted},end_time = #{endTime} " +
+        "where id = #{taskId}")
+    int updateMultiSimulationProjectTaskRecordStatusAndEnd(@Param("status") Integer status, @Param("taskId") String taskId, @Param("deleted") Integer deleted, @Param("endTime") Long endTime);
+
+    @Select("select id,project_id as projectId,scene_id as sceneId,task_body as taskBody,status,sort,start_time as startTime,end_time as endTime from multi_simulation_project_task_record where project_id = #{projectId} and deleted = 0")
     List<MultiSimulationProjectTaskRecordPO> selectMultiSimulationProjectTaskRecordList(@Param("projectId") String projectId);
 
-    @Select("select id,project_id as projectId,scene_id as sceneId,task_body as taskBody,status,sort from multi_simulation_project_task_record where id = #{taskId} and deleted = 0")
+    @Select("select id,project_id as projectId,scene_id as sceneId,task_body as taskBody,status,sort,start_time as startTime,end_time as endTime from multi_simulation_project_task_record where id = #{taskId} and deleted = 0")
     MultiSimulationProjectTaskRecordPO selectMultiSimulationProjectTaskRecordById(@Param("taskId") String taskId);
 
     @Delete("delete from multi_simulation_project_task_record where project_id = #{projectId}")