117 lines
3.9 KiB
Go
117 lines
3.9 KiB
Go
package chat_message_ctrl
|
|
|
|
import (
|
|
"91porn-server/common"
|
|
"91porn-server/common/log"
|
|
"91porn-server/common/stderr"
|
|
"91porn-server/models/v/messagemod"
|
|
"91porn-server/web/service/chat_message_ser"
|
|
"fmt"
|
|
"github.com/gin-gonic/gin"
|
|
)
|
|
|
|
// List doc
|
|
// @Summary 用户私信列表
|
|
// @Description 用户私信列表
|
|
// @Tags 用户私信
|
|
// @Accept json
|
|
// @Produce json
|
|
// @Param sendUid query int false "发送者uid"
|
|
// @Param takeUid query int false "接收者uid"
|
|
// @Param isRead query boolean false "消息已读or未读"
|
|
// @Param pageNumber query int true "第几页"
|
|
// @Param pageSize query int true "每页数量"
|
|
// @Success 200 object interface{} "成功后返回"
|
|
// @Failure 400 {string} json "{"msg": "操作失败"}"
|
|
// @Router /web/admin/user/chatMessage/list [get]
|
|
func List(ctx *gin.Context) {
|
|
manager, err := common.GetAdminAct(ctx)
|
|
if err != nil {
|
|
common.ServeJSON(ctx, stderr.AdminIDErr, err.Error())
|
|
return
|
|
}
|
|
var req messagemod.WebListRequest
|
|
if err := ctx.ShouldBindQuery(&req); err != nil {
|
|
common.ServeJSON(ctx, stderr.ErrNoToken, err)
|
|
return
|
|
}
|
|
data, code := chat_message_ser.List(&req)
|
|
if code != stderr.Success {
|
|
log.Error(fmt.Sprintf("chat_message_ser web List error%v,manager%v", code.Error(), manager))
|
|
common.ServeJSON(ctx, code, nil)
|
|
return
|
|
}
|
|
common.ServeJSON(ctx, code, data)
|
|
}
|
|
|
|
// Del doc
|
|
// @Summary 删除用户私信
|
|
// @Description 删除用户私信
|
|
// @Tags 用户私信
|
|
// @Accept json
|
|
// @Produce json
|
|
// @Param sendUid query int false "发送者uid"
|
|
// @Param takeUid query int false "接收者uid"
|
|
// @Param isRead query boolean false "消息已读or未读"
|
|
// @Param pageNumber query int true "第几页"
|
|
// @Param pageSize query int true "每页数量"
|
|
// @Success 200 object interface{} "成功后返回"
|
|
// @Failure 400 {string} json "{"msg": "操作失败"}"
|
|
// @Router /web/admin/user/chatMessage/del [delete]
|
|
func Del(ctx *gin.Context) {
|
|
manager, err := common.GetAdminAct(ctx)
|
|
if err != nil {
|
|
common.ServeJSON(ctx, stderr.AdminIDErr, err.Error())
|
|
return
|
|
}
|
|
var req messagemod.WebDelReq
|
|
if err := ctx.ShouldBindQuery(&req); err != nil {
|
|
common.ServeJSON(ctx, stderr.ErrNoToken, err)
|
|
return
|
|
}
|
|
code := chat_message_ser.Del(&req)
|
|
if code != stderr.Success {
|
|
log.Error(fmt.Sprintf("chat_message_ser web Del error%v,manager%v", code.Error(), manager))
|
|
common.ServeJSON(ctx, code, nil)
|
|
return
|
|
}
|
|
common.ServeJSON(ctx, code, stderr.Success.Msg())
|
|
}
|
|
|
|
// Send doc
|
|
// @Summary 发送用户私信
|
|
// @Description 发送用户私信
|
|
// @Tags 用户私信
|
|
// @Accept json
|
|
// @Produce json
|
|
// @Param sender formData int true "发送者uid"
|
|
// @Param receiver formData int true "接收者uid"
|
|
// @Param content formData string true "消息内容"
|
|
// @Success 200 object interface{} "成功后返回"
|
|
// @Failure 400 {string} json "{"msg": "操作失败"}"
|
|
// @Router /api/web/admin/user/chatMessage/send [post]
|
|
func Send(ctx *gin.Context) {
|
|
manager, err := common.GetAdminAct(ctx)
|
|
if err != nil {
|
|
common.ServeJSON(ctx, stderr.AdminIDErr, err.Error())
|
|
return
|
|
}
|
|
var req messagemod.WebSendReq
|
|
if err := ctx.ShouldBind(&req); err != nil {
|
|
common.ServeJSON(ctx, stderr.ErrParamError, err)
|
|
return
|
|
}
|
|
code := chat_message_ser.AddPrivateLetter(&messagemod.SendMsg{
|
|
Sender: req.Sender,
|
|
Receiver: req.Receiver,
|
|
Content: req.Content,
|
|
MsgType: messagemod.PrivateLetterMsg,
|
|
})
|
|
if code != stderr.Success {
|
|
log.Error(fmt.Sprintf("chat_message_ser web Del error%v,manager%v", code.Error(), manager))
|
|
common.ServeJSON(ctx, code, nil)
|
|
return
|
|
}
|
|
common.ServeJSON(ctx, code, stderr.Success.Msg())
|
|
}
|