680 lines
27 KiB
JavaScript
680 lines
27 KiB
JavaScript
// pages/messages/messages.js
|
|
const app = getApp();
|
|
import { formatDate } from '../../static/lib/utils';
|
|
import { resolveAvatarUrl, getDefaultAvatarUrl, resolveAvatarFromStorage } from '../../utils/avatar.js';
|
|
import { getLocalImUserId, getLocalImIdentity, getImUserIdForRole, loadGroupMetaCache, getDefaultAvatar } from '../../utils/im-user.js';
|
|
import { enrichGroupConversation, isOrderGroupConversation, sortConversations, recordConversationOpen, getZhuangtaiText } from '../../utils/group-chat.js';
|
|
import request from '../../utils/request';
|
|
import { openCustomerServiceChat } from '../../utils/kefu-nav.js';
|
|
import { getPrimaryRole } from '../../utils/primary-role.js';
|
|
import { isStaffMode } from '../../utils/staff-api.js';
|
|
import { createPage } from '../../utils/base-page.js';
|
|
const { jianquanxian } = require('../../utils/imAuth/jianquanxian');
|
|
|
|
Page(createPage({
|
|
data: {
|
|
allConversations: [],
|
|
filteredConversations: [],
|
|
activeTab: 0,
|
|
tabUnread: [0, 0, 0],
|
|
displayCount: 10,
|
|
searchKeyword: '',
|
|
actionPopup: { visible: false, conversation: null },
|
|
currentUser: null,
|
|
notificationMuted: false,
|
|
scrollHeight: 0,
|
|
imStatus: 'connecting',
|
|
imStatusText: '',
|
|
defaultAvatarUrl: '',
|
|
},
|
|
|
|
_permissionSeq: 0,
|
|
_peerProfileCache: {},
|
|
_lastConvSignature: '',
|
|
_lastRefreshTs: 0,
|
|
_showRefreshTimer: null,
|
|
_statusRefreshTimer: null,
|
|
_chatAllowed: true,
|
|
|
|
onLoad() {
|
|
this.calculateScrollHeight();
|
|
this.setData({ defaultAvatarUrl: getDefaultAvatarUrl(app) });
|
|
const muted = wx.getStorageSync('notificationMuted') || false;
|
|
this.setData({ notificationMuted: muted });
|
|
if (app.globalData.messageManager) {
|
|
app.globalData.messageManager.notificationMuted = muted;
|
|
}
|
|
loadGroupMetaCache(app);
|
|
this._onGlobalConvUpdated = (content) => {
|
|
if (content && content.conversations) {
|
|
this.renderConversations(content);
|
|
} else if (app.loadConversations) {
|
|
app.loadConversations();
|
|
}
|
|
};
|
|
this._onUnreadChanged = (data) => {
|
|
const unreadTotal = data?.unreadTotal ?? app.globalData.messageManager?.unreadTotal ?? 0;
|
|
if (app.globalData.messageManager) {
|
|
app.globalData.messageManager.unreadTotal = unreadTotal;
|
|
}
|
|
if (app.emitEvent) {
|
|
app.emitEvent('tabBarBadgeChanged', {
|
|
badgeText: unreadTotal > 0 ? String(unreadTotal) : '',
|
|
});
|
|
}
|
|
};
|
|
this._onConnectionChanged = (data) => {
|
|
const status = data?.status || 'disconnected';
|
|
const textMap = {
|
|
connected: '',
|
|
connecting: '正在连接消息服务…',
|
|
reconnecting: '正在重新连接…',
|
|
disconnected: '消息未连接，点击重试',
|
|
disabled: '消息服务未配置',
|
|
};
|
|
this.setData({
|
|
imStatus: status,
|
|
imStatusText: textMap[status] || (status === 'connected' ? '' : '消息未连接，点击重试'),
|
|
});
|
|
if (status === 'connected') {
|
|
this.setupConversationListener();
|
|
this.loadConversations();
|
|
}
|
|
};
|
|
app.on('conversationsUpdated', this._onGlobalConvUpdated);
|
|
app.on('unreadCountChanged', this._onUnreadChanged);
|
|
app.on('connectionChanged', this._onConnectionChanged);
|
|
},
|
|
|
|
onUnload() {
|
|
if (this._onGlobalConvUpdated) {
|
|
app.off('conversationsUpdated', this._onGlobalConvUpdated);
|
|
}
|
|
if (this._onUnreadChanged) {
|
|
app.off('unreadCountChanged', this._onUnreadChanged);
|
|
}
|
|
if (this._onConnectionChanged) {
|
|
app.off('connectionChanged', this._onConnectionChanged);
|
|
}
|
|
if (this.conversationsUpdatedListener && wx.goEasy?.im) {
|
|
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, this.conversationsUpdatedListener);
|
|
this.conversationsUpdatedListener = null;
|
|
}
|
|
},
|
|
|
|
async onShow() {
|
|
if (!this.checkLoginStatus()) return;
|
|
this.setData({ defaultAvatarUrl: getDefaultAvatarUrl(app) });
|
|
loadGroupMetaCache(app);
|
|
if (app.restoreTabBarBadge) app.restoreTabBarBadge();
|
|
this.registerNotificationComponent();
|
|
if (app.globalData.messageManager?.unreadTotal != null && app.emitEvent) {
|
|
app.emitEvent('tabBarBadgeChanged', {
|
|
badgeText: app.globalData.messageManager.unreadTotal > 0
|
|
? String(app.globalData.messageManager.unreadTotal) : '',
|
|
});
|
|
}
|
|
this.patchLocalReadState();
|
|
await this.checkPermissionAndAutoConnect();
|
|
if (this._chatAllowed) {
|
|
if (app.ensureConnection) app.ensureConnection();
|
|
this.setupConversationListener();
|
|
if (app.syncConnectionStatus) app.syncConnectionStatus();
|
|
this.scheduleSoftRefresh();
|
|
}
|
|
},
|
|
|
|
scheduleSoftRefresh() {
|
|
if (this._showRefreshTimer) clearTimeout(this._showRefreshTimer);
|
|
if (this._statusRefreshTimer) clearTimeout(this._statusRefreshTimer);
|
|
this._showRefreshTimer = setTimeout(() => {
|
|
this._showRefreshTimer = null;
|
|
const now = Date.now();
|
|
if (now - this._lastRefreshTs < 1800 && this.data.allConversations.length) {
|
|
return;
|
|
}
|
|
this._lastRefreshTs = now;
|
|
if (app.loadConversations) app.loadConversations();
|
|
else if (wx.goEasy?.im) this.loadConversations();
|
|
}, 350);
|
|
},
|
|
|
|
patchLocalReadState() {
|
|
const openId = app.globalData.pageState?.lastOpenedConvId;
|
|
if (!openId || !this.data.allConversations.length) return;
|
|
|
|
const list = this.data.allConversations.map((c) => {
|
|
const id = c.groupId || c.userId;
|
|
if (id === openId && (c.unread || 0) > 0) {
|
|
return { ...c, unread: 0 };
|
|
}
|
|
return c;
|
|
});
|
|
|
|
const openTimes = wx.getStorageSync('conversationOpenTimes') || {};
|
|
sortConversations(list, openTimes);
|
|
this.setData({ allConversations: list }, () => this.applyFilter());
|
|
},
|
|
|
|
retryImConnection() {
|
|
if (!app.globalData.chatEnabled) {
|
|
wx.showToast({ title: '消息服务未就绪', icon: 'none' });
|
|
return;
|
|
}
|
|
this.setData({ imStatus: 'connecting', imStatusText: '正在连接消息服务…' });
|
|
app.globalData.goEasyConnection.autoReconnect = true;
|
|
app.globalData.goEasyConnection.reconnectAttempts = 0;
|
|
if (app.ensureConnection) app.ensureConnection();
|
|
setTimeout(() => {
|
|
if (app.syncConnectionStatus) app.syncConnectionStatus();
|
|
if (app.loadConversations) app.loadConversations();
|
|
}, 2000);
|
|
},
|
|
|
|
onHide() {},
|
|
|
|
// ========== ==== ================ ==== ================ 鉴权检查 ==========
|
|
async checkPermissionAndAutoConnect() {
|
|
const seq = ++this._permissionSeq;
|
|
let quanxian;
|
|
try {
|
|
quanxian = await jianquanxian(app, { silent: true });
|
|
} catch (e) {
|
|
this._chatAllowed = true;
|
|
return;
|
|
}
|
|
if (seq !== this._permissionSeq) return;
|
|
|
|
if (!quanxian.allowed) {
|
|
this._chatAllowed = false;
|
|
const currentRole = app.globalData.currentRole || 'normal';
|
|
let hint = '消息连接暂不可用，列表可正常浏览';
|
|
if (currentRole === 'dashou') {
|
|
hint = '开通会员后可收发消息（列表可正常浏览）';
|
|
}
|
|
const prev = this.data.imStatusText;
|
|
if (prev !== hint) {
|
|
this.setData({ imStatusText: hint });
|
|
}
|
|
return;
|
|
}
|
|
this._chatAllowed = true;
|
|
if (this.data.imStatusText && this.data.imStatusText.includes('会员')) {
|
|
this.setData({ imStatusText: '' });
|
|
}
|
|
this.autoConnect();
|
|
},
|
|
|
|
// 登录状态检查
|
|
checkLoginStatus() {
|
|
const uid = wx.getStorageSync('uid');
|
|
if (!uid) {
|
|
wx.showToast({ title: '请先登录', icon: 'none' });
|
|
setTimeout(() => { wx.redirectTo({ url: '/pages/mine/mine' }); }, 1500);
|
|
return false;
|
|
}
|
|
let currentUser = app.globalData.currentUser;
|
|
if (!currentUser) {
|
|
currentUser = {
|
|
id: getLocalImUserId(app) || uid,
|
|
name: wx.getStorageSync('nicheng') || app.globalData.dashouNicheng || app.globalData.nicheng || ('用户' + uid.substring(0, 6)),
|
|
avatar: resolveAvatarFromStorage(app),
|
|
};
|
|
app.globalData.currentUser = currentUser;
|
|
}
|
|
this.setData({ currentUser });
|
|
return true;
|
|
},
|
|
|
|
autoConnect() {
|
|
const role = isStaffMode() ? 'shangjia' : (getLocalImIdentity(app) || app.globalData.currentRole || 'normal');
|
|
const uid = wx.getStorageSync('uid');
|
|
const targetUserId = getImUserIdForRole(role, uid);
|
|
if (!targetUserId) return;
|
|
|
|
const onReady = () => {
|
|
this.setupConversationListener();
|
|
if (app.loadConversations) app.loadConversations();
|
|
else this.loadConversations();
|
|
};
|
|
|
|
const status = wx.goEasy?.getConnectionStatus?.() || 'disconnected';
|
|
const currentUserId = wx.goEasy?.im?.userId;
|
|
if ((status === 'connected' || status === 'reconnected') && currentUserId === targetUserId) {
|
|
onReady();
|
|
return;
|
|
}
|
|
|
|
const tryConnect = async () => {
|
|
try {
|
|
if (app.ensureImForRole) {
|
|
await app.ensureImForRole(role);
|
|
} else if (app.connectWithIdentity) {
|
|
await app.connectWithIdentity(role, targetUserId, true);
|
|
} else if (app.ensureConnection) {
|
|
app.ensureConnection();
|
|
}
|
|
onReady();
|
|
} catch (e) {
|
|
const s = wx.goEasy?.getConnectionStatus?.();
|
|
if (s === 'connected' || s === 'reconnected') onReady();
|
|
}
|
|
};
|
|
tryConnect();
|
|
},
|
|
|
|
connectGoEasy(userId) {
|
|
const { currentUser } = this.data;
|
|
if (!currentUser) return;
|
|
wx.goEasy.connect({
|
|
id: userId,
|
|
data: {
|
|
name: currentUser.name,
|
|
avatar: resolveAvatarUrl(currentUser.avatar, app),
|
|
},
|
|
onSuccess: () => {
|
|
try {
|
|
wx.setStorageSync('savedGoEasyConnection', JSON.stringify({
|
|
userId,
|
|
identityType: app.globalData.currentRole,
|
|
lastConnectTime: Date.now(),
|
|
status: 'connected',
|
|
}));
|
|
} catch (e) {}
|
|
this.setupConversationListener();
|
|
this.loadConversations();
|
|
if (app.registerNotification) {
|
|
}
|
|
},
|
|
onFailed: (error) => {
|
|
if (error.code === 408) {
|
|
this.setupConversationListener();
|
|
this.loadConversations();
|
|
} else {
|
|
wx.showToast({ title: '连接失败，请重试', icon: 'none' });
|
|
}
|
|
},
|
|
});
|
|
},
|
|
|
|
setupConversationListener() {
|
|
if (!wx.goEasy || !wx.goEasy.im) return;
|
|
if (this.conversationsUpdatedListener) {
|
|
wx.goEasy.im.off(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, this.conversationsUpdatedListener);
|
|
}
|
|
this.conversationsUpdatedListener = (result) => {
|
|
const content = result?.content || result;
|
|
this.renderConversations(content);
|
|
};
|
|
wx.goEasy.im.on(wx.GoEasy.IM_EVENT.CONVERSATIONS_UPDATED, this.conversationsUpdatedListener);
|
|
},
|
|
|
|
loadConversations() {
|
|
if (!wx.goEasy || !wx.goEasy.im) return;
|
|
wx.goEasy.im.latestConversations({
|
|
onSuccess: (result) => {
|
|
const content = result?.content || result;
|
|
this.renderConversations(content);
|
|
},
|
|
onFailed: () => {
|
|
wx.showToast({ title: '获取会话失败', icon: 'none' });
|
|
},
|
|
});
|
|
},
|
|
|
|
// 会话渲染与排序
|
|
renderConversations(content) {
|
|
if (!content || !content.conversations) {
|
|
this.setData({ allConversations: [] }, () => this.applyFilter());
|
|
return;
|
|
}
|
|
let list = content.conversations;
|
|
const defaultAvatar = getDefaultAvatar(app);
|
|
const myGoEasyId = wx.goEasy?.im?.userId || getLocalImUserId(app);
|
|
const ossBase = app.globalData.ossImageUrl || '';
|
|
const groupMeta = app.globalData.groupInfoMap || {};
|
|
|
|
list.forEach((item, idx) => {
|
|
item.key = item.groupId || item.userId || item.teamId || `${item.type || 'c'}_${idx}`;
|
|
if (item.type === 'group') {
|
|
if (!item.data) item.data = {};
|
|
if (!item.data.orderId && item.groupId) {
|
|
const m = /^group_(.+)$/.exec(String(item.groupId));
|
|
if (m) item.data.orderId = m[1];
|
|
}
|
|
const meta = groupMeta[item.groupId];
|
|
if (meta) {
|
|
if (!item.data) item.data = {};
|
|
Object.assign(item.data, meta);
|
|
}
|
|
if (item.data.orderJieshao && !item.data.orderDesc) {
|
|
item.data.orderDesc = item.data.orderJieshao;
|
|
}
|
|
if (item.data && item.data.dashouGoEasyId) {
|
|
if (!app.globalData.groupInfoMap) app.globalData.groupInfoMap = {};
|
|
app.globalData.groupInfoMap[item.groupId] = {
|
|
...app.globalData.groupInfoMap[item.groupId],
|
|
...item.data,
|
|
};
|
|
}
|
|
enrichGroupConversation(item, myGoEasyId, defaultAvatar, ossBase);
|
|
} else {
|
|
if (!item.data) item.data = {};
|
|
item.data.avatar = resolveAvatarUrl(item.data.avatar, app) || defaultAvatar;
|
|
}
|
|
if (!item.lastMessage) {
|
|
item.lastMessage = { type: 'text', payload: { text: '' }, timestamp: 0 };
|
|
}
|
|
if (item.lastMessage.timestamp) {
|
|
item.lastMessage.date = formatDate(item.lastMessage.timestamp);
|
|
}
|
|
});
|
|
|
|
const openTimes = wx.getStorageSync('conversationOpenTimes') || {};
|
|
sortConversations(list, openTimes);
|
|
|
|
const unreadTotal = content.unreadTotal !== undefined
|
|
? content.unreadTotal
|
|
: list.reduce((sum, c) => sum + (c.unread || 0), 0);
|
|
|
|
const signature = list.map((c) => {
|
|
const id = c.groupId || c.userId || c.teamId || '';
|
|
const unread = c.unread || 0;
|
|
const ts = c.lastMessage?.timestamp || 0;
|
|
const preview = c.displayLastMsg || c.lastMessage?.payload?.text || '';
|
|
return `${id}:${unread}:${ts}:${preview.slice(0, 20)}`;
|
|
}).join('|');
|
|
|
|
if (signature === this._lastConvSignature && this.data.allConversations.length) {
|
|
if (app.globalData.messageManager) {
|
|
app.globalData.messageManager.unreadTotal = unreadTotal;
|
|
}
|
|
if (app.updateUnreadCount) {
|
|
app.updateUnreadCount(unreadTotal);
|
|
} else if (app.emitEvent) {
|
|
app.emitEvent('tabBarBadgeChanged', { badgeText: unreadTotal > 0 ? String(unreadTotal) : '' });
|
|
}
|
|
this.applyFilter();
|
|
return;
|
|
}
|
|
this._lastConvSignature = signature;
|
|
|
|
if (app.globalData.messageManager) {
|
|
app.globalData.messageManager.unreadTotal = unreadTotal;
|
|
}
|
|
if (app.updateUnreadCount) {
|
|
app.updateUnreadCount(unreadTotal);
|
|
} else if (app.emitEvent) {
|
|
app.emitEvent('tabBarBadgeChanged', { badgeText: unreadTotal > 0 ? String(unreadTotal) : '' });
|
|
}
|
|
|
|
const prevDisplay = this.data.displayCount;
|
|
this.setData({
|
|
allConversations: list,
|
|
displayCount: prevDisplay > 10 ? prevDisplay : 10,
|
|
}, () => {
|
|
this.applyFilter();
|
|
});
|
|
|
|
this.subscribeGroupsIfNeeded(list);
|
|
this.scheduleOrderStatusRefresh(list);
|
|
},
|
|
|
|
scheduleOrderStatusRefresh(conversations) {
|
|
if (this._statusRefreshTimer) clearTimeout(this._statusRefreshTimer);
|
|
this._statusRefreshTimer = setTimeout(() => {
|
|
this._statusRefreshTimer = null;
|
|
this.refreshOrderStatuses(conversations);
|
|
}, 400);
|
|
},
|
|
|
|
async refreshOrderStatuses(conversations) {
|
|
const orderIds = [];
|
|
(conversations || this.data.allConversations).forEach((c) => {
|
|
if (!isOrderGroupConversation(c)) return;
|
|
const oid = c.data?.orderId;
|
|
if (oid && !orderIds.includes(oid)) orderIds.push(oid);
|
|
});
|
|
if (!orderIds.length) return;
|
|
|
|
try {
|
|
const res = await request({
|
|
url: '/dingdan/ltddztpl',
|
|
method: 'POST',
|
|
data: { order_ids: orderIds.slice(0, 20) },
|
|
});
|
|
const body = res?.data || {};
|
|
const map = body.data || {};
|
|
if (!Object.keys(map).length) return;
|
|
|
|
let changed = false;
|
|
const list = this.data.allConversations.map((c) => {
|
|
const oid = c.data?.orderId;
|
|
if (!oid || !map[oid]) return c;
|
|
const st = map[oid];
|
|
changed = true;
|
|
const data = {
|
|
...c.data,
|
|
orderId: oid,
|
|
orderDesc: st.jieshao || c.data.orderDesc,
|
|
orderJine: st.jine != null ? st.jine : c.data.orderJine,
|
|
orderZhuangtai: st.zhuangtai,
|
|
orderZhuangtaiText: getZhuangtaiText(st.zhuangtai),
|
|
};
|
|
if (c.groupId && app.globalData.groupInfoMap) {
|
|
app.globalData.groupInfoMap[c.groupId] = {
|
|
...(app.globalData.groupInfoMap[c.groupId] || {}),
|
|
...data,
|
|
};
|
|
}
|
|
return { ...c, data };
|
|
});
|
|
if (changed) {
|
|
this.setData({ allConversations: list }, () => this.applyFilter());
|
|
}
|
|
} catch (e) {
|
|
console.warn('刷新订单状态失败', e);
|
|
}
|
|
},
|
|
|
|
/**
|
|
* 群组订阅，每次获取群组列表时直接订阅保证消息不丢失
|
|
*/
|
|
subscribeGroupsIfNeeded(conversations) {
|
|
if (!wx.goEasy?.im || typeof wx.goEasy.im.subscribeGroup !== 'function') return;
|
|
|
|
const groupIds = conversations
|
|
.filter(c => c.type === 'group' && c.groupId)
|
|
.map(c => c.groupId);
|
|
|
|
if (groupIds.length === 0) return;
|
|
|
|
// 不再判断缓存，直接订阅当前所有群组
|
|
wx.goEasy.im.subscribeGroup({
|
|
groupIds: groupIds,
|
|
onSuccess: () => {
|
|
// 可选的日志输出，不影响功能
|
|
// console.log('群组订阅成功', groupIds);
|
|
},
|
|
onFailed: (error) => {
|
|
console.error('群组订阅失败:', error);
|
|
}
|
|
});
|
|
},
|
|
|
|
applyFilter() {
|
|
const { allConversations, activeTab, searchKeyword } = this.data;
|
|
let filtered = [];
|
|
if (activeTab === 0) {
|
|
filtered = allConversations.filter(c => isOrderGroupConversation(c));
|
|
} else if (activeTab === 1) {
|
|
filtered = allConversations.filter(c => c.type === 'private');
|
|
} else if (activeTab === 2) {
|
|
filtered = allConversations.filter(c => c.type === 'cs');
|
|
}
|
|
|
|
if (searchKeyword.trim()) {
|
|
const kw = searchKeyword.trim().toLowerCase();
|
|
filtered = filtered.filter(c => {
|
|
const name = (c.data && c.data.name || '').toLowerCase();
|
|
const orderId = (c.data && c.data.orderId || '').toLowerCase();
|
|
const id = (c.userId || c.groupId || '').toLowerCase();
|
|
return name.includes(kw) || id.includes(kw) || orderId.includes(kw);
|
|
});
|
|
}
|
|
|
|
const tabUnread = [0, 0, 0];
|
|
allConversations.forEach(c => {
|
|
if (isOrderGroupConversation(c)) tabUnread[0] += c.unread || 0;
|
|
else if (c.type === 'private') tabUnread[1] += c.unread || 0;
|
|
else if (c.type === 'cs') tabUnread[2] += c.unread || 0;
|
|
});
|
|
|
|
this.setData({ filteredConversations: filtered, tabUnread });
|
|
},
|
|
|
|
switchTab(e) {
|
|
const index = parseInt(e.currentTarget.dataset.index);
|
|
this.setData({ activeTab: index, displayCount: 10, searchKeyword: '' }, () => {
|
|
this.applyFilter();
|
|
this.calculateScrollHeight();
|
|
});
|
|
},
|
|
|
|
onSearchInput(e) {
|
|
this.setData({ searchKeyword: e.detail.value, displayCount: 10 }, () => this.applyFilter());
|
|
},
|
|
|
|
onScrollToLower() {
|
|
const { displayCount, filteredConversations } = this.data;
|
|
if (displayCount < filteredConversations.length) {
|
|
this.setData({ displayCount: Math.min(displayCount + 10, filteredConversations.length) });
|
|
}
|
|
},
|
|
|
|
onRefresh() {
|
|
this.loadConversations();
|
|
},
|
|
|
|
chat(e) {
|
|
const conversation = e.currentTarget.dataset.conversation;
|
|
if (!conversation) return;
|
|
if (this._chatAllowed === false) {
|
|
wx.showToast({ title: '请先开通会员后再聊天', icon: 'none' });
|
|
return;
|
|
}
|
|
recordConversationOpen(conversation);
|
|
const convId = conversation.groupId || conversation.userId;
|
|
if (convId) {
|
|
if (!app.globalData.pageState) app.globalData.pageState = {};
|
|
app.globalData.pageState.lastOpenedConvId = convId;
|
|
}
|
|
|
|
if (conversation.type === 'private') {
|
|
const param = {
|
|
toUserId: conversation.userId,
|
|
toName: conversation.data.name || '用户',
|
|
toAvatar: resolveAvatarUrl(conversation.data.avatar, app),
|
|
};
|
|
wx.navigateTo({ url: '/pages/chat/chat?data=' + encodeURIComponent(JSON.stringify(param)) });
|
|
} else if (conversation.type === 'group' || (conversation.groupId && isOrderGroupConversation(conversation))) {
|
|
const d = conversation.data || {};
|
|
const rawGid = conversation.groupId || '';
|
|
const oid = String(d.orderId || rawGid).replace(/^group_/, '');
|
|
const groupId = rawGid.startsWith('group_') ? rawGid : (oid ? `group_${oid}` : rawGid);
|
|
const param = {
|
|
groupId,
|
|
orderId: oid,
|
|
groupName: d.name || '订单群聊',
|
|
groupAvatar: d.avatar,
|
|
isCross: d.isCross || 0,
|
|
orderZhuangtai: d.orderZhuangtai,
|
|
orderJine: d.orderJine,
|
|
orderDesc: d.orderDesc || d.orderJieshao || '',
|
|
currentUserId: wx.goEasy?.im?.userId || getLocalImUserId(app),
|
|
currentUserName: this.data.currentUser?.name || '',
|
|
currentUserAvatar: this.data.currentUser?.avatar || '',
|
|
};
|
|
wx.navigateTo({ url: '/pages/group-chat/group-chat?data=' + encodeURIComponent(JSON.stringify(param)) });
|
|
} else if (conversation.type === 'cs') {
|
|
const param = { teamId: conversation.teamId || conversation.id };
|
|
wx.navigateTo({ url: '/pages/cs-chat/cs-chat?data=' + encodeURIComponent(JSON.stringify(param)) });
|
|
}
|
|
},
|
|
|
|
chatKefu() {
|
|
openCustomerServiceChat();
|
|
},
|
|
|
|
showAction(e) {
|
|
const conversation = e.currentTarget.dataset.conversation;
|
|
this.setData({ ['actionPopup.conversation']: conversation, ['actionPopup.visible']: true });
|
|
},
|
|
closeMask() {
|
|
this.setData({ ['actionPopup.visible']: false });
|
|
},
|
|
topConversation() {
|
|
let conversation = this.data.actionPopup.conversation;
|
|
if (!conversation) return;
|
|
const top = !conversation.top;
|
|
wx.showLoading({ title: '处理中...' });
|
|
if (conversation.type === 'private') {
|
|
wx.goEasy.im.topPrivateConversation({
|
|
userId: conversation.userId, top,
|
|
onSuccess: () => {
|
|
wx.hideLoading(); this.loadConversations();
|
|
wx.showToast({ title: top ? '已置顶' : '已取消置顶' });
|
|
},
|
|
onFailed: () => { wx.hideLoading(); wx.showToast({ title: '操作失败', icon: 'none' }); }
|
|
});
|
|
} else {
|
|
wx.goEasy.im.topGroupConversation({
|
|
groupId: conversation.groupId, top,
|
|
onSuccess: () => {
|
|
wx.hideLoading(); this.loadConversations();
|
|
wx.showToast({ title: top ? '已置顶' : '已取消置顶' });
|
|
},
|
|
onFailed: () => { wx.hideLoading(); wx.showToast({ title: '操作失败', icon: 'none' }); }
|
|
});
|
|
}
|
|
this.closeMask();
|
|
},
|
|
removeConversation() {
|
|
let conversation = this.data.actionPopup.conversation;
|
|
if (!conversation) return;
|
|
wx.showLoading({ title: '删除中...' });
|
|
wx.goEasy.im.removeConversation({
|
|
conversation: conversation,
|
|
onSuccess: () => { wx.hideLoading(); this.loadConversations(); wx.showToast({ title: '已删除' }); },
|
|
onFailed: () => { wx.hideLoading(); wx.showToast({ title: '删除失败', icon: 'none' }); }
|
|
});
|
|
this.closeMask();
|
|
},
|
|
|
|
toggleNotification() {
|
|
const newMuted = !this.data.notificationMuted;
|
|
this.setData({ notificationMuted: newMuted });
|
|
wx.setStorageSync('notificationMuted', newMuted);
|
|
wx.showToast({ title: newMuted ? '已静音' : '已开启通知', icon: 'none' });
|
|
},
|
|
|
|
calculateScrollHeight() {
|
|
const systemInfo = wx.getSystemInfoSync();
|
|
const windowHeight = systemInfo.windowHeight;
|
|
const windowWidth = systemInfo.windowWidth;
|
|
const rpxRatio = 750 / windowWidth;
|
|
const headerHeight = 150 / rpxRatio;
|
|
const tabBarHeight = 130 / rpxRatio;
|
|
const kefuBarHeight = this.data.activeTab === 2 ? (112 / rpxRatio) : 0;
|
|
const safeAreaBottom = systemInfo.safeArea ? (windowHeight - systemInfo.safeArea.bottom) : 0;
|
|
this.setData({ scrollHeight: windowHeight - headerHeight - tabBarHeight - kefuBarHeight - safeAreaBottom });
|
|
},
|
|
|
|
onAvatarError(e) {
|
|
const index = e.currentTarget.dataset.index;
|
|
const def = getDefaultAvatarUrl(app);
|
|
const key = `filteredConversations[${index}].data.avatar`;
|
|
this.setData({ [key]: def });
|
|
}
|
|
}))
|