车道指标相关计算逻辑

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

@@ -399,6 +399,8 @@ public class LaneNormProcessFunction extends KeyedCoProcessFunction<String, Cycl
     public static void main(String[] args) {
         try {
             Connection connection = getConnection();
+            boolean dbConnected = DataSourceUtils.isDbConnected(connection);
+
             List<Map> dictResult = getDictResult(connection, "SELECT\n" +
                     "  a.ID id,\n" +
                     "  a.Direction direction,\n" +

realtime/hologram-streaming/src/main/java/com/zhht/irn/sink/GreenRadioSink.java

@@ -51,7 +51,7 @@ public class GreenRadioSink extends RichSinkFunction<Cycle> {
         /**
          * 添加连接判断 防止过长时间没写入数据导致的jdbc 失效
          */
-        if(!DataSourceUtils.isDbConnected(connection)){
+        if(DataSourceUtils.isDbConnected(connection)){
             connection=DorisUtils.getConnection();
         }
         insertCyclePstmt.setLong(1, cycle.getId());