@ -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/ |
@ -0,0 +1,2 @@ | |||
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.5/apache-maven-3.9.5-bin.zip | |||
wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.2.0/maven-wrapper-3.2.0.jar |
@ -0,0 +1,308 @@ | |||
#!/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. | |||
# ---------------------------------------------------------------------------- | |||
# ---------------------------------------------------------------------------- | |||
# Apache Maven Wrapper startup batch script, version 3.2.0 | |||
# | |||
# Required ENV vars: | |||
# ------------------ | |||
# JAVA_HOME - location of a JDK home dir | |||
# | |||
# Optional ENV vars | |||
# ----------------- | |||
# 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 /usr/local/etc/mavenrc ] ; then | |||
. /usr/local/etc/mavenrc | |||
fi | |||
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 | |||
JAVA_HOME="$(/usr/libexec/java_home)"; export JAVA_HOME | |||
else | |||
JAVA_HOME="/Library/Java/Home"; export JAVA_HOME | |||
fi | |||
fi | |||
;; | |||
esac | |||
if [ -z "$JAVA_HOME" ] ; then | |||
if [ -r /etc/gentoo-release ] ; then | |||
JAVA_HOME=$(java-config --jre-home) | |||
fi | |||
fi | |||
# For Cygwin, ensure paths are in UNIX format before anything is touched | |||
if $cygwin ; then | |||
[ -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 "$JAVA_HOME" ] && [ -d "$JAVA_HOME" ] && | |||
JAVA_HOME="$(cd "$JAVA_HOME" || (echo "cannot cd into $JAVA_HOME."; exit 1); 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="$(\unset -f command 2>/dev/null; \command -v 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 | |||
# 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/.." || exit 1; pwd) | |||
fi | |||
# end of workaround | |||
done | |||
printf '%s' "$(cd "$basedir" || exit 1; pwd)" | |||
} | |||
# concatenates all lines of a file | |||
concat_lines() { | |||
if [ -f "$1" ]; then | |||
# Remove \r in case we run on Windows within Git Bash | |||
# and check out the repository with auto CRLF management | |||
# enabled. Otherwise, we may read lines that are delimited with | |||
# \r\n and produce $'-Xarg\r' rather than -Xarg due to word | |||
# splitting rules. | |||
tr -s '\r\n' ' ' < "$1" | |||
fi | |||
} | |||
log() { | |||
if [ "$MVNW_VERBOSE" = true ]; then | |||
printf '%s\n' "$1" | |||
fi | |||
} | |||
BASE_DIR=$(find_maven_basedir "$(dirname "$0")") | |||
if [ -z "$BASE_DIR" ]; then | |||
exit 1; | |||
fi | |||
MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}; export MAVEN_PROJECTBASEDIR | |||
log "$MAVEN_PROJECTBASEDIR" | |||
########################################################################################## | |||
# 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. | |||
########################################################################################## | |||
wrapperJarPath="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" | |||
if [ -r "$wrapperJarPath" ]; then | |||
log "Found $wrapperJarPath" | |||
else | |||
log "Couldn't find $wrapperJarPath, downloading it ..." | |||
if [ -n "$MVNW_REPOURL" ]; then | |||
wrapperUrl="$MVNW_REPOURL/org/apache/maven/wrapper/maven-wrapper/3.2.0/maven-wrapper-3.2.0.jar" | |||
else | |||
wrapperUrl="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.2.0/maven-wrapper-3.2.0.jar" | |||
fi | |||
while IFS="=" read -r key value; do | |||
# Remove '\r' from value to allow usage on windows as IFS does not consider '\r' as a separator ( considers space, tab, new line ('\n'), and custom '=' ) | |||
safeValue=$(echo "$value" | tr -d '\r') | |||
case "$key" in (wrapperUrl) wrapperUrl="$safeValue"; break ;; | |||
esac | |||
done < "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.properties" | |||
log "Downloading from: $wrapperUrl" | |||
if $cygwin; then | |||
wrapperJarPath=$(cygpath --path --windows "$wrapperJarPath") | |||
fi | |||
if command -v wget > /dev/null; then | |||
log "Found wget ... using wget" | |||
[ "$MVNW_VERBOSE" = true ] && QUIET="" || QUIET="--quiet" | |||
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then | |||
wget $QUIET "$wrapperUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath" | |||
else | |||
wget $QUIET --http-user="$MVNW_USERNAME" --http-password="$MVNW_PASSWORD" "$wrapperUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath" | |||
fi | |||
elif command -v curl > /dev/null; then | |||
log "Found curl ... using curl" | |||
[ "$MVNW_VERBOSE" = true ] && QUIET="" || QUIET="--silent" | |||
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then | |||
curl $QUIET -o "$wrapperJarPath" "$wrapperUrl" -f -L || rm -f "$wrapperJarPath" | |||
else | |||
curl $QUIET --user "$MVNW_USERNAME:$MVNW_PASSWORD" -o "$wrapperJarPath" "$wrapperUrl" -f -L || rm -f "$wrapperJarPath" | |||
fi | |||
else | |||
log "Falling back to using Java to download" | |||
javaSource="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/MavenWrapperDownloader.java" | |||
javaClass="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/MavenWrapperDownloader.class" | |||
# For Cygwin, switch paths to Windows format before running javac | |||
if $cygwin; then | |||
javaSource=$(cygpath --path --windows "$javaSource") | |||
javaClass=$(cygpath --path --windows "$javaClass") | |||
fi | |||
if [ -e "$javaSource" ]; then | |||
if [ ! -e "$javaClass" ]; then | |||
log " - Compiling MavenWrapperDownloader.java ..." | |||
("$JAVA_HOME/bin/javac" "$javaSource") | |||
fi | |||
if [ -e "$javaClass" ]; then | |||
log " - Running MavenWrapperDownloader.java ..." | |||
("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$wrapperUrl" "$wrapperJarPath") || rm -f "$wrapperJarPath" | |||
fi | |||
fi | |||
fi | |||
fi | |||
########################################################################################## | |||
# End of extension | |||
########################################################################################## | |||
# If specified, validate the SHA-256 sum of the Maven wrapper jar file | |||
wrapperSha256Sum="" | |||
while IFS="=" read -r key value; do | |||
case "$key" in (wrapperSha256Sum) wrapperSha256Sum=$value; break ;; | |||
esac | |||
done < "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.properties" | |||
if [ -n "$wrapperSha256Sum" ]; then | |||
wrapperSha256Result=false | |||
if command -v sha256sum > /dev/null; then | |||
if echo "$wrapperSha256Sum $wrapperJarPath" | sha256sum -c > /dev/null 2>&1; then | |||
wrapperSha256Result=true | |||
fi | |||
elif command -v shasum > /dev/null; then | |||
if echo "$wrapperSha256Sum $wrapperJarPath" | shasum -a 256 -c > /dev/null 2>&1; then | |||
wrapperSha256Result=true | |||
fi | |||
else | |||
echo "Checksum validation was requested but neither 'sha256sum' or 'shasum' are available." | |||
echo "Please install either command, or disable validation by removing 'wrapperSha256Sum' from your maven-wrapper.properties." | |||
exit 1 | |||
fi | |||
if [ $wrapperSha256Result = false ]; then | |||
echo "Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised." >&2 | |||
echo "Investigate or delete $wrapperJarPath to attempt a clean download." >&2 | |||
echo "If you updated your Maven version, you need to update the specified wrapperSha256Sum property." >&2 | |||
exit 1 | |||
fi | |||
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 "$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 | |||
# shellcheck disable=SC2086 # safe args | |||
exec "$JAVACMD" \ | |||
$MAVEN_OPTS \ | |||
$MAVEN_DEBUG_OPTS \ | |||
-classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \ | |||
"-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \ | |||
${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@" |
@ -0,0 +1,205 @@ | |||
@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 Apache Maven Wrapper startup batch script, version 3.2.0 | |||
@REM | |||
@REM Required ENV vars: | |||
@REM JAVA_HOME - location of a JDK home dir | |||
@REM | |||
@REM Optional ENV vars | |||
@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 "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %* | |||
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\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 WRAPPER_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.2.0/maven-wrapper-3.2.0.jar" | |||
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO ( | |||
IF "%%A"=="wrapperUrl" SET WRAPPER_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 WRAPPER_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.2.0/maven-wrapper-3.2.0.jar" | |||
) | |||
if "%MVNW_VERBOSE%" == "true" ( | |||
echo Couldn't find %WRAPPER_JAR%, downloading it ... | |||
echo Downloading from: %WRAPPER_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('%WRAPPER_URL%', '%WRAPPER_JAR%')"^ | |||
"}" | |||
if "%MVNW_VERBOSE%" == "true" ( | |||
echo Finished downloading %WRAPPER_JAR% | |||
) | |||
) | |||
@REM End of extension | |||
@REM If specified, validate the SHA-256 sum of the Maven wrapper jar file | |||
SET WRAPPER_SHA_256_SUM="" | |||
FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO ( | |||
IF "%%A"=="wrapperSha256Sum" SET WRAPPER_SHA_256_SUM=%%B | |||
) | |||
IF NOT %WRAPPER_SHA_256_SUM%=="" ( | |||
powershell -Command "&{"^ | |||
"$hash = (Get-FileHash \"%WRAPPER_JAR%\" -Algorithm SHA256).Hash.ToLower();"^ | |||
"If('%WRAPPER_SHA_256_SUM%' -ne $hash){"^ | |||
" Write-Output 'Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised.';"^ | |||
" Write-Output 'Investigate or delete %WRAPPER_JAR% to attempt a clean download.';"^ | |||
" Write-Output 'If you updated your Maven version, you need to update the specified wrapperSha256Sum property.';"^ | |||
" exit 1;"^ | |||
"}"^ | |||
"}" | |||
if ERRORLEVEL 1 goto error | |||
) | |||
@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 "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat" | |||
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\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% | |||
cmd /C exit /B %ERROR_CODE% |
@ -0,0 +1,62 @@ | |||
<?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>3.2.3</version> | |||
<relativePath/> <!-- lookup parent from repository --> | |||
</parent> | |||
<groupId>com.binary</groupId> | |||
<artifactId>weight</artifactId> | |||
<version>0.0.1-SNAPSHOT</version> | |||
<name>weight</name> | |||
<description>Weight project for Spring Boot</description> | |||
<properties> | |||
<java.version>17</java.version> | |||
</properties> | |||
<dependencies> | |||
<dependency> | |||
<groupId>org.apache.commons</groupId> | |||
<artifactId>commons-lang3</artifactId> | |||
</dependency> | |||
<dependency> | |||
<groupId>org.springframework.boot</groupId> | |||
<artifactId>spring-boot-starter-data-jdbc</artifactId> | |||
</dependency> | |||
<dependency> | |||
<groupId>mysql</groupId> | |||
<artifactId>mysql-connector-java</artifactId> | |||
<version>8.0.33</version> | |||
</dependency> | |||
<dependency> | |||
<groupId>com.microsoft.sqlserver</groupId> | |||
<artifactId>mssql-jdbc</artifactId> | |||
<version>11.2.1.jre17</version> | |||
</dependency> | |||
<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> | |||
</dependencies> | |||
<build> | |||
<plugins> | |||
<plugin> | |||
<groupId>org.springframework.boot</groupId> | |||
<artifactId>spring-boot-maven-plugin</artifactId> | |||
</plugin> | |||
</plugins> | |||
</build> | |||
</project> |
@ -0,0 +1,16 @@ | |||
package com.binary.weight; | |||
import org.springframework.boot.SpringApplication; | |||
import org.springframework.boot.autoconfigure.SpringBootApplication; | |||
import org.springframework.scheduling.annotation.EnableScheduling; | |||
//@EnableScheduling | |||
@SpringBootApplication | |||
public class WeightApplication { | |||
public static void main(String[] args) { | |||
SpringApplication.run(WeightApplication.class, args); | |||
} | |||
} |
@ -0,0 +1,27 @@ | |||
package com.binary.weight.config; | |||
import org.springframework.boot.context.properties.ConfigurationProperties; | |||
import org.springframework.boot.jdbc.DataSourceBuilder; | |||
import org.springframework.context.annotation.Bean; | |||
import org.springframework.context.annotation.Configuration; | |||
import org.springframework.context.annotation.Primary; | |||
import javax.sql.DataSource; | |||
@Configuration | |||
public class DatasourceConfig { | |||
@Primary | |||
@Bean | |||
@ConfigurationProperties(prefix = "spring.datasource.mysql") | |||
public DataSource dataSource() { | |||
return DataSourceBuilder.create().build(); | |||
} | |||
@Bean(value = "sqlServerDataSource") | |||
@ConfigurationProperties(prefix = "spring.datasource.sqlserver") | |||
public DataSource sqlServerDataSource() { | |||
return DataSourceBuilder.create().build(); | |||
} | |||
} |
@ -0,0 +1,43 @@ | |||
package com.binary.weight.controller; | |||
import com.binary.weight.entity.Order; | |||
import com.binary.weight.entity.Response; | |||
import com.binary.weight.service.OrderService; | |||
import org.springframework.beans.factory.annotation.Autowired; | |||
import org.springframework.web.bind.annotation.*; | |||
import java.util.List; | |||
@RestController | |||
@RequestMapping("/order") | |||
public class OrderController { | |||
@Autowired | |||
private OrderService orderService; | |||
// 增加订单 | |||
@PostMapping | |||
public Response addOrder(@RequestBody Order order) { | |||
int result = orderService.addOrder(order); | |||
if (result > 0) { | |||
return new Response("ok", true, null); | |||
} else { | |||
return new Response("error", false, null); | |||
} | |||
} | |||
// 获取所有订单 | |||
@GetMapping | |||
public Response getAllOrders() { | |||
List<Order> orders = orderService.getOrders(); | |||
return Response.success(orders); | |||
} | |||
// 根据ID获取订单 | |||
@GetMapping("/{id}") | |||
public Response getOrderById(@PathVariable int id) { | |||
Order order = orderService.getOrderById(id); | |||
return Response.success(order); | |||
} | |||
} |
@ -0,0 +1,23 @@ | |||
package com.binary.weight.controller; | |||
import com.binary.weight.service.SSEService; | |||
import jakarta.annotation.Resource; | |||
import org.springframework.http.MediaType; | |||
import org.springframework.web.bind.annotation.CrossOrigin; | |||
import org.springframework.web.bind.annotation.GetMapping; | |||
import org.springframework.web.bind.annotation.RestController; | |||
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; | |||
@RestController | |||
@CrossOrigin | |||
public class SSEController { | |||
@Resource | |||
private SSEService sseService; | |||
@GetMapping(value = "/events", produces = MediaType.TEXT_EVENT_STREAM_VALUE) | |||
public SseEmitter handleEvents() { | |||
return sseService.handleEvents(); | |||
} | |||
} |
@ -0,0 +1,29 @@ | |||
package com.binary.weight.controller; | |||
import com.binary.weight.service.WeightService; | |||
import jakarta.annotation.Resource; | |||
import jakarta.servlet.http.HttpServletResponse; | |||
import org.springframework.web.bind.annotation.CrossOrigin; | |||
import org.springframework.web.bind.annotation.GetMapping; | |||
import org.springframework.web.bind.annotation.RestController; | |||
import java.io.IOException; | |||
@RestController | |||
@CrossOrigin | |||
public class WeightController { | |||
@Resource | |||
private WeightService weightService; | |||
@GetMapping("weight") | |||
public void getWeight(HttpServletResponse response) throws IOException { | |||
response.setContentType("application/json;charset=UTF-8"); | |||
response.setHeader("Content-Encoding", "gzip"); | |||
response.getOutputStream().write(weightService.getWeightData()); | |||
response.getOutputStream().flush(); | |||
} | |||
} |
@ -0,0 +1,231 @@ | |||
package com.binary.weight.entity; | |||
public class Order { | |||
private int id; | |||
private String orderNo; | |||
private String receiver; | |||
private String salesTy; | |||
private String goods1; | |||
private String tonnage1; | |||
private String goods2; | |||
private String tonnage2; | |||
private String goods3; | |||
private String tonnage3; | |||
private String goods4; | |||
private String tonnage4; | |||
private String shipNo; | |||
private String transportInfo; | |||
private String wharf; | |||
private String carTeam1; | |||
private String cars1; | |||
private String carTeam2; | |||
private String cars2; | |||
private String carTeam3; | |||
private String cars3; | |||
private String carTeam4; | |||
private String cars4; | |||
private String orderTime; | |||
private String remark; | |||
public int getId() { | |||
return id; | |||
} | |||
public void setId(int id) { | |||
this.id = id; | |||
} | |||
public String getOrderNo() { | |||
return orderNo; | |||
} | |||
public void setOrderNo(String orderNo) { | |||
this.orderNo = orderNo; | |||
} | |||
public String getReceiver() { | |||
return receiver; | |||
} | |||
public void setReceiver(String receiver) { | |||
this.receiver = receiver; | |||
} | |||
public String getSalesTy() { | |||
return salesTy; | |||
} | |||
public void setSalesTy(String salesTy) { | |||
this.salesTy = salesTy; | |||
} | |||
public String getGoods1() { | |||
return goods1; | |||
} | |||
public void setGoods1(String goods1) { | |||
this.goods1 = goods1; | |||
} | |||
public String getTonnage1() { | |||
return tonnage1; | |||
} | |||
public void setTonnage1(String tonnage1) { | |||
this.tonnage1 = tonnage1; | |||
} | |||
public String getGoods2() { | |||
return goods2; | |||
} | |||
public void setGoods2(String goods2) { | |||
this.goods2 = goods2; | |||
} | |||
public String getTonnage2() { | |||
return tonnage2; | |||
} | |||
public void setTonnage2(String tonnage2) { | |||
this.tonnage2 = tonnage2; | |||
} | |||
public String getGoods3() { | |||
return goods3; | |||
} | |||
public void setGoods3(String goods3) { | |||
this.goods3 = goods3; | |||
} | |||
public String getTonnage3() { | |||
return tonnage3; | |||
} | |||
public void setTonnage3(String tonnage3) { | |||
this.tonnage3 = tonnage3; | |||
} | |||
public String getGoods4() { | |||
return goods4; | |||
} | |||
public void setGoods4(String goods4) { | |||
this.goods4 = goods4; | |||
} | |||
public String getTonnage4() { | |||
return tonnage4; | |||
} | |||
public void setTonnage4(String tonnage4) { | |||
this.tonnage4 = tonnage4; | |||
} | |||
public String getShipNo() { | |||
return shipNo; | |||
} | |||
public void setShipNo(String shipNo) { | |||
this.shipNo = shipNo; | |||
} | |||
public String getTransportInfo() { | |||
return transportInfo; | |||
} | |||
public void setTransportInfo(String transportInfo) { | |||
this.transportInfo = transportInfo; | |||
} | |||
public String getWharf() { | |||
return wharf; | |||
} | |||
public void setWharf(String wharf) { | |||
this.wharf = wharf; | |||
} | |||
public String getCarTeam1() { | |||
return carTeam1; | |||
} | |||
public void setCarTeam1(String carTeam1) { | |||
this.carTeam1 = carTeam1; | |||
} | |||
public String getCars1() { | |||
return cars1; | |||
} | |||
public void setCars1(String cars1) { | |||
this.cars1 = cars1; | |||
} | |||
public String getCarTeam2() { | |||
return carTeam2; | |||
} | |||
public void setCarTeam2(String carTeam2) { | |||
this.carTeam2 = carTeam2; | |||
} | |||
public String getCars2() { | |||
return cars2; | |||
} | |||
public void setCars2(String cars2) { | |||
this.cars2 = cars2; | |||
} | |||
public String getCarTeam3() { | |||
return carTeam3; | |||
} | |||
public void setCarTeam3(String carTeam3) { | |||
this.carTeam3 = carTeam3; | |||
} | |||
public String getCars3() { | |||
return cars3; | |||
} | |||
public void setCars3(String cars3) { | |||
this.cars3 = cars3; | |||
} | |||
public String getCarTeam4() { | |||
return carTeam4; | |||
} | |||
public void setCarTeam4(String carTeam4) { | |||
this.carTeam4 = carTeam4; | |||
} | |||
public String getCars4() { | |||
return cars4; | |||
} | |||
public void setCars4(String cars4) { | |||
this.cars4 = cars4; | |||
} | |||
public String getOrderTime() { | |||
return orderTime; | |||
} | |||
public void setOrderTime(String orderTime) { | |||
this.orderTime = orderTime; | |||
} | |||
public String getRemark() { | |||
return remark; | |||
} | |||
public void setRemark(String remark) { | |||
this.remark = remark; | |||
} | |||
// Getter和Setter方法省略 | |||
} |
@ -0,0 +1,44 @@ | |||
package com.binary.weight.entity; | |||
public class Response { | |||
private String message; | |||
private boolean status; | |||
private Object data; | |||
public Response(String message, boolean status, Object data) { | |||
this.message = message; | |||
this.status = status; | |||
this.data = data; | |||
} | |||
public static Response success(Object data) { | |||
return new Response(null, true, data); | |||
} | |||
public String getMessage() { | |||
return message; | |||
} | |||
public void setMessage(String message) { | |||
this.message = message; | |||
} | |||
public boolean isStatus() { | |||
return status; | |||
} | |||
public void setStatus(boolean status) { | |||
this.status = status; | |||
} | |||
public Object getData() { | |||
return data; | |||
} | |||
public void setData(Object data) { | |||
this.data = data; | |||
} | |||
} |
@ -0,0 +1,36 @@ | |||
package com.binary.weight.service; | |||
import com.binary.weight.entity.Order; | |||
import org.springframework.beans.factory.annotation.Autowired; | |||
import org.springframework.beans.factory.annotation.Qualifier; | |||
import org.springframework.jdbc.core.BeanPropertyRowMapper; | |||
import org.springframework.jdbc.core.JdbcTemplate; | |||
import org.springframework.stereotype.Service; | |||
import javax.sql.DataSource; | |||
import java.util.List; | |||
@Service | |||
public class OrderService { | |||
private final JdbcTemplate jdbcTemplate; | |||
public OrderService(@Qualifier("sqlServerDataSource") DataSource sqlServerDatasource) { | |||
this.jdbcTemplate = new JdbcTemplate(sqlServerDatasource); | |||
} | |||
public int addOrder(Order order) { | |||
String sql = "INSERT INTO tbl_order (orderno, receiver, salesty, goods1, tonnage1, goods2, tonnage2, goods3, tonnage3, goods4, tonnage4, shipno, transportinfo, wharf, car_team1, cars1, car_team2, cars2, car_team3, cars3, car_team4, cars4, order_time, remark) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; | |||
return jdbcTemplate.update(sql, order.getOrderNo(), order.getReceiver(), order.getSalesTy(), order.getGoods1(), order.getTonnage1(), order.getGoods2(), order.getTonnage2(), order.getGoods3(), order.getTonnage3(), order.getGoods4(), order.getTonnage4(), order.getShipNo(), order.getTransportInfo(), order.getWharf(), order.getCarTeam1(), order.getCars1(), order.getCarTeam2(), order.getCars2(), order.getCarTeam3(), order.getCars3(), order.getCarTeam4(), order.getCars4(), order.getOrderTime(), order.getRemark()); | |||
} | |||
public List<Order> getOrders() { | |||
String sql = "SELECT * FROM tbl_order"; | |||
return jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(Order.class)); | |||
} | |||
public Order getOrderById(int id) { | |||
String sql = "SELECT * FROM tbl_order WHERE id = ?"; | |||
return jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(Order.class), id); | |||
} | |||
} |
@ -0,0 +1,37 @@ | |||
package com.binary.weight.service; | |||
import org.apache.catalina.connector.ClientAbortException; | |||
import org.springframework.stereotype.Service; | |||
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; | |||
import java.io.IOException; | |||
import java.util.List; | |||
import java.util.concurrent.CopyOnWriteArrayList; | |||
@Service | |||
public class SSEService { | |||
private final List<SseEmitter> emitters = new CopyOnWriteArrayList<>(); | |||
public SseEmitter handleEvents() { | |||
SseEmitter emitter = new SseEmitter(0L); | |||
emitters.add(emitter); | |||
emitter.onCompletion(() -> emitters.remove(emitter)); | |||
emitter.onTimeout(() -> emitters.remove(emitter)); | |||
return emitter; | |||
} | |||
public void sendMessage(Object data) { | |||
for (SseEmitter emitter : emitters) { | |||
try { | |||
emitter.send(data); | |||
} catch (ClientAbortException e) { | |||
// ignore | |||
} catch (IOException e) { | |||
e.printStackTrace(); | |||
} | |||
} | |||
} | |||
} |
@ -0,0 +1,73 @@ | |||
package com.binary.weight.service; | |||
import jakarta.annotation.Resource; | |||
import org.slf4j.Logger; | |||
import org.slf4j.LoggerFactory; | |||
import org.springframework.beans.factory.annotation.Qualifier; | |||
import org.springframework.jdbc.core.JdbcTemplate; | |||
import org.springframework.stereotype.Service; | |||
import javax.sql.DataSource; | |||
import java.util.List; | |||
import java.util.Map; | |||
@Service | |||
public class SyncService { | |||
private JdbcTemplate sqlServerJdbcTemplate; | |||
private JdbcTemplate jdbcTemplate; | |||
@Resource | |||
private WeightService weightService; | |||
@Resource | |||
private SSEService sseService; | |||
Logger logger = LoggerFactory.getLogger(SyncService.class); | |||
public SyncService(@Qualifier("sqlServerDataSource") DataSource sqlServerDatasource, DataSource dataSource) { | |||
this.sqlServerJdbcTemplate = new JdbcTemplate(sqlServerDatasource); | |||
this.jdbcTemplate = new JdbcTemplate(dataSource); | |||
} | |||
public void sync() { | |||
long start = System.currentTimeMillis(); | |||
String sql = "SELECT TOP 1000 * FROM tbl_weight_info WHERE id > ?"; | |||
String id = jdbcTemplate.queryForObject("select max(id) from tbl_weight_info", String.class); | |||
List<Map<String, Object>> rows = sqlServerJdbcTemplate.queryForList(sql, id); | |||
// 动态生成插入语句 | |||
if (!rows.isEmpty()) { | |||
StringBuilder insertSql = new StringBuilder("INSERT INTO tbl_weight_info ("); | |||
// 获取列名并构建列部分的SQL | |||
String[] columnNames = rows.get(0).keySet().toArray(new String[0]); | |||
for (String column : columnNames) { | |||
insertSql.append("`").append(column).append("`").append(","); | |||
} | |||
insertSql.setLength(insertSql.length() - 1); // 去掉最后一个逗号 | |||
insertSql.append(") VALUES ("); | |||
// 构建值部分的SQL | |||
insertSql.append("?,".repeat(columnNames.length)); | |||
insertSql.setLength(insertSql.length() - 1); // 去掉最后一个逗号 | |||
insertSql.append(")"); | |||
String finalInsertSql = insertSql.toString(); | |||
// 准备批量插入的数据 | |||
List<Object[]> batchArgs = rows.stream() | |||
.map(row -> row.values().toArray()) | |||
.toList(); | |||
// 执行批量插入 | |||
jdbcTemplate.batchUpdate(finalInsertSql, batchArgs); | |||
} | |||
sseService.sendMessage(rows); | |||
weightService.removeCache(); | |||
logger.info("同步数据:" + rows.size() + "条"); | |||
} | |||
} |
@ -0,0 +1,49 @@ | |||
package com.binary.weight.service; | |||
import com.fasterxml.jackson.databind.ObjectMapper; | |||
import jakarta.annotation.Resource; | |||
import org.springframework.jdbc.core.JdbcTemplate; | |||
import org.springframework.stereotype.Service; | |||
import java.io.ByteArrayOutputStream; | |||
import java.io.IOException; | |||
import java.nio.charset.StandardCharsets; | |||
import java.util.zip.GZIPOutputStream; | |||
@Service | |||
public class WeightService { | |||
private byte[] cache; | |||
@Resource | |||
private JdbcTemplate jdbcTemplate; | |||
public byte[] getWeightData() { | |||
String sql = "SELECT net, carno, receiver, remark, goods, YEAR(gross_time) as `year`, MONTH(gross_time) as `month`, DAY(gross_time) as `day`, TIME(gross_time) as `time` FROM tbl_weight_info"; | |||
if (cache == null) { | |||
ObjectMapper objectMapper = new ObjectMapper(); | |||
try ( | |||
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); | |||
GZIPOutputStream gzipOutputStream = new GZIPOutputStream(byteArrayOutputStream, 4096 * 8) | |||
) { | |||
String json = objectMapper.writeValueAsString(jdbcTemplate.queryForList(sql)); | |||
gzipOutputStream.write(json.getBytes(StandardCharsets.UTF_8)); | |||
gzipOutputStream.finish(); | |||
cache = byteArrayOutputStream.toByteArray(); | |||
} catch (IOException e) { | |||
throw new RuntimeException(e); | |||
} | |||
} | |||
return cache; | |||
} | |||
public void removeCache() { | |||
cache = null; | |||
} | |||
} |
@ -0,0 +1,21 @@ | |||
package com.binary.weight.timer; | |||
import com.binary.weight.service.SyncService; | |||
import jakarta.annotation.Resource; | |||
import org.springframework.scheduling.annotation.Scheduled; | |||
import org.springframework.stereotype.Component; | |||
import java.io.IOException; | |||
@Component | |||
public class WeightDataTimer { | |||
@Resource | |||
private SyncService syncService; | |||
@Scheduled(fixedRate = 120000) | |||
public void test() throws IOException { | |||
syncService.sync(); | |||
} | |||
} |
@ -0,0 +1,18 @@ | |||
spring: | |||
datasource: | |||
mysql: | |||
jdbc-url: jdbc:mysql://192.168.1.152:3307/eagle-cloud-plus?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8 | |||
username: root | |||
password: Cnqisoft@2020 | |||
driver-class-name: com.mysql.cj.jdbc.Driver | |||
sqlserver: | |||
jdbc-url: jdbc:sqlserver://221.179.56.134:51433;DatabaseName=WEIGHT55;encrypt=false;trustServerCertificate=true; | |||
username: sa | |||
password: ABCabc12345 | |||
driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver | |||
profiles: | |||
active: prod | |||
server: | |||
port: 8005 |
@ -0,0 +1,12 @@ | |||
spring: | |||
application: | |||
name: dispatch-server | |||
cloud: | |||
nacos: | |||
server-addr: 192.168.1.35:8848 | |||
config: | |||
file-extension: yaml | |||
discovery: | |||
ip: 192.168.1.152 | |||
port: 8006 |
@ -0,0 +1,101 @@ | |||
//package com.binary.demo; | |||
// | |||
//import org.junit.jupiter.api.Test; | |||
// | |||
//import java.io.IOException; | |||
//import java.io.InputStream; | |||
//import java.nio.file.*; | |||
//import java.nio.file.attribute.BasicFileAttributes; | |||
//import java.sql.SQLException; | |||
// | |||
//class DemoApplicationTests { | |||
// | |||
// | |||
// | |||
// @Test | |||
// void test() throws SQLException, IOException { | |||
// Path startPath = Paths.get("C:/Users/Binary/Desktop/terra_b3dms/Block"); // 替换为你的文件夹路径 | |||
// | |||
// try { | |||
// Files.walkFileTree(startPath, new SimpleFileVisitor<Path>() { | |||
// @Override | |||
// public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException { | |||
// String fullPath = file.toString().toLowerCase(); | |||
// if (fullPath.endsWith(".b3dm")) { | |||
// Path glbPath = file.getParent().resolve(file.getFileName() + ".glb"); | |||
// Path gltfPath = file.getParent().resolve(file.getFileName() + ".gltf"); | |||
// | |||
// if (Files.notExists(glbPath)) { | |||
// b3dmToGlb(fullPath, glbPath.toString()); | |||
// } | |||
// | |||
// if (Files.notExists(gltfPath)) { | |||
// glbToGltf(glbPath.toString(), gltfPath.toString()); | |||
// } | |||
// | |||
// optimizeGlb(gltfPath.toString(), glbPath.toString()); | |||
// } | |||
// | |||
// return FileVisitResult.CONTINUE; | |||
// } | |||
// | |||
// @Override | |||
// public FileVisitResult visitFileFailed(Path file, IOException exc) { | |||
// // 可以在这里处理访问失败的情况 | |||
// System.err.println("Failed to access file: " + file + " due to " + exc); | |||
// return FileVisitResult.CONTINUE; | |||
// } | |||
// }); | |||
// } catch (IOException e) { | |||
// e.printStackTrace(); | |||
// } | |||
// | |||
// } | |||
// | |||
// public void b3dmToGlb(String b3dmPath, String glbPath) throws IOException { | |||
// ProcessBuilder processBuilder = new ProcessBuilder("C:/Users/Binary/AppData/Roaming/npm/3d-tiles-tools.cmd", "b3dmToGlb", "-f", "-i", b3dmPath, "-o", glbPath); | |||
// Process process = processBuilder.start(); | |||
// int i; | |||
// try { | |||
// InputStream inputStream = process.getInputStream(); | |||
// byte[] bytes = inputStream.readAllBytes(); | |||
// System.out.println(new String(bytes)); | |||
// i = process.waitFor(); | |||
// } catch (InterruptedException e) { | |||
// throw new RuntimeException(e); | |||
// } | |||
// System.out.println(i); | |||
// } | |||
// | |||
// public void glbToGltf(String glbPath, String gltfPath) throws IOException { | |||
// ProcessBuilder processBuilder = new ProcessBuilder("C:/Users/Binary/AppData/Roaming/npm/gltf-pipeline.cmd", "-i", glbPath, "-o", gltfPath); | |||
// Process process = processBuilder.start(); | |||
// int i; | |||
// try { | |||
// InputStream inputStream = process.getErrorStream(); | |||
// byte[] bytes = inputStream.readAllBytes(); | |||
// System.out.println(new String(bytes)); | |||
// i = process.waitFor(); | |||
// } catch (InterruptedException e) { | |||
// throw new RuntimeException(e); | |||
// } | |||
// | |||
// System.out.println(i); | |||
// } | |||
// | |||
// public void optimizeGlb(String gltfPath, String glbPath) throws IOException { | |||
// ProcessBuilder processBuilder = new ProcessBuilder("D:/gltfpack.exe", "-cc", "-tc", "-i", gltfPath, "-o", glbPath); | |||
// Process process = processBuilder.start(); | |||
// int i; | |||
// try { | |||
// InputStream inputStream = process.getErrorStream(); | |||
// byte[] bytes = inputStream.readAllBytes(); | |||
// System.out.println(new String(bytes)); | |||
// i = process.waitFor(); | |||
// } catch (InterruptedException e) { | |||
// throw new RuntimeException(e); | |||
// } | |||
// | |||
// System.out.println(i); | |||
// } | |||
//} |
@ -0,0 +1,20 @@ | |||
//package com.binary.demo; | |||
// | |||
//import jakarta.annotation.Resource; | |||
//import org.junit.jupiter.api.Test; | |||
//import org.springframework.boot.test.context.SpringBootTest; | |||
// | |||
//@SpringBootTest | |||
//public class DemoTest { | |||
// | |||
// @Resource | |||
// private SyncService syncService; | |||
// | |||
// @Test | |||
// public void test() throws InterruptedException { | |||
// while (true) { | |||
// syncService.sync(); | |||
// Thread.sleep(5000); | |||
// } | |||
// } | |||
//} |