代码完善

pom.xml

@@ -42,6 +42,11 @@
             <artifactId>postgresql</artifactId>
         </dependency>
         <dependency>
+            <groupId>com.gct.common.util</groupId>
+            <artifactId>common-util</artifactId>
+            <version>2.0-SNAPSHOT</version>
+        </dependency>
+        <dependency>
             <groupId>com.oracle</groupId>
             <artifactId>ojdbc6</artifactId>
             <version>11.2.0.4.0-atlassian-hosted</version>

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

@@ -1,5 +1,6 @@
 package com.gct.tools.etlcamelhuge.routeconfig;
 
+import com.gct.common.util.SGTUtil;
 import com.gct.tools.etlcamelhuge.MQ.MessageBody;
 import com.gct.tools.etlcamelhuge.MQ.MessageProducer;
 import com.gct.tools.etlcamelhuge.entity.DiagnoseMsg;
@@ -13,6 +14,7 @@ import org.springframework.context.annotation.Configuration;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
+import java.text.DecimalFormat;
 import java.text.SimpleDateFormat;
 import java.time.LocalDateTime;
 import java.util.*;
@@ -266,6 +268,23 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
         }
         return Arrays.stream(doubles).max().getAsDouble();
     }
+    /**
+     * 对位移数据除10
+     * **/
+    public String[] wy(String [] strings){
+        String[] ret= new String[strings.length];
+        for (int i = 0; i < strings.length; i++) {
+            Double aDouble = Double.valueOf(strings[i]);
+            //System.out.println("duo"+aDouble);
+            if (aDouble==0.0){
+                ret[i] = "0";
+            }else {
+                ret[i] = String.valueOf(Math.round(aDouble/10));
+            }
+        }
+        return ret;
+    }
+
     @Resource(name = "diagnoseMessageProducer")
     private MessageProducer producer;
     @Bean
@@ -287,7 +306,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                 from("timer:mytimer1?period=604800000")
                         .routeId("oracle-1")
                         .setHeader("date", constant(date1))
-                        .setBody(simple("select  distinct jh,cydmc,zyq,zk,qyrq,sccw,qk,bz from zd_zdgs.dba01@A2 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null "))
+                        .setBody(simple("select  distinct jh,cydmc,zyq,zk,qyrq,sccw,qk,bz from DBA01 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null "))
                         .to("jdbc:oracle")
                         .transform()
                         .body((result) -> {
@@ -324,7 +343,6 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                                 " ON conflict(well_id) DO UPDATE set remarks = '${body[BZ]}' "))
                         .to("jdbc:centralbase")
                         .end()
-
                         .transform().body((re) -> {
                     List<Map<String, Object>> rows = new ArrayList<>();
                     int code = 0;
@@ -372,8 +390,8 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                 from("timer:mytimer2?period=3600000")
                         .routeId("oracle-2")
                         .setHeader("date", constant(date1))
-                        .setBody(simple("select  distinct jh,rq,cyfs,yz,hysx , yysx ,tysx,bs,dym from zd_zdgs.dba01@A2 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null "))
-                        //.setBody(simple("select  distinct jh,rq,cyfs,yz,hysx , yysx ,tysx,bs,dym from zd_zdgs.dba01@A2 where rq  = to_date('2021-07-05','yyyy-MM-dd') and qyrq is not null "))
+                        .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 qyrq is not null "))
+                        //.setBody(simple("select  distinct jh,rq,cyfs,yz,hysx , yysx ,tysx,bs,dym from DBA01 where rq  = to_date('2021-07-05','yyyy-MM-dd') and qyrq is not null "))
                         .to("jdbc:oracle")
                         .split(body()).process(exchange -> {
                     Message in = exchange.getIn();
@@ -384,8 +402,8 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                     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)" +
-                                "values ('${body[JH]}','${body[RQ]}','${body[CYFS]}','${body[YZ]}','${body[HYSX]}','${body[YYSX]}','${body[TYSX]}','${body[BS]}')"))
+                        //.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)" +
+                         //       "values ('${body[JH]}','${body[RQ]}','${body[CYFS]}','${body[YZ]}','${body[HYSX]}','${body[YYSX]}','${body[TYSX]}','${body[BS]}')"))
                         .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]}' " +
                                 "where NOT EXISTS ( SELECT * FROM centralbase.cb_pc_pro_wellbore_status_daily WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}')"))
