灯态数据流

wj-realtime-computing/src/main/java/com/wanji/indicators/task/lightstatus/LaneCarHeadTimeProcessFunction.java

@@ -110,7 +110,8 @@ public class LaneCarHeadTimeProcessFunction extends KeyedProcessFunction<String,
                     Integer agoGreenTime = greenRemainTimeState.get(key);
                     //绿灯区间计算
                     if (agoCar != null && agoGreenTime != null) {
-                        if (agoGreenTime > 0){//有绿灯时长时监测是否有后车
+                        //有绿灯时长时监测是否有后车
+                        if (agoGreenTime > 0){
                             Integer agoTrackId = agoCar.getId();
                             Integer trackId = lastCar.getId();
                             //新的车辆驶出停止线