|
@@ -33,70 +33,8 @@ func NewSynthesis() *Synthesis {
|
|
|
|
|
|
// 统计用户相关信息
|
|
// 统计用户相关信息
|
|
func (s *Synthesis) UserList(req entity.UserListReq) (*entity.UserListResp, *code.Result) {
|
|
func (s *Synthesis) UserList(req entity.UserListReq) (*entity.UserListResp, *code.Result) {
|
|
- // 验证参数
|
|
|
|
- page := req.Page
|
|
|
|
- if req.Page <= 0 {
|
|
|
|
- page = 1
|
|
|
|
- }
|
|
|
|
- pageSize := req.Size
|
|
|
|
- if req.Size <= 0 {
|
|
|
|
- pageSize = 10
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- // 构建查询条件
|
|
|
|
- filter := bson.M{}
|
|
|
|
- if req.UserName != "" {
|
|
|
|
- filter["userName"] = req.UserName
|
|
|
|
- }
|
|
|
|
- if req.NickName != "" {
|
|
|
|
- filter["nickName"] = req.NickName
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- // 设置分页选项
|
|
|
|
- findOptions := options.Find()
|
|
|
|
- findOptions.SetSkip(int64((page - 1) * pageSize))
|
|
|
|
- findOptions.SetLimit(int64(pageSize))
|
|
|
|
- findOptions.SetSort(bson.D{{"createTime", -1}})
|
|
|
|
-
|
|
|
|
- collection := mdb.MDB.Collection(constant.CNamePlayer)
|
|
|
|
- // 获取总数total
|
|
|
|
- count, err := collection.CountDocuments(ctx, filter)
|
|
|
|
- if err != nil {
|
|
|
|
- mhayaLogger.Warnf("UserList CountDocuments error:%v", err)
|
|
|
|
- return nil, common.NewResult(code.InternalError)
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
// TODO UserList 统计用户相关信息
|
|
// TODO UserList 统计用户相关信息
|
|
- // 查询数据
|
|
|
|
- var results []*entity.UserListDetail
|
|
|
|
- ctx, cancel := context.WithTimeout(context.Background(), 100*time.Second)
|
|
|
|
- defer cancel()
|
|
|
|
- cursor, err := collection.Find(ctx, filter, findOptions)
|
|
|
|
- if err != nil {
|
|
|
|
- mhayaLogger.Warnf("UserList Find error:%v", err)
|
|
|
|
- return nil, common.NewResult(code.InternalError)
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- defer cursor.Close(ctx)
|
|
|
|
- // 解析结果
|
|
|
|
- for cursor.Next(ctx) {
|
|
|
|
- var result entity.UserListDetail
|
|
|
|
- if err := cursor.Decode(&result); err != nil {
|
|
|
|
- mhayaLogger.Warnf("UserList Decode error:%v", err)
|
|
|
|
- return nil, common.NewResult(code.InternalError)
|
|
|
|
- }
|
|
|
|
- results = append(results, &result)
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- if err := cursor.Err(); err != nil {
|
|
|
|
- mhayaLogger.Warnf("UserList cursor error:%v", err)
|
|
|
|
- return nil, common.NewResult(code.InternalError)
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- return &entity.UserListResp{
|
|
|
|
- Details: results,
|
|
|
|
- Total: count,
|
|
|
|
- }, nil
|
|
|
|
|
|
+ return nil, nil
|
|
}
|
|
}
|
|
|
|
|
|
func (s *Synthesis) FindMDBUserLogDaily(req entity.UserLogDailyReq) (*entity.UserLogDailyResp, *code.Result) {
|
|
func (s *Synthesis) FindMDBUserLogDaily(req entity.UserLogDailyReq) (*entity.UserLogDailyResp, *code.Result) {
|
|
@@ -731,21 +669,3 @@ func (s *Synthesis) RecordList(req entity.RecordListReq) (*entity.RecordListResp
|
|
Total: count,
|
|
Total: count,
|
|
}, nil
|
|
}, nil
|
|
}
|
|
}
|
|
-
|
|
|
|
-// 转盘统计
|
|
|
|
-func (s *Synthesis) Turntable(req entity.TurntableReq) (*entity.TurntableResp, *code.Result) {
|
|
|
|
- // TODO Turntable 转盘统计
|
|
|
|
- return nil, nil
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
-// 资产统计
|
|
|
|
-func (s *Synthesis) Assets(req entity.AssetsReq) (*entity.AssetsResp, *code.Result) {
|
|
|
|
- // TODO Assets 资产统计
|
|
|
|
- return nil, nil
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
-// 邀请统计
|
|
|
|
-func (s *Synthesis) Invite(req entity.InviteReq) (*entity.InviteResp, *code.Result) {
|
|
|
|
- // TODO Invite 邀请统计
|
|
|
|
- return nil, nil
|
|
|
|
-}
|
|
|