Skip to content

T
tagManager
Commit 3c0fe097 by xieshaohua
Options

ngdb改造初始化

parent 642fa0ce
Showing with 2891 additions and 611 deletions
.gitignore
/target/
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**
!**/src/test/**
### STS ###
.apt_generated
......@@ -18,8 +21,11 @@
### NetBeans ###
/nbproject/private/
/build/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
### VS Code ###
.vscode/
Dockerfile 0 → 100644
FROM hub.sofadev.res.aliyun-test.sdebank.com/library/openjdk:8-jdk-alpine-base
WORKDIR /home/admin
COPY ./tag-runtime/target/tag-runtime-2.0.1-SNAPSHOT.jar .
COPY ./start.sh .
RUN sed -i 's/\r//' ./start.sh
ENTRYPOINT [ "/bin/sh", "/home/admin/start.sh", "start" ]
mvnw 0 → 100644
#!/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 "$@"
mvnw.cmd 0 → 100644
@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%
pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.keymobile</groupId>
<artifactId>tagManager</artifactId>
<version>1.0.2-SNAPSHOT</version>
<packaging>jar</packaging>
<name>tagManager</name>
<description>tagManager</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.4.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
<groupId>com.keymobile.sdrcb</groupId>
<artifactId>ngdb-starter</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<docker.image.prefix>springio</docker.image.prefix>
<druid.version>1.0.29</druid.version>
<fastjson.version>1.2.70</fastjson.version>
<spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
<easypoi.version>4.1.3</easypoi.version>
<spring.version>5.0.19.RELEASE</spring.version>
</properties>
<groupId>com.keymobile</groupId>
<artifactId>tag-manager</artifactId>
<version>2.0.1-SNAPSHOT</version>
<packaging>pom</packaging>
<modules>
<module>tag-facade</module>
<module>tag-service</module>
<module>tag-runtime</module>
</modules>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<exclusions>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-json</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.9.10.6</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.7</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.5.0</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.5.0</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>${fastjson.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-configuration-processor</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-config-client</artifactId>
</dependency>
<dependency>
<groupId>org.dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>2.1.0</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>20.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.antlr</groupId>
<artifactId>antlr4-runtime</artifactId>
<version>4.7</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.46</version>
</dependency>
<!-- 引入easypoi -->
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-base</artifactId>
<version>${easypoi.version}</version>
</dependency>
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-web</artifactId>
<version>${easypoi.version}</version>
</dependency>
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-annotation</artifactId>
<version>${easypoi.version}</version>
</dependency>
<!-- 引入easypoi -->
<dependency>
<groupId>auth</groupId>
<artifactId>auth-common</artifactId>
<scope>system</scope>
<systemPath>${project.basedir}/lib/auth-common-1.0.2-SNAPSHOT.jar</systemPath>
<version>1.0.2</version>
</dependency>
<!-- cas相关 -->
<dependency>
<groupId>com.kakawait</groupId>
<artifactId>cas-security-spring-boot-starter</artifactId>
<version>1.0.0-beta-1</version>
</dependency>
<!-- gson -->
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
</dependency>
<dependency>
<groupId>com.github.ulisesbocchio</groupId>
<artifactId>jasypt-spring-boot-starter</artifactId>
<version>3.0.3</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-oauth2</artifactId>
</dependency>
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.1.3</version>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>org.springframework.security</groupId>
<artifactId>spring-security-bom</artifactId>
<version>${spring-security.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<resources>
<resource>
<directory>lib</directory>
<targetPath>BOOT-INF/lib/</targetPath>
<includes>
<include>**/*.jar</include>
</includes>
</resource>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>*.yml</include>
<include>**/*.xml</include>
<include>**/*.properties</include>
</includes>
</resource>
</resources>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>com.spotify</groupId>
<artifactId>docker-maven-plugin</artifactId>
<version>0.4.13</version>
<configuration>
<imageName>${docker.image.prefix}/${project.artifactId}</imageName>
<dockerDirectory>src/main/docker</dockerDirectory>
<resources>
<resource>
<targetPath>/</targetPath>
<directory>${project.build.directory}</directory>
<include>${project.build.finalName}.jar</include>
</resource>
</resources>
</configuration>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>spring-milestones</id>
<name>Spring Milestones</name>
<url>https://repo.spring.io/milestone</url>
<id>nexus</id>
<url>http://139.198.127.28:18081/repository/maven-public/</url>
<name>keymobile</name>
<snapshots>
<enabled>false</enabled>
<enabled>true</enabled>
</snapshots>
</repository>
</repositories>
</project>
readme.txt 0 → 100644
readme
\ No newline at end of file
settings.xml 0 → 100644
<settings>
<mirrors>
<mirror>
<id>nexus</id>
<mirrorOf>*</mirrorOf>
<url>http://mgr-00:8081/repository/maven-public/</url>
</mirror>
</mirrors>
<servers>
<server>
<id>nexus-snapshots</id>
<username>admin</username>
<password>dataSharing</password>
</server>
<server>
<id>nexus-releases</id>
<username>admin</username>
<password>dataSharing</password>
</server>
</servers>
</settings>
\ No newline at end of file
src/main/java/com/keymobile/tagmanager/TagManagerApplication.java deleted 100644 → 0
package com.keymobile.tagmanager;
import org.jasypt.encryption.StringEncryptor;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.scheduling.annotation.EnableAsync;
import com.keymobile.auth.common.security.ApplicationHelper;
import com.ulisesbocchio.jasyptspringboot.environment.StandardEncryptableEnvironment;
@EnableFeignClients
@SpringBootApplication
@EnableCaching
@EnableAsync
public class TagManagerApplication {
public static void main(String[] args) {
System.setProperty("es.set.netty.runtime.available.processors", "false");
// SpringApplication.run(TagManagerApplication.class, args);
new SpringApplicationBuilder()
.environment(StandardEncryptableEnvironment.builder().encryptor(stringEncryptor()).build())
.sources(TagManagerApplication.class).run(args);
}
private static StringEncryptor stringEncryptor() {
return new StringEncryptor() {
@Override
public String encrypt(String s) {
return ApplicationHelper.getEncryptor().encrypt(s);
}
@Override
public String decrypt(String s) {
return ApplicationHelper.getEncryptor().decrypt(s);
}
};
}
}
src/main/java/com/keymobile/tagmanager/logging/MdcLogEnhancerFilter.java deleted 100644 → 0
package com.keymobile.tagmanager.logging;
import org.springframework.security.core.Authentication;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.stereotype.Component;
import org.slf4j.MDC;
import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;
import javax.servlet.*;
import java.io.IOException;
@Component
public class MdcLogEnhancerFilter implements Filter {
@Override
public void destroy() {
}
@Override
public void init(FilterConfig filterConfig) throws ServletException {
}
@Override
public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException
{
MDC.put("user", getUser());
MDC.put("session", getSession());
filterChain.doFilter(servletRequest, servletResponse);
}
private String getUser() {
Authentication auth = SecurityContextHolder.getContext().getAuthentication();
String userName = "NO_USER";
if (auth != null) {
userName = auth.getName();
}
return userName;
}
private String getSession() {
RequestAttributes attrs = RequestContextHolder.getRequestAttributes();
String session = "NO_SESSION";
if (attrs != null) {
session = attrs.getSessionId();
}
return session;
}
}
src/main/resources/application-cgn.yml deleted 100644 → 0
mongodb:
database: tagManagerCGN
uri: dev-vm-00:27017
username: root
password: dataPlatform
maxConnectionIdleTime: 120000
eureka:
client:
registryFetchIntervalSeconds: 5
region: default
serviceUrl:
defaultZone: http://dev-vm-22:8081/eureka/
instance:
prefer-ip-address: false
hostname: dev-vm-22
spring:
application:
name: tagManager
session:
store-type: redis
redis:
namespace: cgn2
redis:
host: dev-vm-00
port: 6379
datasource:
url: jdbc:mysql://dev-vm-00:3306/cgn2?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8
username: test
password: test
hikari:
maximum-pool-size: 3
server:
port: 8099
#security permit true :permitAll ;flase:authenticated
security:
authUser: root
authPwd: pwd
permit: false
feign:
client:
config:
default:
ReadTimeout: 30000
ConnectTimeout: 30000
src/main/resources/application-sentinel.yml deleted 100644 → 0
mongodb:
database: dataCatalogTest
uri: 192.168.0.192:27017
username: root
password: dataPlatform
maxConnectionIdleTime: 120000
essearch:
host: localhost
port: 9300
cluster: dataSharing
eureka:
client:
registryFetchIntervalSeconds: 5
region: default
serviceUrl:
defaultZone: http://139.198.126.96:8081/eureka/
enabled: true
instance:
prefer-ip-address: false
hostname: 127.0.0.1
spring:
application:
name: dataCatalog1
session:
store-type: redis
redis:
namespace: dataplatformdev
redis:
sentinel:
master: master-1
nodes: 127.0.0.1:63791,127.0.0.1:63792,127.0.0.1:63793
password: zombie
datasource:
url: jdbc:mysql://localhost:3306/test?autoReconnect=true&useUnicode=yes&characterEncoding=UTF-8
username: root
password: dataSharing
rabbitmq:
host: 127.0.0.1
port: 5672
username: guest
password: guest
virtualHost: dams
exchange: metadata-exchange
dataCatalogQueue: dataCatalog-mdqueue
sqlEngineExchange: sqlEngine-exchange
sqlEngineQueue: sqlEngine-queue
labelQueue: label-queue
sampleQueue: sample-queueTest
server:
port: 8079
logging:
level:
org:
springframework:
security: info
#security permit true :permitAll ;flase:authenticated
security:
authUser: root
authPwd: pwd
permit: false
hikari:
maximum-pool-size: 5
feign:
client:
config:
default:
connectTimeout: 40000
ReadTimeout: 40000
tableModel:
openCache: true
auditKey: audit
sampleQueueSize: 3
\ No newline at end of file
src/main/resources/application-test.yml deleted 100644 → 0
mongodb:
database: tagManagerCGN_dev
uri: dev-vm-00:27017
username: root
password: dataPlatform
maxConnectionIdleTime: 120000
eureka:
client:
registryFetchIntervalSeconds: 5
region: default
serviceUrl:
defaultZone: http://dev-vm-22:8081/eureka/
instance:
prefer-ip-address: true
hostname: 192.168.0.215
spring:
application:
name: tagManager
session:
store-type: redis
redis:
namespace: cgn2
redis:
host: dev-vm-00
port: 6379
datasource:
url: jdbc:mysql://dev-vm-00:3306/cgn2_dev?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8
username: test
password: test
hikari:
maximum-pool-size: 3
server:
port: 8072
#security permit true :permitAll ;flase:authenticated
security:
authUser: root
authPwd: pwd
permit: false
feign:
client:
config:
default:
ReadTimeout: 30000
ConnectTimeout: 30000
src/main/resources/application.properties deleted 100644 → 0
jasypt.encryptor.algorithm=PBEWithMD5AndDES
jasypt.encryptor.iv-generator-classname=org.jasypt.iv.NoIvGenerator
\ No newline at end of file
src/main/resources/application.yml deleted 100644 → 0
spring:
profiles:
active: ${spring.profiles.active:test}
\ No newline at end of file
start.sh 0 → 100644
#!/bin/sh
WORK_DIR=/home/admin
JAR_NAME=`ls ${WORK_DIR} | grep jar`
JVM_WORK_DIR=${WORK_DIR}/logs/jvm-logs
mkdir -p ${JVM_WORK_DIR}
MEM_OPTS="${MEM_OPTS} -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=512m"
MEM_OPTS="${MEM_OPTS} -XX:+AlwaysPreTouch"
OPTIMIZE_OPTS="-XX:AutoBoxCacheMax=20000 -Djava.security.egd=file:/dev/./urandom"
JMX_OPTS="-Dcom.sun.management.jmxremote.port=9981 -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false"
SHOOTING_OPTS="-XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=${JVM_WORK_DIR}/"
SOFA_OPTS="-DSOFA_CAFE_CELL_NAME=${SOFA_CAFE_CELL_NAME} -DSOFA_CAFE_CLUSTER_NAME=${SOFA_CAFE_CLUSTER_NAME}"
if [ -z "${SOFA_CAFE_AVAILABILITY_ZONE}" ]; then
if [ "${SOFA_CAFE_CELL_NAME}" == "CellA" ]; then
echo "excepted value \${SOFA_CAFE_CELL_NAME}:${SOFA_CAFE_CELL_NAME}"
SOFA_OPTS="${SOFA_OPTS} -Dcom.alipay.ldc.datacenter=default -Dcom.alipay.ldc.zone=CellA"
elif [ "${SOFA_CAFE_CELL_NAME}" == "CellB" ]; then
echo "excepted value \${SOFA_CAFE_CELL_NAME}:${SOFA_CAFE_CELL_NAME}"
SOFA_OPTS="${SOFA_OPTS} -Dcom.alipay.ldc.datacenter=defaultB -Dcom.alipay.ldc.zone=CellB"
else
echo "unExcepted value \${SOFA_CAFE_CELL_NAME}:${SOFA_CAFE_CELL_NAME}"
fi
else
echo "default value \${SOFA_CAFE_CELL_NAME}:${SOFA_CAFE_CELL_NAME} and \${SOFA_CAFE_AVAILABILITY_ZONE}:${SOFA_CAFE_AVAILABILITY_ZONE}"
SOFA_OPTS="${SOFA_OPTS} -Dcom.alipay.ldc.datacenter=${SOFA_CAFE_CELL_NAME} -Dcom.alipay.ldc.zone=${SOFA_CAFE_AVAILABILITY_ZONE}"
fi
JVM="-server ${MEM_OPTS} ${OPTIMIZE_OPTS} ${JMX_OPTS} ${SHOOTING_OPTS} ${SOFA_OPTS}"
cd ${WORK_DIR}
start(){
java $JVM -jar $JAR_NAME >> ./logs/tag.out
if [ $? -eq 0 ]; then
echo "${JAR_NAME} is started success !"
else
echo "${JAR_NAME} is started failed !"
fi
}
case "$1" in
start)
start
;;
*)
esac
exit $?
\ No newline at end of file
tag-facade/pom.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>com.keymobile</groupId>
<artifactId>tag-manager</artifactId>
<version>2.0.1-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>tag-facade</artifactId>
<dependencies>
</dependencies>
</project>
\ No newline at end of file
tag-facade/src/main/java/com/keymobile/tagmanager/facade/response/Result.java 0 → 100644
package com.keymobile.tagmanager.facade.response;
import java.io.Serializable;
/**
* 统一结果对象
* @param <T>
*/
public class Result<T> implements Serializable {
private static final String DEFAULT_UNAUTHORIZED_MESSAGE = "Need authorized";
private static final String DEFAULT_METHOD_NOT_ALLOWED_MESSAGE = "Request method incorrect";
/**
* 结果编码
*/
private int code;
/**
* 结果消息内容
*/
private String msg;
/**
* 结果数据对象
*/
private T data;
public Result(T data) {
this(ResultCodeEnum.SUCCESS_200, data);
}
public Result(ResultCodeEnum codeEnum) {
this(codeEnum.getCode(), codeEnum.getMsg(), null);
}
public Result(ResultCodeEnum codeEnum, T data) {
this(codeEnum.getCode(), codeEnum.getMsg(), data);
}
public Result(ResultCodeEnum codeEnum, String msg, T data) {
this(codeEnum.getCode(), msg, data);
}
public Result(int code, String msg, T data) {
this.code = code;
this.msg = msg;
this.data = data;
}
public Integer getCode() {
return code;
}
public String getMsg() {
return msg;
}
public T getData() {
return data;
}
public boolean isSuccess() {
return this.code == ResultCodeEnum.SUCCESS_200.getCode();
}
@Override
public String toString() {
return "Result{" +
"code=" + code +
", msg='" + msg + '\'' +
", data=" + data +
'}';
}
public static <T> Result<T> genOkResult() {
return new Result<T>(ResultCodeEnum.SUCCESS_200, null);
}
public static Result genOkResult(final Object data) {
return new Result<Object>(ResultCodeEnum.SUCCESS_200, data);
}
public static Result genFailedResult(final String msg) {
return new Result<Object>(ResultCodeEnum.OPERATION_FAIL, msg, msg);
}
public static Result genOteherCodeOkResult(final Object data,ResultCodeEnum resultCodeEnum) {
return new Result<Object>(resultCodeEnum, data);
}
public static Result genOteherCodeFailResult(ResultCodeEnum resultCodeEnum, final String msg) {
return new Result<Object>(resultCodeEnum, msg, null);
}
public static Result genMethodErrorResult() {
return new Result<Object>(ResultCodeEnum.METHOD_NOT_ALLOWED, DEFAULT_METHOD_NOT_ALLOWED_MESSAGE);
}
public static Result genUnauthorizedResult() {
return new Result<Object>(ResultCodeEnum.UNAUTHORIZED, DEFAULT_UNAUTHORIZED_MESSAGE);
}
public static Result genUnauthorizedResult(final String msg) {
return new Result<Object>(ResultCodeEnum.UNAUTHORIZED, msg);
}
}
tag-facade/src/main/java/com/keymobile/tagmanager/facade/response/ResultCodeEnum.java 0 → 100644
package com.keymobile.tagmanager.facade.response;
/**
* 返回结果编码枚举定义
*/
public enum ResultCodeEnum {
// 响应码定义
// ====== 通用状态码 ======
// 正常
SUCCESS(0, "OK"),
// 系统异常
EXCEPTION(-1, "System Exception"),
// 连接失败
CONN_ERR(-2, "Connection Error Or Timeout"),
// 参数缺失
PARAM_EMPTY(-3, "Param Is Null Or Empty"),
// 参数异常
PARAM_ILLEGAL(-4, "Param Illegal"),
// 操作失败
OPERATION_FAIL(-5, "Operation Fail"),
// 参数验证
NOT_NULL(-5, "%s 不能为null value:null"),
INVALID_TYPE(-5, "%s 参数类型不正确 value:%s"),
INVALID_PARAM(-5, "%s 参数不正确 value:%s"),
INVALID_BODY_PARAM(-5, "请求体不正确：%s"),
VALIDATE_ERROR_CODE(-6, "验证错误"),
BASE_ERROR_CODE(-7, "基础错误"),
OCCUPATION_CLOSED(10001,"所查占用已被临时关闭"),
SUCCESS_200(200, "ok"),
REQUEST_ERROR(400, "Param Error"),
UNAUTHORIZED(401, "Unauthorized"),
METHOD_NOT_ALLOWED(405, "Method Not Allowed"),
NOT_FOUND(404, "404 Not Found"),
DATA_ERR(420, "data err"),
SYSTEM_ERROR(500, "System Error");
private final int code;
private final String msg;
ResultCodeEnum(int code, String msg) {
this.code = code;
this.msg = msg;
}
public int getCode() {
return code;
}
public String getMsg() {
return msg;
}
public String formatMsg(Object...args) {
return String.format(msg, args);
}
@Override
public String toString() {
return "ResultCodeEnum{" +
"code=" + code +
", msg='" + msg + '\'' +
'}';
}
}
tag-facade/src/main/java/com/keymobile/tagmanager/facade/service/ExcelParserSVC.java 0 → 100644
package com.keymobile.tagmanager.facade.service;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import java.util.Map;
/**
* Excel文件处理 ngdb SVC
* @author xiesh
* @version 1.0.0
* @date 2022/04/21
*/
@Path("excel")
public interface ExcelParserSVC {
/**
* 解析Excel文件
*
* @param requestMap
* @return
*/
@POST
@Path("parseExcel")
@Produces("application/json")
Map<String, Object> parseExcel(Map<String, Object> requestMap) throws Exception;
/**
* 解析系统Excel文件
*
* @param requestMap
* @return
*/
@POST
@Path("parseSysExcel")
@Produces("application/json")
Map<String, Object> parseSysExcel(Map<String, Object> requestMap) throws Exception;
/**
* 系统导出(系统id传参样式：4,9,10,23)
*
* @param requestMap
* @return
*/
@POST
@Path("exportSystemExcel")
@Produces("application/json")
Map<String, Object> exportSystemExcel(Map<String, Object> requestMap) throws Exception;
}
tag-facade/src/main/java/com/keymobile/tagmanager/facade/service/MockSVC.java 0 → 100644
package com.keymobile.tagmanager.facade.service;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import java.util.Map;
/**
* 模拟数据 ngdb SVC
* @author xiesh
* @version 1.0.0
* @date 2022/04/21
*/
@Path("mock")
public interface MockSVC {
/**
* 返回组织树
*
* @param requestMap
* @return
*/
@POST
@Path("queryOrgAsTree")
@Produces("application/json")
Map<String, Object> queryOrgAsTree(Map<String, Object> requestMap) throws Exception;
}
tag-facade/src/main/java/com/keymobile/tagmanager/facade/service/TagFileSVC.java 0 → 100644
package com.keymobile.tagmanager.facade.service;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import java.util.Map;
/**
* 标签文件 ngdb SVC
* @author xiesh
* @version 1.0.0
* @date 2022/04/21
*/
@Path("file")
public interface TagFileSVC {
/**
* 导入标签元数据
*
* @param requestMap
* @return
*/
@POST
@Path("importTagMeta")
@Produces("application/json")
Map<String, Object> importTagMeta(Map<String, Object> requestMap) throws Exception;
/**
* 导出标签元数据excel文件
*
* @param requestMap
* @return
*/
@POST
@Path("exportTagMeta")
@Produces("application/json")
Map<String, Object> exportTagMeta(Map<String, Object> requestMap);
/**
* 导出标签excel文件
*
* @param requestMap
* @return
*/
@POST
@Path("exportTag")
@Produces("application/json")
Map<String, Object> exportTag(Map<String, Object> requestMap);
/**
* 导入标签
*
* @param requestMap
* @return
*/
@POST
@Path("importTag")
@Produces("application/json")
Map<String, Object> importTag(Map<String, Object> requestMap);
/**
* 分页获取导入日志
*
* @param requestMap
* @return
*/
@POST
@Path("listImportTagLogByPage")
@Produces("application/json")
Map<String, Object> listImportTagLogByPage(Map<String, Object> requestMap);
/**
* 撤销导入
*
* @param requestMap
* @return
*/
@POST
@Path("undoImportTag")
@Produces("application/json")
Map<String, Object> undoImportTag(Map<String, Object> requestMap);
/**
* 系统导出
*
* @param requestMap
* @return
*/
@POST
@Path("exportSystem")
@Produces("application/json")
Map<String, Object> exportSystem(Map<String, Object> requestMap);
/**
* 系统导入
*
* @param requestMap
* @return
*/
@POST
@Path("importSystem")
@Produces("application/json")
Map<String, Object> importSystem(Map<String, Object> requestMap);
}
tag-facade/src/main/java/com/keymobile/tagmanager/facade/service/TagRelSVC.java 0 → 100644
package com.keymobile.tagmanager.facade.service;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import java.util.Map;
/**
* 标签关系 ngdb SVC
* @author xiesh
* @version 1.0.0
* @date 2022/04/21
*/
@Path("rel")
public interface TagRelSVC {
/**
* 新增标签关系
*
* @param requestMap
* @return
*/
@POST
@Path("addTagRel")
@Produces("application/json")
Map<String, Object> addTagRel(Map<String, Object> requestMap) throws Exception;
/**
* 删除标签关系
*
* @param requestMap
* @return
*/
@POST
@Path("deleteTagRel")
@Produces("application/json")
Map<String, Object> deleteTagRel(Map<String, Object> requestMap);
/**
* 根据当前标签id获取源标签
*
* @param requestMap
* @return
*/
@POST
@Path("getSourceTags")
@Produces("application/json")
Map<String, Object> getSourceTags(Map<String, Object> requestMap);
/**
* 根据当前标签id获取目标标签
*
* @param requestMap
* @return
*/
@POST
@Path("getTargetTags")
@Produces("application/json")
Map<String, Object> getTargetTags(Map<String, Object> requestMap);
/**
* 获取所有标签关系
*
* @param requestMap
* @return
*/
@POST
@Path("getAll")
@Produces("application/json")
Map<String, Object> getAll(Map<String, Object> requestMap);
}
tag-facade/src/main/java/com/keymobile/tagmanager/facade/service/TagSVC.java 0 → 100644
package com.keymobile.tagmanager.facade.service;
import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import java.util.Map;
/**
* 标签相关 ngdb SVC
* @author xiesh
* @version 1.0.0
* @date 2022/04/21
*/
@Path("tag")
public interface TagSVC {
/**
* 新增或更新标签
*
* @param requestMap
* @return
*/
@POST
@Path("addOrUpdateTag")
@Produces("application/json")
Map<String, Object> addOrUpdateTag(Map<String, Object> requestMap) throws Exception;
/**
* 删除标签
*
* @param requestMap
* @return
*/
@POST
@Path("deleteTag")
@Produces("application/json")
Map<String, Object> deleteTag(Map<String, Object> requestMap);
/**
* 存在节点
*
* @param requestMap
* @return
*/
@POST
@Path("hasChild")
@Produces("application/json")
Map<String, Object> hasChild(Map<String, Object> requestMap);
/**
* 根据多个标签id获取标签信息列表
*
* @param requestMap
* @return
*/
@POST
@Path("getTagListByIds")
@Produces("application/json")
Map<String, Object> getTagListByIds(Map<String, Object> requestMap);
/**
* 获取维度标签树
*
* @param requestMap
* @return
*/
@POST
@Path("queryDimensionTagAsTree")
@Produces("application/json")
Map<String, Object> queryDimensionTagAsTree(Map<String, Object> requestMap);
/**
* 获取个人标签树
*
* @param requestMap
* @return
*/
@POST
@Path("queryPersonalTagAsTree")
@Produces("application/json")
Map<String, Object> queryPersonalTagAsTree(Map<String, Object> requestMap);
/**
* 搜索维度标签里面的个人标签
*
* @param requestMap
* @return
*/
@POST
@Path("searchPersonalDimensionTagByPage")
@Produces("application/json")
Map<String, Object> searchPersonalDimensionTagByPage(Map<String, Object> requestMap);
/**
* 搜索个人标签
*
* @param requestMap
* @return
*/
@POST
@Path("searchPersonalTagByPage")
@Produces("application/json")
Map<String, Object> searchPersonalTagByPage(Map<String, Object> requestMap);
/**
* 查询系统标签树
*
* @param requestMap
* @return
*/
@POST
@Path("querySystemTagAsTree")
@Produces("application/json")
Map<String, Object> querySystemTagAsTree(Map<String, Object> requestMap);
/**
* 搜索系統标签
*
* @param requestMap
* @return
*/
@POST
@Path("searchSystemTagByPage")
@Produces("application/json")
Map<String, Object> searchSystemTagByPage(Map<String, Object> requestMap);
/**
* 查询个人标签树不包括分享的标签
*
* @param requestMap
* @return
*/
@POST
@Path("queryPersonalTagExcludeOpenTypeAsTree")
@Produces("application/json")
Map<String, Object> queryPersonalTagExcludeOpenTypeAsTree(Map<String, Object> requestMap);
/**
* 分享/取消分享标签
*
* @param requestMap
* @return
*/
@POST
@Path("shareTags")
@Produces("application/json")
Map<String, Object> shareTags(Map<String, Object> requestMap);
/**
* 标签分析
*
* @param requestMap
* @return
*/
@POST
@Path("tagAnalysis")
@Produces("application/json")
Map<String, Object> tagAnalysis(Map<String, Object> requestMap);
/**
* 导出标签分析excel文件
*
* @param requestMap
* @return
*/
@POST
@Path("exportTagAnalysis")
@Produces("application/json")
Map<String, Object> exportTagAnalysis(Map<String, Object> requestMap);
/**
* 根据用户授予的数据权限加载标签元数据
*
* @param requestMap
* @return
*/
@POST
@Path("getByTagWithPrivilege")
@Produces("application/json")
Map<String, Object> getByTagWithPrivilege(Map<String, Object> requestMap);
/**
* 获取所有维度标签数据
*
* @param requestMap
* @return
*/
@POST
@Path("getAllDimensionTag")
@Produces("application/json")
Map<String, Object> getAllDimensionTag(Map<String, Object> requestMap);
/**
* 获取所有根目录维度标签
*
* @param requestMap
* @return
*/
@POST
@Path("getAllDimensionRootTag")
@Produces("application/json")
Map<String, Object> getAllDimensionRootTag(Map<String, Object> requestMap);
/**
* 前台获取所有根目录维度标签
*
* @param requestMap
* @return
*/
@POST
@Path("getDimensionRootTag")
@Produces("application/json")
Map<String, Object> getDimensionRootTag(Map<String, Object> requestMap);
/**
* 分析系统
*
* @param requestMap
* @return
*/
@POST
@Path("analysisSystem")
@Produces("application/json")
Map<String, Object> analysisSystem(Map<String, Object> requestMap);
/**
* 查询系统标签
*
* @param requestMap
* @return
*/
@POST
@Path("listSystems")
@Produces("application/json")
Map<String, Object> listSystems(Map<String, Object> requestMap);
/**
* 查询系统标签
*
* @param requestMap
* @return
*/
@POST
@Path("getSystemByCode")
@Produces("application/json")
Map<String, Object> getSystemByCode(Map<String, Object> requestMap);
/**
* 更新系统抽取信息
*
* @param requestMap
* @return
*/
@POST
@Path("updateSystemExtractInfo")
@Produces("application/json")
Map<String, Object> updateSystemExtractInfo(Map<String, Object> requestMap);
}
tag-runtime/pom.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>tag-manager</artifactId>
<groupId>com.keymobile</groupId>
<version>2.0.1-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>tag-runtime</artifactId>
<dependencies>
<dependency>
<groupId>com.keymobile</groupId>
<artifactId>tag-service</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
<build>
<resources>
<resource>
<directory>src/main/resources</directory>
</resource>
</resources>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
\ No newline at end of file
tag-runtime/src/main/java/com/keymobile/tagmanager/TagManagerApplication.java 0 → 100644
package com.keymobile.tagmanager;
import com.alipay.sofa.boot.autoconfigure.tracer.EnterpriseDstSofaTracerAutoConfiguration;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.actuate.autoconfigure.security.servlet.ManagementWebSecurityAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;
import org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.ImportResource;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
@ImportResource({"classpath*:sofa/ngdb_*.xml"})
@SpringBootApplication(scanBasePackages = {"com.sdebank.ngdb.*", "com.keymobile.*"},
exclude = {EnterpriseDstSofaTracerAutoConfiguration.class,
SecurityAutoConfiguration.class,
ManagementWebSecurityAutoConfiguration.class})
@MapperScan({"com.sdebank.ngdb.oaps.engine.*.mapper"})
@EnableMongoRepositories(basePackages = {"com.keymobile.tagmanager.model"})
@EntityScan("com.keymobile.infomanage.common.entity")
@MapperScan({"com.sdebank.ngdb.oaps.engine.*.mapper"})
@EnableFeignClients(basePackages = {"com.keymobile.tagmanager.remote"})
@EnableCaching
public class TagManagerApplication {
public static void main(String[] args) {
SpringApplication.run(TagManagerApplication.class, args);
}
}
src/main/java/com/keymobile/tagmanager/config/ExceptionAdvice.java → tag-runtime/src/main/java/com/keymobile/tagmanager/runtime/config/ExceptionAdvice.java
package com.keymobile.tagmanager.config;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
package com.keymobile.tagmanager.runtime.config;
import com.keymobile.tagmanager.util.DateUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseBody;
import com.keymobile.tagmanager.util.DateUtils;
import javax.servlet.http.HttpServletRequest;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
//@ControllerAdvice
public class ExceptionAdvice {
......
src/main/java/com/keymobile/tagmanager/config/FeignClientConfig.java → tag-runtime/src/main/java/com/keymobile/tagmanager/runtime/config/FeignClientConfig.java
package com.keymobile.tagmanager.config;
package com.keymobile.tagmanager.runtime.config;
import feign.auth.BasicAuthRequestInterceptor;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import feign.auth.BasicAuthRequestInterceptor;
@Configuration
public class FeignClientConfig {
......
src/main/java/com/keymobile/tagmanager/config/MongoDBConfig.java → tag-runtime/src/main/java/com/keymobile/tagmanager/runtime/config/MongoDBConfig.java
package com.keymobile.tagmanager.config;
import java.util.ArrayList;
import java.util.List;
package com.keymobile.tagmanager.runtime.config;
import com.mongodb.*;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.gridfs.GridFSBucket;
import com.mongodb.client.gridfs.GridFSBuckets;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
......@@ -14,17 +19,9 @@ import org.springframework.data.mongodb.core.convert.DefaultMongoTypeMapper;
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
import org.springframework.data.mongodb.core.mapping.MongoMappingContext;
import org.springframework.data.mongodb.gridfs.GridFsTemplate;
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoClientURI;
import com.mongodb.MongoCredential;
import com.mongodb.ReadPreference;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.gridfs.GridFSBucket;
import com.mongodb.client.gridfs.GridFSBuckets;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.NoSuchBeanDefinitionException;
import java.util.ArrayList;
import java.util.List;
@Configuration
public class MongoDBConfig extends AbstractMongoConfiguration {
......
src/main/java/com/keymobile/tagmanager/config/RedisConf.java → tag-runtime/src/main/java/com/keymobile/tagmanager/runtime/config/RedisConfig.java
package com.keymobile.tagmanager.config;
package com.keymobile.tagmanager.runtime.config;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.ListOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.SetOperations;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.data.redis.core.*;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.session.data.redis.config.ConfigureRedisAction;
/**
* redis配置类
*/
@Configuration
public class RedisConf {
public class RedisConfig {
/**
* 注入 RedisConnectionFactory
......@@ -105,9 +103,4 @@ public class RedisConf {
public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
return redisTemplate.opsForZSet();
}
@Bean
public static ConfigureRedisAction configureRedisAction(){
return ConfigureRedisAction.NO_OP;
}
}
src/main/java/com/keymobile/tagmanager/config/SecurityConfig.java → tag-runtime/src/main/java/com/keymobile/tagmanager/runtime/config/SecurityConfig.java
package com.keymobile.tagmanager.config;
package com.keymobile.tagmanager.runtime.config;
import javax.sql.DataSource;
import com.keymobile.auth.common.security.CustomizedUserDetailService;
import com.keymobile.common.security.CustomizedUserDetailService;
import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
......@@ -13,15 +11,18 @@ import org.springframework.security.config.annotation.method.configuration.Enabl
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
import org.springframework.security.crypto.password.NoOpPasswordEncoder;
import org.springframework.security.crypto.password.PasswordEncoder;
import javax.sql.DataSource;
@Configuration
@EnableWebSecurity
@EnableGlobalMethodSecurity(prePostEnabled = true)
@ComponentScan("com.keymobile.auth.common.security")
@ComponentScan("com.keymobile.common.security")
public class SecurityConfig extends WebSecurityConfigurerAdapter {
@Autowired
private CustomizedUserDetailService customUserDetailService;
......@@ -33,7 +34,7 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
@Autowired
public void configure(AuthenticationManagerBuilder auth) throws Exception {
auth.userDetailsService(customUserDetailService).passwordEncoder(new SHA1PasswordEncoder());
auth.userDetailsService(customUserDetailService).passwordEncoder(NoOpPasswordEncoder.getInstance());
}
@Override
......@@ -58,5 +59,4 @@ public class SecurityConfig extends WebSecurityConfigurerAdapter {
return DigestUtils.sha1Hex(charSequence.toString()).equals(s);
}
}
}
src/main/java/com/keymobile/tagmanager/config/Swagger2Config.java → tag-runtime/src/main/java/com/keymobile/tagmanager/runtime/config/Swagger2Config.java
package com.keymobile.tagmanager.config;
package com.keymobile.tagmanager.runtime.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
......
tag-runtime/src/main/resources/application-home.yml 0 → 100644
mongodb:
database: dmgt
uri: 101.132.149.116:27017
username: dmgt
password: dmgt
maxConnectionIdleTime: 120000
spring:
data:
jpa:
repositories:
enabled: false
redis:
repositories:
enabled: false
servlet:
multipart:
max-file-size: 20MB
max-request-size: 100MB
session:
store-type: redis
redis:
namespace: sdebank
redis:
host: 47.107.70.172
port: 6379
password: baige123456
datasource:
url: jdbc:mysql://rm-q0sid6o090do561j1.mysql.rds.ops.aliyun-test.sdebank.com:3306/dmgt?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8
username: dmgt
password: dmgt
hikari:
maximum-pool-size: 10
validationTimeout: 3000
main:
allow-bean-definition-overriding: true
# rabbitmq:
# host: 172.16.88.108
# port: 5672
# username: datamgt_test
# password: datamgt_test
# virtualHost: datamgt_test
# listener:
# simple:
# concurrency: 5
# acknowledge-mode: manual
# max-concurrency: 10
# prefetch: 1
# exchange: metadata-exchange
# queue: standard-queue
server:
port: 8099
security:
permit: true
authUser: root
authPwd: 37fa265330ad83eaa879efb1e2db6380896cf639
needApply: false
##远程服务配置
service:
url:
activiti: localhost:8110
auth: localhost:8097
metadata: localhost:8099
dataq: localhost:8765
feign:
client:
config:
default:
connectTimeout: 10000
readTimeout: 10000
loggerLevel: basic
logging:
config: classpath:logback-custom.xml
tag-runtime/src/main/resources/application-local.yml 0 → 100644
mongodb:
database: dmgt
uri: 107.255.17.254:27017
username: dmgt
password: dmgt
maxConnectionIdleTime: 120000
lower_case_metadata_names: true
spring:
data:
jpa:
repositories:
enabled: false
redis:
repositories:
enabled: false
servlet:
multipart:
max-file-size: 20MB
max-request-size: 100MB
session:
store-type: redis
redis:
namespace: dmgt
redis:
host: r-q0s49a7201b396e4.redis.rds.ops.aliyun-test.sdebank.com
port: 6379
password: Abcd1234
datasource:
url: jdbc:mysql://rm-q0sid6o090do561j1.mysql.rds.ops.aliyun-test.sdebank.com:3306/dmgt?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8
username: dmgt
password: dmgt
hikari:
maximum-pool-size: 3
validationTimeout: 3000
driver-class-name: com.mysql.jdbc.Driver
main:
allow-bean-definition-overriding: true
# rabbitmq:
# host: 172.16.88.108
# port: 5672
# username: datamgt_test
# password: datamgt_test
# virtualHost: datamgt_test
# listener:
# simple:
# concurrency: 5
# acknowledge-mode: manual
# max-concurrency: 10
# prefetch: 1
# exchange: metadata-exchange
# queue: standard-queue
server:
port: 8099
security:
permit: false
authUser: root
authPwd: 37fa265330ad83eaa879efb1e2db6380896cf639
needApply: true
##远程服务配置
service:
url:
activiti: 172.16.88.109:8080
auth: 172.16.88.109:8080
metadata: 172.16.88.109:8080
dataq: 172.16.88.109:8080
feign:
client:
config:
default:
connectTimeout: 10000
readTimeout: 10000
loggerLevel: basic
logging:
config: classpath:logback-custom.xml
tag-runtime/src/main/resources/application-test.yml 0 → 100644
mongodb:
database: sdebank
uri: dev-vm-00:27017
username: sdebank
password: sdebank
maxConnectionIdleTime: 120000
spring:
data:
jpa:
repositories:
enabled: false
redis:
repositories:
enabled: false
servlet:
multipart:
max-file-size: 20MB
max-request-size: 100MB
session:
store-type: redis
redis:
namespace: sdebank
redis:
host: dev-vm-00
port: 6379
datasource:
url: jdbc:mysql://192.168.0.192:3306/sdebank?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8
username: test
password: test
hikari:
maximum-pool-size: 3
validationTimeout: 3000
main:
allow-bean-definition-overriding: true
# rabbitmq:
# host: 172.16.88.108
# port: 5672
# username: datamgt_test
# password: datamgt_test
# virtualHost: datamgt_test
# listener:
# simple:
# concurrency: 5
# acknowledge-mode: manual
# max-concurrency: 10
# prefetch: 1
# exchange: metadata-exchange
# queue: standard-queue
server:
port: 8099
security:
permit: false
authUser: root
authPwd: 37fa265330ad83eaa879efb1e2db6380896cf639
##远程服务配置
service:
url:
activiti: 192.168.0.166:8110
auth: 192.168.0.166:8097
metadata: 192.168.0.166:8099
dataq: 192.168.0.166:8765
feign:
client:
config:
default:
connectTimeout: 10000
readTimeout: 10000
loggerLevel: basic
logging:
config: classpath:logback-custom.xml
tag-runtime/src/main/resources/application.properties 0 → 100644
application.code=NGDMCP
#management.endpoint.health.show-details=always
run.mode=DEV
com.alipay.env=shared
com.alipay.instanceid=GGR3SMJXTNZB
com.antcloud.antvip.endpoint=localhost
com.antcloud.mw.access=ACgYoMcAHo4vPMJU
com.antcloud.mw.secret=Wi2JaDa6M4xUdtReyPTHiCbPeFcMs9bt
#数据库连接池配置
spring.datasource.druid.enable=true
spring.datasource.druid.min-idle=50
spring.datasource.druid.max-active=200
spring.datasource.druid.validation-query=select 1
spring.datasource.druid.max-wait=6000
spring.datasource.druid.test-on-borrow=false
spring.datasource.druid.test-on-return=false
spring.datasource.druid.test-while-idle=true
spring.datasource.druid.pool-prepared-statements=false
spring.datasource.druid.max-open-prepared-statements=150
spring.datasource.druid.time-between-eviction-runs-millis=60000
spring.datasource.druid.min-evictable-idle-time-millis=300000
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
com.alipay.sofa.rpc.rest-allowed-origins=*
com.sdebank.ngdb.global.redis.host=r-q0s49a7201b396e4.redis.rds.ops.aliyun-test.sdebank.com
com.sdebank.ngdb.global.redis.port=6379
com.sdebank.ngdb.global.redis.password=Abcd1234
com.sdebank.ngdb.global.redis.lettuce.pool.max-active=30
com.sdebank.ngdb.global.redis.lettuce.pool.min-idle=1
com.sdebank.ngdb.global.redis.enable=true
#mybatis配置
mybatis.mapper-locations=classpath*:mybatis/mapping/mysql/*Mapper.xml
#显示健康检查的详细信息
management.endpoint.health.show-details=always
#日志路径
logging.path=./logs
#日志级别
logging.level.com.sdebank.ngdb=INFO
logging.level.org.flowable=INFO
#网卡绑定
com.alipay.sofa.rpc.bind-network-interface=eth0
#sofa rest协议端口配置
com.alipay.sofa.rpc.rest.port=8341
#sofa bolt协议端口配置
com.alipay.sofa.rpc.bolt.port=12200
#sofa bolt协议核心线程数
com.alipay.sofa.rpc.bolt-thread-pool-core-size=200
#sofa bolt协议最大线程数
com.alipay.sofa.rpc.bolt-thread-pool-max-size=500
#sofa bolt协议线程队列数
com.alipay.sofa.rpc.bolt-thread-pool-queue-size=100
#OSS对外服务的访问域名,由资源组提供
com.sdebank.ngdb.oss.endpoint=oss-cn-shanghai.aliyuncs.com
#OSS接入的accessKey,由资源组提供
com.sdebank.ngdb.oss.accessKey=LTAIPVU6FazcZeIx
#OSS接入的秘钥,由资源组提供
com.sdebank.ngdb.oss.secretKey=AlIFwCpK9K4Md4r4Ybx0rmYj3HL6xN
#OSS接入的bucketName,由资源组提供
com.sdebank.ngdb.oss.bucketName=jadeite-dev
com.sdebank.ngdb.oss.switch=on
com.sdebank.ngdb.dcn.code=001
com.sdebank.ngdb.aac.code=001
com.sdebank.ngdb.idc.code=1
com.sdebank.ngdb.pod.code=
#SOFOTracer配置
com.alipay.sofa.tracer.remote=dst
com.alipay.sofa.tracer.dst.acvip=false
com.alipay.sofa.tracer.dst.url=
com.alipay.sofa.tracer.datasource.enterprise=true
#DRM动态配置推送OAPS
sofa.ddcs.region=oaps
com.sdebank.ngdb.sofa.mq.dataCenter=dc1
#工作流引擎配置
flowable.database-schema-update=false
flowable.app.enabled=false
flowable.cmmn.enabled=false
flowable.idm.enabled=false
flowable.content.enabled=false
flowable.dmn.enabled=false
flowable.form.enabled=false
flowable.jpa-enabled=false
flowable.history-level=audit
flowable.async-executor-activate=true
flowable.async-history-executor-activate=true
flowable.process.async.executor.async-job-acquisition-enabled=true
flowable.process.async-history.executor.async-job-acquisition-enabled=true
flowable.process.async.executor.core-pool-size=200
flowable.process.async.executor.max-pool-size=500
flowable.process.async.executor.queue-size=100
flowable.process.async-history.executor.core-pool-size=200
flowable.process.async-history.executor.max-pool-size=500
flowable.process.async-history.executor.queue-size=100
\ No newline at end of file
src/main/resources/bootstrap.yml → tag-runtime/src/main/resources/bootstrap.yml
spring:
application:
name: tagManager
name: tagmanager
profiles:
active: test
active: local
cloud:
config:
uri: http://localhost:8082
\ No newline at end of file
uri:
src/main/resources/logback-custom.xml → tag-runtime/src/main/resources/logback-custom.xml
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<springProperty name="spring.datasource.driverClassName" source="spring.datasource.driverClassName"/>
<springProperty name="spring.datasource.url" source="spring.datasource.url"/>
<springProperty name="spring.datasource.username" source="spring.datasource.username"/>
<springProperty name="spring.datasource.password" source="spring.datasource.password"/>
<springProperty scope="context" name="spring.datasource.url" source="spring.datasource.url"/>
<springProperty scope="context" name="spring.datasource.username" source="spring.datasource.username"/>
<springProperty scope="context" name="spring.datasource.password" source="spring.datasource.password"/>
<appender name="stdout" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{HH:mm:ss.SSS} [%thread] %X{user} %X{session} %-5level %logger{5} - %msg%n</pattern>
<pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{5} - %msg%n
</pattern>
</encoder>
</appender>
<appender name="db" class="ch.qos.logback.classic.db.DBAppender">
......
tag-service/pom.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>com.keymobile</groupId>
<artifactId>tag-manager</artifactId>
<version>2.0.1-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>tag-service</artifactId>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<akka.version>2.6.0</akka.version>
<poi.version>4.1.1</poi.version>
<fastjson.version>1.2.70</fastjson.version>
<easyExcel.version>2.1.1</easyExcel.version>
<mockito.version>2.18.3</mockito.version>
<junit.jupiter.version>5.5.2</junit.jupiter.version>
<!-- <druid.version>1.0.29</druid.version>-->
<easypoi.version>4.1.3</easypoi.version>
</properties>
<dependencies>
<dependency>
<groupId>com.keymobile</groupId>
<artifactId>tag-facade</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.keymobile.sdrcb</groupId>
<artifactId>feign-core-naive</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.keymobile.sdrcb</groupId>
<artifactId>common-core</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.keymobile.sdrcb</groupId>
<artifactId>common-ngdb-security</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.keymobile.sdrcb</groupId>
<artifactId>common-oss-service</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>easyexcel</artifactId>
<version>${easyExcel.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<exclusions>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-json</artifactId>
</exclusion>
</exclusions>
</dependency><dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<exclusions>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-json</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.9.10.6</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.7</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger2</artifactId>
<version>2.5.0</version>
</dependency>
<dependency>
<groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId>
<version>2.5.0</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>${fastjson.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
<dependency>
<groupId>org.dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>2.1.0</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>20.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.antlr</groupId>
<artifactId>antlr4-runtime</artifactId>
<version>4.7</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.46</version>
</dependency>
<!-- 引入easypoi -->
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-base</artifactId>
<version>${easypoi.version}</version>
</dependency>
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-web</artifactId>
<version>${easypoi.version}</version>
</dependency>
<dependency>
<groupId>cn.afterturn</groupId>
<artifactId>easypoi-annotation</artifactId>
<version>${easypoi.version}</version>
</dependency>
<!-- cas相关 -->
<!-- <dependency>-->
<!-- <groupId>com.kakawait</groupId>-->
<!-- <artifactId>cas-security-spring-boot-starter</artifactId>-->
<!-- <version>1.0.0-beta-1</version>-->
<!-- </dependency>-->
<!-- gson -->
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.github.ulisesbocchio</groupId>-->
<!-- <artifactId>jasypt-spring-boot-starter</artifactId>-->
<!-- <version>3.0.3</version>-->
<!-- </dependency>-->
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.1.3</version>
</dependency>
</dependencies>
</project>
\ No newline at end of file
src/main/java/com/keymobile/tagmanager/api/TagCtrl.java → tag-service/src/main/java/com/keymobile/tagmanager/api/TagCtrl.java
......@@ -14,7 +14,7 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import com.keymobile.auth.common.security.GrantedAuthHelper;
import com.keymobile.common.security.GrantedAuthHelper;
import com.keymobile.tagmanager.exception.TagNotExistException;
import com.keymobile.tagmanager.logging.LogConstants;
import com.keymobile.tagmanager.logging.LogManager;
......
src/main/java/com/keymobile/tagmanager/api/TagFileCtrl.java → tag-service/src/main/java/com/keymobile/tagmanager/api/TagFileCtrl.java
......@@ -15,7 +15,7 @@ import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import com.keymobile.auth.common.security.GrantedAuthHelper;
import com.keymobile.common.security.GrantedAuthHelper;
import com.keymobile.tagmanager.logging.LogConstants;
import com.keymobile.tagmanager.logging.LogManager;
import com.keymobile.tagmanager.model.Page;
......
src/main/java/com/keymobile/tagmanager/api/TagRelCtrl.java → tag-service/src/main/java/com/keymobile/tagmanager/api/TagRelCtrl.java
......@@ -9,7 +9,7 @@ import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import com.keymobile.auth.common.security.GrantedAuthHelper;
import com.keymobile.common.security.GrantedAuthHelper;
import com.keymobile.tagmanager.logging.LogConstants;
import com.keymobile.tagmanager.logging.LogManager;
import com.keymobile.tagmanager.model.TagRelation;
......
src/main/java/com/keymobile/tagmanager/logging/LogConstants.java → tag-service/src/main/java/com/keymobile/tagmanager/logging/LogConstants.java
package com.keymobile.tagmanager.logging;
public interface LogConstants {
public static final String CTX_OPTTAG = "tagManager.OPTTAG";
public static final String CTX_OPTFILETAG = "tagManager.OPTFILETAG";
public static final String CTX_OPTTAGREL = "tagManager.OPTTAGREL";
public static final String CTX_OPTTAG = "tagmanager.OPTTAG";
public static final String CTX_OPTFILETAG = "tagmanager.OPTFILETAG";
public static final String CTX_OPTTAGREL = "tagmanager.OPTTAGREL";
}
tag-service/src/main/java/com/keymobile/tagmanager/logging/MdcLogEnhancerFilter.java 0 → 100644
//package com.keymobile.tagmanager.logging;
//
//import org.springframework.security.core.Authentication;
//import org.springframework.security.core.context.SecurityContextHolder;
//import org.springframework.stereotype.Component;
//import org.slf4j.MDC;
//import org.springframework.web.context.request.RequestAttributes;
//import org.springframework.web.context.request.RequestContextHolder;
//
//import javax.servlet.*;
//import java.io.IOException;
//
//@Component("myMdcLogEnhancerFilter")
//public class MdcLogEnhancerFilter implements Filter {
//
// @Override
// public void destroy() {
//
// }
//
// @Override
// public void init(FilterConfig filterConfig) throws ServletException {
//
// }
//
// @Override
// public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException
// {
// MDC.put("user", getUser());
// MDC.put("session", getSession());
// filterChain.doFilter(servletRequest, servletResponse);
// }
//
// private String getUser() {
// Authentication auth = SecurityContextHolder.getContext().getAuthentication();
// String userName = "NO_USER";
// if (auth != null) {
// userName = auth.getName();
// }
// return userName;
// }
//
// private String getSession() {
// RequestAttributes attrs = RequestContextHolder.getRequestAttributes();
// String session = "NO_SESSION";
// if (attrs != null) {
// session = attrs.getSessionId();
// }
// return session;
// }
//
//}
src/main/java/com/keymobile/tagmanager/service/ExcelParserService.java → tag-service/src/main/java/com/keymobile/tagmanager/service/ExcelParserService.java
package com.keymobile.tagmanager.service;
import java.io.BufferedOutputStream;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.Arrays;
......@@ -126,6 +129,84 @@ public class ExcelParserService {
return sysInfos;
}
public List<SysInfo> importSystemExcel(InputStream is) throws Exception {
List<SysInfo> sysInfos = new ArrayList<>();
List<SysFunction> sysFuns = new ArrayList<>();
List<SysApplication> sysApps = new ArrayList<>();
List<SysConstruction> sysCons = new ArrayList<>();
List<SysOperations> sysOpers = new ArrayList<>();
for(int numSheet=0;numSheet<=4;numSheet++) {
ImportParams params = new ImportParams();
params.setTitleRows(0);
params.setHeadRows(1);
params.setNeedVerify(true);
params.setStartSheetIndex(numSheet);
if(numSheet==0) {
params.setVerifyHandler(new SysInfoVerifyHandler());
ExcelImportResult<SysInfo> sysInfoResult=ExcelImportUtil
.importExcelMore(is, SysInfo.class, params);
sysInfos = sysInfoResult.getList();
}
if(numSheet==1) {
params.setVerifyHandler(new SysFunVerifyHandler());
ExcelImportResult<SysFunction> sysFunResult=ExcelImportUtil
.importExcelMore(is, SysFunction.class, params);
sysFuns = sysFunResult.getList();
}
if(numSheet==2) {
params.setVerifyHandler(new SysAppVerifyHandler());
ExcelImportResult<SysApplication> sysAppResult=ExcelImportUtil
.importExcelMore(is, SysApplication.class, params);
sysApps = sysAppResult.getList();
}
if(numSheet==3) {
params.setVerifyHandler(new SysConsVerifyHandler());
ExcelImportResult<SysConstruction> sysConsResult=ExcelImportUtil
.importExcelMore(is, SysConstruction.class, params);
sysCons = sysConsResult.getList();
}
if(numSheet==4) {
params.setVerifyHandler(new SysOperVerifyHandler());
ExcelImportResult<SysOperations> sysOpersResult=ExcelImportUtil
.importExcelMore(is, SysOperations.class, params);
sysOpers = sysOpersResult.getList();
}
}
//整合excel信息
for(SysInfo sysInfo : sysInfos) {
for(SysFunction sysFun : sysFuns) {
if(StringUtils.isNotBlank(sysInfo.getSystemCode())&&
StringUtils.isNotBlank(sysFun.getSystemCode())&&
sysInfo.getSystemCode().equals(sysFun.getSystemCode())) {
sysInfo.getSysFunction().add(sysFun);
}
}
for(SysApplication sysApp : sysApps) {
if(StringUtils.isNotBlank(sysInfo.getSystemCode())&&
StringUtils.isNotBlank(sysApp.getSystemCode())&&
sysInfo.getSystemCode().equals(sysApp.getSystemCode())) {
sysInfo.getSysApplication().add(sysApp);
}
}
for(SysConstruction sysCon : sysCons) {
if(StringUtils.isNotBlank(sysInfo.getSystemCode())&&
StringUtils.isNotBlank(sysCon.getSystemCode())&&
sysInfo.getSystemCode().equals(sysCon.getSystemCode())) {
sysInfo.getSysConstruction().add(sysCon);
}
}
for(SysOperations sysOper : sysOpers) {
if(StringUtils.isNotBlank(sysInfo.getSystemCode())&&
StringUtils.isNotBlank(sysOper.getSystemCode())&&
sysInfo.getSystemCode().equals(sysOper.getSystemCode())) {
sysInfo.getSysOperations().add(sysOper);
}
}
}
return sysInfos;
}
//系统基本信息校验信息
class SysInfoVerifyHandler implements IExcelVerifyHandler<SysInfo>{
@Override
......@@ -239,6 +320,58 @@ public class ExcelParserService {
this.responseWorkbook(workbook, "信息系统管理界面数据_", request, response);
}
@SuppressWarnings("unchecked")
public InputStream exportSystemExcelForNgdb(List<Long> systemIds) throws Exception{
List<SysInfo> sysInfoList = new ArrayList<>();
List<SysFunction> sysFunList = new ArrayList<>();
List<SysApplication> sysAppList = new ArrayList<>();
List<SysConstruction> sysConsList = new ArrayList<>();
List<SysOperations> sysOperList = new ArrayList<>();
//循环根据系统id获取系统详细信息
for(Long systemId : systemIds) {
Gson gson = new Gson();
Map<String,Object> sysMap = authService.getScopes(0L, systemId);
Map<String,Object> options = (Map<String, Object>) sysMap.get("options");
SysInfo sysInfo = new Gson().fromJson(gson.toJson(options),SysInfo.class);
sysInfoList.add(sysInfo);
if(StringUtils.isNotBlank(sysInfo.getSystemOfflineTime())) {
//兼容旧数据导出操作
this.exportSystemOldData(sysInfo,sysFunList,sysAppList,sysConsList,sysOperList);
}
sysFunList.addAll(sysInfo.getSysFunction());
for(SysFunction sysFun : sysFunList) {
sysFun.setSystemCode(sysInfo.getSystemCode());
}
sysAppList.addAll(sysInfo.getSysApplication());
for(SysApplication sysApp : sysAppList) {
sysApp.setSystemCode(sysInfo.getSystemCode());
}
sysConsList.addAll(sysInfo.getSysConstruction());
for(SysConstruction sysCon : sysConsList) {
sysCon.setSystemCode(sysInfo.getSystemCode());
}
sysOperList.addAll(sysInfo.getSysOperations());
for(SysOperations sysOper : sysOperList) {
sysOper.setSystemCode(sysInfo.getSystemCode());
}
}
Workbook workbook = new XSSFWorkbook();//创建HSSFWorkbook对象
this.createSysInfoSheetAndFillData(workbook, sysInfoList);
this.createSysFunSheetAndFillData(workbook, sysFunList);
this.createSysAppSheetAndFillData(workbook, sysAppList);
this.createSysConsSheetAndFillData(workbook, sysConsList);
this.createSysOperSheetAndFillData(workbook, sysOperList);
ByteArrayOutputStream os = new ByteArrayOutputStream();
workbook.write(os);
InputStream is = new ByteArrayInputStream(os.toByteArray());
if(os!=null){
os.close();
}
return is;
}
private void createSysInfoSheetAndFillData(Workbook workbook,
List<SysInfo> sysInfoList) {
int rowIndex = 0;
......
src/main/java/com/keymobile/tagmanager/service/TagService.java → tag-service/src/main/java/com/keymobile/tagmanager/service/TagService.java
......@@ -25,7 +25,7 @@ import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
import com.keymobile.auth.common.security.GrantedAuthHelper;
import com.keymobile.common.security.GrantedAuthHelper;
import com.keymobile.tagmanager.exception.TagDuplicateException;
import com.keymobile.tagmanager.exception.TagException;
import com.keymobile.tagmanager.exception.TagNotExistException;
......
tag-service/src/main/java/com/keymobile/tagmanager/service/busi/ExcelParserCtrlService.java 0 → 100644
package com.keymobile.tagmanager.service.busi;
import cn.afterturn.easypoi.excel.ExcelImportUtil;
import cn.afterturn.easypoi.excel.entity.ImportParams;
import cn.afterturn.easypoi.excel.entity.result.ExcelImportResult;
import com.keymobile.tagmanager.logging.LogConstants;
import com.keymobile.tagmanager.logging.LogManager;
import com.keymobile.tagmanager.model.SysTag;
import com.keymobile.tagmanager.model.system.*;
import com.keymobile.tagmanager.remote.AuthServiceClient;
import com.keymobile.tagmanager.service.ExcelParserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
@Service
public class ExcelParserCtrlService {
@Autowired
private ExcelParserService excelParserService;
@Autowired
private AuthServiceClient authService;
public List<SysTag> parseExcel(InputStream is) throws Exception {
ImportParams params = new ImportParams();
params.setTitleRows(0);
params.setHeadRows(1);
params.setNeedVerify(false);
ExcelImportResult<SysTag> excelImportResult = ExcelImportUtil.importExcelMore(is, SysTag.class, params);
List<SysTag> sysTags = excelImportResult.getList();
return sysTags;
}
public List<SysInfo> parseSysExcel(InputStream is) throws Exception {
return excelParserService.importSystemExcel(is);
}
public InputStream exportSystemExcel(String systemIdString) throws Exception{
InputStream is = null;
if(StringUtils.isNotBlank(systemIdString)) {
List<Long> systemIds = new ArrayList<>();
String[] systemId = systemIdString.split(",");
for(String sid : systemId) {
systemIds.add(Long.valueOf(sid));
}
is = excelParserService.exportSystemExcelForNgdb(systemIds);
}
LogManager.logInfo(LogConstants.CTX_OPTFILETAG, "导出系统");
return is;
}
}
tag-service/src/main/java/com/keymobile/tagmanager/service/busi/MockCtrlService.java 0 → 100644
package com.keymobile.tagmanager.service.busi;
import com.keymobile.tagmanager.exception.TagNotExistException;
import com.keymobile.tagmanager.util.JsonTreeHelper;
import com.keymobile.tagmanager.util.JsonTreeHelper.JsonNode;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.ArrayList;
import java.util.List;
import java.util.UUID;
@Service
public class MockCtrlService {
private static final String ORG_SEPERATOR = "\\";
private static final String ORG_TOP_NODE = "中广核集团";
private static final String ORG_SECOND_NODE = "工程公司";
public JsonNode[] queryPersonalTagAsTree() throws TagNotExistException {
List<JsonNode> jsonNodes = new ArrayList<>();
jsonNodes.add(new JsonNode(ORG_TOP_NODE, UUID.randomUUID().toString(), ORG_TOP_NODE));
addSecodeNodes(ORG_TOP_NODE, ORG_SECOND_NODE, jsonNodes);
addThirdNodes(ORG_TOP_NODE + ORG_SEPERATOR + ORG_SECOND_NODE, "人力资源部", jsonNodes);
addThirdNodes(ORG_TOP_NODE + ORG_SEPERATOR + ORG_SECOND_NODE, "财务部", jsonNodes);
addThirdNodes(ORG_TOP_NODE + ORG_SEPERATOR + ORG_SECOND_NODE, "安全质保部", jsonNodes);
addThirdNodes(ORG_TOP_NODE + ORG_SEPERATOR + ORG_SECOND_NODE, "施工管理中心", jsonNodes);
addThirdNodes(ORG_TOP_NODE + ORG_SEPERATOR + ORG_SECOND_NODE, "设备采购与成套中心", jsonNodes);
JsonNode root = JsonTreeHelper.toJsonTree(jsonNodes, ORG_SEPERATOR + ORG_SEPERATOR);
if (root.children != null)
return root.children;
else
return new JsonNode[] {};
}
private void addThirdNodes(String secondNode, String thirdNode, List<JsonNode> jsonNodes) {
JsonNode third = new JsonNode(secondNode + ORG_SEPERATOR + thirdNode, UUID.randomUUID().toString(), secondNode + ORG_SEPERATOR + thirdNode);
jsonNodes.add(third);
}
private void addSecodeNodes(String topNode, String secodeNode, List<JsonNode> jsonNodes) {
JsonNode second = new JsonNode(topNode + ORG_SEPERATOR + secodeNode, UUID.randomUUID().toString(), topNode + ORG_SEPERATOR + secodeNode);
jsonNodes.add(second);
}
}
tag-service/src/main/java/com/keymobile/tagmanager/service/busi/TagFileCtrlService.java 0 → 100644
package com.keymobile.tagmanager.service.busi;
import com.keymobile.common.security.GrantedAuthHelper;
import com.keymobile.tagmanager.logging.LogConstants;
import com.keymobile.tagmanager.logging.LogManager;
import com.keymobile.tagmanager.model.Page;
import com.keymobile.tagmanager.service.TagFileService;
import com.keymobile.tagmanager.util.UserInfoUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
@Api(value = "文件", tags = "文件")
@RestController
@RequestMapping(value = "/file")
public class TagFileCtrlService {
@Autowired
private TagFileService tagExportService;
public String importTagMeta(String idPath, String dimensionType, String tagType,InputStream is) throws Exception {
String userName = UserInfoUtils.getUserName();
String userId = UserInfoUtils.getUserId();
String deptIdPath = /**UserInfoUtils.getDataRoleOrg()*/String.valueOf(GrantedAuthHelper.getUserOrg());
LogManager.logInfo(LogConstants.CTX_OPTFILETAG, "导入标签元数据");
return tagExportService.importTagMetadataExcelForNgdb(userName, userId, deptIdPath,
idPath, dimensionType, tagType, is);
}
public InputStream exportTagMeta(String idPath,String dimensionType,String tagType) throws Exception {
LogManager.logInfo(LogConstants.CTX_OPTFILETAG, "导出标签元数据");
return tagExportService.exportTagMetadataExcelForNgdb(idPath, dimensionType, tagType);
}
public InputStream exportTag(String deptIdPath,String isSys) throws Exception{
deptIdPath = /**UserInfoUtils.getDataRoleOrg()*/String.valueOf(GrantedAuthHelper.getUserOrg());
LogManager.logInfo(LogConstants.CTX_OPTFILETAG, "导出标签");
return tagExportService.exportExcelForNgdb(deptIdPath, isSys);
}
public String importTag(InputStream is,String deptIdPath) throws Exception {
String userName = UserInfoUtils.getUserName();
String userId = UserInfoUtils.getUserId();
deptIdPath = /**UserInfoUtils.getDataRoleOrg()*/String.valueOf(GrantedAuthHelper.getUserOrg());
LogManager.logInfo(LogConstants.CTX_OPTFILETAG, "导入标签");
return tagExportService.importExcelForNgdb(userName, userId, deptIdPath, is);
}
public Page listImportTagLogByPage(String deptIdPath,Integer pageNo,Integer pageSize) {
String userName = UserInfoUtils.getUserName();
return tagExportService.listImportlogByPage(userName, new Page(pageSize, pageNo));
}
public void undoImportTag(String importlogId) {
tagExportService.undoImportExcel(importlogId);
}
public InputStream exportSystem(String systemIdString) throws Exception{
InputStream is = null;
if(StringUtils.isNotBlank(systemIdString)) {
List<Long> systemIds = new ArrayList<>();
String[] systemId = systemIdString.split(",");
for(String sid : systemId) {
systemIds.add(Long.valueOf(sid));
}
is = tagExportService.exportSystemForNgdb(systemIds);
}
LogManager.logInfo(LogConstants.CTX_OPTFILETAG, "导出系统");
return is;
}
public String importSystem(InputStream is) throws Exception {
String userName = UserInfoUtils.getUserName();
return tagExportService.importSystemForNgdb(userName, is);
}
}
tag-service/src/main/java/com/keymobile/tagmanager/service/busi/TagRelCtrlService.java 0 → 100644
package com.keymobile.tagmanager.service.busi;
import com.keymobile.common.security.GrantedAuthHelper;
import com.keymobile.tagmanager.logging.LogConstants;
import com.keymobile.tagmanager.logging.LogManager;
import com.keymobile.tagmanager.model.TagRelation;
import com.keymobile.tagmanager.service.TagRelService;
import com.keymobile.tagmanager.util.UserInfoUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@Service
public class TagRelCtrlService {
private Logger logger = LoggerFactory.getLogger(TagRelCtrlService.class);
@Autowired
private TagRelService tagRelService;
public TagRelation addTagRel(String sourceId,String targetId) throws Exception {
//获取当前登录用户名和id
/**String userName = UserInfoUtils.getUserName();*/
String userId = UserInfoUtils.getUserId();
//获取当前登录用户所属机构
String org = /**UserInfoUtils.getDataRoleOrg()*/String.valueOf(GrantedAuthHelper.getUserOrg());
if(sourceId.equals(targetId)) {
throw new Exception("can not make source and target as the same one.");
}
//判断关系是否存在
if(tagRelService.tagRelExist(sourceId, targetId)) {
throw new Exception("the tag relation is exist");
}
LogManager.logInfo(LogConstants.CTX_OPTTAGREL, "新增标签关系");
return tagRelService.addTagRel(sourceId, targetId, userId, org);
}
public void deleteTagRel(String id) {
LogManager.logInfo(LogConstants.CTX_OPTTAGREL, "删除标签关系");
tagRelService.deleteTagRel(id);
}
public List<TagRelation> getSourceTags(String tagId){
return tagRelService.getSource(tagId);
}
public List<TagRelation> getTargetTags(String tagId){
return tagRelService.getTarget(tagId);
}
public List<TagRelation> getAll(){
return tagRelService.getAll();
}
}
tag-service/src/main/java/com/keymobile/tagmanager/service/ngdb/impl/ExcelParserSVCImpl.java 0 → 100644
package com.keymobile.tagmanager.service.ngdb.impl;
import com.keymobile.common.oss.service.OssCommonService;
import com.keymobile.tagmanager.facade.response.Result;
import com.keymobile.tagmanager.facade.service.ExcelParserSVC;
import com.keymobile.tagmanager.model.SysTag;
import com.keymobile.tagmanager.model.system.SysInfo;
import com.keymobile.tagmanager.service.busi.ExcelParserCtrlService;
import com.sdebank.ngdb.oaps.context.ServiceContext;
import org.springframework.beans.factory.annotation.Autowired;
import java.io.IOException;
import java.io.InputStream;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Map;
public class ExcelParserSVCImpl implements ExcelParserSVC {
@Autowired
private ExcelParserCtrlService excelParserCtrlService;
@Autowired
private OssCommonService ossCommonService;
public Map<String, Object> parseExcel(Map<String, Object> requestMap) throws Exception {
Map<String, Object> rqMp = ServiceContext.getReqData();
String objectKey = rqMp.get("objectKey") != null ? (rqMp.get("objectKey").toString()) : null;
InputStream is = null;
Result result = null;
try {
is = ossCommonService.download(objectKey);
List<SysTag> resultBody = excelParserCtrlService.parseExcel(is);
result = Result.genOkResult(resultBody);
} catch (Exception e) {
e.printStackTrace();
Result.genFailedResult(e.getMessage());
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> parseSysExcel(Map<String, Object> requestMap) throws Exception {
Map<String, Object> rqMp = ServiceContext.getReqData();
String objectKey = rqMp.get("objectKey") != null ? (rqMp.get("objectKey").toString()) : null;
InputStream is = null;
Result result = null;
try {
is = ossCommonService.download(objectKey);
List<SysInfo> resultBody = excelParserCtrlService.parseSysExcel(is);
result = Result.genOkResult(resultBody);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> exportSystemExcel(Map<String, Object> requestMap) throws Exception {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
InputStream is = null;
try {
String systemIdString = requestMap.get("systemIdString") != null ? (requestMap.get("systemIdString").toString()) : null;
is = excelParserCtrlService.exportSystemExcel(systemIdString);
String fileName = "信息系统管理界面数据_" + LocalDateTime.now().toString();
String resultStr = ossCommonService.uploadAndGenExpireTimeUrl(is, fileName, "xlsx", 365 * 24 * 60 * 60L);
result = Result.genOkResult(resultStr);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return ServiceContext.setRespBodyDto(result);
}
}
tag-service/src/main/java/com/keymobile/tagmanager/service/ngdb/impl/MockSVCImpl.java 0 → 100644
package com.keymobile.tagmanager.service.ngdb.impl;
import com.keymobile.tagmanager.exception.TagNotExistException;
import com.keymobile.tagmanager.facade.response.Result;
import com.keymobile.tagmanager.facade.service.MockSVC;
import com.keymobile.tagmanager.service.busi.MockCtrlService;
import com.keymobile.tagmanager.util.JsonTreeHelper.JsonNode;
import com.sdebank.ngdb.oaps.context.ServiceContext;
import java.util.Map;
public class MockSVCImpl implements MockSVC {
private MockCtrlService mockCtrlService;
public Map<String, Object> queryOrgAsTree(Map<String, Object> requestMap) throws TagNotExistException {
JsonNode[] resultBody = mockCtrlService.queryPersonalTagAsTree();
Result result = Result.genOkResult(resultBody);
return ServiceContext.setRespBodyDto(result);
}
}
tag-service/src/main/java/com/keymobile/tagmanager/service/ngdb/impl/TagFileSVCImpl.java 0 → 100644
package com.keymobile.tagmanager.service.ngdb.impl;
import com.keymobile.common.oss.service.OssCommonService;
import com.keymobile.tagmanager.facade.response.Result;
import com.keymobile.tagmanager.facade.service.TagFileSVC;
import com.keymobile.tagmanager.model.Page;
import com.keymobile.tagmanager.service.busi.TagFileCtrlService;
import com.sdebank.ngdb.oaps.context.ServiceContext;
import org.springframework.beans.factory.annotation.Autowired;
import java.io.IOException;
import java.io.InputStream;
import java.time.LocalDateTime;
import java.util.Map;
public class TagFileSVCImpl implements TagFileSVC {
@Autowired
private TagFileCtrlService tagFileCtrlService;
@Autowired
private OssCommonService ossCommonService;
public Map<String, Object> importTagMeta(Map<String, Object> requestMap) throws Exception {
Map<String, Object> rqMp = ServiceContext.getReqData();
String idPath = rqMp.get("idPath") != null ? (rqMp.get("idPath").toString()) : null;
String dimensionType = rqMp.get("dimensionType") != null ? (rqMp.get("dimensionType").toString()) : null;
String tagType = rqMp.get("tagType") != null ? (rqMp.get("tagType").toString()) : null;
String objectKey = rqMp.get("objectKey") != null ? (rqMp.get("objectKey").toString()) : null;
InputStream is = ossCommonService.download(objectKey);
String resultBody = tagFileCtrlService.importTagMeta(idPath, dimensionType, tagType, is);
Result result = Result.genOkResult(resultBody);
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> exportTagMeta(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
InputStream is = null;
try {
String idPath = rqMp.get("idPath") != null ? (rqMp.get("idPath").toString()) : null;
String dimensionType = rqMp.get("dimensionType") != null ? (rqMp.get("dimensionType").toString()) : null;
String tagType = rqMp.get("tagType") != null ? (rqMp.get("tagType").toString()) : null;
is = tagFileCtrlService.exportTagMeta(idPath, dimensionType, tagType);
String fileName = "tagMetadata_" + LocalDateTime.now().toString();
String resultStr = ossCommonService.uploadAndGenExpireTimeUrl(is, fileName, "xlsx", 365 * 24 * 60 * 60L);
result = Result.genOkResult(resultStr);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> exportTag(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
InputStream is = null;
try {
String deptIdPath = rqMp.get("deptIdPath") != null ? (rqMp.get("deptIdPath").toString()) : null;
String isSys = rqMp.get("isSys") != null ? (rqMp.get("isSys").toString()) : null;
is = tagFileCtrlService.exportTag(deptIdPath, isSys);
String fileName = "tagMetadata_" + LocalDateTime.now().toString();
String resultStr = ossCommonService.uploadAndGenExpireTimeUrl(is, fileName, "xlsx", 365 * 24 * 60 * 60L);
result = Result.genOkResult(resultStr);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> importTag(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
InputStream is = null;
Result result = null;
try {
String deptIdPath = rqMp.get("deptIdPath") != null ? (rqMp.get("deptIdPath").toString()) : null;
String objectKey = rqMp.get("objectKey") != null ? (rqMp.get("objectKey").toString()) : null;
is = ossCommonService.download(objectKey);
String resultBody = tagFileCtrlService.importTag(is, deptIdPath);
result = Result.genOkResult(resultBody);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> listImportTagLogByPage(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
String deptIdPath = rqMp.get("deptIdPath") != null ? (rqMp.get("deptIdPath").toString()) : null;
Integer pageNo = rqMp.get("pageNo") != null ? (Integer.valueOf(rqMp.get("pageNo").toString())) : null;
Integer pageSize = rqMp.get("pageSize") != null ? (Integer.valueOf(rqMp.get("pageSize").toString())) : null;
Page resultBody = tagFileCtrlService.listImportTagLogByPage(deptIdPath, pageNo, pageSize);
Result result = Result.genOkResult(resultBody);
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> undoImportTag(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
String importlogId = rqMp.get("importlogId") != null ? (rqMp.get("importlogId").toString()) : null;
tagFileCtrlService.undoImportTag(importlogId);
Result result = Result.genOkResult();
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> exportSystem(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
InputStream is = null;
try {
String systemIdString = rqMp.get("systemIdString") != null ? (rqMp.get("systemIdString").toString()) : null;
is = tagFileCtrlService.exportSystem(systemIdString);
if (is != null) {
String fileName = "CGNSystem_" + LocalDateTime.now().toString();
String resultStr = ossCommonService.uploadAndGenExpireTimeUrl(is, fileName, "xlsx", 365 * 24 * 60 * 60L);
result = Result.genOkResult(resultStr);
} else {
result = Result.genFailedResult("传入参数为空");
}
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> importSystem(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
InputStream is = null;
Result result = null;
try {
String objectKey = rqMp.get("objectKey") != null ? (rqMp.get("objectKey").toString()) : null;
is = ossCommonService.download(objectKey);
String resultBody = tagFileCtrlService.importSystem(is);
result = Result.genOkResult(resultBody);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
}
return ServiceContext.setRespBodyDto(result);
}
}
tag-service/src/main/java/com/keymobile/tagmanager/service/ngdb/impl/TagRelSVCImpl.java 0 → 100644
package com.keymobile.tagmanager.service.ngdb.impl;
import com.keymobile.tagmanager.facade.response.Result;
import com.keymobile.tagmanager.facade.service.TagRelSVC;
import com.keymobile.tagmanager.model.TagRelation;
import com.keymobile.tagmanager.service.busi.TagRelCtrlService;
import com.sdebank.ngdb.oaps.context.ServiceContext;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
import java.util.Map;
public class TagRelSVCImpl implements TagRelSVC {
@Autowired
private TagRelCtrlService tagRelCtrlService;
public Map<String, Object> addTagRel(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
try {
String sourceId = rqMp.get("sourceId") != null ? (rqMp.get("sourceId").toString()) : null;
String targetId = rqMp.get("targetId") != null ? (rqMp.get("targetId").toString()) : null;
TagRelation resultBody = tagRelCtrlService.addTagRel(sourceId, targetId);
result = Result.genOkResult(resultBody);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> deleteTagRel(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
try {
String id = rqMp.get("id") != null ? (rqMp.get("id").toString()) : null;
tagRelCtrlService.deleteTagRel(id);
result = Result.genOkResult();
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> getSourceTags(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
try {
String tagId = rqMp.get("tagId") != null ? (rqMp.get("tagId").toString()) : null;
List<TagRelation> resultBody = tagRelCtrlService.getSourceTags(tagId);
result = Result.genOkResult(resultBody);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> getTargetTags(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
try {
String tagId = rqMp.get("tagId") != null ? (rqMp.get("tagId").toString()) : null;
List<TagRelation> resultBody = tagRelCtrlService.getTargetTags(tagId);
result = Result.genOkResult(resultBody);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
}
return ServiceContext.setRespBodyDto(result);
}
public Map<String, Object> getAll(Map<String, Object> requestMap) {
Map<String, Object> rqMp = ServiceContext.getReqData();
Result result = null;
try {
List<TagRelation> resultBody = tagRelCtrlService.getAll();
result = Result.genOkResult(resultBody);
} catch (Exception e) {
e.printStackTrace();
result = Result.genFailedResult(e.getMessage());
}
return ServiceContext.setRespBodyDto(result);
}
}
tag-service/src/main/resources/MEATA-INF/param/com.sdebank.ngdb.opas.definition.properties 0 → 100644
#若是不需要配置私有责任链以及调整参数配置，则使用默认参数配置，无需在应用中配置服务参数，若需要配置私有责任链则需要定义服务参数，定义参数参考如下
\ No newline at end of file
tag-service/src/main/resources/sofa/ngdb_dmgt_apply_server_provider.xml 0 → 100644
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:sofa="http://sofastack.io/schema/sofaboot"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://sofastack.io/schema/sofaboot http://sofastack.io/schema/sofaboot.xsd"
default-autowire="byName">
<bean id="ExcelParserSVC" class="com.keymobile.tagmanager.service.ngdb.impl.ExcelParserSVCImpl"/>
<sofa:service ref="ExcelParserSVC"
interface="com.keymobile.tagmanager.facade.service.ExcelParserSVC" >
<sofa:binding.bolt/>
<sofa:binding.rest/>
</sofa:service>
<bean id="MockSVC" class="com.keymobile.tagmanager.service.ngdb.impl.MockSVCImpl"/>
<sofa:service ref="MockSVC"
interface="com.keymobile.tagmanager.facade.service.MockSVC" >
<sofa:binding.bolt/>
<sofa:binding.rest/>
</sofa:service>
<bean id="TagFileSVC" class="com.keymobile.tagmanager.service.ngdb.impl.TagFileSVCImpl"/>
<sofa:service ref="TagFileSVC"
interface="com.keymobile.tagmanager.facade.service.TagFileSVC" >
<sofa:binding.bolt/>
<sofa:binding.rest/>
</sofa:service>
<bean id="TagRelSVC" class="com.keymobile.tagmanager.service.ngdb.impl.TagRelSVCImpl"/>
<sofa:service ref="TagRelSVC"
interface="com.keymobile.tagmanager.facade.service.TagRelSVC" >
<sofa:binding.bolt/>
<sofa:binding.rest/>
</sofa:service>
<bean id="TagSVC" class="com.keymobile.tagmanager.service.ngdb.impl.TagSVCImpl"/>
<sofa:service ref="TagSVC"
interface="com.keymobile.tagmanager.facade.service.TagSVC" >
<sofa:binding.bolt/>
<sofa:binding.rest/>
</sofa:service>
</beans>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment