var strophe = require('../../utils/strophe.js')
var WebIM = require('../../utils/WebIM.js')
var WebIM = WebIM.default
// 网络请求工具类
var networkUtil = require('../../utils/network_util.js')
var api = require('../../utils/apiFile.js')
var RecordStatus = {
SHOW: 0,
HIDE: 1,
HOLD: 2,
SWIPE: 3,
RELEASE: 4
}
var RecordDesc = {
0: '长按开始录音',
2: '向上滑动取消',
3: '松开手取消',
}
Page({
data: {
chatMsg: [],
emojiStr: '',
yourname: '',
myName: '',
yourName: '',
yourIcon: '',
myIcon: '',
sendInfo: '',
userMessage: '',
inputMessage: '',
indicatorDots: true,
autoplay: false,
interval: 5000,
duration: 1000,
show: 'emoji_list',
view: 'scroll_view',
toView: '',
emoji: WebIM.Emoji,
emojiObj: WebIM.EmojiObj,
msgView: {},
RecordStatus: RecordStatus,
RecordDesc: RecordDesc,
recordStatus: RecordStatus.HIDE,
},
connectWebIM() {
console.log('chatroom开始连接')
WebIM.conn.close()
var that = this
var options = {
apiUrl: WebIM.config.apiURL,
user: wx.getStorageSync('hxName'),
pwd: wx.getStorageSync('hxPassWord'),
accessToken: wx.getStorageSync('access_token'),
// grant_type: "password",
success: function (res) {
console.log("conn success:", res);
},
fail: function (e) {
console.log("fail:" + e);
},
autoReconnectNumMax: 30,
autoReconnectInterval: 1,
appKey: WebIM.config.appkey
}
WebIM.conn.open(options)
},
onLoad: function (options) {
var that = this
console.log(options)
var myName = wx.getStorageSync('myUsername')
console.log(myName)
var options = JSON.parse(options.username)
var num = wx.getStorageSync(options.your + myName).length - 1
if (num > 0) {
setTimeout(function () {
that.setData({
toView: wx.getStorageSync(options.your + myName)[num].mid
})
}, 10)
}
this.setData({
yourname: options.your,
yourName: options.yourName,
yourIcon: options.yourIcon,
myIcon: getApp().globalData.userInfo.avatar.medium,
myName: myName,
inputMessage: '',
chatMsg: wx.getStorageSync(options.your + myName) || []
})
console.log(that.data.chatMsg)
if (that.data.yourName != null) {
wx.setNavigationBarTitle({
title: that.data.yourName
})
} else {
that.getNameIcon(options.your)
}
},
onShow: function () {
var that = this
this.setData({
inputMessage: ''
})
if (wx.getStorageSync("access_token") != null && !wx.getStorageSync("isHxOpend")) {
this.connectWebIM()
}
},
bindMessage: function (e) {
this.setData({
userMessage: e.detail.value
})
},
cleanInput: function () {
var that = this
var setUserMessage = {
sendInfo: that.data.userMessage
}
that.setData(setUserMessage)
},
longTap: function (e) {
// console.log("longTap:", e.currentTarget.dataset.content["0"].data)
wx.setClipboardData({
data: e.currentTarget.dataset.content["0"].data,
success: function (res) {
wx.getClipboardData({
success: function (res) {
// console.log("setClipboardData:",res.data) // data
wx.showToast({
title: '已复制到粘贴板',
})
},
fail: function (res) {
}
})
}
})
},
//***************** 录音 begin ***************************
changedTouches: null,
toggleRecordModal: function (e) {
this.setData({
recordStatus: this.data.recordStatus == RecordStatus.HIDE ? RecordStatus.SHOW : RecordStatus.HIDE
})
},
toggleWithoutAction: function (e) {
console.log('toggleWithoutModal 拦截请求不做处理')
},
handleRecordingMove: function (e) {
var touches = e.touches[0]
var changedTouches = this.changedTouches
if (!this.changedTouches) {
return
}
// 无效
// var changedTouches = e.changedTouches[0]
// console.log(changedTouches.pageY, touches.pageY)
if (this.data.recordStatus == RecordStatus.SWIPE) {
if (changedTouches.pageY - touches.pageY < 20) {
this.setData({
recordStatus: RecordStatus.HOLD
})
}
}
if (this.data.recordStatus == RecordStatus.HOLD) {
if (changedTouches.pageY - touches.pageY > 20) {
this.setData({
recordStatus: RecordStatus.SWIPE
})
}
}
},
handleRecording: function (e) {
var self = this
console.log('handleRecording')
this.changedTouches = e.touches[0]
this.setData({
recordStatus: RecordStatus.HOLD
})
wx.startRecord({
fail: function (err) {
// 时间太短会失败
console.log(err)
},
success: function (res) {
console.log('success')
// 取消录音发放状态 -> 退出不发送
if (self.data.recordStatus == RecordStatus.RELEASE) {
console.log('user canceled')
return
}
console.log(" send voice tempFilePath:" + res.tempFilePath)
self.uploadRecord(res.tempFilePath)
},
complete: function () {
console.log("complete")
this.handleRecordingCancel()
}.bind(this)
})
setTimeout(function () {
//超时
self.handleRecordingCancel()
}, 100000)
},
handleRecordingCancel: function () {
console.log('handleRecordingCancel')
// 向上滑动状态停止：取消录音发放
if (this.data.recordStatus == RecordStatus.SWIPE) {
this.setData({
recordStatus: RecordStatus.RELEASE
})
} else {
this.setData({
recordStatus: RecordStatus.HIDE
})
}
wx.stopRecord()
},
stopRecord: function (e) {
let {url, mid} = e.target.dataset
this.data.msgView[mid] = this.data.msgView[mid] || {}
this.data.msgView[mid].isPlay = false;
this.setData({
msgView: this.data.msgView
})
wx.stopVoice()
},
playRecord: function (e) {
var self=this
let {url, mid} = e.target.dataset
this.data.msgView[mid] = this.data.msgView[mid] || {}
// reset all plays
for (let v in this.data.msgView) {
this.data.msgView[v] = this.data.msgView && (this.data.msgView[v] || {})
this.data.msgView[v].isPlay = false
}
// is play then stop
if (this.data.msgView[mid].isPlay) {
this.stopRecord(e)
return;
}
console.log(url, mid)
this.data.msgView[mid].isPlay = true;
this.setData({
msgView: this.data.msgView
})
wx.downloadFile({
url: url,
type: 'audio',
success: function (res) {
console.log("downloadFile voice success",res)
wx.playVoice({
filePath: res.tempFilePath,
success: function () {
console.log("playVoice success")
}, fail: function () {
console.log("playVoice fail")
},
complete: function () {
console.log("playVoice complete")
self.stopRecord(e)
}.bind(self)
})
// wx.saveFile({
// tempFilePath: res.tempFilePath,
// success: function (res ) {
// console.log("saveFile success", res )
// wx.playVoice({
// filePath: res.savedFilePath,
// success: function () {
// console.log("playVoice success")
// }, fail: function () {
// console.log("playVoice fail")
// },
// complete: function () {
// console.log("playVoice complete")
// self.stopRecord(e)
// }.bind(self)
// })
// }, fail: function () {
// console.log("saveFile fail")
// },
// complete: function () {
// console.log("saveFile complete")
// self.stopRecord(e)
// }
// })
}.bind(self),
fail: function (err) {
console.log("downloadFile voice fail,", err)
},
complete: function complete() {
}
})
},
uploadRecord: function (tempFilePath) {
var str = WebIM.config.appkey.split('#')
var that = this
wx.uploadFile({
url: 'https://a1.easemob.com/' + str[0] + '/' + str[1] + '/chatfiles',
filePath: tempFilePath,
name: 'file',
header: {
'Content-Type': 'multipart/form-data'
},
success: function (res) {
// return;
// 发送xmpp消息
var msg = new WebIM.message('audio', WebIM.conn.getUniqueId())
var data = res.data
var dataObj = JSON.parse(data)
var file = {
type: 'audio',
'url': dataObj.uri + '/' + dataObj.entities[0].uuid,
'filetype': '',
'filename': tempFilePath
}
var option = {
apiUrl: WebIM.config.apiURL,
body: file,
to: that.data.yourname, // 接收消息对象
roomType: false,
chatType: 'singleChat'
}
msg.set(option)
WebIM.conn.send(msg.body)
// 本地消息展示
var time = WebIM.time()
var msgData = {
info: {
to: msg.body.to
},
username: that.data.myName,
yourname: msg.body.to,
msg: {
type: msg.type,
data: msg.body.body.url,
url: msg.body.body.url,
},
style: 'self',
time: time,
mid: msg.id
}
that.data.chatMsg.push(msgData)
console.log(that.data.chatMsg)
// 存储到本地消息
var myName = wx.getStorageSync('myUsername')
wx.setStorage({
key: that.data.yourname + myName,
data: that.data.chatMsg,
success: function () {
console.log('save message success', that.data)
that.setData({
chatMsg: that.data.chatMsg
})
setTimeout(function () {
that.setData({
toView: that.data.chatMsg[that.data.chatMsg.length - 1].mid
})
}, 10)
}
})
}
})
},
//***************** 录音 end ***************************
sendMessage: function () {
if (!this.data.userMessage.trim()) return;
var that = this
wx.getNetworkType({
success: function (res) {
// console.log("getNetworkType:",res)
if (res.networkType == 'none' && wx.getStorageSync('isHxOpend') == true) {
wx.showModal({
title: '提示',
content: '请检查网络',
showCancel: false,
success: function (res) {
}
})
//断网时不清空消息
that.setData({
inputMessage: that.data.sendInfo
})
} else {
// //console.log(that.data.userMessage)
// //console.log(that.data.sendInfo)
var myName = wx.getStorageSync('myUsername')
var id = WebIM.conn.getUniqueId();
var msg = new WebIM.message('txt', id);
msg.set({
msg: that.data.sendInfo,
to: that.data.yourname,
roomType: false,
success: function (id, serverMsgId) {
console.log(' sendMessage success')
}, fail: function (error) {
console.log("sendMessage error:" + error)
}
});
// //console.log(msg)
msg.body.chatType = 'singleChat';
WebIM.conn.send(msg.body);
if (msg) {
var value = WebIM.parseEmoji(msg.value.replace(/\n/mg, ''))
var time = WebIM.time()
var msgData = {
info: {
to: msg.body.to
},
username: that.data.myName,
yourname: msg.body.to,
msg: {
type: msg.type,
data: value
},
style: 'self',
time: time,
mid: msg.id
}
that.data.chatMsg.push(msgData)
// console.log(that.data.chatMsg)
wx.setStorage({
key: that.data.yourname + myName,
data: that.data.chatMsg,
success: function () {
//console.log('success', that.data)
that.setData({
chatMsg: that.data.chatMsg,
emojiList: [],
inputMessage: ''
})
setTimeout(function () {
that.setData({
toView: that.data.chatMsg[that.data.chatMsg.length - 1].mid
})
}, 100)
}
})
that.setData({
userMessage: ''
})
}
}
},
})
},
receiveMsg: function (msg, type) {
var that = this
var myName = wx.getStorageSync('myUsername')
if (msg.from == that.data.yourname || msg.to == that.data.yourname) {
//console.log(msg)
if (type == 'txt') {
var value = WebIM.parseEmoji(msg.data.replace(/\n/mg, ''))
} else if (type == 'emoji') {
var value = msg.data
}
//console.log(msg)
//console.log(value)
var time = WebIM.time()
var msgData = {
info: {
from: msg.from,
to: msg.to
},
username: '',
yourname: msg.from,
msg: {
type: type,
data: value,
url: msg.url
},
style: '',
time: time,
mid: msg.type + msg.id
}
if (msg.from == that.data.yourname) {
msgData.style = ''
msgData.username = msg.from
} else {
msgData.style = 'self'
msgData.username = msg.to
}
//console.log(msgData, that.data.chatMsg, that.data)
that.data.chatMsg.push(msgData)
wx.setStorage({
key: that.data.yourname + myName,
data: that.data.chatMsg,
success: function () {
//console.log('success', that.data)
that.setData({
chatMsg: that.data.chatMsg,
})
setTimeout(function () {
that.setData({
toView: that.data.chatMsg[that.data.chatMsg.length - 1].mid
})
}, 100)
}
})
}
},
openEmoji: function () {
this.setData({
show: 'showEmoji',
view: 'scroll_view_change'
})
},
sendEmoji: function (event) {
var that = this
var emoji = event.target.dataset.emoji
var msglen = that.data.userMessage.length - 1
if (emoji && emoji != '[del]') {
var str = that.data.userMessage + emoji
} else if (emoji == '[del]') {
var start = that.data.userMessage.lastIndexOf('[')
var end = that.data.userMessage.lastIndexOf(']')
var len = end - start
if (end != -1 && end == msglen && len >= 3 && len <= 4) {
var str = that.data.userMessage.slice(0, start)
} else {
var str = that.data.userMessage.slice(0, msglen)
}
}
this.setData({
userMessage: str,
inputMessage: str
})
},
sendImage: function () {
var that = this
wx.getNetworkType({
success: function (res) {
// console.log("getNetworkType:",res)
if (res.networkType == 'none') {
wx.showModal({
title: '提示',
content: '请检查网络',
showCancel: false,
success: function (res) {
}, fail: function (error) {
console.log("sendImage error:" + error)
}
})
} else {
var pages = getCurrentPages()
pages[pages.length - 1].cancelEmoji()
wx.chooseImage({
count: 1,
sizeType: ['original', 'compressed'],
sourceType: ['album'],
success: function (res) {
// console.log(res)
//console.log(pages)
if (pages[pages.length - 1]) {
pages[pages.length - 1].upLoadImage(res, that)
}
}
})
}
}
})
},
// sendVideo: function() {
// var that = this
// wx.chooseVideo({
// sourceType: ['album', 'camera'],
// maxDuration: 60,
// camera: 'back',
// success: function(res) {
// console.log(res)
// var tempFilePaths = res.tempFilePath
// var str = WebIM.config.appkey.split('#')
// wx.uploadFile({
// url: 'https://a1.easemob.com/'+ str[0] + '/' + str[1] + '/chatfiles',
// filePath: tempFilePaths,
// name: 'file',
// header: {
// 'Content-Type': 'multipart/form-data'
// },
// success: function (res) {
// var data = res.data
// var dataObj = JSON.parse(data)
// console.log(dataObj)
// var id = WebIM.conn.getUniqueId(); // 生成本地消息id
// var msg = new WebIM.message('img', id);
// console.log(msg)
// var file = {
// type: 'img',
// 'url': dataObj.uri + '/' + dataObj.entities[0].uuid,
// 'filetype': 'mp4',
// 'filename': tempFilePaths
// }
// //console.log(file)
// var option = {
// apiUrl: WebIM.config.apiURL,
// body: file,
// to: that.data.yourname, // 接收消息对象
// roomType: false,
// chatType: 'singleChat'
// }
// msg.set(option)
// WebIM.conn.send(msg.body)
// if (msg) {
// //console.log(msg,msg.body.body.url)
// var time = WebIM.time()
// var msgData = {
// info: {
// to: msg.body.to
// },
// username: that.data.myName,
// yourname: msg.body.to,
// msg: {
// type: msg.type,
// data: msg.body.body.url
// },
// style: 'self',
// time: time,
// mid: msg.id
// }
// that.data.chatMsg.push(msgData)
// console.log(that.data.chatMsg)
// var myName = wx.getStorageSync('myUsername')
// wx.setStorage({
// key: that.data.yourname + myName,
// data: that.data.chatMsg,
// success: function () {
// //console.log('success', that.data)
// that.setData({
// chatMsg: that.data.chatMsg
// })
// setTimeout(function () {
// that.setData({
// toView: that.data.chatMsg[that.data.chatMsg.length - 1].mid
// })
// }, 10)
// }
// })
// }
// }
// })
// }
// })
// },
receiveImage: function (msg, type) {
var that = this
var myName = wx.getStorageSync('myUsername')
//console.log(msg)
if (msg) {
//console.log(msg)
var time = WebIM.time()
var msgData = {
info: {
from: msg.from,
to: msg.to
},
username: msg.from,
yourname: msg.from,
msg: {
type: 'img',
data: msg.url
},
style: '',
time: time,
mid: 'img' + msg.id
}
//console.log(msgData)
that.data.chatMsg.push(msgData)
//console.log(that.data.chatMsg)
wx.setStorage({
key: that.data.yourname + myName,
data: that.data.chatMsg,
success: function () {
//console.log('success', that.data)
that.setData({
chatMsg: that.data.chatMsg
})
setTimeout(function () {
that.setData({
toView: that.data.chatMsg[that.data.chatMsg.length - 1].mid
})
}, 100)
}
})
}
},
openCamera: function () {
var that = this
wx.getNetworkType({
success: function (res) {
// console.log("getNetworkType:",res)
if (res.networkType == 'none') {
wx.showModal({
title: '提示',
content: '请检查网络',
showCancel: false,
success: function (res) {
}
})
} else {
var pages = getCurrentPages()
pages[pages.length - 1].cancelEmoji()
wx.chooseImage({
count: 1,
sizeType: ['original', 'compressed'],
sourceType: ['camera'],
success: function (res) {
if (pages[pages.length - 1]) {
pages[pages.length - 1].upLoadImage(res, that)
}
}
})
}
}
})
},
focus: function () {
this.setData({
show: 'emoji_list',
view: 'scroll_view'
})
},
cancelEmoji: function () {
this.setData({
show: 'emoji_list',
view: 'scroll_view'
})
},
scroll: function (e) {
// //console.log(e)
},
lower: function (e) {
//console.log(e)
},
upLoadImage: function (res, that) {
//console.log(res)
var tempFilePaths = res.tempFilePaths
//console.log(tempFilePaths)
wx.getImageInfo({
src: res.tempFilePaths[0],
success: function (res) {
// console.log(res)
var allowType = {
'jpg': true,
'gif': true,
'png': true,
'bmp': true
};
var str = WebIM.config.appkey.split('#')
var width = res.width
var height = res.height
var index = res.path.lastIndexOf('.')
if (index != -1) {
var filetype = res.path.slice(index + 1)
}
if (filetype.toLowerCase() in allowType) {
wx.uploadFile({
url: 'https://a1.easemob.com/' + str[0] + '/' + str[1] + '/chatfiles',
filePath: tempFilePaths[0],
name: 'file',
header: {
'Content-Type': 'multipart/form-data'
},
success: function (res) {
var data = res.data
var dataObj = JSON.parse(data)
console.log("upLoadImage:", dataObj)
var id = WebIM.conn.getUniqueId(); // 生成本地消息id
var msg = new WebIM.message('img', id);
var file = {
type: 'img',
size: {
width: width,
height: height
},
'url': dataObj.uri + '/' + dataObj.entities[0].uuid,
'filetype': filetype,
'filename': tempFilePaths[0]
}
//console.log(file)
var option = {
apiUrl: WebIM.config.apiURL,
body: file,
to: that.data.yourname, // 接收消息对象
roomType: false,
chatType: 'singleChat'
}
msg.set(option)
WebIM.conn.send(msg.body)
if (msg) {
//console.log(msg,msg.body.body.url)
var time = WebIM.time()
var msgData = {
info: {
to: msg.body.to
},
username: that.data.myName,
yourname: msg.body.to,
msg: {
type: msg.type,
data: msg.body.body.url,
size: {
width: msg.body.body.size.width,
height: msg.body.body.size.height,
}
},
style: 'self',
time: time,
mid: msg.id
}
that.data.chatMsg.push(msgData)
//console.log(that.data.chatMsg)
var myName = wx.getStorageSync('myUsername')
wx.setStorage({
key: that.data.yourname + myName,
data: that.data.chatMsg,
success: function () {
//console.log('success', that.data)
that.setData({
chatMsg: that.data.chatMsg
})
setTimeout(function () {
that.setData({
toView: that.data.chatMsg[that.data.chatMsg.length - 1].mid
})
}, 10)
}
})
}
}
})
}
}
})
},
previewImage: function (event) {
var url = event.target.dataset.url
wx.previewImage({
urls: [url] // 需要预览的图片http链接列表
})
},
getNameIcon(hxName) {
var self = this
networkUtil._get(api.getDoctorHxName, { hxName: hxName }, function (res) {
// yourName = res.data.avatar
// yourIcon= res.data.username
wx.setNavigationBarTitle({
title: res.data.username
})
self.setData({
yourName: res.data.username,
yourIcon: res.data.avatar,
})
console.log("getNameIcon:", res)
}, function (res) {
})
}
})