From 04102f7237efefa744090ed7c25f7b5d0807b679 Mon Sep 17 00:00:00 2001
From: quanwei <419654421@qq.com>
Date: Thu, 05 Feb 2026 18:11:57 +0800
Subject: [PATCH] 完成运营中心提现和运营中心权限管理
---
mobile/pages/plus/business/chat/chat.vue | 52 +++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 41 insertions(+), 11 deletions(-)
diff --git a/mobile/pages/plus/business/chat/chat.vue b/mobile/pages/plus/business/chat/chat.vue
index d8a4190..3c1447c 100644
--- a/mobile/pages/plus/business/chat/chat.vue
+++ b/mobile/pages/plus/business/chat/chat.vue
@@ -64,7 +64,7 @@
</view> -->
</view>
<view class="message-info">
- <text class="message-time">{{ formatTime(message.send_time) }}</text>
+ <text class="message-time">{{ formatTime(message.send_time||message.create_time) }}</text>
</view>
</view>
</view>
@@ -86,7 +86,7 @@
</view>
<view class="message-info">
- <text class="message-time">{{ formatTime(message.send_time) }}</text>
+ <text class="message-time">{{ formatTime(message.send_time||message.create_time) }}</text>
</view>
</view>
@@ -235,9 +235,12 @@
if (!this.conversationId) {
// 初始化会话
this.initConversation();
+ }else{
+ // 加载消息
+ this.loadMessages();
+ this.initWebSocket();
}
- // 加载消息
- this.loadMessages();
+
},
onUnload() {
this.is_exit = true;
@@ -275,6 +278,7 @@
business_card_id: this.businessCardId
}, res => {
this.conversationId = res.data.conversation.conversation_id;
+ this.loadMessages();
this.wsUrl = res.data.wsUrl;
// 初始化WebSocket连接
this.initWebSocket();
@@ -319,6 +323,7 @@
self.loadMore = false;
self.page++;
if (self.page == 2) {
+ console.log(res.data.heUser);
// 获取目标用户信息
this.targetUser = res.data.heUser;
this.card = res.data.card;
@@ -355,6 +360,7 @@
let self = this;
if (!this.inputMessage.trim()) return;
const content = self.inputMessage.trim();
+ console.log(content);
self.sendWebSocketMessage(content);
},
@@ -369,7 +375,7 @@
const currentUserId = this.currentUser.user_id;
// 构建WebSocket连接URL - 使用名片聊天专用端口2349
- const wsUrl = `${this.wsUrl}:2349?user_id=${currentUserId}`;
+ const wsUrl = `${this.wsUrl}:2349?user_id=${currentUserId}&usertype=supplier `;
try {
// 创建WebSocket连接
this.socketTask = uni.connectSocket({
@@ -567,15 +573,38 @@
});
console.log('所有未读消息已标记为已读');
},
-
+ sendMessages(message){
+ if(message==''){
+ return
+ }
+ this._post('plus.business.chat.chat/sendMessage',{
+ content:this.inputMessage,
+ conversation_id: this.conversationId,
+ business_card_id: this.businessCardId,
+ },res=>{
+ // 添加消息到本地列表
+ const localMessage = {
+ chat_id: Date.now(),
+ conversation_id: this.conversationId,
+ sender_id: this.currentUser.user_id,
+ content: this.inputMessage,
+ create_time: Math.floor(Date.now() / 1000),
+ send_time: (Date.now() / 1000),
+ is_read: false
+ };
+ this.messages.push(localMessage);
+ this.inputMessage = '';
+ })
+ },
// 发送WebSocket消息
sendWebSocketMessage(message) {
let self = this;
if (!this.socketTask) {
self.initWebSocket();
+ self.sendMessages(message);
// 等待连接建立后再发送消息
setTimeout(() => {
- self.sendWebSocketMessage(message);
+ self.sendWebSocketMessage('');
}, 1000);
return;
}
@@ -585,8 +614,6 @@
user_id: this.currentUser.user_id,
to_user_id: this.targetUserId,
content: message,
- conversation_id: this.conversationId,
- business_card_id: this.businessCardId,
app_id: this.currentUser.grade.app_id
};
@@ -594,12 +621,15 @@
if (!this.isOnline) {
self.initWebSocket();
// 等待连接建立后再发送消息
+ self.sendMessages(message);
setTimeout(() => {
- self.sendWebSocketMessage(message);
+ self.sendWebSocketMessage('');
}, 1000);
return;
}
-
+ if(message==''){
+ return
+ }
try {
self.socketTask.send({
data: JSON.stringify(wsMessage)
--
Gitblit v1.9.2