get pull 20240724

spring-boot-demo-alwaysuse/pom.xml

@@ -0,0 +1,190 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.springframework.boot</groupId>
+    <artifactId>spring-boot-starter-parent</artifactId>
+    <version>2.3.12.RELEASE</version>
+    <relativePath/> <!-- lookup parent from repository -->
+  </parent>
+  <groupId>com.example</groupId>
+  <artifactId>awaysuse</artifactId>
+  <version>0.0.1-SNAPSHOT</version>
+  <name>awaysuse</name>
+  <description>Demo project for Spring Boot</description>
+  <properties>
+    <java.version>1.8</java.version>
+  </properties>
+  <dependencies>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-web</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <!-- lombok -->
+    <dependency>
+      <groupId>org.projectlombok</groupId>
+      <artifactId>lombok</artifactId>
+      <optional>true</optional>
+    </dependency>
+
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-configuration-processor</artifactId>
+      <optional>true</optional>
+    </dependency>
+
+    <dependency>
+      <groupId>cn.hutool</groupId>
+      <artifactId>hutool-all</artifactId>
+      <version>5.5.2</version>
+    </dependency>
+    <dependency>
+      <groupId>com.alibaba</groupId>
+      <artifactId>fastjson</artifactId>
+      <version>1.2.68</version>
+      <scope>compile</scope>
+    </dependency>
+
+    <dependency>
+      <groupId>uyun.whale</groupId>
+      <artifactId>common-encryption</artifactId>
+      <version>2.0.4-SNAPSHOT</version>
+    </dependency>
+
+    <dependency>
+      <groupId>com.squareup.okhttp</groupId>
+      <artifactId>okhttp</artifactId>
+      <version>2.7.5</version>
+    </dependency>
+
+    <dependency>
+      <groupId>org.apache.commons</groupId>
+      <artifactId>commons-lang3</artifactId>
+    </dependency>
+
+    <!--poi依赖-->
+    <dependency>
+      <groupId>org.apache.poi</groupId>
+      <artifactId>poi</artifactId>
+      <version>3.9</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.poi</groupId>
+      <artifactId>poi-ooxml</artifactId>
+      <version>3.9</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.poi</groupId>
+      <artifactId>poi-ooxml-schemas</artifactId>
+      <version>3.9</version>
+    </dependency>
+
+    <!--elasticsearch-->
+    <dependency>
+      <groupId>org.elasticsearch</groupId>
+      <artifactId>elasticsearch</artifactId>
+      <version>7.5.1</version>
+    </dependency>
+    <!-- Java High Level REST Client -->
+    <dependency>
+      <groupId>org.elasticsearch.client</groupId>
+      <artifactId>elasticsearch-rest-high-level-client</artifactId>
+      <version>7.5.1</version>
+      <exclusions>
+        <exclusion>
+          <groupId>org.elasticsearch</groupId>
+          <artifactId>elasticsearch</artifactId>
+        </exclusion>
+        <exclusion>
+          <groupId>org.elasticsearch.client</groupId>
+          <artifactId>elasticsearch-rest-client</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
+    <!-- Java Low Level REST Client -->
+    <dependency>
+      <groupId>org.elasticsearch.client</groupId>
+      <artifactId>elasticsearch-rest-client</artifactId>
+      <version>7.5.1</version>
+    </dependency>
+
+    <dependency>
+      <groupId>commons-lang</groupId>
+      <artifactId>commons-lang</artifactId>
+      <version>2.6</version>
+    </dependency>
+
+    <!--map工具类-->
+    <dependency>
+      <groupId>org.apache.commons</groupId>
+      <artifactId>commons-collections4</artifactId>
+      <version>4.1</version>
+    </dependency>
+
+
+
+    <dependency>
+      <groupId>net.sf.ezmorph</groupId>
+      <artifactId>ezmorph</artifactId>
+      <version>1.0.6</version>
+    </dependency>
+
+    <dependency>
+      <groupId>org.springframework.retry</groupId>
+      <artifactId>spring-retry</artifactId>
+    </dependency>
+
+    <!-- https://mvnrepository.com/artifact/org.aspectj/aspectjweaver -->
+  <dependency>
+    <groupId>org.aspectj</groupId>
+    <artifactId>aspectjrt</artifactId>
+    <version>1.9.1</version>
+  </dependency>
+  <dependency>
+    <groupId>org.aspectj</groupId>
+    <artifactId>aspectjweaver</artifactId>
+    <version>1.9.1</version>
+  </dependency>
+
+    <dependency>
+      <groupId>org.apache.commons</groupId>
+      <artifactId>commons-lang3</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>com.cronutils</groupId>
+      <artifactId>cron-utils</artifactId>
+      <version>8.0.0</version>
+    </dependency>
+
+    <dependency>
+      <groupId>com.google.guava</groupId>
+      <artifactId>guava</artifactId>
+      <version>28.1-jre</version>
+    </dependency>
+
+    <dependency>
+        <groupId>com.hankcs</groupId>
+        <artifactId>hanlp</artifactId>
+        <version>portable-1.7.8</version>
+    </dependency>
+
+  </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-maven-plugin</artifactId>
+      </plugin>
+    </plugins>
+  </build>
+
+</project>

