eta_mini_api/services/user.go

package services

import (
	"errors"
	"eta/eta_mini_api/models"
	"eta/eta_mini_api/services/go_redis"
	"eta/eta_mini_api/utils"
	"time"
)

// BindUser 用户绑定
func BindUser(unionId, openId, phone, email, areaCode string) (userItem *models.User, errMsg string, err error) {
	if phone == "" && email == "" {
		err = errors.New("手机号或邮箱必填一个")
		return
	}
	// 根据openid获取用户信息
	if openId == "" {
		err = errors.New("openid不能为空")
		return
	}
	userItem, err = models.GetUserByOpenId(openId)
	if err != nil && err.Error() != utils.ErrNoRow() {
		return
	}
	var userId int
	curTime := time.Now()
	if userItem != nil {
		userId = userItem.UserId
		if userItem.Phone != "" && userItem.Phone != phone {
			errMsg = "该手机号已绑定其他微信号"
			return
		}
		if userItem.Email != "" && userItem.Email != email {
			errMsg = "该邮箱已绑定其他微信号"
			return
		}
		if userItem.Phone == "" && phone != "" {
			user := &models.User{
				UserId:       userItem.UserId,
				Phone:        phone,
				AreaCode:     areaCode,
				RegisterTime: curTime,
				ModifyTime:   curTime,
			}
			updateUserErr := user.Update([]string{"phone", "area_code", "register_time", "modify_time"})
			err = updateUserErr
		}
		if userItem.Email == "" && email != "" {
			user := &models.User{
				UserId:       userItem.UserId,
				Email:        email,
				RegisterTime: curTime,
				ModifyTime:   curTime,
			}
			updateUserErr := user.Update([]string{"email", "modify_time", "register_time"})
			err = updateUserErr
		}
	} else {
		//根据手机号获取用户信息
		var phoneUser, emailUser *models.User
		if phone != "" {
			tmpUser, userErr := models.GetUserByPhone(phone)
			if userErr != nil && userErr.Error() != utils.ErrNoRow() {
				err = userErr
				return
			}
			phoneUser = tmpUser
		}
		//根据邮箱获取用户信息
		if email != "" {
			tmpUser, userErr := models.GetUserByEmail(email)
			if userErr != nil && userErr.Error() != utils.ErrNoRow() {
				err = userErr
				return
			}
			emailUser = tmpUser
		}
		// 理论上来说不会同时出现手机号和邮箱同时存在的情况
		if phoneUser != nil && emailUser != nil && phoneUser.UserId != emailUser.UserId {
			errMsg = "该手机号和邮箱已绑定其他微信号"
			err = errors.New("该手机号和邮箱已绑定其他微信号")
			return
		}
		if phoneUser != nil {
			userItem = phoneUser
		}
		if emailUser != nil {
			userItem = emailUser
		}
		//如果查询出来的用户是nil，那么需要新增用户
		if userItem == nil {
			key := utils.CACHE_ACCESS_WX_BIND + phone + ":" + email
			isHas := go_redis.IsExist(key)
			if isHas {
				err = errors.New("多次提交，请关闭页面重新进入")
				return
			}
			go_redis.SetNX(key, "ok", time.Second*300)
			user := &models.User{
				Phone:    phone,
				AreaCode: areaCode,
				Email:    email,
				Status:   utils.UserStatusPotential,
				OpenId:   openId,
				UnionId:  unionId,
			}
			tmpUserId, addUserErr := user.Insert()
			//添加完成，清除缓存
			_ = go_redis.Delete(key)
			if addUserErr != nil {
				err = addUserErr
				return
			}
			user.UserId = int(tmpUserId)
			userId = int(tmpUserId)
			userItem, err = models.GetUserById(userId)
		} else {
			userItem.OpenId = openId
			userItem.UnionId = unionId
			err = userItem.Update([]string{"open_id", "union_id"})
			if err != nil {
				errMsg = "用户绑定失败"
				return
			}
			userId = userItem.UserId
		}
	}

	//如果该用户 绑定注册状态 字段处于 未注册 的情况下，那么去修改该数据
	if !userItem.IsRegistered {
		err = models.ModifyUserRegisterStatus(userId, true, curTime, curTime)
		if err != nil {
			return
		}
	}
	return
}