From b5dab616bc724492318766730a53840efe9316c0 Mon Sep 17 00:00:00 2001
From: richboo111 <yangsiqi1376@163.com>
Date: Thu, 27 Apr 2023 16:28:23 +0800
Subject: [PATCH] 1

---
 business/partner/purchase/im/im.go | 23 ++++++++++++++---------
 1 file changed, 14 insertions(+), 9 deletions(-)

diff --git a/business/partner/purchase/im/im.go b/business/partner/purchase/im/im.go
index 76e851100..b6a9c511f 100644
--- a/business/partner/purchase/im/im.go
+++ b/business/partner/purchase/im/im.go
@@ -317,25 +317,28 @@ func GenMsgListID(jxMsg *JXMsg, vendorID int, elmAppID string) (msgID string) {
 }
 
 // GetImUserList 获取门店用户聊天列表
-func GetImUserList(req []RelInfo) (retVal []interface{}, err error) {
+func GetImUserList(req []RelInfo) (map[string][]interface{}, error) {
+	retVal := make(map[string][]interface{}, 0)
 	if len(req) == 0 {
 		return nil, errors.New("msgID不允许为空")
 	}
-	fmt.Printf("测试测试%s", rdb.Get("test"))
 	var keys []string
 	for _, i := range req {
 		key := i.AppID + ":" + i.VendorStoreID + ":" + i.VendorID
 		keys = append(keys, key)
 	}
 	for _, j := range keys {
-		temp := rdb.Get(j)
-		retVal = append(retVal, temp)
+		temp := rdb.LRange(j)
+		for _, v := range temp {
+			retVal[j] = append(retVal[j], v)
+		}
 	}
-	return retVal, err
+	return retVal, nil
 }
 
 // GetImChatDetail 获取门店用户聊天详情
-func GetImChatDetail(req []UserRelInfo) (retVal []interface{}, err error) {
+func GetImChatDetail(req []UserRelInfo) (map[string][]interface{}, error) {
+	retVal := make(map[string][]interface{}, 0)
 	if len(req) == 0 {
 		return nil, errors.New("msgID不允许为空")
 	}
@@ -345,10 +348,12 @@ func GetImChatDetail(req []UserRelInfo) (retVal []interface{}, err error) {
 		keys = append(keys, key)
 	}
 	for _, j := range keys {
-		temp := rdb.Get(j)
-		retVal = append(retVal, temp)
+		temp := rdb.LRange(j)
+		for _, v := range temp {
+			retVal[j] = append(retVal[j], v)
+		}
 	}
-	return retVal, err
+	return retVal, nil
 }
 
 // SetJxMsgRead   设置jx消息已读 userID(美团：openUserID;饿了么：groupID)