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 {