Initial commit

.gitignore

+*.iml
+node_modules/
+.idea/
+*.class
+target/
+dist/
\ No newline at end of file

agent-manager/.gitignore

+*.iml
+node_modules/
+.idea/
+*.class
+target/
\ No newline at end of file

agent-manager/pom.xml

+<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>com.mortals.xhx</groupId>
+		<artifactId>agent-platform</artifactId>
+		<version>1.0.0-SNAPSHOT</version>
+	</parent>
+
+	<artifactId>agent-manager</artifactId>
+	<packaging>jar</packaging>
+	<description>代办帮办服务管理平台</description>
+
+
+	<properties>
+		<!-- 默认值 -->
+		<profiles.server.debug></profiles.server.debug>
+		<profiles.nacos.group>DEFAULT_GROUP</profiles.nacos.group>
+		<profiles.nacos.namespace>smart-gov</profiles.nacos.namespace>
+		<profiles.server.port>18009</profiles.server.port>
+		<profiles.log.path>/home/mortals/app/logs</profiles.log.path>
+		<profiles.log.level>info</profiles.log.level>
+		<profiles.publish.path>/home/publish</profiles.publish.path>
+		<profiles.filepath>/mortals/app/data</profiles.filepath>
+		<skipDeploy>true</skipDeploy>
+	</properties>
+
+
+	<profiles>
+		<profile>
+			<id>develop</id>
+			<activation>
+				<activeByDefault>true</activeByDefault>
+			</activation>
+			<properties>
+				<profiles.active>develop</profiles.active>
+				<profiles.nacos.server-addr>127.0.0.1:8848</profiles.nacos.server-addr>
+			</properties>
+		</profile>
+		<profile>
+			<id>test</id>
+			<properties>
+				<profiles.active>test</profiles.active>
+				<profiles.server.debug>-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=6517</profiles.server.debug>
+				<profiles.nacos.server-addr>192.168.0.252:8848</profiles.nacos.server-addr>
+			</properties>
+		</profile>
+
+		<profile>
+			<id>product</id>
+			<properties>
+				<profiles.active>product</profiles.active>
+				<profiles.server.debug>-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=6517</profiles.server.debug>
+				<profiles.nacos.server-addr>127.0.0.1:8848</profiles.nacos.server-addr>
+			</properties>
+		</profile>
+
+	</profiles>
+
+	<dependencies>
+		<dependency>
+			<groupId>com.mortals.xhx</groupId>
+			<artifactId>common-lib</artifactId>
+		</dependency>
+
+		<!-- 引入 SpringMVC 相关依赖，并实现对其的自动配置 -->
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>druid-spring-boot-starter</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.mybatis.spring.boot</groupId>
+			<artifactId>mybatis-spring-boot-starter</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-websocket</artifactId>
+			<version>2.5.2</version>
+		</dependency>
+		<dependency>
+			<groupId>mysql</groupId>
+			<artifactId>mysql-connector-java</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.data</groupId>
+			<artifactId>spring-data-redis</artifactId>
+		</dependency>
+
+		<!--Token生成与解析-->
+		<dependency>
+			<groupId>io.jsonwebtoken</groupId>
+			<artifactId>jjwt</artifactId>
+		</dependency>
+
+
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<scope>test</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-webflux</artifactId>
+		</dependency>
+
+	</dependencies>
+
+
+	<build>
+		<resources>
+			<resource>
+				<directory>src/main/resources</directory>
+				<filtering>true</filtering>
+			</resource>
+		</resources>
+
+		<plugins>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-surefire-plugin</artifactId>
+				<version>2.19.1</version>
+				<configuration>
+					<skipTests>true</skipTests>    <!--默认关掉单元测试 -->
+				</configuration>
+			</plugin>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<configuration>
+					<source>${java.version}</source>
+					<target>${java.version}</target>
+					<encoding>${project.build.sourceEncoding}</encoding>
+				</configuration>
+			</plugin>
+
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-resources-plugin</artifactId>
+				<executions>
+					<execution>
+						<id>copy-bin</id>
+						<phase>package</phase>
+						<goals>
+							<goal>copy-resources</goal>
+						</goals>
+						<configuration>
+							<encoding>UTF-8</encoding>
+							<outputDirectory>target/bin
+							</outputDirectory>
+							<resources>
+								<resource>
+									<directory>src/main/bin/</directory>
+									<excludes>
+										<exclude>deploy.sh</exclude>
+									</excludes>
+									<filtering>true</filtering>
+								</resource>
+							</resources>
+						</configuration>
+					</execution>
+
+					<execution>
+						<id>copy-deploy</id>
+						<phase>package</phase>
+						<goals>
+							<goal>copy-resources</goal>
+						</goals>
+						<configuration>
+							<encoding>UTF-8</encoding>
+							<outputDirectory>${project.parent.basedir}/dist/${project.artifactId}/
+							</outputDirectory>
+							<resources>
+								<resource>
+									<directory>src/main/bin</directory>
+									<includes>
+										<include>deploy.sh</include>
+									</includes>
+									<filtering>true</filtering>
+								</resource>
+							</resources>
+						</configuration>
+					</execution>
+				</executions>
+			</plugin>
+
+			<plugin>
+				<artifactId>maven-assembly-plugin</artifactId>
+				<version>3.3.0</version>
+				<executions>
+					<execution>
+						<id>make-assembly</id>
+						<phase>package</phase>
+						<goals>
+							<goal>single</goal>
+						</goals>
+						<configuration>
+							<finalName>${project.artifactId}</finalName>
+							<appendAssemblyId>false</appendAssemblyId>
+							<descriptors>
+								<descriptor>../assembly/assembly.xml</descriptor>
+							</descriptors>
+							<outputDirectory>${project.parent.basedir}/dist/${project.artifactId}</outputDirectory>
+						</configuration>
+					</execution>
+				</executions>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>

agent-manager/src/main/bin/check_server.sh

+#!/bin/bash
+PORT="@profiles.server.port@"
+PROJECT_NAME="@project.artifactId@";
+MAIN_CLASS="$PROJECT_NAME-@project.version@.jar";
+SHELL_NAME=$0
+SHELL_LOG="${SHELL_NAME}.log"
+
+LOG_DATE='date "+%Y-%m-%d"'
+LOG_TIME='date "+%H-%M-%S"'
+
+CDATE=$(date "+%Y-%m-%d")
+CTIME=$(date "+%H-%M-%S")
+
+#写日志
+writelog() {
+  LOGINFO=$1
+  echo "${CDATE} ${CTIME}: ${SHELL_NAME} : ${LOGINFO}" >>${SHELL_LOG}
+}
+jcpid=`ps -ef | grep -v "grep" | grep "$MAIN_CLASS" | grep "app.port=$PORT" | sed -n '1P' | awk '{print $2}'`
+
+if [ $jcpid ]; then
+		writelog "The $PROJECT_NAME start finished, PID is $jcpid"
+		exit $SUCCESS
+	else
+    writelog "start service..."
+    systemctl stop ${PROJECT_NAME} && systemctl start ${PROJECT_NAME}
+fi
+

agent-manager/src/main/bin/deploy.sh

+#!/bin/sh
+RETVAL=$?
+SHELL_NAME="deploy"
+BASEDIR=$(dirname $0)
+BASEDIR=$( (
+  cd "$BASEDIR"
+  pwd
+))
+LOCK_FILE="/tmp/deploy.lock"
+# 时间变量
+CDATE=$(date "+%Y-%m-%d")
+CTIME=$(date "+%H:%M:%S")
+SHELL_LOG="${BASEDIR}/${SHELL_NAME}.log"
+
+JAVA_HOME="/usr/local/java/jdk1.8"
+SERVICE_PATH="/usr/lib/systemd/system"
+PUBLISH_PATH="/home/publish"
+PROJECT_NAME="@project.artifactId@"
+
+PROJECT_EXECPATH="${PUBLISH_PATH}/${PROJECT_NAME}"
+PROJECT_UI_EXECPATH="${PUBLISH_PATH}/${PROJECT_NAME}-ui/dist"
+PROJECT_FILENAME="${PROJECT_NAME}.tar.gz"
+PROJECT_UI_FILENAME="${PROJECT_NAME}-ui.tar.gz"
+PROJECT_SERVICE="${SERVICE_PATH}/${PROJECT_NAME}.service"
+
+#写日志
+writelog() {
+  LOGINFO=$1
+  echo "${CDATE} ${CTIME}: ${SHELL_NAME} : ${LOGINFO}" >>${SHELL_LOG}
+  echo ${LOGINFO}
+}
+
+#清理目标
+clear_deploy() {
+  SERVICE=$1
+  EXECPATH=$2
+  #清理后台自启服务
+  rm -f ${SERVICE}
+  #清理执行文件目录
+  rm -rf ${EXECPATH}
+}
+
+#清理ui
+clear_ui_deploy() {
+  EXEC_UI_PATH=$1
+  rm -rf ${EXEC_UI_PATH}
+  mkdir -p ${EXEC_UI_PATH}
+}
+
+build_service() {
+  SERVICE=$1
+  EXECPATH=$2
+  echo "" >${SERVICE}
+  echo "[Unit]" >>${SERVICE}
+  echo "Description=${PROJECT_NAME}" >>${SERVICE}
+  echo "After=network.target" >>${SERVICE}
+  echo "" >>${SERVICE}
+  echo "[Service]" >>${SERVICE}
+  echo "Environment=\"JAVA_HOME=$JAVA_HOME\"" >>${SERVICE}
+  echo "Type=forking" >>${SERVICE}
+  echo "ExecStartPre=-/bin/sleep 5s" >>${SERVICE}
+  echo "ExecStart=${EXECPATH}/bin/start.sh" >>${SERVICE}
+  echo "ExecStop=${EXECPATH}/bin/shutdown.sh" >>${SERVICE}
+  echo "PrivateTmp=true" >>${SERVICE}
+  echo "" >>${SERVICE}
+  echo "[Install]" >>${SERVICE}
+  echo "WantedBy=multi-user.target" >>${SERVICE}
+  writelog "${PROJECT_NAME}服务创建完成!"
+
+}
+
+#启动服务与nginx
+start_service() {
+  systemctl enable ${PROJECT_NAME}
+  systemctl daemon-reload
+  writelog "${PROJECT_NAME}服务启动..."
+  systemctl stop ${PROJECT_NAME} && systemctl start ${PROJECT_NAME}
+  project_status=$(systemctl status "${PROJECT_NAME}"|grep Active |awk '{print $2}')
+  jcpid=$(ps -ef | grep -v "grep" | grep "${PROJECT_NAME} " | awk '{print $2}')
+  writelog "${PROJECT_NAME}服务启动,PID is ${jcpid} ,status:${project_status}"
+}
+#部署后台服务
+project_deploy() {
+  writelog "${PROJECT_NAME}_deploy"
+  systemctl stop ${PROJECT_NAME}
+  clear_deploy ${PROJECT_SERVICE} ${PROJECT_EXECPATH}
+  writelog "${PROJECT_NAME}_clear_finish"
+  tar -zvxf ./${PROJECT_FILENAME} -C ${PUBLISH_PATH}
+  build_service ${PROJECT_SERVICE} ${PROJECT_EXECPATH}
+  start_service
+  writelog "${PROJECT_NAME}_deploy_finish"
+}
+
+#部署前台服务
+project_ui_deploy() {
+  writelog "${PROJECT_NAME}_ui_deploy"
+  clear_ui_deploy ${PROJECT_UI_EXECPATH}
+  tar -zvxf ./${PROJECT_UI_FILENAME} -C ${PUBLISH_PATH}
+  writelog "${PROJECT_NAME}_ui_deploy_finish"
+
+}
+
+#主函数
+main() {
+  echo "后台服务部署"
+  project_deploy
+  #判断是否需要部署ui
+  if [ "@skipDeploy@" == "false" ];then
+    echo "前端服务部署"
+    project_ui_deploy
+  fi;
+  exit ${RETVAL}
+}
+
+main $1

agent-manager/src/main/bin/project_deploy.sh

+#!/bin/sh
+RETVAL=$?
+SHELL_NAME="deploy"
+BASEDIR=$(dirname $0)
+BASEDIR=$( (
+  cd "$BASEDIR"
+  pwd
+))
+LOCK_FILE="/tmp/deploy.lock"
+# 时间变量
+CDATE=$(date "+%Y-%m-%d")
+CTIME=$(date "+%H:%M:%S")
+SHELL_LOG="${BASEDIR}/${SHELL_NAME}.log"
+
+JAVA_HOME="/usr/local/java/jdk1.8"
+SERVICE_PATH="/usr/lib/systemd/system"
+PUBLISH_PATH="/home/publish"
+PROJECT_NAME="@project.artifactId@"
+
+PROJECT_EXECPATH="${PUBLISH_PATH}/${PROJECT_NAME}"
+PROJECT_FILENAME="${PROJECT_NAME}.tar.gz"
+PROJECT_SERVICE="${SERVICE_PATH}/${PROJECT_NAME}.service"
+
+#写日志
+writelog() {
+  LOGINFO=$1
+  echo "${CDATE} ${CTIME}: ${SHELL_NAME} : ${LOGINFO}" >>${SHELL_LOG}
+  echo ${LOGINFO}
+}
+
+#清理目标
+clear_deploy() {
+  SERVICE=$1
+  EXECPATH=$2
+  #清理后台自启服务
+  rm -f ${SERVICE}
+  #清理执行文件目录
+}
+build_service() {
+  SERVICE=$1
+  EXECPATH=$2
+  echo "" >${SERVICE}
+  echo "[Unit]" >>${SERVICE}
+  echo "Description=${PROJECT_NAME}" >>${SERVICE}
+  echo "After=network.target" >>${SERVICE}
+  echo "" >>${SERVICE}
+  echo "[Service]" >>${SERVICE}
+  echo "Environment=\"JAVA_HOME=$JAVA_HOME\"" >>${SERVICE}
+  echo "Type=forking" >>${SERVICE}
+  echo "ExecStartPre=-/bin/sleep 5s" >>${SERVICE}
+  echo "ExecStart=${EXECPATH}/bin/start.sh" >>${SERVICE}
+  echo "ExecStop=${EXECPATH}/bin/shutdown.sh" >>${SERVICE}
+  echo "PrivateTmp=true" >>${SERVICE}
+  echo "" >>${SERVICE}
+  echo "[Install]" >>${SERVICE}
+  echo "WantedBy=multi-user.target" >>${SERVICE}
+  writelog "${PROJECT_NAME}服务创建完成!"
+
+}
+
+#启动服务与nginx
+start_service() {
+  systemctl enable ${PROJECT_NAME}
+  systemctl daemon-reload
+  writelog "${PROJECT_NAME}服务启动..."
+  systemctl stop ${PROJECT_NAME}&&systemctl start ${PROJECT_NAME}
+  project_status=$(systemctl status "${PROJECT_NAME}"|grep Active |awk '{print $2}')
+  jcpid=$(ps -ef | grep -v "grep" | grep "${PROJECT_NAME} " | awk '{print $2}')
+  writelog "${PROJECT_NAME}服务启动,PID is ${jcpid} ,status:${project_status}"
+}
+#部署后台服务
+project_deploy() {
+  writelog "${PROJECT_NAME}_deploy"
+  clear_deploy ${PROJECT_SERVICE} ${PROJECT_EXECPATH}
+  writelog "${PROJECT_NAME}_clear_finish"
+  tar -zvxf ./${PROJECT_FILENAME} -C ${PUBLISH_PATH}
+  build_service ${PROJECT_SERVICE} ${PROJECT_EXECPATH}
+  start_service
+  writelog "${PROJECT_NAME}_deploy_finish"
+}
+
+
+#主函数
+main() {
+  echo "后台服务部署"
+  project_deploy
+  exit ${RETVAL}
+}
+
+main $1

