// pages/list/list.js
import * as chatInput from "../../modules/chat-input/chat-input";
import IMOperator from "./im-operator";
import UI from "./ui";
import MsgManager from "./msg-manager";
/**
* 聊天页面
*/
Page({
/**
* 页面的初始数据
*/
data: {
textMessage: '',
chatItems: [],
latestPlayVoicePath: '',
isAndroid: true,
chatStatue: 'open',
limit_page:1,
charItem_message:[]
},
/**
* 生命周期函数--监听页面加载
*/
onLoad(options) {
this.ArrMsg = [];
// to_id
// nickname
// headUrl
// wx.startPullDownRefresh
//请空未读消息条数
console.log(options);
console.log(options,'chat');
const friend = options;
this.SocketSend({ to_id: friend.to_id, form_id: getApp().UserId(), type: 'get_history', page: this.data.limit_page});
getApp().Imsocket().onSocketMessageCallback = this.onSocketMessageCallback;
// const friend = JSON.parse(options.friend);//获取传递进来的信息
this.setData({
friendId: friend.to_id,
myheadurl: friend.myheadurl,
headUrl: friend.headUrl
})
// console.log(friend);
// return false;
this.initData();
//设置bar内容
wx.setNavigationBarTitle({
title: friend.nickName || ''
});
this.imOperator = new IMOperator(this, friend);
this.UI = new UI(this);
this.msgManager = new MsgManager(this);
// this.imOperator.onSimulateReceiveMsg((msg) => {
// console.log(msg);
// this.msgManager.showMsg({msg})
// });
// this.UI.updateChatStatus('正在聊天中：' + friend.nickname);
},
onShow: function (e) {
//获取历史消息getget
// this.onLoad();
},
initData() {
let that = this;
let systemInfo = wx.getSystemInfoSync();
chatInput.init(this, {
systemInfo: systemInfo,
minVoiceTime: 1,
maxVoiceTime: 60,
startTimeDown: 56,
format: 'mp3',//aac/mp3
sendButtonBgColor: 'mediumseagreen',
sendButtonTextColor: 'white',
extraArr: [{
picName: 'choose_picture',
description: '照片'
}
// , {
// picName: 'take_photos',
// description: '拍摄'
// }, {
// picName: 'close_chat',
// description: '自定义功能'
// }
],
// tabbarHeigth: 48
});
that.setData({
pageHeight: systemInfo.windowHeight,
isAndroid: systemInfo.system.indexOf("Android") !== -1,
});
wx.setNavigationBarTitle({
title: '好友'
});
that.textButton();
that.extraButton();
that.voiceButton();
},
textButton() {
let _that = this;
chatInput.setTextMessageListener((e) => {
console.log(e,'发送的消息');
let content = e.detail.value;
this.msgManager.sendMsg({type: IMOperator.TextType, content});
});
},
voiceButton() {
console.log(1);
// chatInput.recordVoiceListener((res, duration) => {
// let tempFilePath = res.tempFilePath;
// this.msgManager.sendMsg({type: IMOperator.VoiceType, content: tempFilePath, duration});
// });
// chatInput.setVoiceRecordStatusListener((status) => {
// this.msgManager.stopAllVoice();
// })
},
//模拟上传文件，注意这里的cbOk回调函数传入的参数应该是上传文件成功时返回的文件url，这里因为模拟，我直接用的savedFilePath
simulateUploadFile({savedFilePath, duration, itemIndex, success, fail}) {
setTimeout(() => {
let urlFromServerWhenUploadSuccess = savedFilePath;
success && success(urlFromServerWhenUploadSuccess);
}, 1000);
},
extraButton() {
let that = this;
chatInput.clickExtraListener((e) => {
console.log('图片上传111111111111');
let chooseIndex = parseInt(e.currentTarget.dataset.index);
if (chooseIndex === 2) {
that.myFun();
return;
}
wx.chooseImage({
count: 5, // 默认9
sizeType: ['compressed'],
sourceType: chooseIndex === 0 ? ['album'] : ['camera'],
success: (res) => {
let ImgRes = res;
//发送上传图片
//上传图片
wx.uploadFile({
url: getApp().globalData.url + 'imsocket/images/chatimg',
filePath: res.tempFilePaths[0],
name: 'photo',
formData: {
key: wx.getStorageSync('access_key'),
token: wx.getStorageSync('access_token')
},
success: function (res) {
var data = JSON.parse(res.data);
console.log(data,'图片上传成功');
if (data.code == 201) {
let con = data.data;
//显示图片
console.log(con,1);
console.log(ImgRes.tempFilePaths[0], 1222222);
that.msgManager.sendMsg({ type: IMOperator.ImageType, content: con })
} else if (data.code == 301) {
wx.showModal({
title: '提示',
content: data.msg,
showCancel: false,
})
}
}, fail: function (d) {
}
})
// that.msgManager.sendMsg({ type: IMOperator.ImageType, content: res.tempFilePaths[0] })
}
});
});
},
/**
* 自定义事件
*/
myFun() {
wx.showModal({
title: '小贴士',
content: '演示更新会话状态',
confirmText: '确认',
showCancel: true,
success: (res) => {
if (res.confirm) {
this.msgManager.sendMsg({type: IMOperator.CustomType})
}
}
})
},
resetInputStatus() {
chatInput.closeExtraView();
},
sendMsg({content, itemIndex, success}) {
//发送消息
this.imOperator.onSimulateSendMsg({
content,
success: (msg) => {
this.UI.updateViewWhenSendSuccess(msg, itemIndex);
success && success(msg);
},
fail: () => {
this.UI.updateViewWhenSendFailed(itemIndex);
}
})
},
/**
* 重发消息
* @param e
*/
resendMsgEvent(e) {
const itemIndex = parseInt(e.currentTarget.dataset.resendIndex);
const item = this.data.chatItems[itemIndex];
this.UI.updateDataWhenStartSending(item, false, false);
this.msgManager.resend({...item, itemIndex});
},
onSocketMessageCallback:function(e){
let data = JSON.parse(e);
console.log(data,11222);
let _that = this;
if(data.type){
switch (data.type) {
case 'get_history':
console.log(data, '分页消息');
console.log(getApp().UserId(),'UserId');
for (var index in data.data) {
switch(data.data[index].type){
case 1:
data.data[index].type = 'text';
break;
case 2:
data.data[index].type = 'image';
break
}
data.data[index].timestamp = data.data[index].create_at;
// data.data[index].time = data.data[index].create_at;
data.data[index].showTime = true;
//自己
console.log(getApp().UserToken());
if (data.data[index].form_id == getApp().UserToken()) {
data.data[index].isMy = true;
data.data[index].userId = data.data[index].form_id;
data.data[index].headUrl = _that.data.myheadurl
} else {
//别人
data.data[index].isMy = false;
data.data[index].headUrl = _that.data.headUrl
}
_that.ArrMsg.push(data.data[index]);
}
// data.data.push(_that.data.chatItems)
// let content = data.data;
// _that.msgManager.showMsg({ type: IMOperator.TextType, content});
// console.log(CharItemMessage);
_that.scrollTopValLength = data.data.length
if (_that.data.limit_page == 1){
_that.scrollTopValLength = data.data.length * 999
}else{
_that.scrollTopValLength = data.data.length * 100
}
_that.setData({
chatItems: _that.sortarr(_that.ArrMsg),
scrollTopVal: _that.scrollTopValLength
})
break;
case 'alone':
let content = data.data.content;
let msg = _that.imOperator.createNormalChatItem({
type: 'text',
content: content,
isMy: false
})
_that.msgManager = new MsgManager(_that);
_that.msgManager.showMsg({ msg});
break;
}
}
// let msg = data.data
// this.msgManager.showMsg({ msg})
// console.log(e,'接受到历史消息');
},
onUnload:function(e){
let url = 'imsocket/imchatmessage/clearunreadmsg';
let datas = {
to_id: this.data.friendId, form_id: getApp().UserId()
};
//清除未读信息
getApp().postRequest(url, datas, function (res) {
console.log(res,11111);
})
console.log('销毁页面');
},
SocketSend:function(msg){
// { to_id: friend.to_id, form_id: getApp().UserId(), type: 'get_history' }
// msg.type = 'get_history';
getApp().Imsocket().sendSocketMessage({
msg: JSON.stringify(msg),
success: function (res) {
console.log(res, '获取历史消息成功');
}, fail: function (res) {
console.log('获取历史消息失败')
}
})
},
sortarr: function (arr) {//冒泡排序
for (let i = 0; i < arr.length - 1; i++) {
for (let j = 0; j < arr.length - 1 - i; j++) {
if (arr[j].create_at > arr[j + 1].create_at) {
var temp = arr[j];
arr[j] = arr[j + 1];
arr[j + 1] = temp;
}
}
}
return arr;
},
upper:function(e){
console.log(e);
let _that = this;
this.setData({
limit_page: this.data.limit_page * 1 + 1
})
this.SocketSend({ to_id: _that.data.friendId, form_id: getApp().UserId(), type: 'get_history', page: _that.data.limit_page})
},
emojis:function(){
getApp().Tips('该功能正在开发中。');
}
});