feat(user): user模块初始提交 完成了数据同步功能

kt-user/.gitignore

+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

kt-user/.mvn/wrapper/maven-wrapper.properties

+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.4/apache-maven-3.8.4-bin.zip
+wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar

kt-user/mvnw.cmd

+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements.  See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership.  The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License.  You may obtain a copy of the License at
+@REM
+@REM    https://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied.  See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Maven 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 keystroke before ending
+@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
+@REM     e.g. to debug Maven itself, use
+@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
+@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
+@REM ----------------------------------------------------------------------------
+
+@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
+@echo off
+@REM set title of command window
+title %0
+@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
+@if "%MAVEN_BATCH_ECHO%" == "on"  echo %MAVEN_BATCH_ECHO%
+
+@REM set %HOME% to equivalent of $HOME
+if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
+
+@REM Execute a user defined script before this one
+if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
+@REM check for pre script, once with legacy .bat ending and once with .cmd ending
+if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
+if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
+:skipRcPre
+
+@setlocal
+
+set ERROR_CODE=0
+
+@REM To isolate internal variables from possible post scripts, we use another setlocal
+@setlocal
+
+@REM ==== START VALIDATION ====
+if not "%JAVA_HOME%" == "" goto OkJHome
+
+echo.
+echo Error: JAVA_HOME not found in your environment. >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+:OkJHome
+if exist "%JAVA_HOME%\bin\java.exe" goto init
+
+echo.
+echo Error: JAVA_HOME is set to an invalid directory. >&2
+echo JAVA_HOME = "%JAVA_HOME%" >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+@REM ==== END VALIDATION ====
+
+:init
+
+@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
+@REM Fallback to current working directory if not found.
+
+set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
+IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
+
+set EXEC_DIR=%CD%
+set WDIR=%EXEC_DIR%
+:findBaseDir
+IF EXIST "%WDIR%"\.mvn goto baseDirFound
+cd ..
+IF "%WDIR%"=="%CD%" goto baseDirNotFound
+set WDIR=%CD%
+goto findBaseDir
+
+:baseDirFound
+set MAVEN_PROJECTBASEDIR=%WDIR%
+cd "%EXEC_DIR%"
+goto endDetectBaseDir
+
+:baseDirNotFound
+set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
+cd "%EXEC_DIR%"
+
+:endDetectBaseDir
+
+IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
+
+@setlocal EnableExtensions EnableDelayedExpansion
+for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
+@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
+
+:endReadAdditionalConfig
+
+SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
+set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
+set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
+
+set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
+
+FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
+    IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
+)
+
+@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
+@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
+if exist %WRAPPER_JAR% (
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Found %WRAPPER_JAR%
+    )
+) else (
+    if not "%MVNW_REPOURL%" == "" (
+        SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
+    )
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Couldn't find %WRAPPER_JAR%, downloading it ...
+        echo Downloading from: %DOWNLOAD_URL%
+    )
+
+    powershell -Command "&{"^
+		"$webclient = new-object System.Net.WebClient;"^
+		"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
+		"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
+		"}"^
+		"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
+		"}"
+    if "%MVNW_VERBOSE%" == "true" (
+        echo Finished downloading %WRAPPER_JAR%
+    )
+)
+@REM End of extension
+
+@REM Provide a "standardized" way to retrieve the CLI args that will
+@REM work with both Windows and non-Windows executions.
+set MAVEN_CMD_LINE_ARGS=%*
+
+%MAVEN_JAVA_EXE% ^
+  %JVM_CONFIG_MAVEN_PROPS% ^
+  %MAVEN_OPTS% ^
+  %MAVEN_DEBUG_OPTS% ^
+  -classpath %WRAPPER_JAR% ^
+  "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
+  %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
+if ERRORLEVEL 1 goto error
+goto end
+
+:error
+set ERROR_CODE=1
+
+:end
+@endlocal & set ERROR_CODE=%ERROR_CODE%
+
+if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
+@REM check for post script, once with legacy .bat ending and once with .cmd ending
+if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
+if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\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%
+
+cmd /C exit /B %ERROR_CODE%

kt-user/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>keystone</artifactId>
+        <groupId>org.matrix</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>kt-user</artifactId>
+
+    <packaging>jar</packaging>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>org.matrix</groupId>
+            <artifactId>kt-kit</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
+            <version>3.5.0</version>
+        </dependency>
+
+        <!--swagger-->
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger2</artifactId>
+            <version>2.9.2</version>
+        </dependency>
+
+        <!--swagger ui-->
+        <dependency>
+            <groupId>io.springfox</groupId>
+            <artifactId>springfox-swagger-ui</artifactId>
+            <version>2.9.2</version>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

kt-user/src/main/java/org/matrix/ZentaoApplication.java

+package org.matrix;
+
+import lombok.extern.slf4j.Slf4j;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.domain.EntityScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+/**
+ * Hello world!
+ *
+ * @author matrix
+ */
+@Slf4j
+@EnableScheduling
+@SpringBootApplication
+@EntityScan(basePackages = {"org.matrix.remote.entity","org.matrix.local.entity"})
+@MapperScan(basePackages = {"org.matrix.remote.mapper","org.matrix.local.mapper"})
+public class ZentaoApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ZentaoApplication.class, args);
+    }
+
+}

kt-user/src/main/java/org/matrix/local/entity/BaseEntity.java

+package org.matrix.local.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * BaseEntity.
+ *
+ * @author Matrix <xhyrzldf@gmail.com>
+ * @since 2021/11/22 at 4:02 下午
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@ApiModel(value = "基础对象")
+public abstract class BaseEntity implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键id
+     */
+    @TableId(type = IdType.AUTO)
+    @ApiModelProperty("主键id,从0开始自增")
+    private Long id;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    @ApiModelProperty("数据创建时间")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    @ApiModelProperty("数据更新时间")
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "Asia/Shanghai")
+    private LocalDateTime updateTime;
+
+}

kt-user/src/main/java/org/matrix/local/entity/Project.java

+package org.matrix.local.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+import org.matrix.local.entity.BaseEntity;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author matrix
+ * @since 2022-01-15
+ */
+@Accessors(chain = true)
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value = "Project对象", description = "项目")
+@TableName(value = "kt_project")
+public class Project extends BaseEntity {
+
+    @ApiModelProperty("名称")
+    private String name;
+
+}

kt-user/src/main/java/org/matrix/local/entity/User.java

+package org.matrix.local.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import org.matrix.local.entity.BaseEntity;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author matrix
+ * @since 2022-01-15
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value = "User对象", description = "用户")
+@TableName(value = "kt_user")
+public class User extends BaseEntity{
+
+    @ApiModelProperty("名称")
+    private String name;
+
+    @ApiModelProperty("账号")
+    private String account;
+
+    @ApiModelProperty("密码")
+    private String password;
+
+}

kt-user/src/main/java/org/matrix/local/entity/UserProject.java

+package org.matrix.local.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModel;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.Accessors;
+import org.matrix.local.entity.BaseEntity;
+
+/**
+ * <p>
+ *
+ * </p>
+ *
+ * @author matrix
+ * @since 2022-01-15
+ */
+@Accessors(chain = true)
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value = "UserProject对象", description = "用户项目关系")
+@TableName(value = "kt_user_project")
+public class UserProject extends BaseEntity {
+
+    private Long userId;
+
+    private Long projectId;
+
+}

kt-user/src/main/java/org/matrix/local/mapper/ProjectMapper.java

+package org.matrix.local.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.matrix.local.entity.Project;
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author matrix
+ * @since 2022-01-15
+ */
+@DS("master")
+@Repository
+public interface ProjectMapper extends BaseMapper<Project> {
+
+}

kt-user/src/main/java/org/matrix/local/mapper/UserMapper.java

+package org.matrix.local.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.matrix.local.entity.User;
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author matrix
+ * @since 2022-01-15
+ */
+@DS("master")
+@Repository
+public interface UserMapper extends BaseMapper<User> {
+}

kt-user/src/main/java/org/matrix/local/mapper/UserProjectMapper.java

+package org.matrix.local.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.matrix.local.entity.UserProject;
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>
+ * Mapper 接口
+ * </p>
+ *
+ * @author matrix
+ * @since 2022-01-15
+ */
+@DS("master")
+@Repository
+public interface UserProjectMapper extends BaseMapper<UserProject> {
+}

kt-user/src/main/java/org/matrix/local/service/IProjectService.java

+package org.matrix.local.service;
+
+public interface IProjectService {
+
+}

