人脸抓拍数据清洗

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

@@ -0,0 +1,34 @@
+package com.ssf.mysqloracletest.domain;
+
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @TableName bone_vehicle
+ */
+@TableName(value ="bone_vehicle")
+@Data
+public class BoneVehicle implements Serializable {
+    private Long id;
+
+
+    @TableField(value = "no")
+    private String no;
+
+    @TableField(value = "owner_person_name")
+    private String ownerPersonName;
+
+    @TableField(value = "owner_person_idcard")
+    private String ownerPersonIdcard;
+
+    @TableField(value = "owner_person_phone")
+    private String ownerPersonPhone;
+
+
+
+    private static final long serialVersionUID = 1L;
+}

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

@@ -0,0 +1,23 @@
+package com.ssf.mysqloracletest.mapper;
+
+
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ssf.mysqloracletest.domain.BoneVehicle;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+* @author 28758
+* @description 针对表【bone_vehicle(小区机动车表 )】的数据库操作Mapper
+* @createDate 2023-12-26 21:35:05
+* @Entity generator.domain.BoneVehicle
+*/
+@Mapper
+public interface BoneVehicleMapper extends BaseMapper<BoneVehicle> {
+
+}
+
+
+
+

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

@@ -0,0 +1,14 @@
+package com.ssf.mysqloracletest.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ssf.mysqloracletest.domain.BoneVehicle;
+
+/**
+* @author 28758
+* @description 针对表【bone_vehicle(小区机动车表 )】的数据库操作Service
+* @createDate 2023-12-26 21:35:05
+*/
+public interface BoneVehicleService extends IService<BoneVehicle> {
+
+}

src/main/java/com/ssf/mysqloracletest/service/impl/BoneVehicleServiceImpl.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.BoneVehicle;
+import com.ssf.mysqloracletest.mapper.BoneVehicleMapper;
+import com.ssf.mysqloracletest.service.BoneVehicleService;
+import org.springframework.stereotype.Service;
+
+/**
+* @author 28758
+* @description 针对表【bone_vehicle(小区机动车表 )】的数据库操作Service实现
+* @createDate 2023-12-26 21:35:05
+*/
+@Service
+@DS("mysql")
+public class BoneVehicleServiceImpl extends ServiceImpl<BoneVehicleMapper, BoneVehicle>
+    implements BoneVehicleService {
+
+}
+
+
+
+

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

@@ -5,10 +5,8 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.ssf.mysqloracletest.domain.DevopsDeviceInfo;
-import com.ssf.mysqloracletest.domain.TMotorvehicle;
-import com.ssf.mysqloracletest.domain.TransitUserRecord;
-import com.ssf.mysqloracletest.domain.TransitVehicleRecord;
+import com.ssf.mysqloracletest.domain.*;
+import com.ssf.mysqloracletest.service.BoneVehicleService;
 import com.ssf.mysqloracletest.service.DevopsDeviceInfoService;
 import com.ssf.mysqloracletest.service.TMotorvehicleService;
 import com.ssf.mysqloracletest.service.TransitVehicleRecordService;
@@ -36,6 +34,7 @@ public class VehicleRecordTask {
     private final TMotorvehicleService tMotorvehicleService;
     private final TransitVehicleRecordService transitVehicleRecordService;
     private final DevopsDeviceInfoService devopsDeviceInfoService;
+    private final BoneVehicleService boneVehicleService;
 
     SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmmss");
     String maxTime = "20231200000000";
@@ -75,6 +74,11 @@ public class VehicleRecordTask {
                     List<TMotorvehicle> records = tMotorvehicleService.page(page,wrapper).getRecords();
                     for (TMotorvehicle tMotorvehicle : records){
                         TransitVehicleRecord transitVehicleRecord = new TransitVehicleRecord();
+                        BoneVehicle one2 = boneVehicleService.lambdaQuery().eq(BoneVehicle::getNo, tMotorvehicle.getPlateno()).one();
+                        if (one2 != null){
+                            transitVehicleRecord.setOwnerName(one2.getOwnerPersonName());
+                            transitVehicleRecord.setIdCard(one2.getOwnerPersonIdcard());
+                        }
                         DevopsDeviceInfo devopsDeviceInfo = devopsDeviceInfoService.lambdaQuery().eq(DevopsDeviceInfo::getGbsChannelNo, tMotorvehicle.getTollgateid()).one();
                         transitVehicleRecord.setPlaceCode(devopsDeviceInfo.getPlaceCode());
                         transitVehicleRecord.setPlaceName(devopsDeviceInfo.getDeviceName());