查询功图数据的sql修改

src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelJDBCCofRealTimeConfiguration.java

@@ -80,7 +80,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
                             exchange.getIn().setHeader("well_id",body.get("well_id"));
                             exchange.getIn().setHeader("sgt_last_time",body.get("sgt_last_time"));
                         })
-                        .setBody(simple("select distinct well_name,dyna_create_time,check_date,displacement,disp_load,stroke,frequency,susp_max_load,susp_min_load from public.pc_fd_pumpjack_dyna_dia_t where   dyna_create_time >= '${header.sgt_last_time}' and well_name='${header.well_id}' limit 50 "))
+                        .setBody(simple("select distinct well_name,dyna_create_time,check_date,displacement,disp_load,stroke,frequency,susp_max_load,susp_min_load from public.pc_fd_pumpjack_dyna_dia_t where   well_name='${header.well_id}' and  dyna_create_time >= '${header.sgt_last_time}' and dzt =1 limit 50 "))
                         .to("jdbc:gtsj")
                         .process(exchange -> {
                             sendMsgRunTime = 0;