agent-manager/src/main/bin/shutdown.cmd

+
+if not exist "%JAVA_HOME%\bin\jps.exe" echo Please set the JAVA_HOME variable in your environment, We need java(x64)! jdk8 or later is better! & EXIT /B 1
+
+setlocal
+
+set "PATH=%JAVA_HOME%\bin;%PATH%"
+
+echo killing  server
+
+for /f "tokens=1" %%i in ('jps -m ^| find "@project.artifactId@"') do ( taskkill /F /PID %%i )
+
+echo Done!

agent-manager/src/main/bin/shutdown.sh

+#! /bin/sh
+PORT="@profiles.server.port@"
+BASEDIR=$(dirname $0)
+BASEDIR=$( (
+  cd "$BASEDIR"
+  pwd
+))
+PROJECT_NAME="@project.artifactId@"
+MAIN_CLASS="$PROJECT_NAME"
+
+if [ ! -n "$PORT" ]; then
+  echo $"Usage: $0 {port}"
+  exit $FAIL
+fi
+
+pid=$(ps ax | grep -i "$MAIN_CLASS" | grep java | grep -v grep | awk '{print $1}')
+if [ -z "$pid" ]; then
+  echo "No Server running."
+  exit 1
+fi
+
+echo "stoping application $PROJECT_NAME......"
+
+kill -15 ${pid}
+
+echo "Send shutdown request to Server $PROJECT_NAME OK"

agent-manager/src/main/bin/start.cmd

+echo off
+
+if not exist "%JAVA_HOME%\bin\java.exe" echo Please set the JAVA_HOME variable in your environment, We need java(x64)! jdk8 or later is better! & EXIT /B 1
+set "JAVA=%JAVA_HOME%\bin\java.exe"
+
+set BASEDIR=%~dp0
+set BASEDIR="%BASEDIR:~0,-5%"
+
+set PROJECT_NAME=@project.artifactId@
+
+set APP_NAME=%PROJECT_NAME%-@project.version@.jar
+
+set LOG_PATH="%BASEDIR%@profiles.log.path@/%PROJECT_NAME%"
+if not exist "%LOG_PATH%"  md "%LOG_PATH%"
+set GC_PATH=%LOG_PATH%/gc.log
+set HS_ERR_PATH=%LOG_PATH%PORT%-hs_err.log
+set HEAP_DUMP_PATH=%LOG_PATH%/heap_dump.hprof
+set TEMP_PATH=%LOG_PATH%/temp/
+if not exist "%TEMP_PATH%"  md "%TEMP_PATH%"
+rem jvm启动参数
+set JAVA_OPTS=-Xms512M -Xmx512M -Xss256K -XX:+UseAdaptiveSizePolicy -XX:+UseParallelGC -XX:+UseParallelOldGC -XX:GCTimeRatio=39 -XX:+PrintGCDetails -XX:+PrintGCDateStamps  -XX:+HeapDumpOnOutOfMemoryError
+set JAVA_OPTS=%JAVA_OPTS% -XX:+PrintGCDateStamps -Xloggc:%GC_PATH%
+set JAVA_OPTS=%JAVA_OPTS% -XX:ErrorFile=%HS_ERR_PATH%
+set JAVA_OPTS=%JAVA_OPTS% -XX:HeapDumpPath=%HEAP_DUMP_PATH%
+
+rem jvm config
+set JVM_CONFIG=%JVM_CONFIG% -Dapp.name=%PROJECT_NAME%
+set JVM_CONFIG=%JVM_CONFIG% -Dapp.port=%PORT%
+set JVM_CONFIG=%JVM_CONFIG% -Djava.io.tmpdir=%TEMP_PATH%
+set JVM_CONFIG=%JVM_CONFIG% -Dbasedir=%BASEDIR%
+set JVM_CONFIG=%JVM_CONFIG% -Dloader.path=file://%BASEDIR%/conf,file://%BASEDIR%/lib
+set JVM_CONFIG=%JVM_CONFIG% -Dfile.encoding=utf-8
+
+set DEBUG_OPTS=
+if ""%1"" == ""debug"" (
+   set DEBUG_OPTS= -Xloggc:../logs/gc.log -verbose:gc -XX:+PrintGCDetails -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=../logs
+   goto debug
+)
+
+set JMX_OPTS=
+if ""%1"" == ""jmx"" (
+   set JMX_OPTS= -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=9888 -Dcom.sun.management.jmxremote.ssl=FALSE -Dcom.sun.management.jmxremote.authenticate=FALSE
+   goto jmx
+)
+
+
+set "LOG_OPTS=--logging.config=%BASEDIR%/conf/logback-spring.xml"
+
+echo "Starting the %APP_NAME%"
+"%JAVA%" %JAVA_OPTS% -server  %JVM_CONFIG% -jar %BASEDIR%/boot/%APP_NAME%
+echo ""%JAVA%" %JAVA_OPTS% -server  %JVM_CONFIG% -jar %BASEDIR%/boot/%APP_NAME% "
+goto end
+
+:debug
+echo "debug"
+"%JAVA%" -Xms512m -Xmx512m -server %DEBUG_OPTS% %JVM_CONFIG% -jar ../boot/%APP_NAME%
+goto end
+
+:jmx
+"%JAVA%" -Xms512m -Xmx512m -server %JMX_OPTS% %JVM_CONFIG% -jar ../boot/%APP_NAME%
+goto end
+
+:end
+pause

agent-manager/src/main/bin/start.sh

