modify BJ update logic

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

@@ -77,11 +77,10 @@ public class BaseDataController {
                     sql = " update centralbase.cb_pc_pro_wellbore_status_daily set submergence_depth = '" + stringObjectMap.get("submergence_depth") + "' where well_id = '" + stringObjectMap.get("well_id") + "' and prod_date  = '" + stringObjectMap.get("prod_date") + "' ";
                     updateCMDCount = updateBaseDataSourceOfStatusDaily(sql) + updateCMDCount;
                 }
-                sql = " select distinct rn.well_id,cb.prod_date,rn.pump_diameter  from centralbase.cb_temp_well_mech_runtime rn ,centralbase.cb_pc_pro_wellbore_status_daily cb where cb.well_id = rn.well_id " +
-                        " and cb.prod_date = '" + date + "'  ";
+                sql = " SELECT  distinct jh,max(rq),bj FROM DBA01 WHERE dym is not null group by jh,dym ";
                 List<Map<String, Object>> oilNozzleList = selectBaseDataSourceStatusDaily(sql);
                 for (Map<String, Object> stringObjectMap : oilNozzleList) {
-                    sql = " update centralbase.cb_pc_pro_wellbore_status_daily set oil_nozzle = '" + stringObjectMap.get("pump_diameter") + "' where well_id ='" + stringObjectMap.get("well_id") + "' and prod_date='" + stringObjectMap.get("prod_date") + "' ";
+                    sql = " update centralbase.cb_pc_pro_wellbore_status_daily set oil_nozzle = '" + stringObjectMap.get("BJ") + "' where well_id ='" + stringObjectMap.get("JH") + "' and prod_date='" + stringObjectMap.get("RQ") + "' ";
                     updateOLiNozzleCount = updateBaseDataSourceOfStatusDaily(sql) + updateOLiNozzleCount;
                 }
                 insertCount++;

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

