gbs在线状态定时任务更新

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<DevopsVideoInfoMappe
                                     .eq(DevopsVideoInfo0::getGbsChannelNo, bean.getGbsChannelNo()));
                             if (checklists != null && checklists.size() > 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<DevopsVideoStatus> devopsVideoStatusQueryWrapper = new QueryWrapper<>();
+                                devopsVideoStatusQueryWrapper.eq("gbs_channel_no",StringKit.toString(videoInfo.getGbsChannelNo()));
+                                videoStatusService.update(videoStatus,devopsVideoStatusQueryWrapper);
+                                logger.info("修改成功:" + videoInfo.getGbsChannelNo());
                                 continue;
                             }
                         } else {