修复转发国标notify-update时信息错误的问题

648540858

2024-04-23 901dee2bf4c91fa92306b5d8aa66b3148658186c

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

@@ -136,9 +136,9 @@
                  } else if (CmdType.MOBILE_POSITION.equals(cmd)) {
//                     logger.info("接收到MobilePosition通知");
//                     processNotifyMobilePosition(take.getEvt());
                     taskExecutor.execute(() -> {
//                     taskExecutor.execute(() -> {
                        notifyRequestForMobilePositionProcessor.process(take.getEvt());
                     });
//                     });

                  } else {
                     logger.info("接收到消息：" + cmd);
@@ -226,8 +226,8 @@
         } else {
            mobilePosition.setAltitude(0.0);
         }
         logger.info("[收到移动位置订阅通知]：{}/{}->{}.{}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(),
               mobilePosition.getLongitude(), mobilePosition.getLatitude());
//         logger.info("[收到移动位置订阅通知]：{}/{}->{}.{}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(),
//               mobilePosition.getLongitude(), mobilePosition.getLatitude());
         mobilePosition.setReportSource("Mobile Position");

         // 更新device channel 的经纬度
@@ -370,8 +370,8 @@
      this.redisCatchStorage = redisCatchStorage;
   }

   @Scheduled(fixedRate = 1000)   //每1秒执行一次
   @Scheduled(fixedRate = 10000)   //每1秒执行一次
   public void execute(){
      System.out.println("待处理消息数量: " + taskQueue.size());
      logger.info("[待处理Notify消息数量]: {}", taskQueue.size());
   }
}