From 1ddae204b64150fb2765a5309448aaa0e33f4ec0 Mon Sep 17 00:00:00 2001
From: DengBiao <2319963317@qq.com>
Date: Tue, 28 Feb 2023 20:57:36 +0800
Subject: [PATCH] update

---
 internal/logic/domain/message/service/message_service.go | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/internal/logic/domain/message/service/message_service.go b/internal/logic/domain/message/service/message_service.go
index 63ea96a..1fcd618 100644
--- a/internal/logic/domain/message/service/message_service.go
+++ b/internal/logic/domain/message/service/message_service.go
@@ -159,6 +159,13 @@ func (*messageService) SendToUser(ctx context.Context, sender *pb.Sender, toUser
 		return 0, err
 	}
 
+	// 查询接受者用户在线设备
+	receiverDevices, err := proxy.DeviceProxy.ListOnlineByUserId(ctx, req.ReceiverId)
+	if err != nil {
+		logger.Sugar.Error(err)
+		return 0, err
+	}
+
 	isOpenAppPush := svc.SysCfgGet(masterId, "is_open_app_push")
 	utils.FilePutContents("SendToUser", utils.SerializeStr(map[string]interface{}{
 		"devices_len":   len(devices),
@@ -168,7 +175,7 @@ func (*messageService) SendToUser(ctx context.Context, sender *pb.Sender, toUser
 		"req":           req,
 	}))
 
-	if len(devices) <= 0 {
+	if len(receiverDevices) <= 0 {
 		//isOpenAppPush := svc.SysCfgGet(masterId, "is_open_app_push")
 		if sender.SenderType == pb.SenderType_ST_USER && req.ReceiverType == pb.ReceiverType_RT_USER && isOpenAppPush == "1" && req.ReceiverId != toUserId {
 			uid := strconv.FormatInt(req.ReceiverId, 10)