Initial commit

.dockerignore

+*
+!build/*-runner
+!build/*-runner.jar
+!build/lib/*
+!build/quarkus-app/*
\ No newline at end of file

.gitignore

+# Gradle
+.gradle/
+build/
+
+# Eclipse
+.project
+.classpath
+.settings/
+bin/
+
+# IntelliJ
+.idea
+*.ipr
+*.iml
+*.iws
+
+# NetBeans
+nb-configuration.xml
+
+# Visual Studio Code
+.vscode
+.factorypath
+
+# OSX
+.DS_Store
+
+# Vim
+*.swp
+*.swo
+
+# patch
+*.orig
+*.rej
+
+# Local environment
+.env
+
+# Plugin directory
+/.quarkus/cli/plugins/
+# TLS Certificates
+.certs/

build.gradle.kts

+plugins {
+    java
+    id("io.quarkus")
+}
+
+repositories {
+    mavenCentral()
+    mavenLocal()
+}
+
+val quarkusPlatformGroupId: String by project
+val quarkusPlatformArtifactId: String by project
+val quarkusPlatformVersion: String by project
+
+dependencies {
+    implementation(enforcedPlatform("${quarkusPlatformGroupId}:${quarkusPlatformArtifactId}:${quarkusPlatformVersion}"))
+    implementation("io.quarkus:quarkus-resteasy-reactive")
+    implementation("io.quarkus:quarkus-resteasy-reactive-jackson")
+    implementation("io.quarkus:quarkus-config-yaml")
+    implementation("io.quarkus:quarkus-jdbc-mysql")
+    implementation("io.quarkus:quarkus-arc")
+    implementation("io.quarkiverse.mybatis:quarkus-mybatis-plus:2.2.4") {
+        exclude(group = "org.springframework")
+    }
+    implementation("com.gitee.Jmysy:binlog4j-core:1.9.1")
+    testImplementation("io.quarkus:quarkus-junit5")
+    testImplementation("io.rest-assured:rest-assured")
+}
+
+group = "com.eazytec.hkydatabasessynchronization"
+version = "1.0-SNAPSHOT"
+
+java {
+    sourceCompatibility = JavaVersion.VERSION_21
+    targetCompatibility = JavaVersion.VERSION_21
+}
+
+tasks.withType<Test> {
+    systemProperty("java.util.logging.manager", "org.jboss.logmanager.LogManager")
+}
+tasks.withType<JavaCompile> {
+    options.encoding = "UTF-8"
+    options.compilerArgs.add("-parameters")
+}

build.sh

+#! /bin/sh
+
+### variable
+TARGET=digital-hky-database-synchronization
+PROJECT=yimatong
+DOCKER_HOST=hub.eazytec-cloud.com
+DOCKER_USER=eazytec
+DOCKER_PWD=Eazytec2023
+
+
+echo "*****[Info]***** package..."
+
+## docker build
+echo "*****[Info]***** docker build..."
+docker build -f src/main/docker/Dockerfile.legacy-jar -t $TARGET:latest .
+found_image_cout=$(docker images | grep $TARGET | wc -l)
+if [[ $? -ne 0 ]] || [[ $found_image_cout -lt 1 ]]; then
+    echo "*****[Error]***** docker build failed!"
+    exit -1
+else
+    echo "*****[Info]***** docker build succeeded!"
+fi
+
+
+## docker login
+docker login -p $DOCKER_PWD -u $DOCKER_USER $DOCKER_HOST
+
+if [[ $? -ne 0 ]]; then
+    echo "*****[Error]***** docker login failed!"
+    exit -1
+else
+    echo "*****[Info]***** docker login succeeded!"
+fi
+
+
+## docker tag
+docker tag $TARGET $DOCKER_HOST/$PROJECT/$TARGET:latest
+
+
+## docker push
+echo "*****[Info]***** docker pushing ..."
+echo "docker push $DOCKER_HOST/$PROJECT/$TARGET"
+docker push $DOCKER_HOST/$PROJECT/$TARGET
+if [[ $? -ne 0 ]]; then
+    echo "*****[Error]***** docker push failed!"
+    exit -1
+else
+    echo "*****[Info]***** docker push succeeded!"
+fi
+
+echo "*****[Info]***** build succeeded!"
+

gradle.properties

+# Gradle properties
+quarkusPluginId=io.quarkus
+quarkusPluginVersion=3.15.1
+quarkusPlatformGroupId=io.quarkus.platform
+quarkusPlatformArtifactId=quarkus-bom
+quarkusPlatformVersion=3.15.1

gradle/wrapper/gradle-wrapper.properties

+distributionBase=GRADLE_USER_HOME
+distributionPath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.9-bin.zip
+zipStoreBase=GRADLE_USER_HOME
+zipStorePath=wrapper/dists

gradlew

+#!/usr/bin/env sh
+
+#
+# Copyright 2015 the original author or authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      https://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+##############################################################################
+##
+##  Gradle start up script for UN*X
+##
+##############################################################################
+
+# Attempt to set APP_HOME
+# Resolve links: $0 may be a link
+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
+SAVED="`pwd`"
+cd "`dirname \"$PRG\"`/" >/dev/null
+APP_HOME="`pwd -P`"
+cd "$SAVED" >/dev/null
+
+APP_NAME="Gradle"
+APP_BASE_NAME=`basename "$0"`
+
+# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"'
+
+# Use the maximum available, or set MAX_FD != -1 to use that value.
+MAX_FD="maximum"
+
+warn () {
+    echo "$*"
+}
+
+die () {
+    echo
+    echo "$*"
+    echo
+    exit 1
+}
+
+# OS specific support (must be 'true' or 'false').
+cygwin=false
+msys=false
+darwin=false
+nonstop=false
+case "`uname`" in
+  CYGWIN* )
+    cygwin=true
+    ;;
+  Darwin* )
+    darwin=true
+    ;;
+  MINGW* )
+    msys=true
+    ;;
+  NONSTOP* )
+    nonstop=true
+    ;;
+esac
+
+CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar
+
+
+# Determine the Java command to use to start the JVM.
+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
+    if [ ! -x "$JAVACMD" ] ; then
+        die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+    fi
+else
+    JAVACMD="java"
+    which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+
+Please set the JAVA_HOME variable in your environment to match the
+location of your Java installation."
+fi
+
+# Increase the maximum file descriptors if we can.
+if [ "$cygwin" = "false" -a "$darwin" = "false" -a "$nonstop" = "false" ] ; then
+    MAX_FD_LIMIT=`ulimit -H -n`
+    if [ $? -eq 0 ] ; then
+        if [ "$MAX_FD" = "maximum" -o "$MAX_FD" = "max" ] ; then
+            MAX_FD="$MAX_FD_LIMIT"
+        fi
+        ulimit -n $MAX_FD
+        if [ $? -ne 0 ] ; then
+            warn "Could not set maximum file descriptor limit: $MAX_FD"
+        fi
+    else
+        warn "Could not query maximum file descriptor limit: $MAX_FD_LIMIT"
+    fi
+fi
+
+# For Darwin, add options to specify how the application appears in the dock
+if $darwin; then
+    GRADLE_OPTS="$GRADLE_OPTS \"-Xdock:name=$APP_NAME\" \"-Xdock:icon=$APP_HOME/media/gradle.icns\""
+fi
+
+# For Cygwin or MSYS, switch paths to Windows format before running java
+if [ "$cygwin" = "true" -o "$msys" = "true" ] ; then
+    APP_HOME=`cygpath --path --mixed "$APP_HOME"`
+    CLASSPATH=`cygpath --path --mixed "$CLASSPATH"`
+    
+    JAVACMD=`cygpath --unix "$JAVACMD"`
+
+    # We build the pattern for arguments to be converted via cygpath
+    ROOTDIRSRAW=`find -L / -maxdepth 1 -mindepth 1 -type d 2>/dev/null`
+    SEP=""
+    for dir in $ROOTDIRSRAW ; do
+        ROOTDIRS="$ROOTDIRS$SEP$dir"
+        SEP="|"
+    done
+    OURCYGPATTERN="(^($ROOTDIRS))"
+    # Add a user-defined pattern to the cygpath arguments
+    if [ "$GRADLE_CYGPATTERN" != "" ] ; then
+        OURCYGPATTERN="$OURCYGPATTERN|($GRADLE_CYGPATTERN)"
+    fi
+    # Now convert the arguments - kludge to limit ourselves to /bin/sh
+    i=0
+    for arg in "$@" ; do
+        CHECK=`echo "$arg"|egrep -c "$OURCYGPATTERN" -`
+        CHECK2=`echo "$arg"|egrep -c "^-"`                                 ### Determine if an option
+
+        if [ $CHECK -ne 0 ] && [ $CHECK2 -eq 0 ] ; then                    ### Added a condition
+            eval `echo args$i`=`cygpath --path --ignore --mixed "$arg"`
+        else
+            eval `echo args$i`="\"$arg\""
+        fi
+        i=`expr $i + 1`
+    done
+    case $i in
+        0) set -- ;;
+        1) set -- "$args0" ;;
+        2) set -- "$args0" "$args1" ;;
+        3) set -- "$args0" "$args1" "$args2" ;;
+        4) set -- "$args0" "$args1" "$args2" "$args3" ;;
+        5) set -- "$args0" "$args1" "$args2" "$args3" "$args4" ;;
+        6) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" ;;
+        7) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" ;;
+        8) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" ;;
+        9) set -- "$args0" "$args1" "$args2" "$args3" "$args4" "$args5" "$args6" "$args7" "$args8" ;;
+    esac
+fi
+
+# Escape application args
+save () {
+    for i do printf %s\\n "$i" | sed "s/'/'\\\\''/g;1s/^/'/;\$s/\$/' \\\\/" ; done
+    echo " "
+}
+APP_ARGS=`save "$@"`
+
+# Collect all arguments for the java command, following the shell quoting and substitution rules
+eval set -- $DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS "\"-Dorg.gradle.appname=$APP_BASE_NAME\"" -classpath "\"$CLASSPATH\"" org.gradle.wrapper.GradleWrapperMain "$APP_ARGS"
+
+exec "$JAVACMD" "$@"

gradlew.bat

+@rem
+@rem Copyright 2015 the original author or authors.
+@rem
+@rem Licensed under the Apache License, Version 2.0 (the "License");
+@rem you may not use this file except in compliance with the License.
+@rem 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, software
+@rem distributed under the License is distributed on an "AS IS" BASIS,
+@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+@rem See the License for the specific language governing permissions and
+@rem limitations under the License.
+@rem
+
+@if "%DEBUG%" == "" @echo off
+@rem ##########################################################################
+@rem
+@rem  Gradle startup script for Windows
+@rem
+@rem ##########################################################################
+
+@rem Set local scope for the variables with windows NT shell
+if "%OS%"=="Windows_NT" setlocal
+
+set DIRNAME=%~dp0
+if "%DIRNAME%" == "" set DIRNAME=.
+set APP_BASE_NAME=%~n0
+set APP_HOME=%DIRNAME%
+
+@rem Resolve any "." and ".." in APP_HOME to make it shorter.
+for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi
+
+@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script.
+set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m"
+
+@rem Find java.exe
+if defined JAVA_HOME goto findJavaFromJavaHome
+
+set JAVA_EXE=java.exe
+%JAVA_EXE% -version >NUL 2>&1
+if "%ERRORLEVEL%" == "0" goto init
+
+echo.
+echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH.
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:findJavaFromJavaHome
+set JAVA_HOME=%JAVA_HOME:"=%
+set JAVA_EXE=%JAVA_HOME%/bin/java.exe
+
+if exist "%JAVA_EXE%" goto init
+
+echo.
+echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME%
+echo.
+echo Please set the JAVA_HOME variable in your environment to match the
+echo location of your Java installation.
+
+goto fail
+
+:init
+@rem Get command-line arguments, handling Windows variants
+
+if not "%OS%" == "Windows_NT" goto win9xME_args
+
+:win9xME_args
+@rem Slurp the command line arguments.
+set CMD_LINE_ARGS=
+set _SKIP=2
+
+:win9xME_args_slurp
+if "x%~1" == "x" goto execute
+
+set CMD_LINE_ARGS=%*
+
+:execute
+@rem Setup the command line
+
+set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar
+
+
+@rem Execute Gradle
+"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %CMD_LINE_ARGS%
+
+:end
+@rem End local scope for the variables with windows NT shell
+if "%ERRORLEVEL%"=="0" goto mainEnd
+
+:fail
+rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of
+rem the _cmd.exe /c_ return code!
+if  not "" == "%GRADLE_EXIT_CONSOLE%" exit 1
+exit /b 1
+
+:mainEnd
+if "%OS%"=="Windows_NT" endlocal
+
+:omega

settings.gradle.kts

+pluginManagement {
+    val quarkusPluginVersion: String by settings
+    val quarkusPluginId: String by settings
+    repositories {
+        mavenCentral()
+        gradlePluginPortal()
+        mavenLocal()
+    }
+    plugins {
+        id(quarkusPluginId) version quarkusPluginVersion
+    }
+}
+rootProject.name = "hky-database-synchronization"

src/main/docker/Dockerfile.legacy-jar

+FROM swr.cn-north-4.myhuaweicloud.com/ddn-k8s/docker.io/openjdk:21
+
+LABEL maintainer="yangjianfei yangjf@eazytec.com"
+
+ENV LANG en_US.UTF-8
+USER root
+ENV TZ "Asia/Shanghai"
+
+COPY build/*-runner.jar /deployments/quarkus-run.jar
+
+EXPOSE 9111
+ENV JAVA_OPTS_APPEND="-Dquarkus.http.host=0.0.0.0 -Djava.util.logging.manager=org.jboss.logmanager.LogManager"
+ENV JAVA_APP_JAR="/deployments/quarkus-run.jar"
+
+
+CMD ["java", "-jar", "/deployments/quarkus-run.jar"]

src/main/java/com/eazytec/hkydatabasessynchronization/config/BinlogConfig.java

+package com.eazytec.hkydatabasessynchronization.config;
+
+import com.eazytec.hkydatabasessynchronization.event.*;
+import com.eazytec.hkydatabasessynchronization.utils.DataSourceNameConstant;
+import com.gitee.Jmysy.binlog4j.core.*;
+import io.quarkus.agroal.runtime.DataSourcesJdbcRuntimeConfig;
+import io.quarkus.arc.Unremovable;
+import io.quarkus.datasource.runtime.DataSourceRuntimeConfig;
+import io.quarkus.datasource.runtime.DataSourcesRuntimeConfig;
+import io.quarkus.runtime.Startup;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.inject.Inject;
+import jakarta.inject.Singleton;
+
+import java.net.URI;
+import java.util.Map;
+import java.util.Optional;
+
+@ApplicationScoped
+public class BinlogConfig {
+
+    @Inject
+    DataSourcesRuntimeConfig dataSourcesRuntimeConfig;
+
+    @Inject
+    DataSourcesJdbcRuntimeConfig dataSourcesJdbcRuntimeConfig;
+
+    @Inject
+    EnterpriseBaseInfoEvent enterpriseBaseInfoEvent;
+
+    @Inject
+    EnterpriseRescueMaterialEvent enterpriseRescueMaterialEvent;
+
+    @Inject
+    EnterpriseRescueTeamEvent enterpriseRescueTeamEvent;
+
+    @Inject
+    EnterpriseTestReportEvent enterpriseTestReportEvent;
+
+    @Inject
+    EOTEmerspsSpsEnterpriseMajorHazardEvent eotEmerspsSpsEnterpriseMajorHazardEvent;
+
+    @Inject
+    OT12345SysAreaEvent ot12345SysAreaEvent;
+
+    @Inject
+    OT12345SysGroupDataEvent ot12345SysGroupDataEvent;
+
+    @Inject
+    OT12345TBusiAdviceEvent ot12345TBusiAdviceEvent;
+
+    @Inject
+    OT12345TBusiFormEvent ot12345TBusiFormEvent;
+
+    @Inject
+    OTBaseAjqyEvent otBaseAjqyEvent;
+
+    @Inject
+    OTBaseIstProjectEvent otBaseIstProjectEvent;
+
+    @Inject
+    OTBaseJiyueMapQiyeEvent otBaseJiyueMapQiyeEvent;
+
+    @Inject
+    OTEmerspsEmeCdeCodeDictoTEmerspsEmeCdeCodeDictEvent otEmerspsEmeCdeCodeDictoTEmerspsEmeCdeCodeDictEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseEvaluationTestReportEvent otEmerspsSpsEnterpriseEvaluationTestReportEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseHazardousChemicalsEvent otEmerspsSpsEnterpriseHazardousChemicalsEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseHistoryHiddenTroubleEvent otEmerspsSpsEnterpriseHistoryHiddenTroubleEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseLeakPointEvent otEmerspsSpsEnterpriseLeakPointEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseMaterialInfoEvent otEmerspsSpsEnterpriseMaterialInfoEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseRealtimeAlarmRecordEvent otEmerspsSpsEnterpriseRealtimeAlarmRecordEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseRiskIdentificationEvent otEmerspsSpsEnterpriseRiskIdentificationEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseRiskPartitionEvent otEmerspsSpsEnterpriseRiskPartitionEvent;
+
+    @Inject
+    OTEmerspsSpsEnterpriseSpecialOperationPersonEvent otEmerspsSpsEnterpriseSpecialOperationPersonEvent;
+
+    @Inject
+    OTEmerspsSpsSpSysCodeEvent otEmerspsSpsSpSysCodeEvent;
+
+    @Inject
+    OTGaTJxwCzrkxxEvent otGaTJxwCzrkxxEvent;
+
+    @Inject
+    OTGxjCydnJiyueMapDikuaiEvent otGxjCydnJiyueMapDikuaiEvent;
+
+    @Inject
+    OTSthjTAirCityHourForecastEvent otThjTAirCityHourForecastEvent;
+
+    @Inject
+    OTSthjTAirStationBaseinfoEvent otThjTAirStationBaseinfoEvent;
+
+    @Inject
+    OTSthjTAirStationDayZhEvent otSthjTAirStationDayZhEvent;
+
+    @Inject
+    OTSthjTAirStationHourZhEvent otSthjTAirStationHourZhEvent;
+
+    @Inject
+    OTSthjTWaterStationBaseinfoEvent otThjTWaterStationBaseinfoEvent;
+
+    @Inject
+    OTSthjTWaterStationDayZhEvent otThjTWaterStationDayZhEvent;
+
+    @Inject
+    OTSthjTWaterStationHourZhEvent otThjTWaterStationHourZhEvent;
+
+    @Inject
+    OTSyrkEvent otSyrkEvent;
+
+    @Inject
+    OTWghsjTRyjcxxbEvent otTWghsjTRyjcxxbEvent;
+
+    @Inject
+    OTYqydEnterpriseEvent otYqydEnterpriseEvent;
+
+    @Inject
+    PartyActivityEvent partyActivityEvent;
+
+    @Inject
+    PartyDictEvent partyDictEvent;
+
+    @Inject
+    PartyMemberEvent partyMemberEvent;
+
+    @Inject
+    PartyOrganizationEvent partyOrganizationEvent;
+
+    @Inject
+    TProjectEvent tProjectEvent;
+
+    @Inject
+    TProjectJgEvent tProjectJgEvent;
+
+    @Inject
+    TProjectNjEvent tProjectNjEvent;
+
+    @Inject
+    TProjectScheduleEvent tProjectScheduleEvent;
+
+    @Inject
+    TProjectZjEvent tProjectZjEvent;
+
+    @Singleton
+    @Unremovable
+    @Startup
+    public IBinlogClient binlogClient() {
+        DataSourceRuntimeConfig fromDataSourceRuntimeConfig = dataSourcesRuntimeConfig.dataSources().get(DataSourceNameConstant.FROM_DB);
+        Map<String, DataSourcesJdbcRuntimeConfig.DataSourceJdbcOuterNamedRuntimeConfig> dataSources = dataSourcesJdbcRuntimeConfig.dataSources();
+        DataSourcesJdbcRuntimeConfig.DataSourceJdbcOuterNamedRuntimeConfig fromDataSourceConfig = dataSources.get(DataSourceNameConstant.FROM_DB);
+        Optional<String> urlOptional = fromDataSourceConfig.jdbc().url();
+        String cleanURI = urlOptional.get().substring(5);
+        URI uri = URI.create(cleanURI);
+        BinlogClientConfig clientConfig = new BinlogClientConfig();
+        clientConfig.setHost(uri.getHost());
+        clientConfig.setPort(uri.getPort());
+        clientConfig.setUsername(fromDataSourceRuntimeConfig.username().get());
+        clientConfig.setPassword(fromDataSourceRuntimeConfig.password().get());
+        clientConfig.setServerId(1);
+        IBinlogClient binlogClient = new BinlogClient(clientConfig);
+        binlogClient.registerEventHandler(enterpriseBaseInfoEvent);
+        binlogClient.registerEventHandler(enterpriseRescueMaterialEvent);
+        binlogClient.registerEventHandler(enterpriseRescueTeamEvent);
+        binlogClient.registerEventHandler(enterpriseTestReportEvent);
+        binlogClient.registerEventHandler(eotEmerspsSpsEnterpriseMajorHazardEvent);
+        binlogClient.registerEventHandler(ot12345SysAreaEvent);
+        binlogClient.registerEventHandler(ot12345SysGroupDataEvent);
+        binlogClient.registerEventHandler(ot12345TBusiAdviceEvent);
+        binlogClient.registerEventHandler(ot12345TBusiFormEvent);
+        binlogClient.registerEventHandler(otBaseAjqyEvent);
+        binlogClient.registerEventHandler(otBaseIstProjectEvent);
+        binlogClient.registerEventHandler(otBaseJiyueMapQiyeEvent);
+        binlogClient.registerEventHandler(otEmerspsEmeCdeCodeDictoTEmerspsEmeCdeCodeDictEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseEvaluationTestReportEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseHazardousChemicalsEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseHistoryHiddenTroubleEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseLeakPointEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseMaterialInfoEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseRealtimeAlarmRecordEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseRiskIdentificationEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseRiskPartitionEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsEnterpriseSpecialOperationPersonEvent);
+        binlogClient.registerEventHandler(otEmerspsSpsSpSysCodeEvent);
+        binlogClient.registerEventHandler(otGaTJxwCzrkxxEvent);
+        binlogClient.registerEventHandler(otGxjCydnJiyueMapDikuaiEvent);
+        binlogClient.registerEventHandler(otThjTAirCityHourForecastEvent);
+        binlogClient.registerEventHandler(otThjTAirStationBaseinfoEvent);
+        binlogClient.registerEventHandler(otSthjTAirStationDayZhEvent);
+        binlogClient.registerEventHandler(otSthjTAirStationHourZhEvent);
+        binlogClient.registerEventHandler(otThjTWaterStationBaseinfoEvent);
+        binlogClient.registerEventHandler(otThjTWaterStationDayZhEvent);
+        binlogClient.registerEventHandler(otThjTWaterStationHourZhEvent);
+        binlogClient.registerEventHandler(otSyrkEvent);
+        binlogClient.registerEventHandler(otTWghsjTRyjcxxbEvent);
+        binlogClient.registerEventHandler(otYqydEnterpriseEvent);
+        binlogClient.registerEventHandler(partyActivityEvent);
+        binlogClient.registerEventHandler(partyDictEvent);
+        binlogClient.registerEventHandler(partyMemberEvent);
+        binlogClient.registerEventHandler(partyOrganizationEvent);
+        binlogClient.registerEventHandler(tProjectEvent);
+        binlogClient.registerEventHandler(tProjectJgEvent);
+        binlogClient.registerEventHandler(tProjectNjEvent);
+        binlogClient.registerEventHandler(tProjectScheduleEvent);
+        binlogClient.registerEventHandler(tProjectZjEvent);
+        binlogClient.connect();
+        return binlogClient;
+    }
+}

src/main/java/com/eazytec/hkydatabasessynchronization/entity/EnterpriseRescueMaterial.java

+package com.eazytec.hkydatabasessynchronization.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.IdType;
+
+/**
+ * 企业应急救援物资
+ *
+ * @author lx
+ * @since 2024-10-12 18:16
+ */
+@TableName("enterprise_rescue_material")
+public class EnterpriseRescueMaterial implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "enterprise_emergency_rescue_material_id", type = IdType.AUTO)
+    private String enterpriseEmergencyRescueMaterialId;
+
+    /**
+     * 企业ID
+     */
+    private String enterpriseId;
+
+    /**
+     * 企业名称
+     */
+    private String enterpriseName;
+
+    /**
+     * 规格型号
+     */
+    private String materialModel;
+
+    /**
+     * 物资数量
+     */
+    private String materialNumber;
+
+    /**
+     * 物资类别
+     */
+    private String materialType;
+
+    /**
+     * 主要负责人
+     */
+    private String mainChargePerson;
+
+    /**
+     * 负责人电话
+     */
+    private String chargePersonMobile;
+
+    /**
+     * 购买日期
+     */
+    private Date buyDate;
+
+    /**
+     * 生产厂家
+     */
+    private String manufactureFactory;
+
+    /**
+     * 使用期限
+     */
+    private Date expireTime;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 主要用途
+     */
+    private String mainApplication;
+
+    /**
+     * 存放地址
+     */
+    private String storeAddress;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建时间
+     */
+    private Date gmtCreated;
+
+    /**
+     * 检索题名
+     */
+    private String searchTitle;
+
+    /**
+     * 数据来源ID
+     */
+    private String dataSourceId;
+
+    /**
+     * 修改时间
+     */
+    private Date gmtModified;
+
+    /**
+     * 数据锁版本号
+     */
+    private String dataVersion;
+
+    /**
+     * odm入库时间
+     */
+    @TableField("odm_rksj")
+    private Date odmRksj;
+
+    /**
+     * 物资名称
+     */
+    private String materialName;
+
+    public String getEnterpriseEmergencyRescueMaterialId() {
+        return enterpriseEmergencyRescueMaterialId;
+    }
+
+    public void setEnterpriseEmergencyRescueMaterialId(String enterpriseEmergencyRescueMaterialId) {
+        this.enterpriseEmergencyRescueMaterialId = enterpriseEmergencyRescueMaterialId;
+    }
+
+    public String getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(String enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public String getEnterpriseName() {
+        return enterpriseName;
+    }
+
+    public void setEnterpriseName(String enterpriseName) {
+        this.enterpriseName = enterpriseName;
+    }
+
+    public String getMaterialModel() {
+        return materialModel;
+    }
+
+    public void setMaterialModel(String materialModel) {
+        this.materialModel = materialModel;
+    }
+
+    public String getMaterialNumber() {
+        return materialNumber;
+    }
+
+    public void setMaterialNumber(String materialNumber) {
+        this.materialNumber = materialNumber;
+    }
+
+    public String getMaterialType() {
+        return materialType;
+    }
+
+    public void setMaterialType(String materialType) {
+        this.materialType = materialType;
+    }
+
+    public String getMainChargePerson() {
+        return mainChargePerson;
+    }
+
+    public void setMainChargePerson(String mainChargePerson) {
+        this.mainChargePerson = mainChargePerson;
+    }
+
+    public String getChargePersonMobile() {
+        return chargePersonMobile;
+    }
+
+    public void setChargePersonMobile(String chargePersonMobile) {
+        this.chargePersonMobile = chargePersonMobile;
+    }
+
+    public Date getBuyDate() {
+        return buyDate;
+    }
+
+    public void setBuyDate(Date buyDate) {
+        this.buyDate = buyDate;
+    }
+
+    public String getManufactureFactory() {
+        return manufactureFactory;
+    }
+
+    public void setManufactureFactory(String manufactureFactory) {
+        this.manufactureFactory = manufactureFactory;
+    }
+
+    public Date getExpireTime() {
+        return expireTime;
+    }
+
+    public void setExpireTime(Date expireTime) {
+        this.expireTime = expireTime;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getMainApplication() {
+        return mainApplication;
+    }
+
+    public void setMainApplication(String mainApplication) {
+        this.mainApplication = mainApplication;
+    }
+
+    public String getStoreAddress() {
+        return storeAddress;
+    }
+
+    public void setStoreAddress(String storeAddress) {
+        this.storeAddress = storeAddress;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public Date getGmtCreated() {
+        return gmtCreated;
+    }
+
+    public void setGmtCreated(Date gmtCreated) {
+        this.gmtCreated = gmtCreated;
+    }
+
+    public String getSearchTitle() {
+        return searchTitle;
+    }
+
+    public void setSearchTitle(String searchTitle) {
+        this.searchTitle = searchTitle;
+    }
+
+    public String getDataSourceId() {
+        return dataSourceId;
+    }
+
+    public void setDataSourceId(String dataSourceId) {
+        this.dataSourceId = dataSourceId;
+    }
+
+    public Date getGmtModified() {
+        return gmtModified;
+    }
+
+    public void setGmtModified(Date gmtModified) {
+        this.gmtModified = gmtModified;
+    }
+
+    public String getDataVersion() {
+        return dataVersion;
+    }
+
+    public void setDataVersion(String dataVersion) {
+        this.dataVersion = dataVersion;
+    }
+
+    public Date getOdmRksj() {
+        return odmRksj;
+    }
+
+    public void setOdmRksj(Date odmRksj) {
+        this.odmRksj = odmRksj;
+    }
+
+    public String getMaterialName() {
+        return materialName;
+    }
+
+    public void setMaterialName(String materialName) {
+        this.materialName = materialName;
+    }
+}

src/main/java/com/eazytec/hkydatabasessynchronization/entity/EnterpriseRescueTeam.java

+package com.eazytec.hkydatabasessynchronization.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.IdType;
+
+/**
+ * 企业应急救援队伍
+ *
+ * @author lx
+ * @since 2024-10-12 17:33
+ */
+@TableName("enterprise_rescue_team")
+public class EnterpriseRescueTeam implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "enterprise_emergency_rescue_team_id", type = IdType.AUTO)
+    private String enterpriseEmergencyRescueTeamId;
+
+    /**
+     * 企业名称
+
+     */
+    private String enterpriseName;
+
+    /**
+     * 队伍名称
+     */
+    private String teamName;
+
+    /**
+     * 专兼职
+     */
+    private String fullOrPartTime;
+
+    /**
+     * 所属单位
+     */
+    private String dept;
+
+    /**
+     * 队伍性质
+     */
+    private String teamProperty;
+
+    /**
+     * 队伍级别
+     */
+    private String teamLevel;
+
+    /**
+     * 擅长事故类型
+     */
+    private String expertAccidentType;
+
+    /**
+     * 地址
+     */
+    private String address;
+
+    /**
+     * 主要联系人
+     */
+    private String mainContact;
+
+    /**
+     * 联系电话
+     */
+    private String contactMobile;
+
+    /**
+     * 队伍人数
+     */
+    private String teamPersons;
+
+    /**
+     * 备注
+     */
+    private String remark;
+
+    /**
+     * 创建时间
+     */
+    private Date gmtCreated;
+
+    /**
+     * 企业ID
+     */
+    private String enterpriseId;
+
+    /**
+     * 成立日期
+     */
+    private Date foundDate;
+
+    /**
+     * 服务区域
+     */
+    private String serviceArea;
+
+    /**
+     * 数据来源ID
+     */
+    private String dataSourceId;
+
+    /**
+     * 修改时间
+     */
+    private Date gmtModified;
+
+    /**
+     * 数据锁版本号
+     */
+    private String dataVersion;
+
+    /**
+     * 检索题名
+     */
+    private String searchTitle;
+
+    /**
+     * odm入库时间
+     */
+    @TableField("odm_rksj")
+    private Date odmRksj;
+
+    public String getEnterpriseEmergencyRescueTeamId() {
+        return enterpriseEmergencyRescueTeamId;
+    }
+
+    public void setEnterpriseEmergencyRescueTeamId(String enterpriseEmergencyRescueTeamId) {
+        this.enterpriseEmergencyRescueTeamId = enterpriseEmergencyRescueTeamId;
+    }
+
+    public String getEnterpriseName() {
+        return enterpriseName;
+    }
+
+    public void setEnterpriseName(String enterpriseName) {
+        this.enterpriseName = enterpriseName;
+    }
+
+    public String getTeamName() {
+        return teamName;
+    }
+
+    public void setTeamName(String teamName) {
+        this.teamName = teamName;
+    }
+
+    public String getFullOrPartTime() {
+        return fullOrPartTime;
+    }
+
+    public void setFullOrPartTime(String fullOrPartTime) {
+        this.fullOrPartTime = fullOrPartTime;
+    }
+
+    public String getDept() {
+        return dept;
+    }
+
+    public void setDept(String dept) {
+        this.dept = dept;
+    }
+
+    public String getTeamProperty() {
+        return teamProperty;
+    }
+
+    public void setTeamProperty(String teamProperty) {
+        this.teamProperty = teamProperty;
+    }
+
+    public String getTeamLevel() {
+        return teamLevel;
+    }
+
+    public void setTeamLevel(String teamLevel) {
+        this.teamLevel = teamLevel;
+    }
+
+    public String getExpertAccidentType() {
+        return expertAccidentType;
+    }
+
+    public void setExpertAccidentType(String expertAccidentType) {
+        this.expertAccidentType = expertAccidentType;
+    }
+
+    public String getAddress() {
+        return address;
+    }
+
+    public void setAddress(String address) {
+        this.address = address;
+    }
+
+    public String getMainContact() {
+        return mainContact;
+    }
+
+    public void setMainContact(String mainContact) {
+        this.mainContact = mainContact;
+    }
+
+    public String getContactMobile() {
+        return contactMobile;
+    }
+
+    public void setContactMobile(String contactMobile) {
+        this.contactMobile = contactMobile;
+    }
+
+    public String getTeamPersons() {
+        return teamPersons;
+    }
+
+    public void setTeamPersons(String teamPersons) {
+        this.teamPersons = teamPersons;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark;
+    }
+
+    public Date getGmtCreated() {
+        return gmtCreated;
+    }
+
+    public void setGmtCreated(Date gmtCreated) {
+        this.gmtCreated = gmtCreated;
+    }
+
+    public String getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(String enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public Date getFoundDate() {
+        return foundDate;
+    }
+
+    public void setFoundDate(Date foundDate) {
+        this.foundDate = foundDate;
+    }
+
+    public String getServiceArea() {
+        return serviceArea;
+    }
+
+    public void setServiceArea(String serviceArea) {
+        this.serviceArea = serviceArea;
+    }
+
+    public String getDataSourceId() {
+        return dataSourceId;
+    }
+
+    public void setDataSourceId(String dataSourceId) {
+        this.dataSourceId = dataSourceId;
+    }
+
+    public Date getGmtModified() {
+        return gmtModified;
+    }
+
+    public void setGmtModified(Date gmtModified) {
+        this.gmtModified = gmtModified;
+    }
+
+    public String getDataVersion() {
+        return dataVersion;
+    }
+
+    public void setDataVersion(String dataVersion) {
+        this.dataVersion = dataVersion;
+    }
+
+    public String getSearchTitle() {
+        return searchTitle;
+    }
+
+    public void setSearchTitle(String searchTitle) {
+        this.searchTitle = searchTitle;
+    }
+
+    public Date getOdmRksj() {
+        return odmRksj;
+    }
+
+    public void setOdmRksj(Date odmRksj) {
+        this.odmRksj = odmRksj;
+    }
+}

src/main/java/com/eazytec/hkydatabasessynchronization/entity/EnterpriseTestReport.java

+package com.eazytec.hkydatabasessynchronization.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.IdType;
+
+/**
+ * 企业风险分区
+ *
+ * @author lx
+ * @since 2024-10-12 17:33
+ */
+@TableName("enterprise_test_report")
+public class EnterpriseTestReport implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "enterprise_risk_partition_id", type = IdType.AUTO)
+    private String enterpriseRiskPartitionId;
+
+    /**
+     * 企业ID
+     */
+    private String enterpriseId;
+
+    /**
+     * 企业名称
+     */
+    private String enterpriseName;
+
+    /**
+     * 风险图名称
+     */
+    private String riskPhotoName;
+
+    /**
+     * 风险图类型
+     */
+    private String riskPhotoType;
+
+    /**
+     * 评估时间
+     */
+    private Date assessmentTime;
+
+    /**
+     * 复评时间
+     */
+    private Date reevaluationTime;
+
+    /**
+     * 评估人
+     */
+    private String assessor;
+
+    /**
+     * 创建时间
+     */
+    private Date gmtCreated;
+
+    /**
+     * 检索题名
+     */
+    private String searchTitle;
+
+    /**
+     * 风险图
+     */
+    private String riskPhoto;
+
+    /**
+     * 数据来源ID
+     */
+    private String dataSourceId;
+
+    /**
+     * 修改时间
+     */
+    private Date gmtModified;
+
+    /**
+     * 数据锁版本号
+     */
+    private String dataVersion;
+
+    /**
+     * odm入库时间
+     */
+    @TableField("odm_rksj")
+    private Date odmRksj;
+
+    public String getEnterpriseRiskPartitionId() {
+        return enterpriseRiskPartitionId;
+    }
+
+    public void setEnterpriseRiskPartitionId(String enterpriseRiskPartitionId) {
+        this.enterpriseRiskPartitionId = enterpriseRiskPartitionId;
+    }
+
+    public String getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(String enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public String getEnterpriseName() {
+        return enterpriseName;
+    }
+
+    public void setEnterpriseName(String enterpriseName) {
+        this.enterpriseName = enterpriseName;
+    }
+
+    public String getRiskPhotoName() {
+        return riskPhotoName;
+    }
+
+    public void setRiskPhotoName(String riskPhotoName) {
+        this.riskPhotoName = riskPhotoName;
+    }
+
+    public String getRiskPhotoType() {
+        return riskPhotoType;
+    }
+
+    public void setRiskPhotoType(String riskPhotoType) {
+        this.riskPhotoType = riskPhotoType;
+    }
+
+    public Date getAssessmentTime() {
+        return assessmentTime;
+    }
+
+    public void setAssessmentTime(Date assessmentTime) {
+        this.assessmentTime = assessmentTime;
+    }
+
+    public Date getReevaluationTime() {
+        return reevaluationTime;
+    }
+
+    public void setReevaluationTime(Date reevaluationTime) {
+        this.reevaluationTime = reevaluationTime;
+    }
+
+    public String getAssessor() {
+        return assessor;
+    }
+
+    public void setAssessor(String assessor) {
+        this.assessor = assessor;
+    }
+
+    public Date getGmtCreated() {
+        return gmtCreated;
+    }
+
+    public void setGmtCreated(Date gmtCreated) {
+        this.gmtCreated = gmtCreated;
+    }
+
+    public String getSearchTitle() {
+        return searchTitle;
+    }
+
+    public void setSearchTitle(String searchTitle) {
+        this.searchTitle = searchTitle;
+    }
+
+    public String getRiskPhoto() {
+        return riskPhoto;
+    }
+
+    public void setRiskPhoto(String riskPhoto) {
+        this.riskPhoto = riskPhoto;
+    }
+
+    public String getDataSourceId() {
+        return dataSourceId;
+    }
+
+    public void setDataSourceId(String dataSourceId) {
+        this.dataSourceId = dataSourceId;
+    }
+
+    public Date getGmtModified() {
+        return gmtModified;
+    }
+
+    public void setGmtModified(Date gmtModified) {
+        this.gmtModified = gmtModified;
+    }
+
+    public String getDataVersion() {
+        return dataVersion;
+    }
+
+    public void setDataVersion(String dataVersion) {
+        this.dataVersion = dataVersion;
+    }
+
+    public Date getOdmRksj() {
+        return odmRksj;
+    }
+
+    public void setOdmRksj(Date odmRksj) {
+        this.odmRksj = odmRksj;
+    }
+}

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OT12345SysArea.java

