86 lines
2.1 KiB
Go
86 lines
2.1 KiB
Go
package logic
|
|
|
|
import (
|
|
"context"
|
|
"lone-services/pkg/modelbase"
|
|
"lone-services/pkg/utils"
|
|
admin "lone-services/rpc/admin/pb"
|
|
sale "lone-services/rpc/sale/pb"
|
|
"lone-services/services/admin/internal/dao"
|
|
"lone-services/services/admin/internal/model"
|
|
"lone-services/services/admin/internal/svc"
|
|
"lone-services/services/admin/validator"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
)
|
|
|
|
type AdminInfoLogic struct {
|
|
ctx context.Context
|
|
svcCtx *svc.ServiceContext
|
|
logx.Logger
|
|
BaseLogic
|
|
}
|
|
|
|
func NewAdminInfoLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AdminInfoLogic {
|
|
return &AdminInfoLogic{
|
|
ctx: ctx,
|
|
svcCtx: svcCtx,
|
|
Logger: logx.WithContext(ctx),
|
|
}
|
|
}
|
|
|
|
func (l *AdminInfoLogic) AdminInfo(in *admin.AdminInfoRequest) (*admin.Response, error) {
|
|
var v validator.AdminInfoValidator
|
|
if fail := l.checkParams(in, &v); fail != nil {
|
|
return fail, nil
|
|
}
|
|
|
|
info := dao.AdminInfo{}
|
|
modelObj := model.AdminModel{}.Init()
|
|
w := modelbase.Params{Eq: map[string]string{"id": strconv.Itoa(int(in.Id))}}
|
|
err := modelObj.GetOne(w, &info)
|
|
if err != nil {
|
|
return l.fail(utils.ErrorNotFund)
|
|
}
|
|
if info.Id > utils.NumberZero {
|
|
mobile, dErr := utils.DecryptPhone(info.Phone)
|
|
if dErr == nil {
|
|
info.Phone = mobile
|
|
}
|
|
}
|
|
|
|
var roles []int
|
|
if len(roles) > utils.NumberZero {
|
|
for _, role := range strings.Split(info.Roles, utils.DecollatorComma) {
|
|
r, _ := strconv.Atoi(role)
|
|
roles = append(roles, r)
|
|
}
|
|
}
|
|
if info.Type == dao.AdminTypeSale {
|
|
cli, err := svc.GetRpcClient(l.svcCtx.SaleSvcName)
|
|
if err != nil {
|
|
logx.Errorf("get rpc client err: %v", err)
|
|
return l.fail(utils.ErrorInternalServer)
|
|
}
|
|
saleClient := sale.NewSaleClient(cli.Conn())
|
|
saleInfo, err := saleClient.InfoInternal(context.Background(), &sale.InfoReq{Id: info.SaleId})
|
|
if err != nil {
|
|
logx.Errorf("get sale err: %v", err)
|
|
return l.fail(utils.ErrorInternalServer)
|
|
}
|
|
|
|
info.GroupName = saleInfo.Group.Name
|
|
info.GroupId = saleInfo.GroupId
|
|
info.SaleName = saleInfo.Name
|
|
}
|
|
|
|
retData := dao.AdminInfoRet{
|
|
AdminInfo: info,
|
|
Roles: roles,
|
|
}
|
|
|
|
return l.ok(retData)
|
|
}
|