spring-boot-demo-alwaysuse/src/main/java/com/example/awaysuse/AwaysuseApplication.java

@@ -0,0 +1,15 @@
+package com.example.awaysuse;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@SpringBootApplication
+@EnableScheduling
+public class AwaysuseApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(AwaysuseApplication.class, args);
+    }
+
+}

spring-boot-demo-alwaysuse/src/main/java/com/example/awaysuse/callmsg/CallResultMsg.java

@@ -0,0 +1,15 @@
+package com.example.awaysuse.callmsg;
+
+import com.example.awaysuse.result.ResultCode;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+@Data
+@AllArgsConstructor
+public class CallResultMsg<T> {
+    private boolean result;
+    private int code;
+    private String message;
+    private T data;
+
+}

spring-boot-demo-alwaysuse/src/main/java/com/example/awaysuse/callmsg/CodeAndMsg.java

@@ -0,0 +1,24 @@
+package com.example.awaysuse.callmsg;
+
+import lombok.Data;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+
+@Getter
+public enum CodeAndMsg{
+    SUCCESS(1000, "SUCCESS"),
+    METHODFAIL(2000, "ENCOUNTER AN ERROR WHEN EXECUTE METHOD"),
+    NOT_FOUND(404, "Not Found"),
+    UNKNOWEXCEPTION(3000, "THIS IS AN UNKNOW EXCEPTION"),
+    BAD_GATEWAY(502, "Bad Gateway");
+
+    private int code;
+    private String msg;
+
+    CodeAndMsg(int code, String msg){
+        this.code = code;
+        this.msg = msg;
+    }
+}

spring-boot-demo-alwaysuse/src/main/java/com/example/awaysuse/callmsg/UniformReponseHandler.java

@@ -0,0 +1,47 @@
+package com.example.awaysuse.callmsg;
+
+import com.example.awaysuse.result.ResultCode;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseStatus;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+@RestControllerAdvice(annotations = RestController.class)
+public class UniformReponseHandler<T> {
+
+    @ResponseStatus(HttpStatus.OK)
+    public CallResultMsg sendSuccessResponse(){
+        return new CallResultMsg(true, CodeAndMsg.SUCCESS.getCode(), CodeAndMsg.SUCCESS.getMsg(), null);
+    }
+
+    @ResponseStatus(HttpStatus.OK)
+    public CallResultMsg sendSuccessResponse(T data) {
+        return new CallResultMsg(true, CodeAndMsg.SUCCESS.getCode(), CodeAndMsg.SUCCESS.getMsg(), data);
+    }
+
+    @ExceptionHandler(UserDefinedException.class)
+    @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
+    public CallResultMsg sendErrorResponse_UserDefined(Exception exception){
+        // return new CallResultMsg(false, ((UserDefinedException)exception).getException().getCode(), ((UserDefinedException)exception).getException().getMsg(), null);
+        return new CallResultMsg(false, HttpStatus.INTERNAL_SERVER_ERROR.value(), HttpStatus.INTERNAL_SERVER_ERROR.toString(), null);
+
+    }
+
+
+    @ExceptionHandler(Exception.class)
+    @ResponseStatus(HttpStatus.BAD_GATEWAY)
+    public CallResultMsg badGatewayResponse(Exception exception){
+        if (exception instanceof UserDefinedException) {
+            return this.sendErrorResponse_UserDefined(exception);
+        }
+
+        return new CallResultMsg(false, CodeAndMsg.BAD_GATEWAY.getCode(),CodeAndMsg.BAD_GATEWAY.getMsg(),null);
+    }
+
+
+    @ResponseStatus(HttpStatus.NOT_FOUND)
+    public CallResultMsg  notFoundErrorResponse_System(){
+        return new CallResultMsg(false, CodeAndMsg.NOT_FOUND.getCode(),CodeAndMsg.NOT_FOUND.getMsg(),null);
+    }
+}

