有两个液量的井要累加

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

@@ -488,7 +488,15 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
                         .to("jdbc:centralbase")
                         .split(body())
 //                        .setBody(simple("select  WELL_COMMON_NAME jh, PROD_DATE rq,PROD_TIME scsj, LIQ_PROD_DAILY rcyl1,OIL_PROD_DAILY rcyl,GAS_PROD_DAILY rcql,WATER_CUT hs,REMARKS bz from V_PC_PRO_COM_DAILY_CYYC_A2 where prod_date = to_date('${header.date}','yyyy-MM-dd') and WELL_COMMON_NAME = '${body[wellid]}'"))
-                        .setBody(simple("select  WELL_COMMON_NAME jh, PROD_DATE rq,PROD_TIME scsj, LIQ_PROD_DAILY rcyl1,OIL_PROD_DAILY rcyl,GAS_PROD_DAILY rcql,WATER_CUT hs,REMARKS bz from V_PC_PRO_COM_DAILY_CYYC where prod_date = to_date('${header.date}','yyyy-MM-dd') and WELL_COMMON_NAME = '${body[wellid]}'"))
+//                        .setBody(simple("select  WELL_COMMON_NAME jh, PROD_DATE rq,PROD_TIME scsj, LIQ_PROD_DAILY rcyl1,OIL_PROD_DAILY rcyl,GAS_PROD_DAILY rcql,WATER_CUT hs,REMARKS bz from V_PC_PRO_COM_DAILY_CYYC where prod_date = to_date('${header.date}','yyyy-MM-dd') and WELL_COMMON_NAME = '${body[wellid]}' and LIQ_PROD_DAILY >0 "))
+                        .setBody(simple("select  WELL_COMMON_NAME jh,\n" +
+                                "                       PROD_DATE rq,\n" +
+                                "                       PROD_TIME scsj,\n" +
+                                "                       (select  sum(LIQ_PROD_DAILY) from V_PC_PRO_COM_DAILY_CYYC where prod_date = to_date('${header.date}','yyyy-MM-dd') and WELL_COMMON_NAME = '${body[wellid]}') rcyl1,\n" +
+                                "                       OIL_PROD_DAILY rcyl,GAS_PROD_DAILY rcql,WATER_CUT hs,REMARKS bz\n" +
+                            "                       from   V_PC_PRO_COM_DAILY_CYYC\n" +
+                            "                       where prod_date = to_date('${header.date}','yyyy-MM-dd')\n" +
+                            "                       and WELL_COMMON_NAME = '${body[wellid]}'  "))
                         .to("jdbc:oracle_A2")
                         .split(body()).process(exchange -> {
                     Message in = exchange.getIn();
@@ -714,20 +722,15 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
 
                     }
                     })
-//                        .setBody(simple("select wellname , jbsj , jbyy, jbzq  from JBSJ where SYDATE >= date'${header.date}'"))
-//                        .setBody(simple(" Select jh,scjbrq,jbyy From ( Select t.jh,t.wgrq scjbrq,t.csmc jbyy, row_number() Over(Partition By t.jh   Order By t.wgrq Desc) rn   FROM Ddcc03_v t Where t.jh= '${header.JH}' And t.wgrq<=date'${header.date}')  Where rn < 3"))
-//
-//                        .to("jdbc:oracle_A2")
-//                        .split(body()).process(exchange -> {
-//                            Message in = exchange.getIn();
-//                            HashMap<String, Object> aRow = in.getBody(HashMap.class);
-//                            if (aRow.get("JBSJ") != null)
-//                            aRow.put("JBSJ",aRow.get("JBSJ").toString().substring(0,10));
-//                })
+                        .log("${body[JH]}")
+                        .log("${body[SCJBRQ]}")
+                        .log("${body[JBYY]}")
+                        .log("${body[ZQ]}")
+                        .log("${header.date}")
                         .doTry()
                         .setBody(simple("insert into centralbase.cb_cd_checkpump_source(well_common_name,check_pump_date,reason,period,sys_date) " +
                                         "select '${body[JH]}','${body[SCJBRQ]}','${body[JBYY]}','${body[ZQ]}','${header.date}' " +
-                                        "where NOT EXISTS(select * from centralbase.cb_cd_checkpump_source where well_common_name = '${body[WELLNAME]}' and sys_date = '${header.date}')"))
+                                        "where NOT EXISTS(select * from centralbase.cb_cd_checkpump_source where well_common_name = '${body[JH]}' and sys_date = '${header.date}')"))
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
                         .log("${header.date}"+" routeId:oracle-8->  centralbase.cb_pc_pro_wellbore_status_daily update date faild")