diff --git a/config/application.properties b/config/application.properties index 88cbeb0..0af0ab6 100644 --- a/config/application.properties +++ b/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 diff --git a/pom.xml b/pom.xml index 70f5c9e..e3b1eb9 100644 --- a/pom.xml +++ b/pom.xml @@ -109,6 +109,14 @@ 4.9.1 + + + + com.github.ben-manes.caffeine + caffeine + 2.9.0 + + diff --git a/src/main/java/com/ssf/mysqloracletest/cache/DeviceCache.java b/src/main/java/com/ssf/mysqloracletest/cache/DeviceCache.java new file mode 100644 index 0000000..864f57b --- /dev/null +++ b/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 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().eq(DevopsDeviceInfo::getGbsChannelNo, key))); + } catch (Exception e) { + return null; + } + }); + } + + /** + * 缂撳瓨鍒锋柊 + */ + @Scheduled(cron = "0 0 3 * * ?") + public static void refresh() { + load(); + } + + private static void load() { + + List list = devopsDeviceInfoService.list(); + Map dictMap = list.stream().collect(Collectors.toMap(DevopsDeviceInfo::getGbsChannelNo, e -> String.valueOf(e), (v1, v2) -> v2)); + Map dictMapCode = list.stream().collect(Collectors.toMap( + e -> e.getGbsChannelNo(), + e -> String.valueOf(e), (v1, v2) -> v2)); + cache.putAll(dictMap); + cache.putAll(dictMapCode); + } +} diff --git a/src/main/java/com/ssf/mysqloracletest/cache/VideoCache.java b/src/main/java/com/ssf/mysqloracletest/cache/VideoCache.java new file mode 100644 index 0000000..4a79164 --- /dev/null +++ b/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 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().eq(DevopsVideoInfo::getGbsChannelNo, key))); + } catch (Exception e) { + return null; + } + }); + } + + /** + * 缂撳瓨鍒锋柊 + */ + @Scheduled(cron = "0 0 3 * * ?") + public static void refresh() { + load(); + } + + private static void load() { + + List list = devopsVideoInfoService.list(); + Map dictMap = list.stream().collect(Collectors.toMap(DevopsVideoInfo::getGbsChannelNo, e -> String.valueOf(e), (v1, v2) -> v2)); + Map dictMapCode = list.stream().collect(Collectors.toMap( + e -> e.getGbsChannelNo(), + e -> String.valueOf(e), (v1, v2) -> v2)); + cache.putAll(dictMap); + cache.putAll(dictMapCode); + } +} diff --git a/src/main/java/com/ssf/mysqloracletest/domain/DevopsDeviceInfo.java b/src/main/java/com/ssf/mysqloracletest/domain/DevopsDeviceInfo.java new file mode 100644 index 0000000..437fa16 --- /dev/null +++ b/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; + +} diff --git a/src/main/java/com/ssf/mysqloracletest/domain/DevopsDeviceStatus.java b/src/main/java/com/ssf/mysqloracletest/domain/DevopsDeviceStatus.java new file mode 100644 index 0000000..28d8216 --- /dev/null +++ b/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; + +} diff --git a/src/main/java/com/ssf/mysqloracletest/domain/DevopsVideoInfo.java b/src/main/java/com/ssf/mysqloracletest/domain/DevopsVideoInfo.java new file mode 100644 index 0000000..65a88d4 --- /dev/null +++ b/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; + +} diff --git a/src/main/java/com/ssf/mysqloracletest/domain/DevopsVideoStatus.java b/src/main/java/com/ssf/mysqloracletest/domain/DevopsVideoStatus.java new file mode 100644 index 0000000..0b99e9b --- /dev/null +++ b/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; + +} diff --git a/src/main/java/com/ssf/mysqloracletest/domain/TransitUserRecord.java b/src/main/java/com/ssf/mysqloracletest/domain/TransitUserRecord.java new file mode 100644 index 0000000..2b65ae5 --- /dev/null +++ b/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; +} \ No newline at end of file diff --git a/src/main/java/com/ssf/mysqloracletest/domain/TransitVehicleRecord.java b/src/main/java/com/ssf/mysqloracletest/domain/TransitVehicleRecord.java new file mode 100644 index 0000000..3e0ece6 --- /dev/null +++ b/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; +} \ No newline at end of file diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/DevopsDeviceInfoMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/DevopsDeviceInfoMapper.java new file mode 100644 index 0000000..e8a7669 --- /dev/null +++ b/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 { + +} diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/DevopsDeviceStatusMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/DevopsDeviceStatusMapper.java new file mode 100644 index 0000000..eda7872 --- /dev/null +++ b/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 { + +} diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/DevopsVideoInfoMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/DevopsVideoInfoMapper.java new file mode 100644 index 0000000..021ef04 --- /dev/null +++ b/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 { + +} diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/DevopsVideoStatusMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/DevopsVideoStatusMapper.java new file mode 100644 index 0000000..90e5454 --- /dev/null +++ b/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 { + +} diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/TransitUserRecordMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/TransitUserRecordMapper.java new file mode 100644 index 0000000..fa11bd5 --- /dev/null +++ b/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 閽堝琛ㄣ恡ransit_user_record(浜鸿劯璁板綍琛)銆戠殑鏁版嵁搴撴搷浣淢apper +* @createDate 2023-12-14 16:46:10 +* @Entity com.ssf.mysqloracletest.domain.TransitUserRecord +*/ +public interface TransitUserRecordMapper extends BaseMapper { + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/TransitVehicleRecordMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/TransitVehicleRecordMapper.java new file mode 100644 index 0000000..6b6c24f --- /dev/null +++ b/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 閽堝琛ㄣ恡ransit_vehicle_record(杞﹁締璁板綍琛)銆戠殑鏁版嵁搴撴搷浣淢apper +* @createDate 2023-12-14 16:47:49 +* @Entity com.ssf.mysqloracletest.domain.TransitVehicleRecord +*/ +public interface TransitVehicleRecordMapper extends BaseMapper { + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/DevopsDeviceInfoService.java b/src/main/java/com/ssf/mysqloracletest/service/DevopsDeviceInfoService.java new file mode 100644 index 0000000..a8e429f --- /dev/null +++ b/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 { + + /** + * 鏂板鎴栬呮洿鏂版櫤鑳借澶囦俊鎭〃 + * + * @param devopsDeviceInfo 鏅鸿兘璁惧淇℃伅琛ㄥ璞 + * @return 缁撴灉 + */ + boolean insertOrUpdate(DevopsDeviceInfo devopsDeviceInfo); + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/DevopsDeviceStatusService.java b/src/main/java/com/ssf/mysqloracletest/service/DevopsDeviceStatusService.java new file mode 100644 index 0000000..0a128a0 --- /dev/null +++ b/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 { + + /** + * 鏂板鎴栬呮洿鏂拌澶囩姸鎬佷俊鎭〃 + * + * @param devopsDeviceStatus 璁惧鐘舵佷俊鎭〃瀵硅薄 + * @return 缁撴灉 + */ + boolean insertOrUpdate(DevopsDeviceStatus devopsDeviceStatus); + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/DevopsVideoInfoService.java b/src/main/java/com/ssf/mysqloracletest/service/DevopsVideoInfoService.java new file mode 100644 index 0000000..24f1aa0 --- /dev/null +++ b/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 { + + /** + * 鏂板鎴栬呮洿鏂拌棰戠洃鎺ц澶囪〃 + * + * @param devopsVideoInfo 瑙嗛鐩戞帶璁惧琛ㄥ璞 + * @return 缁撴灉 + */ + boolean insertOrUpdate(DevopsVideoInfo devopsVideoInfo); + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/DevopsVideoStatusService.java b/src/main/java/com/ssf/mysqloracletest/service/DevopsVideoStatusService.java new file mode 100644 index 0000000..f8ace86 --- /dev/null +++ b/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 { + + /** + * 鏂板鎴栬呮洿鏂拌棰戠洃鎺х姸鎬佽〃 + * + * @param devopsVideoStatus 瑙嗛鐩戞帶鐘舵佽〃瀵硅薄 + * @return 缁撴灉 + */ + boolean insertOrUpdate(DevopsVideoStatus devopsVideoStatus); + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/TransitUserRecordService.java b/src/main/java/com/ssf/mysqloracletest/service/TransitUserRecordService.java new file mode 100644 index 0000000..ba8b350 --- /dev/null +++ b/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 閽堝琛ㄣ恡ransit_user_record(浜鸿劯璁板綍琛)銆戠殑鏁版嵁搴撴搷浣淪ervice +* @createDate 2023-12-14 16:46:10 +*/ +public interface TransitUserRecordService extends IService { + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/TransitVehicleRecordService.java b/src/main/java/com/ssf/mysqloracletest/service/TransitVehicleRecordService.java new file mode 100644 index 0000000..031f92d --- /dev/null +++ b/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 閽堝琛ㄣ恡ransit_vehicle_record(杞﹁締璁板綍琛)銆戠殑鏁版嵁搴撴搷浣淪ervice +* @createDate 2023-12-14 16:47:49 +*/ +public interface TransitVehicleRecordService 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 new file mode 100644 index 0000000..d3751b5 --- /dev/null +++ b/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 implements DevopsDeviceInfoService { + + @Override + public boolean insertOrUpdate(DevopsDeviceInfo devopsDeviceInfo) { + return false; + } + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceStatusServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceStatusServiceImpl.java new file mode 100644 index 0000000..98f602b --- /dev/null +++ b/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 implements DevopsDeviceStatusService { + + @Override + public boolean insertOrUpdate(DevopsDeviceStatus devopsDeviceStatus) { + return false; + } + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java new file mode 100644 index 0000000..3ba0e2c --- /dev/null +++ b/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 implements DevopsVideoInfoService { + + @Override + public boolean insertOrUpdate(DevopsVideoInfo devopsVideoInfo) { + return false; + } + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoStatusServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoStatusServiceImpl.java new file mode 100644 index 0000000..3c7c048 --- /dev/null +++ b/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 implements DevopsVideoStatusService { + + @Override + public boolean insertOrUpdate(DevopsVideoStatus devopsVideoStatus) { + return false; + } + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/TransitUserRecordServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/TransitUserRecordServiceImpl.java new file mode 100644 index 0000000..8c6b88d --- /dev/null +++ b/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 閽堝琛ㄣ恡ransit_user_record(浜鸿劯璁板綍琛)銆戠殑鏁版嵁搴撴搷浣淪ervice瀹炵幇 +* @createDate 2023-12-14 16:46:10 +*/ +@Service +@RequiredArgsConstructor +@DS("mysql") +public class TransitUserRecordServiceImpl extends ServiceImpl + implements TransitUserRecordService{ + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/TransitVehicleRecordServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/TransitVehicleRecordServiceImpl.java new file mode 100644 index 0000000..467fca2 --- /dev/null +++ b/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 閽堝琛ㄣ恡ransit_vehicle_record(杞﹁締璁板綍琛)銆戠殑鏁版嵁搴撴搷浣淪ervice瀹炵幇 +* @createDate 2023-12-14 16:47:49 +*/ +@Service +@RequiredArgsConstructor +@DS("mysql") +public class TransitVehicleRecordServiceImpl extends ServiceImpl + implements TransitVehicleRecordService{ + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java b/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java index d0127d0..2fcbaed 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java +++ b/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; } diff --git a/src/main/resources/mapper/TransitUserRecordMapper.xml b/src/main/resources/mapper/TransitUserRecordMapper.xml new file mode 100644 index 0000000..8b10da6 --- /dev/null +++ b/src/main/resources/mapper/TransitUserRecordMapper.xml @@ -0,0 +1,48 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/src/main/resources/mapper/TransitVehicleRecordMapper.xml b/src/main/resources/mapper/TransitVehicleRecordMapper.xml new file mode 100644 index 0000000..186b67c --- /dev/null +++ b/src/main/resources/mapper/TransitVehicleRecordMapper.xml @@ -0,0 +1,53 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +