车道指标相关计算逻辑

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

@@ -3,6 +3,7 @@ package com.zhht.irn.functions;
 import com.zhht.irn.entity.*;
 import com.zhht.irn.enums.EventType;
 import com.zhht.irn.utils.DateUtils;
+import com.zhht.irn.utils.DorisUtils;
 import com.zhht.irn.utils.MySQLUtils;
 import com.zhht.irn.utils.StringUtils;
 import org.apache.flink.api.common.state.*;
@@ -65,7 +66,7 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
                     "FROM tb_phase_movement a\n" +
                     "LEFT JOIN trafficflowdirection b\n" +
                     "  on a.TrafficFlowId = b.ID\n" +
-                    "LEFT JOIN dic_phase c\n" +
+                    "LEFT JOIN dim_dic_phase c\n" +
                     "  on a.PhaseId = c.ID"));
         }
         Cycle f1 = cycle;
@@ -456,7 +457,7 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
     }
 
     private static Connection getConnection() throws Exception {
-        Connection connection = MySQLUtils.getConnection("E:\\zhht\\ZHHT-IRN-BD-ANALYSIS\\realtime\\hologram-streaming\\src\\main\\resources\\mysql.properties");
+        Connection connection = DorisUtils.getConnection();
         return connection;
     }