+#!/bin/sh
+PORT="@profiles.server.port@"
+DEBUG=@profiles.server.debug@
+BASEDIR=`dirname $0`/..
+BASEDIR=`(cd "$BASEDIR"; pwd)`
+PROJECT_NAME="@project.artifactId@";
+MAIN_CLASS="$PROJECT_NAME-@project.version@.jar";
+LOG_PATH="@profiles.log.path@/$PROJECT_NAME"
+GC_PATH=$LOG_PATH/$PROJECT_NAME"-gc.log"
+HS_ERR_PATH=$LOG_PATH/$PROJECT_NAME"-hs_err.log"
+HEAP_DUMP_PATH=$LOG_PATH/$PROJECT_NAME"-heap_dump.hprof"
+TEMP_PATH=$LOG_PATH/temp/
+SUCCESS=0
+FAIL=9
+if [ ! -n "$PORT" ]; then
+	echo $"Usage: $0 {port}"
+	exit $FAIL
+fi
+if [ ! -d $LOG_PATH ];
+then
+    mkdir -p $LOG_PATH;
+fi
+if [ ! -d $TEMP_PATH ];
+then
+    mkdir -p $TEMP_PATH;
+fi
+if [ -z "$JAVACMD" ] ; then
+  if [ -n "$JAVA_HOME" ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+      # IBM's JDK on AIX uses strange locations for the executables
+      JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+      JAVACMD="$JAVA_HOME/bin/java"
+    fi
+  else
+    JAVACMD=`which java > /dev/null 2>&1`
+	echo  "Error: JAVA_HOME is not defined correctly."
+    exit $ERR_NO_JAVA
+  fi
+fi
+
+if [ ! -x "$JAVACMD" ] ; then
+  echo "We cannot execute $JAVACMD"
+  exit $ERR_NO_JAVA
+fi
+
+if [ -e "$BASEDIR" ]
+then
+  JAVA_OPTS="-Xms1024M -Xmx2048M -Xss256K -XX:+UseAdaptiveSizePolicy -XX:+UseParallelGC -XX:+UseParallelOldGC -XX:GCTimeRatio=39 -XX:+PrintGCDetails -XX:+PrintGCDateStamps -Xloggc:$GC_PATH -XX:+HeapDumpOnOutOfMemoryError -XX:ErrorFile=$HS_ERR_PATH -XX:HeapDumpPath=$HEAP_DUMP_PATH"
+fi
+
+CLASSPATH=$CLASSPATH_PREFIX:
+EXTRA_JVM_ARGUMENTS=""
+
+cd "$BASEDIR/boot";
+
+echo "starting application $PROJECT_NAME......"
+exec "$JAVACMD" $JAVA_OPTS \
+				$EXTRA_JVM_ARGUMENTS \
+				$DEBUG \
+				-Dapp.name="$PROJECT_NAME" \
+				-Dapp.port="$PORT" \
+				-Dbasedir="$BASEDIR" \
+				-Dfile.encoding=utf-8 \
+				-Djava.io.tmpdir=$TEMP_PATH \
+				-jar $MAIN_CLASS \
+				> /dev/null &
+				
+for i in {1..60}
+do
+	jcpid=`ps -ef | grep -v "grep" | grep "$MAIN_CLASS" | grep "app.port=$PORT" | sed -n '1P' | awk '{print $2}'`
+	if [ $jcpid ]; then
+		echo "The $PROJECT_NAME start finished, PID is $jcpid"
+		exit $SUCCESS
+	else
+		echo "starting the application .. $i"
+		sleep 1
+	fi
+done
+echo "$PROJECT_NAME start failure!"

agent-manager/src/main/java/com/mortals/xhx/ManagerApplication.java

+package com.mortals.xhx;
+
+import com.mortals.framework.springcloud.boot.BaseWebApplication;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.boot.web.servlet.ServletComponentScan;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.annotation.ImportResource;
+@EnableFeignClients
+@EnableConfigurationProperties
+@SpringBootApplication(scanBasePackages = {"com.mortals"})
+@ServletComponentScan("com.mortals")
+@ImportResource(locations = {"classpath:config/spring-config.xml"})
+public class ManagerApplication extends BaseWebApplication {
+
+
+    public static void main(String[] args) {
+        SpringApplication.run(ManagerApplication.class, args);
+
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/annotation/DataPermission.java

+package com.mortals.xhx.annotation;
+
+import java.lang.annotation.*;
+
+/**
+ *
+ * @author: zxfei
+ * @date: 2024/5/15 16:09
+ */
+@Retention(RetentionPolicy.RUNTIME)
+@Target({ElementType.TYPE, ElementType.METHOD})
+@Documented
+public @interface DataPermission {
+    /**
+     * 数据权限类型
+     * 1 上下级授权  2 数据范围授权
+     */
+    String permissionType() default "2";
+
+    /**
+     * 配置菜单的组件路径,用于数据权限
+     */
+    String componentRoute() default "";
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/CustomJsonDateDeserializer.java

+package com.mortals.xhx.base.framework;
+
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.databind.DeserializationContext;
+import com.fasterxml.jackson.databind.JsonDeserializer;
+import org.springframework.util.ObjectUtils;
+
+import java.io.IOException;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+/**
+ * @author: zxfei
+ * @date: 2022/6/30 10:49
+ * @description:
+ **/
+public class CustomJsonDateDeserializer extends JsonDeserializer<Date> {
+
+    @Override
+    public Date deserialize(JsonParser jp, DeserializationContext ctxt) throws IOException {
+        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        String date = jp.getText();
+
+        if (!ObjectUtils.isEmpty(date)) {
+            try {
+                return format.parse(date);
+            } catch (ParseException e) {
+                return null;
+            }
+        } else {
+            return null;
+        }
+
+
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/DateJacksonConverter.java

+package com.mortals.xhx.base.framework;
+
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.DeserializationContext;
+import com.fasterxml.jackson.databind.JsonDeserializer;
+import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.time.DateUtils;
+
+import java.io.IOException;
+import java.text.ParseException;
+import java.util.Date;
+
+/**
+ * 自定义Jackson反序列化日期类型时应用的类型转换器,一般用于@RequestBody接受参数时使用
+ */
+public class DateJacksonConverter extends JsonDeserializer {
+
+    private static String[] pattern = new String[]{"yyyy-MM-dd", "yyyy-MM-dd HH:mm", "yyyy-MM-dd HH:mm:ss", "yyyy-MM-dd HH:mm:ss.S", "yyyy.MM.dd", "yyyy.MM.dd HH:mm", "yyyy.MM.dd HH:mm:ss", "yyyy.MM.dd HH:mm:ss.S", "yyyy/MM/dd", "yyyy/MM/dd HH:mm", "yyyy/MM/dd HH:mm:ss", "yyyy/MM/dd HH:mm:ss.S"};
+
+    @Override
+    public Date deserialize(JsonParser p, DeserializationContext ctxt) throws IOException, JsonProcessingException {
+        Date targetDate = null;
+        String originDate = p.getText();
+        if (StringUtils.isNotEmpty(originDate)) {
+            try {
+                long longDate = Long.valueOf(originDate.trim());
+                targetDate = new Date(longDate);
+            } catch (NumberFormatException e) {
+                try {
+                    targetDate = DateUtils.parseDate(originDate, DateJacksonConverter.pattern);
+                } catch (ParseException pe) {
+                    throw new IOException(String.format("'%s' can not convert to type 'java.util.Date',just support timestamp(type of long) and following date format(%s)",
+                            originDate,
+                            StringUtils.join(pattern, ",")));
+                }
+            }
+        }
+        return targetDate;
+    }
+
+    @Override
+    public Class handledType() {
+        return Date.class;
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/WxMessageConverter.java

+package com.mortals.xhx.base.framework;
+
+import org.springframework.http.MediaType;
+import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author: zxfei
+ * @date: 2022/6/28 15:57
+ * @description:
+ **/
+// 创建一个新的转换器 解析微信的 [text/plain]
+public class WxMessageConverter extends MappingJackson2HttpMessageConverter {
+    public WxMessageConverter() {
+        List<MediaType> mediaTypes = new ArrayList<>();
+        mediaTypes.add(MediaType.TEXT_PLAIN);
+        setSupportedMediaTypes(mediaTypes);
+    }
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/framework/annotation/ApiUserAuth.java

+package com.mortals.xhx.base.framework.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.METHOD)
+public @interface ApiUserAuth {
+    String msg() default "";
+
+    String params() default "";
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/annotation/Operlog.java

+package com.mortals.xhx.base.framework.annotation;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Target(ElementType.METHOD)
+public @interface Operlog {
+    String msg() default "";
+
+    String params() default "";
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/annotation/aspect/OperlogAspect.java

+package com.mortals.xhx.base.framework.annotation.aspect;
+
+import com.mortals.framework.model.OperateLogPdu;
+import com.mortals.framework.service.ILogService;
+import com.mortals.framework.service.IMessageProduceService;
+import com.mortals.framework.service.impl.FileLogServiceImpl;
+import com.mortals.xhx.base.system.oper.service.OperLogService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+import java.util.Date;
+
+/**
+ * 操作日志记录
+ *
+ * @author: zxfei
+ * @date: 2021/11/5 13:28
+ */
+@Component
+@Slf4j
+public class OperlogAspect extends FileLogServiceImpl implements ILogService {
+
+    @Autowired
+    private OperLogService operLogService;
+    @Autowired
+    private IMessageProduceService messageProducer;
+
+    @Override
+    public void doHandlerLog(String platformMark, Long userId, String userName, String loginName, String requestUrl,
+                             String content, String ip, Date logDate) {
+        super.doHandlerLog(platformMark, userId, userName, loginName, requestUrl, content, ip, logDate);
+        if(ObjectUtils.isEmpty(userId)) return;
+        operLogService.insertOperLog(ip, requestUrl, userId, userName, loginName, content);
+        OperateLogPdu operateLogPdu = new OperateLogPdu();
+        operateLogPdu.initAttrValue();
+        operateLogPdu.setIp(ip);
+        operateLogPdu.setRequestUrl(requestUrl);
+        operateLogPdu.setUserId(userId);
+        operateLogPdu.setUserName(userName);
+        operateLogPdu.setLoginName(loginName);
+        operateLogPdu.setPlatformMark(platformMark);
+        operateLogPdu.setLogDate(logDate);
+        operateLogPdu.setContent(content);
+        operateLogPdu.setOperType(1);
+        messageProducer.syncOperSend(operateLogPdu);
+    }
+
+    @Override
+    public void doHandlerLog(String platformMark, String loginName, String requestUrl, String content, String ip) {
+        this.doHandlerLog(platformMark, null, "", loginName, requestUrl, content, ip, new Date());
+
+
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/annotation/aspect/WebLogAspect.java

+package com.mortals.xhx.base.framework.annotation.aspect;
+
+import cn.hutool.extra.servlet.ServletUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.annotation.AfterReturning;
+import org.aspectj.lang.annotation.Before;
+import org.aspectj.lang.annotation.Pointcut;
+import org.slf4j.MDC;
+import org.springframework.core.annotation.Order;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+import org.springframework.web.util.ContentCachingRequestWrapper;
+
+import javax.servlet.http.HttpServletRequest;
+import java.net.URLDecoder;
+import java.nio.charset.StandardCharsets;
+import java.util.Arrays;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 打印每个请求的入参、出参等信息
+ *
+ * @author: zxfei
+ * @date: 2022/4/20 9:24
+ */
+//@Aspect
+//@Component
+@Slf4j
+@Order(1)
+//@Profile({"default", "develop", "test"})
+public class WebLogAspect {
+    @Pointcut("execution(public * com.mortals..*Controller.*(..))")
+    public void webLog() {
+    }
+
+
+    @Pointcut("execution(public * com.mortals.xhx.base.framework.exception.ExceptionHandle.*(..))")
+    public void exceptions() {
+    }
+
+    /**
+     * 只在进入controller时记录请求信息
+     */
+    @Before("webLog()")
+    public void doBefore(JoinPoint joinPoint) {
+        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+        HttpServletRequest request = attributes.getRequest();
+       // log.debug("请求路径 {} ,进入方法 {}", request.getRequestURI(), joinPoint.getSignature().getDeclaringTypeName() + ":" + joinPoint.getSignature().getName());
+        MDC.put("req", getRequestInfo(request).toJSONString());
+        MDC.put("startTime", String.valueOf(System.currentTimeMillis()));
+    }
+
+    /**
+     * 打印请求日志
+     */
+    @AfterReturning(pointcut = "webLog()|| exceptions()", returning = "result")
+    public void afterReturning(Object result) {
+        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+        HttpServletRequest request = attributes.getRequest();
+
+        Map<String, String> map = MDC.getCopyOfContextMap();
+        if (map != null&&result!=null) {
+            String startTime = map.getOrDefault("startTime", String.valueOf(System.currentTimeMillis()));
+            long takeTime = (System.currentTimeMillis() - Long.parseLong(startTime));
+            String req = map.getOrDefault("req", "");
+            if (result instanceof String) {
+                log.info(" \n 请求路径:{} 耗时：{}ms 客户端IP:{} \n 请求报文：{} \n 响应报文：{}\n cookies：{} "
+                        , request.getRequestURI(), takeTime,ServletUtil.getClientIP(request), req, result);
+            } else {
+                log.info(" \n 请求路径:{} 耗时：{}ms 客户端IP:{}\n 请求报文：{} \n 响应报文：{}\n cookies：{}"
+                        , request.getRequestURI(), takeTime,ServletUtil.getClientIP(request), req, JSON.toJSONString(result));
+            }
+
+        }
+    }
+
+    /**
+     * 读取请求信息,如果是表单则转换为json
+     */
+    private JSONObject getRequestInfo(HttpServletRequest req) {
+        JSONObject requestInfo = new JSONObject();
+        try {
+            StringBuffer requestURL = req.getRequestURL();
+            requestInfo.put("requestURL", requestURL);
+            String method = req.getMethod();
+            requestInfo.put("method", method);
+            if (req.getQueryString() != null) {
+                requestInfo.put("queryString", URLDecoder.decode(req.getQueryString(), "UTF-8"));
+            }
+            String remoteAddr = req.getRemoteAddr();
+            requestInfo.put("remoteAddr", remoteAddr);
+            if (req instanceof ContentCachingRequestWrapper) {
+                ContentCachingRequestWrapper wrapper = (ContentCachingRequestWrapper) req;
+
+                String bodyStr = new String(wrapper.getContentAsByteArray(), StandardCharsets.UTF_8);
+                if (bodyStr.startsWith("{")) {
+                    JSONObject jsonObject = JSON.parseObject(bodyStr);
+                    requestInfo.put("requestBody", jsonObject);
+                }
+
+                String cookieStr = Arrays.asList(wrapper.getCookies()).stream().map(item -> JSON.toJSONString(item)).collect(Collectors.joining("|"));
+                requestInfo.put("cookieStr", cookieStr);
+            }
+        } catch (Exception e) {
+            log.error("解析请求失败", e);
+            requestInfo.put("parseError", e.getMessage());
+        }
+        return requestInfo;
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/config/AccountConfig.java

+package com.mortals.xhx.base.framework.config;
+
+import com.mortals.framework.springcloud.config.web.BaseWebMvcConfigurer;
+import com.mortals.xhx.base.framework.WxMessageConverter;
+import feign.codec.Decoder;
+import org.springframework.beans.factory.ObjectFactory;
+import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
+import org.springframework.cloud.openfeign.support.SpringDecoder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author: zxfei
+ * @date: 2021/8/13 0:24
+ * @description:
+ **/
+@Configuration
+public class AccountConfig {
+    @Bean
+    public BaseWebMvcConfigurer getBaseWebMvc() {
+        return new BaseWebMvcConfigurer(false, null);
+    }
+
+
+    @Bean
+    public Decoder feignDecoder() {
+        WxMessageConverter wxConverter = new WxMessageConverter();
+        ObjectFactory<HttpMessageConverters> objectFactory = () -> new HttpMessageConverters(wxConverter);
+        return new SpringDecoder(objectFactory);
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/config/ConverterConfig.java

+package com.mortals.xhx.base.framework.config;
+
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.mortals.xhx.base.framework.DateJacksonConverter;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.converter.json.Jackson2ObjectMapperFactoryBean;
+import org.springframework.http.converter.json.MappingJackson2HttpMessageConverter;
+
+import java.util.TimeZone;
+
+@Configuration
+public class ConverterConfig {
+    @Bean
+    public DateJacksonConverter dateJacksonConverter() {
+        return new DateJacksonConverter();
+    }
+
+    @Bean
+    public Jackson2ObjectMapperFactoryBean jackson2ObjectMapperFactoryBean(DateJacksonConverter dateJacksonConverter) {
+        Jackson2ObjectMapperFactoryBean jackson2ObjectMapperFactoryBean = new Jackson2ObjectMapperFactoryBean();
+        jackson2ObjectMapperFactoryBean.setDeserializers(dateJacksonConverter);
+        return jackson2ObjectMapperFactoryBean;
+    }
+
+    @Bean
+    public MappingJackson2HttpMessageConverter mappingJackson2HttpMessageConverter(ObjectMapper objectMapper) {
+        MappingJackson2HttpMessageConverter mappingJackson2HttpMessageConverter = new MappingJackson2HttpMessageConverter();
+        objectMapper.setTimeZone(TimeZone.getTimeZone("GMT+8"));
+        mappingJackson2HttpMessageConverter.setObjectMapper(objectMapper);
+        return mappingJackson2HttpMessageConverter;
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/config/CrossInterceptor.java

+package com.mortals.xhx.base.framework.config;
+
+import org.springframework.stereotype.Component;
+import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * @author: zxfei
+ * @date: 2022/6/6 15:05
+ * @description:添加跨域响应
+ **/
+@Component
+public class CrossInterceptor extends HandlerInterceptorAdapter {
+
+    @Override
+    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
+        response.setHeader("Access-Control-Allow-Origin", "*");
+        response.setHeader("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE, OPTIONS");
+        response.setHeader("Access-Control-Max-Age", "3600");
+        response.setHeader("Access-Control-Allow-Headers", "*");
+        response.setHeader("Access-Control-Allow-Credentials", "true");
+        return true;
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/config/InterceptorConfig.java

+package com.mortals.xhx.base.framework.config;
+
+import com.mortals.framework.util.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+import javax.annotation.PostConstruct;
+import java.util.HashSet;
+import java.util.Set;
+
+@Configuration
+public class InterceptorConfig {
+    /**
+     * cookie的密钥
+     */
+    @Value("${cookie.key}")
+    private String securityKey;
+
+    /**
+     * 不需要登录的URL地址，多个用逗号分隔
+     */
+    @Value("${application.auth.unloginUrl}")
+    private String uncheckLoginUrl;
+
+    /**
+     * 不需要鉴权的URL地址，多个用逗号分隔
+     */
+    @Value("${application.auth.uncheckUrl}")
+    private String uncheckAuthUrl;
+
+
+    private Set<String> uncheckLoginUrls = new HashSet<>();
+
+    private Set<String> uncheckAuthUrls = new HashSet<>();
+    /**
+     * 有后缀占位符的不检验地址，如/spi/user/*
+     */
+    private Set<String> uncheckAuthUrlsSuffix = new HashSet<>();
+
+    public String getSecurityKey() {
+        return securityKey;
+    }
+
+    public Set<String> getUncheckLoginUrls() {
+        return uncheckLoginUrls;
+    }
+
+    public Set<String> getUncheckAuthUrls() {
+        return uncheckAuthUrls;
+    }
+
+    /**
+     * 校验地址是否需要权限
+     *
+     * @param url
+     * @return true：需要，false：不需要
+     */
+    public boolean needCheckAuth(String url) {
+        if (uncheckAuthUrls.contains(url)) {
+            return false;
+        }
+        for (String regexUrl : uncheckAuthUrlsSuffix) {// 支持*结尾
+            if (url.startsWith(regexUrl)) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    @PostConstruct
+    public void convert() {
+        uncheckLoginUrls.clear();
+        uncheckLoginUrls.addAll(StringUtils.converStr2Set(uncheckLoginUrl));
+
+        uncheckAuthUrls.clear();
+        uncheckAuthUrls.addAll(StringUtils.converStr2Set(uncheckAuthUrl));
+
+        uncheckAuthUrlsSuffix.clear();
+        for (String url : uncheckAuthUrls) {
+            int index = url.indexOf("*");// 支持*结尾
+            if (index != -1) {
+                uncheckAuthUrlsSuffix.add(url.substring(0, index));
+            }
+        }
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/config/MybatisConfiguration.java

+package com.mortals.xhx.base.framework.config;
+
+import com.mortals.framework.springcloud.config.mybatis.AbstractMybatisConfiguration;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import javax.sql.DataSource;
+
+
+@Configuration
+public class MybatisConfiguration extends AbstractMybatisConfiguration {
+    private static Log logger = LogFactory.getLog(MybatisConfiguration.class);
+
+    // 配置类型别名
+    @Value("${spring.application.name}")
+    private String name;
+    // 配置类型别名
+    @Value("${mybatis.root-path}")
+    private String rootPath;
+
+    // 配置类型别名
+    @Value("${mybatis.type-aliases-package}")
+    private String typeAliasesPackage;
+
+    // 配置mapper的扫描，找到所有的mapper.xml映射文件
+    @Value("${mybatis.mapper-locations}")
+    private String mapperLocations;
+
+    // 加载全局的配置文件
+    @Value("${mybatis.config-location}")
+    private String configLocation;
+
+    // 提供SqlSeesion
+    @Bean(name = "sqlSessionFactory")
+    public SqlSessionFactory sqlSessionFactoryBean(@Qualifier("dataSource") DataSource dataSource) {
+        return super.getSqlSessionFactoryBean(dataSource);
+    }
+
+    @Override
+    public String getTypeAliasesRootPackage() {
+        return rootPath;
+    }
+
+    @Override
+    public String getSqlMappers() {
+        return mapperLocations;
+    }
+
+    @Override
+    public String getMybatisConfig() {
+        return configLocation;
+    }
+
+    @Override
+    public String getTypeAliasesPackage() {
+        logger.info("typeAliasesPackage:"+typeAliasesPackage);
+        return typeAliasesPackage;
+    }
+
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/framework/config/MybatisConfigurationMasterSlave.java

+package com.mortals.xhx.base.framework.config;
+
+import com.mortals.framework.springcloud.config.mybatis.AbstractMybatisMasterSlaveDataSourceConfiguration;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+
+import javax.sql.DataSource;
+import java.util.List;
+
+
+//@Configuration
+//@AutoConfigureAfter(DataSourceAutoConfiguration.class)
+public class MybatisConfigurationMasterSlave extends AbstractMybatisMasterSlaveDataSourceConfiguration {
+    private static Log logger = LogFactory.getLog(MybatisConfigurationMasterSlave.class);
+
+    // 配置类型别名
+    @Value("${spring.application.name}")
+    private String name;
+    // 配置类型别名
+    @Value("${mybatis.root-path}")
+    private String rootPath;
+
+    // 配置类型别名
+    @Value("${mybatis.type-aliases-package}")
+    private String typeAliasesPackage;
+
+    // 配置mapper的扫描，找到所有的mapper.xml映射文件
+    @Value("${mybatis.mapper-locations}")
+    private String mapperLocations;
+
+    // 加载全局的配置文件
+    @Value("${mybatis.config-location}")
+    private String configLocation;
+
+    // 提供SqlSeesion
+    @Bean(name = "sqlSessionFactory")
+    public SqlSessionFactory sqlSessionFactoryBean(@Qualifier("dataSource") DataSource dataSource) {
+        return super.getSqlSessionFactoryBean(dataSource);
+    }
+
+    @Override
+    public String getTypeAliasesRootPackage() {
+        return rootPath;
+    }
+
+    @Override
+    public String getSqlMappers() {
+        return mapperLocations;
+    }
+
+    @Override
+    public String getMybatisConfig() {
+        return configLocation;
+    }
+
+    @Override
+    public String getTypeAliasesPackage() {
+        logger.info("typeAliasesPackage:"+typeAliasesPackage);
+        return typeAliasesPackage;
+    }
+
+    @Override
+    public DataSource getDefaultDataSource() {
+        return null;
+    }
+
+    @Override
+    public List<DataSource> findMasterDataSource() {
+        return null;
+    }
+
+    @Override
+    public List<DataSource> findSlaveDataSource() {
+        return null;
+    }
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/framework/exception/ExceptionHandle.java

+package com.mortals.xhx.base.framework.exception;
+
+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;
+
+import com.alibaba.fastjson.JSONObject;
+import com.mortals.framework.exception.AppException;
+
+/**
+ * 统一异常处理
+ */
+@ControllerAdvice
+public class ExceptionHandle {
+
+	private final static Logger log = LoggerFactory.getLogger(ExceptionHandle.class);
+
+	public static final String KEY_RESULT_CODE = "code";
+	public static final String KEY_RESULT_MSG = "msg";
+	public static final String KEY_RESULT_DATA = "data";
+	public static final int VALUE_RESULT_FAILURE = -1;
+
+	@ExceptionHandler(value = Exception.class)
+	@ResponseBody
+	public String handle(Exception e) {
+		JSONObject ret = new JSONObject();
+		ret.put(KEY_RESULT_CODE, VALUE_RESULT_FAILURE);
+		if (e instanceof AppException) {
+			StackTraceElement stack = e.getStackTrace()[0];
+			log.error("[business error]=========stack message[{}],[{},method:{},line{}][{}]", e.getMessage(),
+					stack.getClassName(), stack.getMethodName(), stack.getLineNumber(), e.getClass().getName());
+			AppException ex = (AppException) e;
+			ret.put(KEY_RESULT_MSG, ex.getMessage());
+		} else {
+			log.error("[system error]", e);
+			ret.put(KEY_RESULT_MSG, "unknown exception!");
+		}
+		return ret.toJSONString();
+	}
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/filter/RequestFilter.java

+package com.mortals.xhx.base.framework.filter;
+
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.MDC;
+import org.springframework.stereotype.Component;
+import org.springframework.web.filter.OncePerRequestFilter;
+import org.springframework.web.util.ContentCachingRequestWrapper;
+
+import javax.servlet.Filter;
+import javax.servlet.FilterChain;
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+
+/**
+ * 
+ * 请求过滤链
+ * @author: zxfei
+ * @date: 2022/4/20 14:52
+ */
+//@Component
+@Slf4j
+public class RequestFilter extends OncePerRequestFilter implements Filter {
+
+    @Override
+    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
+        try {
+            request = new ContentCachingRequestWrapper(request);
+            filterChain.doFilter(request, response);
+        } catch (Exception e) {
+            throw e;
+        } finally {
+            //清理ThreadLocal
+            MDC.clear();
+        }
+    }
+
+
+    /*private void setUsername(HttpServletRequest request) {
+        //通过token解析出username
+        String token = authTokenService.getToken(request);
+        //String token = request.getHeader("token");
+        if (!ObjectUtils.isEmpty(token)) {
+            MDC.put("token",token);
+            MDC.put("token", token);
+            try {
+                SessionUserInfo info = tokenService.getUserInfo();
+                if (info != null) {
+                    String username = info.getUsername();
+                    MDC.put("username", username);
+                }
+            } catch (CommonJsonException e) {
+                log.info("无效的token:{}", token);
+            }
+        }
+    }*/
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/interceptor/AuthTokenServiceImpl.java

+package com.mortals.xhx.base.framework.interceptor;
+
+import com.alibaba.fastjson.JSONObject;
+import com.mortals.framework.ap.SysConstains;
+import com.mortals.framework.service.IAuthTokenService;
+import com.mortals.framework.service.ICacheService;
+import com.mortals.framework.service.IUser;
+import com.mortals.framework.util.DateUtils;
+import com.mortals.framework.util.StringUtils;
+import com.mortals.xhx.base.system.resource.service.ResourceService;
+import com.mortals.xhx.base.system.user.model.UserEntity;
+import com.mortals.xhx.base.system.user.service.UserService;
+import com.mortals.xhx.common.key.RedisKey;
+import com.mortals.xhx.common.utils.MenuEncodeUtil;
+import io.jsonwebtoken.Claims;
+import io.jsonwebtoken.Jwts;
+import io.jsonwebtoken.SignatureAlgorithm;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Primary;
+import org.springframework.core.annotation.Order;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Base64;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * token验证处理
+ *
+ * @author zxfei
+ */
+@Primary
+@Service
+@Order(1)
+@Slf4j
+public class AuthTokenServiceImpl implements IAuthTokenService {
+
+    @Autowired
+    private UserService userService;
+
+    // 令牌自定义标识
+    @Value("${token.header:Authorization}")
+    private String header;
+
+    // 令牌秘钥
+    @Value("${token.secret:026db82420614469897fcc2dc1b4ce38}")
+    private String secret;
+
+    // 令牌有效期（默认60分钟）
+    @Value("${token.expireTime:60}")
+    private int expireTime;
+
+    // 令牌前缀
+    @Value("${token.prefix:}")
+    private String tokenPrefix;
+    // redis db
+    @Value("${spring.redis.database:}")
+    private Integer db;
+
+    @Value("${token.database:0}")
+    private Integer portalDb;
+
+    protected static final Long SECOND = 1l;
+
+    protected static final Long SECOND_MINUTE = 60 * SECOND;
+
+    protected static final Long SECOND_HOUR = 60 * SECOND_MINUTE;
+
+    protected static final Long SECOND_DAY = 24 * SECOND_HOUR;
+
+    protected static final Long SECOND_WEEK = 7 * SECOND_DAY;
+
+    private static final Long SECOND_MINUTE_TEN = 1 * SECOND_MINUTE;
+
+    @Autowired
+    private ICacheService cacheService;
+
+    @Autowired
+    private ResourceService resourceService;
+
+
+    /**
+     * 获取信息
+     *
+     * @return 用户信息
+     */
+    @Override
+    public IUser getLoginUser(HttpServletRequest request) {
+
+        // 获取请求携带的令牌
+        String token = getToken(request);
+        if (StringUtils.isNotEmpty(token)) {
+            try {
+                boolean signed = Jwts.parser().isSigned(token);
+                if (!signed) {
+                    log.error("token非法！=>{}", token);
+                    return null;
+                }
+                Claims claims = parseToken(token);
+                String uuid = (String) claims.get(SysConstains.LOGIN_USER_KEY);
+                String userKey = getTokenKey(uuid);
+                //cacheService.select(portalDb);
+                // String userStr = cacheService.get(userKey);
+                RedisTemplate<String, String> redisTemplate = cacheService.selectDbRedisTemplate(portalDb);
+                String userStr =redisTemplate.opsForValue().get(userKey);
+
+                //刷新token时间
+                UserEntity userEntity = JSONObject.parseObject(userStr, UserEntity.class);
+                if (!ObjectUtils.isEmpty(userEntity)) {
+                    verifyToken(userEntity);
+                }
+                // cacheService.select(db);
+                if (!ObjectUtils.isEmpty(userEntity)) {
+                    UserEntity temp = userService.getExtCache(userEntity.getLoginName());
+                    if (!ObjectUtils.isEmpty(temp)) {
+                        userEntity.setId(temp.getId());
+                    }
+                    //更新resource 路径
+                    String menuUrlCode = cacheService.hget(RedisKey.KEY_USER_MENU_CACHE, userEntity.getId().toString(), String.class);
+//                    if (ObjectUtils.isEmpty(menuUrlCode)) {
+//                        Set<String> urls = resourceService.findUrlSetByUserId(userEntity.getId());
+//                        menuUrlCode = MenuEncodeUtil.generateMenuUrlCode(urls);
+//                        cacheService.hset(RedisKey.KEY_USER_MENU_CACHE, userEntity.getId().toString(), menuUrlCode);
+//                    }
+                    userEntity.setMenuUrl(menuUrlCode);
+                    return userEntity;
+                }
+            } catch (Exception e) {
+                log.error("解析jwt token异常！,token:{}",token, e);
+                return null;
+            }
+        }
+        return null;
+    }
+
+    /**
+     * 设置用户信息
+     */
+    @Override
+    public void setUser(IUser user) {
+        if (StringUtils.isNotNull(user) && StringUtils.isNotEmpty(user.getToken())) {
+            refreshToken(user);
+        }
+    }
+
+    /**
+     * 删除用户身份信息
+     */
+    @Override
+    public void delUser(String token) {
+        if (StringUtils.isNotEmpty(token)) {
+            String userKey = getTokenKey(token);
+            cacheService.del(userKey);
+        }
+    }
+
+    /**
+     * 创建令牌
+     *
+     * @param user 用户信息
+     * @return 令牌
+     */
+    @Override
+    public String createToken(IUser user) {
+//        String token = IdUtil.fastSimpleUUID();
+//        user.setToken(token);
+        refreshToken(user);
+        Map<String, Object> claims = new HashMap<>();
+        claims.put(SysConstains.LOGIN_USER_KEY, user.getToken());
+        return createToken(claims);
+    }
+
+    /**
+     * 验证令牌有效期，相差不足20分钟，自动刷新缓存
+     *
+     * @param user
+     * @return 令牌
+     */
+    @Override
+    public void verifyToken(IUser user) {
+        long expireTime = user.getExpireTime();
+        long currentTime = System.currentTimeMillis();
+        if (expireTime - currentTime <= SECOND_MINUTE_TEN*1000) {
+            log.info("不足二十分钟，刷新过期时间");
+            refreshToken(user);
+        }
+    }
+
+    /**
+     * 刷新令牌有效期
+     *
+     * @param user 信息
+     */
+    public void refreshToken(IUser user) {
+        //user.setLoginTime(System.currentTimeMillis());
+        user.setExpireTime(user.getLoginTime() == null ? System.currentTimeMillis() : user.getLoginTime() + expireTime * SECOND_MINUTE*1000);
+        // 根据uuid将user缓存
+        String userKey = getTokenKey(user.getToken());
+        //设置有效时间 单位秒
+        cacheService.set(userKey, user, expireTime * SECOND_MINUTE);
+    }
+
+
+    /**
+     * 从数据声明生成令牌
+     *
+     * @param claims 数据声明
+     * @return 令牌
+     */
+    private String createToken(Map<String, Object> claims) {
+        String token = Jwts.builder()
+                .setExpiration(DateUtils.addCurrDate(7))
+                .setClaims(claims)
+                .signWith(SignatureAlgorithm.HS256, Base64.getEncoder()
+                        .encodeToString(secret.getBytes())).compact();
+        return token;
+    }
+
+    /**
+     * 从令牌中获取数据声明
+     *
+     * @param token 令牌
+     * @return 数据声明
+     */
+    @Override
+    public Claims parseToken(String token) {
+        return Jwts.parser()
+                .setSigningKey(Base64.getEncoder().encodeToString(secret.getBytes()))
+                .parseClaimsJws(token)
+                .getBody();
+    }
+
+    /**
+     * 从令牌中获取用户
+     *
+     * @param token 令牌
+     * @return 用户名
+     */
+    @Override
+    public String getUserNumFromToken(String token) {
+        Claims claims = parseToken(token);
+        return claims.getSubject();
+    }
+
+    /**
+     * 获取请求token
+     *
+     * @param request
+     * @return token
+     */
+    @Override
+    public String getToken(HttpServletRequest request) {
+        String token = request.getHeader(header);
+        if (StringUtils.isNotEmpty(token) && token.startsWith(tokenPrefix)) {
+            token = token.replace(tokenPrefix, "");
+        }
+        return token;
+    }
+
+    private String getTokenKey(String uuid) {
+        return SysConstains.LOGIN_TOKEN_KEY + uuid;
+    }
+
+
+    public static void main(String[] args) {
+        //  boolean signed = Jwts.parser().isSigned("123");
+        boolean signed = Jwts.parser().isSigned("eyJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJuaW5naGFvLm5ldCIsImV4cCI6IjE0Mzg5NTU0NDUiLCJuYW1lIjoid2FuZ2hhbyIsImFkbWluIjp0cnVlfQ.SwyHTEx_RQppr97g4J5lKXtabJecpejuef8AqKYMAJc");
+        System.out.println(signed);
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/interceptor/AuthUserInterceptor.java

+package com.mortals.xhx.base.framework.interceptor;
+
+import com.alibaba.fastjson.JSONObject;
+import com.mortals.framework.annotation.UnAuth;
+import com.mortals.framework.common.Rest;
+import com.mortals.framework.service.IAuthTokenService;
+import com.mortals.framework.service.ICacheService;
+import com.mortals.framework.service.IUser;
+import com.mortals.framework.util.AESUtil;
+import com.mortals.framework.utils.ServletUtils;
+import com.mortals.framework.web.interceptor.BaseInterceptor;
+import com.mortals.xhx.base.framework.config.InterceptorConfig;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
+import org.springframework.web.method.HandlerMethod;
+import org.springframework.web.servlet.resource.ResourceHttpRequestHandler;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.lang.reflect.Method;
+
+import static com.mortals.xhx.common.key.ErrorCode.*;
+
+/**
+ * 用户权限验证，基于token
+ *
+ * @author: zxfei
+ * @date: 2022/4/24 11:04
+ */
+@Component
+public class AuthUserInterceptor extends BaseInterceptor {
+    @Autowired
+    private InterceptorConfig config;
+    @Autowired
+    private IAuthTokenService authTokenService;
+    @Autowired
+    private ICacheService cacheService;
+
+    @Override
+    public int getOrder() {
+        return Integer.MAX_VALUE - 9;
+    }
+
+    @Override
+    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)
+            throws Exception {
+        JSONObject ret = new JSONObject();
+        if(handler instanceof HandlerMethod){
+            HandlerMethod handlerMethod = (HandlerMethod) handler;
+            Method method = handlerMethod.getMethod();
+            UnAuth annotation = method.getAnnotation(UnAuth.class);
+            if (annotation != null) {
+                //取消校验
+                return true;
+            }
+        }else if(handler instanceof ResourceHttpRequestHandler){
+            return true;
+        }
+        try {
+            String uri = request.getServletPath();
+            //校验配置的请求路径是否需要检查权限
+            if (config.needCheckAuth(uri)) {
+                //需要校验权限
+                boolean auth = this.checkAuth(request, uri, config.getSecurityKey());
+                if (!auth) {
+                    //校验token不正常
+                    String token = authTokenService.getToken(request);
+                    if(ObjectUtils.isEmpty(token)){
+                        ServletUtils.renderString(response, JSONObject.toJSONString(Rest.fail(ERROR_TOKEN_UNAUTHORIZED, ERROR_TOKEN_UNAUTHORIZED_CONTENT)));
+                        return false;
+                    }
+                    //不存在时候 如果是管理员也不做拦截
+                    IUser loginUser = authTokenService.getLoginUser(request);
+                    if (ObjectUtils.isEmpty(loginUser)) {
+                        ServletUtils.renderString(response, JSONObject.toJSONString(Rest.fail(ERROR_TOKEN_EXPIRED, ERROR_TOKEN_EXPIRED_CONTENT)));
+                        return false;
+                        // } else if (loginUser.isAdmin() || loginUser.getUserType() == 1) {
+                    } else if (loginUser.isAdmin()) {
+                        return super.preHandle(request, response, handler);
+                    } else {
+                        ServletUtils.renderString(response, JSONObject.toJSONString(Rest.fail(ERROR_USER_OPERATION, ERROR_USER_OPERATION_CONTENT)));
+                        return false;
+                    }
+                }
+            }
+        } catch (Exception e) {
+            logger.error("权限校验拦截请求处理异常-->" + e.getMessage());
+            writeJsonResponse(response, HttpServletResponse.SC_INTERNAL_SERVER_ERROR, "用户权限校验异常");
+            return false;
+        }
+
+        return super.preHandle(request, response, handler);
+    }
+
+    private boolean checkAuth(HttpServletRequest request, String requestUrl, String securityKey) throws Exception {
+        int code = requestUrl.hashCode() & (Integer.MAX_VALUE - 1);
+        IUser loginUser = authTokenService.getLoginUser(request);
+        if (ObjectUtils.isEmpty(loginUser)) return false;
+        String menuUrl = loginUser.getMenuUrl();
+        if (ObjectUtils.isEmpty(menuUrl)) return false;
+        menuUrl = AESUtil.decrypt(menuUrl, securityKey);
+        String codes = "," + menuUrl + ",";
+        String codeKey = "," + code + ",";
+        if (codes.indexOf(codeKey) != -1) {
+            return true;
+        }
+        return false;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/listener/RabbitLoggingErrorHandler.java

+package com.mortals.xhx.base.framework.listener;
+
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.util.ErrorHandler;
+
+@Component
+@Slf4j
+public class RabbitLoggingErrorHandler implements ErrorHandler {
+
+    public RabbitLoggingErrorHandler(SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory) {
+        rabbitListenerContainerFactory.setErrorHandler(this);
+    }
+
+    @Override
+    public void handleError(Throwable t) {
+
+        log.error("[handleError][发生异常]]", t);
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/listener/SimpleDynamicListener.java

+package com.mortals.xhx.base.framework.listener;
+
+import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author: zxfei
+ * @date: 2022/8/23 0:32
+ * @description:
+ **/
+@Slf4j
+@Service
+public class SimpleDynamicListener implements ChannelAwareMessageListener {
+
+    @Override
+    public void onMessage(Message message, Channel channel)  {
+        try {
+            if (message.equals("exception")) {
+                log.info("rabbitmq ecception!");
+            }
+            String queue = message.getMessageProperties().getConsumerQueue();
+            byte[] body = message.getBody();
+            log.info("接收到：" + queue + "，消息内容为：" + new String(body));
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+            log.info(queue + "队列消息消费成功");
+        } catch (Exception e) {
+            log.error("接收消息异常");
+        }
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/WebSocketConfiguration.java

+package com.mortals.xhx.base.framework.ws;
+
+import com.mortals.xhx.base.framework.ws.websocket.WebSocketHandler;
+import com.mortals.xhx.base.framework.ws.websocket.WebSocketShakeInterceptor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.socket.config.annotation.EnableWebSocket;
+import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
+import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
+
+@Configuration
+@EnableWebSocket // 开启 Spring WebSocket
+public class WebSocketConfiguration implements WebSocketConfigurer {
+
+    @Override
+    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
+        registry.addHandler(this.webSocketHandler(), "/ws") // 配置处理器
+                .addInterceptors(new WebSocketShakeInterceptor()) // 配置拦截器
+                .setAllowedOrigins("*"); // 解决跨域问题
+    }
+
+    @Bean
+    public WebSocketHandler webSocketHandler() {
+        return new WebSocketHandler();
+    }
+
+    @Bean
+    public WebSocketShakeInterceptor webSocketShakeInterceptor() {
+        return new WebSocketShakeInterceptor();
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/handler/AuthMessageHandler.java

+package com.mortals.xhx.base.framework.ws.handler;
+
+import com.alibaba.fastjson.JSON;
+import com.mortals.xhx.base.framework.ws.message.AuthRequest;
+import com.mortals.xhx.base.framework.ws.message.AuthResponse;
+import com.mortals.xhx.base.framework.ws.util.WebSocketUtil;
+import lombok.extern.apachecommons.CommonsLog;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+import org.springframework.web.socket.WebSocketSession;
+
+@Component
+@CommonsLog
+public class AuthMessageHandler implements MessageHandler<AuthRequest> {
+
+    @Override
+    public void execute(WebSocketSession session, AuthRequest message) {
+        log.info("receive message:"+ JSON.toJSONString(message));
+
+        // 如果未传递 accessToken
+        if (StringUtils.isEmpty(message.getAccessToken())) {
+            WebSocketUtil.send(session, AuthResponse.TYPE,
+                    new AuthResponse().setCode(1).setMessage("认证 accessToken 未传入"));
+            return;
+        }
+
+        // 添加到 WebSocketUtil 中
+        WebSocketUtil.addSession(session, message.getAccessToken()); // 考虑到代码简化，我们先直接使用 accessToken 作为 User
+
+        // 判断是否认证成功。这里，假装直接成功
+        WebSocketUtil.send(session, AuthResponse.TYPE, new AuthResponse().setCode(0));
+
+        // 通知所有人，某个人加入了。这个是可选逻辑，仅仅是为了演示
+//        WebSocketUtil.broadcast(UserJoinNoticeRequest.TYPE,
+//                new UserJoinNoticeRequest().setNickname(message.getAccessToken())); // 考虑到代码简化，我们先直接使用 accessToken 作为 User
+//
+
+    }
+
+    @Override
+    public String getType() {
+        return AuthRequest.TYPE;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/handler/HeartBeatHandler.java

+package com.mortals.xhx.base.framework.ws.handler;
+
+import com.mortals.xhx.base.framework.ws.message.HeartBeatRequest;
+import com.mortals.xhx.base.framework.ws.message.SendResponse;
+import com.mortals.xhx.base.framework.ws.util.WebSocketUtil;
+import org.springframework.stereotype.Component;
+import org.springframework.web.socket.WebSocketSession;
+
+@Component
+public class HeartBeatHandler implements MessageHandler<HeartBeatRequest> {
+
+    @Override
+    public void execute(WebSocketSession session, HeartBeatRequest message) {
+        // 这里，假装直接成功
+        SendResponse sendResponse = new SendResponse().setMsgId(message.getMsgId()).setCode(0);
+        WebSocketUtil.send(session, SendResponse.TYPE, sendResponse);
+    }
+
+    @Override
+    public String getType() {
+        return HeartBeatRequest.TYPE;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/handler/MessageHandler.java

+package com.mortals.xhx.base.framework.ws.handler;
+
+import com.mortals.xhx.base.framework.ws.message.Message;
+import org.springframework.web.socket.WebSocketSession;
+
+/**
+ * 消息处理器接口
+ */
+public interface MessageHandler<T extends Message> {
+
+    /**
+     * 执行处理消息
+     *
+     * @param session 会话
+     * @param message 消息
+     */
+    void execute(WebSocketSession session, T message);
+
+    /**
+     * @return 消息类型，即每个 Message 实现类上的 TYPE 静态字段
+     */
+    String getType();
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/handler/SendToAllHandler.java

+package com.mortals.xhx.base.framework.ws.handler;
+
+
+import com.mortals.xhx.base.framework.ws.message.SendResponse;
+import com.mortals.xhx.base.framework.ws.message.SendToAllRequest;
+import com.mortals.xhx.base.framework.ws.message.SendToUserRequest;
+import com.mortals.xhx.base.framework.ws.util.WebSocketUtil;
+import org.springframework.stereotype.Component;
+import org.springframework.web.socket.WebSocketSession;
+
+@Component
+public class SendToAllHandler implements MessageHandler<SendToAllRequest> {
+
+    @Override
+    public void execute(WebSocketSession session, SendToAllRequest message) {
+        // 这里，假装直接成功
+        SendResponse sendResponse = new SendResponse().setMsgId(message.getMsgId()).setCode(0);
+        WebSocketUtil.send(session, SendResponse.TYPE, sendResponse);
+
+        // 创建转发的消息
+        SendToUserRequest sendToUserRequest = new SendToUserRequest().setMsgId(message.getMsgId())
+                .setContent(message.getContent());
+        // 广播发送
+        WebSocketUtil.broadcast(SendToUserRequest.TYPE, sendToUserRequest);
+    }
+
+    @Override
+    public String getType() {
+        return SendToAllRequest.TYPE;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/handler/SendToOneHandler.java

+package com.mortals.xhx.base.framework.ws.handler;
+
+import com.mortals.xhx.base.framework.ws.message.SendResponse;
+import com.mortals.xhx.base.framework.ws.message.SendToOneRequest;
+import com.mortals.xhx.base.framework.ws.message.SendToUserRequest;
+import com.mortals.xhx.base.framework.ws.util.WebSocketUtil;
+import org.springframework.stereotype.Component;
+import org.springframework.web.socket.WebSocketSession;
+
+@Component
+public class SendToOneHandler implements MessageHandler<SendToOneRequest> {
+
+    @Override
+    public void execute(WebSocketSession session, SendToOneRequest message) {
+        // 这里，假装直接成功
+        SendResponse sendResponse = new SendResponse().setMsgId(message.getMsgId()).setCode(0);
+        WebSocketUtil.send(session, SendResponse.TYPE, sendResponse);
+
+        // 创建转发的消息
+        SendToUserRequest sendToUserRequest = new SendToUserRequest().setMsgId(message.getMsgId())
+                .setContent(message.getContent());
+        // 广播发送
+        WebSocketUtil.send(message.getToUser(), SendToUserRequest.TYPE, sendToUserRequest);
+    }
+
+    @Override
+    public String getType() {
+        return SendToOneRequest.TYPE;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/AuthRequest.java

+package com.mortals.xhx.base.framework.ws.message;
+
+/**
+ * 用户认证请求
+ */
+public class AuthRequest implements Message {
+
+    public static final String TYPE = "AUTH_REQUEST";
+
+    /**
+     * 认证 Token
+     */
+    private String accessToken;
+
+    public String getAccessToken() {
+        return accessToken;
+    }
+
+    public AuthRequest setAccessToken(String accessToken) {
+        this.accessToken = accessToken;
+        return this;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/AuthResponse.java

+package com.mortals.xhx.base.framework.ws.message;
+
+/**
+ * 用户认证响应
+ */
+public class AuthResponse implements Message {
+
+    public static final String TYPE = "AUTH_RESPONSE";
+
+    /**
+     * 响应状态码
+     */
+    private Integer code;
+    /**
+     * 响应提示
+     */
+    private String message;
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public AuthResponse setCode(Integer code) {
+        this.code = code;
+        return this;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public AuthResponse setMessage(String message) {
+        this.message = message;
+        return this;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/HeartBeatRequest.java

+package com.mortals.xhx.base.framework.ws.message;
+
+import com.alibaba.fastjson.JSON;
+
+/**
+ * 心跳 Message
+ */
+public class HeartBeatRequest implements Message {
+
+    public static final String TYPE = "HEART_BEAT_REQUEST";
+
+    /**
+     * 消息编号
+     */
+    private String msgId;
+    /**
+     * 内容
+     */
+    private String content;
+
+
+
+    public String getMsgId() {
+        return msgId;
+    }
+
+    public HeartBeatRequest setMsgId(String msgId) {
+        this.msgId = msgId;
+        return this;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public HeartBeatRequest setContent(String content) {
+        this.content = content;
+        return this;
+    }
+
+
+    public static void main(String[] args) {
+        HeartBeatRequest heartBeatRequest = new HeartBeatRequest();
+
+        heartBeatRequest.setMsgId("123");
+
+
+
+        System.out.println(JSON.toJSONString(heartBeatRequest));
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/Message.java

+package com.mortals.xhx.base.framework.ws.message;
+
+/**
+ * 基础消息体
+ */
+public interface Message {
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/SendResponse.java

+package com.mortals.xhx.base.framework.ws.message;
+
+/**
+ * 发送消息响应结果的 Message
+ */
+public class SendResponse implements Message {
+
+    public static final String TYPE = "SEND_RESPONSE";
+
+    /**
+     * 消息编号
+     */
+    private String msgId;
+    /**
+     * 响应状态码
+     */
+    private Integer code;
+    /**
+     * 响应提示
+     */
+    private String message;
+
+    public String getMsgId() {
+        return msgId;
+    }
+
+    public SendResponse setMsgId(String msgId) {
+        this.msgId = msgId;
+        return this;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+
+    public SendResponse setCode(Integer code) {
+        this.code = code;
+        return this;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public SendResponse setMessage(String message) {
+        this.message = message;
+        return this;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/SendToAllRequest.java

+package com.mortals.xhx.base.framework.ws.message;
+
+/**
+ * 发送给所有人的群聊消息的 Message
+ */
+public class SendToAllRequest implements Message {
+
+    public static final String TYPE = "SEND_TO_ALL_REQUEST";
+
+    /**
+     * 消息编号
+     */
+    private String msgId;
+    /**
+     * 内容
+     */
+    private String content;
+
+    public String getContent() {
+        return content;
+    }
+
+    public SendToAllRequest setContent(String content) {
+        this.content = content;
+        return this;
+    }
+
+    public String getMsgId() {
+        return msgId;
+    }
+
+    public SendToAllRequest setMsgId(String msgId) {
+        this.msgId = msgId;
+        return this;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/SendToOneRequest.java

+package com.mortals.xhx.base.framework.ws.message;
+
+/**
+ * 发送给指定人的私聊消息的 Message
+ */
+public class SendToOneRequest implements Message {
+
+    public static final String TYPE = "SEND_TO_ONE_REQUEST";
+
+    /**
+     * 发送给的用户
+     */
+    private String toUser;
+    /**
+     * 消息编号
+     */
+    private String msgId;
+    /**
+     * 内容
+     */
+    private String content;
+
+    public String getToUser() {
+        return toUser;
+    }
+
+    public SendToOneRequest setToUser(String toUser) {
+        this.toUser = toUser;
+        return this;
+    }
+
+    public String getMsgId() {
+        return msgId;
+    }
+
+    public SendToOneRequest setMsgId(String msgId) {
+        this.msgId = msgId;
+        return this;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public SendToOneRequest setContent(String content) {
+        this.content = content;
+        return this;
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/SendToUserRequest.java

+package com.mortals.xhx.base.framework.ws.message;
+
+/**
+ * 发送消息给一个用户的 Message
+ */
+public class SendToUserRequest implements Message {
+
+    public static final String TYPE = "SEND_TO_USER_REQUEST";
+
+    /**
+     * 消息编号
+     */
+    private String msgId;
+    /**
+     * 内容
+     */
+    private String content;
+
+    public String getMsgId() {
+        return msgId;
+    }
+
+    public SendToUserRequest setMsgId(String msgId) {
+        this.msgId = msgId;
+        return this;
+    }
+
+    public String getContent() {
+        return content;
+    }
+
+    public SendToUserRequest setContent(String content) {
+        this.content = content;
+        return this;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/message/UserJoinNoticeRequest.java

+package com.mortals.xhx.base.framework.ws.message;
+
+/**
+ * 用户加入群聊的通知 Message
+ */
+public class UserJoinNoticeRequest implements Message {
+
+    public static final String TYPE = "USER_JOIN_NOTICE_REQUEST";
+
+    /**
+     * 昵称
+     */
+    private String nickname;
+
+    public String getNickname() {
+        return nickname;
+    }
+
+    public UserJoinNoticeRequest setNickname(String nickname) {
+        this.nickname = nickname;
+        return this;
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/util/WebSocketUtil.java

+package com.mortals.xhx.base.framework.ws.util;
+
+import com.alibaba.fastjson.JSONObject;
+import com.mortals.xhx.base.framework.ws.message.Message;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.socket.TextMessage;
+import org.springframework.web.socket.WebSocketSession;
+
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * WebSocket 工具类，提供客户端连接的管理等功能
+ */
+public class WebSocketUtil {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(WebSocketUtil.class);
+
+    // ========== 会话相关 ==========
+
+    /**
+     * Session 与用户的映射
+     */
+    private static final Map<WebSocketSession, String> SESSION_USER_MAP = new ConcurrentHashMap<>();
+    /**
+     * 用户与 Session 的映射
+     */
+    private static final Map<String, WebSocketSession> USER_SESSION_MAP = new ConcurrentHashMap<>();
+
+    /**
+     * 添加 Session 。在这个方法中，会添加用户和 Session 之间的映射
+     *
+     * @param session Session
+     * @param user 用户
+     */
+    public static void addSession(WebSocketSession session, String user) {
+        // 更新 USER_SESSION_MAP
+        USER_SESSION_MAP.put(user, session);
+        // 更新 SESSION_USER_MAP
+        SESSION_USER_MAP.put(session, user);
+    }
+
+    /**
+     * 移除 Session 。
+     *
+     * @param session Session
+     */
+    public static void removeSession(WebSocketSession session) {
+        // 从 SESSION_USER_MAP 中移除
+        String user = SESSION_USER_MAP.remove(session);
+        // 从 USER_SESSION_MAP 中移除
+        if (user != null && user.length() > 0) {
+            USER_SESSION_MAP.remove(user);
+        }
+    }
+
+    // ========== 消息相关 ==========
+
+    /**
+     * 广播发送消息给所有在线用户
+     *
+     * @param type 消息类型
+     * @param message 消息体
+     * @param <T> 消息类型
+     */
+    public static <T extends Message> void broadcast(String type, T message) {
+        // 创建消息
+        TextMessage textMessage = buildTextMessage(type, message);
+        // 遍历 SESSION_USER_MAP ，进行逐个发送
+        for (WebSocketSession session : SESSION_USER_MAP.keySet()) {
+            sendTextMessage(session, textMessage);
+        }
+    }
+
+    /**
+     * 发送消息给单个用户的 Session
+     *
+     * @param session Session
+     * @param type 消息类型
+     * @param message 消息体
+     * @param <T> 消息类型
+     */
+    public static <T extends Message> void send(WebSocketSession session, String type, T message) {
+        // 创建消息
+        TextMessage textMessage = buildTextMessage(type, message);
+        // 遍历给单个 Session ，进行逐个发送
+        sendTextMessage(session, textMessage);
+    }
+
+    /**
+     * 发送消息给指定用户
+     *
+     * @param user 指定用户
+     * @param type 消息类型
+     * @param message 消息体
+     * @param <T> 消息类型
+     * @return 发送是否成功你那个
+     */
+    public static <T extends Message> boolean send(String user, String type, T message) {
+        // 获得用户对应的 Session
+        WebSocketSession session = USER_SESSION_MAP.get(user);
+        if (session == null) {
+            LOGGER.error("[send][user({}) 不存在对应的 session]", user);
+            return false;
+        }
+        // 发送消息
+        send(session, type, message);
+        return true;
+    }
+
+    /**
+     * 构建完整的消息
+     *
+     * @param type 消息类型
+     * @param message 消息体
+     * @param <T> 消息类型
+     * @return 消息
+     */
+    private static <T extends Message> TextMessage buildTextMessage(String type, T message) {
+        JSONObject messageObject = new JSONObject();
+        messageObject.put("type", type);
+        messageObject.put("body", message);
+        return new TextMessage(messageObject.toString());
+    }
+
+    /**
+     * 真正发送消息
+     *
+     * @param session Session
+     * @param textMessage 消息
+     */
+    private static void sendTextMessage(WebSocketSession session, TextMessage textMessage) {
+        if (session == null) {
+            LOGGER.error("[sendTextMessage][session 为 null]");
+            return;
+        }
+        try {
+            session.sendMessage(textMessage);
+        } catch (IOException e) {
+            LOGGER.error("[sendTextMessage][session({}) 发送消息{}) 发生异常",
+                    session, textMessage, e);
+        }
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/websocket/WebSocketHandler.java

+package com.mortals.xhx.base.framework.ws.websocket;
+
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.mortals.xhx.base.framework.ws.handler.MessageHandler;
+import com.mortals.xhx.base.framework.ws.message.AuthRequest;
+import com.mortals.xhx.base.framework.ws.message.Message;
+import com.mortals.xhx.base.framework.ws.util.WebSocketUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.aop.framework.AopProxyUtils;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationContext;
+import org.springframework.web.socket.CloseStatus;
+import org.springframework.web.socket.TextMessage;
+import org.springframework.web.socket.WebSocketSession;
+import org.springframework.web.socket.handler.TextWebSocketHandler;
+
+import java.lang.reflect.ParameterizedType;
+import java.lang.reflect.Type;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
+public class WebSocketHandler extends TextWebSocketHandler implements InitializingBean {
+
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    /**
+     * 消息类型与 MessageHandler 的映射
+     *
+     * 无需设置成静态变量
+     */
+    private final Map<String, MessageHandler> HANDLERS = new HashMap<>();
+
+    @Autowired
+    private ApplicationContext applicationContext;
+
+    @Override // 对应 open 事件
+    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
+        logger.info("[afterConnectionEstablished][session({}) 接入]", session);
+        // 解析 accessToken
+        String accessToken = (String) session.getAttributes().get("accessToken");
+        // 创建 AuthRequest 消息类型
+        AuthRequest authRequest = new AuthRequest().setAccessToken(accessToken);
+        // 获得消息处理器
+        MessageHandler<AuthRequest> messageHandler = HANDLERS.get(AuthRequest.TYPE);
+        if (messageHandler == null) {
+            logger.error("[onOpen][认证消息类型，不存在消息处理器]");
+            return;
+        }
+        messageHandler.execute(session, authRequest);
+    }
+
+    @Override // 对应 message 事件
+    public void handleTextMessage(WebSocketSession session, TextMessage textMessage) throws Exception {
+        //logger.info("[handleMessage][session({}) 接收到一条消息({})]", session, textMessage); // 生产环境下，请设置成 debug 级别
+        try {
+            // 获得消息类型
+            JSONObject jsonMessage = JSON.parseObject(textMessage.getPayload());
+            String messageType = jsonMessage.getString("type");
+            // 获得消息处理器
+            MessageHandler messageHandler = HANDLERS.get(messageType);
+            if (messageHandler == null) {
+                logger.error("[onMessage][消息类型({}) 不存在消息处理器]", messageType);
+                return;
+            }
+            // 解析消息
+            Class<? extends Message> messageClass = this.getMessageClass(messageHandler);
+            // 处理消息
+            Message messageObj = JSON.parseObject(jsonMessage.getString("body"), messageClass);
+            messageHandler.execute(session, messageObj);
+        } catch (Throwable throwable) {
+            logger.info("[onMessage][session({}) message({}) 发生异常]", session, throwable);
+        }
+    }
+
+    @Override // 对应 close 事件
+    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
+        logger.info("[afterConnectionClosed][session({}) 连接关闭。关闭原因是({})}]", session, status);
+        WebSocketUtil.removeSession(session);
+    }
+
+    @Override // 对应 error 事件
+    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
+        logger.info("[handleTransportError][session({}) 发生异常]", session, exception);
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        // 通过 ApplicationContext 获得所有 MessageHandler Bean
+        applicationContext.getBeansOfType(MessageHandler.class).values() // 获得所有 MessageHandler Bean
+                .forEach(messageHandler -> HANDLERS.put(messageHandler.getType(), messageHandler)); // 添加到 handlers 中
+        logger.info("[afterPropertiesSet][消息处理器数量：{}]", HANDLERS.size());
+    }
+
+    private Class<? extends Message> getMessageClass(MessageHandler handler) {
+        // 获得 Bean 对应的 Class 类名。因为有可能被 AOP 代理过。
+        Class<?> targetClass = AopProxyUtils.ultimateTargetClass(handler);
+        // 获得接口的 Type 数组
+        Type[] interfaces = targetClass.getGenericInterfaces();
+        Class<?> superclass = targetClass.getSuperclass();
+        while ((Objects.isNull(interfaces) || 0 == interfaces.length) && Objects.nonNull(superclass)) { // 此处，是以父类的接口为准
+            interfaces = superclass.getGenericInterfaces();
+            superclass = targetClass.getSuperclass();
+        }
+        if (Objects.nonNull(interfaces)) {
+            // 遍历 interfaces 数组
+            for (Type type : interfaces) {
+                // 要求 type 是泛型参数
+                if (type instanceof ParameterizedType) {
+                    ParameterizedType parameterizedType = (ParameterizedType) type;
+                    // 要求是 MessageHandler 接口
+                    if (Objects.equals(parameterizedType.getRawType(), MessageHandler.class)) {
+                        Type[] actualTypeArguments = parameterizedType.getActualTypeArguments();
+                        // 取首个元素
+                        if (Objects.nonNull(actualTypeArguments) && actualTypeArguments.length > 0) {
+                            return (Class<Message>) actualTypeArguments[0];
+                        } else {
+                            throw new IllegalStateException(String.format("类型(%s) 获得不到消息类型", handler));
+                        }
+                    }
+                }
+            }
+        }
+        throw new IllegalStateException(String.format("类型(%s) 获得不到消息类型", handler));
+    }
+
+
+    public static void main(String[] args) {
+        WebSocketHandler webSocketHandler = new WebSocketHandler();
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/framework/ws/websocket/WebSocketShakeInterceptor.java

+package com.mortals.xhx.base.framework.ws.websocket;
+
+import lombok.extern.apachecommons.CommonsLog;
+import org.springframework.http.server.ServerHttpRequest;
+import org.springframework.http.server.ServerHttpResponse;
+import org.springframework.http.server.ServletServerHttpRequest;
+import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;
+
+import java.util.Map;
+
+/**
+ * 自定义 HttpSessionHandshakeInterceptor 拦截器
+ *
+ * 因为 WebSocketSession 无法获得 ws 地址上的请求参数，所以只好通过该拦截器，获得 accessToken 请求参数，设置到 attributes 中
+ */
+@CommonsLog
+public class WebSocketShakeInterceptor extends HttpSessionHandshakeInterceptor {
+
+
+    @Override
+    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, org.springframework.web.socket.WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
+
+        // 获得 accessToken
+        if (request instanceof ServletServerHttpRequest) {
+            ServletServerHttpRequest serverRequest = (ServletServerHttpRequest) request;
+            attributes.put("accessToken", serverRequest.getServletRequest().getParameter("accessToken"));
+        }
+
+        return super.beforeHandshake(request, response, wsHandler, attributes);
+    }
+
+
+    public static void main(String[] args) {
+        WebSocketShakeInterceptor webSocketShakeInterceptor = new WebSocketShakeInterceptor();
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/login/service/GifSecurityImage.java

+package com.mortals.xhx.base.login.service;
+
+import java.awt.Color;
+import java.awt.Font;
+import java.awt.Graphics;
+import java.awt.image.BufferedImage;
+import java.io.ByteArrayInputStream;
+import java.io.ByteArrayOutputStream;
+import java.util.Random;
+
+import javax.imageio.ImageIO;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+/**
+ * gif动态图验证码图片生成器
+ *
+ */
+public class GifSecurityImage {
+	
+    private static Log logger = LogFactory.getLog(GifSecurityImage.class);
+
+	public static BufferedImage createImage(String securityCode) {
+		int codeLength = securityCode.length();
+
+		int fSize = 14;
+		int fWidth = fSize + 1;
+
+		int width = codeLength * fWidth + 6;
+
+		int height = fSize * 2 + 1;
+		BufferedImage image = new BufferedImage(width, height, 1);
+		Graphics g = image.createGraphics();
+
+		g.setColor(Color.WHITE);
+
+		g.fillRect(0, 0, width, height);
+
+		g.setColor(Color.LIGHT_GRAY);
+
+		g.setFont(new Font("Arial", 1, height - 2));
+
+		Random rand = new Random();
+		// 画点
+		g.setColor(Color.LIGHT_GRAY);
+		for (int i = 0; i < codeLength * 10; i++) {
+			g.setColor(randomColor());
+			int x = rand.nextInt(width);
+			int y = rand.nextInt(height);
+			g.drawOval(x, y, 1, 1);
+		}
+
+		for (int i = 0; i < 5; i++) {
+			g.setColor(randomColor());
+			int x = rand.nextInt(width - 1);
+			int y = rand.nextInt(height - 1);
+			int xl = rand.nextInt(6) + 1;
+			int yl = rand.nextInt(12) + 1;
+			g.drawLine(x, y, xl, yl);
+		}
+
+		// 写字
+		g.setFont(new Font("Georgia", 1, fSize));
+		for (int i = 0; i < codeLength; i++) {
+			int codeY = height - 8 - rand.nextInt(5);
+			int codeX = width / 4 * i + (width / 4 - fSize) / 2;
+			g.drawString(String.valueOf(securityCode.charAt(i)), codeX, codeY);
+		}
+		g.dispose();
+
+		return image;
+	}
+	
+	public static byte[] createGifImage(String securityCode) {
+		ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
+		AnimatedGifEncoder gifEncoder = new AnimatedGifEncoder();
+		gifEncoder.setRepeat(0);
+		gifEncoder.start(outputStream);
+		for (int j = 0; j < 4; j++) {
+			gifEncoder.setDelay(200); // 设置播放的延迟时间
+			gifEncoder.addFrame(createImage(securityCode));
+		}
+		gifEncoder.finish();
+		return outputStream.toByteArray();
+	}
+
+	private static Color randomColor() {
+		Random random = new Random();
+		int r = random.nextInt(256);
+		int g = random.nextInt(256);
+		int b = random.nextInt(256);
+		return new Color(r, g, b);
+	}
+
+	public static ByteArrayInputStream getImageAsInputStream(String securityCode) {
+		BufferedImage image = createImage(securityCode);
+		return convertImageToStream(image);
+	}
+
+	private static ByteArrayInputStream convertImageToStream(BufferedImage image) {
+		ByteArrayInputStream inputStream = null;
+		ByteArrayOutputStream bos = new ByteArrayOutputStream();
+		try {
+			byte[] bts = bos.toByteArray();
+			inputStream = new ByteArrayInputStream(bts);
+			ImageIO.write(image, "JPG", bos);
+		} catch (Exception e) {
+		    logger.debug("转换图片数据流异常-->" + e.getMessage());
+		}
+		return inputStream;
+	}
+	
+}

agent-manager/src/main/java/com/mortals/xhx/base/login/service/LZWEncoder.java

+package com.mortals.xhx.base.login.service;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+//==============================================================================
+//  Adapted from Jef Poskanzer's Java port by way of J. M. G. Elliott.
+//  K Weiner 12/00
+
+class LZWEncoder {
+
+	private static final int EOF = -1;
+
+	private int imgW, imgH;
+	private byte[] pixAry;
+	private int initCodeSize;
+	private int remaining;
+	private int curPixel;
+
+	// GIFCOMPR.C - GIF Image compression routines
+	//
+	// Lempel-Ziv compression based on 'compress'. GIF modifications by
+	// David Rowley (mgardi@watdcsu.waterloo.edu)
+
+	// General DEFINEs
+
+	static final int BITS = 12;
+
+	static final int HSIZE = 5003; // 80% occupancy
+
+	// GIF Image compression - modified 'compress'
+	//
+	// Based on: compress.c - File compression ala IEEE Computer, June 1984.
+	//
+	// By Authors: Spencer W. Thomas (decvax!harpo!utah-cs!utah-gr!thomas)
+	// Jim McKie (decvax!mcvax!jim)
+	// Steve Davies (decvax!vax135!petsd!peora!srd)
+	// Ken Turkowski (decvax!decwrl!turtlevax!ken)
+	// James A. Woods (decvax!ihnp4!ames!jaw)
+	// Joe Orost (decvax!vax135!petsd!joe)
+
+	int n_bits; // number of bits/code
+	int maxbits = BITS; // user settable max # bits/code
+	int maxcode; // maximum code, given n_bits
+	int maxmaxcode = 1 << BITS; // should NEVER generate this code
+
+	int[] htab = new int[HSIZE];
+	int[] codetab = new int[HSIZE];
+
+	int hsize = HSIZE; // for dynamic table sizing
+
+	int free_ent = 0; // first unused entry
+
+	// block compression parameters -- after all codes are used up,
+	// and compression rate changes, start over.
+	boolean clear_flg = false;
+
+	// Algorithm: use open addressing double hashing (no chaining) on the
+	// prefix code / next character combination. We do a variant of Knuth's
+	// algorithm D (vol. 3, sec. 6.4) along with G. Knott's relatively-prime
+	// secondary probe. Here, the modular division first probe is gives way
+	// to a faster exclusive-or manipulation. Also do block compression with
+	// an adaptive reset, whereby the code table is cleared when the compression
+	// ratio decreases, but after the table fills. The variable-length output
+	// codes are re-sized at this point, and a special CLEAR code is generated
+	// for the decompressor. Late addition: construct the table according to
+	// file size for noticeable speed improvement on small files. Please direct
+	// questions about this implementation to ames!jaw.
+
+	int g_init_bits;
+
+	int ClearCode;
+	int EOFCode;
+
+	// output
+	//
+	// Output the given code.
+	// Inputs:
+	// code: A n_bits-bit integer. If == -1, then EOF. This assumes
+	// that n_bits =< wordsize - 1.
+	// Outputs:
+	// Outputs code to the file.
+	// Assumptions:
+	// Chars are 8 bits long.
+	// Algorithm:
+	// Maintain a BITS character long buffer (so that 8 codes will
+	// fit in it exactly). Use the VAX insv instruction to insert each
+	// code in turn. When the buffer fills up empty it and start over.
+
+	int cur_accum = 0;
+	int cur_bits = 0;
+
+	int masks[] = { 0x0000, 0x0001, 0x0003, 0x0007, 0x000F, 0x001F, 0x003F, 0x007F, 0x00FF, 0x01FF, 0x03FF, 0x07FF,
+			0x0FFF, 0x1FFF, 0x3FFF, 0x7FFF, 0xFFFF };
+
+	// Number of characters so far in this 'packet'
+	int a_count;
+
+	// Define the storage for the packet accumulator
+	byte[] accum = new byte[256];
+
+	// ----------------------------------------------------------------------------
+	LZWEncoder(int width, int height, byte[] pixels, int color_depth) {
+		imgW = width;
+		imgH = height;
+		pixAry = pixels;
+		initCodeSize = Math.max(2, color_depth);
+	}
+
+	// Add a character to the end of the current packet, and if it is 254
+	// characters, flush the packet to disk.
+	void char_out(byte c, OutputStream outs) throws IOException {
+		accum[a_count++] = c;
+		if (a_count >= 254)
+			flush_char(outs);
+	}
+
+	// Clear out the hash table
+
+	// table clear for block compress
+	void cl_block(OutputStream outs) throws IOException {
+		cl_hash(hsize);
+		free_ent = ClearCode + 2;
+		clear_flg = true;
+
+		output(ClearCode, outs);
+	}
+
+	// reset code table
+	void cl_hash(int hsize) {
+		for (int i = 0; i < hsize; ++i)
+			htab[i] = -1;
+	}
+
+	void compress(int init_bits, OutputStream outs) throws IOException {
+		int fcode;
+		int i /* = 0 */;
+		int c;
+		int ent;
+		int disp;
+		int hsize_reg;
+		int hshift;
+
+		// Set up the globals: g_init_bits - initial number of bits
+		g_init_bits = init_bits;
+
+		// Set up the necessary values
+		clear_flg = false;
+		n_bits = g_init_bits;
+		maxcode = MAXCODE(n_bits);
+
+		ClearCode = 1 << (init_bits - 1);
+		EOFCode = ClearCode + 1;
+		free_ent = ClearCode + 2;
+
+		a_count = 0; // clear packet
+
+		ent = nextPixel();
+
+		hshift = 0;
+		for (fcode = hsize; fcode < 65536; fcode *= 2)
+			++hshift;
+		hshift = 8 - hshift; // set hash code range bound
+
+		hsize_reg = hsize;
+		cl_hash(hsize_reg); // clear hash table
+
+		output(ClearCode, outs);
+
+		outer_loop: while ((c = nextPixel()) != EOF) {
+			fcode = (c << maxbits) + ent;
+			i = (c << hshift) ^ ent; // xor hashing
+
+			if (htab[i] == fcode) {
+				ent = codetab[i];
+				continue;
+			} else if (htab[i] >= 0) // non-empty slot
+			{
+				disp = hsize_reg - i; // secondary hash (after G. Knott)
+				if (i == 0)
+					disp = 1;
+				do {
+					if ((i -= disp) < 0)
+						i += hsize_reg;
+
+					if (htab[i] == fcode) {
+						ent = codetab[i];
+						continue outer_loop;
+					}
+				} while (htab[i] >= 0);
+			}
+			output(ent, outs);
+			ent = c;
+			if (free_ent < maxmaxcode) {
+				codetab[i] = free_ent++; // code -> hashtable
+				htab[i] = fcode;
+			} else
+				cl_block(outs);
+		}
+		// Put out the final code.
+		output(ent, outs);
+		output(EOFCode, outs);
+	}
+
+	// ----------------------------------------------------------------------------
+	void encode(OutputStream os) throws IOException {
+		os.write(initCodeSize); // write "initial code size" byte
+
+		remaining = imgW * imgH; // reset navigation variables
+		curPixel = 0;
+
+		compress(initCodeSize + 1, os); // compress and write the pixel data
+
+		os.write(0); // write block terminator
+	}
+
+	// Flush the packet to disk, and reset the accumulator
+	void flush_char(OutputStream outs) throws IOException {
+		if (a_count > 0) {
+			outs.write(a_count);
+			outs.write(accum, 0, a_count);
+			a_count = 0;
+		}
+	}
+
+	final int MAXCODE(int n_bits) {
+		return (1 << n_bits) - 1;
+	}
+
+	// ----------------------------------------------------------------------------
+	// Return the next pixel from the image
+	// ----------------------------------------------------------------------------
+	private int nextPixel() {
+		if (remaining == 0)
+			return EOF;
+
+		--remaining;
+
+		byte pix = pixAry[curPixel++];
+
+		return pix & 0xff;
+	}
+
+	void output(int code, OutputStream outs) throws IOException {
+		cur_accum &= masks[cur_bits];
+
+		if (cur_bits > 0)
+			cur_accum |= (code << cur_bits);
+		else
+			cur_accum = code;
+
+		cur_bits += n_bits;
+
+		while (cur_bits >= 8) {
+			char_out((byte) (cur_accum & 0xff), outs);
+			cur_accum >>= 8;
+			cur_bits -= 8;
+		}
+
+		// If the next entry is going to be too big for the code size,
+		// then increase it, if possible.
+		if (free_ent > maxcode || clear_flg) {
+			if (clear_flg) {
+				maxcode = MAXCODE(n_bits = g_init_bits);
+				clear_flg = false;
+			} else {
+				++n_bits;
+				if (n_bits == maxbits)
+					maxcode = maxmaxcode;
+				else
+					maxcode = MAXCODE(n_bits);
+			}
+		}
+
+		if (code == EOFCode) {
+			// At EOF, write the rest of the buffer.
+			while (cur_bits > 0) {
+				char_out((byte) (cur_accum & 0xff), outs);
+				cur_accum >>= 8;
+				cur_bits -= 8;
+			}
+
+			flush_char(outs);
+		}
+	}
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/login/web/LoginController.java

+package com.mortals.xhx.base.login.web;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.mortals.framework.common.Rest;
+import com.mortals.framework.service.IAuthTokenService;
+import com.mortals.framework.service.ICacheService;
+import com.mortals.framework.service.IUser;
+import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
+import com.mortals.xhx.base.system.menu.model.MenuEntity;
+import com.mortals.xhx.base.system.menu.service.MenuService;
+import com.mortals.xhx.base.system.resource.service.ResourceService;
+import com.mortals.xhx.base.system.user.model.UserEntity;
+import com.mortals.xhx.base.system.user.service.UserService;
+import com.mortals.xhx.common.key.RedisKey;
+import com.mortals.xhx.common.utils.MenuEncodeUtil;
+import com.mortals.xhx.feign.user.IUserFeign;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+import java.util.Set;
+
+import static com.mortals.xhx.common.key.ErrorCode.ERROR_TOKEN_EXPIRED;
+import static com.mortals.xhx.common.key.ErrorCode.ERROR_TOKEN_EXPIRED_CONTENT;
+
+@RestController
+@Slf4j
+@RequestMapping("login")
+public class LoginController extends BaseCRUDJsonBodyMappingController<UserService, UserEntity, Long> implements InitializingBean {
+
+    @Autowired
+    private ResourceService resourceService;
+    @Autowired
+    private MenuService menuService;
+    @Autowired
+    private ICacheService cacheService;
+    @Autowired
+    private IAuthTokenService authTokenService;
+    @Autowired
+    private IUserFeign userFeign;
+
+
+/*    @RequestMapping("login")
+    public String login(@RequestBody LoginForm loginForm) throws Exception {
+
+        String loginName = loginForm.getLoginName();
+        String password = loginForm.getPassword();
+        LoginPdu loginPdu = new LoginPdu();
+        loginPdu.setLoginName(loginName);
+        loginPdu.setPassword(password);
+        loginPdu.setSecurityCode("admin");
+        String resp = userFeign.portalLogin(loginPdu);
+        return resp;
+    }*/
+
+    @RequestMapping("logout")
+    public void logout(HttpServletRequest request, HttpServletResponse response) throws Exception {
+        recordSysLog(request, "退出登录");
+        super.removeCurrUser(request);
+    }
+
+    @RequestMapping("index")
+    public String index() throws Exception {
+        JSONObject ret = new JSONObject();
+        IUser user = this.getCurUser();
+        if (user == null) {
+            return JSONObject.toJSONString(Rest.fail(ERROR_TOKEN_EXPIRED, ERROR_TOKEN_EXPIRED_CONTENT));
+        }
+        Set<String> urls = resourceService.findUrlSetByUserId(user.getId());
+        log.info("userId:{},urls:{}", user.getId(), JSON.toJSONString(urls));
+        // List<MenuEntity> outlookBarList = menuService.findTreeMenu(user, urls);
+
+        List<MenuEntity> treeMenuList = menuService.findTreeMenu(user);
+        String currUserName = user.getRealName();
+        if (currUserName == null || currUserName.trim().length() == 0) {
+            currUserName = "管理员";
+        }
+        JSONObject data = new JSONObject();
+
+        String token = authTokenService.getToken(request);
+        data.put("token", token);
+        data.put("currUserName", currUserName);
+        data.put("menuList", treeMenuList);
+        data.put("id", user.getId());
+        data.put("userType", user.getUserType());
+        ret.put(KEY_RESULT_DATA, data);
+        cacheService.hset(RedisKey.KEY_USER_MENU_CACHE, user.getId().toString(), MenuEncodeUtil.generateMenuUrlCode(urls));
+
+        ret.put(KEY_RESULT_CODE, VALUE_RESULT_SUCCESS);
+        ret.put(KEY_RESULT_MSG, "用户登录系统成功!");
+        ret.put("resources", urls);
+        return ret.toJSONString();
+    }
+
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        log.info("初始化加载登录。。。");
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/login/web/LoginForm.java

+package com.mortals.xhx.base.login.web;
+
+import com.mortals.framework.exception.AppException;
+import com.mortals.framework.web.BaseForm;
+
+public class LoginForm extends BaseForm {
+    private String loginName;
+
+    private String password;
+
+    private String securityCode;
+
+    public String getLoginName() {
+        return loginName;
+    }
+
+    public void setLoginName(String loginName) {
+        this.loginName = loginName;
+    }
+
+    public String getPassword() {
+        return password;
+    }
+
+    public void setPassword(String password) {
+        this.password = password;
+    }
+
+
+    public String getSecurityCode() {
+        return securityCode;
+    }
+
+    public void setSecurityCode(String securityCode) {
+        this.securityCode = securityCode;
+    }
+
+    @Override
+    public String toString() {
+        return "loginName:" + this.loginName + "  password:" + this.password + "  securityCode:" + this.securityCode;
+    }
+
+    @Override
+    public boolean validate() throws AppException {
+        if (loginName == null || loginName.trim().length() == 0) {
+            throw new AppException("帐号不能为空！");
+        }
+        if (password == null || password.trim().length() == 0) {
+            throw new AppException("密码不能为空！");
+        }
+//        if (securityCode == null || securityCode.trim().length() == 0) {
+//            throw new AppException("验证码不能为空！");
+//        }
+        return super.validate();
+    }
+}

agent-manager/src/main/java/com/mortals/xhx/base/login/web/SecurityCodeController.java

+package com.mortals.xhx.base.login.web;
+
+import com.mortals.framework.util.SecurityImage;
+import com.mortals.framework.web.BaseCRUDJsonController;
+import com.mortals.xhx.base.login.service.GifSecurityImage;
+import com.mortals.xhx.base.system.valid.model.ValidCodeEntity;
+import com.mortals.xhx.base.system.valid.service.ValidCodeService;
+import com.mortals.xhx.base.system.valid.web.ValidCodeForm;
+import org.apache.commons.io.IOUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.awt.image.BufferedImage;
+
+@RestController
+@RequestMapping("securitycode")
+public class SecurityCodeController
+	extends BaseCRUDJsonController<ValidCodeService, ValidCodeForm, ValidCodeEntity, Long> {
+    @Autowired
+    private ValidCodeService validCodeService;
+
+    @RequestMapping("createCode")
+    public void createCode(HttpServletRequest request, HttpServletResponse response) {
+
+	// 获取默认难度和长度的验证码
+	String securityCode = validCodeService.createImageValidCode(request.getSession().getId(),
+		super.getRequestIP(request));
+
+	// int imageType = ParamUtil.getInt("securityImage", 1);
+	int imageType = 0;
+	switch (imageType) {
+	case 1:
+	    BufferedImage image = SecurityImage.createImage(securityCode);
+	    super.doResponseImage(response, image);
+	    break;
+
+	default:
+	    // 默认图验
+	    byte[] content = GifSecurityImage.createGifImage(securityCode);
+	    doResponseGif(response, content);
+	    break;
+	}
+    }
+
+    protected void doResponseGif(HttpServletResponse response, byte[] content) {
+	try {
+	    response.setHeader("Pragma", "No-cache");
+	    response.setHeader("Cache-Control", "No-cache");
+	    response.setDateHeader("Expires", 0);
+	    response.setContentType("image/gif");
+	    IOUtils.write(content, response.getOutputStream());
+	} catch (Exception e) {
+	    log.error("验证码图片传输异常-->" + e.getMessage());
+	}
+    }
+
+}

agent-manager/src/main/java/com/mortals/xhx/base/system/idgenerator/dao/IdgeneratorDao.java

+package com.mortals.xhx.base.system.idgenerator.dao;
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.base.system.idgenerator.model.IdgeneratorEntity;
+
+/**
+ * <p>Title: id生成器</p>
+ * <p>Description: IdgeneratorDao DAO接口 </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ *
+ * @author
+ * @version 1.0.0
+ */
+
+public interface IdgeneratorDao extends ICRUDDao<IdgeneratorEntity, Long> {
+
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/idgenerator/dao/ibatis/IdgeneratorDaoImpl.java

+package com.mortals.xhx.base.system.idgenerator.dao.ibatis;
+
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import com.mortals.xhx.base.system.idgenerator.dao.IdgeneratorDao;
+import com.mortals.xhx.base.system.idgenerator.model.IdgeneratorEntity;
+
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>Title: id生成器</p>
+ * <p>Description: IdgeneratorDaoImpl DAO接口 </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ *
+ * @author
+ * @version 1.0.0
+ */
+@Repository("idgeneratorDao")
+public class IdgeneratorDaoImpl extends BaseCRUDDaoMybatis<IdgeneratorEntity, Long> implements IdgeneratorDao {
+
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/idgenerator/model/IdgeneratorEntity.java

+package com.mortals.xhx.base.system.idgenerator.model;
+
+import com.mortals.framework.model.BaseEntityLong;
+
+import java.util.Date;
+
+/**
+ * <p>Title: id生成器</p>
+ * <p>Description: IdgeneratorEntity  </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ *
+ * @author
+ * @version 1.0.0
+ */
+public class IdgeneratorEntity extends BaseEntityLong {
+
+    private static final long serialVersionUID = 1555564885341L;
+
+    /** id类型 */
+    private String idType;
+
+    /** 当前id最大值 */
+    private Long idMaxValue;
+
+    /** 备注 */
+    private String remark;
+
+    /** 版本号，默认0 */
+    private Long versionNum;
+
+    /** 最后修改时间 */
+    private Date gmtModify;
+
+
+    public IdgeneratorEntity() {
+
+    }
+
+    /**
+     * 获取 id类型
+     *
+     * @return idType
+     */
+    public String getIdType() {
+        return this.idType;
+    }
+
+    /**
+     * 设置 id类型
+     *
+     * @param idType
+     */
+    public void setIdType(String idType) {
+        this.idType = idType;
+    }
+
+    /**
+     * 获取 当前id最大值
+     *
+     * @return idMaxValue
+     */
+    public Long getIdMaxValue() {
+        return this.idMaxValue;
+    }
+
+    /**
+     * 设置 当前id最大值
+     *
+     * @param idMaxValue
+     */
+    public void setIdMaxValue(Long idMaxValue) {
+        this.idMaxValue = idMaxValue;
+    }
+
+    /**
+     * 获取 备注
+     *
+     * @return remark
+     */
+    public String getRemark() {
+        return this.remark;
+    }
+
+    /**
+     * 设置 备注
+     *
+     * @param remark
+     */
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    /**
+     * 获取 版本号，默认0
+     *
+     * @return versionNum
+     */
+    public Long getVersionNum() {
+        return this.versionNum;
+    }
+
+    /**
+     * 设置 版本号，默认0
+     *
+     * @param versionNum
+     */
+    public void setVersionNum(Long versionNum) {
+        this.versionNum = versionNum;
+    }
+
+    /**
+     * 获取 最后修改时间
+     *
+     * @return gmtModify
+     */
+    public Date getGmtModify() {
+        return this.gmtModify;
+    }
+
+    /**
+     * 设置 最后修改时间
+     *
+     * @param gmtModify
+     */
+    public void setGmtModify(Date gmtModify) {
+        this.gmtModify = gmtModify;
+    }
+
+
+    @Override
+    public int hashCode() {
+        return this.getId().hashCode();
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (obj == null) {
+            return false;
+        }
+        if (obj instanceof IdgeneratorEntity) {
+            IdgeneratorEntity tmp = (IdgeneratorEntity) obj;
+            return this.getId().longValue() == tmp.getId().longValue();
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return "IdgeneratorEntity{" + "idType='" + idType + '\'' + ", idMaxValue=" + idMaxValue + ", remark='" + remark
+                + '\'' + ", versionNum=" + versionNum + ", gmtModify=" + gmtModify + ", id=" + id + '}';
+    }
+
+    @Override
+    public void initAttrValue() {
+        this.idType = null;
+        this.idMaxValue = null;
+        this.remark = null;
+        this.versionNum = 0L;
+        this.gmtModify = null;
+    }
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/idgenerator/service/IdgeneratorService.java

+package com.mortals.xhx.base.system.idgenerator.service;
+
+import java.util.List;
+
+import com.mortals.xhx.base.system.idgenerator.service.impl.IdgeneratorServiceImpl.IdGeneratorKey;
+
+/**
+ * <p>Title: id生成器</p>
+ * <p>Description: IdgeneratorService service接口 </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ *
+ * @author
+ * @version 1.0.0
+ */
+
+public interface IdgeneratorService {
+
+    /**
+     * 获取Long类型ID
+     *
+     * @param idGeneratorKey
+     * @param factorInfo     生成因子，根据各IdGeneratorKey要求选择传入
+     * @return
+     * @createTime 2016年3月16日 上午10:43:22
+     */
+    Long getLongId(IdGeneratorKey idGeneratorKey, Object... factorInfo);
+
+    /**
+     * 获取String类型ID
+     *
+     * @param idGeneratorKey
+     * @param factorInfo     生成因子，根据各IdGeneratorKey要求选择传入
+     * @return
+     * @createTime 2016年3月16日 上午10:43:38
+     */
+    String getStringId(IdGeneratorKey idGeneratorKey, Object... factorInfo);
+
+    /**
+     * 批量获取Long类型ID
+     *
+     * @param idGeneratorKey
+     * @param factorInfo
+     * @return
+     */
+    List<Long> getLongIdList(IdGeneratorKey idGeneratorKey, Object... factorInfo);
+
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/menu/dao/MenuDao.java

+/**
+* 文件：MenuDao.java
+* 版本：1.0.0
+* 日期：
+* Copyright ® 
+* All right reserved.
+*/
+
+package com.mortals.xhx.base.system.menu.dao;
+
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.base.system.menu.model.MenuEntity;
+import com.mortals.xhx.base.system.resource.model.ResourceEntity;
+
+import java.util.List;
+
+/**
+ * <p>Title: 菜单信息</p>
+ * <p>Description: MenuDao DAO接口 </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ * @author 
+ * @version 1.0.0
+ */
+
+public interface MenuDao extends ICRUDDao<MenuEntity,Long> {
+    List<MenuEntity> getListByUserId(Long userId);
+
+    /**
+     * 查询子节点
+     *
+     * @param
+     * @return
+     */
+    List<MenuEntity> selectChildrenMenuById(String menuId);
+
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/menu/dao/ibatis/MenuDaoImpl.java

+/**
+* 文件：MenuDaoImpl.java
+* 版本：1.0.0
+* 日期：
+* Copyright ® 
+* All right reserved.
+*/
+
+package com.mortals.xhx.base.system.menu.dao.ibatis;
+
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import com.mortals.framework.model.ParamDto;
+import com.mortals.xhx.base.system.menu.dao.MenuDao;
+import com.mortals.xhx.base.system.menu.model.MenuEntity;
+
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+/**
+ * <p>Title: 菜单信息</p>
+ * <p>Description: MenuDaoImpl DAO接口 </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ * @author 
+ * @version 1.0.0
+ */
+@Repository("menuDao")
+public class MenuDaoImpl extends BaseCRUDDaoMybatis<MenuEntity,Long> implements MenuDao {
+
+
+    @Override
+    public List<MenuEntity> selectChildrenMenuById(String menuId) {
+        return getSqlSession().selectList(getSqlId("selectChildrenMenuById"), menuId);
+    }
+
+    @Override
+    public List<MenuEntity> getListByUserId(Long userId) {
+        ParamDto param = new ParamDto();
+        param.getCondition().put("userId", userId);
+        return getSqlSession().selectList(getSqlId("getListByUserId"), param);
+    }
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/menu/model/vo/MenuVo.java

+package com.mortals.xhx.base.system.menu.model.vo;
+import com.mortals.framework.model.BaseEntityLong;
+import com.mortals.xhx.base.system.menu.model.MenuEntity;
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Data;
+import com.mortals.framework.annotation.Excel;
+import java.math.BigDecimal;
+import java.util.Date;
+/**
+* 菜单信息业务视图对象
+*
+* @author zxfei
+* @date 2024-09-06
+*/
+@Data
+public class MenuVo extends BaseEntityLong {
+
+    /** 菜单ID，主键，自增长列表 */
+    private List <Long> idList;
+
+
+    /** 子菜单信息业务 */
+    private List<MenuEntity> children = new ArrayList<>();
+
+    private List<MenuEntity> childList = new ArrayList<>();
+
+
+    private Integer type;
+    /**
+     * 是否选中，0为未选中，1选中。默认0
+     */
+    private Integer checked;
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/oper/dao/OperLogDao.java

+/**
+* 文件：OperLogDao.java
+* 版本：1.0.0
+* 日期：
+* Copyright ® 
+* All right reserved.
+*/
+
+package com.mortals.xhx.base.system.oper.dao;
+
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.base.system.oper.model.OperLogEntity;
+
+/**
+ * <p>Title: 操作日志</p>
+ * <p>Description: OperLogDao DAO接口 </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ * @author 
+ * @version 1.0.0
+ */
+
+public interface OperLogDao extends ICRUDDao<OperLogEntity,Long> {
+	
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/oper/dao/ibatis/OperLogDaoImpl.java

+/**
+* 文件：OperLogDaoImpl.java
+* 版本：1.0.0
+* 日期：
+* Copyright ® 
+* All right reserved.
+*/
+
+package com.mortals.xhx.base.system.oper.dao.ibatis;
+
+import com.mortals.framework.dao.ibatis.BaseCRUDDaoMybatis;
+import com.mortals.xhx.base.system.oper.dao.OperLogDao;
+import com.mortals.xhx.base.system.oper.model.OperLogEntity;
+
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>Title: 操作日志</p>
+ * <p>Description: OperLogDaoImpl DAO接口 </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ * @author 
+ * @version 1.0.0
+ */
+@Repository("operLogDao")
+public class OperLogDaoImpl extends BaseCRUDDaoMybatis<OperLogEntity,Long> implements OperLogDao {
+
+}
\ No newline at end of file

agent-manager/src/main/java/com/mortals/xhx/base/system/param/dao/ParamDao.java

+/**
+* 文件：ParamDao.java
+* 版本：1.0.0
+* 日期：
+* Copyright ® 
+* All right reserved.
+*/
+
+package com.mortals.xhx.base.system.param.dao;
+
+
+import com.mortals.framework.dao.ICRUDDao;
+import com.mortals.xhx.base.system.param.model.ParamEntity;
+
+/**
+ * <p>Title: 参数信息</p>
+ * <p>Description: ParamDao DAO接口 </p>
+ * <p>Copyright: Copyright &reg;  </p>
+ * <p>Company: </p>
+ * @author 
+ * @version 1.0.0
+ */
+
+public interface ParamDao extends ICRUDDao<ParamEntity,Long> {
+	
+}
\ No newline at end of file