tijiao

api-common/src/main/java/api/common/pojo/constants/ProjectConstants.java

@@ -11,6 +11,10 @@ public class ProjectConstants {
     //任务终止，kafka推送主题
     public static final String STOP_TASK_TOPIC = "stopProject";//   manualProject-stop
 
+    public static final String RUN_MULTI_TOPIC = "multiProject";
+
+    public static final String STOP_MULTI_TOPIC = "stopMultiProject";
+
     //自动任务运行开始
 //    public static final String AUTO_PROJECT = "autoProject";
 

api-common/src/main/java/api/common/pojo/param/project/MultiSimulationProjectKafkaParam.java

@@ -0,0 +1,18 @@
+package api.common.pojo.param.project;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.Accessors;
+
+import java.util.List;
+
+/**
+ * kafka让推送需要的参数
+ */
+@Getter
+@Setter
+@Accessors(chain = true)
+public class MultiSimulationProjectKafkaParam {
+    private String projectId;
+    private List<MultiSimulationSceneKafkaParam> kafkaParamList;
+}

api-common/src/main/java/api/common/pojo/param/project/MultiSimulationSceneCarKafkaParam.java

@@ -0,0 +1,15 @@
+package api.common.pojo.param.project;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.Accessors;
+
+/**
+ * kafka让推送需要的参数
+ */
+@Getter
+@Setter
+@Accessors(chain = true)
+public class MultiSimulationSceneCarKafkaParam {
+
+}

api-common/src/main/java/api/common/pojo/param/project/MultiSimulationSceneKafkaParam.java

@@ -0,0 +1,19 @@
+package api.common.pojo.param.project;
+
+import api.common.pojo.po.project.MultiSimulationScenePO;
+import api.common.pojo.vo.project.MultiSimulationSceneCarVO;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.Accessors;
+
+import java.util.List;
+
+/**
+ * kafka让推送需要的参数
+ */
+@Getter
+@Setter
+@Accessors(chain = true)
+public class MultiSimulationSceneKafkaParam extends MultiSimulationScenePO {
+    private List<MultiSimulationSceneCarVO> simulationSceneCarVOList;
+}