bj,dym 重复导入不是最新问题解决-3

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

@@ -58,7 +58,7 @@ public class BaseDataController {
                 sql = "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) " +
                         "values (?,?,?,?,?,?,?,?)";
                 insertCount = insertBaseDataSourceOfStatusDaily(sql, map);
-                sql = "select jh , rq , dym from centralbase.cb_pc_pro_wellbore_status_daily where  (jh,rq) in (SELECT  jh,max(rq) rq  FROM DBA01 WHERE dym is not null and to_date('"+date+"','yyyy-MM-dd') group by jh)";
+                sql = "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('"+date+"','yyyy-MM-dd') group by jh)";
                 List<Map<String, Object>> dymIsNotNUllList = selectA2DataOfNotIsNullDYMOrBJ(sql);
                 for (Map<String, Object> stringObjectMap : dymIsNotNUllList) {
                     sql = "update centralbase.cb_pc_pro_wellbore_status_daily set start_pump_liq_level = '" + stringObjectMap.get("DYM") + "' where well_id = '" + stringObjectMap.get("JH") + "' and prod_date::date  = '" + stringObjectMap.get("RQ") + "' ";
@@ -78,7 +78,7 @@ 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 jh , rq , bj from centralbase.cb_pc_pro_wellbore_status_daily where  (jh,rq) in (SELECT  jh,max(rq) rq  FROM DBA01 WHERE bj is not null and to_date('"+date+"','yyyy-MM-dd') group by jh)";
+                sql = "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('"+date+"','yyyy-MM-dd') group by jh)";
                 List<Map<String, Object>> oilNozzleList = selectA2DataOfNotIsNullDYMOrBJ(sql);
                 for (Map<String, Object> stringObjectMap : oilNozzleList) {
                     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") + "' ";

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

@@ -95,9 +95,9 @@ public class CamelJDBCCofRealTimeConfiguration  {
                         .log("${header.date}"+" routeId:update-runTime -> centralbase.cb_temp_well_mech_runtime update data failed")
                         .end();*/
 
-                from("timer:mytimer-insert-runtimeAndSendToMQ?period=3600000")
+                from("timer:mytimer-insert-runtimeAndSendToMQ?period=1800000")
                         .routeId("insert-runtimeAndSendToMQ")
-                        .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
+                        .setBody(simple("select max(prod_date)  from centralbase.cb_temp_well_mech_runtime "))
                         .to("jdbc:centralbase")
                         .split(body())
                         .setHeader("date", simple("${body[max]}"))
@@ -105,7 +105,7 @@ public class CamelJDBCCofRealTimeConfiguration  {
                         .doTry()
                         .to("jdbc:gtsj")
                         .doCatch(Exception.class)
-                        .log("${deader.date}" + " routeId:insert-runtimeAndSendToMQ -> select runTime data failed")
+                        .log("${header.date}" + " routeId:insert-runtimeAndSendToMQ -> select runTime data failed")
                         .process(exchange -> {
                             sendMsgRunTime = 0;
                         })

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

@@ -175,7 +175,7 @@ public class CamelJDBCConfiguration {
                 from("timer:mytimer-update-statusDaily-DYM?period=3600000")
                         .routeId("update-statusDaily-DYM")
                         .setHeader("date", constant(getDate()))
-                        .setBody(simple("select jh , rq , dym from centralbase.cb_pc_pro_wellbore_status_daily where  (jh,rq) in (SELECT  jh,max(rq) rq  FROM DBA01 WHERE dym is not null and to_date('${header.date}','yyyy-MM-dd') group by jh)"))
+                        .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())
                         .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set start_pump_liq_level = '${body[DYM]}'  where well_id = '${body[JH]}' and prod_date::date  = '${header.date}' "))
@@ -188,7 +188,7 @@ public class CamelJDBCConfiguration {
                 from("timer:mytimer-update-statusDaily-BJ?period=3600000")
                         .routeId("update-statusDaily-BJ")
                         .setHeader("date", constant(getDate()))
-                        .setBody(simple("select jh , rq , bj from centralbase.cb_pc_pro_wellbore_status_daily where  (jh,rq) in (SELECT  jh,max(rq) rq  FROM DBA01 WHERE bj is not null and to_date('${header.date}','yyyy-MM-dd') group by jh)"))
+                        .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 -> {
                             HashMap body = exchange.getIn().getBody(HashMap.class);
@@ -307,7 +307,7 @@ public class CamelJDBCConfiguration {
                         .to("jdbc:centralbase")
                         .end();
 
-                from("timer:mytimer-update-volDaily-liq_prod_daily?period=1800000")
+                from("timer:mytimer-update-volDaily-liq_prod_daily?period=3600000")
                         .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 "))