1

business/partner/purchase/im/im.go

@@ -87,7 +87,7 @@ func Send(data []byte) {
 			break
 		} else {
 			temp := string(msg)
-			if temp != HeartCheckSuccess {
+			if temp != HeartCheckSuccess || temp != "成功" {
 				ReadMsgFromVendor(VendorIDMT, "", msg)
 			}
 		}
@@ -358,19 +358,33 @@ func GetImChatDetail(req []UserRelInfo) (map[string][]interface{}, error) {
 
 // SetJxMsgRead   设置jx消息已读 userID(美团：openUserID;饿了么：groupID)
 func SetJxMsgRead(appID, vendorStoreID, vendorID, userID string) error {
-	key := appID + ":" + vendorStoreID + ":" + vendorID
+	var (
+		temp = UserMessageList{}
+		key  = appID + ":" + vendorStoreID + ":" + vendorID
+	)
 	if n, err := rdb.Exists(key); n > 0 && err == nil {
 		s2 := rdb.LRange(key)
 		for i := 0; i < len(s2); i++ {
 			v := UserMessageList{}
 			_ = json.Unmarshal([]byte(s2[i]), &v)
 			if v.UserID == userID {
+				//删除此条数据
 				err = rdb.LSet(key, i, "del")
 				err = rdb.LRem(key, 0, "del")
 				s2 = append(s2[:i], s2[i+1:]...)
 				i--
+				//cnt=0 重新赋值
+				temp = UserMessageList{
+					VendorID:      v.VendorID,
+					UserID:        v.UserID,
+					NewMessageNum: 0,
+					LatestMsg:     v.LatestMsg,
+					LatestTime:    v.LatestTime,
+				}
 			}
 		}
+		str, _ := json.Marshal(temp)
+		err = rdb.RPush(key, str)
 	}
 	return nil
 }