msb-mca
/
shop-admin
mirror of http://internel-git.mashibing.cn/yanxuan-frontend/shop-admin.git
2.1k
2
Code Issues Projects Releases Wiki Activity

fix:修改文件名

Browse Source
feat-im-0607-ch
ch 2 years ago
parent ad989779a2
commit d269b48e60
6 changed files with 427 additions and 397 deletions
Show Stats Download Patch File Download Diff File

363
src/store/modules/chat/chat copy.js
Unescape View File

@ -0,0 +1,363 @@
import { login } from '@/api/chat';
import config from '@/configs';
import { ElMessage } from '@/plugins/element-plus';
import { UUID } from '@/utils/chat';
import dayjs from 'dayjs';
const state = () => ({
socket: null,
heart: null,
queue: [],
task: [],
currentSession: null,
messageList: [],
messageType: { 1: 'text', 2: 'audio', 3: 'image', 4: 'video', 5: 'revoke', 6: 'custom', 7: 'notify' },
curCustomerService: {},
sessionData: [],
customerServiceList: [],
opts: {
customerServiceType: [
{
label: '售前',
value: 1,
},
{
label: '售后',
value: 2,
},
{
label: '发货',
value: 3,
},
],
},
});
const getters = {
parseTime: () => {
return (timestamp) => {
dayjs(new Date(timestamp)).format('MM-DD HH:mm:ss');
};
},
parseText: () => {
return ({ payload, type }) => {
if (type === 2) {
payload = '[语音]';
} else if (type === 3) {
payload = '[图片]';
} else if (type === 4) {
payload = '[视频]';
} else if (type === 5) {
payload = '[撤回消息]';
} else if (type === 6 || type === 1) {
try {
// payload = JSON.parse(payload);
if ('text' in payload) {
payload = payload.text;
} else if ('linkJump' in payload) {
payload = '[超链接]';
} else if ('orderNo' in payload) {
payload = '[订单信息]';
} else if ('productImageUrl' in payload) {
payload = '[商品信息]';
} else {
payload = '[未知数据]';
}
} catch (e) {
payload = '[解析异常]';
}
} else if (type === 7) {
payload = '[撤回消息]';
} else {
payload = '[未知类型]';
}
return payload;
};
},
parseImage: () => {
return (payload) => {
try {
// payload = JSON.parse(payload);
if ('url' in payload) {
payload = payload.url;
} else {
payload = '[未知图片]';
}
} catch (e) {
payload = '[解析异常]';
}
return payload;
};
},
parseVideo: () => {
return (payload) => {
try {
// payload = JSON.parse(payload);
if ('url' in payload) {
payload = payload.url;
} else {
payload = '[未知视频]';
}
} catch (e) {
payload = '[解析异常]';
}
return payload;
};
},
parseContent: () => {
return (payload) => {
try {
// payload = JSON.parse(payload);
if ('linkJump' in payload) {
payload.type = 'link';
} else if ('orderNo' in payload) {
payload.type = 'order';
} else if ('productImageUrl' in payload) {
payload.type = 'product';
} else {
payload = '[未知消息]';
}
} catch (e) {
payload = '[解析异常]';
}
return payload;
};
},
};
const mutations = {
setSocket: (state, data) => (state.socket = data),
setHeart: (state, data) => (state.heart = data),
setTask: (state, data) => (state.task = data),
addTask: (state, data) => state.task.push(data),
delTask: (state, data) => state.task.splice(data, 1),
setCurrentSession: (state, data) => (state.currentSession = data),
setSessionData: (state, data) => (state.sessionData = data),
setMessageList: (state, data) => (state.messageList = data),
setCustomerServiceList: (state, data) => (state.customerServiceList = data),
SET_CUR_SERVICE(state, data) {
state.curCustomerService = data || {};
},
SET_SESSION_DATA(state, data) {
state.sessionData = data;
},
SET_SERVICE_LIST(state, data) {
state.customerServiceList = data;
},
};
const actions = {
/**
* 创建连接
*/
connect: async ({ state, commit, dispatch }) => {
let { ticket } = await login({ storeId: 1 });
return new Promise((resolve, reject) => {
if (window.WebSocket) {
const socket = new WebSocket(`${config.socketURL}?client=${ticket}&type=2`);
socket.onmessage = ({ data }) => {
dispatch('receive', data);
};
socket.onopen = () => {
commit(
'setHeart',
setInterval(() => {
dispatch('heart');
}, 3000)
);
console.info('[chat] open');
resolve(socket);
};
socket.onclose = () => {
clearInterval(state.heart);
console.info('[chat] close');
};
socket.onerror = (e) => {
clearInterval(state.heart);
console.info('[chat] error', e);
reject(e);
};
commit('setSocket', socket);
} else {
ElMessage.error('当前浏览器不支持 WebSocket');
reject('not support websocket');
}
});
},
/**
* 发送心跳，任务监测
*/
heart: ({ state, dispatch }) => {
dispatch('send', {
traceType: 26,
content: { storeId: 1 },
});
// console.info('[chat] heart');
state.task.forEach((item) => {
dispatch('send', item);
});
},
/**
* 执行任务
*/
invoke: ({ commit, dispatch }, data) => {
data.traceId = UUID();
commit('addTask', data);
dispatch('send', data);
},
/**
* 撤销任务
*/
revoke: ({ state, commit }, data) => {
console.info(state.task.length);
commit(
'setTask',
state.task.filter((item) => item.traceType !== data)
);
console.info(state.task.length);
},
/**
* 发送数据
*/
send: ({ state }, data) => {
if (window.WebSocket) {
if (state.socket?.readyState === WebSocket.OPEN) {
data.traceId = data.traceId || UUID();
state.socket.send(JSON.stringify(data));
if (data.traceType !== 26) {
console.info('[chat] send', data);
}
}
}
},
/**
* 接收数据
*/
receive: ({ state, commit, dispatch }, data) => {
data = JSON.parse(data);
if (data.traceType !== 0) {
let index = state.task.findIndex((item) => item.traceId === data.traceId);
if (index !== -1) {
console.info('[chat] data', data);
commit('delTask', index);
dispatch('handle', data);
} else if (data.traceType === 25) {
console.info('[chat] msg', data);
dispatch('handle', data);
} else {
console.info('[chat] deprecated', data);
}
}
},
/**
* 处理数据
*/
handle: ({ state, commit, dispatch }, { code, traceType, content }) => {
if (code === 200) {
switch (traceType) {
case 25: // 收到消息
if (content.sessionId === state.currentSession) {
commit('setMessageList', [...state.messageList, content]);
dispatch('submitRead');
} else {
dispatch('querySession');
}
break;
case 32: // 发送消息
commit('setMessageList', [...state.messageList, content]);
break;
case 27: // 会话列表
commit('setSessionData', content);
break;
case 28: // 消息列表
commit('setMessageList', [...content, ...state.messageList]);
break;
case 29: // 客服列表
commit('setCustomerServiceList', content);
break;
case 31: // 已读消息
dispatch('querySession');
break;
default:
break;
}
}
},
/**
* 查询会话列表
*/
querySession: ({ dispatch }) => {
dispatch('invoke', {
traceType: 27,
content: { storeId: 1 },
});
},
/**
* 查询会话消息列表
*/
querySessionMessage: ({ state, dispatch }, data) => {
dispatch('invoke', {
traceType: 28,
content: { sessionId: state.currentSession, size: 10, topMessageId: null, ...data },
});
},
/**
* 查询可转移客服列表
*/
queryCustomerService: ({ dispatch }) => {
dispatch('invoke', {
traceType: 29,
content: { storeId: 1 },
});
},
/**
* 提交转移会话
*/
submitTransferSession: ({ dispatch }, data) => {
dispatch('invoke', {
traceType: 30,
content: { storeId: 1, ...data },
});
},
/**
* 提交已读消息
*/
submitRead: ({ state, dispatch }) => {
dispatch('invoke', {
traceType: 31,
content: { sessionId: state.currentSession },
});
},
/**
* 提交发送消息
*/
submitMessage: ({ state, dispatch }, payload) => {
dispatch('invoke', {
traceType: 32,
content: { payload, toSessionId: state.currentSession, type: 1 },
});
},
/**
* 提交发送图片
*/
submitImage: ({ state, dispatch }, payload) => {
dispatch('invoke', {
traceType: 32,
content: { payload, toSessionId: state.currentSession, type: 3 },
});
},
/**
* 提交发送视频
*/
submitVideo: ({ state, dispatch }, payload) => {
dispatch('invoke', {
traceType: 32,
content: { payload, toSessionId: state.currentSession, type: 4 },
});
},
};
export default {
state,
getters,
mutations,
actions,
};

