浏览代码

只接入油井及库调整

lijian 3 年之前
父节点
当前提交
44a40056d4

+ 17 - 11
src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelJDBCConfiguration.java

@@ -223,7 +223,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
223 223
             //全部执行完成的大概时间在30-40分钟
224 224
             @Override
225 225
             public void configure() throws Exception {
226
-               /* RouteDefinition OrgAndWellSource= (RouteDefinition) from("timer:insert-OrgAndWellSource?period=86400000")
226
+                RouteDefinition OrgAndWellSource= (RouteDefinition) from("timer:insert-OrgAndWellSource?period=86400000")
227 227
                         .routeId("insert-OrgAndWellSource")
228 228
                         .setHeader("date", constant(getDate()))
229 229
                         .process(exchange -> {
@@ -404,8 +404,9 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
404 404
                         .setBody(simple("SELECT well_id wellid FROM centralbase.sys_access_well_control where access_status = '1' and error_id = '1' "))
405 405
                         .to("jdbc:centralbase")
406 406
                         .split(body())
407
-                        .setBody(simple("select v.WELL_COMMON_NAME jh,v.PROD_DATE rq,v.OIL_PRODUCTION_METHOD cyfs,v.PUMP_DIAMETER yz,v.BACK_PRES hysx,v.MAX_TUBING_PRES yysx,v.MAX_CASING_PRES tysx,v.PUMP_DEPTH bs from V_PC_PRO_COM_DAILY_CYYC_A2 v  where  v.PROD_DATE = to_date('${header.date}','yyyy-MM-dd')  and  v.WELL_COMMON_NAME = '${body[wellid]}' "))
408
-                        .to("jdbc:oracle")
407
+//                        .setBody(simple("select v.WELL_COMMON_NAME jh,v.PROD_DATE rq,v.OIL_PRODUCTION_METHOD cyfs,v.PUMP_DIAMETER yz,v.BACK_PRES hysx,v.MAX_TUBING_PRES yysx,v.MAX_CASING_PRES tysx,v.PUMP_DEPTH bs from V_PC_PRO_COM_DAILY_CYYC_A2 v  where  v.PROD_DATE = to_date('${header.date}','yyyy-MM-dd')  and  v.WELL_COMMON_NAME = '${body[wellid]}' "))
408
+                       .setBody(simple("select v.WELL_COMMON_NAME jh,v.PROD_DATE rq,v.OIL_PRODUCTION_METHOD cyfs,v.PUMP_DIAMETER yz,v.BACK_PRES hysx,v.MAX_TUBING_PRES yysx,v.MAX_CASING_PRES tysx,v.PUMP_DEPTH bs from V_PC_PRO_COM_DAILY_CYYC v  where  v.PROD_DATE = to_date('${header.date}','yyyy-MM-dd')  and  v.WELL_COMMON_NAME = '${body[wellid]}' "))
409
+                        .to("jdbc:oracle_A2")
409 410
                         .split(body()).process(exchange -> {
410 411
                     Message in = exchange.getIn();
411 412
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -441,8 +442,9 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
441 442
                         .setBody(simple("SELECT well_id wellid FROM centralbase.sys_access_well_control where access_status = '1' and error_id = '1' "))
442 443
                         .to("jdbc:centralbase")
443 444
                         .split(body())
444
-                        .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]}'"))
445
-                        .to("jdbc:oracle")
445
+//                        .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]}'"))
446
+                        .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]}'"))
447
+                        .to("jdbc:oracle_A2")
446 448
                         .split(body()).process(exchange -> {
447 449
                     Message in = exchange.getIn();
448 450
                     HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -521,8 +523,12 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
521 523
                         aRow.put("JH", aRow.get("jh").toString());
522 524
                         in.setHeader("JH",aRow.get("jh").toString());
523 525
                 })
524
-                    .setBody(simple("Select t.jh, t.prod_date rq,t.static_pressure jy,t.flow_pres ly,t.pump_diameter bj, t.pump_depth bs,t.pump_efficiency bx,t.rotate_frequency zs,t.stroke_length cc,t.stroke_frequency cs, t.pump_type blx,t.elec_frequency dl,t.dynamic_liq_level dym   FROM V_TEMP_WELL_MECH_ALL t where jh = '${body[JH]}'"))
525
-                    .to("jdbc:oracle")
526
+//                    .setBody(simple("Select t.jh, t.prod_date rq,t.static_pressure jy,t.flow_pres ly,t.pump_diameter bj, t.pump_depth bs,t.pump_efficiency bx,t.rotate_frequency zs,
527
+// t.stroke_length cc,t.stroke_frequency cs, t.pump_type blx,t.elec_frequency dl,t.dynamic_liq_level dym   FROM V_TEMP_WELL_MECH_ALL t where jh = '${body[JH]}'"))
528
+                    .setBody(simple("select  * from ( Select  v.WELL_COMMON_NAME, t.prod_date rq,t.static_pressure jy,t.flow_pres ly,t.pump_diameter bj, t.pump_depth bs,t.pump_efficiency bx, t.rotate_frequency zs,t.stroke_length cc,t.stroke_frequency cs, t.pump_type blx,t.elec_frequency dl, t.dynamic_liq_level dym  " +
529
+                            " FROM V_TEMP_WELL_MECH_ALL t inner join V_CD_WELL_SOURCE_YC v on  t.well_id = v.well_id  and  v.WELL_COMMON_NAME = '${body[JH]}'  " +
530
+                            " order by rq desc) where rownum = 1"))
531
+                    .to("jdbc:oracle_A2")
526 532
                     .split(body()).process(exchange -> {
527 533
                         Message in = exchange.getIn();
528 534
                         HashMap<String, Object> aRow = in.getBody(HashMap.class);
@@ -567,7 +573,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
567 573
                         .end();
568 574
 
569 575
                 //计量间产液量
570
-                from("timer:mytimer6?period=3600000")
576
+                 from("timer:mytimer6?period=3600000")
571 577
                         .routeId("oracle-6")
572 578
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
573 579
                         .to("jdbc:centralbase")
@@ -651,7 +657,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
651 657
                         .end();
652 658
 
653 659
                 //稀稠油信息
654
-                from("timer:mytimer9?period=3600000")
660
+               /* from("timer:mytimer9?period=3600000")
655 661
                         .routeId("oracle-9")
656 662
                         .setBody(simple("select max(prod_date) from centralbase.cb_temp_well_mech_runtime "))
657 663
                         .to("jdbc:centralbase")
@@ -679,7 +685,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
679 685
                         .to("jdbc:centralbase")
680 686
                         .doCatch(Exception.class)
681 687
                         .log("${header.date}"+" routeId:oracle-9->  centralbase.cb_pc_pro_wellbore_status_daily update date faild")
682
-                        .end();
688
+                        .end();*/
683 689
 
684 690
 
685 691
                 from("timer:mytimer10?period=3600000")
@@ -735,7 +741,7 @@ public class CamelJDBCConfiguration /*extends RouteBuilder */ {
735 741
                         })
