reading_bloc.dart
5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
import 'package:audioplayers/audioplayers.dart';
import 'package:flutter/cupertino.dart';
import 'package:flutter/foundation.dart';
import 'package:flutter/services.dart';
import 'package:flutter_bloc/flutter_bloc.dart';
import 'package:flutter_easyloading/flutter_easyloading.dart';
import 'package:wow_english/pages/reading/widgets/ReadingModeType.dart';
import '../../../common/request/dao/listen_dao.dart';
import '../../../common/request/exception.dart';
import '../../../models/course_process_entity.dart';
import '../../../utils/loading.dart';
part 'reading_event.dart';
part 'reading_state.dart';
class ReadingPageBloc extends Bloc<ReadingPageEvent, ReadingPageState> {
final PageController pageController;
///当前页索引
int _currentPage = 0;
///当前播放模式
ReadingModeType _currentMode = ReadingModeType.auto;
int get currentPage => _currentPage + 1;
ReadingModeType get currentMode => _currentMode;
CourseProcessEntity? _entity;
CourseProcessEntity? get entity => _entity;
///正在评测
bool _isRecording = false;
bool get isRecording => _isRecording;
late MethodChannel methodChannel;
late AudioPlayer audioPlayer;
ReadingPageBloc(this.pageController) : super(ReadingPageInitial()) {
on<CurrentPageIndexChangeEvent>(_pageControllerChange);
on<CurrentModeChangeEvent>(_selectItemLoad);
// pageController.addListener(() {
// _currentPage = pageController.page!.round();
// });
on<RequestDataEvent>(_requestData);
on<ReadingPageEvent>((event, emit) {
//音频播放器
audioPlayer = AudioPlayer();
audioPlayer.onPlayerStateChanged.listen((event) {
if (event == PlayerState.completed) {
if (kDebugMode) {
print('绘本播放完成');
}
}
});
methodChannel = const MethodChannel('sing_sound_method_channel');
methodChannel.invokeMethod('initVoiceSdk',{});
methodChannel.setMethodCallHandler((call) async {
if (call.method == 'voiceResult') {//评测结束
// add(XSVoiceResultEvent(call.arguments));
}
});
});
on<PlayOriginalAudioEvent>(_playOriginalAudio);
on<XSVoiceTestEvent>(_voiceXsTest);
on<XSVoiceResultEvent>(_voiceXsResult);
}
@override
Future<void> close() {
pageController.dispose();
audioPlayer.release();
audioPlayer.dispose();
return super.close();
}
void _pageControllerChange(CurrentPageIndexChangeEvent event,
Emitter<ReadingPageState> emitter) async {
_currentPage = event.pageIndex;
_playOriginVoice(null);
emitter(CurrentPageIndexState());
}
void _selectItemLoad(
CurrentModeChangeEvent event, Emitter<ReadingPageState> emitter) async {
if (_currentMode == ReadingModeType.auto) {
_currentMode = ReadingModeType.manual;
} else {
_currentMode = ReadingModeType.auto;
}
emitter(CurrentModeState());
}
///请求数据
void _requestData(
RequestDataEvent event, Emitter<ReadingPageState> emitter) async {
try {
await loading(() async {
_entity = await ListenDao.process('1');
print("reading page entity: ${_entity!.toJson()}");
emitter(RequestDataState());
});
} catch (e) {
if (e is ApiException) {
EasyLoading.showToast(e.message ?? '请求失败,请检查网络连接');
}
}
}
void _playOriginalAudio(PlayOriginalAudioEvent event, Emitter<ReadingPageState> emitter) async {
print("_playOriginalAudio");
_playOriginVoice(event.url);
}
/// 播放绘本原音
void _playOriginVoice(String? audioUrl) async {
audioPlayer.stop();
final readingData = currentPageData();
if (readingData?.audioUrl != null) {
final urlStr = audioUrl ?? readingData?.audioUrl ?? '';
if (urlStr.isNotEmpty) {
audioPlayer.play(UrlSource(urlStr));
}
}
}
int dataCount() {
// print("dataCount=${_entity?.readings?.length ?? 0}");
return _entity?.readings?.length ?? 0;
}
CourseProcessReadings? currentPageData() {
return _entity?.readings?[_currentPage];
}
///先声测试
void _voiceXsTest(XSVoiceTestEvent event, Emitter<ReadingPageState> emitter) async {
startRecord(event.content);
emitter(XSVoiceTestState());
}
void startRecord(String content) async {
if (_isRecording == true) {
return;
}
EasyLoading.show(status: '录音中....');
methodChannel.invokeMethod(
'startVoice',
{'word':'how old are you','type':'0','userId':'1'}
);
_isRecording = true;
}
void _voiceXsResult(XSVoiceResultEvent event,Emitter<ReadingPageState> emitter) async {
final Map args = event.message as Map;
final result = args['result'] as String;
if (result == '1') {
final overall = args['overall'].toString();
EasyLoading.showToast('测评成功,分数是$overall',duration: const Duration(seconds: 10));
} else {
EasyLoading.showToast('测评失败',duration: const Duration(seconds: 10));
}
_isRecording = false;
emitter(XSVoiceTestState());
}
}