Merge remote-tracking branch 'origin/develop' into develop

config/application.properties

@@ -32,4 +32,4 @@ wsDownloadPicAreaStart=320924
 wsDownloadPicPath=/home/dataaccess
 wshttpurl=http://50.146.63.16:8080/syx_webservice/getCzrkImgage.xhtml?sfzh=
 #射阳 实有人口将有房屋号的数据根据户籍表数据清洗，并更新户主关系
-jwzUserInfoToActual=true
+jwzUserInfoToActual=false

pom.xml

@@ -109,6 +109,14 @@
 			<version>4.9.1</version>
 		</dependency>
 
+
+		<!--caffeine本地缓存-->
+		<dependency>
+			<groupId>com.github.ben-manes.caffeine</groupId>
+			<artifactId>caffeine</artifactId>
+			<version>2.9.0</version>
+		</dependency>
+
 	</dependencies>
 
 	<build>

src/main/java/com/ssf/mysqloracletest/cache/DeviceCache.java

@@ -0,0 +1,66 @@
+package com.ssf.mysqloracletest.cache;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.github.benmanes.caffeine.cache.Cache;
+import com.github.benmanes.caffeine.cache.Caffeine;
+import com.ssf.mysqloracletest.domain.DevopsDeviceInfo;
+import com.ssf.mysqloracletest.service.DevopsDeviceInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 区域缓存
+ *
+ * @since 2023-09-16 11:04
+ */
+@Component
+public class DeviceCache {
+
+    /**
+     *
+     */
+    private static final Cache<String, String> cache = Caffeine.newBuilder().build();
+
+    private static DevopsDeviceInfoService devopsDeviceInfoService;
+
+    @Autowired
+    DeviceCache(DevopsDeviceInfoService devopsDeviceInfoService) {
+        DeviceCache.devopsDeviceInfoService = devopsDeviceInfoService;
+        //初始化
+        load();
+    }
+
+    public static String get(String key) {
+        return cache.get(key, s -> {
+            try {
+                return String.valueOf(devopsDeviceInfoService.getOne(new LambdaQueryWrapper<DevopsDeviceInfo>().eq(DevopsDeviceInfo::getGbsChannelNo, key)));
+            } catch (Exception e) {
+                return null;
+            }
+        });
+    }
+
+    /**
+     * 缓存刷新
+     */
+    @Scheduled(cron = "0 0 3 * * ?")
+    public static void refresh() {
+        load();
+    }
+
+    private static void load() {
+
+        List<DevopsDeviceInfo> list = devopsDeviceInfoService.list();
+        Map<String, String> dictMap = list.stream().collect(Collectors.toMap(DevopsDeviceInfo::getGbsChannelNo, e -> String.valueOf(e), (v1, v2) -> v2));
+        Map<String, String> dictMapCode = list.stream().collect(Collectors.toMap(
+                e -> e.getGbsChannelNo(),
+                e -> String.valueOf(e), (v1, v2) -> v2));
+        cache.putAll(dictMap);
+        cache.putAll(dictMapCode);
+    }
+}

src/main/java/com/ssf/mysqloracletest/cache/VideoCache.java

@@ -0,0 +1,66 @@
+package com.ssf.mysqloracletest.cache;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.github.benmanes.caffeine.cache.Cache;
+import com.github.benmanes.caffeine.cache.Caffeine;
+import com.ssf.mysqloracletest.domain.DevopsVideoInfo;
+import com.ssf.mysqloracletest.service.DevopsVideoInfoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+/**
+ * 区域缓存
+ *
+ * @since 2023-09-16 11:04
+ */
+@Component
+public class VideoCache {
+
+    /**
+     *
+     */
+    private static final Cache<String, String> cache = Caffeine.newBuilder().build();
+
+    private static DevopsVideoInfoService devopsVideoInfoService;
+
+    @Autowired
+    VideoCache(DevopsVideoInfoService devopsVideoInfoService) {
+        VideoCache.devopsVideoInfoService = devopsVideoInfoService;
+        //初始化
+        load();
+    }
+
+    public static String get(String key) {
+        return cache.get(key, s -> {
+            try {
+                return String.valueOf(devopsVideoInfoService.getOne(new LambdaQueryWrapper<DevopsVideoInfo>().eq(DevopsVideoInfo::getGbsChannelNo, key)));
+            } catch (Exception e) {
+                return null;
+            }
+        });
+    }
+
+    /**
+     * 缓存刷新
+     */
+    @Scheduled(cron = "0 0 3 * * ?")
+    public static void refresh() {
+        load();
+    }
+
+    private static void load() {
+
+        List<DevopsVideoInfo> list = devopsVideoInfoService.list();
+        Map<String, String> dictMap = list.stream().collect(Collectors.toMap(DevopsVideoInfo::getGbsChannelNo, e -> String.valueOf(e), (v1, v2) -> v2));
+        Map<String, String> dictMapCode = list.stream().collect(Collectors.toMap(
+                e -> e.getGbsChannelNo(),
+                e -> String.valueOf(e), (v1, v2) -> v2));
+        cache.putAll(dictMap);
+        cache.putAll(dictMapCode);
+    }
+}

src/main/java/com/ssf/mysqloracletest/domain/DevopsDeviceInfo.java

@@ -0,0 +1,171 @@
+package com.ssf.mysqloracletest.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 智能设备信息表(DevopsDeviceInfo)Domain
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:46
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName(value = "devops_device_info")
+public class DevopsDeviceInfo {
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 场所编码
+     */
+    private String placeCode;
+
+    /**
+     * 场所名称
+     */
+    private String placeName;
+
+    /**
+     * 设备名称
+     */
+    private String deviceName;
+
+    /**
+     * 设备编码
+     */
+    private String deviceCode;
+
+    /**
+     * 通道国标编码
+     */
+    private String gbsChannelNo;
+
+    /**
+     * 设备类型
+     */
+    private Integer deviceType;
+
+    /**
+     * 设备能力集
+     */
+    private String structuredCameraType;
+
+    /**
+     * 安装位置
+     */
+    private String deviceAddress;
+
+    /**
+     * 设备方位
+     */
+    private Integer orientation;
+
+    /**
+     * 设备SN编号
+     */
+    private String deviceSn;
+
+    /**
+     * 设备品牌
+     */
+    private String deviceBrand;
+
+    /**
+     * 设备ip
+     */
+    private String deviceIp;
+
+    /**
+     * 设备端口
+     */
+    private Integer devicePort;
+
+    /**
+     * 设备MAC
+     */
+    private String deviceMac;
+
+    /**
+     * 设备IMEI
+     */
+    private String deviceImei;
+
+    /**
+     * 设备经度
+     */
+    private Double longitude;
+
+    /**
+     * 设备纬度
+     */
+    private Double latitude;
+
+    /**
+     * U3D经度
+     */
+    private Double u3dLongitude;
+
+    /**
+     * U3D纬度
+     */
+    private Double u3dLatitude;
+
+    /**
+     * 设备高度
+     */
+    private String deviceHeight;
+
+    /**
+     * 设备厂家
+     */
+    private String manufactor;
+
+    /**
+     * 设备登陆帐号
+     */
+    private String account;
+
+    /**
+     * 设备登陆密码
+     */
+    private String password;
+
+    /**
+     * 进出方向
+     */
+    private Integer direction;
+
+    /**
+     * RTSP流地址
+     */
+    private String rtspAddress;
+
+    /**
+     * 是否卡口设备
+     */
+    private Integer isDoorwayVideo;
+
+    /**
+     * 商汤region_id
+     */
+    private String stRegionId;
+
+    /**
+     * 商汤camera_idx
+     */
+    private String stCameraIdx;
+
+    /**
+     * 通道号
+     */
+    private Integer channelNo;
+
+}

src/main/java/com/ssf/mysqloracletest/domain/DevopsDeviceStatus.java

@@ -0,0 +1,76 @@
+package com.ssf.mysqloracletest.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 设备状态信息表(DevopsDeviceStatus)Domain
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName(value = "devops_device_status")
+public class DevopsDeviceStatus {
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 场所编码
+     */
+    private String placeCode;
+
+    /**
+     * 场所名称
+     */
+    private String placeName;
+
+    /**
+     * 设备编码
+     */
+    private String deviceCode;
+
+    /**
+     * 通道国标编码
+     */
+    private String gbsChannelNo;
+
+    /**
+     * 设备名称
+     */
+    private String deviceName;
+
+    /**
+     * 设备ip
+     */
+    private String deviceIp;
+
+    /**
+     * 设备类型
+     */
+    private Integer deviceType;
+
+    /**
+     * 心跳时间
+     */
+    private Long heartbeatTime;
+
+    /**
+     * 是否在线
+     */
+    private Integer isOnline;
+
+    /**
+     * 是否存在告警
+     */
+    private Integer isAlarm;
+
+}

src/main/java/com/ssf/mysqloracletest/domain/DevopsVideoInfo.java

@@ -0,0 +1,141 @@
+package com.ssf.mysqloracletest.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 视频监控设备表(DevopsVideoInfo)Domain
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName(value = "devops_video_info")
+public class DevopsVideoInfo {
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 场所编码
+     */
+    private String placeCode;
+
+    /**
+     * 场所名称
+     */
+    private String placeName;
+
+    /**
+     * 设备编码
+     */
+    private String deviceCode;
+
+    /**
+     * 设备名称
+     */
+    private String deviceName;
+
+    /**
+     * 监控类型
+     */
+    private Integer monitoringType;
+
+    /**
+     * 安装位置
+     */
+    private String deviceAddress;
+
+    /**
+     * 设备方位
+     */
+    private Integer orientation;
+
+    /**
+     * 设备SN编号
+     */
+    private String deviceSn;
+
+    /**
+     * 设备品牌
+     */
+    private String deviceBrand;
+
+    /**
+     * 设备ip
+     */
+    private String deviceIp;
+
+    /**
+     * 设备端口
+     */
+    private Integer devicePort;
+
+    /**
+     * 设备MAC
+     */
+    private String deviceMac;
+
+    /**
+     * 设备经度
+     */
+    private Double longitude;
+
+    /**
+     * 设备纬度
+     */
+    private Double latitude;
+
+    /**
+     * U3D经度
+     */
+    private Double u3dLongitude;
+
+    /**
+     * U3D纬度
+     */
+    private Double u3dLatitude;
+
+    /**
+     * 设备高度
+     */
+    private String deviceHeight;
+
+    /**
+     * 设备厂家
+     */
+    private String manufactor;
+
+    /**
+     * 登陆帐号
+     */
+    private String account;
+
+    /**
+     * 登陆密码
+     */
+    private String password;
+
+    /**
+     * 通道国标编码
+     */
+    private String gbsChannelNo;
+
+    /**
+     * NVR设备编码
+     */
+    private String gbsNvrNo;
+
+    /**
+     * 通道号
+     */
+    private Integer channelNo;
+
+}

src/main/java/com/ssf/mysqloracletest/domain/DevopsVideoStatus.java

@@ -0,0 +1,76 @@
+package com.ssf.mysqloracletest.domain;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+/**
+ * 视频监控状态表(DevopsVideoStatus)Domain
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@TableName(value = "devops_video_status")
+public class DevopsVideoStatus {
+
+    /**
+     * 主键
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 场所编码
+     */
+    private String placeCode;
+
+    /**
+     * 场所名称
+     */
+    private String placeName;
+
+    /**
+     * 设备编码
+     */
+    private String deviceCode;
+
+    /**
+     * NVR设备编码
+     */
+    private String gbsNvrNo;
+
+    /**
+     * 通道国标编码
+     */
+    private String gbsChannelNo;
+
+    /**
+     * 设备名称
+     */
+    private String deviceName;
+
+    /**
+     * 设备ip
+     */
+    private String deviceIp;
+
+    /**
+     * 监控类型
+     */
+    private Integer monitoringType;
+
+    /**
+     * 心跳时间
+     */
+    private Long heartbeatTime;
+
+    /**
+     * 是否在线
+     */
+    private Integer isOnline;
+
+}

src/main/java/com/ssf/mysqloracletest/domain/TransitUserRecord.java

@@ -0,0 +1,207 @@
+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 java.util.Date;
+import lombok.Data;
+
+/**
+ * 人脸记录表
+ * @TableName transit_user_record
+ */
+@TableName(value ="transit_user_record")
+@Data
+public class TransitUserRecord implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 抓拍时间（分区）
+     */
+    @TableId
+    private Date partitionField;
+
+    /**
+     * 场所编码
+     */
+    private String placeCode;
+
+    /**
+     * 场所名称
+     */
+    private String placeName;
+
+    /**
+     * 设备编码
+     */
+    private String deviceCode;
+
+    /**
+     * 设备名称
+     */
+    private String deviceName;
+
+    /**
+     * 通道国标编码
+     */
+    private String gbsChannelNo;
+
+    /**
+     * 安装位置
+     */
+    private String deviceAddress;
+
+    /**
+     * 方位
+     */
+    private Integer orientation;
+
+    /**
+     * 设备ip
+     */
+    private String deviceIp;
+
+    /**
+     * 全景图
+     */
+    private String globalPic;
+
+    /**
+     * 人脸图
+     */
+    private String personPic;
+
+    /**
+     * 人体全景图
+     */
+    private String bodyGlobalPic;
+
+    /**
+     * 人体小图
+     */
+    private String bodyPic;
+
+    /**
+     * 常口库标准照片
+     */
+    private String userStandardPic;
+
+    /**
+     * 人员姓名
+     */
+    private String userName;
+
+    /**
+     * 档案编号
+     */
+    private String dossierCode;
+
+    /**
+     * 证件号码
+     */
+    private String idCard;
+
+    /**
+     * 联系电话
+     */
+    private String phone;
+
+    /**
+     * 记录唯一标识
+     */
+    private String recordId;
+
+    /**
+     * 人车同拍唯一记录
+     */
+    private String userVehicleRecordId;
+
+    /**
+     * 人体关联ID
+     */
+    private String userBodyRecordId;
+
+    /**
+     * 商汤人脸记录
+     */
+    private String stUserRecordId;
+
+    /**
+     * 数据来源唯一ID
+     */
+    private String sourceId;
+
+    /**
+     * 人脸小图唯一ID
+     */
+    private String personImageId;
+
+    /**
+     * 人脸大图唯一ID
+     */
+    private String globalImageId;
+
+    /**
+     * 相似度
+     */
+    private String similarity;
+
+    /**
+     * 是否已比对人脸
+     */
+    private Integer isCompare;
+
+    /**
+     * 进出方向
+     */
+    private Integer direction;
+
+    /**
+     * 抓拍时间
+     */
+    private Long passTime;
+
+    /**
+     * 轴系坐标
+     */
+    private String axis;
+
+    /**
+     * 数据来源
+     */
+    private Integer dataSrc;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建者
+     */
+    private Integer createBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新者
+     */
+    private Integer updateBy;
+
+    /**
+     * 0:不活跃,1:活跃
+     */
+    private Integer isActive;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/ssf/mysqloracletest/domain/TransitVehicleRecord.java

@@ -0,0 +1,232 @@
+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 java.util.Date;
+import lombok.Data;
+
+/**
+ * 车辆记录表
+ * @TableName transit_vehicle_record
+ */
+@TableName(value ="transit_vehicle_record")
+@Data
+public class TransitVehicleRecord implements Serializable {
+    /**
+     * 主键
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 过车时间（分区）
+     */
+    @TableId
+    private Date partitionField;
+
+    /**
+     * 场所编码
+     */
+    private String placeCode;
+
+    /**
+     * 场所名称
+     */
+    private String placeName;
+
+    /**
+     * 设备编码
+     */
+    private String deviceCode;
+
+    /**
+     * 设备名称
+     */
+    private String deviceName;
+
+    /**
+     * 通道国标编码
+     */
+    private String gbsChannelNo;
+
+    /**
+     * 安装位置
+     */
+    private String deviceAddress;
+
+    /**
+     * 方位
+     */
+    private Integer orientation;
+
+    /**
+     * 设备ip
+     */
+    private String deviceIp;
+
+    /**
+     * 车牌号码
+     */
+    private String plateNo;
+
+    /**
+     * 全景图
+     */
+    private String globalPic;
+
+    /**
+     * 车牌图
+     */
+    private String platePic;
+
+    /**
+     * 记录唯一ID
+     */
+    private String recordId;
+
+    /**
+     * 数据来源唯一ID
+     */
+    private String sourceId;
+
+    /**
+     * 车牌号小图唯一ID
+     */
+    private String plateImageId;
+
+    /**
+     * 车辆全景图唯一ID
+     */
+    private String globalImageId;
+
+    /**
+     * 人车同拍唯一记录
+     */
+    private String userVehicleRecordId;
+
+    /**
+     * 车主人脸图
+     */
+    private String ownerPersonPic;
+
+    /**
+     * 车主全景图
+     */
+    private String ownerGlobalPic;
+
+    /**
+     * 车主姓名
+     */
+    private String ownerName;
+
+    /**
+     * 证件号码
+     */
+    private String idCard;
+
+    /**
+     * 联系电话
+     */
+    private String phone;
+
+    /**
+     * 副驾驶人脸图
+     */
+    private String copilotPersonPic;
+
+    /**
+     * 副驾驶全景图
+     */
+    private String copilotGlobalPic;
+
+    /**
+     * 副驾驶姓名
+     */
+    private String copilotOwnerName;
+
+    /**
+     * 副驾驶证件号码
+     */
+    private String copilotIdcard;
+
+    /**
+     * 副驾驶联系电话
+     */
+    private String copilotPhone;
+
+    /**
+     * 进出方向
+     */
+    private Integer direction;
+
+    /**
+     * 卡口编码
+     */
+    private String doorwayCode;
+
+    /**
+     * 车道编码
+     */
+    private String roadCode;
+
+    /**
+     * 过车时间
+     */
+    private Long passTime;
+
+    /**
+     * 车牌颜色
+     */
+    private String plateColor;
+
+    /**
+     * 车身颜色
+     */
+    private String vehicleColor;
+
+    /**
+     * 车辆类型
+     */
+    private String vehicleType;
+
+    /**
+     * 车辆品牌
+     */
+    private String vehicleBrand;
+
+    /**
+     * 数据来源
+     */
+    private Integer dataSrc;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建者
+     */
+    private Integer createBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新者
+     */
+    private Integer updateBy;
+
+    /**
+     * 0:不活跃,1:活跃
+     */
+    private Integer isActive;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}

src/main/java/com/ssf/mysqloracletest/mapper/DevopsDeviceInfoMapper.java

@@ -0,0 +1,16 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ssf.mysqloracletest.domain.DevopsDeviceInfo;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 智能设备信息表(DevopsDeviceInfo)Mapper
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:46
+ */
+@Mapper
+public interface DevopsDeviceInfoMapper extends BaseMapper<DevopsDeviceInfo> {
+
+}

src/main/java/com/ssf/mysqloracletest/mapper/DevopsDeviceStatusMapper.java

@@ -0,0 +1,16 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ssf.mysqloracletest.domain.DevopsDeviceStatus;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 设备状态信息表(DevopsDeviceStatus)Mapper
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Mapper
+public interface DevopsDeviceStatusMapper extends BaseMapper<DevopsDeviceStatus> {
+
+}

src/main/java/com/ssf/mysqloracletest/mapper/DevopsVideoInfoMapper.java

@@ -0,0 +1,16 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ssf.mysqloracletest.domain.DevopsVideoInfo;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 视频监控设备表(DevopsVideoInfo)Mapper
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Mapper
+public interface DevopsVideoInfoMapper extends BaseMapper<DevopsVideoInfo> {
+
+}

src/main/java/com/ssf/mysqloracletest/mapper/DevopsVideoStatusMapper.java

@@ -0,0 +1,16 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ssf.mysqloracletest.domain.DevopsVideoStatus;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 视频监控状态表(DevopsVideoStatus)Mapper
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Mapper
+public interface DevopsVideoStatusMapper extends BaseMapper<DevopsVideoStatus> {
+
+}

src/main/java/com/ssf/mysqloracletest/mapper/TransitUserRecordMapper.java

@@ -0,0 +1,18 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.ssf.mysqloracletest.domain.TransitUserRecord;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author 28758
+* @description 针对表【transit_user_record(人脸记录表)】的数据库操作Mapper
+* @createDate 2023-12-14 16:46:10
+* @Entity com.ssf.mysqloracletest.domain.TransitUserRecord
+*/
+public interface TransitUserRecordMapper extends BaseMapper<TransitUserRecord> {
+
+}
+
+
+
+

src/main/java/com/ssf/mysqloracletest/mapper/TransitVehicleRecordMapper.java

@@ -0,0 +1,18 @@
+package com.ssf.mysqloracletest.mapper;
+
+import com.ssf.mysqloracletest.domain.TransitVehicleRecord;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+* @author 28758
+* @description 针对表【transit_vehicle_record(车辆记录表)】的数据库操作Mapper
+* @createDate 2023-12-14 16:47:49
+* @Entity com.ssf.mysqloracletest.domain.TransitVehicleRecord
+*/
+public interface TransitVehicleRecordMapper extends BaseMapper<TransitVehicleRecord> {
+
+}
+
+
+
+

src/main/java/com/ssf/mysqloracletest/service/DevopsDeviceInfoService.java

@@ -0,0 +1,25 @@
+package com.ssf.mysqloracletest.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.DevopsDeviceInfo;
+
+import java.util.List;
+
+/**
+ * 智能设备信息表(DevopsDeviceInfo)Service
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:46
+ */
+public interface DevopsDeviceInfoService extends IService<DevopsDeviceInfo> {
+
+    /**
+     * 新增或者更新智能设备信息表
+     *
+     * @param devopsDeviceInfo 智能设备信息表对象
+     * @return 结果
+     */
+    boolean insertOrUpdate(DevopsDeviceInfo devopsDeviceInfo);
+
+}

src/main/java/com/ssf/mysqloracletest/service/DevopsDeviceStatusService.java

@@ -0,0 +1,25 @@
+package com.ssf.mysqloracletest.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.DevopsDeviceStatus;
+
+import java.util.List;
+
+/**
+ * 设备状态信息表(DevopsDeviceStatus)Service
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:46
+ */
+public interface DevopsDeviceStatusService extends IService<DevopsDeviceStatus> {
+
+    /**
+     * 新增或者更新设备状态信息表
+     *
+     * @param devopsDeviceStatus 设备状态信息表对象
+     * @return 结果
+     */
+    boolean insertOrUpdate(DevopsDeviceStatus devopsDeviceStatus);
+
+}

src/main/java/com/ssf/mysqloracletest/service/DevopsVideoInfoService.java

@@ -0,0 +1,25 @@
+package com.ssf.mysqloracletest.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.DevopsVideoInfo;
+
+import java.util.List;
+
+/**
+ * 视频监控设备表(DevopsVideoInfo)Service
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+public interface DevopsVideoInfoService extends IService<DevopsVideoInfo> {
+
+    /**
+     * 新增或者更新视频监控设备表
+     *
+     * @param devopsVideoInfo 视频监控设备表对象
+     * @return 结果
+     */
+    boolean insertOrUpdate(DevopsVideoInfo devopsVideoInfo);
+
+}

src/main/java/com/ssf/mysqloracletest/service/DevopsVideoStatusService.java

@@ -0,0 +1,25 @@
+package com.ssf.mysqloracletest.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.DevopsVideoStatus;
+
+import java.util.List;
+
+/**
+ * 视频监控状态表(DevopsVideoStatus)Service
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+public interface DevopsVideoStatusService extends IService<DevopsVideoStatus> {
+
+    /**
+     * 新增或者更新视频监控状态表
+     *
+     * @param devopsVideoStatus 视频监控状态表对象
+     * @return 结果
+     */
+    boolean insertOrUpdate(DevopsVideoStatus devopsVideoStatus);
+
+}

src/main/java/com/ssf/mysqloracletest/service/TransitUserRecordService.java

@@ -0,0 +1,13 @@
+package com.ssf.mysqloracletest.service;
+
+import com.ssf.mysqloracletest.domain.TransitUserRecord;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author 28758
+* @description 针对表【transit_user_record(人脸记录表)】的数据库操作Service
+* @createDate 2023-12-14 16:46:10
+*/
+public interface TransitUserRecordService extends IService<TransitUserRecord> {
+
+}

src/main/java/com/ssf/mysqloracletest/service/TransitVehicleRecordService.java

@@ -0,0 +1,13 @@
+package com.ssf.mysqloracletest.service;
+
+import com.ssf.mysqloracletest.domain.TransitVehicleRecord;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+* @author 28758
+* @description 针对表【transit_vehicle_record(车辆记录表)】的数据库操作Service
+* @createDate 2023-12-14 16:47:49
+*/
+public interface TransitVehicleRecordService extends IService<TransitVehicleRecord> {
+
+}

src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceInfoServiceImpl.java

@@ -0,0 +1,24 @@
+package com.ssf.mysqloracletest.service.impl;
+
+
+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 org.springframework.stereotype.Service;
+
+/**
+ * 智能设备信息表(DevopsDeviceInfo)ServiceImpl
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:46
+ */
+@Service
+public class DevopsDeviceInfoServiceImpl extends ServiceImpl<DevopsDeviceInfoMapper, DevopsDeviceInfo> implements DevopsDeviceInfoService {
+
+    @Override
+    public boolean insertOrUpdate(DevopsDeviceInfo devopsDeviceInfo) {
+        return false;
+    }
+
+}

src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceStatusServiceImpl.java

@@ -0,0 +1,24 @@
+package com.ssf.mysqloracletest.service.impl;
+
+
+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 org.springframework.stereotype.Service;
+
+/**
+ * 设备状态信息表(DevopsDeviceStatus)ServiceImpl
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Service
+public class DevopsDeviceStatusServiceImpl extends ServiceImpl<DevopsDeviceStatusMapper, DevopsDeviceStatus> implements DevopsDeviceStatusService {
+
+    @Override
+    public boolean insertOrUpdate(DevopsDeviceStatus devopsDeviceStatus) {
+        return false;
+    }
+
+}

src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java

@@ -0,0 +1,24 @@
+package com.ssf.mysqloracletest.service.impl;
+
+
+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 org.springframework.stereotype.Service;
+
+/**
+ * 视频监控设备表(DevopsVideoInfo)ServiceImpl
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Service
+public class DevopsVideoInfoServiceImpl extends ServiceImpl<DevopsVideoInfoMapper, DevopsVideoInfo> implements DevopsVideoInfoService {
+
+    @Override
+    public boolean insertOrUpdate(DevopsVideoInfo devopsVideoInfo) {
+        return false;
+    }
+
+}

src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoStatusServiceImpl.java

@@ -0,0 +1,24 @@
+package com.ssf.mysqloracletest.service.impl;
+
+
+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 org.springframework.stereotype.Service;
+
+/**
+ * 视频监控状态表(DevopsVideoStatus)ServiceImpl
+ *
+ * @author makejava
+ * @since 2023-12-14 16:26:47
+ */
+@Service
+public class DevopsVideoStatusServiceImpl extends ServiceImpl<DevopsVideoStatusMapper, DevopsVideoStatus> implements DevopsVideoStatusService {
+
+    @Override
+    public boolean insertOrUpdate(DevopsVideoStatus devopsVideoStatus) {
+        return false;
+    }
+
+}

src/main/java/com/ssf/mysqloracletest/service/impl/TransitUserRecordServiceImpl.java

@@ -0,0 +1,26 @@
+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.TransitUserRecord;
+import com.ssf.mysqloracletest.service.TransitUserRecordService;
+import com.ssf.mysqloracletest.mapper.TransitUserRecordMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+* @author 28758
+* @description 针对表【transit_user_record(人脸记录表)】的数据库操作Service实现
+* @createDate 2023-12-14 16:46:10
+*/
+@Service
+@RequiredArgsConstructor
+@DS("mysql")
+public class TransitUserRecordServiceImpl extends ServiceImpl<TransitUserRecordMapper, TransitUserRecord>
+    implements TransitUserRecordService{
+
+}
+
+
+
+

src/main/java/com/ssf/mysqloracletest/service/impl/TransitVehicleRecordServiceImpl.java

@@ -0,0 +1,26 @@
+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.TransitVehicleRecord;
+import com.ssf.mysqloracletest.service.TransitVehicleRecordService;
+import com.ssf.mysqloracletest.mapper.TransitVehicleRecordMapper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+* @author 28758
+* @description 针对表【transit_vehicle_record(车辆记录表)】的数据库操作Service实现
+* @createDate 2023-12-14 16:47:49
+*/
+@Service
+@RequiredArgsConstructor
+@DS("mysql")
+public class TransitVehicleRecordServiceImpl extends ServiceImpl<TransitVehicleRecordMapper, TransitVehicleRecord>
+    implements TransitVehicleRecordService{
+
+}
+
+
+
+

src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java

@@ -47,6 +47,9 @@ public class JcjCjxxTask {
     @Scheduled(initialDelay = 100, fixedDelay = 3000)
     public void transcjxx() {
 
+//        String value = DeviceCache.get("32092451211328052004");
+//        System.out.println();
+
         if (cjxxTag) {
             return;
         }

src/main/resources/mapper/TransitUserRecordMapper.xml

@@ -0,0 +1,48 @@
+<?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.TransitUserRecordMapper">
+
+    <resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.TransitUserRecord">
+            <id property="id" column="id" jdbcType="BIGINT"/>
+            <id property="partitionField" column="partition_field" jdbcType="TIMESTAMP"/>
+            <result property="placeCode" column="place_code" jdbcType="VARCHAR"/>
+            <result property="placeName" column="place_name" jdbcType="VARCHAR"/>
+            <result property="deviceCode" column="device_code" jdbcType="VARCHAR"/>
+            <result property="deviceName" column="device_name" jdbcType="VARCHAR"/>
+            <result property="gbsChannelNo" column="gbs_channel_no" jdbcType="VARCHAR"/>
+            <result property="deviceAddress" column="device_address" jdbcType="VARCHAR"/>
+            <result property="orientation" column="orientation" jdbcType="TINYINT"/>
+            <result property="deviceIp" column="device_ip" jdbcType="VARCHAR"/>
+            <result property="globalPic" column="global_pic" jdbcType="VARCHAR"/>
+            <result property="personPic" column="person_pic" jdbcType="VARCHAR"/>
+            <result property="bodyGlobalPic" column="body_global_pic" jdbcType="VARCHAR"/>
+            <result property="bodyPic" column="body_pic" jdbcType="VARCHAR"/>
+            <result property="userStandardPic" column="user_standard_pic" jdbcType="VARCHAR"/>
+            <result property="userName" column="user_name" jdbcType="VARCHAR"/>
+            <result property="dossierCode" column="dossier_code" jdbcType="VARCHAR"/>
+            <result property="idCard" column="id_card" jdbcType="VARCHAR"/>
+            <result property="phone" column="phone" jdbcType="VARCHAR"/>
+            <result property="recordId" column="record_id" jdbcType="VARCHAR"/>
+            <result property="userVehicleRecordId" column="user_vehicle_record_id" jdbcType="VARCHAR"/>
+            <result property="userBodyRecordId" column="user_body_record_id" jdbcType="VARCHAR"/>
+            <result property="stUserRecordId" column="st_user_record_id" jdbcType="VARCHAR"/>
+            <result property="sourceId" column="source_id" jdbcType="VARCHAR"/>
+            <result property="personImageId" column="person_image_id" jdbcType="VARCHAR"/>
+            <result property="globalImageId" column="global_image_id" jdbcType="VARCHAR"/>
+            <result property="similarity" column="similarity" jdbcType="VARCHAR"/>
+            <result property="isCompare" column="is_compare" jdbcType="TINYINT"/>
+            <result property="direction" column="direction" jdbcType="TINYINT"/>
+            <result property="passTime" column="pass_time" jdbcType="BIGINT"/>
+            <result property="axis" column="axis" jdbcType="VARCHAR"/>
+            <result property="dataSrc" column="data_src" jdbcType="TINYINT"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="createBy" column="create_by" jdbcType="INTEGER"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="INTEGER"/>
+            <result property="isActive" column="is_active" jdbcType="TINYINT"/>
+    </resultMap>
+
+
+</mapper>

src/main/resources/mapper/TransitVehicleRecordMapper.xml

@@ -0,0 +1,53 @@
+<?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.TransitVehicleRecordMapper">
+
+    <resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.TransitVehicleRecord">
+            <id property="id" column="id" jdbcType="BIGINT"/>
+            <id property="partitionField" column="partition_field" jdbcType="TIMESTAMP"/>
+            <result property="placeCode" column="place_code" jdbcType="VARCHAR"/>
+            <result property="placeName" column="place_name" jdbcType="VARCHAR"/>
+            <result property="deviceCode" column="device_code" jdbcType="VARCHAR"/>
+            <result property="deviceName" column="device_name" jdbcType="VARCHAR"/>
+            <result property="gbsChannelNo" column="gbs_channel_no" jdbcType="VARCHAR"/>
+            <result property="deviceAddress" column="device_address" jdbcType="VARCHAR"/>
+            <result property="orientation" column="orientation" jdbcType="TINYINT"/>
+            <result property="deviceIp" column="device_ip" jdbcType="VARCHAR"/>
+            <result property="plateNo" column="plate_no" jdbcType="VARCHAR"/>
+            <result property="globalPic" column="global_pic" jdbcType="VARCHAR"/>
+            <result property="platePic" column="plate_pic" jdbcType="VARCHAR"/>
+            <result property="recordId" column="record_id" jdbcType="VARCHAR"/>
+            <result property="sourceId" column="source_id" jdbcType="VARCHAR"/>
+            <result property="plateImageId" column="plate_image_id" jdbcType="VARCHAR"/>
+            <result property="globalImageId" column="global_image_id" jdbcType="VARCHAR"/>
+            <result property="userVehicleRecordId" column="user_vehicle_record_id" jdbcType="VARCHAR"/>
+            <result property="ownerPersonPic" column="owner_person_pic" jdbcType="VARCHAR"/>
+            <result property="ownerGlobalPic" column="owner_global_pic" jdbcType="VARCHAR"/>
+            <result property="ownerName" column="owner_name" jdbcType="VARCHAR"/>
+            <result property="idCard" column="id_card" jdbcType="VARCHAR"/>
+            <result property="phone" column="phone" jdbcType="VARCHAR"/>
+            <result property="copilotPersonPic" column="copilot_person_pic" jdbcType="VARCHAR"/>
+            <result property="copilotGlobalPic" column="copilot_global_pic" jdbcType="VARCHAR"/>
+            <result property="copilotOwnerName" column="copilot_owner_name" jdbcType="VARCHAR"/>
+            <result property="copilotIdcard" column="copilot_idcard" jdbcType="VARCHAR"/>
+            <result property="copilotPhone" column="copilot_phone" jdbcType="VARCHAR"/>
+            <result property="direction" column="direction" jdbcType="TINYINT"/>
+            <result property="doorwayCode" column="doorway_code" jdbcType="VARCHAR"/>
+            <result property="roadCode" column="road_code" jdbcType="VARCHAR"/>
+            <result property="passTime" column="pass_time" jdbcType="BIGINT"/>
+            <result property="plateColor" column="plate_color" jdbcType="VARCHAR"/>
+            <result property="vehicleColor" column="vehicle_color" jdbcType="VARCHAR"/>
+            <result property="vehicleType" column="vehicle_type" jdbcType="VARCHAR"/>
+            <result property="vehicleBrand" column="vehicle_brand" jdbcType="VARCHAR"/>
+            <result property="dataSrc" column="data_src" jdbcType="TINYINT"/>
+            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
+            <result property="createBy" column="create_by" jdbcType="INTEGER"/>
+            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
+            <result property="updateBy" column="update_by" jdbcType="INTEGER"/>
+            <result property="isActive" column="is_active" jdbcType="TINYINT"/>
+    </resultMap>
+
+
+</mapper>