auto make

pom.xml

@@ -103,10 +103,10 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-actuator</artifactId>
-        </dependency>
+<!--        <dependency>-->
+<!--            <groupId>org.springframework.boot</groupId>-->
+<!--            <artifactId>spring-boot-starter-actuator</artifactId>-->
+<!--        </dependency>-->
         <dependency>
             <groupId>org.springframework.integration</groupId>
             <artifactId>spring-integration-jms</artifactId>
@@ -185,7 +185,7 @@
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>fastjson</artifactId>
-            <version>1.2.69</version>
+            <version>2.0.6</version>
         </dependency>
         <dependency>
             <groupId>org.assertj</groupId>

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

@@ -50,7 +50,7 @@ public class GtController {
     public JSONObject sendGTSJ(@RequestBody GTBody gtBody){
         String startDate = gtBody.getStartDate();
         String endDate = gtBody.getEndDate();
-        List<String> wellList = gtBody.getWellList().stream().map(x->x.toString()).collect(Collectors.toList());
+        List<String> wellList = (List<String>) gtBody.getWellList().stream().map(x->x.toString()).collect(Collectors.toList());
         JSONObject jsonObject = new JSONObject();
         jdbcTemplate = new JdbcTemplate(dataSource);
         long sumData = 0;

src/main/resources/application.yml

@@ -4,8 +4,8 @@ camel:
 # 日志打印级别
 logging:
   level:
-    root: error
-    com.gct.tools.etlcamelhuge.routeconfig: error
+    root: debug
+    com.gct.tools.etlcamelhuge.routeconfig: debug
 spring:
   ## 数据库配置
   datasource:
@@ -141,16 +141,6 @@ server:
   port: 9999
 
 
-rocketmq:
-  #rocketmq的路由调度器的地址
-  name-server: 10.72.143.2:9876
-  producer:
-    # 消息分组
-    group: aoid
-    # 超时时间
-    sendMessageTimeout: 300000
-    access-key: 123456
-    secret-key: 123456
 gct:
   rocketmq:
     one:

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

@@ -1,45 +1,26 @@
 package com.gct.tools.etlcamelhuge;
 
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.gct.tools.etlcamelhuge.entity.GTBody;
+import com.gct.tools.etlcamelhuge.MQ.MessageProducer;
+import com.gct.tools.etlcamelhuge.entity.DiagnoseMsg;
 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;
-import org.apache.camel.CamelContext;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.http.common.HttpMessage;
-import org.apache.camel.impl.DefaultCamelContext;
-import org.apache.camel.model.ModelCamelContext;
 import org.junit.jupiter.api.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.context.annotation.Bean;
 import org.springframework.test.context.junit4.SpringRunner;
 
-import java.io.IOException;
-import java.io.InputStream;
+import javax.annotation.Resource;
 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;
 import java.util.List;
 
-import static org.junit.Assert.assertEquals;
-
 @RunWith(SpringRunner.class)
-@SpringBootTest
+@SpringBootTest(classes = EtlCamelHugeApplication.class)
 class EtlCamelHugeApplicationTests {
 
    /* @Autowired
@@ -181,6 +162,13 @@ class EtlCamelHugeApplicationTests {
     public static void main(String args[]) throws Exception {
         System.out.println(LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
     }
+    @Resource(name = "diagnoseMessageProducer")
+    private MessageProducer producer;
 
+    @Test
+    public void testProducer(){
+        producer.send(new DiagnoseMsg("xx1","asdf","0","2225-12-12 12:12:56"
+                ,"123.,2,3,2,31.2.31.23.0","dfasdf",12,12));
+    }
 
 }