车道指标增加日志级别配置 方便现场调试程序

realtime/hologram-streaming/src/main/java/com/zhht/irn/functions/LaneNormProcessFunction.java

@@ -46,6 +46,8 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
     //每天的cycleOrder 不允许重复
     private MapState<String,String> dayCycle;
 
+    private String loggerLevel="info";
+
     @Override
     public void open(Configuration parameters) throws Exception {
         super.open(parameters);
@@ -89,6 +91,7 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
             if(connection==null){
                 connection=DorisUtils.getConnection();
             }
+            loggerLevel = applicationUtils.getLoggerLevel();
             //查询相位方向信息
             dict.put("phaseDirection", getDictResult(connection, "SELECT\n" +
                     "  a.ID id,\n" +
@@ -147,7 +150,7 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
         List<Map> positionNameList = dict.get("positionNameList").stream().filter(recode -> f1.getCrossCode().equals(recode.get("cross_id"))).collect(Collectors.toList());
         for (Map map : dictResult) {
             //根据车道字典计算车道指标
-            LaneNorm laneNorm = getLaneNorm(map, f1, carForLane, laneList);
+            LaneNorm laneNorm = getLaneNorm(map, f1, carForLane, laneList,loggerLevel);
             list.add(laneNorm);
             //交通流量为0得不参与计算
             if (laneNorm != null) {
@@ -393,7 +396,7 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
      * @param laneList 车道相关信息
      * @return
      */
-    private static LaneNorm getLaneNorm(Map map, Cycle cycle, Map<String, List<TravelEvent>> car, List<Map> laneList) {
+    private static LaneNorm getLaneNorm(Map map, Cycle cycle, Map<String, List<TravelEvent>> car, List<Map> laneList,String loggerLevel) {
         LaneNorm laneNorm = new LaneNorm();
         //车道属性 分别是车道编码 方向
         String lane_id = String.valueOf(map.get("lane_id"));
@@ -454,6 +457,9 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
         laneNorm.setSpotSpaceShare(d1 > 1d ? 1d : d1);
         //计算空间占有长度
         laneNorm.setSpotSpaceLength(maxQueueLength);
+        if("debug".equals(loggerLevel)){
+            System.out.println("车道指标信息->"+laneNorm.toString()+" 车道饱和度->"+saturation_flow_rate+" 有效绿灯时间为->"+effcetGreenTime[1]+" 周期有效绿灯时间->"+cycle.getDuration());
+        }
         return laneNorm;
     }
 

realtime/hologram-streaming/src/main/java/com/zhht/irn/utils/applicationUtils.java

+package com.zhht.irn.utils;
+
+import org.apache.flink.api.java.utils.ParameterTool;
+
+import java.io.InputStream;
+import java.sql.Connection;
+import java.sql.DriverManager;
+
+/**
+ * @Description:
+ * @Author ：Marinh
+ * @Param:
+ * @retrun:
+ * @Creat :2023-01-06-12:32
+ **/
+public class applicationUtils {
+    public static String getLoggerLevel() throws Exception {
+        InputStream inputStream = DorisUtils.class.getClassLoader().getResourceAsStream("application.properties");
+        ParameterTool tool = ParameterTool.fromPropertiesFile(inputStream);
+        // 根据路径的配置文件获取MySQL链接参数
+        String driver = tool.getRequired("log.info.level");
+        return driver;
+    }
+
+}

realtime/hologram-streaming/src/main/resources/application.properties

+log.info.level=debug