准东添加量液信息入A2库代码

pom.xml

@@ -162,6 +162,10 @@
             <groupId>org.apache.camel.springboot</groupId>
             <artifactId>camel-quartz-starter</artifactId>
         </dependency>
+        <!--<dependency>
+            <groupId>org.apache.camel.springboot</groupId>
+            <artifactId>camel-cron-starter</artifactId>
+        </dependency>-->
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>

src/main/java/com/gct/tools/etlcamelhuge/camelconfig/MyDataSourceConfiguration.java

@@ -18,21 +18,32 @@ import javax.sql.DataSource;
 @Configuration
 public class MyDataSourceConfiguration {
 
-    @Bean(name = "centralbase")
+   @Bean(name = "centralbase")
     @ConfigurationProperties(prefix = "spring.datasource.ds1")
     public DataSource dataSource1() {
         return DataSourceBuilder.create().build();
     }
 
-    @Bean(name = "oracle")
+     @Bean(name = "oracle")
     @ConfigurationProperties(prefix = "spring.datasource.ds2")
-    public DataSource dataSource3() {
+    public DataSource dataSource2() {
         return DataSourceBuilder.create().build();
     }
 
     @Bean(name = "gtsj")
     @ConfigurationProperties(prefix = "spring.datasource.ds3")
-    public DataSource dataSource4() {
+    public DataSource dataSource3() {
+        return DataSourceBuilder.create().build();
+    }
+   @Bean(name = "aoid")
+   @ConfigurationProperties(prefix = "spring.datasource.ds4")
+   public DataSource dataSource4() {
+       return DataSourceBuilder.create().build();
+   }
+
+    @Bean(name = "insertA2")
+    @ConfigurationProperties(prefix = "spring.datasource.ds5")
+    public DataSource dataSource5() {
         return DataSourceBuilder.create().build();
     }
 }

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

@@ -0,0 +1,68 @@
+package com.gct.tools.etlcamelhuge.routeconfig;
+
+import com.alibaba.fastjson.JSON;
+import org.apache.camel.Message;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.ExpressionNode;
+import org.apache.camel.model.ProcessorDefinition;
+import org.apache.camel.model.RouteDefinition;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.util.StringUtils;
+
+import java.math.BigDecimal;
+import java.sql.Timestamp;
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.ZoneOffset;
+import java.time.format.DateTimeFormatter;
+import java.util.*;
+
+/**
+ * class name: CamelJDBCConfiguration
+ *
+ * @author lloyd
+ * @version 1.0
+ * @since 2021/4/14 下午3:16
+ */
+@Configuration
+public class CamelInsertA2Configuration {
+
+    @Value("${insertA2.cron}")
+    private String cron;
+
+
+    @Bean
+    public RouteBuilder routeBuilderWithInsertA2() {
+        return new RouteBuilder() {
+            @Override
+            public void configure() throws Exception {
+                from("quartz:tab?cron="+cron)
+                        .routeId("update-test")
+                        .process(exchange -> {
+                            Message in = exchange.getIn();
+                            in.setHeader("date",getDate());
+                        })
+                        .setBody(simple("select well_id,prod_date,liq_prod_daily from aoid.aoid_daily_yield where prod_date='${header.date}' "))
+                        .to("jdbc:aoid")
+                        .split(body()).process(exchange -> {
+                            Message in = exchange.getIn();
+                            HashMap<String, Object> aRow = in.getBody(HashMap.class);
+                            aRow.putIfAbsent("liq_prod_daily", "0.0");
+                            Timestamp timestamp = (Timestamp) aRow.get("prod_date");
+                            Instant instant = Instant.ofEpochMilli(timestamp.getTime());
+                            LocalDateTime localDateTime = LocalDateTime.ofInstant(instant, ZoneId.systemDefault());
+                            aRow.put("prod_date",localDateTime.toLocalDate().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
+                        })
+                        .setBody(simple(" insert into DMS_DBA01_RCYL (JH, RQ, RCYL) values('${body[well_id]}', to_date(to_char('${body[prod_date]}'),'yyyy-MM-dd'),'${body[liq_prod_daily]}') "))
+                        .to("jdbc:insertA2")
+                        .end();
+            };
+        };
+    }
+    private String getDate(){
+        return  LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+    }
+}

src/main/resources/application.yml

@@ -1,6 +1,11 @@
 camel:
   springboot:
     main-run-controller: true
+# 日志打印级别
+logging:
+  level:
+    root: error
+    com.gct.tools.etlcamelhuge.routeconfig: error
 spring:
   ## 数据库配置
   datasource:
@@ -70,6 +75,50 @@ spring:
         max-lifetime: 1800000
         ## 数据库连接超时时间,默认30秒，即30000
         connection-timeout: 60000
+    ds4:
+      ## Hikari连接池的设置 Hikari 时间单位都是毫秒
+      type: com.zaxxer.hikari.HikariDataSource
+      jdbc-url: jdbc:postgresql://10.72.143.2:54321/calliquid
+      username: root
+      password: 123456
+      driver-class-name: org.postgresql.Driver
+      hikari:
+        ## 连接池名字
+        pool-name: SystemHikariCP
+        ## 最小空闲连接数量
+        minimum-idle: 5
+        ## 空闲连接存活最大时间，默认600000（10分钟）
+        idle-timeout: 60000
+        ## 连接池最大连接数，默认是10
+        maximum-pool-size: 15
+        ## 此属性控制从池返回的连接的默认自动提交行为,默认值：true
+        auto-commit: true
+        ## 此属性控制池中连接的最长生命周期，值0表示无限生命周期，默认1800000即30分钟
+        max-lifetime: 1800000
+        ## 数据库连接超时时间,默认30秒，即30000
+        connection-timeout: 30000
+    ds5:
+      ## Hikari连接池的设置 Hikari 时间单位都是毫秒
+      type: com.zaxxer.hikari.HikariDataSource
+      jdbc-url: jdbc:oracle:thin:@11.71.15.28:1521:oracycn2
+      username: ZD_A2USER
+      password: A2#2014ZD
+      driver-class-name: oracle.jdbc.driver.OracleDriver
+      hikari:
+        ## 连接池名字
+        pool-name: SystemHikariCP
+        ## 最小空闲连接数量
+        minimum-idle: 5
+        ## 空闲连接存活最大时间，默认600000（10分钟）
+        idle-timeout: 60000
+        ## 连接池最大连接数，默认是10
+        maximum-pool-size: 15
+        ## 此属性控制从池返回的连接的默认自动提交行为,默认值：true
+        auto-commit: true
+        ## 此属性控制池中连接的最长生命周期，值0表示无限生命周期，默认1800000即30分钟
+        max-lifetime: 1800000
+        ## 数据库连接超时时间,默认30秒，即30000
+        connection-timeout: 30000
 
 management:
   info:
@@ -135,4 +184,7 @@ gct:
 swagger:
   authorization:
     key-name: token
-  enabled: true
+  enabled: true
+
+insertA2:
+  cron: 0 0 8 * * ?

src/test/java/com/gct/tools/etlcamelhuge/EtlCamelHugeApplicationTests.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.gct.tools.etlcamelhuge.entity.GTBody;
 import com.gct.tools.etlcamelhuge.routeconfig.CamelJDBCConfiguration;
+import com.mysql.cj.log.Log;
 import io.micrometer.core.instrument.util.IOUtils;
 import lombok.Data;
 import org.apache.camel.AggregationStrategy;
@@ -26,6 +27,10 @@ import java.io.InputStream;
 import java.lang.reflect.Array;
 import java.lang.reflect.InvocationTargetException;
 import java.text.SimpleDateFormat;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Date;
@@ -174,27 +179,7 @@ class EtlCamelHugeApplicationTests {
     }
 
     public static void main(String args[]) throws Exception {
-        CamelContext context = new DefaultCamelContext();
-        //new ClassPathXmlApplicationContext("jetty/camel.xml");
-        context.addRoutes(new RouteBuilder() {
-            @Override
-            public void configure() {
-                JSONObject body = new JSONObject();
-                body.put("userno", "zdcycgtlyxt"); // 分配的系统用户账号
-                body.put("password", "Zdcycgtlyxt");
-                from("timer:mytimer?repeatCount=1")
-                        .setBody(simple(body.toJSONString()))
-                        .removeHeaders("CamelHttp*")
-                        .to("http://11.71.3.110:30010/dibs/0/service/token")
-                        .log("${body}:");
-            }
-        });
-        context.start();
-        boolean loop = true;
-        while (loop) {
-            Thread.sleep(25000);
-        }
-        context.stop();
+        System.out.println(LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
     }