|
@@ -68,9 +68,11 @@ public class ManualProjectConsumer {
|
|
|
System.out.println("------- 消费成功:" + projectRecord.value());
|
|
|
}
|
|
|
|
|
|
- @KafkaListener(groupId = "simulation-resource-scheduler", topics = "${scheduler.manual-project.topic}")
|
|
|
- public void parseProject(ConsumerRecord<String, String> projectRecord) throws IOException, ApiException {
|
|
|
- System.out.println("------- 接收到消息为:" + projectRecord);
|
|
|
+// @KafkaListener(groupId = "simulation-resource-scheduler", topics = "${scheduler.manual-project.topic}")
|
|
|
+// public void parseProject(ConsumerRecord<String, String> projectRecord) throws IOException, ApiException {
|
|
|
+ public void parseProject(String projectJson) throws IOException, ApiException {
|
|
|
+// System.out.println("------- 接收到消息为:" + projectRecord);
|
|
|
+ System.out.println("------- 接收到消息为:" + projectJson);
|
|
|
//1 读取 kafka 的 project 信息
|
|
|
/*
|
|
|
{
|
|
@@ -82,10 +84,10 @@ public class ManualProjectConsumer {
|
|
|
"parallelism": 30 // 并行度
|
|
|
}
|
|
|
*/
|
|
|
- String projectJson = projectRecord.value();
|
|
|
+// String projectJson = projectRecord.value();
|
|
|
ProjectMessageDTO projectMessageDTO = JsonUtil.jsonToBean(projectJson, ProjectMessageDTO.class);
|
|
|
String projectId = projectMessageDTO.getProjectId(); // 项目 id
|
|
|
- projectMapper.updateProjectState(projectId, "2"); // 修改该 project 的状态为执行中
|
|
|
+ projectMapper.updateProjectState(projectId, "20"); // 修改该 project 的状态为执行中
|
|
|
|
|
|
|
|
|
// -------------------------------- 1 场景 --------------------------------
|