117 lines
2.8 KiB
JavaScript
117 lines
2.8 KiB
JavaScript
import { defineStore } from "pinia";
|
|
// import * as shopApi from "@/http/api/shop.js";
|
|
|
|
// #ifdef H5
|
|
const socketUrl = "http://192.168.1.42:2348";
|
|
// #endif
|
|
// #ifndef H5
|
|
const socketUrl = "ws://192.168.1.42:2348";
|
|
// #endif
|
|
|
|
// 聊天
|
|
export const useChatStore = defineStore("chat", {
|
|
state: () => {
|
|
return {
|
|
socketUrl,
|
|
isConnect: false,
|
|
socketTask: null,
|
|
onReceiveMsg: () => {},
|
|
chatList: [],
|
|
};
|
|
},
|
|
actions: {
|
|
init() {
|
|
if (!this.isConnect) {
|
|
return uni.showToast({
|
|
title: "请先连接socket",
|
|
icon: "none",
|
|
});
|
|
}
|
|
this.sendMessage(
|
|
{
|
|
type: "OnbocChat",
|
|
operate_type: "init",
|
|
shop_id: uni.getStorageSync("shopId"),
|
|
token: uni.getStorageSync("iToken").tokenValue || "",
|
|
},
|
|
false
|
|
);
|
|
},
|
|
sendMessage(msg, isAutoAppend = true) {
|
|
if (!this.isConnect) {
|
|
return uni.showToast({
|
|
title: "请先连接socket",
|
|
icon: "none",
|
|
});
|
|
}
|
|
console.log(this.socketTask);
|
|
const message = isAutoAppend
|
|
? {
|
|
type: "OnbocChat",
|
|
operate_type: "sendMsg",
|
|
shop_id: uni.getStorageSync("shopId"),
|
|
token: uni.getStorageSync("iToken").tokenValue || "",
|
|
...msg,
|
|
}
|
|
: msg;
|
|
this.socketTask.send({
|
|
data: JSON.stringify(message),
|
|
success: (res) => {
|
|
console.log("发送成功", res);
|
|
},
|
|
fail: (error) => {
|
|
console.log("发送失败", error);
|
|
},
|
|
});
|
|
},
|
|
connectSocket() {
|
|
this.socketTask = uni.connectSocket({
|
|
url: socketUrl,
|
|
success: (res) => {},
|
|
fail: (res) => {
|
|
console.log(res);
|
|
},
|
|
});
|
|
|
|
this.socketTask.onOpen((res) => {
|
|
this.isConnect = true;
|
|
this.init();
|
|
});
|
|
|
|
this.socketTask.onMessage((res) => {
|
|
const data = JSON.parse(res.data);
|
|
console.log("收到服务器消息", data);
|
|
if (data.msg) {
|
|
uni.showToast({
|
|
title: data.msg,
|
|
icon: "none",
|
|
});
|
|
}
|
|
|
|
if (data && data.operate_type == "sendMsg") {
|
|
this.chatList.unshift(data.data);
|
|
this.onReceiveMsg(data.data);
|
|
console.log(this.chatList);
|
|
}
|
|
});
|
|
|
|
this.socketTask.onError((res) => {
|
|
this.isConnect = false;
|
|
console.log("连接错误", res);
|
|
});
|
|
|
|
this.socketTask.onClose(() => {
|
|
this.isConnect = false;
|
|
console.log("连接已关闭");
|
|
this.connectSocket();
|
|
});
|
|
},
|
|
|
|
closeSocket() {
|
|
this.socketTask.close();
|
|
this.isConnect = false;
|
|
},
|
|
},
|
|
unistorage: false, // 开启后对 state 的数据读写都将持久化
|
|
});
|