1

internal/api_to_rpc/api.go

@@ -13,8 +13,7 @@ import (
 
 func ApiToRpc(c *gin.Context, apiReq, apiResp interface{}, rpcName string, rpcClientFunc interface{}, rpcFuncName string) {
 	logFuncName := fmt.Sprintf("[ApiToRpc: %s]%s", utils2.GetFuncName(1), rpcFuncName)
-	operationID := c.GetHeader("operationID")
-	nCtx := trace_log.NewCtx1(c, rpcFuncName, operationID)
+	nCtx := trace_log.NewCtx1(c, rpcFuncName)
 	defer log.ShowLog(nCtx)
 	if err := c.BindJSON(apiReq); err != nil {
 		trace_log.WriteErrorResponse(nCtx, "BindJSON", err)

pkg/common/trace_log/ctx.go

@@ -22,8 +22,8 @@ func NewCtx(c *gin.Context, api string) context.Context {
 	return context.WithValue(c, TraceLogKey, req)
 }
 
-func NewCtx1(c *gin.Context, api, operationID string) context.Context {
-	req := &ApiInfo{ApiName: api, GinCtx: c, OperationID: operationID, Funcs: &[]FuncInfo{}}
+func NewCtx1(c *gin.Context, api string) context.Context {
+	req := &ApiInfo{ApiName: api, GinCtx: c, OperationID: c.GetHeader("operationID"), Funcs: &[]FuncInfo{}}
 	return context.WithValue(c, TraceLogKey, req)
 }