Compare commits
No commits in common. 'master' and 'x32' have entirely different histories.
@ -1,33 +0,0 @@
|
||||
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/
|
||||
Binary file not shown.
@ -1,2 +0,0 @@
|
||||
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,6 @@
|
||||
export JAVA_HOME=/usr/lib/jvm/jdk1.8.0_271
|
||||
export JRE_HOME=${JAVA_HOME}/jre
|
||||
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
|
||||
export PATH=${JAVA_HOME}/bin:$PATH
|
||||
/usr/lib/jvm/jdk1.8.0_271/bin/java -version
|
||||
/usr/lib/jvm/jdk1.8.0_271/bin/java ${CLASSPATH} -jar /root/Downloads/I2client/dist/I2client.jar
|
||||
@ -0,0 +1,18 @@
|
||||
#!/bin/bash
|
||||
ps -x |grep I2client | grep -v grep
|
||||
if [ $? -eq 0 ]; then echo "正在运行"
|
||||
else
|
||||
export JAVA_HOME=/usr/java/jdk1.8.0_171
|
||||
export JRE_HOME=${JAVA_HOME}/jre
|
||||
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib:$CLASSPATH
|
||||
export JAVA_PATH=${JAVA_HOME}/bin:${JRE_HOME}/bin
|
||||
export PATH=$PATH:${JAVA_PATH}
|
||||
|
||||
cd /home/quyi/I2client/dist/
|
||||
java -jar I2client.jar
|
||||
fi
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
@ -0,0 +1,3 @@
|
||||
Manifest-Version: 1.0
|
||||
X-COMMENT: Main-Class will be added automatically by build
|
||||
|
||||
@ -1,308 +0,0 @@
|
||||
#!/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 "$@"
|
||||
@ -1,205 +0,0 @@
|
||||
@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%
|
||||
@ -1,8 +0,0 @@
|
||||
CREATE TABLE `upload_statics` (
|
||||
`id` int NOT NULL AUTO_INCREMENT,
|
||||
`check_type` varchar(32) NOT NULL,
|
||||
`first_value` bigint DEFAULT NULL,
|
||||
`upload_time` date DEFAULT NULL COMMENT '上传记录的日期',
|
||||
`update_time` timestamp NULL DEFAULT NULL COMMENT '修改时间',
|
||||
PRIMARY KEY (`id`)
|
||||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='i2上传Id的确认表';
|
||||
@ -0,0 +1,5 @@
|
||||
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
|
||||
<catalog xmlns="urn:oasis:names:tc:entity:xmlns:xml:catalog" prefer="system">
|
||||
<system systemId="http://222.90.232.140:8443/xydl/service/XydlService?wsdl" uri="wsdl/222.90.232.140_8443/xydl/service/XydlService.wsdl"/>
|
||||
<system systemId="http://192.168.128.86:10080/busi-back-ws/service/XydlService?wsdl" uri="wsdl/192.168.128.86:10080/busi-back-ws/service/XydlService.wsdl"/>
|
||||
</catalog>
|
||||
@ -0,0 +1,61 @@
|
||||
<?xml version="1.0" encoding="UTF-8" ?>
|
||||
|
||||
<Form version="1.3" maxVersion="1.9" type="org.netbeans.modules.form.forminfo.JFrameFormInfo">
|
||||
<Properties>
|
||||
<Property name="defaultCloseOperation" type="int" value="3"/>
|
||||
<Property name="title" type="java.lang.String" value="I2通道数据显示"/>
|
||||
</Properties>
|
||||
<SyntheticProperties>
|
||||
<SyntheticProperty name="formSizePolicy" type="int" value="1"/>
|
||||
<SyntheticProperty name="generateCenter" type="boolean" value="false"/>
|
||||
</SyntheticProperties>
|
||||
<AuxValues>
|
||||
<AuxValue name="FormSettings_autoResourcing" type="java.lang.Integer" value="0"/>
|
||||
<AuxValue name="FormSettings_autoSetComponentName" type="java.lang.Boolean" value="false"/>
|
||||
<AuxValue name="FormSettings_generateFQN" type="java.lang.Boolean" value="true"/>
|
||||
<AuxValue name="FormSettings_generateMnemonicsCode" type="java.lang.Boolean" value="false"/>
|
||||
<AuxValue name="FormSettings_i18nAutoMode" type="java.lang.Boolean" value="false"/>
|
||||
<AuxValue name="FormSettings_layoutCodeTarget" type="java.lang.Integer" value="1"/>
|
||||
<AuxValue name="FormSettings_listenerGenerationStyle" type="java.lang.Integer" value="0"/>
|
||||
<AuxValue name="FormSettings_variablesLocal" type="java.lang.Boolean" value="false"/>
|
||||
<AuxValue name="FormSettings_variablesModifier" type="java.lang.Integer" value="2"/>
|
||||
</AuxValues>
|
||||
|
||||
<Layout>
|
||||
<DimensionLayout dim="0">
|
||||
<Group type="103" groupAlignment="0" attributes="0">
|
||||
<Group type="102" alignment="0" attributes="0">
|
||||
<EmptySpace max="-2" attributes="0"/>
|
||||
<Component id="jScrollPane1" pref="785" max="32767" attributes="0"/>
|
||||
<EmptySpace max="-2" attributes="0"/>
|
||||
</Group>
|
||||
</Group>
|
||||
</DimensionLayout>
|
||||
<DimensionLayout dim="1">
|
||||
<Group type="103" groupAlignment="0" attributes="0">
|
||||
<Group type="102" alignment="0" attributes="0">
|
||||
<EmptySpace max="-2" attributes="0"/>
|
||||
<Component id="jScrollPane1" min="-2" pref="344" max="-2" attributes="0"/>
|
||||
<EmptySpace pref="19" max="32767" attributes="0"/>
|
||||
</Group>
|
||||
</Group>
|
||||
</DimensionLayout>
|
||||
</Layout>
|
||||
<SubComponents>
|
||||
<Container class="javax.swing.JScrollPane" name="jScrollPane1">
|
||||
<AuxValues>
|
||||
<AuxValue name="autoScrollPane" type="java.lang.Boolean" value="true"/>
|
||||
</AuxValues>
|
||||
|
||||
<Layout class="org.netbeans.modules.form.compat2.layouts.support.JScrollPaneSupportLayout"/>
|
||||
<SubComponents>
|
||||
<Component class="javax.swing.JTextArea" name="jTextArea1">
|
||||
<Properties>
|
||||
<Property name="columns" type="int" value="20"/>
|
||||
<Property name="rows" type="int" value="5"/>
|
||||
</Properties>
|
||||
</Component>
|
||||
</SubComponents>
|
||||
</Container>
|
||||
</SubComponents>
|
||||
</Form>
|
||||
File diff suppressed because it is too large
Load Diff
@ -1,32 +0,0 @@
|
||||
package com.shxy.i2;
|
||||
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
//import org.mybatis.spring.annotation.MapperScan;
|
||||
import org.mybatis.spring.annotation.MapperScan;
|
||||
import org.springframework.boot.SpringApplication;
|
||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
|
||||
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
||||
import org.springframework.cache.annotation.EnableCaching;
|
||||
import org.springframework.context.annotation.ComponentScan;
|
||||
import org.springframework.context.annotation.EnableAspectJAutoProxy;
|
||||
import org.springframework.scheduling.annotation.EnableAsync;
|
||||
import org.springframework.scheduling.annotation.EnableScheduling;
|
||||
|
||||
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
|
||||
//@SpringBootApplication
|
||||
@MapperScan("com.shxy.i2.dao")
|
||||
@EnableAspectJAutoProxy(exposeProxy = true)
|
||||
@Slf4j
|
||||
@EnableConfigurationProperties
|
||||
@ComponentScan(basePackages = {"com.shxy"})
|
||||
//@EnableCaching
|
||||
//@EnableAsync
|
||||
public class I2Application {
|
||||
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(I2Application.class, args);
|
||||
log.info("系统启动");
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,83 +0,0 @@
|
||||
package com.shxy.i2.Tool;
|
||||
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import com.shxy.i2.bean.AttrBean;
|
||||
import com.shxy.i2.bean.YxAttrBean;
|
||||
import com.shxy.i2.constant.Constant;
|
||||
|
||||
import java.util.ArrayList;
|
||||
|
||||
public class GenerateI2Xml {
|
||||
|
||||
public static String generateCacXml(String type, String sensorid, String equipmentid, String timestamp, ArrayList<AttrBean> attrlist) {
|
||||
String cacdata = "";
|
||||
cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
|
||||
cacdata += "<type>" + type + "</type> ";
|
||||
cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
|
||||
if (StrUtil.isNotEmpty(timestamp)) {
|
||||
cacdata += "<timestamp>" + timestamp + "</timestamp> ";
|
||||
}
|
||||
cacdata += "<attrs> ";
|
||||
for (AttrBean bean : attrlist) {
|
||||
cacdata += "<attr name=\"" + bean.getKey() + "\" value=\"" + bean.getValue() + "\" alarm=\"FALSE\" /> ";
|
||||
}
|
||||
cacdata += "</attrs> ";
|
||||
cacdata += "</datanode>";
|
||||
return cacdata;
|
||||
}
|
||||
|
||||
public static String generateEndCacXml(ArrayList<String> cacdatalist) {
|
||||
String cacxml = "";
|
||||
cacxml += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
|
||||
cacxml += "<request> ";
|
||||
cacxml += "<monitordata cacid=\"" + Constant.Cacid + "\" datanodenum=\"" + cacdatalist.size() + "\"> ";
|
||||
for (String str : cacdatalist) {
|
||||
cacxml += str;
|
||||
}
|
||||
// cacxml += "</attrs> ";
|
||||
// cacxml += "</datanode>";
|
||||
cacxml += "</monitordata> ";
|
||||
cacxml += "</request> ";
|
||||
|
||||
return cacxml;
|
||||
}
|
||||
|
||||
public static String generateYxCacXml(YxAttrBean<Integer> attr) {
|
||||
String cacdata = "";
|
||||
String sensorid = attr.getSensorid();
|
||||
String equipmentid = attr.getEquipmentid();
|
||||
String devicetype = attr.getDevicetype();
|
||||
String timestamp = attr.getTimestamp();
|
||||
String key = attr.getKey();
|
||||
Integer value = attr.getValue();
|
||||
String phase = attr.getPhase();
|
||||
|
||||
String status = "FALSE";
|
||||
if (value != null) {
|
||||
if (value.intValue() == 0) {
|
||||
status = "FALSE";
|
||||
} else {
|
||||
status = "TRUE";
|
||||
}
|
||||
if (StrUtil.isNotEmpty(sensorid) && StrUtil.isNotEmpty(equipmentid) && StrUtil.isNotEmpty(timestamp) && StrUtil.isNotEmpty(key)) {
|
||||
cacdata += "<?xml version=\"1.0\" encoding=\"UTF-8\"?> ";
|
||||
cacdata += "<request> ";
|
||||
cacdata += "<monitordata cacid=\"" + Constant.Cacid + "\" datanodenum=\"" + 1 + "\"> ";
|
||||
cacdata += "<datanode sensorid=\"" + sensorid + "\"> ";
|
||||
cacdata += "<type>" + devicetype + "</type> ";
|
||||
cacdata += "<equipmentid>" + equipmentid + "</equipmentid> ";
|
||||
if (StrUtil.isNotEmpty(timestamp)) {
|
||||
cacdata += "<timestamp>" + timestamp + "</timestamp> ";
|
||||
}
|
||||
cacdata += "<attrs> ";
|
||||
cacdata += "<attr name=\"Phase\" value=\"" + phase + "\" alarm=\"" + status + "\" /> ";
|
||||
cacdata += "<attr name=\"" + key + "\" value=\"" + value + "\" alarm=\"" + status + "\" /> ";
|
||||
cacdata += "</attrs> ";
|
||||
cacdata += "</datanode>";
|
||||
cacdata += "</monitordata> ";
|
||||
cacdata += "</request> ";
|
||||
}
|
||||
}
|
||||
return cacdata;
|
||||
}
|
||||
}
|
||||
@ -1,9 +0,0 @@
|
||||
package com.shxy.i2.bean;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class AttrBean<T> {
|
||||
private String key;
|
||||
private T value;
|
||||
}
|
||||
@ -1,17 +0,0 @@
|
||||
package com.shxy.i2.bean;
|
||||
|
||||
/**
|
||||
* 常用API返回对象接口
|
||||
*
|
||||
*/
|
||||
public interface IErrorCode {
|
||||
/**
|
||||
* 返回码
|
||||
*/
|
||||
int getCode();
|
||||
|
||||
/**
|
||||
* 返回信息
|
||||
*/
|
||||
String getMessage();
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
package com.shxy.i2.bean;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 线路树状图列表
|
||||
*/
|
||||
@Data
|
||||
public class ListModel implements Serializable {
|
||||
|
||||
private List<Beans> list = new ArrayList<>();
|
||||
|
||||
@Data
|
||||
public static class Beans {
|
||||
|
||||
private String name;
|
||||
|
||||
private BigInteger history;//历史数据量
|
||||
|
||||
private BigInteger uploadnum;//已上传数据量
|
||||
|
||||
private BigInteger nownum;//今日数据量
|
||||
|
||||
private BigInteger nowuploadnum;//今日上传数据量
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,121 +0,0 @@
|
||||
package com.shxy.i2.bean;
|
||||
|
||||
|
||||
import cn.hutool.http.HttpStatus;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
public class ResponseReult<T> implements Serializable {
|
||||
/**
|
||||
* 返回对象
|
||||
*/
|
||||
private T data;
|
||||
/**
|
||||
* 返回状态码
|
||||
*/
|
||||
private int code;
|
||||
/**
|
||||
* 返回描述
|
||||
*/
|
||||
private String msg;
|
||||
|
||||
|
||||
|
||||
public T getData() {
|
||||
return data;
|
||||
}
|
||||
|
||||
public void setData(T data) {
|
||||
this.data = data;
|
||||
}
|
||||
|
||||
public int getCode() {
|
||||
return code;
|
||||
}
|
||||
|
||||
public void setCode(int code) {
|
||||
this.code = code;
|
||||
}
|
||||
|
||||
public void setCode(int code, String msg) {
|
||||
this.code = code;
|
||||
this.msg = msg;
|
||||
}
|
||||
|
||||
public String getMsg() {
|
||||
return msg;
|
||||
}
|
||||
|
||||
public void setMsg(String msg) {
|
||||
this.msg = msg;
|
||||
}
|
||||
|
||||
/**
|
||||
* 返回成功消息
|
||||
*
|
||||
* @return 成功消息
|
||||
*/
|
||||
public static <T> ResponseReult<T> success(T obj) {
|
||||
ResponseReult<T> success = ResponseReult.success();
|
||||
if (obj != null) {
|
||||
success.setData(obj);
|
||||
}
|
||||
return success;
|
||||
}
|
||||
|
||||
/**
|
||||
* 返回成功消息
|
||||
*
|
||||
* @return 成功消息
|
||||
*/
|
||||
public static <T> ResponseReult<T> success() {
|
||||
ResponseReult<T> response = new ResponseReult<>();
|
||||
response.setCode(HttpStatus.HTTP_OK, "操作成功");
|
||||
return response;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 失败返回结果
|
||||
*
|
||||
* @param message 错误信息
|
||||
*/
|
||||
public static <T> ResponseReult<T> fail(String message) {
|
||||
return ResponseReult.error(HttpStatus.HTTP_BAD_REQUEST, message);
|
||||
}
|
||||
|
||||
public static <T> ResponseReult<T> fail(int code, String msg) {
|
||||
ResponseReult<T> response = new ResponseReult<>();
|
||||
response.setCode(code, msg);
|
||||
return response;
|
||||
}
|
||||
/**
|
||||
* 返回失败消息
|
||||
*
|
||||
* @return 失败消息
|
||||
*/
|
||||
public static <T> ResponseReult<T> error(int code, String msg) {
|
||||
ResponseReult<T> response = new ResponseReult<>();
|
||||
response.setCode(code, msg);
|
||||
return response;
|
||||
}
|
||||
|
||||
/**
|
||||
* 失败返回结果
|
||||
*
|
||||
* @param errorCode 错误码
|
||||
*/
|
||||
public static <T> ResponseReult<T> error(IErrorCode errorCode) {
|
||||
return ResponseReult.error(errorCode.getCode(), errorCode.getMessage());
|
||||
}
|
||||
|
||||
/**
|
||||
* 失败返回结果
|
||||
*
|
||||
* @param message 错误信息
|
||||
*/
|
||||
public static <T> ResponseReult<T> error(String message) {
|
||||
return ResponseReult.error(HttpStatus.HTTP_INTERNAL_ERROR, message);
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,11 +0,0 @@
|
||||
package com.shxy.i2.bean;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.math.BigInteger;
|
||||
|
||||
@Data
|
||||
public class SendDataBean {
|
||||
private Integer eqmid;
|
||||
private BigInteger maxid;
|
||||
}
|
||||
@ -1,25 +0,0 @@
|
||||
package com.shxy.i2.bean;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
/**
|
||||
* service服务请求返回
|
||||
*
|
||||
* @author 晶晶
|
||||
*/
|
||||
@Data
|
||||
public class ServiceBody<T> {
|
||||
|
||||
/**
|
||||
* 返回体
|
||||
*/
|
||||
private T data;
|
||||
/**
|
||||
* 返回状态码
|
||||
*/
|
||||
private int code;
|
||||
/**
|
||||
* 错误描述
|
||||
*/
|
||||
private String msg;
|
||||
}
|
||||
@ -1,17 +0,0 @@
|
||||
package com.shxy.i2.bean;
|
||||
|
||||
/**
|
||||
* 返回状态码
|
||||
*
|
||||
* @author xzg
|
||||
*/
|
||||
public class ServiceStatus {
|
||||
/**
|
||||
* 操作成功
|
||||
*/
|
||||
public static final int SUCCESS = 200;
|
||||
/**
|
||||
* 操作失败
|
||||
*/
|
||||
public static final int ERROR = 400;
|
||||
}
|
||||
@ -1,14 +0,0 @@
|
||||
package com.shxy.i2.bean;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
@Data
|
||||
public class YxAttrBean<T> {
|
||||
private String devicetype;
|
||||
private String sensorid;
|
||||
private String equipmentid;
|
||||
private String timestamp;
|
||||
private String phase;
|
||||
private String key;
|
||||
private T value;
|
||||
}
|
||||
@ -1,59 +0,0 @@
|
||||
package com.shxy.i2.configure;
|
||||
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.cxf.endpoint.Client;
|
||||
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
|
||||
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
|
||||
import org.apache.cxf.transport.http.HTTPConduit;
|
||||
import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
|
||||
import org.springframework.beans.factory.annotation.Value;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.context.annotation.Configuration;
|
||||
|
||||
@Configuration
|
||||
@Slf4j
|
||||
public class CxfClientConfig {
|
||||
@Value("${webservice.address}")
|
||||
public String address;
|
||||
//
|
||||
@Value("${webservice.connecttime}")
|
||||
public int connecttime;
|
||||
|
||||
@Value("${webservice.receivetime}")
|
||||
public int receivetime;
|
||||
/**
|
||||
* 采用代理方式
|
||||
*
|
||||
* @return NBAPlayerSoap
|
||||
*/
|
||||
// @Bean
|
||||
// public NBAPlayerSoap createAuthorPortTypeProxy() {
|
||||
// JaxWsProxyFactoryBean jaxWsProxyFactoryBean = new JaxWsProxyFactoryBean();
|
||||
// jaxWsProxyFactoryBean.setServiceClass(NBAPlayerSoap.class);
|
||||
// jaxWsProxyFactoryBean.setAddress(WsConst.SERVICE_ADDRESS);
|
||||
// return (NBAPlayerSoap) jaxWsProxyFactoryBean.create();
|
||||
// }
|
||||
|
||||
/**
|
||||
* 采用动态工厂方式 不需要指定服务接口
|
||||
* "http://www.webxml.com.cn/webservices/qqOnlineWebService.asmx?wsdl"
|
||||
*
|
||||
*/
|
||||
@Bean
|
||||
public Client createDynamicClient() {
|
||||
// 动态客户端
|
||||
JaxWsDynamicClientFactory clientFactory = JaxWsDynamicClientFactory.newInstance();
|
||||
log.info("实时数据 publicsecurity webService url : {}", address);
|
||||
//根据WebServices接口地址创建client
|
||||
Client client = clientFactory.createClient(address);
|
||||
HTTPConduit conduit = (HTTPConduit) client.getConduit();
|
||||
HTTPClientPolicy policy = new HTTPClientPolicy();
|
||||
policy.setAllowChunking(false);
|
||||
// 连接服务器超时时间 60秒
|
||||
policy.setConnectionTimeout(connecttime);
|
||||
// 等待服务器响应超时时间 60秒
|
||||
policy.setReceiveTimeout(receivetime);
|
||||
conduit.setClient(policy);
|
||||
return client;
|
||||
}
|
||||
}
|
||||
@ -1,32 +0,0 @@
|
||||
//package com.shxy.i2.configure;
|
||||
//
|
||||
//import lombok.extern.slf4j.Slf4j;
|
||||
//import org.apache.cxf.endpoint.Client;
|
||||
//import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
|
||||
//import org.apache.cxf.transport.http.HTTPConduit;
|
||||
//import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
|
||||
//import org.springframework.context.annotation.Bean;
|
||||
//import org.springframework.context.annotation.Configuration;
|
||||
//
|
||||
//@Configuration
|
||||
//@Slf4j
|
||||
//public class JaxWsClientConfig {
|
||||
//
|
||||
// @Bean("JaxWsClient")
|
||||
// public Client client() {
|
||||
// // 创建动态客户端
|
||||
// JaxWsDynamicClientFactory clientFactory = JaxWsDynamicClientFactory.newInstance();
|
||||
// log.info("publicsecurity webService url : {}", "http://10.238.71.98:18096/ppa/webservice/CAGAccessService?wsdl");
|
||||
// //根据WebServices接口地址创建client
|
||||
// Client client = clientFactory.createClient("http://10.238.71.98:18096/ppa/webservice/CAGAccessService?wsdl");
|
||||
// HTTPConduit conduit = (HTTPConduit) client.getConduit();
|
||||
// HTTPClientPolicy policy = new HTTPClientPolicy();
|
||||
// policy.setAllowChunking(false);
|
||||
// // 连接服务器超时时间 10秒
|
||||
// policy.setConnectionTimeout(60000);
|
||||
// // 等待服务器响应超时时间 20秒
|
||||
// policy.setReceiveTimeout(20000);
|
||||
// conduit.setClient(policy);
|
||||
// return client;
|
||||
// }
|
||||
//}
|
||||
@ -1,37 +0,0 @@
|
||||
//package com.shxy.i2.configure;
|
||||
//
|
||||
//import org.springframework.context.annotation.Bean;
|
||||
//import org.springframework.context.annotation.Configuration;
|
||||
//import org.springframework.scheduling.annotation.EnableAsync;
|
||||
//import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
||||
//
|
||||
//import java.util.concurrent.Executor;
|
||||
//import java.util.concurrent.ThreadPoolExecutor;
|
||||
//
|
||||
//
|
||||
//@Configuration
|
||||
//@EnableAsync
|
||||
//public class ThreadPoolConfig {
|
||||
//
|
||||
// /**
|
||||
// * 自定义线程池配置
|
||||
// *
|
||||
// * @return
|
||||
// */
|
||||
// @Bean(name = "asyncServiceExecutor")
|
||||
// public Executor asyncServiceExecutor() {
|
||||
// ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
|
||||
// //配置核心线程数
|
||||
// executor.setCorePoolSize(50);
|
||||
// //配置最大线程数
|
||||
// executor.setMaxPoolSize(200);
|
||||
// //配置队列大小
|
||||
// executor.setQueueCapacity(1000000);
|
||||
// //配置线程池中的线程的名称前缀
|
||||
// executor.setThreadNamePrefix("async-cron-table");
|
||||
// executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
|
||||
// executor.initialize();
|
||||
// return executor;
|
||||
// }
|
||||
//
|
||||
//}
|
||||
@ -1,51 +0,0 @@
|
||||
//package com.shxy.i2;
|
||||
//
|
||||
//import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
|
||||
//import org.springframework.context.annotation.Bean;
|
||||
//import org.springframework.context.annotation.Configuration;
|
||||
//import org.springframework.oxm.jaxb.Jaxb2Marshaller;
|
||||
//import org.springframework.ws.client.core.WebServiceTemplate;
|
||||
//import org.springframework.ws.transport.http.HttpUrlConnectionMessageSender;
|
||||
//
|
||||
//import javax.xml.ws.soap.SOAPBinding;
|
||||
//
|
||||
//@Configuration
|
||||
//public class WebServiceConfig {
|
||||
//
|
||||
// @Bean(name = "webServiceTemplate")
|
||||
// public WebServiceTemplate webServiceTemplate(Jaxb2Marshaller marshaller) {
|
||||
// WebServiceTemplate webServiceTemplate = new WebServiceTemplate();
|
||||
// webServiceTemplate.setMarshaller(marshaller);
|
||||
// webServiceTemplate.setUnmarshaller(marshaller);
|
||||
// webServiceTemplate.setMessageSender(httpUrlConnectionMessageSender());
|
||||
// return webServiceTemplate;
|
||||
// }
|
||||
//
|
||||
// @Bean(name="httpUrlConnectionMessageSender")
|
||||
// public HttpUrlConnectionMessageSender httpUrlConnectionMessageSender() {
|
||||
// return new HttpUrlConnectionMessageSender();
|
||||
// }
|
||||
//
|
||||
// @Bean
|
||||
// public Jaxb2Marshaller marshaller() {
|
||||
// Jaxb2Marshaller marshaller = new Jaxb2Marshaller();
|
||||
// marshaller.setContextPath("com.example.demo");
|
||||
// return marshaller;
|
||||
// }
|
||||
//
|
||||
// @Bean(name="testServiceClient")
|
||||
// public TestService testServiceClient(Jaxb2Marshaller marshaller) {
|
||||
// JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
|
||||
// factory.setServiceClass(TestService.class);
|
||||
// factory.setAddress("http://localhost:8080/services/TestService");
|
||||
// factory.setServiceName(new QName("http://example.com/", "TestServicePort"));
|
||||
// factory.setEndpointName(new QName("http://example.com/", "TestServiceSoap"));
|
||||
// factory.setBindingId(SOAPBinding.SOAP11HTTP_BINDING);
|
||||
// factory.setUnmarshaller(marshaller);
|
||||
// factory.setMarshaller(marshaller);
|
||||
//
|
||||
// Object obj = factory.create();
|
||||
// return (TestService) obj;
|
||||
// }
|
||||
//
|
||||
//}
|
||||
@ -1,29 +0,0 @@
|
||||
package com.shxy.i2.constant;
|
||||
|
||||
|
||||
/**
|
||||
* 常用状态
|
||||
* "0---删除 1---生效中"
|
||||
*
|
||||
* @author 晶晶
|
||||
*/
|
||||
public enum CommonStatus {
|
||||
UNUPLOAD("UNUPLOAD", 0), UPLOAD("UPLOAD", 1);
|
||||
|
||||
private String name;
|
||||
private Integer value;
|
||||
|
||||
CommonStatus(String name, Integer value) {
|
||||
this.name = name;
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return this.value + "_" + this.name;
|
||||
}
|
||||
|
||||
public Integer value() {
|
||||
return this.value;
|
||||
}
|
||||
}
|
||||
@ -1,53 +0,0 @@
|
||||
package com.shxy.i2.constant;
|
||||
|
||||
public class Constant {
|
||||
public static String Cacid = "changtai";
|
||||
|
||||
|
||||
public static String YXID = "yxid";
|
||||
public static String YSPID = "yspid";
|
||||
public static String BYQJBFDID = "byqjbfdid";
|
||||
public static String DLQJBFDID = "dlqjbfdid";
|
||||
public static String CNJID = "cnjid";
|
||||
public static String DCYWID = "dcywid";
|
||||
public static String DRJYJCID = "drjyjcid";
|
||||
public static String FHDLBXID = "fhdlbxid";
|
||||
public static String FHZXQID = "fhzxqid";
|
||||
public static String JSYHWJYJCID = "jsyhwjyjcid";
|
||||
public static String SF6QTSFID = "sf6qtsfid";
|
||||
public static String SF6QTYLID = "sf6qtylid";
|
||||
public static String TXID = "txid";
|
||||
public static String WSID = "wsid";
|
||||
public static String MICROCLIMATEID = "microclimateid";
|
||||
|
||||
public static String BYQ_JBFD = "021001";
|
||||
public static String YSP = "021002";
|
||||
public static String WS = "021003";
|
||||
public static String TX = "021004";
|
||||
public static String DCYW = "021005";
|
||||
public static String DRJYJC = "022001";
|
||||
public static String JSYHW = "023001";
|
||||
public static String DLQJBFD = "024001";
|
||||
public static String FHZXQ = "024002";
|
||||
public static String FHDLBX = "024003";
|
||||
public static String SF6_QTYL = "024004";
|
||||
public static String SF6_QTSF = "024005";
|
||||
public static String CNJ = "024006";
|
||||
public static String WQX = "025001";
|
||||
|
||||
|
||||
public static String data_byq_jbfd = "data_byq_jbfd";
|
||||
public static String data_cnj = "data_cnj";
|
||||
public static String data_dcyw = "data_dcyw";
|
||||
public static String data_dlq_jbfd = "data_dlq_jbfd";
|
||||
public static String data_dr_jyjc = "data_dr_jyjc";
|
||||
public static String data_fhdlbx = "data_fhdlbx";
|
||||
public static String data_fhzxq = "data_fhzxq";
|
||||
public static String data_jsyhw_jyjc = "data_jsyhw_jyjc";
|
||||
public static String data_microclimate = "data_microclimate";
|
||||
public static String data_sf6_qtsf = "data_sf6_qtsf";
|
||||
public static String data_sf6_qtyl = "data_sf6_qtyl";
|
||||
public static String data_tx = "data_tx";
|
||||
public static String data_ws = "data_ws";
|
||||
public static String data_ysp = "data_ysp";
|
||||
}
|
||||
@ -1,32 +0,0 @@
|
||||
package com.shxy.i2.controller;
|
||||
|
||||
import com.shxy.i2.bean.ListModel;
|
||||
import com.shxy.i2.bean.ResponseReult;
|
||||
import com.shxy.i2.bean.ServiceBody;
|
||||
import com.shxy.i2.bean.ServiceStatus;
|
||||
import com.shxy.i2.service.XydlI2Service;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.web.bind.annotation.RequestMapping;
|
||||
import org.springframework.web.bind.annotation.RestController;
|
||||
|
||||
|
||||
@RestController
|
||||
@Slf4j
|
||||
public class CheckController {
|
||||
|
||||
@Autowired
|
||||
XydlI2Service xydlI2Service;
|
||||
|
||||
@RequestMapping("/list")
|
||||
public ResponseReult<ListModel> list() {
|
||||
ServiceBody<ListModel> serviceBody = xydlI2Service.list();
|
||||
if (serviceBody.getCode() == ServiceStatus.SUCCESS) {
|
||||
return ResponseReult.success(serviceBody.getData());
|
||||
} else {
|
||||
return ResponseReult.error(serviceBody.getCode(), serviceBody.getMsg());
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,21 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.bean.SendDataBean;
|
||||
import com.shxy.i2.entity.Data_Byq_Jbfd;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_Byq_JbfdDao {
|
||||
|
||||
List<Data_Byq_Jbfd> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Byq_Jbfd selectMaxId();
|
||||
|
||||
Data_Byq_Jbfd selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Byq_Jbfd;
|
||||
import com.shxy.i2.entity.Data_Cnj;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_CnjDao {
|
||||
|
||||
List<Data_Cnj> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Cnj selectMaxId();
|
||||
|
||||
Data_Cnj selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Cnj;
|
||||
import com.shxy.i2.entity.Data_Dcyw;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_DcywDao {
|
||||
|
||||
List<Data_Dcyw> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Dcyw selectMaxId();
|
||||
|
||||
Data_Dcyw selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,23 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.bean.SendDataBean;
|
||||
import com.shxy.i2.entity.Data_Dcyw;
|
||||
import com.shxy.i2.entity.Data_Dlq_Jbfd;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_Dlq_JbfdDao {
|
||||
|
||||
|
||||
Data_Dlq_Jbfd selectMaxId();
|
||||
|
||||
Data_Dlq_Jbfd selectNowId(@Param("date") Date date);
|
||||
|
||||
List<Data_Dlq_Jbfd> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Dlq_Jbfd;
|
||||
import com.shxy.i2.entity.Data_Dr_Jyjc;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_Dr_JyjcDao {
|
||||
|
||||
List<Data_Dr_Jyjc> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Dr_Jyjc selectMaxId();
|
||||
|
||||
Data_Dr_Jyjc selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Dr_Jyjc;
|
||||
import com.shxy.i2.entity.Data_Fhdlbx;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_FhdlbxDao {
|
||||
|
||||
List<Data_Fhdlbx> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Fhdlbx selectMaxId();
|
||||
|
||||
Data_Fhdlbx selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Fhdlbx;
|
||||
import com.shxy.i2.entity.Data_Fhzxq;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_FhzxqDao {
|
||||
|
||||
List<Data_Fhzxq> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Fhzxq selectMaxId();
|
||||
|
||||
Data_Fhzxq selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Fhzxq;
|
||||
import com.shxy.i2.entity.Data_Jsyhw_Jyjc;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_Jsyhw_JyjcDao {
|
||||
|
||||
List<Data_Jsyhw_Jyjc> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Jsyhw_Jyjc selectMaxId();
|
||||
|
||||
Data_Jsyhw_Jyjc selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Jsyhw_Jyjc;
|
||||
import com.shxy.i2.entity.Data_Microclimate;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_MicroclimateDao {
|
||||
|
||||
List<Data_Microclimate> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Microclimate selectMaxId();
|
||||
|
||||
Data_Microclimate selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Microclimate;
|
||||
import com.shxy.i2.entity.Data_SF6_Qtsf;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_SF6_QtsfDao {
|
||||
|
||||
List<Data_SF6_Qtsf> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_SF6_Qtsf selectMaxId();
|
||||
|
||||
Data_SF6_Qtsf selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_SF6_Qtsf;
|
||||
import com.shxy.i2.entity.Data_SF6_Qtyl;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_SF6_QtylDao {
|
||||
|
||||
List<Data_SF6_Qtyl> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_SF6_Qtyl selectMaxId();
|
||||
|
||||
Data_SF6_Qtyl selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,21 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_SF6_Qtyl;
|
||||
import com.shxy.i2.entity.Data_Tx;
|
||||
import com.shxy.i2.entity.Data_Ysp;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_TxDao {
|
||||
|
||||
List<Data_Tx> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Tx selectMaxId();
|
||||
|
||||
Data_Tx selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Data_Tx;
|
||||
import com.shxy.i2.entity.Data_Ws;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_WsDao {
|
||||
|
||||
List<Data_Ws> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Ws selectMaxId();
|
||||
|
||||
Data_Ws selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,23 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import cn.hutool.core.date.DateTime;
|
||||
import com.shxy.i2.bean.SendDataBean;
|
||||
import com.shxy.i2.entity.Data_Byq_Jbfd;
|
||||
import com.shxy.i2.entity.Data_Ysp;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_YspDao {
|
||||
|
||||
List<Data_Ysp> selectUploadById(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_Ysp selectMaxId();
|
||||
|
||||
Data_Ysp selectNowId(@Param("date") Date time);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,20 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.dto.Data_YxlDto;
|
||||
import com.shxy.i2.entity.Data_Ws;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Data_YxDao {
|
||||
|
||||
List<Data_YxlDto> selectByPrimaryKey(@Param("maxid") BigInteger maxid);
|
||||
|
||||
Data_YxlDto selectMaxId();
|
||||
|
||||
Data_YxlDto selectNowId(@Param("date") Date date);
|
||||
|
||||
int deleteData(@Param("time") Date time);
|
||||
}
|
||||
@ -1,11 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Niec_Sensors;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface Niec_SensorsDao {
|
||||
|
||||
List<Niec_Sensors> selectAll();
|
||||
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Upload_Statics;
|
||||
import com.shxy.i2.entity.Upload_StaticsExample;
|
||||
import java.util.List;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
public interface Upload_StaticsDao {
|
||||
long countByExample(Upload_StaticsExample example);
|
||||
|
||||
int deleteByExample(Upload_StaticsExample example);
|
||||
|
||||
int deleteByPrimaryKey(String checkType);
|
||||
|
||||
int insert(Upload_Statics record);
|
||||
|
||||
int insertSelective(Upload_Statics record);
|
||||
|
||||
List<Upload_Statics> selectByExample(Upload_StaticsExample example);
|
||||
|
||||
Upload_Statics selectByPrimaryKey(String checkType);
|
||||
|
||||
int updateByExampleSelective(@Param("record") Upload_Statics record, @Param("example") Upload_StaticsExample example);
|
||||
|
||||
int updateByExample(@Param("record") Upload_Statics record, @Param("example") Upload_StaticsExample example);
|
||||
|
||||
int updateByPrimaryKeySelective(Upload_Statics record);
|
||||
|
||||
int updateByPrimaryKey(Upload_Statics record);
|
||||
}
|
||||
@ -1,17 +0,0 @@
|
||||
package com.shxy.i2.dao;
|
||||
|
||||
import com.shxy.i2.entity.Upload_check;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
public interface Upload_checkDao {
|
||||
|
||||
Upload_check selectByPrimaryKey(String checkType);
|
||||
|
||||
List<Upload_check> selectAll();
|
||||
|
||||
int updateByPrimaryKey(@Param("checkType") String checkType, @Param("value") BigInteger value, @Param("updateTime") Date updateTime);
|
||||
}
|
||||
@ -1,31 +0,0 @@
|
||||
package com.shxy.i2.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_SF6_QtylDetailDto {
|
||||
|
||||
private BigInteger id;
|
||||
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float temperature;
|
||||
|
||||
private Float absolutepressure;
|
||||
|
||||
private Float density;
|
||||
|
||||
private Float pressure20c;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
}
|
||||
@ -1,17 +0,0 @@
|
||||
package com.shxy.i2.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Data
|
||||
public class Data_SF6_QtylDto {
|
||||
|
||||
private Integer eqmid;
|
||||
|
||||
private List<Data_SF6_QtylDetailDto> list;
|
||||
|
||||
|
||||
|
||||
|
||||
}
|
||||
@ -1,24 +0,0 @@
|
||||
package com.shxy.i2.dto;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
@Data
|
||||
public class Data_YxlDto {
|
||||
|
||||
BigInteger id;
|
||||
BigInteger maxid;
|
||||
BigInteger minid;
|
||||
Integer sadr;
|
||||
Date dtime;
|
||||
Integer ival;
|
||||
String field;
|
||||
String sensorCode;
|
||||
String equipmentId;
|
||||
String tableName;
|
||||
String phase;
|
||||
|
||||
}
|
||||
@ -1,35 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Byq_Jbfd implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float dischargecapacity;
|
||||
|
||||
private Float dischargeposition;
|
||||
|
||||
private Float pulsecount;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private byte[] dischargewaveform;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,28 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Cnj implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float chargetime;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,28 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Dcyw implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float oiltemperature;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,35 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
@Data
|
||||
public class Data_Dlq_Jbfd implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private String phase;
|
||||
|
||||
private Float dischargecapacity;
|
||||
|
||||
private Float dischargeposition;
|
||||
|
||||
private Float pulsecount;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private byte[] dischargewaveform;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,38 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Dr_Jyjc implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float capacitance;
|
||||
|
||||
private Float lossfactor;
|
||||
|
||||
private Float unbalancecurrent;
|
||||
|
||||
private Float unbalancevoltage;
|
||||
|
||||
private Float totalcurrent;
|
||||
|
||||
private Float systemvoltage;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Fhdlbx implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Integer action;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private byte[] loadwaveform;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Fhzxq implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Integer action;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private byte[] coilwaveform;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,36 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Jsyhw_Jyjc implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float systemvoltage;
|
||||
|
||||
private Float totalcurrent;
|
||||
|
||||
private Float resistivecurrent;
|
||||
|
||||
private Float actioncount;
|
||||
|
||||
private Date lastactiontime;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,40 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Microclimate implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float airtemperature;
|
||||
|
||||
private Float airpressure;
|
||||
|
||||
private Float humidity;
|
||||
|
||||
private Float precipitation;
|
||||
|
||||
private Float wddir;
|
||||
|
||||
private Float precipitationintensity;
|
||||
|
||||
private Float radiationintensity;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_SF6_Qtsf implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float temperature;
|
||||
|
||||
private Float moisture;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,35 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_SF6_Qtyl implements Serializable {
|
||||
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float temperature;
|
||||
|
||||
private Float absolutepressure;
|
||||
|
||||
private Float density;
|
||||
|
||||
private Float pressure20c;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,29 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Tx implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float totalcorecurrent;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,27 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
@Data
|
||||
public class Data_Ws implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float moisture;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,47 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Ysp implements Serializable {
|
||||
private BigInteger id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
|
||||
private Integer eqmid;
|
||||
|
||||
private Date acquisitiontime;
|
||||
|
||||
private Float h2;
|
||||
|
||||
private Float ch4;
|
||||
|
||||
private Float c2h6;
|
||||
|
||||
private Float c2h4;
|
||||
|
||||
private Float c2h2;
|
||||
|
||||
private Float co;
|
||||
|
||||
private Float co2;
|
||||
|
||||
private Float o2;
|
||||
|
||||
private Float n2;
|
||||
|
||||
private Float totalhydrocarbon;
|
||||
|
||||
private Integer isupload;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,22 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Data_Yx implements Serializable {
|
||||
private Long id;
|
||||
private BigInteger maxid;
|
||||
private BigInteger minid;
|
||||
private Integer sadr;
|
||||
|
||||
private Date dTime;
|
||||
|
||||
private Integer ival;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,45 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Niec_Sensors implements Serializable {
|
||||
|
||||
private Integer id;
|
||||
|
||||
private Integer parentId;
|
||||
|
||||
private String siteId;
|
||||
|
||||
private String sensorCode;
|
||||
|
||||
private String equipmentId;
|
||||
|
||||
private String phase;
|
||||
|
||||
private String name;
|
||||
|
||||
private Integer grpNo;
|
||||
|
||||
private Integer status;
|
||||
|
||||
private String equipmentType;
|
||||
|
||||
private String systemCode;
|
||||
|
||||
private String tableName;
|
||||
|
||||
private String devidFieldName;
|
||||
|
||||
private String dtimeFieldName;
|
||||
|
||||
private Integer oneDtime;
|
||||
|
||||
private Date createTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,23 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Upload_Statics implements Serializable {
|
||||
private String checkType;
|
||||
|
||||
private Integer id;
|
||||
|
||||
private BigInteger firstValue;
|
||||
|
||||
private Date uploadTime;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,538 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Date;
|
||||
import java.util.Iterator;
|
||||
import java.util.List;
|
||||
|
||||
public class Upload_StaticsExample {
|
||||
protected String orderByClause;
|
||||
|
||||
protected boolean distinct;
|
||||
|
||||
protected List<Criteria> oredCriteria;
|
||||
|
||||
public Upload_StaticsExample() {
|
||||
oredCriteria = new ArrayList<Criteria>();
|
||||
}
|
||||
|
||||
public void setOrderByClause(String orderByClause) {
|
||||
this.orderByClause = orderByClause;
|
||||
}
|
||||
|
||||
public String getOrderByClause() {
|
||||
return orderByClause;
|
||||
}
|
||||
|
||||
public void setDistinct(boolean distinct) {
|
||||
this.distinct = distinct;
|
||||
}
|
||||
|
||||
public boolean isDistinct() {
|
||||
return distinct;
|
||||
}
|
||||
|
||||
public List<Criteria> getOredCriteria() {
|
||||
return oredCriteria;
|
||||
}
|
||||
|
||||
public void or(Criteria criteria) {
|
||||
oredCriteria.add(criteria);
|
||||
}
|
||||
|
||||
public Criteria or() {
|
||||
Criteria criteria = createCriteriaInternal();
|
||||
oredCriteria.add(criteria);
|
||||
return criteria;
|
||||
}
|
||||
|
||||
public Criteria createCriteria() {
|
||||
Criteria criteria = createCriteriaInternal();
|
||||
if (oredCriteria.size() == 0) {
|
||||
oredCriteria.add(criteria);
|
||||
}
|
||||
return criteria;
|
||||
}
|
||||
|
||||
protected Criteria createCriteriaInternal() {
|
||||
Criteria criteria = new Criteria();
|
||||
return criteria;
|
||||
}
|
||||
|
||||
public void clear() {
|
||||
oredCriteria.clear();
|
||||
orderByClause = null;
|
||||
distinct = false;
|
||||
}
|
||||
|
||||
protected abstract static class GeneratedCriteria {
|
||||
protected List<Criterion> criteria;
|
||||
|
||||
protected GeneratedCriteria() {
|
||||
super();
|
||||
criteria = new ArrayList<Criterion>();
|
||||
}
|
||||
|
||||
public boolean isValid() {
|
||||
return criteria.size() > 0;
|
||||
}
|
||||
|
||||
public List<Criterion> getAllCriteria() {
|
||||
return criteria;
|
||||
}
|
||||
|
||||
public List<Criterion> getCriteria() {
|
||||
return criteria;
|
||||
}
|
||||
|
||||
protected void addCriterion(String condition) {
|
||||
if (condition == null) {
|
||||
throw new RuntimeException("Value for condition cannot be null");
|
||||
}
|
||||
criteria.add(new Criterion(condition));
|
||||
}
|
||||
|
||||
protected void addCriterion(String condition, Object value, String property) {
|
||||
if (value == null) {
|
||||
throw new RuntimeException("Value for " + property + " cannot be null");
|
||||
}
|
||||
criteria.add(new Criterion(condition, value));
|
||||
}
|
||||
|
||||
protected void addCriterion(String condition, Object value1, Object value2, String property) {
|
||||
if (value1 == null || value2 == null) {
|
||||
throw new RuntimeException("Between values for " + property + " cannot be null");
|
||||
}
|
||||
criteria.add(new Criterion(condition, value1, value2));
|
||||
}
|
||||
|
||||
protected void addCriterionForJDBCDate(String condition, Date value, String property) {
|
||||
if (value == null) {
|
||||
throw new RuntimeException("Value for " + property + " cannot be null");
|
||||
}
|
||||
addCriterion(condition, new java.sql.Date(value.getTime()), property);
|
||||
}
|
||||
|
||||
protected void addCriterionForJDBCDate(String condition, List<Date> values, String property) {
|
||||
if (values == null || values.size() == 0) {
|
||||
throw new RuntimeException("Value list for " + property + " cannot be null or empty");
|
||||
}
|
||||
List<java.sql.Date> dateList = new ArrayList<java.sql.Date>();
|
||||
Iterator<Date> iter = values.iterator();
|
||||
while (iter.hasNext()) {
|
||||
dateList.add(new java.sql.Date(iter.next().getTime()));
|
||||
}
|
||||
addCriterion(condition, dateList, property);
|
||||
}
|
||||
|
||||
protected void addCriterionForJDBCDate(String condition, Date value1, Date value2, String property) {
|
||||
if (value1 == null || value2 == null) {
|
||||
throw new RuntimeException("Between values for " + property + " cannot be null");
|
||||
}
|
||||
addCriterion(condition, new java.sql.Date(value1.getTime()), new java.sql.Date(value2.getTime()), property);
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeIsNull() {
|
||||
addCriterion("check_type is null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeIsNotNull() {
|
||||
addCriterion("check_type is not null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeEqualTo(String value) {
|
||||
addCriterion("check_type =", value, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeNotEqualTo(String value) {
|
||||
addCriterion("check_type <>", value, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeGreaterThan(String value) {
|
||||
addCriterion("check_type >", value, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeGreaterThanOrEqualTo(String value) {
|
||||
addCriterion("check_type >=", value, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeLessThan(String value) {
|
||||
addCriterion("check_type <", value, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeLessThanOrEqualTo(String value) {
|
||||
addCriterion("check_type <=", value, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeLike(String value) {
|
||||
addCriterion("check_type like", value, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeNotLike(String value) {
|
||||
addCriterion("check_type not like", value, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeIn(List<String> values) {
|
||||
addCriterion("check_type in", values, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeNotIn(List<String> values) {
|
||||
addCriterion("check_type not in", values, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeBetween(String value1, String value2) {
|
||||
addCriterion("check_type between", value1, value2, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andCheckTypeNotBetween(String value1, String value2) {
|
||||
addCriterion("check_type not between", value1, value2, "checkType");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdIsNull() {
|
||||
addCriterion("id is null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdIsNotNull() {
|
||||
addCriterion("id is not null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdEqualTo(Integer value) {
|
||||
addCriterion("id =", value, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdNotEqualTo(Integer value) {
|
||||
addCriterion("id <>", value, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdGreaterThan(Integer value) {
|
||||
addCriterion("id >", value, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdGreaterThanOrEqualTo(Integer value) {
|
||||
addCriterion("id >=", value, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdLessThan(Integer value) {
|
||||
addCriterion("id <", value, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdLessThanOrEqualTo(Integer value) {
|
||||
addCriterion("id <=", value, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdIn(List<Integer> values) {
|
||||
addCriterion("id in", values, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdNotIn(List<Integer> values) {
|
||||
addCriterion("id not in", values, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdBetween(Integer value1, Integer value2) {
|
||||
addCriterion("id between", value1, value2, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andIdNotBetween(Integer value1, Integer value2) {
|
||||
addCriterion("id not between", value1, value2, "id");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueIsNull() {
|
||||
addCriterion("first_value is null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueIsNotNull() {
|
||||
addCriterion("first_value is not null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueEqualTo(Long value) {
|
||||
addCriterion("first_value =", value, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueNotEqualTo(Long value) {
|
||||
addCriterion("first_value <>", value, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueGreaterThan(Long value) {
|
||||
addCriterion("first_value >", value, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueGreaterThanOrEqualTo(Long value) {
|
||||
addCriterion("first_value >=", value, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueLessThan(Long value) {
|
||||
addCriterion("first_value <", value, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueLessThanOrEqualTo(Long value) {
|
||||
addCriterion("first_value <=", value, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueIn(List<Long> values) {
|
||||
addCriterion("first_value in", values, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueNotIn(List<Long> values) {
|
||||
addCriterion("first_value not in", values, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueBetween(Long value1, Long value2) {
|
||||
addCriterion("first_value between", value1, value2, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andFirstValueNotBetween(Long value1, Long value2) {
|
||||
addCriterion("first_value not between", value1, value2, "firstValue");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeIsNull() {
|
||||
addCriterion("upload_time is null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeIsNotNull() {
|
||||
addCriterion("upload_time is not null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeEqualTo(Date value) {
|
||||
addCriterionForJDBCDate("upload_time =", value, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeNotEqualTo(Date value) {
|
||||
addCriterionForJDBCDate("upload_time <>", value, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeGreaterThan(Date value) {
|
||||
addCriterionForJDBCDate("upload_time >", value, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeGreaterThanOrEqualTo(Date value) {
|
||||
addCriterionForJDBCDate("upload_time >=", value, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeLessThan(Date value) {
|
||||
addCriterionForJDBCDate("upload_time <", value, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeLessThanOrEqualTo(Date value) {
|
||||
addCriterionForJDBCDate("upload_time <=", value, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeIn(List<Date> values) {
|
||||
addCriterionForJDBCDate("upload_time in", values, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeNotIn(List<Date> values) {
|
||||
addCriterionForJDBCDate("upload_time not in", values, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeBetween(Date value1, Date value2) {
|
||||
addCriterionForJDBCDate("upload_time between", value1, value2, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUploadTimeNotBetween(Date value1, Date value2) {
|
||||
addCriterionForJDBCDate("upload_time not between", value1, value2, "uploadTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeIsNull() {
|
||||
addCriterion("update_time is null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeIsNotNull() {
|
||||
addCriterion("update_time is not null");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeEqualTo(Date value) {
|
||||
addCriterion("update_time =", value, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeNotEqualTo(Date value) {
|
||||
addCriterion("update_time <>", value, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeGreaterThan(Date value) {
|
||||
addCriterion("update_time >", value, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeGreaterThanOrEqualTo(Date value) {
|
||||
addCriterion("update_time >=", value, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeLessThan(Date value) {
|
||||
addCriterion("update_time <", value, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeLessThanOrEqualTo(Date value) {
|
||||
addCriterion("update_time <=", value, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeIn(List<Date> values) {
|
||||
addCriterion("update_time in", values, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeNotIn(List<Date> values) {
|
||||
addCriterion("update_time not in", values, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeBetween(Date value1, Date value2) {
|
||||
addCriterion("update_time between", value1, value2, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
|
||||
public Criteria andUpdateTimeNotBetween(Date value1, Date value2) {
|
||||
addCriterion("update_time not between", value1, value2, "updateTime");
|
||||
return (Criteria) this;
|
||||
}
|
||||
}
|
||||
|
||||
public static class Criteria extends GeneratedCriteria {
|
||||
|
||||
protected Criteria() {
|
||||
super();
|
||||
}
|
||||
}
|
||||
|
||||
public static class Criterion {
|
||||
private String condition;
|
||||
|
||||
private Object value;
|
||||
|
||||
private Object secondValue;
|
||||
|
||||
private boolean noValue;
|
||||
|
||||
private boolean singleValue;
|
||||
|
||||
private boolean betweenValue;
|
||||
|
||||
private boolean listValue;
|
||||
|
||||
private String typeHandler;
|
||||
|
||||
public String getCondition() {
|
||||
return condition;
|
||||
}
|
||||
|
||||
public Object getValue() {
|
||||
return value;
|
||||
}
|
||||
|
||||
public Object getSecondValue() {
|
||||
return secondValue;
|
||||
}
|
||||
|
||||
public boolean isNoValue() {
|
||||
return noValue;
|
||||
}
|
||||
|
||||
public boolean isSingleValue() {
|
||||
return singleValue;
|
||||
}
|
||||
|
||||
public boolean isBetweenValue() {
|
||||
return betweenValue;
|
||||
}
|
||||
|
||||
public boolean isListValue() {
|
||||
return listValue;
|
||||
}
|
||||
|
||||
public String getTypeHandler() {
|
||||
return typeHandler;
|
||||
}
|
||||
|
||||
protected Criterion(String condition) {
|
||||
super();
|
||||
this.condition = condition;
|
||||
this.typeHandler = null;
|
||||
this.noValue = true;
|
||||
}
|
||||
|
||||
protected Criterion(String condition, Object value, String typeHandler) {
|
||||
super();
|
||||
this.condition = condition;
|
||||
this.value = value;
|
||||
this.typeHandler = typeHandler;
|
||||
if (value instanceof List<?>) {
|
||||
this.listValue = true;
|
||||
} else {
|
||||
this.singleValue = true;
|
||||
}
|
||||
}
|
||||
|
||||
protected Criterion(String condition, Object value) {
|
||||
this(condition, value, null);
|
||||
}
|
||||
|
||||
protected Criterion(String condition, Object value, Object secondValue, String typeHandler) {
|
||||
super();
|
||||
this.condition = condition;
|
||||
this.value = value;
|
||||
this.secondValue = secondValue;
|
||||
this.typeHandler = typeHandler;
|
||||
this.betweenValue = true;
|
||||
}
|
||||
|
||||
protected Criterion(String condition, Object value, Object secondValue) {
|
||||
this(condition, value, secondValue, null);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,19 +0,0 @@
|
||||
package com.shxy.i2.entity;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.io.Serializable;
|
||||
import java.math.BigInteger;
|
||||
import java.util.Date;
|
||||
|
||||
@Data
|
||||
public class Upload_check implements Serializable {
|
||||
private String checkType;
|
||||
|
||||
private BigInteger value;
|
||||
|
||||
private Date updateTime;
|
||||
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
}
|
||||
@ -1,18 +0,0 @@
|
||||
package com.shxy.i2.service;
|
||||
|
||||
public interface Webservcies {
|
||||
|
||||
void uploadData();
|
||||
|
||||
|
||||
void uploadtxData();
|
||||
|
||||
void uploadyspData();
|
||||
void uploadjfjcData();
|
||||
|
||||
void uploadyxData();
|
||||
|
||||
void uploaddcywData();
|
||||
|
||||
void uploadjsyhwjyjcData();
|
||||
}
|
||||
@ -1,48 +0,0 @@
|
||||
package com.shxy.i2.service;
|
||||
|
||||
import com.shxy.i2.bean.ListModel;
|
||||
import com.shxy.i2.bean.ServiceBody;
|
||||
import com.shxy.i2.entity.Niec_Sensors;
|
||||
import org.apache.cxf.endpoint.Client;
|
||||
|
||||
import java.util.HashMap;
|
||||
|
||||
public interface XydlI2Service {
|
||||
|
||||
void upload_byq_jbfd( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_sf6_qtyl( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_dcyw(HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_fhdlbx( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_fhzxq(HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_sf6_qtsf( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_tx( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_ws( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_dr_jyjc( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_jsyhw_jyjc( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_microclimate( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_dlq_jbfd( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_ysp(HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_cnj( HashMap<Integer, Niec_Sensors> equipMap);
|
||||
|
||||
void upload_yx();
|
||||
|
||||
void clear_history();
|
||||
|
||||
ServiceBody<ListModel> list();
|
||||
|
||||
void statics();
|
||||
|
||||
}
|
||||
@ -1,158 +0,0 @@
|
||||
package com.shxy.i2.serviceimpl;
|
||||
|
||||
import com.shxy.i2.Tool.AsyncMethod;
|
||||
import com.shxy.i2.dao.*;
|
||||
import com.shxy.i2.entity.*;
|
||||
import com.shxy.i2.service.Webservcies;
|
||||
import com.shxy.i2.service.XydlI2Service;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Value;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
@Service
|
||||
@Slf4j
|
||||
//@EnableAsync
|
||||
public class WebServiceImpl implements Webservcies {
|
||||
|
||||
@Autowired
|
||||
XydlI2Service xydlI2Service;
|
||||
|
||||
@Autowired
|
||||
AsyncMethod asyncMethod;
|
||||
|
||||
@Autowired
|
||||
private Niec_SensorsDao niec_sensorsDao;
|
||||
|
||||
|
||||
@Value("${webservice.address}")
|
||||
public String address;
|
||||
//
|
||||
@Value("${webservice.connecttime}")
|
||||
public int connecttime;
|
||||
|
||||
@Value("${webservice.receivetime}")
|
||||
public int receivetime;
|
||||
|
||||
// private static String address = "http://10.238.71.98:18096/ppa/webservice/CAGAccessService?wsdl";
|
||||
//
|
||||
// public static int receivetime = 60;
|
||||
//
|
||||
// public static int connecttime = 60;
|
||||
|
||||
/**
|
||||
* 上传cac数据
|
||||
*/
|
||||
@Override
|
||||
public void uploadData() {
|
||||
log.info("实时数据定时任务启动");
|
||||
// 动态客户端
|
||||
log.info("开始执行定时任务-查询数据库");
|
||||
HashMap<Integer, Niec_Sensors> equipMap = new HashMap();
|
||||
List<Niec_Sensors> niec_sensors = niec_sensorsDao.selectAll();
|
||||
for (Niec_Sensors item : niec_sensors) {
|
||||
equipMap.put(item.getId(), item);
|
||||
}
|
||||
xydlI2Service.upload_sf6_qtyl( equipMap);
|
||||
|
||||
xydlI2Service.upload_fhdlbx(equipMap);
|
||||
xydlI2Service.upload_fhzxq( equipMap);
|
||||
xydlI2Service.upload_sf6_qtsf( equipMap);
|
||||
xydlI2Service.upload_ws( equipMap);
|
||||
xydlI2Service.upload_dr_jyjc( equipMap);
|
||||
|
||||
xydlI2Service.upload_microclimate( equipMap);
|
||||
xydlI2Service.upload_cnj( equipMap);
|
||||
log.info("实时数据定时任务结束");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void uploadtxData() {
|
||||
log.info("实时铁芯数据定时任务启动");
|
||||
// 动态客户端
|
||||
log.info("开始执行定时任务-查询数据库");
|
||||
HashMap<Integer, Niec_Sensors> equipMap = new HashMap();
|
||||
List<Niec_Sensors> niec_sensors = niec_sensorsDao.selectAll();
|
||||
for (Niec_Sensors item : niec_sensors) {
|
||||
equipMap.put(item.getId(), item);
|
||||
}
|
||||
xydlI2Service.upload_tx( equipMap);
|
||||
log.info("实时数据定时任务结束");
|
||||
}
|
||||
|
||||
|
||||
//放到配置文件
|
||||
@Override
|
||||
public void uploadyspData() {
|
||||
log.info("油色谱数据定时任务启动");
|
||||
// 动态客户端
|
||||
log.info("开始执行定时任务-查询数据库");
|
||||
HashMap<Integer, Niec_Sensors> equipMap = new HashMap();
|
||||
List<Niec_Sensors> niec_sensors = niec_sensorsDao.selectAll();
|
||||
for (Niec_Sensors item : niec_sensors) {
|
||||
equipMap.put(item.getId(), item);
|
||||
}
|
||||
xydlI2Service.upload_ysp( equipMap);
|
||||
log.info("油色谱数据定时任务结束");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void uploadjfjcData() {
|
||||
log.info("局放监测数据定时任务启动");
|
||||
// 动态客户端
|
||||
HashMap<Integer, Niec_Sensors> equipMap = new HashMap();
|
||||
List<Niec_Sensors> niec_sensors = niec_sensorsDao.selectAll();
|
||||
for (Niec_Sensors item : niec_sensors) {
|
||||
equipMap.put(item.getId(), item);
|
||||
}
|
||||
xydlI2Service.upload_dlq_jbfd( equipMap);
|
||||
xydlI2Service.upload_byq_jbfd( equipMap);
|
||||
log.info("局放监测数据定时任务结束");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void uploadyxData() {
|
||||
log.info("实时数据定时任务启动");
|
||||
// 动态客户端
|
||||
log.info("开始执行定时任务-查询数据库");
|
||||
HashMap<Integer, Niec_Sensors> equipMap = new HashMap();
|
||||
List<Niec_Sensors> niec_sensors = niec_sensorsDao.selectAll();
|
||||
for (Niec_Sensors item : niec_sensors) {
|
||||
equipMap.put(item.getId(), item);
|
||||
}
|
||||
xydlI2Service.upload_yx();
|
||||
log.info("实时数据定时任务结束");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void uploaddcywData() {
|
||||
log.info("实时数据定时任务启动");
|
||||
// 动态客户端
|
||||
log.info("开始执行定时任务-查询数据库");
|
||||
HashMap<Integer, Niec_Sensors> equipMap = new HashMap();
|
||||
List<Niec_Sensors> niec_sensors = niec_sensorsDao.selectAll();
|
||||
for (Niec_Sensors item : niec_sensors) {
|
||||
equipMap.put(item.getId(), item);
|
||||
}
|
||||
xydlI2Service.upload_dcyw( equipMap);
|
||||
log.info("实时数据定时任务结束");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void uploadjsyhwjyjcData() {
|
||||
log.info("实时数据定时任务启动");
|
||||
// 动态客户端
|
||||
log.info("开始执行定时任务-查询数据库");
|
||||
HashMap<Integer, Niec_Sensors> equipMap = new HashMap();
|
||||
List<Niec_Sensors> niec_sensors = niec_sensorsDao.selectAll();
|
||||
for (Niec_Sensors item : niec_sensors) {
|
||||
equipMap.put(item.getId(), item);
|
||||
}
|
||||
xydlI2Service.upload_jsyhw_jyjc( equipMap);
|
||||
log.info("实时数据定时任务结束");
|
||||
}
|
||||
|
||||
}
|
||||
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
File diff suppressed because it is too large
Load Diff
@ -1,81 +0,0 @@
|
||||
package com.shxy.i2.timeTask;
|
||||
|
||||
import com.shxy.i2.service.Webservcies;
|
||||
import com.shxy.i2.service.XydlI2Service;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.scheduling.annotation.EnableScheduling;
|
||||
import org.springframework.scheduling.annotation.Scheduled;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
/**
|
||||
* @author jingjing
|
||||
* @date 2023-11-16 15:06
|
||||
*/
|
||||
@Component
|
||||
@EnableScheduling
|
||||
@Slf4j
|
||||
//@EnableAsync
|
||||
public class ScheduledTask {
|
||||
|
||||
@Autowired
|
||||
Webservcies webservcies;
|
||||
|
||||
@Autowired
|
||||
XydlI2Service xydlI2Service;
|
||||
|
||||
@Scheduled(fixedDelay = 60 * 60 * 1000)
|
||||
public void cacyspupload() {
|
||||
log.info("cacyspupload执行" );
|
||||
webservcies.uploadyspData();
|
||||
}
|
||||
|
||||
@Scheduled(fixedDelay = 1 * 30 * 1000)
|
||||
public void cacjfjcupload() {
|
||||
log.info("cacjfjcupload执行" );
|
||||
webservcies.uploadjfjcData();
|
||||
}
|
||||
|
||||
@Scheduled(fixedDelay = 1 * 30 * 1000)
|
||||
public void cacupload() {
|
||||
log.info("cacupload执行" );
|
||||
webservcies.uploadData();
|
||||
}
|
||||
|
||||
@Scheduled(fixedDelay = 1 * 30 * 1000)
|
||||
public void cactxupload() {
|
||||
log.info("cactxupload执行" );
|
||||
webservcies.uploadtxData();
|
||||
}
|
||||
|
||||
@Scheduled(fixedDelay = 1 * 30 * 1000)
|
||||
public void cacyxupload() {
|
||||
log.info("cacyxupload执行" );
|
||||
webservcies.uploadyxData();
|
||||
}
|
||||
|
||||
@Scheduled(fixedDelay = 1 * 30 * 1000)
|
||||
public void cacdcywupload() {
|
||||
log.info("cacdcywupload执行" );
|
||||
webservcies.uploaddcywData();
|
||||
}
|
||||
|
||||
@Scheduled(fixedDelay = 1 * 30 * 1000)
|
||||
public void cacjsyhwjyjcupload() {
|
||||
log.info("cacjsyhwjyjcupload执行" );
|
||||
webservcies.uploadjsyhwjyjcData();
|
||||
}
|
||||
|
||||
@Scheduled(cron = "0 0 13 * * ?")
|
||||
public void clear() {
|
||||
log.info("clear" );
|
||||
xydlI2Service.clear_history();
|
||||
}
|
||||
|
||||
// @Scheduled(cron = "0 0 * * * ?")
|
||||
// public void statics() {
|
||||
// log.info("开始统计" );
|
||||
// xydlI2Service.statics();
|
||||
// }
|
||||
|
||||
}
|
||||
@ -1,4 +0,0 @@
|
||||
# Spring配置
|
||||
spring:
|
||||
profiles:
|
||||
active: test
|
||||
@ -1,44 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.shxy.i2.dao.Data_Byq_JbfdDao">
|
||||
<resultMap id="BaseResultMap" type="com.shxy.i2.entity.Data_Byq_Jbfd">
|
||||
<id column="id" jdbcType="BIGINT" property="id"/>
|
||||
<result column="maxid" jdbcType="BIGINT" property="maxid"/>
|
||||
<result column="minid" jdbcType="BIGINT" property="minid"/>
|
||||
<result column="eqmid" jdbcType="INTEGER" property="eqmid"/>
|
||||
<result column="acquisitionTime" jdbcType="TIMESTAMP" property="acquisitiontime"/>
|
||||
<result column="dischargeCapacity" jdbcType="REAL" property="dischargecapacity"/>
|
||||
<result column="dischargePosition" jdbcType="REAL" property="dischargeposition"/>
|
||||
<result column="pulseCount" jdbcType="REAL" property="pulsecount"/>
|
||||
<result column="isupload" jdbcType="INTEGER" property="isupload"/>
|
||||
<result column="create_time" jdbcType="TIMESTAMP" property="createTime"/>
|
||||
<result column="update_time" jdbcType="TIMESTAMP" property="updateTime"/>
|
||||
<result column="dischargeWaveform" jdbcType="LONGVARBINARY" property="dischargewaveform"/>
|
||||
</resultMap>
|
||||
<sql id="Base_Column_List">
|
||||
id, eqmid, acquisitionTime, dischargeCapacity, dischargePosition, pulseCount, isupload, dischargeWaveform,
|
||||
create_time, update_time
|
||||
</sql>
|
||||
|
||||
<select id="selectUploadById" resultMap="BaseResultMap">
|
||||
SELECT
|
||||
t1.id, t1.eqmid, t1.acquisitionTime, t1.dischargeCapacity, t1.dischargePosition, t1.pulseCount, t1.isupload,
|
||||
t1.dischargeWaveform,t1.create_time, t1.update_time
|
||||
FROM
|
||||
data_byq_jbfd t1 where t1.id <![CDATA[>]]> #{maxid} limit 10000
|
||||
</select>
|
||||
|
||||
<select id="selectMaxId" resultMap="BaseResultMap">
|
||||
SELECT MAX( id ) AS maxid FROM data_byq_jbfd
|
||||
</select>
|
||||
|
||||
<select id="selectNowId" resultMap="BaseResultMap">
|
||||
SELECT MAX( id ) AS maxid,MIN( id ) AS minid FROM data_byq_jbfd where acquisitionTime >= #{date}
|
||||
</select>
|
||||
|
||||
<delete id="deleteData" >
|
||||
delete
|
||||
from data_byq_jbfd
|
||||
where acquisitionTime <![CDATA[<]]> #{time}
|
||||
</delete>
|
||||
</mapper>
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue