lift-app/lib/internal/bbs/provide/websocket.dart

import 'dart:async';
import 'dart:convert';
import 'dart:math';

import 'package:flustars/flustars.dart' as FlutterStars;
import 'package:flutter/foundation.dart';
import 'package:flutter/material.dart';
import 'package:liftmanager/common/common.dart';
import 'package:liftmanager/routers/fluro_navigator.dart';
import 'package:liftmanager/utils/fast_notification.dart';
import 'package:liftmanager/utils/log_util.dart';
import 'package:liftmanager/utils/toast.dart';
import 'package:liftmanager/utils/url.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:web_socket_channel/io.dart';

class WebSocketProvide with ChangeNotifier {
  List<dynamic> historyMessageqqq = []; //接收到哦的所有的历史消息
  List<String> historyMessageString = []; //接收到哦的所有的历史消息
  var connecting = false; //websocket连接状态
  IOWebSocketChannel channel;
  String roomId;
  bool socketIsConnect = false;
  bool isSend = true;
  Timer _timer;
  void startTimer() {
    //设置 10 秒回调一次
    const period = const Duration(seconds: 10);
    _timer = Timer.periodic(period, (timer) {
      initLoop();
    });
  }

  void cancelTimer() {
    if (_timer != null) {
      print('websocket CancelTimer');
      _timer.cancel();
      _timer = null;
    }
    print('websocket CancelTimer2');
  }

  @override
  void dispose() {
    super.dispose();
    cancelTimer();
  }

  // DartNotificationCenter.subscribe(
  //   channel: CHANNEL_NAME,
  //   observer: i,
  //   onNotification: (result) => print('received: $result'),
  // );

  // DartNotificationCenter.post(
  //     channel: CHANNEL_NAME,
  //     options: 'with options!!',
  //   );

  void createWebsocket(roomIdss) async {
    //创建连接并且发送鉴别身份信息

    // print(JsonEncoder().convert(historyMessageString));
    // historyMessageString = [];
    // historyMessageqqq = [];
    // roomId= roomId;
    print(666664);
    // FlutterStars.SpUtil.putObject("sessionIdObj", res);
    // SharedPreferences prefs = await SharedPreferences.getInstance();
    // if(prefs.get(roomIdss)==null){
    //   prefs.setStringList(roomIdss, historyMessageString);
    // }else {
    //   historyMessageString = prefs.getStringList(roomIdss);
    // }

    // print(JsonEncoder().convert(historyMessageqqq));
    // LogUtil.d(historyMessageString);
    // print(4444);
    try {
      channel = await new IOWebSocketChannel.connect(socketUrl);
      var objs = {
        "cmd": "LOGINALL",
        "type": 1,
        "avatarUrl": FlutterStars.SpUtil.getString("avatarUrl"),
        "time": DateTime.now().millisecondsSinceEpoch,
        "fromUser": FlutterStars.SpUtil.getString(Constant.userId),
        "userId": FlutterStars.SpUtil.getString(Constant.userId),
        "name": FlutterStars.SpUtil.getString("username"),
        "sessionid": roomIdss,
        // "sessionid":roomId,
        "msg": "我是app端初始化"
      };
      String text = json.encode(objs).toString();
      channel.sink.add(text);
      //监听到服务器返回消息
      channel.stream.listen((data) => listenMessage(data),
          onError: onError, onDone: onDone);
      if (!socketIsConnect && !isSend) {
        String initThisSocket = randomInt(1111, 9999).toString() +
            DateTime.now().millisecondsSinceEpoch.toString();
        FastNotification.push("initSocket", initThisSocket);
        isSend = true;
        print('websocket重连');
      }
      // else {
      //   startTimer();
      // }
      cancelTimer();

      startTimer();
      socketIsConnect = true;
    } catch (e) {
      socketIsConnect = false;
      print(e);
    }
  }

  //缓存历史消息
  void setStringEvent(id, strList) async {
    SharedPreferences prefs = await SharedPreferences.getInstance();
    prefs.setStringList(id, strList);
    LogUtil.d(prefs.getStringList(id));
    print(414141);
  }

  void setOnlineUserEvent(id, strOnlineList) async {
    SharedPreferences prefs = await SharedPreferences.getInstance();
    // prefs.setString(id, strOnlineList);
    FlutterStars.SpUtil.putString(id, strOnlineList);
    LogUtil.d(strOnlineList);
    // LogUtil.d(prefs.getString(id));
    print(414141);
  }

