ES数据库操作服务

.gitignore

@@ -0,0 +1,33 @@
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/

.mvn/wrapper/MavenWrapperDownloader.java

@@ -0,0 +1,118 @@
/*
 * Copyright 2007-present the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
import java.net.*;
import java.io.*;
import java.nio.channels.*;
import java.util.Properties;
public class MavenWrapperDownloader {
    private static final String WRAPPER_VERSION = "0.5.6";
    /**
     * Default URL to download the maven-wrapper.jar from, if no 'downloadUrl' is provided.
     */
    private static final String DEFAULT_DOWNLOAD_URL = "https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/"
            + WRAPPER_VERSION + "/maven-wrapper-" + WRAPPER_VERSION + ".jar";
    /**
     * Path to the maven-wrapper.properties file, which might contain a downloadUrl property to
     * use instead of the default one.
     */
    private static final String MAVEN_WRAPPER_PROPERTIES_PATH =
            ".mvn/wrapper/maven-wrapper.properties";
    /**
     * Path where the maven-wrapper.jar will be saved to.
     */
    private static final String MAVEN_WRAPPER_JAR_PATH =
            ".mvn/wrapper/maven-wrapper.jar";
    /**
     * Name of the property which should be used to override the default download url for the wrapper.
     */
    private static final String PROPERTY_NAME_WRAPPER_URL = "wrapperUrl";
    public static void main(String args[]) {
        System.out.println("- Downloader started");
        File baseDirectory = new File(args[0]);
        System.out.println("- Using base directory: " + baseDirectory.getAbsolutePath());
        // If the maven-wrapper.properties exists, read it and check if it contains a custom
        // wrapperUrl parameter.
        File mavenWrapperPropertyFile = new File(baseDirectory, MAVEN_WRAPPER_PROPERTIES_PATH);
        String url = DEFAULT_DOWNLOAD_URL;
        if (mavenWrapperPropertyFile.exists()) {
            FileInputStream mavenWrapperPropertyFileInputStream = null;
            try {
                mavenWrapperPropertyFileInputStream = new FileInputStream(mavenWrapperPropertyFile);
                Properties mavenWrapperProperties = new Properties();
                mavenWrapperProperties.load(mavenWrapperPropertyFileInputStream);
                url = mavenWrapperProperties.getProperty(PROPERTY_NAME_WRAPPER_URL, url);
            } catch (IOException e) {
                System.out.println("- ERROR loading '" + MAVEN_WRAPPER_PROPERTIES_PATH + "'");
            } finally {
                try {
                    if (mavenWrapperPropertyFileInputStream != null) {
                        mavenWrapperPropertyFileInputStream.close();
                    }
                } catch (IOException e) {
                    // Ignore ...
                }
            }
        }
        System.out.println("- Downloading from: " + url);
        File outputFile = new File(baseDirectory.getAbsolutePath(), MAVEN_WRAPPER_JAR_PATH);
        if (!outputFile.getParentFile().exists()) {
            if (!outputFile.getParentFile().mkdirs()) {
                System.out.println(
                        "- ERROR creating output directory '" + outputFile.getParentFile().getAbsolutePath() + "'");
            }
        }
        System.out.println("- Downloading to: " + outputFile.getAbsolutePath());
        try {
            downloadFileFromURL(url, outputFile);
            System.out.println("Done");
            System.exit(0);
        } catch (Throwable e) {
            System.out.println("- Error downloading");
            e.printStackTrace();
            System.exit(1);
        }
    }
    private static void downloadFileFromURL(String urlString, File destination) throws Exception {
        if (System.getenv("MVNW_USERNAME") != null && System.getenv("MVNW_PASSWORD") != null) {
            String username = System.getenv("MVNW_USERNAME");
            char[] password = System.getenv("MVNW_PASSWORD").toCharArray();
            Authenticator.setDefault(new Authenticator() {
                @Override
                protected PasswordAuthentication getPasswordAuthentication() {
                    return new PasswordAuthentication(username, password);
                }
            });
        }
        URL website = new URL(urlString);
        ReadableByteChannel rbc;
        rbc = Channels.newChannel(website.openStream());
        FileOutputStream fos = new FileOutputStream(destination);
        fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
        fos.close();
        rbc.close();
    }
}

.mvn/wrapper/maven-wrapper.properties

@@ -0,0 +1,2 @@
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.6.3/apache-maven-3.6.3-bin.zip
wrapperUrl=https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar

mvnw

@@ -0,0 +1,310 @@
#!/bin/sh
# ----------------------------------------------------------------------------
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#    https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.
# ----------------------------------------------------------------------------
# ----------------------------------------------------------------------------
# Maven Start Up Batch script
#
# Required ENV vars:
# ------------------
#   JAVA_HOME - location of a JDK home dir
#
# Optional ENV vars
# -----------------
#   M2_HOME - location of maven2's installed home dir
#   MAVEN_OPTS - parameters passed to the Java VM when running Maven
#     e.g. to debug Maven itself, use
#       set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
#   MAVEN_SKIP_RC - flag to disable loading of mavenrc files
# ----------------------------------------------------------------------------
if [ -z "$MAVEN_SKIP_RC" ] ; then
  if [ -f /etc/mavenrc ] ; then
    . /etc/mavenrc
  fi
  if [ -f "$HOME/.mavenrc" ] ; then
    . "$HOME/.mavenrc"
  fi
fi
# OS specific support.  $var _must_ be set to either true or false.
cygwin=false;
darwin=false;
mingw=false
case "`uname`" in
  CYGWIN*) cygwin=true ;;
  MINGW*) mingw=true;;
  Darwin*) darwin=true
    # Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
    # See https://developer.apple.com/library/mac/qa/qa1170/_index.html
    if [ -z "$JAVA_HOME" ]; then
      if [ -x "/usr/libexec/java_home" ]; then
        export JAVA_HOME="`/usr/libexec/java_home`"
      else
        export JAVA_HOME="/Library/Java/Home"
      fi
    fi
    ;;
esac
if [ -z "$JAVA_HOME" ] ; then
  if [ -r /etc/gentoo-release ] ; then
    JAVA_HOME=`java-config --jre-home`
  fi
