ideship/itfx
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix：params naming

Browse Source
This commit is contained in:
xiaolipro 2026-01-14 15:41:38 +08:00
parent 7c38077519
commit b7158b1f72
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/InterfaceForward.Application/Services/InterfaceForwardService.cs
View File

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