[update] 交通大脑-统计数据优化转向数据

wj-realtime-computing/src/main/java/com/wanji/indicators/task/citybrainreceive/lanestatistics/LaneStatisticsReceive2LaneDataMap.java

@@ -34,8 +34,7 @@ public class LaneStatisticsReceive2LaneDataMap implements MapFunction<String, St
             if (StringUtils.isNotBlank(headers) && (headers.contains(Constant.WAN_JI_NAME) || StringUtils.isBlank(body))) {
                 return null;
             }
-            List<LaneStatisticsDataVO> laneStatisticsDataVOS = mapper.readValue(body, new TypeReference<List<LaneStatisticsDataVO>>() {
-            });
+            List<LaneStatisticsDataVO> laneStatisticsDataVOS = mapper.readValue(body, new TypeReference<List<LaneStatisticsDataVO>>() {});
             if (!CollectionUtils.isEmpty(laneStatisticsDataVOS)) {
                 for (LaneStatisticsDataVO inVo : laneStatisticsDataVOS) {
                     String crossId = inVo.getDeviceNo();

wj-realtime-computing/src/main/java/com/wanji/indicators/task/citybrainreceive/lanestatistics/LaneStatisticsReceive2TurnDataMap.java

@@ -34,8 +34,7 @@ public class LaneStatisticsReceive2TurnDataMap implements MapFunction<String, St
             if (StringUtils.isNotBlank(headers) && (headers.contains(Constant.WAN_JI_NAME) || StringUtils.isBlank(body))) {
                 return null;
             }
-            List<LaneStatisticsDataVO> laneStatisticsDataVOS = mapper.readValue(body, new TypeReference<List<LaneStatisticsDataVO>>() {
-            });
+            List<LaneStatisticsDataVO> laneStatisticsDataVOS = mapper.readValue(body, new TypeReference<List<LaneStatisticsDataVO>>() {});
             if (!CollectionUtils.isEmpty(laneStatisticsDataVOS)) {
                 for (LaneStatisticsDataVO inVo : laneStatisticsDataVOS) {
                     String crossId = inVo.getDeviceNo();

wj-realtime-computing/src/main/java/com/wanji/indicators/task/citybrainreceive/lanestatistics/LaneStatisticsReceiveMain.java

@@ -48,8 +48,8 @@ public class LaneStatisticsReceiveMain {
                     "city-brain-spillover-receive-data-source");
 
             dealLaneRealTimeData(statisticsStream, env);
-            // 车道数据中不能处理转向，暂不处理
-            //dealTurnRealTimeData(statisticsStream);
+            // 车道数据中不能处理转向，暂不处理 数据不匹配
+            dealTurnRealTimeData(statisticsStream);
             dealDirRealTimeData(statisticsStream);
             dealCrossRealTimeData(env, statisticsStream, spilloverStream);