@@ -400,20 +418,42 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         .routeId("oracle-5")
                         .setHeader("date", constant(date1 + " 00:00:00"))
                         //三个月之内dym不为空的数据
-                        //.setBody(simple("SELECT distinct jh,rq,dym FROM zd_zdgs.dba01@A2 WHERE  rq between to_date(TO_CHAR(ADD_MONTHS(SYSDATE,-3),'yyyy-MM-dd'),'yyyy-MM-dd')and to_date(TO_CHAR(SYSDATE,'yyyy-MM-dd'),'yyyy-MM-dd') and dym is not null;"))
-                        .setBody(simple("SELECT  distinct jh,max(rq),dym FROM zd_zdgs.dba01@A2 WHERE dym is not null group by jh,dym"))
+                        //.setBody(simple("SELECT distinct jh,rq,dym FROM DBA01 WHERE  rq between to_date(TO_CHAR(ADD_MONTHS(SYSDATE,-3),'yyyy-MM-dd'),'yyyy-MM-dd')and to_date(TO_CHAR(SYSDATE,'yyyy-MM-dd'),'yyyy-MM-dd') and dym is not null;"))
+                            .setBody(simple("SELECT  distinct jh,max(rq),dym 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 start_pump_liq_level = '${body[DYM]}' where well_id = '${body[JH]}' "))
+                        .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}' "))
                         .to("jdbc:centralbase")
                         .log("insert !!!")
                         .end();
 
+                from("timer:mytimer7?period=3600000")
+                        .routeId("oracle-7")
+                        .setHeader("date", constant(date1 + " 00:00:00"))
+                        //三个月之内dym不为空的数据
+                        //.setBody(simple("SELECT distinct jh,rq,dym FROM DBA01 WHERE  rq between to_date(TO_CHAR(ADD_MONTHS(SYSDATE,-3),'yyyy-MM-dd'),'yyyy-MM-dd')and to_date(TO_CHAR(SYSDATE,'yyyy-MM-dd'),'yyyy-MM-dd') and dym is not null;"))
+                        .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}' "))
+                        .to("jdbc:centralbase")
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                            aRow.put("submergence_depth",null);
+                            if (aRow.get("start_pump_liq_level")!=null && aRow.get("pump_depth")!=null){
+                                double cmd= Double.valueOf(aRow.get("pump_depth").toString())-Double.valueOf(aRow.get("start_pump_liq_level").toString())/10;
+                                BigDecimal bd=new BigDecimal(cmd);
+                                double cmd1=bd.setScale(1,BigDecimal.ROUND_HALF_UP).doubleValue();
+                                aRow.put("submergence_depth",cmd1);
+                            }
+                })
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set submergence_depth = '${body[submergence_depth]}' where well_id = '${body[well_id]}' and prod_date  = '${body[prod_date]}'"))
+                        .to("jdbc:centralbase")
+                        .log("insert !!!")
+                        .end();
                 //单独执行时间30s
                 from("timer:mytimer3?period=3600000")
                         .routeId("oracle-3")
                         .setHeader("date", constant(date1))
