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

import 'dart:convert';
import 'dart:math';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:flutter/foundation.dart';
import 'package:web_socket_channel/io.dart';
import 'package:flutter/material.dart';
import '../model/conversation.dart';
import 'package:liftmanager/utils/url.dart';
import 'package:liftmanager/internal/bbs/model/talk_model.dart';
import 'package:liftmanager/utils/log_util.dart';
import 'package:dart_notification_center/dart_notification_center.dart';
import 'package:liftmanager/utils/fast_notification.dart';
import 'package:liftmanager/common/common.dart';
// import 'package:flustars/flustars.dart';
import 'package:flustars/flustars.dart' as FlutterStars;
import 'package:liftmanager/utils/toast.dart';
import 'package:liftmanager/routers/fluro_navigator.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;

  
  // 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);
    channel = await new IOWebSocketChannel.connect(socketUrl);
    // channel = await new IOWebSocketChannel.connect('ws://192.168.0.110:8002/ws');
    // channel = await new IOWebSocketChannel.connect('ws://111.231.225.178:3001');
    var objs = {
      "cmd":"LOGINALL",
      "type":1,
      "avatarUrl":FlutterStars.SpUtil.getString("avatarUrl"),
      "time": DateTime.now().millisecondsSinceEpoch,
      "fromUser":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重连');
    }
    socketIsConnect = true;
  }

  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);
      List<String>strChat = prefs.getStringList(obj["sessionid"]);
      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",historyMessageqqq);
      }
      String friendsInit = randomInt(1111,9999).toString() + DateTime.now().millisecondsSinceEpoch.toString();
      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");
        // }
        
        value.forEach((item){
          if(item["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());
          // }
          
        });
        // 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"] =="SYSTEM"){
      //系统消息
       List<dynamic>userList = jsonDecode(obj["msg"]);
      //  List<String>userListStr = [];
      //  userList.forEach((item){
      //    print(item);
      //    userListStr.add(item.toString());
      //  });
       
      // List<dynamic>userList = jsonDecode(obj["msg"]).map((t)=>jsonDecode(t)).toList();
      String setUserListStr;
      List<dynamic>setUserList=[];
      LogUtil.d(userList);
      // prefs.setString(userList[0]["sessionId"].toString()+"userOnline",obj["msg"]);
      FlutterStars.SpUtil.putString(userList[0]["sessionId"].toString()+"userOnline",obj["msg"]);
      // userList.forEach((item){
      //   // LogUtil.d(item.avatarUrl);
      //   // LogUtil.d(item["avatarUrl"]);
      //   // var params = {
      //   //   "avatarUrl":item["avatarUrl"],
      //   //   "name":item["name"],
      //   //   "flag":item["flag"],
      //   // };
      //   // setUserList.add(params);
      //   List<String>str = 
      //   List<dynamic>strObj = str.map((t)=>jsonDecode(t)).toList();
      //   List<dynamic>lastObj = [];
        
        


      //   strObj.forEach((val){
      //     if(item["userId"] == val["userId"]){
      //       lastObj.addAll(item);
      //     }else {
      //       lastObj.addAll(val);
      //     }
          
      //   });
        
      // });
      if(userList[0]["sessionId"].toString()==roomId){
        // setUserListStr = prefs.getString(userList[0]["sessionId"].toString()+"userOnline");
        setUserListStr = FlutterStars.SpUtil.getString(userList[0]["sessionId"].toString()+"userOnline");
        print(JsonEncoder().convert(setUserListStr));
        print(56566666);
        setUserList = jsonDecode(setUserListStr);
        print(JsonEncoder().convert(setUserList));
        print(roomId);
        print("roomId/////////////20200612150634081101746");
        FastNotification.push("set_user",setUserList);  //触发通知
      }
      
    }
    
    
  }
    
  void listenMessage (data){
    connecting = true;
    
    var obj = jsonDecode(data);
    // if(obj["sessionid"] != roomId){
      historyMessageString = [];
      historyMessageqqq = [];
      
    // }
    getStringEvent(obj,data);
    print(222219);
    print(data);
      //触发通知
    notifyListeners();
  }
  void sendMessage(context,data,id,msgType){//发送消息
  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,
      "avatarUrl":FlutterStars.SpUtil.getString("avatarUrl"),
      "time": DateTime.now().millisecondsSinceEpoch,
      "fromUser":int.parse(FlutterStars.SpUtil.getString(Constant.userId)),
      "name":FlutterStars.SpUtil.getString("username"),
      "sessionid":id,
      "msg":data
    };
    String text = json.encode(objs).toString();
    print(text);
    print(777);
    channel.sink.add(text);
  }

  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)),
      "name":FlutterStars.SpUtil.getString("username"),
      "sessionid":roomId,
      "msg":"我首次进入房间"
    };
    
    String text = json.encode(objs).toString();
    print(text);
    print(777);
    channel.sink.add(text);
  }
  void loginAllSeconds(id){//临时重新初始化房间
  roomId = id;
  getOnlineUserEvent(roomId);
  print(JsonEncoder().convert(roomId));
  print(555);
    var objs = {
      "cmd":"LOGINALL",
      "type":1,
      "avatarUrl":FlutterStars.SpUtil.getString("avatarUrl"),
      "time": DateTime.now().millisecondsSinceEpoch,
      "fromUser":int.parse(FlutterStars.SpUtil.getString(Constant.userId)),
      "name":FlutterStars.SpUtil.getString("username"),
      "sessionid":roomId,
      "msg":"我是app端初始化临时"
    };
    
    String text = json.encode(objs).toString();
    print(text);
    print(778);
    channel.sink.add(text);
  }
  void incomeFriend(id){//进入朋友房间
  roomId = id;
  getOnlineUserEvent(roomId);
  
  }

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

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

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