register.go 1.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package service
  2. import (
  3. "context"
  4. "fmt"
  5. "time"
  6. "youngee_b_api/consts"
  7. "youngee_b_api/db"
  8. "youngee_b_api/redis"
  9. )
  10. var Register *register
  11. type register struct {
  12. sessionTTL time.Duration
  13. }
  14. func (r *register) AuthRegister(ctx context.Context, phone string, code string) (string, error) {
  15. user, err := db.GetUserByPhone(ctx, phone)
  16. if err != nil {
  17. return "", err
  18. } else if user != nil {
  19. return "手机号已存在", nil
  20. } else {
  21. vcode, err := r.getSession(ctx, phone)
  22. if err != nil {
  23. return "", err
  24. } else {
  25. if *vcode != code {
  26. return "验证码有误", nil
  27. } else {
  28. return "", nil
  29. }
  30. }
  31. }
  32. }
  33. func (r *register) getSession(ctx context.Context, phone string) (*string, error) {
  34. value, err := redis.Get(ctx, r.getRedisKey(phone))
  35. if err != nil {
  36. if err == consts.RedisNil {
  37. return nil, fmt.Errorf("not found in redis,phone:%+v", phone)
  38. }
  39. return nil, err
  40. }
  41. return &value, nil
  42. }
  43. func (r *register) getRedisKey(key string) string {
  44. return fmt.Sprintf("%s%s", consts.SessionRedisPrefix, key)
  45. }