team/tyapi-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
liangzai
2025-12-27 19:18:12 +08:00
parent 53d2c75a9c
commit a70e736cdd
1 changed files with 16 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
internal/application/api/api_application_service.go
View File

@@ -218,6 +218,12 @@ func (s *ApiApplicationServiceImpl) validateApiCall(ctx context.Context, cmd *co
return nil, ErrFrozenAccount return nil, ErrFrozenAccount
} }
// 验证产品是否启用
if !product.IsEnabled {
s.logger.Error("产品未启用", zap.String("product_code", product.Code))
return nil, ErrProductDisabled
}
// 4. 验证IP白名单（非开发环境） // 4. 验证IP白名单（非开发环境）
if !s.config.App.IsDevelopment() && !cmd.Options.IsDebug { if !s.config.App.IsDevelopment() && !cmd.Options.IsDebug {
if !apiUser.IsWhiteListed(cmd.ClientIP) { if !apiUser.IsWhiteListed(cmd.ClientIP) {
@@ -589,8 +595,8 @@ func (s *ApiApplicationServiceImpl) GetUserApiCalls(ctx context.Context, userID
// 获取用户的API密钥信息 // 获取用户的API密钥信息
apiUser, err := s.apiUserService.LoadApiUserByUserId(ctx, *call.UserId) apiUser, err := s.apiUserService.LoadApiUserByUserId(ctx, *call.UserId)
if err != nil { if err != nil {
s.logger.Error("获取用户API信息失败", s.logger.Error("获取用户API信息失败",
zap.Error(err), zap.Error(err),
zap.String("call_id", call.ID), zap.String("call_id", call.ID),
zap.String("user_id", *call.UserId)) zap.String("user_id", *call.UserId))
// 获取失败时使用原始值 // 获取失败时使用原始值
@@ -601,8 +607,8 @@ func (s *ApiApplicationServiceImpl) GetUserApiCalls(ctx context.Context, userID
SecretKey: apiUser.SecretKey, SecretKey: apiUser.SecretKey,
}) })
if err != nil { if err != nil {
s.logger.Error("解密请求参数失败", s.logger.Error("解密请求参数失败",
zap.Error(err), zap.Error(err),
zap.String("call_id", call.ID), zap.String("call_id", call.ID),
zap.String("user_id", *call.UserId)) zap.String("user_id", *call.UserId))
// 解密失败时使用原始值 // 解密失败时使用原始值
@@ -611,7 +617,7 @@ func (s *ApiApplicationServiceImpl) GetUserApiCalls(ctx context.Context, userID
if jsonBytes, err := json.Marshal(decryptedParams); err == nil { if jsonBytes, err := json.Marshal(decryptedParams); err == nil {
requestParamsStr = string(jsonBytes) requestParamsStr = string(jsonBytes)
} else { } else {
s.logger.Error("序列化解密参数失败", s.logger.Error("序列化解密参数失败",
zap.Error(err), zap.Error(err),
zap.String("call_id", call.ID)) zap.String("call_id", call.ID))
// 序列化失败时使用原始值 // 序列化失败时使用原始值
@@ -693,8 +699,8 @@ func (s *ApiApplicationServiceImpl) GetAdminApiCalls(ctx context.Context, filter
// 获取用户的API密钥信息 // 获取用户的API密钥信息
apiUser, err := s.apiUserService.LoadApiUserByUserId(ctx, *call.UserId) apiUser, err := s.apiUserService.LoadApiUserByUserId(ctx, *call.UserId)
if err != nil { if err != nil {
s.logger.Error("获取用户API信息失败", s.logger.Error("获取用户API信息失败",
zap.Error(err), zap.Error(err),
zap.String("call_id", call.ID), zap.String("call_id", call.ID),
zap.String("user_id", *call.UserId)) zap.String("user_id", *call.UserId))
// 获取失败时使用原始值 // 获取失败时使用原始值
@@ -705,8 +711,8 @@ func (s *ApiApplicationServiceImpl) GetAdminApiCalls(ctx context.Context, filter
SecretKey: apiUser.SecretKey, SecretKey: apiUser.SecretKey,
}) })
if err != nil { if err != nil {
s.logger.Error("解密请求参数失败", s.logger.Error("解密请求参数失败",
zap.Error(err), zap.Error(err),
zap.String("call_id", call.ID), zap.String("call_id", call.ID),
zap.String("user_id", *call.UserId)) zap.String("user_id", *call.UserId))
// 解密失败时使用原始值 // 解密失败时使用原始值
@@ -715,7 +721,7 @@ func (s *ApiApplicationServiceImpl) GetAdminApiCalls(ctx context.Context, filter
if jsonBytes, err := json.Marshal(decryptedParams); err == nil { if jsonBytes, err := json.Marshal(decryptedParams); err == nil {
requestParamsStr = string(jsonBytes) requestParamsStr = string(jsonBytes)
} else { } else {
s.logger.Error("序列化解密参数失败", s.logger.Error("序列化解密参数失败",
zap.Error(err), zap.Error(err),
zap.String("call_id", call.ID)) zap.String("call_id", call.ID))
// 序列化失败时使用原始值 // 序列化失败时使用原始值