[update] 绿波优化停止数据处理

wj-datacenter-service/src/main/java/net/wanji/datacenter/kafka/GreenBeltDataConsumerHandler.java

@@ -28,7 +28,7 @@ public class GreenBeltDataConsumerHandler implements KafkaListenerErrorHandler {
     private GreenBeltInfoService greenBeltInfoService;
 
 
-    @KafkaListener(topics = {"${kafka-consumer.greenBeltInfoDataTopic}"}, groupId = "group-blet-new ")
+    @KafkaListener(topics = {"${kafka-consumer.greenBeltInfoDataTopic}"}, groupId = "group ")
     public void receiveGreenBeltInfoData(ConsumerRecord<Object, Object> record, Acknowledgment acknowledgment) throws Exception {
         try {
             String message = String.valueOf(record.value());

wj-datacenter-service/src/main/java/net/wanji/datacenter/service/impl/GreenBeltInfoServiceImpl.java

@@ -202,6 +202,19 @@ public class GreenBeltInfoServiceImpl implements GreenBeltInfoService {
     public GreenBeltOptInfoVO convertData(String message) throws Exception {
         ObjectMapper mapper = JacksonUtils.getInstance();
         GreenBeltKafkaDTO kafkaDTO = mapper.readValue(message, GreenBeltKafkaDTO.class);
+        if (Objects.equals(-1, kafkaDTO.getControlMethod())) {
+            GreenBeltOptInfoVO greenBeltOptInfoVO = new GreenBeltOptInfoVO();
+            greenBeltOptInfoVO.setGreenId(kafkaDTO.getGreenbeltId());
+            greenBeltOptInfoVO.setLength(kafkaDTO.getGreenbeltLength());
+            greenBeltOptInfoVO.setCycle(kafkaDTO.getMaxCycle());
+            greenBeltOptInfoVO.setControlTime(kafkaDTO.getControlTime());
+            greenBeltOptInfoVO.setControlDuration(kafkaDTO.getControlDuration());
+            greenBeltOptInfoVO.setType(kafkaDTO.getGreenbeltType());
+            greenBeltOptInfoVO.setDynamic(kafkaDTO.getDynamic());
+            greenBeltOptInfoVO.setControlMethod(kafkaDTO.getControlMethod());
+            greenBeltOptInfoVO.setDirGreenDetails(null);
+            return greenBeltOptInfoVO;
+        }
         // 正反绿波容器
         List<GreenBeltOptInfoVO.DirGreenDetail> dirGreenDetails = new ArrayList<>();
         // 构建正向绿波