commit a10633894933039a161ff251441dfbbc62de29f9
Author: lijiazhuo <13787924+lijiazhuosky@user.noreply.gitee.com>
Date: Fri Sep 26 14:16:20 2025 +0800
first commit
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..a2a3040
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,31 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**
+!**/src/test/**
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+
+### VS Code ###
+.vscode/
diff --git a/.mvn/wrapper/MavenWrapperDownloader.java b/.mvn/wrapper/MavenWrapperDownloader.java
new file mode 100644
index 0000000..74f4de4
--- /dev/null
+++ b/.mvn/wrapper/MavenWrapperDownloader.java
@@ -0,0 +1,118 @@
+/*
+ * Copyright 2012-2019 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import java.net.*;
+import java.io.*;
+import java.nio.channels.*;
+import java.util.Properties;
+
+public class MavenWrapperDownloader {
+
+ private static final String WRAPPER_VERSION = "0.5.5";
+ /**
+ * Default URL to download the maven-wrapper.jar from, if no 'downloadUrl' is provided.
+ */
+ private static final String DEFAULT_DOWNLOAD_URL = "https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/"
+ + WRAPPER_VERSION + "/maven-wrapper-" + WRAPPER_VERSION + ".jar";
+
+ /**
+ * Path to the maven-wrapper.properties file, which might contain a downloadUrl property to
+ * use instead of the default one.
+ */
+ private static final String MAVEN_WRAPPER_PROPERTIES_PATH =
+ ".mvn/wrapper/maven-wrapper.properties";
+
+ /**
+ * Path where the maven-wrapper.jar will be saved to.
+ */
+ private static final String MAVEN_WRAPPER_JAR_PATH =
+ ".mvn/wrapper/maven-wrapper.jar";
+
+ /**
+ * Name of the property which should be used to override the default download url for the wrapper.
+ */
+ private static final String PROPERTY_NAME_WRAPPER_URL = "wrapperUrl";
+
+ public static void main(String args[]) {
+ System.out.println("- Downloader started");
+ File baseDirectory = new File(args[0]);
+ System.out.println("- Using base directory: " + baseDirectory.getAbsolutePath());
+
+ // If the maven-wrapper.properties exists, read it and check if it contains a custom
+ // wrapperUrl parameter.
+ File mavenWrapperPropertyFile = new File(baseDirectory, MAVEN_WRAPPER_PROPERTIES_PATH);
+ String url = DEFAULT_DOWNLOAD_URL;
+ if (mavenWrapperPropertyFile.exists()) {
+ FileInputStream mavenWrapperPropertyFileInputStream = null;
+ try {
+ mavenWrapperPropertyFileInputStream = new FileInputStream(mavenWrapperPropertyFile);
+ Properties mavenWrapperProperties = new Properties();
+ mavenWrapperProperties.load(mavenWrapperPropertyFileInputStream);
+ url = mavenWrapperProperties.getProperty(PROPERTY_NAME_WRAPPER_URL, url);
+ } catch (IOException e) {
+ System.out.println("- ERROR loading '" + MAVEN_WRAPPER_PROPERTIES_PATH + "'");
+ } finally {
+ try {
+ if (mavenWrapperPropertyFileInputStream != null) {
+ mavenWrapperPropertyFileInputStream.close();
+ }
+ } catch (IOException e) {
+ // Ignore ...
+ }
+ }
+ }
+ System.out.println("- Downloading from: " + url);
+
+ File outputFile = new File(baseDirectory.getAbsolutePath(), MAVEN_WRAPPER_JAR_PATH);
+ if (!outputFile.getParentFile().exists()) {
+ if (!outputFile.getParentFile().mkdirs()) {
+ System.out.println(
+ "- ERROR creating output directory '" + outputFile.getParentFile().getAbsolutePath() + "'");
+ }
+ }
+ System.out.println("- Downloading to: " + outputFile.getAbsolutePath());
+ try {
+ downloadFileFromURL(url, outputFile);
+ System.out.println("Done");
+ System.exit(0);
+ } catch (Throwable e) {
+ System.out.println("- Error downloading");
+ e.printStackTrace();
+ System.exit(1);
+ }
+ }
+
+ private static void downloadFileFromURL(String urlString, File destination) throws Exception {
+ if (System.getenv("MVNW_USERNAME") != null && System.getenv("MVNW_PASSWORD") != null) {
+ String username = System.getenv("MVNW_USERNAME");
+ char[] password = System.getenv("MVNW_PASSWORD").toCharArray();
+ Authenticator.setDefault(new Authenticator() {
+ @Override
+ protected PasswordAuthentication getPasswordAuthentication() {
+ return new PasswordAuthentication(username, password);
+ }
+ });
+ }
+ URL website = new URL(urlString);
+ ReadableByteChannel rbc;
+ rbc = Channels.newChannel(website.openStream());
+ FileOutputStream fos = new FileOutputStream(destination);
+ fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
+ fos.close();
+ rbc.close();
+ }
+
+}
diff --git a/.mvn/wrapper/maven-wrapper.jar b/.mvn/wrapper/maven-wrapper.jar
new file mode 100644
index 0000000..0d5e649
Binary files /dev/null and b/.mvn/wrapper/maven-wrapper.jar differ
diff --git a/.mvn/wrapper/maven-wrapper.properties b/.mvn/wrapper/maven-wrapper.properties
new file mode 100644
index 0000000..7d59a01
--- /dev/null
+++ b/.mvn/wrapper/maven-wrapper.properties
@@ -0,0 +1,2 @@
+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.6.2/apache-maven-3.6.2-bin.zip
+wrapperUrl=https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.5/maven-wrapper-0.5.5.jar
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..6a59abd
--- /dev/null
+++ b/README.md
@@ -0,0 +1,5 @@
+项目概述：
+此项目为接手项目，没有交接，里边的任何代码需自己研究
+
+对接人：
+王波涵，王茜 （如果需要接口文档以及业务逻辑上的问题请联系王茜，王波涵）
\ No newline at end of file
diff --git a/mvnw b/mvnw
new file mode 100644
index 0000000..822f699
--- /dev/null
+++ b/mvnw
@@ -0,0 +1,322 @@
+#!/bin/sh
+# ----------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements. See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership. The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License. You may obtain a copy of the License at
+#
+# https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied. See the License for the
+# specific language governing permissions and limitations
+# under the License.
+# ----------------------------------------------------------------------------
+
+# ----------------------------------------------------------------------------
+# Maven2 Start Up Batch script
+#
+# Required ENV vars:
+# ------------------
+# JAVA_HOME - location of a JDK home dir
+#
+# Optional ENV vars
+# -----------------
+# M2_HOME - location of maven2's installed home dir
+# MAVEN_OPTS - parameters passed to the Java VM when running Maven
+# e.g. to debug Maven itself, use
+# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
+# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
+# ----------------------------------------------------------------------------
+
+if [ -z "$MAVEN_SKIP_RC" ]; then
+
+ if [ -f /etc/mavenrc ]; then
+ . /etc/mavenrc
+ fi
+
+ if [ -f "$HOME/.mavenrc" ]; then
+ . "$HOME/.mavenrc"
+ fi
+
+fi
+
+# OS specific support. $var _must_ be set to either true or false.
+cygwin=false
+darwin=false
+mingw=false
+case "$(uname)" in
+CYGWIN*) cygwin=true ;;
+MINGW*) mingw=true ;;
+Darwin*)
+ darwin=true
+ # Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
+ # See https://developer.apple.com/library/mac/qa/qa1170/_index.html
+ if [ -z "$JAVA_HOME" ]; then
+ if [ -x "/usr/libexec/java_home" ]; then
+ export JAVA_HOME="$(/usr/libexec/java_home)"
+ else
+ export JAVA_HOME="/Library/Java/Home"
+ fi
+ fi
+ ;;
+esac
+
+if [ -z "$JAVA_HOME" ]; then
+ if [ -r /etc/gentoo-release ]; then
+ JAVA_HOME=$(java-config --jre-home)
+ fi
+fi
+
+if [ -z "$M2_HOME" ]; then
+ ## resolve links - $0 may be a link to maven's home
+ PRG="$0"
+
+ # need this for relative symlinks
+ while [ -h "$PRG" ]; do
+ ls=$(ls -ld "$PRG")
+ link=$(expr "$ls" : '.*-> \(.*\)$')
+ if expr "$link" : '/.*' >/dev/null; then
+ PRG="$link"
+ else
+ PRG="$(dirname "$PRG")/$link"
+ fi
+ done
+
+ saveddir=$(pwd)
+
+ M2_HOME=$(dirname "$PRG")/..
+
+ # make it fully qualified
+ M2_HOME=$(cd "$M2_HOME" && pwd)
+
+ cd "$saveddir"
+ # echo Using m2 at $M2_HOME
+fi
+
+# For Cygwin, ensure paths are in UNIX format before anything is touched
+if $cygwin; then
+ [ -n "$M2_HOME" ] &&
+ M2_HOME=$(cygpath --unix "$M2_HOME")
+ [ -n "$JAVA_HOME" ] &&
+ JAVA_HOME=$(cygpath --unix "$JAVA_HOME")
+ [ -n "$CLASSPATH" ] &&
+ CLASSPATH=$(cygpath --path --unix "$CLASSPATH")
+fi
+
+# For Mingw, ensure paths are in UNIX format before anything is touched
+if $mingw; then
+ [ -n "$M2_HOME" ] &&
+ M2_HOME="$( (
+ cd "$M2_HOME"
+ pwd
+ ))"
+ [ -n "$JAVA_HOME" ] &&
+ JAVA_HOME="$( (
+ cd "$JAVA_HOME"
+ pwd
+ ))"
+fi
+
+if [ -z "$JAVA_HOME" ]; then
+ javaExecutable="$(which javac)"
+ if [ -n "$javaExecutable" ] && ! [ "$(expr \"$javaExecutable\" : '\([^ ]*\)')" = "no" ]; then
+ # readlink(1) is not available as standard on Solaris 10.
+ readLink=$(which readlink)
+ if [ ! $(expr "$readLink" : '\([^ ]*\)') = "no" ]; then
+ if $darwin; then
+ javaHome="$(dirname \"$javaExecutable\")"
+ javaExecutable="$(cd \"$javaHome\" && pwd -P)/javac"
+ else
+ javaExecutable="$(readlink -f \"$javaExecutable\")"
+ fi
+ javaHome="$(dirname \"$javaExecutable\")"
+ javaHome=$(expr "$javaHome" : '\(.*\)/bin')
+ JAVA_HOME="$javaHome"
+ export JAVA_HOME
+ fi
+ fi
+fi
+
+if [ -z "$JAVACMD" ]; then
+ if [ -n "$JAVA_HOME" ]; then
+ if [ -x "$JAVA_HOME/jre/sh/java" ]; then
+ # IBM's JDK on AIX uses strange locations for the executables
+ JAVACMD="$JAVA_HOME/jre/sh/java"
+ else
+ JAVACMD="$JAVA_HOME/bin/java"
+ fi
+ else
+ JAVACMD="$(which java)"
+ fi
+fi
+
+if [ ! -x "$JAVACMD" ]; then
+ echo "Error: JAVA_HOME is not defined correctly." >&2
+ echo " We cannot execute $JAVACMD" >&2
+ exit 1
+fi
+
+if [ -z "$JAVA_HOME" ]; then
+ echo "Warning: JAVA_HOME environment variable is not set."
+fi
+
+CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher
+
+# traverses directory structure from process work directory to filesystem root
+# first directory with .mvn subdirectory is considered project base directory
+find_maven_basedir() {
+
+ if [ -z "$1" ]; then
+ echo "Path not specified to find_maven_basedir"
+ return 1
+ fi
+
+ basedir="$1"
+ wdir="$1"
+ while [ "$wdir" != '/' ]; do
+ if [ -d "$wdir"/.mvn ]; then
+ basedir=$wdir
+ break
+ fi
+ # workaround for JBEAP-8937 (on Solaris 10/Sparc)
+ if [ -d "${wdir}" ]; then
+ wdir=$(
+ cd "$wdir/.."
+ pwd
+ )
+ fi
+ # end of workaround
+ done
+ echo "${basedir}"
+}
+
+# concatenates all lines of a file
+concat_lines() {
+ if [ -f "$1" ]; then
+ echo "$(tr -s '\n' ' ' <"$1")"
+ fi
+}
+
+BASE_DIR=$(find_maven_basedir "$(pwd)")
+if [ -z "$BASE_DIR" ]; then
+ exit 1
+fi
+
+##########################################################################################
+# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
+# This allows using the maven wrapper in projects that prohibit checking in binary data.
+##########################################################################################
+if [ -r "$BASE_DIR/.mvn/wrapper/maven-wrapper.jar" ]; then
+ if [ "$MVNW_VERBOSE" = true ]; then
+ echo "Found .mvn/wrapper/maven-wrapper.jar"
+ fi
+else
+ if [ "$MVNW_VERBOSE" = true ]; then
+ echo "Couldn't find .mvn/wrapper/maven-wrapper.jar, downloading it ..."
+ fi
+ if [ -n "$MVNW_REPOURL" ]; then
+ jarUrl="$MVNW_REPOURL/io/takari/maven-wrapper/0.5.5/maven-wrapper-0.5.5.jar"
+ else
+ jarUrl="https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.5/maven-wrapper-0.5.5.jar"
+ fi
+ while IFS="=" read key value; do
+ case "$key" in wrapperUrl)
+ jarUrl="$value"
+ break
+ ;;
+ esac
+ done <"$BASE_DIR/.mvn/wrapper/maven-wrapper.properties"
+ if [ "$MVNW_VERBOSE" = true ]; then
+ echo "Downloading from: $jarUrl"
+ fi
+ wrapperJarPath="$BASE_DIR/.mvn/wrapper/maven-wrapper.jar"
+ if $cygwin; then
+ wrapperJarPath=$(cygpath --path --windows "$wrapperJarPath")
+ fi
+
+ if command -v wget >/dev/null; then
+ if [ "$MVNW_VERBOSE" = true ]; then
+ echo "Found wget ... using wget"
+ fi
+ if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
+ wget "$jarUrl" -O "$wrapperJarPath"
+ else
+ wget --http-user=$MVNW_USERNAME --http-password=$MVNW_PASSWORD "$jarUrl" -O "$wrapperJarPath"
+ fi
+ elif command -v curl >/dev/null; then
+ if [ "$MVNW_VERBOSE" = true ]; then
+ echo "Found curl ... using curl"
+ fi
+ if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
+ curl -o "$wrapperJarPath" "$jarUrl" -f
+ else
+ curl --user $MVNW_USERNAME:$MVNW_PASSWORD -o "$wrapperJarPath" "$jarUrl" -f
+ fi
+
+ else
+ if [ "$MVNW_VERBOSE" = true ]; then
+ echo "Falling back to using Java to download"
+ fi
+ javaClass="$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.java"
+ # For Cygwin, switch paths to Windows format before running javac
+ if $cygwin; then
+ javaClass=$(cygpath --path --windows "$javaClass")
+ fi
+ if [ -e "$javaClass" ]; then
+ if [ ! -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
+ if [ "$MVNW_VERBOSE" = true ]; then
+ echo " - Compiling MavenWrapperDownloader.java ..."
+ fi
+ # Compiling the Java class
+ ("$JAVA_HOME/bin/javac" "$javaClass")
+ fi
+ if [ -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
+ # Running the downloader
+ if [ "$MVNW_VERBOSE" = true ]; then
+ echo " - Running MavenWrapperDownloader.java ..."
+ fi
+ ("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$MAVEN_PROJECTBASEDIR")
+ fi
+ fi
+ fi
+fi
+##########################################################################################
+# End of extension
+##########################################################################################
+
+export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
+if [ "$MVNW_VERBOSE" = true ]; then
+ echo $MAVEN_PROJECTBASEDIR
+fi
+MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin; then
+ [ -n "$M2_HOME" ] &&
+ M2_HOME=$(cygpath --path --windows "$M2_HOME")
+ [ -n "$JAVA_HOME" ] &&
+ JAVA_HOME=$(cygpath --path --windows "$JAVA_HOME")
+ [ -n "$CLASSPATH" ] &&
+ CLASSPATH=$(cygpath --path --windows "$CLASSPATH")
+ [ -n "$MAVEN_PROJECTBASEDIR" ] &&
+ MAVEN_PROJECTBASEDIR=$(cygpath --path --windows "$MAVEN_PROJECTBASEDIR")
+fi
+
+# Provide a "standardized" way to retrieve the CLI args that will
+# work with both Windows and non-Windows executions.
+MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $@"
+export MAVEN_CMD_LINE_ARGS
+
+WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
+
+exec "$JAVACMD" \
+ $MAVEN_OPTS \
+ -classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
+ "-Dmaven.home=${M2_HOME}" "-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
+ ${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"
diff --git a/mvnw.cmd b/mvnw.cmd
new file mode 100644
index 0000000..84d60ab
--- /dev/null
+++ b/mvnw.cmd
@@ -0,0 +1,182 @@
+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements. See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership. The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License. You may obtain a copy of the License at
+@REM
+@REM https://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied. See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Maven2 Start Up Batch script
+@REM
+@REM Required ENV vars:
+@REM JAVA_HOME - location of a JDK home dir
+@REM
+@REM Optional ENV vars
+@REM M2_HOME - location of maven2's installed home dir
+@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
+@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a key stroke before ending
+@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
+@REM e.g. to debug Maven itself, use
+@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
+@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
+@REM ----------------------------------------------------------------------------
+
+@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
+@echo off
+@REM set title of command window
+title %0
+@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
+@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%
+
+@REM set %HOME% to equivalent of $HOME
+if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
+
+@REM Execute a user defined script before this one
+if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
+@REM check for pre script, once with legacy .bat ending and once with .cmd ending
+if exist "%HOME%\mavenrc_pre.bat" call "%HOME%\mavenrc_pre.bat"
+if exist "%HOME%\mavenrc_pre.cmd" call "%HOME%\mavenrc_pre.cmd"
+:skipRcPre
+
+@setlocal
+
+set ERROR_CODE=0
+
+@REM To isolate internal variables from possible post scripts, we use another setlocal
+@setlocal
+
+@REM ==== START VALIDATION ====
+if not "%JAVA_HOME%" == "" goto OkJHome
+
+echo.
+echo Error: JAVA_HOME not found in your environment. >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+:OkJHome
+if exist "%JAVA_HOME%\bin\java.exe" goto init
+
+echo.
+echo Error: JAVA_HOME is set to an invalid directory. >&2
+echo JAVA_HOME = "%JAVA_HOME%" >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+@REM ==== END VALIDATION ====
+
+:init
+
+@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
+@REM Fallback to current working directory if not found.
+
+set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
+IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
+
+set EXEC_DIR=%CD%
+set WDIR=%EXEC_DIR%
+:findBaseDir
+IF EXIST "%WDIR%"\.mvn goto baseDirFound
+cd ..
+IF "%WDIR%"=="%CD%" goto baseDirNotFound
+set WDIR=%CD%
+goto findBaseDir
+
+:baseDirFound
+set MAVEN_PROJECTBASEDIR=%WDIR%
+cd "%EXEC_DIR%"
+goto endDetectBaseDir
+
+:baseDirNotFound
+set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
+cd "%EXEC_DIR%"
+
+:endDetectBaseDir
+
+IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
+
+@setlocal EnableExtensions EnableDelayedExpansion
+for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
+@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
+
+:endReadAdditionalConfig
+
+SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
+set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
+set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
+
+set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.5/maven-wrapper-0.5.5.jar"
+
+FOR /F "tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
+ IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
+)
+
+@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
+@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
+if exist %WRAPPER_JAR% (
+ if "%MVNW_VERBOSE%" == "true" (
+ echo Found %WRAPPER_JAR%
+ )
+) else (
+ if not "%MVNW_REPOURL%" == "" (
+ SET DOWNLOAD_URL="%MVNW_REPOURL%/io/takari/maven-wrapper/0.5.5/maven-wrapper-0.5.5.jar"
+ )
+ if "%MVNW_VERBOSE%" == "true" (
+ echo Couldn't find %WRAPPER_JAR%, downloading it ...
+ echo Downloading from: %DOWNLOAD_URL%
+ )
+
+ powershell -Command "&{"^
+ "$webclient = new-object System.Net.WebClient;"^
+ "if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
+ "$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
+ "}"^
+ "[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
+ "}"
+ if "%MVNW_VERBOSE%" == "true" (
+ echo Finished downloading %WRAPPER_JAR%
+ )
+)
+@REM End of extension
+
+@REM Provide a "standardized" way to retrieve the CLI args that will
+@REM work with both Windows and non-Windows executions.
+set MAVEN_CMD_LINE_ARGS=%*
+
+%MAVEN_JAVA_EXE% %JVM_CONFIG_MAVEN_PROPS% %MAVEN_OPTS% %MAVEN_DEBUG_OPTS% -classpath %WRAPPER_JAR% "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
+if ERRORLEVEL 1 goto error
+goto end
+
+:error
+set ERROR_CODE=1
+
+:end
+@endlocal & set ERROR_CODE=%ERROR_CODE%
+
+if not "%MAVEN_SKIP_RC%" == "" goto skipRcPost
+@REM check for post script, once with legacy .bat ending and once with .cmd ending
+if exist "%HOME%\mavenrc_post.bat" call "%HOME%\mavenrc_post.bat"
+if exist "%HOME%\mavenrc_post.cmd" call "%HOME%\mavenrc_post.cmd"
+:skipRcPost
+
+@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
+if "%MAVEN_BATCH_PAUSE%" == "on" pause
+
+if "%MAVEN_TERMINATE_CMD%" == "on" exit %ERROR_CODE%
+
+exit /B %ERROR_CODE%
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..62ae4bf
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,68 @@
+
+
+ 4.0.0
+
+ org.springframework.boot
+ spring-boot-starter-parent
+ 2.2.1.RELEASE
+
+
+ com.example
+ sso
+ 0.0.1-SNAPSHOT
+ jar
+ sso
+ Demo project for Spring Boot
+
+
+ 1.8
+
+
+
+
+ com.auth0
+ java-jwt
+ 3.8.1
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+ org.springframework.boot
+ spring-boot-configuration-processor
+ true
+
+
+ org.projectlombok
+ lombok
+ true
+
+
+ org.springframework.boot
+ spring-boot-starter-test
+ test
+
+
+ org.apache.httpcomponents
+ httpclient
+ 4.5.13
+
+
+ com.alibaba
+ fastjson
+ 1.2.45
+
+
+
+
+
+
+ org.springframework.boot
+ spring-boot-maven-plugin
+
+
+
+
+
diff --git a/src/main/java/com/example/sso/SsoApplication.java b/src/main/java/com/example/sso/SsoApplication.java
new file mode 100644
index 0000000..05a1199
--- /dev/null
+++ b/src/main/java/com/example/sso/SsoApplication.java
@@ -0,0 +1,15 @@
+package com.example.sso;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@SpringBootApplication
+@EnableScheduling
+public class SsoApplication {
+
+ public static void main(String[] args) {
+ SpringApplication.run(SsoApplication.class, args);
+ }
+
+}
diff --git a/src/main/java/com/example/sso/config/SSOConfig.java b/src/main/java/com/example/sso/config/SSOConfig.java
new file mode 100644
index 0000000..f3e9ca8
--- /dev/null
+++ b/src/main/java/com/example/sso/config/SSOConfig.java
@@ -0,0 +1,23 @@
+package com.example.sso.config;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.validation.annotation.Validated;
+
+//import javax.validation.constraints.NotBlank;
+
+@Configuration
+@ConfigurationProperties(prefix = "sso")
+@NoArgsConstructor
+@AllArgsConstructor
+@Validated
+@Getter
+@Setter
+public class SSOConfig {
+ private String acs;
+ private String secret;
+}
diff --git a/src/main/java/com/example/sso/controller/BeiSenController.java b/src/main/java/com/example/sso/controller/BeiSenController.java
new file mode 100644
index 0000000..5aab2bc
--- /dev/null
+++ b/src/main/java/com/example/sso/controller/BeiSenController.java
@@ -0,0 +1,117 @@
+package com.example.sso.controller;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.config.SSOConfig;
+import com.example.sso.dao.J9051Dao;
+import com.example.sso.dao.J9052Dao;
+import com.example.sso.dao.J9053Dao;
+import com.example.sso.dao.J905Dao;
+import com.example.sso.service.JDYAuthService;
+import com.example.sso.service.SSOService;
+import com.example.sso.util.BeiSenTest;
+import com.example.sso.util.J905Util;
+import com.example.sso.util.JDYUtil;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.util.Date;
+import java.util.HashMap;
+@RestController
+@NoArgsConstructor
+@AllArgsConstructor
+class BeiSenController {
+ @Getter @Setter @Autowired private SSOConfig ssoConfig;
+ private JSONObject limitIpInfo_dep1 = new JSONObject();
+ private JSONObject limitIpInfo_dep2 = new JSONObject();
+ private JSONObject limitIpInfo_dep3 = new JSONObject();
+ private JSONObject limitIpInfo_dep4 = new JSONObject();
+ private JSONObject limitIpInfo_dep5 = new JSONObject();
+ private JSONObject limitIpInfo_dep6 = new JSONObject();
+ @Getter @Setter @Autowired private SSOService ssoService;
+ @Getter @Setter @Autowired private JDYAuthService jdyAuthService;
+ Logger logger = LoggerFactory.getLogger(getClass());
+
+ /**
+ * 创建人员信息
+ */
+ @GetMapping("/createPerson")
+ public void yxMes() throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ JSONArray drivers=JDYUtil.getAllDrivers();//查询
+ for (Object o:drivers){
+ JSONObject driver=(JSONObject)o;
+ JSONObject orgNos=JDYUtil.getOrgNos();
+ BeiSenTest.createUser(driver,orgNos,"");
+ }
+ }catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ /**
+ * 接收简道云新增的人员数据
+ */
+ @PostMapping("/createPerson_jdy")
+ public void yxMes3(@RequestBody JSONObject driver){
+ try {
+ logger.info(driver.toJSONString());
+ if (driver.getJSONObject("data").getString("status").equals("已择车") ||
+ driver.getJSONObject("data").getString("status").equals("运营")){
+ //if (driver.getJSONObject("data").getString("status").equals("运营")){
+ //这个情况说明上车，创建账户
+ JSONObject orgNos=JDYUtil.getOrgNos();
+ JSONObject data=driver.getJSONObject("data");
+ BeiSenTest.createUser(data,orgNos,driver.getJSONObject("data").getString("_id"));
+ }else if (driver.getJSONObject("data").getString("status").equals("已下车")){
+ //}else if (driver.getJSONObject("data").getString("status").equals("已下车")||
+ //driver.getJSONObject("data").getString("status").equals("休医疗期")){
+ BeiSenTest.deleteUser(driver.getJSONObject("data").getInteger("beisen_id"));
+ }
+ }catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+
+ /**
+ * 更新人员数据信息，修护职务、身份证号码信息
+ */
+ @GetMapping("/updatePersonData")
+ public void yxMes2(){
+ //修改职工基础信息数据
+ try {
+ JSONArray beiSens = JDYUtil.getAllDriversBeiSen();//查询
+ JSONArray drivers = JDYUtil.getAllDrivers();//查询
+ JSONObject orgNos=JDYUtil.getOrgNos();
+ JSONObject jsonObject = new JSONObject();
+ for (Object o : drivers) {
+ HashMap driver = (HashMap) o;
+ jsonObject.put((String) driver.get("shjh") + "@yinjian.com", driver);
+ }
+ for (Object o : beiSens) {
+ JSONObject driver = (JSONObject) o;
+ if (jsonObject.getJSONObject(driver.getString("zhanghao"))!=null){
+// BeiSenTest.updateUser(driver,driver.getString("oid"),orgNos);
+// System.out.println(jsonObject.getJSONObject(driver.getString("zhanghao")));
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+
+}
diff --git a/src/main/java/com/example/sso/controller/SSOController.java b/src/main/java/com/example/sso/controller/SSOController.java
new file mode 100644
index 0000000..257e4c3
--- /dev/null
+++ b/src/main/java/com/example/sso/controller/SSOController.java
@@ -0,0 +1,365 @@
+package com.example.sso.controller;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.config.SSOConfig;
+import com.example.sso.dao.J9051Dao;
+import com.example.sso.dao.J9052Dao;
+import com.example.sso.dao.J9053Dao;
+import com.example.sso.dao.J905Dao;
+import com.example.sso.service.*;
+import com.example.sso.util.J905Util;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import javax.servlet.http.HttpServletRequest;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.util.Date;
+@RestController
+@NoArgsConstructor
+@AllArgsConstructor
+class SSOController {
+ @Getter @Setter @Autowired private SSOConfig ssoConfig;
+ private JSONObject limitIpInfo_dep1 = new JSONObject();
+ private JSONObject limitIpInfo_dep2 = new JSONObject();
+ private JSONObject limitIpInfo_dep3 = new JSONObject();
+ private JSONObject limitIpInfo_dep4 = new JSONObject();
+ private JSONObject limitIpInfo_dep5 = new JSONObject();
+ private JSONObject limitIpInfo_dep6 = new JSONObject();
+ @Getter @Setter @Autowired private SSOService ssoService;
+ @Getter @Setter @Autowired private JDYAuthService jdyAuthService;
+ Logger logger = LoggerFactory.getLogger(getClass());
+ /**
+ * 查询SIM卡号，车牌号和终端号的对应关系
+ * @param jsonMes
+ * @param httpServletRequest
+ * @return
+ * @throws KeyManagementException
+ * @throws NoSuchAlgorithmException
+ */
+ @PostMapping("/mdnVcn/getPageList")
+ public JSONObject yxMes(@RequestBody JSONObject jsonMes,HttpServletRequest httpServletRequest) throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ String ip = httpServletRequest.getRemoteAddr();
+ if (limitIpInfo_dep1.getJSONObject(ip) == null) {
+ limitIpInfo_dep1.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J905Dao.getAllSims();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ } else {
+ JSONObject limitInfo = limitIpInfo_dep1.getJSONObject(ip);
+ Long time = (new Date().getTime() - limitInfo.getLong("time")) / 1000;//秒
+ //logger.info(ip+"：还需等待"+time);
+ if (time>=60) {
+ limitIpInfo_dep1.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J905Dao.getAllSims();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ return J905Util.returnLoser(402,"接口频率超出限制，1分钟内允许调取一次，请稍后再试");//秘钥错误
+ }catch (Exception e){
+ e.printStackTrace();
+ return J905Util.returnLoser(401,"系统查询异常，请联系开发人员");
+ }
+ }
+ /**
+ * 查询车队
+ * @param jsonMes
+ * @param httpServletRequest
+ * @return
+ * @throws KeyManagementException
+ * @throws NoSuchAlgorithmException
+ */
+ @PostMapping("/vDwnoFzr/getPageList")
+ public JSONObject vDwnoFzr(@RequestBody JSONObject jsonMes,HttpServletRequest httpServletRequest) throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ String ip = httpServletRequest.getRemoteAddr();
+ if (limitIpInfo_dep2.getJSONObject(ip) == null) {
+ limitIpInfo_dep2.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J905Dao.getAllSims();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ } else {
+ JSONObject limitInfo = limitIpInfo_dep2.getJSONObject(ip);
+ Long time = (new Date().getTime() - limitInfo.getLong("time")) / 1000;//秒
+ //logger.info(ip+"：还需等待"+time);
+ if (time>=60) {
+ limitIpInfo_dep2.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J905Dao.getAllSims();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ return J905Util.returnLoser(402,"接口频率超出限制，1分钟内允许调取一次，请稍后再试");//秘钥错误
+ }catch (Exception e){
+ e.printStackTrace();
+ return J905Util.returnLoser(401,"系统查询异常，请联系开发人员");
+ }
+ }
+
+
+
+
+ /**
+ * 查询车辆
+ * @param jsonMes
+ * @param httpServletRequest
+ * @return
+ * @throws KeyManagementException
+ * @throws NoSuchAlgorithmException
+ */
+ @PostMapping("/VGpsCheliang/getPageList")
+ public JSONObject VGpsCheliang(@RequestBody JSONObject jsonMes,HttpServletRequest httpServletRequest) throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ String ip = httpServletRequest.getRemoteAddr();
+ if (limitIpInfo_dep3.getJSONObject(ip) == null) {
+ limitIpInfo_dep3.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J905Dao.getVGpsCheliangs();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ } else {
+ JSONObject limitInfo = limitIpInfo_dep3.getJSONObject(ip);
+ Long time = (new Date().getTime() - limitInfo.getLong("time")) / 1000;//秒
+ //logger.info(ip+"：还需等待"+time);
+ if (time>=60) {
+ limitIpInfo_dep3.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J905Dao.getVGpsCheliangs();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ return J905Util.returnLoser(402,"接口频率超出限制，1分钟内允许调取一次，请稍后再试");//秘钥错误
+ }catch (Exception e){
+ e.printStackTrace();
+ return J905Util.returnLoser(401,"系统查询异常，请联系开发人员");
+ }
+ }
+
+
+
+
+ /**
+ * 查询驾驶员
+ * @param jsonMes
+ * @param httpServletRequest
+ * @return
+ * @throws KeyManagementException
+ * @throws NoSuchAlgorithmException
+ */
+ @PostMapping("/vGpsJiashiyuan/getPageList")
+ public JSONObject vGpsJiashiyuan(@RequestBody JSONObject jsonMes,HttpServletRequest httpServletRequest) throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ String ip = httpServletRequest.getRemoteAddr();
+ if (limitIpInfo_dep4.getJSONObject(ip) == null) {
+ limitIpInfo_dep4.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray= J9051Dao.getAllJiashiyuans();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ } else {
+ JSONObject limitInfo = limitIpInfo_dep4.getJSONObject(ip);
+ Long time = (new Date().getTime() - limitInfo.getLong("time")) / 1000;//秒
+ //logger.info(ip+"：还需等待"+time);
+ if (time>=60) {
+ limitIpInfo_dep4.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J9051Dao.getAllJiashiyuans();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ return J905Util.returnLoser(402,"接口频率超出限制，1分钟内允许调取一次，请稍后再试");//秘钥错误
+ }catch (Exception e){
+ e.printStackTrace();
+ return J905Util.returnLoser(401,"系统查询异常，请联系开发人员");
+ }
+ }
+
+
+ /**
+ * 查询驾驶员和车辆关系
+ * @param jsonMes
+ * @param httpServletRequest
+ * @return
+ * @throws KeyManagementException
+ * @throws NoSuchAlgorithmException
+ */
+ @PostMapping("/vGpsHetong/getPageList")
+ public JSONObject vGpsHetong(@RequestBody JSONObject jsonMes,HttpServletRequest httpServletRequest) throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ String ip = httpServletRequest.getRemoteAddr();
+ if (limitIpInfo_dep5.getJSONObject(ip) == null) {
+ limitIpInfo_dep5.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray= J9052Dao.getAllvGpsHetongs();
+ for (Object o:jsonArray){
+ JSONObject jsonObject=(JSONObject)o;
+ String hphm=jsonObject.getString("hphm");
+ if (hphm.contains("")){
+ System.out.println("");
+ }
+ }
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ } else {
+ JSONObject limitInfo = limitIpInfo_dep5.getJSONObject(ip);
+ Long time = (new Date().getTime() - limitInfo.getLong("time")) / 1000;//秒
+ //logger.info(ip+"：还需等待"+time);
+ if (time>=60) {
+ limitIpInfo_dep5.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J9052Dao.getAllvGpsHetongs();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ return J905Util.returnLoser(402,"接口频率超出限制，1分钟内允许调取一次，请稍后再试");//秘钥错误
+ }catch (Exception e){
+ e.printStackTrace();
+ return J905Util.returnLoser(401,"系统查询异常，请联系开发人员");
+ }
+ }
+
+
+
+ /**
+ * 查询历史人车对应关系
+ * @param jsonMes
+ * @param httpServletRequest
+ * @return
+ * @throws KeyManagementException
+ * @throws NoSuchAlgorithmException
+ */
+ @PostMapping("/vGpsLiShiHeTong/getPageList")
+ public JSONObject vGpsLiShiHeTong(@RequestBody JSONObject jsonMes,HttpServletRequest httpServletRequest) throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ String ip = httpServletRequest.getRemoteAddr();
+ if (limitIpInfo_dep6.getJSONObject(ip) == null) {
+ limitIpInfo_dep6.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray= J9053Dao.getAllvGpsLiShiHeTong();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ } else {
+ JSONObject limitInfo = limitIpInfo_dep6.getJSONObject(ip);
+ Long time = (new Date().getTime() - limitInfo.getLong("time")) / 1000;//秒
+ //logger.info(ip+"：还需等待"+time);
+ if (time>=180) {
+ limitIpInfo_dep6.put(ip, initializationIP());
+ try {
+ String key=jsonMes.getString("key");
+ if (key.equals("5fff9123eadbae0007b9ce3e")){
+ JSONArray jsonArray=J9053Dao.getAllvGpsLiShiHeTong();
+ return J905Util.returnOK(jsonArray);
+ }else{
+ return J905Util.returnLoser(400,"秘钥错误");//秘钥错误
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ return J905Util.returnLoser(402,"接口频率超出限制，3分钟内允许调取一次，请稍后再试");//秘钥错误
+ }catch (Exception e){
+ e.printStackTrace();
+ return J905Util.returnLoser(401,"系统查询异常，请联系开发人员");
+ }
+ }
+
+
+ private JSONObject initializationIP() {
+ JSONObject info = new JSONObject();
+ info.put("time", new Date().getTime());
+ info.put("num", 1);
+ return info;
+ }
+}
diff --git a/src/main/java/com/example/sso/dao/J9051Dao.java b/src/main/java/com/example/sso/dao/J9051Dao.java
new file mode 100644
index 0000000..c7c8a95
--- /dev/null
+++ b/src/main/java/com/example/sso/dao/J9051Dao.java
@@ -0,0 +1,102 @@
+package com.example.sso.dao;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.util.APIUtils;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class J9051Dao {
+ public static void main(String[] args) {
+ getAllJiashiyuans();
+ }
+ /**
+ *
+ * @param
+ * @return
+ */
+ public static JSONArray getAllJiashiyuans() {
+ //需要修改 appid entryid apikey
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "5c9d82c72ceed93a0d9ebca4","BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ final List> condList = new ArrayList>();
+ //因为想查询大于50的数据，所以创建一个数组
+ JSONArray jsonArray = new JSONArray();
+ //在这个数组里面放一个数值类型的数字，用来判断查询范围
+ jsonArray.add("");
+ condList.add(new HashMap() {
+ {
+ put("field", "vcn");//查新字段的名称/别名
+ put("method", "nq");//判断的方法
+ put("value", jsonArray);//查询的条件
+ }
+ });
+ Map filter = new HashMap() {
+ {
+ put("rel", "and");
+ put("cond", condList);
+ }
+ };
+ //字段别名
+ List> datas = api.getFormData(10000, new String[]{"jsy_id","xm","xb","shfzhh","whchd","xzhzh","lxdh","shjh","jshzhh","zhjchx","lingzhengriqi","status","jdkh","jjlxr",
+ "jg","zp","createTime","tuizuriqi","sfzzm","sfzbm","yhkh","xhhy","gahy","lhh","gsmc","gsdh","jszzy","jszfy"},
+ //姓名
+ //性别
+ //身份号码
+ //文化程度
+ //居民身份证住址
+ //联系电话
+ //手机号码
+ //驾驶证档案编号
+ //准驾车型
+ //初次领证日期
+ //驾驶员状态
+ //监督卡号
+ //紧急联系人手机号
+ filter, null);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ int i = 1;
+ if (datas != null && datas.size() != 0) {
+ while (i != 0) {
+ if (datas.size() > (i * 10000 - 1)) {
+ String id = (String) (datas.get(i * 10000 - 1).get("_id"));
+ List> data = findData(api, filter, id);
+ if (data == null) {
+ i = 0;
+ } else {
+ datas.addAll(data);
+ i = i + 1;
+ }
+ } else {
+ i = 0;
+ }
+ }
+ }
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("list", datas);
+ return jsonObject.getJSONArray("list");
+ }
+
+ private static List> findData(APIUtils api, Map filter, String id) {
+ List> datas = api.getFormData(10000, new String[]{"jsy_id","xm","xb","shfzhh","whchd","xzhzh","lxdh","shjh","jshzhh","zhjchx","lingzhengriqi","status","jdkh","jjlxr",
+ "jg","zp","createTime","tuizuriqi","sfzzm","sfzbm","yhkh","xhhy","gahy","lhh","gsmc","gsdh","jszzy","jszfy"},
+ filter, id);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ return datas;
+ }
+
+
+
+}
diff --git a/src/main/java/com/example/sso/dao/J9052Dao.java b/src/main/java/com/example/sso/dao/J9052Dao.java
new file mode 100644
index 0000000..cbf5ee8
--- /dev/null
+++ b/src/main/java/com/example/sso/dao/J9052Dao.java
@@ -0,0 +1,97 @@
+package com.example.sso.dao;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.util.APIUtils;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class J9052Dao {
+ public static void main(String[] args) {
+ JSONArray jsonArray= J9052Dao.getAllvGpsHetongs();
+ for (Object o:jsonArray){
+ JSONObject jsonObject=(JSONObject)o;
+ String hphm=jsonObject.getString("hphm");
+ if (hphm.contains("BD98508")){
+ System.out.println("");
+ }
+ }
+ }
+ /**
+ *
+ * @param
+ * @return
+ */
+ public static JSONArray getAllvGpsHetongs() {
+ //需要修改 appid entryid apikey
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "62b80148c6c1af0007f8a824","BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ final List> condList = new ArrayList>();
+ //因为想查询大于50的数据，所以创建一个数组
+ JSONArray jsonArray = new JSONArray();
+ //在这个数组里面放一个数值类型的数字，用来判断查询范围
+ jsonArray.add("");
+ condList.add(new HashMap() {
+ {
+ put("field", "shfzhh");//查新字段的名称/别名
+ put("method", "nq");//判断的方法
+ put("value", jsonArray);//查询的条件
+ }
+ });
+ Map filter = new HashMap() {
+ {
+ put("rel", "and");
+ put("cond", condList);
+ }
+ };
+ //字段别名
+ List> datas = api.getFormData(10000, new String[]{"shfzhh","hphm","xgrq","zhzhrq"},//身份证号，车牌号码，承包合同开始日期，承包合同终止日期
+ //身份号码
+ //车牌号码
+ //承包合同开始日期
+ filter, null);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ int i = 1;
+ if (datas != null && datas.size() != 0) {
+ while (i != 0) {
+ if (datas.size() > (i * 10000 - 1)) {
+ String id = (String) (datas.get(i * 10000 - 1).get("_id"));
+ List> data = findData(api, filter, id);
+ if (data == null) {
+ i = 0;
+ } else {
+ datas.addAll(data);
+ i = i + 1;
+ }
+ } else {
+ i = 0;
+ }
+ }
+ }
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("list", datas);
+ return jsonObject.getJSONArray("list");
+ }
+
+ private static List> findData(APIUtils api, Map filter, String id) {
+ List> datas = api.getFormData(10000, new String[]{"shfzhh","hphm","xgrq","zhzhrq"},
+ filter, id);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ return datas;
+ }
+
+
+
+}
diff --git a/src/main/java/com/example/sso/dao/J9053Dao.java b/src/main/java/com/example/sso/dao/J9053Dao.java
new file mode 100644
index 0000000..22f7f16
--- /dev/null
+++ b/src/main/java/com/example/sso/dao/J9053Dao.java
@@ -0,0 +1,206 @@
+package com.example.sso.dao;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.util.APIUtils;
+import com.example.sso.util.TimeUtil;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class J9053Dao {
+ public static void main(String[] args) {
+ getAllvGpsLiShiHeTong();
+ }
+
+ /**
+ * @param
+ * @return
+ */
+ public static JSONArray getAllvGpsLiShiHeTong() {
+ //需要修改 appid entryid apikey
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "62b817f0a5b6a3000714e456", "BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ final List> condList = new ArrayList>();
+ //因为想查询大于50的数据，所以创建一个数组
+ JSONArray jsonArray = new JSONArray();
+ //在这个数组里面放一个数值类型的数字，用来判断查询范围
+ jsonArray.add("");
+ condList.add(new HashMap() {
+ {
+ put("field", "shfzhh");//查新字段的名称/别名
+ put("method", "nq");//判断的方法
+ put("value", jsonArray);//查询的条件
+ }
+ });
+ Map filter = new HashMap() {
+ {
+ put("rel", "and");
+ put("cond", condList);
+ }
+ };
+ //字段别名
+ List> datas = api.getFormData(10000, new String[]{"shfzhh", "hphm", "xgrq","kshrq"},//身份证号，车牌号码，退租日期，承包合同开始日期
+ //身份号码
+ //车牌号码
+ //承包合同开始日期
+ filter, null);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ int i = 1;
+ if (datas != null && datas.size() != 0) {
+ while (i != 0) {
+ if (datas.size() > (i * 10000 - 1)) {
+ String id = (String) (datas.get(i * 10000 - 1).get("_id"));
+ List> data = findData(api, filter, id);
+ if (data == null) {
+ i = 0;
+ } else {
+ datas.addAll(data);
+ i = i + 1;
+ }
+ } else {
+ i = 0;
+ }
+ }
+ }
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("list", datas);
+ return jsonObject.getJSONArray("list");
+ }
+
+ private static List> findData(APIUtils api, Map filter, String id) {
+ List> datas = api.getFormData(10000, new String[]{"shfzhh", "hphm", "xgrq","kshrq"},
+ filter, id);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ return datas;
+ }
+
+
+ /**
+ * 更新客户报备数据
+ *
+ * @throws Exception
+ */
+ public static void createTuiJianBiao(JSONObject jsonObject) {
+ try {
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "63c0af1e6a928200087c72d5", "BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ Map map1;
+ map1 = new HashMap() {
+ {
+ //推荐人邮箱
+ put("tuijian_recommendemail", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_recommendEmail"));
+ }});
+ put("beituijian_mobile", new HashMap() {{
+ put("value", jsonObject.getString("beituijian_mobile"));
+ }});
+ put("tuijian_recommendmobile", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_recommendMobile"));
+ }});
+ put("tuijian_employeeid", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_employeeId"));
+ }});
+ put("beituijian_eamil", new HashMap() {{
+ put("value", jsonObject.getString("beituijian_mobile"));
+ }});
+ put("tuijian_recommendertype", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_recommenderType"));
+ }});
+ put("beituijian_name", new HashMap() {{
+ put("value", jsonObject.getString("beituijian_name"));
+ }});
+ put("tuijian_recommendname", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_recommendName"));
+ }});
+ put("recommendertype", new HashMap() {{
+ put("value", jsonObject.getString("recommenderType"));
+ }});
+ put("beituijian_certificatenumber", new HashMap() {{
+ put("value", jsonObject.getString("beituijian_certificateNumber"));
+ }});
+ put("delivertime", new HashMap() {{
+ put("value", jsonObject.getString("deliverTime"));
+ }});
+ put("department_name", new HashMap() {{
+ put("value", jsonObject.getString("department_name"));
+ }});
+
+ }
+ };
+ //把封装好的数据创建至简道云
+ api.createData(map1);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+
+ /**
+ * 更新客户报备数据
+ *
+ * @throws Exception
+ */
+ public static void updateTuiJianBiao(String id, JSONObject jsonObject) {
+ try {
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "63c0af1e6a928200087c72d5", "BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ Map map1;
+ map1 = new HashMap() {
+ {
+ //推荐人邮箱
+ put("tuijian_recommendemail", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_recommendEmail"));
+ }});
+ put("beituijian_mobile", new HashMap() {{
+ put("value", jsonObject.getString("beituijian_mobile"));
+ }});
+ put("tuijian_recommendmobile", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_recommendMobile"));
+ }});
+ put("tuijian_employeeid", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_employeeId"));
+ }});
+ put("beituijian_eamil", new HashMap() {{
+ put("value", jsonObject.getString("beituijian_mobile"));
+ }});
+ put("tuijian_recommendertype", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_recommenderType"));
+ }});
+ put("beituijian_name", new HashMap() {{
+ put("value", jsonObject.getString("beituijian_name"));
+ }});
+ put("tuijian_recommendname", new HashMap() {{
+ put("value", jsonObject.getString("tuijian_recommendName"));
+ }});
+ put("recommendertype", new HashMap() {{
+ put("value", jsonObject.getString("recommenderType"));
+ }});
+ put("beituijian_certificatenumber", new HashMap() {{
+ put("value", jsonObject.getString("beituijian_certificateNumber"));
+ }});
+ put("delivertime", new HashMap() {{
+ put("value", jsonObject.getString("deliverTime"));
+ }});
+ put("department_name", new HashMap() {{
+ put("value", jsonObject.getString("department_name"));
+ }});
+ }
+ };
+ //把封装好的数据创建至简道云
+ api.updateData(id, map1);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+}
diff --git a/src/main/java/com/example/sso/dao/J905Dao.java b/src/main/java/com/example/sso/dao/J905Dao.java
new file mode 100644
index 0000000..ffe4d5d
--- /dev/null
+++ b/src/main/java/com/example/sso/dao/J905Dao.java
@@ -0,0 +1,158 @@
+package com.example.sso.dao;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.util.APIUtils;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class J905Dao {
+ public static void main(String[] args) {
+ getVGpsCheliangs();
+ }
+ /**
+ * 查询SIM卡号，车牌号和终端号的对应关系
+ * @param
+ * @return
+ */
+ public static JSONArray getAllSims() {
+ //需要修改 appid entryid apikey
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "5673d2535dee5e584224e3e9","BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ final List> condList = new ArrayList>();
+ //因为想查询大于50的数据，所以创建一个数组
+ JSONArray jsonArray = new JSONArray();
+ //在这个数组里面放一个数值类型的数字，用来判断查询范围
+ jsonArray.add("");
+ condList.add(new HashMap() {
+ {
+ put("field", "vcn");//查新字段的名称/别名
+ put("method", "nq");//判断的方法
+ put("value", jsonArray);//查询的条件
+ }
+ });
+ Map filter = new HashMap() {
+ {
+ put("rel", "and");
+ put("cond", condList);
+ }
+ };
+ //字段别名
+ List> datas = api.getFormData(10000, new String[]{"vcn","mdn","mdn905","jjqbh"},//车牌号，产品序列号，UIM卡号，计价器号
+ filter, null);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ int i = 1;
+ if (datas != null && datas.size() != 0) {
+ while (i != 0) {
+ if (datas.size() > (i * 10000 - 1)) {
+ String id = (String) (datas.get(i * 10000 - 1).get("_id"));
+ List> data = findData(api, filter, id);
+ if (data == null) {
+ i = 0;
+ } else {
+ datas.addAll(data);
+ i = i + 1;
+ }
+ } else {
+ i = 0;
+ }
+ }
+ }
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("list", datas);
+ return jsonObject.getJSONArray("list");
+ }
+
+ private static List> findData(APIUtils api, Map filter, String id) {
+ List> datas = api.getFormData(10000, new String[]{"vcn","mdn","mdn905","jjqbh"},//车牌号，产品序列号，UIM卡号，计价器号
+ filter, id);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ return datas;
+ }
+
+
+
+ /**
+ * 查询车辆
+ * @param
+ * @return
+ */
+ public static JSONArray getVGpsCheliangs() {
+ //需要修改 appid entryid apikey
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "5673d2535dee5e584224e3e9","BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ final List> condList = new ArrayList>();
+ //因为想查询大于50的数据，所以创建一个数组
+ JSONArray jsonArray = new JSONArray();
+ //在这个数组里面放一个数值类型的数字，用来判断查询范围
+ jsonArray.add("");
+ condList.add(new HashMap() {
+ {
+ put("field", "vcn");//查新字段的名称/别名
+ put("method", "nq");//判断的方法
+ put("value", jsonArray);//查询的条件
+ }
+ });
+ Map filter = new HashMap() {
+ {
+ put("rel", "and");
+ put("cond", condList);
+ }
+ };
+ //字段别名
+ List> datas = api.getFormData(10000, new String[]{"dw","ssh","vcn","chp",
+ "xh","ys","djrq","chlzht","jch","pshh","shyxzh","chjh","shynx","dqzht","zhtxf","yyfsh","lhyyf"},//所属部门（文本）,分司，车牌号码，品牌，型号，颜色 ，注册登记日期,班制,简称,喷饰号，使用性质，车架号，使用年限，当前状态，状态细分，运营方式，联合运营方
+ filter, null);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ int i = 1;
+ if (datas != null && datas.size() != 0) {
+ while (i != 0) {
+ if (datas.size() > (i * 10000 - 1)) {
+ String id = (String) (datas.get(i * 10000 - 1).get("_id"));
+ List> data = getVGpsCheliangs_zi(api, filter, id);
+ if (data == null) {
+ i = 0;
+ } else {
+ datas.addAll(data);
+ i = i + 1;
+ }
+ } else {
+ i = 0;
+ }
+ }
+ }
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("list", datas);
+ return jsonObject.getJSONArray("list");
+ }
+
+ private static List> getVGpsCheliangs_zi(APIUtils api, Map filter, String id) {
+ List> datas = api.getFormData(10000, new String[]{"dw","ssh","vcn","chp",
+ "xh","ys","djrq","chlzht","jch","pshh","shyxzh","chjh","shynx","dqzht","zhtxf","yyfsh","lhyyf"},
+ filter, id);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ return datas;
+ }
+
+}
diff --git a/src/main/java/com/example/sso/schedule/ScheduleDep.java b/src/main/java/com/example/sso/schedule/ScheduleDep.java
new file mode 100644
index 0000000..50cc24f
--- /dev/null
+++ b/src/main/java/com/example/sso/schedule/ScheduleDep.java
@@ -0,0 +1,227 @@
+package com.example.sso.schedule;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.dao.J9053Dao;
+import com.example.sso.util.HttpUtil;
+import com.example.sso.util.JDYUtil;
+import com.example.sso.util.TimeUtil;
+import com.example.sso.util.WXUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.sql.Time;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Component
+public class ScheduleDep {
+ private static String app_key = "F493FDF0DA9B4DF3A826530B568E6BAF";
+ private static String app_secret = "B9BAA96975C74DB8AF07EB5D5243F56DE2FAE0ED37D64797AB2487EA3F8011CD";
+
+ @Scheduled(cron = "0 0 5 * * ?")//0 00 00 1 4,7,10,1 ?\
+ public static void SynDep() throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ getApplysByPhaseStatusCode();
+ } catch (NoSuchAlgorithmException e) {
+ e.printStackTrace();
+ } catch (KeyManagementException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static void main(String[] args) {
+ try {
+ getApplysByPhaseStatusCode();
+ } catch (NoSuchAlgorithmException e) {
+ e.printStackTrace();
+ } catch (KeyManagementException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static String getToken() throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/token";
+ JSONObject body = new JSONObject();
+ body.put("grant_type", "client_credentials");
+ body.put("app_key", app_key);
+ body.put("app_secret", app_secret);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString()));
+ return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 修改人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void updateUser(JSONObject driver, Integer id) throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/UpdateEmployee";
+ JSONObject body = new JSONObject();
+ body.put("employeeInformation", "client_credentials");
+ JSONObject employeeInformation = new JSONObject();
+ employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+ JSONObject employmentRecord = new JSONObject();
+ employmentRecord.put("originalId", driver.get("shfzhh"));//外部编码ID
+ employmentRecord.put("employmentType", "020c47b0-74b7-4a75-b454-e9905f64e1fc");//人员类别
+ employmentRecord.put("oIdJobPost", "149359");//职务
+ body.put("employeeInformation", employeeInformation);
+ body.put("employmentRecord", employmentRecord);
+ body.put("userId", id);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+ System.out.println(jsonObject.toJSONString());
+// return jsonObject.getString("access_token");
+ }
+
+ /**
+ * 获取人员数据
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void getApplysByPhaseStatusCode() throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/RecruitV6/api/v1/Apply/GetApplysByPhaseStatusCode";
+ JSONObject body = new JSONObject();
+ body.put("startTime", TimeUtil.getEarly6Month());
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'hh:mm:ss");
+ body.put("endTime", df.format(new Date()));
+ body.put("phaseCode", "S001");
+ body.put("statusCode", "U001");
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+ System.out.println(jsonObject.toJSONString());
+ JSONArray jsonArray = jsonObject.getJSONObject("data").getJSONArray("items");
+// while (jsonObject.getJSONObject("data").getString("nextBatchId")!=null){
+// body.put("batchId",jsonObject.getJSONObject("data").getString("nextBatchId"));
+// JSONObject jsonObject1 =JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+// JSONArray jsonArray1 = jsonObject1.getJSONObject("data").getJSONArray("items");
+// jsonArray.addAll(jsonArray1);
+// }
+ JSONObject jsonObject1 = new JSONObject();
+ JSONObject beitui = JDYUtil.getAllTuiJian();
+ for (Object o : jsonArray) {
+ JSONObject data = (JSONObject) o;
+ JSONObject applicantLite = data.getJSONObject("applicantLite");
+ if (data.getJSONObject("jobLite").getString("jobTitle").equals("出租车驾驶员")) {
+ String applyId = data.getString("applyId");
+// JSONObject applicantLite = data.getJSONObject("applicantLite");
+ jsonObject1.put("beituijian_certificateNumber", applicantLite.getString("certificateNumber"));//身份证号码
+
+ jsonObject1.put("beituijian_name", applicantLite.getString("name"));//姓名
+ jsonObject1.put("beituijian_eamil", applicantLite.getString("eamil"));//身份证号码
+ jsonObject1.put("beituijian_mobile", applicantLite.getString("mobile"));//身份证号码
+ try {
+ getReferrerListByApplyId(applyId, jsonObject1);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ if (beitui.getString(jsonObject1.getString("beituijian_certificateNumber")) == null) {
+ J9053Dao.createTuiJianBiao(jsonObject1);
+ } else {
+ J9053Dao.updateTuiJianBiao(beitui.getJSONObject(jsonObject1.getString("beituijian_certificateNumber")).getString("_id"), jsonObject1);
+ }
+ jsonObject1.clear();
+ }
+ }
+// return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 根据申请ID获取推荐人相关信息
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static JSONObject getReferrerListByApplyId(String guid, JSONObject jsonObject) throws NoSuchAlgorithmException, KeyManagementException, ParseException {
+ String url = "https://openapi.italent.cn/RecruitV6/api/v1/Recommend/GetReferrerListByApplyId?applyId=" + guid;
+ JSONObject jsonObject1 = JSON.parseObject(HttpUtil.sendGet(url, getToken()));
+ System.out.println(jsonObject1.toJSONString());
+ JSONArray jsonArray = jsonObject1.getJSONArray("data");
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'hh:mm:ss");
+ SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
+ Date date = null;
+ for (Object o : jsonArray) {
+ JSONObject jsonObject2 = (JSONObject) o;
+ String deliverTime = jsonObject2.getString("deliverTime");
+ if (deliverTime != null) {
+ deliverTime = deliverTime.split("\\.")[0];
+ deliverTime = dateFormat.format(df.parse(deliverTime));
+ }
+ if (date == null) {
+ date = df.parse(deliverTime);
+ }
+ Boolean isEffective = jsonObject2.getBoolean("isEffective");
+ String recommendName = jsonObject2.getString("recommendName");
+ String recommendEmail = jsonObject2.getString("recommendEmail");
+ String recommendMobile = jsonObject2.getString("recommendMobile");
+ if (recommendEmail != null && recommendMobile != null
+ && !recommendEmail.equals("") && !recommendMobile.equals("")) {
+ if (date != null) {
+ if (date.before(df.parse(deliverTime)) || date.equals(df.parse(deliverTime))) {
+ jsonObject.put("tuijian_recommendMobile", jsonObject2.getString("recommendMobile"));
+ jsonObject.put("tuijian_recommendName", jsonObject2.getString("recommendName"));
+ jsonObject.put("tuijian_recommendEmail", jsonObject2.getString("recommendEmail"));
+ jsonObject.put("tuijian_employeeId", jsonObject2.getString("employeeId"));
+ jsonObject.put("tuijian_recommenderType", jsonObject2.getString("recommenderType"));//推荐人类型
+ jsonObject.put("department_name", jsonObject2.getString("departmentName"));//推荐人类型
+ jsonObject.put("deliverTime", TimeUtil.timeConversion(deliverTime));//申请时间
+ }
+ }
+ }
+ if (date != null) {
+ if (deliverTime != null) {
+ if (date.before(df.parse(deliverTime))) {
+ date = df.parse(deliverTime);
+ }
+ }
+ }
+ }
+ return jsonObject;
+// return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 创建人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void createUser(HashMap driver, JSONObject orgNos) throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Create";
+ JSONObject body = new JSONObject();
+ body.put("employeeInformation", "client_credentials");
+ JSONObject employeeInformation = new JSONObject();
+ employeeInformation.put("name", driver.get("xm"));//姓名：张三
+// employeeInformation.put("email",driver.get("yxbs"));//邮箱
+ employeeInformation.put("email", driver.get("shjh") + "@yinjian.com");//邮箱
+ JSONObject employmentRecord = new JSONObject();
+ employmentRecord.put("entryDate", driver.get("lrrq"));//入职日期
+ employmentRecord.put("probation", 0);//试用期，无试用期为0
+ String name = (String) driver.get("name");//
+ for (String str : orgNos.keySet()) {
+ if (str.contains((String) driver.get("ssbm") + (String) driver.get("fs"))) {
+ employmentRecord.put("OIdDepartment", orgNos.getInteger(str));//试用期，无试用期为0
+ }
+ }
+ body.put("employeeInformation", employeeInformation);
+ body.put("employmentRecord", employmentRecord);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+ System.out.println(jsonObject.toJSONString());
+// return jsonObject.getString("access_token");
+ }
+}
diff --git a/src/main/java/com/example/sso/schedule/ScheduleDep.java.baiduyun.uploading.cfg b/src/main/java/com/example/sso/schedule/ScheduleDep.java.baiduyun.uploading.cfg
new file mode 100644
index 0000000..4f737cd
Binary files /dev/null and b/src/main/java/com/example/sso/schedule/ScheduleDep.java.baiduyun.uploading.cfg differ
diff --git a/src/main/java/com/example/sso/schedule/ScheduleDep1.java b/src/main/java/com/example/sso/schedule/ScheduleDep1.java
new file mode 100644
index 0000000..03eeb35
--- /dev/null
+++ b/src/main/java/com/example/sso/schedule/ScheduleDep1.java
@@ -0,0 +1,219 @@
+package com.example.sso.schedule;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.dao.J9053Dao;
+import com.example.sso.util.BeiSenTest;
+import com.example.sso.util.HttpUtil;
+import com.example.sso.util.JDYUtil;
+import com.example.sso.util.TimeUtil;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Component
+public class ScheduleDep1 {
+ private static String app_key = "F493FDF0DA9B4DF3A826530B568E6BAF";
+ private static String app_secret = "B9BAA96975C74DB8AF07EB5D5243F56DE2FAE0ED37D64797AB2487EA3F8011CD";
+// @Scheduled(cron = "0 35 1 * * ?")//0 00 00 1 4,7,10,1 ?\
+// public static void SynDep() throws KeyManagementException, NoSuchAlgorithmException {
+// try {
+// List> drivers=JDYUtil.getAllDrivers1();//查询
+// for (Map driver:drivers){
+// Integer integer=Integer.valueOf((String) driver.get("oid"));
+// BeiSenTest.deleteUser(integer);
+// }
+// }catch (Exception e) {
+// e.printStackTrace();
+// }
+// }
+
+// public static void main(String[] args) {
+// try {
+// getApplysByPhaseStatusCode();
+// } catch (NoSuchAlgorithmException e) {
+// e.printStackTrace();
+// } catch (KeyManagementException e) {
+// e.printStackTrace();
+// }
+// }
+
+ public static String getToken() throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/token";
+ JSONObject body = new JSONObject();
+ body.put("grant_type", "client_credentials");
+ body.put("app_key", app_key);
+ body.put("app_secret", app_secret);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString()));
+ return jsonObject.getString("access_token");
+ }
+
+
+
+ /**
+ * 修改人员信息
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void updateUser(JSONObject driver, Integer id) throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/UpdateEmployee";
+ JSONObject body = new JSONObject();
+ body.put("employeeInformation", "client_credentials");
+ JSONObject employeeInformation = new JSONObject();
+ employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+ JSONObject employmentRecord = new JSONObject();
+ employmentRecord.put("originalId", driver.get("shfzhh"));//外部编码ID
+ employmentRecord.put("employmentType", "020c47b0-74b7-4a75-b454-e9905f64e1fc");//人员类别
+ employmentRecord.put("oIdJobPost", "149359");//职务
+ body.put("employeeInformation", employeeInformation);
+ body.put("employmentRecord", employmentRecord);
+ body.put("userId", id);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+ System.out.println(jsonObject.toJSONString());
+// return jsonObject.getString("access_token");
+ }
+ /**
+ * 获取人员数据
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void getApplysByPhaseStatusCode() throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/RecruitV6/api/v1/Apply/GetApplysByPhaseStatusCode";
+ JSONObject body = new JSONObject();
+ body.put("startTime", "2020-12-08T12:23:00");
+ SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd'T'hh:mm:ss");
+ body.put("endTime", df.format(new Date()));
+ body.put("phaseCode", "S001");
+ body.put("statusCode", "U001");
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+ System.out.println(jsonObject.toJSONString());
+ JSONArray jsonArray=jsonObject.getJSONObject("data").getJSONArray("items");
+ JSONObject jsonObject1=new JSONObject();
+ JSONObject beitui=JDYUtil.getAllTuiJian();
+ for (Object o:jsonArray){
+ JSONObject data=(JSONObject)o;
+ if (data.getJSONObject("jobLite").getString("jobTitle").equals("出租车驾驶员")){
+ String applyId=data.getString("applyId");
+ JSONObject applicantLite=data.getJSONObject("applicantLite");
+ if (applicantLite.getString("name").equals("吕玲")){
+ System.out.println("");
+ }
+ jsonObject1.put("beituijian_certificateNumber",applicantLite.getString("certificateNumber"));//身份证号码
+ jsonObject1.put("beituijian_name",applicantLite.getString("name"));//姓名
+ jsonObject1.put("beituijian_eamil",applicantLite.getString("eamil"));//身份证号码
+ jsonObject1.put("beituijian_mobile",applicantLite.getString("mobile"));//身份证号码
+ try {
+ getReferrerListByApplyId(applyId,jsonObject1);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ if (beitui.getString(jsonObject1.getString("beituijian_certificateNumber"))==null){
+ J9053Dao.createTuiJianBiao(jsonObject1);
+ }else {
+ J9053Dao.updateTuiJianBiao(beitui.getJSONObject(jsonObject1.getString("beituijian_certificateNumber")).getString("_id"),jsonObject1);
+ }
+ }
+ }
+// return jsonObject.getString("access_token");
+ }
+
+
+
+ /**
+ * 根据申请ID获取推荐人相关信息
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static JSONObject getReferrerListByApplyId(String guid,JSONObject jsonObject) throws NoSuchAlgorithmException, KeyManagementException, ParseException {
+ String url = "https://openapi.italent.cn/RecruitV6/api/v1/Recommend/GetReferrerListByApplyId?applyId="+guid;
+ JSONObject jsonObject1 = JSON.parseObject(HttpUtil.sendGet(url,getToken()));
+ System.out.println(jsonObject1.toJSONString());
+ JSONArray jsonArray=jsonObject1.getJSONArray("data");
+ SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd'T'hh:mm:ss");
+ SimpleDateFormat dateFormat=new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
+ Date date=null;
+ for (Object o:jsonArray){
+ JSONObject jsonObject2=(JSONObject)o;
+ String deliverTime =jsonObject2.getString("deliverTime");
+ if (deliverTime!=null){
+ deliverTime=deliverTime.split("\\.")[0];
+ deliverTime=dateFormat.format(df.parse(deliverTime));
+ }
+ if (date==null){
+ date=df.parse(deliverTime);
+ }
+ Boolean isEffective=jsonObject2.getBoolean("isEffective");
+ String recommendName=jsonObject2.getString("recommendName");
+ String recommendEmail=jsonObject2.getString("recommendEmail");
+ String recommendMobile=jsonObject2.getString("recommendMobile");
+ if (recommendName!=null&&recommendEmail!=null&&recommendMobile!=null
+ &!recommendName.equals("")&&!recommendEmail.equals("")&&!recommendMobile.equals("")){
+ if (date!=null){
+ if (date.before(df.parse(deliverTime))||date.equals(df.parse(deliverTime))){
+ jsonObject.put("tuijian_recommendMobile",jsonObject2.getString("recommendMobile"));
+ jsonObject.put("tuijian_recommendName",jsonObject2.getString("recommendName"));
+ jsonObject.put("tuijian_recommendEmail",jsonObject2.getString("recommendEmail"));
+ jsonObject.put("tuijian_employeeId",jsonObject2.getString("employeeId"));
+ jsonObject.put("tuijian_recommenderType",jsonObject2.getString("recommenderType"));//推荐人类型
+ jsonObject.put("department_name",jsonObject2.getString("departmentName"));//推荐人类型
+ jsonObject.put("deliverTime", TimeUtil.timeConversion(deliverTime));//申请时间
+ }
+ }
+ }
+ if (date!=null){
+ if (deliverTime!=null){
+ if (date.before(df.parse(deliverTime))){
+ date=df.parse(deliverTime);
+ }
+ }
+ }
+ }
+ return jsonObject;
+// return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 创建人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void createUser(HashMap driver, JSONObject orgNos) throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Create";
+ JSONObject body = new JSONObject();
+ body.put("employeeInformation", "client_credentials");
+ JSONObject employeeInformation = new JSONObject();
+ employeeInformation.put("name", driver.get("xm"));//姓名：张三
+// employeeInformation.put("email",driver.get("yxbs"));//邮箱
+ employeeInformation.put("email", driver.get("shjh") + "@yinjian.com");//邮箱
+ JSONObject employmentRecord = new JSONObject();
+ employmentRecord.put("entryDate", driver.get("lrrq"));//入职日期
+ employmentRecord.put("probation", 0);//试用期，无试用期为0
+ String name = (String) driver.get("name");//
+ for (String str : orgNos.keySet()) {
+ if (str.contains((String) driver.get("ssbm") + (String) driver.get("fs"))) {
+ employmentRecord.put("OIdDepartment", orgNos.getInteger(str));//试用期，无试用期为0
+ }
+ }
+ body.put("employeeInformation", employeeInformation);
+ body.put("employmentRecord", employmentRecord);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+ System.out.println(jsonObject.toJSONString());
+// return jsonObject.getString("access_token");
+ }
+}
diff --git a/src/main/java/com/example/sso/schedule/ScheduleLiZhiPerson.java b/src/main/java/com/example/sso/schedule/ScheduleLiZhiPerson.java
new file mode 100644
index 0000000..3c1b49c
--- /dev/null
+++ b/src/main/java/com/example/sso/schedule/ScheduleLiZhiPerson.java
@@ -0,0 +1,402 @@
+package com.example.sso.schedule;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.dao.J9053Dao;
+import com.example.sso.util.APIUtils;
+import com.example.sso.util.HttpUtil;
+import com.example.sso.util.JDYUtil;
+import com.example.sso.util.TimeUtil;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.*;
+
+
+/**
+ * 处理当日下车又上车相关人员
+ * 这部分人，不能使用修改接口，应在第二天使用新增接口遍历
+ */
+@Component
+public class ScheduleLiZhiPerson {
+ private static String app_key = "F493FDF0DA9B4DF3A826530B568E6BAF";
+ private static String app_secret = "B9BAA96975C74DB8AF07EB5D5243F56DE2FAE0ED37D64797AB2487EA3F8011CD";
+
+ @Scheduled(cron = "0 20 5 * * ?")//0 00 00 1 4,7,10,1 ?\
+// public static void main(String[] args) {
+// try {
+// SynDep();
+// } catch (KeyManagementException e) {
+// e.printStackTrace();
+// } catch (NoSuchAlgorithmException e) {
+// e.printStackTrace();
+// }
+// }
+
+ public static void SynDep() throws KeyManagementException, NoSuchAlgorithmException {
+ try {
+ JSONArray drivers = getAllLiShangDriver();//查询下车又上车的所有相关人员
+ for (Object o : drivers) {
+ JSONObject driver = (JSONObject) o;
+ String _id = driver.getString("_id");
+ String shfzhh = (String) driver.get("shfzhh");//获取当前人员身份证号码
+ JSONObject person = findPersonById_Card(shfzhh);//查询驾驶员信息表里该驾驶员的数据
+ JSONObject orgNos = JDYUtil.getOrgNos();
+ String integer=createUser(person, orgNos, person.getString("_id"));//创建该人员
+ if (integer.contains("200")){
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "6434f517e34c130008183344", "BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ api.deleteData(_id);
+ }else {
+ updateBeiSenStatus(_id,integer);
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+
+
+ /**
+ * 修改简道云订单数据状态字段
+ * @param id
+ * @param
+ * @return
+ */
+ public static void updateBeiSenStatus(String id,String status){
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "6434f517e34c130008183344", "BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ Map data = new HashMap() {{
+ put("status", new HashMap() {{
+ put("value", status);
+ }});
+ }};
+ api.updateData(id, data);
+ }
+
+// public static void main(String[] args) {
+// try {
+// JSONArray drivers = getAllLiShangDriver();//查询下车又上车的所有相关人员
+// for (Object o : drivers) {
+// JSONObject driver = (JSONObject) o;
+// String shfzhh = (String) driver.get("shfzhh");//获取当前人员身份证号码
+// JSONObject person = findPersonById_Card(shfzhh);//查询驾驶员信息表里该驾驶员的数据
+// JSONObject orgNos = JDYUtil.getOrgNos();
+// createUser(person, orgNos, person.getString("_id"));//创建该人员
+// }
+// } catch (Exception e) {
+// e.printStackTrace();
+// }
+// }
+
+
+ /**
+ * 查询下车又上车的所有相关人员
+ *
+ * @param
+ * @return
+ */
+ public static JSONArray getAllLiShangDriver() {
+ //需要修改 appid entryid apikey
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "6434f517e34c130008183344", "BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ final List> condList = new ArrayList>();
+ //因为想查询大于50的数据，所以创建一个数组
+ JSONArray jsonArray = new JSONArray();
+ //在这个数组里面放一个数值类型的数字，用来判断查询范围
+ jsonArray.add("");
+ condList.add(new HashMap() {
+ {
+ put("field", "xm");//查新字段的名称/别名
+ put("method", "nq");//判断的方法
+ put("value", jsonArray);//查询的条件
+ }
+ });
+ Map filter = new HashMap() {
+ {
+ put("rel", "and");
+ put("cond", condList);
+ }
+ };
+ //字段别名
+ List> datas = api.getFormData(10000, new String[]{"shfzhh"},//身份证号码
+ filter, null);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("list", datas);
+ return jsonObject.getJSONArray("list");
+ }
+
+ /**
+ * 根据身份证查询驾驶员信息表数据
+ */
+ public static JSONObject findPersonById_Card(String id_card_num) {
+ //需要修改 appid entryid apikey
+ APIUtils api = new APIUtils("628eeaace7f28c00089a60cc", "5c9d82c72ceed93a0d9ebca4", "BkIyzlh1onqnqu9cQ3ralDQBjECn97ex");
+ final List> condList = new ArrayList>();
+ //因为想查询大于50的数据，所以创建一个数组
+ JSONArray jsonArray = new JSONArray();
+ //在这个数组里面放一个数值类型的数字，用来判断查询范围
+ jsonArray.add(id_card_num);
+ condList.add(new HashMap() {
+ {
+ put("field", "shfzhh");//查新字段的名称/别名
+ put("method", "eq");//判断的方法
+ put("value", jsonArray);//查询的条件
+ }
+ });
+ Map filter = new HashMap() {
+ {
+ put("rel", "and");
+ put("cond", condList);
+ }
+ };
+ //字段别名
+ List> datas = api.getFormData(10000, new String[]{"xm", "ssbm",
+ "fs", "yxbs", "lrrq", "shjh", "shfzhh", "shjh", "beisen_id"},//身份证号码
+ filter, null);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ JSONObject jsonObject = new JSONObject();
+ jsonObject.put("list", datas);
+ JSONArray jsonArray1 = new JSONArray();
+ for (Map o : datas) {
+ String time = (String) o.get("lrrq");
+ if (time != null) {
+ o.put("lrrq", TimeUtil.timeConversion2(time));
+ }
+ jsonArray1.add(o);
+ }
+ return jsonArray1.getJSONObject(0);
+ }
+
+
+ /**
+ * 创建人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+// public static void createUser(JSONObject driver, JSONObject orgNos,JSONArray deps) throws NoSuchAlgorithmException, KeyManagementException {
+// String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Create";
+// JSONObject body = new JSONObject();
+// body.put("employeeInformation", "client_credentials");
+// JSONObject employeeInformation = new JSONObject();
+// employeeInformation.put("name", driver.get("xm"));//姓名：张三
+// employeeInformation.put("email",driver.get("yxbs"));//邮箱
+// employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+//// employeeInformation.put("email", driver.get("shjh") + "@yinjian.com");//邮箱
+// employeeInformation.put("mobilePhone", driver.get("shjh"));//身份证号码
+// JSONObject employmentRecord = new JSONObject();
+// employmentRecord.put("entryDate", driver.get("lrrq"));//入职日期\
+// employeeInformation.put("emergencyContactPhone", driver.get("shjh"));//身份证号码
+// employmentRecord.put("probation", 0);//试用期，无试用期为0
+// String name = (String) driver.get("name");//
+// String uu=(String) driver.get("ssbm") + (String) driver.get("fs");
+// for (String str : orgNos.keySet()) {
+// if (str.equals((String) driver.get("ssbm") + (String) driver.get("fs")+"司")) {
+// employmentRecord.put("OIdDepartment", orgNos.getInteger(str));//试用期，无试用期为0
+// break;
+// }
+// }
+// Integer O=employmentRecord.getInteger("OIdDepartment");
+// if (O==null){
+// deps.add(uu);
+// System.out.println("");
+// }
+// employmentRecord.put("originalId", driver.get("shfzhh"));//外部编码ID
+// employmentRecord.put("employmentType", "020c47b0-74b7-4a75-b454-e9905f64e1fc");//人员类别
+// employmentRecord.put("oIdJobPost", "149359");//职务
+// body.put("employeeInformation", employeeInformation);
+// body.put("employmentRecord", employmentRecord);
+// JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+// System.out.println(jsonObject.toJSONString());
+//// JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+//// System.out.println(jsonObject.toJSONString());
+//// return jsonObject.getString("access_token");
+//}
+ public static String getToken() throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/token";
+ JSONObject body = new JSONObject();
+ body.put("grant_type", "client_credentials");
+ body.put("app_key", app_key);
+ body.put("app_secret", app_secret);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString()));
+ return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 创建人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static String createUser(JSONObject driver, JSONObject orgNos, String id) throws NoSuchAlgorithmException, KeyManagementException {
+ String token = getToken();
+// if (driver.getString("beisen_id") == null || driver.getString("beisen_id").equals("")) {
+ try {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Create";
+ JSONObject body = new JSONObject();
+ body.put("employeeInformation", "client_credentials");
+ JSONObject employeeInformation = new JSONObject();
+ employeeInformation.put("name", driver.get("xm"));//姓名：张三
+ employeeInformation.put("email", driver.get("yxbs"));//邮箱
+// employeeInformation.put("originalId", driver.get("shfzhh"));//外部ID
+ employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+ employeeInformation.put("mobilePhone", driver.get("shjh"));//电话号码
+ employeeInformation.put("emergencyContactPhone", driver.get("shjh"));//电话
+ JSONObject employmentRecord = new JSONObject();
+ employmentRecord.put("entryDate", driver.get("lrrq"));//入职日期
+ employmentRecord.put("probation", 0);//试用期，无试用期为0
+ String name = (String) driver.get("name");//
+ for (String str : orgNos.keySet()) {
+ if (str.equals(driver.get("fs"))) {
+ employmentRecord.put("OIdDepartment", orgNos.getInteger(str));//试用期，无试用期为0
+ break;
+ }
+ }
+ employmentRecord.put("employmentType", "020c47b0-74b7-4a75-b454-e9905f64e1fc");//人员类别
+ employmentRecord.put("oIdJobPost", "149359");//职务
+ body.put("employeeInformation", employeeInformation);
+ body.put("employmentRecord", employmentRecord);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), token));
+ JSONObject returnData = jsonObject.getJSONObject("data");
+ System.out.println(driver.get("shfzhh") + "的创建账户动作返回为:" + jsonObject.toJSONString());
+ if (jsonObject.getString("code").equals("200")) {
+ JDYUtil.updateBeiSenId(id, returnData.getString("userId"));
+ }
+ return jsonObject.toJSONString();
+ }catch (Exception e){
+ e.printStackTrace();
+ return "同步异常";
+ }
+
+// } else {
+ //如果不是新增则修改数据
+// updateUser(driver, driver.getInteger("beisen_id"), orgNos, token);
+// }
+// return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 创建人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+// public static void createUser(JSONObject driver, JSONObject orgNos,String id) throws NoSuchAlgorithmException, KeyManagementException {
+// String token=getToken();
+// if (driver.getString("beisen_id")==null||driver.getString("beisen_id").equals("")){
+// String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Create";
+// JSONObject body = new JSONObject();
+// body.put("employeeInformation", "client_credentials");
+// JSONObject employeeInformation = new JSONObject();
+// employeeInformation.put("name", driver.get("xm"));//姓名：张三
+// employeeInformation.put("email",driver.get("yxbs"));//邮箱
+// employeeInformation.put("originalId",driver.get("shfzhh"));//外部ID
+// employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+// employeeInformation.put("mobilePhone", driver.get("shjh"));//电话号码
+// employeeInformation.put("emergencyContactPhone", driver.get("shjh"));//电话
+// JSONObject employmentRecord = new JSONObject();
+// employmentRecord.put("entryDate", driver.get("lrrq"));//入职日期
+// employmentRecord.put("probation", 0);//试用期，无试用期为0
+// String name = (String) driver.get("name");//
+// employmentRecord.put("OIdDepartment",600186);//试用期，无试用期为0
+// body.put("employeeInformation", employeeInformation);
+// body.put("employmentRecord", employmentRecord);
+// JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(),token));
+// JSONObject returnData=jsonObject.getJSONObject("data");
+// try {
+// if (returnData!=null){
+// System.out.println(driver.get("shfzhh")+"的创建账户动作返回为:"+jsonObject.toJSONString());
+// if (jsonObject.getString("code").equals("200")){
+// JDYUtil.updateBeiSenId(id,returnData.getString("userId"));
+// }
+// }
+// }catch (Exception e){
+// e.printStackTrace();
+// }
+// }else {
+// //如果不是新增则修改数据
+// updateUser(driver,driver.getInteger("beisen_id"),orgNos,token);
+// }
+//// return jsonObject.getString("access_token");
+// }
+
+ /**
+ * 修改人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void updateUser(JSONObject driver, Integer id, JSONObject orgNos, String token) throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/UpdateEmployee";
+ JSONObject body = new JSONObject();
+ body.put("employeeInformation", "client_credentials");
+ JSONObject employeeInformation = new JSONObject();
+ employeeInformation.put("name", driver.get("xm"));//姓名：张三
+ employeeInformation.put("email", driver.get("yxbs"));//邮箱
+ employeeInformation.put("originalId", driver.get("shfzhh"));//外部ID
+ employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+ employeeInformation.put("mobilePhone", driver.get("shjh"));//电话号码
+ employeeInformation.put("emergencyContactPhone", driver.get("shjh"));//电话
+ JSONObject employmentRecord = new JSONObject();
+ employmentRecord.put("employmentType", "020c47b0-74b7-4a75-b454-e9905f64e1fc");//人员类别
+ for (String str : orgNos.keySet()) {
+ if (str.equals((String) driver.get("ssbm") + (String) driver.get("fs") + "司")) {
+ employmentRecord.put("OIdDepartment", orgNos.getInteger(str));//试用期，无试用期为0
+ break;
+ }
+ }
+ employmentRecord.put("oIdJobPost", "149359");//职务
+ body.put("employeeInformation", employeeInformation);
+ body.put("employmentRecord", employmentRecord);
+ body.put("userId", id);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), token));
+ System.out.println(jsonObject.toJSONString());
+// return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 离职人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void deleteUser(Integer id) throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Dimission";
+ JSONObject body = new JSONObject();
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
+ JSONObject employmentRecord = new JSONObject();
+ try {
+ employmentRecord.put("lastWorkDate", df.format(new Date()));//最后工作日期
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ body.put("employmentRecord", employmentRecord);
+ body.put("userId", id);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+ System.out.println(jsonObject.toJSONString());
+// return jsonObject.getString("access_token");
+ }
+}
diff --git a/src/main/java/com/example/sso/service/JDYAuthService.java b/src/main/java/com/example/sso/service/JDYAuthService.java
new file mode 100644
index 0000000..ca05b67
--- /dev/null
+++ b/src/main/java/com/example/sso/service/JDYAuthService.java
@@ -0,0 +1,27 @@
+package com.example.sso.service;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.example.sso.util.HttpUtil;
+import lombok.NoArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+
+@Service
+@NoArgsConstructor
+public class JDYAuthService {
+ public static final String GET_USERINFO_URL = "http://10.165.35.44/cgi-bin/user/getuserinfo?access_token=ACCESS_TOKEN&code=CODE";
+
+ public String getUserID(String accessToken, String code) throws NoSuchAlgorithmException, KeyManagementException {
+ //1.获取请求的url
+ String get_userInfo_url = GET_USERINFO_URL.replace("ACCESS_TOKEN", accessToken)
+ .replace("CODE", code);
+
+ //2.调用接口，发送请求，获取成员信息
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendGet(get_userInfo_url,accessToken));
+ return jsonObject.getString("UserId");
+ }
+}
+
diff --git a/src/main/java/com/example/sso/service/SSOService.java b/src/main/java/com/example/sso/service/SSOService.java
new file mode 100644
index 0000000..176fb1d
--- /dev/null
+++ b/src/main/java/com/example/sso/service/SSOService.java
@@ -0,0 +1,44 @@
+package com.example.sso.service;
+
+import com.auth0.jwt.JWT;
+import com.auth0.jwt.JWTVerifier;
+import com.auth0.jwt.algorithms.Algorithm;
+import com.auth0.jwt.interfaces.DecodedJWT;
+import com.example.sso.config.SSOConfig;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Calendar;
+import java.util.Date;
+
+@Service
+@NoArgsConstructor
+@AllArgsConstructor
+public class SSOService {
+ @Getter @Setter @Autowired private SSOConfig ssoConfig;
+
+ public String getResponse(String request,String username) {
+ Algorithm algorithm = Algorithm.HMAC256("");
+ JWTVerifier verifier = JWT.require(algorithm)
+ .withIssuer("com.jiandaoyun")
+ .build();
+// DecodedJWT decoded = verifier.verify(request);
+// if (!"sso_req".equals(decoded.getClaim("type").asString())) {
+// return "";
+// }
+ Calendar calendar = Calendar.getInstance();
+ calendar.setTime(new Date());
+ calendar.add(Calendar.HOUR_OF_DAY, 1);
+ return JWT.create()
+ .withIssuer("com.jiandaoyun")
+ .withClaim("type", "sso_res")
+ .withClaim("username", username)
+ .withAudience("com.jiandaoyun")
+ .withExpiresAt(calendar.getTime())
+ .sign(algorithm);
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/example/sso/util/APIUtils.java b/src/main/java/com/example/sso/util/APIUtils.java
new file mode 100644
index 0000000..5d56cf8
--- /dev/null
+++ b/src/main/java/com/example/sso/util/APIUtils.java
@@ -0,0 +1,503 @@
+package com.example.sso.util;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.commons.codec.Charsets;
+import org.apache.http.Header;
+import org.apache.http.HttpEntity;
+import org.apache.http.HttpResponse;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpRequestBase;
+import org.apache.http.client.utils.URIBuilder;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicHeader;
+import org.apache.http.ssl.SSLContextBuilder;
+import org.apache.http.ssl.TrustStrategy;
+
+import javax.net.ssl.SSLContext;
+import java.security.cert.CertificateException;
+import java.security.cert.X509Certificate;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class APIUtils {
+ public static final String WEBSITE = "https://www.jiyuankeshang.com";
+ private static boolean retryIfRateLimited = true;
+ private String urlGetWidgets;
+ private String urlGetFormData;
+ private String urlRetrieveData;
+ private String urlUpdateData;
+ private String urlCreateData;
+ private String urlDeleteData;
+ private String urlCreateUSer;
+ private String urlCreatePerson;
+ private String urlCreatePersonAll;
+ private String urlCreateDep;
+ private String urlCreateDepAll;
+ private String urlGetDepartment;
+ private String urlGetPeople;
+ private String urlDeletePeople;
+ private static String apiKey;
+ /**
+ * @param appId - 应用id
+ * @param entryId - 表单id
+ * @param apiKey - apiKey
+ */
+ public APIUtils(String appId, String entryId, String apiKey) {
+ this.apiKey = apiKey;
+ this.initUrl(appId, entryId);
+ }
+ public Map createPerson (Map person) {
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",urlCreatePerson, person);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+ public Map createDep (Map person) {
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",urlCreatePerson, person);
+ data = (Map) result.get("department");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+ private void initUrl (String appId, String entryId) {
+ urlGetWidgets = WEBSITE + "/api/v1/app/" + appId + "/entry/" + entryId + "/widgets";
+ urlGetFormData = WEBSITE + "/api/v1/app/" + appId + "/entry/" + entryId + "/data";
+ urlRetrieveData = WEBSITE + "/api/v1/app/" + appId + "/entry/" + entryId + "/data_retrieve";
+ urlUpdateData = WEBSITE + "/api/v1/app/" + appId + "/entry/" + entryId + "/data_update";
+ urlCreateData = WEBSITE + "/api/v3/app/" + appId + "/entry/" + entryId + "/data_create";
+ urlDeleteData = WEBSITE + "/api/v1/app/" + appId + "/entry/" + entryId + "/data_delete";
+ urlCreatePerson=WEBSITE+"/api/v2/user/create";
+ urlCreateUSer = WEBSITE + "/api/v2/user/create";
+ urlCreateDep=WEBSITE+"/api/v2/department/create";
+ urlCreateDepAll=WEBSITE+"/api/v2/department/import";
+ urlCreatePersonAll=WEBSITE+"/api/v2/user/import";
+ urlGetDepartment=WEBSITE+"/api/v2/department/1/department_list";
+ urlGetPeople=WEBSITE + "/api/v2/department/1/member_list";
+ urlDeletePeople=WEBSITE+"/api/v2/user/batch_delete";
+ }
+
+ public static HttpClient getSSLHttpClient() throws Exception {
+ SSLContext sslContext = new SSLContextBuilder().loadTrustMaterial(null, new TrustStrategy() {
+ //信任所有
+ public boolean isTrusted(X509Certificate[] chain, String authType) throws CertificateException {
+ return true;
+ }
+ }).build();
+ SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslContext);
+ return HttpClients.custom().setSSLSocketFactory(sslsf).build();
+ }
+ /**
+ * 获取部门成员信息
+ * @param - 创建数据内容
+ * @return 更新后的数据
+ */
+ public Map deletePeopleBatch(Map map) {
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",urlDeletePeople, map);
+ return result;
+// data = (Map) result.get("department");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+ /**
+ * 获取请求头信息
+ * @return
+ */
+ public static Header[] getHttpHeaders() {
+ List headerList = new ArrayList();
+ headerList.add(new BasicHeader("Authorization", "Bearer " + apiKey));
+ headerList.add(new BasicHeader("Content-Type", "application/json;charset=utf-8"));
+ return headerList.toArray(new Header[headerList.size()]);
+ }
+
+ /**
+ * 查询人员信息
+ * @param username - 创建数据内容
+ * @return 更新后的数据
+ */
+ public Map findPerson (String username) {
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",WEBSITE + "/api/v2/user/"+username+"/user_retrieve", new HashMap<>());
+ data = (Map) result.get("data");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+ /**
+ * 发送HTTP请求
+ * @param method - HTTP动词 { GET|POST }
+ * @param url - 请求路径
+ * @param data - 请求的数据
+ * @throws Exception
+ */
+ public static Object sendRequest (String method, String url, Map data) throws Exception {
+ HttpClient client = getSSLHttpClient();
+ Header[] headers = getHttpHeaders();
+ HttpRequestBase request;
+ method = method.toUpperCase();
+ if ("GET".equals(method)) {
+ // GET请求
+ URIBuilder uriBuilder = new URIBuilder(url);
+ if (data != null) {
+ // 添加请求参数
+ for(Map.Entry entry : data.entrySet()) {
+ uriBuilder.addParameter(entry.getKey(), (String) entry.getValue());
+ }
+ }
+ request = new HttpGet(uriBuilder.build());
+ } else if ("POST".equals(method)) {
+ // POST请求
+ request = new HttpPost(url);
+ ObjectMapper mapper = new ObjectMapper();
+ HttpEntity entity = new StringEntity(mapper.writeValueAsString(data), Charsets.UTF_8);
+ ((HttpPost) request).setEntity(entity);
+ } else {
+ throw new RuntimeException("不支持的HTTP动词");
+ }
+ // 设置请求头
+ request.setHeaders(headers);
+ // 发送请求并获取返回结果
+ HttpResponse response = client.execute(request);
+ int statusCode = response.getStatusLine().getStatusCode();
+ ObjectMapper mapper = new ObjectMapper();
+ Map result = (Map) mapper.readValue(response.getEntity().getContent(), Object.class);
+ if (statusCode >= 400) {
+ // 请求错误
+ if ((Integer) result.get("code") == 8303 && retryIfRateLimited) {
+ // 频率超限，1s后重试
+ Thread.sleep(1000);
+ return sendRequest(method, url, data);
+ } else {
+ return result;
+ }
+ } else {
+ // 处理返回结果
+ return result;
+ }
+ }
+
+
+
+
+ /**
+ * 获取表单字段
+ * @return 表单字段
+ */
+ public List> getFormWidgets () {
+ List> widgets = null;
+ try {
+ Map result = (Map) this.sendRequest("POST", urlGetWidgets, new HashMap());
+ widgets = (List>) result.get("widgets");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return widgets;
+ }
+
+
+
+ public List> createUser(String username, String name, Integer[] departments){
+ Map data = null;
+ try {
+ Map requestData = new HashMap();
+ requestData.put("username",username);
+ requestData.put("name",name);
+ requestData.put("departments",departments);
+ Map result = (Map) this.sendRequest("POST",urlCreateUSer, requestData);
+ data = (Map) result.get("data");
+ }catch (Exception e) {
+ e.printStackTrace();
+ }
+ return (List>) data;
+ }
+ /**
+ * 按条件获取表单数据
+ * @param limit - 数据条数
+ * @param fields - 显示的字段
+ * @param filter - 过滤条件
+ * @param dataId - 上次取数的最后一个数据id
+ * @return - 返回的数据
+ */
+ public List> getFormData (final int limit, final String[] fields, final Map filter, String dataId) {
+ List> data = null;
+ try {
+ // 构造请求数据
+ Map requestData = new HashMap() {
+ {
+ put("limit", limit);
+ put("fields", fields);
+ put("filter", filter);
+ }
+ };
+ if (dataId != null) {
+ requestData.put("data_id", dataId);
+ }
+ Map result = (Map) this.sendRequest("POST", urlGetFormData, requestData);
+ data = (List>) result.get("data");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+ /**
+ * 按条件获取全部表单数据
+ * @return 表单数据
+ */
+ public List> getAllFormData (String[] fields, Map filter) {
+ List> dataList = new ArrayList>();
+ String offset = null;
+ do {
+ List> data = this.getFormData(100, fields, filter, offset);
+ // 获取返回的数据
+ if (data == null || data.isEmpty()) {
+ // 已经获取全部的数据
+ offset = null;
+ } else {
+ // 获取最后一条数据的id
+ offset = (String) data.get(data.size() - 1).get("_id");
+ dataList.addAll(data);
+ }
+ } while (offset != null);
+ return dataList;
+ }
+
+
+
+
+ /**
+ * 搜索单条数据
+ * @param dataId - 要查询的数据id
+ * @return 表单数据
+ */
+ public Map retrieveData (String dataId) {
+ Map data = null;
+ try {
+ Map requestData = new HashMap();
+ requestData.put("data_id", dataId);
+ Map result = (Map) this.sendRequest("POST", urlRetrieveData, requestData);
+ data = (Map) result.get("data");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+ /**
+ * 新增部门
+ * @param - 创建数据内容
+ * @return 更新后的数据
+ */
+ public Map createDataDep (Map requestData) {
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",urlCreateDep, requestData);
+// data = (Map) result.get("department");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+
+
+ /**
+ * 批量创建部门
+ * @param - 创建数据内容
+ * @return 更新后的数据
+ */
+ public Map createDataDepAll (Map requestData) {
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",urlCreateDepAll, requestData);
+// data = (Map) result.get("department");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+
+ /**
+ * 批量创建人员
+ * @param - 创建数据内容
+ * @return 更新后的数据
+ */
+ public Map createDataPersonAll (Map requestData) {
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",urlCreatePersonAll, requestData);
+ System.out.println(result);
+ return result;
+// data = (Map) result.get("department");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+ /**
+ * 获取部门信息
+ * @param - 创建数据内容
+ * @return 更新后的数据
+ */
+ public Map getDepartment() {
+ Map map=new HashMap<>();
+ map.put("has_child",1);
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",urlGetDepartment,map);
+ System.out.println(result);
+ return result;
+// data = (Map) result.get("department");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+
+ /**
+ * 获取部门成员信息
+ * @param - 创建数据内容
+ * @return 更新后的数据
+ */
+ public Map getDepartmentPerson(String dno) {
+ Map map=new HashMap<>();
+// map.put("has_child",1);
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",WEBSITE+"/api/v2/department/"+dno+"/member_list",map);
+ return result;
+// data = (Map) result.get("department");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+ public Map deleteDepartment(Integer no) {
+ Map map=new HashMap<>();
+ map.put("has_child",1);
+ Map data = null;
+ try {
+ Map result = (Map) this.sendRequest("POST",WEBSITE+"/api/v2/department/"+no+"/delete",new HashMap<>());
+ System.out.println(result);
+ return result;
+// data = (Map) result.get("department");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+
+
+// /**
+// * 新增部门
+// * @param - 创建数据内容
+// * @return 更新后的数据
+// */
+// public Map createDataDep (Map requestData) {
+// Map data = null;
+// try {
+// Map result = (Map) this.sendRequest("POST",urlCreateDep, requestData);
+// data = (Map) result.get("data");
+// } catch (Exception e) {
+// e.printStackTrace();
+// }
+// return data;
+// }
+
+
+ /**
+ * 创建单条数据
+ * @param rawData - 创建数据内容
+ * @return 更新后的数据
+ */
+ public Map createData (Map rawData) {
+ Map data = null;
+ try {
+ Map requestData = new HashMap();
+ requestData.put("data", rawData);
+ requestData.put("is_start_workflow",true);
+ Map result = (Map) this.sendRequest("POST",urlCreateData, requestData);
+ data = (Map) result.get("data");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+
+
+ /**
+ * 获取所有的人在简道云
+ * @return 更新后的数据
+ */
+ public List> getAllPeople () {
+ List> data = null;
+ try {
+ Map requestData = new HashMap();
+ requestData.put("has_child",true);
+// System.out.println("准备发起HTTP请求！"+urlGetPeople);
+ Map result = (Map) this.sendRequest("POST",urlGetPeople, requestData);
+ data = (List>) result.get("users");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+ /**
+ * 更新单条数据
+ * @return 更新结果
+ */
+ public Map updateData (String dataId, Map update) {
+ Map data = null;
+ try {
+ Map requestData = new HashMap();
+ requestData.put("data_id", dataId);
+ requestData.put("data", update);
+ Map result = (Map) this.sendRequest("POST", urlUpdateData, requestData);
+ data = (Map) result.get("data");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return data;
+ }
+
+ /**
+ * 删除单条数据
+ * @return 删除结果
+ */
+ public Map deleteData (String dataId) {
+ Map result = null;
+ try {
+ Map requestData = new HashMap();
+ requestData.put("data_id", dataId);
+ result = (Map) this.sendRequest("POST", urlDeleteData, requestData);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return result;
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/example/sso/util/BeiSenTest.java b/src/main/java/com/example/sso/util/BeiSenTest.java
new file mode 100644
index 0000000..4f495e0
--- /dev/null
+++ b/src/main/java/com/example/sso/util/BeiSenTest.java
@@ -0,0 +1,274 @@
+package com.example.sso.util;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Set;
+
+public class BeiSenTest {
+ private static String app_key = "F493FDF0DA9B4DF3A826530B568E6BAF";
+ private static String app_secret = "B9BAA96975C74DB8AF07EB5D5243F56DE2FAE0ED37D64797AB2487EA3F8011CD";
+ private static int i=0;
+ public static void main(String[] args) {
+// 同步职工数据
+// try {
+//// deleteUser(608421892);
+// } catch (NoSuchAlgorithmException e) {
+// e.printStackTrace();
+// } catch (KeyManagementException e) {
+// e.printStackTrace();
+// }
+
+// //修改职工基础信息数据
+ try {
+ JSONArray beiSens = JDYUtil.getAllDriversBeiSen();//查询
+ JSONArray drivers = JDYUtil.getAllDrivers();//查询
+ JSONObject orgNos=JDYUtil.getOrgNos();
+ JSONObject jsonObject = new JSONObject();
+ for (Object o : drivers) {
+ HashMap driver = (HashMap) o;
+ jsonObject.put((String) driver.get("shjh") + "@yinjian.com", driver);
+ }
+ String token=getToken();
+ int i=0;
+ for (Object o : beiSens) {
+ i=i+1;
+ JSONObject driver = (JSONObject) o;
+ String xm=driver.getString("xm");
+ if (xm.equals("宋乃庆")){
+ if (jsonObject.getJSONObject(driver.getString("zhanghao"))!=null){
+ BeiSenTest.updateUser(jsonObject.getJSONObject(driver.getString("zhanghao")),driver.getInteger("oid"),orgNos,token);
+ System.out.println(jsonObject.getJSONObject(driver.getString("zhanghao")));
+ //更新简道云数据
+ JDYUtil.updateBeiSenId(jsonObject.getJSONObject(driver.getString("zhanghao")).
+ getString("_id"),driver.getString("oid"));
+ }
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+// JSONArray drivers=JDYUtil.getAllDrivers();//查询
+// JSONObject orgNos=JDYUtil.getOrgNos();
+// JSONArray deps=new JSONArray();
+// for (Object o:drivers){
+// HashMap driver=(HashMap)o;
+//// try {
+////// BeiSenTest.updateUser(driver,(String) driver.get("shfzhh"),orgNos);
+//// } catch (NoSuchAlgorithmException e) {
+//// e.printStackTrace();
+//// } catch (KeyManagementException e) {
+//// e.printStackTrace();
+//// }
+// }
+// Set set=new HashSet();//创建set集合
+// for (int i=0;i> condList = new ArrayList>();
+ //因为想查询大于50的数据，所以创建一个数组
+ JSONArray jsonArray = new JSONArray();
+ //在这个数组里面放一个数值类型的数字，用来判断查询范围
+ jsonArray.add(id_card_num);
+ condList.add(new HashMap() {
+ {
+ put("field", "shfzhh");//查新字段的名称/别名
+ put("method", "eq");//判断的方法
+ put("value", jsonArray);//查询的条件
+ }
+ });
+ Map filter = new HashMap() {
+ {
+ put("rel", "and");
+ put("cond", condList);
+ }
+ };
+ //字段别名
+ List> datas = api.getFormData(10000, new String[]{"xm", "ssbm",
+ "fs","yxbs","lrrq","shjh","shfzhh","shjh","beisen_id"},//身份证号码
+ filter, null);
+ if (datas == null) {
+ return null;
+ }
+ if (datas.size() == 0) {
+ return null;
+ }
+ JSONObject jsonObject=new JSONObject();
+ jsonObject.put("list",datas);
+ JSONArray jsonArray1=new JSONArray();
+ for (Map o:datas){
+ String time=(String) o.get("lrrq");
+ if (time!=null){
+ o.put("lrrq",TimeUtil.timeConversion2(time));
+ }
+ jsonArray1.add(o);
+ }
+ return jsonArray1.getJSONObject(0);
+ }
+
+
+ /**
+ * 创建人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+// public static void createUser(JSONObject driver, JSONObject orgNos,JSONArray deps) throws NoSuchAlgorithmException, KeyManagementException {
+// String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Create";
+// JSONObject body = new JSONObject();
+// body.put("employeeInformation", "client_credentials");
+// JSONObject employeeInformation = new JSONObject();
+// employeeInformation.put("name", driver.get("xm"));//姓名：张三
+// employeeInformation.put("email",driver.get("yxbs"));//邮箱
+// employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+//// employeeInformation.put("email", driver.get("shjh") + "@yinjian.com");//邮箱
+// employeeInformation.put("mobilePhone", driver.get("shjh"));//身份证号码
+// JSONObject employmentRecord = new JSONObject();
+// employmentRecord.put("entryDate", driver.get("lrrq"));//入职日期\
+// employeeInformation.put("emergencyContactPhone", driver.get("shjh"));//身份证号码
+// employmentRecord.put("probation", 0);//试用期，无试用期为0
+// String name = (String) driver.get("name");//
+// String uu=(String) driver.get("ssbm") + (String) driver.get("fs");
+// for (String str : orgNos.keySet()) {
+// if (str.equals((String) driver.get("ssbm") + (String) driver.get("fs")+"司")) {
+// employmentRecord.put("OIdDepartment", orgNos.getInteger(str));//试用期，无试用期为0
+// break;
+// }
+// }
+// Integer O=employmentRecord.getInteger("OIdDepartment");
+// if (O==null){
+// deps.add(uu);
+// System.out.println("");
+// }
+// employmentRecord.put("originalId", driver.get("shfzhh"));//外部编码ID
+// employmentRecord.put("employmentType", "020c47b0-74b7-4a75-b454-e9905f64e1fc");//人员类别
+// employmentRecord.put("oIdJobPost", "149359");//职务
+// body.put("employeeInformation", employeeInformation);
+// body.put("employmentRecord", employmentRecord);
+// JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+// System.out.println(jsonObject.toJSONString());
+//// JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+//// System.out.println(jsonObject.toJSONString());
+//// return jsonObject.getString("access_token");
+//}
+ public static String getToken() throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/token";
+ JSONObject body = new JSONObject();
+ body.put("grant_type", "client_credentials");
+ body.put("app_key", app_key);
+ body.put("app_secret", app_secret);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString()));
+ return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 创建人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void createUser(JSONObject driver, JSONObject orgNos, String id) throws NoSuchAlgorithmException, KeyManagementException {
+ String token = getToken();
+// if (driver.getString("beisen_id") == null || driver.getString("beisen_id").equals("")) {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Create";
+ JSONObject body = new JSONObject();
+ body.put("employeeInformation", "client_credentials");
+ JSONObject employeeInformation = new JSONObject();
+ employeeInformation.put("name", driver.get("xm"));//姓名：张三
+ employeeInformation.put("email", driver.get("yxbs"));//邮箱
+ employeeInformation.put("originalId", driver.get("shfzhh"));//外部ID
+ employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+ employeeInformation.put("mobilePhone", driver.get("shjh"));//电话号码
+ employeeInformation.put("emergencyContactPhone", driver.get("shjh"));//电话
+ JSONObject employmentRecord = new JSONObject();
+ employmentRecord.put("entryDate", driver.get("lrrq"));//入职日期
+ employmentRecord.put("probation", 0);//试用期，无试用期为0
+ String name = (String) driver.get("name");//
+ for (String str : orgNos.keySet()) {
+ if (str.equals(driver.get("fs"))) {
+ employmentRecord.put("OIdDepartment", orgNos.getInteger(str));//试用期，无试用期为0
+ break;
+ }
+ }
+ employmentRecord.put("employmentType", "020c47b0-74b7-4a75-b454-e9905f64e1fc");//人员类别
+ employmentRecord.put("oIdJobPost", "149359");//职务
+ body.put("employeeInformation", employeeInformation);
+ body.put("employmentRecord", employmentRecord);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), token));
+ JSONObject returnData = jsonObject.getJSONObject("data");
+ System.out.println(driver.get("shfzhh") + "的创建账户动作返回为:" + jsonObject.toJSONString());
+ if (jsonObject.getString("code").equals("200")) {
+ JDYUtil.updateBeiSenId(id, returnData.getString("userId"));
+ }
+// } else {
+ //如果不是新增则修改数据
+// updateUser(driver, driver.getInteger("beisen_id"), orgNos, token);
+// }
+// return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 创建人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+// public static void createUser(JSONObject driver, JSONObject orgNos,String id) throws NoSuchAlgorithmException, KeyManagementException {
+// String token=getToken();
+// if (driver.getString("beisen_id")==null||driver.getString("beisen_id").equals("")){
+// String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Create";
+// JSONObject body = new JSONObject();
+// body.put("employeeInformation", "client_credentials");
+// JSONObject employeeInformation = new JSONObject();
+// employeeInformation.put("name", driver.get("xm"));//姓名：张三
+// employeeInformation.put("email",driver.get("yxbs"));//邮箱
+// employeeInformation.put("originalId",driver.get("shfzhh"));//外部ID
+// employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+// employeeInformation.put("mobilePhone", driver.get("shjh"));//电话号码
+// employeeInformation.put("emergencyContactPhone", driver.get("shjh"));//电话
+// JSONObject employmentRecord = new JSONObject();
+// employmentRecord.put("entryDate", driver.get("lrrq"));//入职日期
+// employmentRecord.put("probation", 0);//试用期，无试用期为0
+// String name = (String) driver.get("name");//
+// employmentRecord.put("OIdDepartment",600186);//试用期，无试用期为0
+// body.put("employeeInformation", employeeInformation);
+// body.put("employmentRecord", employmentRecord);
+// JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(),token));
+// JSONObject returnData=jsonObject.getJSONObject("data");
+// try {
+// if (returnData!=null){
+// System.out.println(driver.get("shfzhh")+"的创建账户动作返回为:"+jsonObject.toJSONString());
+// if (jsonObject.getString("code").equals("200")){
+// JDYUtil.updateBeiSenId(id,returnData.getString("userId"));
+// }
+// }
+// }catch (Exception e){
+// e.printStackTrace();
+// }
+// }else {
+// //如果不是新增则修改数据
+// updateUser(driver,driver.getInteger("beisen_id"),orgNos,token);
+// }
+//// return jsonObject.getString("access_token");
+// }
+
+ /**
+ * 修改人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void updateUser(JSONObject driver, Integer id, JSONObject orgNos, String token) throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/UpdateEmployee";
+ JSONObject body = new JSONObject();
+ body.put("employeeInformation", "client_credentials");
+ JSONObject employeeInformation = new JSONObject();
+ employeeInformation.put("name", driver.get("xm"));//姓名：张三
+ employeeInformation.put("email", driver.get("yxbs"));//邮箱
+ employeeInformation.put("originalId", driver.get("shfzhh"));//外部ID
+ employeeInformation.put("iDNumber", driver.get("shfzhh"));//身份证号码
+ employeeInformation.put("mobilePhone", driver.get("shjh"));//电话号码
+ employeeInformation.put("emergencyContactPhone", driver.get("shjh"));//电话
+ JSONObject employmentRecord = new JSONObject();
+ employmentRecord.put("employmentType", "020c47b0-74b7-4a75-b454-e9905f64e1fc");//人员类别
+ for (String str : orgNos.keySet()) {
+ if (str.equals((String) driver.get("ssbm") + (String) driver.get("fs") + "司")) {
+ employmentRecord.put("OIdDepartment", orgNos.getInteger(str));//试用期，无试用期为0
+ break;
+ }
+ }
+ employmentRecord.put("oIdJobPost", "149359");//职务
+ body.put("employeeInformation", employeeInformation);
+ body.put("employmentRecord", employmentRecord);
+ body.put("userId", id);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), token));
+ System.out.println(jsonObject.toJSONString());
+// return jsonObject.getString("access_token");
+ }
+
+
+ /**
+ * 离职人员信息
+ *
+ * @return
+ * @throws NoSuchAlgorithmException
+ * @throws KeyManagementException
+ */
+ public static void deleteUser(Integer id) throws NoSuchAlgorithmException, KeyManagementException {
+ String url = "https://openapi.italent.cn/TenantBaseExternal/api/v5/Employee/Dimission";
+ JSONObject body = new JSONObject();
+ SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
+ JSONObject employmentRecord = new JSONObject();
+ try {
+ employmentRecord.put("lastWorkDate", df.format(new Date()));//最后工作日期
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ body.put("employmentRecord", employmentRecord);
+ body.put("userId", id);
+ JSONObject jsonObject = JSON.parseObject(HttpUtil.sendPost(url, body.toJSONString(), getToken()));
+ System.out.println(jsonObject.toJSONString());
+// return jsonObject.getString("access_token");
+ }
+
+
+}
diff --git a/src/main/java/com/example/sso/util/BeiSenTest1.java.baiduyun.uploading.cfg b/src/main/java/com/example/sso/util/BeiSenTest1.java.baiduyun.uploading.cfg
new file mode 100644
index 0000000..4f737cd
Binary files /dev/null and b/src/main/java/com/example/sso/util/BeiSenTest1.java.baiduyun.uploading.cfg differ
diff --git a/src/main/java/com/example/sso/util/HttpUtil.java b/src/main/java/com/example/sso/util/HttpUtil.java
new file mode 100644
index 0000000..90614bc
--- /dev/null
+++ b/src/main/java/com/example/sso/util/HttpUtil.java
@@ -0,0 +1,265 @@
+package com.example.sso.util;
+
+import java.io.IOException;
+import java.security.KeyManagementException;
+import java.security.NoSuchAlgorithmException;
+import java.security.cert.CertificateException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.http.Consts;
+import org.apache.http.HttpEntity;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.config.Registry;
+import org.apache.http.config.RegistryBuilder;
+import org.apache.http.conn.socket.ConnectionSocketFactory;
+import org.apache.http.conn.socket.PlainConnectionSocketFactory;
+import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+
+/** * Http工具类，发送Http请求， Get请求请将参数放在url中 Post请求请将参数放在Map中 * * @author 程高伟 * @date 2017年1月5日 下午6:03:50 */
+public class HttpUtil {
+// private static final Logger log = LoggerFactory.getLogger(HttpUtil.class);
+ private static final CloseableHttpClient httpclient = HttpClients.createDefault();
+ private static final String userAgent = "Mozilla/5.0 (Windows NT 6.2; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/54.0.2840.87 Safari/537.36";
+
+ public static SSLContext createIgnoreVerifySSL() throws NoSuchAlgorithmException, KeyManagementException {
+ SSLContext sc = SSLContext.getInstance("SSLv3");
+
+ // 实现一个X509TrustManager接口，用于绕过验证，不用修改里面的方法
+ X509TrustManager trustManager = new X509TrustManager() {
+ @Override
+ public void checkClientTrusted(
+ java.security.cert.X509Certificate[] paramArrayOfX509Certificate,
+ String paramString) throws CertificateException {
+ }
+
+ @Override
+ public void checkServerTrusted(
+ java.security.cert.X509Certificate[] paramArrayOfX509Certificate,
+ String paramString) throws CertificateException {
+ }
+
+ @Override
+ public java.security.cert.X509Certificate[] getAcceptedIssuers() {
+ return null;
+ }
+ };
+
+ sc.init(null, new TrustManager[] { trustManager }, null);
+ return sc;
+ }
+ /** * 发送HttpGet请求 * * @param url * 请求地址 * @return 返回字符串 */
+ public static String sendGet(String url,String token) throws KeyManagementException, NoSuchAlgorithmException {
+ SSLContext sslcontext = createIgnoreVerifySSL();
+
+ // 设置协议http和https对应的处理socket链接工厂的对象
+ Registry socketFactoryRegistry = RegistryBuilder.create()
+ .register("http", PlainConnectionSocketFactory.INSTANCE)
+ .register("https", new SSLConnectionSocketFactory(sslcontext))
+ .build();
+ PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
+ CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(connManager).build();
+ String result = null;
+ CloseableHttpResponse response = null;
+ try {
+ HttpGet httpGet = new HttpGet(url);
+ httpGet.setHeader("User-Agent", userAgent);
+ httpGet.setHeader("Authorization", "Bearer "+token);
+ response = httpClient.execute(httpGet);
+ HttpEntity entity = response.getEntity();
+ if (entity != null) {
+ result = EntityUtils.toString(entity,"UTF-8");
+ }
+ } catch (Exception e) {
+// log.error("处理失败 {}" + e);
+ e.printStackTrace();
+ } finally {
+ if (response != null) {
+ try {
+ response.close();
+ } catch (IOException e) {
+// // log.error(e.getMessage());
+ }
+ }
+ }
+ return result;
+ }
+
+
+
+ /** * 发送HttpPost请求，参数为json字符串 * * @param url * @param jsonStr * @return */
+ public static String sendPost(String url, String jsonStr,String token) throws KeyManagementException, NoSuchAlgorithmException {
+ //采用绕过验证的方式处理https请求
+ SSLContext sslcontext = createIgnoreVerifySSL();
+
+ // 设置协议http和https对应的处理socket链接工厂的对象
+ Registry socketFactoryRegistry = RegistryBuilder.create()
+ .register("http", PlainConnectionSocketFactory.INSTANCE)
+ .register("https", new SSLConnectionSocketFactory(sslcontext))
+ .build();
+ PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
+ CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(connManager).build();
+ String result = null;
+ // 字符串编码
+ StringEntity entity = new StringEntity(jsonStr, Consts.UTF_8);
+ // 设置content-type
+ entity.setContentType("application/json");
+ HttpPost httpPost = new HttpPost(url);
+ // 防止被当成攻击添加的
+ httpPost.setHeader("User-Agent", userAgent);
+ httpPost.setHeader("Authorization", "Bearer "+token);
+ // 接收参数设置
+ httpPost.setHeader("Accept", "application/json");
+ httpPost.setEntity(entity);
+ CloseableHttpResponse response = null;
+ try {
+ response = httpClient.execute(httpPost);
+ HttpEntity httpEntity = response.getEntity();
+ result = EntityUtils.toString(httpEntity);
+ } catch (IOException e) {
+// // log.error(e.getMessage());
+ } finally {
+ // 关闭CloseableHttpResponse
+ if (response != null) {
+ try {
+ response.close();
+ } catch (IOException e) {
+// // log.error(e.getMessage());
+ }
+ }
+ }
+ return result;
+ }
+
+
+ /** * 发送HttpPost请求，参数为map * * @param url * 请求地址 * @param map * 请求参数 * @return 返回字符串 */
+ public static String sendPost(String url, Map map) {
+ // 设置参数
+ List formparams = new ArrayList();
+ for (Map.Entry entry : map.entrySet()) {
+ formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
+ }
+ // 编码
+ UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
+ // 取得HttpPost对象
+ HttpPost httpPost = new HttpPost(url);
+ // 防止被当成攻击添加的
+ httpPost.setHeader("User-Agent", userAgent);
+ // 参数放入Entity
+ httpPost.setEntity(formEntity);
+ CloseableHttpResponse response = null;
+ String result = null;
+ try {
+ // 执行post请求
+ response = httpclient.execute(httpPost);
+ // 得到entity
+ HttpEntity entity = response.getEntity();
+ // 得到字符串
+ result = EntityUtils.toString(entity);
+ } catch (IOException e) {
+ // log.error(e.getMessage());
+ } finally {
+ if (response != null) {
+ try {
+ response.close();
+ } catch (IOException e) {
+ // log.error(e.getMessage());
+ }
+ }
+ }
+ return result;
+ }
+
+
+ /** * 发送HttpPost请求，参数为json字符串 * * @param url * @param jsonStr * @return */
+ public static String sendPost(String url, String jsonStr) throws KeyManagementException, NoSuchAlgorithmException {
+ //采用绕过验证的方式处理https请求
+ SSLContext sslcontext = createIgnoreVerifySSL();
+
+ // 设置协议http和https对应的处理socket链接工厂的对象
+ Registry socketFactoryRegistry = RegistryBuilder.create()
+ .register("http", PlainConnectionSocketFactory.INSTANCE)
+ .register("https", new SSLConnectionSocketFactory(sslcontext))
+ .build();
+ PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(socketFactoryRegistry);
+ CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(connManager).build();
+ String result = null;
+ // 字符串编码
+ StringEntity entity = new StringEntity(jsonStr, Consts.UTF_8);
+ // 设置content-type
+ entity.setContentType("application/json");
+ HttpPost httpPost = new HttpPost(url);
+ // 防止被当成攻击添加的
+ httpPost.setHeader("User-Agent", userAgent);
+ httpPost.setHeader("Authorization", "Bearer ");
+ // 接收参数设置
+ httpPost.setHeader("Accept", "application/json");
+ httpPost.setEntity(entity);
+ CloseableHttpResponse response = null;
+ try {
+ response = httpClient.execute(httpPost);
+ HttpEntity httpEntity = response.getEntity();
+ result = EntityUtils.toString(httpEntity);
+ } catch (IOException e) {
+ // log.error(e.getMessage());
+ } finally {
+ // 关闭CloseableHttpResponse
+ if (response != null) {
+ try {
+ response.close();
+ } catch (IOException e) {
+ // log.error(e.getMessage());
+ }
+ }
+ }
+ System.out.println(result);
+ return result;
+ }
+
+ /** * 发送不带参数的HttpPost请求 * * @param url * @return */
+ public static String sendPost(String url) {
+ String result = null;
+ // 得到一个HttpPost对象
+ HttpPost httpPost = new HttpPost(url);
+ // 防止被当成攻击添加的
+ httpPost.setHeader("User-Agent", userAgent);
+ CloseableHttpResponse response = null;
+ try {
+ // 执行HttpPost请求，并得到一个CloseableHttpResponse
+ response = httpclient.execute(httpPost);
+ // 从CloseableHttpResponse中拿到HttpEntity
+ HttpEntity entity = response.getEntity();
+ // 将HttpEntity转换为字符串
+ result = EntityUtils.toString(entity);
+ } catch (IOException e) {
+ // log.error(e.getMessage());
+ } finally {
+ // 关闭CloseableHttpResponse
+ if (response != null) {
+ try {
+ response.close();
+ } catch (IOException e) {
+ // log.error(e.getMessage());
+ }
+ }
+ }
+ return result;
+ }
+}
diff --git a/src/main/java/com/example/sso/util/J905Util.java b/src/main/java/com/example/sso/util/J905Util.java
new file mode 100644
index 0000000..1bb0bc5
--- /dev/null
+++ b/src/main/java/com/example/sso/util/J905Util.java
@@ -0,0 +1,33 @@
+package com.example.sso.util;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+
+public class J905Util {
+
+ /**
+ * 请求成功
+ * @param data
+ * @return
+ */
+ public static JSONObject returnOK(JSONArray data){
+ JSONObject jsonObject=new JSONObject();
+ jsonObject.put("code",2000);
+ jsonObject.put("message","操作成功");
+ jsonObject.put("result",data);
+ return jsonObject;
+ }
+
+
+ /**
+ * 请求失败
+ * @param
+ * @return
+ */
+ public static JSONObject returnLoser(int num,String meg){
+ JSONObject jsonObject=new JSONObject();
+ jsonObject.put("code",num);
+ jsonObject.put("message",meg);
+ return jsonObject;
+ }
+}
diff --git a/src/main/java/com/example/sso/util/JDYUtil.java b/src/main/java/com/example/sso/util/JDYUtil.java
new file mode 100644
index 0000000..128e3fc
--- /dev/null
+++ b/src/main/java/com/example/sso/util/JDYUtil.java
@@ -0,0 +1,482 @@
+package com.example.sso.util;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+
+import java.util.*;
+
+public class JDYUtil {
+
+
+ public static void main(String[] args) {
+// JSONArray drivers=JDYUtil.getAllDrivers();//查询
+// for (Object o:drivers){
+// HashMap