src/main/java/com/genersoft/iot/vmp/gb28181/session/CatalogDataManager.java

@@ -194,15 +194,6 @@ public class CatalogDataManager implements CommandLineRunner {
         for (String key : keySet) {
             CatalogData catalogData = dataMap.get(key);
             if (catalogData != null && deviceId.equals(catalogData.getDevice().getDeviceId())) {
-                // 此时检查是否过期
-                Instant instantBefore30S = Instant.now().minusMillis(TimeUnit.SECONDS.toMillis(30));
-                if ((catalogData.getStatus().equals(CatalogData.CatalogDataStatus.end)
-                        || catalogData.getStatus().equals(CatalogData.CatalogDataStatus.ready))
-                        && catalogData.getTime().isBefore(instantBefore30S)) {
-                    dataMap.remove(key);
-                    return false;
-                }
-
                 return !catalogData.getStatus().equals(CatalogData.CatalogDataStatus.end);
             }
         }
@@ -231,26 +222,21 @@ public class CatalogDataManager implements CommandLineRunner {
                     String deviceId = catalogData.getDevice().getDeviceId();
                     int sn = catalogData.getSn();
                     List<DeviceChannel> deviceChannelList = getDeviceChannelList(deviceId, sn);
-                    try {
+                    if (catalogData.getTotal() == deviceChannelList.size()) {
-                        if (catalogData.getTotal() == deviceChannelList.size()) {
+                        deviceChannelService.resetChannels(catalogData.getDevice().getId(), deviceChannelList);
-                            deviceChannelService.resetChannels(catalogData.getDevice().getId(), deviceChannelList);
+                    }else {
-                        }else {
+                        deviceChannelService.updateChannels(catalogData.getDevice(), deviceChannelList);
-                            deviceChannelService.updateChannels(catalogData.getDevice(), deviceChannelList);
+                    }
-                        }
+                    List<Region> regionList = getRegionList(deviceId, sn);
-                        List<Region> regionList = getRegionList(deviceId, sn);
+                    if ( regionList!= null && !regionList.isEmpty()) {
-                        if ( regionList!= null && !regionList.isEmpty()) {
+                        regionService.batchAdd(regionList);
-                            regionService.batchAdd(regionList);
+                    }
-                        }
+                    List<Group> groupList = getGroupList(deviceId, sn);
-                        List<Group> groupList = getGroupList(deviceId, sn);
+                    if (groupList != null && !groupList.isEmpty()) {
-                        if (groupList != null && !groupList.isEmpty()) {
+                        groupService.batchAdd(groupList);
-                            groupService.batchAdd(groupList);
-                        }
-                    }catch (Exception e) {
-                        log.error("[国标通道同步] 入库失败： ", e);
                     }
                     String errorMsg = "更新成功，共" + catalogData.getTotal() + "条，已更新" + deviceChannelList.size() + "条";
                     catalogData.setErrorMsg(errorMsg);
-                    catalogData.setStatus(CatalogData.CatalogDataStatus.end);
                 }else if (catalogData.getStatus().equals(CatalogData.CatalogDataStatus.ready)) {
                     String errorMsg = "同步失败，等待回复超时";
                     catalogData.setErrorMsg(errorMsg);

web/src/views/common/jessibuca.vue

@@ -143,7 +143,7 @@ export default {
         isFlv: false,
         isFullResize: false,
         isNotMute: this.isNotMute,
-        isResize: true,
+        isResize: false,
         keepScreenOn: true,
         loadingText: '请稍等, 视频加载中......',
         loadingTimeout: 10,