稳定版

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

@@ -100,7 +100,6 @@ public class CamelJDBCCofRealTimeConfiguration  {
                         .routeId("insert-runtime")
                         .setBody(simple("select max(prod_date)  from centralbase.cb_temp_well_mech_runtime "))
                         .to("jdbc:centralbase")
-                        .log("max(prod_date) ${body}")
                         .split(body())
                         .setHeader("date", simple("${body[max]}"))
                         .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.date}' "))
@@ -183,7 +182,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
 
                from("timer:mytimer-update-avg-mech_daily?period=3600000")
                         .routeId("update-avg-mech_daily")
-                       .split(body()).process(exchange -> {
+                       .process(exchange -> {
                            Message in = exchange.getIn();
                            in.setHeader("date",getDate());
                        })
@@ -212,7 +211,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
 
                 from("timer:mytimer-insert-mechDaily?period=3600000")
                         .routeId("insert-mech_daily")
-                        .split(body()).process(exchange -> {
+                        .process(exchange -> {
                             Message in = exchange.getIn();
                             in.setHeader("date",getDate());
                         })

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

@@ -151,7 +151,7 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-insert-statusDaily?period=3600000")
                         .routeId("insert-statusDaily")
-                        .split(body()).process(exchange -> {
+                        .process(exchange -> {
                             Message in = exchange.getIn();
                             in.setHeader("date",getDate());
                         })
@@ -178,7 +178,7 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-update-statusDaily-DYM?period=3600000")
                         .routeId("update-statusDaily-DYM")
-                        .split(body()).process(exchange -> {
+                        .process(exchange -> {
                             Message in = exchange.getIn();
                             in.setHeader("date",getDate());
                         })
@@ -194,7 +194,7 @@ public class CamelJDBCConfiguration {
                 //因为数据库有可能会查出多条数据,现在的做法时,在数据库中增加两个个字段,用来记录BJ和DYM 的更新时间 ,只有获取到的时间大于数据库中存储的时间时,才会更新,并且该字段也会更新
                 from("timer:mytimer-update-statusDaily-BJ?period=3600000")
                         .routeId("update-statusDaily-BJ")
-                        .split(body()).process(exchange -> {
+                        .process(exchange -> {
                             Message in = exchange.getIn();
                             in.setHeader("date",getDate());
                         })
@@ -212,7 +212,7 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-update-statusDaily-submergenceDepth?period=3600000")
                         .routeId("update-statusDaily-submergenceDepth")
-                        .split(body()).process(exchange -> {
+                        .process(exchange -> {
                             Message in = exchange.getIn();
                             in.setHeader("date",getDate()+" 00:00:00");
                         })
@@ -259,7 +259,7 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-insert-volDaily?period=3600000")
                         .routeId("insert-volDaily")
-                        .split(body()).process(exchange -> {
+                        .process(exchange -> {
                             Message in = exchange.getIn();
                             in.setHeader("date",getDate());
                         })
@@ -326,7 +326,7 @@ public class CamelJDBCConfiguration {
 
                 from("timer:mytimer-update-volDaily-liq_prod_daily?period=3600000")
                         .routeId("update-volDaily-liq_prod_daily")
-                        .split(body()).process(exchange -> {
+                        .process(exchange -> {
                             Message in = exchange.getIn();
                             in.setHeader("date",getDate());
                         })