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

-f

Browse Source
This commit is contained in:
Mrx
2026-01-20 14:26:47 +08:00
parent bdb8395615
commit abc7d655ce
1 changed files with 38 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -713,50 +713,50 @@ func (s *ApiApplicationServiceImpl) GetAdminApiCalls(ctx context.Context, filter
continue continue
} }
// 解密请求参数 // // 解密请求参数
var requestParamsStr string = call.RequestParams // 默认使用原始值 // var requestParamsStr string = call.RequestParams // 默认使用原始值
if call.UserId != nil && *call.UserId != "" { // if call.UserId != nil && *call.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))
// 获取失败时使用原始值 // // 获取失败时使用原始值
} else if apiUser.SecretKey != "" { // } else if apiUser.SecretKey != "" {
// 使用用户的SecretKey解密请求参数 // // 使用用户的SecretKey解密请求参数
decryptedParams, err := s.DecryptParams(ctx, *call.UserId, &commands.DecryptCommand{ // decryptedParams, err := s.DecryptParams(ctx, *call.UserId, &commands.DecryptCommand{
EncryptedData: call.RequestParams, // EncryptedData: call.RequestParams,
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))
// 解密失败时使用原始值 // // 解密失败时使用原始值
} else { // } else {
// 将解密后的数据转换为JSON字符串 // // 将解密后的数据转换为JSON字符串
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))
// 序列化失败时使用原始值 // // 序列化失败时使用原始值
} // }
} // }
} // }
} // }
item := dto.ApiCallRecordResponse{ item := dto.ApiCallRecordResponse{
ID: call.ID, ID: call.ID,
AccessId: call.AccessId, AccessId: call.AccessId,
TransactionId: call.TransactionId, TransactionId: call.TransactionId,
ClientIp: call.ClientIp, ClientIp: call.ClientIp,
RequestParams: requestParamsStr, // RequestParams: requestParamsStr,
Status: call.Status, Status: call.Status,
} }
// 安全设置用户ID // 安全设置用户ID