kt-user/src/main/java/org/matrix/local/service/IUserService.java

+package org.matrix.local.service;
+
+public interface IUserService {
+}

kt-user/src/main/java/org/matrix/local/service/impl/ProjectServiceImpl.java

+package org.matrix.local.service.impl;
+
+import org.matrix.local.service.IProjectService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class ProjectServiceImpl implements IProjectService {
+}

kt-user/src/main/java/org/matrix/local/service/impl/UserServiceImpl.java

+package org.matrix.local.service.impl;
+
+import org.matrix.local.service.IUserService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class UserServiceImpl implements IUserService {
+
+
+
+}

kt-user/src/main/java/org/matrix/remote/entity/ZtProject.java

+package org.matrix.remote.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModel;
+import lombok.*;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author c
+ * @since 2022-02-15
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@TableName("zt_project")
+@ApiModel(value = "ZtProject对象", description = "")
+public class ZtProject {
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    private Integer project;
+
+    private String model;
+
+    private String type;
+
+    private String lifetime;
+
+    private String budget;
+
+    @TableField(value = "budgetUnit")
+    private String budgetUnit;
+
+    private String attribute;
+
+    private Float percent;
+
+    private String milestone;
+
+    private String output;
+
+    private String auth;
+
+    private Integer parent;
+
+    private String path;
+
+    private Integer grade;
+
+    private String name;
+
+    private String code;
+
+    private LocalDate begin;
+
+    private LocalDate end;
+
+    @TableField(value = "realBegan")
+    private LocalDate realBegan;
+
+    @TableField(value = "realEnd")
+    private LocalDate realEnd;
+
+    private Integer days;
+
+    private String status;
+
+    @TableField(value = "subStatus")
+    private String subStatus;
+
+    private String pri;
+
+//    private String desc;
+
+    private Integer version;
+
+    @TableField(value = "parentVersion")
+    private Integer parentVersion;
+
+    @TableField(value = "planDuration")
+    private Integer planDuration;
+
+    @TableField(value = "realDuration")
+    private Integer realDuration;
+
+    @TableField(value = "openedBy")
+    private String openedBy;
+
+    @TableField(value = "openedDate")
+    private LocalDateTime openedDate;
+
+    @TableField(value = "openedVersion")
+    private String openedVersion;
+
+    @TableField(value = "lastEditedBy")
+    private String lastEditedBy;
+
+    @TableField(value = "lastEditedDate")
+    private LocalDateTime lastEditedDate;
+
+    @TableField(value = "closedBy")
+    private String closedBy;
+
+    @TableField(value = "closedDate")
+    private LocalDateTime closedDate;
+
+    @TableField(value = "canceledBy")
+    private String canceledBy;
+
+    @TableField(value = "canceledDate")
+    private LocalDateTime canceledDate;
+
+    private String po;
+
+    private String pm;
+
+    private String qd;
+
+    private String rd;
+
+    private String team;
+
+    private String acl;
+
+    private String whitelist;
+
+//    private Integer order;
+
+    private String deleted;
+
+
+}

kt-user/src/main/java/org/matrix/remote/entity/ZtUser.java

+package org.matrix.remote.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import io.swagger.annotations.ApiModel;
+import lombok.*;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author c
+ * @since 2022-02-15
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@TableName("zt_user")
+@ApiModel(value = "ZtUser对象", description = "")
+public class ZtUser {
+
+    @TableId(value = "id", type = IdType.AUTO)
+    private Integer id;
+
+    private Integer company;
+
+    private String type;
+
+    private Integer dept;
+
+    private String account;
+
+    private String password;
+
+    private String role;
+
+    private String realname;
+
+    private String pinyin;
+
+    private String nickname;
+
+    private String commiter;
+
+    private String avatar;
+
+    private LocalDate birthday;
+
+    private String gender;
+
+    private String email;
+
+    private String skype;
+
+    private String qq;
+
+    private String mobile;
+
+    private String phone;
+
+    private String weixin;
+
+    private String dingding;
+
+    private String slack;
+
+    private String whatsapp;
+
+    private String address;
+
+    private String zipcode;
+
+    private String nature;
+
+    private String analysis;
+
+    private String strategy;
+
+//    private LocalDate join;
+
+    private Integer visits;
+
+    private String ip;
+
+    private Integer last;
+
+    private Integer fails;
+
+    private LocalDateTime locked;
+
+    private String ranzhi;
+
+    private Integer score;
+
+    @TableField(value = "scoreLevel")
+    private Integer scoreLevel;
+
+    private String deleted;
+
+    @TableField(value = "clientStatus")
+    private String clientStatus;
+
+    @TableField(value = "clientLang")
+    private String clientLang;
+
+
+}

