‘sxh’
2023-06-15 ccc0a99d6894844d83d751b924cfebe74da7826c
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/callback/DeferredResultHolder.java
@@ -45,13 +45,15 @@
   public static final String UPLOAD_FILE_CHANNEL = "UPLOAD_FILE_CHANNEL";
   public static final String CALLBACK_CMD_MOBILEPOSITION = "CALLBACK_MOBILEPOSITION";
   public static final String CALLBACK_CMD_MOBILE_POSITION = "CALLBACK_CMD_MOBILE_POSITION";
   public static final String CALLBACK_CMD_PRESETQUERY = "CALLBACK_PRESETQUERY";
   public static final String CALLBACK_CMD_ALARM = "CALLBACK_ALARM";
   public static final String CALLBACK_CMD_BROADCAST = "CALLBACK_BROADCAST";
   public static final String CALLBACK_CMD_SNAP= "CALLBACK_SNAP";
   private Map<String, Map<String, DeferredResultEx>> map = new ConcurrentHashMap<>();
@@ -153,4 +155,30 @@
         map.remove(msg.getKey());
      }
   }
   /*============================设备主子码流逻辑START========================*/
   public static String getPlayKey(String deviceId,String channelId,boolean deviceSwitchSubStream,boolean isSubStream){
      String key = null;
      if(deviceSwitchSubStream){
         key = CALLBACK_CMD_PLAY + isSubStream + deviceId + channelId;
      }else {
         key = CALLBACK_CMD_PLAY +deviceId + channelId;
      }
      return key;
   }
   public static String getSnapKey(String deviceId,String channelId,boolean deviceSwitchSubStream,boolean isSubStream){
      String key = null;
      if(deviceSwitchSubStream){
         key = CALLBACK_CMD_SNAP + isSubStream + deviceId + channelId;
      }else {
         key = CALLBACK_CMD_SNAP +deviceId + channelId;
      }
      return key;
   }
   /*============================设备主子码流逻辑END========================*/
}