  //用户头像显示
  // void getOnlineUserEvent(id)async{
  //   SharedPreferences prefs = await SharedPreferences.getInstance();
  //   // String userStr = prefs.getString(id+"userOnline");
  //   String userStr = FlutterStars.SpUtil.getString(id+"userOnline");
  //   // List<dynamic>setUserList = userStr.map((item)=>jsonDecode(item)).toList();
  //   if(userStr!=null&&userStr!=""){
  //     List<dynamic>setUserList = jsonDecode(userStr);
  //     FastNotification.push("set_user",setUserList);
  //     // LogUtil.d(prefs.getString(id+"userOnline"));
  //     print(33333);
  //   }

  // }

  randomInt(int min, int max) {
    return new Random().nextInt(max) % (max - min + 1) + min;
  }

  void getStringEvent(obj, data) async {
    SharedPreferences prefs = await SharedPreferences.getInstance();

    // if(prefs.getStringList(roomId)==null){
    //   prefs.setStringList(roomId, []);
    // }else {
    //   historyMessageString = prefs.getStringList(roomId);
    // }
    // historyMessageString = prefs.getStringList(roomId);
    // LogUtil.d(historyMessageString);
    // print(456741);
    // LogUtil.d(data);
    if (obj["cmd"] == "CHAT") {
      //正常消息
      // historyMessageString.add(data.toString());
      // setStringEvent(roomId,historyMessageString);
      // print(JsonEncoder().convert(prefs.getStringList(obj["sessionid"])));
      String friendsInit = randomInt(1111, 9999).toString() +
          DateTime.now().millisecondsSinceEpoch.toString();
      print(123);
      List<String> strChat;
      print(prefs.getStringList(obj["sessionid"]));
      // ignore: unrelated_type_equality_checks
      if (prefs.getStringList(obj["sessionid"]) != "" &&
          prefs.getStringList(obj["sessionid"]) != null) {
        strChat = prefs.getStringList(obj["sessionid"]);
      } else {
        strChat = [];
        FastNotification.push("friendAction", friendsInit);
      }

      print(JsonEncoder().convert(data));
      print("JsonEncoder().convert(data)---------------------");
      strChat.add(data);
      // strChat.add(JsonEncoder().convert(data));
      // strChat.add(json.encode(data).toString());
      setStringEvent(obj["sessionid"], strChat);
      if (obj["sessionid"] == roomId) {
        historyMessageString = strChat;
        print(222220);
        historyMessageqqq =
            historyMessageString.map((item) => jsonDecode(item)).toList();
        FastNotification.push("chat_room_chat", historyMessageqqq);
      }

      prefs.setString("changeRoomId", obj["sessionid"]);
      FastNotification.push("friendAction", friendsInit);
    }
    // else if(obj["cmd"] =="UNREAD"){
    //   //离线消息
    //   Map<String,dynamic>msgObj = jsonDecode(obj["msg"]);
    //   // print(JsonEncoder().convert(historyMessageqqq));
    //   msgObj.forEach((key, value) {
    //     List<String>str = [];
    //     if(prefs.getStringList(key) != null){
    //       str = prefs.getStringList(key);
    //     }
    //     String strUserOnline;
    //     // if(prefs.getString(key+"userOnline") != null){
    //     //   strUserOnline = prefs.getString(key+"userOnline");
    //     // }
    //     print(jsonEncode(value));
    //     print("--------------------------------------///123456");
    //     // value.forEach((key,item){
    //     //   if(value[key]["msgList"].length>0){
    //     //     // str.add(JsonEncoder().convert(item["msgList"]));
    //     //     item["msgList"].forEach((ii){
    //     //       str.add(JsonEncoder().convert(ii));
    //     //     });
    //     //     // str.add(item["msgList"].toString());
    //     //   }
    //     //   // if(item["flag"]){
    //     //   //   strUserOnline.add(item.toString());
    //     //   // }

    //     // });

    //     if(value["msgList"].length>0){
    //         // str.add(JsonEncoder().convert(item["msgList"]));
    //         value["msgList"].forEach((ii){
    //           str.add(JsonEncoder().convert(ii));
    //         });
    //         // str.add(item["msgList"].toString());
    //       }
    //     // strUserOnline = value.toString();
    //     strUserOnline = JsonEncoder().convert(value);

    //     setStringEvent(key,str);
    //     setOnlineUserEvent(key+"userOnline",strUserOnline);
    //   });
    //   LogUtil.d(msgObj);
    //   // print("456456111------------------------");
    //   // msgList.forEach((item){
    //   //   historyMessageString.add(jsonEncode(item));
    //   // });
    //   // setStringEvent();
    // }
    else if (obj["cmd"] == "INITROOM") {
      List<dynamic> msgListInitRoom = jsonDecode(obj["msg"]);
      if (msgListInitRoom != null && msgListInitRoom != []) {
        List<String> strList = [];
        msgListInitRoom.forEach((item) {
          strList.add(JsonEncoder().convert(item));
        });
        setStringEvent(obj["sessionid"], strList);
        print(JsonEncoder().convert(msgListInitRoom));
        print(prefs.getStringList(obj["sessionid"]));
        print("JsonEncoder().convert(INITROOM)---------------------");
        historyMessageqqq = msgListInitRoom;
        FastNotification.push("chat_room", historyMessageqqq);
        String friendsInit = randomInt(1111, 9999).toString() +
            DateTime.now().millisecondsSinceEpoch.toString();
        FastNotification.push("friendAction", friendsInit);
      }
    }
  }