kt-user/src/main/java/org/matrix/remote/entity/ZtUserView.java

+package org.matrix.remote.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModel;
+import lombok.*;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author c
+ * @since 2022-02-15
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@TableName("zt_userview")
+@ApiModel(value = "ZtUserview对象", description = "")
+public class ZtUserView {
+
+    private String account;
+
+    private String programs;
+
+    private String products;
+
+    private String projects;
+
+    private String sprints;
+
+
+}

kt-user/src/main/java/org/matrix/remote/mapper/ZtProjectMapper.java

+package org.matrix.remote.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import org.matrix.remote.entity.ZtProject;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author c
+ * @since 2022-02-15
+ */
+@DS("zentao")
+@Repository
+public interface ZtProjectMapper extends BaseMapper<ZtProject> {
+
+}

kt-user/src/main/java/org/matrix/remote/mapper/ZtUserMapper.java

+package org.matrix.remote.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import org.matrix.remote.entity.ZtUser;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author c
+ * @since 2022-02-15
+ */
+@DS("zentao")
+@Repository
+public interface ZtUserMapper extends BaseMapper<ZtUser> {
+
+}

kt-user/src/main/java/org/matrix/remote/mapper/ZtUserViewMapper.java

+package org.matrix.remote.mapper;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import org.matrix.remote.entity.ZtUserView;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author c
+ * @since 2022-02-15
+ */
+@DS("zentao")
+@Repository
+public interface ZtUserViewMapper extends BaseMapper<ZtUserView> {
+
+}

kt-user/src/main/java/org/matrix/remote/service/IDataCollector.java

+package org.matrix.remote.service;
+
+/**
+ * 禅道数据收集工具
+ */
+public interface IDataCollector {
+
+    void execute();
+
+}

kt-user/src/main/java/org/matrix/remote/service/impl/DataCollectorImpl.java

