优化通道更新

648540858

2024-04-20 b57dbeac1354999488b9ef2ad4192dc1b323f642

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/NotifyRequestForCatalogProcessor.java

@@ -108,7 +108,7 @@
               }else {
                  event = eventElement.getText().toUpperCase();
               }
               DeviceChannel channel = XmlUtil.channelContentHandler(itemDevice, device, event, civilCodeFileConf);
               DeviceChannel channel = XmlUtil.channelContentHandler(itemDevice, device, event);
               if (channel == null) {
                  logger.info("[收到目录订阅]：但是解析失败 {}", new String(evt.getRequest().getRawContent()));
                  continue;
@@ -295,9 +295,10 @@

   private void executeSaveForUpdate(){
      if (!updateChannelMap.values().isEmpty()) {
         logger.info("[存储收到的更新通道], 数量： {}", updateChannelMap.size());
         ArrayList<DeviceChannel> deviceChannels = new ArrayList<>(updateChannelMap.values());
         updateChannelMap.clear();
         deviceChannelService.batchUpdateChannel(deviceChannels);
         updateChannelMap.clear();
      }

   }