fi
if [ -z "$M2_HOME" ] ; then
  ## resolve links - $0 may be a link to maven's home
  PRG="$0"
  # need this for relative symlinks
  while [ -h "$PRG" ] ; do
    ls=`ls -ld "$PRG"`
    link=`expr "$ls" : '.*-> \(.*\)$'`
    if expr "$link" : '/.*' > /dev/null; then
      PRG="$link"
    else
      PRG="`dirname "$PRG"`/$link"
    fi
  done
  saveddir=`pwd`
  M2_HOME=`dirname "$PRG"`/..
  # make it fully qualified
  M2_HOME=`cd "$M2_HOME" && pwd`
  cd "$saveddir"
  # echo Using m2 at $M2_HOME
fi
# For Cygwin, ensure paths are in UNIX format before anything is touched
if $cygwin ; then
  [ -n "$M2_HOME" ] &&
    M2_HOME=`cygpath --unix "$M2_HOME"`
  [ -n "$JAVA_HOME" ] &&
    JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
  [ -n "$CLASSPATH" ] &&
    CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
fi
# For Mingw, ensure paths are in UNIX format before anything is touched
if $mingw ; then
  [ -n "$M2_HOME" ] &&
    M2_HOME="`(cd "$M2_HOME"; pwd)`"
  [ -n "$JAVA_HOME" ] &&
    JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`"
fi
if [ -z "$JAVA_HOME" ]; then
  javaExecutable="`which javac`"
  if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then
    # readlink(1) is not available as standard on Solaris 10.
    readLink=`which readlink`
    if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then
      if $darwin ; then
        javaHome="`dirname \"$javaExecutable\"`"
        javaExecutable="`cd \"$javaHome\" && pwd -P`/javac"
      else
        javaExecutable="`readlink -f \"$javaExecutable\"`"
      fi
      javaHome="`dirname \"$javaExecutable\"`"
      javaHome=`expr "$javaHome" : '\(.*\)/bin'`
      JAVA_HOME="$javaHome"
      export JAVA_HOME
    fi
  fi
fi
if [ -z "$JAVACMD" ] ; then
  if [ -n "$JAVA_HOME"  ] ; then
    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
      # IBM's JDK on AIX uses strange locations for the executables
      JAVACMD="$JAVA_HOME/jre/sh/java"
    else
      JAVACMD="$JAVA_HOME/bin/java"
    fi
  else
    JAVACMD="`which java`"
  fi
fi
if [ ! -x "$JAVACMD" ] ; then
  echo "Error: JAVA_HOME is not defined correctly." >&2
  echo "  We cannot execute $JAVACMD" >&2
  exit 1
fi
if [ -z "$JAVA_HOME" ] ; then
  echo "Warning: JAVA_HOME environment variable is not set."
fi
CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher
# traverses directory structure from process work directory to filesystem root
# first directory with .mvn subdirectory is considered project base directory
find_maven_basedir() {
  if [ -z "$1" ]
  then
    echo "Path not specified to find_maven_basedir"
    return 1
  fi
  basedir="$1"
  wdir="$1"
  while [ "$wdir" != '/' ] ; do
    if [ -d "$wdir"/.mvn ] ; then
      basedir=$wdir
      break
    fi
    # workaround for JBEAP-8937 (on Solaris 10/Sparc)
    if [ -d "${wdir}" ]; then
      wdir=`cd "$wdir/.."; pwd`
    fi
    # end of workaround
  done
  echo "${basedir}"
}
# concatenates all lines of a file
concat_lines() {
  if [ -f "$1" ]; then
    echo "$(tr -s '\n' ' ' < "$1")"
  fi
}
BASE_DIR=`find_maven_basedir "$(pwd)"`
if [ -z "$BASE_DIR" ]; then
  exit 1;
fi
##########################################################################################
# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
# This allows using the maven wrapper in projects that prohibit checking in binary data.
##########################################################################################
if [ -r "$BASE_DIR/.mvn/wrapper/maven-wrapper.jar" ]; then
    if [ "$MVNW_VERBOSE" = true ]; then
      echo "Found .mvn/wrapper/maven-wrapper.jar"
    fi
