yangyakun921/MoGoAiCloudSdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复30秒检测是否关闭直播的逻辑

Browse Source
This commit is contained in:
董宏宇
2021-03-03 17:47:39 +08:00
parent 20b9609cf3
commit 5d6dcd2dde
4 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/main/AndroidManifest.xml
View File

@@ -65,14 +65,14 @@
android:label="路况服务"
android:launchMode="singleTask" />
<receiver android:name=".wifi.WifiBroadCastReceiver">
<!-- <receiver android:name=".wifi.WifiBroadCastReceiver">
<intent-filter>
<action android:name="android.net.wifi.RSSI_CHANGED" />
<action android:name="android.net.wifi.STATE_CHANGE" />
<action android:name="android.net.wifi.WIFI_STATE_CHANGED" />
</intent-filter>
</receiver>
</receiver>-->
</application>
</manifest>

4
app/src/main/java/com/mogo/cloud/LivePlayAndPushActivity.java
View File

@@ -28,7 +28,7 @@ public class LivePlayAndPushActivity extends BaseLiveActivity
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
WifiStateManager.getInstance().registerWifiStateListener(this);
// WifiStateManager.getInstance().registerWifiStateListener(this);
// 初始化直播流管理
liveStreamManager = LiveStreamManagerImpl.getInstance(this.getApplication(),
@@ -119,7 +119,7 @@ public class LivePlayAndPushActivity extends BaseLiveActivity
MoGoAiCloudTrafficLive.stopLive(liveSn);
MoGoAiCloudTrafficLive.destroyLive();
WifiStateManager.getInstance().unRegisterWifiStateListener(this);
// WifiStateManager.getInstance().unRegisterWifiStateListener(this);
}
@Override

3
foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/LiveStreamManagerImpl.java
View File

@@ -172,6 +172,9 @@ public class LiveStreamManagerImpl implements ILiveStreamManager {
uploadCamStatus(sCam1AvailableStatus, sCam2AvailableStatus);
restartCamStatusLoop();
// 判断当前观众的个数，如果没人观看了的情况则停止直播
Logger.i(TAG, "直播状态为： " + mLivePusher.isPushing() +
" 观众人数：" + mLivePusher.getOnlineNumber());
if (mLivePusher.isPushing() && mLivePusher.getOnlineNumber() <= 1) {
livePushHandler(PUSH_STOP, C1);
}

12
foudations/mogo-live/src/main/java/com/mogo/cloud/live/manager/MoGoLiveManager.java
View File

@@ -251,10 +251,13 @@ public class MoGoLiveManager {
@Override
public void onRoomOnlineUserCountUpdate(String roomID, int count) {
super.onRoomOnlineUserCountUpdate(roomID, count);
onlineNumber = count;
Logger.i(TAG, "onRoomOnlineUserCountUpdate roomID : " + roomID + " , online user number : " + onlineNumber);
if (mRoomStatusListener != null) {
mRoomStatusListener.onRoomOnlineUserCountUpdate(count);
// 这里只处理当前设备登录的房间中的用户总数
if (currentRoomId.equals(roomID)) {
onlineNumber = count;
Logger.i(TAG, "onRoomOnlineUserCountUpdate roomID : " + roomID + " , online user number : " + onlineNumber);
if (mRoomStatusListener != null) {
mRoomStatusListener.onRoomOnlineUserCountUpdate(count);
}
}
}
@@ -262,7 +265,6 @@ public class MoGoLiveManager {
@Override
public void onRoomUserUpdate(String roomID, ZegoUpdateType updateType, ArrayList<ZegoUser> userList) {
super.onRoomUserUpdate(roomID, updateType, userList);
onlineNumber = userList.size();
Logger.i(TAG, "onRoomUserUpdate roomId : " + roomID + " , updateType : " + updateType.name() + " , online user number : " + onlineNumber);
if (mRoomStatusListener != null) {
mRoomStatusListener.onRoomUserUpdate(updateType, userList);