liangchengyou / wow_english

  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';

  import 'dart:convert';

  part 'reading_event.dart';
  part 'reading_state.dart';
  

  enum VoicePlayState {
    ///未知
    unKnow,
  
    ///播放中
    playing,
  
    ///播放完成
    completed,
  
    ///播放终止
    stop
  }
  

  class ReadingPageBloc extends Bloc<ReadingPageEvent, ReadingPageState> {

    final PageController pageController;
  

    final String courseLessonId;
  

    ///当前页索引
    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;
  

    ///原始音频是否正在播放
    bool _isOriginAudioPlaying = false;
  
    bool get isOriginAudioPlaying => _isOriginAudioPlaying;
  
    ///录音音频是否正在播放
    bool _isRecordAudioPlaying = false;
  
    bool get isRecordAudioPlaying => _isRecordAudioPlaying;
  
    ///正在播放音频状态
    VoicePlayState _voicePlayState = VoicePlayState.unKnow;
  
    VoicePlayState get voicePlayState => _voicePlayState;
  

    late MethodChannel methodChannel;
  
    late AudioPlayer audioPlayer;
  

    ReadingPageBloc(this.pageController, this.courseLessonId)
        : super(ReadingPageInitial()) {

      on<CurrentPageIndexChangeEvent>(_pageControllerChange);

      on<CurrentModeChangeEvent>(_playModeChange);

      // pageController.addListener(() {
      //   _currentPage = pageController.page!.round();
      // });

      on<RequestDataEvent>(_requestData);

      on<InitBlocEvent>((event, emit) {

        //音频播放器
        audioPlayer = AudioPlayer();

        audioPlayer.onPlayerStateChanged.listen((event) async {
          debugPrint('播放状态变化');

          if (event == PlayerState.completed) {

            debugPrint('播放完成');
            _voicePlayState = VoicePlayState.completed;
          }
          if (event == PlayerState.stopped) {
            debugPrint('播放结束');
            _voicePlayState = VoicePlayState.stop;
          }

          if (event == PlayerState.playing) {
            debugPrint('正在播放中');
            _voicePlayState = VoicePlayState.playing;
          }
          if (isClosed) {
            return;

          }

          add(VoicePlayStateChangeEvent());

        });
  

        methodChannel =
            const MethodChannel('wow_english/sing_sound_method_channel');
        methodChannel.invokeMethod('initVoiceSdk', {}); //初始化评测

        methodChannel.setMethodCallHandler((call) async {

          if (call.method == 'voiceResult') {
            //评测结果
            add(XSVoiceResultEvent(call.arguments));
            return;
          }
  
          if (call.method == 'voiceStart') {
            //评测开始
            if (kDebugMode) {
              print('评测开始');
            }
            return;
          }
  
          if (call.method == 'voiceEnd') {
            //评测结束
            if (kDebugMode) {
              print('评测结束');
            }
            return;
          }
  
          if (call.method == 'voiceFail') {
            //评测失败
            EasyLoading.showToast('评测失败');
            return;

          }
        });
      });

      on<VoicePlayStateChangeEvent>(_voicePlayStateChange);

      on<PlayOriginalAudioEvent>(_playOriginalAudio);

      on<XSVoiceInitEvent>(_initVoiceSdk);
      on<XSVoiceStartEvent>(_voiceXsStart);
      on<XSVoiceStopEvent>(_voiceXsStop);

      on<XSVoiceResultEvent>(_voiceXsResult);

  
      on<PlayRecordAudioEvent>(_playRecordAudio);

    }
  
    @override
    Future<void> close() {
      pageController.dispose();

      audioPlayer.release();
      audioPlayer.dispose();

      return super.close();
    }
  

    void _pageControllerChange(CurrentPageIndexChangeEvent event,
        Emitter<ReadingPageState> emitter) async {

      _currentPage = event.pageIndex;

      _playOriginalAudioInner(null);

      emitter(CurrentPageIndexState());
    }
  

    void _playModeChange(

        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(courseLessonId);

          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 {
      _playOriginalAudioInner(event.url);
    }
  
    void _playOriginalAudioInner(String? audioUrl) {
      print("_playOriginalAudio url=$audioUrl");
      audioUrl ??= currentPageData()?.audioUrl ?? '';
      _playAudio(audioUrl);
      _isOriginAudioPlaying = true;

    }
  

    /// 播放录音
    void _playRecordAudio(
        PlayRecordAudioEvent event, Emitter<ReadingPageState> emitter) async {
      _playRecordAudioInner();
    }
  
    void _playRecordAudioInner() {
      final recordAudioUrl = currentPageData()?.recordUrl;
      print("_playRecordAudioInner url=${currentPageData()?.recordUrl}");
      _playAudio(recordAudioUrl);
      _isRecordAudioPlaying = true;
    }
  
    void _playAudio(String? audioUrl) async {
      await audioPlayer.stop();
      if (audioUrl!.isNotEmpty) {
        await audioPlayer.play(UrlSource(audioUrl));

      }
    }
  
    int dataCount() {
      // print("dataCount=${_entity?.readings?.length ?? 0}");
      return _entity?.readings?.length ?? 0;
    }
  
    CourseProcessReadings? currentPageData() {
      return _entity?.readings?[_currentPage];
    }
  

    ///初始化SDK
    _initVoiceSdk(
        XSVoiceInitEvent event, Emitter<ReadingPageState> emitter) async {
      methodChannel.invokeMethod('initVoiceSdk', event.data);
    }
  

    ///先声测试

    void _voiceXsStart(
        XSVoiceStartEvent event, Emitter<ReadingPageState> emitter) async {
      _stopAudio();

      startRecord(event.content);
      emitter(XSVoiceTestState());
    }
  
    void startRecord(String content) async {
      if (_isRecording == true) {
        return;
      }

      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 = json.decode(event.message);
      final result = args['result'];
      print("_voiceXsResult result=${result}");
      if (result != null) {
        final overall = result['overall'].toString();
        EasyLoading.showToast('测评成功,分数是$overall',
            duration: const Duration(seconds: 10));
        currentPageData()?.recordScore = overall;
        currentPageData()?.recordUrl = args['audioUrl'] + '.mp3';
        _playRecordAudioInner();

      } else {

        EasyLoading.showToast('测评失败', duration: const Duration(seconds: 10));

      }
      _isRecording = false;
      emitter(XSVoiceTestState());
    }

  
    ///终止评测
    void _voiceXsStop(
        XSVoiceStopEvent event, Emitter<ReadingPageState> emitter) async {
      methodChannel.invokeMethod('stopVoice');
    }
  
    void _voicePlayStateChange(VoicePlayStateChangeEvent event,
        Emitter<ReadingPageState> emitter) async {
      emitter(VoicePlayStateChange());
    }
  
    void _stopAudio() async {
      await audioPlayer.stop();
      _isOriginAudioPlaying = false;
      _isRecordAudioPlaying = false;
    }

  }