fix: SpringBoot3 + mybatis-flex + Spring-security

.gitignore

@@ -31,3 +31,8 @@ build/
 
 ### VS Code ###
 .vscode/
+
+/log
+/logs
+/config
+/.mvn

mvnw

@@ -0,0 +1,259 @@
+#!/bin/sh
+# ----------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#    https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+# ----------------------------------------------------------------------------
+
+# ----------------------------------------------------------------------------
+# Apache Maven Wrapper startup batch script, version 3.3.2
+#
+# Optional ENV vars
+# -----------------
+#   JAVA_HOME - location of a JDK home dir, required when download maven via java source
+#   MVNW_REPOURL - repo url base for downloading maven distribution
+#   MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
+#   MVNW_VERBOSE - true: enable verbose log; debug: trace the mvnw script; others: silence the output
+# ----------------------------------------------------------------------------
+
+set -euf
+[ "${MVNW_VERBOSE-}" != debug ] || set -x
+
+# OS specific support.
+native_path() { printf %s\\n "$1"; }
+case "$(uname)" in
+CYGWIN* | MINGW*)
+  [ -z "${JAVA_HOME-}" ] || JAVA_HOME="$(cygpath --unix "$JAVA_HOME")"
+  native_path() { cygpath --path --windows "$1"; }
+  ;;
+esac
+
+# set JAVACMD and JAVACCMD
+set_java_home() {
+  # For Cygwin and MinGW, ensure paths are in Unix format before anything is touched
+  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"
+      JAVACCMD="$JAVA_HOME/jre/sh/javac"
+    else
+      JAVACMD="$JAVA_HOME/bin/java"
+      JAVACCMD="$JAVA_HOME/bin/javac"
+
+      if [ ! -x "$JAVACMD" ] || [ ! -x "$JAVACCMD" ]; then
+        echo "The JAVA_HOME environment variable is not defined correctly, so mvnw cannot run." >&2
+        echo "JAVA_HOME is set to \"$JAVA_HOME\", but \"\$JAVA_HOME/bin/java\" or \"\$JAVA_HOME/bin/javac\" does not exist." >&2
+        return 1
+      fi
+    fi
+  else
+    JAVACMD="$(
+      'set' +e
+      'unset' -f command 2>/dev/null
+      'command' -v java
+    )" || :
+    JAVACCMD="$(
+      'set' +e
+      'unset' -f command 2>/dev/null
+      'command' -v javac
+    )" || :
+
+    if [ ! -x "${JAVACMD-}" ] || [ ! -x "${JAVACCMD-}" ]; then
+      echo "The java/javac command does not exist in PATH nor is JAVA_HOME set, so mvnw cannot run." >&2
+      return 1
+    fi
+  fi
+}
+
+# hash string like Java String::hashCode
+hash_string() {
+  str="${1:-}" h=0
+  while [ -n "$str" ]; do
+    char="${str%"${str#?}"}"
+    h=$(((h * 31 + $(LC_CTYPE=C printf %d "'$char")) % 4294967296))
+    str="${str#?}"
+  done
+  printf %x\\n $h
+}
+
+verbose() { :; }
+[ "${MVNW_VERBOSE-}" != true ] || verbose() { printf %s\\n "${1-}"; }
+
+die() {
+  printf %s\\n "$1" >&2
+  exit 1
+}
+
+trim() {
+  # MWRAPPER-139:
+  #   Trims trailing and leading whitespace, carriage returns, tabs, and linefeeds.
+  #   Needed for removing poorly interpreted newline sequences when running in more
+  #   exotic environments such as mingw bash on Windows.
+  printf "%s" "${1}" | tr -d '[:space:]'
+}
+
+# parse distributionUrl and optional distributionSha256Sum, requires .mvn/wrapper/maven-wrapper.properties
+while IFS="=" read -r key value; do
+  case "${key-}" in
+  distributionUrl) distributionUrl=$(trim "${value-}") ;;
+  distributionSha256Sum) distributionSha256Sum=$(trim "${value-}") ;;
+  esac
+done <"${0%/*}/.mvn/wrapper/maven-wrapper.properties"
+[ -n "${distributionUrl-}" ] || die "cannot read distributionUrl property in ${0%/*}/.mvn/wrapper/maven-wrapper.properties"
+
+case "${distributionUrl##*/}" in
+maven-mvnd-*bin.*)
+  MVN_CMD=mvnd.sh _MVNW_REPO_PATTERN=/maven/mvnd/
+  case "${PROCESSOR_ARCHITECTURE-}${PROCESSOR_ARCHITEW6432-}:$(uname -a)" in
+  *AMD64:CYGWIN* | *AMD64:MINGW*) distributionPlatform=windows-amd64 ;;
+  :Darwin*x86_64) distributionPlatform=darwin-amd64 ;;
+  :Darwin*arm64) distributionPlatform=darwin-aarch64 ;;
+  :Linux*x86_64*) distributionPlatform=linux-amd64 ;;
+  *)
+    echo "Cannot detect native platform for mvnd on $(uname)-$(uname -m), use pure java version" >&2
+    distributionPlatform=linux-amd64
+    ;;
+  esac
+  distributionUrl="${distributionUrl%-bin.*}-$distributionPlatform.zip"
+  ;;
+maven-mvnd-*) MVN_CMD=mvnd.sh _MVNW_REPO_PATTERN=/maven/mvnd/ ;;
+*) MVN_CMD="mvn${0##*/mvnw}" _MVNW_REPO_PATTERN=/org/apache/maven/ ;;
+esac
+
+# apply MVNW_REPOURL and calculate MAVEN_HOME
+# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-<version>,maven-mvnd-<version>-<platform>}/<hash>
+[ -z "${MVNW_REPOURL-}" ] || distributionUrl="$MVNW_REPOURL$_MVNW_REPO_PATTERN${distributionUrl#*"$_MVNW_REPO_PATTERN"}"
+distributionUrlName="${distributionUrl##*/}"
+distributionUrlNameMain="${distributionUrlName%.*}"
+distributionUrlNameMain="${distributionUrlNameMain%-bin}"
+MAVEN_USER_HOME="${MAVEN_USER_HOME:-${HOME}/.m2}"
+MAVEN_HOME="${MAVEN_USER_HOME}/wrapper/dists/${distributionUrlNameMain-}/$(hash_string "$distributionUrl")"
+
+exec_maven() {
+  unset MVNW_VERBOSE MVNW_USERNAME MVNW_PASSWORD MVNW_REPOURL || :
+  exec "$MAVEN_HOME/bin/$MVN_CMD" "$@" || die "cannot exec $MAVEN_HOME/bin/$MVN_CMD"
+}
+
+if [ -d "$MAVEN_HOME" ]; then
+  verbose "found existing MAVEN_HOME at $MAVEN_HOME"
+  exec_maven "$@"
+fi
+
+case "${distributionUrl-}" in
+*?-bin.zip | *?maven-mvnd-?*-?*.zip) ;;
+*) die "distributionUrl is not valid, must match *-bin.zip or maven-mvnd-*.zip, but found '${distributionUrl-}'" ;;
+esac
+
+# prepare tmp dir
+if TMP_DOWNLOAD_DIR="$(mktemp -d)" && [ -d "$TMP_DOWNLOAD_DIR" ]; then
+  clean() { rm -rf -- "$TMP_DOWNLOAD_DIR"; }
+  trap clean HUP INT TERM EXIT
+else
+  die "cannot create temp dir"
+fi
+
+mkdir -p -- "${MAVEN_HOME%/*}"
+
+# Download and Install Apache Maven
+verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
+verbose "Downloading from: $distributionUrl"
+verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
+
+# select .zip or .tar.gz
+if ! command -v unzip >/dev/null; then
+  distributionUrl="${distributionUrl%.zip}.tar.gz"
+  distributionUrlName="${distributionUrl##*/}"
+fi
+
+# verbose opt
+__MVNW_QUIET_WGET=--quiet __MVNW_QUIET_CURL=--silent __MVNW_QUIET_UNZIP=-q __MVNW_QUIET_TAR=''
+[ "${MVNW_VERBOSE-}" != true ] || __MVNW_QUIET_WGET='' __MVNW_QUIET_CURL='' __MVNW_QUIET_UNZIP='' __MVNW_QUIET_TAR=v
+
+# normalize http auth
+case "${MVNW_PASSWORD:+has-password}" in
+'') MVNW_USERNAME='' MVNW_PASSWORD='' ;;
+has-password) [ -n "${MVNW_USERNAME-}" ] || MVNW_USERNAME='' MVNW_PASSWORD='' ;;
+esac
+
+if [ -z "${MVNW_USERNAME-}" ] && command -v wget >/dev/null; then
+  verbose "Found wget ... using wget"
+  wget ${__MVNW_QUIET_WGET:+"$__MVNW_QUIET_WGET"} "$distributionUrl" -O "$TMP_DOWNLOAD_DIR/$distributionUrlName" || die "wget: Failed to fetch $distributionUrl"
+elif [ -z "${MVNW_USERNAME-}" ] && command -v curl >/dev/null; then
+  verbose "Found curl ... using curl"
+  curl ${__MVNW_QUIET_CURL:+"$__MVNW_QUIET_CURL"} -f -L -o "$TMP_DOWNLOAD_DIR/$distributionUrlName" "$distributionUrl" || die "curl: Failed to fetch $distributionUrl"
+elif set_java_home; then
+  verbose "Falling back to use Java to download"
+  javaSource="$TMP_DOWNLOAD_DIR/Downloader.java"
+  targetZip="$TMP_DOWNLOAD_DIR/$distributionUrlName"
+  cat >"$javaSource" <<-END
+	public class Downloader extends java.net.Authenticator
+	{
+	  protected java.net.PasswordAuthentication getPasswordAuthentication()
+	  {
+	    return new java.net.PasswordAuthentication( System.getenv( "MVNW_USERNAME" ), System.getenv( "MVNW_PASSWORD" ).toCharArray() );
+	  }
+	  public static void main( String[] args ) throws Exception
+	  {
+	    setDefault( new Downloader() );
+	    java.nio.file.Files.copy( java.net.URI.create( args[0] ).toURL().openStream(), java.nio.file.Paths.get( args[1] ).toAbsolutePath().normalize() );
+	  }
+	}
+	END
+  # For Cygwin/MinGW, switch paths to Windows format before running javac and java
+  verbose " - Compiling Downloader.java ..."
+  "$(native_path "$JAVACCMD")" "$(native_path "$javaSource")" || die "Failed to compile Downloader.java"
+  verbose " - Running Downloader.java ..."
+  "$(native_path "$JAVACMD")" -cp "$(native_path "$TMP_DOWNLOAD_DIR")" Downloader "$distributionUrl" "$(native_path "$targetZip")"
+fi
+
+# If specified, validate the SHA-256 sum of the Maven distribution zip file
+if [ -n "${distributionSha256Sum-}" ]; then
+  distributionSha256Result=false
+  if [ "$MVN_CMD" = mvnd.sh ]; then
+    echo "Checksum validation is not supported for maven-mvnd." >&2
+    echo "Please disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties." >&2
+    exit 1
+  elif command -v sha256sum >/dev/null; then
+    if echo "$distributionSha256Sum  $TMP_DOWNLOAD_DIR/$distributionUrlName" | sha256sum -c >/dev/null 2>&1; then
+      distributionSha256Result=true
+    fi
+  elif command -v shasum >/dev/null; then
+    if echo "$distributionSha256Sum  $TMP_DOWNLOAD_DIR/$distributionUrlName" | shasum -a 256 -c >/dev/null 2>&1; then
+      distributionSha256Result=true
+    fi
+  else
+    echo "Checksum validation was requested but neither 'sha256sum' or 'shasum' are available." >&2
+    echo "Please install either command, or disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties." >&2
+    exit 1
+  fi
+  if [ $distributionSha256Result = false ]; then
+    echo "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised." >&2
+    echo "If you updated your Maven version, you need to update the specified distributionSha256Sum property." >&2
+    exit 1
+  fi
+fi
+
+# unzip and move
+if command -v unzip >/dev/null; then
+  unzip ${__MVNW_QUIET_UNZIP:+"$__MVNW_QUIET_UNZIP"} "$TMP_DOWNLOAD_DIR/$distributionUrlName" -d "$TMP_DOWNLOAD_DIR" || die "failed to unzip"
+else
+  tar xzf${__MVNW_QUIET_TAR:+"$__MVNW_QUIET_TAR"} "$TMP_DOWNLOAD_DIR/$distributionUrlName" -C "$TMP_DOWNLOAD_DIR" || die "failed to untar"
+fi
+printf %s\\n "$distributionUrl" >"$TMP_DOWNLOAD_DIR/$distributionUrlNameMain/mvnw.url"
+mv -- "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" "$MAVEN_HOME" || [ -d "$MAVEN_HOME" ] || die "fail to move MAVEN_HOME"
+
+clean || :
+exec_maven "$@"

