283 lines
9.4 KiB
JavaScript
283 lines
9.4 KiB
JavaScript
|
new Vue({
|
||
|
|
el: '#app',
|
||
|
|
delimiters:["<{","}>"],
|
||
|
|
data: {
|
||
|
|
window:window,
|
||
|
|
server:getWsBaseUrl()+"/ws_visitor",
|
||
|
|
socket:null,
|
||
|
|
socketClosed:false,
|
||
|
|
msgList:[],
|
||
|
|
messageContent:"",
|
||
|
|
visitor:{},
|
||
|
|
flyLang:KEFU_LANG[LANG],
|
||
|
|
textareaFocused:false,
|
||
|
|
sendDisabled:false,
|
||
|
|
face:emojiGifsMap(),
|
||
|
|
websocketOpenNum:0,//websocket打开次数
|
||
|
|
websocketMaxOpenNum:10,//websocket最大打开次数
|
||
|
|
fullscreenLoading:false,//loading
|
||
|
|
nameDialog:true,
|
||
|
|
nickname:"",
|
||
|
|
entId:getQuery("ent_id"),
|
||
|
|
roomId:getQuery("room_id"),
|
||
|
|
showFaceIcon:false,
|
||
|
|
},
|
||
|
|
methods: {
|
||
|
|
//初始化websocket
|
||
|
|
initConn:function() {
|
||
|
|
this.socket = new ReconnectingWebSocket(this.server+"?visitor_id="+this.visitor.visitor_id+"&to_id="+this.visitor.to_id+"&room_id="+this.visitor.to_id);//创建Socket实例
|
||
|
|
this.socket.debug = true;
|
||
|
|
this.socket.onmessage = this.OnMessage;
|
||
|
|
this.socket.onopen = this.OnOpen;
|
||
|
|
this.socket.onerror = this.OnError;
|
||
|
|
this.socket.onclose = this.OnClose;
|
||
|
|
},
|
||
|
|
OnOpen:function() {
|
||
|
|
//限制最大打开次数
|
||
|
|
if(this.websocketOpenNum>=this.websocketMaxOpenNum){
|
||
|
|
this.socket.close();
|
||
|
|
this.socketClosed=true;
|
||
|
|
this.fullscreenLoading=true;
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.websocketOpenNum++;
|
||
|
|
console.log("ws:onopen");
|
||
|
|
this.socketClosed=false;
|
||
|
|
this.fullscreenLoading=false;
|
||
|
|
},
|
||
|
|
OnMessage:function(e) {
|
||
|
|
console.log("ws:onmessage");
|
||
|
|
this.fullscreenLoading=false;
|
||
|
|
const redata = JSON.parse(e.data);
|
||
|
|
if (redata.type == "userOnline") {
|
||
|
|
let msg = redata.data
|
||
|
|
if(!msg){
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.showTitle(msg.username);
|
||
|
|
this.$notify({
|
||
|
|
dangerouslyUseHTMLString: true,
|
||
|
|
message: '<span style="line-height: 40px"><img style="float: left;margin-right: 5px;" class="el-avatar el-avatar--circle" src="'+msg.avator+'"/>'+msg.username+'</span>',
|
||
|
|
});
|
||
|
|
}
|
||
|
|
if (redata.type == "notice") {
|
||
|
|
let msg = redata.data
|
||
|
|
if(!msg){
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
this.showTitle(msg);
|
||
|
|
this.scrollBottom();
|
||
|
|
}
|
||
|
|
if (redata.type == "close") {
|
||
|
|
|
||
|
|
this.scrollBottom();
|
||
|
|
this.socket.close();
|
||
|
|
this.socketClosed=true;
|
||
|
|
}
|
||
|
|
if (redata.type == "force_close") {
|
||
|
|
|
||
|
|
this.scrollBottom();
|
||
|
|
this.socket.close();
|
||
|
|
this.socketClosed=true;
|
||
|
|
}
|
||
|
|
if (redata.type == "auto_close") {
|
||
|
|
this.scrollBottom();
|
||
|
|
this.socket.close();
|
||
|
|
}
|
||
|
|
if (redata.type == "message") {
|
||
|
|
let msg = redata.data
|
||
|
|
if(msg.id==this.visitor.visitor_id){
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
let content = {}
|
||
|
|
content.avator = msg.avator;
|
||
|
|
content.name = msg.name;
|
||
|
|
content.content =replaceContent(msg.content);
|
||
|
|
content.is_kefu = false;
|
||
|
|
content.time = msg.time;
|
||
|
|
this.msgList.push(content);
|
||
|
|
this.scrollBottom();
|
||
|
|
}
|
||
|
|
window.parent.postMessage(redata,"*");
|
||
|
|
},
|
||
|
|
OnClose:function() {
|
||
|
|
console.log("ws:onclose");
|
||
|
|
this.fullscreenLoading=true;
|
||
|
|
this.socketClosed=true;
|
||
|
|
},
|
||
|
|
OnError:function() {
|
||
|
|
console.log("ws:onerror");
|
||
|
|
this.fullscreenLoading=true;
|
||
|
|
this.socketClosed=true;
|
||
|
|
},
|
||
|
|
//初始化用户信息
|
||
|
|
initUserInfo:function(){
|
||
|
|
var entId=this.entId;
|
||
|
|
var roomId=this.roomId;
|
||
|
|
if(entId==""||roomId==""){
|
||
|
|
this.$message({
|
||
|
|
message: "error:ent_id,room_id",
|
||
|
|
type: 'error'
|
||
|
|
});
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
var visitorId="";
|
||
|
|
var avator="";
|
||
|
|
var toId=roomId;
|
||
|
|
var obj=getLocalStorage("chatroom_"+roomId);
|
||
|
|
if(obj){
|
||
|
|
visitorId=obj.visitor_id;
|
||
|
|
toId=obj.to_id;
|
||
|
|
avator=obj.avator;
|
||
|
|
}
|
||
|
|
var params={visitor_id:visitorId,
|
||
|
|
to_id:toId,
|
||
|
|
ent_id:entId,
|
||
|
|
visitor_name:this.nickname,
|
||
|
|
avator:avator
|
||
|
|
};
|
||
|
|
var _this=this;
|
||
|
|
this.sendAjax("/room/login","post",params,function(data){
|
||
|
|
setLocalStorage("chatroom_"+roomId,data);
|
||
|
|
_this.visitor=data;
|
||
|
|
_this.initConn();
|
||
|
|
_this.ping();
|
||
|
|
})
|
||
|
|
},
|
||
|
|
//滚动到底部
|
||
|
|
scrollBottom:function(){
|
||
|
|
var _this=this;
|
||
|
|
this.$nextTick(function(){
|
||
|
|
$('.chatRoomMessageBox').scrollTop($(".chatRoomMessageBox")[0].scrollHeight);
|
||
|
|
});
|
||
|
|
},
|
||
|
|
chatToUser:function() {
|
||
|
|
if(this.socketClosed){
|
||
|
|
this.initConn();
|
||
|
|
// this.$message({
|
||
|
|
// message: KEFU_LANG[LANG]['socketclose'],
|
||
|
|
// type: 'warning'
|
||
|
|
// });
|
||
|
|
// return;
|
||
|
|
}
|
||
|
|
var messageContent=this.messageContent.trim("\r\n");
|
||
|
|
messageContent=messageContent.replace("\n","");
|
||
|
|
messageContent=messageContent.replace("\r\n","");
|
||
|
|
if(messageContent==""||messageContent=="\r\n"){
|
||
|
|
this.messageContent="";
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
this.messageContent=messageContent;
|
||
|
|
this.sendDisabled=true;
|
||
|
|
let _this=this;
|
||
|
|
let content = {}
|
||
|
|
content.avator=_this.visitor.avator;
|
||
|
|
content.content = replaceContent(_this.messageContent);
|
||
|
|
content.name = _this.visitor.name;
|
||
|
|
content.is_kefu = true;
|
||
|
|
content.time = "";
|
||
|
|
content.show_time=false;
|
||
|
|
_this.msgList.push(content);
|
||
|
|
_this.scrollBottom();
|
||
|
|
|
||
|
|
let mes = {};
|
||
|
|
mes.type = "visitor";
|
||
|
|
mes.content = this.messageContent;
|
||
|
|
mes.from_id = this.visitor.visitor_id;
|
||
|
|
mes.to_id = this.visitor.to_id;
|
||
|
|
mes.content = this.messageContent;
|
||
|
|
$.post("/room/message",mes,function(res){
|
||
|
|
_this.sendDisabled=false;
|
||
|
|
if(res.code!=200){
|
||
|
|
_this.msgList.pop();
|
||
|
|
_this.$message({
|
||
|
|
message: res.msg,
|
||
|
|
type: 'error'
|
||
|
|
});
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
_this.messageContent = "";
|
||
|
|
_this.sendDisabled=false;
|
||
|
|
});
|
||
|
|
},
|
||
|
|
//发送ajax
|
||
|
|
sendAjax:function(url,method,params,callback){
|
||
|
|
let _this=this;
|
||
|
|
$.ajax({
|
||
|
|
type: method,
|
||
|
|
url: url,
|
||
|
|
data:params,
|
||
|
|
error:function(res){
|
||
|
|
var data=JSON.parse(res.responseText);
|
||
|
|
console.log(data);
|
||
|
|
if(data.code!=200){
|
||
|
|
_this.$message({
|
||
|
|
message: data.msg,
|
||
|
|
type: 'error'
|
||
|
|
});
|
||
|
|
}
|
||
|
|
},
|
||
|
|
success: function(data) {
|
||
|
|
if(data.code!=200){
|
||
|
|
_this.$message({
|
||
|
|
message: data.msg,
|
||
|
|
type: 'error'
|
||
|
|
});
|
||
|
|
}else if(data.result!=null){
|
||
|
|
callback(data.result);
|
||
|
|
}else{
|
||
|
|
callback(data);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
});
|
||
|
|
},
|
||
|
|
showTitle:function(title){
|
||
|
|
$(".chatBox").append("<div class=\"chatTime\"><span>"+title+"</span></div>");
|
||
|
|
this.scrollBottom();
|
||
|
|
},
|
||
|
|
//表情点击事件
|
||
|
|
faceIconClick:function(index){
|
||
|
|
$('.faceBox').hide();
|
||
|
|
this.messageContent+="face"+this.face[index].name;
|
||
|
|
},
|
||
|
|
initCss:function(){
|
||
|
|
var nickname=getLocalStorage("chatroom_nickname_"+this.roomId);
|
||
|
|
if(nickname!=""){
|
||
|
|
this.nickname=nickname;
|
||
|
|
this.nameDialog=false;
|
||
|
|
this.initUserInfo();
|
||
|
|
}
|
||
|
|
},
|
||
|
|
//心跳
|
||
|
|
ping:function(){
|
||
|
|
let _this=this;
|
||
|
|
let mes = {}
|
||
|
|
mes.type = "ping";
|
||
|
|
mes.data = "visitor:"+_this.visitor.visitor_id;
|
||
|
|
setInterval(function () {
|
||
|
|
if(_this.socket!=null&&!this.socketClosed){
|
||
|
|
_this.socket.send(JSON.stringify(mes));
|
||
|
|
}
|
||
|
|
},55000);
|
||
|
|
|
||
|
|
},
|
||
|
|
//开始
|
||
|
|
startChat:function(){
|
||
|
|
if(this.nickname==""){
|
||
|
|
this.$message.error('请填写昵称');
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
setLocalStorage("chatroom_nickname_"+this.roomId,this.nickname)
|
||
|
|
this.nameDialog = false;
|
||
|
|
this.initUserInfo();
|
||
|
|
}
|
||
|
|
},
|
||
|
|
mounted:function() {
|
||
|
|
|
||
|
|
},
|
||
|
|
created: function () {
|
||
|
|
this.initCss();
|
||
|
|
}
|
||
|
|
})
|