From df343d273126aad1e3508b4ad8506f946404c410 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=BB=9D=E5=B0=98?= <237809796@qq.com>
Date: Fri, 26 Jul 2024 18:56:27 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=EF=BC=9A=E7=94=A8=E6=88=B7?=
 =?UTF-8?q?=E4=B8=8A=E4=B8=8B=E7=BA=BF=E4=BA=8B=E4=BB=B6=E6=8E=A8=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/com/zchd/zim/ImChatService.java    | 2 +-
 src/com/zchd/zim/ImMessageMonitor.java | 4 ++++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/com/zchd/zim/ImChatService.java b/src/com/zchd/zim/ImChatService.java
index 4cf9c9e..71c7f06 100644
--- a/src/com/zchd/zim/ImChatService.java
+++ b/src/com/zchd/zim/ImChatService.java
@@ -201,7 +201,7 @@ public class ImChatService extends BaseService {
         zhub.broadcast("im:channel:" + message.buildChannelid(), message);
     }
 
-    private String getGuserid(int userid) {
+    protected String getGuserid(int userid) {
         if (userid == 0) {
             return "0";
         }
diff --git a/src/com/zchd/zim/ImMessageMonitor.java b/src/com/zchd/zim/ImMessageMonitor.java
index 73699a5..adbec10 100644
--- a/src/com/zchd/zim/ImMessageMonitor.java
+++ b/src/com/zchd/zim/ImMessageMonitor.java
@@ -74,6 +74,8 @@ public class ImMessageMonitor extends BaseService {
         list.forEach(x -> {
             subscribeChannel(userid, x.buildChannelid());
         });
+        // 推送上线状态
+        zhub.publish("im:online", chatService.getGuserid(userid));
 
         // 开启对点订阅
         zhub.subscribe("im:friend:" + userid, new TypeToken<FriendMessage>() {
@@ -91,6 +93,8 @@ public class ImMessageMonitor extends BaseService {
 
         // 取消点对点订阅
         zhub.unsubscribe("im:friend:" + userid);
+        // 推送离线状态
+        zhub.publish("im:offline", chatService.getGuserid(userid));
 
         // 取消频道订阅
         List<ChannelUser> list = chatService.userChannels(userid);