bgy
/
scheduletask
1
0
Fork 0
Code Issues 0 Pull Requests 0 Projects 0 Releases 0 Wiki Activity
Browse Source

定时检查服务

master
bgy 3 months ago
commit
5dcc8f67c6
25 changed files with 2135 additions and 0 deletions
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. +31
    -0
      .gitignore
  2. +114
    -0
      .mvn/wrapper/MavenWrapperDownloader.java
  3. BIN
      .mvn/wrapper/maven-wrapper.jar
  4. +1
    -0
      .mvn/wrapper/maven-wrapper.properties
  5. +286
    -0
      mvnw
  6. +161
    -0
      mvnw.cmd
  7. +144
    -0
      pom.xml
  8. +16
    -0
      src/main/java/com/topsail/scheduletask/ScheduleTaskApplication.java
  9. +77
    -0
      src/main/java/com/topsail/scheduletask/mapper/InformLogDao.java
  10. +62
    -0
      src/main/java/com/topsail/scheduletask/pojo/InformLog.java
  11. +74
    -0
      src/main/java/com/topsail/scheduletask/pojo/InformLogVo.java
  12. +55
    -0
      src/main/java/com/topsail/scheduletask/receiver/AmqpListener.java
  13. +65
    -0
      src/main/java/com/topsail/scheduletask/result/CodeMsg.java
  14. +89
    -0
      src/main/java/com/topsail/scheduletask/result/Result.java
  15. +261
    -0
      src/main/java/com/topsail/scheduletask/service/AmqpService.java
  16. +60
    -0
      src/main/java/com/topsail/scheduletask/task/CheckRabbitMqScheduleTask.java
  17. +39
    -0
      src/main/java/com/topsail/scheduletask/task/ScheduleDeleteTask.java
  18. +168
    -0
      src/main/java/com/topsail/scheduletask/util/MaiSenderlUtil.java
  19. +111
    -0
      src/main/java/com/topsail/scheduletask/util/StringHandleUtil.java
  20. +6
    -0
      src/main/resources/application-prod.properties
  21. +11
    -0
      src/main/resources/application-rds.properties
  22. +6
    -0
      src/main/resources/application-test.properties
  23. +52
    -0
      src/main/resources/application.properties
  24. +186
    -0
      src/main/resources/com/topsail/scheduletask/mapper/InformLogMapper.xml
  25. +60
    -0
      src/main/resources/generatorConfig.xml

+ 31
- 0
.gitignore View File

@ -0,0 +1,31 @@
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**
!**/src/test/**
### 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/
### VS Code ###
.vscode/

+ 114
- 0
.mvn/wrapper/MavenWrapperDownloader.java View File

@ -0,0 +1,114 @@
/*
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.
*/
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.net.URL;
import java.nio.channels.Channels;
import java.nio.channels.ReadableByteChannel;
import java.util.Properties;
public class MavenWrapperDownloader {
/**
* Default URL to download the maven-wrapper.jar from, if no 'downloadUrl' is provided.
*/
private static final String DEFAULT_DOWNLOAD_URL =
"https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.4.2/maven-wrapper-0.4.2.jar";
/**
* Path to the maven-wrapper.properties file, which might contain a downloadUrl property to
* use instead of the default one.
*/
private static final String MAVEN_WRAPPER_PROPERTIES_PATH =
".mvn/wrapper/maven-wrapper.properties";
/**
* Path where the maven-wrapper.jar will be saved to.
*/
private static final String MAVEN_WRAPPER_JAR_PATH =
".mvn/wrapper/maven-wrapper.jar";
/**
* Name of the property which should be used to override the default download url for the wrapper.
*/
private static final String PROPERTY_NAME_WRAPPER_URL = "wrapperUrl";
public static void main(String args[]) {
System.out.println("- Downloader started");
File baseDirectory = new File(args[0]);
System.out.println("- Using base directory: " + baseDirectory.getAbsolutePath());
// If the maven-wrapper.properties exists, read it and check if it contains a custom
// wrapperUrl parameter.
File mavenWrapperPropertyFile = new File(baseDirectory, MAVEN_WRAPPER_PROPERTIES_PATH);
String url = DEFAULT_DOWNLOAD_URL;
if (mavenWrapperPropertyFile.exists()) {
FileInputStream mavenWrapperPropertyFileInputStream = null;
try {
mavenWrapperPropertyFileInputStream = new FileInputStream(mavenWrapperPropertyFile);
Properties mavenWrapperProperties = new Properties();
mavenWrapperProperties.load(mavenWrapperPropertyFileInputStream);
url = mavenWrapperProperties.getProperty(PROPERTY_NAME_WRAPPER_URL, url);
} catch (IOException e) {
System.out.println("- ERROR loading '" + MAVEN_WRAPPER_PROPERTIES_PATH + "'");
} finally {
try {
if (mavenWrapperPropertyFileInputStream != null) {
mavenWrapperPropertyFileInputStream.close();
}
} catch (IOException e) {
// Ignore ...
}
}
}
System.out.println("- Downloading from: : " + url);
File outputFile = new File(baseDirectory.getAbsolutePath(), MAVEN_WRAPPER_JAR_PATH);
if (!outputFile.getParentFile().exists()) {
if (!outputFile.getParentFile().mkdirs()) {
System.out.println(
"- ERROR creating output direcrory '" + outputFile.getParentFile().getAbsolutePath() + "'");
}
}
System.out.println("- Downloading to: " + outputFile.getAbsolutePath());
try {
downloadFileFromURL(url, outputFile);
System.out.println("Done");
System.exit(0);
} catch (Throwable e) {
System.out.println("- Error downloading");
e.printStackTrace();
System.exit(1);
}
}
private static void downloadFileFromURL(String urlString, File destination) throws Exception {
URL website = new URL(urlString);
ReadableByteChannel rbc;
rbc = Channels.newChannel(website.openStream());
FileOutputStream fos = new FileOutputStream(destination);
fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
fos.close();
rbc.close();
}
}

BIN
.mvn/wrapper/maven-wrapper.jar View File


+ 1
- 0
.mvn/wrapper/maven-wrapper.properties View File

@ -0,0 +1 @@
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.6.0/apache-maven-3.6.0-bin.zip

+ 286
- 0
mvnw View File

