marking
/
WGShare.Mobile.Flutter
19
0
Fork 0
Code Pull Requests Actions Releases Activity

1.7下午

This commit is contained in:
fuenmao 2025-01-07 15:45:20 +08:00
parent 976b76adae
commit 44180f9924
9 changed files with 237 additions and 184 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
wgshare/lib/common/config/request_config.dart
View File

@ -5,7 +5,7 @@ class RequestConfig {
// static const _devBaseUrl = "https://zyapitest.23544.com:16440"; // 开发 // static const _devBaseUrl = "https://zyapitest.23544.com:16440"; // 开发
static const _devBaseUrl = "http://192.168.2.9:5192"; // 开发 static const _devBaseUrl = "http://192.168.2.9:5192"; // 开发
// static const _proBaseUrl = "http://192.168.2.119:1091"; // 生产 // static const _proBaseUrl = "http://192.168.2.119:1091"; // 生产
static const _proBaseUrl = "https://zyapi.23544.com/ipadapi"; // 生产 static const _proBaseUrl = "http://192.168.2.9:5192"; // 生产
static const imgUrl = 'https://dpc-job-oss.23544.com/'; static const imgUrl = 'https://dpc-job-oss.23544.com/';
static RequestConfig? _instance; static RequestConfig? _instance;

20
wgshare/lib/common/request/rest_dio.dart
View File

@ -6,6 +6,8 @@ import 'package:dio/dio.dart';
import 'package:wgshare/common/api/retrofit_client.dart'; import 'package:wgshare/common/api/retrofit_client.dart';
import 'package:wgshare/common/config/request_config.dart'; import 'package:wgshare/common/config/request_config.dart';
import 'package:wgshare/common/store/user_store.dart'; import 'package:wgshare/common/store/user_store.dart';
import 'package:wgshare/utils/anti_shake_throttling.dart';
import 'package:wgshare/utils/routeUtil.dart';
import 'package:wgshare/utils/storage.dart'; import 'package:wgshare/utils/storage.dart';
import 'package:wgshare/utils/toast_utils.dart'; import 'package:wgshare/utils/toast_utils.dart';
import 'package:wgshare/routes/app_routes.dart'; import 'package:wgshare/routes/app_routes.dart';
@ -111,9 +113,9 @@ class ResponseHandle extends Interceptor {
((data['code'] != null && (data['code'] == 401 || data['code'] == '401')) || ((data['code'] != null && (data['code'] == 401 || data['code'] == '401')) ||
(data['Code'] != null && (data['Code'] == 401 || data['Code'] == '401'))); (data['Code'] != null && (data['Code'] == 401 || data['Code'] == '401')));
if (statusCode == 401 || flag) { if ((statusCode == 401 || flag) && RouteUtil.getRoute() != Routes.loginPage) {
Future.delayed(const Duration(seconds: 2), () { easyThrottle("toLogin",(){
StorageService.to.erase(); UserStore.to.erase();
getx.Get.offAllNamed(Routes.loginPage); getx.Get.offAllNamed(Routes.loginPage);
}); });
} }
@ -163,12 +165,12 @@ class TheError extends Interceptor {
switch (statusCode) { switch (statusCode) {
case 401: case 401:
message = '用户登录失效，请重新登录'; message = '用户登录失效，请重新登录';
if(RouteUtil.getRoute() != Routes.loginPage){
Future.delayed(const Duration(seconds: 2), () { easyThrottle("toLogin",(){
// UserStore.to.erase(); UserStore.to.erase();
StorageService.to.erase(); getx.Get.offAllNamed(Routes.loginPage);
getx.Get.offAllNamed(Routes.loginPage); });
}); }
break; break;
case 404: case 404:
message = '无效地址'; message = '无效地址';

2
wgshare/lib/pages/homePage/home_logic.dart
View File

@ -134,6 +134,7 @@ class HomeLogic extends GetxController with RequestToolMixin {
leftBtnStr: '拒绝', leftBtnStr: '拒绝',
rightBtnStr: '同意', rightBtnStr: '同意',
leftBtnCallback: () { leftBtnCallback: () {
Get.back();
Get.toNamed(Routes.meetingMainPage, Get.toNamed(Routes.meetingMainPage,
arguments: { arguments: {
"roomNumber": state.meetingRooms.value[index].roomNum "roomNumber": state.meetingRooms.value[index].roomNum
@ -142,6 +143,7 @@ class HomeLogic extends GetxController with RequestToolMixin {
rightBtnCallback: () { rightBtnCallback: () {
PermissionService.requestPermissions().then((value) { PermissionService.requestPermissions().then((value) {
if (value == true) { if (value == true) {
Get.back();
Get.toNamed(Routes.meetingMainPage, Get.toNamed(Routes.meetingMainPage,
arguments: { arguments: {
"roomNumber": state.meetingRooms.value[index].roomNum "roomNumber": state.meetingRooms.value[index].roomNum

52
wgshare/lib/pages/loginPage/login_logic.dart
View File

@ -20,22 +20,22 @@ import '../../view/upgrade/loadJson/load_network_json.dart';
import 'login_state.dart'; import 'login_state.dart';
class LoginLogic extends GetxController with RequestToolMixin { class LoginLogic extends GetxController with RequestToolMixin {
final LoginState state = LoginState(); late LoginState state;
@override @override
void onInit() { void onInit() {
super.onInit(); print("初始化登录init................");
state = LoginState();
HideCheckVersion hideCheckVersion = HideCheckVersion(); HideCheckVersion hideCheckVersion = HideCheckVersion();
hideCheckVersion.doHttpHideCheckVersion(); hideCheckVersion.doHttpHideCheckVersion();
super.onInit();
} }
@override @override
void onClose() { void onClose() {
print("销毁onClose................");
super.onClose(); super.onClose();
state.passwordController.dispose();
state.userNameController.dispose();
state.meetingCodeController.dispose();
state.nickNameCodeController.dispose();
} }
/// 改变页面状态 /// 改变页面状态
@ -50,24 +50,24 @@ class LoginLogic extends GetxController with RequestToolMixin {
/// 登录 /// 登录
Future<void> doHttpLogin() async { Future<void> doHttpLogin() async {
if(state.userNameController.text.isEmpty){ if(state.userNameController!.text.isEmpty){
ToastUtils.showError("请输入账号"); ToastUtils.showError("请输入账号");
}else if(state.passwordController.text.isEmpty){ }else if(state.passwordController!.text.isEmpty){
ToastUtils.showError("请输入密码"); ToastUtils.showError("请输入密码");
}else if(state.checkAgreementBool.value != true){ }else if(state.checkAgreementBool.value != true){
ToastUtils.showError("请阅读并勾选相关协议"); ToastUtils.showError("请阅读并勾选相关协议");
}else{ }else{
BaseStructureResult<UserInfoEntity> res = await getClient().login(state.userNameController.text, md5.convert(utf8.encode(state.passwordController.text)).toString()); BaseStructureResult<UserInfoEntity> res = await getClient().login(state.userNameController!.text, md5.convert(utf8.encode(state.passwordController!.text)).toString());
if (null != res.data) { if (null != res.data) {
UserStore.to.setToken(res.data!.token); UserStore.to.setToken(res.data!.token);
UserStore.to.setRefreshToken(res.data!.refreshToken); UserStore.to.setRefreshToken(res.data!.refreshToken);
UserStore.to.setUserDetailInfo(res.data!); UserStore.to.setUserDetailInfo(res.data!);
UserStore.to.setLoginType(AppConfig.NORMAL_LOGIN); UserStore.to.setLoginType(AppConfig.NORMAL_LOGIN);
Get.offAllNamed(Routes.startPage); Get.offAllNamed(Routes.startPage);
state.userNameController.text = ""; state.userNameController!.text = "";
state.passwordController.text = ""; state.passwordController!.text = "";
state.meetingCodeController.text = ""; state.meetingCodeController!.text = "";
state.nickNameCodeController.text = ""; state.nickNameCodeController!.text = "";
state.checkAgreementBool.value = false; state.checkAgreementBool.value = false;
} }
} }
@ -75,26 +75,26 @@ class LoginLogic extends GetxController with RequestToolMixin {
/// 直接进入会议（匿名登录） /// 直接进入会议（匿名登录）
Future<void> doHttpAnonymousLogin() async { Future<void> doHttpAnonymousLogin() async {
if(state.meetingCodeController.text.isEmpty){ if(state.meetingCodeController!.text.isEmpty){
ToastUtils.showError("请输入会议号"); ToastUtils.showError("请输入会议号");
}else if(state.meetingCodeController.text.length != 8){ }else if(state.meetingCodeController!.text.length != 8){
ToastUtils.showError("请输入正确的会议号"); ToastUtils.showError("请输入正确的会议号");
}else if(state.nickNameCodeController.text.isEmpty){ }else if(state.nickNameCodeController!.text.isEmpty){
ToastUtils.showError("请输入昵称"); ToastUtils.showError("请输入昵称");
}else if(state.checkAgreementBool != true){ }else if(state.checkAgreementBool != true){
ToastUtils.showError("请阅读并勾选相关协议"); ToastUtils.showError("请阅读并勾选相关协议");
}else{ }else{
BaseStructureResult<UserInfoEntity> res = await getClient().anonLogin(await DeviceInfo.getDeviceId(),state.nickNameCodeController.text, state.meetingCodeController.text); BaseStructureResult<UserInfoEntity> res = await getClient().anonLogin(await DeviceInfo.getDeviceId(),state.nickNameCodeController!.text, state.meetingCodeController!.text);
if (null != res.data) { if (null != res.data) {
UserStore.to.setToken(res.data!.token); UserStore.to.setToken(res.data!.token);
UserStore.to.setRefreshToken(res.data!.refreshToken); UserStore.to.setRefreshToken(res.data!.refreshToken);
UserStore.to.setUserDetailInfo(res.data!); UserStore.to.setUserDetailInfo(res.data!);
UserStore.to.setLoginType(AppConfig.ANONYMOUS_LOGIN); UserStore.to.setLoginType(AppConfig.ANONYMOUS_LOGIN);
Get.toNamed(Routes.meetingMainPage, arguments: {"roomNumber": state.meetingCodeController.text}); Get.toNamed(Routes.meetingMainPage, arguments: {"roomNumber": state.meetingCodeController!.text});
state.userNameController.text = ""; state.userNameController!.text = "";
state.passwordController.text = ""; state.passwordController!.text = "";
state.meetingCodeController.text = ""; state.meetingCodeController!.text = "";
state.nickNameCodeController.text = ""; state.nickNameCodeController!.text = "";
state.checkAgreementBool.value = false; state.checkAgreementBool.value = false;
} }
} }
@ -102,16 +102,16 @@ class LoginLogic extends GetxController with RequestToolMixin {
/// 检验房间 /// 检验房间
Future<void> doHttpCheckMeetingRoom() async { Future<void> doHttpCheckMeetingRoom() async {
if(state.meetingCodeController.text.isEmpty){ if(state.meetingCodeController!.text.isEmpty){
ToastUtils.showError("请输入会议号"); ToastUtils.showError("请输入会议号");
}else if(state.meetingCodeController.text.length != 8){ }else if(state.meetingCodeController!.text.length != 8){
ToastUtils.showError("请输入正确的会议号"); ToastUtils.showError("请输入正确的会议号");
}else if(state.nickNameCodeController.text.isEmpty){ }else if(state.nickNameCodeController!.text.isEmpty){
ToastUtils.showError("请输入昵称"); ToastUtils.showError("请输入昵称");
}else if(state.checkAgreementBool != true){ }else if(state.checkAgreementBool != true){
ToastUtils.showError("请阅读并勾选相关协议"); ToastUtils.showError("请阅读并勾选相关协议");
}else{ }else{
BaseStructureResult<bool> res = await getClient().checkout(state.meetingCodeController.text); BaseStructureResult<bool> res = await getClient().checkout(state.meetingCodeController!.text);
if (null != res.data) { if (null != res.data) {
if(res.data == true){ if(res.data == true){
doHttpAnonymousLogin(); doHttpAnonymousLogin();

12
wgshare/lib/pages/loginPage/login_state.dart
View File

@ -3,12 +3,14 @@ import 'package:get/get.dart';
class LoginState { class LoginState {
LoginState() {} TextEditingController? userNameController;
TextEditingController? passwordController;
TextEditingController? meetingCodeController;
TextEditingController? nickNameCodeController;
LoginState() {
}
late TextEditingController userNameController = TextEditingController();
late TextEditingController passwordController = TextEditingController();
late TextEditingController meetingCodeController = TextEditingController();
late TextEditingController nickNameCodeController = TextEditingController();
/// 页面状态，0：账号，1：会议号 /// 页面状态，0：账号，1：会议号
late RxInt pageState = 0.obs; late RxInt pageState = 0.obs;

13
wgshare/lib/pages/loginPage/login_view.dart
View File

@ -23,6 +23,10 @@ class _LoginPageState extends State<LoginPage> {
@override @override
void initState() { void initState() {
Utils.hideKeyboard(); Utils.hideKeyboard();
state.userNameController = TextEditingController();
state.passwordController = TextEditingController();
state.meetingCodeController = TextEditingController();
state.nickNameCodeController = TextEditingController();
super.initState(); super.initState();
} }
@ -394,4 +398,13 @@ class _LoginPageState extends State<LoginPage> {
), ),
); );
} }
@override
void dispose() {
state.passwordController?.dispose();
state.userNameController?.dispose();
state.meetingCodeController?.dispose();
state.nickNameCodeController?.dispose();
super.dispose();
}
} }

313
wgshare/lib/pages/metting/meeting_main_logic.dart
View File

@ -64,9 +64,9 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
await getClient().getMeetingToken(state.roomNumber.value); await getClient().getMeetingToken(state.roomNumber.value);
state.meetingToken.value = res.data!; state.meetingToken.value = res.data!;
if (isInit == true) { if (isInit) {
signalRSocket(); signalRSocket();
}else{ } else {
initRtc(); initRtc();
} }
} }
@ -89,6 +89,7 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
getMeetingRoomAllUser(results[1].data as List<MeetingRoomUser>); getMeetingRoomAllUser(results[1].data as List<MeetingRoomUser>);
} finally { } finally {
ToastUtils.dismiss(); ToastUtils.dismiss();
ToastUtils.showSuccess("${state.isJoinSuccess}--${state.rctEngine.value}--${state.users.isNotEmpty}");
} }
} }
@ -162,15 +163,17 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
} }
/// 点击grid切换大屏 /// 点击grid切换大屏
void checkLargeScreen(String uid){ void checkLargeScreen(String uid) {
ToastUtils.showSuccess("切换用户成功"); ToastUtils.showSuccess("切换用户成功");
if(uid == UserStore.to.userInfoEntity.value!.uid) { if (uid == UserStore.to.userInfoEntity.value!.uid) {
state.remoteUid.value = "0"; state.remoteUid.value = "0";
}else{ state.remoteAssistantUid.value = "0";
if(state.isSpeak.value == true && state.isOpenCamera.value == true){ } else {
if (state.isSpeak.value == true && state.isOpenCamera.value == true) {
state.floating.value?.open(Get.context!); state.floating.value?.open(Get.context!);
} }
state.remoteUid.value = uid; state.remoteUid.value = uid;
state.remoteAssistantUid.value = uid;
} }
changePageState(0); changePageState(0);
Future.delayed(const Duration(milliseconds: 200), () { Future.delayed(const Duration(milliseconds: 200), () {
@ -208,7 +211,7 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
/// ------------------------------------------------------------------------------麦克风相关（操作） /// ------------------------------------------------------------------------------麦克风相关（操作）
/// 用户开闭麦 /// 用户开闭麦
Future<void> doHttpSetMicr(bool isOpenMicrophone) async { Future<void> doHttpSetMicr(bool isOpenMicrophone) async {
if(isOpenMicrophone == false){ if (isOpenMicrophone == false) {
state.spokesman.value = ""; state.spokesman.value = "";
state.spokesmanVolume.value = 0; state.spokesmanVolume.value = 0;
} }
@ -257,9 +260,9 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
isOtherOpenCamera = true; isOtherOpenCamera = true;
} }
} }
if(isOtherOpenCamera == false){ if (isOtherOpenCamera == false) {
changePageState(0); changePageState(0);
}else{ } else {
state.remoteUid.value = ""; state.remoteUid.value = "";
changePageState(1); changePageState(1);
} }
@ -270,7 +273,8 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
// 判断当前会议室是否存在全员观看主播 // 判断当前会议室是否存在全员观看主播
var isCurrentUserIsCamera = false; var isCurrentUserIsCamera = false;
for (var i = 0; i < state.cacheUsers.value.length; i++) { for (var i = 0; i < state.cacheUsers.value.length; i++) {
if (state.remoteUid.value == state.cacheUsers.value[i].uid && state.cacheUsers.value[i].enableCamera == true) { if (state.remoteUid.value == state.cacheUsers.value[i].uid &&
state.cacheUsers.value[i].enableCamera == true) {
isCurrentUserIsCamera = true; isCurrentUserIsCamera = true;
} }
} }
@ -398,11 +402,21 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
debugPrint("wgs输出===：SignalR Socket-重连失败$error"); debugPrint("wgs输出===：SignalR Socket-重连失败$error");
ToastUtils.dismiss(); ToastUtils.dismiss();
if ((state.isNormaExit.value == false && state.isShowOkAlertDialog.value == false) || null == UserStore.to.userInfoEntity.value) { debugPrint(
"wgs输出===：SignalR Socket-重连打印1${state.isNormaExit.value == false && state.isShowOkAlertDialog.value == false}");
debugPrint("wgs输出===：SignalR Socket-重连打印2${null != UserStore.to.token}");
debugPrint(
"wgs输出===：SignalR Socket-重连打印3${UserStore.to.token!.isNotEmpty}");
debugPrint(
"wgs输出===：SignalR Socket-重连打印4${(state.isNormaExit.value == false && state.isShowOkAlertDialog.value == false) || null != UserStore.to.token || UserStore.to.token!.isNotEmpty}");
if ((state.isNormaExit.value == false &&
state.isShowOkAlertDialog.value == false) ||
(state.isNormaExit.value == false && null != UserStore.to.token)) {
showOkAlertDialog( showOkAlertDialog(
context: Get.context!, context: Get.context!,
title: "提示", title: "提示",
message: "网络错误，请重新加入会议室", message: "网络错误，请重新加入会议室1",
okLabel: "确定", okLabel: "确定",
barrierDismissible: false, barrierDismissible: false,
).then((OkCancelResult value) { ).then((OkCancelResult value) {
@ -426,7 +440,7 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
for (MeetingRoomUser mru in state.cacheUsers.value) { for (MeetingRoomUser mru in state.cacheUsers.value) {
if (mru.uid == meetingRoomUser.uid) { if (mru.uid == meetingRoomUser.uid) {
mru.roleId = meetingRoomUser.roleId; mru.roleId = meetingRoomUser.roleId;
if(state.defaulOpenState.value == 1){ if (state.defaulOpenState.value == 1) {
mru.enableMicr = true; mru.enableMicr = true;
} }
mru.isRoomManager = meetingRoomUser.isRoomManager; mru.isRoomManager = meetingRoomUser.isRoomManager;
@ -571,7 +585,7 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
} }
state.users.value = state.cacheUsers.value; state.users.value = state.cacheUsers.value;
update(); update();
if(listDynamic[0] != UserStore.to.userInfoEntity.value!.uid){ if (listDynamic[0] != UserStore.to.userInfoEntity.value!.uid) {
doHttpGetTvAnchor(); doHttpGetTvAnchor();
} }
debugPrint("wgs输出===：Socket-远端用户或主播离开会议室：$jsonStr"); debugPrint("wgs输出===：Socket-远端用户或主播离开会议室：$jsonStr");
@ -648,8 +662,9 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
if (mru.uid == meetingRoomUser.uid) { if (mru.uid == meetingRoomUser.uid) {
mru.enableCamera = true; mru.enableCamera = true;
} }
debugPrint("wgs输出===：Socket-用户单独开摄像头---${state.remoteUid.value}--${meetingRoomUser.uid}"); debugPrint(
if(state.remoteUid.value == meetingRoomUser.uid){ "wgs输出===：Socket-用户单独开摄像头---${state.remoteUid.value}--${meetingRoomUser.uid}");
if (state.remoteUid.value == meetingRoomUser.uid) {
doHttpGetTvAnchor(); doHttpGetTvAnchor();
} }
} }
@ -687,14 +702,15 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
muteLocalVideoStream(true); muteLocalVideoStream(true);
// 停止本地预览 // 停止本地预览
stopPreview(); stopPreview();
// 当前全员观看主播是自己时
if (state.remoteUid.value == "0") {
state.remoteUid.value = "";
}
// 关闭本地预览悬浮窗 // 关闭本地预览悬浮窗
if (state.floating.value?.isShowing == true) { if (state.floating.value?.isShowing == true) {
state.floating.value?.close(); state.floating.value?.close();
} }
// 当前全员观看主播是自己时
if (state.remoteUid.value == "0") {
state.remoteUid.value = "";
doHttpGetTvAnchor();
}
} }
} }
update(); update();
@ -713,8 +729,12 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
/// 加入会议室 /// 加入会议室
/// isAgain：是否重新加入 /// isAgain：是否重新加入
Future<void> joinMeetingToSocket(bool isAgain) async { Future<void> joinMeetingToSocket(bool isAgain) async {
await state.hubConnection.value?.invoke("joinChannel", await state.hubConnection.value?.invoke("joinChannel", args: [
args: [state.roomNumber.value, state.isOpenMicrophone.value, state.isOpenCamera.value, state.isSpeak.value]); state.roomNumber.value,
state.isOpenMicrophone.value,
state.isOpenCamera.value,
state.isSpeak.value
]);
mergeFetch(isAgain); mergeFetch(isAgain);
/*if(isAgain == false){ /*if(isAgain == false){
mergeFetch(isAgain); mergeFetch(isAgain);
@ -765,7 +785,7 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
// 音频模块默认启动，所以这里不再调用启动方法 // 音频模块默认启动，所以这里不再调用启动方法
// 启用视频模块 // 启用视频模块
enableVideo(); await enableVideo();
// 设置默认音频路由为听筒 // 设置默认音频路由为听筒
await state.rctEngine.value?.setDefaultAudioRouteToSpeakerphone(false); await state.rctEngine.value?.setDefaultAudioRouteToSpeakerphone(false);
// 打开用户音量回调 // 打开用户音量回调
@ -775,61 +795,59 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
await state.rctEngine.value await state.rctEngine.value
?.setDualStreamMode(mode: SimulcastStreamMode.enableSimulcastStream); ?.setDualStreamMode(mode: SimulcastStreamMode.enableSimulcastStream);
joinMeetingToRtc();
// 回调 // 回调
state.rctEngine.value?.registerEventHandler( state.rctEngine.value?.registerEventHandler(
RtcEngineEventHandler( RtcEngineEventHandler(
// 成功加入会议室回调 // 成功加入会议室回调
onJoinChannelSuccess: (RtcConnection connection, int elapsed) { onJoinChannelSuccess: (RtcConnection connection, int elapsed) {
state.isJoinSuccess.value = true; state.isJoinSuccess.value = true;
debugPrint("wgs输出===：RTC-自己加入会议室，ID：${connection.localUid}"); debugPrint("wgs输出===：RTC-自己加入会议室，ID：${connection.localUid}");
}, },
// 成功离开会议室回调 // 成功离开会议室回调
onLeaveChannel: (RtcConnection connection, RtcStats stats) { onLeaveChannel: (RtcConnection connection, RtcStats stats) {
debugPrint("wgs输出===：RTC-自己离开会议室，ID：${connection.localUid}"); debugPrint("wgs输出===：RTC-自己离开会议室，ID：${connection.localUid}");
}, },
// 远端用户或主播加入当前会议室回调-主播角色才能接收该回调 // 远端用户或主播加入当前会议室回调-主播角色才能接收该回调
onUserJoined: (RtcConnection connection, int remoteUid, int elapsed) { onUserJoined: (RtcConnection connection, int remoteUid, int elapsed) {
debugPrint("wgs输出===：RTC-远端用户或主播加入会议室，用户或主机的ID：$remoteUid"); debugPrint("wgs输出===：RTC-远端用户或主播加入会议室，用户或主机的ID：$remoteUid");
}, },
// 远端用户或主播离开当前会议室回调-主播角色才能接收该回调 // 远端用户或主播离开当前会议室回调-主播角色才能接收该回调
onUserOffline: (RtcConnection connection, int remoteUid, onUserOffline: (RtcConnection connection, int remoteUid,
UserOfflineReasonType reason) async { UserOfflineReasonType reason) async {
// 判断是否用户取消了共享 // 判断是否用户取消了共享
if (remoteUid.toString().length == 9) { if (remoteUid.toString().length == 9) {
for (var i = 0; i < state.cacheUsers.value.length; i++) { for (var i = 0; i < state.cacheUsers.value.length; i++) {
if (remoteUid.toString() == if (remoteUid.toString() ==
state.cacheUsers.value[i].screenShareId) { state.cacheUsers.value[i].screenShareId) {
state.cacheUsers.value[i].enableShare = false; state.cacheUsers.value[i].enableShare = false;
}
}
} }
} update();
} debugPrint("wgs输出===：RTC-远端用户或主播离开会议室，用户或主机的ID：$remoteUid");
update(); },
debugPrint("wgs输出===：RTC-远端用户或主播离开会议室，用户或主机的ID：$remoteUid");
},
// 音频路由发生变化回调 // 音频路由发生变化回调
onAudioRoutingChanged: (int routing) { onAudioRoutingChanged: (int routing) {
debugPrint("wgs输出===：RTC-音频路由切换：$routing"); debugPrint("wgs输出===：RTC-音频路由切换：$routing");
state.communicationMode.value = routing; state.communicationMode.value = routing;
if (routing == 1) { if (routing == 1) {
debugPrint("wgs输出===：RTC-音频路由切换为听筒"); debugPrint("wgs输出===：RTC-音频路由切换为听筒");
} else if (routing == 3) { } else if (routing == 3) {
debugPrint("wgs输出===：RTC-音频路由切换为扬声器"); debugPrint("wgs输出===：RTC-音频路由切换为扬声器");
} else { } else {
debugPrint("wgs输出===：RTC-音频路由切换为外接设备"); debugPrint("wgs输出===：RTC-音频路由切换为外接设备");
} }
}, },
// 音频采集开关回调 // 音频采集开关回调
onLocalAudioStateChanged: (RtcConnection connection, onLocalAudioStateChanged: (RtcConnection connection,
LocalAudioStreamState state, LocalAudioStreamReason reason) { LocalAudioStreamState state, LocalAudioStreamReason reason) {
debugPrint("wgs输出===：RTC-音频采集开关：$state"); debugPrint("wgs输出===：RTC-音频采集开关：$state");
}, },
// 远端视频状态发生改变回调 // 远端视频状态发生改变回调
onRemoteVideoStateChanged: (RtcConnection connection, onRemoteVideoStateChanged: (RtcConnection connection,
@ -837,56 +855,55 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
RemoteVideoState remoteVideoState, RemoteVideoState remoteVideoState,
RemoteVideoStateReason remoteVideoStateReason, RemoteVideoStateReason remoteVideoStateReason,
int elapsed) { int elapsed) {
debugPrint( debugPrint(
"wgs输出===：RTC-远端视频状态发生改变：ID-$remoteUid-状态-$remoteVideoStateReason"); "wgs输出===：RTC-远端视频状态发生改变：ID-$remoteUid-状态-$remoteVideoStateReason");
if (remoteVideoStateReason == if (remoteVideoStateReason ==
RemoteVideoStateReason.remoteVideoStateReasonRemoteMuted) { RemoteVideoStateReason.remoteVideoStateReasonRemoteMuted) {
// 远端用户停止发送视频流或远端用户禁用视频模块 // 远端用户停止发送视频流或远端用户禁用视频模块
if (remoteUid.toString().length != 9) { if (remoteUid.toString().length != 9) {
// 摄像头 // 摄像头
if (remoteUid.toString() == state.remoteUid.value) { if (remoteUid.toString() == state.remoteUid.value) {
// 如果停止发送视频流或禁用视频模块的远端用户是当前全员观看主播 // 如果停止发送视频流或禁用视频模块的远端用户是当前全员观看主播
doHttpGetTvAnchor(); doHttpGetTvAnchor();
}
} else {
// 共享屏幕（此版本不做）
}
} }
} else { },
// 共享屏幕（此版本不做）
}
}
},
// 用户音量提示回调 // 用户音量提示回调
onAudioVolumeIndication: (RtcConnection connection, onAudioVolumeIndication: (RtcConnection connection,
List<AudioVolumeInfo> speakers, List<AudioVolumeInfo> speakers,
int speakerNumber, int speakerNumber,
int totalVolume) { int totalVolume) {
if (speakers.isNotEmpty) { if (speakers.isNotEmpty) {
for (AudioVolumeInfo avi in speakers) {
for (AudioVolumeInfo avi in speakers) { if (avi.uid == 0) {
if(avi.uid == 0){ // debugPrint("wgs输出===：RTC-本地用户音量提示：${avi.uid}--${avi.volume}");
debugPrint("wgs输出===：RTC-本地用户音量提示：${avi.uid}--${avi.volume}"); for (MeetingRoomUser mru in state.cacheUsers.value) {
for(MeetingRoomUser mru in state.cacheUsers.value){ if (UserStore.to.userInfoEntity.value!.uid == mru.uid) {
if(UserStore.to.userInfoEntity.value!.uid == mru.uid){ mru.volume = CountMicrophoneVolume.getVolume(avi.volume!);
mru.volume = CountMicrophoneVolume.getVolume(avi.volume!); state.microphoneVolume.value =
state.microphoneVolume.value = CountMicrophoneVolume.getVolume(avi.volume!);
CountMicrophoneVolume.getVolume(avi.volume!); }
} }
}
}else{
debugPrint("wgs输出===：RTC-远端用户音量提示：${avi.uid}--${avi.volume}");
for(MeetingRoomUser mru in state.cacheUsers.value){
mru.volume = CountMicrophoneVolume.getVolume(avi.volume!);
if (avi.volume != 0) {
state.spokesman.value = mru.userName;
state.spokesmanVolume.value =
CountMicrophoneVolume.getVolume(avi.volume!);
} else { } else {
state.spokesman.value = ""; // debugPrint("wgs输出===：RTC-远端用户音量提示：${avi.uid}--${avi.volume}");
state.spokesmanVolume.value = 0; for (MeetingRoomUser mru in state.cacheUsers.value) {
mru.volume = CountMicrophoneVolume.getVolume(avi.volume!);
if (avi.volume != 0) {
state.spokesman.value = mru.userName;
state.spokesmanVolume.value =
CountMicrophoneVolume.getVolume(avi.volume!);
} else {
state.spokesman.value = "";
state.spokesmanVolume.value = 0;
}
}
} }
} /*for (MeetingRoomUser mru in state.cacheUsers.value) {
}
/*for (MeetingRoomUser mru in state.cacheUsers.value) {
// 用于更改语音布局里的用户列表麦克风 // 用于更改语音布局里的用户列表麦克风
if (avi.uid == 0) { if (avi.uid == 0) {
// debugPrint("wgs输出===：RTC-用户音量提示（自己）：${CountMicrophoneVolume.getVolume(avi.volume!)}"); // debugPrint("wgs输出===：RTC-用户音量提示（自己）：${CountMicrophoneVolume.getVolume(avi.volume!)}");
@ -910,70 +927,87 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
} }
} }
}*/ }*/
} }
} }
}, },
// 切换用户角色回调 // 切换用户角色回调
onClientRoleChanged: (RtcConnection connection, onClientRoleChanged: (RtcConnection connection,
ClientRoleType oldRole, ClientRoleType oldRole,
ClientRoleType newRole, ClientRoleType newRole,
ClientRoleOptions newRoleOptions) { ClientRoleOptions newRoleOptions) {
debugPrint( debugPrint(
"wgs输出===：RTC-切换用户角色为：${newRole == ClientRoleType.clientRoleBroadcaster ? "主播" : "观众"}"); "wgs输出===：RTC-切换用户角色为：${newRole == ClientRoleType.clientRoleBroadcaster ? "主播" : "观众"}");
}, },
// token即将在30秒内过期回调 // token即将在30秒内过期回调
onTokenPrivilegeWillExpire: (RtcConnection connection, String token) { onTokenPrivilegeWillExpire: (RtcConnection connection, String token) {
doHttpGetMeetingToken(false); doHttpGetMeetingToken(false);
}, },
// 本地视频状态发生改变回调 // 本地视频状态发生改变回调
onLocalVideoStateChanged: (VideoSourceType source, onLocalVideoStateChanged: (VideoSourceType source,
LocalVideoStreamState state, LocalVideoStreamReason reason) { LocalVideoStreamState state, LocalVideoStreamReason reason) {
debugPrint("wgs输出===：RTC-本地视频状态发生改变：$source--$state--$reason"); debugPrint("wgs输出===：RTC-本地视频状态发生改变：$source--$state--$reason");
}, },
// 网络连接状态回调 // 网络连接状态回调
onConnectionStateChanged: (RtcConnection connection, onConnectionStateChanged: (RtcConnection connection,
ConnectionStateType stateType, ConnectionStateType stateType,
ConnectionChangedReasonType reason) { ConnectionChangedReasonType reason) {
debugPrint("wgs输出===：RTC-网络连接状态发生改变：" debugPrint("wgs输出===：RTC-网络连接状态发生改变："
"会议室编号（${connection.channelId}），" "会议室编号（${connection.channelId}），"
"网络状态（$stateType-${AgoraUtil.getConnectionStateChangedType(stateType)}），" "网络状态（$stateType-${AgoraUtil.getConnectionStateChangedType(stateType)}），"
"网络改变原因（$reason-${AgoraUtil.getConnectionChangedReasonType(reason)}）"); "网络改变原因（$reason-${AgoraUtil.getConnectionChangedReasonType(reason)}）");
if (stateType == ConnectionStateType.connectionStateReconnecting) { if (stateType == ConnectionStateType.connectionStateReconnecting) {
if (EasyLoading.isShow == false) { if (EasyLoading.isShow == false) {
ToastUtils.showLoadingToMask( ToastUtils.showLoadingToMask(
"网络故障，正在重连...", EasyLoadingMaskType.black); "网络故障，正在重连...", EasyLoadingMaskType.black);
} }
} else if (stateType == ConnectionStateType.connectionStateConnected && } else if (stateType ==
reason == ConnectionStateType.connectionStateConnected &&
ConnectionChangedReasonType.connectionChangedRejoinSuccess) { reason ==
ToastUtils.dismiss(); ConnectionChangedReasonType
if (EasyLoading.isShow == false) { .connectionChangedRejoinSuccess) {
ToastUtils.showSuccessToMask("重连成功！", EasyLoadingMaskType.black); ToastUtils.dismiss();
} if (EasyLoading.isShow == false) {
} else if (reason == ToastUtils.showSuccessToMask(
ConnectionChangedReasonType.connectionChangedLost) { "重连成功！", EasyLoadingMaskType.black);
// 和服务器失去连接后，再延迟15秒（和signalR Socket一致），让SDK继续重连，如果重连不上则告知用户需要重新加入 }
Future.delayed(const Duration(milliseconds: 15000), () { } else if (reason ==
ToastUtils.dismiss(); ConnectionChangedReasonType.connectionChangedLost) {
if (state.isShowOkAlertDialog.value == false) { // 和服务器失去连接后，再延迟15秒（和signalR Socket一致），让SDK继续重连，如果重连不上则告知用户需要重新加入
showOkAlertDialog( Future.delayed(const Duration(milliseconds: 15000), () {
context: Get.context!, ToastUtils.dismiss();
title: "提示", if (state.isShowOkAlertDialog.value == false) {
message: "网络错误，请重新加入会议室", showOkAlertDialog(
okLabel: "确定", context: Get.context!,
barrierDismissible: false, title: "提示",
).then((OkCancelResult value) { message: "网络错误，请重新加入会议室",
Get.back(); okLabel: "确定",
Get.back(); barrierDismissible: false,
).then((OkCancelResult value) {
Get.back();
Get.back();
});
}
}); });
} }
}); },
}
} // 渲染器已接收首帧远端视频回调
onFirstRemoteVideoFrame: (RtcConnection connection, int remoteUid,
int width, int height, int elapsed) async {
debugPrint("wgs输出===：RTC-渲染器已接收首帧远端视频回调：${remoteUid}--${width}--${height}--${elapsed}");
},
// 已接收到远端视频并完成解码回调
onFirstRemoteVideoDecoded: (RtcConnection connection, int remoteUid,
int width, int height, int elapsed) {
debugPrint("wgs输出===：RTC-已接收到远端视频并完成解码回调：${remoteUid}--${width}--${height}--${elapsed}");
}
// 获取设备权限出错回调 // 获取设备权限出错回调
/*onPermissionError: (PermissionType permissionType){ /*onPermissionError: (PermissionType permissionType){
@ -986,6 +1020,7 @@ class MeetingMainLogic extends GetxController with RequestToolMixin {
}*/ }*/
), ),
); );
await joinMeetingToRtc();
} }
/// 加入会议室 /// 加入会议室

2
wgshare/lib/pages/metting/meeting_main_state.dart
View File

@ -101,7 +101,7 @@ class MeetingMainState {
/// 声网相关 /// 声网相关
final String appId = "4a4f7be64fa1404ebda74784fe9ac381"; final String appId = "4a4f7be64fa1404ebda74784fe9ac381";
late Rx<RtcEngineEx?> rctEngine = Rx(null); Rx<RtcEngineEx?> rctEngine = Rx<RtcEngineEx?>(null);
/// 是否自动订阅所有视频流 /// 是否自动订阅所有视频流
late RxBool isAutoSubscribeVideo = false.obs; late RxBool isAutoSubscribeVideo = false.obs;
/// 是否自动订阅所有音频流 /// 是否自动订阅所有音频流

5
wgshare/lib/pages/metting/meeting_main_view.dart
View File

@ -222,8 +222,7 @@ class MeetingMainPageState extends State<MeetingMainPage> {
visible: state.pageState.value == 1, visible: state.pageState.value == 1,
child: state.isJoinSuccess.value == true && child: state.isJoinSuccess.value == true &&
null != state.rctEngine.value && null != state.rctEngine.value &&
null != state.users.value && state.users.isNotEmpty
state.users.value.isNotEmpty
? Stack( ? Stack(
alignment: Alignment.center, alignment: Alignment.center,
children: [ children: [
@ -305,7 +304,7 @@ class MeetingMainPageState extends State<MeetingMainPage> {
], ],
) )
: Container( : Container(
color: ColorUtil.Color_57_57_57, color: Colors.red,
/*child: Text('加载反馈：是否成功加入会议室${state.isJoinSuccess.value}-会议室对象${state.rctEngine.value}-成员列表${state.users.value.length}-全员观看ID${state.remoteUid.value}'),*/ /*child: Text('加载反馈：是否成功加入会议室${state.isJoinSuccess.value}-会议室对象${state.rctEngine.value}-成员列表${state.users.value.length}-全员观看ID${state.remoteUid.value}'),*/
)), )),