83 lines
1.5 KiB
Go
83 lines
1.5 KiB
Go
|
package usermngmt
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"sync"
|
||
|
|
|
||
|
|
"go.mongodb.org/mongo-driver/bson"
|
||
|
|
)
|
||
|
|
|
||
|
|
// AllQuery ...
|
||
|
|
type AllQuery struct {
|
||
|
|
Page int64
|
||
|
|
Limit int64
|
||
|
|
Keyword string
|
||
|
|
RoleID string
|
||
|
|
Status string
|
||
|
|
}
|
||
|
|
|
||
|
|
// All ...
|
||
|
|
func (s Service) All(queryParams AllQuery) (r ResponseUserAll) {
|
||
|
|
var (
|
||
|
|
ctx = context.Background()
|
||
|
|
wg sync.WaitGroup
|
||
|
|
cond = bson.M{}
|
||
|
|
)
|
||
|
|
query := commonQuery{
|
||
|
|
Page: queryParams.Page,
|
||
|
|
Limit: queryParams.Limit,
|
||
|
|
Keyword: queryParams.Keyword,
|
||
|
|
RoleID: queryParams.RoleID,
|
||
|
|
Status: queryParams.Status,
|
||
|
|
Sort: bson.M{"createdAt": -1},
|
||
|
|
}
|
||
|
|
|
||
|
|
// Assign condition
|
||
|
|
query.SetDefaultLimit()
|
||
|
|
query.AssignKeyword(cond)
|
||
|
|
query.AssignRoleID(cond)
|
||
|
|
query.AssignStatus(cond)
|
||
|
|
|
||
|
|
wg.Add(1)
|
||
|
|
go func() {
|
||
|
|
defer wg.Done()
|
||
|
|
docs := s.userFindByCondition(ctx, cond, query.GetFindOptionsUsingPage())
|
||
|
|
r.List = getResponseList(ctx, docs)
|
||
|
|
}()
|
||
|
|
|
||
|
|
wg.Add(1)
|
||
|
|
go func() {
|
||
|
|
defer wg.Done()
|
||
|
|
r.Total = s.userCountByCondition(ctx, cond)
|
||
|
|
}()
|
||
|
|
|
||
|
|
wg.Wait()
|
||
|
|
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
func getResponseList(ctx context.Context, users []User) []ResponseUser {
|
||
|
|
res := make([]ResponseUser, 0)
|
||
|
|
|
||
|
|
for _, user := range users {
|
||
|
|
role, _ := s.roleFindByID(ctx, user.RoleID)
|
||
|
|
res = append(res, ResponseUser{
|
||
|
|
ID: user.ID.Hex(),
|
||
|
|
Name: user.Name,
|
||
|
|
Phone: user.Phone,
|
||
|
|
Email: user.Email,
|
||
|
|
Status: user.Status,
|
||
|
|
Role: RoleShort{
|
||
|
|
ID: role.ID.Hex(),
|
||
|
|
Name: role.Name,
|
||
|
|
IsAdmin: role.IsAdmin,
|
||
|
|
},
|
||
|
|
Other: user.Other,
|
||
|
|
CreatedAt: user.CreatedAt,
|
||
|
|
UpdatedAt: user.UpdatedAt,
|
||
|
|
})
|
||
|
|
}
|
||
|
|
|
||
|
|
return res
|
||
|
|
}
|