Selly-Modules
/
usermngmt
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix code #13

Merged
nguyenphamquangtue merged 1 commits from feature/merchant into master 2022-10-06 02:26:01 +00:00
Conversation 0 Commits 1 Files Changed 1 +68 -36
1 changed files with 68 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
user/db.go
View File

@ -24,8 +24,9 @@ func isPhoneNumberExisted(ctx context.Context, phone string) bool {
total, err := col.CountDocuments(ctx, cond) total, err := col.CountDocuments(ctx, cond)
if err != nil { if err != nil {
logger.Error("usermngmt - User - CountDocuments", logger.LogData{ logger.Error("usermngmt - User - CountDocuments", logger.LogData{
"condition": cond, Source: "usermngmt.user.isPhoneNumberExisted",
"err": err.Error(), Message: err.Error(),
Data: cond,
}) })
return true return true
} }
@ -44,8 +45,9 @@ func isEmailExisted(ctx context.Context, email string) bool {
total, err := col.CountDocuments(ctx, cond) total, err := col.CountDocuments(ctx, cond)
if err != nil { if err != nil {
logger.Error("usermngmt - User - CountDocuments", logger.LogData{ logger.Error("usermngmt - User - CountDocuments", logger.LogData{
"condition": cond, Source: "usermngmt.user.isEmailExisted",
"err": err.Error(), Message: err.Error(),
Data: cond,
}) })
return true return true
} }
@ -63,8 +65,9 @@ func isRoleExisted(ctx context.Context, roleID primitive.ObjectID) bool {
total, err := col.CountDocuments(ctx, cond) total, err := col.CountDocuments(ctx, cond)
if err != nil { if err != nil {
logger.Error("usermngmt - Role - CountDocuments", logger.LogData{ logger.Error("usermngmt - Role - CountDocuments", logger.LogData{
"condition": cond, Source: "usermngmt.user.isRoleExisted",
"err": err.Error(), Message: err.Error(),
Data: cond,
}) })
} }
return total != 0 return total != 0
@ -88,18 +91,24 @@ func roleFindByCondition(ctx context.Context, cond interface{}, opts ...*options
cursor, err := col.Find(ctx, cond, opts...) cursor, err := col.Find(ctx, cond, opts...)
if err != nil { if err != nil {
logger.Error("usermngmt - Role - Find", logger.LogData{ logger.Error("usermngmt - Role - Find", logger.LogData{
Source: "usermngmt.user.roleFindByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
"opts": opts, "opts": opts,
"err": err.Error(), },
}) })
return return
} }
defer cursor.Close(ctx) defer cursor.Close(ctx)
if err = cursor.All(ctx, &docs); err != nil { if err = cursor.All(ctx, &docs); err != nil {
logger.Error("usermngmt - Role - Decode", logger.LogData{ logger.Error("usermngmt - Role - Decode", logger.LogData{
Source: "usermngmt.user.roleFindByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
"opts": opts, "opts": opts,
"err": err.Error(), },
}) })
return return
} }
@ -115,18 +124,24 @@ func permissionFindByCondition(ctx context.Context, cond interface{}, opts ...*o
cursor, err := col.Find(ctx, cond, opts...) cursor, err := col.Find(ctx, cond, opts...)
if err != nil { if err != nil {
logger.Error("usermngmt - Permission - Find", logger.LogData{ logger.Error("usermngmt - Permission - Find", logger.LogData{
Source: "usermngmt.user.permissionFindByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
"opts": opts, "opts": opts,
"err": err.Error(), },
}) })
return return
} }
defer cursor.Close(ctx) defer cursor.Close(ctx)
if err = cursor.All(ctx, &docs); err != nil { if err = cursor.All(ctx, &docs); err != nil {
logger.Error("usermngmt - Permission - Decode", logger.LogData{ logger.Error("usermngmt - Permission - Decode", logger.LogData{
Source: "usermngmt.user.permissionFindByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
"opts": opts, "opts": opts,
"err": err.Error(), },
}) })
return return
} }
@ -141,8 +156,9 @@ func permissionCountByCondition(ctx context.Context, cond interface{}) int64 {
total, err := col.CountDocuments(ctx, cond) total, err := col.CountDocuments(ctx, cond)
if err != nil { if err != nil {
logger.Error("usermngmt - Permission - CountDocuments", logger.LogData{ logger.Error("usermngmt - Permission - CountDocuments", logger.LogData{
"err": err.Error(), Source: "usermngmt.user.permissionCountByCondition",
"cond": cond, Message: err.Error(),
Data: cond,
}) })
} }
return total return total
@ -155,8 +171,9 @@ func create(ctx context.Context, doc model.DBUser) error {
_, err := col.InsertOne(ctx, doc) _, err := col.InsertOne(ctx, doc)
if err != nil { if err != nil {
logger.Error("usermngmt - User - InsertOne", logger.LogData{ logger.Error("usermngmt - User - InsertOne", logger.LogData{
"doc": doc, Source: "usermngmt.user.create",
"err": err.Error(), Message: err.Error(),
Data: doc,
}) })
return fmt.Errorf("error when create user: %s", err.Error()) return fmt.Errorf("error when create user: %s", err.Error())
} }
@ -171,9 +188,12 @@ func updateOneByCondition(ctx context.Context, cond interface{}, payload interfa
_, err := col.UpdateOne(ctx, cond, payload) _, err := col.UpdateOne(ctx, cond, payload)
if err != nil { if err != nil {
logger.Error("usermngmt - User - UpdateOne", logger.LogData{ logger.Error("usermngmt - User - UpdateOne", logger.LogData{
Source: "usermngmt.user.updateOneByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
"payload": payload, "payload": payload,
"err": err.Error(), },
}) })
return fmt.Errorf("error when update user: %s", err.Error()) return fmt.Errorf("error when update user: %s", err.Error())
} }
@ -188,9 +208,12 @@ func updateManyByCondition(ctx context.Context, cond interface{}, payload interf
_, err := col.UpdateMany(ctx, cond, payload) _, err := col.UpdateMany(ctx, cond, payload)
if err != nil { if err != nil {
logger.Error("usermngmt - User - UpdateMany", logger.LogData{ logger.Error("usermngmt - User - UpdateMany", logger.LogData{
Source: "usermngmt.user.updateManyByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
"payload": payload, "payload": payload,
"err": err.Error(), },
}) })
return fmt.Errorf("error when update user: %s", err.Error()) return fmt.Errorf("error when update user: %s", err.Error())
} }
@ -216,18 +239,24 @@ func findByCondition(ctx context.Context, cond interface{}, opts ...*options.Fin
cursor, err := col.Find(ctx, cond, opts...) cursor, err := col.Find(ctx, cond, opts...)
if err != nil { if err != nil {
logger.Error("usermngmt - User - Find", logger.LogData{ logger.Error("usermngmt - User - Find", logger.LogData{
Source: "usermngmt.user.findByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
"opts": opts, "opts": opts,
"err": err.Error(), },
}) })
return return
} }
defer cursor.Close(ctx) defer cursor.Close(ctx)
if err = cursor.All(ctx, &docs); err != nil { if err = cursor.All(ctx, &docs); err != nil {
logger.Error("usermngmt - User - Decode", logger.LogData{ logger.Error("usermngmt - User - Decode", logger.LogData{
Source: "usermngmt.user.findByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
"opts": opts, "opts": opts,
"err": err.Error(), },
}) })
return return
} }
@ -242,8 +271,11 @@ func countByCondition(ctx context.Context, cond interface{}) int64 {
total, err := col.CountDocuments(ctx, cond) total, err := col.CountDocuments(ctx, cond)
if err != nil { if err != nil {
logger.Error("usermngmt - Count", logger.LogData{ logger.Error("usermngmt - Count", logger.LogData{
"err": err.Error(), Source: "usermngmt.user.countByCondition",
Message: err.Error(),
Data: map[string]interface{}{
"cond": cond, "cond": cond,
},
}) })
} }
return total return total