From 166030e3b83a8bfb009d984fc6c389dab004125c Mon Sep 17 00:00:00 2001
From: puhui999 <puhui999@163.com>
Date: Tue, 2 Jul 2024 17:10:17 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=A2=E6=9C=8D=EF=BC=9A=E4=BD=BF=E7=94=A8?=
 =?UTF-8?q?=E8=BD=AE=E8=AE=AD=E6=A8=A1=E6=8B=9F=20websocket?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pages/chat/components/chatBox.vue | 19 ++++++++++++++++++-
 pages/chat/index.vue              |  3 ++-
 2 files changed, 20 insertions(+), 2 deletions(-)

diff --git a/pages/chat/components/chatBox.vue b/pages/chat/components/chatBox.vue
index e89ddd98..1f19e413 100644
--- a/pages/chat/components/chatBox.vue
+++ b/pages/chat/components/chatBox.vue
@@ -133,7 +133,7 @@
 </template>
 
 <script setup>
-  import { nextTick, reactive, ref, unref } from 'vue';
+  import { nextTick, onMounted,onBeforeUnmount, reactive, ref, unref } from 'vue';
   import { onLoad } from '@dcloudio/uni-app';
   import sheep from '@/sheep';
   import KeFuApi from '@/sheep/api/promotion/kefu';
@@ -174,6 +174,23 @@
     scrollData.value[pageNo ? pageNo - 1 : currentShowPage.value - 1] = data.list;
   };
   defineExpose({ getMessageList });
+
+  const poller = ref(null) // TODO puhui999: 轮训定时器，暂时模拟 websocket
+  onMounted(() => {
+    // TODO puhui999: 轮训相关，功能完善后移除
+    if (!poller.value) {
+      poller.value = setInterval(() => {
+        getMessageList(1)
+      }, 1000)
+    }
+  })
+  // TODO puhui999: 轮训相关，功能完善后移除
+  onBeforeUnmount(() => {
+    if (!poller.value) {
+      return
+    }
+    clearInterval(poller.value)
+  })
   const scrollTop = ref(0); // 当前滚动区域距离顶部的距离
   const currentTop = ref(0);
   const showGoBottom = ref(false);
diff --git a/pages/chat/index.vue b/pages/chat/index.vue
index 4614fa34..4a06139a 100644
--- a/pages/chat/index.vue
+++ b/pages/chat/index.vue
@@ -166,7 +166,8 @@
   //======================= 聊天工具相关 end =======================
 
   onLoad(async () => {
-    socketInit({}, () => {
+    socketInit({}, (res) => {
+      console.log(res);
     // 监听服务端消息
     });
     await nextTick()