修改第二天日数据不会获取bug

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

@@ -183,7 +183,10 @@ public class CamelJDBCCofRealTimeConfiguration  {
 
                from("timer:mytimer-update-avg-mech_daily?period=3600000")
                         .routeId("update-avg-mech_daily")
-                        .setHeader("date", constant(getDate()))
+                       .split(body()).process(exchange -> {
+                           Message in = exchange.getIn();
+                           in.setHeader("date",getDate());
+                       })
                         .setBody(simple("select well_id,avg(stroke_length) stroke_length  ,avg(stroke_frequency) stroke_frequency from centralbase.cb_temp_well_mech_runtime where prod_date::date='${header.date}' group by well_id"))
                         .to("jdbc:centralbase")
                         .split(body()).process(exchange -> {
@@ -209,7 +212,10 @@ public class CamelJDBCCofRealTimeConfiguration  {
 
                 from("timer:mytimer-insert-mechDaily?period=3600000")
                         .routeId("insert-mech_daily")
-                        .setHeader("date", constant(getDate()))
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate());
+                        })
                         .setBody(simple("select distinct jh,rq,dym,jy,ly,bj,bs,bx,zs,cc,cs,blx,dl from DBA01 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null  "))
                         .to("jdbc:oracle")
                         .split(body()).process(exchange -> {

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

@@ -151,7 +151,10 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-insert-statusDaily?period=3600000")
                         .routeId("insert-statusDaily")
-                        .setHeader("date", constant(getDate()))
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate());
+                        })
                         .setBody(simple("select  distinct jh,rq,cyfs,yz,hysx , yysx ,tysx,bs,dym from DBA01 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null "))
                         .to("jdbc:oracle")
                         .split(body()).process(exchange -> {
@@ -175,7 +178,10 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-update-statusDaily-DYM?period=3600000")
                         .routeId("update-statusDaily-DYM")
-                        .setHeader("date", constant(getDate()))
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate());
+                        })
                         .setBody(simple("select distinct jh , rq , dym from DBA01 where  (jh,rq) in (SELECT  jh,max(rq) rq  FROM DBA01 WHERE dym is not null and rq<= to_date('${header.date}','yyyy-MM-dd') group by jh)"))
                         .to("jdbc:oracle")
                         .split(body())
@@ -188,7 +194,10 @@ public class CamelJDBCConfiguration {
                 //因为数据库有可能会查出多条数据,现在的做法时,在数据库中增加两个个字段,用来记录BJ和DYM 的更新时间 ,只有获取到的时间大于数据库中存储的时间时,才会更新,并且该字段也会更新
                 from("timer:mytimer-update-statusDaily-BJ?period=3600000")
                         .routeId("update-statusDaily-BJ")
-                        .setHeader("date", constant(getDate()))
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate());
+                        })
                         .setBody(simple("select distinct jh , rq , bj from DBA01 where  (jh,rq) in (SELECT  jh,max(rq) rq  FROM DBA01 WHERE bj is not null and rq<= to_date('${header.date}','yyyy-MM-dd') group by jh)"))
                         .to("jdbc:oracle")
                         .split(body()).process(exchange -> {
@@ -203,7 +212,10 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-update-statusDaily-submergenceDepth?period=3600000")
                         .routeId("update-statusDaily-submergenceDepth")
-                        .setHeader("date", constant(getDate() + " 00:00:00"))
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate()+" 00:00:00");
+                        })
                         .setBody(simple("select well_id,prod_date,start_pump_liq_level,pump_depth from centralbase.cb_pc_pro_wellbore_status_daily where prod_date = '${header.date}' "))
                         .to("jdbc:centralbase")
                         .split(body()).process(exchange -> {
@@ -247,7 +259,10 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-insert-volDaily?period=3600000")
                         .routeId("insert-volDaily")
-                        .setHeader("date", constant(getDate()))
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate());
+                        })
                         .setBody(simple("select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz from DBA01 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null "))
                         .to("jdbc:oracle")
                         .split(body()).process(exchange -> {
@@ -311,7 +326,10 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-update-volDaily-liq_prod_daily?period=3600000")
                         .routeId("update-volDaily-liq_prod_daily")
-                        .setHeader("date", constant(getDate()))
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate());
+                        })
                         .setBody(simple("select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz from DBA01 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null "))
                         .to("jdbc:oracle")
                         .split(body()).process(exchange -> {