-                        .setBody(simple("select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz from zd_zdgs.dba01@A2 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null "))
+                        .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 "))
                         .to("jdbc:oracle")
                         .split(body()).process(exchange -> {
                     Message in = exchange.getIn();
@@ -423,23 +463,63 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                     if (aRow.get("RCYL") == null) aRow.put("RCYL", "0.0");
                     if (aRow.get("RCQL") == null) aRow.put("RCQL", "0.0");
                     if (aRow.get("HS") == null) aRow.put("HS", "0.0");
-                    if (aRow.get("BZ") == null) aRow.put("DYM", "");
+                    if (aRow.get("BZ") == null) aRow.put("BZ", "");
+                    aRow.put("RCSL",-1);
+                    aRow.put("QYB",-1);
+                    aRow.put("SQB",-1);
+                    if (aRow.get("RCQL")!=null && aRow.get("RCYL")!=null && !aRow.get("RCYL").equals("0.0") && aRow.get("RCYL") != "0.0"){
+                        double qyb = Double.valueOf(aRow.get("RCQL").toString()) / Double.valueOf(aRow.get("RCYL").toString());
+                        if (!Double.isNaN(qyb) && !Double.isInfinite(qyb)){
+                            BigDecimal bd=new BigDecimal(qyb);
+                            double d1=bd.setScale(1,BigDecimal.ROUND_HALF_UP).doubleValue();
+                            aRow.put("QYB",d1);
+                        }
+                    }
+                    if (aRow.get("RCYL1")!=null && aRow.get("HS") != null && !aRow.get("HS").equals("0.0") && aRow.get("HS") != "0.0"){
+                        double rcsl = (Double.valueOf(aRow.get("RCYL1").toString()) * Double.valueOf(aRow.get("HS").toString()))/100;
+                        if (!Double.isNaN(rcsl) && !Double.isInfinite(rcsl)) {
+                            BigDecimal bd = new BigDecimal(rcsl);
+                            double d1 = bd.setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue();
+                            aRow.put("RCSL", d1);
+                        }
+                    }
+                    if (aRow.get("RCQL") != null && aRow.get("RCSL") != null && !aRow.get("RCQL").equals("0.0") && aRow.get("RCQL") != "0.0" ){
+                        double sqb = Double.valueOf(aRow.get("RCSL").toString()) / Double.valueOf(aRow.get("RCQL").toString());
+                        if (!Double.isNaN(sqb) && !Double.isInfinite(sqb)) {
+                            BigDecimal bd = new BigDecimal(sqb);
+                            double d1 = bd.setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue();
+                            aRow.put("SQB", d1);
+                        }
+                    }
+                    if (!aRow.containsKey("SMD")){
+                        aRow.put("SMD",1);
+                    }
+                    if (!aRow.containsKey("YMD")){
+                        aRow.put("YMD",0.85);
+                    }
                 })
-                        .setBody(simple("insert into centralbase.cb_pc_pro_wellbore_vol_daily(well_id,prod_date,prod_time,liq_prod_daily,oil_prod_daily,gas_prod_daily,water_cut,remarks) " +
-                                "values ('${body[JH]}','${body[RQ]}','${body[SCSJ]}','${body[RCYL1]}','${body[RCYL]}','${body[RCQL]}','${body[HS]}','${body[BZ]}')"))
-                        .setBody(simple("insert into centralbase.cb_pc_pro_wellbore_vol_daily(well_id,prod_date,prod_time,liq_prod_daily,oil_prod_daily,gas_prod_daily,water_cut,remarks) " +
-                                "select '${body[JH]}','${body[RQ]}','${body[SCSJ]}','${body[RCYL1]}','${body[RCYL]}','${body[RCQL]}','${body[HS]}','${body[BZ]}' " +
+                       // .setBody(simple("insert into centralbase.cb_pc_pro_wellbore_vol_daily(well_id,prod_date,prod_time,liq_prod_daily,oil_prod_daily,gas_prod_daily,water_cut,remarks) " +
+                        //        "values ('${body[JH]}','${body[RQ]}','${body[SCSJ]}','${body[RCYL1]}','${body[RCYL]}','${body[RCQL]}','${body[HS]}','${body[BZ]}')"))
+                        .setBody(simple("insert into centralbase.cb_pc_pro_wellbore_vol_daily(well_id,prod_date,prod_time,liq_prod_daily,oil_prod_daily,gas_prod_daily,water_cut,remarks,gas_oil_ratio,water_prod_daily,water_gas_ratio,surface_crude_water_density,surface_crude_oil_density) " +
+                                "select '${body[JH]}','${body[RQ]}','${body[SCSJ]}','${body[RCYL1]}','${body[RCYL]}','${body[RCQL]}','${body[HS]}','${body[BZ]}','${body[QYB]}','${body[RCSL]}','${body[SQB]}','${body[SMD]}','${body[YMD]}' " +
                                 "where NOT EXISTS ( SELECT * FROM centralbase.cb_pc_pro_wellbore_vol_daily WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}' )"))
                         .to("jdbc:centralbase")
-                        .log("insert !!!")
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_vol_daily set  water_prod_daily =null where water_prod_daily = -1 and prod_date = '${header.date}' "))
+                        .to("jdbc:centralbase")
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_vol_daily set  gas_oil_ratio =null where gas_oil_ratio = -1 and prod_date = '${header.date}' "))
+                        .to("jdbc:centralbase")
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_vol_daily set  water_gas_ratio =null where water_gas_ratio = -1 and prod_date = '${header.date}' "))
+                        .to("jdbc:centralbase")
+                        .log("insert")
                         .end();
 
+
                 //0 0 */1 * * ? 每1个小时执行一次
                 //单独执行一次30s
                 from("timer:mytimer4?period=3600000")
                         .routeId("oracle-4")
                         .setHeader("date", constant(date1))
-                        .setBody(simple("select distinct jh,rq,dym,jy,ly,bj,bs,bx,zs,cc,cs,blx,dl from zd_zdgs.dba01@A2 where rq  = to_date('${header.date}','yyyy-MM-dd') and qyrq is not null  "))
+                        .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();
@@ -455,8 +535,8 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                     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)" +
-                                "values ('${body[JH]}','${body[RQ]}','${body[JY]}','${body[LY]}','${body[BJ]}','${body[BS]}','${body[BX]}','${body[ZS]}','${body[CC]}','${body[CS]}','${body[BLX]}','${body[DL]}')"))
+                        //.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)" +
+                         //       "values ('${body[JH]}','${body[RQ]}','${body[JY]}','${body[LY]}','${body[BJ]}','${body[BS]}','${body[BX]}','${body[ZS]}','${body[CC]}','${body[CS]}','${body[BLX]}','${body[DL]}')"))
                         .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]}' )"))
