车道指标相关计算逻辑

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

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

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

@@ -55,9 +55,9 @@ public class LaneNormSink  extends RichSinkFunction<List<LaneNorm>> {
         /**
          * 添加连接判断 防止jdbc 失效
          */
-        if(!DataSourceUtils.isDbConnected(connection)){
+       /* if(!DataSourceUtils.isDbConnected(connection)){
             connection=DorisUtils.getConnection();
-        }
+        }*/
         for (LaneNorm value: laneNorms){
             insertPstmt.setString(1, value.getCorssId());
             insertPstmt.setString(2, value.getLaneId());

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

@@ -15,7 +15,7 @@ public class DataSourceUtils {
     public static boolean isDbConnected(Connection con) {
         //final String CHECK_SQL_QUERY = "SELECT 1";
         try {
-            if(con != null && !con.isValid(1000)){
+            if(con != null && con.isValid(1000)){
                 return true;
             }
         } catch (SQLException e) {