else
    if [ "$MVNW_VERBOSE" = true ]; then
      echo "Couldn't find .mvn/wrapper/maven-wrapper.jar, downloading it ..."
    fi
    if [ -n "$MVNW_REPOURL" ]; then
      jarUrl="$MVNW_REPOURL/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar"
    else
      jarUrl="https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar"
    fi
    while IFS="=" read key value; do
      case "$key" in (wrapperUrl) jarUrl="$value"; break ;;
      esac
    done < "$BASE_DIR/.mvn/wrapper/maven-wrapper.properties"
    if [ "$MVNW_VERBOSE" = true ]; then
      echo "Downloading from: $jarUrl"
    fi
    wrapperJarPath="$BASE_DIR/.mvn/wrapper/maven-wrapper.jar"
    if $cygwin; then
      wrapperJarPath=`cygpath --path --windows "$wrapperJarPath"`
    fi
    if command -v wget > /dev/null; then
        if [ "$MVNW_VERBOSE" = true ]; then
          echo "Found wget ... using wget"
        fi
        if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
            wget "$jarUrl" -O "$wrapperJarPath"
        else
            wget --http-user=$MVNW_USERNAME --http-password=$MVNW_PASSWORD "$jarUrl" -O "$wrapperJarPath"
        fi
    elif command -v curl > /dev/null; then
        if [ "$MVNW_VERBOSE" = true ]; then
          echo "Found curl ... using curl"
        fi
        if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
            curl -o "$wrapperJarPath" "$jarUrl" -f
        else
            curl --user $MVNW_USERNAME:$MVNW_PASSWORD -o "$wrapperJarPath" "$jarUrl" -f
        fi
    else
        if [ "$MVNW_VERBOSE" = true ]; then
          echo "Falling back to using Java to download"
        fi
        javaClass="$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.java"
        # For Cygwin, switch paths to Windows format before running javac
        if $cygwin; then
          javaClass=`cygpath --path --windows "$javaClass"`
        fi
        if [ -e "$javaClass" ]; then
            if [ ! -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
                if [ "$MVNW_VERBOSE" = true ]; then
                  echo " - Compiling MavenWrapperDownloader.java ..."
                fi
                # Compiling the Java class
                ("$JAVA_HOME/bin/javac" "$javaClass")
            fi
            if [ -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
                # Running the downloader
                if [ "$MVNW_VERBOSE" = true ]; then
                  echo " - Running MavenWrapperDownloader.java ..."
                fi
                ("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$MAVEN_PROJECTBASEDIR")
            fi
        fi
    fi
fi
##########################################################################################
# End of extension
##########################################################################################
export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
if [ "$MVNW_VERBOSE" = true ]; then
  echo $MAVEN_PROJECTBASEDIR
fi
MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
# For Cygwin, switch paths to Windows format before running java
if $cygwin; then
  [ -n "$M2_HOME" ] &&
    M2_HOME=`cygpath --path --windows "$M2_HOME"`
  [ -n "$JAVA_HOME" ] &&
    JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"`
  [ -n "$CLASSPATH" ] &&
    CLASSPATH=`cygpath --path --windows "$CLASSPATH"`
  [ -n "$MAVEN_PROJECTBASEDIR" ] &&
    MAVEN_PROJECTBASEDIR=`cygpath --path --windows "$MAVEN_PROJECTBASEDIR"`
fi
# Provide a "standardized" way to retrieve the CLI args that will
# work with both Windows and non-Windows executions.
MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $@"
export MAVEN_CMD_LINE_ARGS
WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
exec "$JAVACMD" \
  $MAVEN_OPTS \
  -classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
  "-Dmaven.home=${M2_HOME}" "-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
  ${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"

mvnw.cmd

@@ -0,0 +1,182 @@
@REM ----------------------------------------------------------------------------
@REM Licensed to the Apache Software Foundation (ASF) under one
@REM or more contributor license agreements.  See the NOTICE file
@REM distributed with this work for additional information
@REM regarding copyright ownership.  The ASF licenses this file
@REM to you under the Apache License, Version 2.0 (the
@REM "License"); you may not use this file except in compliance
@REM with the License.  You may obtain a copy of the License at
@REM
@REM    https://www.apache.org/licenses/LICENSE-2.0
@REM
@REM Unless required by applicable law or agreed to in writing,
@REM software distributed under the License is distributed on an
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@REM KIND, either express or implied.  See the License for the
@REM specific language governing permissions and limitations
@REM under the License.
@REM ----------------------------------------------------------------------------
@REM ----------------------------------------------------------------------------
@REM Maven Start Up Batch script
@REM
@REM Required ENV vars:
@REM JAVA_HOME - location of a JDK home dir
@REM
@REM Optional ENV vars
@REM M2_HOME - location of maven2's installed home dir
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
@REM     e.g. to debug Maven itself, use
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
@REM ----------------------------------------------------------------------------
@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
@echo off
@REM set title of command window
title %0
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
@if "%MAVEN_BATCH_ECHO%" == "on"  echo %MAVEN_BATCH_ECHO%
@REM set %HOME% to equivalent of $HOME
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
@REM Execute a user defined script before this one
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
if exist "%HOME%\mavenrc_pre.bat" call "%HOME%\mavenrc_pre.bat"
if exist "%HOME%\mavenrc_pre.cmd" call "%HOME%\mavenrc_pre.cmd"
:skipRcPre
@setlocal
set ERROR_CODE=0
@REM To isolate internal variables from possible post scripts, we use another setlocal
@setlocal
@REM ==== START VALIDATION ====
if not "%JAVA_HOME%" == "" goto OkJHome
echo.
echo Error: JAVA_HOME not found in your environment. >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
:OkJHome
if exist "%JAVA_HOME%\bin\java.exe" goto init
echo.
echo Error: JAVA_HOME is set to an invalid directory. >&2
echo JAVA_HOME = "%JAVA_HOME%" >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
@REM ==== END VALIDATION ====
:init
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
@REM Fallback to current working directory if not found.
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
set EXEC_DIR=%CD%
set WDIR=%EXEC_DIR%
:findBaseDir
IF EXIST "%WDIR%"\.mvn goto baseDirFound
cd ..
IF "%WDIR%"=="%CD%" goto baseDirNotFound
set WDIR=%CD%
goto findBaseDir
:baseDirFound
set MAVEN_PROJECTBASEDIR=%WDIR%
cd "%EXEC_DIR%"
goto endDetectBaseDir
:baseDirNotFound
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
cd "%EXEC_DIR%"
:endDetectBaseDir
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
@setlocal EnableExtensions EnableDelayedExpansion
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
:endReadAdditionalConfig
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar"
FOR /F "tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
    IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
)
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
if exist %WRAPPER_JAR% (
    if "%MVNW_VERBOSE%" == "true" (
        echo Found %WRAPPER_JAR%
    )
) else (
    if not "%MVNW_REPOURL%" == "" (
        SET DOWNLOAD_URL="%MVNW_REPOURL%/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar"
    )
    if "%MVNW_VERBOSE%" == "true" (
        echo Couldn't find %WRAPPER_JAR%, downloading it ...
        echo Downloading from: %DOWNLOAD_URL%
    )
    powershell -Command "&{"^
		"$webclient = new-object System.Net.WebClient;"^
		"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
		"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
		"}"^
		"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
		"}"
    if "%MVNW_VERBOSE%" == "true" (
        echo Finished downloading %WRAPPER_JAR%
    )
)
@REM End of extension
@REM Provide a "standardized" way to retrieve the CLI args that will
@REM work with both Windows and non-Windows executions.
set MAVEN_CMD_LINE_ARGS=%*
%MAVEN_JAVA_EXE% %JVM_CONFIG_MAVEN_PROPS% %MAVEN_OPTS% %MAVEN_DEBUG_OPTS% -classpath %WRAPPER_JAR% "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
if ERRORLEVEL 1 goto error
goto end
:error
set ERROR_CODE=1
:end
@endlocal & set ERROR_CODE=%ERROR_CODE%
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPost
@REM check for post script, once with legacy .bat ending and once with .cmd ending
if exist "%HOME%\mavenrc_post.bat" call "%HOME%\mavenrc_post.bat"
if exist "%HOME%\mavenrc_post.cmd" call "%HOME%\mavenrc_post.cmd"
:skipRcPost
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
if "%MAVEN_BATCH_PAUSE%" == "on" pause
if "%MAVEN_TERMINATE_CMD%" == "on" exit %ERROR_CODE%
exit /B %ERROR_CODE%

pom.xml

@@ -0,0 +1,223 @@
<?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.4.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.ai.bss.es</groupId>
    <artifactId>es-manage</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>es-manage</name>
    <description>es manage for Spring Boot</description>
    <properties>
        <java.version>1.8</java.version>
        <!-- 这里必须要填写，因为springboot2.3.2默认的elasticsearch版本为7.6.2,我们使用的是7.4.2，不更改会产生版本不兼容等问题 -->
        <elasticsearch.version>7.4.2</elasticsearch.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
<!--         这里我使用的是elasticsearch的high-level-client 版本要和你的elasticsearch版本对应-->
<!--        <dependency>-->
<!--            <groupId>org.elasticsearch.client</groupId>-->
<!--            <artifactId>elasticsearch-rest-high-level-client</artifactId>-->
<!--            <version>7.4.2</version>-->
<!--            <exclusions>-->
<!--                <exclusion>-->
<!--                    <groupId>org.elasticsearch</groupId>-->
<!--                    <artifactId>elasticsearch</artifactId>-->
<!--                </exclusion>-->
<!--            </exclusions>-->
<!--        </dependency>-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.12</version>
        </dependency>
        <dependency>
            <groupId>com.ai.abc</groupId>
            <artifactId>persistence-es</artifactId>
            <version>2.0-SNAPSHOT</version>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-log4j2</artifactId>
                </exclusion>
<!--                <exclusion>-->
<!--                    <groupId>org.elasticsearch</groupId>-->
<!--                    <artifactId>elasticsearch</artifactId>-->
<!--                </exclusion>-->
<!--                <exclusion>-->
<!--                    <groupId>org.elasticsearch.client</groupId>-->
<!--                    <artifactId>elasticsearch-rest-high-level-client</artifactId>-->
<!--                </exclusion>-->
<!--                <exclusion>-->
<!--                    <groupId>org.projectlombok</groupId>-->
<!--                    <artifactId>lombok</artifactId>-->
<!--                </exclusion>-->
            </exclusions>
        </dependency>
    </dependencies>
    <build>
        <resources>
            <resource>
                <directory>src/main/resources</directory>
                <excludes>
                    <exclude>environment/dev/**</exclude>
                    <exclude>environment/product/**</exclude>
                    <exclude>environment/test/**</exclude>
                </excludes>
            </resource>
            <resource>
                <directory>${project.basedir}/src/main/resources/environment/${env}</directory>
            </resource>
        </resources>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
            <!--            <plugin>
                            <groupId>org.apache.maven.plugins</groupId>
                            <artifactId>maven-resources-plugin</artifactId>
                            <executions>
                                <execution>
                                    <id>copy-resources</id>
                                    <phase>package</phase>
                                    <goals>
                                        <goal>copy-resources</goal>
                                    </goals>
                                    <configuration>
                                        <encoding>UTF-8</encoding>
                                        <outputDirectory>
                                            ${project.build.directory}/config
                                        </outputDirectory>
                                        <resources>
                                            <resource>
                                                <directory>src/main/resources/environment/${env}</directory>
                                                <includes>
                                                    <include>**/*.properties</include>
                                                    <include>**/*.xml</include>
                                                </includes>
                                            </resource>
                                        </resources>
                                    </configuration>
                                </execution>
                            </executions>
                        </plugin>-->
            <!-- The configuration of maven-jar-plugin -->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-jar-plugin</artifactId>
                <version>2.4</version>
                <!-- The configuration of the plugin -->
                <configuration>
                    <!-- Configuration of the archiver -->
                    <archive>
                        <!--生成的jar中，不要包含pom.xml和pom.properties这两个文件-->
                        <addMavenDescriptor>false</addMavenDescriptor>
                        <!-- Manifest specific configuration -->
                        <manifest>
                            <!--是否要把第三方jar放到manifest的classpath中-->
                            <addClasspath>true</addClasspath>
                            <!--生成的manifest中classpath的前缀，因为要把第三方jar放到lib目录下，所以classpath的前缀是lib/-->
                            <classpathPrefix>lib/</classpathPrefix>
                            <!--应用的main class-->
                            <mainClass>com.ai.bss.es.esmanage.EsManageApplication</mainClass>
                        </manifest>
                        <manifestEntries>
                            <Class-Path>./config/</Class-Path>
                        </manifestEntries>
                    </archive>
                    <!--过滤掉不希望包含在jar中的文件-->
                    <excludes>
                        <exclude>**/*.properties</exclude>
                        <exclude>**/*.xml</exclude>
                    </excludes>
                </configuration>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-dependency-plugin</artifactId>
                <version>2.10</version>
                <executions>
                    <execution>
                        <id>copy-dependencies</id>
                        <phase>package</phase>
                        <goals>
                            <goal>copy-dependencies</goal>
                        </goals>
                        <configuration>
                            <outputDirectory>${project.build.directory}/lib</outputDirectory>
                        </configuration>
                    </execution>
                </executions>
            </plugin>
            <!-- The configuration of maven-assembly-plugin -->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-assembly-plugin</artifactId>
                <version>2.4</version>
                <!-- The configuration of the plugin -->
                <configuration>
                    <!-- Specifies the configuration file of the assembly plugin -->
                    <descriptors>
                        <descriptor>${project.basedir}/src/main/assembly/package.xml</descriptor>
                    </descriptors>
                </configuration>
                <executions>
                    <execution>
                        <id>make-assembly</id>
                        <phase>package</phase>
                        <goals>
                            <goal>single</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-surefire-plugin</artifactId>
                <configuration>
                    <skip>true</skip>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

src/main/assembly/package.xml

@@ -0,0 +1,60 @@
<assembly>
  <id>bin</id>
  <!-- 最终打包成一个用于发布的zip文件 -->
  <formats>
    <format>zip</format>
  </formats>
  <!-- Adds dependencies to zip package under lib directory -->
  <dependencySets>
    <dependencySet>
      <!-- 不使用项目的artifact，第三方jar不要解压，打包进zip文件的lib目录 -->
      <useProjectArtifact>false</useProjectArtifact>
      <outputDirectory>lib</outputDirectory>
      <unpack>false</unpack>
      <scope>runtime</scope>
    </dependencySet>
  </dependencySets>
  <fileSets>
    <!-- 把项目相关的说明文件，打包进zip文件的根目录 -->
    <fileSet>
      <directory>${project.basedir}</directory>
      <outputDirectory>/</outputDirectory>
      <includes>
        <include>README*</include>
        <include>LICENSE*</include>
        <include>NOTICE*</include>
      </includes>
    </fileSet>
    <!-- 把项目的配置文件，打包进zip文件的config目录 -->
    <fileSet>
<!--      <directory>/src/main/resources/environment/${env}</directory>-->
      <directory>/src/main/resources</directory>
      <outputDirectory>/config</outputDirectory>
      <includes>
        <include>**/*.properties</include>
        <include>**/*.xml</include>
      </includes>
    </fileSet>
    <!-- 把项目的脚本文件目录（ src/main/scripts ）中的启动脚本文件，打包进zip文件的跟目录 -->
    <fileSet>
      <directory>${project.build.scriptSourceDirectory}</directory>
      <outputDirectory></outputDirectory>
      <includes>
        <include>startup.*</include>
      </includes>
    </fileSet>
    <!-- 把项目自己编译出来的jar文件，打包进zip文件的根目录 -->
    <fileSet>
      <directory>${project.build.directory}</directory>
      <outputDirectory></outputDirectory>
      <includes>
        <include>*.jar</include>
      </includes>
    </fileSet>
  </fileSets>
</assembly>

src/main/java/com/ai/bss/es/esmanage/EsManageApplication.java

@@ -0,0 +1,13 @@
package com.ai.bss.es.esmanage;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class EsManageApplication {
    public static void main(String[] args) {
        SpringApplication.run(EsManageApplication.class, args);
    }
}

src/main/java/com/ai/bss/es/esmanage/controller/EsController.java

@@ -0,0 +1,133 @@
package com.ai.bss.es.esmanage.controller;
import com.ai.bss.es.esmanage.service.EsService;
import com.ai.bss.es.esmanage.utils.RequestEntity;
import com.ai.bss.es.esmanage.utils.ResponseResult;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.MatchQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
import org.elasticsearch.search.aggregations.metrics.AvgAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@RestController
@RequestMapping("/es")
public class EsController {
    @Autowired
    private RestHighLevelClient client;
    @Autowired
    private EsService esService;
    @PostMapping("/execute")
    ResponseResult execute(@RequestBody RequestEntity requestEntity) throws IOException {
//        SearchRequest requestEs = null;
//        String entity = requestEntity.getEntity();
//        String methods = requestEntity.getMethods();
//        String tableName = requestEntity.getTableName();
//        String type = requestEntity.getType();
//        if("search".equals(methods)){
//            requestEs =  new SearchRequest(tableName);
//            SearchResponse searchResponse = client.search(requestEs, RequestOptions.DEFAULT);
//
//            //6、开始处理返回的数据
//            SearchHit[] hits = searchResponse.getHits().getHits();
//            List<String> list = new ArrayList<String>();
//            for (SearchHit hit : hits) {
//                String hitString = hit.getSourceAsString();
//                System.out.println(hitString);
//                list.add(hitString);
//            }
//            ResponseResult.sucess(list);
//        }
//
//        if("GET".equals(methods)){
//            requestEs =  new SearchRequest(tableName);
//            SearchResponse searchResponse = null;//purePersist(requestEs, RequestOptions.DEFAULT);
//
//            //6、开始处理返回的数据
//            SearchHit[] hits = searchResponse.getHits().getHits();
//            List<String> list = new ArrayList<String>();
//            for (SearchHit hit : hits) {
//                String hitString = hit.getSourceAsString();
//                System.out.println(hitString);
//                list.add(hitString);
//            }
//            ResponseResult.sucess(list);
//        }
        return esService.executeEsEntity(requestEntity);
    }
    @RequestMapping("/test")
    List<String> contextLoads() throws IOException {
        //1、创建查询请求，规定查询的索引
        SearchRequest request = new SearchRequest("es_terminal_event");
        //2、创建条件构造
        SearchSourceBuilder builder = new SearchSourceBuilder();
        //3、构造条件
        MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("address", "Lane");
        builder.query(matchQueryBuilder);
        //聚合年龄分布
        TermsAggregationBuilder ageAgg = AggregationBuilders.terms("ageAgg").field("age");
        builder.aggregation(ageAgg);
//
//        //聚合平均年龄
        AvgAggregationBuilder balanceAvg = AggregationBuilders.avg("balanceAvg").field("balance");
        builder.aggregation(balanceAvg);
        List<String> ids = new ArrayList();
        ids.add("981489");
        ids.add("155682");
        BoolQueryBuilder exersiceBoolQuery = QueryBuilders.boolQuery();
        for (String exerciseId: ids)
        {
            exersiceBoolQuery.must(QueryBuilders.termQuery("resourceId", exerciseId));
        }
        builder.query(exersiceBoolQuery);
        //4、将构造好的条件放入请求中
        request.source(builder);
        //5、开始执行发送request请求
        SearchResponse searchResponse = client.search(request, RequestOptions.DEFAULT);
        //6、开始处理返回的数据
        SearchHit[] hits = searchResponse.getHits().getHits();
        List<String> list = new ArrayList<String>();
        for (SearchHit hit : hits) {
            String hitString = hit.getSourceAsString();
            System.out.println(hitString);
            list.add(hitString);
        }
        return list;
    }
}

src/main/java/com/ai/bss/es/esmanage/service/EsService.java

@@ -0,0 +1,11 @@
package com.ai.bss.es.esmanage.service;
import com.ai.bss.es.esmanage.utils.RequestEntity;
import com.ai.bss.es.esmanage.utils.ResponseResult;
public interface EsService {
    ResponseResult executeEsEntity(RequestEntity requestEntity);
}

src/main/java/com/ai/bss/es/esmanage/service/impl/EsServiceImpl.java

@@ -0,0 +1,137 @@
package com.ai.bss.es.esmanage.service.impl;
import com.ai.abc.jpa.elastic.model.ElasticPage;
import com.ai.abc.jpa.elastic.model.PageInfo;
import com.ai.abc.jpa.elastic.model.TimeInfo;
import com.ai.abc.jpa.elastic.repository.ElasticEntityRepository;
import com.ai.abc.jpa.elastic.repository.impl.ElasticEntityRepositoryImpl;
import com.ai.bss.es.esmanage.service.EsService;
import com.ai.bss.es.esmanage.utils.RequestEntity;
import com.ai.bss.es.esmanage.utils.ResponseResult;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import lombok.extern.slf4j.Slf4j;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.TermsQueryBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.*;
@Slf4j
@Service
public class EsServiceImpl implements EsService {
    @Value("${es.server:47.105.160.21:10020}")
    String esServer ;
    ElasticEntityRepository elasticEntityRepository = null;
    private ElasticEntityRepository getElasticEntityRepository(){
        if(elasticEntityRepository==null){
            elasticEntityRepository = new ElasticEntityRepositoryImpl();
            elasticEntityRepository.initServer(esServer);
        }
        return elasticEntityRepository;
    }
    @Override
    public ResponseResult executeEsEntity(RequestEntity requestEntity) {
        if(requestEntity==null){
            return null;
        }
        String methods = requestEntity.getMethods();
        if("SAVE".equals(methods)){
            saveEsEntity(requestEntity);
            return ResponseResult.sucess();
        }else{
            return findEsEntityList(requestEntity);
        }
    }
    private void saveEsEntity(RequestEntity requestEntity){
        getElasticEntityRepository().purePersist(requestEntity.getTableName(), "", requestEntity.getEntity());
    }
    private ResponseResult findEsEntityList(RequestEntity requestEntity) {
        PageInfo pageInfo = new PageInfo();
        int pageSize = requestEntity.getPageSize() == null ? 0 : requestEntity.getPageSize();
        int startNum = requestEntity.getStartNumber() == null ? 0 : requestEntity.getStartNumber()*pageSize;
        pageInfo.setStartNumber(startNum);
        pageInfo.setPageSize(pageSize);
        Map entityMap = null;
        if (!StringUtils.isEmpty(requestEntity.getEntity())) {
            String entityStr = requestEntity.getEntity();
            entityMap = JSONObject.parseObject(entityStr, new TypeReference<Map<String, Object>>() {});
        }
        Map fieldMap = null;
        String entityKey;
        if (entityMap != null && !entityMap.isEmpty()) {
            fieldMap = new HashMap();
            Iterator var10 = entityMap.entrySet().iterator();
            while(var10.hasNext()) {
                Map.Entry<String, Object> entry = (Map.Entry)var10.next();
                entityKey = (String)entry.getKey();
                if (entry.getValue() != null) {
                    TermsQueryBuilder termsQueryBuilder = null;
                    if (entry.getValue().getClass() == JSONArray.class) {
//                        this.log.debug("mapKey=" + sortType + ",entry.getValue()=" + entry.getValue());
//                        termsQueryBuilder = QueryBuilders.termsQuery(sortType, (ArrayList)entry.getValue());
                        fieldMap.put(entityKey,JSONArrayToArrayList((JSONArray)entry.getValue()));
                    } else {
                        String mapValue = entry.getValue().toString();
//                        termsQueryBuilder = QueryBuilders.termsQuery(sortType, new String[]{mapValue});
                        fieldMap.put(entityKey,mapValue);
                    }
                }
//                fieldMap.put(entityKey)
            }
        }
        Map sortMap = new HashMap();
        if(!StringUtils.isEmpty(requestEntity.getSortFieldName())){
            sortMap.put("sortFieldName",requestEntity.getSortFieldName());
            sortMap.put("sortType",requestEntity.getSortType());
        }
        TimeInfo timeInfo =new TimeInfo();
        timeInfo.setStartTime(requestEntity.getStartTime());
        timeInfo.setEndTime(requestEntity.getEndTime());
        timeInfo.setFieldName(requestEntity.getTimeFieldName());
        ElasticPage elasticPage = getElasticEntityRepository().findEntity(requestEntity.getTableName(), fieldMap, timeInfo, pageInfo,sortMap);
        return ResponseResult.sucess(elasticPage.getTotalSize(),elasticPage.getResults());
    }
    private ArrayList<String> JSONArrayToArrayList(JSONArray jsonArray){
        ArrayList<String> listdata = null;
        if (jsonArray != null) {
            listdata = new ArrayList<String>();
            for (int i=0;i<jsonArray.size();i++){
                listdata.add(jsonArray.getString(i));
            }
        }
        return listdata;
    }
    private Object findEsEntity(){
        return null;
    }
}

src/main/java/com/ai/bss/es/esmanage/utils/CommonConsts.java

@@ -0,0 +1,100 @@
package com.ai.bss.es.esmanage.utils;
/**
 * 公共常量类
 *
 * @author chencai
 */
public class CommonConsts {
    /**
     * 接口调用返回的成功编码
     */
    public static final String RESULT_CODE_SUCCESSFUL = "0";
    /**
     * 接口调用返回的失败编码
     */
    public static final String RESULT_CODE_FAILED = "1";
    /**
     * 接口调用返回的成功描述信息
     */
    public static final String RESULT_MSG_SUCCESSFUL = "成功";
    /**
     * 接口调用返回的失败的描述信息
     */
    public static final String RESULT_MSG_FAILED = "失败";
    /**
     * CSV文件列分隔符
     */
    public static final String CSV_COLUMN_SEPARATOR = ",";
    public static final String CSV_COLUMN_SEPARATOR2 = "|";
    /**
     * CSV文件列分隔符
     */
    public static final String CSV_RN = "\r\n";
    /**
     * 最小误差
     */
    public static final double EPSILON = 0.00000000000000022204;
    /**
     * 时间格式转化 yyyyMMdd_HHmmss
     */
    public static final String DATE_FORMAT_YYYYMMDD_HHMMSS = "yyyyMMdd_HHmmss";
    /**
     * 时间格式转化 yyyyMM
     */
    public static final String DATE_FORMAT_YYYYMM = "yyyyMM";
    /**
     * 时间格式转化 yyyyMMdd
     */
    public static final String DATE_FORMAT_YYYYMMDD = "yyyyMMdd";
    /**
     *
     */
    public static final String RESULT_MSG_CREATE_CSV_FAILED = "生成csv文件失败";
    /**
     * uspa组织类型-基础平台
     */
    public static final String USPA_ORG_TYPE_PLATFORM_ORG = "PLATFORM_ORG";
    /**
     * uspa组织类型-行业云
     */
    public static final String USPA_ORG_TYPE_INDUSTRY_ORG = "INDUSTRY_ORG";
    /**
     * uspa组织类型-客户
     */
    public static final String USPA_ORG_TYPE_CUSTOMER_ORG = "CUSTOMER_ORG";
    public static final String CHARSET_UTF8 = "UTF-8";
    public static final String HTTP_CONTENT_TYPE_JSON = "application/json; charset=utf-8";
    private CommonConsts() {}
//
//    /** 
//     * callsTimesMap存放方法被调用的次数O 
//     */
//    public  static ThreadLocal<Map<String, Long >> callsTimesMap = new ThreadLocal<Map<String, Long>>();// new ThreadLocal<>();
//    /** 
//     * methodTotalTmieMap存放方法总耗时 
//     */
//    public  static ThreadLocal<Map<String, Long >> methodTotalTmieMap = new ThreadLocal<Map<String, Long>>();
}

src/main/java/com/ai/bss/es/esmanage/utils/ElasticSearchConfig.java

@@ -0,0 +1,35 @@
package com.ai.bss.es.esmanage.utils;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
 * 给容器中注入一个RestHighLevelClient
 */
@Configuration
public class ElasticSearchConfig {
    @Value("${es.server:47.105.160.21}")
    String esServer ;
    @Value("${es.server.port:10020}")
    Integer esServerPort ;
    @Bean
    public RestHighLevelClient esRestClient(){
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                        //在这里配置你的elasticsearch的情况
                        new HttpHost(esServer, esServerPort, "http")
                )
        );
        return client;
    }
}

