|
|
package service
|
|
|
|
|
|
import (
|
|
|
"errors"
|
|
|
"time"
|
|
|
|
|
|
"github.com/linmadan/egglib-go/core/application"
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/application/factory"
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/application/mobile/auth/command"
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/domain"
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/infrastructure/service_gateway/allied_creation_user"
|
|
|
)
|
|
|
|
|
|
// 组织管理
|
|
|
type AuthService struct {
|
|
|
}
|
|
|
|
|
|
//AuthLogin 用户登录
|
|
|
func (srv AuthService) AuthLogin(loginCommand *command.LoginCommand) (interface{}, error) {
|
|
|
var (
|
|
|
result interface{}
|
|
|
err error
|
|
|
)
|
|
|
switch loginCommand.GrantType {
|
|
|
case "signInPassword":
|
|
|
result, err = srv.SignInPassword(loginCommand.Phone, loginCommand.Password)
|
|
|
case "signInCaptcha":
|
|
|
default:
|
|
|
err = errors.New("登录方式无法解析")
|
|
|
}
|
|
|
return result, err
|
|
|
}
|
|
|
|
|
|
//SignInPassword 使用账号密码校验
|
|
|
func (srv AuthService) SignInPassword(account string, password string) (interface{}, error) {
|
|
|
creationUserGateway := allied_creation_user.NewHttplibAlliedCreationUser(0, 0, 0)
|
|
|
_, err := creationUserGateway.AuthCheckPassword(allied_creation_user.ReqAuthCheckPassword{
|
|
|
Password: password,
|
|
|
Phone: account,
|
|
|
})
|
|
|
if err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
ltoken := domain.LoginToken{
|
|
|
UserId: 0,
|
|
|
Account: account,
|
|
|
Platform: domain.LoginPlatformApp,
|
|
|
CompanyId: 0,
|
|
|
}
|
|
|
authcode, err := ltoken.GenerateAuthCode()
|
|
|
if err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
result := map[string]string{
|
|
|
"authCode": authcode,
|
|
|
}
|
|
|
return result, nil
|
|
|
}
|
|
|
|
|
|
//SignInCaptcha 使用手机验证码登录
|
|
|
func (srv AuthService) SignInCaptcha(phone string, captcha string) (interface{}, error) {
|
|
|
return nil, nil
|
|
|
}
|
|
|
|
|
|
//GetAuthAccessToken 获取令牌Token
|
|
|
func (srv AuthService) GetAuthAccessToken(accessTokenCommand *command.AccessTokenCommand) (interface{}, error) {
|
|
|
ltoken := domain.LoginToken{}
|
|
|
err := ltoken.ParseToken(accessTokenCommand.AuthCode)
|
|
|
if err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
phone := ltoken.Account
|
|
|
creationUserGateway := allied_creation_user.NewHttplibAlliedCreationUser(0, 0, 0)
|
|
|
userSeachResult, err := creationUserGateway.UserSearch(allied_creation_user.ReqUserSearch{
|
|
|
Phone: phone,
|
|
|
})
|
|
|
if err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
if len(userSeachResult.Users) == 0 {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取用户信息失败")
|
|
|
}
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
if err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
defer func() {
|
|
|
transactionContext.RollbackTransaction()
|
|
|
}()
|
|
|
var loginAccessRepository domain.LoginAccessRepository
|
|
|
if loginAccessRepository, err = factory.CreateLoginAccessRepository(map[string]interface{}{
|
|
|
"transactionContext": transactionContext,
|
|
|
}); err != nil {
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
}
|
|
|
_, lAccess, err := loginAccessRepository.Find(map[string]interface{}{
|
|
|
"account": phone,
|
|
|
"platform": domain.LoginPlatformApp,
|
|
|
})
|
|
|
if err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
var currentAccess *domain.LoginAccess
|
|
|
if len(lAccess) > 0 {
|
|
|
currentAccess = lAccess[0]
|
|
|
currentAccess.UpdatedTime = time.Now()
|
|
|
} else {
|
|
|
currentAccess = &domain.LoginAccess{
|
|
|
UserBaseId: int64(userSeachResult.Users[0].UserBaseId),
|
|
|
UserId: int64(userSeachResult.Users[0].UserId),
|
|
|
Account: userSeachResult.Users[0].UserInfo.Phone,
|
|
|
Platform: domain.LoginPlatformApp,
|
|
|
CompanyId: int64(userSeachResult.Users[0].Company.CompanyId),
|
|
|
OrganizationId: int64(userSeachResult.Users[0].Org.OrgId),
|
|
|
AccessToken: "",
|
|
|
RefreshToken: "",
|
|
|
AccessExpired: 0,
|
|
|
RefreshExpired: 0,
|
|
|
CreatedTime: time.Now(),
|
|
|
UpdatedTime: time.Now(),
|
|
|
}
|
|
|
}
|
|
|
loginToken := domain.LoginToken{
|
|
|
UserId: currentAccess.UserId,
|
|
|
Account: currentAccess.Account,
|
|
|
CompanyId: currentAccess.CompanyId,
|
|
|
OrgId: currentAccess.OrganizationId,
|
|
|
Platform: currentAccess.Platform,
|
|
|
}
|
|
|
|
|
|
accessTokenStr, err := loginToken.GenerateAccessToken()
|
|
|
if err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
currentAccess.AccessToken = accessTokenStr
|
|
|
currentAccess.AccessExpired = loginToken.ExpiresAt
|
|
|
refreshTokenStr, err := loginToken.GenerateRefreshToken()
|
|
|
if err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
currentAccess.RefreshToken = refreshTokenStr
|
|
|
currentAccess.AccessExpired = loginToken.ExpiresAt
|
|
|
|
|
|
//先存数据库
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
}
|
|
|
//先删缓存
|
|
|
//后加缓存
|
|
|
return nil, nil
|
|
|
} |
...
|
...
|
|