音频视频发送推流消息的时候需要加userId

@@ -58,7 +58,7 @@ class AudioApe extends Ape {
         }
 
         if (_param == null||_param.channelId == null||
-            _param.classId == null||_param.userId == null||
+            _param.classId == null||_param.userId == null||_param.userId==""||
             _param.siteId == null|| _param.timestamp==null)
         {
             loger.warn('publishAudio,参数错误', _param);
@@ -93,6 +93,7 @@ class AudioApe extends Ape {
         channelInfo.classId=_param.classId;//GlobalConfig.classId;
         channelInfo.siteId=_param.siteId;//GlobalConfig.siteId;
         channelInfo.toNodeId=0;
+        channelInfo.userId=_param.userId;
         channelInfo.mediaType=ApeConsts.MEDIA_TYPE_AUDIO;
         this.sendTableUpdateHandler(channelInfo);
         return {"code": ApeConsts.RETURN_SUCCESS, "data":"推流成功!"}

@@ -59,7 +59,7 @@ class VideoApe extends Ape {
         }
 
         if (_param == null||_param.channelId == null||
-            _param.classId == null||_param.userId == null||
+            _param.classId == null||_param.userId == null||_param.userId==""||
             _param.siteId == null|| _param.timestamp==null)
         {
             loger.warn('publishVideo,参数错误', _param);
@@ -96,6 +96,7 @@ class VideoApe extends Ape {
         channelInfo.classId=_param.classId;//GlobalConfig.classId;
         channelInfo.siteId=_param.siteId;//GlobalConfig.siteId;
         channelInfo.toNodeId=0;
+        channelInfo.userId=_param.userId;
         channelInfo.mediaType=ApeConsts.MEDIA_TYPE_VIDEO;
         this.sendTableUpdateHandler(channelInfo);
         return {"code": ApeConsts.RETURN_SUCCESS, "data":"推流成功!"}