spring-boot-demo-alwaysuse/src/main/java/com/example/awaysuse/callmsg/UserDefinedException.java

@@ -0,0 +1,20 @@
+package com.example.awaysuse.callmsg;
+
+import com.example.awaysuse.result.ResultCode;
+
+
+public class UserDefinedException extends RuntimeException {
+    private CodeAndMsg exception;
+
+    public UserDefinedException(CodeAndMsg exception){
+        this.exception = exception;
+    }
+
+    public CodeAndMsg getException() {
+        return exception;
+    }
+
+    public void setException(CodeAndMsg exception) {
+        this.exception = exception;
+    }
+}

spring-boot-demo-alwaysuse/src/main/java/com/example/awaysuse/config/ESConfig.java

@@ -0,0 +1,73 @@
+package com.example.awaysuse.config;
+
+import org.apache.http.HttpHost;
+import org.apache.http.auth.AuthScope;
+import org.apache.http.auth.UsernamePasswordCredentials;
+import org.apache.http.client.CredentialsProvider;
+import org.apache.http.impl.client.BasicCredentialsProvider;
+import org.elasticsearch.client.RestClient;
+import org.elasticsearch.client.RestClientBuilder;
+import org.elasticsearch.client.RestHighLevelClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @auther: fengh
+ * @Date: 2020/7/2 17:04
+ * @Description:
+ */
+@Configuration
+public class ESConfig {
+
+    @Value("${elasticsearch.hosts}")
+    private String hosts;
+    @Value("${elasticsearch.username}")
+    private String username;
+    @Value("${elasticsearch.passowrd}")
+    private String password;
+    @Value("${elasticsearch.schema}")
+    private String schema;
+    @Value("${elasticsearch.connectTimeOut}")
+    private int connectTimeOut;
+    @Value("${elasticsearch.socketTimeOut}")
+    private int socketTimeOut;
+    @Value("${elasticsearch.connectionRequestTimeOut}")
+    private int connectionRequestTimeOut;
+    @Value("${elasticsearch.maxConnectNum}")
+    private int maxConnectNum;
+    @Value("${elasticsearch.maxConnectPerRoute}")
+    private int maxConnectPerRoute;
+
+    @Bean("restHighLevelClient")
+    public RestHighLevelClient client(){
+        CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
+        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));
+        List<HttpHost> hostList = new ArrayList<>();
+        String[] hostArray = hosts.split(",");
+        for (String host : hostArray) {
+            String[] ipPort = host.split(":");
+            hostList.add(new HttpHost(ipPort[0], Integer.parseInt(ipPort[1]), schema));
+        }
+        RestClientBuilder builder = RestClient.builder(hostList.toArray(new HttpHost[0]));
+        // 异步httpclient连接延时配置
+        builder.setRequestConfigCallback(requestConfigBuilder -> {
+            requestConfigBuilder.setConnectTimeout(connectTimeOut);
+            requestConfigBuilder.setSocketTimeout(socketTimeOut);
+            requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeOut);
+            return requestConfigBuilder;
+        });
+        // 异步httpclient连接数配置
+        builder.setHttpClientConfigCallback(httpClientBuilder -> {
+            httpClientBuilder.setMaxConnTotal(maxConnectNum);
+            httpClientBuilder.setMaxConnPerRoute(maxConnectPerRoute);
+            httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
+            return httpClientBuilder;
+        });
+        return new RestHighLevelClient(builder);
+    }
+
+}