From 4f6cc776468ce43c9732c08053a8d1fa62746f1f Mon Sep 17 00:00:00 2001
From: PQZ <pangqingzhou@gmail.com>
Date: Tue, 5 Aug 2025 16:38:00 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/ruoyi/webSocket/WebSocketServer.java  |  2 +-
 .../mapper/busi/BusiChatMainMapper.xml        |  1 +
 dl_vue/src/App.vue                            |  1 +
 dl_vue/src/api/busi/chatMain.js               |  8 +++
 dl_vue/src/store/modules/websocket.js         | 10 +++-
 dl_vue/src/views/busi/chatMain/chatForm.vue   | 49 +++++++++++--------
 dl_vue/src/views/busi/chatMain/index.vue      | 45 ++++++++++-------
 7 files changed, 77 insertions(+), 39 deletions(-)

diff --git a/dl_admin/ruoyi-admin/src/main/java/com/ruoyi/webSocket/WebSocketServer.java b/dl_admin/ruoyi-admin/src/main/java/com/ruoyi/webSocket/WebSocketServer.java
index 464da3a..a8b3505 100644
--- a/dl_admin/ruoyi-admin/src/main/java/com/ruoyi/webSocket/WebSocketServer.java
+++ b/dl_admin/ruoyi-admin/src/main/java/com/ruoyi/webSocket/WebSocketServer.java
@@ -95,7 +95,7 @@ public class WebSocketServer {
     public void CountPerson(String count){
         for (String name : webSocketSet.keySet()){
             try {
-                webSocketSet.get(name).session.getBasicRemote().sendText(count);
+                webSocketSet.get(name).session.getBasicRemote().sendText("close,"+name+"退出聊天");
             }catch (Exception e){
                 e.printStackTrace();
             }
diff --git a/dl_admin/ruoyi-admin/src/main/resources/mapper/busi/BusiChatMainMapper.xml b/dl_admin/ruoyi-admin/src/main/resources/mapper/busi/BusiChatMainMapper.xml
index 3f11fc8..21c52ee 100644
--- a/dl_admin/ruoyi-admin/src/main/resources/mapper/busi/BusiChatMainMapper.xml
+++ b/dl_admin/ruoyi-admin/src/main/resources/mapper/busi/BusiChatMainMapper.xml
@@ -24,6 +24,7 @@
         <result property="prodName" column="prod_name"/>
         <result property="userName" column="user_name"/>
         <result property="siteName" column="site_name"/>
+        <result property="itemJson" column="item_json"/>
     </resultMap>
 
     <sql id="selectBusiChatMainVo">
diff --git a/dl_vue/src/App.vue b/dl_vue/src/App.vue
index 135df7d..5555206 100644
--- a/dl_vue/src/App.vue
+++ b/dl_vue/src/App.vue
@@ -28,6 +28,7 @@ export default {
     this.$store.dispatch('websocket_init', process.env.VUE_APP_WEBSOCKET+username)
   },
   mounted(){
+    //事件总线调起聊天记录弹窗
     EventBus.$on('newMessage', (message) => {
       this.$refs.chatFrom.openForm()
     });
diff --git a/dl_vue/src/api/busi/chatMain.js b/dl_vue/src/api/busi/chatMain.js
index f2f048e..c679475 100644
--- a/dl_vue/src/api/busi/chatMain.js
+++ b/dl_vue/src/api/busi/chatMain.js
@@ -26,6 +26,14 @@ export function addChatMain(data) {
   })
 }
 
+export function saveMessage(data) {
+  return request({
+    url: '/web/saveMessage',
+    method: 'post',
+    data: data
+  })
+}
+
 // 修改在线聊天
 export function updateChatMain(data) {
   return request({
diff --git a/dl_vue/src/store/modules/websocket.js b/dl_vue/src/store/modules/websocket.js
index 4b78f3a..e577995 100644
--- a/dl_vue/src/store/modules/websocket.js
+++ b/dl_vue/src/store/modules/websocket.js
@@ -19,7 +19,9 @@ const websocket = {
         } else if (e.data.startsWith("系统通知")){
           state.notice.push(e.data);
           console.log(state.notice);
-        } else {
+        } else if (e.data.startsWith("close")){
+          console.log(e.data)
+        }else {
           console.log(e.data,'消息内容')
           //这里捕获消息
           const messageData = JSON.parse(e.data)
@@ -42,6 +44,9 @@ const websocket = {
     },
     WEBSOCKET_CLOSE(state){
       state.socket.close();
+    },
+    SET_MESSAGE(state,msg){
+      state.message = msg
     }
   },
 
@@ -54,6 +59,9 @@ const websocket = {
     },
     websocket_close({commit}){
       commit('WEBSOCKET_CLOSE')
+    },
+    set_message({commit},msg){
+      commit('SET_MESSAGE',msg)
     }
   }
 }
diff --git a/dl_vue/src/views/busi/chatMain/chatForm.vue b/dl_vue/src/views/busi/chatMain/chatForm.vue
index f4c2cd6..9499443 100644
--- a/dl_vue/src/views/busi/chatMain/chatForm.vue
+++ b/dl_vue/src/views/busi/chatMain/chatForm.vue
@@ -1,6 +1,6 @@
 <template>
   <!-- 选择产品对话框 -->
-  <el-dialog :title="title" :visible.sync="open" width="800px" append-to-body>
+  <el-dialog @close="close" :title="title" :visible.sync="open" width="800px" append-to-body>
     <div class="dl-chat-box"   >
       <template v-for="(item,index) in messages">
         <div v-if="item.dataFrom=='customer'" class="dl-customer-dom">
@@ -13,12 +13,13 @@
           </div>
         </div>
         <div v-if="item.dataFrom=='platform'" class="dl-platform-dom">
+
           <div class="dl-platform-right">
             <div class="dl-platform-time">{{item.createTime}}</div>
             <div class="dl-platform-content">{{ item.content }}</div>
           </div>
           <div class="dl-platform-photo">
-            <img :src="picPrex+item.userImg" >
+            <img src="@/assets/images/customer.jpg" >
           </div>
         </div>
       </template>
@@ -36,7 +37,7 @@
 </template>
 
 <script>
-import { listChatItem, getChatItem, delChatItem, addChatItem, updateChatItem } from "@/api/busi/chatItem";
+import { saveMessage } from "@/api/busi/chatMain";
 export default {
   name: 'chatForm',
   data() {
@@ -52,6 +53,8 @@ export default {
       pages:0,
       //发送的消息
       text:'',
+      //消息id
+      chatId:'',
       // 查询参数
       queryParams: {
         mainId: null,
@@ -62,40 +65,46 @@ export default {
     /**
      * 组件显示
      */
-    show(id,title) {
+    show(row) {
       this.reset()
-      this.title = title?title:"聊天记录"
       this.open = true
-      this.queryParams.mainId = id
-      this.getList()
+      console.log(row)
+      this.chatId = row.id
+      if (row.itemJson!=null) {
+        this.messages = JSON.parse(row.itemJson)
+        this.$store.dispatch('set_message',this.messages);
+      }
     },
 
     openForm(){
-      this.open = true
-      this.messages = this.$store._modules.root.state.websocket.message
+      if (!this.open) {
+        this.open = true
+        this.messages = this.$store._modules.root.state.websocket.message
+      }
     },
 
     reset(){
       this.chatItemList=[]
     },
 
-    // 取消按钮--新增随机产品
-    cancelSelect() {
-      this.open = false;
-    },
-    /** 查询在线聊天记录列表 */
-    getList() {
-      listChatItem(this.queryParams).then(response => {
-          this.chatItemList = response.data;
-      });
-    },
-
     /**发送消息*/
     sendToServer() {
       this.$store.dispatch('websocket_send',"platform," + this.text);
       this.messages = this.$store._modules.root.state.websocket.message
       this.text=''
+    },
+
+    close(){
+      this.open = false;
+      let data = {
+        id:this.chatId,
+        jsonArray:this.messages
+      }
+      saveMessage(data).then(res=>{
+
+      })
     }
+
   }
 }
 </script>
diff --git a/dl_vue/src/views/busi/chatMain/index.vue b/dl_vue/src/views/busi/chatMain/index.vue
index 6d39c74..3c14ccb 100644
--- a/dl_vue/src/views/busi/chatMain/index.vue
+++ b/dl_vue/src/views/busi/chatMain/index.vue
@@ -96,7 +96,7 @@
     <el-table v-loading="loading" :data="chatMainList" @selection-change="handleSelectionChange">
 <!--      <el-table-column type="selection" width="55" align="center" />-->
       <el-table-column type="index" width="60" label="序号" align="center"/>
-      <el-table-column label="客户唯一编码" align="center" prop="cusCode" />
+<!--      <el-table-column label="客户唯一编码" align="center" prop="cusCode" />-->
       <el-table-column  align="center" prop="prodName" :min-width="120">
         <template slot="header" slot-scope="scope">
           <span>产品名称</span>
@@ -116,29 +116,39 @@
       <el-table-column label="洲" align="center" prop="oceania" />
       <el-table-column label="设备类型" align="center" prop="equipment"/>
       <el-table-column label="负责员工" align="center" prop="userName" />
-      <el-table-column  align="center" prop="nums" >
-        <template slot="header" slot-scope="scope">
-          <span>聊天记录数</span>
-          <el-tooltip class="item" effect="dark" content="鼠标单机数据可查看聊天记录"
-                      placement="bottom"
-          >
-            <i class="el-icon-question"></i>
-          </el-tooltip>
-        </template>
-        <template slot-scope="scope">
-          <el-tag style="cursor: pointer" @click="handleDetail(scope.row)">{{scope.row.nums}}</el-tag>
-        </template>
-      </el-table-column>
-      <el-table-column label="最早聊天时间" align="center" prop="createTime" >
+<!--      <el-table-column  align="center" prop="nums" >-->
+<!--        <template slot="header" slot-scope="scope">-->
+<!--          <span>聊天记录数</span>-->
+<!--          <el-tooltip class="item" effect="dark" content="鼠标单机数据可查看聊天记录"-->
+<!--                      placement="bottom"-->
+<!--          >-->
+<!--            <i class="el-icon-question"></i>-->
+<!--          </el-tooltip>-->
+<!--        </template>-->
+<!--        <template slot-scope="scope">-->
+<!--          <el-tag style="cursor: pointer" @click="handleDetail(scope.row)">{{scope.row.nums}}</el-tag>-->
+<!--        </template>-->
+<!--      </el-table-column>-->
+      <el-table-column label="最早聊天时间" width="180" align="center" prop="createTime" >
         <template slot-scope="scope">
           {{scope.row.createTime | formatDate}}
         </template>
       </el-table-column>
-      <el-table-column label="最近聊天时间" align="center" prop="updateTime" >
+      <el-table-column label="最近聊天时间" width="180" align="center" prop="updateTime" >
         <template slot-scope="scope">
           {{scope.row.updateTime | formatDate}}
         </template>
       </el-table-column>
+      <el-table-column label="操作" align="center" class-name="small-padding fixed-width">
+        <template slot-scope="scope">
+          <el-button
+            size="mini"
+            type="text"
+            icon="el-icon-s-comment"
+            @click="handleDetail(scope.row)"
+          >聊天</el-button>
+        </template>
+      </el-table-column>
     </el-table>
 
     <pagination
@@ -265,7 +275,8 @@ export default {
      * @param row
      */
     handleDetail(row){
-      this.$refs.chatFrom.show(row.id,"来自"+row.national+"-"+row.cusCode+"("+row.ip+")聊天记录")
+      console.log(row,'sdfadsafadsf')
+      this.$refs.chatFrom.show(row)
     }
   }
 };