Merge branch 'refs/heads/2.7.1'

648540858

2024-06-25 57a230afb3b02cedf8ec39cd60e5163f953e3260

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

@@ -154,7 +154,7 @@
            }catch (Exception e) {
               logger.error("[向上级转发移动位置失败] ", e);
            }
            if (mobilePosition.getChannelId() == null || mobilePosition.getChannelId().equals(mobilePosition.getDeviceId()) ) {
            if (mobilePosition.getChannelId() == null || mobilePosition.getChannelId().equals(mobilePosition.getDeviceId())) {
               List<DeviceChannel> channels = deviceChannelService.queryChaneListByDeviceId(mobilePosition.getDeviceId());
               channels.forEach(channel -> {
                  // 发送redis消息。 通知位置信息的变化
@@ -188,8 +188,8 @@
      }
      taskQueue.clear();
   }
   @Scheduled(fixedRate = 10000)
   public void execute(){
      logger.info("[待处理Notify-移动位置订阅消息数量]: {}", taskQueue.size());
   }
//   @Scheduled(fixedRate = 10000)
//   public void execute(){
//      logger.debug("[待处理Notify-移动位置订阅消息数量]: {}", taskQueue.size());
//   }
}