From c5d4eba244e3d79d38916eea34b3e9a587020082 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B5=B5=E6=AF=85?= <1335909236@qq.com>
Date: Thu, 25 Sep 2025 11:42:52 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=A2=E6=9C=8D=E6=A8=A1=E5=9D=97=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../customerService/chattingRecords/index.vue | 44 ++++++-------
 packages/customerService/index/index.vue      | 66 +++++++++++--------
 packages/user/index/index.vue                 |  2 +
 pages/login/login.vue                         |  3 +
 pages/user/index.vue                          |  5 +-
 5 files changed, 65 insertions(+), 55 deletions(-)

diff --git a/packages/customerService/chattingRecords/index.vue b/packages/customerService/chattingRecords/index.vue
index e17b049a..069c0323 100644
--- a/packages/customerService/chattingRecords/index.vue
+++ b/packages/customerService/chattingRecords/index.vue
@@ -40,11 +40,10 @@ export default {
       isLoading: false,
       page_num: 1,
       page_size: 10,
+      itemObj: {},
     };
   },
   onLoad() {
-    // 加载聊天记录列表
-    this.loadChattingRecords();
   },
   onShow() {
     // 页面显示时重新加载聊天记录
@@ -62,7 +61,7 @@ export default {
           page_num: this.page_num,
           page_size: this.page_size,
         }).then((res) => {
-          this.recordsList = res.msg_list
+          this.recordsList = res.msg_list.filter(item => item.client_id_one !== item.client_id_two)
         })
       } catch (error) {
         console.error('加载聊天记录失败', error);
@@ -104,29 +103,24 @@ export default {
 
     // 跳转到聊天页面
     goToChatPage(record) {
-      const params = {
-        mch_id: record.mch_id,
-      }
-
-      request(apiArr.csGetMchContactList, "POST", params).then((res) => {
-        if (res.rows && res.rows.length > 0) {
-          res.rows.map(item => {
-            item.employee_image = picUrl + item.employee_image;
-          })
-          const itemObj = res.rows.find(item => item.employee_mobile === record.two.account)
-
-          // 跳转到聊天页面
-          uni.navigateTo({
-            url: '/packages/customerService/index/index?item=' + JSON.stringify(itemObj)
-          });
-        } else {
-          console.log("没有获取到客服列表数据");
-          uni.showToast({
-            title: '该客服不存在',
-            icon: 'none'
-          })
+      console.log("🚀 ~ goToChatPage ~ record:", record)
+      if (record.client_id_two == uni.getStorageSync('openId')) {
+        this.itemObj = {
+          ...record.one,
+          bind_id: record.id
         }
-      })
+      } else {
+        this.itemObj = {
+          ...record.one,
+          bind_id: record.id
+        }
+      }
+      console.log("🚀 ~ goToChatPage ~ itemObj:", this.itemObj)
+
+      // 跳转到聊天页面
+      uni.navigateTo({
+        url: '/packages/customerService/index/index?item=' + JSON.stringify(this.itemObj)
+      });
     }
   }
 };
diff --git a/packages/customerService/index/index.vue b/packages/customerService/index/index.vue
index 098faf2c..b9418f7c 100644
--- a/packages/customerService/index/index.vue
+++ b/packages/customerService/index/index.vue
@@ -47,7 +47,7 @@ packages/customerService/index/index<template>
           @confirm="sendMessage" @input="handleInput" auto-height hold-keyboard="true"
           enable-keyboard-accessory-view="true" cursor-spacing="10" maxlength="500" @focus="onInputFocus"
           @blur="onInputBlur"></textarea>
-        <button :disabled="!canSend || !client || !isConnected" class="send-btn" @tap="sendMessage">
+        <button :disabled="inputMessage.trim() === ''" class="send-btn" @tap="sendMessage">
           发送
         </button>
       </view>
@@ -112,7 +112,8 @@ export default {
     // 获取聊天对象信息
     if (options.item) {
       this.chatTarget = JSON.parse(options.item)
-      this.chatTarget.title = `客服${this.chatTarget.employee_name}`
+      console.log("🚀 ~ onLoad ~ this.chatTarget:", this.chatTarget)
+      this.chatTarget.title = this.chatTarget.employee_name ? `客服${this.chatTarget.employee_name}` : `客服${this.chatTarget.real_name}`
     }
     // 初始化MQTT连接
     this.initChat()
@@ -214,33 +215,40 @@ export default {
 
     // 获取MQTT连接配置
     async getMqttConfig() {
-      try {
-        // 如果没有已创建的实例或clientId，则通过API获取
-        return new Promise((resolve, reject) => {
-          const params = {
-            worker_id: this.chatTarget.id || '',
-            open_id: this.selfClientId || ''
-          }
-          request(apiArr.csGetToClientId, 'POST', params).then((res) => {
-            console.log('聊天列表:', res)
-            // 检查响应数据格式是否正确
-            if (res && res.client_bind && res.client_bind.client_id_one && res.client_bind.client_id_two) {
-              this.mqttConfig.clientId = res.client_bind.client_id_one // 登录人的open_id
-              this.chatTarget.openId = res.client_bind.client_id_two // 接收方的open_id
-              this.mqttConfig.bind_id = res.client_bind.id
-              resolve()
-            } else {
-              console.error('MQTT配置响应格式不正确:', res)
-              reject(new Error('未获取到有效的MQTT配置'))
+      console.log("🚀 ~ onLoad ~ this.chatTarget.open_id:", this.chatTarget.open_id)
+      if (this.chatTarget.open_id) {
+        this.mqttConfig.clientId = uni.getStorageSync('openId') // 登录人的open_id
+        this.chatTarget.openId = this.chatTarget.open_id // 接收方的open_id
+        this.mqttConfig.bind_id = this.chatTarget.bind_id
+      } else {
+        try {
+          // 如果没有已创建的实例或clientId，则通过API获取
+          return new Promise((resolve, reject) => {
+            const params = {
+              worker_id: this.chatTarget.id || '',
+              open_id: this.selfClientId || '',
             }
-          }).catch(error => {
-            console.error('获取MQTT配置失败', error)
-            reject(error)
+            request(apiArr.csGetToClientId, 'POST', params).then((res) => {
+              console.log('聊天列表:', res)
+              // 检查响应数据格式是否正确
+              if (res && res.client_bind && res.client_bind.client_id_one && res.client_bind.client_id_two) {
+                this.mqttConfig.clientId = res.client_bind.client_id_one // 登录人的open_id
+                this.chatTarget.openId = res.client_bind.client_id_two // 接收方的open_id
+                this.mqttConfig.bind_id = res.client_bind.id
+                resolve()
+              } else {
+                console.error('MQTT配置响应格式不正确:', res)
+                reject(new Error('未获取到有效的MQTT配置'))
+              }
+            }).catch(error => {
+              console.error('获取MQTT配置失败', error)
+              reject(error)
+            })
           })
-        })
-      } catch (error) {
-        console.error('获取MQTT配置失败', error)
-        throw error
+        } catch (error) {
+          console.error('获取MQTT配置失败', error)
+          throw error
+        }
       }
     },
 
@@ -337,8 +345,8 @@ export default {
       // 按照用户提供的格式构建发送消息
       const msgData = {
         bind_id: this.mqttConfig.bind_id, // 聊天列表的ID，这里暂时固定为1
-        send_client: this.mqttConfig.clientId, // 消息发送方open_id 
-        receive_client: this.chatTarget.openId, // 消息接收方open_id 
+        send_client: this.selfClientId, // 消息发送方open_id 
+        receive_client: this.mqttConfig.clientId, // 消息接收方open_id 
         type: 1, // 消息类型，1表示文字消息
         content: content, // 消息内容
         receive_read_status: 2 // 接收方阅读状态
diff --git a/packages/user/index/index.vue b/packages/user/index/index.vue
index 1ad9fe29..5bca0901 100644
--- a/packages/user/index/index.vue
+++ b/packages/user/index/index.vue
@@ -120,6 +120,7 @@ export default {
 			uni.removeStorageSync('is_deal');
 			uni.removeStorageSync('is_dev');
 			uni.removeStorageSync('is_shop');
+			uni.removeStorageSync('is_merchant');
 			uni.removeStorageSync('is_worker');
 			uni.removeStorageSync('shopId');
 			uni.removeStorageSync('order_dispatch_permission');
@@ -147,6 +148,7 @@ export default {
 						uni.setStorageSync('is_deal', loginRes.is_deal);
 						uni.setStorageSync('is_dev', loginRes.is_dev);
 						uni.setStorageSync('is_shop', loginRes.is_shop);
+						uni.setStorageSync('is_merchant', loginRes.is_merchant);
 						uni.setStorageSync('is_worker', loginRes.is_worker);
 
 
diff --git a/pages/login/login.vue b/pages/login/login.vue
index fd0e43e7..1482c02d 100644
--- a/pages/login/login.vue
+++ b/pages/login/login.vue
@@ -78,6 +78,7 @@ export default {
 						uni.setStorageSync('is_deal', loginRes.is_deal);
 						uni.setStorageSync('is_dev', loginRes.is_dev);
 						uni.setStorageSync('is_shop', loginRes.is_shop);
+						uni.setStorageSync('is_merchant', loginRes.is_merchant);
 						uni.setStorageSync('is_worker', loginRes.is_worker);
 
 
@@ -148,6 +149,7 @@ export default {
 				uni.removeStorageSync('is_deal');
 				uni.removeStorageSync('is_dev');
 				uni.removeStorageSync('is_shop');
+				uni.removeStorageSync('is_merchant');
 				uni.removeStorageSync('is_worker');
 				uni.removeStorageSync('shopId');
 				uni.removeStorageSync('order_dispatch_permission');
@@ -197,6 +199,7 @@ export default {
 				uni.setStorageSync('is_deal', loginRes.is_deal);
 				uni.setStorageSync('is_dev', loginRes.is_dev);
 				uni.setStorageSync('is_shop', loginRes.is_shop);
+				uni.setStorageSync('is_merchant', loginRes.is_merchant);
 				uni.setStorageSync('is_worker', loginRes.is_worker);
 
 				// 获取用户信息
diff --git a/pages/user/index.vue b/pages/user/index.vue
index d91c53e3..f0dcdb7e 100644
--- a/pages/user/index.vue
+++ b/pages/user/index.vue
@@ -113,7 +113,7 @@
 				</u-grid>
 			</view>
 		</view>
-		<view class="main margin20" v-if="isShop">
+		<view class="main margin20" v-if="isMerchant">
 			<view class="main_title">商家端</view>
 			<view class="item1 padding_bottom0">
 				<u-grid col="4" :border="false">
@@ -246,6 +246,7 @@ export default {
 			],
 			userInfo: {},
 			isShop: uni.getStorageSync('is_shop'),
+			isMerchant: uni.getStorageSync('is_merchant'),
 		}
 	},
 
@@ -269,6 +270,7 @@ export default {
 			uni.removeStorageSync('is_deal');
 			uni.removeStorageSync('is_dev');
 			uni.removeStorageSync('is_shop');
+			uni.removeStorageSync('is_merchant');
 			uni.removeStorageSync('is_worker');
 			uni.removeStorageSync('shopId');
 			uni.removeStorageSync('order_dispatch_permission');
@@ -296,6 +298,7 @@ export default {
 						uni.setStorageSync('is_deal', loginRes.is_deal);
 						uni.setStorageSync('is_dev', loginRes.is_dev);
 						uni.setStorageSync('is_shop', loginRes.is_shop);
+						uni.setStorageSync('is_merchant', loginRes.is_merchant);
 						uni.setStorageSync('is_worker', loginRes.is_worker);