车道指标相关计算逻辑

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());