mlx

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

@@ -263,6 +263,11 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
         return new ResponseBodyVO(ResponseBodyVO.Response.SERVER_FAILURE, "删除失败。");
     }
 
+    /**
+     * 手动运行项目状态吸怪
+     * @param param
+     * @return
+     */
     @SneakyThrows
     @Override
     public ResponseBodyVO updateProjectNowRunState(SimulationManualProjectParam param) {
@@ -270,14 +275,12 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
         if (isEmpty(param.getId()) || isEmpty(param.getNowRunState())) {
             return new ResponseBodyVO(ResponseBodyVO.Response.CLIENT_FAILURE);
         }
-
         SimulationManualProjectPo po = simulationProjectMapper.selectProjectById(param);
-
         if (po == null) {
             return new ResponseBodyVO(ResponseBodyVO.Response.SERVER_FAILURE, "数据没有找到。");
         }
 
-        //已经完成的项目再次运行
+        // 已经完成的项目再次运行
         if ("30".equals(po.getNowRunState()) && "20".equals(param.getNowRunState())) {
             po.createPo(AuthUtil.getCurrentUserId());
             //生成id
@@ -314,15 +317,11 @@ public class SimulationProjectServiceImpl implements SimulationProjectService {
             }
 
         }
-
         //项目终止，推送到kafka
         if (DictConstants.PROJECT_TERMINATED.equals(param.getNowRunState())) {
             projectStopToKafka(po);
         }
-
-
         return new ResponseBodyVO(ResponseBodyVO.Response.SUCCESS);
-
     }
 
     private void projectRunToKafka(SimulationManualProjectPo po) throws JsonProcessingException {