commit
e318999998
28 changed files with 1217 additions and 0 deletions
-
3.gitattributes
-
37.gitignore
-
43build.gradle
-
BINgradle/wrapper/gradle-wrapper.jar
-
7gradle/wrapper/gradle-wrapper.properties
-
251gradlew
-
94gradlew.bat
-
1settings.gradle
-
13src/main/java/com/iflytop/gd/GraphiteDigesterServiceApplication.java
-
44src/main/java/com/iflytop/gd/app/common/base/BaseEntity.java
-
26src/main/java/com/iflytop/gd/app/common/base/BasePageQuery.java
-
84src/main/java/com/iflytop/gd/app/common/base/IBaseEnum.java
-
24src/main/java/com/iflytop/gd/app/common/enums/DeletedEnum.java
-
24src/main/java/com/iflytop/gd/app/common/enums/StatusEnum.java
-
12src/main/java/com/iflytop/gd/app/common/result/IResultCode.java
-
43src/main/java/com/iflytop/gd/app/common/result/PageResult.java
-
71src/main/java/com/iflytop/gd/app/common/result/Result.java
-
75src/main/java/com/iflytop/gd/app/common/result/ResultCode.java
-
61src/main/java/com/iflytop/gd/app/config/MybatisPlusConfig.java
-
69src/main/java/com/iflytop/gd/app/config/SwaggerConfig.java
-
16src/main/java/com/iflytop/gd/app/config/WebConfig.java
-
14src/main/java/com/iflytop/gd/app/config/WebSocketConfig.java
-
49src/main/java/com/iflytop/gd/app/config/WebSocketServer.java
-
36src/main/java/com/iflytop/gd/app/core/handler/MyMetaObjectHandler.java
-
34src/main/resources/application.yml
-
58src/main/resources/logback.xml
-
15src/main/resources/sql/init.sql
-
13src/test/java/com/iflytop/gd/GraphiteDigesterServiceApplicationTests.java
@ -0,0 +1,3 @@ |
|||
/gradlew text eol=lf |
|||
*.bat text eol=crlf |
|||
*.jar binary |
@ -0,0 +1,37 @@ |
|||
HELP.md |
|||
.gradle |
|||
build/ |
|||
!gradle/wrapper/gradle-wrapper.jar |
|||
!**/src/main/**/build/ |
|||
!**/src/test/**/build/ |
|||
|
|||
### STS ### |
|||
.apt_generated |
|||
.classpath |
|||
.factorypath |
|||
.project |
|||
.settings |
|||
.springBeans |
|||
.sts4-cache |
|||
bin/ |
|||
!**/src/main/**/bin/ |
|||
!**/src/test/**/bin/ |
|||
|
|||
### IntelliJ IDEA ### |
|||
.idea |
|||
*.iws |
|||
*.iml |
|||
*.ipr |
|||
out/ |
|||
!**/src/main/**/out/ |
|||
!**/src/test/**/out/ |
|||
|
|||
### NetBeans ### |
|||
/nbproject/private/ |
|||
/nbbuild/ |
|||
/dist/ |
|||
/nbdist/ |
|||
/.nb-gradle/ |
|||
|
|||
### VS Code ### |
|||
.vscode/ |
@ -0,0 +1,43 @@ |
|||
plugins { |
|||
id 'java' |
|||
id 'org.springframework.boot' version '3.4.5' |
|||
id 'io.spring.dependency-management' version '1.1.7' |
|||
} |
|||
|
|||
group = 'com.iflytop' |
|||
version = '0.0.1-SNAPSHOT' |
|||
|
|||
java { |
|||
toolchain { |
|||
languageVersion = JavaLanguageVersion.of(17) |
|||
} |
|||
} |
|||
|
|||
repositories { |
|||
mavenCentral() |
|||
} |
|||
|
|||
dependencies { |
|||
implementation 'org.springframework.boot:spring-boot-starter' |
|||
implementation 'org.springframework.boot:spring-boot-starter-web' |
|||
implementation group: 'ch.qos.logback', name: 'logback-core', version: '1.5.16' |
|||
implementation group: 'org.xerial', name: 'sqlite-jdbc', version: '3.48.0.0' |
|||
implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:3.0.4' |
|||
implementation group: 'org.freemarker', name: 'freemarker', version: '2.3.34' |
|||
implementation group: 'com.baomidou', name: 'mybatis-plus-boot-starter', version: '3.5.10.1' |
|||
implementation group: 'com.baomidou', name: 'mybatis-plus-jsqlparser', version: '3.5.10.1' |
|||
implementation group: 'com.baomidou', name: 'mybatis-plus-generator', version: '3.5.10.1' |
|||
implementation group: 'cn.hutool', name: 'hutool-all', version: '5.8.35' |
|||
implementation group: 'com.github.xiaoymin', name: 'knife4j-openapi3-jakarta-spring-boot-starter', version: '4.5.0' |
|||
implementation group: 'org.springframework.boot', name: 'spring-boot-starter-websocket', version: '3.4.2' |
|||
implementation 'jakarta.annotation:jakarta.annotation-api:2.1.1' |
|||
|
|||
compileOnly 'org.projectlombok:lombok' |
|||
annotationProcessor 'org.projectlombok:lombok' |
|||
testImplementation 'org.springframework.boot:spring-boot-starter-test' |
|||
testRuntimeOnly 'org.junit.platform:junit-platform-launcher' |
|||
} |
|||
|
|||
tasks.named('test') { |
|||
useJUnitPlatform() |
|||
} |
@ -0,0 +1,7 @@ |
|||
distributionBase=GRADLE_USER_HOME |
|||
distributionPath=wrapper/dists |
|||
distributionUrl=https\://services.gradle.org/distributions/gradle-8.13-bin.zip |
|||
networkTimeout=10000 |
|||
validateDistributionUrl=true |
|||
zipStoreBase=GRADLE_USER_HOME |
|||
zipStorePath=wrapper/dists |
@ -0,0 +1,251 @@ |
|||
#!/bin/sh |
|||
|
|||
# |
|||
# Copyright © 2015-2021 the original authors. |
|||
# |
|||
# Licensed under the Apache License, Version 2.0 (the "License"); |
|||
# you may not use this file except in compliance with the License. |
|||
# You may obtain a copy of the License at |
|||
# |
|||
# https://www.apache.org/licenses/LICENSE-2.0 |
|||
# |
|||
# Unless required by applicable law or agreed to in writing, software |
|||
# distributed under the License is distributed on an "AS IS" BASIS, |
|||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|||
# See the License for the specific language governing permissions and |
|||
# limitations under the License. |
|||
# |
|||
# SPDX-License-Identifier: Apache-2.0 |
|||
# |
|||
|
|||
############################################################################## |
|||
# |
|||
# Gradle start up script for POSIX generated by Gradle. |
|||
# |
|||
# Important for running: |
|||
# |
|||
# (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is |
|||
# noncompliant, but you have some other compliant shell such as ksh or |
|||
# bash, then to run this script, type that shell name before the whole |
|||
# command line, like: |
|||
# |
|||
# ksh Gradle |
|||
# |
|||
# Busybox and similar reduced shells will NOT work, because this script |
|||
# requires all of these POSIX shell features: |
|||
# * functions; |
|||
# * expansions «$var», «${var}», «${var:-default}», «${var+SET}», |
|||
# «${var#prefix}», «${var%suffix}», and «$( cmd )»; |
|||
# * compound commands having a testable exit status, especially «case»; |
|||
# * various built-in commands including «command», «set», and «ulimit». |
|||
# |
|||
# Important for patching: |
|||
# |
|||
# (2) This script targets any POSIX shell, so it avoids extensions provided |
|||
# by Bash, Ksh, etc; in particular arrays are avoided. |
|||
# |
|||
# The "traditional" practice of packing multiple parameters into a |
|||
# space-separated string is a well documented source of bugs and security |
|||
# problems, so this is (mostly) avoided, by progressively accumulating |
|||
# options in "$@", and eventually passing that to Java. |
|||
# |
|||
# Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS, |
|||
# and GRADLE_OPTS) rely on word-splitting, this is performed explicitly; |
|||
# see the in-line comments for details. |
|||
# |
|||
# There are tweaks for specific operating systems such as AIX, CygWin, |
|||
# Darwin, MinGW, and NonStop. |
|||
# |
|||
# (3) This script is generated from the Groovy template |
|||
# https://github.com/gradle/gradle/blob/HEAD/platforms/jvm/plugins-application/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt |
|||
# within the Gradle project. |
|||
# |
|||
# You can find Gradle at https://github.com/gradle/gradle/. |
|||
# |
|||
############################################################################## |
|||
|
|||
# Attempt to set APP_HOME |
|||
|
|||
# Resolve links: $0 may be a link |
|||
app_path=$0 |
|||
|
|||
# Need this for daisy-chained symlinks. |
|||
while |
|||
APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path |
|||
[ -h "$app_path" ] |
|||
do |
|||
ls=$( ls -ld "$app_path" ) |
|||
link=${ls#*' -> '} |
|||
case $link in #( |
|||
/*) app_path=$link ;; #( |
|||
*) app_path=$APP_HOME$link ;; |
|||
esac |
|||
done |
|||
|
|||
# This is normally unused |
|||
# shellcheck disable=SC2034 |
|||
APP_BASE_NAME=${0##*/} |
|||
# Discard cd standard output in case $CDPATH is set (https://github.com/gradle/gradle/issues/25036) |
|||
APP_HOME=$( cd -P "${APP_HOME:-./}" > /dev/null && printf '%s\n' "$PWD" ) || exit |
|||
|
|||
# Use the maximum available, or set MAX_FD != -1 to use that value. |
|||
MAX_FD=maximum |
|||
|
|||
warn () { |
|||
echo "$*" |
|||
} >&2 |
|||
|
|||
die () { |
|||
echo |
|||
echo "$*" |
|||
echo |
|||
exit 1 |
|||
} >&2 |
|||
|
|||
# OS specific support (must be 'true' or 'false'). |
|||
cygwin=false |
|||
msys=false |
|||
darwin=false |
|||
nonstop=false |
|||
case "$( uname )" in #( |
|||
CYGWIN* ) cygwin=true ;; #( |
|||
Darwin* ) darwin=true ;; #( |
|||
MSYS* | MINGW* ) msys=true ;; #( |
|||
NONSTOP* ) nonstop=true ;; |
|||
esac |
|||
|
|||
CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar |
|||
|
|||
|
|||
# Determine the Java command to use to start the JVM. |
|||
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 |
|||
if [ ! -x "$JAVACMD" ] ; then |
|||
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME |
|||
|
|||
Please set the JAVA_HOME variable in your environment to match the |
|||
location of your Java installation." |
|||
fi |
|||
else |
|||
JAVACMD=java |
|||
if ! command -v java >/dev/null 2>&1 |
|||
then |
|||
die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. |
|||
|
|||
Please set the JAVA_HOME variable in your environment to match the |
|||
location of your Java installation." |
|||
fi |
|||
fi |
|||
|
|||
# Increase the maximum file descriptors if we can. |
|||
if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then |
|||
case $MAX_FD in #( |
|||
max*) |
|||
# In POSIX sh, ulimit -H is undefined. That's why the result is checked to see if it worked. |
|||
# shellcheck disable=SC2039,SC3045 |
|||
MAX_FD=$( ulimit -H -n ) || |
|||
warn "Could not query maximum file descriptor limit" |
|||
esac |
|||
case $MAX_FD in #( |
|||
'' | soft) :;; #( |
|||
*) |
|||
# In POSIX sh, ulimit -n is undefined. That's why the result is checked to see if it worked. |
|||
# shellcheck disable=SC2039,SC3045 |
|||
ulimit -n "$MAX_FD" || |
|||
warn "Could not set maximum file descriptor limit to $MAX_FD" |
|||
esac |
|||
fi |
|||
|
|||
# Collect all arguments for the java command, stacking in reverse order: |
|||
# * args from the command line |
|||
# * the main class name |
|||
# * -classpath |
|||
# * -D...appname settings |
|||
# * --module-path (only if needed) |
|||
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables. |
|||
|
|||
# For Cygwin or MSYS, switch paths to Windows format before running java |
|||
if "$cygwin" || "$msys" ; then |
|||
APP_HOME=$( cygpath --path --mixed "$APP_HOME" ) |
|||
CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" ) |
|||
|
|||
JAVACMD=$( cygpath --unix "$JAVACMD" ) |
|||
|
|||
# Now convert the arguments - kludge to limit ourselves to /bin/sh |
|||
for arg do |
|||
if |
|||
case $arg in #( |
|||
-*) false ;; # don't mess with options #( |
|||
/?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath |
|||
[ -e "$t" ] ;; #( |
|||
*) false ;; |
|||
esac |
|||
then |
|||
arg=$( cygpath --path --ignore --mixed "$arg" ) |
|||
fi |
|||
# Roll the args list around exactly as many times as the number of |
|||
# args, so each arg winds up back in the position where it started, but |
|||
# possibly modified. |
|||
# |
|||
# NB: a `for` loop captures its iteration list before it begins, so |
|||
# changing the positional parameters here affects neither the number of |
|||
# iterations, nor the values presented in `arg`. |
|||
shift # remove old arg |
|||
set -- "$@" "$arg" # push replacement arg |
|||
done |
|||
fi |
|||
|
|||
|
|||
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. |
|||
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"' |
|||
|
|||
# Collect all arguments for the java command: |
|||
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and optsEnvironmentVar are not allowed to contain shell fragments, |
|||
# and any embedded shellness will be escaped. |
|||
# * For example: A user cannot expect ${Hostname} to be expanded, as it is an environment variable and will be |
|||
# treated as '${Hostname}' itself on the command line. |
|||
|
|||
set -- \ |
|||
"-Dorg.gradle.appname=$APP_BASE_NAME" \ |
|||
-classpath "$CLASSPATH" \ |
|||
org.gradle.wrapper.GradleWrapperMain \ |
|||
"$@" |
|||
|
|||
# Stop when "xargs" is not available. |
|||
if ! command -v xargs >/dev/null 2>&1 |
|||
then |
|||
die "xargs is not available" |
|||
fi |
|||
|
|||
# Use "xargs" to parse quoted args. |
|||
# |
|||
# With -n1 it outputs one arg per line, with the quotes and backslashes removed. |
|||
# |
|||
# In Bash we could simply go: |
|||
# |
|||
# readarray ARGS < <( xargs -n1 <<<"$var" ) && |
|||
# set -- "${ARGS[@]}" "$@" |
|||
# |
|||
# but POSIX shell has neither arrays nor command substitution, so instead we |
|||
# post-process each arg (as a line of input to sed) to backslash-escape any |
|||
# character that might be a shell metacharacter, then use eval to reverse |
|||
# that process (while maintaining the separation between arguments), and wrap |
|||
# the whole thing up as a single "set" statement. |
|||
# |
|||
# This will of course break if any of these variables contains a newline or |
|||
# an unmatched quote. |
|||
# |
|||
|
|||
eval "set -- $( |
|||
printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" | |
|||
xargs -n1 | |
|||
sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' | |
|||
tr '\n' ' ' |
|||
)" '"$@"' |
|||
|
|||
exec "$JAVACMD" "$@" |
@ -0,0 +1,94 @@ |
|||
@rem |
|||
@rem Copyright 2015 the original author or authors. |
|||
@rem |
|||
@rem Licensed under the Apache License, Version 2.0 (the "License"); |
|||
@rem you may not use this file except in compliance with the License. |
|||
@rem 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, software |
|||
@rem distributed under the License is distributed on an "AS IS" BASIS, |
|||
@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|||
@rem See the License for the specific language governing permissions and |
|||
@rem limitations under the License. |
|||
@rem |
|||
@rem SPDX-License-Identifier: Apache-2.0 |
|||
@rem |
|||
|
|||
@if "%DEBUG%"=="" @echo off |
|||
@rem ########################################################################## |
|||
@rem |
|||
@rem Gradle startup script for Windows |
|||
@rem |
|||
@rem ########################################################################## |
|||
|
|||
@rem Set local scope for the variables with windows NT shell |
|||
if "%OS%"=="Windows_NT" setlocal |
|||
|
|||
set DIRNAME=%~dp0 |
|||
if "%DIRNAME%"=="" set DIRNAME=. |
|||
@rem This is normally unused |
|||
set APP_BASE_NAME=%~n0 |
|||
set APP_HOME=%DIRNAME% |
|||
|
|||
@rem Resolve any "." and ".." in APP_HOME to make it shorter. |
|||
for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi |
|||
|
|||
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. |
|||
set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m" |
|||
|
|||
@rem Find java.exe |
|||
if defined JAVA_HOME goto findJavaFromJavaHome |
|||
|
|||
set JAVA_EXE=java.exe |
|||
%JAVA_EXE% -version >NUL 2>&1 |
|||
if %ERRORLEVEL% equ 0 goto execute |
|||
|
|||
echo. 1>&2 |
|||
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. 1>&2 |
|||
echo. 1>&2 |
|||
echo Please set the JAVA_HOME variable in your environment to match the 1>&2 |
|||
echo location of your Java installation. 1>&2 |
|||
|
|||
goto fail |
|||
|
|||
:findJavaFromJavaHome |
|||
set JAVA_HOME=%JAVA_HOME:"=% |
|||
set JAVA_EXE=%JAVA_HOME%/bin/java.exe |
|||
|
|||
if exist "%JAVA_EXE%" goto execute |
|||
|
|||
echo. 1>&2 |
|||
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% 1>&2 |
|||
echo. 1>&2 |
|||
echo Please set the JAVA_HOME variable in your environment to match the 1>&2 |
|||
echo location of your Java installation. 1>&2 |
|||
|
|||
goto fail |
|||
|
|||
:execute |
|||
@rem Setup the command line |
|||
|
|||
set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar |
|||
|
|||
|
|||
@rem Execute Gradle |
|||
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %* |
|||
|
|||
:end |
|||
@rem End local scope for the variables with windows NT shell |
|||
if %ERRORLEVEL% equ 0 goto mainEnd |
|||
|
|||
:fail |
|||
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of |
|||
rem the _cmd.exe /c_ return code! |
|||
set EXIT_CODE=%ERRORLEVEL% |
|||
if %EXIT_CODE% equ 0 set EXIT_CODE=1 |
|||
if not ""=="%GRADLE_EXIT_CONSOLE%" exit %EXIT_CODE% |
|||
exit /b %EXIT_CODE% |
|||
|
|||
:mainEnd |
|||
if "%OS%"=="Windows_NT" endlocal |
|||
|
|||
:omega |
@ -0,0 +1 @@ |
|||
rootProject.name = 'graphite-digester-service' |
@ -0,0 +1,13 @@ |
|||
package com.iflytop.gd; |
|||
|
|||
import org.springframework.boot.SpringApplication; |
|||
import org.springframework.boot.autoconfigure.SpringBootApplication; |
|||
|
|||
@SpringBootApplication |
|||
public class GraphiteDigesterServiceApplication { |
|||
|
|||
public static void main(String[] args) { |
|||
SpringApplication.run(GraphiteDigesterServiceApplication.class, args); |
|||
} |
|||
|
|||
} |
@ -0,0 +1,44 @@ |
|||
package com.iflytop.gd.app.common.base; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.FieldFill; |
|||
import com.baomidou.mybatisplus.annotation.IdType; |
|||
import com.baomidou.mybatisplus.annotation.TableField; |
|||
import com.baomidou.mybatisplus.annotation.TableId; |
|||
import com.fasterxml.jackson.annotation.JsonFormat; |
|||
import lombok.Data; |
|||
|
|||
import java.io.Serial; |
|||
import java.io.Serializable; |
|||
import java.time.LocalDateTime; |
|||
|
|||
/** |
|||
* 基础实体类 |
|||
* 实体类的基类,包含了实体类的公共属性,如创建时间、更新时间、逻辑删除标识等</p> |
|||
*/ |
|||
@Data |
|||
public class BaseEntity implements Serializable { |
|||
|
|||
@Serial |
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
/** |
|||
* 主键ID |
|||
*/ |
|||
@TableId(type = IdType.AUTO) |
|||
private Long id; |
|||
|
|||
/** |
|||
* 创建时间 |
|||
*/ |
|||
@TableField(fill = FieldFill.INSERT) |
|||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") |
|||
private LocalDateTime createTime; |
|||
|
|||
/** |
|||
* 更新时间 |
|||
*/ |
|||
@TableField(fill = FieldFill.INSERT_UPDATE) |
|||
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") |
|||
private LocalDateTime updateTime; |
|||
|
|||
} |
@ -0,0 +1,26 @@ |
|||
package com.iflytop.gd.app.common.base; |
|||
|
|||
import io.swagger.v3.oas.annotations.media.Schema; |
|||
import lombok.Data; |
|||
|
|||
import java.io.Serial; |
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* 基础分页请求对象 |
|||
*/ |
|||
@Data |
|||
@Schema |
|||
public class BasePageQuery implements Serializable { |
|||
|
|||
@Serial |
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
@Schema(description = "页码", requiredMode = Schema.RequiredMode.REQUIRED, example = "1") |
|||
private int pageNum = 1; |
|||
|
|||
@Schema(description = "每页记录数", requiredMode = Schema.RequiredMode.REQUIRED, example = "10") |
|||
private int pageSize = 10; |
|||
|
|||
|
|||
} |
@ -0,0 +1,84 @@ |
|||
package com.iflytop.gd.app.common.base; |
|||
|
|||
|
|||
import cn.hutool.core.util.ObjectUtil; |
|||
|
|||
import java.util.EnumSet; |
|||
import java.util.Objects; |
|||
|
|||
/** |
|||
* 枚举通用接口 |
|||
*/ |
|||
public interface IBaseEnum<T> { |
|||
|
|||
/** |
|||
* 根据值获取枚举 |
|||
* |
|||
* @param value |
|||
* @param clazz |
|||
* @param <E> 枚举 |
|||
* @return |
|||
*/ |
|||
static <E extends Enum<E> & IBaseEnum> E getEnumByValue(Object value, Class<E> clazz) { |
|||
Objects.requireNonNull(value); |
|||
EnumSet<E> allEnums = EnumSet.allOf(clazz); // 获取类型下的所有枚举 |
|||
E matchEnum = allEnums.stream() |
|||
.filter(e -> ObjectUtil.equal(e.getValue(), value)) |
|||
.findFirst() |
|||
.orElse(null); |
|||
return matchEnum; |
|||
} |
|||
|
|||
/** |
|||
* 根据文本标签获取值 |
|||
* |
|||
* @param value |
|||
* @param clazz |
|||
* @param <E> |
|||
* @return |
|||
*/ |
|||
static <E extends Enum<E> & IBaseEnum> String getLabelByValue(Object value, Class<E> clazz) { |
|||
Objects.requireNonNull(value); |
|||
EnumSet<E> allEnums = EnumSet.allOf(clazz); // 获取类型下的所有枚举 |
|||
E matchEnum = allEnums.stream() |
|||
.filter(e -> ObjectUtil.equal(e.getValue(), value)) |
|||
.findFirst() |
|||
.orElse(null); |
|||
|
|||
String label = null; |
|||
if (matchEnum != null) { |
|||
label = matchEnum.getLabel(); |
|||
} |
|||
return label; |
|||
} |
|||
|
|||
/** |
|||
* 根据文本标签获取值 |
|||
* |
|||
* @param label |
|||
* @param clazz |
|||
* @param <E> |
|||
* @return |
|||
*/ |
|||
static <E extends Enum<E> & IBaseEnum> Object getValueByLabel(String label, Class<E> clazz) { |
|||
Objects.requireNonNull(label); |
|||
EnumSet<E> allEnums = EnumSet.allOf(clazz); // 获取类型下的所有枚举 |
|||
String finalLabel = label; |
|||
E matchEnum = allEnums.stream() |
|||
.filter(e -> ObjectUtil.equal(e.getLabel(), finalLabel)) |
|||
.findFirst() |
|||
.orElse(null); |
|||
|
|||
Object value = null; |
|||
if (matchEnum != null) { |
|||
value = matchEnum.getValue(); |
|||
} |
|||
return value; |
|||
} |
|||
|
|||
T getValue(); |
|||
|
|||
String getLabel(); |
|||
|
|||
|
|||
} |
@ -0,0 +1,24 @@ |
|||
package com.iflytop.gd.app.common.enums; |
|||
|
|||
import com.iflytop.gd.app.common.base.IBaseEnum; |
|||
import lombok.Getter; |
|||
|
|||
/** |
|||
* 删除状态枚举 |
|||
*/ |
|||
@Getter |
|||
public enum DeletedEnum implements IBaseEnum<Integer> { |
|||
|
|||
ENABLE(1, "删除"), |
|||
DISABLE(0, "未删除"); |
|||
|
|||
private final Integer value; |
|||
|
|||
|
|||
private final String label; |
|||
|
|||
DeletedEnum(Integer value, String label) { |
|||
this.value = value; |
|||
this.label = label; |
|||
} |
|||
} |
@ -0,0 +1,24 @@ |
|||
package com.iflytop.gd.app.common.enums; |
|||
|
|||
import com.iflytop.gd.app.common.base.IBaseEnum; |
|||
import lombok.Getter; |
|||
|
|||
/** |
|||
* 状态枚举 |
|||
*/ |
|||
@Getter |
|||
public enum StatusEnum implements IBaseEnum<Integer> { |
|||
|
|||
ENABLE(1, "启用"), |
|||
DISABLE(0, "禁用"); |
|||
|
|||
private final Integer value; |
|||
|
|||
|
|||
private final String label; |
|||
|
|||
StatusEnum(Integer value, String label) { |
|||
this.value = value; |
|||
this.label = label; |
|||
} |
|||
} |
@ -0,0 +1,12 @@ |
|||
package com.iflytop.gd.app.common.result; |
|||
|
|||
/** |
|||
* 响应码接口 |
|||
**/ |
|||
public interface IResultCode { |
|||
|
|||
String getCode(); |
|||
|
|||
String getMsg(); |
|||
|
|||
} |
@ -0,0 +1,43 @@ |
|||
package com.iflytop.gd.app.common.result; |
|||
|
|||
import com.baomidou.mybatisplus.core.metadata.IPage; |
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* 分页响应结构体 |
|||
*/ |
|||
@Data |
|||
public class PageResult<T> implements Serializable { |
|||
|
|||
private String code; |
|||
|
|||
private Data<T> data; |
|||
|
|||
private String msg; |
|||
|
|||
public static <T> PageResult<T> success(IPage<T> page) { |
|||
PageResult<T> result = new PageResult<>(); |
|||
result.setCode(ResultCode.SUCCESS.getCode()); |
|||
|
|||
Data<T> data = new Data<>(); |
|||
data.setList(page.getRecords()); |
|||
data.setTotal(page.getTotal()); |
|||
|
|||
result.setData(data); |
|||
result.setMsg(ResultCode.SUCCESS.getMsg()); |
|||
return result; |
|||
} |
|||
|
|||
@lombok.Data |
|||
public static class Data<T> { |
|||
|
|||
private List<T> list; |
|||
|
|||
private long total; |
|||
|
|||
} |
|||
|
|||
} |
@ -0,0 +1,71 @@ |
|||
package com.iflytop.gd.app.common.result; |
|||
|
|||
import cn.hutool.core.util.StrUtil; |
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* 统一响应结构体 |
|||
**/ |
|||
@Data |
|||
public class Result<T> implements Serializable { |
|||
|
|||
private String code; |
|||
|
|||
private T data; |
|||
|
|||
private String msg; |
|||
|
|||
public static <T> Result<T> success() { |
|||
return success(null); |
|||
} |
|||
|
|||
public static <T> Result<T> success(T data) { |
|||
Result<T> result = new Result<>(); |
|||
result.setCode(ResultCode.SUCCESS.getCode()); |
|||
result.setMsg(ResultCode.SUCCESS.getMsg()); |
|||
result.setData(data); |
|||
return result; |
|||
} |
|||
|
|||
public static <T> Result<T> failed() { |
|||
return result(ResultCode.SYSTEM_ERROR.getCode(), ResultCode.SYSTEM_ERROR.getMsg(), null); |
|||
} |
|||
|
|||
public static <T> Result<T> failed(String msg) { |
|||
return result(ResultCode.SYSTEM_ERROR.getCode(), msg, null); |
|||
} |
|||
|
|||
public static <T> Result<T> judge(boolean status) { |
|||
if (status) { |
|||
return success(); |
|||
} else { |
|||
return failed(); |
|||
} |
|||
} |
|||
|
|||
public static <T> Result<T> failed(IResultCode resultCode) { |
|||
return result(resultCode.getCode(), resultCode.getMsg(), null); |
|||
} |
|||
|
|||
public static <T> Result<T> failed(IResultCode resultCode, String msg) { |
|||
return result(resultCode.getCode(), StrUtil.isNotBlank(msg) ? msg : resultCode.getMsg(), null); |
|||
} |
|||
|
|||
private static <T> Result<T> result(IResultCode resultCode, T data) { |
|||
return result(resultCode.getCode(), resultCode.getMsg(), data); |
|||
} |
|||
|
|||
private static <T> Result<T> result(String code, String msg, T data) { |
|||
Result<T> result = new Result<>(); |
|||
result.setCode(code); |
|||
result.setData(data); |
|||
result.setMsg(msg); |
|||
return result; |
|||
} |
|||
|
|||
public static boolean isSuccess(Result<?> result) { |
|||
return result != null && ResultCode.SUCCESS.getCode().equals(result.getCode()); |
|||
} |
|||
} |
@ -0,0 +1,75 @@ |
|||
package com.iflytop.gd.app.common.result; |
|||
|
|||
import lombok.AllArgsConstructor; |
|||
import lombok.Getter; |
|||
|
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* 统一前端响应码定义 |
|||
*/ |
|||
@Getter |
|||
@AllArgsConstructor |
|||
public enum ResultCode implements IResultCode, Serializable { |
|||
// 成功 |
|||
SUCCESS("00000", "成功"), |
|||
|
|||
// 通用失败 |
|||
FAILED("99999", "失败"), |
|||
|
|||
// 参数校验类(4xxxx) |
|||
VALIDATION_ERROR("40000", "参数校验失败"), |
|||
|
|||
// 鉴权/认证类(4xxxx) |
|||
UNAUTHORIZED("40100", "未认证或Token失效"), |
|||
FORBIDDEN("40300", "无访问权限"), |
|||
|
|||
// 资源访问类(4xxxx) |
|||
NOT_FOUND("40400", "资源不存在"), |
|||
METHOD_NOT_ALLOWED("40500", "不支持的请求方法"), |
|||
|
|||
// 系统错误(5xxxx) |
|||
SYSTEM_ERROR("50000", "系统内部错误"), |
|||
|
|||
// ----------------- 业务错误(1xxxx)示例 ----------------- |
|||
USER_NOT_FOUND("10001", "用户不存在"), |
|||
USERNAME_ALREADY_EXISTS("10002", "用户名已存在"), |
|||
PASSWORD_INCORRECT("10003", "用户名或密码错误"); |
|||
|
|||
/** |
|||
* 状态码 |
|||
*/ |
|||
private final String code; |
|||
/** |
|||
* 提示信息 |
|||
*/ |
|||
private final String msg; |
|||
|
|||
@Override |
|||
public String getCode() { |
|||
return code; |
|||
} |
|||
|
|||
@Override |
|||
public String getMsg() { |
|||
return msg; |
|||
} |
|||
|
|||
/** |
|||
* 根据 code 获取枚举 |
|||
*/ |
|||
public static ResultCode parse(String code) { |
|||
for (ResultCode item : values()) { |
|||
if (item.code.equals(code)) { |
|||
return item; |
|||
} |
|||
} |
|||
// 找不到则返回通用失败或系统错误 |
|||
return SYSTEM_ERROR; |
|||
} |
|||
|
|||
@Override |
|||
public String toString() { |
|||
return "{\"code\":\"" + code + "\", \"msg\":\"" + msg + "\"}"; |
|||
} |
|||
} |
@ -0,0 +1,61 @@ |
|||
package com.iflytop.gd.app.config; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.DbType; |
|||
import com.baomidou.mybatisplus.core.config.GlobalConfig; |
|||
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; |
|||
import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor; |
|||
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; |
|||
import com.iflytop.gd.app.core.handler.MyMetaObjectHandler; |
|||
import org.springframework.context.annotation.Bean; |
|||
import org.springframework.context.annotation.Configuration; |
|||
import org.springframework.transaction.annotation.EnableTransactionManagement; |
|||
|
|||
/** |
|||
* |
|||
*/ |
|||
@EnableTransactionManagement |
|||
@Configuration |
|||
public class MybatisPlusConfig { |
|||
|
|||
@Bean |
|||
public MybatisPlusInterceptor mybatisPlusInterceptor() { |
|||
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor(); |
|||
// 乐观锁插件 |
|||
interceptor.addInnerInterceptor(optimisticLockerInnerInterceptor()); |
|||
// 分页插件 |
|||
interceptor.addInnerInterceptor(paginationInnerInterceptor()); |
|||
|
|||
return interceptor; |
|||
} |
|||
|
|||
/** |
|||
* 分页插件,自动识别数据库类型 |
|||
* https://baomidou.com/guide/interceptor-pagination.html |
|||
*/ |
|||
public PaginationInnerInterceptor paginationInnerInterceptor() { |
|||
PaginationInnerInterceptor paginationInnerInterceptor = new PaginationInnerInterceptor(); |
|||
// 设置数据库类型 |
|||
paginationInnerInterceptor.setDbType(DbType.SQLITE); |
|||
// 设置最大单页限制数量,默认 500 条,-1 不受限制 |
|||
paginationInnerInterceptor.setMaxLimit(-1L); |
|||
return paginationInnerInterceptor; |
|||
} |
|||
|
|||
/** |
|||
* 乐观锁插件 |
|||
* https://baomidou.com/guide/interceptor-optimistic-locker.html |
|||
*/ |
|||
public OptimisticLockerInnerInterceptor optimisticLockerInnerInterceptor() { |
|||
return new OptimisticLockerInnerInterceptor(); |
|||
} |
|||
|
|||
/** |
|||
* 自动填充数据库创建人、创建时间、更新人、更新时间 |
|||
*/ |
|||
@Bean |
|||
public GlobalConfig globalConfig() { |
|||
GlobalConfig globalConfig = new GlobalConfig(); |
|||
globalConfig.setMetaObjectHandler(new MyMetaObjectHandler()); |
|||
return globalConfig; |
|||
} |
|||
} |
@ -0,0 +1,69 @@ |
|||
package com.iflytop.gd.app.config; |
|||
|
|||
import cn.hutool.core.util.ArrayUtil; |
|||
import io.swagger.v3.oas.models.Components; |
|||
import io.swagger.v3.oas.models.OpenAPI; |
|||
import io.swagger.v3.oas.models.info.Info; |
|||
import io.swagger.v3.oas.models.security.SecurityRequirement; |
|||
import io.swagger.v3.oas.models.security.SecurityScheme; |
|||
import org.springdoc.core.customizers.GlobalOpenApiCustomizer; |
|||
import org.springframework.context.annotation.Bean; |
|||
import org.springframework.context.annotation.Configuration; |
|||
import org.springframework.http.HttpHeaders; |
|||
import org.springframework.util.AntPathMatcher; |
|||
|
|||
import java.util.stream.Stream; |
|||
|
|||
/*** |
|||
* 创建Swagger配置 |
|||
*/ |
|||
@Configuration |
|||
public class SwaggerConfig { |
|||
|
|||
@Bean |
|||
public GlobalOpenApiCustomizer orderGlobalOpenApiCustomizer() { |
|||
return openApi -> { |
|||
// 全局添加Authorization |
|||
if (openApi.getPaths() != null) { |
|||
openApi.getPaths().forEach((path, pathItem) -> { |
|||
|
|||
// 忽略认证的请求无需携带 Authorization |
|||
String[] ignoreUrls = {"/api/auth/login"}; |
|||
if (ArrayUtil.isNotEmpty(ignoreUrls)) { |
|||
// Ant 匹配忽略的路径,不添加Authorization |
|||
AntPathMatcher antPathMatcher = new AntPathMatcher(); |
|||
if (Stream.of(ignoreUrls).anyMatch(ignoreUrl -> antPathMatcher.match(ignoreUrl, path))) { |
|||
return; |
|||
} |
|||
} |
|||
|
|||
// 其他接口统一添加Authorization |
|||
pathItem.readOperations() |
|||
.forEach(operation -> |
|||
operation.addSecurityItem(new SecurityRequirement().addList(HttpHeaders.AUTHORIZATION)) |
|||
); |
|||
}); |
|||
} |
|||
}; |
|||
} |
|||
|
|||
@Bean |
|||
public OpenAPI customOpenAPI() { |
|||
return new OpenAPI() |
|||
.info(new Info() |
|||
.title("系统API") |
|||
.version("1.0")) // 配置全局鉴权参数-Authorize |
|||
.components(new Components() |
|||
.addSecuritySchemes(HttpHeaders.AUTHORIZATION, |
|||
new SecurityScheme() |
|||
.name(HttpHeaders.AUTHORIZATION) |
|||
.type(SecurityScheme.Type.APIKEY) |
|||
.in(SecurityScheme.In.HEADER) |
|||
.scheme("Bearer") |
|||
.bearerFormat("JWT") |
|||
) |
|||
); |
|||
} |
|||
|
|||
|
|||
} |
@ -0,0 +1,16 @@ |
|||
package com.iflytop.gd.app.config; |
|||
|
|||
import org.springframework.context.annotation.Configuration; |
|||
import org.springframework.web.servlet.config.annotation.CorsRegistry; |
|||
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; |
|||
|
|||
@Configuration |
|||
public class WebConfig implements WebMvcConfigurer { |
|||
@Override |
|||
public void addCorsMappings(CorsRegistry registry) { |
|||
registry.addMapping("/api/**") |
|||
.allowedOrigins("*") |
|||
.allowedMethods("GET", "POST", "PUT", "DELETE") |
|||
.allowedHeaders("*"); |
|||
} |
|||
} |
@ -0,0 +1,14 @@ |
|||
package com.iflytop.gd.app.config; |
|||
|
|||
import org.springframework.context.annotation.Bean; |
|||
import org.springframework.context.annotation.Configuration; |
|||
import org.springframework.web.socket.server.standard.ServerEndpointExporter; |
|||
|
|||
@Configuration |
|||
public class WebSocketConfig { |
|||
|
|||
@Bean |
|||
public ServerEndpointExporter serverEndpointExporter() { |
|||
return new ServerEndpointExporter(); |
|||
} |
|||
} |
@ -0,0 +1,49 @@ |
|||
package com.iflytop.gd.app.config; |
|||
|
|||
|
|||
import jakarta.websocket.*; |
|||
import jakarta.websocket.server.ServerEndpoint; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.util.Collections; |
|||
import java.util.HashSet; |
|||
import java.util.Set; |
|||
|
|||
@Slf4j |
|||
@ServerEndpoint("/ws") |
|||
@Component |
|||
public class WebSocketServer { |
|||
|
|||
private static final Set<Session> sessions = Collections.synchronizedSet(new HashSet<>()); |
|||
|
|||
public static void sendMessageToClients(String message) { |
|||
synchronized (sessions) { |
|||
for (Session session : sessions) { |
|||
try { |
|||
session.getBasicRemote().sendText(message); |
|||
} catch (Exception e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
@OnOpen |
|||
public void onOpen(Session session) { |
|||
sessions.add(session); |
|||
} |
|||
|
|||
@OnMessage |
|||
public void onMessage(String message, Session session) { |
|||
} |
|||
|
|||
@OnClose |
|||
public void onClose(Session session) { |
|||
sessions.remove(session); // 移除关闭连接的 Session |
|||
} |
|||
|
|||
@OnError |
|||
public void onError(Throwable error) { |
|||
} |
|||
} |
@ -0,0 +1,36 @@ |
|||
package com.iflytop.gd.app.core.handler; |
|||
|
|||
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler; |
|||
import org.apache.ibatis.reflection.MetaObject; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.time.LocalDateTime; |
|||
|
|||
/** |
|||
* mybatis-plus 字段自动填充 |
|||
*/ |
|||
@Component |
|||
public class MyMetaObjectHandler implements MetaObjectHandler { |
|||
|
|||
/** |
|||
* 新增填充创建时间 |
|||
* |
|||
* @param metaObject 元数据 |
|||
*/ |
|||
@Override |
|||
public void insertFill(MetaObject metaObject) { |
|||
this.strictInsertFill(metaObject, "createTime", LocalDateTime::now, LocalDateTime.class); |
|||
this.strictUpdateFill(metaObject, "updateTime", LocalDateTime::now, LocalDateTime.class); |
|||
} |
|||
|
|||
/** |
|||
* 更新填充更新时间 |
|||
* |
|||
* @param metaObject 元数据 |
|||
*/ |
|||
@Override |
|||
public void updateFill(MetaObject metaObject) { |
|||
this.strictUpdateFill(metaObject, "updateTime", LocalDateTime::now, LocalDateTime.class); |
|||
} |
|||
|
|||
} |
@ -0,0 +1,34 @@ |
|||
server: |
|||
servlet: |
|||
context-path: / |
|||
port: 8080 |
|||
|
|||
spring: |
|||
application: |
|||
name: graphite_digestion_service |
|||
datasource: |
|||
url: jdbc:sqlite:db/app.db |
|||
driver-class-name: org.sqlite.JDBC |
|||
sql: |
|||
init: |
|||
#always embedded never |
|||
mode: always |
|||
schema-locations: classpath:/sql/init.sql |
|||
|
|||
mybatis-plus: |
|||
configuration: |
|||
# 开启 SQL 日志输出(可选) |
|||
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl |
|||
# 如果需要加载 XML 文件(自定义 SQL),可配置 mapper-locations: |
|||
mapper-locations: classpath*:mapper/*.xml |
|||
|
|||
#开启 SQL 打印,调试时方便查看 |
|||
logging: |
|||
level: |
|||
root: INFO |
|||
org.mybatis: DEBUG |
|||
|
|||
springdoc: |
|||
default-flat-param-object: true |
|||
|
|||
|
@ -0,0 +1,58 @@ |
|||
<?xml version="1.0" encoding="UTF-8"?> |
|||
<configuration scan="true" scanPeriod="30 seconds"> |
|||
|
|||
<property name="LOG_PATH" value="./logs"/> |
|||
<property name="LOG_PATTERN" value="%d{HH:mm:ss.SSS} [%thread] %-5level %logger{20} - [%method,%line] - %msg%n"/> |
|||
|
|||
<!-- 控制台 --> |
|||
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender"> |
|||
<encoder> |
|||
<pattern>${LOG_PATTERN}</pattern> |
|||
</encoder> |
|||
</appender> |
|||
|
|||
<!-- 系统日志(INFO 及以上),按日期+大小滚动,归档后压缩 --> |
|||
<appender name="FILE_INFO" class="ch.qos.logback.core.rolling.RollingFileAppender"> |
|||
<file>${LOG_PATH}/sys-info.log</file> |
|||
<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy"> |
|||
<fileNamePattern>${LOG_PATH}/history/info/sys-info.%d{yyyy-MM-dd}.%i.log.zip</fileNamePattern> |
|||
<maxFileSize>20MB</maxFileSize> |
|||
<maxHistory>7</maxHistory> |
|||
<totalSizeCap>200MB</totalSizeCap> |
|||
</rollingPolicy> |
|||
<encoder> |
|||
<pattern>${LOG_PATTERN}</pattern> |
|||
</encoder> |
|||
<filter class="ch.qos.logback.classic.filter.ThresholdFilter"> |
|||
<level>INFO</level> |
|||
</filter> |
|||
</appender> |
|||
|
|||
<!-- 系统错误日志(ERROR 及以上),按日期+大小滚动,归档后压缩 --> |
|||
<appender name="FILE_ERROR" class="ch.qos.logback.core.rolling.RollingFileAppender"> |
|||
<file>${LOG_PATH}/sys-error.log</file> |
|||
<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy"> |
|||
<fileNamePattern>${LOG_PATH}/history/error/sys-error.%d{yyyy-MM-dd}.%i.log.zip</fileNamePattern> |
|||
<maxFileSize>20MB</maxFileSize> |
|||
<maxHistory>7</maxHistory> |
|||
<totalSizeCap>200MB</totalSizeCap> |
|||
</rollingPolicy> |
|||
<encoder> |
|||
<pattern>${LOG_PATTERN}</pattern> |
|||
</encoder> |
|||
<filter class="ch.qos.logback.classic.filter.ThresholdFilter"> |
|||
<level>ERROR</level> |
|||
</filter> |
|||
</appender> |
|||
|
|||
<!-- 包级别日志 --> |
|||
<logger name="com.iflytop" level="INFO"/> |
|||
<logger name="org.springframework" level="WARN"/> |
|||
|
|||
<root level="INFO"> |
|||
<appender-ref ref="CONSOLE"/> |
|||
<appender-ref ref="FILE_INFO"/> |
|||
<appender-ref ref="FILE_ERROR"/> |
|||
</root> |
|||
|
|||
</configuration> |
@ -0,0 +1,15 @@ |
|||
-- 用户表,插入时判断账户是否已存在 |
|||
CREATE TABLE IF NOT EXISTS user ( |
|||
id INTEGER PRIMARY KEY AUTOINCREMENT, |
|||
username TEXT, |
|||
nickname TEXT, |
|||
password TEXT, |
|||
role TEXT, |
|||
fixed_user INTEGER, |
|||
create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP, |
|||
update_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP |
|||
); |
|||
|
|||
INSERT INTO user (username,nickname, password, role, fixed_user) |
|||
SELECT 'admin','Admin', '000000', 'ADMIN', 1 |
|||
WHERE NOT EXISTS (SELECT 1 FROM user WHERE username = 'admin'); |
@ -0,0 +1,13 @@ |
|||
package com.iflytop.gd; |
|||
|
|||
import org.junit.jupiter.api.Test; |
|||
import org.springframework.boot.test.context.SpringBootTest; |
|||
|
|||
@SpringBootTest |
|||
class GraphiteDigesterServiceApplicationTests { |
|||
|
|||
@Test |
|||
void contextLoads() { |
|||
} |
|||
|
|||
} |
Write
Preview
Loading…
Cancel
Save
Reference in new issue