src/main/java/com/ai/bss/es/esmanage/utils/RequestEntity.java

@@ -0,0 +1,22 @@
package com.ai.bss.es.esmanage.utils;
import lombok.Getter;
import lombok.Setter;
@Setter
@Getter
public class RequestEntity {
    private String tableName;
    private String type;
    private String methods;
    private String entity;
    private Integer startNumber;
    private Integer pageSize;
    private String startTime;
    private String endTime;
    private String timeFieldName;
    private String sortFieldName;
    private String sortType;
}

src/main/java/com/ai/bss/es/esmanage/utils/ResponseResult.java

@@ -0,0 +1,105 @@
package com.ai.bss.es.esmanage.utils;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
/**
 * 接口响应参数公共类
 *
 * @author chencai
 */
@NoArgsConstructor
@Getter
@Setter
public class ResponseResult<T> {
    /**
     * 结果编码
     */
    private String resultCode;
    /**
     * 结果信息
     */
    private String resultMsg;
    /**
     * 调用轨迹标识
     */
    private Long traceId;
    /**
     * 结果集数量
     */
    private Long totalResultNumber;
    /**
     * 结果集信息
     */
    private T result;
    private ResponseResult(String resultCode, String resultMsg) {
        this.resultCode = resultCode;
        this.resultMsg = resultMsg;
    }
    private ResponseResult(String resultCode, String resultMsg, T result) {
        this.resultCode = resultCode;
        this.resultMsg = resultMsg;
        this.result = result;
    }
    private ResponseResult(String resultCode, String resultMsg, Long totalResuleNumber,
                           T result) {
        this.resultCode = resultCode;
        this.resultMsg = resultMsg;
        this.totalResultNumber = totalResuleNumber;
        this.result = result;
    }
    private ResponseResult(String resultCode, String resultMsg, Long traceId, Long totalResuleNumber,
                           T result) {
        this.resultCode = resultCode;
        this.resultMsg = resultMsg;
        this.traceId = traceId;
        this.totalResultNumber = totalResuleNumber;
        this.result = result;
    }
    