+package org.matrix.remote.service.impl;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import org.matrix.local.entity.Project;
+import org.matrix.local.entity.User;
+import org.matrix.local.entity.UserProject;
+import org.matrix.local.mapper.ProjectMapper;
+import org.matrix.local.mapper.UserMapper;
+import org.matrix.local.mapper.UserProjectMapper;
+import org.matrix.remote.entity.ZtProject;
+import org.matrix.remote.entity.ZtUser;
+import org.matrix.remote.entity.ZtUserView;
+import org.matrix.remote.mapper.ZtProjectMapper;
+import org.matrix.remote.mapper.ZtUserMapper;
+import org.matrix.remote.mapper.ZtUserViewMapper;
+import org.matrix.remote.service.IDataCollector;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Service
+public class DataCollectorImpl implements IDataCollector {
+
+    @Autowired
+    private ZtUserMapper ztUserMapper;
+    @Autowired
+    private ZtUserViewMapper ztUserViewMapper;
+    @Autowired
+    private ZtProjectMapper ztProjectMapper;
+    @Autowired
+    private UserMapper userMapper;
+    @Autowired
+    private ProjectMapper projectMapper;
+    @Autowired
+    private UserProjectMapper userProjectMapper;
+
+    private List<ZtUser> ztUsers = new ArrayList<>();
+    private List<ZtUserView> ztUserViews = new ArrayList<>();
+    private List<ZtProject> ztProjects = new ArrayList<>();
+
+    @Override
+    public void execute() {
+        //用户数据
+        collectUser();
+        saveUser();
+        //项目数据
+        collectProject();
+        saveProject();
+        //用户项目关系数据
+        collectUserView();
+        saveUserProject();
+    }
+
+    /**
+     * 从禅道数据库读取用户数据
+     */
+    private void collectUser() {
+        ztUsers.clear();
+        ztUsers = ztUserMapper.selectList(Wrappers.lambdaQuery());
+    }
+
+
+    /**
+     * 从禅道数据库读取项目数据
+     */
+    private void collectProject() {
+        ztProjects.clear();
+        ztProjects = ztProjectMapper.selectList(Wrappers.lambdaQuery());
+    }
+
+    /**
+     * 从禅道数据库读取用户相关项目关系数据
+     */
+    private void collectUserView() {
+        ztUserViews.clear();
+        ztUserViews = ztUserViewMapper.selectList(Wrappers.lambdaQuery());
+    }
+
+    /**
+     * 将用户数据保存到本地
+     */
+    private void saveUser() {
+        userMapper.delete(Wrappers.lambdaQuery());
+        ztUsers.stream()
+                .map(this::user)
+                .forEach(userMapper::insert);
+    }
+
+    /**
+     * 将项目数据保存到本地
+     */
+    private void saveProject() {
+        projectMapper.delete(Wrappers.lambdaQuery());
+        ztProjects.stream()
+                .map(this::project)
+                .forEach(projectMapper::insert);
+    }
+
+    /**
+     * 将用户项目关系数据保存到本地
+     */
+    private void saveUserProject() {
+        userProjectMapper.delete(Wrappers.lambdaQuery());
+        ztUserViews.stream()
+                .flatMap(ztUserView -> userProjects(ztUserView).stream())
+                .forEach(userProjectMapper::insert);
+    }
+
+    //------------------------private------------------------------------//
+
+    private User user(ZtUser ztUser) {
+        return new User(ztUser.getRealname(), ztUser.getAccount(), ztUser.getPassword());
+    }
+
+    private Project project(ZtProject ztProject) {
+        return new Project(ztProject.getName());
+    }
+
+    private List<UserProject> userProjects(ZtUserView ztUserView) {
+        Long userId = userMapper.selectOne(Wrappers.<User>lambdaQuery().eq(User::getAccount, ztUserView.getAccount())).getId();
+        return toList(ztUserView.getProjects()).stream()
+                .map(Long::parseLong)
+                .map(projectId -> new UserProject(userId, projectId))
+                .collect(Collectors.toList());
+    }
+
+    private List<String> toList(String content) {
+        List<String> result = Arrays.stream(content.split(",")).collect(Collectors.toList());
+        result.remove(0);
+        return result;
+    }
+
+}

kt-user/src/main/java/org/matrix/remote/task/DataCollectorTask.java

+package org.matrix.remote.task;
+
+import lombok.extern.slf4j.Slf4j;
+import org.matrix.remote.service.IDataCollector;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+/**
+ * 定时任务
+ */
+@Slf4j
+@Component
+public class DataCollectorTask {
+
+
+    @Autowired
+    IDataCollector dataCollector;
+
+    /**
+     * 同步禅道取的用户和项目数据
+     * 每小时收集一次
+     */
+    @Scheduled(cron = "0 0 */1 * * ?")
+    public void collect(){
+        log.info("同步禅道用户项目数据...");
+        dataCollector.execute();
+        log.info("同步结束....");
+    }
+
+}

kt-user/src/main/resources/application.yml

+spring:
+  application:
+    name: keystone
+  datasource:
+    dynamic:
+      primary: master #设置默认的数据源或者数据源组,默认值即为master
+      strict: true #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
+      datasource:
+        master:  #增加默认数据源
+          driverClassName: com.mysql.cj.jdbc.Driver
+          url: jdbc:mysql://192.168.100.248:3306/key_stone?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC
+          username: root
+          password: root
+        zentao:
+          driverClassName: com.mysql.cj.jdbc.Driver
+          url: jdbc:mysql://192.168.100.247:3306/zentao?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=UTC&&zeroDateTimeBehavior=convertToNull
+          username: root
+          password: 123456
\ No newline at end of file

kt-user/src/test/java/org/matrix/ktzentao/KtZentaoApplicationTests.java

+package org.matrix.ktzentao;
+
+import org.junit.jupiter.api.Test;
+import org.matrix.ZentaoApplication;
+import org.matrix.remote.service.IDataCollector;
+import org.matrix.remote.task.DataCollectorTask;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest(classes = ZentaoApplication.class)
+class KtZentaoApplicationTests {
+
+    @Autowired
+    IDataCollector dataCollector;
+    @Autowired
+    DataCollectorTask dataCollectorTask;
+    @Test
+    void test() {
+        dataCollectorTask.collect();
+    }
+
+}