736 742
                         .doCatch(Exception.class)
737 743
                         .log("${header.date}"+" rocketMQ send data faild")
738
-                        .end();*/
744
+                        .end();
739 745
 
740 746
 
741 747
                 //手动导入井信息

+ 13 - 10
src/main/java/com/gct/tools/etlcamelhuge/routeconfig/CamelRestConfiguration.java

@@ -175,7 +175,7 @@ public class CamelRestConfiguration extends RouteBuilder {
175 175
     @Override
176 176
     public synchronized void configure() throws Exception {
177 177
 
178
-        JSONObject body = new JSONObject();
178
+        /*JSONObject body = new JSONObject();
179 179
 
180 180
           restConfiguration()
181 181
                 .component("servlet")
@@ -202,14 +202,17 @@ public class CamelRestConfiguration extends RouteBuilder {
202 202
 //                    loadDate(,aRow.get("id")+"/analyse/功图数据", );
203 203
 //                    in.setHeader("id",aRow.get("id")+"/analyse/功图数据");
204 204
 //                    in.setHeader("wellid",aRow.get("code"));
205
-                    ZDJG_WELL zdjg_well = loadGtData(aRow.get("id")+"/analyse/功图数据", aRow.get("code").toString(), "2021-08-17");
206
-                    aRow.put("sgt",gtTransUtil(zdjg_well.getZd_init_sgt()) );//null
207
-                    aRow.put("susp_max_load",zdjg_well.getSxzh());//最大载荷
208
-                    aRow.put("susp_min_load",zdjg_well.getXxzh());//最小载荷
209
-                    aRow.put("stroke",zdjg_well.getStroke());
210
-                    aRow.put("frequency",zdjg_well.getFrequence());
211
-                    aRow.put("dyna_create_time",zdjg_well.getProd_date());
212
-                    aRow.put("well_name",aRow.get("code"));
205
+                    if (aRow.get("typeName").toString().indexOf("油井")> 0){
206
+                        ZDJG_WELL zdjg_well = loadGtData(aRow.get("id")+"/analyse/功图数据", aRow.get("code").toString(), "2021-08-17");
207
+                        aRow.put("sgt",gtTransUtil(zdjg_well.getZd_init_sgt()) );//null
208
+                        aRow.put("susp_max_load",zdjg_well.getSxzh());//最大载荷
209
+                        aRow.put("susp_min_load",zdjg_well.getXxzh());//最小载荷
210
+                        aRow.put("stroke",zdjg_well.getStroke());
211
+                        aRow.put("frequency",zdjg_well.getFrequence());
212
+                        aRow.put("dyna_create_time",zdjg_well.getProd_date());
213
+                        aRow.put("well_name",aRow.get("code"));
214
+                    }
215
+
213 216
 
214 217
                 })
215 218
                 .log("${in.header.date}")
@@ -219,7 +222,7 @@ public class CamelRestConfiguration extends RouteBuilder {
219 222
 //                        "where NOT EXISTS (SELECT * FROM centralbase.cb_temp_well_mech_runtime WHERE well_id = '${body[well_name]}' and  prod_date = '${in.header.date}' )"))
220 223
                 .to("jdbc:centralbase")
221 224
                 .doCatch(Exception.class)
222
-                .end();
225
+                .end();*/
223 226
 
224 227
       /* JSONArray jsonArray = new JSONArray();
225 228
         JSONObject search = new JSONObject();

+ 1 - 1
src/main/resources/application.yml

@@ -163,7 +163,7 @@ management:
163 163
       cors:
164 164
         allow-credentials: off
165 165
 server:
166
-  port: 12121
166
+  port: 1010
167 167
 
168 168
 
169 169
 rocketmq: