lijian 3 年之前
父节点
当前提交
903ac5dd3f
共有 1 个文件被更改,包括 5 次插入5 次删除
  1. 5 5
      src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelJDBCConfiguration.java

+ 5 - 5
src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelJDBCConfiguration.java

@@ -393,7 +393,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
393
 
393
 
394
 
394
 
395
                 //   A2数据
395
                 //   A2数据
396
-                from("timer:mytimer2?period=3600000")
396
+                from("timer:mytimer2?period=21600000")
397
                         .routeId("oracle-2")
397
                         .routeId("oracle-2")
398
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
398
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
399
                         .to("jdbc:centralbase")
399
                         .to("jdbc:centralbase")
@@ -430,7 +430,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
430
                         .end();
430
                         .end();
431
 
431
 
432
 
432
 
433
-                from("timer:mytimer3?period=3600000")
433
+                from("timer:mytimer3?period=21600000")
434
                         .routeId("oracle-3")
434
                         .routeId("oracle-3")
435
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
435
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
436
                         .to("jdbc:centralbase")
436
                         .to("jdbc:centralbase")
@@ -507,7 +507,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
507
                         .log("${header.date}"+" routeId:oracle-3->  centralbase.cb_pc_pro_wellbore_vol_daily update date faild")
507
                         .log("${header.date}"+" routeId:oracle-3->  centralbase.cb_pc_pro_wellbore_vol_daily update date faild")
508
                         .end();
508
                         .end();
509
 
509
 
510
-                from("timer:mytimer4?period=3600000")
510
+                from("timer:mytimer4?period=21600000")
511
                     .routeId("oracle-4")
511
                     .routeId("oracle-4")
512
                     .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
512
                     .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
513
                     .to("jdbc:centralbase")
513
                     .to("jdbc:centralbase")
@@ -657,7 +657,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
657
                         .end();
657
                         .end();
658
 
658
 
659
                 //稀稠油信息
659
                 //稀稠油信息
660
-               /* from("timer:mytimer9?period=3600000")
660
+                from("timer:mytimer9?period=3600000")
661
                         .routeId("oracle-9")
661
                         .routeId("oracle-9")
662
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
662
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
663
                         .to("jdbc:centralbase")
663
                         .to("jdbc:centralbase")
@@ -685,7 +685,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
685
                         .to("jdbc:centralbase")
685
                         .to("jdbc:centralbase")
686
                         .doCatch(Exception.class)
686
                         .doCatch(Exception.class)
687
                         .log("${header.date}"+" routeId:oracle-9->  centralbase.cb_pc_pro_wellbore_status_daily update date faild")
687
                         .log("${header.date}"+" routeId:oracle-9->  centralbase.cb_pc_pro_wellbore_status_daily update date faild")
688
-                        .end();*/
688
+                        .end();
689
 
689
 
690
 
690
 
691
                 from("timer:mytimer10?period=3600000")
691
                 from("timer:mytimer10?period=3600000")