标准化测试

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/infrastructure/persistence/mysql/mapper/ManualProjectMapper.java

@@ -23,6 +23,7 @@ public interface ManualProjectMapper {
     @Select("select id,\n" +
             "       scene,\n" +
             "       create_user_id,\n" +
+            "       parallelism,\n" +
             "       is_choice_gpu,\n" +
             "       '1' project_type,\n" +
             "       max_simulation_time\n" +

simulation-resource-server/src/main/java/com/css/simulation/resource/project/service/impl/SimulationProjectServiceImpl.java

@@ -299,15 +299,19 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
                 String projectDetailsVOJson = JsonUtil.beanToJson(projectDetailsVO);
                 newProjectPO.setDetails(projectDetailsVOJson);
                 simulationProjectMapper.add(newProjectPO);
+                projectRunToKafka(newProjectPO);
             } else if (DictConstants.PROJECT_TERMINATED.equals(oldState)) { //重新运行被终止的项目需要修改新的ID
                 // 如果是重新运行的项目，修改项目ID
                 String newProjectId = StringUtil.getRandomUUID();
+                oldProjectPO.setProjectId(newProjectId);
                 String projectDetailsVOJson = JsonUtil.beanToJson(projectDetailsVO);
                 simulationProjectMapper.updateIdAndDetailsAndNowRunStateById(oldProjectId, newProjectId, projectDetailsVOJson, DictConstants.PROJECT_RUNNING);
+                projectRunToKafka(oldProjectPO);
             } else { // 启动已保存的新项目
                 log.info("启动已保存的新项目");
+                projectRunToKafka(oldProjectPO);
             }
-            projectRunToKafka(oldProjectPO);
+
         }
         return new ResponseBodyVO<>(ResponseBodyVO.Response.SUCCESS);
     }