  void listenMessage(data) {
    try {
      connecting = true;

      var obj = jsonDecode(data);
      // if(obj["sessionid"] != roomId){
      historyMessageString = [];
      historyMessageqqq = [];

      // }
      getStringEvent(obj, data);
      print(222219);
      print(data);
    } catch (e) {}

    //触发通知
    notifyListeners();
  }

  void sendMessage(context, {msg, id, msgType, dataTable, toUserId, recordingDuration}) {
    //发送消息
    // FocusScope.of(context).requestFocus(FocusNode());
    if (!socketIsConnect) {
      showAlert(
        context,
        "提示",
        "聊天室已断开，是否重新连接",
        "确定",
        () {
          // Navigator.of(context)..pop()..pop();
          // // setExtAddress(address+","+coord.latitude.toString()+","+coord.longitude.toString());
          // String setAddress = address +
          //     "," +
          //     coord.latitude.toString() +
          //     "," +
          //     coord.longitude.toString();
          // FastNotification.push("set_address", setAddress);
          createWebsocket(roomId);
          NavigatorUtils.goBack(context);
        },
        txt2: "取消",
        onPre2: () {
          NavigatorUtils.goBack(context);
        },
      );
      return;
    }
    roomId = id;
    // print(JsonEncoder().convert(roomId));
    // print(555);
    var objs = {
      "cmd": "CHAT",
      "type": msgType,
      "dataTable": dataTable,
      "receiver": toUserId,
      "avatarUrl": FlutterStars.SpUtil.getString("avatarUrl"),
      "time": DateTime.now().millisecondsSinceEpoch,
      "fromUser": int.parse(FlutterStars.SpUtil.getString(Constant.userId)),
      "userId": int.parse(FlutterStars.SpUtil.getString(Constant.userId)),
      "name": FlutterStars.SpUtil.getString("username"),
      "sessionid": id,
      "msg": msg,
      "dura": recordingDuration,
    };
    String text = json.encode(objs).toString();
    print(text);
    print(777);
    channel.sink.add(text);
  }

  void initLoop() {
    //定时10秒发送

    try {
      print("LOOP");
      var objs = {
        "cmd": "LOOP",
        "userId": int.parse(FlutterStars.SpUtil.getString(Constant.userId))
      };

      String text = json.encode(objs).toString();
      // print(text);
      // print(777);
      if (channel != null) {
        channel.sink?.add(text);
      }
    } catch (e) {
      print(e);
    }
  }

  void incomeRoom(id) {
    //进入房间
    roomId = id;
    // getOnlineUserEvent(roomId);
    // print(JsonEncoder().convert(roomId));
    // print(555);
    var objs = {
      "cmd": "INITROOM",
      "type": 1,
      "avatarUrl": FlutterStars.SpUtil.getString("avatarUrl"),
      "time": DateTime.now().millisecondsSinceEpoch,
      "fromUser": int.parse(FlutterStars.SpUtil.getString(Constant.userId)),
      "userId": int.parse(FlutterStars.SpUtil.getString(Constant.userId)),
      "name": FlutterStars.SpUtil.getString("username"),
      "sessionid": roomId,
      "msg": "进入房间"
    };

    String text = json.encode(objs).toString();
    // print(text);
    // print(777);
    channel.sink.add(text);
  }

  void incomeFriend(id) {
    //进入朋友房间
    roomId = id;
    // getOnlineUserEvent(roomId);
  }

  onError(error) {
    print('error------------>${error}');
  }

  void onDone() {
    print('websocket断开了');
    toasts("聊天室连接已断开！");
    cancelTimer();
    socketIsConnect = false;
    isSend = false;
    // closeWebSocket();
    // createWebsocket(roomId);
    // print('websocket重连');
  }

  void closeWebSocket() {
    //关闭链接
    if (channel != null) {
      channel.sink.close();
    }

    print('关闭了websocket');
    notifyListeners();
  }
}