+package com.eazytec.hkydatabasessynchronization.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.IdType;
+
+/**
+ * 归属地字典表
+ *
+ * @author lx
+ * @since 2024-10-12 17:33
+ */
+@TableName("o_t_12345_sys_area")
+public class OT12345SysArea implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private String id;
+
+    private String parentId;
+
+    private String parentIds;
+
+    private String name;
+
+    private Long sort;
+
+    private String code;
+
+    private String type;
+
+    private String createBy;
+
+    private Date createDate;
+
+    private String updateBy;
+
+    private Date updateDate;
+
+    private String remarks;
+
+    private String delFlag;
+
+    @TableField("odm_rksj")
+    private Date odmRksj;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getParentId() {
+        return parentId;
+    }
+
+    public void setParentId(String parentId) {
+        this.parentId = parentId;
+    }
+
+    public String getParentIds() {
+        return parentIds;
+    }
+
+    public void setParentIds(String parentIds) {
+        this.parentIds = parentIds;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public Long getSort() {
+        return sort;
+    }
+
+    public void setSort(Long sort) {
+        this.sort = sort;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public String getRemarks() {
+        return remarks;
+    }
+
+    public void setRemarks(String remarks) {
+        this.remarks = remarks;
+    }
+
+    public String getDelFlag() {
+        return delFlag;
+    }
+
+    public void setDelFlag(String delFlag) {
+        this.delFlag = delFlag;
+    }
+
+    public Date getOdmRksj() {
+        return odmRksj;
+    }
+
+    public void setOdmRksj(Date odmRksj) {
+        this.odmRksj = odmRksj;
+    }
+}

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OT12345SysGroupData.java

+package com.eazytec.hkydatabasessynchronization.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.IdType;
+
+/**
+ * 业务分类字典表
+ *
+ * @author lx
+ * @since 2024-10-12 17:33
+ */
+@TableName("o_t_12345_sys_group_data")
+public class OT12345SysGroupData implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private String id;
+
+    private String createBy;
+
+    private String updateBy;
+
+    private String remarks;
+
+    private String delFlag;
+
+    private String dataGroup;
+
+    private String dataVal;
+
+    private String parentId;
+
+    private String parentIds;
+
+    private String name;
+
+    private Integer sort;
+
+    private Date createDate;
+
+    private Date updateDate;
+
+    @TableField("odm_rksj")
+    private Date odmRksj;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public String getRemarks() {
+        return remarks;
+    }
+
+    public void setRemarks(String remarks) {
+        this.remarks = remarks;
+    }
+
+    public String getDelFlag() {
+        return delFlag;
+    }
+
+    public void setDelFlag(String delFlag) {
+        this.delFlag = delFlag;
+    }
+
+    public String getDataGroup() {
+        return dataGroup;
+    }
+
+    public void setDataGroup(String dataGroup) {
+        this.dataGroup = dataGroup;
+    }
+
+    public String getDataVal() {
+        return dataVal;
+    }
+
+    public void setDataVal(String dataVal) {
+        this.dataVal = dataVal;
+    }
+
+    public String getParentId() {
+        return parentId;
+    }
+
+    public void setParentId(String parentId) {
+        this.parentId = parentId;
+    }
+
+    public String getParentIds() {
+        return parentIds;
+    }
+
+    public void setParentIds(String parentIds) {
+        this.parentIds = parentIds;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public Integer getSort() {
+        return sort;
+    }
+
+    public void setSort(Integer sort) {
+        this.sort = sort;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Date getOdmRksj() {
+        return odmRksj;
+    }
+
+    public void setOdmRksj(Date odmRksj) {
+        this.odmRksj = odmRksj;
+    }
+}

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OT12345TBusiAdvice.java

+package com.eazytec.hkydatabasessynchronization.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.IdType;
+
+/**
+ * 处置流程和结果表
+ *
+ * @author lx
+ * @since 2024-10-12 17:33
+ */
+@TableName("o_t_12345_t_busi_advice")
+public class OT12345TBusiAdvice implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private String id;
+
+    private String createBy;
+
+    private String updateBy;
+
+    private String remarks;
+
+    private String delFlag;
+
+    private String deptId;
+
+    private String doAction;
+
+    private String formStatus;
+
+    private String formId;
+
+    private String taskId;
+
+    private String advContent;
+
+    private String currentNodeEnd;
+
+    private String contactCustomerSign;
+
+    private String subjectAttitudeSatify;
+
+    private String subjectResultSatify;
+
+    private String processingTime;
+
+    private String signingTime;
+
+    private String deptSatisfy;
+
+    private Date createDate;
+
+    private Date updateDate;
+
+    private Date planTime;
+
+    private Date signTime;
+
+    @TableField("odm_rksj")
+    private Date odmRksj;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getCreateBy() {
+        return createBy;
+    }
+
+    public void setCreateBy(String createBy) {
+        this.createBy = createBy;
+    }
+
+    public String getUpdateBy() {
+        return updateBy;
+    }
+
+    public void setUpdateBy(String updateBy) {
+        this.updateBy = updateBy;
+    }
+
+    public String getRemarks() {
+        return remarks;
+    }
+
+    public void setRemarks(String remarks) {
+        this.remarks = remarks;
+    }
+
+    public String getDelFlag() {
+        return delFlag;
+    }
+
+    public void setDelFlag(String delFlag) {
+        this.delFlag = delFlag;
+    }
+
+    public String getDeptId() {
+        return deptId;
+    }
+
+    public void setDeptId(String deptId) {
+        this.deptId = deptId;
+    }
+
+    public String getDoAction() {
+        return doAction;
+    }
+
+    public void setDoAction(String doAction) {
+        this.doAction = doAction;
+    }
+
+    public String getFormStatus() {
+        return formStatus;
+    }
+
+    public void setFormStatus(String formStatus) {
+        this.formStatus = formStatus;
+    }
+
+    public String getFormId() {
+        return formId;
+    }
+
+    public void setFormId(String formId) {
+        this.formId = formId;
+    }
+
+    public String getTaskId() {
+        return taskId;
+    }
+
+    public void setTaskId(String taskId) {
+        this.taskId = taskId;
+    }
+
+    public String getAdvContent() {
+        return advContent;
+    }
+
+    public void setAdvContent(String advContent) {
+        this.advContent = advContent;
+    }
+
+    public String getCurrentNodeEnd() {
+        return currentNodeEnd;
+    }
+
+    public void setCurrentNodeEnd(String currentNodeEnd) {
+        this.currentNodeEnd = currentNodeEnd;
+    }
+
+    public String getContactCustomerSign() {
+        return contactCustomerSign;
+    }
+
+    public void setContactCustomerSign(String contactCustomerSign) {
+        this.contactCustomerSign = contactCustomerSign;
+    }
+
+    public String getSubjectAttitudeSatify() {
+        return subjectAttitudeSatify;
+    }
+
+    public void setSubjectAttitudeSatify(String subjectAttitudeSatify) {
+        this.subjectAttitudeSatify = subjectAttitudeSatify;
+    }
+
+    public String getSubjectResultSatify() {
+        return subjectResultSatify;
+    }
+
+    public void setSubjectResultSatify(String subjectResultSatify) {
+        this.subjectResultSatify = subjectResultSatify;
+    }
+
+    public String getProcessingTime() {
+        return processingTime;
+    }
+
+    public void setProcessingTime(String processingTime) {
+        this.processingTime = processingTime;
+    }
+
+    public String getSigningTime() {
+        return signingTime;
+    }
+
+    public void setSigningTime(String signingTime) {
+        this.signingTime = signingTime;
+    }
+
+    public String getDeptSatisfy() {
+        return deptSatisfy;
+    }
+
+    public void setDeptSatisfy(String deptSatisfy) {
+        this.deptSatisfy = deptSatisfy;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public Date getUpdateDate() {
+        return updateDate;
+    }
+
+    public void setUpdateDate(Date updateDate) {
+        this.updateDate = updateDate;
+    }
+
+    public Date getPlanTime() {
+        return planTime;
+    }
+
+    public void setPlanTime(Date planTime) {
+        this.planTime = planTime;
+    }
+
+    public Date getSignTime() {
+        return signTime;
+    }
+
+    public void setSignTime(Date signTime) {
+        this.signTime = signTime;
+    }
+
+    public Date getOdmRksj() {
+        return odmRksj;
+    }
+
+    public void setOdmRksj(Date odmRksj) {
+        this.odmRksj = odmRksj;
+    }
+}

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OTBaseAjqy.java

+package com.eazytec.hkydatabasessynchronization.entity;
+
+import java.io.Serializable;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+/**
+ * 安监企业数据
+ *
+ * @author lx
+ * @since 2024-10-12 17:33
+ */
+@TableName("o_t_base_ajqy")
+public class OTBaseAjqy implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private String shhy;
+
+    private String scjyqkZycp;
+
+    private String scjyqkZygy;
+
+    private String scjyqkZyyl;
+
+    private String aqscBzhYxq;
+
+    private String aqscBzhLevel;
+
+    private String aqscBzhHyfl;
+
+    private String aqscJyxkzYxq;
+
+    private String aqscJyxkzFzjg;
+
+    private String aqscJyxkzNo;
+
+    private String qygm;
+
+    private String jjlx;
+
+    private String cfqkCount;
+
+    private String area;
+
+    private String orgCode;
+
+    private String scjyAdress;
+
+    private String zcAdress;
+
+    private String phone;
+
+    private String cfqkJg;
+
+    private String idOld;
+
+    private String cfqkCq;
+
+    private String yyzcYxq;
+
+    private String yyzcNo;
+
+    private String companyName;
+
+    private String czPhone;
+
+    private String yyzcFzjg;
+
+    private String postal;
+
+    @TableField("odm_rksj")
+    private Date odmRksj;
+
+    public String getShhy() {
+        return shhy;
+    }
+
+    public void setShhy(String shhy) {
+        this.shhy = shhy;
+    }
+
+    public String getScjyqkZycp() {
+        return scjyqkZycp;
+    }
+
+    public void setScjyqkZycp(String scjyqkZycp) {
+        this.scjyqkZycp = scjyqkZycp;
+    }
+
+    public String getScjyqkZygy() {
+        return scjyqkZygy;
+    }
+
+    public void setScjyqkZygy(String scjyqkZygy) {
+        this.scjyqkZygy = scjyqkZygy;
+    }
+
+    public String getScjyqkZyyl() {
+        return scjyqkZyyl;
+    }
+
+    public void setScjyqkZyyl(String scjyqkZyyl) {
+        this.scjyqkZyyl = scjyqkZyyl;
+    }
+
+    public String getAqscBzhYxq() {
+        return aqscBzhYxq;
+    }
+
+    public void setAqscBzhYxq(String aqscBzhYxq) {
+        this.aqscBzhYxq = aqscBzhYxq;
+    }
+
+    public String getAqscBzhLevel() {
+        return aqscBzhLevel;
+    }
+
+    public void setAqscBzhLevel(String aqscBzhLevel) {
+        this.aqscBzhLevel = aqscBzhLevel;
+    }
+
+    public String getAqscBzhHyfl() {
+        return aqscBzhHyfl;
+    }
+
+    public void setAqscBzhHyfl(String aqscBzhHyfl) {
+        this.aqscBzhHyfl = aqscBzhHyfl;
+    }
+
+    public String getAqscJyxkzYxq() {
+        return aqscJyxkzYxq;
+    }
+
+    public void setAqscJyxkzYxq(String aqscJyxkzYxq) {
+        this.aqscJyxkzYxq = aqscJyxkzYxq;
+    }
+
+    public String getAqscJyxkzFzjg() {
+        return aqscJyxkzFzjg;
+    }
+
+    public void setAqscJyxkzFzjg(String aqscJyxkzFzjg) {
+        this.aqscJyxkzFzjg = aqscJyxkzFzjg;
+    }
+
+    public String getAqscJyxkzNo() {
+        return aqscJyxkzNo;
+    }
+
+    public void setAqscJyxkzNo(String aqscJyxkzNo) {
+        this.aqscJyxkzNo = aqscJyxkzNo;
+    }
+
+    public String getQygm() {
+        return qygm;
+    }
+
+    public void setQygm(String qygm) {
+        this.qygm = qygm;
+    }
+
+    public String getJjlx() {
+        return jjlx;
+    }
+
+    public void setJjlx(String jjlx) {
+        this.jjlx = jjlx;
+    }
+
+    public String getCfqkCount() {
+        return cfqkCount;
+    }
+
+    public void setCfqkCount(String cfqkCount) {
+        this.cfqkCount = cfqkCount;
+    }
+
+    public String getArea() {
+        return area;
+    }
+
+    public void setArea(String area) {
+        this.area = area;
+    }
+
+    public String getOrgCode() {
+        return orgCode;
+    }
+
+    public void setOrgCode(String orgCode) {
+        this.orgCode = orgCode;
+    }
+
+    public String getScjyAdress() {
+        return scjyAdress;
+    }
+
+    public void setScjyAdress(String scjyAdress) {
+        this.scjyAdress = scjyAdress;
+    }
+
+    public String getZcAdress() {
+        return zcAdress;
+    }
+
+    public void setZcAdress(String zcAdress) {
+        this.zcAdress = zcAdress;
+    }
+
+    public String getPhone() {
+        return phone;
+    }
+
+    public void setPhone(String phone) {
+        this.phone = phone;
+    }
+
+    public String getCfqkJg() {
+        return cfqkJg;
+    }
+
+    public void setCfqkJg(String cfqkJg) {
+        this.cfqkJg = cfqkJg;
+    }
+
+    public String getIdOld() {
+        return idOld;
+    }
+
+    public void setIdOld(String idOld) {
+        this.idOld = idOld;
+    }
+
+    public String getCfqkCq() {
+        return cfqkCq;
+    }
+
+    public void setCfqkCq(String cfqkCq) {
+        this.cfqkCq = cfqkCq;
+    }
+
+    public String getYyzcYxq() {
+        return yyzcYxq;
+    }
+
+    public void setYyzcYxq(String yyzcYxq) {
+        this.yyzcYxq = yyzcYxq;
+    }
+
+    public String getYyzcNo() {
+        return yyzcNo;
+    }
+
+    public void setYyzcNo(String yyzcNo) {
+        this.yyzcNo = yyzcNo;
+    }
+
+    public String getCompanyName() {
+        return companyName;
+    }
+
+    public void setCompanyName(String companyName) {
+        this.companyName = companyName;
+    }
+
+    public String getCzPhone() {
+        return czPhone;
+    }
+
+    public void setCzPhone(String czPhone) {
+        this.czPhone = czPhone;
+    }
+
+    public String getYyzcFzjg() {
+        return yyzcFzjg;
+    }
+
+    public void setYyzcFzjg(String yyzcFzjg) {
+        this.yyzcFzjg = yyzcFzjg;
+    }
+
+    public String getPostal() {
+        return postal;
+    }
+
+    public void setPostal(String postal) {
+        this.postal = postal;
+    }
+
+    public Date getOdmRksj() {
+        return odmRksj;
+    }
+
+    public void setOdmRksj(Date odmRksj) {
+        this.odmRksj = odmRksj;
+    }
+}

src/main/java/com/eazytec/hkydatabasessynchronization/entity/OTSyrk.java

+package com.eazytec.hkydatabasessynchronization.entity;
+
+import java.io.Serializable;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+/**
+ * 公安实有人口表
+ *
+ * @author lx
+ * @since 2024-10-12 17:33
+ */
+@TableName("o_t_syrk")
+public class OTSyrk implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    private String mz;
+
+    private String sfz;
+
+    private String jd;
+
+    private String sq;
+
+    private String sqdm;
+
+    public String getMz() {
+        return mz;
+    }
+
+    public void setMz(String mz) {
+        this.mz = mz;
+    }
+
+    public String getSfz() {
+        return sfz;
+    }
+
+    public void setSfz(String sfz) {
+        this.sfz = sfz;
+    }
+
+    public String getJd() {
+        return jd;
+    }
+
+    public void setJd(String jd) {
+        this.jd = jd;
+    }
+
+    public String getSq() {
+        return sq;
+    }
+
+    public void setSq(String sq) {
+        this.sq = sq;
+    }
+
+    public String getSqdm() {
+        return sqdm;
+    }
+
+    public void setSqdm(String sqdm) {
+        this.sqdm = sqdm;
+    }
+}