diff --git a/pom.xml b/pom.xml
index e3b1eb9..c0cbd03 100644
--- a/pom.xml
+++ b/pom.xml
@@ -62,6 +62,10 @@
spring-boot-starter-web
+
+ org.postgresql
+ postgresql
+
@@ -110,6 +114,7 @@
+
com.github.ben-manes.caffeine
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 {
+
+}
+
+
+
+
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 {
+
+}
+
+
+
+
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 {
+
+}
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 {
+
+}
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 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 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 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 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
+ 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
+ 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 list = devopsDeviceInfoService.list();
+ for (DevopsDeviceInfo one : list){
+ if (one.getDeviceType() == 1){
+ List 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 wrapper = new UpdateWrapper<>();
+ wrapper.eq("global_pic", info.getImage());
+ boolean update = transitUserRecordService.update(transitUserRecord, wrapper);
+ if (update) {
+ logger.info("人脸-:更新成功");
+ }
+ }
+ }
+ }
+ if (one.getDeviceType() == 2){
+ List 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 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 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
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 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+