@@ -78,35 +78,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
         return new RouteBuilder() {
             @Override
             public void configure() throws Exception {
-                from("timer:mytimer-insert-mechDaily?period=3600000")
-                        .routeId("insert-mech_daily")
-                        .setHeader("date", constant(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 -> {
-                    Message in = exchange.getIn();
-                    HashMap<String, Object> aRow = in.getBody(HashMap.class);
-                    if (aRow.get("JY") == null) aRow.put("JY", "0.0");
-                    if (aRow.get("LY") == null) aRow.put("LY", "0.0");
-                    if (aRow.get("BJ") == null) aRow.put("BJ", "0.0");
-                    if (aRow.get("BS") == null) aRow.put("BS", "0.0");
-                    if (aRow.get("BX") == null) aRow.put("BX", "0.0");
-                    if (aRow.get("ZS") == null) aRow.put("ZS", "0.0");
-                    if (aRow.get("CC") == null) aRow.put("CC", "0.0");
-                    if (aRow.get("CS") == null) aRow.put("CS", "0.0");
-                    if (aRow.get("BLX") == null) aRow.put("BLX", "");
-                    if (aRow.get("DL") == null) aRow.put("DL", "0.0");
-                })
-                        .setBody(simple("insert into centralbase.cb_temp_well_mech_daily(well_id,prod_date,static_pressure,flow_pres,pump_diameter,pump_depth,pump_efficiency,rotate_frequency,stroke_length,stroke_frequency,pump_type,elec_frequency) " +
-                                "select '${body[JH]}','${body[RQ]}','${body[JY]}','${body[LY]}','${body[BJ]}','${body[BS]}','${body[BX]}','${body[ZS]}','${body[CC]}','${body[CS]}','${body[BLX]}','${body[DL]}' " +
-                                "where NOT EXISTS ( SELECT * FROM centralbase.cb_temp_well_mech_daily WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}' )"))
-                        .doTry()
-                        .to("jdbc:centralbase")
-                        .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:insert-mech_daily ->  centralbase.cb_temp_well_mech_daily insert data failed")
-                        .end();
-
-                from("timer:mytimer-update-runTime?period=3600000")
+                /*from("timer:mytimer-update-runTime?period=3600000")
                         .routeId("update-runTime")
                         .setHeader("date", constant(getDate() + " 00:00:00"))
                         .setBody(simple("SELECT  distinct jh,max(rq),bj FROM DBA01 WHERE dym is not null group by jh,bj"))
@@ -121,7 +93,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
                         .log("${header.date}"+" routeId:update-runTime -> centralbase.cb_temp_well_mech_runtime update data failed")
-                        .end();
+                        .end();*/
 
                 from("timer:mytimer-insert-runtimeAndSendToMQ?period=3600000")
                         .routeId("insert-runtimeAndSendToMQ")
@@ -189,7 +161,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
                         .log("${header.date}"+" routeId:insert-runtimeAndSendToMQ ->  centralbase.cb_temp_well_mech_runtime insert data failed ${body}")
                         .end();
 
-               from("timer:mytimer-update-avg-mech_daily?period=3600000")
+               from("timer:mytimer-update-avg-mech_daily?period=1800000")
                         .routeId("update-avg-mech_daily")
                         .setHeader("date", constant(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"))
@@ -214,6 +186,34 @@ public class CamelJDBCCofRealTimeConfiguration  {
                         .doCatch(Exception.class)
                         .log("${header.date}"+" routeId:update-avg-mech_daily ->  centralbase.cb_temp_well_mech_daily update data failed")
                         .end();
+
+                from("timer:mytimer-insert-mechDaily?period=3600000")
+                        .routeId("insert-mech_daily")
+                        .setHeader("date", constant(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 -> {
+                            Message in = exchange.getIn();
+                            HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                            if (aRow.get("JY") == null) aRow.put("JY", "0.0");
+                            if (aRow.get("LY") == null) aRow.put("LY", "0.0");
+                            if (aRow.get("BJ") == null) aRow.put("BJ", "0.0");
+                            if (aRow.get("BS") == null) aRow.put("BS", "0.0");
+                            if (aRow.get("BX") == null) aRow.put("BX", "0.0");
+                            if (aRow.get("ZS") == null) aRow.put("ZS", "0.0");
+                            if (aRow.get("CC") == null) aRow.put("CC", "0.0");
+                            if (aRow.get("CS") == null) aRow.put("CS", "0.0");
+                            if (aRow.get("BLX") == null) aRow.put("BLX", "");
+                            if (aRow.get("DL") == null) aRow.put("DL", "0.0");
+                        })
+                        .setBody(simple("insert into centralbase.cb_temp_well_mech_daily(well_id,prod_date,static_pressure,flow_pres,pump_diameter,pump_depth,pump_efficiency,rotate_frequency,stroke_length,stroke_frequency,pump_type,elec_frequency) " +
+                                "select '${body[JH]}','${body[RQ]}','${body[JY]}','${body[LY]}','${body[BJ]}','${body[BS]}','${body[BX]}','${body[ZS]}','${body[CC]}','${body[CS]}','${body[BLX]}','${body[DL]}' " +
+                                "where NOT EXISTS ( SELECT * FROM centralbase.cb_temp_well_mech_daily WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}' )"))
+                        .doTry()
+                        .to("jdbc:centralbase")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:insert-mech_daily ->  centralbase.cb_temp_well_mech_daily insert data failed")
+                        .end();
             };
         };
     }

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

@@ -172,7 +172,7 @@ public class CamelJDBCConfiguration {
                         .end();
 
 
-                from("timer:mytimer-update-statusDaily-DYM?period=3600000")
+                from("timer:mytimer-update-statusDaily-DYM?period=1800000")
                         .routeId("update-statusDaily-DYM")
                         .setHeader("date", constant(getDate() + " 00:00:00"))
                         .setBody(simple("SELECT  distinct jh,max(rq),dym FROM DBA01 WHERE dym is not null group by jh,dym"))
@@ -185,7 +185,20 @@ public class CamelJDBCConfiguration {
                         .log("${header.date}"+" routeId:update-statusDaily-DYM ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
                         .end();
 
-                from("timer:mytimer-update-statusDaily-submergenceDepth?period=3600000")
+                from("timer:mytimer-update-statusDaily-BJ?period=1800000")
+                        .routeId("update-statusDaily-DYM")
+                        .setHeader("date", constant(getDate() + " 00:00:00"))
+                        .setBody(simple("SELECT  distinct jh,max(rq),bj FROM DBA01 WHERE dym is not null group by jh,dym"))
+                        .to("jdbc:oracle")
+                        .split(body())
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set oil_nozzle = '${body[BJ]}' where well_id = '${body[JH]}' and prod_date::date  = '${header.date}' "))
+                        .doTry()
+                        .to("jdbc:centralbase")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:update-statusDaily-DYM ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
+                        .end();
+
+                from("timer:mytimer-update-statusDaily-submergenceDepth?period=1800000")
                         .routeId("update-statusDaily-submergenceDepth")
                         .setHeader("date", constant(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}' "))
@@ -209,7 +222,7 @@ public class CamelJDBCConfiguration {
                         .end();
 
 
-                from("timer:mytimer-update-statusDaily-oil_nozzle?period=3600000")
+              /*  from("timer:mytimer-update-statusDaily-oil_nozzle?period=1800000")
                         .routeId("update-statusDaily-oil_nozzle")
                         .setHeader("date", constant(getDate() + " 00:00:00"))
                         .setBody(simple("select distinct rn.well_id,cb.prod_date,rn.pump_diameter  from centralbase.cb_temp_well_mech_runtime rn ,centralbase.cb_pc_pro_wellbore_status_daily cb where cb.well_id = rn.well_id " +
@@ -225,7 +238,7 @@ public class CamelJDBCConfiguration {
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
                         .log("${header.date}"+" routeId:update-statusDaily-oil_nozzle ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
-                        .end();
+                        .end();*/
 
 
 
@@ -292,7 +305,7 @@ public class CamelJDBCConfiguration {
                         .to("jdbc:centralbase")
                         .end();
 
-                from("timer:mytimer-update-volDaily-liq_prod_daily?period=3600000")
+                from("timer:mytimer-update-volDaily-liq_prod_daily?period=1800000")
                         .routeId("update-volDaily-liq_prod_daily")
                         .setHeader("date", constant(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 "))