订阅

CODE/smart-community/mq-message/.gitignore

@@ -0,0 +1,25 @@
+/target/
+!.mvn/wrapper/maven-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/build/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/

CODE/smart-community/mq-message/.mvn/wrapper/maven-wrapper.properties

@@ -0,0 +1 @@
+distributionUrl=https://repo1.maven.org/maven2/org/apache/maven/apache-maven/3.5.4/apache-maven-3.5.4-bin.zip

CODE/smart-community/mq-message/mvnw

@@ -0,0 +1,225 @@
+#!/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
+#
+#    http://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 Migwn, 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)`"
+  # TODO classpath?
+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
+
+export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
+echo $MAVEN_PROJECTBASEDIR
+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
+
+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 "$@"

CODE/smart-community/mq-message/mvnw.cmd

@@ -0,0 +1,143 @@
+@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    http://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 enable echoing my 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
+
+%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%

CODE/smart-community/mq-message/pom.xml

@@ -0,0 +1,275 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>com.community</groupId>
+	<artifactId>mq-message</artifactId>
+	<version>0.0.1</version>
+	<packaging>jar</packaging>
+
+	<name>mq-message</name>
+	<description>mq-message</description>
+
+	<parent>
+		<groupId>com.community</groupId>
+		<artifactId>smart-community</artifactId>
+		<version>0.0.1</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>
+		<spring-cloud.version>Finchley.SR1</spring-cloud.version>
+		<spring-session-jdbc.version>2.0.5.RELEASE</spring-session-jdbc.version>
+		<logback.version>1.1.6</logback.version>
+		<logback.access.version>1.1.2</logback.access.version>
+		<commons.logging.version>1.2</commons.logging.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-openfeign</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-swagger2</artifactId>
+			<version>2.7.0</version>
+		</dependency>
+
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-swagger-ui</artifactId>
+			<version>2.7.0</version>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-config</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-actuator</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.mybatis.spring.boot</groupId>
+			<artifactId>mybatis-spring-boot-starter</artifactId>
+			<version>1.3.2</version>
+		</dependency>
+
+		<dependency>
+			<groupId>com.github.pagehelper</groupId>
+			<artifactId>pagehelper-spring-boot-starter</artifactId>
+			<version>1.2.3</version>
+		</dependency>
+
+		<dependency>
+			<groupId>mysql</groupId>
+			<artifactId>mysql-connector-java</artifactId>
+			<scope>runtime</scope>
+		</dependency>
+
+		<dependency>
+			<groupId>com.community</groupId>
+			<artifactId>community-common</artifactId>
+			<version>0.0.1</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-jdbc</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.session</groupId>
+			<artifactId>spring-session-jdbc</artifactId>
+			<version>${spring-session-jdbc.version}</version>
+		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+			<version>1.18.2</version>
+			<scope>provided</scope>
+		</dependency>
+
+		<!-- log4j -->
+		<dependency>
+			<groupId>org.apache.activemq</groupId>
+			<artifactId>activemq-core</artifactId>
+			<version>5.7.0</version>
+		</dependency>
+
+		<dependency>
+			<groupId>com.google.protobuf</groupId>
+			<artifactId>protobuf-java</artifactId>
+			<version>2.3.0</version>
+		</dependency>
+
+
+		<dependency>
+			<groupId>net.sf.json-lib</groupId>
+			<artifactId>json-lib</artifactId>
+			<version>2.4</version>
+			<classifier>jdk15</classifier>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>commons-beanutils</groupId>
+			<artifactId>commons-beanutils</artifactId>
+			<version>1.8.1</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>commons-collections</groupId>
+			<artifactId>commons-collections</artifactId>
+			<version>3.2.1</version>
+			<scope>compile</scope>
+		</dependency>
+		<dependency>
+			<groupId>commons-lang</groupId>
+			<artifactId>commons-lang</artifactId>
+			<version>2.6</version>
+			<scope>${jar.scope}</scope>
+		</dependency>
+		<dependency>
+			<groupId>commons-logging</groupId>
+			<artifactId>commons-logging</artifactId>
+			<version>1.1.1</version>
+			<scope>${jar.scope}</scope>
+		</dependency>
+		<dependency>
+			<groupId>net.sf.ezmorph</groupId>
+			<artifactId>ezmorph</artifactId>
+			<version>1.0.6</version>
+			<scope>${jar.scope}</scope>
+		</dependency>
+
+		<!--<dependency>-->
+			<!--<groupId>org.springframework.boot</groupId>-->
+			<!--<artifactId>spring-boot-starter-log4j</artifactId>-->
+		<!--</dependency>-->
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter</artifactId>
+		</dependency>
+
+
+		<dependency>
+			<groupId>commons-logging</groupId>
+			<artifactId>commons-logging</artifactId>
+			<version>${commons.logging.version}</version>
+		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
+		<dependency>
+			<groupId>com.google.guava</groupId>
+			<artifactId>guava</artifactId>
+			<version>26.0-jre</version>
+		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+			<version>3.8.1</version>
+		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/commons-lang/commons-lang -->
+		<dependency>
+			<groupId>commons-lang</groupId>
+			<artifactId>commons-lang</artifactId>
+			<version>2.6</version>
+		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/com.squareup.okhttp3/okhttp -->
+		<dependency>
+			<groupId>com.squareup.okhttp3</groupId>
+			<artifactId>okhttp</artifactId>
+			<version>3.11.0</version>
+		</dependency>
+
+		<dependency>
+			<groupId>commons-httpclient</groupId>
+			<artifactId>commons-httpclient</artifactId>
+			<version>3.1</version>
+		</dependency>
+
+		<!-- https://mvnrepository.com/artifact/commons-io/commons-io -->
+		<dependency>
+			<groupId>commons-io</groupId>
+			<artifactId>commons-io</artifactId>
+			<version>1.4</version>
+		</dependency>
+
+		<dependency>
+			<groupId>net.coobird</groupId>
+			<artifactId>thumbnailator</artifactId>
+			<version>0.4.2</version>
+		</dependency>
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </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>
+		</dependencies>
+	</dependencyManagement>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>3.7.0</version>
+				<configuration>
+					<source>1.8</source>
+					<target>1.8</target>
+					<encoding>UTF-8</encoding>
+					<compilerArguments>
+						<extdirs>${project.basedir}/lib</extdirs>
+					</compilerArguments>
+				</configuration>
+			</plugin>
+		</plugins>
+	</build>
+
+
+</project>

CODE/smart-community/mq-message/src/main/java/com/community/huiju/MqApplication.java

@@ -0,0 +1,40 @@
+package com.community.huiju;
+
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.alibaba.fastjson.support.config.FastJsonConfig;
+import com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter;
+import com.community.huiju.common.hk.code.AcsEvent;
+import com.community.huiju.common.hk.code.EventDis;
+import com.google.protobuf.ByteString;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.annotation.Bean;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+import org.springframework.web.client.RestTemplate;
+
+import javax.jms.BytesMessage;
+import javax.jms.Connection;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageListener;
+import javax.jms.Session;
+import javax.jms.Topic;
+
+/**
+ * @author fxf
+ */
+@EnableDiscoveryClient
+@SpringBootApplication
+@EnableFeignClients
+@EnableTransactionManagement
+public class MqApplication {
+	
+	public static void main(String[] args) {
+		SpringApplication.run(MqApplication.class, args);
+	}
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/Swagger2.java

@@ -0,0 +1,40 @@
+package com.community.huiju;
+
+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;
+import springfox.documentation.service.ApiInfo;
+import springfox.documentation.service.Contact;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+
+/**
+ * @author FXF
+ * @date 2018-09-27
+ */
+@Configuration
+@EnableSwagger2
+public class Swagger2 {
+    @Bean
+    public Docket docket(){
+        return new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo()).select()
+                .apis(RequestHandlerSelectors.basePackage("com.community.huiju.controller"))
+                .paths(PathSelectors.any()).build();
+    }
+    //构建api文档的详细信息函数
+    private ApiInfo apiInfo(){
+        return new ApiInfoBuilder()
+                //页面标题
+                .title("app端的 RESTful API")
+                //创建人
+                .contact(new Contact("fuxingfan","","fuxingfan@dingtalk.com"))
+                //版本号
+                .version("1.0")
+                //描述
+                .description("API 描述")
+                .build();
+    }
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/common/code/ICode.java

@@ -0,0 +1,15 @@
+package com.community.huiju.common.code;
+
+
+/**
+ * 验证码接口
+ * @author weiximei
+ */
+public interface ICode {
+
+    /**
+     * 验证码
+     */
+    boolean sendCode(String phone,String code);
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/common/code/cache/AppkeyCache.java

@@ -0,0 +1,46 @@
+package com.community.huiju.common.code.cache;
+import com.community.commom.constant.Constant;
+import com.google.common.cache.CacheBuilder;
+import com.google.common.cache.CacheLoader;
+import com.google.common.cache.LoadingCache;
+import lombok.extern.slf4j.Slf4j;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 缓存
+ * @author weiximei
+ */
+@Slf4j
+public class AppkeyCache {
+
+    // .refreshAfterWrite(3, TimeUnit.HOURS)// 给定时间内没有被读/写访问，则回收。
+    static LoadingCache<String, Object> cache = CacheBuilder.newBuilder()
+            .expireAfterAccess(Constant.CACHE_EXPIRE, TimeUnit.HOURS)// 缓存过期时间和redis缓存时长一样
+            .maximumSize(Constant.CACHE_SIZE).// 设置缓存个数
+            build(new CacheLoader<String, Object>() {
+            @Override
+            /** 当本地缓存命没有中时，调用load方法获取结果并将结果缓存 **/
+            public String load(String appKey) throws Exception {
+                return null;
+            }
+
+    });
+
+    public static Object getCache(String appKey) {
+        Object value = null;
+        try {
+            value = cache.get(appKey);
+        } catch (Exception e) {
+            //e.printStackTrace();
+            value = null;
+        }
+        return value;
+    }
+
+    public static void setCache(String appKey,Object appValue){
+        log.info("缓存的key-value: {}-{}", appKey,appValue);
+        cache.put(appKey,appValue);
+    }
+
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/common/code/entity/CodeEntity.java

@@ -0,0 +1,23 @@
+package com.community.huiju.common.code.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class CodeEntity {
+
+   private String code;
+
+   private String tel;
+
+    /**
+     * 参数 格式 String params = "["xxx"]"
+     */
+   private String params;
+
+
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/common/code/impl/ImgCodeImpl.java

@@ -0,0 +1,13 @@
+package com.community.huiju.common.code.impl;
+
+import com.community.huiju.common.code.ICode;
+
+/**
+ * 图片验证码
+ * @author weiximei
+ */
+public class ImgCodeImpl {
+
+
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/common/code/impl/PhoneCodeImpl.java

@@ -0,0 +1,74 @@
+package com.community.huiju.common.code.impl;
+
+import com.community.commom.constant.Constant;
+import com.community.commom.utils.AccountValidatorUtil;
+import com.community.huiju.common.code.ICode;
+import com.community.huiju.common.code.cache.AppkeyCache;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.io.IOException;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 手机验证码
+ * @author weiximei
+ */
+@Service("phoneCodeImpl")
+@Slf4j
+public class PhoneCodeImpl implements ICode {
+
+    public static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    public OkHttpClient getClient() {
+        OkHttpClient client  = new OkHttpClient.Builder()
+                .connectTimeout(10, TimeUnit.SECONDS)
+                .writeTimeout(10,TimeUnit.SECONDS)
+                .readTimeout(20, TimeUnit.SECONDS)
+                .build();
+        return client;
+    }
+
+    @Override
+    public boolean sendCode(String phone, String code) {
+        boolean bool = false;
+
+        try {
+            String result = null;
+            OkHttpClient client = getClient();
+            RequestBody body = RequestBody.create(JSON, "{\"code\":\""+Constant.CODE+"\"," + "\"tel\":\""+phone+"\"," + "\"params\":[\""+code+"\"]}");
+            Request request = new Request.Builder()
+                    .url(Constant.REQUEST_URL)
+                    .post(body)
+                    .build();
+            Response response = client.newCall(request).execute();
+            if (response.isSuccessful()) {
+                result = response.body().string();
+            } else {
+                throw new IOException("Unexpected code " + response);
+            }
+
+
+
+            if ("发送成功".equals(result)) {
+                bool = true;
+                log.info("手机号 {} 验证码 {} 发送成功!",phone,code);
+            }else {
+                bool = false;
+                log.error("短信发送验证码失败!{}", result);
+            }
+        } catch (Exception e){
+            e.printStackTrace();
+            log.error("短信发送错误!",e);
+            bool = false;
+        }
+
+        return bool;
+    }
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/common/hk/HKConstant.java

@@ -0,0 +1,130 @@
+package com.community.huiju.common.hk;
+
+public class HKConstant {
+
+    /**
+     * APPKEY需要到部署的平台服务器上生成。
+     * <p>
+     * 调用Openpai的操作码，需要去平台上生成，详见《海康威视iVMS-8700平台SDKV2.*.* HTTP-OpenAPI使用说明书.chm》中[获取AppKey和Secret]章节说明
+     * </p>
+     * <p>
+     * 《海康威视iVMS-8700平台SDKV2.*.* HTTP-OpenAPI使用说明书.chm》 该文档请找技术支持或者交付的同事提供
+     * </p>
+     */
+    public static final String APPKEY = "b4434b13";
+
+    /**
+     * SECRET需要到部署的平台服务器上生成。
+     * <p>
+     * 调用Openpai的操作码，需要去平台上生成，详见《海康威视iVMS-8700平台SDKV2.*.* HTTP-OpenAPI使用说明书.chm》中[获取AppKey和Secret]章节说明
+     * </p>
+     * <p>
+     * 《海康威视iVMS-8700平台SDKV2.*.* HTTP-OpenAPI使用说明书.chm》 该文档请找技术支持或者交付的同事提供
+     * </p>
+     */
+    public static final String SECRET = "64a1f32d53784ce2a34bd81822db1b91";
+
+
+    /**
+     * http请求地址
+     * <p>openapi的地址,默认情况下openapi的IP端口与基础应用的IP端口是一致的</p>
+     * <p>请将地址配置正确.</p>
+     * <p>默认情况下是127.0.0.1:80 ，如果地址不通请根据实际情况修改IP端口</p>
+     */
+   // public static final String OPENAPI_IP_PORT_HTTP = "http://192.168.0.122";
+    //  public static final String OPENAPI_IP_PORT_HTTPS = "http://192.168.0.122";
+    //public static final String OPENAPI_IP_PORT_HTTP = "http://huiju.ngrok.xiaomiqiu.cn";
+    public static final String OPENAPI_IP_PORT_HTTP = "http://huifang.vipgz1.idcfengye.com";
+
+    /**
+     * <p>操作用户UUID，即用户UUID，首次使用操作用户UUID可以通过接口 [获取默认用户UUID]来获取</p>
+     * <p>也可以通过接口[分页获取用户]来获取</p>
+     */
+
+    /**
+     * 获取默认用户UUID的接口地址，此地址可以从《海康威视iVMS-8700平台SDKV2.*.* HTTP-OpenAPI使用说明书.chm》中具体的接口说明上获取
+     */
+    public static final String ITF_ADDRESS_GET_DEFAULT_USER_UUID = "/openapi/service/base/user/getDefaultUserUuid";
+
+    /**
+     * 分页获取监控点信息的接口地址，此地址可以从《海康威视iVMS-8700平台SDKV2.*.* HTTP-OpenAPI使用说明书.chm》中具体的接口说明上获取
+     */
+    public static final String ITF_ADDRESS_GET_CAMERAS = "/openapi/service/vss/res/getCameras";
+
+    /**
+     * 查询监控点地址
+     */
+    public static final String OP_USER_UUID = "5b2eb534696b11e89c2e438f92627767";
+
+    /**--主要是推送图片到海康
+     * 通过此接口将人员名单添加到指定的人员分组当中，此接口适合一次添加一个人员，如果需要批量添加可以使用平台上自带的图片压缩包的方式批量添加。
+     */
+    public  static  final  String OP_IMG="/openapi/service/fas/personInfo/addPersonInfoIntoGroup";
+
+    public static final String ITF_MONITORY_POINT = "/openapi/service/vss/res/getCamerasEx";
+    
+    /**
+     * 根据区域UUID集获取门禁点
+     */
+    public static final String DOORS_BY_REGION_UUIDS = "/openapi/service/acs/res/getDoorsByRegionUuids";
+    
+    /**
+     * 根据人员ID集添加权限
+     */
+    public static final String ADD_AUTHORITIES_BY_PERSONIDS = "/openapi/service/acs/auth/addAuthoritiesByPersonIds";
+    
+    /**
+     * 根据设备UUID集异动下载门禁权限
+     */
+    public static final String DOWNLOAD_AUTHORITY_BY_DEVICEUUIDS = "/openapi/service/acs/auth/downloadAuthorityByDeviceUuids";
+    
+    /**
+     * 指定人员人脸/指纹权限下载
+     */
+    public static final String DOWNLOAD_FACE_AND_FINGERINFOS = "/openapi/service/acs/auth/downloadFaceAndFingerInfos";
+
+    /**--推送图片时需要获取人员分组下的，人员分组ID
+     * --personGroupId--
+     */
+    public static final  String OP_PERSON_ID="/openapi/service/fas/personGroup/getPersonGroup";
+
+    /**
+     * 分页获取部门
+     */
+    public static final String ITF_DEPT= "/openapi/service/base/dept/getDeptInfos";
+
+    /**
+     * 根据部门名称分页获取部门
+     */
+    public static final String ITF_LIKE_DEPT_NAME = "/openapi/service/base/dept/getDeptInfosByName";
+
+    /**
+     * 添加 人员
+     */
+    public static final String ITF_ADD_USER = "/openapi/service/base/person/addPersonInfo";
+
+
+    /**
+     * 修改人员
+     */
+    public static final String ITF_UPDATE_USER ="/openapi/service/base/person/modifyPersonInfo";
+
+
+    /**
+     * 批量开卡
+     */
+    public static final String ITF_OPEN_CARD = "/openapi/service/base/person/batchOpenCards";
+
+    /**
+     * 根据人员ID集获取人员
+     */
+    public static final String ITF_GET_USER_ID = "/openapi/service/base/person/getPersonInfosByIds";
+    
+    /**
+     * 未预约登记（临时登记）
+     */
+    public static final String TEMPORARY_REGISTER = "/openapi/service/rvs/register/temporaryRegister";
+
+    
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/common/hk/entity/MonitoryPoint.java

@@ -0,0 +1,40 @@
+package com.community.huiju.common.hk.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 响应 监控中心 实体类
+ * @author weiximei
+ */
+@AllArgsConstructor
+@NoArgsConstructor
+@Data
+public class MonitoryPoint {
+
+    private Integer errorCode;
+
+    private String errorMessage;
+
+    private String data;
+
+
+    private class MonitoryPointData {
+        Integer total;
+        Integer pageNo;
+        Integer pageSize;
+        String list;
+
+
+    }
+
+    private class MonitoryPointList {
+
+        String cameraUuid;
+        String cameraName;
+
+    }
+
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/config/HttpSessionConfig.java

@@ -0,0 +1,22 @@
+package com.community.huiju.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.session.MapSession;
+import org.springframework.session.jdbc.config.annotation.web.http.EnableJdbcHttpSession;
+import org.springframework.session.web.http.HeaderHttpSessionIdResolver;
+import org.springframework.session.web.http.HttpSessionIdResolver;
+
+/**
+ * @author weiximei
+ */
+@Configuration
+@EnableJdbcHttpSession(maxInactiveIntervalInSeconds = MapSession.DEFAULT_MAX_INACTIVE_INTERVAL_SECONDS*4)
+public class HttpSessionConfig {
+
+    @Bean
+    public HttpSessionIdResolver httpSessionIdResolver() {
+        return HeaderHttpSessionIdResolver.xAuthToken();
+    }
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/dao/MqMessageMapper.java

@@ -0,0 +1,21 @@
+package com.community.huiju.dao;
+
+import com.community.huiju.model.MqMessage;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface MqMessageMapper {
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(MqMessage record);
+
+    int insertSelective(MqMessage record);
+
+    MqMessage selectByPrimaryKey(Integer id);
+
+    int updateByPrimaryKeySelective(MqMessage record);
+
+    int updateByPrimaryKeyWithBLOBs(MqMessage record);
+
+    int updateByPrimaryKey(MqMessage record);
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/model/MqMessage.java

@@ -0,0 +1,285 @@
+package com.community.huiju.model;
+
+import java.util.Date;
+
+public class MqMessage {
+    private Integer id;
+
+    private Integer eventState;
+
+    private Integer eventLevel;
+
+    private String unitIdx;
+
+    private Integer eventType;
+
+    private String eventTypeName;
+
+    private Integer subSysType;
+
+    private String eventName;
+
+    private Date startTime;
+
+    private Date stopTime;
+
+    private String sourceIdx;
+
+    private Integer sourceType;
+
+    private String sourceName;
+
+    private String regionIdx;
+
+    private Integer eventCode;
+
+    private Integer deviceId;
+
+    private Integer deviceType;
+
+    private String deviceName;
+
+    private String eventCard;
+
+    private Integer personId;
+
+    private String personName;
+
+    private Integer deptId;
+
+    private String deptName;
+
+    private String deptCode;
+
+    private Integer inOut;
+
+    private Integer cardStatus;
+
+    private String picUrl;
+
+    private String extTxt;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getEventState() {
+        return eventState;
+    }
+
+    public void setEventState(Integer eventState) {
+        this.eventState = eventState;
+    }
+
+    public Integer getEventLevel() {
+        return eventLevel;
+    }
+
+    public void setEventLevel(Integer eventLevel) {
+        this.eventLevel = eventLevel;
+    }
+
+    public String getUnitIdx() {
+        return unitIdx;
+    }
+
+    public void setUnitIdx(String unitIdx) {
+        this.unitIdx = unitIdx == null ? null : unitIdx.trim();
+    }
+
+    public Integer getEventType() {
+        return eventType;
+    }
+
+    public void setEventType(Integer eventType) {
+        this.eventType = eventType;
+    }
+
+    public String getEventTypeName() {
+        return eventTypeName;
+    }
+
+    public void setEventTypeName(String eventTypeName) {
+        this.eventTypeName = eventTypeName == null ? null : eventTypeName.trim();
+    }
+
+    public Integer getSubSysType() {
+        return subSysType;
+    }
+
+    public void setSubSysType(Integer subSysType) {
+        this.subSysType = subSysType;
+    }
+
+    public String getEventName() {
+        return eventName;
+    }
+
+    public void setEventName(String eventName) {
+        this.eventName = eventName == null ? null : eventName.trim();
+    }
+
+    public Date getStartTime() {
+        return startTime;
+    }
+
+    public void setStartTime(Date startTime) {
+        this.startTime = startTime;
+    }
+
+    public Date getStopTime() {
+        return stopTime;
+    }
+
+    public void setStopTime(Date stopTime) {
+        this.stopTime = stopTime;
+    }
+
+    public String getSourceIdx() {
+        return sourceIdx;
+    }
+
+    public void setSourceIdx(String sourceIdx) {
+        this.sourceIdx = sourceIdx == null ? null : sourceIdx.trim();
+    }
+
+    public String getSourceName() {
+        return sourceName;
+    }
+
+    public void setSourceName(String sourceName) {
+        this.sourceName = sourceName == null ? null : sourceName.trim();
+    }
+
+    public String getRegionIdx() {
+        return regionIdx;
+    }
+
+    public void setRegionIdx(String regionIdx) {
+        this.regionIdx = regionIdx == null ? null : regionIdx.trim();
+    }
+
+    public Integer getEventCode() {
+        return eventCode;
+    }
+
+    public void setEventCode(Integer eventCode) {
+        this.eventCode = eventCode;
+    }
+
+    public Integer getDeviceId() {
+        return deviceId;
+    }
+
+    public void setDeviceId(Integer deviceId) {
+        this.deviceId = deviceId;
+    }
+
+    public Integer getDeviceType() {
+        return deviceType;
+    }
+
+    public void setDeviceType(Integer deviceType) {
+        this.deviceType = deviceType;
+    }
+
+    public String getDeviceName() {
+        return deviceName;
+    }
+
+    public void setDeviceName(String deviceName) {
+        this.deviceName = deviceName == null ? null : deviceName.trim();
+    }
+
+    public String getEventCard() {
+        return eventCard;
+    }
+
+    public void setEventCard(String eventCard) {
+        this.eventCard = eventCard == null ? null : eventCard.trim();
+    }
+
+    public Integer getPersonId() {
+        return personId;
+    }
+
+    public void setPersonId(Integer personId) {
+        this.personId = personId;
+    }
+
+    public String getPersonName() {
+        return personName;
+    }
+
+    public void setPersonName(String personName) {
+        this.personName = personName == null ? null : personName.trim();
+    }
+
+    public Integer getDeptId() {
+        return deptId;
+    }
+
+    public void setDeptId(Integer deptId) {
+        this.deptId = deptId;
+    }
+
+    public String getDeptName() {
+        return deptName;
+    }
+
+    public void setDeptName(String deptName) {
+        this.deptName = deptName == null ? null : deptName.trim();
+    }
+
+    public String getDeptCode() {
+        return deptCode;
+    }
+
+    public void setDeptCode(String deptCode) {
+        this.deptCode = deptCode == null ? null : deptCode.trim();
+    }
+
+    public Integer getInOut() {
+        return inOut;
+    }
+
+    public void setInOut(Integer inOut) {
+        this.inOut = inOut;
+    }
+
+    public Integer getCardStatus() {
+        return cardStatus;
+    }
+
+    public void setCardStatus(Integer cardStatus) {
+        this.cardStatus = cardStatus;
+    }
+
+    public String getPicUrl() {
+        return picUrl;
+    }
+
+    public void setPicUrl(String picUrl) {
+        this.picUrl = picUrl == null ? null : picUrl.trim();
+    }
+
+    public String getExtTxt() {
+        return extTxt;
+    }
+
+    public void setExtTxt(String extTxt) {
+        this.extTxt = extTxt == null ? null : extTxt.trim();
+    }
+    
+    public Integer getSourceType() {
+        return sourceType;
+    }
+    
+    public void setSourceType(Integer sourceType) {
+        this.sourceType = sourceType;
+    }
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/runner/MqRunner.java

@@ -0,0 +1,84 @@
+package com.community.huiju.runner;
+
+import com.community.huiju.common.hk.code.EventDis;
+import com.community.huiju.service.MqMessageServiceI;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.stereotype.Component;
+
+import javax.jms.BytesMessage;
+import javax.jms.Connection;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageListener;
+import javax.jms.Session;
+import javax.jms.Topic;
+
+/**
+ * @author FXF
+ * @date 2018-11-23
+ */
+@Component
+public class MqRunner implements ApplicationRunner {
+	
+	public static final String BROKER_URL = "failover:(tcp://192.168.0.122:61618)?timeout=2000";
+	
+	public static final String TARGET = "openapi.acs.topic";
+	
+	@Autowired
+	private MqMessageServiceI mqMessageService;
+	
+	@Override
+	public void run(ApplicationArguments args) throws Exception {
+		
+		Connection connection = null;
+		Session session = null;
+		try {
+			// 创建链接工厂
+			ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(BROKER_URL);
+			// 通过工厂创建一个连接
+			connection = factory.createConnection();
+			// factory.createConnection(userName, password)
+			// 启动连接
+			connection.start();
+			// 第一个参数表示是否使用事务，第二个参数指定消息的确认模式
+			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+			Topic topic = session.createTopic(TARGET);
+			MessageConsumer consumer = session.createConsumer(topic);
+			// 消费者异步接收topic里的消息
+			consumer.setMessageListener(new MessageListener() {
+				@Override
+				public void onMessage(Message msg) {
+					try {
+						// cms里发送的消息为BytesMessage，此处不做判断亦可
+						if (msg instanceof BytesMessage) {
+							BytesMessage bytesMessage = (BytesMessage)msg;
+							long length = bytesMessage.getBodyLength();
+							byte[] bt = new byte[(int)length];
+							// 将BytesMessage转换为byte类型
+							bytesMessage.readBytes(bt);
+							// 壳文件字段，EventDis类为event_dis.proto文件解析而来，CommEventLog类为事件壳文件类
+							EventDis.CommEventLog parseFrom = EventDis.CommEventLog.parseFrom(bt);
+							
+							//插入数据库
+							mqMessageService.saveMqMessage(parseFrom);
+							// 输出壳文件字段
+							//System.out.println(parseFrom.toString());
+							// 扩展字段，此字段为设备上报事件内容，部分事件需要使用pb文件再次解析
+							//ByteString extInfo = parseFrom.getExtInfo();
+							// 输出扩展字段
+							//System.out.println("序列化解析：" + AcsEvent.AccessEventLog.parseFrom(extInfo));
+						}
+					} catch (Exception e) {
+						System.out.println("订阅程序出错！");
+						e.printStackTrace();
+					}
+				}
+			});
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+	}
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/service/MqMessageServiceI.java

@@ -0,0 +1,10 @@
+package com.community.huiju.service;
+
+import com.community.huiju.common.hk.code.EventDis;
+import com.google.protobuf.InvalidProtocolBufferException;
+
+import java.text.ParseException;
+
+public interface MqMessageServiceI {
+	void saveMqMessage(EventDis.CommEventLog parseFrom) throws InvalidProtocolBufferException, ParseException;
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/service/impl/MqMessageServiceImpl.java

@@ -0,0 +1,65 @@
+package com.community.huiju.service.impl;
+
+import com.community.huiju.common.hk.code.AcsEvent;
+import com.community.huiju.common.hk.code.EventDis;
+import com.community.huiju.dao.MqMessageMapper;
+import com.community.huiju.model.MqMessage;
+import com.community.huiju.service.MqMessageServiceI;
+import com.google.protobuf.ByteString;
+import com.google.protobuf.InvalidProtocolBufferException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.text.DateFormat;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+
+/**
+ * @author FXF
+ * @date 2018-11-23
+ */
+@Service("mqMessageService")
+public class MqMessageServiceImpl implements MqMessageServiceI {
+	
+	@Autowired
+	private MqMessageMapper mqMessageMapper;
+	
+	@Override
+	public void saveMqMessage(EventDis.CommEventLog parseFrom) throws InvalidProtocolBufferException, ParseException {
+		DateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		ByteString extInfo = parseFrom.getExtInfo();
+		//额外信息
+		AcsEvent.AccessEventLog exitFrom = AcsEvent.AccessEventLog.parseFrom(extInfo);
+		//插入数据库
+		MqMessage mqMessage = new MqMessage();
+		mqMessage.setEventState(parseFrom.getEventState());
+		mqMessage.setEventLevel(parseFrom.getEventLevel());
+		mqMessage.setUnitIdx(parseFrom.getUnitIdx());
+		mqMessage.setEventType(parseFrom.getEventType());
+		mqMessage.setEventTypeName(parseFrom.getEventTypeName());
+		mqMessage.setSubSysType(parseFrom.getSubSysType());
+		mqMessage.setEventName(parseFrom.getEventName());
+		mqMessage.setStartTime(format.parse(parseFrom.getStartTime()));
+		mqMessage.setStopTime(format.parse(parseFrom.getStopTime()));
+		mqMessage.setSourceIdx(parseFrom.getSourceIdx());
+		mqMessage.setSourceType(parseFrom.getSourceType());
+		mqMessage.setSourceName(parseFrom.getSourceName());
+		mqMessage.setRegionIdx(parseFrom.getRegionIdx());
+		mqMessage.setEventCode(exitFrom.getEventCode());
+		mqMessage.setDeviceId(exitFrom.getDeviceId());
+		mqMessage.setDeviceType(exitFrom.getDeviceType());
+		mqMessage.setDeviceName(exitFrom.getDeviceName());
+		mqMessage.setEventCard(exitFrom.getEventCard());
+		mqMessage.setPersonId(exitFrom.getPersonId());
+		mqMessage.setPersonName(exitFrom.getPersonName());
+		mqMessage.setDeptId(exitFrom.getDeptId());
+		mqMessage.setDeptName(exitFrom.getDeptName());
+		mqMessage.setDeptCode(exitFrom.getDeptCode());
+		mqMessage.setInOut(exitFrom.getInOut());
+		mqMessage.setExtTxt(exitFrom.getExtTxt());
+		mqMessage.setCardStatus(exitFrom.getCardStatus());
+		mqMessage.setPicUrl(exitFrom.getPicUrl());
+		//插入mq_message
+		mqMessageMapper.insertSelective(mqMessage);
+	}
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/vo/TaUserVO.java

@@ -0,0 +1,61 @@
+package com.community.huiju.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * 用户数据
+ * @author weiximei
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class TaUserVO {
+
+    /** 编号 **/
+    private Integer id;
+
+    /** 小区编号 **/
+    private Integer communityId;
+
+    /** 头像 **/
+    private String headPortrait;
+
+    /** 用户名 **/
+    private String userName;
+
+    /** 登录名 **/
+    private String loginName;
+
+    /** 邮箱 **/
+    private String email;
+
+    /** 性别 **/
+    private String gender;
+
+    /** 认证状态 **/
+    private String verifyStatus;
+
+    /** 角色 **/
+    private String role;
+
+    /** 用户状态 **/
+    private String status;
+
+    /** 用户token **/
+    private String token;
+
+    /** 地址省市区 **/
+    private String addressProvince;
+
+    /** 小区名 **/
+    private String communityName;
+
+    /** 楼栋单元号 **/
+    private String addressBuilding;
+
+    /** 人脸录入 **/
+    private String face;
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/vo/TpTicketInfoVO.java

@@ -0,0 +1,36 @@
+package com.community.huiju.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * 工单不包含所有的 答复 记录
+ * 只包含最新的 答复和答复时间
+ * @author weiximei
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class TpTicketInfoVO extends TpTicketVO {
+
+
+    /** 工单内容 **/
+    private String ticketContent;
+
+    /** 流转状态 **/
+    private String status;
+
+    /** 报修类型 0:公共区域  1: 房屋质量  2::户内设施   **/
+    private String repairType;
+
+    /** 评分 **/
+    private String score;
+
+    /** 评语 **/
+    private String comment;
+
+
+}

CODE/smart-community/mq-message/src/main/java/com/community/huiju/vo/TpTicketVO.java

@@ -0,0 +1,63 @@
+package com.community.huiju.vo;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * 工单列表数据
+ * @author weiximei
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class TpTicketVO {
+
+    /** 编号 **/
+    private Integer id;
+
+    /** 小区编号 **/
+    private Integer communityId;
+
+    /** 用户app的id **/
+    private Integer taUserId;
+
+    /** ================================ **/
+
+    /** 工单标题 **/
+    private String ticketTitle;
+
+    /** 类型 报修/投诉/联系单 **/
+    private String type;
+
+    /** 受理人的id **/
+    private Integer tpUserId;
+
+    private Date createDate;
+
+    private Date updateDate;
+
+    /** 报修类型：0:公共区域  1: 房屋质量  2::户内设施  PS : 报修的情况下才有报修类型  **/
+    private String repairType;
+
+    /**
+     * 报修类型的名字
+     */
+    private String repairName;
+
+    /** ====================================== **/
+
+    /** 流程状态 **/
+    private String status;
+
+    /** 流程状态名称 **/
+    private String ticketStatusName;
+
+    /** 最新进展 **/
+    private String commentContent;
+
+    /** 最新进展的时间 **/
+    private Date commentCreateDate;
+}

CODE/smart-community/mq-message/src/main/resources/application.yml

@@ -0,0 +1,21 @@
+management:
+  endpoints:
+    web:
+      exposure:
+        include: refresh,health,info
+## Mybatis
+mybatis:
+  typeAliasesPackage: com.community.huiju.model
+  mapperLocations: classpath:mapper/*.xml
+  configuration:
+    call-setters-on-nulls: true
+# 分页配置
+pagehelper:
+  helper-dialect: mysql
+  reasonable: true
+  support-methods-arguments: true
+  params: count=countSql
+# 打印sql
+logging:
+  level:
+    com.community.huiju.dao: debug

CODE/smart-community/mq-message/src/main/resources/bootstrap.yml

@@ -0,0 +1,24 @@
+server:
+  port: 8087
+spring:
+  application:
+    name: mq-meaasge
+  cloud:
+    config:
+      name: application
+      profile: dev
+      label: master
+      discovery:
+        enabled: true
+        serviceId: config-server
+  session:
+    store-type: jdbc
+  servlet:
+    multipart:
+      max-file-size: 10MB
+      max-request-size: 50MB
+eureka:
+  client:
+    service-url:
+      defaultZone: http://localhost:8080/eureka/
+

CODE/smart-community/mq-message/src/main/resources/log4j.properties

@@ -0,0 +1,31 @@
+log4j.rootLogger=info,A1,R
+log4j.appender.A1=org.apache.log4j.ConsoleAppender
+log4j.appender.A1.Target=System.out
+log4j.appender.A1.layout=org.apache.log4j.PatternLayout
+log4j.appender.A1.layout.ConversionPattern=%-5p%x [%t] %d - %c %m%n  
+
+log4j.appender.R=org.apache.log4j.DailyRollingFileAppender
+log4j.appender.R.File=../logs/resold_admin_.log
+log4j.appender.R.layout=org.apache.log4j.PatternLayout
+log4j.appender.R.Append = true
+log4j.appender.R.ImmediateFlush = true
+log4j.appender.R.DatePattern = '.' yyyy - MM - dd '.txt'
+log4j.appender.R.layout.ConversionPattern=%-5p%x [%t] %d -%c %m%n
+
+#log4j.logger.com.ibatis=DEBUG
+log4j.logger.org.springframework.transaction.support.TransactionSynchronizationManager = INFO
+log4j.logger.java.sql.Connection=DEBUG
+log4j.logger.java.sql.Statement=DEBUG
+log4j.logger.java.sql.PreparedStatement=DEBUG
+
+###############Log4j 4 SQL Output start################# #DEBUG
+log4j.logger.com.**.dao=INFO
+log4j.logger.com.springframework=DEBUG
+log4j.logger.com.ibatis=DEBUG  
+log4j.logger.com.ibatis.common.jdbc.SimpleDataSource=DEBUG  
+log4j.logger.com.ibatis.common.jdbc.ScriptRunner=DEBUG  
+log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate=DEBUG
+log4j.logger.java.sql.ResultSet=DEBUG
+log4j.logger.org.apache.ibatis.logging.commons.JakartaCommonsLoggingImpl=DEBUG
+log4j.logger.java.sql=DEBUG,CONSOLE 
+###############Log4j 4 SQL Output end###################

CODE/smart-community/mq-message/src/main/resources/mapper/MqMessageMapper.xml

@@ -0,0 +1,402 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
+<mapper namespace="com.community.huiju.dao.MqMessageMapper" >
+  <resultMap id="BaseResultMap" type="com.community.huiju.model.MqMessage" >
+    <id column="id" property="id" jdbcType="INTEGER" />
+    <result column="event_state" property="eventState" jdbcType="INTEGER" />
+    <result column="event_level" property="eventLevel" jdbcType="INTEGER" />
+    <result column="unit_idx" property="unitIdx" jdbcType="VARCHAR" />
+    <result column="event_type" property="eventType" jdbcType="INTEGER" />
+    <result column="event_type_name" property="eventTypeName" jdbcType="VARCHAR" />
+    <result column="sub_sys_type" property="subSysType" jdbcType="INTEGER" />
+    <result column="event_name" property="eventName" jdbcType="VARCHAR" />
+    <result column="start_time" property="startTime" jdbcType="TIMESTAMP" />
+    <result column="stop_time" property="stopTime" jdbcType="TIMESTAMP" />
+    <result column="source_idx" property="sourceIdx" jdbcType="CHAR" />
+    <result column="source_type" property="sourceType" jdbcType="INTEGER" />
+    <result column="source_name" property="sourceName" jdbcType="VARCHAR" />
+    <result column="region_idx" property="regionIdx" jdbcType="VARCHAR" />
+    <result column="event_code" property="eventCode" jdbcType="INTEGER" />
+    <result column="device_id" property="deviceId" jdbcType="INTEGER" />
+    <result column="device_type" property="deviceType" jdbcType="INTEGER" />
+    <result column="device_name" property="deviceName" jdbcType="VARCHAR" />
+    <result column="event_card" property="eventCard" jdbcType="VARCHAR" />
+    <result column="person_id" property="personId" jdbcType="INTEGER" />
+    <result column="person_name" property="personName" jdbcType="VARCHAR" />
+    <result column="dept_id" property="deptId" jdbcType="INTEGER" />
+    <result column="dept_name" property="deptName" jdbcType="VARCHAR" />
+    <result column="dept_code" property="deptCode" jdbcType="VARCHAR" />
+    <result column="in_out" property="inOut" jdbcType="INTEGER" />
+    <result column="card_status" property="cardStatus" jdbcType="INTEGER" />
+    <result column="pic_url" property="picUrl" jdbcType="VARCHAR" />
+  </resultMap>
+  <resultMap id="ResultMapWithBLOBs" type="com.community.huiju.model.MqMessage" extends="BaseResultMap" >
+    <result column="ext_txt" property="extTxt" jdbcType="LONGVARCHAR" />
+  </resultMap>
+  <sql id="Base_Column_List" >
+    id, event_state, event_level, unit_idx, event_type, event_type_name, sub_sys_type, 
+    event_name, start_time, stop_time, source_idx, source_type, source_name, region_idx, 
+    event_code, device_id, device_type, device_name, event_card, person_id, person_name, 
+    dept_id, dept_name, dept_code, in_out, card_status, pic_url
+  </sql>
+  <sql id="Blob_Column_List" >
+    ext_txt
+  </sql>
+  <select id="selectByPrimaryKey" resultMap="ResultMapWithBLOBs" parameterType="java.lang.Integer" >
+    select 
+    <include refid="Base_Column_List" />
+    ,
+    <include refid="Blob_Column_List" />
+    from mq_message
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
+    delete from mq_message
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.community.huiju.model.MqMessage" >
+    insert into mq_message (id, event_state, event_level, 
+      unit_idx, event_type, event_type_name, 
+      sub_sys_type, event_name, start_time, 
+      stop_time, source_idx, source_type, 
+      source_name, region_idx, event_code, 
+      device_id, device_type, device_name, 
+      event_card, person_id, person_name, 
+      dept_id, dept_name, dept_code, 
+      in_out, card_status, pic_url, 
+      ext_txt)
+    values (#{id,jdbcType=INTEGER}, #{eventState,jdbcType=INTEGER}, #{eventLevel,jdbcType=INTEGER}, 
+      #{unitIdx,jdbcType=VARCHAR}, #{eventType,jdbcType=INTEGER}, #{eventTypeName,jdbcType=VARCHAR}, 
+      #{subSysType,jdbcType=INTEGER}, #{eventName,jdbcType=VARCHAR}, #{startTime,jdbcType=TIMESTAMP}, 
+      #{stopTime,jdbcType=TIMESTAMP}, #{sourceIdx,jdbcType=CHAR}, #{sourceType,jdbcType=INTEGER},
+      #{sourceName,jdbcType=VARCHAR}, #{regionIdx,jdbcType=VARCHAR}, #{eventCode,jdbcType=INTEGER}, 
+      #{deviceId,jdbcType=INTEGER}, #{deviceType,jdbcType=INTEGER}, #{deviceName,jdbcType=VARCHAR}, 
+      #{eventCard,jdbcType=VARCHAR}, #{personId,jdbcType=INTEGER}, #{personName,jdbcType=VARCHAR}, 
+      #{deptId,jdbcType=INTEGER}, #{deptName,jdbcType=VARCHAR}, #{deptCode,jdbcType=VARCHAR}, 
+      #{inOut,jdbcType=INTEGER}, #{cardStatus,jdbcType=INTEGER}, #{picUrl,jdbcType=VARCHAR}, 
+      #{extTxt,jdbcType=LONGVARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.community.huiju.model.MqMessage" >
+    insert into mq_message
+    <trim prefix="(" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        id,
+      </if>
+      <if test="eventState != null" >
+        event_state,
+      </if>
+      <if test="eventLevel != null" >
+        event_level,
+      </if>
+      <if test="unitIdx != null" >
+        unit_idx,
+      </if>
+      <if test="eventType != null" >
+        event_type,
+      </if>
+      <if test="eventTypeName != null" >
+        event_type_name,
+      </if>
+      <if test="subSysType != null" >
+        sub_sys_type,
+      </if>
+      <if test="eventName != null" >
+        event_name,
+      </if>
+      <if test="startTime != null" >
+        start_time,
+      </if>
+      <if test="stopTime != null" >
+        stop_time,
+      </if>
+      <if test="sourceIdx != null" >
+        source_idx,
+      </if>
+      <if test="sourceType != null" >
+        source_type,
+      </if>
+      <if test="sourceName != null" >
+        source_name,
+      </if>
+      <if test="regionIdx != null" >
+        region_idx,
+      </if>
+      <if test="eventCode != null" >
+        event_code,
+      </if>
+      <if test="deviceId != null" >
+        device_id,
+      </if>
+      <if test="deviceType != null" >
+        device_type,
+      </if>
+      <if test="deviceName != null" >
+        device_name,
+      </if>
+      <if test="eventCard != null" >
+        event_card,
+      </if>
+      <if test="personId != null" >
+        person_id,
+      </if>
+      <if test="personName != null" >
+        person_name,
+      </if>
+      <if test="deptId != null" >
+        dept_id,
+      </if>
+      <if test="deptName != null" >
+        dept_name,
+      </if>
+      <if test="deptCode != null" >
+        dept_code,
+      </if>
+      <if test="inOut != null" >
+        in_out,
+      </if>
+      <if test="cardStatus != null" >
+        card_status,
+      </if>
+      <if test="picUrl != null" >
+        pic_url,
+      </if>
+      <if test="extTxt != null" >
+        ext_txt,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="eventState != null" >
+        #{eventState,jdbcType=INTEGER},
+      </if>
+      <if test="eventLevel != null" >
+        #{eventLevel,jdbcType=INTEGER},
+      </if>
+      <if test="unitIdx != null" >
+        #{unitIdx,jdbcType=VARCHAR},
+      </if>
+      <if test="eventType != null" >
+        #{eventType,jdbcType=INTEGER},
+      </if>
+      <if test="eventTypeName != null" >
+        #{eventTypeName,jdbcType=VARCHAR},
+      </if>
+      <if test="subSysType != null" >
+        #{subSysType,jdbcType=INTEGER},
+      </if>
+      <if test="eventName != null" >
+        #{eventName,jdbcType=VARCHAR},
+      </if>
+      <if test="startTime != null" >
+        #{startTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="stopTime != null" >
+        #{stopTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="sourceIdx != null" >
+        #{sourceIdx,jdbcType=CHAR},
+      </if>
+      <if test="sourceType != null" >
+        #{sourceType,jdbcType=INTEGER},
+      </if>
+      <if test="sourceName != null" >
+        #{sourceName,jdbcType=VARCHAR},
+      </if>
+      <if test="regionIdx != null" >
+        #{regionIdx,jdbcType=VARCHAR},
+      </if>
+      <if test="eventCode != null" >
+        #{eventCode,jdbcType=INTEGER},
+      </if>
+      <if test="deviceId != null" >
+        #{deviceId,jdbcType=INTEGER},
+      </if>
+      <if test="deviceType != null" >
+        #{deviceType,jdbcType=INTEGER},
+      </if>
+      <if test="deviceName != null" >
+        #{deviceName,jdbcType=VARCHAR},
+      </if>
+      <if test="eventCard != null" >
+        #{eventCard,jdbcType=VARCHAR},
+      </if>
+      <if test="personId != null" >
+        #{personId,jdbcType=INTEGER},
+      </if>
+      <if test="personName != null" >
+        #{personName,jdbcType=VARCHAR},
+      </if>
+      <if test="deptId != null" >
+        #{deptId,jdbcType=INTEGER},
+      </if>
+      <if test="deptName != null" >
+        #{deptName,jdbcType=VARCHAR},
+      </if>
+      <if test="deptCode != null" >
+        #{deptCode,jdbcType=VARCHAR},
+      </if>
+      <if test="inOut != null" >
+        #{inOut,jdbcType=INTEGER},
+      </if>
+      <if test="cardStatus != null" >
+        #{cardStatus,jdbcType=INTEGER},
+      </if>
+      <if test="picUrl != null" >
+        #{picUrl,jdbcType=VARCHAR},
+      </if>
+      <if test="extTxt != null" >
+        #{extTxt,jdbcType=LONGVARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByPrimaryKeySelective" parameterType="com.community.huiju.model.MqMessage" >
+    update mq_message
+    <set >
+      <if test="eventState != null" >
+        event_state = #{eventState,jdbcType=INTEGER},
+      </if>
+      <if test="eventLevel != null" >
+        event_level = #{eventLevel,jdbcType=INTEGER},
+      </if>
+      <if test="unitIdx != null" >
+        unit_idx = #{unitIdx,jdbcType=VARCHAR},
+      </if>
+      <if test="eventType != null" >
+        event_type = #{eventType,jdbcType=INTEGER},
+      </if>
+      <if test="eventTypeName != null" >
+        event_type_name = #{eventTypeName,jdbcType=VARCHAR},
+      </if>
+      <if test="subSysType != null" >
+        sub_sys_type = #{subSysType,jdbcType=INTEGER},
+      </if>
+      <if test="eventName != null" >
+        event_name = #{eventName,jdbcType=VARCHAR},
+      </if>
+      <if test="startTime != null" >
+        start_time = #{startTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="stopTime != null" >
+        stop_time = #{stopTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="sourceIdx != null" >
+        source_idx = #{sourceIdx,jdbcType=CHAR},
+      </if>
+      <if test="sourceType != null" >
+        source_type = #{sourceType,jdbcType=INTEGER},
+      </if>
+      <if test="sourceName != null" >
+        source_name = #{sourceName,jdbcType=VARCHAR},
+      </if>
+      <if test="regionIdx != null" >
+        region_idx = #{regionIdx,jdbcType=VARCHAR},
+      </if>
+      <if test="eventCode != null" >
+        event_code = #{eventCode,jdbcType=INTEGER},
+      </if>
+      <if test="deviceId != null" >
+        device_id = #{deviceId,jdbcType=INTEGER},
+      </if>
+      <if test="deviceType != null" >
+        device_type = #{deviceType,jdbcType=INTEGER},
+      </if>
+      <if test="deviceName != null" >
+        device_name = #{deviceName,jdbcType=VARCHAR},
+      </if>
+      <if test="eventCard != null" >
+        event_card = #{eventCard,jdbcType=VARCHAR},
+      </if>
+      <if test="personId != null" >
+        person_id = #{personId,jdbcType=INTEGER},
+      </if>
+      <if test="personName != null" >
+        person_name = #{personName,jdbcType=VARCHAR},
+      </if>
+      <if test="deptId != null" >
+        dept_id = #{deptId,jdbcType=INTEGER},
+      </if>
+      <if test="deptName != null" >
+        dept_name = #{deptName,jdbcType=VARCHAR},
+      </if>
+      <if test="deptCode != null" >
+        dept_code = #{deptCode,jdbcType=VARCHAR},
+      </if>
+      <if test="inOut != null" >
+        in_out = #{inOut,jdbcType=INTEGER},
+      </if>
+      <if test="cardStatus != null" >
+        card_status = #{cardStatus,jdbcType=INTEGER},
+      </if>
+      <if test="picUrl != null" >
+        pic_url = #{picUrl,jdbcType=VARCHAR},
+      </if>
+      <if test="extTxt != null" >
+        ext_txt = #{extTxt,jdbcType=LONGVARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKeyWithBLOBs" parameterType="com.community.huiju.model.MqMessage" >
+    update mq_message
+    set event_state = #{eventState,jdbcType=INTEGER},
+      event_level = #{eventLevel,jdbcType=INTEGER},
+      unit_idx = #{unitIdx,jdbcType=VARCHAR},
+      event_type = #{eventType,jdbcType=INTEGER},
+      event_type_name = #{eventTypeName,jdbcType=VARCHAR},
+      sub_sys_type = #{subSysType,jdbcType=INTEGER},
+      event_name = #{eventName,jdbcType=VARCHAR},
+      start_time = #{startTime,jdbcType=TIMESTAMP},
+      stop_time = #{stopTime,jdbcType=TIMESTAMP},
+      source_idx = #{sourceIdx,jdbcType=CHAR},
+      source_type = #{sourceType,jdbcType=INTEGER},
+      source_name = #{sourceName,jdbcType=VARCHAR},
+      region_idx = #{regionIdx,jdbcType=VARCHAR},
+      event_code = #{eventCode,jdbcType=INTEGER},
+      device_id = #{deviceId,jdbcType=INTEGER},
+      device_type = #{deviceType,jdbcType=INTEGER},
+      device_name = #{deviceName,jdbcType=VARCHAR},
+      event_card = #{eventCard,jdbcType=VARCHAR},
+      person_id = #{personId,jdbcType=INTEGER},
+      person_name = #{personName,jdbcType=VARCHAR},
+      dept_id = #{deptId,jdbcType=INTEGER},
+      dept_name = #{deptName,jdbcType=VARCHAR},
+      dept_code = #{deptCode,jdbcType=VARCHAR},
+      in_out = #{inOut,jdbcType=INTEGER},
+      card_status = #{cardStatus,jdbcType=INTEGER},
+      pic_url = #{picUrl,jdbcType=VARCHAR},
+      ext_txt = #{extTxt,jdbcType=LONGVARCHAR}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.community.huiju.model.MqMessage" >
+    update mq_message
+    set event_state = #{eventState,jdbcType=INTEGER},
+      event_level = #{eventLevel,jdbcType=INTEGER},
+      unit_idx = #{unitIdx,jdbcType=VARCHAR},
+      event_type = #{eventType,jdbcType=INTEGER},
+      event_type_name = #{eventTypeName,jdbcType=VARCHAR},
+      sub_sys_type = #{subSysType,jdbcType=INTEGER},
+      event_name = #{eventName,jdbcType=VARCHAR},
+      start_time = #{startTime,jdbcType=TIMESTAMP},
+      stop_time = #{stopTime,jdbcType=TIMESTAMP},
+      source_idx = #{sourceIdx,jdbcType=CHAR},
+      source_type = #{sourceType,jdbcType=INTEGER},
+      source_name = #{sourceName,jdbcType=VARCHAR},
+      region_idx = #{regionIdx,jdbcType=VARCHAR},
+      event_code = #{eventCode,jdbcType=INTEGER},
+      device_id = #{deviceId,jdbcType=INTEGER},
+      device_type = #{deviceType,jdbcType=INTEGER},
+      device_name = #{deviceName,jdbcType=VARCHAR},
+      event_card = #{eventCard,jdbcType=VARCHAR},
+      person_id = #{personId,jdbcType=INTEGER},
+      person_name = #{personName,jdbcType=VARCHAR},
+      dept_id = #{deptId,jdbcType=INTEGER},
+      dept_name = #{deptName,jdbcType=VARCHAR},
+      dept_code = #{deptCode,jdbcType=VARCHAR},
+      in_out = #{inOut,jdbcType=INTEGER},
+      card_status = #{cardStatus,jdbcType=INTEGER},
+      pic_url = #{picUrl,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+</mapper>

CODE/smart-community/pom.xml

@@ -15,6 +15,7 @@
 		<module>eureka-sever</module>
 		<module>zuul</module>
 		<module>operate-api</module>
+		<module>mq-message</module>
         <module>community-common</module>
     </modules>
 

文档/MYSQL/smartCommunity.pdb

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<?PowerDesigner AppLocale="UTF16" ID="{1EFA7B8F-E5BE-422B-A0AE-B907AA87924F}" Label="" LastModificationDate="1542953140" Name="smartCommunity" Objects="697" Symbols="79" Target="MySQL 5.0" Type="{CDE44E21-9669-11D1-9914-006097355D9B}" signature="PDM_DATA_MODEL_XML" version="16.5.0.3982"?>
+<?PowerDesigner AppLocale="UTF16" ID="{1EFA7B8F-E5BE-422B-A0AE-B907AA87924F}" Label="" LastModificationDate="1542960175" Name="smartCommunity" Objects="686" Symbols="79" Target="MySQL 5.0" Type="{CDE44E21-9669-11D1-9914-006097355D9B}" signature="PDM_DATA_MODEL_XML" version="16.5.0.3982"?>
 <!-- do not edit this file -->
 
 <Model xmlns:a="attribute" xmlns:c="collection" xmlns:o="object">
@@ -12262,11 +12262,11 @@ LABL 0 新宋体,8,N</a:FontList>
 </o:Table>
 <o:Table Id="o162">
 <a:ObjectID>DA8BCB49-B53D-4292-8F74-53A643DB2C6C</a:ObjectID>
-<a:Name>mq_messa</a:Name>
-<a:Code>mq_messa</a:Code>
+<a:Name>mq_message</a:Name>
+<a:Code>mq_message</a:Code>
 <a:CreationDate>1542952019</a:CreationDate>
 <a:Creator>szc</a:Creator>
-<a:ModificationDate>1542953140</a:ModificationDate>
+<a:ModificationDate>1542957441</a:ModificationDate>
 <a:Modifier>szc</a:Modifier>
 <a:Comment>消息订阅消息表</a:Comment>
 <a:TotalSavingCurrency/>
@@ -12387,8 +12387,10 @@ LABL 0 新宋体,8,N</a:FontList>
 <a:Code>source_idx</a:Code>
 <a:CreationDate>1542952568</a:CreationDate>
 <a:Creator>szc</a:Creator>
-<a:ModificationDate>1542953140</a:ModificationDate>
+<a:ModificationDate>1542960175</a:ModificationDate>
 <a:Modifier>szc</a:Modifier>
+<a:DataType>varchar(255)</a:DataType>
+<a:Length>255</a:Length>
 </o:Column>
 <o:Column Id="o625">
 <a:ObjectID>5DA158D3-6F7D-4D03-8D78-C3D556CB6AC5</a:ObjectID>
@@ -12396,10 +12398,10 @@ LABL 0 新宋体,8,N</a:FontList>
 <a:Code>source_type</a:Code>
 <a:CreationDate>1542952568</a:CreationDate>
 <a:Creator>szc</a:Creator>
-<a:ModificationDate>1542953140</a:ModificationDate>
+<a:ModificationDate>1542959578</a:ModificationDate>
 <a:Modifier>szc</a:Modifier>
-<a:DataType>varchar(255)</a:DataType>
-<a:Length>255</a:Length>
+<a:DataType>int(90)</a:DataType>
+<a:Length>90</a:Length>
 </o:Column>
 <o:Column Id="o626">
 <a:ObjectID>3D617607-AAB2-4D24-8C28-578B3FBC4917</a:ObjectID>

文档/MYSQL/smartCommunity.pdm

@@ -1,5 +1,5 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<?PowerDesigner AppLocale="UTF16" ID="{1EFA7B8F-E5BE-422B-A0AE-B907AA87924F}" Label="" LastModificationDate="1542953140" Name="smartCommunity" Objects="697" Symbols="79" Target="MySQL 5.0" Type="{CDE44E21-9669-11D1-9914-006097355D9B}" signature="PDM_DATA_MODEL_XML" version="16.5.0.3982"?>
+<?PowerDesigner AppLocale="UTF16" ID="{1EFA7B8F-E5BE-422B-A0AE-B907AA87924F}" Label="" LastModificationDate="1542960175" Name="smartCommunity" Objects="686" Symbols="79" Target="MySQL 5.0" Type="{CDE44E21-9669-11D1-9914-006097355D9B}" signature="PDM_DATA_MODEL_XML" version="16.5.0.3982"?>
 <!-- do not edit this file -->
 
 <Model xmlns:a="attribute" xmlns:c="collection" xmlns:o="object">
@@ -12262,11 +12262,11 @@ LABL 0 新宋体,8,N</a:FontList>
 </o:Table>
 <o:Table Id="o162">
 <a:ObjectID>DA8BCB49-B53D-4292-8F74-53A643DB2C6C</a:ObjectID>
-<a:Name>mq_messa</a:Name>
-<a:Code>mq_messa</a:Code>
+<a:Name>mq_message</a:Name>
+<a:Code>mq_message</a:Code>
 <a:CreationDate>1542952019</a:CreationDate>
 <a:Creator>szc</a:Creator>
-<a:ModificationDate>1542953140</a:ModificationDate>
+<a:ModificationDate>1542957441</a:ModificationDate>
 <a:Modifier>szc</a:Modifier>
 <a:Comment>消息订阅消息表</a:Comment>
 <a:TotalSavingCurrency/>
@@ -12387,8 +12387,10 @@ LABL 0 新宋体,8,N</a:FontList>
 <a:Code>source_idx</a:Code>
 <a:CreationDate>1542952568</a:CreationDate>
 <a:Creator>szc</a:Creator>
-<a:ModificationDate>1542953140</a:ModificationDate>
+<a:ModificationDate>1542960175</a:ModificationDate>
 <a:Modifier>szc</a:Modifier>
+<a:DataType>varchar(255)</a:DataType>
+<a:Length>255</a:Length>
 </o:Column>
 <o:Column Id="o625">
 <a:ObjectID>5DA158D3-6F7D-4D03-8D78-C3D556CB6AC5</a:ObjectID>
@@ -12396,10 +12398,10 @@ LABL 0 新宋体,8,N</a:FontList>
 <a:Code>source_type</a:Code>
 <a:CreationDate>1542952568</a:CreationDate>
 <a:Creator>szc</a:Creator>
-<a:ModificationDate>1542953140</a:ModificationDate>
+<a:ModificationDate>1542959578</a:ModificationDate>
 <a:Modifier>szc</a:Modifier>
-<a:DataType>varchar(255)</a:DataType>
-<a:Length>255</a:Length>
+<a:DataType>int(90)</a:DataType>
+<a:Length>90</a:Length>
 </o:Column>
 <o:Column Id="o626">
 <a:ObjectID>3D617607-AAB2-4D24-8C28-578B3FBC4917</a:ObjectID>