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:
liangzai
2026-01-20 18:32:16 +08:00
parent 03cfddee93
commit 8a222a0b7f
7 changed files with 27 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/infrastructure/external/jiguang/jiguang_service.go vendored
View File

@@ -108,7 +108,7 @@ func (j *JiguangService) CallAPI(ctx context.Context, apiCode string, apiPath st
// 记录请求日志 // 记录请求日志
if j.logger != nil { if j.logger != nil {
j.logger.LogRequest(requestID, transactionID, apiCode, requestURL, params) j.logger.LogRequest(requestID, transactionID, apiCode, requestURL)
} }
// 将请求参数转换为JSON // 将请求参数转换为JSON
@@ -212,12 +212,12 @@ func (j *JiguangService) CallAPI(ctx context.Context, apiCode string, apiPath st
return nil, err return nil, err
} }
// 记录响应日志 // 记录响应日志（不记录具体响应数据）
if j.logger != nil { if j.logger != nil {
if jiguangResp.OrderID != "" { if jiguangResp.OrderID != "" {
j.logger.LogResponseWithID(requestID, transactionID, apiCode, httpResp.StatusCode, bodyBytes, duration, jiguangResp.OrderID) j.logger.LogResponseWithID(requestID, transactionID, apiCode, httpResp.StatusCode, duration, jiguangResp.OrderID)
} else { } else {
j.logger.LogResponse(requestID, transactionID, apiCode, httpResp.StatusCode, bodyBytes, duration) j.logger.LogResponse(requestID, transactionID, apiCode, httpResp.StatusCode, duration)
} }
} }

5
internal/infrastructure/external/muzi/muzi_service.go vendored
View File

