1

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)