diff --git a/src/main/java/com/ssf/mysqloracletest/domain/BoneVehicle.java b/src/main/java/com/ssf/mysqloracletest/domain/BoneVehicle.java new file mode 100644 index 0000000..94fe5dc --- /dev/null +++ b/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; +} \ No newline at end of file diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/BoneVehicleMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/BoneVehicleMapper.java new file mode 100644 index 0000000..7b0777f --- /dev/null +++ b/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 { + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/BoneVehicleService.java b/src/main/java/com/ssf/mysqloracletest/service/BoneVehicleService.java new file mode 100644 index 0000000..38f71a7 --- /dev/null +++ b/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 { + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/BoneVehicleServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/BoneVehicleServiceImpl.java new file mode 100644 index 0000000..794a7dc --- /dev/null +++ b/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 + implements BoneVehicleService { + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/task/VehicleRecordTask.java b/src/main/java/com/ssf/mysqloracletest/task/VehicleRecordTask.java index 4226ed8..535ef0c 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/VehicleRecordTask.java +++ b/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 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());