@@ -118,7 +118,7 @@ func (m *MuziService) CallAPI(ctx context.Context, prodCode string, path string,
} }
if m.logger != nil { if m.logger != nil {
m.logger.LogRequest(requestID, transactionID, prodCode, m.config.URL, requestBody) m.logger.LogRequest(requestID, transactionID, prodCode, m.config.URL)
} }
bodyBytes, marshalErr := json.Marshal(requestBody) bodyBytes, marshalErr := json.Marshal(requestBody)
@@ -187,7 +187,8 @@ func (m *MuziService) CallAPI(ctx context.Context, prodCode string, path string,
} }
if m.logger != nil { if m.logger != nil {
m.logger.LogResponse(requestID, transactionID, prodCode, resp.StatusCode, respBody, time.Since(now)) // 记录响应日志（不记录具体响应数据）
m.logger.LogResponse(requestID, transactionID, prodCode, resp.StatusCode, time.Since(now))
} }
if resp.StatusCode != http.StatusOK { if resp.StatusCode != http.StatusOK {

12
internal/infrastructure/external/westdex/westdex_service.go vendored
View File

@@ -95,7 +95,7 @@ func (w *WestDexService) CallAPI(ctx context.Context, code string, reqData map[s
// 记录请求日志 // 记录请求日志
if w.logger != nil { if w.logger != nil {
w.logger.LogRequest(requestID, transactionID, code, reqUrl, reqData) w.logger.LogRequest(requestID, transactionID, code, reqUrl)
} }
jsonData, marshalErr := json.Marshal(reqData) jsonData, marshalErr := json.Marshal(reqData)
@@ -186,9 +186,9 @@ func (w *WestDexService) CallAPI(ctx context.Context, code string, reqData map[s
return nil, err return nil, err
} }
// 记录响应日志，包含响应ID // 记录响应日志（不记录具体响应数据）
if w.logger != nil { if w.logger != nil {
w.logger.LogResponseWithID(requestID, transactionID, code, httpResp.StatusCode, bodyBytes, duration, westDexResp.ID) w.logger.LogResponseWithID(requestID, transactionID, code, httpResp.StatusCode, duration, westDexResp.ID)
} }
if westDexResp.Code != "00000" && westDexResp.Code != "200" && westDexResp.Code != "0" { if westDexResp.Code != "00000" && westDexResp.Code != "200" && westDexResp.Code != "0" {
@@ -268,7 +268,7 @@ func (w *WestDexService) G05HZ01CallAPI(ctx context.Context, code string, reqDat
// 记录请求日志 // 记录请求日志
if w.logger != nil { if w.logger != nil {
w.logger.LogRequest(requestID, transactionID, code, reqUrl, reqData) w.logger.LogRequest(requestID, transactionID, code, reqUrl)
} }
jsonData, marshalErr := json.Marshal(reqData) jsonData, marshalErr := json.Marshal(reqData)
@@ -356,9 +356,9 @@ func (w *WestDexService) G05HZ01CallAPI(ctx context.Context, code string, reqDat
return nil, err return nil, err
} }
// 记录响应日志，包含响应ID // 记录响应日志（不记录具体响应数据）
if w.logger != nil { if w.logger != nil {
w.logger.LogResponseWithID(requestID, transactionID, code, httpResp.StatusCode, bodyBytes, duration, westDexResp.ID) w.logger.LogResponseWithID(requestID, transactionID, code, httpResp.StatusCode, duration, westDexResp.ID)
} }
if westDexResp.Code != "0000" { if westDexResp.Code != "0000" {

9
internal/infrastructure/external/xingwei/xingwei_service.go vendored
View File

@@ -128,7 +128,7 @@ func (x *XingweiService) CallAPI(ctx context.Context, projectID string, params m
// 记录请求日志 // 记录请求日志
if x.logger != nil { if x.logger != nil {
x.logger.LogRequest(requestID, transactionID, "xingwei_api", x.config.URL, params) x.logger.LogRequest(requestID, transactionID, "xingwei_api", x.config.URL)
} }
// 将请求参数转换为JSON // 将请求参数转换为JSON
@@ -212,9 +212,9 @@ func (x *XingweiService) CallAPI(ctx context.Context, projectID string, params m
return nil, err return nil, err
} }
// 记录响应日志 // 记录响应日志（不记录具体响应数据）
if x.logger != nil { if x.logger != nil {
x.logger.LogResponse(requestID, transactionID, "xingwei_api", httpResp.StatusCode, bodyBytes, duration) x.logger.LogResponse(requestID, transactionID, "xingwei_api", httpResp.StatusCode, duration)
} }
// 检查HTTP状态码 // 检查HTTP状态码
@@ -259,7 +259,8 @@ func (x *XingweiService) CallAPI(ctx context.Context, projectID string, params m
case CodeNotFound: case CodeNotFound:
// 未查询到结果，返回空数组 // 未查询到结果，返回空数组
if x.logger != nil { if x.logger != nil {
x.logger.LogResponse(requestID, transactionID, "xingwei_api", httpResp.StatusCode, []byte("[]"), duration) // 这里只记录有响应，不记录具体返回内容
x.logger.LogResponse(requestID, transactionID, "xingwei_api", httpResp.StatusCode, duration)
} }
return []byte("[]"), nil return []byte("[]"), nil

6
internal/infrastructure/external/yushan/yushan_service.go vendored
View File

@@ -64,7 +64,7 @@ func (y *YushanService) CallAPI(ctx context.Context, code string, params map[str
// 记录请求日志 // 记录请求日志
if y.logger != nil { if y.logger != nil {
y.logger.LogRequest(requestID, transactionID, code, y.config.URL, params) y.logger.LogRequest(requestID, transactionID, code, y.config.URL)
} }
// 获取当前时间戳 // 获取当前时间戳
@@ -176,10 +176,10 @@ func (y *YushanService) CallAPI(ctx context.Context, code string, params map[str
} }
retCode := gjson.GetBytes(respData, "retcode").String() retCode := gjson.GetBytes(respData, "retcode").String()
// 记录响应日志 // 记录响应日志（不记录具体响应数据）
if y.logger != nil { if y.logger != nil {
duration := time.Since(startTime) duration := time.Since(startTime)
y.logger.LogResponse(requestID, transactionID, code, resp.StatusCode, respData, duration) y.logger.LogResponse(requestID, transactionID, code, resp.StatusCode, duration)
} }
if retCode == "100000" { if retCode == "100000" {

6
internal/infrastructure/external/zhicha/zhicha_service.go vendored
View File

@@ -101,7 +101,7 @@ func (z *ZhichaService) CallAPI(ctx context.Context, proID string, params map[st
// 记录请求日志 // 记录请求日志
if z.logger != nil { if z.logger != nil {
z.logger.LogRequest(requestID, transactionID, proID, z.config.URL, params) z.logger.LogRequest(requestID, transactionID, proID, z.config.URL)
} }
jsonData, marshalErr := json.Marshal(params) jsonData, marshalErr := json.Marshal(params)
@@ -175,10 +175,10 @@ func (z *ZhichaService) CallAPI(ctx context.Context, proID string, params map[st
return nil, err return nil, err
} }
// 记录响应日志 // 记录响应日志（不记录具体响应数据）
if z.logger != nil { if z.logger != nil {
duration := time.Since(startTime) duration := time.Since(startTime)
z.logger.LogResponse(requestID, transactionID, proID, response.StatusCode, respBody, duration) z.logger.LogResponse(requestID, transactionID, proID, response.StatusCode, duration)
} }
// 检查HTTP状态码 // 检查HTTP状态码

9
internal/shared/external_logger/external_logger.go
View File

@@ -295,7 +295,7 @@ func createFileWriter(logDir, level string, config ExternalServiceLevelFileConfi
} }
// LogRequest 记录请求日志 // LogRequest 记录请求日志
func (e *ExternalServiceLogger) LogRequest(requestID, transactionID, apiCode string, url interface{}, params interface{}) { func (e *ExternalServiceLogger) LogRequest(requestID, transactionID, apiCode string, url interface{}) {
logger := e.requestLogger logger := e.requestLogger
if logger == nil { if logger == nil {
logger = e.logger logger = e.logger
@@ -306,13 +306,12 @@ func (e *ExternalServiceLogger) LogRequest(requestID, transactionID, apiCode str
zap.String("transaction_id", transactionID), zap.String("transaction_id", transactionID),
zap.String("api_code", apiCode), zap.String("api_code", apiCode),
zap.Any("url", url), zap.Any("url", url),
zap.Any("params", params),
zap.String("timestamp", time.Now().Format(time.RFC3339)), zap.String("timestamp", time.Now().Format(time.RFC3339)),
) )
} }
// LogResponse 记录响应日志 // LogResponse 记录响应日志
func (e *ExternalServiceLogger) LogResponse(requestID, transactionID, apiCode string, statusCode int, response []byte, duration time.Duration) { func (e *ExternalServiceLogger) LogResponse(requestID, transactionID, apiCode string, statusCode int, duration time.Duration) {
logger := e.responseLogger logger := e.responseLogger
if logger == nil { if logger == nil {
logger = e.logger logger = e.logger
@@ -323,14 +322,13 @@ func (e *ExternalServiceLogger) LogResponse(requestID, transactionID, apiCode st
zap.String("transaction_id", transactionID), zap.String("transaction_id", transactionID),
zap.String("api_code", apiCode), zap.String("api_code", apiCode),
zap.Int("status_code", statusCode), zap.Int("status_code", statusCode),
zap.String("response", string(response)),
zap.Duration("duration", duration), zap.Duration("duration", duration),
zap.String("timestamp", time.Now().Format(time.RFC3339)), zap.String("timestamp", time.Now().Format(time.RFC3339)),
) )
} }
// LogResponseWithID 记录包含响应ID的响应日志 // LogResponseWithID 记录包含响应ID的响应日志
func (e *ExternalServiceLogger) LogResponseWithID(requestID, transactionID, apiCode string, statusCode int, response []byte, duration time.Duration, responseID string) { func (e *ExternalServiceLogger) LogResponseWithID(requestID, transactionID, apiCode string, statusCode int, duration time.Duration, responseID string) {
logger := e.responseLogger logger := e.responseLogger
if logger == nil { if logger == nil {
logger = e.logger logger = e.logger
@@ -341,7 +339,6 @@ func (e *ExternalServiceLogger) LogResponseWithID(requestID, transactionID, apiC
zap.String("transaction_id", transactionID), zap.String("transaction_id", transactionID),
zap.String("api_code", apiCode), zap.String("api_code", apiCode),
zap.Int("status_code", statusCode), zap.Int("status_code", statusCode),
zap.String("response", string(response)),
zap.Duration("duration", duration), zap.Duration("duration", duration),
zap.String("response_id", responseID), zap.String("response_id", responseID),
zap.String("timestamp", time.Now().Format(time.RFC3339)), zap.String("timestamp", time.Now().Format(time.RFC3339)),