package mysqlbusiness

import (
	"strconv"
	"wss-pool/internal"
	"wss-pool/internal/data"
	"wss-pool/logging/applogger"
	"wss-pool/pkg/model/sqlmodel"
)

// GetBoUserOptionalStocksNew
func GetBoUserOptionalStocksNew(bourseType, systemBoursesId int, userId int64) ([]sqlmodel.BoUserOptionalStocks, error) {
	var bom []sqlmodel.BoUserOptionalStocks
	if err := data.Engine.Table("bo_user_optional_stocks").
		Where("bourseType = ?", bourseType).
		Where("systemBoursesId = ?", systemBoursesId).
		Where("userId = ?", userId).
		Desc("id").
		Find(&bom); err != nil {
		applogger.Error("GetBoUserOptionalStocksNew find info err: %v", err)
		return nil, err
	}

	return bom, nil
}

// GetBoUsers
func GetBoUsers(token string) (bool, int64, error) {
	var bom []sqlmodel.BoUsers
	err := data.Engine.Table("bo_users").
		Where("accessToken=?", token).
		Where("status=1").
		Where("deleteTime is null").
		Find(&bom)
	if err != nil {
		applogger.Error("GetBoUsers info err: %v", err)
		return false, 0, err
	}
	for _, value := range bom {
		return true, value.Id, nil
	}
	return false, 0, nil
}

// GetBoUsersByPhoneNumber
func GetBoUsersByPhoneNumber(phoneNumber string) (string, error) {
	phone, err := strconv.Atoi(phoneNumber)
	if err != nil {
		applogger.Error("Atoi err: %v", err)
		return "电话号码解析失败,请联系管理员", err
	}
	var bom []sqlmodel.BoUsers
	err = data.Engine.Table("bo_users").
		Where("phoneNumber=?", phone).
		Where("status=1").
		Where("deleteTime is null").
		Find(&bom)
	if err != nil {
		applogger.Error("GetBoUsersByPhoneNumber info err: %v", err)
		return "注册异常请联系管理员", err
	}

	applogger.Debug("查询数据信息：", bom)

	if len(bom) > 0 {
		return "用户已经存在", nil
	}

	return "", nil
}

// GetBoUsersByPhoneAndPassWord
func GetBoUsersByPhoneAndPassWord(phoneNumber string, password string) (string, error) {
	token, err := internal.GetToken()
	if err != nil {
		applogger.Error("select token err：%v", err)
		return "生成token失败,请联系管理员", err
	}
	phone, err := strconv.Atoi(phoneNumber)
	if err != nil {
		applogger.Error("Atoi err: %v", err)
		return "电话号码解析失败,请联系管理员", err
	}
	var u sqlmodel.UsersJson
	query := "select id,uid,accessToken from bo_users where phoneNumber=? and loginPassword=?  and status=1 and deleteTime is null limit 1"
	if err := data.DB.QueryRow(query, phone, password).Scan(&u.Id, &u.Uid, &u.AccessToken); err != nil {
		applogger.Error("QueryRow err：%v", err)
		if err.Error() == "sql: no rows in result set" {
			return "用户不存在", err
		}
		return "登录异常请联系管理员", err
	}

	if err = UpdateBoUsersTokenById(u.Id, token); err != nil {
		applogger.Error("update info err: %v", err)
		return "更新token失败,请联系管理员", err
	}

	return token, nil
}

func GetBoUserTerminalEquipments(userId int64) error {
	var bom []sqlmodel.BoUserTerminalEquipments
	if err := data.Engine.Table("bo_user_terminal_equipments").Where("userId = ?", userId).Find(&bom); err != nil {
		applogger.Error("SaveBoUserSms info err: %v", err)
		return err
	}

	applogger.Debug("查询数据信息：%v", bom)

	return nil
}