缓存代码

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

pom.xml

@@ -109,6 +109,14 @@
 			<version>4.9.1</version>
 		</dependency>
 
+
+		<!--caffeine本地缓存-->
+		<dependency>
+			<groupId>com.github.ben-manes.caffeine</groupId>
+			<artifactId>caffeine</artifactId>
+			<version>2.9.0</version>
+		</dependency>
+
 	</dependencies>
 
 	<build>

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<String, String> 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<DevopsDeviceInfo>().eq(DevopsDeviceInfo::getGbsChannelNo, key)));
+            } catch (Exception e) {
+                return null;
+            }
+        });
+    }
+
+    /**
+     * 缓存刷新
+     */
+    @Scheduled(cron = "0 0 3 * * ?")
+    public static void refresh() {
+        load();
+    }
+
+    private static void load() {
+
+        List<DevopsDeviceInfo> list = devopsDeviceInfoService.list();
+        Map<String, String> dictMap = list.stream().collect(Collectors.toMap(DevopsDeviceInfo::getGbsChannelNo, e -> String.valueOf(e), (v1, v2) -> v2));
+        Map<String, String> dictMapCode = list.stream().collect(Collectors.toMap(
+                e -> e.getGbsChannelNo(),
+                e -> String.valueOf(e), (v1, v2) -> v2));
+        cache.putAll(dictMap);
+        cache.putAll(dictMapCode);
+    }
+}

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<String, String> 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<DevopsVideoInfo>().eq(DevopsVideoInfo::getGbsChannelNo, key)));
+            } catch (Exception e) {
+                return null;
+            }
+        });
+    }
+
+    /**
+     * 缓存刷新
+     */
+    @Scheduled(cron = "0 0 3 * * ?")
+    public static void refresh() {
+        load();
+    }
+
+    private static void load() {
+
+        List<DevopsVideoInfo> list = devopsVideoInfoService.list();
+        Map<String, String> dictMap = list.stream().collect(Collectors.toMap(DevopsVideoInfo::getGbsChannelNo, e -> String.valueOf(e), (v1, v2) -> v2));
+        Map<String, String> dictMapCode = list.stream().collect(Collectors.toMap(
+                e -> e.getGbsChannelNo(),
+                e -> String.valueOf(e), (v1, v2) -> v2));
+        cache.putAll(dictMap);
+        cache.putAll(dictMapCode);
+    }
+}

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;
+
+}

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;
+
+}

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;
+
+}

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;
+
+}

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<DevopsDeviceInfo> {
+
+}

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<DevopsDeviceStatus> {
+
+}

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<DevopsVideoInfo> {
+
+}

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<DevopsVideoStatus> {
+
+}

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<DevopsDeviceInfo> {
+
+    /**
+     * 新增或者更新智能设备信息表
+     *
+     * @param devopsDeviceInfo 智能设备信息表对象
+     * @return 结果
+     */
+    boolean insertOrUpdate(DevopsDeviceInfo devopsDeviceInfo);
+
+}

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<DevopsDeviceStatus> {
+
+    /**
+     * 新增或者更新设备状态信息表
+     *
+     * @param devopsDeviceStatus 设备状态信息表对象
+     * @return 结果
+     */
+    boolean insertOrUpdate(DevopsDeviceStatus devopsDeviceStatus);
+
+}

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<DevopsVideoInfo> {
+
+    /**
+     * 新增或者更新视频监控设备表
+     *
+     * @param devopsVideoInfo 视频监控设备表对象
+     * @return 结果
+     */
+    boolean insertOrUpdate(DevopsVideoInfo devopsVideoInfo);
+
+}

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<DevopsVideoStatus> {
+
+    /**
+     * 新增或者更新视频监控状态表
+     *
+     * @param devopsVideoStatus 视频监控状态表对象
+     * @return 结果
+     */
+    boolean insertOrUpdate(DevopsVideoStatus devopsVideoStatus);
+
+}

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<DevopsDeviceInfoMapper, DevopsDeviceInfo> implements DevopsDeviceInfoService {
+
+    @Override
+    public boolean insertOrUpdate(DevopsDeviceInfo devopsDeviceInfo) {
+        return false;
+    }
+
+}

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<DevopsDeviceStatusMapper, DevopsDeviceStatus> implements DevopsDeviceStatusService {
+
+    @Override
+    public boolean insertOrUpdate(DevopsDeviceStatus devopsDeviceStatus) {
+        return false;
+    }
+
+}

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<DevopsVideoInfoMapper, DevopsVideoInfo> implements DevopsVideoInfoService {
+
+    @Override
+    public boolean insertOrUpdate(DevopsVideoInfo devopsVideoInfo) {
+        return false;
+    }
+
+}

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<DevopsVideoStatusMapper, DevopsVideoStatus> implements DevopsVideoStatusService {
+
+    @Override
+    public boolean insertOrUpdate(DevopsVideoStatus devopsVideoStatus) {
+        return false;
+    }
+
+}

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;
         }