service/app/mix/controller/account_op.go

256 lines
6.7 KiB
Go

package controller
import (
"service/api/consts"
"service/api/errcode"
accountproto "service/api/proto/account/proto"
"service/app/mix/service"
"service/bizcommon/util"
"service/library/logger"
"service/library/mediafiller"
"github.com/gin-gonic/gin"
)
func OpUpdateAccount(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpUpdateReq)
ec := service.DefaultService.OpUpdateAccount(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpUpdateAccount fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
ReplyOk(ctx, nil)
}
func OpGetAccountListByMid(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpListByMidReq)
account, ec := service.DefaultService.OpGetAccountListByMid(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetAccountListByMid fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
//填充媒体
mediafiller.FillEntity(ctx, account.Avatar)
data := &accountproto.OpListByMidData{
Account: account,
}
ReplyOk(ctx, data)
}
func OpGetAccountListByMids(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpListByMidsReq)
//设置默认页长
if req.Limit == 0 {
req.Limit = consts.DefaultPageSize
}
list, ec := service.DefaultService.OpGetAccountListByMids(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetAccountListByMids fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
//填充媒体切片
objectMediaNum := 1 // 单个用户服务总共1个媒体类
mediaFillableList := make([]mediafiller.MediaFillable, len(list)*objectMediaNum)
for i, account := range list {
mediaFillableList[objectMediaNum*i+0] = account.Avatar
}
mediafiller.FillList(ctx, mediaFillableList)
data := &accountproto.OpListByMidsData{
List: list,
Offset: req.Offset + len(list),
}
if len(list) >= req.Limit {
data.More = 1
}
ReplyOk(ctx, data)
}
func OpGetAccountListByUserId(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpListByUserIdReq)
account, ec := service.DefaultService.OpGetAccountListByUserId(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetAccountListByUserId fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
//填充媒体
mediafiller.FillEntity(ctx, account.Avatar)
data := &accountproto.OpListByUserIdData{
Account: account,
}
ReplyOk(ctx, data)
}
func OpGetMobilePhoneByUserId(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpGetMobilePhoneByUserIdReq)
mobilePhone, ec := service.DefaultService.OpGetMobilePhoneByUserId(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetMobilePhoneByUserId fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
data := &accountproto.OpGetMobilePhoneByUserIdData{
MobilePhone: mobilePhone,
}
ReplyOk(ctx, data)
}
func OpGetAccountListFuzzilyByUserId(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpListFuzzilyByUserIdReq)
//设置默认页长
if req.Limit == 0 {
req.Limit = consts.DefaultPageSize
}
list, ec := service.DefaultService.OpGetAccountListFuzzilyByUserId(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetAccountListFuzzilyByUserId fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
//填充媒体切片
objectMediaNum := 1 // 单个用户服务总共1个媒体类
mediaFillableListFuzzily := make([]mediafiller.MediaFillable, len(list)*objectMediaNum)
for i, account := range list {
mediaFillableListFuzzily[objectMediaNum*i+0] = account.Avatar
}
mediafiller.FillList(ctx, mediaFillableListFuzzily)
data := &accountproto.OpListFuzzilyByUserIdData{
List: list,
Offset: req.Offset + len(list),
}
if len(list) >= req.Limit {
data.More = 1
}
ReplyOk(ctx, data)
}
func OpGetAccountListFuzzilyByName(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpListFuzzilyByNameReq)
//设置默认页长
if req.Limit == 0 {
req.Limit = consts.DefaultPageSize
}
list, ec := service.DefaultService.OpGetAccountListFuzzilyByName(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetAccountListFuzzilyByName fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
//填充媒体切片
objectMediaNum := 1 // 单个用户服务总共1个媒体类
mediaFillableListFuzzily := make([]mediafiller.MediaFillable, len(list)*objectMediaNum)
for i, account := range list {
mediaFillableListFuzzily[objectMediaNum*i+0] = account.Avatar
}
mediafiller.FillList(ctx, mediaFillableListFuzzily)
data := &accountproto.OpListFuzzilyByNameData{
List: list,
Offset: req.Offset + len(list),
}
if len(list) >= req.Limit {
data.More = 1
}
ReplyOk(ctx, data)
}
func OpGetAccountListForOthersByMid(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpListOthersByMidReq)
account, ec := service.DefaultService.OpGetAccountListForOthersByMid(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetAccountListOthersByMid fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
//填充媒体
mediafiller.FillEntity(ctx, account.Avatar)
data := &accountproto.OpListOthersByMidData{
Account: account,
}
ReplyOk(ctx, data)
}
func OpGetAccountListForOthersByMids(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpListOthersByMidsReq)
//设置默认页长
if req.Limit == 0 {
req.Limit = consts.DefaultPageSize
}
list, ec := service.DefaultService.OpGetAccountListForOthersByMids(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetAccountListForOthersByMids fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
//填充媒体切片
objectMediaNum := 1 // 单个用户服务总共1个媒体类
mediaFillableList := make([]mediafiller.MediaFillable, len(list)*objectMediaNum)
for i, account := range list {
mediaFillableList[objectMediaNum*i+0] = account.Avatar
}
mediafiller.FillList(ctx, mediaFillableList)
data := &accountproto.OpListOthersByMidsData{
List: list,
Offset: req.Offset + len(list),
}
if len(list) >= req.Limit {
data.More = 1
}
ReplyOk(ctx, data)
}
func OpGetAccountCount(ctx *gin.Context) {
req := ctx.MustGet("client_req").(*accountproto.OpCountReq)
count, ec := service.DefaultService.OpGetAccountCount(ctx, req)
if ec != errcode.ErrCodeAccountSrvOk {
logger.Error("OpGetAccountCount fail, req: %v, ec: %v", util.ToJson(req), ec)
ReplyErrCodeMsg(ctx, ec)
return
}
data := &accountproto.OpCountData{
Count: count,
}
ReplyOk(ctx, data)
}