mvnw.cmd

@@ -0,0 +1,149 @@
+<# : batch portion
+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements.  See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership.  The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License.  You may obtain a copy of the License at
+@REM
+@REM    https://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied.  See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Apache Maven Wrapper startup batch script, version 3.3.2
+@REM
+@REM Optional ENV vars
+@REM   MVNW_REPOURL - repo url base for downloading maven distribution
+@REM   MVNW_USERNAME/MVNW_PASSWORD - user and password for downloading maven
+@REM   MVNW_VERBOSE - true: enable verbose log; others: silence the output
+@REM ----------------------------------------------------------------------------
+
+@IF "%__MVNW_ARG0_NAME__%"=="" (SET __MVNW_ARG0_NAME__=%~nx0)
+@SET __MVNW_CMD__=
+@SET __MVNW_ERROR__=
+@SET __MVNW_PSMODULEP_SAVE=%PSModulePath%
+@SET PSModulePath=
+@FOR /F "usebackq tokens=1* delims==" %%A IN (`powershell -noprofile "& {$scriptDir='%~dp0'; $script='%__MVNW_ARG0_NAME__%'; icm -ScriptBlock ([Scriptblock]::Create((Get-Content -Raw '%~f0'))) -NoNewScope}"`) DO @(
+  IF "%%A"=="MVN_CMD" (set __MVNW_CMD__=%%B) ELSE IF "%%B"=="" (echo %%A) ELSE (echo %%A=%%B)
+)
+@SET PSModulePath=%__MVNW_PSMODULEP_SAVE%
+@SET __MVNW_PSMODULEP_SAVE=
+@SET __MVNW_ARG0_NAME__=
+@SET MVNW_USERNAME=
+@SET MVNW_PASSWORD=
+@IF NOT "%__MVNW_CMD__%"=="" (%__MVNW_CMD__% %*)
+@echo Cannot start maven from wrapper >&2 && exit /b 1
+@GOTO :EOF
+: end batch / begin powershell #>
+
+$ErrorActionPreference = "Stop"
+if ($env:MVNW_VERBOSE -eq "true") {
+  $VerbosePreference = "Continue"
+}
+
+# calculate distributionUrl, requires .mvn/wrapper/maven-wrapper.properties
+$distributionUrl = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionUrl
+if (!$distributionUrl) {
+  Write-Error "cannot read distributionUrl property in $scriptDir/.mvn/wrapper/maven-wrapper.properties"
+}
+
+switch -wildcard -casesensitive ( $($distributionUrl -replace '^.*/','') ) {
+  "maven-mvnd-*" {
+    $USE_MVND = $true
+    $distributionUrl = $distributionUrl -replace '-bin\.[^.]*$',"-windows-amd64.zip"
+    $MVN_CMD = "mvnd.cmd"
+    break
+  }
+  default {
+    $USE_MVND = $false
+    $MVN_CMD = $script -replace '^mvnw','mvn'
+    break
+  }
+}
+
+# apply MVNW_REPOURL and calculate MAVEN_HOME
+# maven home pattern: ~/.m2/wrapper/dists/{apache-maven-<version>,maven-mvnd-<version>-<platform>}/<hash>
+if ($env:MVNW_REPOURL) {
+  $MVNW_REPO_PATTERN = if ($USE_MVND) { "/org/apache/maven/" } else { "/maven/mvnd/" }
+  $distributionUrl = "$env:MVNW_REPOURL$MVNW_REPO_PATTERN$($distributionUrl -replace '^.*'+$MVNW_REPO_PATTERN,'')"
+}
+$distributionUrlName = $distributionUrl -replace '^.*/',''
+$distributionUrlNameMain = $distributionUrlName -replace '\.[^.]*$','' -replace '-bin$',''
+$MAVEN_HOME_PARENT = "$HOME/.m2/wrapper/dists/$distributionUrlNameMain"
+if ($env:MAVEN_USER_HOME) {
+  $MAVEN_HOME_PARENT = "$env:MAVEN_USER_HOME/wrapper/dists/$distributionUrlNameMain"
+}
+$MAVEN_HOME_NAME = ([System.Security.Cryptography.MD5]::Create().ComputeHash([byte[]][char[]]$distributionUrl) | ForEach-Object {$_.ToString("x2")}) -join ''
+$MAVEN_HOME = "$MAVEN_HOME_PARENT/$MAVEN_HOME_NAME"
+
+if (Test-Path -Path "$MAVEN_HOME" -PathType Container) {
+  Write-Verbose "found existing MAVEN_HOME at $MAVEN_HOME"
+  Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"
+  exit $?
+}
+
+if (! $distributionUrlNameMain -or ($distributionUrlName -eq $distributionUrlNameMain)) {
+  Write-Error "distributionUrl is not valid, must end with *-bin.zip, but found $distributionUrl"
+}
+
+# prepare tmp dir
+$TMP_DOWNLOAD_DIR_HOLDER = New-TemporaryFile
+$TMP_DOWNLOAD_DIR = New-Item -Itemtype Directory -Path "$TMP_DOWNLOAD_DIR_HOLDER.dir"
+$TMP_DOWNLOAD_DIR_HOLDER.Delete() | Out-Null
+trap {
+  if ($TMP_DOWNLOAD_DIR.Exists) {
+    try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
+    catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
+  }
+}
+
+New-Item -Itemtype Directory -Path "$MAVEN_HOME_PARENT" -Force | Out-Null
+
+# Download and Install Apache Maven
+Write-Verbose "Couldn't find MAVEN_HOME, downloading and installing it ..."
+Write-Verbose "Downloading from: $distributionUrl"
+Write-Verbose "Downloading to: $TMP_DOWNLOAD_DIR/$distributionUrlName"
+
+$webclient = New-Object System.Net.WebClient
+if ($env:MVNW_USERNAME -and $env:MVNW_PASSWORD) {
+  $webclient.Credentials = New-Object System.Net.NetworkCredential($env:MVNW_USERNAME, $env:MVNW_PASSWORD)
+}
+[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12
+$webclient.DownloadFile($distributionUrl, "$TMP_DOWNLOAD_DIR/$distributionUrlName") | Out-Null
+
+# If specified, validate the SHA-256 sum of the Maven distribution zip file
+$distributionSha256Sum = (Get-Content -Raw "$scriptDir/.mvn/wrapper/maven-wrapper.properties" | ConvertFrom-StringData).distributionSha256Sum
+if ($distributionSha256Sum) {
+  if ($USE_MVND) {
+    Write-Error "Checksum validation is not supported for maven-mvnd. `nPlease disable validation by removing 'distributionSha256Sum' from your maven-wrapper.properties."
+  }
+  Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash
+  if ((Get-FileHash "$TMP_DOWNLOAD_DIR/$distributionUrlName" -Algorithm SHA256).Hash.ToLower() -ne $distributionSha256Sum) {
+    Write-Error "Error: Failed to validate Maven distribution SHA-256, your Maven distribution might be compromised. If you updated your Maven version, you need to update the specified distributionSha256Sum property."
+  }
+}
+
+# unzip and move
+Expand-Archive "$TMP_DOWNLOAD_DIR/$distributionUrlName" -DestinationPath "$TMP_DOWNLOAD_DIR" | Out-Null
+Rename-Item -Path "$TMP_DOWNLOAD_DIR/$distributionUrlNameMain" -NewName $MAVEN_HOME_NAME | Out-Null
+try {
+  Move-Item -Path "$TMP_DOWNLOAD_DIR/$MAVEN_HOME_NAME" -Destination $MAVEN_HOME_PARENT | Out-Null
+} catch {
+  if (! (Test-Path -Path "$MAVEN_HOME" -PathType Container)) {
+    Write-Error "fail to move MAVEN_HOME"
+  }
+} finally {
+  try { Remove-Item $TMP_DOWNLOAD_DIR -Recurse -Force | Out-Null }
+  catch { Write-Warning "Cannot remove $TMP_DOWNLOAD_DIR" }
+}
+
+Write-Output "MVN_CMD=$MAVEN_HOME/bin/$MVN_CMD"

pom.xml

@@ -0,0 +1,147 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>3.2.8</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>com.lqkj</groupId>
+    <artifactId>CMLCP-SERVER</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>CMLCP-SERVER</name>
+    <description>CMLCP-SERVER</description>
+    <url/>
+    <licenses>
+        <license/>
+    </licenses>
+    <developers>
+        <developer/>
+    </developers>
+    <scm>
+        <connection/>
+        <developerConnection/>
+        <tag/>
+        <url/>
+    </scm>
+    <properties>
+        <java.version>17</java.version>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-jdbc</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.14.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.flywaydb</groupId>
+            <artifactId>flyway-core</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springdoc</groupId>
+            <artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
+            <version>2.1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springdoc</groupId>
+            <artifactId>springdoc-openapi-starter-webmvc-api</artifactId>
+            <version>2.1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>jakarta.servlet</groupId>
+            <artifactId>jakarta.servlet-api</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.squareup.okio</groupId>
+            <artifactId>okio</artifactId>
+            <version>3.6.0</version>
+        </dependency>
+        <!-- mybatis-flex -->
+        <dependency>
+            <groupId>com.mybatis-flex</groupId>
+            <artifactId>mybatis-flex-spring-boot3-starter</artifactId>
+            <version>1.9.5</version>
+        </dependency>
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+        </dependency>
+<!--        redis-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+            <version>2.15.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-security</artifactId>
+        </dependency>
+        <!-- JWT 相关 -->
+        <dependency>
+            <groupId>io.jsonwebtoken</groupId>
+            <artifactId>jjwt-api</artifactId>
+            <version>0.11.5</version>
+        </dependency>
+        <dependency>
+            <groupId>io.jsonwebtoken</groupId>
+            <artifactId>jjwt-impl</artifactId>
+            <version>0.11.5</version>
+            <scope>runtime</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.jsonwebtoken</groupId>
+            <artifactId>jjwt-jackson</artifactId>
+            <version>0.11.5</version>
+            <scope>runtime</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <configuration>
+                    <excludes>
+                        <exclude>
+                            <groupId>org.projectlombok</groupId>
+                            <artifactId>lombok</artifactId>
+                        </exclude>
+                    </excludes>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

src/main/java/com/lqkj/cmlcp/CmlcpServerApplication.java

@@ -0,0 +1,23 @@
+package com.lqkj.cmlcp;
+
+import com.lqkj.cmlcp.config.PropertyDeploy;
+import org.springframework.boot.Banner;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class CmlcpServerApplication {
+
+    public static void main(String[] args) {
+        // 生成配置文件
+        PropertyDeploy deploy=new PropertyDeploy();
+        deploy.deploy();
+
+        // 禁止actuator端点
+        SpringApplication app = new SpringApplication(CmlcpServerApplication.class);
+        app.setBannerMode(Banner.Mode.OFF);
+        app.setAddCommandLineProperties(false);
+        app.run(args);
+    }
+
+}

src/main/java/com/lqkj/cmlcp/config/PropertyDeploy.java

@@ -0,0 +1,136 @@
+package com.lqkj.cmlcp.config;
+
+import okio.BufferedSink;
+import okio.Okio;
+import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.io.ClassPathResource;
+import org.yaml.snakeyaml.Yaml;
+
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.LinkedHashMap;
+import java.util.Scanner;
+
+/**
+ * 环境文件部署
+ */
+public class PropertyDeploy {
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+    public static final String PropertyDirPath = "./config";
+    public static final String PropertyFilePath = PropertyDirPath + "/application.yml";
+
+    /**
+     * 查询文件是否存在
+     *
+     * @return
+     */
+    private boolean isPropertyFileExist() {
+        return Files.exists(Paths.get(PropertyFilePath));
+    }
+
+    /**
+     * 数据库链接询问
+     */
+    private void inputDataBaseConfig() {
+        Scanner scanner = new Scanner(System.in);
+
+        System.out.println("请输入数据库IP:");
+        String ip = scanner.nextLine();
+
+        System.out.println("请输入数据库端口:");
+        String port = scanner.nextLine();
+
+        System.out.println("请输入数据库名称");
+        String dbName = scanner.nextLine();
+
+        System.out.println("请输入数据库用户名:");
+        String userName = scanner.nextLine();
+
+        System.out.println("请输入数据库密码");
+        String passWord = scanner.nextLine();
+
+        System.out.println("指定server绑定的地址");
+        String address = scanner.nextLine();
+
+        createConfigureFile(ip, port, dbName, userName, passWord, address);
+    }
+
+    /**
+     * 创建配置文件
+     */
+    public void createConfigureFile(String ip, String port, String dbName, String userName, String passWord, String address) {
+        if (StringUtils.isEmpty(ip)) {
+            ip = "127.0.0.1";
+        }
+        if (StringUtils.isEmpty(port)) {
+            port = "5432";
+        }
+        File applicationFile = new File(PropertyFilePath);
+
+        ClassPathResource resource = new ClassPathResource("application-install.yml");
+
+        Yaml yaml = new Yaml();
+
+        BufferedSink sink = null;
+
+        InputStream inputStream = null;
+
+        try {
+            Files.createDirectories(Paths.get(PropertyDirPath));
+
+            Files.createFile(Paths.get(PropertyFilePath));
+
+            inputStream = resource.getInputStream();
+
+            LinkedHashMap<String, LinkedHashMap> application = yaml.load(inputStream);
+
+            LinkedHashMap<String, Object> dateSource = (LinkedHashMap<String, Object>) application.get("spring").get("datasource");
+            LinkedHashMap<String, Object> hikari = (LinkedHashMap<String, Object>) dateSource.get("hikari");
+            dateSource.put("url", "jdbc:postgresql://" + ip + ":" + port + "/" + dbName);
+            hikari.put("username", userName);
+            hikari.put("password", passWord);
+
+            LinkedHashMap<String, Object> serverAddress = (LinkedHashMap<String, Object>) application.get("server");
+            serverAddress.put("address", address);
+
+            sink = Okio.buffer(Okio.sink(applicationFile));
+
+            sink.write(yaml.dump(application).getBytes());
+
+            sink.flush();
+        } catch (IOException e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (sink != null) {
+                    sink.close();
+                }
+                if (inputStream != null) {
+                    inputStream.close();
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+
+    /**
+     * 部署文件
+     */
+    public void deploy() {
+        try {
+            if (!isPropertyFileExist()) {
+                inputDataBaseConfig();
+            }
+        } catch (Exception e) {
+            logger.error(e.getMessage(), e);
+        }
+
+    }
+}

src/main/java/com/lqkj/cmlcp/config/RedisConfig.java

@@ -0,0 +1,26 @@
+package com.lqkj.cmlcp.config;
+
+import org.springframework.context.annotation.Bean;
+   import org.springframework.context.annotation.Configuration;
+   import org.springframework.data.redis.connection.RedisConnectionFactory;
+   import org.springframework.data.redis.core.RedisTemplate;
+   import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+   import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+   @Configuration
+   public class RedisConfig {
+
+       @Bean
+       public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
+           RedisTemplate<String, Object> template = new RedisTemplate<>();
+           template.setConnectionFactory(factory);
+
+           Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
+           // 使用Jackson2JsonRedisSerializer 替换默认的 JdkSerializationRedisSerializer
+           template.setValueSerializer(serializer);
+           template.setKeySerializer(new StringRedisSerializer());
+           template.afterPropertiesSet();
+
+           return template;
+       }
+   }

src/main/java/com/lqkj/cmlcp/config/SpringDocConfig.java

@@ -0,0 +1,35 @@
+package com.lqkj.cmlcp.config;
+
+import io.swagger.v3.oas.models.OpenAPI;
+import io.swagger.v3.oas.models.info.Contact;
+import io.swagger.v3.oas.models.info.Info;
+import io.swagger.v3.oas.models.info.License;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class SpringDocConfig {
+    @Bean
+    public OpenAPI openAPI() {
+        return new OpenAPI()
+                // 配置接口文档基本信息
+                .info(this.getApiInfo())
+                ;
+    }
+    private Info getApiInfo() {
+        return new Info()
+                 // 配置文档标题
+                .title("SpringBoot3集成Swagger3")
+                // 配置文档描述
+                .description("SpringBoot3集成Swagger3示例文档")
+                // 配置作者信息
+                .contact(new Contact().name("lqkj").url("").email(""))
+                // 配置License许可证信息
+                .license(new License().name("Apache 2.0").url("https://www.xiezhrspace.cn"))
+                // 概述信息
+                .summary("SpringBoot3集成Swagger3示例文档aaa")
+                .termsOfService("")
+                // 配置版本号
+                .version("2.0");
+    }
+}

src/main/java/com/lqkj/cmlcp/config/WebConfig.java

@@ -0,0 +1,19 @@
+package com.lqkj.cmlcp.config;
+
+import com.lqkj.cmlcp.filter.RequestUrlLoggingFilter;
+import org.springframework.boot.web.servlet.FilterRegistrationBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+ 
+@Configuration
+public class WebConfig {
+ 
+    @Bean
+    public FilterRegistrationBean<RequestUrlLoggingFilter> loggingFilter() {
+        FilterRegistrationBean<RequestUrlLoggingFilter> registrationBean = new FilterRegistrationBean<>();
+        registrationBean.setFilter(new RequestUrlLoggingFilter());
+        registrationBean.addUrlPatterns("/*");
+        registrationBean.setOrder(1);
+        return registrationBean;
+    }
+}

src/main/java/com/lqkj/cmlcp/config/WebSecurityConfig.java

@@ -0,0 +1,76 @@
+package com.lqkj.cmlcp.config;
+
+
+import com.lqkj.cmlcp.config.auth.LoginAuthenticationProvider;
+import com.lqkj.cmlcp.filter.JwtAuthFilter;
+import com.lqkj.cmlcp.module.authority.service.impl.DatabaseUserDetailService;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.security.authentication.AuthenticationManager;
+import org.springframework.security.authentication.AuthenticationProvider;
+import org.springframework.security.authentication.dao.DaoAuthenticationProvider;
+import org.springframework.security.config.annotation.authentication.configuration.AuthenticationConfiguration;
+import org.springframework.security.config.annotation.web.builders.HttpSecurity;
+import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
+import org.springframework.security.config.annotation.web.configurers.AbstractHttpConfigurer;
+import org.springframework.security.config.http.SessionCreationPolicy;
+import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
+import org.springframework.security.crypto.password.PasswordEncoder;
+import org.springframework.security.web.SecurityFilterChain;
+import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
+
+
+@Configuration
+@EnableWebSecurity
+public class WebSecurityConfig {
+    private final JwtAuthFilter authFilter;
+    private final DatabaseUserDetailService userDetailService;
+
+    public WebSecurityConfig(JwtAuthFilter authFilter, DatabaseUserDetailService userDetailService) {
+        this.authFilter = authFilter;
+        this.userDetailService = userDetailService;
+    }
+
+    @Bean
+    public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception {
+        return http
+                .csrf(AbstractHttpConfigurer::disable)
+                .authorizeHttpRequests((requests) -> requests
+                        .requestMatchers(
+                                "/jwt/token",
+                                "/jwt/getAdminToken",
+                                "/encrypt/**",
+                                "/swagger-ui.html",
+                                "/swagger-ui/**",
+                                "/v3/api-docs/**",
+                                "/geom/all",
+                                "/test/**",
+                                "/upload/**")
+                        .permitAll()
+                        .requestMatchers("/**")
+                        .authenticated())
+                .sessionManagement((session) -> session
+                        .sessionCreationPolicy(SessionCreationPolicy.STATELESS))
+                .authenticationProvider(authenticationProvider())
+                .addFilterBefore(authFilter, UsernamePasswordAuthenticationFilter.class)
+                .build();
+    }
+
+
+    @Bean
+    public PasswordEncoder passwordEncoder() {
+        return new BCryptPasswordEncoder();
+    }
+    @Bean
+    public AuthenticationProvider authenticationProvider(){
+        DaoAuthenticationProvider authenticationProvider=new LoginAuthenticationProvider(userDetailService, passwordEncoder());
+        authenticationProvider.setUserDetailsService(userDetailService);
+        authenticationProvider.setPasswordEncoder(passwordEncoder());
+        return authenticationProvider;
+    }
+    @Bean
+    public AuthenticationManager authenticationManager(AuthenticationConfiguration config) throws Exception {
+        return config.getAuthenticationManager();
+    }
+
+}

src/main/java/com/lqkj/cmlcp/config/auth/LoginAuthenticationProvider.java

@@ -0,0 +1,44 @@
+package com.lqkj.cmlcp.config.auth;
+
+import com.lqkj.cmlcp.module.authority.service.impl.DatabaseUserDetailService;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.authentication.dao.DaoAuthenticationProvider;
+import org.springframework.security.core.AuthenticationException;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.security.crypto.password.PasswordEncoder;
+
+/**
+ * oauth2验证
+ */
+public class LoginAuthenticationProvider extends DaoAuthenticationProvider {
+    private final PasswordEncoder passwordEncoder;
+    public LoginAuthenticationProvider(DatabaseUserDetailService userDetailsService, PasswordEncoder passwordEncoder) {
+        setUserDetailsService(userDetailsService);
+        this.passwordEncoder = passwordEncoder;
+    }
+
+    protected void additionalAuthenticationChecks(UserDetails userDetails, UsernamePasswordAuthenticationToken authentication) throws AuthenticationException {
+//        //在接收到符合权限的帐号密码后进行再处理
+//        if (authentication.getCredentials() == null) {
+//            this.logger.debug("Authentication failed: no credentials provided");
+//            throw new BadCredentialsException(this.messages.getMessage("AbstractUserDetailsAuthenticationProvider.badCredentials", "Bad credentials"));
+//        } else {
+//            String pw;
+//            //如果位数为172则先解密
+//            if (authentication.getCredentials().toString().length() != 172) {
+//                this.logger.debug("Authentication failed: password length error");
+//                throw new BadCredentialsException(this.messages.getMessage("AbstractUserDetailsAuthenticationProvider.badCredentials", "Bad credentials"));
+//            }
+//            pw = RSAUtils.decryptBase64(authentication.getCredentials().toString());
+//            DatabaseUserDetailService userDetailsService = (DatabaseUserDetailService) getUserDetailsService();
+//            if (userDetailsService.isLocked(userDetails.getUsername())) {//账号是否被冻结
+//                throw new LockedException("账号已被冻结,请稍后重试");
+//            }
+//            if (!passwordEncoder.matches(pw, userDetails.getPassword())) {
+//                throw new LockedException(userDetailsService.lockedUser(userDetails.getUsername()));
+//            }else {
+//                userDetailsService.unlockedUser(userDetails.getUsername());
+//            }
+//        }
+    }
+}

src/main/java/com/lqkj/cmlcp/config/auth/OauthAuthorizationConfig.java

@@ -0,0 +1,130 @@
+package com.lqkj.cmlcp.config.auth;//package com.lqkj.link.config.auth;
+//
+//
+//import com.nimbusds.jose.jwk.JWKSet;
+//import com.nimbusds.jose.jwk.RSAKey;
+//import com.nimbusds.jose.jwk.source.ImmutableJWKSet;
+//import com.nimbusds.jose.jwk.source.JWKSource;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.core.annotation.Order;
+//import org.springframework.security.config.Customizer;
+//import org.springframework.security.config.annotation.web.builders.HttpSecurity;
+//import org.springframework.security.core.userdetails.User;
+//import org.springframework.security.core.userdetails.UserDetails;
+//import org.springframework.security.core.userdetails.UserDetailsService;
+//import org.springframework.security.oauth2.core.AuthorizationGrantType;
+//import org.springframework.security.oauth2.core.ClientAuthenticationMethod;
+//import org.springframework.security.oauth2.core.oidc.OidcScopes;
+//import org.springframework.security.oauth2.jwt.JwtDecoder;
+//import org.springframework.security.oauth2.server.authorization.client.InMemoryRegisteredClientRepository;
+//import org.springframework.security.oauth2.server.authorization.client.RegisteredClient;
+//import org.springframework.security.oauth2.server.authorization.client.RegisteredClientRepository;
+//import org.springframework.security.oauth2.server.authorization.config.annotation.web.configuration.OAuth2AuthorizationServerConfiguration;
+//import org.springframework.security.oauth2.server.authorization.config.annotation.web.configurers.OAuth2AuthorizationServerConfigurer;
+//import org.springframework.security.oauth2.server.authorization.settings.AuthorizationServerSettings;
+//import org.springframework.security.oauth2.server.authorization.settings.ClientSettings;
+//import org.springframework.security.provisioning.InMemoryUserDetailsManager;
+//import org.springframework.security.web.SecurityFilterChain;
+//import org.springframework.security.web.util.matcher.AntPathRequestMatcher;
+//
+//import java.security.KeyPair;
+//import java.security.KeyPairGenerator;
+//import java.security.interfaces.RSAPrivateKey;
+//import java.security.interfaces.RSAPublicKey;
+//import java.util.UUID;
+//
+//@Configuration
+//public class OauthAuthorizationConfig {
+//    @Bean
+//    @Order(1)
+//    public SecurityFilterChain authorizationServerSecurityFilterChain(HttpSecurity http) throws Exception {
+//        OAuth2AuthorizationServerConfiguration.applyDefaultSecurity(http);
+//        http
+//                .getConfigurer(OAuth2AuthorizationServerConfigurer.class)
+//                .oidc(Customizer.withDefaults());
+//
+//        http
+//                .oauth2ResourceServer(Customizer.withDefaults());
+//        return http.build();
+//    }
+//
+//    @Bean
+//    @Order(2)
+//    public SecurityFilterChain defaultSecurityFilterChain(HttpSecurity http) throws Exception {
+//        http
+//                .authorizeHttpRequests((authorize) ->
+//                        authorize
+//                                .requestMatchers(
+//                                    new AntPathRequestMatcher("/oauth2/**"),
+//                                    new AntPathRequestMatcher("/**/*.html"))
+//                                .permitAll()
+//                                .anyRequest()
+//                                .authenticated());
+//
+//        return http.build();
+//    }
+//
+//    @Bean
+//    public UserDetailsService userDetailsService() {
+//        UserDetails userDetails = User.withDefaultPasswordEncoder()
+//                .username("test")
+//                .password("test")
+//                .roles("USER")
+//                .build();
+//
+//        return new InMemoryUserDetailsManager(userDetails);
+//    }
+//
+//    @Bean
+//    public RegisteredClientRepository registeredClientRepository() {
+//        RegisteredClient registeredClient = RegisteredClient.withId(UUID.randomUUID().toString())
+//                .clientId("link_server")
+//                .clientSecret("{noop}demo-client-secret")
+//                .authorizationGrantType(AuthorizationGrantType.PASSWORD)
+//                .authorizationGrantType(AuthorizationGrantType.REFRESH_TOKEN)
+//                .scope("all")
+//                // 登录成功后对scope进行确认授权
+//                .clientSettings(ClientSettings.builder().requireAuthorizationConsent(true).build())
+//                .build();
+//
+//        return new InMemoryRegisteredClientRepository(registeredClient);
+//    }
+//
+//    @Bean
+//    public JWKSource jwkSource() {
+//        KeyPair keyPair = generateRsaKey();
+//        RSAPublicKey publicKey = (RSAPublicKey) keyPair.getPublic();
+//        RSAPrivateKey privateKey = (RSAPrivateKey) keyPair.getPrivate();
+//        RSAKey rsaKey = new RSAKey
+//                .Builder(publicKey)
+//                .privateKey(privateKey)
+//                .keyID(UUID.randomUUID().toString())
+//                .build();
+//        JWKSet jwkSet = new JWKSet(rsaKey);
+//        return new ImmutableJWKSet<>(jwkSet);
+//    }
+//
+//    private static KeyPair generateRsaKey() {
+//        KeyPair keyPair;
+//        try {
+//            KeyPairGenerator keyPairGenerator = KeyPairGenerator.getInstance("RSA");
+//            keyPairGenerator.initialize(2048);
+//            keyPair = keyPairGenerator.generateKeyPair();
+//        }
+//        catch (Exception ex) {
+//            throw new IllegalStateException(ex);
+//        }
+//        return keyPair;
+//    }
+//
+//    @Bean
+//    public JwtDecoder jwtDecoder(JWKSource jwkSource) {
+//        return OAuth2AuthorizationServerConfiguration.jwtDecoder(jwkSource);
+//    }
+//
+//    @Bean
+//    public AuthorizationServerSettings authorizationServerSettings() {
+//        return AuthorizationServerSettings.builder().build();
+//    }
+//}

src/main/java/com/lqkj/cmlcp/config/auth/OauthResourceConfig.java

@@ -0,0 +1,24 @@
+package com.lqkj.cmlcp.config.auth;//package com.lqkj.link.config.auth;
+//
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.security.config.annotation.web.builders.HttpSecurity;
+//import org.springframework.security.oauth2.jwt.JwtDecoders;
+//import org.springframework.security.web.SecurityFilterChain;
+//
+//@Configuration
+//public class OauthResourceConfig {
+//
+//    @Bean
+//    public SecurityFilterChain resourceServerSecurityFilterChain(HttpSecurity http) throws Exception {
+//        return http
+//                .authorizeHttpRequests((authorize) -> authorize
+//                            .anyRequest()
+//                            .authenticated()
+//                )
+//                .oauth2ResourceServer(oauth2 -> oauth2
+//                        .jwt(jwt -> jwt.decoder(JwtDecoders.fromIssuerLocation())))
+//                .jwt();
+//
+//    }
+//}

src/main/java/com/lqkj/cmlcp/exception/GlobalAsyncExceptionHandler.java

@@ -0,0 +1,28 @@
+package com.lqkj.cmlcp.exception;
+
+import com.lqkj.cmlcp.message.Result;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.context.request.NativeWebRequest;
+import org.springframework.web.context.request.async.CallableProcessingInterceptor;
+
+import java.util.concurrent.Callable;
+
+/**
+ * 异步全局异常处理
+ */
+public class GlobalAsyncExceptionHandler implements CallableProcessingInterceptor {
+
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Override
+    public <T> Object handleTimeout(NativeWebRequest request, Callable<T> task) throws Exception {
+        return Result.fail("请求超时");
+    }
+
+    @Override
+    public <T> Object handleError(NativeWebRequest request, Callable<T> task, Throwable t) throws Exception {
+        logger.error("收到异常", t);
+        return Result.fail(t.toString());
+    }
+}

src/main/java/com/lqkj/cmlcp/exception/GlobalExceptionHandler.java

@@ -0,0 +1,25 @@
+package com.lqkj.cmlcp.exception;
+
+import com.lqkj.cmlcp.message.Result;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+/**
+ * 全局异常处理
+ */
+@ControllerAdvice
+public class GlobalExceptionHandler {
+
+    private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @ExceptionHandler(Exception.class)
+    @ResponseBody
+    public Result<String> resolveException(Exception e) {
+        logger.error("收到异常", e);
+
+        return Result.fail(e.toString());
+    }
+}

src/main/java/com/lqkj/cmlcp/filter/JwtAuthFilter.java

@@ -0,0 +1,54 @@
+package com.lqkj.cmlcp.filter;
+
+
+import com.lqkj.cmlcp.module.authority.service.impl.DatabaseUserDetailService;
+import com.lqkj.cmlcp.module.jwt.service.JwtService;
+import jakarta.servlet.FilterChain;
+import jakarta.servlet.ServletException;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.jetbrains.annotations.NotNull;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.security.web.authentication.WebAuthenticationDetailsSource;
+import org.springframework.stereotype.Component;
+import org.springframework.web.filter.OncePerRequestFilter;
+
+import java.io.IOException;
+
+@Component
+public class JwtAuthFilter extends OncePerRequestFilter {
+
+    private final JwtService jwtService;
+    private final DatabaseUserDetailService userDetailService;
+
+    public JwtAuthFilter(JwtService jwtService, DatabaseUserDetailService userDetailService) {
+        this.jwtService = jwtService;
+        this.userDetailService = userDetailService;
+    }
+
+    @Override
+    protected void doFilterInternal(HttpServletRequest request, @NotNull HttpServletResponse response, @NotNull FilterChain filterChain) throws ServletException, IOException {
+        String url = request.getRequestURI();
+        logger.info(url);
+
+        String authHeader = request.getHeader("Authorization");
+        String token = null;
+        String username = null;
+        if (authHeader != null && authHeader.startsWith("Bearer ")) {
+            token = authHeader.substring(7);
+            username = jwtService.extractUsername(token);
+        }
+
+        if (username != null && SecurityContextHolder.getContext().getAuthentication() == null) {
+            UserDetails userDetails = userDetailService.loadUserByUsername(username);
+            if (jwtService.validateToken(token, userDetails)) {
+                UsernamePasswordAuthenticationToken authToken = new UsernamePasswordAuthenticationToken(userDetails, null, userDetails.getAuthorities());
+                authToken.setDetails(new WebAuthenticationDetailsSource().buildDetails(request));
+                SecurityContextHolder.getContext().setAuthentication(authToken);
+            }
+        }
+        filterChain.doFilter(request, response);
+    }
+}

src/main/java/com/lqkj/cmlcp/filter/RequestUrlLoggingFilter.java

@@ -0,0 +1,17 @@
+package com.lqkj.cmlcp.filter;
+
+
+import jakarta.servlet.*;
+import jakarta.servlet.http.HttpServletRequest;
+
+import java.io.IOException;
+ 
+public class RequestUrlLoggingFilter implements Filter {
+
+    @Override
+    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException {
+        HttpServletRequest request = (HttpServletRequest) servletRequest;
+        System.out.println("Request URL: " + request.getRequestURL());
+        filterChain.doFilter(servletRequest, servletResponse);
+    }
+}

src/main/java/com/lqkj/cmlcp/message/MessageBaseBean.java

@@ -0,0 +1,112 @@
+package com.lqkj.cmlcp.message;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 基础消息bean
+ * Created by free on 2017/7/27 0027.
+ */
+@Schema(description = "基础返回对象")
+public class MessageBaseBean implements Serializable {
+
+    public static final String NEXT_PAGE="nextPage";
+    /**
+     * 总页数
+     */
+    public static final String ALL_PAGE="allPage";
+    /**
+     * 当前页数
+     */
+    public static final String TOTAL_PAGE="totalPage";
+
+    /**
+     * 消息状态
+     */
+    @Schema(description = "消息状态")
+    private boolean status;
+
+    /**
+     * 消息时间戳
+     */
+    @Schema(description = "消息时间戳")
+    private long time;
+
+    /**
+     * 消息状态码
+     */
+    @Schema(description = "消息状态码")
+    private int code;
+
+    /**
+     * 提示信息
+     */
+    @Schema(description = "提示信息")
+    private String message;
+
+    /**
+     * 附加消息
+     */
+    @Schema(description = "附加消息")
+    private Map<String,Object> properties=new HashMap<String, Object>();
+
+    public boolean isStatus() {
+        return status;
+    }
+
+    public long getTime() {
+        return time;
+    }
+
+    public int getCode() {
+        return code;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public Map<String, Object> getProperties() {
+        return properties;
+    }
+
+    public void setStatus(boolean status) {
+        this.status = status;
+    }
+
+    public void setTime(long time) {
+        this.time = time;
+    }
+
+    public void setCode(int code) {
+        this.code = code;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public void setProperties(Map<String, Object> properties) {
+        this.properties = properties;
+    }
+
+    /**
+     * 增加一个附属信息
+     * @param key 附属信息的名称
+     * @param value 附属信息
+     */
+    public void addPropertie(String key,Object value){
+        this.properties.put(key,value);
+    }
+
+    /**
+     * 移除一个附属信息
+     * @param key 附属信息的名称
+     */
+    public void removePropertie(String key){
+        this.properties.remove(key);
+    }
+}

src/main/java/com/lqkj/cmlcp/message/MessageBean.java

@@ -0,0 +1,59 @@
+package com.lqkj.cmlcp.message;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.io.Serializable;
+
+/**
+ * 服务器单个信息bean
+ * Created by free on 2017/7/27 0027.
+ */
+@Schema(description = "单个实体返回对象")
+public class MessageBean<T> extends MessageBaseBean implements Serializable {
+
+    public MessageBean() {
+        this.setTime(System.currentTimeMillis());
+    }
+
+    public MessageBean(T data) {
+        this.data = data;
+        this.setTime(System.currentTimeMillis());
+    }
+
+    /**
+     * 被包含的消息实体
+     */
+    @Schema(description = "包含的数据")
+    private T data;
+
+    public T getData() {
+        return data;
+    }
+
+    public void setData(T data) {
+        this.data = data;
+    }
+
+    public static <T> MessageBean<T> ok() {
+        MessageBean<T> messageBean = new MessageBean<>();
+        messageBean.setStatus(true);
+        return messageBean;
+    }
+
+    public static <T> MessageBean<T> ok(T data, String message) {
+        MessageBean<T> messageBean = new MessageBean<>();
+        messageBean.setStatus(true);
+        messageBean.setData(data);
+        messageBean.setCode(200);
+        messageBean.setMessage(message);
+        return messageBean;
+    }
+
+    public static <T> MessageBean<T> error(String message) {
+        MessageBean<T> messageBean = new MessageBean<>();
+        messageBean.setStatus(false);
+        messageBean.setCode(-1);
+        messageBean.setMessage(message);
+        return messageBean;
+    }
+}

src/main/java/com/lqkj/cmlcp/message/MessageListBean.java

@@ -0,0 +1,68 @@
+package com.lqkj.cmlcp.message;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 服务器多个信息bean
+ * Created by free on 2017/7/27 0027.
+ */
+@Schema(description = "多个实体返回对象")
+public class MessageListBean<T> extends MessageBaseBean implements Serializable {
+
+    public MessageListBean() {
+        this.setTime(System.currentTimeMillis());
+    }
+
+    public MessageListBean(List<T> data) {
+        this.data = data;
+
+        this.setTime(System.currentTimeMillis());
+    }
+
+    /**
+     * 被包含的多个消息实体
+     */
+    @Schema(description = "包含的对象")
+    private List<T> data;
+
+    public List<T> getData() {
+        return data;
+    }
+
+    public void setData(List<T> data) {
+        this.data = data;
+    }
+
+    /**
+     * 增加一个数据
+     *
+     * @param data 数据
+     */
+    public void addData(T data) {
+        if (this.data == null) {
+            this.data = new ArrayList<T>(5);
+        }
+        this.data.add(data);
+    }
+
+    public static <T> MessageListBean<T> ok(List<T> data, String message) {
+        MessageListBean<T> messageListBean = new MessageListBean<>();
+        messageListBean.setStatus(true);
+        messageListBean.setData(data);
+        messageListBean.setCode(200);
+        messageListBean.setMessage(message);
+        return messageListBean;
+    }
+
+    public static <T> MessageListBean<T> error(String message) {
+        MessageListBean<T> messageListBean = new MessageListBean<>();
+        messageListBean.setStatus(false);
+        messageListBean.setCode(-1);
+        messageListBean.setMessage(message);
+        return messageListBean;
+    }
+}

src/main/java/com/lqkj/cmlcp/message/Result.java

@@ -0,0 +1,110 @@
+package com.lqkj.cmlcp.message;
+import lombok.Data;
+
+/**
+ * 全局统一返回结果类
+ */
+@Data
+//@ApiModel(value = "全局统一返回结果")
+public class Result<T> {
+
+    //@ApiModelProperty(value = "返回码")
+    private Integer code;
+
+    //@ApiModelProperty(value = "返回消息")
+    private String message;
+
+    //@ApiModelProperty(value = "返回数据")
+    private T data;
+
+    private Boolean success = true;    // 表示当前操作是成功还是失败 true:成功 false:失败
+
+    public Result(){}
+
+    protected static <T> Result<T> build(T data) {
+            Result<T> result = new Result<T>();
+            if (data != null)
+            result.setData(data);
+        return result;
+    }
+
+    public static <T> Result<T> build(T body, ResultCodeEnum resultCodeEnum, Boolean isSuccess) {
+        Result<T> result = build(body);
+        result.setCode(resultCodeEnum.getCode());
+        result.setMessage(resultCodeEnum.getMessage());
+        result.setSuccess(isSuccess);
+        return result;
+    }
+
+    public static <T> Result<T> build(Integer code, String message, Boolean isSuccess) {
+        Result<T> result = build(null);
+        result.setCode(code);
+        result.setMessage(message);
+        result.setSuccess(isSuccess);
+        return result;
+    }
+
+    private static <T> Result<T> build(T data, String msg, boolean isSuccess) {
+        Result<T> result = build(data);
+        result.setCode(200);
+        result.setMessage(msg);
+        result.setSuccess(isSuccess);
+        return result;
+    }
+
+    public static<T> Result<T> ok(){
+        return Result.ok(null);
+    }
+
+    public static <T> Result<T> me(Integer code, String message, Boolean isSuccess){
+        return build(code, message, isSuccess);
+    }
+
+    /**
+     * 操作成功
+     * @param data
+     * @param <T>
+     * @return
+     */
+    public static<T> Result<T> ok(T data){
+        return build(data, ResultCodeEnum.SUCCESS, true);
+    }
+
+    public static<T> Result<T> ok(T data, String msg){
+        return build(data, msg, true);
+    }
+
+
+
+    public static<T> Result<T> fail(){
+        return Result.fail(null);
+    }
+
+    /**
+     * 操作失败
+     * @param data
+     * @param <T>
+     * @return
+     */
+    public static<T> Result<T> fail(T data){
+        Result<T> result = build(data);
+        return build(data, ResultCodeEnum.FAIL, false);
+    }
+
+    public Result<T> message(String msg){
+        this.setMessage(msg);
+        return this;
+    }
+
+    public Result<T> code(Integer code){
+        this.setCode(code);
+        return this;
+    }
+
+    public boolean isOk() {
+        if(this.getCode().intValue() == ResultCodeEnum.SUCCESS.getCode().intValue()) {
+            return true;
+        }
+        return false;
+    }
+}

src/main/java/com/lqkj/cmlcp/message/ResultCodeEnum.java

@@ -0,0 +1,59 @@
+package com.lqkj.cmlcp.message;
+
+import lombok.Getter;
+
+/**
+ * 统一返回结果状态信息类
+ */
+@Getter
+public enum ResultCodeEnum {
+
+    SUCCESS(200,"成功"),
+    FAIL(201, "网络异常！请联系管理员！"),
+    PARAM_ERROR( 202, "参数不正确"),
+    SERVICE_ERROR(203, "服务异常"),
+    DATA_ERROR(204, "数据异常"),
+    DATA_UPDATE_ERROR(205, "数据版本异常"),
+
+    LOGIN_AUTH(208, "未登陆"),
+    PERMISSION(209, "没有权限"),
+
+    CODE_ERROR(210, "验证码错误"),
+//    LOGIN_MOBLE_ERROR(211, "账号不正确"),
+    LOGIN_DISABLED_ERROR(212, "改用户已被禁用"),
+    REGISTER_MOBLE_ERROR(213, "手机号已被使用"),
+    LOGIN_AURH(214, "需要登录"),
+    LOGIN_ACL(215, "没有权限"),
+
+    URL_ENCODE_ERROR( 216, "URL编码失败"),
+    ILLEGAL_CALLBACK_REQUEST_ERROR( 217, "非法回调请求"),
+    FETCH_ACCESSTOKEN_FAILD( 218, "获取accessToken失败"),
+    FETCH_USERINFO_ERROR( 219, "获取用户信息失败"),
+    //LOGIN_ERROR( 23005, "登录失败"),
+
+    PAY_RUN(220, "支付中"),
+    CANCEL_ORDER_FAIL(225, "取消订单失败"),
+    CANCEL_ORDER_NO(225, "不能取消预约"),
+
+    HOSCODE_EXIST(230, "医院编号已经存在"),
+    NUMBER_NO(240, "可预约号不足"),
+    TIME_NO(250, "当前时间不可以预约"),
+
+    SIGN_ERROR(300, "签名错误"),
+    HOSPITAL_OPEN(310, "医院未开通，暂时不能访问"),
+    HOSPITAL_LOCK(320, "医院被锁定，暂时不能访问"),
+
+    RESPONSE_CODE_400(400,"参数错误!"),
+    RESPONSE_CODE_400001(400001,"两次密码不一致,请检查后重新提交!"),
+    RESPONSE_CODE_400002(400002,"店铺已存在,请检查后重新提交!"),
+    RESPONSE_CODE_500(500,"网络异常!请稍后重试!");
+    ;
+
+    private Integer code;
+    private String message;
+
+    private ResultCodeEnum(Integer code, String message) {
+        this.code = code;
+        this.message = message;
+    }
+}

src/main/java/com/lqkj/cmlcp/module/authority/domain/RoleInfo.java

@@ -0,0 +1,39 @@
+package com.lqkj.cmlcp.module.authority.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.KeyType;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.*;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+import java.util.List;
+
+
+@Accessors(chain = true)
+@Data(staticConstructor = "create")
+@NoArgsConstructor
+@AllArgsConstructor
+public class RoleInfo {
+
+    @Id(keyType = KeyType.Auto)
+    @Schema(description = "角色ID")
+    private Integer roleId;
+
+    @Schema(description = "角色名称")
+    private String roleName;
+
+    @Schema(description = "")
+    private String enName;
+
+    @JsonFormat(pattern = "YYYY-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
+    private Date updateTime;
+
+    @Column(ignore = true)
+    private List<Integer> authorityList;
+
+    @Column(ignore = true)
+    private String auths;
+}

src/main/java/com/lqkj/cmlcp/module/authority/domain/UserInfo.java

@@ -0,0 +1,112 @@
+package com.lqkj.cmlcp.module.authority.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.KeyType;
+import com.mybatisflex.core.activerecord.Model;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+import org.springframework.security.core.GrantedAuthority;
+import org.springframework.security.core.userdetails.UserDetails;
+
+import java.util.Collection;
+import java.util.Date;
+import java.util.List;
+
+@Accessors(chain = true)
+@Data(staticConstructor = "create")
+@NoArgsConstructor
+@AllArgsConstructor
+public class UserInfo extends Model<UserInfo> implements UserDetails {
+
+	@Id(keyType = KeyType.Auto)
+	@Schema(description = "用户ID")
+	private Integer Id;
+
+	@Schema(description = "登录账号")
+	private String userCode;
+
+	@Schema(description = "显示名称")
+	private String displayName;
+
+	@Schema(description = "密码")
+	@JsonProperty(access = JsonProperty.Access.WRITE_ONLY)
+	private String password;
+
+	@Schema(description = "授权码")
+	private String authorizationCode;
+
+	@Schema(description = "头像图片地址")
+	private String headImg;
+
+	@Schema(description = "文件存储路径")
+	private String fileSavePath;
+
+	@Schema(description = "是否有审核权限")
+	private Boolean hasAuth;
+
+	@Schema(description = "是否锁定")
+	private Boolean locking;
+
+	@Schema(description = "登录错误次数")
+	private Integer loginErrorCount;
+
+	@Schema(description = "锁定时间")
+	@JsonFormat(pattern = "YYYY-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
+	private Date lockTime;
+
+	@JsonFormat(pattern = "YYYY-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
+	@Schema(description = "更新时间")
+	private Date updateTime;
+
+	@Schema(description = "是否能进入后台")
+	private Boolean hasManage;
+
+	@Schema(description = "角色列表")
+	private List<RoleInfo> roleInfoList;
+
+	@Schema(description = "角色ID数组")
+	private List<Integer> roleIds;
+
+	@Column(ignore = true)
+	private String roleNames;
+
+
+	/**
+	 * @Description 得到用户的角色列表
+	 */
+	@Column(ignore = true)
+    private Collection<? extends GrantedAuthority> authorities;
+	/**
+	 * 判断用户是否为过期
+	 */
+	@Column(ignore = true)
+    private boolean accountNonExpired = true;
+	/**
+	 * 判断用户是否为锁定
+	 */
+	@Column(ignore = true)
+    private boolean accountNonLocked = true;
+	/**
+	 * 判断密码是否未过期
+	 */
+	@Column(ignore = true)
+    private boolean credentialsNonExpired = true;
+	/**
+	 * 判断账户是否激活
+	 */
+	@Column(ignore = true)
+    private boolean enabled = true;
+
+
+	@Override
+	public String getUsername() {
+		return this.userCode;
+	}
+
+}

src/main/java/com/lqkj/cmlcp/module/authority/mapper/UserInfoMapper.java

@@ -0,0 +1,13 @@
+package com.lqkj.cmlcp.module.authority.mapper;
+
+import com.lqkj.cmlcp.module.authority.domain.UserInfo;
+import com.mybatisflex.core.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface UserInfoMapper extends BaseMapper<UserInfo> {
+    void initUserIdSeq();
+
+    void initSuperAdminRole();
+
+}

src/main/java/com/lqkj/cmlcp/module/authority/service/UserInfoService.java

@@ -0,0 +1,16 @@
+package com.lqkj.cmlcp.module.authority.service;
+
+import com.lqkj.cmlcp.module.authority.domain.UserInfo;
+import com.mybatisflex.core.service.IService;
+
+public interface UserInfoService extends IService<UserInfo> {
+    UserInfo findByUserCode(String userCode);
+
+    boolean isLocked(String userCode);
+
+    String lockedUser(String userCode);
+
+    void unlockedUser(String userCode);
+
+    UserInfo selectByUserName(String username);
+}

src/main/java/com/lqkj/cmlcp/module/authority/service/impl/DatabaseUserDetailService.java

@@ -0,0 +1,35 @@
+package com.lqkj.cmlcp.module.authority.service.impl;
+
+import com.lqkj.cmlcp.module.authority.domain.UserInfo;
+import com.lqkj.cmlcp.module.authority.service.UserInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.security.core.userdetails.UserDetailsService;
+import org.springframework.security.core.userdetails.UsernameNotFoundException;
+import org.springframework.stereotype.Service;
+
+@Service
+public class DatabaseUserDetailService implements UserDetailsService {
+
+    @Autowired
+    private UserInfoService userInfoService;
+
+
+    @Override
+    public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
+//        if (username.length() != 172) throw new UsernameNotFoundException("用户名错误！");
+//        try {
+//            username = RSAUtils.decryptBase64(username);
+//        } catch (Exception e) {
+//            throw new UsernameNotFoundException("用户名错误！");
+//        }
+        UserInfo userInfo = userInfoService.selectByUserName(username);
+        if (userInfo == null) {
+            throw new UsernameNotFoundException("用户名不存在！");
+        }
+        return userInfo;
+    }
+
+
+
+}

src/main/java/com/lqkj/cmlcp/module/authority/service/impl/UserInfoServiceImpl.java

@@ -0,0 +1,149 @@
+package com.lqkj.cmlcp.module.authority.service.impl;
+
+import com.lqkj.cmlcp.module.authority.domain.UserInfo;
+import com.lqkj.cmlcp.module.authority.mapper.UserInfoMapper;
+import com.lqkj.cmlcp.module.authority.service.UserInfoService;
+import com.mybatisflex.core.query.QueryWrapper;
+import com.mybatisflex.core.update.UpdateChain;
+import com.mybatisflex.spring.service.impl.ServiceImpl;
+import jakarta.annotation.PostConstruct;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.Date;
+import java.util.Objects;
+
+@Component
+public class UserInfoServiceImpl extends ServiceImpl<UserInfoMapper, UserInfo> implements UserInfoService{
+
+    @Autowired
+    private UserInfoMapper userInfoMapper;
+
+
+    @Override
+    public UserInfo findByUserCode(String userCode) {
+        return userInfoMapper.selectOneByQuery(new QueryWrapper().eq("user_code",userCode));
+    }
+
+        /**
+     * 账号是否锁定
+     * @param userCode
+     * @return
+     */
+    @Transactional
+    public boolean isLocked(String userCode) {
+        UserInfo userInfo = findByUserCode(userCode);
+        if (userInfo == null){
+            return false;
+        }else {
+            if (userInfo.getLocking()) {
+                if (new Date().getTime() - userInfo.getLockTime().getTime() > 1000 * 60 * 60){
+                    UpdateChain.of(UserInfo.class)
+                            .set(UserInfo::getLocking, false)
+                            .set(UserInfo::getLockTime, null)
+                            .set(UserInfo::getLoginErrorCount, 0)
+                            .where(UserInfo::getId).eq(userInfo.getId())
+                            .update();
+                    return false;
+                }else{
+                    return true;
+                }
+            }else{
+                return false;
+            }
+        }
+    }
+
+    /**
+     * 更新登录错误次数
+     * @param userCode
+     * @return
+     */
+    @Transactional
+    public String lockedUser(String userCode){
+        UserInfo userInfo = findByUserCode(userCode);
+        if (userInfo == null){
+            return "用户名或密码错误";
+        }else{
+            int loginErrorCount = userInfo.getLoginErrorCount() == null ? 0 : userInfo.getLoginErrorCount();
+            loginErrorCount += 1;
+            userInfo.setLoginErrorCount(loginErrorCount);
+            if (loginErrorCount == 4){
+                userInfo.setLocking(true);
+                userInfo.setLockTime(new Date());
+                userInfoMapper.update(userInfo);
+                return "账号已被冻结,请稍后重试";
+            }
+            userInfoMapper.update(userInfo);
+            return "账号、密码或授权码输入错误," + (4 - loginErrorCount) +"次错误后,账号将会冻结1小时";
+        }
+    }
+
+    /**
+     * 解锁用户
+     * @param userCode
+     */
+    @Transactional
+    public void unlockedUser(String userCode){
+        UserInfo userInfo = findByUserCode(userCode);
+        UpdateChain.of(UserInfo.class)
+                .set(UserInfo::getLocking, false)
+                .set(UserInfo::getLockTime, null)
+                .set(UserInfo::getLoginErrorCount, 0)
+                .where(UserInfo::getId).eq(userInfo.getId())
+                .update();
+    }
+
+    @Override
+    public UserInfo selectByUserName(String username) {
+        return userInfoMapper.selectOneByQuery(new QueryWrapper().eq("user_name",username));
+    }
+
+
+    @PostConstruct
+    @Transactional
+    public void initSuperUser() {
+        if (Objects.isNull(userInfoMapper.selectOneById(1))){
+            initSuperAdmin();
+            initUserIdSeq();
+            initSuperAdminRole();
+        }
+    }
+
+    private void initSuperAdmin() {
+        UserInfo userInfo = new UserInfo()
+                .setId(1)
+                .setUserCode("admin")
+                .setDisplayName("超级管理员")
+                .setPassword("$2a$10$OIBK8kKBDY07OS4CcVdx9e2GdxKH4T2lqWfDXgubjwZbxbis5.vSu")
+                .setAuthorizationCode("87449007")
+                .setHeadImg("")
+                .setFileSavePath("")
+                .setHasManage(true)
+                .setHasAuth(true)
+                .setLocking(false)
+                .setLockTime(null)
+                .setLoginErrorCount(0)
+                .setUpdateTime(new Date())
+                .setEnabled(true);
+        userInfoMapper.insert(userInfo);
+
+    }
+
+    private void initUserIdSeq() {
+        userInfoMapper.initUserIdSeq();
+    }
+
+    private void initSuperAdminRole() {
+
+        userInfoMapper.initSuperAdminRole();
+    }
+
+    private void test(){
+
+
+
+    }
+
+}

src/main/java/com/lqkj/cmlcp/module/base/controller/BaseController.java

@@ -0,0 +1,32 @@
+package com.lqkj.cmlcp.module.base.controller;
+
+
+import com.lqkj.cmlcp.message.Result;
+import com.lqkj.cmlcp.module.base.service.BaseService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+@RestController
+@RequestMapping("/base")
+public class BaseController {
+
+    @Autowired
+    private BaseService baseService;
+
+    @Operation(
+            summary = "5.1.3.33 空间信息json文件上传接口",
+            description = "5.1.3.33 空间信息json文件上传接口",
+            parameters = {
+                    @Parameter(name = "file", description = "空间信息json文件上传接口", required = true)
+            }
+    )
+    @PostMapping({"/addJsonFile"})
+    public Result<String> addJsonFile(MultipartFile file) {
+        return Result.ok(baseService.uploadJsonFile(file, "base/json/"));
+    }
+}

src/main/java/com/lqkj/cmlcp/module/base/service/BaseService.java

@@ -0,0 +1,9 @@
+package com.lqkj.cmlcp.module.base.service;
+
+import org.springframework.web.multipart.MultipartFile;
+
+public interface BaseService {
+
+
+    String uploadJsonFile(MultipartFile file, String s);
+}

src/main/java/com/lqkj/cmlcp/module/base/service/impl/BaseServiceImpl.java

@@ -0,0 +1,23 @@
+package com.lqkj.cmlcp.module.base.service.impl;
+
+import com.lqkj.cmlcp.message.Result;
+import com.lqkj.cmlcp.module.base.service.BaseService;
+import com.lqkj.cmlcp.utils.FileUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import java.util.UUID;
+
+@Service
+public class BaseServiceImpl implements BaseService {
+    @Override
+    public String uploadJsonFile(MultipartFile file, String path) {
+        String fileName = file.getOriginalFilename();
+        String suffix = fileName == null ? "" : fileName.substring(fileName.lastIndexOf(".") + 1);
+        if (!suffix.equals("json")) throw new RuntimeException("上传文件类型必须是json格式的json文件");
+        String newFileName = UUID.randomUUID() + "." + suffix;
+        String filePath = "./upload/" + path;
+        FileUtils.saveFile(file, filePath, newFileName);
+        return filePath.substring(1) + newFileName;
+    }
+}

src/main/java/com/lqkj/cmlcp/module/jwt/controller/JwtController.java

@@ -0,0 +1,97 @@
+package com.lqkj.cmlcp.module.jwt.controller;
+
+import com.lqkj.cmlcp.message.MessageBean;
+import com.lqkj.cmlcp.message.Result;
+import com.lqkj.cmlcp.module.authority.domain.LoginBody;
+import com.lqkj.cmlcp.module.authority.domain.UserInfo;
+import com.lqkj.cmlcp.module.authority.service.UserInfoService;
+import com.lqkj.cmlcp.module.jwt.service.JwtService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.servlet.http.HttpServletRequest;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.crypto.password.PasswordEncoder;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/jwt")
+@Tag(name = "授权服务", description = "授权服务")
+public class JwtController {
+
+    @Autowired
+    private  UserInfoService userInfoService;
+    private final JwtService jwtService;
+    private final PasswordEncoder passwordEncoder;
+
+    public JwtController(JwtService jwtService, PasswordEncoder passwordEncoder) {
+        this.jwtService = jwtService;
+        this.passwordEncoder = passwordEncoder;
+    }
+
+    @Operation(
+            summary = "5.1.1.2 登录接口",
+            description = "5.1.1.2 登录接口",
+            requestBody = @io.swagger.v3.oas.annotations.parameters.RequestBody(
+                    description = "登录信息对象",
+                    required = true,
+                    content = @Content(
+                            mediaType = "application/json",
+                            schema = @Schema(implementation = LoginBody.class)
+                    )
+            ))
+    @PostMapping("/token")
+    public Result<String> getToken(@RequestBody LoginBody loginBody){
+        String userCode = loginBody.getUsername();
+        String password = loginBody.getPassword();
+        String authCode = loginBody.getAuthCode();
+//        if (userCode.length() != 172 || password.length() != 172 || authCode.length() != 172) {
+//            return Result.fail("用户名或密码或授权码错误！");
+//        }
+//        userCode = RSAUtils.decryptBase64(userCode);
+//        password = RSAUtils.decryptBase64(password);
+//        authCode = RSAUtils.decryptBase64(authCode);
+
+        UserInfo userInfo = userInfoService.findByUserCode(userCode);
+        if (userInfo == null) {
+            return Result.fail("账号不存在！");
+        }
+        if (userInfoService.isLocked(userInfo.getUserCode())) {//账号是否被冻结
+            return Result.fail("账号已被冻结,请稍后重试！");
+        }
+        if (!passwordEncoder.matches(password, userInfo.getPassword())) {
+            return Result.fail(userInfoService.lockedUser(userInfo.getUserCode()));
+        }
+        if (!authCode.equals(userInfo.getAuthorizationCode())) {
+            return Result.fail("授权码错误！");
+        }
+        userInfoService.unlockedUser(userInfo.getUserCode());
+
+        return Result.ok(jwtService.generateToken(userCode));
+    }
+
+    @Operation(
+            summary = "5.1.1.4 刷新token接口",
+            description = "5.1.1.4 刷新token接口"
+    )
+    @PostMapping("/refreshToken")
+    public MessageBean<String> refreshToken(HttpServletRequest request) {
+        String authHeader = request.getHeader("Authorization");
+        String username = jwtService.decryptUsernameWithHeader(authHeader);
+        return MessageBean.ok(jwtService.generateToken(username), "刷新token");
+
+    }
+
+    @Operation(
+            summary = "直接获取ADMIN-TOKEN",
+            description = "直接获取ADMIN-TOKEN"
+    )
+    @PostMapping("/getAdminToken")
+    public Result<String> getAdminToken() {
+        return Result.ok(jwtService.generateToken("meta-link"), "获取ADMIN-TOKEN");
+    }
+}

src/main/java/com/lqkj/cmlcp/module/jwt/service/JwtService.java

@@ -0,0 +1,80 @@
+package com.lqkj.cmlcp.module.jwt.service;
+
+import com.lqkj.cmlcp.utils.RSAUtils;
+import io.jsonwebtoken.Claims;
+import io.jsonwebtoken.Jwts;
+import io.jsonwebtoken.SignatureAlgorithm;
+import io.jsonwebtoken.io.Decoders;
+import io.jsonwebtoken.security.Keys;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.stereotype.Component;
+
+import java.security.Key;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.function.Function;
+
+@Component
+public class JwtService {
+
+
+    public static final String SECRET = "zdvilXBILaMtQVtcJQ19ovIAo6GE1fEreTVYFXU1TZXg42Cc6AacW9fC1LV0u5Pc";
+
+
+    public String extractUsername(String token) {
+        return extractClaim(token, Claims::getSubject);
+    }
+
+    public String decryptUsernameWithHeader(String header) {
+        String token = header.substring(7);
+        return RSAUtils.decryptBase64(extractUsername(token));
+    }
+
+    public Date extractExpiration(String token) {
+        return extractClaim(token, Claims::getExpiration);
+    }
+
+    public <T> T extractClaim(String token, Function<Claims, T> claimsResolver) {
+        final Claims claims = extractAllClaims(token);
+        return claimsResolver.apply(claims);
+    }
+
+    private Claims extractAllClaims(String token) {
+        return Jwts
+                .parserBuilder()
+                .setSigningKey(getSignKey())
+                .build()
+                .parseClaimsJws(token)
+                .getBody();
+    }
+
+    private Boolean isTokenExpired(String token) {
+        return extractExpiration(token).before(new Date());
+    }
+
+    public Boolean validateToken(String token, UserDetails userDetails) {
+        final String username = extractUsername(token);
+        return (RSAUtils.decryptBase64(username).equals(userDetails.getUsername()) && !isTokenExpired(token));
+    }
+
+
+    public String generateToken(String userName){
+        Map<String,Object> claims=new HashMap<>();
+        return createToken(claims,userName);
+    }
+
+    private String createToken(Map<String, Object> claims, String userName) {
+        return Jwts.builder()
+                .setClaims(claims)
+                .setSubject(RSAUtils.encryptBase64(userName))
+                .setIssuedAt(new Date(System.currentTimeMillis()))
+                .setExpiration(new Date(System.currentTimeMillis()+1000*60*30))
+                .signWith(getSignKey(), SignatureAlgorithm.HS256).compact();
+    }
+
+    private Key getSignKey() {
+        byte[] keyBytes= Decoders.BASE64.decode(SECRET);
+        return Keys.hmacShaKeyFor(keyBytes);
+    }
+}

src/main/java/com/lqkj/cmlcp/module/test/controller/TestController.java

@@ -0,0 +1,29 @@
+package com.lqkj.cmlcp.module.test.controller;
+
+import com.lqkj.cmlcp.message.Result;
+import com.lqkj.cmlcp.module.test.service.CaptchaService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/test")
+public class TestController {
+
+    @Autowired
+    private CaptchaService captchaService;
+
+    @GetMapping("/test1")
+    public Result test1() {
+        var captcha = captchaService.findAll();
+        return Result.ok(captcha);
+    }
+
+    @PostMapping("/test2")
+    public Result test2() {
+        var captcha = captchaService.findById();
+        return Result.ok(captcha);
+    }
+}

src/main/java/com/lqkj/cmlcp/module/test/domain/Captcha.java

@@ -0,0 +1,33 @@
+package com.lqkj.cmlcp.module.test.domain;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+
+
+@Accessors(chain = true)
+@Data(staticConstructor = "create")
+@NoArgsConstructor
+@AllArgsConstructor
+public class Captcha {
+
+    private static final long serialVersionUID = 1L;
+
+    @Schema(description = "验证码id")
+    private Long id;
+
+    @Schema(description = "验证码")
+    private String code;
+
+    @Schema(description = "手机号")
+    private String phoneNumber;
+
+    @JsonFormat(pattern = "YYYY-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
+    private Date createTime;
+
+}

src/main/java/com/lqkj/cmlcp/module/test/mapper/CaptchaMapper.java

@@ -0,0 +1,9 @@
+package com.lqkj.cmlcp.module.test.mapper;
+
+import com.lqkj.cmlcp.module.test.domain.Captcha;
+import com.mybatisflex.core.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface CaptchaMapper extends BaseMapper<Captcha> {
+}

src/main/java/com/lqkj/cmlcp/module/test/service/CaptchaService.java

@@ -0,0 +1,12 @@
+package com.lqkj.cmlcp.module.test.service;
+
+import com.lqkj.cmlcp.module.test.domain.Captcha;
+import com.mybatisflex.core.service.IService;
+
+import java.util.List;
+
+public interface CaptchaService extends IService<Captcha> {
+    List<Captcha> findAll();
+
+    Captcha findById();
+}

src/main/java/com/lqkj/cmlcp/module/test/service/impl/CaptchaServiceImpl.java

@@ -0,0 +1,44 @@
+package com.lqkj.cmlcp.module.test.service.impl;
+
+import com.lqkj.cmlcp.module.test.domain.Captcha;
+import com.lqkj.cmlcp.module.test.mapper.CaptchaMapper;
+import com.lqkj.cmlcp.module.test.service.CaptchaService;
+import com.mybatisflex.spring.service.impl.ServiceImpl;
+import jakarta.annotation.Resource;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Objects;
+
+
+@Service
+@Transactional(propagation = Propagation.SUPPORTS, readOnly = true)
+public class CaptchaServiceImpl extends ServiceImpl<CaptchaMapper, Captcha> implements CaptchaService {
+    @Autowired
+    private CaptchaMapper captchaMapper;
+
+    @Resource
+    private RedisTemplate<String, List<Captcha>> redisTemplate;
+
+
+    @Override
+    public List<Captcha> findAll() {
+        var test = redisTemplate.opsForValue().get("test");
+        if (Objects.nonNull(test)){
+            return test;
+        }
+        var list = super.list();
+        redisTemplate.opsForValue().set("test",list);
+        return super.list();
+
+    }
+
+    @Override
+    public Captcha findById() {
+        return captchaMapper.selectOneById(1);
+    }
+}

src/main/java/com/lqkj/cmlcp/utils/FileUtils.java

@@ -0,0 +1,182 @@
+package com.lqkj.cmlcp.utils;
+
+import org.springframework.web.multipart.MultipartFile;
+
+import java.io.*;
+import java.net.URL;
+import java.net.URLConnection;
+import java.util.ArrayList;
+import java.util.Base64;
+import java.util.List;
+
+/**
+ * @ClassName FileUtils
+ * @Description: TODO
+ * @Author wells
+ * @Date 2019/11/29 9:22
+ * @Version V1.0
+ **/
+public class FileUtils {
+
+    public static void dirCopy(File src, String destPath) throws Exception {
+        if (!new File(destPath).exists()) {
+            new File(destPath).mkdirs();
+        }
+        for (File s : src.listFiles()) {
+            if (s.isFile()) {
+                fileCopy(s.getPath(), destPath + File.separator + s.getName());
+            } else {
+                dirCopy(s, destPath + File.separator + s.getName());
+            }
+        }
+    }
+
+    public static void fileCopy(String srcPath, String destPath) throws IOException {
+        File src = new File(srcPath);
+        File dest = new File(destPath);
+        try (InputStream is = new BufferedInputStream(new FileInputStream(src));
+             OutputStream out = new BufferedOutputStream(new FileOutputStream(dest))) {
+            byte[] flush = new byte[1024];
+            int len = -1;
+            while ((len = is.read(flush)) != -1) {
+                out.write(flush, 0, len);
+            }
+            out.flush();
+        } catch (FileNotFoundException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static void fileCopyIn(InputStream srcIn, String destPath, String fileName) {
+        if (!new File(destPath).exists()) {
+            new File(destPath).mkdirs();
+        }
+        File dest = new File(destPath + fileName);
+        try (
+                OutputStream out = new BufferedOutputStream(new FileOutputStream(dest))) {
+            byte[] flush = new byte[1024];
+            int len = -1;
+            while ((len = srcIn.read(flush)) != -1) {
+                out.write(flush, 0, len);
+            }
+            out.flush();
+        } catch (FileNotFoundException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 将base64字符解码保存文件
+     *
+     * @param base64Code
+     * @param targetPath
+     * @throws Exception
+     */
+
+    public static void decoderBase64File(String base64Code, String targetPath)
+            throws Exception {
+        File file = new File(targetPath.substring(0, targetPath.lastIndexOf("/")));
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+        byte[] buffer = Base64.getDecoder().decode(base64Code);
+        FileOutputStream out = new FileOutputStream(targetPath);
+        out.write(buffer);
+        out.close();
+    }
+
+    /**
+     * 判断是否为图片格式
+     *
+     * @param fileExtension
+     * @return
+     */
+    public static Boolean isImgFile(String fileExtension) {
+        if (fileExtension.toLowerCase().contains("jpg") || fileExtension.toLowerCase().contains("jpeg") || fileExtension.toLowerCase().contains("png")
+                || fileExtension.contains("gif")) {
+            return true;
+        }
+        return false;
+    }
+
+    public static void downloadFile(String url, String targetPath) throws Exception {
+        File file = new File(targetPath.substring(0, targetPath.lastIndexOf("/")));
+        if (!file.exists()) {
+            file.mkdirs();
+        }
+
+        URL downloadUrl = new URL(url);
+        // 下载网络文件
+        int bytesum = 0;
+        int byteread = 0;
+        try {
+            URLConnection conn = downloadUrl.openConnection();
+            InputStream inStream = conn.getInputStream();
+            FileOutputStream fs = new FileOutputStream(targetPath);
+
+            byte[] buffer = new byte[1024];
+            while ((byteread = inStream.read(buffer)) != -1) {
+                bytesum += byteread;
+                System.out.println(bytesum);
+                fs.write(buffer, 0, byteread);
+            }
+        } catch (FileNotFoundException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 保存上传的文件到本地
+     *
+     * @param file 被删除文件的文件名
+     * @param path 保存路径
+     * @return 保存后的文件
+     */
+    public static File saveFile(MultipartFile file, String path, String name) {
+        try (InputStream inputStream = file.getInputStream()) {
+            File writeFile = new File(path + name);
+            org.apache.commons.io.FileUtils.copyInputStreamToFile(inputStream, writeFile);
+            return writeFile;
+        } catch (Exception e) {
+            return null;
+        }
+    }
+
+    public static List<File> searchFiles(File folder, final String keyword) {
+        List<File> result = new ArrayList<File>();
+        if (folder.isFile())
+            result.add(folder);
+
+        File[] subFolders = folder.listFiles(new FileFilter() {
+            @Override
+            public boolean accept(File file) {
+                if (file.isDirectory()) {
+                    return true;
+                }
+                if (file.getName().toLowerCase().contains(keyword)) {
+                    return true;
+                }
+                return false;
+            }
+        });
+
+        if (subFolders != null) {
+            for (File file : subFolders) {
+                if (file.isFile()) {
+                    // 如果是文件则将文件添加到结果列表中
+                    result.add(file);
+                } else {
+                    // 如果是文件夹，则递归调用本方法，然后把所有的文件加到结果列表中
+                    result.addAll(searchFiles(file, keyword));
+                }
+            }
+        }
+        return result;
+    }
+}

src/main/java/com/lqkj/cmlcp/utils/RSAUtils.java

@@ -0,0 +1,124 @@
+package com.lqkj.cmlcp.utils;
+
+import javax.crypto.Cipher;
+import java.nio.charset.StandardCharsets;
+import java.security.*;
+import java.security.spec.InvalidKeySpecException;
+import java.security.spec.X509EncodedKeySpec;
+import java.util.Base64;
+
+/**
+ * @ClassName RSAUtils
+ * @Description TODO
+ * @Author wells
+ * @Date 2021/3/2 11:37 上午
+ * @Version 1.0
+ **/
+public class RSAUtils {
+    //KeyPair is a simple holder for a key pair.
+    private static final KeyPair keyPair = initKey();
+
+
+
+    /**
+     * 初始化方法，产生key pair，提供provider和random
+     *
+     * @return KeyPair instance
+     */
+    private static KeyPair initKey() {
+        try {
+            //添加provider
+            //产生用于安全加密的随机数
+            SecureRandom random = new SecureRandom();
+            KeyPairGenerator generator = KeyPairGenerator.getInstance("RSA");
+            generator.initialize(1024, random);
+            return generator.generateKeyPair();
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    /**
+     * 产生public key
+     *
+     * @return public key字符串
+     */
+    public static String generateBase64PublicKey() {
+        PublicKey publicKey = keyPair.getPublic();
+        //encodeBase64(): Encodes binary data using the base64
+        //algorithm but does not chunk the output.
+        //getEncoded():返回key的原始编码形式
+        return Base64.getEncoder().encodeToString(publicKey.getEncoded());
+    }
+
+    /**
+     * 解密数据
+     *
+     * @param string 需要解密的字符串
+     * @return 破解之后的字符串
+     */
+    public static String decryptBase64(String string) {
+        //decodeBase64():将Base64数据解码为"八位字节”数据
+        return new String(decrypt(Base64.getDecoder().decode(string.getBytes())));
+    }
+    public static String encryptBase64(String str) {
+        return Base64.getEncoder().encodeToString(encrypt(str.getBytes(StandardCharsets.UTF_8)));
+    }
+
+    public static String encryptBase64(String str, String publicKey) {
+        return Base64.getEncoder().encodeToString(encrypt(str.getBytes(StandardCharsets.UTF_8), publicKey));
+    }
+
+    private static byte[] encrypt(byte[] byteArray){
+        try {
+
+            Cipher cipher = Cipher.getInstance("RSA");
+            PublicKey publicKey = keyPair.getPublic();
+            cipher.init(Cipher.ENCRYPT_MODE, publicKey);
+            return cipher.doFinal(byteArray);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    private static byte[] decrypt(byte[] byteArray) {
+        try {
+
+            //Cipher: 提供加密和解密功能的实例
+            //transformation: "algorithm/mode/padding"
+            Cipher cipher = Cipher.getInstance("RSA");
+            PrivateKey privateKey = keyPair.getPrivate();
+            //初始化
+            cipher.init(Cipher.DECRYPT_MODE, privateKey);
+            //doFinal(): 加密或者解密数据
+            return cipher.doFinal(byteArray);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    private static byte[] encrypt(byte[] byteArray, String publicKey){
+        try {
+
+            Cipher cipher = Cipher.getInstance("RSA");
+            cipher.init(Cipher.ENCRYPT_MODE, getPublicKey(publicKey));
+            return cipher.doFinal(byteArray);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    private static PublicKey getPublicKey(String key) throws NoSuchAlgorithmException, InvalidKeySpecException {
+        byte[] keyBytes = Base64.getDecoder().decode(key);
+        X509EncodedKeySpec keySpec = new X509EncodedKeySpec(keyBytes);
+        KeyFactory keyFactory = KeyFactory.getInstance("RSA");
+        return keyFactory.generatePublic(keySpec);
+    }
+
+    public static void main(String[] args) {
+        String s = RSAUtils.encryptBase64("9wytyRIgskPdprmHvb13kJJpUv78=");
+        System.out.println(s);
+        String a = RSAUtils.decryptBase64(s);
+        System.out.println(a);
+    }
+}

src/main/resources/application-install.yml

@@ -0,0 +1,78 @@
+server:
+  address: 192.168.4.219
+  servlet:
+    context-path: /cmlcp-server
+  port: 9999
+  error:
+    include-exception: true
+  compression:
+    enabled: false
+  tomcat:
+    max-connections: 1000
+    max-swallow-size: 1000MB
+    max-http-form-post-size: 1000MB
+spring:
+  data:
+    redis:
+      host: 127.0.0.1
+      database: 0
+      port: 6379
+      connect-timeout: 10s
+      lettuce:
+        pool:
+          # 连接池最大连接数
+          max-active: 200
+          # 连接池最大阻塞等待时间（使用负值表示没有限制）
+          max-wait: -1ms
+          # 连接池中的最大空闲连接
+          max-idle: 10
+          # 连接池中的最小空闲连接
+          min-idle: 0
+  application:
+    name: CMLCP-SERVER
+  servlet:
+    multipart:
+      max-file-size: 1000MB
+      max-request-size: 1000MB
+      file-size-threshold: 10MB
+  jdbc:
+    template:
+      query-timeout: 20s
+  datasource:
+    hikari:
+      driver-class-name: org.postgresql.Driver
+      username: postgres
+      password: lqkj!@#456
+      auto-commit: true
+      pool-name: link
+      minimum-idle: 4
+      maximum-pool-size: 200
+      idle-timeout: 60000
+      max-lifetime: 1800000
+      connection-timeout: 30000
+      read-only: false
+    url: jdbc:postgresql://192.168.4.241:5432/dev_cmlcp
+  flyway:
+    baseline-on-migrate: true
+    enabled: true
+    validate-on-migrate: false
+  web:
+    resources:
+      cache:
+        cachecontrol:
+          cache-public: true
+          max-age: 0s
+      chain:
+        cache: true
+        enabled: true
+logging:
+  register-shutdown-hook: true
+  level:
+    org.springframework.boot: info
+    org.ehcache.impl.internal.store.heap.OnHeapStore: error
+    org.apache.coyote.http11.Http11InputBuffer: debug
+    org.hibernate.SQL: debug
+    io.swagger.models.parameters.AbstractSerializableParameter: error
+  file:
+    name: ./log/link.log
+    path: classpath:log4j2.xml

src/main/resources/com/lqkj/cmlcp/module/authority/mapper/UserInfoMapper.xml

@@ -0,0 +1,13 @@
+<?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.lqkj.cmlcp.module.authority.mapper.UserInfoMapper">
+
+    <insert id="initSuperAdminRole">
+        insert into user_role values (1, 1)
+    </insert>
+
+    <select id="initUserIdSeq">
+        ALTER SEQUENCE user_info_id_seq RESTART WITH 3
+    </select>
+
+</mapper>

src/main/resources/com/lqkj/cmlcp/module/test/mapper/CaptchaMapper.xml

@@ -0,0 +1,4 @@
+<?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.lqkj.cmlcp.module.test.mapper.CaptchaMapper">
+</mapper>

src/main/resources/db/migration/V1__INIT.sql

@@ -0,0 +1,164 @@
+create table authority_info (
+                                authority_id         INT4                 not null,
+                                parent_id            INT4                 null,
+                                authority_name       VARCHAR(255)         null,
+                                en_name              VARCHAR(255)         null,
+                                route                VARCHAR(255)         null,
+                                component            VARCHAR(255)         null,
+                                redirect             VARCHAR(255)         null,
+                                icon                 VARCHAR(255)         null,
+                                order_id             INT4                 null,
+                                constraint PK_AUTHORITY_INFO primary key (authority_id)
+);
+
+comment on table authority_info is
+'权限信息：authority_info';
+
+comment on column authority_info.authority_id is
+'权限ID：authority_id';
+
+comment on column authority_info.parent_id is
+'父权限ID：parent_id';
+
+comment on column authority_info.authority_name is
+'权限名称：authority_name';
+
+comment on column authority_info.en_name is
+'英文名：en_name';
+
+comment on column authority_info.route is
+'路由地址：route';
+
+comment on column authority_info.component is
+'组件：component';
+
+comment on column authority_info.redirect is
+'重定向地址：redirect';
+
+comment on column authority_info.icon is
+'图标：icon';
+
+comment on column authority_info.order_id is
+'排序：order_id';
+
+create table role_authority (
+                                role_id              INT4                 not null,
+                                authority_id         INT4                 not null,
+                                constraint PK_ROLE_AUTHORITY primary key (role_id, authority_id)
+);
+comment on table role_authority is
+'角色权限信息：role_authority';
+
+comment on column role_authority.role_id is
+'角色ID：role_id';
+
+comment on column role_authority.authority_id is
+'权限ID：authority_id';
+insert into role_authority select 1,  generate_series (1, 11);
+
+create table role_info (
+                           role_id              SERIAL               not null,
+                           role_name            VARCHAR(255)         null,
+                           en_name              VARCHAR(255)         null,
+                           update_time          TIMESTAMP            null,
+                           constraint PK_ROLE_INFO primary key (role_id)
+);
+comment on table role_info is
+'角色信息：role_info';
+
+comment on column role_info.role_id is
+'角色ID：role_id';
+
+comment on column role_info.role_name is
+'角色名称：role_name';
+
+comment on column role_info.en_name is
+'英文名称：en_name';
+
+comment on column role_info.update_time is
+'更新时间：update_time';
+
+insert into role_info values
+    (1, '超级管理员', 'superAdmin', now());
+
+select nextval('role_info_role_id_seq');
+
+/*==============================================================*/
+/* Table: user_info                                             */
+/*==============================================================*/
+create table user_info (
+   id              SERIAL               not null,
+   user_code            VARCHAR(255)         null,
+   display_name         VARCHAR(255)         null,
+   password             VARCHAR(255)         null,
+   authorization_code   VARCHAR(64)          null,
+   head_img             VARCHAR(1024)        null,
+   file_save_path       VARCHAR(1024)        null,
+   has_auth             BOOL                 null,
+   login_error_count    INT4                 null,
+   locking              BOOL                 null,
+   lock_time            TIMESTAMP            null,
+   update_time          TIMESTAMP            null,
+   has_manage           BOOLEAN              null,
+   constraint PK_USER_INFO primary key (id)
+);
+comment on table user_info is
+'用户信息：user_info';
+
+comment on column user_info.id is
+'用户ID：user_id';
+
+comment on column user_info.user_code is
+'登录账号：user_code';
+
+comment on column user_info.display_name is
+'显示名称：display_name';
+
+comment on column user_info.password is
+'登录密码：password';
+
+comment on column user_info.authorization_code is
+'授权码：authorization_code';
+
+comment on column user_info.head_img is
+'头像：head_img';
+
+comment on column user_info.file_save_path is
+'文件保存路径：file_save_path';
+
+comment on column user_info.has_auth is
+'是否有审核权限：has_auth';
+
+comment on column user_info.login_error_count is
+'登录错误次数：login_error_count';
+
+comment on column user_info.locking is
+'是否锁定：locking';
+
+comment on column user_info.lock_time is
+'锁定时间：lock_time';
+
+comment on column user_info.update_time is
+'更新时间：update_time';
+
+comment on column user_info.has_manage is
+'能否进入管理后台：has_manage';
+
+
+/*==============================================================*/
+/* Table: user_role                                             */
+/*==============================================================*/
+create table user_role (
+                           role_id              INT4                 not null,
+                           user_id              INT4                 not null,
+                           constraint PK_USER_ROLE primary key (role_id, user_id)
+);
+
+comment on table user_role is
+'用户角色：user_role';
+
+comment on column user_role.role_id is
+'角色ID：role_id';
+
+comment on column user_role.user_id is
+'用户ID：user_id';

src/main/resources/log4j2.xml

@@ -0,0 +1,47 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!-- 设置log4j2的自身log级别为warn -->
+<!-- OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->
+<Configuration status="OFF">
+    <Properties>
+        <Property name="LOG_PATH">./log</Property>
+        <Property name="LOG_FILE">./log/cmccr2.log</Property>
+        <Property name="PID">????</Property>
+        <Property name="LOG_EXCEPTION_CONVERSION_WORD">%xwEx</Property>
+        <Property name="LOG_LEVEL_PATTERN">%5p</Property>
+        <Property name="LOG_DATEFORMAT_PATTERN">yyyy-MM-dd HH:mm:ss.SSS</Property>
+        <Property name="CONSOLE_LOG_PATTERN">%clr{%d{${LOG_DATEFORMAT_PATTERN}}}{faint} %clr{${LOG_LEVEL_PATTERN}} %clr{${sys:PID}}{magenta} %clr{---}{faint} %clr{[%15.15t]}{faint} %clr{%-40.40c{1.}}{cyan} %clr{:}{faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD}</Property>
+        <Property name="FILE_LOG_PATTERN">%d{${LOG_DATEFORMAT_PATTERN}} ${LOG_LEVEL_PATTERN} ${sys:PID} --- [%t] %-40.40c{1.} : %m%n${LOG_EXCEPTION_CONVERSION_WORD}</Property>
+    </Properties>
+    <Appenders>
+        <Console name="Console" target="SYSTEM_OUT" follow="true" immediateFlush="false">
+            <PatternLayout pattern="${CONSOLE_LOG_PATTERN}" />
+        </Console>
+        <RollingFile name="File" fileName="${LOG_FILE}" filePattern="${LOG_PATH}/$${date:yyyy-MM}/app-%d{yyyy-MM-dd-HH}-%i.log.gz" immediateFlush="false">
+            <PatternLayout>
+                <Pattern>${FILE_LOG_PATTERN}</Pattern>
+            </PatternLayout>
+            <Policies>
+                <SizeBasedTriggeringPolicy size="10 MB" />
+            </Policies>
+        </RollingFile>
+    </Appenders>
+
+    <Loggers>
+        <Logger name="org.apache.catalina.startup.DigesterFactory" level="info" />
+        <Logger name="org.apache.catalina.util.LifecycleBase" level="info" />
+        <Logger name="org.apache.coyote.http11.Http11NioProtocol" level="info" />
+        <logger name="org.apache.sshd.common.util.SecurityUtils" level="info"/>
+        <Logger name="org.apache.tomcat.util.net.NioSelectorPool" level="info" />
+        <Logger name="org.eclipse.jetty.util.component.AbstractLifeCycle" level="info" />
+        <Logger name="org.hibernate.validator.internal.util.Version" level="info" />
+        <logger name="org.springframework.boot.actuate.endpoint.jmx" level="info"/>
+        <logger name="com.apache.ibatis" level="info"/>
+        <logger name="java.sql.Connection" level="info"/>
+        <logger name="java.sql.Statement" level="info"/>
+        <logger name="java.sql.PreparedStatement" level="info"/>
+        <AsyncRoot level="info" additivity="false">
+            <AppenderRef ref="Console"/>
+            <AppenderRef ref="File"/>
+        </AsyncRoot>
+    </Loggers>
+</Configuration>

src/test/java/com/lqkj/cmlcp/CmlcpServerApplicationTests.java

@@ -0,0 +1,13 @@
+package com.lqkj.cmlcp;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class CmlcpServerApplicationTests {
+
+    @Test
+    void contextLoads() {
+    }
+
+}