fix sse

dao/im.go

@@ -57,7 +57,7 @@ func GetMsgUserByIndex(from_user_id, to_user_id, msg_type, index, status int) ([
 		res = DB.Debug().Where("from_user_id = ? and to_user_id = ? and type = ? and status = ? ", from_user_id, to_user_id, msg_type, status).Order("created_at DESC").Limit(20 * index).Find(&msgs)
 	} else if msg_type == 1 {
 		//单聊,只有两个人的消息
-		res = DB.Debug().Raw("select * from messages where (from_user_id = ? AND to_user_id = ?) or (from_user_id = ? AND to_user_id = ?) and type = ? order by created_at desc limit ?", from_user_id, to_user_id, to_user_id, from_user_id, msg_type, 20*index).Scan(&msgs)
+		res = DB.Debug().Raw("select * from messages where (from_user_id = ? AND to_user_id = ?) and type = ? or (from_user_id = ? AND to_user_id = ?) and type = ? order by created_at desc limit ?", from_user_id, to_user_id, msg_type, to_user_id, from_user_id, msg_type, 20*index).Scan(&msgs)
 		//res = DB.Debug().Where("(from_user_id = ? AND to_user_id = ?) or (from_user_id = ? AND to_user_id = ?) and type = ? ", from_user_id, to_user_id, to_user_id, from_user_id, msg_type).Order("created_at DESC").Limit(20 * index).Find(&msgs)
 	} else {
 		res = DB.Debug().Where("from_user_id = ? and to_user_id = ? and type = ? ", from_user_id, to_user_id, msg_type).Order("created_at DESC").Limit(20 * index).Find(&msgs)

handler/im.go

@@ -362,7 +362,8 @@ func ServerSendMsg(c *gin.Context) {
 			if len(msgs) > 0 {
 				msg := msgs[0]
 				//发送消息
-				_, err := c.Writer.Write([]byte("data: " + msg.Msg + "\n\n"))
+				msg_str, _ := json.Marshal(msg)
+				_, err := c.Writer.Write([]byte("data: " + string(msg_str) + "\n\n"))
 				if err != nil {
 					worker.SetRedisWithExpire("user_"+strconv.Itoa(user_id)+"_status_v2", "0", time.Second*3600)
 					break