修改冲程冲次为A2的

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

@@ -50,7 +50,7 @@ public class CamelInsertA2Configuration {
                         .split(body()).process(exchange -> {
                             Message in = exchange.getIn();
                             HashMap<String, Object> aRow = in.getBody(HashMap.class);
-                            aRow.putIfAbsent("liq_prod_daily", "0.0");
+                            //aRow.putIfAbsent("liq_prod_daily", null);
                             Timestamp timestamp = (Timestamp) aRow.get("prod_date");
                             Instant instant = Instant.ofEpochMilli(timestamp.getTime());
                             LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault());

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

@@ -158,8 +158,8 @@ public class CamelJDBCCofRealTimeConfiguration  {
                             in.setHeader("well_id",wellId);
                             sendDataToRocketMQ(wellName,wellId,prodDate,strokeLength,strokeFrequency,sgt);
                         })
-                        .setBody(simple("insert into centralbase.cb_temp_well_mech_runtime(well_id,prod_date,stroke_length,stroke_frequency,susp_max_load,susp_min_load,sgt) " +
-                                "select '${body[well_name]}','${body[dyna_create_time]}','${body[stroke]}','${body[frequency]}','${body[susp_max_load]}','${body[susp_min_load]}','${body[sgt]}' " +
+                        .setBody(simple("insert into centralbase.cb_temp_well_mech_runtime(well_id,prod_date,susp_max_load,susp_min_load,sgt) " +
+                                "select '${body[well_name]}','${body[dyna_create_time]}','${body[susp_max_load]}','${body[susp_min_load]}','${body[sgt]}' " +
                                 "where NOT EXISTS (SELECT * FROM centralbase.cb_temp_well_mech_runtime WHERE well_id = '${body[well_name]}' and  prod_date = '${body[dyna_create_time]}' )"))
                         .to("jdbc:centralbase")
                         .setBody(simple("update centralbase.sys_access_well_control set sgt_last_time = '${header.sgt_last_time}' where well_id ='${header.well_id}' "))

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

@@ -389,6 +389,25 @@ public class CamelJDBCConfiguration {
                         .doCatch(Exception.class)
                         .log("${header.date}"+" routeId:update-volDaily-liq_prod_daily ->  centralbase.cb_pc_pro_wellbore_vol_daily update data failed")
                         .end();
+
+                RouteDefinition runTime = from("timer:mytimer-update-runTime-strokeAndFrequency?period=10800000")
+                        .routeId("update-runTime-strokeAndFrequency")
+                        .process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate());
+                        });
+                        setMyBody(runTime)
+                        .setBody(simple("select distinct  jh,rq,cc,cs 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())
+                        .setBody(simple("insert into centralbase.cb_temp_well_mech_runtime(well_id,prod_date,stroke_length,stroke_frequency)" +
+                                "select '${body[JH]}','${body[RQ]}','${body[CC]}','${body[CS]}'" +
+                                "where NOT EXISTS (SELECT * FROM centralbase.cb_temp_well_mech_runtime WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}' )"))
+                        .doTry()
+                        .to("jdbc:centralbase")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:update-runTime-strokeAndFrequency ->  centralbase.cb_temp_well_mech_runtime update data failed")
+                        .end();
             };
         };