From dd086364a1cd818394bbf25ef9812c7d5343670e Mon Sep 17 00:00:00 2001 From: hanrenchun Date: Wed, 10 Jan 2024 18:42:16 +0800 Subject: [PATCH] =?UTF-8?q?gbs=E5=9C=A8=E7=BA=BF=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/DevopsVideoInfoServiceImpl.java | 20 +++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java index 78c13b7..69d7edd 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/DevopsVideoInfoServiceImpl.java @@ -7,6 +7,7 @@ import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.dynamic.datasource.annotation.DS; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ssf.mysqloracletest.domain.DevopsVideoInfo0; import com.ssf.mysqloracletest.domain.DevopsVideoStatus; @@ -184,6 +185,25 @@ public class DevopsVideoInfoServiceImpl extends ServiceImpl 0) { logger.info("设备国标已存在:" + bean.getGbsChannelNo()); + DevopsVideoInfo0 videoInfo = new DevopsVideoInfo0(); + BeanUtils.copyProperties(bean, videoInfo); + int isOnline = 2; + if ("ON".equals(Status)) { + isOnline = 1; + } + //如果设备插入成功 + DevopsVideoStatus videoStatus = new DevopsVideoStatus(); + videoStatus.setGbsNvrNo(StringKit.toString(videoInfo.getGbsNvrNo())); + videoStatus.setGbsChannelNo(StringKit.toString(videoInfo.getGbsChannelNo())); + videoStatus.setDeviceName(StringKit.toString(videoInfo.getDeviceName())); + videoStatus.setDeviceIp(StringKit.toString(videoInfo.getDeviceIp())); + videoStatus.setMonitoringType(videoInfo.getMonitoringType()); + videoStatus.setHeartbeatTime(System.currentTimeMillis() / 1000); + videoStatus.setIsOnline(isOnline); + QueryWrapper devopsVideoStatusQueryWrapper = new QueryWrapper<>(); + devopsVideoStatusQueryWrapper.eq("gbs_channel_no",StringKit.toString(videoInfo.getGbsChannelNo())); + videoStatusService.update(videoStatus,devopsVideoStatusQueryWrapper); + logger.info("修改成功:" + videoInfo.getGbsChannelNo()); continue; } } else {