bug fix 并且将之前的一小时执行一次修改为3小时一次

src/main/java/com/gct/tools/etlcamelhuge/controller/BaseDataController.java

@@ -210,7 +210,9 @@ public class BaseDataController {
         JSONObject jsonObject = new JSONObject();
         jdbcTemplate = new JdbcTemplate(gtsjDataSource);
         try{
+            long st = System.currentTimeMillis();
             List<Map<String, Object>> list = jdbcTemplate.queryForList(baseDataBody.getSql());
+            jsonObject.put("cost",(System.currentTimeMillis()-st)+" ms");
             jsonObject.put("RunTimedata",list);
         }catch (Exception e){
             jsonObject.put("error",e.getMessage());

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

@@ -78,7 +78,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}' "))
+                        .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 "))
                         .to("jdbc:gtsj")
                         .process(exchange -> {
                             sendMsgRunTime = 0;
@@ -160,7 +160,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
                         .to("jdbc:centralbase")
                         .end();
 
-               from("timer:mytimer-update-avg-mech_daily?period=3600000")
+               from("timer:mytimer-update-avg-mech_daily?period=10800000")
                         .routeId("update-avg-mech_daily")
                        .process(exchange -> {
                            Message in = exchange.getIn();

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

@@ -187,26 +187,27 @@ public class CamelJDBCConfiguration {
                         .end();
 
 
-                RouteDefinition statusDaily= from("timer:mytimer-insert-statusDaily?period=3600000")
+                RouteDefinition statusDaily= from("timer:mytimer-insert-statusDaily?period=10800000")
                         .routeId("insert-statusDaily")
                         .process(exchange -> {
                             Message in = exchange.getIn();
                             in.setHeader("date",getDate());
                         });
                          setMyBody(statusDaily)
-                        .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 jh='${header.well_id}' and qyrq is not null "))
+                        .setBody(simple("select  distinct jh,rq,cyfs,yz,hysx ,bj, yysx ,tysx,bs,dym from DBA01 where rq  = to_date('${header.date}','yyyy-MM-dd') and jh='${header.well_id}' and qyrq is not null "))
                         .to("jdbc:oracle")
                         .split(body()).process(exchange -> {
                     Message in = exchange.getIn();
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
                     if (aRow.get("YZ") == null) aRow.put("YZ", "0.0");
+                    if (aRow.get("BJ") == null) aRow.put("BJ", "0.0");
                     if (aRow.get("HYSX") == null) aRow.put("HYSX", "0.0");
                     if (aRow.get("YYSX") == null) aRow.put("YYSX", "0.0");
                     if (aRow.get("TYSX") == null) aRow.put("TYSX", "0.0");
                     if (aRow.get("BS") == null) aRow.put("BS", "0.0");
                 })
                         .setBody(simple("insert into centralbase.cb_pc_pro_wellbore_status_daily(well_id,prod_date,oil_prod_method,oil_nozzle,back_pres,tubing_pres,casing_pres,pump_depth) " +
-                                "select '${body[JH]}','${body[RQ]}','${body[CYFS]}','${body[YZ]}','${body[HYSX]}','${body[YYSX]}','${body[TYSX]}','${body[BS]}' " +
+                                "select '${body[JH]}','${body[RQ]}','${body[CYFS]}','${body[BJ]}','${body[HYSX]}','${body[YYSX]}','${body[TYSX]}','${body[BS]}' " +
                                 "where NOT EXISTS ( SELECT * FROM centralbase.cb_pc_pro_wellbore_status_daily WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}')"))
                         .doTry()
                         .to("jdbc:centralbase")
@@ -215,7 +216,7 @@ public class CamelJDBCConfiguration {
                         .end();
 
 
-                RouteDefinition statusDailyDYM = from("timer:mytimer-update-statusDaily-DYM?period=3600000")
+                RouteDefinition statusDailyDYM = from("timer:mytimer-update-statusDaily-DYM?period=10800000")
                         .routeId("update-statusDaily-DYM")
                         .process(exchange -> {
                             Message in = exchange.getIn();
@@ -231,7 +232,7 @@ public class CamelJDBCConfiguration {
                         .doCatch(Exception.class)
                         .log("${header.date}"+" routeId:update-statusDaily-DYM ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
                         .end();
-                RouteDefinition statusDailyBJ = from("timer:mytimer-update-statusDaily-BJ?period=3600000")
+               /* RouteDefinition statusDailyBJ = from("timer:mytimer-update-statusDaily-BJ?period=3600000")
                         .routeId("update-statusDaily-BJ")
                         .process(exchange -> {
                             Message in = exchange.getIn();
@@ -248,9 +249,9 @@ public class CamelJDBCConfiguration {
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
                         .log("${header.date}"+" routeId:update-statusDaily-BJ ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
-                        .end();
+                        .end();*/
 
-                RouteDefinition submergenceDepth = from("timer:mytimer-update-statusDaily-submergenceDepth?period=3600000")
+                RouteDefinition submergenceDepth = from("timer:mytimer-update-statusDaily-submergenceDepth?period=10800000")
                         .routeId("update-statusDaily-submergenceDepth")
                         .process(exchange -> {
                             Message in = exchange.getIn();
@@ -277,7 +278,7 @@ public class CamelJDBCConfiguration {
                         .log("${header.date}"+" routeId:update-statusDaily-submergenceDepth ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
                         .end();
 
-                RouteDefinition volDaily = from("timer:mytimer-insert-volDaily?period=3600000")
+                RouteDefinition volDaily = from("timer:mytimer-insert-volDaily?period=10800000")
                         .routeId("insert-volDaily")
                         .process(exchange -> {
                             Message in = exchange.getIn();
@@ -345,7 +346,7 @@ public class CamelJDBCConfiguration {
                         .to("jdbc:centralbase")
                         .end();
 
-                RouteDefinition volDailyLiqProdDaily = from("timer:mytimer-update-volDaily-liq_prod_daily?period=3600000")
+                RouteDefinition volDailyLiqProdDaily = from("timer:mytimer-update-volDaily-liq_prod_daily?period=10800000")
                         .routeId("update-volDaily-liq_prod_daily")
                         .process(exchange -> {
                             Message in = exchange.getIn();