正常使用版本

src/main/java/com/gct/tools/etlcamelhuge/MQ/DefaultMsgSendSuccessCallBack.java

@@ -18,6 +18,6 @@ public class DefaultMsgSendSuccessCallBack implements SendSuccessCallBack {
     @Override
     public void accept(SendResult sendResult) {
         System.out.println("send = "+count++);
-        log.info("send msg success,msg:{}", sendResult.getMsgId());
+        //log.info("send msg success,msg:{}", sendResult.getMsgId());
     }
 }

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

@@ -58,7 +58,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
             private SortedSet<String> organization;
             private Map<String, Integer> orgIDs;
             private Integer orgID;
-
+            private Map<String, Integer> stringIntegerMap;
             //全部执行完成的大概时间在30-40分钟
             @Override
             public void configure() throws Exception {
@@ -67,8 +67,11 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                 from("timer:mytimer1?period=604800000")
                         .routeId("oracle-1")
                         .setHeader("date", constant(getDate()))
+                        .doTry()
                         .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")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+"routeId:oracle-1->  select cb_cd_well_source need data failed")
                         .transform()
                         .body((result) -> {
                             organization = new TreeSet<>();
@@ -105,7 +108,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                                 " ON conflict(well_id) DO UPDATE set remarks = '${body[BZ]}' "))
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-1->  centralbase.cb_cd_well_source 导入数据失败")
+                        .log("${header.date}"+" routeId:oracle-1->  centralbase.cb_cd_well_source insert data failed")
                         .end()
                         .transform().body((re) -> {
                     List<Map<String, Object>> rows = new ArrayList<>();
@@ -144,7 +147,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                                 "ON conflict(org_id_pre) DO UPDATE set org_code = '${body[org_code]}' "))
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-1->  centralbase.cb_pc_organization insert date faild")
+                        .log("${header.date}"+" routeId:oracle-1->  centralbase.cb_pc_organization insert data failed")
                         .end()
                         .setBody(simple("select org_id,org_name from centralbase.cb_pc_organization where org_level = '3' "))
                         .to("jdbc:centralbase")
@@ -153,14 +156,17 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         .setBody(simple("update centralbase.cb_cd_well_source set org_id = '${body[org_id]}' where station_name = '${body[org_name]}'"))
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-1->  centralbase.cb_pc_organization update date faild")
+                        .log("${header.date}"+" routeId:oracle-1->  centralbase.cb_pc_organization update data failed")
                         .end();
                 //单独执行时间10s
                 from("timer:mytimer2?period=3600000")
                         .routeId("oracle-2")
                         .setHeader("date", constant(getDate()))
+                        .doTry()
                         .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 "))
                         .to("jdbc:oracle")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:oracle-2->  select cb_pc_pro_wellbore_status_daily  need data failed")
                         .split(body()).process(exchange -> {
                     Message in = exchange.getIn();
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -176,7 +182,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                                 "where NOT EXISTS ( SELECT * FROM centralbase.cb_pc_pro_wellbore_status_daily WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}')"))
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-2->  centralbase.cb_pc_pro_wellbore_status_daily insert date faild")
+                        .log("${header.date}"+" routeId:oracle-2->  centralbase.cb_pc_pro_wellbore_status_daily insert data failed")
                         .end();
                 //查询井对应dym不为空的数据 --目前是只要对应井能查到dym不为空的,无论是什么时间的,都放进去
                 //将查询到的DYM数据更新到cb_pc_pro_wellbore_status_daily中
@@ -186,24 +192,29 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         .routeId("oracle-5")
                         .setHeader("date", constant(getDate() + " 00:00:00"))
                         //三个月之内dym不为空的数据
+                        .doTry()
                         //.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")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:oracle-5->  select DYM data failed")
                         .split(body())
                         .doTry()
                         .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")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-5->  centralbase.cb_pc_pro_wellbore_status_daily update date faild")