@@ -468,8 +548,8 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         .routeId("oracle-6")
                         .setHeader("date", constant(date1 + " 00:00:00"))
                         //五个月之内bj不为空的数据
-                        //.setBody(simple("SELECT distinct jh,rq,dym FROM zd_zdgs.dba01@A2 WHERE  rq between to_date(TO_CHAR(ADD_MONTHS(SYSDATE,-3),'yyyy-MM-dd'),'yyyy-MM-dd')and to_date(TO_CHAR(SYSDATE,'yyyy-MM-dd'),'yyyy-MM-dd') and dym is not null;"))
-                        .setBody(simple("SELECT distinct jh,bj FROM zd_zdgs.dba01@A2 WHERE  rq between to_date(TO_CHAR(ADD_MONTHS(SYSDATE,-5),'yyyy-MM-dd'),'yyyy-MM-dd')and to_date(TO_CHAR(SYSDATE,'yyyy-MM-dd'),'yyyy-MM-dd') and bj is not null"))
+                        //.setBody(simple("SELECT distinct jh,rq,dym FROM DBA01 WHERE  rq between to_date(TO_CHAR(ADD_MONTHS(SYSDATE,-3),'yyyy-MM-dd'),'yyyy-MM-dd')and to_date(TO_CHAR(SYSDATE,'yyyy-MM-dd'),'yyyy-MM-dd') and dym is not null;"))
+                        .setBody(simple("SELECT distinct jh,bj FROM DBA01 WHERE  rq between to_date(TO_CHAR(ADD_MONTHS(SYSDATE,-5),'yyyy-MM-dd'),'yyyy-MM-dd')and to_date(TO_CHAR(SYSDATE,'yyyy-MM-dd'),'yyyy-MM-dd') and bj is not null"))
                         .to("jdbc:oracle")
                         .split(body())
                         .setBody(simple("update centralbase.cb_temp_well_mech_runtime set pump_diameter = '${body[BJ]}' where well_id = '${body[JH]}' "))
@@ -479,7 +559,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                 //从天安哪里获取的数据
                 //0 0 */1 * * ? 每1个小时执行一次
                 //单独执行一小时的数据30s
-                from("timer:mytimer7?period=3600000")
+                from("timer:mytimer8?period=3600000")
                         .routeId("jdbc-gtsj-?")
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
                         .to("jdbc:centralbase")
@@ -494,7 +574,8 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                     String prod_date = aRow.get("dyna_create_time").toString().split("\\+")[0];
                     aRow.put("dyna_create_time", prod_date);
                     if (aRow.get("displacement") != null && !aRow.get("displacement").equals("") && aRow.get("disp_load") != null && !aRow.get("disp_load").equals("")) {
-                        String[] displacements = aRow.get("displacement").toString().split(";");
+                        String[] displacements = aRow.get("displacement").toString().split(";");//10 四舍五入
+                        //String[] displacements = wy(displacementsOld);
                         String[] disp_loads = aRow.get("disp_load").toString().split(";");
                         Double susp_max_load = max(disp_loads);
                         Double susp_min_load = min(disp_loads);
@@ -507,7 +588,11 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         for (int i = 0; i < s.length; i++) {
                             w += new BigDecimal(Math.round(Double.parseDouble(s[i]) * 100)).stripTrailingZeros().toPlainString() + ",";
                         }
-                        aRow.put("sgt", w);
+                        Double[][] doubles = SGTUtil.encodeToDoubleArray(w);
+                        for (int i = 0;i<doubles.length;i++){
+                            doubles[i][0] = doubles[i][0] / 10;
+                        }
+                        aRow.put("sgt", SGTUtil.encodeToString(doubles));
                         aRow.put("susp_max_load",susp_max_load);
                         aRow.put("susp_min_load",susp_min_load);
                     }
