接处警

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

@@ -1,6 +1,5 @@
 package com.ssf.mysqloracletest.domain;
 
-import com.baomidou.mybatisplus.annotation.TableName;
 import lombok.Data;
 
 import java.io.Serializable;

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

@@ -3,11 +3,10 @@ package com.ssf.mysqloracletest.domain;
 
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
 
 import java.io.Serializable;
 
-import lombok.Data;
-
 /**
  * @TableName jcj_jjxx_view
  */

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

@@ -4,10 +4,11 @@ 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 lombok.Data;
+
 import java.io.Serializable;
 import java.math.BigDecimal;
 import java.util.Date;
-import lombok.Data;
 
 /**
  * 接警信息表
@@ -22,71 +23,103 @@ public class MetaAlarmInfo implements Serializable {
     @TableId(type = IdType.AUTO)
     private Long id;
 
+    @TableField(value = "alarm_code")
     private String alarmCode;
 
     /**
      * 接警人姓名
      */
+    @TableField(value = "police_receiver_name")
     private String policeReceiverName;
 
     /**
      * 接警单位
      */
+    @TableField(value = "alarm_response_unit")
     private String alarmResponseUnit;
 
     /**
      * 接警时间
      */
+    @TableField(value = "alarm_response_time")
     private String alarmResponseTime;
 
     /**
      * 报警内容
      */
+    @TableField(value = "alarm_response_content")
     private String alarmResponseContent;
 
     /**
      * 报警类型名称
      */
+    @TableField(value = "alarm_response_type_name")
     private String alarmResponseTypeName;
 
     /**
      * 报警人姓名
      */
+    @TableField(value = "informant_name")
     private String informantName;
 
     /**
      * 报警人联系方式
      */
+    @TableField(value = "informant_phone")
     private String informantPhone;
 
     /**
      * 报警时间
      */
+    @TableField(value = "informant_time")
     private String informantTime;
 
     /**
      * 接警事发地址
      */
+    @TableField(value = "alarm_address")
     private String alarmAddress;
 
     /**
      * 经度
      */
+    @TableField(value = "longitude")
     private BigDecimal longitude;
 
     /**
      * 纬度
      */
+    @TableField(value = "latitude")
     private BigDecimal latitude;
 
     /**
      * 创建时间
      */
+    @TableField(value = "create_time")
     private Date createTime;
 
+    /**
+     * 创建者
+     */
+    @TableField(value = "create_by")
+    private Integer createBy;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 更新者
+     */
+    @TableField(value = "update_by")
+    private Integer updateBy;
+
     /**
      * 0:不活跃,1:活跃
      */
+    @TableField(value = "is_active")
     private Integer isActive;
 
 //    @TableField(exist = false)

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

@@ -4,9 +4,10 @@ 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 lombok.Data;
+
 import java.io.Serializable;
 import java.util.Date;
-import lombok.Data;
 
 /**
  * 处警信息表
@@ -24,51 +25,78 @@ public class MetaHandleAlarmInfo implements Serializable {
     /**
      * 警情编码
      */
+    @TableField(value = "alarm_code")
     private String alarmCode;
     /**
      * 处警单位名称
      */
+    @TableField(value = "handle_alarm_unit")
     private String handleAlarmUnit;
 
     /**
      * 处警时间
      */
+    @TableField(value = "handle_alarm_time")
     private String handleAlarmTime;
 
     /**
      * 处警简要警情
      */
+    @TableField(value = "handle_alarm_content")
     private String handleAlarmContent;
 
     /**
      * 处警详细地点
      */
+    @TableField(value = "handle_alarm_address")
     private String handleAlarmAddress;
 
     /**
      * 处警人姓名
      */
+    @TableField(value = "handle_alarm_user")
     private String handleAlarmUser;
 
     /**
      * 处境人姓名和编码
      */
+    @TableField(value = "handle_alarm_user_code")
     private String handleAlarmUserCode;
 
     /**
      * 处警结果
      */
+    @TableField(value = "handle_alarm_result")
     private String handleAlarmResult;
 
     /**
      * 创建时间
      */
+    @TableField(value = "create_time")
     private Date createTime;
 
+    /**
+     * 创建者
+     */
+    @TableField(value = "create_by")
+    private Integer createBy;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 更新者
+     */
+    @TableField(value = "update_by")
+    private Integer updateBy;
 
     /**
      * 0:不活跃,1:活跃
      */
+    @TableField(value = "is_active")
     private Integer isActive;
 
     @TableField(exist = false)

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/JcjCjxxViewMysqlMapper.java

@@ -2,7 +2,6 @@ package com.ssf.mysqloracletest.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.ssf.mysqloracletest.domain.JcjCjxxViewMysql;
-import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql;
 import org.apache.ibatis.annotations.Mapper;
 
 /**

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

@@ -3,6 +3,7 @@ package com.ssf.mysqloracletest.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.ssf.mysqloracletest.domain.JcjCjxxViewOracle;
 import org.apache.ibatis.annotations.Mapper;
+
 import java.util.List;
 import java.util.Map;
 

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

@@ -1,7 +1,7 @@
 package com.ssf.mysqloracletest.mapper;
 
-import com.ssf.mysqloracletest.domain.MetaAlarmInfo;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ssf.mysqloracletest.domain.MetaAlarmInfo;
 import org.apache.ibatis.annotations.Mapper;
 
 /**

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

@@ -1,7 +1,7 @@
 package com.ssf.mysqloracletest.mapper;
 
-import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
 import org.apache.ibatis.annotations.Mapper;
 
 /**

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/JcjCjxxViewMysqlService.java

@@ -2,8 +2,6 @@ package com.ssf.mysqloracletest.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.ssf.mysqloracletest.domain.JcjCjxxViewMysql;
-import com.ssf.mysqloracletest.domain.JcjCjxxViewMysql;
-import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql;
 
 /**
  * @author 28758

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

@@ -1,7 +1,7 @@
 package com.ssf.mysqloracletest.service;
 
-import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql;
 
 /**
  * @author 10503

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

@@ -1,7 +1,7 @@
 package com.ssf.mysqloracletest.service;
 
-import com.ssf.mysqloracletest.domain.MetaAlarmInfo;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.MetaAlarmInfo;
 
 /**
 * @author 10503

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

@@ -1,7 +1,7 @@
 package com.ssf.mysqloracletest.service;
 
-import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.MetaHandleAlarmInfo;
 
 /**
 * @author 28758

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/JcjCjxxViewMysqlServiceImpl.java

@@ -3,7 +3,6 @@ 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.JcjCjxxViewMysql;
-import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql;
 import com.ssf.mysqloracletest.mapper.JcjCjxxViewMysqlMapper;
 import com.ssf.mysqloracletest.service.JcjCjxxViewMysqlService;
 import lombok.RequiredArgsConstructor;

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

@@ -2,11 +2,8 @@ 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.JcjJjxxViewMysql;
 import com.ssf.mysqloracletest.domain.JcjJjxxViewOracle;
 import com.ssf.mysqloracletest.mapper.JcjJjxxViewOracleMapper;
-import com.ssf.mysqloracletest.mapper.JcjJxxViewMysqlMapper;
-import com.ssf.mysqloracletest.service.JcjJjxxViewMysqlService;
 import com.ssf.mysqloracletest.service.JcjJjxxViewOracleService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;

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

@@ -3,8 +3,8 @@ 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.MetaAlarmInfo;
-import com.ssf.mysqloracletest.service.MetaAlarmInfoService;
 import com.ssf.mysqloracletest.mapper.MetaAlarmInfoMapper;
+import com.ssf.mysqloracletest.service.MetaAlarmInfoService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 

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

@@ -3,8 +3,8 @@ 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.MetaHandleAlarmInfo;
-import com.ssf.mysqloracletest.service.MetaHandleAlarmInfoService;
 import com.ssf.mysqloracletest.mapper.MetaHandleAlarmInfoMapper;
+import com.ssf.mysqloracletest.service.MetaHandleAlarmInfoService;
 import org.springframework.stereotype.Service;
 
 /**

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/AlarmInfoTask.java

@@ -7,6 +7,7 @@ import com.ssf.mysqloracletest.domain.MetaAlarmInfo;
 import com.ssf.mysqloracletest.service.JcjJjxxViewMysqlService;
 import com.ssf.mysqloracletest.service.MetaAlarmInfoService;
 import com.ssf.mysqloracletest.utils.ConfigParam;
+import com.ssf.mysqloracletest.utils.NumKit;
 import com.ssf.mysqloracletest.utils.StringKit;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -15,7 +16,6 @@ import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
-import java.math.BigDecimal;
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ExecutorService;
@@ -82,6 +82,7 @@ public class AlarmInfoTask {
         JcjJjxxViewMysql jjxxViewMysqlCp = new JcjJjxxViewMysql();
         try {
             BeanUtils.copyProperties(bean, jjxxViewMysqlCp);
+            JcjJjxxViewMysql jwd = jjxxViewMysqlService.selectJcjJxxByJJBH(bean.getJJBH());
             MetaAlarmInfo alarmInfo = new MetaAlarmInfo();
             //设置目标字段的值
             //alarm_code<-----JJBH 接警编号
@@ -105,23 +106,15 @@ public class AlarmInfoTask {
             //alarm_response_unit<-----JJDWMC接警单位名称
             alarmInfo.setAlarmResponseUnit(jjxxViewMysqlCp.getJJDWMC());
 
-            if (jjxxViewMysqlCp.getWDZB() != null) {
-                //转换类型
-                BigDecimal WDZBDecimal = new BigDecimal(jjxxViewMysqlCp.getWDZB());
-                //latitude(纬度)<-----WDZB纬度坐标
-                alarmInfo.setLatitude(WDZBDecimal);
-            } else {
+            if (jwd.getGIS_Y() != null) {
+
                 //latitude(纬度)<-----WDZB纬度坐标
-                alarmInfo.setLatitude(null);
+                alarmInfo.setLatitude(NumKit.checkBigDecimal(jwd.getGIS_Y()));
             }
 
-            if (jjxxViewMysqlCp.getJDZB() != null) {
-                BigDecimal JDZBDecimal = new BigDecimal(jjxxViewMysqlCp.getJDZB());
-                //longitude(经度)<-----JDZB经度坐标
-                alarmInfo.setLatitude(JDZBDecimal);
-            } else {
+            if (jwd.getGIS_X() != null) {
                 //longitude(经度)<-----JDZB经度坐标
-                alarmInfo.setLongitude(null);
+                alarmInfo.setLongitude(NumKit.checkBigDecimal(jwd.getGIS_X()));
             }
 
             boolean b = alarmInfoService.save(alarmInfo);

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

@@ -3,7 +3,6 @@ package com.ssf.mysqloracletest.task;
 import cn.hutool.core.io.FileUtil;
 import com.ssf.mysqloracletest.domain.JcjCjxxViewMysql;
 import com.ssf.mysqloracletest.domain.JcjCjxxViewOracle;
-import com.ssf.mysqloracletest.domain.JcjJjxxViewMysql;
 import com.ssf.mysqloracletest.service.JcjCjxxViewMysqlService;
 import com.ssf.mysqloracletest.service.JcjCjxxViewOracleService;
 import com.ssf.mysqloracletest.utils.ConfigParam;
@@ -17,7 +16,6 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.io.File;
-import java.text.DateFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.concurrent.CountDownLatch;
@@ -168,7 +166,7 @@ public class JcjCjxxTask {
             //1  去mysql查出当前最大时间
             JcjCjxxViewMysql cjxxViewMysql = cjxxMysqlService.selectRecordOrderByRksj();
             //2  用得到的最大时间去oracle 查询大于这个时间的记录
-            List<JcjCjxxViewOracle> list = cjxxOracleService.getRealTimeRecording(cjxxViewMysql.getCJSJ());
+            List<JcjCjxxViewOracle> list = cjxxOracleService.getRealTimeRecording(cjxxViewMysql.getWS_RKSJ());
             //3  解析入库
             for (JcjCjxxViewOracle cjxx : list) {
                 JcjCjxxViewMysql sBean = new JcjCjxxViewMysql();

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

@@ -118,10 +118,6 @@ public class JcjJjxxTask {
                 return;
             }
 
-            if (!"true".equals(ConfigParam.JjxxSwitch)) {
-                return;
-            }
-
             //1  去mysql查出当前最大时间
             JcjJjxxViewMysql jcjJjxxViewMysql = jcjJjxxViewMysqlService.selectRecordOrderByRksj();
             //2  用得到的最大时间去oracle 查询大于这个时间的记录

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>