@ -0,0 +1,286 @@
#!/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.
# ----------------------------------------------------------------------------
# ----------------------------------------------------------------------------
# Maven2 Start Up Batch script
#
# Required ENV vars:
# ------------------
# JAVA_HOME - location of a JDK home dir
#
# Optional ENV vars
# -----------------
# M2_HOME - location of maven2's installed home dir
# MAVEN_OPTS - parameters passed to the Java VM when running Maven
# e.g. to debug Maven itself, use
# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
# ----------------------------------------------------------------------------
if [ -z "$MAVEN_SKIP_RC" ] ; then
if [ -f /etc/mavenrc ] ; then
. /etc/mavenrc
fi
if [ -f "$HOME/.mavenrc" ] ; then
. "$HOME/.mavenrc"
fi
fi
# OS specific support. $var _must_ be set to either true or false.
cygwin=false;
darwin=false;
mingw=false
case "`uname`" in
CYGWIN*) cygwin=true ;;
MINGW*) mingw=true;;
Darwin*) darwin=true
# Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
# See https://developer.apple.com/library/mac/qa/qa1170/_index.html
if [ -z "$JAVA_HOME" ]; then
if [ -x "/usr/libexec/java_home" ]; then
export JAVA_HOME="`/usr/libexec/java_home`"
else
export JAVA_HOME="/Library/Java/Home"
fi
fi
;;
esac
if [ -z "$JAVA_HOME" ] ; then
if [ -r /etc/gentoo-release ] ; then
JAVA_HOME=`java-config --jre-home`
fi
fi
if [ -z "$M2_HOME" ] ; then
## resolve links - $0 may be a link to maven's home
PRG="$0"
# need this for relative symlinks
while [ -h "$PRG" ] ; do
ls=`ls -ld "$PRG"`
link=`expr "$ls" : '.*-> \(.*\)$'`
if expr "$link" : '/.*' > /dev/null; then
PRG="$link"
else
PRG="`dirname "$PRG"`/$link"
fi
done
saveddir=`pwd`
M2_HOME=`dirname "$PRG"`/..
# make it fully qualified
M2_HOME=`cd "$M2_HOME" && pwd`
cd "$saveddir"
# echo Using m2 at $M2_HOME
fi
# For Cygwin, ensure paths are in UNIX format before anything is touched
if $cygwin ; then
[ -n "$M2_HOME" ] &&
M2_HOME=`cygpath --unix "$M2_HOME"`
[ -n "$JAVA_HOME" ] &&
JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
[ -n "$CLASSPATH" ] &&
CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
fi
# For Mingw, ensure paths are in UNIX format before anything is touched
if $mingw ; then
[ -n "$M2_HOME" ] &&
M2_HOME="`(cd "$M2_HOME"; pwd)`"
[ -n "$JAVA_HOME" ] &&
JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`"
# TODO classpath?
fi
if [ -z "$JAVA_HOME" ]; then
javaExecutable="`which javac`"
if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then
# readlink(1) is not available as standard on Solaris 10.
readLink=`which readlink`
if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then
if $darwin ; then
javaHome="`dirname \"$javaExecutable\"`"
javaExecutable="`cd \"$javaHome\" && pwd -P`/javac"
else
javaExecutable="`readlink -f \"$javaExecutable\"`"
fi
javaHome="`dirname \"$javaExecutable\"`"
javaHome=`expr "$javaHome" : '\(.*\)/bin'`
JAVA_HOME="$javaHome"
export JAVA_HOME
fi
fi
fi
if [ -z "$JAVACMD" ] ; then
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD="$JAVA_HOME/jre/sh/java"
else
JAVACMD="$JAVA_HOME/bin/java"
fi
else
JAVACMD="`which java`"
fi
fi
if [ ! -x "$JAVACMD" ] ; then
echo "Error: JAVA_HOME is not defined correctly." >&2
echo " We cannot execute $JAVACMD" >&2
exit 1
fi
if [ -z "$JAVA_HOME" ] ; then
echo "Warning: JAVA_HOME environment variable is not set."
fi
CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher
# traverses directory structure from process work directory to filesystem root
# first directory with .mvn subdirectory is considered project base directory
find_maven_basedir() {
if [ -z "$1" ]
then
echo "Path not specified to find_maven_basedir"
return 1
fi
basedir="$1"
wdir="$1"
while [ "$wdir" != '/' ] ; do
if [ -d "$wdir"/.mvn ] ; then
basedir=$wdir
break
fi
# workaround for JBEAP-8937 (on Solaris 10/Sparc)
if [ -d "${wdir}" ]; then
wdir=`cd "$wdir/.."; pwd`
fi
# end of workaround
done
echo "${basedir}"
}
# concatenates all lines of a file
concat_lines() {
if [ -f "$1" ]; then
echo "$(tr -s '\n' ' ' < "$1")"
fi
}
BASE_DIR=`find_maven_basedir "$(pwd)"`
if [ -z "$BASE_DIR" ]; then
exit 1;
fi
##########################################################################################
# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
# This allows using the maven wrapper in projects that prohibit checking in binary data.
##########################################################################################
if [ -r "$BASE_DIR/.mvn/wrapper/maven-wrapper.jar" ]; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found .mvn/wrapper/maven-wrapper.jar"
fi
else
if [ "$MVNW_VERBOSE" = true ]; then
echo "Couldn't find .mvn/wrapper/maven-wrapper.jar, downloading it ..."
fi
jarUrl="https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.4.2/maven-wrapper-0.4.2.jar"
while IFS="=" read key value; do
case "$key" in (wrapperUrl) jarUrl="$value"; break ;;
esac
done < "$BASE_DIR/.mvn/wrapper/maven-wrapper.properties"
if [ "$MVNW_VERBOSE" = true ]; then
echo "Downloading from: $jarUrl"
fi
wrapperJarPath="$BASE_DIR/.mvn/wrapper/maven-wrapper.jar"
if command -v wget > /dev/null; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found wget ... using wget"
fi
wget "$jarUrl" -O "$wrapperJarPath"
elif command -v curl > /dev/null; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found curl ... using curl"
fi
curl -o "$wrapperJarPath" "$jarUrl"
else
if [ "$MVNW_VERBOSE" = true ]; then
echo "Falling back to using Java to download"
fi
javaClass="$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.java"
if [ -e "$javaClass" ]; then
if [ ! -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
if [ "$MVNW_VERBOSE" = true ]; then
echo " - Compiling MavenWrapperDownloader.java ..."
fi
# Compiling the Java class
("$JAVA_HOME/bin/javac" "$javaClass")
fi
if [ -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
# Running the downloader
if [ "$MVNW_VERBOSE" = true ]; then
echo " - Running MavenWrapperDownloader.java ..."
fi
("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$MAVEN_PROJECTBASEDIR")
fi
fi
fi
fi
##########################################################################################
# End of extension
##########################################################################################
export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
if [ "$MVNW_VERBOSE" = true ]; then
echo $MAVEN_PROJECTBASEDIR
fi
MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
# For Cygwin, switch paths to Windows format before running java
if $cygwin; then
[ -n "$M2_HOME" ] &&
M2_HOME=`cygpath --path --windows "$M2_HOME"`
[ -n "$JAVA_HOME" ] &&
JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"`
[ -n "$CLASSPATH" ] &&
CLASSPATH=`cygpath --path --windows "$CLASSPATH"`
[ -n "$MAVEN_PROJECTBASEDIR" ] &&
MAVEN_PROJECTBASEDIR=`cygpath --path --windows "$MAVEN_PROJECTBASEDIR"`
fi
WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
exec "$JAVACMD" \
$MAVEN_OPTS \
-classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
"-Dmaven.home=${M2_HOME}" "-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"

+ 161
- 0
mvnw.cmd View File

@ -0,0 +1,161 @@
@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 Maven2 Start Up Batch script
@REM
@REM Required ENV vars:
@REM JAVA_HOME - location of a JDK home dir
@REM
@REM Optional ENV vars
@REM M2_HOME - location of maven2's installed home dir
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a key stroke 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 my setting MAVEN_BATCH_ECHO to 'on'
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
@REM set %HOME% to equivalent of $HOME
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
@REM Execute a user defined script before this one
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
if exist "%HOME%\mavenrc_pre.bat" call "%HOME%\mavenrc_pre.bat"
if exist "%HOME%\mavenrc_pre.cmd" call "%HOME%\mavenrc_pre.cmd"
:skipRcPre
@setlocal
set ERROR_CODE=0
@REM To isolate internal variables from possible post scripts, we use another setlocal
@setlocal
@REM ==== START VALIDATION ====
if not "%JAVA_HOME%" == "" goto OkJHome
echo.
echo Error: JAVA_HOME not found in your environment. >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
:OkJHome
if exist "%JAVA_HOME%\bin\java.exe" goto init
echo.
echo Error: JAVA_HOME is set to an invalid directory. >&2
echo JAVA_HOME = "%JAVA_HOME%" >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error
@REM ==== END VALIDATION ====
:init
@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
@REM Fallback to current working directory if not found.
set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
set EXEC_DIR=%CD%
set WDIR=%EXEC_DIR%
:findBaseDir
IF EXIST "%WDIR%"\.mvn goto baseDirFound
cd ..
IF "%WDIR%"=="%CD%" goto baseDirNotFound
set WDIR=%CD%
goto findBaseDir
:baseDirFound
set MAVEN_PROJECTBASEDIR=%WDIR%
cd "%EXEC_DIR%"
goto endDetectBaseDir
:baseDirNotFound
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
cd "%EXEC_DIR%"
:endDetectBaseDir
IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
@setlocal EnableExtensions EnableDelayedExpansion
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
:endReadAdditionalConfig
SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.4.2/maven-wrapper-0.4.2.jar"
FOR /F "tokens=1,2 delims==" %%A IN (%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties) DO (
IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
)
@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
if exist %WRAPPER_JAR% (
echo Found %WRAPPER_JAR%
) else (
echo Couldn't find %WRAPPER_JAR%, downloading it ...
echo Downloading from: %DOWNLOAD_URL%
powershell -Command "(New-Object Net.WebClient).DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"
echo Finished downloading %WRAPPER_JAR%
)
@REM End of extension
%MAVEN_JAVA_EXE% %JVM_CONFIG_MAVEN_PROPS% %MAVEN_OPTS% %MAVEN_DEBUG_OPTS% -classpath %WRAPPER_JAR% "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
if ERRORLEVEL 1 goto error
goto end
:error
set ERROR_CODE=1
:end
@endlocal & set ERROR_CODE=%ERROR_CODE%
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPost
@REM check for post script, once with legacy .bat ending and once with .cmd ending
if exist "%HOME%\mavenrc_post.bat" call "%HOME%\mavenrc_post.bat"
if exist "%HOME%\mavenrc_post.cmd" call "%HOME%\mavenrc_post.cmd"
:skipRcPost
@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
if "%MAVEN_BATCH_PAUSE%" == "on" pause
if "%MAVEN_TERMINATE_CMD%" == "on" exit %ERROR_CODE%
exit /B %ERROR_CODE%

+ 144
- 0
pom.xml View File

@ -0,0 +1,144 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.8.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.topsail</groupId>
<artifactId>scheduletask</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>scheduletask</name>
<description>scheduletask</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.0</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.13</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.15</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
</dependency>
<dependency>
<groupId>com.influxdb</groupId>
<artifactId>influxdb-client-java</artifactId>
<version>1.8.0</version>
</dependency>
<!-- 添加junit测试单元包 -->
<!-- <dependency>-->
<!-- <groupId>org.springframework.boot</groupId>-->
<!-- <artifactId>spring-boot-starter-test</artifactId>-->
<!-- <version> 1.5.1.RELEASE</version>-->
<!-- </dependency>-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>4.3.6.RELEASE</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.6</version>
</dependency>
<!-- 分页pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>1.2.10</version>
</dependency>
<!-- import spring mail sender -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-mail</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>2.1.8.RELEASE</version>
</plugin>
<plugin>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-maven-plugin</artifactId>
<version>1.3.5</version>
<dependencies>
<!-- jdbc 依赖 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.40</version>
</dependency>
<dependency>
<groupId>com.itfsw</groupId>
<artifactId>mybatis-generator-plugin</artifactId>
<version>1.2.20</version>
</dependency>
</dependencies>
</plugin>
</plugins>
<resources>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*.properties</include>
<include>**/*.xml</include>
</includes>
<filtering>false</filtering>
</resource>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.properties</include>
<include>**/*.xml</include>
</includes>
<filtering>false</filtering>
</resource>
</resources>
</build>
</project>

+ 16
- 0
src/main/java/com/topsail/scheduletask/ScheduleTaskApplication.java View File

@ -0,0 +1,16 @@
package com.topsail.scheduletask;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import java.util.TimeZone;
@SpringBootApplication
@MapperScan("com.topsail.scheduletask.mapper")
public class ScheduleTaskApplication {
public static void main(String[] args) {
TimeZone.setDefault(TimeZone.getTimeZone("Asia/Shanghai"));
SpringApplication.run(ScheduleTaskApplication.class, args);
}
}

+ 77
- 0
src/main/java/com/topsail/scheduletask/mapper/InformLogDao.java View File

@ -0,0 +1,77 @@
package com.topsail.scheduletask.mapper;
import com.topsail.scheduletask.pojo.InformLog;
import com.topsail.scheduletask.pojo.InformLogVo;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
*
* 信息推送日志表Dao
*
* @version
* <pre>
* Author Version Date Changes
* Administrator 1.0 2021年11月24日 Created
*
* </pre>
* @since 1.
*/
@Repository
public interface InformLogDao {
/**
* 信息推送日志表 新增
*
* @param informLog
* @return
*/
int saveInformLog(@Param("informLog") InformLog informLog);
/**
* 信息推送日志表 更新
*
* @param informLog
* @return
*/
int updateInformLog(InformLog informLog);
/**
*信息推送日志表 删除
*
* @param id
* @return
*/
int deleteInformLog(Integer id);
/**
* 信息推送日志表 查询列表
*
* @param informLog
* @param start
* @param pageSize
* @return
*/
List<InformLogVo> pageListInformLog(@Param("informLog") InformLogVo informLog, @Param("start") Integer start, @Param("pageSize") Integer pageSize);
/**
* 信息推送日志表 count
*
* @param informLog
* @return
*/
Integer findCountInformLog(@Param("informLog") InformLogVo informLog);
/**
* 信息推送日志表 根据id查询
*
* @param id
* @return
*/
InformLogVo findInformLog(Integer id);
Integer getNewInformLogCount(@Param("subject") String subject,@Param("today") String today);
}

+ 62
- 0
src/main/java/com/topsail/scheduletask/pojo/InformLog.java View File

@ -0,0 +1,62 @@
package com.topsail.scheduletask.pojo;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
import java.util.Date;
/**
*
* 信息推送日志表实体
*
* @version
*
<pre>
* Author Version Date Changes
* Administrator 1.0 2021年11月24日 Created
*
* </pre>
* @since 1.
*/
@Data
public class InformLog implements Serializable {
private static final long serialVersionUID = 5892789166672676L;
/**
*id
*/
private Integer id;
/**
*推送方式
*/
private String informType;
/**
*推送地址
*/
private String informAddress;
/**
*推送内容
*/
private String informData;
/**
*推送结果（0失败1成功）
*/
private Integer state;
/**
*推送返回值记录
*/
private String resultMsg;
/**
*推送场景
*/
private String sendScenarios;
/**
*创建时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime = new Date();
}

+ 74
- 0
src/main/java/com/topsail/scheduletask/pojo/InformLogVo.java View File

@ -0,0 +1,74 @@
package com.topsail.scheduletask.pojo;
import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
import java.util.Date;
/**
*
* 信息推送日志表实体
*
* @version
*
<pre>
* Author Version Date Changes
* Administrator 1.0 2021年11月24日 Created
*
* </pre>
* @since 1.
*/
@Data
public class InformLogVo implements Serializable {
private static final long serialVersionUID = 6509367370157091L;
/**
*id
*/
private Integer id;
/**
*推送方式
*/
private String informType;
/**
*推送地址
*/
private String informAddress;
/**
*推送内容
*/
private String informData;
/**
*推送结果（0失败1成功）
*/
private Integer state;
/**
*推送返回值记录
*/
private String resultMsg;
/**
*推送场景
*/
private String sendScenarios;
/**
*创建时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date createTime;
/**
* 开始时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date startTime;
/**
* 结束时间
*/
@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date endTime;
}

+ 55
- 0
src/main/java/com/topsail/scheduletask/receiver/AmqpListener.java View File

@ -0,0 +1,55 @@
package com.topsail.scheduletask.receiver;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.rabbitmq.client.Channel;
import com.topsail.scheduletask.mapper.InformLogDao;
import com.topsail.scheduletask.service.AmqpService;
import com.topsail.scheduletask.util.MaiSenderlUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.Header;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.Date;
@Component
public class AmqpListener {
public static final Logger LOG = LoggerFactory.getLogger(AmqpListener.class);
//初始化设备时钟错误的设备号集合
@Autowired
private MaiSenderlUtil maiSenderlUtil;
@Autowired
AmqpService amqpService;
@Autowired
InformLogDao informLogDao;
@RabbitListener(queues = "mailNotice")
public void sendMailMessage(@Payload String message, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag, Channel channel) throws Exception {
try {
JSONObject jsonObject = JSONObject.parseObject(message);
String subject = "设备数据流转服务异常";
StringBuffer mailMessage = new StringBuffer();
String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
String today = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
Integer count = informLogDao.getNewInformLogCount(subject, today);
if (count == null || (count != null && count < 2)) {
mailMessage.append("尊敬的&nbsp;").append("，你好！：<br/> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;").append("截止：").append(time).append("&nbsp;&nbsp;").append("堆积消息超过2000条消息未消费，请检查服务器和后台服务程序").append("&nbsp;&nbsp;").append("告警队列信息：").append(JSON.toJSONString(jsonObject));
maiSenderlUtil.sendMail("1129801211@qq.com", subject, mailMessage.toString(), true, null, "设备数据流转服务异常");
}
channel.basicAck(deliveryTag, false);
} catch (Exception e) {
e.printStackTrace();
channel.basicAck(deliveryTag, false);
}
}
}

+ 65
- 0
src/main/java/com/topsail/scheduletask/result/CodeMsg.java View File

@ -0,0 +1,65 @@
package com.topsail.scheduletask.result;
public class CodeMsg {
private int code;
private String msg;
//通用的错误码
public static CodeMsg SUCCESS = new CodeMsg(0, "success");
public static CodeMsg FAILED = new CodeMsg(502, "failed");
public static CodeMsg TOKEN_EXPIRED = new CodeMsg(400, "token过期");
public static CodeMsg TOKEN_INVALID = new CodeMsg(401, "token解析异常");
public static CodeMsg USER_NOT_LOGGED_IN = new CodeMsg(402, "未登录，请登录！");
public static CodeMsg SIGNATURE_ERROR = new CodeMsg(506, "签名失败");
public static CodeMsg SERVER_ERROR = new CodeMsg(500, "服务端异常");
public static CodeMsg FILE_ERROR = new CodeMsg(501, "文件不存在");
public static CodeMsg FILE_EXIST = new CodeMsg(5012, "文件已存在");
public static CodeMsg TIME_ERROR = new CodeMsg(502, "时间格式错误,应为 yyyy-MM-dd HH:mm:ss");
public static CodeMsg DUPLICATEKEY_ERROR = new CodeMsg(502, "IMEI已注册");
public static CodeMsg TIMEMISS_ERROR = new CodeMsg(503, "查询时间缺失，应为 yyyy-MM-dd HH:mm:ss");
public static CodeMsg BIND_ERROR = new CodeMsg(504, "参数绑定异常");
public static CodeMsg CONTROL_ERROR = new CodeMsg(505, "命令下发失败，请检查设备相关信息是否存在或正确以及参数输入是否正确");
private CodeMsg() {
}
public CodeMsg(int code, String msg) {
this.code = code;
this.msg = msg;
}
public int getCode() {
return code;
}
public void setCode(int code) {
this.code = code;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
/**
* 返回带参数的错误码
* @param args
* @return
*/
public CodeMsg fillArgs(Object... args) {
int code = this.code;
String message = String.format(this.msg, args);
return new CodeMsg(code, message);
}
@Override
public String toString() {
return "CodeMsg [code=" + code + ", msg=" + msg + "]";
}
}

+ 89
- 0
src/main/java/com/topsail/scheduletask/result/Result.java View File

@ -0,0 +1,89 @@
package com.topsail.scheduletask.result;
import com.github.pagehelper.PageInfo;
import lombok.Data;
import org.springframework.validation.BindingResult;
import org.springframework.validation.FieldError;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@Data
public class Result<T> {
private int code;
private String msg="success";
private T data;
private Result(T data) {
this.data = data;
}
private Result(int code, String msg) {
this.code = code;
this.msg = msg;
}
private Result(CodeMsg codeMsg) {
if(codeMsg != null) {
this.code = codeMsg.getCode();
this.msg = codeMsg.getMsg();
}
}
/**
* 成功时候的调用
* */
public static<T> Result<T> success(T data){
return new Result<T>(data);
}
/**
* 失败时候的调用
* */
public static <T> Result<T> error(CodeMsg codeMsg){
return new Result<T>(codeMsg);
}
public static <T> Result<T> error(){
return new Result<T>(CodeMsg.FAILED);
}
/**
* BindingResult统一处理
*/
public static Result resolveBindResult(BindingResult bindingResult){
StringBuilder stringBuilder = new StringBuilder();
for (String s : bindingResult.getFieldErrors().stream().map(FieldError::getDefaultMessage).collect(Collectors.toList())) {
stringBuilder.append(",").append(s);
}
return Result.error(new CodeMsg(502,stringBuilder.toString().substring(1)));
}
/**
*分页之后的统一返回对象
* @param t
* @param <T>
* @return
*/
public static<T> Map<String,Object> returnPageMap(List<T> t){
PageInfo<T> pageInfo=new PageInfo(t);
int count=(int)pageInfo.getTotal();
Map<String,Object> map=new HashMap<>();
map.put("list", new ArrayList(pageInfo.getList()));
map.put("count",count);
return map;
}
}

+ 261
- 0
src/main/java/com/topsail/scheduletask/service/AmqpService.java View File

@ -0,0 +1,261 @@
package com.topsail.scheduletask.service;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.rabbitmq.client.Channel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.AmqpAdmin;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.Base64;
import java.util.List;
import java.util.concurrent.TimeoutException;
@Service
public class AmqpService {
public static final Logger LOG = LoggerFactory.getLogger(AmqpService.class);
private final AmqpAdmin amqpAdmin;
private final AmqpTemplate amqpTemplate;
private final ConnectionFactory connectionFactory;
// 从配置文件读取 RabbitMQ Management API 配置
@Value("${rabbitmq.management.url:http://localhost:15672}")
private String managementUrl;
@Value("${rabbitmq.management.username:guest}")
private String managementUsername;
@Value("${rabbitmq.management.password:guest}")
private String managementPassword;
@Value("${rabbitmq.management.vhost:/}")
private String managementVhost;
// 缓存认证头，避免重复计算
private String cachedAuthHeader = null;
@Autowired
public AmqpService(AmqpAdmin amqpAdmin, AmqpTemplate amqpTemplate, ConnectionFactory connectionFactory) {
this.amqpAdmin = amqpAdmin;
this.amqpTemplate = amqpTemplate;
this.connectionFactory = connectionFactory;
}
public void SendMessage(String queue,String content){
//LOG.info("Send ampg" + content);
this.amqpTemplate.convertAndSend(queue,content);
}
public void SendExchange(String exchange,String content){
this.amqpTemplate.convertAndSend(exchange,"",content);
}
public boolean IsQueuesEmpty(String queue){
try{
Message msg = this.amqpTemplate.receive(queue);
if(msg!=null){
this.amqpTemplate.send(queue,msg);
return false;
}else{
return true;
}
}catch (Exception e){
return true;
}
}
/**
* 获取指定队列的消息数量（兼容 Spring Boot 2.1.8）
* @param queueName 队列名称
* @return 队列中待消费的消息数量，如果获取失败或队列不存在则返回-1
*/
public long getQueueMessageCount(String queueName) {
if (queueName == null || queueName.trim().isEmpty()) {
LOG.warn("队列名称不能为空");
return -1;
}
// 使用 Spring AMQP 的 Connection，由 Spring 管理生命周期
org.springframework.amqp.rabbit.connection.Connection connection = null;
Channel channel = null;
try {
// 从 Spring 连接工厂获取连接（有连接池支持）
connection = connectionFactory.createConnection();
channel = connection.createChannel(false);
// queueDeclarePassive 不会创建队列，只是获取队列信息，如果队列不存在会抛出异常
com.rabbitmq.client.AMQP.Queue.DeclareOk declareOk = channel.queueDeclarePassive(queueName);
long messageCount = declareOk.getMessageCount();
LOG.debug("队列 [{}] 当前消息数量: {}", queueName, messageCount);
return messageCount;
} catch (IOException e) {
// 队列不存在时也会抛出 IOException
String errorMsg = e.getMessage();
if (errorMsg != null && (errorMsg.contains("NOT_FOUND") || errorMsg.contains("404"))) {
LOG.warn("队列 [{}] 不存在", queueName);
} else {
LOG.error("获取队列 [{}] 消息数量时发生IO异常: {}", queueName, errorMsg);
}
return -1;
} catch (Exception e) {
LOG.error("获取队列 [{}] 消息数量时发生异常", queueName, e);
return -1;
} finally {
// 关闭资源（从内到外）
if (channel != null && channel.isOpen()) {
try {
channel.close();
} catch (IOException | TimeoutException e) {
LOG.warn("关闭 Channel 时发生异常", e);
}
}
if (connection != null) {
try {
connection.close();
} catch (Exception e) {
LOG.warn("关闭 Connection 时发生异常", e);
}
}
}
}
/**
* 获取RabbitMQ中所有的队列名称（通过 Management HTTP API）
* @return 队列名称列表，如果获取失败则返回空列表
*/
public List<String> getAllQueueNames() {
List<String> queueNames = new ArrayList<>();
// 构建完整的 API URL（处理 URL 末尾可能的斜杠）
String baseUrl = managementUrl.endsWith("/") ? managementUrl.substring(0, managementUrl.length() - 1) : managementUrl;
String apiUrl = baseUrl + "/api/queues";
// 如果需要指定虚拟主机，使用：/api/queues/{vhost}
if (managementVhost != null && !managementVhost.trim().isEmpty() && !"/".equals(managementVhost)) {
try {
// URL 编码虚拟主机名称（因为 / 需要编码为 %2F）
String encodedVhost = java.net.URLEncoder.encode(managementVhost, StandardCharsets.UTF_8.name());
apiUrl = baseUrl + "/api/queues/" + encodedVhost;
} catch (Exception e) {
LOG.warn("虚拟主机名称编码失败，使用默认队列列表", e);
}
}
HttpURLConnection connection = null;
InputStream inputStream = null;
BufferedReader reader = null;
try {
LOG.debug("正在连接 RabbitMQ Management API: {}", apiUrl);
URL url = new URL(apiUrl);
connection = (HttpURLConnection) url.openConnection();
// 设置基本认证（使用缓存的认证头）
String authHeader = getAuthHeader();
connection.setRequestProperty("Authorization", authHeader);
connection.setRequestProperty("Accept", "application/json");
connection.setRequestMethod("GET");
connection.setConnectTimeout(5000);
connection.setReadTimeout(10000);
int responseCode = connection.getResponseCode();
if (responseCode == HttpURLConnection.HTTP_OK) {
inputStream = connection.getInputStream();
reader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8));
// 使用 StringBuilder 高效读取响应
StringBuilder response = new StringBuilder();
char[] buffer = new char[4096];
int bytesRead;
while ((bytesRead = reader.read(buffer)) != -1) {
response.append(buffer, 0, bytesRead);
}
// 使用 FastJSON 解析响应
String jsonResponse = response.toString().trim();
if (!jsonResponse.isEmpty()) {
try {
JSONArray queues = JSONArray.parseArray(jsonResponse);
if (queues != null && !queues.isEmpty()) {
for (int i = 0; i < queues.size(); i++) {
JSONObject queue = queues.getJSONObject(i);
String queueName = queue.getString("name");
if (queueName != null && !queueName.trim().isEmpty()) {
queueNames.add(queueName);
}
}
LOG.info("成功获取 {} 个队列名称", queueNames.size());
} else {
LOG.info("RabbitMQ 中暂无队列");
}
} catch (Exception jsonEx) {
LOG.error("解析 RabbitMQ Management API 响应失败", jsonEx);
}
} else {
LOG.warn("RabbitMQ Management API 返回空响应");
}
} else if (responseCode == HttpURLConnection.HTTP_UNAUTHORIZED) {
LOG.error("RabbitMQ Management API 认证失败，请检查用户名和密码配置");
} else if (responseCode == HttpURLConnection.HTTP_NOT_FOUND) {
LOG.error("RabbitMQ Management API 未找到，请确认 rabbitmq_management 插件已启用");
} else {
LOG.warn("RabbitMQ Management API 响应码: {}, 消息: {}", responseCode, connection.getResponseMessage());
}
} catch (IOException e) {
LOG.error("获取队列列表时发生IO异常，请确认 RabbitMQ Management 插件已启用且服务正常运行", e);
} catch (Exception e) {
LOG.error("获取队列列表时发生未知异常", e);
} finally {
// 关闭资源（从内到外）
if (reader != null) {
try {
reader.close();
} catch (IOException e) {
LOG.warn("关闭 BufferedReader 时发生异常", e);
}
}
if (inputStream != null) {
try {
inputStream.close();
} catch (IOException e) {
LOG.warn("关闭 InputStream 时发生异常", e);
}
}
if (connection != null) {
connection.disconnect();
}
}
return queueNames;
}
/**
* 获取或生成 Basic Auth 认证头
* @return Authorization header 值
*/
private String getAuthHeader() {
if (cachedAuthHeader == null) {
String auth = managementUsername + ":" + managementPassword;
String encodedAuth = Base64.getEncoder().encodeToString(auth.getBytes(StandardCharsets.UTF_8));
cachedAuthHeader = "Basic " + encodedAuth;
}
return cachedAuthHeader;
}
}

+ 60
- 0
src/main/java/com/topsail/scheduletask/task/CheckRabbitMqScheduleTask.java View File

@ -0,0 +1,60 @@
package com.topsail.scheduletask.task;
import com.alibaba.fastjson.JSON;
import com.topsail.scheduletask.service.AmqpService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Component
@Configuration //1.主要用于标记配置类，兼备Component的效果。
@EnableScheduling // 2.开启定时任务
public class CheckRabbitMqScheduleTask {
@Autowired
private Environment env;
@Autowired
AmqpService amqpService;
//1.每个小时定时检查rabbitmq
// @Scheduled(cron = "0 0 0/1 * * ?")
@Scheduled(cron = "0 0/30 * * * ?")
//或直接指定时间间隔，例如：5秒
// @Scheduled(fixedRate=5000)
private void checkRabbitMqCount() {
//查询rabbitmq的队列名称
List<String> allQueueNames = amqpService.getAllQueueNames();
Map<String, Long> queueMessageCountMap = new HashMap<>();
for (String queueName : allQueueNames) {
//获取队列中待消费的消息数量
long count = amqpService.getQueueMessageCount(queueName);
if (count > 2000) {
System.err.println("队列名称：" + queueName + "，待消费消息数量：" + count);
queueMessageCountMap.put(queueName, count);
}
}
if (queueMessageCountMap.size() > 0) {
//将queueMessageCountMap转成json字符串
String json = JSON.toJSONString(queueMessageCountMap);
amqpService.SendMessage("mailNotice", json);
}
}
public static void main(String[] args) {
Map<String, Long> queueMessageCountMap = new HashMap<>();
queueMessageCountMap.put("queue1", 1000L);
queueMessageCountMap.put("queue2", 2000L);
queueMessageCountMap.put("queue3", 3000L);
queueMessageCountMap.put("queue4", 4000L);
String json = JSON.toJSONString(queueMessageCountMap);
System.out.println( json);
}
}

+ 39
- 0
src/main/java/com/topsail/scheduletask/task/ScheduleDeleteTask.java View File

@ -0,0 +1,39 @@
package com.topsail.scheduletask.task;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component
public class ScheduleDeleteTask {
// @Autowired
// SystemLogDao systemLogDao;
// /**
// * 每天凌晨0点45清空数据表collection_meter_mbus_command_step_log
// */
// @Scheduled(cron = "0 45 0 * * ?")
// public void truncateTableRecordsTask() {
// try {
// systemLogDao.truncateTableRecords();
// System.out.println("清空数据表collection_meter_mbus_command_step_log成功！");
// }catch (Exception e){
// e.printStackTrace();
// System.out.println("清空数据表collection_meter_mbus_command_step_log失败！");
// }
// }
//
// /**
// * 每周周一0点删除数据表online_rate(最新前10万条数据)
// */
// @Scheduled(cron = "0 0 0 * * 1")
// public void deleteTableRecordsTask() {
// try {
// Integer minId = systemLogDao.queryNeedDeleteMinId();
// systemLogDao.deleteTableRecordsTask(minId);
// System.out.println("清空数据表online_rate成功！"+minId);
// }catch (Exception e){
// e.printStackTrace();
// System.out.println("清空数据表online_rate失败！");
// }
// }
}

+ 168
- 0
src/main/java/com/topsail/scheduletask/util/MaiSenderlUtil.java View File

@ -0,0 +1,168 @@
package com.topsail.scheduletask.util;
import com.topsail.scheduletask.mapper.InformLogDao;
import com.topsail.scheduletask.pojo.InformLog;
import com.topsail.scheduletask.result.CodeMsg;
import com.topsail.scheduletask.result.Result;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.FileSystemResource;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.mail.javamail.MimeMessageHelper;
import org.springframework.stereotype.Component;
import javax.mail.internet.MimeMessage;
import java.util.List;
/**
* @ClassName MaiSenderlUtil
* @Deacription TODO
* @Author Administrator
* @Date 2021/3/15 11:00
* @Version 1.0
**/
@Component
public class MaiSenderlUtil {
static final Logger logger = LoggerFactory.getLogger(MaiSenderlUtil.class);
@Autowired
private JavaMailSender mailSender;
@Autowired
private InformLogDao informLogDao;
@Value("${spring.mail.username}")
private String from;
// @Autowired
// public void setQueryMapper(JavaMailSender mailSender) {
// this.mailSender = mailSender;
// }
public Result sendMail(String to, String subject, String text , String sendScenarios){
InformLog informLog = new InformLog();
informLog.setInformAddress(to);
informLog.setInformType("email");
informLog.setInformData(text);
informLog.setSendScenarios(sendScenarios);
// //设置服务器验证信息
// Properties prop = new Properties();
// prop.setProperty("mail.smtp.auth", "true");
// prop.setProperty("mail.smtp.timeout", "994"); // 加密端口(ssl) 可通过 https://qiye.163.com/help/client-profile.html 进行查询
//
// MailSSLSocketFactory sf = new MailSSLSocketFactory();// SSL加密
// sf.setTrustAllHosts(true); // 设置信任所有的主机
// prop.put("mail.smtp.ssl.enable", "true");
// prop.put("mail.smtp.ssl.socketFactory", sf);
SimpleMailMessage message = new SimpleMailMessage();
//发件人昵称展示 要与邮箱设置的发送名称一致，不然报错
message.setFrom(from);
//接收邮箱
message.setTo(to);
//邮件主题
message.setSubject(subject);
//邮箱内容
message.setText(text);
try {
mailSender.send(message);
logger.info("send mail success");
informLog.setState(1);
informLog.setResultMsg("send mail success");
return Result.success(null);
} catch (Exception e) {
logger.error("send mail fail:", e);
informLog.setState(0);
informLog.setResultMsg("send mail fail:"+ e);
return Result.error(new CodeMsg(502,"失败"));
}finally {
informLogDao.saveInformLog(informLog);
}
}
public Result sendMail(String to, String subject, String text, boolean html, List<String> fileUrls, String sendScenarios){
InformLog informLog = new InformLog();
informLog.setInformAddress(to);
informLog.setInformType("email");
informLog.setInformData(text);
informLog.setSendScenarios(sendScenarios);
try {
// Properties prop = new Properties();
// prop.setProperty("mail.smtp.auth", "true"); // 需要验证用户名密码
// //设置超时时间
// prop.setProperty("mail.smtp.timeout", "25000");
//
// // 关于QQ邮箱，还要设置SSL加密，加上以下代码即可
// MailSSLSocketFactory sf = new MailSSLSocketFactory();
// sf.setTrustAllHosts(true);
// prop.put("mail.smtp.ssl.enable", "true");
// prop.put("mail.smtp.ssl.socketFactory", sf);
MimeMessage mimeMessage = mailSender.createMimeMessage();
MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
helper.setFrom(from);
helper.setTo(to);
helper.setSubject(subject);
helper.setText(text,html);
if(fileUrls != null && fileUrls.size() > 0){
for(String fileUrl : fileUrls){
FileSystemResource fsr = new FileSystemResource(fileUrl);
String fileName = fsr.getFilename();
helper.addAttachment(fileName, fsr);
}
}
mailSender.send(mimeMessage);
logger.info("send mail success");
informLog.setState(1);
informLog.setResultMsg("send mail success");
return Result.success(null);
} catch (Exception e) {
logger.error("send mail fail", e);
informLog.setState(0);
informLog.setResultMsg("send mail fail:"+ e);
return Result.error(new CodeMsg(502,"失败"));
}finally {
try {
informLogDao.saveInformLog(informLog);
}catch (Exception e){
logger.error("保存异常信息失败",e);
}
}
}
public static void main(String[] args) {
String fileUrl = "D:\\test\\report\\2020年按照产品进行异常问题统计.xlsx";
if(fileUrl.contains("\\")){
String fileName = fileUrl.substring(fileUrl.lastIndexOf("\\")+1);
System.out.println(fileName);
}
}
}

+ 111
- 0
src/main/java/com/topsail/scheduletask/util/StringHandleUtil.java View File

@ -0,0 +1,111 @@
package com.topsail.scheduletask.util;
import java.math.BigInteger;
public class StringHandleUtil {
/**
* 判断字符串是否头部和尾部都以两个双引号包裹
*
* @param str 待检查的字符串
* @return 若字符串首尾各有两个双引号则返回true，否则返回false
*/
public static boolean isWrappedWithTwoQuotes(String str) {
// 检查字符串是否为null或长度不足4（至少需要4个字符：2个前引号+2个后引号）
if (str == null || str.length() < 4) {
return false;
}
// 检查头部两个字符是否为双引号
boolean startsWithTwoQuotes = str.charAt(0) == '"' && str.charAt(1) == '"';
// 检查尾部两个字符是否为双引号
int length = str.length();
boolean endsWithTwoQuotes = str.charAt(length - 2) == '"' && str.charAt(length - 1) == '"';
// 只有两者都满足才返回true
return startsWithTwoQuotes && endsWithTwoQuotes;
}
/**
* 处理字符串，使其前后只保留一个双引号
*
* @param str 输入字符串
* @return 处理后的字符串
*/
public static String keepSingleQuotesAtBothEnds(String str) {
// 处理null情况
if (str == null) {
return null;
}
// 去除所有前导双引号
String trimmedStart = str.replaceAll("^\"+", "");
// 去除所有尾随双引号
String trimmed = trimmedStart.replaceAll("\"+$", "");
// 如果原字符串没有引号，直接返回
if (trimmed.equals(str)) {
return str;
}
// 在处理后的字符串前后各添加一个双引号
return "\"" + trimmed + "\"";
}
/**
* 去除字符串头部和尾部所有的双引号
* @param str 输入字符串
* @return 处理后的字符串（首尾无引号）
*/
public static String trimAllQuotes(String str) {
// 处理null情况
if (str == null) {
return null;
}
// 使用正则表达式去除开头和结尾的所有双引号
// ^\"+ 匹配字符串开头的一个或多个双引号
// \"+$ 匹配字符串结尾的一个或多个双引号
return str.replaceAll("^\"+", "").replaceAll("\"+$", "");
}
/**
* 16进制转换为10进制
*
* @return
*/
public static int hexToDecimal(String hex) {
/* int decimalValue = 0;
for (int i = 0; i < hex.length(); i++) {
char hexChar = hex.charAt(i);
decimalValue = decimalValue * 16 + hexCharToDecimal(hexChar);
}
return decimalValue;*/
int parseInt = new BigInteger(hex, 16).intValue();
return parseInt;
}
/**
* 将8位字符串截取为4段（每段2字符）并返回点分格式
*
* @param input 8位字符串
* @return 点分格式结果（如"12.34.56.78"）
* @throws IllegalArgumentException 输入长度不为8时抛出
*/
public static String splitToDottedVersionFormat(String input) {
// 截取4段并拼接
StringBuilder result = new StringBuilder();
try {
// 验证输入长度
if (input == null || input.length() != 8) {
throw new IllegalArgumentException("输入必须是8位字符串");
}
for (int i = 0; i < 8; i += 2) {
int decimalPart = hexToDecimal(input.substring(i, i + 2));
if (i > 0) result.append('.'); // 添加分隔符
result.append(decimalPart);
}
} catch (Exception e) {
e.printStackTrace();
}
return result.toString();
}
}

+ 6
- 0
src/main/resources/application-prod.properties View File

@ -0,0 +1,6 @@
spring.rabbitmq.host=182.92.218.150
spring.rabbitmq.username=topsail
spring.rabbitmq.password=topsail
#spring.datasource.url=jdbc:mysql://localhost:3306/iot?useSSL=false&useUnicode=true&characterEncoding=utf-8
#spring.datasource.username=topsail
#spring.datasource.password=topsail2020

+ 11
- 0
src/main/resources/application-rds.properties View File

@ -0,0 +1,11 @@
#spring.rabbitmq.host=182.92.218.150
spring.rabbitmq.host=182.92.218.150
spring.rabbitmq.username=topsail
spring.rabbitmq.password=topsail
spring.datasource.url=jdbc:mysql://rm-2ze77qng1ddlfur9g4o.mysql.rds.aliyuncs.com/iot?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&serverTimezone=Asia/Shanghai
spring.datasource.username=topsail
spring.datasource.password=Topsail2020
#spring.datasource.url=jdbc:mysql://localhost:3306/iot?useSSL=false&useUnicode=true&characterEncoding=utf-8
#spring.datasource.username=topsail
#spring.datasource.password=topsail2020

+ 6
- 0
src/main/resources/application-test.properties View File

@ -0,0 +1,6 @@
spring.rabbitmq.host=47.97.117.253
#spring.rabbitmq.username=topsail
#spring.rabbitmq.password=top
#spring.datasource.url=jdbc:mysql://localhost:3306/iot?useSSL=false&useUnicode=true&characterEncoding=utf-8
#spring.datasource.username=topsail
#spring.datasource.password=topsail2020

+ 52
- 0
src/main/resources/application.properties View File

@ -0,0 +1,52 @@
spring.rabbitmq.host=182.92.218.150
#spring.rabbitmq.host=localhost
spring.rabbitmq.username=topsail
spring.rabbitmq.password=topsail
spring.rabbitmq.virtualHost=/
spring.rabbitmq.listener.simple.acknowledge-mode=manual
spring.rabbitmq.listener.simple.prefetch=100
spring.rabbitmq.listener.simple.concurrency=5
spring.rabbitmq.listener.simple.max-concurrency=10
# RabbitMQ Management API 配置（用于获取队列列表）
rabbitmq.management.url=http://182.92.218.150:15672
rabbitmq.management.username=topsail
rabbitmq.management.password=topsail
rabbitmq.management.vhost=/
spring.datasource.url=jdbc:mysql://47.98.32.177:3306/iot?useSSL=false&useUnicode=true&characterEncoding=utf-8
spring.datasource.username=yunmei
spring.datasource.password=yunmei1234
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
# 启用 MyBatis 日志输出
#mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
mybatis.type-aliases-package=com.topsail.scheduletask.pojo
mybatis.mapper-locations=classpath:com/topsail/scheduletask/mapper/*.xml
compute.schedule=0
offline.gap=120
spring.profiles.active=rds
#spring.influx.url=http://47.97.117.253:9999
#spring.influx.user=topsail
#spring.influx.password=topsail
#spring.influx.database=iot
### mial config ###
spring.mail.host=smtp.ym.163.com
spring.mail.username=topsail_mail@topsail-tech.com
spring.mail.password=topsail2020#
spring.mail.protocol=smtp
spring.mail.test-connection=false
spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.auth.starttls.enable=true
spring.mail.properties.mail.smtp.auth.starttls.required=true
# ssl 配置 (非ssl发送一般是25端口,linux服务器一般都是禁用的,所以要切换465，免费企业邮是994)
spring.mail.port=994
spring.mail.default-encoding=UTF-8
spring.mail.properties.mail.smtp.ssl.enable=true
spring.mail.properties.mail.smtp.socketFactory.port=994
spring.mail.properties.mail.smtp.socketFactory.class=javax.net.ssl.SSLSocketFactory
mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

+ 186
- 0
src/main/resources/com/topsail/scheduletask/mapper/InformLogMapper.xml View File

@ -0,0 +1,186 @@
<?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.topsail.scheduletask.mapper.InformLogDao">
<resultMap id="informLogMap" type="com.topsail.scheduletask.pojo.InformLogVo">
<id column="id" property="id"/>
<result column="inform_type" jdbcType="VARCHAR" property="informType" />
<result column="inform_address" jdbcType="VARCHAR" property="informAddress" />
<result column="inform_data" jdbcType="VARCHAR" property="informData" />
<result column="state" jdbcType="INTEGER" property="state" />
<result column="result_msg" jdbcType="VARCHAR" property="resultMsg" />
<result column="send_scenarios" jdbcType="VARCHAR" property="sendScenarios" />
<result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
</resultMap>
<!-- 基本列 -->
<sql id="informLogColumn">
il.id,
il.inform_type,
il.inform_address,
il.inform_data,
il.state,
il.result_msg,
il.send_scenarios,
il.create_time
</sql>
<!-- 单个插入 -->
<insert id="saveInformLog" parameterType="com.topsail.scheduletask.pojo.InformLog" useGeneratedKeys="true" keyProperty="informLog.id">
insert into inform_log
<trim prefix="(" suffix=")" suffixOverrides=",">
inform_type,
inform_address,
inform_data,
state,
result_msg,
send_scenarios,
create_time
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
#{informLog.informType,jdbcType=VARCHAR},
#{informLog.informAddress,jdbcType=VARCHAR},
#{informLog.informData,jdbcType=VARCHAR},
#{informLog.state,jdbcType=INTEGER},
#{informLog.resultMsg,jdbcType=VARCHAR},
#{informLog.sendScenarios,jdbcType=VARCHAR},
#{informLog.createTime,jdbcType=TIMESTAMP}
</trim>
</insert>
<!-- 批量新增 -->
<!-- 单个更新 -->
<update id="updateInformLog" parameterType="com.topsail.scheduletask.pojo.InformLog">
update inform_log
<set>
<if test="informType != null">
inform_type=#{informType,jdbcType=VARCHAR},
</if>
<if test="informAddress != null">
inform_address=#{informAddress,jdbcType=VARCHAR},
</if>
<if test="informData != null">
inform_data=#{informData,jdbcType=VARCHAR},
</if>
<if test="state != null">
state=#{state,jdbcType=INTEGER},
</if>
<if test="resultMsg != null">
result_msg=#{resultMsg,jdbcType=VARCHAR},
</if>
<if test="sendScenarios != null">
send_scenarios=#{sendScenarios,jdbcType=VARCHAR},
</if>
<if test="createTime != null">
create_time=#{createTime,jdbcType=TIMESTAMP},
</if>
</set>
where id = #{id}
</update>
<!-- 批量更新 -->
<!-- 删除 -->
<delete id="deleteInformLog" parameterType="java.lang.Integer">
delete from inform_log
where id = #{id}
</delete>
<!-- 批量删除 -->
<!-- 分页查询 -->
<select id="pageListInformLog" resultMap="informLogMap">
SELECT
<include refid="informLogColumn"/>
FROM inform_log as il
<where>
<if test="informLog.informType != null and informLog.informType != ''">
AND il.inform_type=#{informLog.informType,jdbcType=VARCHAR}
</if>
<if test="informLog.informAddress != null and informLog.informAddress != ''">
AND il.inform_address=#{informLog.informAddress,jdbcType=VARCHAR}
</if>
<if test="informLog.informData != null and informLog.informData != ''">
AND il.inform_data=#{informLog.informData,jdbcType=VARCHAR}
</if>
<if test="informLog.state != null and informLog.state != ''">
AND il.state=#{informLog.state,jdbcType=INTEGER}
</if>
<if test="informLog.resultMsg != null and informLog.resultMsg != ''">
AND il.result_msg=#{informLog.resultMsg,jdbcType=VARCHAR}
</if>
<if test="informLog.sendScenarios != null and informLog.sendScenarios != ''">
AND il.send_scenarios like concat('%',#{informLog.sendScenarios,jdbcType=VARCHAR},'%')
</if>
<if test="informLog.startTime != null and informLog.endTime != null">
AND il.create_time between #{informLog.startTime,jdbcType=TIMESTAMP} and #{informLog.endTime,jdbcType=TIMESTAMP}
</if>
</where>
<choose>
<when test="start != null and pageSize != null">
order by il.create_time desc
limit #{start},#{pageSize};
</when>
<otherwise>
order by il.create_time desc
</otherwise>
</choose>
</select>
<!-- 单个查询 -->
<select id="findInformLog" parameterType="java.lang.Integer" resultMap="informLogMap">
SELECT
<include refid="informLogColumn"/>
FROM inform_log as il
where il.id = #{id}
</select>
<!-- 查询count -->
<select id="findCountInformLog" resultType="java.lang.Integer">
SELECT
count(*)
FROM inform_log as il
<where>
<if test="informLog.informType != null and informLog.informType != ''">
AND il.inform_type=#{informLog.informType,jdbcType=VARCHAR}
</if>
<if test="informLog.informAddress != null and informLog.informAddress != ''">
AND il.inform_address=#{informLog.informAddress,jdbcType=VARCHAR}
</if>
<if test="informLog.informData != null and informLog.informData != ''">
AND il.inform_data=#{informLog.informData,jdbcType=VARCHAR}
</if>
<if test="informLog.state != null and informLog.state != ''">
AND il.state=#{informLog.state,jdbcType=INTEGER}
</if>
<if test="informLog.resultMsg != null and informLog.resultMsg != ''">
AND il.result_msg=#{informLog.resultMsg,jdbcType=VARCHAR}
</if>
<if test="informLog.sendScenarios != null and informLog.sendScenarios != ''">
AND il.send_scenarios like concat('%',#{informLog.sendScenarios,jdbcType=VARCHAR},'%')
</if>
<if test="informLog.startTime != null and informLog.endTime != null">
AND il.create_time between #{informLog.startTime,jdbcType=TIMESTAMP} and #{informLog.endTime,jdbcType=TIMESTAMP}
</if>
</where>
</select>
<select id="getNewInformLogCount" resultType="java.lang.Integer">
SELECT
count(*)
FROM inform_log as il
where il.send_scenarios like concat('%',#{subject,jdbcType=VARCHAR},'%')
and il.state=1
and DATE(il.create_time) = #{today,jdbcType=VARCHAR}
</select>
</mapper>

+ 60
- 0
src/main/resources/generatorConfig.xml View File

@ -0,0 +1,60 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE generatorConfiguration
PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
"http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
<generatorConfiguration>
<!--mysql 连接数据库jar 这里选择自己本地位置-->
<classPathEntry location="d:/mysql-connector-java-5.1.39-bin.jar"/>
<context id="testTables" targetRuntime="MyBatis3">
<property name="mybatisVersion" value="3.5.0"/>
<plugin type="com.itfsw.mybatis.generator.plugins.ModelColumnPlugin"/>
<plugin type="com.itfsw.mybatis.generator.plugins.BatchInsertPlugin">
<property name="allowMultiQueries" value="false"/>
<property name="mybatisVersion" value="3.5.0"/>
</plugin>
<commentGenerator>
<!-- 是否去除自动生成的注释 true：是 ： false:否 -->
<property name="suppressAllComments" value="true"/>
</commentGenerator>
<!--数据库连接的信息：驱动类、连接地址、用户名、密码 -->
<jdbcConnection driverClass="com.mysql.jdbc.Driver"
connectionURL="jdbc:mysql://47.98.32.177:3306/iot?useSSL=false" userId="yunmei"
password="yunmei1234">
</jdbcConnection>
<!-- 默认false，把JDBC DECIMAL 和 NUMERIC 类型解析为 Integer，为 true时把JDBC DECIMAL 和
NUMERIC 类型解析为java.math.BigDecimal -->
<javaTypeResolver>
<property name="forceBigDecimals" value="false"/>
</javaTypeResolver>
<!-- targetProject:生成PO类的位置 -->
<javaModelGenerator targetPackage="com.topsail.scheduletask.pojo"
targetProject="src/main/java">
<!-- enableSubPackages:是否让schema作为包的后缀 -->
<property name="enableSubPackages" value="false"/>
<!-- 从数据库返回的值被清理前后的空格 -->
<property name="trimStrings" value="true"/>
</javaModelGenerator>
<!-- targetProject:mapper映射文件生成的位置
如果maven工程只是单独的一个工程，targetProject="src/main/java"
若果maven工程是分模块的工程，targetProject="所属模块的名称"，例如：
targetProject="ecps-manager-mapper"，下同-->
<sqlMapGenerator targetPackage="com.topsail.scheduletask.mapper"
targetProject="src/main/java">
<!-- enableSubPackages:是否让schema作为包的后缀 -->
<property name="enableSubPackages" value="false"/>
</sqlMapGenerator>
<!-- targetPackage：mapper接口生成的位置 -->
<javaClientGenerator type="XMLMAPPER"
targetPackage="com.topsail.scheduletask.mapper"
targetProject="src/main/java">
<!-- enableSubPackages:是否让schema作为包的后缀 -->
<property name="enableSubPackages" value="false"/>
</javaClientGenerator>
<!-- 指定数据库表 -->
<table tableName="project_transmit"></table>
</context>
</generatorConfiguration>

Write Preview
Loading…
Cancel
Save