+                        .log("${header.date}"+" routeId:oracle-5->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
                         .end();
 
                 from("timer:mytimer7?period=3600000")
                         .routeId("oracle-7")
                         .setHeader("date", constant(getDate() + " 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;"))
+                        .doTry()
+                        //.setBody(simple("SELECT  distinct jh,max(rq),dym FROM DBA01 WHERE dym is not null group by jh,dym"))
                         .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")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:oracle-7-> select  centralbase.cb_pc_pro_wellbore_status_daily need data failed")
                         .split(body()).process(exchange -> {
                             Message in = exchange.getIn();
                             HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -219,14 +230,17 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         .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")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-7->  centralbase.cb_pc_pro_wellbore_status_daily update date faild")
+                        .log("${header.date}"+" routeId:oracle-7->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
                         .end();
                 //单独执行时间30s
                 from("timer:mytimer3?period=3600000")
                         .routeId("oracle-3")
                         .setHeader("date", constant(getDate()))
+                        .doTry()
                         .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")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:oracle-3->  select centralbase.cb_pc_pro_wellbore_vol_daily need  insert data failed")
                         .split(body()).process(exchange -> {
                     Message in = exchange.getIn();
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -276,26 +290,86 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                                 "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")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-3->  centralbase.cb_pc_pro_wellbore_status_daily insert date faild")
+                        .log("${header.date}"+" routeId:oracle-3->  centralbase.cb_pc_pro_wellbore_vol_daily insert data failed")
                         .doTry()
-                        .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}' "))
+                        .setBody(simple("routeId:oracle-3->  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}' "))
+                        .setBody(simple("routeId:oracle-3->  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}' "))
+                        .setBody(simple(" routeId:oracle-3->  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")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-3->  centralbase.cb_pc_pro_wellbore_vol_daily update date faild")
+                        .log("${header.date}"+" routeId:oracle-3->  centralbase.cb_pc_pro_wellbore_vol_daily update data failed")
                         .end();
 
-
+                from("timer:mytimer12?period=3600000")
+                        .routeId("oracle-12")
+                        .setHeader("date", constant(getDate()))
+                        .doTry()
+                        .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")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:oracle-12-> select  centralbase.cb_pc_pro_wellbore_vol_daily need  update data failed")
+                        .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", "");
+                            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);
+                            }
+                        })
+                        .doTry()
+                        .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]}' " +
+                                "where well_id = '${body[JH]}' and prod_date ='${body[RQ]}' "))
+                        .to("jdbc:centralbase")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:oracle-12->  centralbase.cb_pc_pro_wellbore_vol_daily update data failed")
+                        .end();
                 //0 0 */1 * * ? 每1个小时执行一次
                 //单独执行一次30s
                 from("timer:mytimer4?period=3600000")
                         .routeId("oracle-4")
                         .setHeader("date", constant(getDate()))
+                        .doTry()
                         .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")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:oracle-4-> select  centralbase.cb_temp_well_mech_daily need insert data failed")
                         .split(body()).process(exchange -> {
                     Message in = exchange.getIn();
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -316,36 +390,46 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                                 "where NOT EXISTS ( SELECT * FROM centralbase.cb_temp_well_mech_daily WHERE well_id = '${body[JH]}' and  prod_date = '${body[RQ]}' )"))
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-4->  centralbase.cb_temp_well_mech_daily insert date faild")
+                        .log("${header.date}"+" routeId:oracle-4->  centralbase.cb_temp_well_mech_daily insert data failed")
                         .end();
 
                 from("timer:mytimer6?period=3600000")
                         .routeId("oracle-6")
                         .setHeader("date", constant(getDate() + " 00:00:00"))
+                        .doTry()
                         //五个月之内bj不为空的数据
-                        .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"))
+                        //.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"))
+                        .setBody(simple("SELECT  distinct jh,max(rq),bj FROM DBA01 WHERE dym is not null group by jh,bj"))
                         .to("jdbc:oracle")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:oracle-6-> select bj  centralbase.cb_temp_well_mech_runtime need update data failed")
                         .split(body())
                         .doTry()
                         .setBody(simple("update centralbase.cb_temp_well_mech_runtime set pump_diameter = '${body[BJ]}' where well_id = '${body[JH]}' "))
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:oracle-6->  centralbase.cb_temp_well_mech_runtime update date faild")
+                        .log("${header.date}"+" routeId:oracle-6->  centralbase.cb_temp_well_mech_runtime update data failed")
                         .end();
                 //从天安哪里获取的数据
                 //0 0 */1 * * ? 每1个小时执行一次
                 //单独执行一小时的数据30s
-                from("timer:mytimer8?period=3600000")
+               from("timer:mytimer8?period=3600000")
                         .routeId("jdbc-gtsj-?")
+                        .doTry()
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
                         .to("jdbc:centralbase")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:jdbc-gtsj-?->select max(date)  data failed")
                         .split(body())
                         .setHeader("date", simple("${body[max]}"))
                         .setBody(simple("select distinct well_name,dyna_create_time,check_date,displacement,disp_load,stroke,frequency,susp_max_load,susp_min_load from public.pc_fd_pumpjack_dyna_dia_t where   dyna_create_time > '${header.date}' "))
+                        //.setBody(simple("select distinct well_name,dyna_create_time,check_date,displacement,disp_load,stroke,frequency,susp_max_load,susp_min_load from public.pc_fd_pumpjack_dyna_dia_t where   dyna_create_time > '2021-08-23 17:00:00' "))
                         .to("jdbc:gtsj")
                         .split(body()).process(exchange -> {
+
                     Message in = exchange.getIn();
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                    System.out.println("well_name---"+aRow.get("well_name"));
                     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("")) {
@@ -364,9 +448,6 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                             w += new BigDecimal(Math.round(Double.parseDouble(s[i]) * 100)).stripTrailingZeros().toPlainString() + ",";
                         }
                         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);
@@ -393,15 +474,18 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                                 "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")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:jdbc-gtsj-?->  centralbase.cb_temp_well_mech_runtime insert date faild")
+                        .log("${header.date}"+" routeId:jdbc-gtsj-?->  centralbase.cb_temp_well_mech_runtime insert data failed")
                         .end();
 
-                from("timer:mytimer9?period=3600000")
+                  from("timer:mytimer9?period=3600000")
                         .routeId("centralbase-2")
                         .setHeader("date", constant(getDate() + " 00:00:00"))
+                        .doTry()
                         .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}")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:centralbase-2-> select  pump_diameter centralbase.cb_pc_pro_wellbore_status_daily  data failed")
                         .split(body()).process(exchange -> {
                             Message in = exchange.getIn();
                             HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -411,14 +495,17 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         .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")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:centralbase-2->  centralbase.cb_pc_pro_wellbore_status_daily update date faild")
+                        .log("${header.date}"+" routeId:centralbase-2->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
                         .end();
 
-                from("timer:mytimer10?period=3600000")
+               from("timer:mytimer10?period=3600000")
                         .routeId("centralbase-3")
                         .setHeader("date", constant(getDate()))
+                        .doTry()
                         .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}")
+                        .doCatch(Exception.class)
+                        .log("${header.date}"+" routeId:centralbase-3-> select stroke_length  centralbase.cb_temp_well_mech_daily  data failed")
                         .split(body()).process(exchange -> {
                     Message in = exchange.getIn();
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -437,9 +524,8 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         .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")
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" routeId:centralbase-3->  centralbase.cb_temp_well_mech_daily update date faild")
+                        .log("${header.date}"+" routeId:centralbase-3->  centralbase.cb_temp_well_mech_daily update data failed")
                         .end();
-
                 from("timer:mytimer11?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) "))
@@ -456,13 +542,15 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                             Double strokeLength = Double.valueOf(aRow.get("stroke_length").toString());
                             Double strokeFrequency = Double.valueOf(aRow.get("stroke_frequency").toString());
                             String sgt = aRow.get("sgt").toString();
+                            if (sgt == null || sgt.length() ==0){
+                                sgt = "0,0";
+                            }
                             DiagnoseMsg diagnoseMsg = new DiagnoseMsg(wellId, wellName, orgId, prodDate, sgt, LocalDateTime.now().toString(), strokeLength, strokeFrequency);
                             producer.send((MessageBody) diagnoseMsg);
                         })
                         .doCatch(Exception.class)
-                        .log("${header.date}"+" rocketMQ send data faild")
+                        .log("${header.date}"+" rocketMQ send data failed")
                         .end();
-
             };
         };
     }

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

@@ -12,7 +12,7 @@ import java.util.HashMap;
 import java.util.concurrent.atomic.AtomicInteger;
 
 
-@Configuration
+//@Configuration
 public class CamelRestConfiguration extends RouteBuilder {
     @Override
     public synchronized void configure() throws Exception {
@@ -37,6 +37,7 @@ public class CamelRestConfiguration extends RouteBuilder {
                 .setBody(simple(body.toJSONString()))
                 .to("rest:post:/dibs/0/service/token")
                 .unmarshal().json(JsonLibrary.Jackson)
+                .log("${body}")
                 .setBody(simple("${body[result]}"))
                 .setHeader("token", simple("${body[token]}"))
                 .setHeader("Authorization", simple("Bearer " + "${in.header.token}"))

src/main/resources/application.yml

@@ -111,7 +111,7 @@ management:
       cors:
         allow-credentials: off
 server:
-  port: 8080
+  port: 9999
 
 
 rocketmq: