mlx

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/consumer/ProjectConsumer.java

@@ -103,7 +103,7 @@ public class ProjectConsumer {
         log.info("createTaskAndFixData() 接收到项目开始消息为：" + initialProjectJson);
         ProjectMessageDTO projectMessageDTO = JsonUtil.jsonToBean(initialProjectJson, ProjectMessageDTO.class);
         String projectId = projectMessageDTO.getProjectId();                // 手动执行项目 id 或 自动执行子项目 id
-        String modelType = projectMessageDTO.getModelType();                // 手动执行项目 id 或 自动执行子项目 id
+        String modelType = projectMessageDTO.getModelType();                // 模型类型，1 动力学模型 2 carsim模型
         String packageId = projectMessageDTO.getScenePackageId();           // 场景测试包 id
         String vehicleConfigId = projectMessageDTO.getVehicleConfigId();    // 模型配置 id
         String algorithmId = projectMessageDTO.getAlgorithmId();            // 模型配置 id

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/manager/TaskManager.java

@@ -116,6 +116,8 @@ public class TaskManager {
             taskTick(taskId); // 刷新一下心跳
             log.info("TaskManager--state 修改任务 " + taskId + " 的状态为 " + state + "，pod 名称为：" + podName);
             taskMapper.updateStateWithStartTime(taskId, state, TimeUtil.getNowForMysql());
+            // 插入证书使用数据
+
             return false;
         } else { // 结束的 pod 都直接删除，并判断项目是否完成
             // -------------------------------- 处理状态 --------------------------------