centralbase vol 表增加sccw字段,dym修改为新表导入

src/main/java/com/gct/tools/etlcamelhuge/controller/BaseDataController.java

@@ -135,7 +135,7 @@ public class BaseDataController {
         try {
             jdbcTemplate = new JdbcTemplate(oracleDataSource);
             String date = baseDataBody.getDate();
-            String sql = " select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz from DBA01 where rq  = to_date('" + date + "','yyyy-MM-dd') and qyrq is not null ";
+            String sql = " select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz,sccw from DBA01 where rq  = to_date('" + date + "','yyyy-MM-dd') and qyrq is not null ";
             List<Map<String, Object>> list = jdbcTemplate.queryForList(sql);
             for (Map<String, Object> map : list) {
                 if (map.get("SCSJ") == null) map.put("SCSJ", "0.0");
@@ -144,6 +144,7 @@ public class BaseDataController {
                 if (map.get("RCQL") == null) map.put("RCQL", "0.0");
                 if (map.get("HS") == null) map.put("HS", "0.0");
                 if (map.get("BZ") == null) map.put("BZ", "");
+                if (map.get("SCCW") == null) map.put("SCCW", "");
                 map.put("RCSL", -1);
                 map.put("QYB", -1);
                 map.put("SQB", -1);
@@ -177,10 +178,10 @@ public class BaseDataController {
                 if (!map.containsKey("YMD")) {
                     map.put("YMD", 0.85);
                 }
-                sql = "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) " +
-                        "values(?,?,?,?,?,?,?,?,?,?,?,?,?) ";
+                sql = "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) " +
+                        "values(?,?,?,?,?,?,?,?,?,?,?,?,?,?) ";
                 insertCount = insertBaseDataVolDaily(sql, map) + insertCount;
-                sql = "select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz from DBA01 where rq  = to_date('" + date + "','yyyy-MM-dd') and qyrq is not null ";
+                sql = "select distinct  jh,rq,scsj, rcyl1,rcyl,rcql,hs, bz,sccw from DBA01 where rq  = to_date('" + date + "','yyyy-MM-dd') and qyrq is not null ";
                 updateLiqOliDailyCount = updateBaseDataVolDaily(sql) + updateLiqOliDailyCount;
             }
 
@@ -196,7 +197,7 @@ public class BaseDataController {
     public int insertBaseDataVolDaily(String sql, Map<String, Object> map) {
         jdbcTemplate = new JdbcTemplate(baseDataSource);
         if (map.isEmpty()) return 0;
-        return jdbcTemplate.update(sql, map.get("JH"), map.get("RQ"), map.get("SCSJ"), map.get("RCYL1"), map.get("RCYL"), map.get("RCQL"), map.get("HS"), map.get("BZ"), map.get("QYB"), map.get("RCSL"), map.get("SQB"), map.get("SMD"), map.get("YMD"));
+        return jdbcTemplate.update(sql, map.get("JH"), map.get("RQ"), map.get("SCSJ"), map.get("RCYL1"), map.get("RCYL"), map.get("RCQL"), map.get("HS"), map.get("BZ"), map.get("QYB"), map.get("RCSL"), map.get("SQB"), map.get("SMD"), map.get("YMD"), map.get("SCCW"));
     }
 
     public int updateBaseDataVolDaily(String sql) {

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

@@ -225,34 +225,15 @@ public class CamelJDBCConfiguration {
                             in.setHeader("date",getDate());
                         });
                          setMyBody(statusDailyDYM)
-                        .setBody(simple("select distinct jh , rq , dym from DBA01 where  (jh,rq) in (SELECT  jh,max(rq) rq  FROM DBA01 WHERE dym is not null and jh='${header.well_id}' group by jh)"))
+                        .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)"))
                         .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]}' and prod_date::date  = '${header.date}' "))
+                        .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}' "))
                         .doTry()
                         .to("jdbc:centralbase")
                         .doCatch(Exception.class)
                         .log("${header.date}"+" routeId:update-statusDaily-DYM ->  centralbase.cb_pc_pro_wellbore_status_daily update data failed")
                         .end();
-               /* RouteDefinition statusDailyBJ = from("timer:mytimer-update-statusDaily-BJ?period=3600000")
-                        .routeId("update-statusDaily-BJ")
-                        .process(exchange -> {
-                            Message in = exchange.getIn();
-                            in.setHeader("date",getDate());
-                        });
-                         setMyBody(statusDailyBJ)
-                        .setBody(simple("select distinct jh , rq , bj from DBA01 where  (jh,rq) in (SELECT  jh,max(rq) rq  FROM DBA01 WHERE bj is not null and rq<= to_date('${header.date}','yyyy-MM-dd') and jh='${header.well_id}' group by jh)"))
-                        .to("jdbc:oracle")
-                        .split(body()).process(exchange -> {
-                            HashMap body = exchange.getIn().getBody(HashMap.class);
-                        })
-                        .setBody(simple("update centralbase.cb_pc_pro_wellbore_status_daily set oil_nozzle = '${body[BJ]}' where well_id = '${body[JH]}' 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 -> {
@@ -287,7 +268,7 @@ public class CamelJDBCConfiguration {
                             in.setHeader("date",getDate());
                         });
                          setMyBody(volDaily)
-                        .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 "))
+                        .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();
@@ -298,6 +279,7 @@ 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", "");
+                    if (aRow.get("SCCW") == null) aRow.put("SCCW", "");
                     aRow.put("RCSL",-1);
                     aRow.put("QYB",-1);
                     aRow.put("SQB",-1);
@@ -332,8 +314,8 @@ public class CamelJDBCConfiguration {
                         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) " +
-                                "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]}' " +
+                        .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")