// pages/childDetails/childDetails.js
// 网络请求工具类
var networkUtil = require('../../utils/network_util.js')
var api = require('../../utils/apiFile.js')
//聊天工具类
let msgStorage = require("./chat/msgstorage");
let disp = require("../../utils/broadcast");
let WebIM = require("../../utils/WebIM")["default"];
let msgType = require("./chat/msgtype");
// 获取应用实例
var app = getApp();
let LIST_STATUS = {
SHORT: "scroll_view_change",
NORMAL: "scroll_view"
};
let page = 0;
let Index = 0;
let isFail = false;
let RECORD_CONST = require("./audio/record_status");
let RecordStatus = RECORD_CONST.RecordStatus;
let RecordDesc = RECORD_CONST.RecordDesc;
let RunAnimation = false
const InitHeight = [50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50, 50]
Page({
/**
* 页面的初始数据
*/
data: {
changedTouches: null,
userData:[],
illnessValue:'',
type:0,
memberId:0,
serviceId:0,
doctorHxName:'',
doctorName:'',
kfHxName:'',
kfName:'',
memberHxName:'',
memberName:'',
unTotleReadCount:0,
chatMsg: [],
username:'',
bubbles:false,
isShowRecordingBtn:false,
RecordDesc, // 模板中有引用
recorderManager: wx.getRecorderManager(),
recordClicked: false,
recordStatus: RecordStatus.HIDE,
RecordStatus,
radomheight: InitHeight,
},
/**
* 生命周期函数--监听页面加载
*/
onLoad: function (options) {
let self=this;
var options=JSON.parse(options.username)
networkUtil._post(api.addBabyChatroom,{doctorId:options.doctorId},function(res){
console.log(res)
self.setData({
memberId:options.memberId,
serviceId:options.serviceId,
doctorHxName:res.data.data.doctorHxName,
doctorName:res.data.data.doctorName,
kfHxName:res.data.data.kfHxName,
kfName:res.data.data.kfName,
memberHxName:res.data.data.memberHxName,
memberName:res.data.data.memberName,
username:res.data.data.chatroomId
})
self.initChat()
},function(res){
},'application/json')
self.initChat()
disp.on('em.xmpp.error.sendMsgErr', function(err) {
curMsgMid = err.data.mid
isFail = true
return
console.log('发送失败了')
let msgList = me.data.chatMsg
msgList.map((item) =>{
if (item.mid.substring(item.mid.length - 10) == curMsgMid.substring(curMsgMid.length - 10)) {
item.msg.data[0].isFail = true
item.isFail = true
me.setData({
chatMsg: msgList
})
}
})
if (me.curChatMsg[0].mid == curMsgMid) {
me.curChatMsg[0].msg.data[0].isShow = false;
me.curChatMsg[0].isShow = false
}
wx.setStorageSync("rendered_" + sessionKey, msgList);
});
},
/**
* 生命周期函数--监听页面初次渲染完成
*/
onReady: function (e) {
},
/**
* 生命周期函数--监听页面显示
*/
onShow: function () {
},
/**
* 生命周期函数--监听页面隐藏
*/
onHide: function () {
},
/**
* 生命周期函数--监听页面卸载
*/
onUnload: function () {
},
/**
* 页面相关事件处理函数--监听用户下拉动作
*/
onPullDownRefresh: function () {
},
/**
* 页面上拉触底事件的处理函数
*/
onReachBottom: function () {
},
/**
* 用户点击右上角分享
*/
onShareAppMessage: function () {
},
// 初始化聊天数据
initChat () {
//聊天功能
let me = this;
let username = this.data.username;
let myUsername = wx.getStorageSync("hxName");
let sessionKey = username.groupId
? username + myUsername
: username + myUsername;
let chatMsg = wx.getStorageSync(sessionKey) || [];
this.renderMsg(null, null, chatMsg, sessionKey);
wx.setStorageSync(sessionKey, null);
},
//获取儿童信息
requestData(id) {
var self = this
networkUtil.showLoading()
networkUtil._get(api.getBabyInfo , {memberId:id}, function (res) {
if(0 == res.data.errorcode){
self.setData({
userData: res.data.babyInfo
})
}
}, function (res) {
networkUtil.showErrorToast(res.errormsg)
})
},
//跳转血糖值
gohisSuger(){
var id = this.data.memberId;
wx.navigateTo({
url: "../historicalSymptoms/historicalSymptoms?memberId="+id,
})
},
//结束咨询
endConsultation(){
var id = this.data.serviceId;
var that = this;
wx.showModal({
title: '确认',
content: '请确认是否要结束',
showCancel: true,
success: function(res) {
if (res.confirm) {
networkUtil.showLoading()
networkUtil._get(api.serviceEnd , {serviceId:id}, function (res) {
if(0 == res.data.errorcode){
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('hxName')
var id = WebIM.conn.getUniqueId();
var msg = new WebIM.message('txt', id);
msg.set({
msg: '医生已结束咨询服务',
from: myName,
to: that.data.username,
roomType: false,
ext:{
isEnding:true,
serviceId:that.data.serviceId
},
success: function (id, serverMsgId) {
console.log(' sendMessage success')
}, fail: function (error) {
console.log("sendMessage error:" + error)
}
});
console.log('发送消息', msg)
msg.body.chatType = 'chatRoom';
msg.body.group = 'groupchat' ;
msg.body.from = myName
WebIM.conn.send(msg.body);
}
}
})
wx.navigateBack({
delta: 1,
})
}
}, function (res) {
wx.showModal({
title: '服务器异常',
content: err.errormsg,
showCancel: false
});
})
} else if (res.cancel) {
console.log('用户点击取消')
}
},
});
},
//消息发送
bindMessage(e){
//console.log(e.detail.value)
this.setData({
userMessage: e.detail.value
});
if(this.data.userMessage){
this.setData({
bubbles:true
})
}else{
this.setData({
bubbles:false
})
}
},
sendMessage: function () {
String.prototype.trim=function()
{
return this.replace(/(^\s*)|(\s*$)/g, '');
}
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('hxName')
var id = WebIM.conn.getUniqueId();
var msg = new WebIM.message('txt', id);
msg.set({
msg: that.data.userMessage,
to: that.data.username,
roomType: false,
ext:{
serviceId:that.data.serviceId
},
success: function (id, serverMsgId) {
console.log(' sendMessage success')
}, fail: function (error) {
console.log("sendMessage error:" + error)
}
});
console.log('发送消息', msg)
msg.body.chatType = 'chatRoom';
msg.body.group = 'groupchat' ;
msg.body.from = myName
WebIM.conn.send(msg.body);
that.triggerEvent(
"newTextMsg",
{
msg: msg,
type: msgType.TEXT,
},
{
bubbles: true,
composed: true
}
);
if (msg) {
var value = WebIM.parseEmoji(msg.value.replace(/\n/mg, ''))
var time = WebIM.time()
var msgData = {
info: {
to: msg.body.to
},
username: 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)
var sessionKey = that.data.username + myName;
var historyChatMsgs = wx.getStorageSync("rendered_" + sessionKey) || [];
historyChatMsgs.push(msgData);
// 消息提醒音效
// const innerAudioContext = wx.createInnerAudioContext();
// innerAudioContext.src = '../../source/maide/9411.mp3';
// innerAudioContext.play();
// innerAudioContext.onPlay(() => {
// console.log('开始播放')
// })
// innerAudioContext.onError((res) => {
// console.log(res.errMsg)
// console.log(res.errCode)
// })
wx.vibrateLong({
success:function() {
console.log('震动调取成功')
},
})
wx.setStorage({
key: "rendered_" + that.data.username + myName,
data: historyChatMsgs,
success: function () {
//console.log('success', that.data)
that.setData({
chatMsg: that.data.chatMsg,
emojiList: [],
inputMessage: '',
bubbles:false
})
that.onRender();
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('hxName')
if (msg.from == that.data.username || msg.to == that.data.username) {
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: msg.from,
yourname: msg.from,
msg: {
type: type,
data: value,
url: msg.url
},
style: '',
time: time,
mid: msg.type + msg.id
}
if (type == 'audio') {
msgData.msg.length = msg.length,
msgData.msg.token = msg.accessToken
}
if (msg.from !== myName) {
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)
var sessionKey = that.data.username + myName ;
var historyChatMsgs = wx.getStorageSync("rendered_" + sessionKey) || [];
//console.log('当前历史',renderableMsg)
//console.log('历史消息', historyChatMsgs)
historyChatMsgs.push(msgData);
wx.vibrateLong({
success:function() {
console.log('震动调取成功')
},
})
wx.setStorage({
key: "rendered_" + that.data.username + myName,
data: historyChatMsgs,
success: function () {
console.log('success接收保存', that.data)
that.setData({
chatMsg: that.data.chatMsg,
})
that.onRender();
setTimeout(function () {
that.setData({
toView: that.data.chatMsg[that.data.chatMsg.length - 1].mid
})
}, 100)
}
})
}
},
renderMsg(renderableMsg, type, curChatMsg, sessionKey, isnew){
let me = this
var historyChatMsgs = wx.getStorageSync("rendered_" + sessionKey) || [];
//console.log('当前历史',renderableMsg)
console.log('历史消息', historyChatMsgs)
if(curChatMsg !== []){
historyChatMsgs = historyChatMsgs.concat(curChatMsg);
wx.setStorageSync(sessionKey, []);
app.globalData.unrederMsg[sessionKey] = [];
}
if(!historyChatMsgs.length) return;
this.setData({
chatMsg: historyChatMsgs.slice(-10),
// 跳到最后一条
toView: historyChatMsgs[historyChatMsgs.length - 1].mid,
});
wx.setStorageSync("rendered_" + sessionKey, historyChatMsgs);
Index = historyChatMsgs.slice(-10).length;
wx.pageScrollTo({
scrollTop: 5000,
duration: 300,
})
this.triggerEvent('render')
},
onPullDownRefresh: function () {
if (app.globalData.token == null || app.globalData.token == '') {
wx.stopPullDownRefresh()
return
}
var that = this;
// 下拉获取数据
that.historyMsgs();
},
//获取历史聊天记录
historyMsgs : function () {
wx.showToast({
title: '加载中...' ,
icon: 'loading',
duration: 300
})
let me = this
let username = this.data.username;
let myUsername = wx.getStorageSync("hxName");
let sessionKey = username + myUsername;
let historyChatMsgs = wx.getStorageSync("rendered_" + sessionKey) || [];
if (Index < historyChatMsgs.length) {
let timesMsgList = historyChatMsgs.slice(-Index-10, -Index)
this.setData({
chatMsg: timesMsgList.concat(me.data.chatMsg),
toView: timesMsgList[timesMsgList.length - 1].mid,
});
Index += timesMsgList.length;
if (timesMsgList.length == 10) {
page ++
}
wx.stopPullDownRefresh()
}
},
onRender(){
wx.pageScrollTo({
scrollTop: 50000,
duration: 300,
success: function(){console.log('滚动成功')},
fail: function(){console.log('滚动失败')}
})
},
previewImage(event){
var url = event.target.dataset.url;
wx.previewImage({
urls: [url] // 需要预览的图片 http 链接列表
});
},
sendImage(){
var me = this;
wx.chooseImage({
count: 1,
sizeType: ["original", "compressed"],
sourceType: ["album"],
success(res){
me.upLoadImage(res);
},
});
},
openCamera(){
var me = this;
wx.chooseImage({
count: 1,
sizeType: ["original", "compressed"],
sourceType: ["camera"],
success(res){
me.upLoadImage(res);
}
});
},
upLoadImage(res){
var me = this;
var tempFilePaths = res.tempFilePaths;
var token = WebIM.conn.context.accessToken
wx.getImageInfo({
src: res.tempFilePaths[0],
success(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(".");
var filetype = (~index && 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",
Authorization: "Bearer " + token
},
success(res){
if(res.statusCode === 400){
// 图片上传阿里云检验不合法
var errData = JSON.parse(res.data);
if (errData.error === 'content improper') {
wx.showToast({
title: '图片不合法'
});
return false
}
}
var data = res.data;
var dataObj = JSON.parse(data);
var id = WebIM.conn.getUniqueId(); // 生成本地消息 id
var msg = new WebIM.message('img', id);
var myName = wx.getStorageSync('hxName')
var file = {
type: 'img',
size: {
width: width,
height: height
},
url: dataObj.uri + "/" + dataObj.entities[0].uuid,
filetype: filetype,
filename: tempFilePaths[0]
};
msg.set({
apiUrl: WebIM.config.apiURL,
body: file,
from: myName,
to: me.data.username,
ext:{
serviceId:me.data.serviceId
},
roomType: false,
chatType: 'chatRoom',
success: function (argument) {
disp.fire('em.chat.sendSuccess', id);
}
});
msg.body.group = 'groupchat';
WebIM.conn.send(msg.body);
if(msg){
var time = WebIM.time();
var msgData = {
info: {
to: msg.body.to
},
username: myName,
yourname: msg.body.to,
msg: {
type: msg.type,
data: msg.body.body.url,
url:msg.body.body.url,
size: {
width: msg.body.body.size.width,
height: msg.body.body.size.height,
}
},
style: 'self',
time: time,
mid: msg.id
}
}
me.data.chatMsg.push(msgData)
var sessionKey = me.data.username + myName;
var historyChatMsgs = wx.getStorageSync("rendered_" + sessionKey) || [];
historyChatMsgs.push(msgData);
wx.vibrateLong({
success:function() {
console.log('震动调取成功')
},
})
wx.setStorage({
key: "rendered_" + me.data.username + myName,
data: historyChatMsgs,
success: function () {
console.log('success发送图片', me.data)
me.setData({
chatMsg: me.data.chatMsg,
})
me.onRender();
setTimeout(function () {
me.setData({
toView: me.data.chatMsg[me.data.chatMsg.length - 1].mid
})
}, 100)
}
})
}
});
}
}
});
},
// 录音开始
showRecordingBtn(){
this.setData({
isShowRecordingBtn:!this.data.isShowRecordingBtn
})
},
handleRecordingMove(e){
var touches = e.touches[0];
var changedTouches = this.data.changedTouches;
if(!changedTouches){
return;
}
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(e){
let me = this;
wx.vibrateShort({
success:function() {
console.log('震动调取成功')
},
})
me.setData({
recordClicked: true
})
setTimeout(() => {
if (me.data.recordClicked == true) {
executeRecord()
}
}, 350)
function executeRecord(){
wx.getSetting({
success: (res) => {
let recordAuth = res.authSetting['scope.record']
if (recordAuth == false) { //已申请过授权，但是用户拒绝
wx.openSetting({
success: function (res) {
let recordAuth = res.authSetting['scope.record']
if (recordAuth == true) {
wx.showToast({
title: "授权成功",
icon: "success"
})
} else {
wx.showToast({
title: "请授权录音",
icon: "none"
})
}
me.setData({
isLongPress: false
})
}
})
} else if (recordAuth == true) { // 用户已经同意授权
startRecord()
} else { // 第一次进来，未发起授权
wx.authorize({
scope: 'scope.record',
success: () => {//授权成功
wx.showToast({
title: "授权成功",
icon: "success"
})
}
})
}
},
fail: function () {
wx.showToast({
title: "鉴权失败，请重试",
icon: "none"
})
}
})
}
function startRecord(){
me.data.changedTouches = e.touches[0];
me.setData({
recordStatus: RecordStatus.HOLD
});
RunAnimation = true;
me.myradom();
let recorderManager = me.data.recorderManager || wx.getRecorderManager();
recorderManager.onStart(() => {
// console.log("开始录音...");
});
recorderManager.start({
format: "mp3"
});
// 超时
setTimeout(function(){
me.handleRecordingCancel();
RunAnimation = false
}, 100000);
}
},
handleRecordingCancel(){
RunAnimation = false
let recorderManager = this.data.recorderManager;
// 向上滑动状态停止：取消录音发放
if(this.data.recordStatus == RecordStatus.SWIPE){
this.setData({
recordStatus: RecordStatus.RELEASE
});
}
else{
this.setData({
recordStatus: RecordStatus.HIDE,
recordClicked: false
});
}
recorderManager.onStop((res) => {
console.log("结束录音...", res);
if(this.data.recordStatus == RecordStatus.RELEASE){
console.log("user canceled");
this.setData({
recordStatus: RecordStatus.HIDE
});
return;
}
if (res.duration < 1000) {
wx.showToast({
title: "录音时间太短",
icon: "none"
})
} else {
// 上传
this.uploadRecord(res.tempFilePath, res.duration);
}
});
// 停止录音
recorderManager.stop();
},
uploadRecord(tempFilePath, dur){
var str = WebIM.config.appkey.split("#");
var me = this;
var token = WebIM.conn.context.accessToken;
var myName = wx.getStorageSync('hxName')
wx.uploadFile({
url: "https://a1.easemob.com/" + str[0] + "/" + str[1] + "/chatfiles",
filePath: tempFilePath,
name: "file",
header: {
"Content-Type": "multipart/form-data",
Authorization: "Bearer " + token
},
success(res){
// 发送 xmpp 消息
var id = WebIM.conn.getUniqueId();
var msg = new WebIM.message(msgType.AUDIO, id);
var dataObj = JSON.parse(res.data);
msg.from = myName;
// 接收消息对象
msg.set({
apiUrl: WebIM.config.apiURL,
accessToken: token,
body: {
type: msgType.AUDIO,
url: dataObj.uri + "/" + dataObj.entities[0].uuid,
filetype: "",
filename: tempFilePath,
accessToken: token,
length: Math.ceil(dur / 1000)
},
from: myName,
ext:{
serviceId:me.data.serviceId
},
to: me.data.username,
roomType: false,
chatType: 'chatRoom',
success: function (argument) {
disp.fire('em.chat.sendSuccess', id);
}
});
var msglength = Math.ceil(dur / 1000);
//console.log('发送的语音消息', msg.body)
msg.body.group = 'groupchat';
WebIM.conn.send(msg.body);
if(msg){
var time = WebIM.time();
var msgData = {
info: {
from: msg.from,
to: msg.to
},
username: msg.from,
yourname: msg.from,
msg: {
type: 'audio',
data: msg.body.body.url,
url: msg.body.body.url,
token:token,
length:msglength,
},
style: 'self',
time: time,
mid: 'audio' + msg.id
}
me.data.chatMsg.push(msgData)
var sessionKey = me.data.username + myName;
var historyChatMsgs = wx.getStorageSync("rendered_" + sessionKey) || [];
historyChatMsgs.push(msgData);
console.log(historyChatMsgs)
wx.vibrateLong({
success:function() {
console.log('震动调取成功')
},
})
wx.setStorage({
key: "rendered_" + me.data.username + myName,
data: historyChatMsgs,
success: function () {
console.log('success发送图片', me.data)
me.setData({
chatMsg: me.data.chatMsg,
})
me.onRender();
setTimeout(function () {
me.setData({
toView: me.data.chatMsg[me.data.chatMsg.length - 1].mid
})
}, 100)
}
})
}
}
});
},
myradom(){
const that = this;
var _radomheight = that.data.radomheight;
for (var i = 0; i < that.data.radomheight.length; i++) {
//+1是为了避免为0
_radomheight[i] = (100 * Math.random().toFixed(2))+10;
}
that.setData({
radomheight: _radomheight
});
if (RunAnimation) {
setTimeout(function () {that.myradom(); }, 300);
}else{
return
}
}
})