diff --git a/pom.xml b/pom.xml
index e3b1eb9..c0cbd03 100644
--- a/pom.xml
+++ b/pom.xml
@@ -62,6 +62,10 @@
 			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
 
+		<dependency>
+			<groupId>org.postgresql</groupId>
+			<artifactId>postgresql</artifactId>
+		</dependency>
 
 		<!--lombok-->
 		<dependency>
@@ -110,6 +114,7 @@
 		</dependency>
 
 
+
 		<!--caffeine本地缓存-->
 		<dependency>
 			<groupId>com.github.ben-manes.caffeine</groupId>
diff --git a/src/main/java/com/ssf/mysqloracletest/domain/TMotorvehicle.java b/src/main/java/com/ssf/mysqloracletest/domain/TMotorvehicle.java
new file mode 100644
index 0000000..4bff23f
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/domain/TMotorvehicle.java
@@ -0,0 +1,419 @@
+package com.ssf.mysqloracletest.domain;
+
+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.io.Serializable;
+import lombok.Data;
+
+/**
+ * 
+ * @TableName t_motorvehicle
+ */
+@TableName(value ="t_motorvehicle")
+@Data
+public class TMotorvehicle implements Serializable {
+    /**
+     * 
+     */
+    private String motorvehicleid;
+
+    /**
+     * 
+     */
+    private String infokind;
+
+    /**
+     * 
+     */
+    private String sourceid;
+
+    /**
+     * 
+     */
+    private String tollgateid;
+
+    /**
+     * 
+     */
+    private String deviceid;
+
+    /**
+     * 
+     */
+    private String storageurl1;
+
+    /**
+     * 
+     */
+    private String storageurl2;
+
+    /**
+     * 
+     */
+    private String storageurl3;
+
+    /**
+     * 
+     */
+    private String storageurl4;
+
+    /**
+     * 
+     */
+    private String storageurl5;
+
+    /**
+     * 
+     */
+    private String lefttopx;
+
+    /**
+     * 
+     */
+    private String lefttopy;
+
+    /**
+     * 
+     */
+    private String rightbtmx;
+
+    /**
+     * 
+     */
+    private String rightbtmy;
+
+    /**
+     * 
+     */
+    private String marktime;
+
+    /**
+     * 
+     */
+    private String appeartime;
+
+    /**
+     * 
+     */
+    private String disappeartime;
+
+    /**
+     * 
+     */
+    private String laneno;
+
+    /**
+     * 
+     */
+    private String hasplate;
+
+    /**
+     * 
+     */
+    private String plateclass;
+
+    /**
+     * 
+     */
+    private String platecolor;
+
+    /**
+     * 
+     */
+    private String plateno;
+
+    /**
+     * 
+     */
+    private String platenoattach;
+
+    /**
+     * 
+     */
+    private String platedescribe;
+
+    /**
+     * 
+     */
+    private String isdecked;
+
+    /**
+     * 
+     */
+    private String isaltered;
+
+    /**
+     * 
+     */
+    private String iscovered;
+
+    /**
+     * 
+     */
+    private String speed;
+
+    /**
+     * 
+     */
+    private String direction;
+
+    /**
+     * 
+     */
+    private String drivingstatuscode;
+
+    /**
+     * 
+     */
+    private String usingpropertiescode;
+
+    /**
+     * 
+     */
+    private String vehicleclass;
+
+    /**
+     * 
+     */
+    private String vehiclebrand;
+
+    /**
+     * 
+     */
+    private String vehiclemodel;
+
+    /**
+     * 
+     */
+    private String vehiclestyles;
+
+    /**
+     * 
+     */
+    private String vehiclelength;
+
+    /**
+     * 
+     */
+    private String vehiclewidth;
+
+    /**
+     * 
+     */
+    private String vehicleheight;
+
+    /**
+     * 
+     */
+    private String vehiclecolor;
+
+    /**
+     * 
+     */
+    private String vehiclecolordepth;
+
+    /**
+     * 
+     */
+    private String vehiclehood;
+
+    /**
+     * 
+     */
+    private String vehicletrunk;
+
+    /**
+     * 
+     */
+    private String vehiclewheel;
+
+    /**
+     * 
+     */
+    private String wheelprintedpattern;
+
+    /**
+     * 
+     */
+    private String vehiclewindow;
+
+    /**
+     * 
+     */
+    private String vehicleroof;
+
+    /**
+     * 
+     */
+    private String vehicledoor;
+
+    /**
+     * 
+     */
+    private String sideofvehicle;
+
+    /**
+     * 
+     */
+    private String carofvehicle;
+
+    /**
+     * 
+     */
+    private String rearviewmirror;
+
+    /**
+     * 
+     */
+    private String vehiclechassis;
+
+    /**
+     * 
+     */
+    private String vehicleshielding;
+
+    /**
+     * 
+     */
+    private String filmcolor;
+
+    /**
+     * 
+     */
+    private String ismodified;
+
+    /**
+     * 
+     */
+    private String hitmarkinfo;
+
+    /**
+     * 
+     */
+    private String vehiclebodydesc;
+
+    /**
+     * 
+     */
+    private String vehiclefrontitem;
+
+    /**
+     * 
+     */
+    private String descoffrontitem;
+
+    /**
+     * 
+     */
+    private String vehiclerearitem;
+
+    /**
+     * 
+     */
+    private String descofrearitem;
+
+    /**
+     * 
+     */
+    private String numofpassenger;
+
+    /**
+     * 
+     */
+    private String passtime;
+
+    /**
+     * 
+     */
+    private String nameofpassedroad;
+
+    /**
+     * 
+     */
+    private String issuspicious;
+
+    /**
+     * 
+     */
+    private String sunvisor;
+
+    /**
+     * 
+     */
+    private String safetybelt;
+
+    /**
+     * 
+     */
+    private String calling;
+
+    /**
+     * 
+     */
+    private String platecharreliability;
+
+    /**
+     * 
+     */
+    private String platereliability;
+
+    /**
+     * 
+     */
+    private String brandreliability;
+
+    /**
+     * 
+     */
+    private String rksj;
+
+    /**
+     * 
+     */
+    private String beforePasstime;
+
+    /**
+     * 
+     */
+    private String linkfacevehicleid;
+
+    /**
+     * 
+     */
+    private String linkvehicleid;
+
+    /**
+     * 
+     */
+    private String passTimeJgms;
+
+    /**
+     * 
+     */
+    private String lastMotorvehicleid;
+
+    /**
+     * 
+     */
+    private String lastDevId;
+
+    /**
+     * 
+     */
+    private String passTimeDay;
+
+    /**
+     * 
+     */
+    private String passTimeHour;
+
+    /**
+     * 
+     */
+    private String lastPassTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file
diff --git a/src/main/java/com/ssf/mysqloracletest/domain/TStrhInfo.java b/src/main/java/com/ssf/mysqloracletest/domain/TStrhInfo.java
new file mode 100644
index 0000000..3afa1ea
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/domain/TStrhInfo.java
@@ -0,0 +1,194 @@
+package com.ssf.mysqloracletest.domain;
+
+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.io.Serializable;
+import lombok.Data;
+
+/**
+ * 
+ * @TableName t_strh_info
+ */
+@TableName(value ="t_strh_info")
+@Data
+public class TStrhInfo implements Serializable {
+    /**
+     * 
+     */
+    private String objectid;
+
+    /**
+     * 
+     */
+    private String type;
+
+    /**
+     * 
+     */
+    private String vendor;
+
+    /**
+     * 
+     */
+    private String algorithmversion;
+
+    /**
+     * 
+     */
+    private String regionid;
+
+    /**
+     * 
+     */
+    private String cameraidx;
+
+    /**
+     * 
+     */
+    private String capturetime;
+
+    /**
+     * 
+     */
+    private String image;
+
+    /**
+     * 
+     */
+    private String imageFormat;
+
+    /**
+     * 
+     */
+    private String vertices;
+
+    /**
+     * 
+     */
+    private String smalimage;
+
+    /**
+     * 
+     */
+    private String smalimageFormat;
+
+    /**
+     * 
+     */
+    private String featureType;
+
+    /**
+     * 
+     */
+    private String featureBlob;
+
+    /**
+     * 
+     */
+    private String objectidOld;
+
+    /**
+     * 
+     */
+    private String ageLowerLimit;
+
+    /**
+     * 
+     */
+    private String ageUpLimit;
+
+    /**
+     * 
+     */
+    private String blackType;
+
+    /**
+     * 
+     */
+    private String capStyle;
+
+    /**
+     * 
+     */
+    private String genderCode;
+
+    /**
+     * 
+     */
+    private String glassStyle;
+
+    /**
+     * 
+     */
+    private String mustacheStyle;
+
+    /**
+     * 
+     */
+    private String respiratorColor;
+
+    /**
+     * 
+     */
+    private String stAge;
+
+    /**
+     * 
+     */
+    private String stAgeValue;
+
+    /**
+     * 
+     */
+    private String stExpression;
+
+    /**
+     * 
+     */
+    private String stHelmetStyle;
+
+    /**
+     * 
+     */
+    private String rksj;
+
+    /**
+     * 
+     */
+    private String gxsj;
+
+    /**
+     * 
+     */
+    private String entitycreatetime;
+
+    /**
+     * 
+     */
+    private String entityupdatetime;
+
+    /**
+     * 
+     */
+    private String facescene;
+
+    /**
+     * 
+     */
+    private String linkfacevehicleid;
+
+    /**
+     * 
+     */
+    private String linkvehicleid;
+
+    /**
+     * 
+     */
+    private String plateno;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file
diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/TMotorvehicleMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/TMotorvehicleMapper.java
new file mode 100644
index 0000000..0a353ed
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/mapper/TMotorvehicleMapper.java
@@ -0,0 +1,18 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.ssf.mysqloracletest.domain.TMotorvehicle;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author 28758
+* @description 针对表【t_motorvehicle】的数据库操作Mapper
+* @createDate 2023-12-14 19:17:07
+* @Entity com.ssf.mysqloracletest.domain.TMotorvehicle
+*/
+public interface TMotorvehicleMapper extends BaseMapper<TMotorvehicle> {
+
+}
+
+
+
+
diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/TStrhInfoMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/TStrhInfoMapper.java
new file mode 100644
index 0000000..b9ed180
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/mapper/TStrhInfoMapper.java
@@ -0,0 +1,18 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.ssf.mysqloracletest.domain.TStrhInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author 28758
+* @description 针对表【t_strh_info】的数据库操作Mapper
+* @createDate 2023-12-14 20:14:20
+* @Entity com.ssf.mysqloracletest.domain.TStrhInfo
+*/
+public interface TStrhInfoMapper extends BaseMapper<TStrhInfo> {
+
+}
+
+
+
+
diff --git a/src/main/java/com/ssf/mysqloracletest/service/TMotorvehicleService.java b/src/main/java/com/ssf/mysqloracletest/service/TMotorvehicleService.java
new file mode 100644
index 0000000..40df31b
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/service/TMotorvehicleService.java
@@ -0,0 +1,13 @@
+package com.ssf.mysqloracletest.service;
+
+import com.ssf.mysqloracletest.domain.TMotorvehicle;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author 28758
+* @description 针对表【t_motorvehicle】的数据库操作Service
+* @createDate 2023-12-14 19:17:07
+*/
+public interface TMotorvehicleService extends IService<TMotorvehicle> {
+
+}
diff --git a/src/main/java/com/ssf/mysqloracletest/service/TStrhInfoService.java b/src/main/java/com/ssf/mysqloracletest/service/TStrhInfoService.java
new file mode 100644
index 0000000..944f58a
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/service/TStrhInfoService.java
@@ -0,0 +1,13 @@
+package com.ssf.mysqloracletest.service;
+
+import com.ssf.mysqloracletest.domain.TStrhInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author 28758
+* @description 针对表【t_strh_info】的数据库操作Service
+* @createDate 2023-12-14 20:14:20
+*/
+public interface TStrhInfoService extends IService<TStrhInfo> {
+
+}
diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceInfoServiceImpl.java
index d3751b5..fb7b661 100644
--- a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceInfoServiceImpl.java
+++ b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceInfoServiceImpl.java
@@ -1,10 +1,12 @@
 package com.ssf.mysqloracletest.service.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ssf.mysqloracletest.domain.DevopsDeviceInfo;
 import com.ssf.mysqloracletest.mapper.DevopsDeviceInfoMapper;
 import com.ssf.mysqloracletest.service.DevopsDeviceInfoService;
+import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
 /**
@@ -14,6 +16,8 @@ import org.springframework.stereotype.Service;
  * @since 2023-12-14 16:26:46
  */
 @Service
+@DS("mysql")
+@RequiredArgsConstructor
 public class DevopsDeviceInfoServiceImpl extends ServiceImpl<DevopsDeviceInfoMapper, DevopsDeviceInfo> implements DevopsDeviceInfoService {
 
     @Override
diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceStatusServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceStatusServiceImpl.java
index 98f602b..88272df 100644
--- a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceStatusServiceImpl.java
+++ b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceStatusServiceImpl.java
@@ -1,10 +1,12 @@
 package com.ssf.mysqloracletest.service.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ssf.mysqloracletest.domain.DevopsDeviceStatus;
 import com.ssf.mysqloracletest.mapper.DevopsDeviceStatusMapper;
 import com.ssf.mysqloracletest.service.DevopsDeviceStatusService;
+import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
 /**
@@ -14,6 +16,8 @@ import org.springframework.stereotype.Service;
  * @since 2023-12-14 16:26:47
  */
 @Service
+@DS("mysql")
+@RequiredArgsConstructor
 public class DevopsDeviceStatusServiceImpl extends ServiceImpl<DevopsDeviceStatusMapper, DevopsDeviceStatus> implements DevopsDeviceStatusService {
 
     @Override
diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java
index 3ba0e2c..0a7871b 100644
--- a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java
+++ b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java
@@ -1,10 +1,12 @@
 package com.ssf.mysqloracletest.service.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ssf.mysqloracletest.domain.DevopsVideoInfo;
 import com.ssf.mysqloracletest.mapper.DevopsVideoInfoMapper;
 import com.ssf.mysqloracletest.service.DevopsVideoInfoService;
+import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
 /**
@@ -14,6 +16,8 @@ import org.springframework.stereotype.Service;
  * @since 2023-12-14 16:26:47
  */
 @Service
+@DS("mysql")
+@RequiredArgsConstructor
 public class DevopsVideoInfoServiceImpl extends ServiceImpl<DevopsVideoInfoMapper, DevopsVideoInfo> implements DevopsVideoInfoService {
 
     @Override
diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoStatusServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoStatusServiceImpl.java
index 3c7c048..a61c634 100644
--- a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoStatusServiceImpl.java
+++ b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoStatusServiceImpl.java
@@ -1,10 +1,12 @@
 package com.ssf.mysqloracletest.service.impl;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ssf.mysqloracletest.domain.DevopsVideoStatus;
 import com.ssf.mysqloracletest.mapper.DevopsVideoStatusMapper;
 import com.ssf.mysqloracletest.service.DevopsVideoStatusService;
+import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 
 /**
@@ -14,6 +16,8 @@ import org.springframework.stereotype.Service;
  * @since 2023-12-14 16:26:47
  */
 @Service
+@DS("mysql")
+@RequiredArgsConstructor
 public class DevopsVideoStatusServiceImpl extends ServiceImpl<DevopsVideoStatusMapper, DevopsVideoStatus> implements DevopsVideoStatusService {
 
     @Override
diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/TMotorvehicleServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/TMotorvehicleServiceImpl.java
new file mode 100644
index 0000000..34645e0
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/service/impl/TMotorvehicleServiceImpl.java
@@ -0,0 +1,22 @@
+package com.ssf.mysqloracletest.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ssf.mysqloracletest.domain.TMotorvehicle;
+import com.ssf.mysqloracletest.service.TMotorvehicleService;
+import com.ssf.mysqloracletest.mapper.TMotorvehicleMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author 28758
+* @description 针对表【t_motorvehicle】的数据库操作Service实现
+* @createDate 2023-12-14 19:17:07
+*/
+@Service
+public class TMotorvehicleServiceImpl extends ServiceImpl<TMotorvehicleMapper, TMotorvehicle>
+    implements TMotorvehicleService{
+
+}
+
+
+
+
diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/TStrhInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/TStrhInfoServiceImpl.java
new file mode 100644
index 0000000..46aa9e1
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/service/impl/TStrhInfoServiceImpl.java
@@ -0,0 +1,22 @@
+package com.ssf.mysqloracletest.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ssf.mysqloracletest.domain.TStrhInfo;
+import com.ssf.mysqloracletest.service.TStrhInfoService;
+import com.ssf.mysqloracletest.mapper.TStrhInfoMapper;
+import org.springframework.stereotype.Service;
+
+/**
+* @author 28758
+* @description 针对表【t_strh_info】的数据库操作Service实现
+* @createDate 2023-12-14 20:14:20
+*/
+@Service
+public class TStrhInfoServiceImpl extends ServiceImpl<TStrhInfoMapper, TStrhInfo>
+    implements TStrhInfoService{
+
+}
+
+
+
+
diff --git a/src/main/java/com/ssf/mysqloracletest/task/UserAndVehicleRecordTask.java b/src/main/java/com/ssf/mysqloracletest/task/UserAndVehicleRecordTask.java
new file mode 100644
index 0000000..1e23fd3
--- /dev/null
+++ b/src/main/java/com/ssf/mysqloracletest/task/UserAndVehicleRecordTask.java
@@ -0,0 +1,134 @@
+package com.ssf.mysqloracletest.task;
+
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.ssf.mysqloracletest.domain.*;
+import com.ssf.mysqloracletest.service.*;
+import com.ssf.mysqloracletest.utils.ConfigParam;
+import com.ssf.mysqloracletest.utils.NumKit;
+import com.ssf.mysqloracletest.utils.StringKit;
+import lombok.RequiredArgsConstructor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.text.SimpleDateFormat;
+import java.util.List;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * 用户数据接入
+ */
+@Component
+@RequiredArgsConstructor
+public class UserAndVehicleRecordTask {
+
+    private static final Logger logger = LoggerFactory.getLogger(UserAndVehicleRecordTask.class);
+    String pattern = "yyyyMMddHHmmss";
+    String pattern1 = "yyyy-MM-dd HH-mm-ss";
+    SimpleDateFormat dateFormat = new SimpleDateFormat(pattern);
+    SimpleDateFormat dateFormat1 = new SimpleDateFormat(pattern1);
+
+    private final TransitUserRecordService transitUserRecordService;
+    private final TransitVehicleRecordService transitVehicleRecordService;
+    private final DevopsDeviceInfoService devopsDeviceInfoService;
+    private final TMotorvehicleService tMotorvehicleService;
+    private final TStrhInfoService tStrhInfoService;
+
+    /**
+     * 连云港 对接海康平台获取人员基础数据
+     * //
+     */
+    @Scheduled(initialDelay = 100, fixedDelay = 3000)
+    public void transNjjxx() {
+
+        if (!"true".equals(ConfigParam.UserAndVehicleSwitch)) {
+            return;
+        }
+
+
+        try {
+            List<DevopsDeviceInfo> list = devopsDeviceInfoService.list();
+            for (DevopsDeviceInfo one : list){
+                if (one.getDeviceType() == 1){
+                    List<TStrhInfo> infoList = tStrhInfoService.lambdaQuery().eq(TStrhInfo::getCameraidx, one.getGbsChannelNo()).list();
+                    for (TStrhInfo info : infoList){
+                        TransitUserRecord transitUserRecord = new TransitUserRecord();
+                        transitUserRecord.setPlaceCode(one.getPlaceCode());
+                        transitUserRecord.setPlaceName(one.getPlaceName());
+                        transitUserRecord.setDeviceCode(one.getDeviceCode());
+                        transitUserRecord.setDeviceName(one.getDeviceName());
+                        transitUserRecord.setGbsChannelNo(one.getGbsChannelNo());
+                        transitUserRecord.setDeviceAddress(one.getDeviceAddress());
+                        transitUserRecord.setOrientation(one.getOrientation());
+                        transitUserRecord.setDeviceIp(one.getDeviceIp());
+                        transitUserRecord.setGlobalPic(info.getImage());
+                        transitUserRecord.setPersonPic(info.getSmalimage());
+                        transitUserRecord.setPassTime(dateFormat.parse(info.getCapturetime()).getTime()/1000);
+                        transitUserRecord.setPartitionField(dateFormat1.parse(info.getCapturetime()));
+                        TransitUserRecord one1 = transitUserRecordService.lambdaQuery().eq(TransitUserRecord::getGlobalPic, info.getImage()).one();
+                        if (one1 == null){
+                            boolean save = transitUserRecordService.save(transitUserRecord);
+                            if (save){
+                                logger.info("人脸-:插入成功");
+                            }
+                        }else {
+                            UpdateWrapper<TransitUserRecord> wrapper = new UpdateWrapper<>();
+                            wrapper.eq("global_pic", info.getImage());
+                            boolean update = transitUserRecordService.update(transitUserRecord, wrapper);
+                            if (update) {
+                                logger.info("人脸-:更新成功");
+                            }
+                        }
+                    }
+                }
+                if (one.getDeviceType() == 2){
+                    List<TMotorvehicle> tMotorvehicleList = tMotorvehicleService.lambdaQuery().eq(TMotorvehicle::getTollgateid, one.getGbsChannelNo()).list();
+                    for (TMotorvehicle tMotorvehicle : tMotorvehicleList){
+                        TransitVehicleRecord transitVehicleRecord = new TransitVehicleRecord();
+                        transitVehicleRecord.setPlaceCode(one.getPlaceCode());
+                        transitVehicleRecord.setPlaceName(one.getPlaceName());
+                        transitVehicleRecord.setDeviceCode(one.getDeviceCode());
+                        transitVehicleRecord.setDeviceName(one.getDeviceName());
+                        transitVehicleRecord.setGbsChannelNo(one.getGbsChannelNo());
+                        transitVehicleRecord.setDeviceAddress(one.getDeviceAddress());
+                        transitVehicleRecord.setOrientation(one.getOrientation());
+                        transitVehicleRecord.setDeviceIp(one.getDeviceIp());
+                        transitVehicleRecord.setPlateNo(tMotorvehicle.getPlateno());
+                        transitVehicleRecord.setGlobalPic(tMotorvehicle.getStorageurl1());
+                        transitVehicleRecord.setPlatePic(tMotorvehicle.getStorageurl2());
+                        transitVehicleRecord.setSourceId(tMotorvehicle.getSourceid());
+                        transitVehicleRecord.setPassTime(dateFormat.parse(tMotorvehicle.getPasstime()).getTime()/1000);
+                        transitVehicleRecord.setPartitionField(dateFormat.parse(tMotorvehicle.getPasstime()));
+                        transitVehicleRecord.setPlateColor(tMotorvehicle.getPlatecolor());
+                        transitVehicleRecord.setVehicleColor(tMotorvehicle.getVehiclecolor());
+                        transitVehicleRecord.setVehicleBrand(tMotorvehicle.getVehiclebrand());
+                        TransitVehicleRecord one1 = transitVehicleRecordService.lambdaQuery().eq(TransitVehicleRecord::getGlobalPic, tMotorvehicle.getStorageurl1()).one();
+                        if (one1 == null){
+                            boolean save = transitVehicleRecordService.save(transitVehicleRecord);
+                            if (save){
+                                logger.info("车辆-:插入成功");
+                            }
+                        }else {
+                            UpdateWrapper<TransitVehicleRecord> wrapper = new UpdateWrapper<>();
+                            wrapper.eq("global_pic", tMotorvehicle.getStorageurl1());
+                            boolean update = transitVehicleRecordService.update(transitVehicleRecord, wrapper);
+                            if (update) {
+                                logger.info("车辆-:更新成功");
+                            }
+                        }
+                    }
+                }
+
+            }
+        } catch (Exception e) {
+            logger.info(StringKit.getTrace(e));
+        }
+
+    }
+
+
+}
diff --git a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java b/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java
index 8e868dd..20c9adf 100644
--- a/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java
+++ b/src/main/java/com/ssf/mysqloracletest/utils/ConfigParam.java
@@ -54,5 +54,6 @@ public class ConfigParam {
     public static String wshttpurl = PropertiesUtil.queryPropertiesByKey("wshttpurl");
     public static String wsDownloadPicPath = PropertiesUtil.queryPropertiesByKey("wsDownloadPicPath");
     public static String wsDownloadPicAreaStart = PropertiesUtil.queryPropertiesByKey("wsDownloadPicAreaStart");
+    public static String UserAndVehicleSwitch = PropertiesUtil.queryPropertiesByKey("UserAndVehicleSwitch");
 
 }
diff --git a/src/main/resources/mapper/TMotorvehicleMapper.xml b/src/main/resources/mapper/TMotorvehicleMapper.xml
new file mode 100644
index 0000000..c3b0ab5
--- /dev/null
+++ b/src/main/resources/mapper/TMotorvehicleMapper.xml
@@ -0,0 +1,91 @@
+<?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.ssf.mysqloracletest.mapper.TMotorvehicleMapper">
+
+    <resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.TMotorvehicle">
+            <result property="motorvehicleid" column="motorvehicleid" jdbcType="VARCHAR"/>
+            <result property="infokind" column="infokind" jdbcType="VARCHAR"/>
+            <result property="sourceid" column="sourceid" jdbcType="VARCHAR"/>
+            <result property="tollgateid" column="tollgateid" jdbcType="VARCHAR"/>
+            <result property="deviceid" column="deviceid" jdbcType="VARCHAR"/>
+            <result property="storageurl1" column="storageurl1" jdbcType="VARCHAR"/>
+            <result property="storageurl2" column="storageurl2" jdbcType="VARCHAR"/>
+            <result property="storageurl3" column="storageurl3" jdbcType="VARCHAR"/>
+            <result property="storageurl4" column="storageurl4" jdbcType="VARCHAR"/>
+            <result property="storageurl5" column="storageurl5" jdbcType="VARCHAR"/>
+            <result property="lefttopx" column="lefttopx" jdbcType="VARCHAR"/>
+            <result property="lefttopy" column="lefttopy" jdbcType="VARCHAR"/>
+            <result property="rightbtmx" column="rightbtmx" jdbcType="VARCHAR"/>
+            <result property="rightbtmy" column="rightbtmy" jdbcType="VARCHAR"/>
+            <result property="marktime" column="marktime" jdbcType="VARCHAR"/>
+            <result property="appeartime" column="appeartime" jdbcType="VARCHAR"/>
+            <result property="disappeartime" column="disappeartime" jdbcType="VARCHAR"/>
+            <result property="laneno" column="laneno" jdbcType="VARCHAR"/>
+            <result property="hasplate" column="hasplate" jdbcType="VARCHAR"/>
+            <result property="plateclass" column="plateclass" jdbcType="VARCHAR"/>
+            <result property="platecolor" column="platecolor" jdbcType="VARCHAR"/>
+            <result property="plateno" column="plateno" jdbcType="VARCHAR"/>
+            <result property="platenoattach" column="platenoattach" jdbcType="VARCHAR"/>
+            <result property="platedescribe" column="platedescribe" jdbcType="VARCHAR"/>
+            <result property="isdecked" column="isdecked" jdbcType="VARCHAR"/>
+            <result property="isaltered" column="isaltered" jdbcType="VARCHAR"/>
+            <result property="iscovered" column="iscovered" jdbcType="VARCHAR"/>
+            <result property="speed" column="speed" jdbcType="VARCHAR"/>
+            <result property="direction" column="direction" jdbcType="VARCHAR"/>
+            <result property="drivingstatuscode" column="drivingstatuscode" jdbcType="VARCHAR"/>
+            <result property="usingpropertiescode" column="usingpropertiescode" jdbcType="VARCHAR"/>
+            <result property="vehicleclass" column="vehicleclass" jdbcType="VARCHAR"/>
+            <result property="vehiclebrand" column="vehiclebrand" jdbcType="VARCHAR"/>
+            <result property="vehiclemodel" column="vehiclemodel" jdbcType="VARCHAR"/>
+            <result property="vehiclestyles" column="vehiclestyles" jdbcType="VARCHAR"/>
+            <result property="vehiclelength" column="vehiclelength" jdbcType="VARCHAR"/>
+            <result property="vehiclewidth" column="vehiclewidth" jdbcType="VARCHAR"/>
+            <result property="vehicleheight" column="vehicleheight" jdbcType="VARCHAR"/>
+            <result property="vehiclecolor" column="vehiclecolor" jdbcType="VARCHAR"/>
+            <result property="vehiclecolordepth" column="vehiclecolordepth" jdbcType="VARCHAR"/>
+            <result property="vehiclehood" column="vehiclehood" jdbcType="VARCHAR"/>
+            <result property="vehicletrunk" column="vehicletrunk" jdbcType="VARCHAR"/>
+            <result property="vehiclewheel" column="vehiclewheel" jdbcType="VARCHAR"/>
+            <result property="wheelprintedpattern" column="wheelprintedpattern" jdbcType="VARCHAR"/>
+            <result property="vehiclewindow" column="vehiclewindow" jdbcType="VARCHAR"/>
+            <result property="vehicleroof" column="vehicleroof" jdbcType="VARCHAR"/>
+            <result property="vehicledoor" column="vehicledoor" jdbcType="VARCHAR"/>
+            <result property="sideofvehicle" column="sideofvehicle" jdbcType="VARCHAR"/>
+            <result property="carofvehicle" column="carofvehicle" jdbcType="VARCHAR"/>
+            <result property="rearviewmirror" column="rearviewmirror" jdbcType="VARCHAR"/>
+            <result property="vehiclechassis" column="vehiclechassis" jdbcType="VARCHAR"/>
+            <result property="vehicleshielding" column="vehicleshielding" jdbcType="VARCHAR"/>
+            <result property="filmcolor" column="filmcolor" jdbcType="VARCHAR"/>
+            <result property="ismodified" column="ismodified" jdbcType="VARCHAR"/>
+            <result property="hitmarkinfo" column="hitmarkinfo" jdbcType="VARCHAR"/>
+            <result property="vehiclebodydesc" column="vehiclebodydesc" jdbcType="VARCHAR"/>
+            <result property="vehiclefrontitem" column="vehiclefrontitem" jdbcType="VARCHAR"/>
+            <result property="descoffrontitem" column="descoffrontitem" jdbcType="VARCHAR"/>
+            <result property="vehiclerearitem" column="vehiclerearitem" jdbcType="VARCHAR"/>
+            <result property="descofrearitem" column="descofrearitem" jdbcType="VARCHAR"/>
+            <result property="numofpassenger" column="numofpassenger" jdbcType="VARCHAR"/>
+            <result property="passtime" column="passtime" jdbcType="VARCHAR"/>
+            <result property="nameofpassedroad" column="nameofpassedroad" jdbcType="VARCHAR"/>
+            <result property="issuspicious" column="issuspicious" jdbcType="VARCHAR"/>
+            <result property="sunvisor" column="sunvisor" jdbcType="VARCHAR"/>
+            <result property="safetybelt" column="safetybelt" jdbcType="VARCHAR"/>
+            <result property="calling" column="calling" jdbcType="VARCHAR"/>
+            <result property="platecharreliability" column="platecharreliability" jdbcType="VARCHAR"/>
+            <result property="platereliability" column="platereliability" jdbcType="VARCHAR"/>
+            <result property="brandreliability" column="brandreliability" jdbcType="VARCHAR"/>
+            <result property="rksj" column="rksj" jdbcType="VARCHAR"/>
+            <result property="beforePasstime" column="before_passtime" jdbcType="VARCHAR"/>
+            <result property="linkfacevehicleid" column="linkfacevehicleid" jdbcType="VARCHAR"/>
+            <result property="linkvehicleid" column="linkvehicleid" jdbcType="VARCHAR"/>
+            <result property="passTimeJgms" column="pass_time_jgms" jdbcType="VARCHAR"/>
+            <result property="lastMotorvehicleid" column="last_motorvehicleid" jdbcType="VARCHAR"/>
+            <result property="lastDevId" column="last_dev_id" jdbcType="VARCHAR"/>
+            <result property="passTimeDay" column="pass_time_day" jdbcType="VARCHAR"/>
+            <result property="passTimeHour" column="pass_time_hour" jdbcType="VARCHAR"/>
+            <result property="lastPassTime" column="last_pass_time" jdbcType="VARCHAR"/>
+    </resultMap>
+
+
+</mapper>
diff --git a/src/main/resources/mapper/TStrhInfoMapper.xml b/src/main/resources/mapper/TStrhInfoMapper.xml
new file mode 100644
index 0000000..387e856
--- /dev/null
+++ b/src/main/resources/mapper/TStrhInfoMapper.xml
@@ -0,0 +1,46 @@
+<?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.ssf.mysqloracletest.mapper.TStrhInfoMapper">
+
+    <resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.TStrhInfo">
+            <result property="objectid" column="objectid" jdbcType="VARCHAR"/>
+            <result property="type" column="type" jdbcType="VARCHAR"/>
+            <result property="vendor" column="vendor" jdbcType="VARCHAR"/>
+            <result property="algorithmversion" column="algorithmversion" jdbcType="VARCHAR"/>
+            <result property="regionid" column="regionid" jdbcType="VARCHAR"/>
+            <result property="cameraidx" column="cameraidx" jdbcType="VARCHAR"/>
+            <result property="capturetime" column="capturetime" jdbcType="VARCHAR"/>
+            <result property="image" column="image" jdbcType="VARCHAR"/>
+            <result property="imageFormat" column="image_format" jdbcType="VARCHAR"/>
+            <result property="vertices" column="vertices" jdbcType="VARCHAR"/>
+            <result property="smalimage" column="smalimage" jdbcType="VARCHAR"/>
+            <result property="smalimageFormat" column="smalimage_format" jdbcType="VARCHAR"/>
+            <result property="featureType" column="feature_type" jdbcType="VARCHAR"/>
+            <result property="featureBlob" column="feature_blob" jdbcType="VARCHAR"/>
+            <result property="objectidOld" column="objectid_old" jdbcType="VARCHAR"/>
+            <result property="ageLowerLimit" column="age_lower_limit" jdbcType="VARCHAR"/>
+            <result property="ageUpLimit" column="age_up_limit" jdbcType="VARCHAR"/>
+            <result property="blackType" column="black_type" jdbcType="VARCHAR"/>
+            <result property="capStyle" column="cap_style" jdbcType="VARCHAR"/>
+            <result property="genderCode" column="gender_code" jdbcType="VARCHAR"/>
+            <result property="glassStyle" column="glass_style" jdbcType="VARCHAR"/>
+            <result property="mustacheStyle" column="mustache_style" jdbcType="VARCHAR"/>
+            <result property="respiratorColor" column="respirator_color" jdbcType="VARCHAR"/>
+            <result property="stAge" column="st_age" jdbcType="VARCHAR"/>
+            <result property="stAgeValue" column="st_age_value" jdbcType="VARCHAR"/>
+            <result property="stExpression" column="st_expression" jdbcType="VARCHAR"/>
+            <result property="stHelmetStyle" column="st_helmet_style" jdbcType="VARCHAR"/>
+            <result property="rksj" column="rksj" jdbcType="VARCHAR"/>
+            <result property="gxsj" column="gxsj" jdbcType="VARCHAR"/>
+            <result property="entitycreatetime" column="entitycreatetime" jdbcType="VARCHAR"/>
+            <result property="entityupdatetime" column="entityupdatetime" jdbcType="VARCHAR"/>
+            <result property="facescene" column="facescene" jdbcType="VARCHAR"/>
+            <result property="linkfacevehicleid" column="linkfacevehicleid" jdbcType="VARCHAR"/>
+            <result property="linkvehicleid" column="linkvehicleid" jdbcType="VARCHAR"/>
+            <result property="plateno" column="plateno" jdbcType="VARCHAR"/>
+    </resultMap>
+
+
+</mapper>