|
@@ -169,13 +169,16 @@ class WebSocketProvide with ChangeNotifier{
|
|
|
// 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"]) != ""){
|
|
|
+ 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));
|
|
@@ -190,7 +193,7 @@ class WebSocketProvide with ChangeNotifier{
|
|
|
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);
|
|
|
}
|
|
@@ -256,6 +259,8 @@ class WebSocketProvide with ChangeNotifier{
|
|
|
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);
|
|
|
}
|
|
|
|
|
|
}
|
|
@@ -278,7 +283,7 @@ class WebSocketProvide with ChangeNotifier{
|
|
|
//触发通知
|
|
|
notifyListeners();
|
|
|
}
|
|
|
- void sendMessage(context,data,id,msgType){//发送消息
|
|
|
+ void sendMessage(context,data,id,msgType,dataTable,toUserId){//发送消息
|
|
|
FocusScope.of(context).requestFocus(FocusNode());
|
|
|
if(!socketIsConnect){
|
|
|
showAlert(
|
|
@@ -311,9 +316,12 @@ class WebSocketProvide with ChangeNotifier{
|
|
|
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":data
|
|
@@ -329,7 +337,8 @@ class WebSocketProvide with ChangeNotifier{
|
|
|
|
|
|
print("LOOP");
|
|
|
var objs = {
|
|
|
- "cmd":"LOOP"
|
|
|
+ "cmd":"LOOP",
|
|
|
+ "userId":int.parse(FlutterStars.SpUtil.getString(Constant.userId))
|
|
|
};
|
|
|
|
|
|
String text = json.encode(objs).toString();
|
|
@@ -360,27 +369,7 @@ class WebSocketProvide with ChangeNotifier{
|
|
|
// 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);
|