Merge branch 'refs/heads/feature-im-gitea'
This commit is contained in:
commit
1a9a8ecefc
14
dao/im.go
14
dao/im.go
|
|
@ -195,3 +195,17 @@ func FindGroups(user_id int) []Group {
|
||||||
DB.Debug().Raw("select groups.* from groups join group_users on groups.id = group_users.group_id where group_users.user_id = ?", user_id).Scan(&groups)
|
DB.Debug().Raw("select groups.* from groups join group_users on groups.id = group_users.group_id where group_users.user_id = ?", user_id).Scan(&groups)
|
||||||
return groups
|
return groups
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type FriendRequest struct {
|
||||||
|
ID int `json:"id"`
|
||||||
|
IMID int `json:"im_id"`
|
||||||
|
Name string `json:"name"`
|
||||||
|
Email string `json:"email"`
|
||||||
|
Age int `json:"age"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func GetFriendRequest(user_id int) []FriendRequest {
|
||||||
|
var users []FriendRequest
|
||||||
|
DB.Debug().Raw("select users.id,users.name,users.email,users.age,messages.id as im_id from users join messages on users.id = messages.from_user_id where messages.to_user_id = ? and messages.type = ? and status = ?", user_id, proto.MSG_TYPE_FRIEND, 0).Scan(&users)
|
||||||
|
return users
|
||||||
|
}
|
||||||
|
|
|
||||||
|
|
@ -68,6 +68,8 @@ func SetUpIMGroup(router *gin.Engine) {
|
||||||
imGroup.GET("/sse_msg", ServerSendMsg)
|
imGroup.GET("/sse_msg", ServerSendMsg)
|
||||||
imGroup.GET("/ws_v2", ServerSsendMsgV2)
|
imGroup.GET("/ws_v2", ServerSsendMsgV2)
|
||||||
imGroup.POST("/get_friend_list", GetFriendList) //获取好友列表,包括群聊
|
imGroup.POST("/get_friend_list", GetFriendList) //获取好友列表,包括群聊
|
||||||
|
//获取好友请求
|
||||||
|
imGroup.POST("/get_friend_request", GetFriendRequest)
|
||||||
}
|
}
|
||||||
func generateRandomHexString(length int) (string, error) {
|
func generateRandomHexString(length int) (string, error) {
|
||||||
bytes := make([]byte, length/2) // 16字节的字符串需要32个十六进制字符,即16个字节
|
bytes := make([]byte, length/2) // 16字节的字符串需要32个十六进制字符,即16个字节
|
||||||
|
|
@ -101,6 +103,14 @@ func GetMessage(c *gin.Context) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetFriendRequest(c *gin.Context) {
|
||||||
|
id, _ := c.Get("id")
|
||||||
|
user_id := int(id.(float64))
|
||||||
|
data := service.GetFriendRequest(user_id)
|
||||||
|
c.JSON(http.StatusOK, gin.H{"code": proto.SuccessCode, "data": data, "message": "success"})
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
func CreateGroup(c *gin.Context) {
|
func CreateGroup(c *gin.Context) {
|
||||||
var req CGroup
|
var req CGroup
|
||||||
id, _ := c.Get("id")
|
id, _ := c.Get("id")
|
||||||
|
|
|
||||||
|
|
@ -123,3 +123,9 @@ func GetFriendList(user_id int) FGRet {
|
||||||
fg.Groups = groups
|
fg.Groups = groups
|
||||||
return fg
|
return fg
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func GetFriendRequest(user_id int) []dao.User {
|
||||||
|
//获取好友请求
|
||||||
|
users := dao.GetFriendRequest(user_id)
|
||||||
|
return users
|
||||||
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue