diff --git a/src/InterfaceForward.Application/Services/InterfaceForwardService.cs b/src/InterfaceForward.Application/Services/InterfaceForwardService.cs index 27858ba..b0a1f4c 100644 --- a/src/InterfaceForward.Application/Services/InterfaceForwardService.cs +++ b/src/InterfaceForward.Application/Services/InterfaceForwardService.cs @@ -112,8 +112,8 @@ public class InterfaceForwardService : ApplicationService [HttpPost("Itfx/ForwardWithSubscribe")] public async Task ForwardWithSubscribeAsync( - [FromQuery] [Required] string upStreamCode, - [FromQuery] [Required] string serviceProviderCode, + [FromQuery] [Required] string standardCode, + [FromQuery] [Required] string supplierCode, [FromBody] [Required] object data, [FromHeader] string? attach = null, [FromHeader] bool isReturnMessage = false, @@ -124,14 +124,14 @@ public class InterfaceForwardService : ApplicationService throw new BusinessException(message: "非法结构,请传对象"); } - var contextList = await _forwardCommon.VerifyBusinessAndBuildForwardContexts(upStreamCode, serviceProviderCode); + var contextList = await _forwardCommon.VerifyBusinessAndBuildForwardContexts(standardCode, supplierCode); var context = contextList.First(); context.OriginalInterfaceInput = contextList.Count == 1 ? jobject : new JObject { - [upStreamCode] = jobject + [standardCode] = jobject }; var res = contextList.Count == 1 @@ -148,8 +148,8 @@ public class InterfaceForwardService : ApplicationService [HttpPost("InterfaceForward/ReForward")] public async Task ReForwardAsync( - [FromQuery] [Required] string upStreamCode, - [FromQuery] [Required] string serviceProviderCode, + [FromQuery] [Required] string standardCode, + [FromQuery] [Required] string supplierCode, [FromHeader] [Required] Guid requestId, [FromBody] [Required] object data, [FromHeader] string? attach = null, @@ -161,7 +161,7 @@ public class InterfaceForwardService : ApplicationService var failedLog = logs.FirstOrDefault(x => !x.IsSuccess); if (failedLog == default) throw new BusinessException(message: "找不到失败日志,无法重试"); - var contextList = await _forwardCommon.VerifyBusinessAndBuildForwardContexts(upStreamCode, serviceProviderCode); + var contextList = await _forwardCommon.VerifyBusinessAndBuildForwardContexts(standardCode, supplierCode); var context = contextList.First(); context.OriginalInterfaceInput = contextList.Count == 1