    public static <T> ResponseResult<T> sucess() {
        return new ResponseResult<T>(CommonConsts.RESULT_CODE_SUCCESSFUL, CommonConsts.RESULT_MSG_SUCCESSFUL);
    }
    public static <T> ResponseResult<T> sucess(String resultMsg) {
        return new ResponseResult<T>(CommonConsts.RESULT_CODE_SUCCESSFUL, resultMsg);
    }
    public static <T> ResponseResult<T> sucess(T result) {
        return new ResponseResult<T>(CommonConsts.RESULT_CODE_SUCCESSFUL, CommonConsts.RESULT_MSG_SUCCESSFUL, result);
    }
    public static <T> ResponseResult<T> sucess(long totalResuleNumber, T result) {
        return new ResponseResult<T>(CommonConsts.RESULT_CODE_SUCCESSFUL, CommonConsts.RESULT_MSG_SUCCESSFUL, totalResuleNumber, result);
    }
    public static <T> ResponseResult<T> sucess(Long traceId, Long totalResuleNumber, T result) {
        return new ResponseResult<T>(CommonConsts.RESULT_CODE_SUCCESSFUL, CommonConsts.RESULT_MSG_SUCCESSFUL, traceId, totalResuleNumber, result);
    }
    public static <T> ResponseResult<T> error() {
        return new ResponseResult<T>(CommonConsts.RESULT_CODE_FAILED, CommonConsts.RESULT_MSG_FAILED);
    }
    public static <T> ResponseResult<T> error(String errorMsg) {
        return new ResponseResult<T>(CommonConsts.RESULT_CODE_FAILED, errorMsg);
    }
    public static <T> ResponseResult<T> error(String resultCode, String errorMsg) {
        return new ResponseResult<T>(resultCode, errorMsg);
    }
    public static <T> ResponseResult<T> error(String resultCode, String errorMsg, Long traceId) {
        return new ResponseResult<T>(resultCode, errorMsg, traceId, 0L, null);
    }
}

src/main/resources/application.properties

@@ -0,0 +1,6 @@
server.port=8111
spring.application.name=elastic
es.server=47.105.160.21:10020
es.server.port=10020

src/main/resources/environment/dev/application.properties

@@ -0,0 +1,6 @@
server.port=8111
spring.application.name=elastic
es.server=47.105.160.21:10020
es.server.port=10020

src/main/resources/environment/product/application.properties

@@ -0,0 +1,6 @@
server.port=8111
spring.application.name=elastic
es.server=47.105.160.21:10020
es.server.port=10020

src/main/resources/environment/test/application.properties

@@ -0,0 +1,6 @@
server.port=8111
spring.application.name=elastic
es.server=47.105.160.21:10020
es.server.port=10020

src/test/java/com/ai/bss/es/esmanage/EsManageApplicationTests.java

@@ -0,0 +1,155 @@
package com.ai.bss.es.esmanage;
import com.ai.abc.jpa.elastic.model.ElasticPage;
import com.ai.abc.jpa.elastic.model.PageInfo;
import com.ai.abc.jpa.elastic.model.TimeInfo;
import com.ai.abc.jpa.elastic.repository.ElasticEntityRepository;
import com.ai.abc.jpa.elastic.repository.impl.ElasticEntityRepositoryImpl;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.MatchQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
import org.elasticsearch.search.aggregations.metrics.AvgAggregationBuilder;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.*;
@SpringBootTest
class EsManageApplicationTests {
    @Autowired
    private RestHighLevelClient client;
    @Test
    void contextLoads()  {
        ElasticEntityRepository elasticEntityRepository = new ElasticEntityRepositoryImpl();
        elasticEntityRepository.initServer("47.105.160.21:10020");
//        JSONObject jsonObject = new JSONObject();
//        jsonObject.put("id", "113");
//        jsonObject.put("type", "1");
//        jsonObject.put("name", "yaxin12");
//        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//        jsonObject.put("create_date", df.format(new Date()));
//
//        //插入
//        String entity = jsonObject.toString();
//
//        entity = "{\"dataExchangeProtocol\":\"Hex\",\"detailInfo\":\"2454585858002a0efa90600ef9f1000000b000b01409020a2d1c45672b1f024e1d0a12010000874d00b0\",\"eventSpecId\":57700004350,\"eventSpecName\":\"定位\",\"eventTime\":1603255716747,\"eventTimeStr\":\"2020-10-21 12:48:36 747\",\"eventTypeName\":\"上行消息\",\"imei\":\"\",\"messageTopic\":\"DW\",\"messageTypeId\":57700000031,\"physicalProtocol\":\"TCP\",\"resourceId\":981489,\"resourceName\":\"手持定位仪001\",\"resourceSpecId\":57700004344,\"terminalEventId\":21700,\"terminalSN\":\"\"}";
//        elasticEntityRepository.purePersist("es_terminal_event", "", entity);
        //查询
        Map jsonSearch = new HashMap();
        //jsonSearch.put("id", "101");
//        jsonSearch.put("type", "1");
        //jsonSearch.put("name", "yaxin");
        List<String> ids = new ArrayList<>();
        ids.add("981489");
        ids.add("155682");
        jsonSearch.put("resourceId", ids);
        PageInfo pageInfo = new PageInfo();
        pageInfo.setStartNumber(0);
        pageInfo.setPageSize(20);
//        Map jsonSearchMap = JSONObject.parseObject(jsonSearch.toJSONString(), new TypeReference<Map<String, String>>(){});
//        Map sortMap = new HashMap();
        TimeInfo timeInfo = new TimeInfo();
        timeInfo.setFieldName("eventTimeStr");
        timeInfo.setStartTime("2020-10-28 00:09:51");
        timeInfo.setEndTime("2020-10-28 00:09:53");
        ElasticPage elasticPage = elasticEntityRepository.findEntity("es_terminal_event", null, timeInfo, pageInfo,null);
        System.out.println(elasticPage.getResults());
//        List<String> ids = new ArrayList();
//        ids.add("981489");
//        ids.add("155682");
//        BoolQueryBuilder exersiceBoolQuery = QueryBuilders.boolQuery();
//        for (String exerciseId: ids)
//        {
//            exersiceBoolQuery.must(QueryBuilders.termQuery("resourceId", exerciseId));
//        }
//
//        SearchRequest request = new SearchRequest("es_terminal_event");
        //5、开始执行发送request请求
//        SearchResponse searchResponse = client.search(request, RequestOptions.DEFAULT);
//        SearchRequestBuilder searchRequestBuilder = client.prepareSearch("index name").setTypes("type name")
//                         .setQuery(exersiceBoolQuery)
//                        .addHighlightedField("*")/*星号表示在所有字段都高亮*/.setHighlighterRequireFieldMatch(false)//配置高亮显示搜索结果
//                .setHighlighterPreTags("<高亮前缀标签>").setHighlighterPostTags("<高亮后缀标签>");//配置高亮显示搜索结果
//
//                         searchRequestBuilder = searchRequestBuilder.addAggregation(AggregationBuilders.terms("agg1(聚类返回时根据此key获取聚类结果)")
//                                         .size(1000)/*返回1000条聚类结果*/.field("要在文档中聚类的字段，如果是嵌套的则用点连接父子字段，如【person.company.name】"));
//
//        SearchResponse searchResponse = searchRequestBuilder.setFrom((0) * 10)//分页起始位置（跳过开始的n个）
//                         .setSize(10)//本次返回的文档数量
//                         .execute().actionGet();//执行搜索
    }
    @Test
    List<String> inSearch() throws IOException {
        //1、创建查询请求，规定查询的索引
        SearchRequest request = new SearchRequest("es_terminal_event");
        //2、创建条件构造
        SearchSourceBuilder builder = new SearchSourceBuilder();
//        //3、构造条件
//        MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("address", "Lane");
//        builder.query(matchQueryBuilder);
//        //聚合年龄分布
//        TermsAggregationBuilder ageAgg = AggregationBuilders.terms("ageAgg").field("age");
//        builder.aggregation(ageAgg);
////
////        //聚合平均年龄
//        AvgAggregationBuilder balanceAvg = AggregationBuilders.avg("balanceAvg").field("balance");
//        builder.aggregation(balanceAvg);
        List<String> ids = new ArrayList();
        ids.add("981489");
        ids.add("155682");
        BoolQueryBuilder exersiceBoolQuery = QueryBuilders.boolQuery();
        for (String exerciseId : ids) {
            exersiceBoolQuery.must(QueryBuilders.termQuery("resourceId", exerciseId));
        }
        builder.query(exersiceBoolQuery);
        //4、将构造好的条件放入请求中
        request.source(builder);
        //5、开始执行发送request请求
        SearchResponse searchResponse = client.search(request, RequestOptions.DEFAULT);
        //6、开始处理返回的数据
        SearchHit[] hits = searchResponse.getHits().getHits();
        List<String> list = new ArrayList<String>();
        for (SearchHit hit : hits) {
            String hitString = hit.getSourceAsString();
            System.out.println(hitString);
            list.add(hitString);
        }
        return list;
    }
    }