user.go 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package db
  2. import (
  3. "context"
  4. "fmt"
  5. "youngee_b_api/model/gorm_model"
  6. "gorm.io/gorm"
  7. )
  8. func CreateUser(ctx context.Context, user gorm_model.YounggeeUser) (*int64, error) {
  9. db := GetReadDB(ctx)
  10. err := db.Create(&user).Error
  11. if err != nil {
  12. return nil, err
  13. }
  14. return &user.ID, nil
  15. }
  16. //GetUserByPhone 查不到返回空
  17. func GetUserByPhone(ctx context.Context, phone string) (*gorm_model.YounggeeUser, error) {
  18. db := GetReadDB(ctx)
  19. user := &gorm_model.YounggeeUser{}
  20. err := db.Model(user).Where("phone = ?", phone).First(user).Error
  21. if err != nil {
  22. if err == gorm.ErrRecordNotFound {
  23. fmt.Println("record not found")
  24. return nil, nil
  25. }
  26. return nil, err
  27. }
  28. return user, nil
  29. }
  30. //GetUserByPhone 查不到返回空
  31. func GetUserByID(ctx context.Context, ID int64) (*gorm_model.YounggeeUser, error) {
  32. db := GetReadDB(ctx)
  33. user := &gorm_model.YounggeeUser{}
  34. err := db.Model(user).Where("id = ?", ID).First(user).Error
  35. if err != nil {
  36. if err == gorm.ErrRecordNotFound {
  37. fmt.Println("record not found")
  38. return nil, nil
  39. }
  40. return nil, err
  41. }
  42. return user, nil
  43. }