You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

581 lines
20 KiB

import 'dart:convert';
import 'dart:io';
import 'dart:math';
import 'dart:ui';
import 'package:flutter/material.dart';
import 'package:oktoast/oktoast.dart';
import 'package:recook/constants/api.dart';
import 'package:recook/constants/header.dart';
import 'package:recook/manager/http_manager.dart';
import 'package:recook/manager/user_manager.dart';
import 'package:recook/pages/live/live_stream/live_blur_page.dart';
import 'package:recook/pages/live/live_stream/live_pick_goods_page.dart';
import 'package:recook/pages/live/live_stream/pick_view/pick_cart.dart';
import 'package:recook/pages/live/live_stream/show_goods_list.dart';
import 'package:recook/pages/live/models/live_exit_model.dart';
import 'package:recook/pages/live/models/live_stream_info_model.dart';
import 'package:recook/pages/live/models/topic_list_model.dart';
import 'package:recook/pages/live/tencent_im/tencent_im_tool.dart';
import 'package:recook/pages/live/video/pick_topic_page.dart';
import 'package:recook/pages/live/widget/live_user_bar.dart';
import 'package:recook/utils/custom_route.dart';
import 'package:recook/widgets/bottom_sheet/action_sheet.dart';
import 'package:recook/widgets/custom_image_button.dart';
import 'package:tencent_im_plugin/entity/message_entity.dart';
import 'package:tencent_im_plugin/entity/session_entity.dart';
import 'package:tencent_im_plugin/message_node/group_system_message_node.dart';
import 'package:tencent_im_plugin/tencent_im_plugin.dart';
import 'package:tencent_live_fluttify/tencent_live_fluttify.dart';
import 'package:image_picker/image_picker.dart';
import 'package:wakelock/wakelock.dart';
class LivePage extends StatefulWidget {
LivePage({Key key}) : super(key: key);
@override
_LivePageState createState() => _LivePageState();
}
class _LivePageState extends State<LivePage> {
LivePusher _livePusher;
File _imageFile;
TopicListModel _topicModel;
TextEditingController _editingController = TextEditingController();
List<int> pickedIds = [];
int liveItemId = 0;
bool _isStream = false;
LiveStreamInfoModel _streamInfoModel;
TencentGroupTool group;
List<MessageEntity> chatObjects = [];
ScrollController _scrollController = ScrollController();
int nowExplain = 0;
@override
void initState() {
super.initState();
Wakelock.enable();
_editingController.text = '${UserManager.instance.user.info.nickname}正在直播';
}
@override
void dispose() {
PickCart.picked.clear();
Wakelock.disable();
_livePusher?.stopPush();
_livePusher?.stopPreview();
_editingController?.dispose();
TencentImPlugin.quitGroup(groupId: _streamInfoModel.groupId);
TencentImPlugin.removeListener(parseMessage);
TencentImPlugin.logout();
if (_isStream)
HttpManager.post(LiveAPI.exitLive, {
'liveItemId': liveItemId,
});
super.dispose();
}
@override
Widget build(BuildContext context) {
return Scaffold(
backgroundColor: Colors.grey,
body: Stack(
children: [
Positioned(
top: 0,
left: 0,
right: 0,
bottom: 0,
child: CloudVideo(
onCloudVideoCreated: (controller) async {
_livePusher = await LivePusher.create();
_livePusher.startPreview(controller);
},
),
),
AnimatedPositioned(
duration: Duration(milliseconds: 200),
right: 0,
left: 0,
bottom: _isStream ? -200 : rSize(30),
child: Column(
mainAxisSize: MainAxisSize.min,
children: [
Row(
children: [
rWBox(72),
MaterialButton(
height: rSize(68),
minWidth: rSize(68),
elevation: 0,
padding: EdgeInsets.zero,
child: _imageFile == null
? Icon(Icons.camera_alt)
: Image.file(
_imageFile,
height: rSize(68),
width: rSize(68),
fit: BoxFit.cover,
),
color: Colors.black.withOpacity(0.25),
onPressed: () {
ActionSheet.show(
context,
items: ['相机', '相册'],
listener: (index) {
Future<PickedFile> getImage() {
if (index == 0)
return ImagePicker()
.getImage(source: ImageSource.camera);
if (index == 1)
return ImagePicker()
.getImage(source: ImageSource.gallery);
return null;
}
getImage().then((pickedFile) {
if (pickedFile != null)
_imageFile = File(pickedFile.path);
setState(() {});
});
},
);
},
),
rWBox(15),
Expanded(
child: Column(
crossAxisAlignment: CrossAxisAlignment.start,
children: [
TextField(
controller: _editingController,
decoration: InputDecoration(
border: InputBorder.none,
),
),
rHBox(8),
GestureDetector(
child: Text(
_topicModel == null
? '选择话题 >'
: '#${_topicModel.title}',
style: TextStyle(
color: Colors.white.withOpacity(0.8),
fontSize: rSP(14),
),
),
onTap: () {
CRoute.push(
context,
PickTopicPage(onPick: (model) {
_topicModel = model;
}),
).then((value) {
setState(() {});
});
},
),
],
),
),
rWBox(72),
],
),
rHBox(28),
MaterialButton(
minWidth: rSize(205),
height: rSize(40),
onPressed: () {
upload(String path) {
GSDialog.of(context)
.showLoadingDialog(context, '准备开始直播中');
HttpManager.post(LiveAPI.startLive, {
'title': _editingController.text,
'cover': path,
'topic': _topicModel == null ? 0 : _topicModel.id,
'goodsIds': pickedIds ?? [],
}).then((resultData) {
GSDialog.of(context).dismiss(context);
liveItemId = resultData.data['data']['liveItemId'];
_livePusher
.startPush(resultData.data['data']['pushUrl']);
_isStream = true;
setState(() {});
TencentIMTool.login().then((_) {
DPrint.printLongJson('用户登陆');
getLiveStreamModel(liveItemId).then((model) {
if (model == null)
Navigator.pop(context);
else {
setState(() {
_streamInfoModel = model;
});
TencentImPlugin.applyJoinGroup(
groupId: model.groupId, reason: 'enterLive');
TencentImPlugin.addListener(parseMessage);
group = TencentGroupTool.fromId(model.groupId);
}
});
});
}).catchError((e) {
GSDialog.of(context).dismiss(context);
});
}
if (pickedIds.isEmpty) {
showToast('必须选择一个商品');
} else {
if (_imageFile != null) {
GSDialog.of(context)
.showLoadingDialog(context, '上传图片中');
HttpManager.uploadFile(
url: CommonApi.upload,
file: _imageFile,
key: "photo",
).then((result) {
GSDialog.of(context).dismiss(context);
upload(result.url);
});
} else {
upload(UserManager.instance.user.info.headImgUrl);
}
}
},
child: Text(
'开始直播',
style: TextStyle(
color: Colors.white,
fontSize: rSP(18),
),
),
color: Color(0xFFDB2D2D),
shape: RoundedRectangleBorder(
borderRadius: BorderRadius.circular(rSize(20)),
),
),
],
),
),
AnimatedPositioned(
bottom: _isStream ? 0 : -300,
left: 0,
right: 0,
child: Row(
crossAxisAlignment: CrossAxisAlignment.end,
children: [
Expanded(
child: Container(
height: 300,
child: ListView.builder(
reverse: true,
controller: _scrollController,
physics: AlwaysScrollableScrollPhysics(
parent: BouncingScrollPhysics()),
itemBuilder: (context, index) {
return _buildChatBox(
chatObjects[index].sender, chatObjects[index].note);
},
itemCount: chatObjects.length,
),
),
),
CustomImageButton(
child: Container(
alignment: Alignment.bottomCenter,
width: rSize(44),
height: rSize(44),
child: Text(
_streamInfoModel == null
? ''
: _streamInfoModel.goodsLists.length.toString(),
style: TextStyle(
color: Colors.white,
fontSize: rSP(13),
height: 28 / 13,
),
),
decoration: BoxDecoration(
image: DecorationImage(
image: AssetImage(R.ASSETS_LIVE_LIVE_GOOD_PNG),
),
),
),
onPressed: () {
showGoodsListDialog(
context,
models: _streamInfoModel.goodsLists,
onExplain: (index) {
setState(() {
nowExplain = index;
});
},
initExplain: nowExplain,
id: _streamInfoModel.id,
isLive: true,
);
},
),
],
),
duration: Duration(milliseconds: 250),
),
AnimatedPositioned(
duration: Duration(milliseconds: 250),
right: _isStream ? -100 : 0,
top: MediaQuery.of(context).viewPadding.top + rSize(15),
child: Column(
mainAxisSize: MainAxisSize.min,
crossAxisAlignment: CrossAxisAlignment.center,
children: [
_buildVerticalButton(R.ASSETS_LIVE_FLIP_CAM_PNG, '翻转', () {
_livePusher.switchCamera();
}),
_buildVerticalButton(R.ASSETS_LIVE_WHITE_CART_PNG, '商品', () {
CRoute.push(context, LivePickGoodsPage(
onPickGoods: (ids) {
pickedIds = ids;
},
));
}),
],
),
),
AnimatedPositioned(
duration: Duration(milliseconds: 250),
right: rSize(15),
left: rSize(15),
top: _isStream
? (MediaQuery.of(context).viewPadding.top + rSize(15))
: -100,
child: Row(
children: [
LiveUserBar(
initAttention: true,
onAttention: () {},
title: UserManager.instance.user.info.nickname,
avatar:
Api.getImgUrl(UserManager.instance.user.info.headImgUrl),
),
Spacer(),
CustomImageButton(
onPressed: () {
_livePusher?.stopPush();
TencentImPlugin.quitGroup(
groupId: _streamInfoModel.groupId);
TencentImPlugin.removeListener(parseMessage);
TencentImPlugin.logout();
if (_isStream)
HttpManager.post(LiveAPI.exitLive, {
'liveItemId': liveItemId,
}).then((resultData) {
if (resultData?.data['data'] == null)
Navigator.pop(context);
else {
CRoute.transparent(
context,
LiveBlurPage(
context: context,
isLive: true,
exitModel: LiveExitModel.fromJson(
resultData.data['data']),
));
}
});
},
child: Image.asset(
R.ASSETS_LIVE_SHUTDOWN_PNG,
height: rSize(21),
width: rSize(21),
),
),
],
),
),
],
),
);
}
Future<LiveStreamInfoModel> getLiveStreamModel(int id) async {
ResultData resultData = await HttpManager.post(
LiveAPI.liveStreamInfo,
{'id': id},
);
if (resultData?.data['data'] == null)
return null;
else
return LiveStreamInfoModel.fromJson(resultData.data['data']);
}
_buildChatBox(String sender, String note) {
final Color color = Color.fromRGBO(
180 + Random().nextInt(55),
180 + Random().nextInt(55),
180 + Random().nextInt(55),
1,
);
return Align(
alignment: Alignment.centerLeft,
child: ClipRRect(
child: BackdropFilter(
filter: ImageFilter.blur(sigmaX: 5, sigmaY: 5),
child: Container(
child: Text.rich(
TextSpan(children: [
TextSpan(
text: '$sender:',
style: TextStyle(
color: color,
fontSize: rSP(13),
),
),
TextSpan(
text: note,
style: TextStyle(
color: Colors.white,
fontSize: rSP(13),
),
),
]),
maxLines: 5,
),
margin: EdgeInsets.symmetric(vertical: rSize(5 / 2)),
padding: EdgeInsets.symmetric(
horizontal: rSize(10),
vertical: rSize(4),
),
constraints: BoxConstraints(
maxWidth: rSize(200),
),
decoration: BoxDecoration(
color: Colors.black.withOpacity(0.1),
borderRadius: BorderRadius.circular(rSize(16)),
),
),
),
),
);
}
parseMessage(ListenerTypeEnum type, params) {
print('ListenerTypeEnum$type');
print(params);
switch (type) {
case ListenerTypeEnum.ForceOffline:
break;
case ListenerTypeEnum.UserSigExpired:
break;
case ListenerTypeEnum.Connected:
break;
case ListenerTypeEnum.Disconnected:
break;
case ListenerTypeEnum.WifiNeedAuth:
break;
case ListenerTypeEnum.Refresh:
break;
case ListenerTypeEnum.RefreshConversation:
break;
case ListenerTypeEnum.MessageRevoked:
break;
case ListenerTypeEnum.NewMessages:
if (params is List<MessageEntity>) {
List<MessageEntity> messageEntities = params;
if (messageEntities[0].sessionType == SessionType.System) {
if (messageEntities[0].elemList[0] is GroupSystemMessageNode) {
String userData =
(messageEntities[0].elemList[0] as GroupSystemMessageNode)
.userData;
Map<String, dynamic> customParams = jsonDecode(userData);
print(customParams);
switch (customParams['type']) {
case 'UnExplain':
break;
case 'Explain':
break;
case 'LiveStop':
}
}
} else {
chatObjects.insertAll(0, messageEntities);
_scrollController.animateTo(
-50,
duration: Duration(milliseconds: 300),
curve: Curves.easeInOutCubic,
);
setState(() {});
}
}
break;
case ListenerTypeEnum.GroupTips:
if (params is String) {
dynamic parseParams = jsonDecode(params);
if (parseParams['tipsType'] == 'Join') {
showToastWidget(
Container(
margin: EdgeInsets.all(rSize(15)),
alignment: Alignment.center,
padding: EdgeInsets.symmetric(horizontal: rSize(10)),
height: rSize(26),
decoration: BoxDecoration(
color: Color(0xFFDC5353),
borderRadius: BorderRadius.circular(rSize(13)),
),
child: Text(
'${parseParams['opUser']}来了',
style: TextStyle(
color: Colors.white,
fontSize: rSP(13),
),
),
),
position: ToastPosition.top,
);
} else if (parseParams['tipsType'] == 'Quit') {
//exit
}
}
break;
case ListenerTypeEnum.RecvReceipt:
break;
case ListenerTypeEnum.ReConnFailed:
break;
case ListenerTypeEnum.ConnFailed:
break;
case ListenerTypeEnum.Connecting:
break;
case ListenerTypeEnum.UploadProgress:
break;
case ListenerTypeEnum.DownloadProgress:
break;
}
}
_buildVerticalButton(String img, String title, VoidCallback onTap) {
return CustomImageButton(
padding: EdgeInsets.symmetric(
horizontal: rSize(15),
vertical: rSize(12),
),
onPressed: onTap,
child: Column(
mainAxisSize: MainAxisSize.min,
children: [
Image.asset(
img,
height: rSize(24),
width: rSize(24),
),
Text(
title,
style: TextStyle(
color: Colors.white,
fontSize: rSP(11),
),
),
],
),
);
}
}