@@ -515,20 +600,68 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                     if (aRow.get("frequency") == null) aRow.put("frequency", "0.0");
                     if (aRow.get("susp_max_load") == null) aRow.put("susp_max_load", "0.0");
                     if (aRow.get("susp_min_load") == null) aRow.put("susp_min_load", "0.0");
-
+                    if (aRow.get("frequency") != null){
+                        BigDecimal bd=new BigDecimal(aRow.get("frequency").toString());
+                        double frequency=bd.setScale(1,BigDecimal.ROUND_HALF_UP).doubleValue();
+                        aRow.put("frequency",frequency);
+                    }
+                    if (aRow.get("stroke") != null){
+                        double stroke1 = Double.parseDouble(aRow.get("stroke").toString())/10;
+                        BigDecimal bd=new BigDecimal(stroke1);
+                        double stroke=bd.setScale(1,BigDecimal.ROUND_HALF_UP).doubleValue();
+                        aRow.put("stroke",stroke);
+                    }
                 })
-                        .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) " +
-                                "values ('${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,stroke_length,stroke_frequency,susp_max_load,susp_min_load,sgt) " +
+                        //        "values ('${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,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]}' " +
                                 "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")
                         .log("insert!!!").end();
 
+                from("timer:mytimer9?period=3600000")
+                        .routeId("centralbase-2")
+                        .setHeader("date", constant(date1 + " 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\n" +
+                                "and cb.prod_date = '${header.date}' "))
+                        .to("jdbc:centralbase")//.log("${body}")
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                            aRow.putIfAbsent("pump_diameter", "0.0");
+                })
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set oil_nozzle = '${body[pump_diameter]}' where well_id ='${body[well_id]}' and prod_date='${body[prod_date]}' "))
+                        .to("jdbc:centralbase")
+                        .log("update success").end();
+
+                from("timer:mytimer10?period=3600000")
+                        .routeId("centralbase-3")
+                        .setHeader("date", constant(date1))
+                        .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"))
+                        .to("jdbc:centralbase")//.log("${body}")
+                        .split(body()).process(exchange -> {
+                    Message in = exchange.getIn();
+                    HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                    if (aRow.get("stroke_length")!=null && aRow.get("stroke_frequency")!=null){
+                        double stroke_length=Double.parseDouble(aRow.get("stroke_length").toString())/10;
+                        double stroke_frequency=Double.parseDouble(aRow.get("stroke_frequency").toString());
+                        BigDecimal bd=new BigDecimal(stroke_length);
+                        double stroke_lengt1=bd.setScale(1,BigDecimal.ROUND_HALF_UP).doubleValue();
+                        BigDecimal bd1=new BigDecimal(stroke_frequency);
+                        double stroke_frequency1=bd1.setScale(1,BigDecimal.ROUND_HALF_UP).doubleValue();
+                        aRow.put("strokeLength",stroke_lengt1);
+                        aRow.put("strokeFrequency",stroke_frequency1);
+                    }
+                })
+                        .setBody(simple("update centralbase.cb_temp_well_mech_daily set stroke_length='${body[strokeLength]}' ,stroke_frequency ='${body[strokeFrequency]}' where well_id = '${body[well_id]}' and prod_date::date='${header.date}' "))
+                        .to("jdbc:centralbase")
+                        .log("update success").end();
+
                 from("timer:mytimer1?period=3600000")
                         .routeId("centralbase-1")
-                        .setBody(simple("select so.well_id,so.well_common_name,so.org_id,ti.prod_date,ti.stroke_frequency,ti.stroke_length,ti.sgt from centralbase.cb_temp_well_mech_runtime ti, centralbase.cb_cd_well_source so where ti.well_id = so.well_id and ti.prod_date =(select max(prod_date) from centralbase.cb_temp_well_mech_runtime) "))
-                        //.setBody(simple("select so.well_id,so.well_common_name,so.org_id,ti.prod_date,ti.stroke_frequency,ti.stroke_length,ti.sgt from centralbase.cb_temp_well_mech_runtime ti, centralbase.cb_cd_well_source so where ti.well_id = so.well_id and ti.prod_date ='2021-07-12 10:25:00' and ti.well_id = '台24' limit 1 "))
+                        //.setBody(simple("select so.well_id,so.well_common_name,so.org_id,ti.prod_date,ti.stroke_frequency,ti.stroke_length,ti.sgt from centralbase.cb_temp_well_mech_runtime ti, centralbase.cb_cd_well_source so where ti.well_id = so.well_id and ti.prod_date =(select max(prod_date) from centralbase.cb_temp_well_mech_runtime) "))
+                        .setBody(simple("select so.well_id,so.well_common_name,so.org_id,ti.prod_date,ti.stroke_frequency,ti.stroke_length,ti.sgt from centralbase.cb_temp_well_mech_runtime ti, centralbase.cb_cd_well_source so where ti.well_id = so.well_id and ti.prod_date::date='2021-07-19' " ))
                         .to("jdbc:centralbase")
                         .split(body())
                         .process(exchange -> {

src/main/resources/application.yml

@@ -51,9 +51,9 @@ spring:
     ds3:
       ## Hikari连接池的设置 Hikari 时间单位都是毫秒
       type: com.zaxxer.hikari.HikariDataSource
-      jdbc-url: jdbc:oracle:thin:@10.72.181.234:1521:orcl
-      username: dhzdly
-      password: gctgct#831511
+      jdbc-url: jdbc:oracle:thin:@11.71.15.28:1521:oracycn2
+      username: ZD_FGD
+      password: ZJGSDDS#2014ZD
       driver-class-name: oracle.jdbc.driver.OracleDriver
       hikari:
         ## 连接池名字
@@ -70,28 +70,28 @@ spring:
         max-lifetime: 1800000
         ## 数据库连接超时时间,默认30秒，即30000
         connection-timeout: 30000
-    ds4:
-      ## Hikari连接池的设置 Hikari 时间单位都是毫秒
-      type: com.zaxxer.hikari.HikariDataSource
-      jdbc-url: jdbc:postgresql://11.72.187.11:5432/GTDATE
-      username: postgres
-      password: Postgres_2021#
-      driver-class-name: org.postgresql.Driver
-      hikari:
-        ## 连接池名字
-        pool-name: SystemHikariCP
-        ## 最小空闲连接数量
-        minimum-idle: 5
-        ## 空闲连接存活最大时间，默认600000（10分钟）
-        idle-timeout: 60000
-        ## 连接池最大连接数，默认是10
-        maximum-pool-size: 15
-        ## 此属性控制从池返回的连接的默认自动提交行为,默认值：true
-        auto-commit: true
-        ## 此属性控制池中连接的最长生命周期，值0表示无限生命周期，默认1800000即30分钟
-        max-lifetime: 1800000
-        ## 数据库连接超时时间,默认30秒，即30000
-        connection-timeout: 30000
+   ds4:
+     ## Hikari连接池的设置 Hikari 时间单位都是毫秒
+     type: com.zaxxer.hikari.HikariDataSource
+     jdbc-url: jdbc:postgresql://11.72.187.11:5432/GTDATE
+     username: postgres
+     password: Postgres_2021#
+     driver-class-name: org.postgresql.Driver
+     hikari:
+       ## 连接池名字
+       pool-name: SystemHikariCP
+       ## 最小空闲连接数量
+       minimum-idle: 5
+       ## 空闲连接存活最大时间，默认600000（10分钟）
+       idle-timeout: 60000
+       ## 连接池最大连接数，默认是10
+       maximum-pool-size: 15
+       ## 此属性控制从池返回的连接的默认自动提交行为,默认值：true
+       auto-commit: true
+       ## 此属性控制池中连接的最长生命周期，值0表示无限生命周期，默认1800000即30分钟
+       max-lifetime: 1800000
+       ## 数据库连接超时时间,默认30秒，即30000
+       connection-timeout: 30000
 
 management:
   info: