common/http增加headers参数
This commit is contained in:
@@ -689,7 +689,7 @@ func (s *order) getAssetFromAssetService(ctx context.Context, tenantID, assetID
|
||||
// 这里应该调用assets服务的getAsset接口
|
||||
// 暂时返回模拟数据
|
||||
var assetResp AssetServiceResponse
|
||||
err := http.Get(ctx, fmt.Sprintf("http://assets-service/internal/asset/%s", assetID), &assetResp)
|
||||
err := http.Get(ctx, fmt.Sprintf("http://assets-service/internal/asset/%s", assetID), nil, &assetResp)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -711,7 +711,7 @@ func (s *order) deductStockFromAssetService(ctx context.Context, tenantID, asset
|
||||
Message string `json:"message"`
|
||||
}
|
||||
|
||||
err := http.Post(ctx, "http://assets-service/internal/stock/deduct", &result, req)
|
||||
err := http.Post(ctx, "http://assets-service/internal/stock/deduct", nil, &result, req)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
@@ -737,7 +737,7 @@ func (s *order) refundStockFromAssetService(ctx context.Context, tenantID, asset
|
||||
Message string `json:"message"`
|
||||
}
|
||||
|
||||
err := http.Post(ctx, "http://assets-service/internal/stock/refund", &result, req)
|
||||
err := http.Post(ctx, "http://assets-service/internal/stock/refund", nil, &result, req)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
@@ -467,7 +467,7 @@ func (s *payment) getAssetFromAssetService(ctx context.Context, tenantID, assetI
|
||||
// 这里应该调用assets服务的getAsset接口
|
||||
// 暂时返回模拟数据
|
||||
var assetResp AssetServiceResponse
|
||||
err := http.Get(ctx, fmt.Sprintf("http://assets-service/internal/asset/%s", assetID), &assetResp)
|
||||
err := http.Get(ctx, fmt.Sprintf("http://assets-service/internal/asset/%s", assetID), nil, &assetResp)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@@ -489,7 +489,7 @@ func (s *payment) deductStockFromAssetService(ctx context.Context, tenantID, ass
|
||||
Message string `json:"message"`
|
||||
}
|
||||
|
||||
err := http.Post(ctx, "http://assets-service/internal/stock/deduct", &result, req)
|
||||
err := http.Post(ctx, "http://assets-service/internal/stock/deduct", nil, &result, req)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
@@ -515,7 +515,7 @@ func (s *payment) refundStockFromAssetService(ctx context.Context, tenantID, ass
|
||||
Message string `json:"message"`
|
||||
}
|
||||
|
||||
err := http.Post(ctx, "http://assets-service/internal/stock/refund", &result, req)
|
||||
err := http.Post(ctx, "http://assets-service/internal/stock/refund", nil, &result, req)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user