save

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

@@ -7,8 +7,6 @@ import org.apache.camel.model.ExpressionNode;
 import org.apache.camel.model.ProcessorDefinition;
 import org.apache.camel.model.RouteDefinition;
 import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.util.StringUtils;
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
@@ -27,30 +25,32 @@ import java.util.*;
 public class CamelJDBCConfiguration {
 
 
-    public String getDate(){
-        return  LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+    public String getDate() {
+        return LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
     }
+
     @Bean
     public RouteBuilder routeBuilderWithOracle1() {
         return new RouteBuilder() {
             private SortedSet<String> organization;
-            private Map<String, Integer>  orgIDs = new HashMap<>();
+            private Map<String, Integer> orgIDs = new HashMap<>();
             private int orgID;
             private Map<Object, Object> orgIdPreList;
             private Integer org;
 
-            public ProcessorDefinition<ExpressionNode> setMyBody(RouteDefinition route){
-             return  route.setBody(simple("select well_id from centralbase.sys_access_well_control  where  access_status='1'  "))
+            public ProcessorDefinition<ExpressionNode> setSysControlBody(RouteDefinition route) {
+                return route.setBody(simple("select well_id from centralbase.sys_access_well_control  where  access_status='1'  "))
                         .to("jdbc:centralbase")
                         .split(body()).process(exchange -> {
                             HashMap body = exchange.getIn().getBody(HashMap.class);
-                            exchange.getIn().setHeader("well_id",body.get("well_id"));
+                            exchange.getIn().setHeader("well_id", body.get("well_id"));
                         });
             }
+
             @Override
             public void configure() throws Exception {
 
-                RouteDefinition OrgAndWellSource= (RouteDefinition) from("timer:insert-OrgAndWellSource?period=86400000")
+                /*RouteDefinition OrgAndWellSource= (RouteDefinition) from("timer:insert-OrgAndWellSource?period=86400000")
                         .routeId("insert-OrgAndWellSource")
                         .setHeader("date", constant(getDate()+" 00:00:00"))
                         .process(exchange -> {
@@ -156,7 +156,7 @@ public class CamelJDBCConfiguration {
                   .to("jdbc:centralbase")
                   .doCatch(Exception.class)
                   .log("${header.date}"+" routeId:insert-OrgAndWellSource->  centralbase.cb_pc_organization insert data failed")
-                  .end();
+                  .end();*/
 
                 from("timer:update-wellControl?period=3600000")
                         .routeId("update-wellControl")
@@ -173,17 +173,17 @@ public class CamelJDBCConfiguration {
                             String yesterday = LocalDateTime.now().minusDays(1).format(df);
                             body.put("yesterday", yesterday);
                             if (body.get("well_common_name") == null || body.get("well_common_name").equals("")) {
-                                body.put("remarks","暂无井信息");
-                                body.put("error_id",0);
-                                body.put("updateTime",format);
-                            }else if (body.get("org_id") == null || body.get("org_id").equals("")){
-                                body.put("remarks","暂无机构信息");
-                                body.put("error_id",0);
-                                body.put("updateTime",format);
-                            }else {
-                                body.put("remarks","");
-                                body.put("error_id",1);
-                                body.put("updateTime",format);
+                                body.put("remarks", "暂无井信息");
+                                body.put("error_id", 0);
+                                body.put("updateTime", format);
+                            } else if (body.get("org_id") == null || body.get("org_id").equals("")) {
+                                body.put("remarks", "暂无机构信息");
+                                body.put("error_id", 0);
+                                body.put("updateTime", format);
+                            } else {
+                                body.put("remarks", "");
+                                body.put("error_id", 1);
+                                body.put("updateTime", format);
                             }
 
                         })
@@ -196,139 +196,198 @@ public class CamelJDBCConfiguration {
                         .to("jdbc:centralbase")
                         .end();
 
-
-                RouteDefinition statusDaily= from("timer:mytimer-insert-statusDaily?period=10800000")
+                RouteDefinition statusDaily = from("timer:mytimer-insert-statusDaily?period=10800000")
                         .routeId("insert-statusDaily")
                         .process(exchange -> {
                             Message in = exchange.getIn();
-                            in.setHeader("date",getDate());
+                            in.setHeader("date", getDate());
                         });
-                         setMyBody(statusDaily)
-                        .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 "))
+                setSysControlBody(statusDaily)
+                        .setBody(simple("select  distinct WELL_ID,PROD_DATE,OIL_PRODUCTION_METHOD ,BACK_PRES,MAX_TUBING_PRES,MIN_TUBING_PRES,CASING_PRES" +
+                                " from ZY_DXGW.PC_PRO_COM_DAILY " +
+                                "where prod_date  = to_date('${header.date}','yyyy-MM-dd') and well_id ='${header.well_id}'"))
                         .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[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]}')"))
+                            Message in = exchange.getIn();
+                            HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                            aRow.putIfAbsent("OIL_NOZZLE", "0.0");
+                            aRow.putIfAbsent("BACK_PRES", "0.0");
+                            if (aRow.get("MAX_TUBING_PRES") == null || aRow.get("MIN_TUBING_PRES") == null)
+                                aRow.put("TUBING_PRES", "0.0");
+                            else {
+                                aRow.put("TUBING_PRES", String.format("%.2f",(Double.parseDouble(aRow.get("MAX_TUBING_PRES").toString())
+                                        + Double.parseDouble(aRow.get("MIN_TUBING_PRES").toString())) / 2));
+                            }
+                            aRow.putIfAbsent("CASING_PRES", "0.0");
+                            aRow.putIfAbsent("PUMP_DEPTH", "0.0");
+                        })
+                        .setBody(simple("insert into centralbase.cb_pc_pro_wellbore_status_daily(well_id,prod_date,oil_prod_method,back_pres,tubing_pres,casing_pres) " +
+                                "select '${body[WELL_ID]}','${body[PROD_DATE]}','${body[OIL_PRODUCTION_METHOD]}'," +
+                                "'${body[BACK_PRES]}','${body[TUBING_PRES]}','${body[CASING_PRES]}'" +
+                                "where NOT EXISTS ( SELECT * FROM centralbase.cb_pc_pro_wellbore_status_daily " +
+                                "      WHERE well_id = '${body[WELL_ID]}' and  prod_date = '${body[PROD_DATE]}')"))
                         .doTry()
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:insert-statusDaily ->  centralbase.cb_pc_pro_wellbore_status_daily insert data failed")
+                        .log("${header.date}" + " routeId:insert-statusDaily ->  centralbase.cb_pc_pro_wellbore_status_daily insert data failed")
                         .end();
 
-
+                // BS BJ DYM find before data
                 RouteDefinition statusDailyDYM = from("timer:mytimer-update-statusDaily-DYM?period=10800000")
                         .routeId("update-statusDaily-DYM")
                         .process(exchange -> {
                             Message in = exchange.getIn();
-                            in.setHeader("date",getDate());
+                            in.setHeader("date", getDate());
                         });
-                         setMyBody(statusDailyDYM)
-                        .setBody(simple("select distinct jh , csrq , ymsd from ZD_YTGSCX.DCA002_ZD where  (jh,csrq) in (SELECT  jh,max(csrq) csrq  FROM ZD_YTGSCX.DCA002_ZD WHERE ymsd is not null and jh='${header.well_id}' group by jh)"))
+                setSysControlBody(statusDailyDYM)
+                        .setBody(simple("select distinct WELL_ID , PROD_DATE , DYNAMIC_LIQ_LEVEL " +
+                                "from ZY_DXGW.PC_PRO_COM_DAILY " +
+                                "where  (WELL_ID,PROD_DATE) in" +
+                                " (SELECT  WELL_ID,max(PROD_DATE) PROD_DATE  FROM ZY_DXGW.PC_PRO_COM_DAILY" +
+                                "    WHERE DYNAMIC_LIQ_LEVEL is not null and WELL_ID='${header.well_id}' group by WELL_ID)"))
                         .to("jdbc:oracle")
                         .split(body())
-                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set start_pump_liq_level = '${body[YMSD]}'  where well_id = '${body[JH]}' and prod_date::date  = '${header.date}' "))
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set start_pump_liq_level = '${body[DYNAMIC_LIQ_LEVEL]}'  " +
+                                "where well_id = '${header.well_id}' 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")
+                        .log("${header.date}" + " routeId:update-statusDaily-DYM ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
                         .end();
+
+                RouteDefinition statusDailyBS = from("timer:mytimer-update-statusDaily-BS?period=10800000")
+                        .routeId("update-statusDaily-BS")
+                        .process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date", getDate());
+                        });
+                setSysControlBody(statusDailyBS)
+                        .setBody(simple("select distinct WELL_ID , PROD_DATE , PUMP_DEPTH " +
+                                "from ZY_DXGW.PC_PRO_COM_DAILY " +
+                                "where  (WELL_ID,PROD_DATE) in" +
+                                " (SELECT  WELL_ID,max(PROD_DATE) PROD_DATE  FROM ZY_DXGW.PC_PRO_COM_DAILY" +
+                                "    WHERE PUMP_DEPTH is not null and WELL_ID='${header.well_id}' group by WELL_ID)"))
+                        .to("jdbc:oracle")
+                        .split(body())
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set pump_depth = '${body[PUMP_DEPTH]}'  " +
+                                "where well_id = '${header.well_id}' and prod_date::date  = '${header.date}' "))
+                        .doTry()
+                        .to("jdbc:centralbase")
+                        .doCatch(Exception.class)
+                        .log("${header.date}" + " routeId:update-statusDaily-BS ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
+                        .end();
+
+                RouteDefinition statusDailyBJ = from("timer:mytimer-update-statusDaily-BJ?period=10800000")
+                        .routeId("update-statusDaily-BJ")
+                        .process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date", getDate());
+                        });
+                setSysControlBody(statusDailyBJ)
+                        .setBody(simple("select distinct WELL_ID , PROD_DATE , PUMP_DIAMETER " +
+                                "from ZY_DXGW.PC_PRO_COM_DAILY " +
+                                "where  (WELL_ID,PROD_DATE) in" +
+                                " (SELECT  WELL_ID,max(PROD_DATE) PROD_DATE  FROM ZY_DXGW.PC_PRO_COM_DAILY" +
+                                "    WHERE PUMP_DIAMETER is not null and WELL_ID='${header.well_id}' group by WELL_ID)"))
+                        .to("jdbc:oracle")
+                        .split(body())
+                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set oil_nozzle = '${body[PUMP_DIAMETER]}'  " +
+                                "where well_id = '${header.well_id}' and prod_date::date  = '${header.date}' "))
+                        .doTry()
+                        .to("jdbc:centralbase")
+                        .doCatch(Exception.class)
+                        .log("${header.date}" + " routeId:update-statusDaily-BJ ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
+                        .end();
+
                 RouteDefinition submergenceDepth = from("timer:mytimer-update-statusDaily-submergenceDepth?period=10800000")
                         .routeId("update-statusDaily-submergenceDepth")
                         .process(exchange -> {
                             Message in = exchange.getIn();
-                            in.setHeader("date",getDate()+" 00:00:00");
+                            in.setHeader("date", getDate() + " 00:00:00");
                         });
-                         setMyBody(submergenceDepth)
+                setSysControlBody(submergenceDepth)
                         .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}' and well_id='${header.well_id}' "))
                         .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.parseDouble(aRow.get("pump_depth").toString())-Double.parseDouble(aRow.get("start_pump_liq_level").toString())/10;
-                                BigDecimal bd=new BigDecimal(cmd);
-                                double cmd1=bd.setScale(1, RoundingMode.HALF_UP).doubleValue();
-                                aRow.put("submergence_depth",cmd1);
+                            aRow.put("submergence_depth", null);
+                            if (aRow.get("start_pump_liq_level") != null && aRow.get("pump_depth") != null) {
+                                double cmd = Double.parseDouble(aRow.get("pump_depth").toString()) - Double.parseDouble(aRow.get("start_pump_liq_level").toString()) / 10;
+                                BigDecimal bd = new BigDecimal(cmd);
+                                double cmd1 = bd.setScale(1, RoundingMode.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]}'"))
                         .doTry()
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:update-statusDaily-submergenceDepth ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
+                        .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=10800000")
                         .routeId("insert-volDaily")
                         .process(exchange -> {
                             Message in = exchange.getIn();
-                            in.setHeader("date",getDate());
+                            in.setHeader("date", getDate());
                         });
-                         setMyBody(volDaily)
+                setSysControlBody(volDaily)
                         .setBody(simple("select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz,sccw 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("SCSJ") == null) aRow.put("SCSJ", "0.0");
-                    if (aRow.get("RCYL1") == null) aRow.put("RCYL1", "0.0");
-                    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("BZ", "");
-                    if (aRow.get("SCCW") == null) aRow.put("SCCW", "");
-                    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);
-                    }
-                })
+                            Message in = exchange.getIn();
+                            HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                            if (aRow.get("SCSJ") == null) aRow.put("SCSJ", "0.0");
+                            if (aRow.get("RCYL1") == null) aRow.put("RCYL1", "0.0");
+                            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("BZ", "");
+                            if (aRow.get("SCCW") == null) aRow.put("SCCW", "");
+                            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,gas_oil_ratio,water_prod_daily,water_gas_ratio,surface_crude_water_density,surface_crude_oil_density,stim_content) " +
                                 "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]}' ,'${body[SCCW]}'" +
                                 "where NOT EXISTS ( SELECT * FROM centralbase.cb_pc_pro_wellbore_vol_daily WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}' )"))
                         .doTry()
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:insert-volDaily ->  centralbase.cb_pc_pro_wellbore_vol_daily insert data failed")
+                        .log("${header.date}" + " routeId:insert-volDaily ->  centralbase.cb_pc_pro_wellbore_vol_daily insert data failed")
                         .endDoTry()
                         .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")
@@ -342,9 +401,9 @@ public class CamelJDBCConfiguration {
                         .routeId("update-volDaily-liq_prod_daily")
                         .process(exchange -> {
                             Message in = exchange.getIn();
-                            in.setHeader("date",getDate());
+                            in.setHeader("date", getDate());
                         });
-                         setMyBody(volDailyLiqProdDaily)
+                setSysControlBody(volDailyLiqProdDaily)
                         .setBody(simple("select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz 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 -> {
@@ -356,26 +415,26 @@ public class CamelJDBCConfiguration {
                             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("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"){
+                            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 (!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 (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" ){
+                            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);
@@ -383,11 +442,11 @@ public class CamelJDBCConfiguration {
                                     aRow.put("SQB", d1);
                                 }
                             }
-                            if (!aRow.containsKey("SMD")){
-                                aRow.put("SMD",1);
+                            if (!aRow.containsKey("SMD")) {
+                                aRow.put("SMD", 1);
                             }
-                            if (!aRow.containsKey("YMD")){
-                                aRow.put("YMD",0.85);
+                            if (!aRow.containsKey("YMD")) {
+                                aRow.put("YMD", 0.85);
                             }
                         })
                         .setBody(simple("update centralbase.cb_pc_pro_wellbore_vol_daily set prod_time = '${body[SCSJ]}' ,liq_prod_daily='${body[RCYL1]}' ,oil_prod_daily ='${body[RCYL]}' ,gas_prod_daily ='${body[RCQL]}' ,water_cut='${body[HS]}' ,remarks='${body[BZ]}' ,gas_oil_ratio='${body[QYB]}' ,water_prod_daily='${body[RCSL]}' ,water_gas_ratio='${body[SQB]}',surface_crude_water_density='${body[SMD]}',surface_crude_oil_density= '${body[YMD]}' " +
@@ -395,16 +454,16 @@ public class CamelJDBCConfiguration {
                         .doTry()
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:update-volDaily-liq_prod_daily ->  centralbase.cb_pc_pro_wellbore_vol_daily update data failed")
+                        .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());
+                            in.setHeader("date", getDate());
                         });
-                        setMyBody(runTime)
+                setSysControlBody(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())
@@ -414,12 +473,12 @@ public class CamelJDBCConfiguration {
                         .doTry()
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:update-runTime-strokeAndFrequency ->  centralbase.cb_temp_well_mech_runtime update data failed")
+                        .log("${header.date}" + " routeId:update-runTime-strokeAndFrequency ->  centralbase.cb_temp_well_mech_runtime update data failed")
                         .end();
-            };
-        };
-
+            }
 
+            ;
+        };
 
 
     }