package allied_creation_user import ( "encoding/json" "fmt" "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/infrastructure/service_gateway" "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/log" ) // AuthCompanySignUp 企业注册 func (gateway HttplibAlliedCreationUser) AuthCompanySignUp(param ReqAuthCompanySignUp) (*DataAuthCompanySignUp, error) { url := gateway.baseUrL + "/auth/company-sign-up" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:企业注册。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求企业注册失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取企业注册失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:企业注册。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析企业注册:%w", err) } var data DataAuthCompanySignUp err = gateway.GetResponseData(result, &data) return &data, err } // AuthUserSignUp 用户注册 func (gateway HttplibAlliedCreationUser) AuthUserSignUp(param ReqAuthUserSignUp) (*DataAuthUserSignUp, error) { url := gateway.baseUrL + "/auth/user-sign-up" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:用户注册。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求用户注册失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取用户注册失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:用户注册。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析用户注册:%w", err) } var data DataAuthUserSignUp err = gateway.GetResponseData(result, &data) return &data, err } //AuthChangePassword 修改密码 func (gateway HttplibAlliedCreationUser) AuthChangePassword(param ReqAuthChangePassword) (*DataAuthChangePassword, error) { url := gateway.baseUrL + "/auth/change-password" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:修改密码。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求修改密码失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取修改密码失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:修改密码。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析修改密码:%w", err) } var data DataAuthChangePassword err = gateway.GetResponseData(result, &data) return &data, err } // AuthCheckPassword 手机账号密码检查 func (gateway HttplibAlliedCreationUser) AuthCheckPassword(param ReqAuthCheckPassword) (*DataAuthCheckPassword, error) { url := gateway.baseUrL + "/auth/check-password" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:手机账号密码检查。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求手机账号密码检查失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取手机账号密码检查失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:手机账号密码检查。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析手机账号密码检查:%w", err) } var data DataAuthCheckPassword err = gateway.GetResponseData(result, &data) return &data, err } // AuthDestroyAccount 注销账号 (添加用户时重新激活) func (gateway HttplibAlliedCreationUser) AuthDestroyAccount(param ReqAuthDestroyAccount) (*DataAuthDestroyAccount, error) { url := gateway.baseUrL + "/auth/destroy-account" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:注销账号 (添加用户时重新激活)。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求注销账号 (添加用户时重新激活)失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取注销账号 (添加用户时重新激活)失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:注销账号 (添加用户时重新激活)。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析注销账号 (添加用户时重新激活):%w", err) } var data DataAuthDestroyAccount err = gateway.GetResponseData(result, &data) return &data, err } // AuthResetPassword 重置密码(忘记密码) func (gateway HttplibAlliedCreationUser) AuthResetPassword(param ReqAuthResetPassword) (*DataAuthResetPassword, error) { url := gateway.baseUrL + "/auth/reset-password" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:重置密码(忘记密码)。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求重置密码(忘记密码)失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取重置密码(忘记密码)失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:重置密码(忘记密码)。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析重置密码(忘记密码):%w", err) } var data DataAuthResetPassword err = gateway.GetResponseData(result, &data) return &data, err } //AuthResetPhone 重置手机号 func (gateway HttplibAlliedCreationUser) AuthResetPhone(param ReqAuthResetPhone) (*DataAuthResetPhone, error) { url := gateway.baseUrL + "/auth/reset-phone" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:重置手机号。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求重置手机号失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取重置手机号失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:重置手机号。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析重置手机号:%w", err) } var data DataAuthResetPhone err = gateway.GetResponseData(result, &data) return &data, err } //RefreshIM 刷新IM信息 func (gateway HttplibAlliedCreationUser) AuthRefreshIM(param ReqAuthRefreshIM) (*DataAuthRefreshIM, error) { url := gateway.baseUrL + "/auth/refresh-im" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:刷新IM信息。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求刷新IM信息失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取刷新IM信息失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:刷新IM信息。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析刷新IM信息:%w", err) } var data DataAuthRefreshIM err = gateway.GetResponseData(result, &data) return &data, err } //RefreshIM 用户基础数据 func (gateway HttplibAlliedCreationUser) AuthUserBaseInfo(param ReqAuthUserBase) (*DataAuthUserBase, error) { url := gateway.baseUrL + "/auth/user-info" method := "POST" req := gateway.CreateRequest(url, method) log.Logger.Debug("向用户模块请求数据:用户基础数据。", map[string]interface{}{ "api": method + ":" + url, "param": param, }) req, err := req.JSONBody(param) if err != nil { return nil, fmt.Errorf("请求用户基础数据失败:%w", err) } byteResult, err := req.Bytes() if err != nil { return nil, fmt.Errorf("获取用户基础数据失败:%w", err) } log.Logger.Debug("获取用户模块请求数据:用户基础数据。", map[string]interface{}{ "result": string(byteResult), }) var result service_gateway.GatewayResponse err = json.Unmarshal(byteResult, &result) if err != nil { return nil, fmt.Errorf("解析用户基础数据:%w", err) } var data DataAuthUserBase err = gateway.GetResponseData(result, &data) return &data, err }