From 829c2b9a6432d3616dac61d26c734cde554a3413 Mon Sep 17 00:00:00 2001 From: fengchunyu Date: Thu, 14 Dec 2023 17:20:21 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BC=93=E5=AD=98=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- config/application.properties | 2 +- pom.xml | 8 + .../mysqloracletest/cache/DeviceCache.java | 66 +++++++ .../ssf/mysqloracletest/cache/VideoCache.java | 66 +++++++ .../domain/DevopsDeviceInfo.java | 171 ++++++++++++++++++ .../domain/DevopsDeviceStatus.java | 76 ++++++++ .../domain/DevopsVideoInfo.java | 141 +++++++++++++++ .../domain/DevopsVideoStatus.java | 76 ++++++++ .../mapper/DevopsDeviceInfoMapper.java | 16 ++ .../mapper/DevopsDeviceStatusMapper.java | 16 ++ .../mapper/DevopsVideoInfoMapper.java | 16 ++ .../mapper/DevopsVideoStatusMapper.java | 16 ++ .../service/DevopsDeviceInfoService.java | 25 +++ .../service/DevopsDeviceStatusService.java | 25 +++ .../service/DevopsVideoInfoService.java | 25 +++ .../service/DevopsVideoStatusService.java | 25 +++ .../impl/DevopsDeviceInfoServiceImpl.java | 24 +++ .../impl/DevopsDeviceStatusServiceImpl.java | 24 +++ .../impl/DevopsVideoInfoServiceImpl.java | 24 +++ .../impl/DevopsVideoStatusServiceImpl.java | 24 +++ .../ssf/mysqloracletest/task/JcjCjxxTask.java | 3 + 21 files changed, 868 insertions(+), 1 deletion(-) create mode 100644 src/main/java/com/ssf/mysqloracletest/cache/DeviceCache.java create mode 100644 src/main/java/com/ssf/mysqloracletest/cache/VideoCache.java create mode 100644 src/main/java/com/ssf/mysqloracletest/domain/DevopsDeviceInfo.java create mode 100644 src/main/java/com/ssf/mysqloracletest/domain/DevopsDeviceStatus.java create mode 100644 src/main/java/com/ssf/mysqloracletest/domain/DevopsVideoInfo.java create mode 100644 src/main/java/com/ssf/mysqloracletest/domain/DevopsVideoStatus.java create mode 100644 src/main/java/com/ssf/mysqloracletest/mapper/DevopsDeviceInfoMapper.java create mode 100644 src/main/java/com/ssf/mysqloracletest/mapper/DevopsDeviceStatusMapper.java create mode 100644 src/main/java/com/ssf/mysqloracletest/mapper/DevopsVideoInfoMapper.java create mode 100644 src/main/java/com/ssf/mysqloracletest/mapper/DevopsVideoStatusMapper.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/DevopsDeviceInfoService.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/DevopsDeviceStatusService.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/DevopsVideoInfoService.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/DevopsVideoStatusService.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceInfoServiceImpl.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/impl/DevopsDeviceStatusServiceImpl.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java create mode 100644 src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoStatusServiceImpl.java 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/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/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/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/task/JcjCjxxTask.java b/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java index 5100199..8dd5ad6 100644 --- a/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java +++ b/src/main/java/com/ssf/mysqloracletest/task/JcjCjxxTask.java @@ -49,6 +49,9 @@ public class JcjCjxxTask { @Scheduled(initialDelay = 100, fixedDelay = 3000) public void transcjxx() { +// String value = DeviceCache.get("32092451211328052004"); +// System.out.println(); + if (cjxxTag) { return; }