265
src/store/modules/chat/chat.js
Unescape View File

@ -1,18 +1,18 @@
import { login } from '@/api/chat'; /*
import config from '@/configs'; * @Author: ch
import { ElMessage } from '@/plugins/element-plus'; * @Date: 2022-06-07 15:41:05
import { UUID } from '@/utils/chat'; * @LastEditors: ch
* @LastEditTime: 2022-06-13 16:30:57
* @Description: file content
*/
import * as api from '@/api/chat';
import dayjs from 'dayjs'; import dayjs from 'dayjs';
const state = () => ({ const state = {
socket: null, curCustomerService: {},
heart: null, sessionData: [],
queue: [],
task: [],
sessionData: {},
currentSession: null,
messageList: [],
messageType: { 1: 'text', 2: 'audio', 3: 'image', 4: 'video', 5: 'revoke', 6: 'custom', 7: 'notify' },
customerServiceList: [], customerServiceList: [],
messageType: { 1: 'text', 2: 'audio', 3: 'image', 4: 'video', 5: 'revoke', 6: 'custom', 7: 'notify' },
opts: { opts: {
customerServiceType: [ customerServiceType: [
{ {
@ -29,7 +29,8 @@ const state = () => ({
}, },
], ],
}, },
}); };
const getters = { const getters = {
parseTime: () => { parseTime: () => {
return (timestamp) => { return (timestamp) => {
@ -48,7 +49,7 @@ const getters = {
payload = '[撤回消息]'; payload = '[撤回消息]';
} else if (type === 6 || type === 1) { } else if (type === 6 || type === 1) {
try { try {
payload = JSON.parse(payload); // payload = JSON.parse(payload.value);
if ('text' in payload) { if ('text' in payload) {
payload = payload.text; payload = payload.text;
} else if ('linkJump' in payload) { } else if ('linkJump' in payload) {
@ -74,7 +75,7 @@ const getters = {
parseImage: () => { parseImage: () => {
return (payload) => { return (payload) => {
try { try {
payload = JSON.parse(payload); // payload = JSON.parse(payload);
if ('url' in payload) { if ('url' in payload) {
payload = payload.url; payload = payload.url;
} else { } else {
@ -89,7 +90,7 @@ const getters = {
parseVideo: () => { parseVideo: () => {
return (payload) => { return (payload) => {
try { try {
payload = JSON.parse(payload); // payload = JSON.parse(payload);
if ('url' in payload) { if ('url' in payload) {
payload = payload.url; payload = payload.url;
} else { } else {
@ -104,7 +105,7 @@ const getters = {
parseContent: () => { parseContent: () => {
return (payload) => { return (payload) => {
try { try {
payload = JSON.parse(payload); // payload = JSON.parse(payload);
if ('linkJump' in payload) { if ('linkJump' in payload) {
payload.type = 'link'; payload.type = 'link';
} else if ('orderNo' in payload) { } else if ('orderNo' in payload) {
@ -122,223 +123,43 @@ const getters = {
}, },
}; };
const mutations = { const mutations = {
setSocket: (state, data) => (state.socket = data), SET_CUR_SERVICE(state, data) {
setHeart: (state, data) => (state.heart = data), state.curCustomerService = data || {};
setTask: (state, data) => (state.task = data),
addTask: (state, data) => state.task.push(data),
delTask: (state, data) => state.task.splice(data, 1),
setCurrentSession: (state, data) => (state.currentSession = data),
setSessionData: (state, data) => (state.sessionData = data),
setMessageList: (state, data) => (state.messageList = data),
setCustomerServiceList: (state, data) => (state.customerServiceList = data),
};
const actions = {
/**
* 创建连接
*/
connect: async ({ state, commit, dispatch }) => {
let { ticket } = await login({ storeId: 1 });
return new Promise((resolve, reject) => {
if (window.WebSocket) {
const socket = new WebSocket(`${config.socketURL}?client=${ticket}&type=2`);
socket.onmessage = ({ data }) => {
dispatch('receive', data);
};
socket.onopen = () => {
commit(
'setHeart',
setInterval(() => {
dispatch('heart');
}, 3000)
);
console.info('[chat] open');
resolve(socket);
};
socket.onclose = () => {
clearInterval(state.heart);
console.info('[chat] close');
};
socket.onerror = (e) => {
clearInterval(state.heart);
console.info('[chat] error', e);
reject(e);
};
commit('setSocket', socket);
} else {
ElMessage.error('当前浏览器不支持 WebSocket');
reject('not support websocket');
}
});
},
/**
* 发送心跳，任务监测
*/
heart: ({ state, dispatch }) => {
dispatch('send', {
traceType: 26,
content: { storeId: 1 },
});
// console.info('[chat] heart');
state.task.forEach((item) => {
dispatch('send', item);
});
}, },
/** SET_SESSION_DATA(state, data) {
* 执行任务 state.sessionData = data;
*/
invoke: ({ commit, dispatch }, data) => {
data.traceId = UUID();
commit('addTask', data);
dispatch('send', data);
}, },
/** SET_SERVICE_LIST(state, data) {
* 撤销任务 state.customerServiceList = data;
*/
revoke: ({ state, commit }, data) => {
console.info(state.task.length);
commit(
'setTask',
state.task.filter((item) => item.traceType !== data)
);
console.info(state.task.length);
}, },
/** };
* 发送数据 const actions = {
*/ queryCurCustomerService: ({ commit }) => {
send: ({ state }, data) => { api.getCustomerService().then((res) => {
if (window.WebSocket) { commit('SET_CUR_SERVICE', res);
if (state.socket?.readyState === WebSocket.OPEN) {
data.traceId = data.traceId || UUID();
state.socket.send(JSON.stringify(data));
if (data.traceType !== 26) {
console.info('[chat] send', data);
}
}
}
},
/**
* 接收数据
*/
receive: ({ state, commit, dispatch }, data) => {
data = JSON.parse(data);
if (data.traceType !== 0) {
let index = state.task.findIndex((item) => item.traceId === data.traceId);
if (index !== -1) {
console.info('[chat] data', data);
commit('delTask', index);
dispatch('handle', data);
} else if (data.traceType === 25) {
console.info('[chat] msg', data);
dispatch('handle', data);
} else {
console.info('[chat] deprecated', data);
}
}
},
/**
* 处理数据
*/
handle: ({ state, commit, dispatch }, { code, traceType, content }) => {
if (code === 200) {
switch (traceType) {
case 25: // 收到消息
if (content.sessionId === state.currentSession) {
commit('setMessageList', [...state.messageList, content]);
dispatch('submitRead');
} else {
dispatch('querySession');
}
break;
case 32: // 发送消息
commit('setMessageList', [...state.messageList, content]);
break;
case 27: // 会话列表
commit('setSessionData', content);
break;
case 28: // 消息列表
commit('setMessageList', [...content, ...state.messageList]);
break;
case 29: // 客服列表
commit('setCustomerServiceList', content);
break;
case 31: // 已读消息
dispatch('querySession');
break;
default:
break;
}
}
},
/**
* 查询会话列表
*/
querySession: ({ dispatch }) => {
dispatch('invoke', {
traceType: 27,
content: { storeId: 1 },
});
},
/**
* 查询会话消息列表
*/
querySessionMessage: ({ state, dispatch }, data) => {
dispatch('invoke', {
traceType: 28,
content: { sessionId: state.currentSession, size: 10, topMessageId: null, ...data },
}); });
}, },
/** /**
* 查询可转移客服列表 * 查询可转移客服列表
*/ */
queryCustomerService: ({ dispatch }) => { queryCustomerService: ({ commit }) => {
dispatch('invoke', { api.customerServiceList({
traceType: 29, length: 100,
content: { storeId: 1 }, pageIndex: 1,
}).then((res) => {
commit('SET_SERVICE_LIST', res.records);
}); });
}, },
/** /**
* 提交转移会话 * 提交转移会话
*/ */
submitTransferSession: ({ dispatch }, data) => { submitTransferSession: ({}, data) => {
dispatch('invoke', { api.transferCustomerService({
traceType: 30, storeId: 1,
content: { storeId: 1, ...data }, ...data,
}); }).then((res) => {
}, console.log(res, 'resresres');
/**
* 提交已读消息
*/
submitRead: ({ state, dispatch }) => {
dispatch('invoke', {
traceType: 31,
content: { sessionId: state.currentSession },
});
},
/**
* 提交发送消息
*/
submitMessage: ({ state, dispatch }, payload) => {
dispatch('invoke', {
traceType: 32,
content: { payload, toSessionId: state.currentSession, type: 1 },
});
},
/**
* 提交发送图片
*/
submitImage: ({ state, dispatch }, payload) => {
dispatch('invoke', {
traceType: 32,
content: { payload, toSessionId: state.currentSession, type: 3 },
});
},
/**
* 提交发送视频
*/
submitVideo: ({ state, dispatch }, payload) => {
dispatch('invoke', {
traceType: 32,
content: { payload, toSessionId: state.currentSession, type: 4 },
}); });
}, },
}; };

154
src/store/modules/im/im.js
Unescape View File

@ -1,154 +0,0 @@
/*
* @Author: ch
* @Date: 2022-06-07 15:41:05
* @LastEditors: ch
* @LastEditTime: 2022-06-13 14:32:42
* @Description: file content
*/
import * as api from '@/api/chat';
import dayjs from 'dayjs';
const state = {
curCustomerService: {},
sessionData: [],
customerServiceList: [],
messageType: { 1: 'text', 2: 'audio', 3: 'image', 4: 'video', 5: 'revoke', 6: 'custom', 7: 'notify' },
};
const getters = {
parseTime: () => {
return (timestamp) => {
dayjs(new Date(timestamp)).format('MM-DD HH:mm:ss');
};
},
parseText: () => {
return ({ payload, type }) => {
if (type === 2) {
payload = '[语音]';
} else if (type === 3) {
payload = '[图片]';
} else if (type === 4) {
payload = '[视频]';
} else if (type === 5) {
payload = '[撤回消息]';
} else if (type === 6 || type === 1) {
try {
// payload = JSON.parse(payload.value);
if ('text' in payload) {
payload = payload.text;
} else if ('linkJump' in payload) {
payload = '[超链接]';
} else if ('orderNo' in payload) {
payload = '[订单信息]';
} else if ('productImageUrl' in payload) {
payload = '[商品信息]';
} else {
payload = '[未知数据]';
}
} catch (e) {
payload = '[解析异常]';
}
} else if (type === 7) {
payload = '[撤回消息]';
} else {
payload = '[未知类型]';
}
return payload;
};
},
parseImage: () => {
return (payload) => {
try {
// payload = JSON.parse(payload);
if ('url' in payload) {
payload = payload.url;
} else {
payload = '[未知图片]';
}
} catch (e) {
payload = '[解析异常]';
}
return payload;
};
},
parseVideo: () => {
return (payload) => {
try {
// payload = JSON.parse(payload);
if ('url' in payload) {
payload = payload.url;
} else {
payload = '[未知视频]';
}
} catch (e) {
payload = '[解析异常]';
}
return payload;
};
},
parseContent: () => {
return (payload) => {
try {
// payload = JSON.parse(payload);
if ('linkJump' in payload) {
payload.type = 'link';
} else if ('orderNo' in payload) {
payload.type = 'order';
} else if ('productImageUrl' in payload) {
payload.type = 'product';
} else {
payload = '[未知消息]';
}
} catch (e) {
payload = '[解析异常]';
}
return payload;
};
},
};
const mutations = {
SET_CUR_SERVICE(state, data) {
state.curCustomerService = data || {};
},
SET_SESSION_DATA(state, data) {
state.sessionData = data;
},
SET_SERVICE_LIST(state, data) {
state.customerServiceList = data;
},
};
const actions = {
queryCurCustomerService: ({ commit }) => {
api.getCustomerService().then((res) => {
commit('SET_CUR_SERVICE', res);
});
},
/**
* 查询可转移客服列表
*/
queryCustomerService: ({ commit }) => {
api.customerServiceList({
length: 100,
pageIndex: 1,
}).then((res) => {
commit('SET_SERVICE_LIST', res.records);
});
},
/**
* 提交转移会话
*/
submitTransferSession: ({}, data) => {
api.transferCustomerService({
storeId: 1,
...data,
}).then((res) => {
console.log(res, 'resresres');
});
},
};
export default {
state,
getters,
mutations,
actions,
};

6
src/utils/im.js
Unescape View File

@ -2,7 +2,7 @@
* @Author: ch * @Author: ch
* @Date: 2022-06-07 15:52:37 * @Date: 2022-06-07 15:52:37
* @LastEditors: ch * @LastEditors: ch
* @LastEditTime: 2022-06-13 15:46:19 * @LastEditTime: 2022-06-13 16:18:45
* @Description: file content * @Description: file content
*/ */
import * as api from '@/api/chat'; import * as api from '@/api/chat';
@ -38,7 +38,7 @@ const ImInit = (waiterId) => {
}; };
Im.interceptors.dataChangeAfter = () => { Im.interceptors.dataChangeAfter = () => {
$store.commit('im/SET_SESSION_DATA', JSON.parse(JSON.stringify(Im.sessionData))); $store.commit('chat/SET_SESSION_DATA', JSON.parse(JSON.stringify(Im.sessionData)));
// let msgCount = 0; // let msgCount = 0;
// Im.sessionData.forEach((i) => { // Im.sessionData.forEach((i) => {
// msgCount += i.unreadCount; // msgCount += i.unreadCount;
@ -49,7 +49,7 @@ Im.interceptors.dataChangeAfter = () => {
Im.interceptors.onLogout = () => { Im.interceptors.onLogout = () => {
Im.setSessionData([]); Im.setSessionData([]);
// Im.setCurSessionId(null); // Im.setCurSessionId(null);
$store.commit('im/SET_SESSION_DATA', []); $store.commit('chat/SET_SESSION_DATA', []);
// $store.commit('SET_IM_MSG_COUNT', 0); // $store.commit('SET_IM_MSG_COUNT', 0);
}; };
export { Im, ImInit }; export { Im, ImInit };

24
src/views/chat/index.vue
Unescape View File

@ -37,12 +37,12 @@
<div class="row"> <div class="row">
<div class="session-name">{{ item.fromNickname }}</div> <div class="session-name">{{ item.fromNickname }}</div>
<div class="session-time"> <div class="session-time">
{{ store.getters['im/parseTime'](item.lastMessage.createTimeStamp) }} {{ store.getters['chat/parseTime'](item.lastMessage.createTimeStamp) }}
</div> </div>
</div> </div>
<div class="row"> <div class="row">
<div class="session-content"> <div class="session-content">
{{ store.getters['im/parseText'](item.lastMessage) }} {{ store.getters['chat/parseText'](item.lastMessage) }}
</div> </div>
</div> </div>
</div> </div>
@ -144,15 +144,15 @@
const { proxy } = getCurrentInstance(); const { proxy } = getCurrentInstance();
const router = useRouter(); const router = useRouter();
const store = useStore(); const store = useStore();
store.dispatch('im/queryCurCustomerService'); store.dispatch('chat/queryCurCustomerService');
const socketInit = () => { const socketInit = () => {
if (!store.state.im.curCustomerService.waiterId) { if (!store.state.chat.curCustomerService.waiterId) {
setTimeout(() => { setTimeout(() => {
socketInit(); socketInit();
}, 1000); }, 1000);
return false; return false;
} }
ImInit(store.state.im.curCustomerService.waiterId).then(() => { ImInit(store.state.chat.curCustomerService.waiterId).then(() => {
Im.getSessionList(); Im.getSessionList();
}); });
}; };
@ -177,7 +177,7 @@
const state = reactive({ const state = reactive({
message: '', message: '',
}); });
const sessionList = computed(() => store.state.im.sessionData); const sessionList = computed(() => store.state.chat.sessionData);
const currentSession = computed(() => sessionList.value.find((item) => item.id === currentSessionId.value)); const currentSession = computed(() => sessionList.value.find((item) => item.id === currentSessionId.value));
const handleChangeSession = (id) => { const handleChangeSession = (id) => {
currentSessionId.value = id; currentSessionId.value = id;
@ -219,7 +219,7 @@
Im.getHistoryMsg(); Im.getHistoryMsg();
}; };
const handleSendMessage = (e) => { const handleSendMessage = (e) => {
const curService = store.state.im.curCustomerService; const curService = store.state.chat.curCustomerService;
if (e && e.shiftKey) { if (e && e.shiftKey) {
state.message += '\n'; state.message += '\n';
} else { } else {
@ -282,9 +282,9 @@
}, },
], ],
}); });
const customerServiceList = computed(() => store.state.im.customerServiceList); const customerServiceList = computed(() => store.state.chat.customerServiceList);
const handleTransferSession = () => { const handleTransferSession = () => {
store.dispatch('im/queryCustomerService'); store.dispatch('chat/queryCustomerService');
transferVisible.value = true; transferVisible.value = true;
}; };
const handleConfirmTransfer = async (row) => { const handleConfirmTransfer = async (row) => {
@ -293,7 +293,7 @@
confirmButtonText: '确定', confirmButtonText: '确定',
}); });
if (res.action === 'confirm') { if (res.action === 'confirm') {
store.dispatch('im/submitTransferSession', { store.dispatch('chat/submitTransferSession', {
toWaiterId: row.waiterId, toWaiterId: row.waiterId,
sessionId: unref(currentSessionId), sessionId: unref(currentSessionId),
reason: res.value, reason: res.value,
@ -322,7 +322,7 @@
const file = e.target.files[0]; const file = e.target.files[0];
e.target.value = null; e.target.value = null;
let url = await upload('mall-product', 'im/', file); let url = await upload('mall-product', 'im/', file);
const curService = store.state.im.curCustomerService; const curService = store.state.chat.curCustomerService;
Im.sendMsg({ Im.sendMsg({
fromId: curService.waiterId, fromId: curService.waiterId,
fromAvatar: curService.waiterAvatar, fromAvatar: curService.waiterAvatar,
@ -346,7 +346,7 @@
let url = await upload('mall-product', 'im/', file); let url = await upload('mall-product', 'im/', file);
// store.dispatch('chat/submitVideo', { url }); // store.dispatch('chat/submitVideo', { url });
const curService = store.state.im.curCustomerService; const curService = store.state.chat.curCustomerService;
Im.sendMsg({ Im.sendMsg({
fromId: curService.waiterId, fromId: curService.waiterId,
fromAvatar: curService.waiterAvatar, fromAvatar: curService.waiterAvatar,

12
src/views/chat/message.vue
Unescape View File

@ -73,26 +73,26 @@
<div v-else-if="messageType[props.message.type] === 'image'" class="content shadow"> <div v-else-if="messageType[props.message.type] === 'image'" class="content shadow">
<el-image <el-image
alt="[图片消息]" alt="[图片消息]"
:src="store.getters['im/parseImage'](props.message.payload)" :src="store.getters['chat/parseImage'](props.message.payload)"
style="max-width: 240px" style="max-width: 240px"
/> />
</div> </div>
<div v-else-if="messageType[props.message.type] === 'video'" class="shadow"> <div v-else-if="messageType[props.message.type] === 'video'" class="shadow">
<video controls width="240"> <video controls width="240">
<source :src="store.getters['im/parseVideo'](props.message.payload)" type="video/mp4" /> <source :src="store.getters['chat/parseVideo'](props.message.payload)" type="video/mp4" />
<object <object
:data="store.getters['im/parseVideo'](props.message.payload)" :data="store.getters['chat/parseVideo'](props.message.payload)"
height="240" height="240"
width="320" width="320"
></object> ></object>
</video> </video>
</div> </div>
<div v-else class="content shadow"> <div v-else class="content shadow">
{{ store.getters['im/parseText'](props.message) }} {{ store.getters['chat/parseText'](props.message) }}
</div> </div>
</div> </div>
<div v-if="!['revoke', 'notify'].includes(messageType[props.message.type])" class="time"> <div v-if="!['revoke', 'notify'].includes(messageType[props.message.type])" class="time">
{{ store.getters['im/parseTime'](props.message.createTimeStamp) }} {{ store.getters['chat/parseTime'](props.message.createTimeStamp) }}
</div> </div>
</div> </div>
</template> </template>
@ -111,7 +111,7 @@
}, },
}); });
const messageType = computed(() => store.state.chat.messageType); const messageType = computed(() => store.state.chat.messageType);
const content = computed(() => store.getters['im/parseContent']({ ...props.message.payload })); const content = computed(() => store.getters['chat/parseContent']({ ...props.message.payload }));
const handleProduct = (id) => { const handleProduct = (id) => {
router.push({ router.push({
name: 'UpdateProduct', name: 'UpdateProduct',

Write Preview
Loading…
Cancel
Save