This commit is contained in:
parent
d90291dcd5
commit
946c9abaca
@ -173,7 +173,19 @@ public class InterfaceForwardCommon(
|
|||||||
foreach (var item in configs.Where(x => x.Flag == AuthParameterFlag.InParameter))
|
foreach (var item in configs.Where(x => x.Flag == AuthParameterFlag.InParameter))
|
||||||
{
|
{
|
||||||
Debug.Assert(item.ParameterAlias != null, "item.ParameterAlias != null");
|
Debug.Assert(item.ParameterAlias != null, "item.ParameterAlias != null");
|
||||||
body[item.ParameterAlias] = item.Value1;
|
|
||||||
|
// 兼容account占位符
|
||||||
|
if (item.Value1 == GlobalConst.FromAccount)
|
||||||
|
{
|
||||||
|
body[item.ParameterAlias] =
|
||||||
|
accountFieldCache.FirstOrDefault(x =>
|
||||||
|
x.FieldName.Equals(item.ParameterAlias, StringComparison.OrdinalIgnoreCase))?.FieldValue ??
|
||||||
|
string.Empty;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
body[item.ParameterAlias] = item.Value1;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 构建授权上下文
|
// 构建授权上下文
|
||||||
@ -208,7 +220,8 @@ public class InterfaceForwardCommon(
|
|||||||
// 授权也走主流程
|
// 授权也走主流程
|
||||||
if (!cacheContext.TargetServiceProvider.AuthInterfaceCode.IsNullOrWhiteSpace())
|
if (!cacheContext.TargetServiceProvider.AuthInterfaceCode.IsNullOrWhiteSpace())
|
||||||
{
|
{
|
||||||
Debug.Assert(cacheContext.ServiceProviderAuthInterface != null, "cacheContext.ServiceProviderAuthInterface != null");
|
Debug.Assert(cacheContext.ServiceProviderAuthInterface != null,
|
||||||
|
"cacheContext.ServiceProviderAuthInterface != null");
|
||||||
var flow = GetForwardFlow(cacheContext.ServiceProviderAuthInterface.TargetInterface.FlowCode!);
|
var flow = GetForwardFlow(cacheContext.ServiceProviderAuthInterface.TargetInterface.FlowCode!);
|
||||||
_flows.Add(cacheContext.ServiceProviderAuthInterface.TargetInterface.Code, flow);
|
_flows.Add(cacheContext.ServiceProviderAuthInterface.TargetInterface.Code, flow);
|
||||||
}
|
}
|
||||||
@ -386,7 +399,7 @@ public class InterfaceForwardCommon(
|
|||||||
// 关联当前服务商日志
|
// 关联当前服务商日志
|
||||||
logRepository.ServiceProviderRequestLog = context.ServiceProviderRequestLog;
|
logRepository.ServiceProviderRequestLog = context.ServiceProviderRequestLog;
|
||||||
|
|
||||||
if (!context.Feature.IsWait) // 批量case服务商日志延迟到 handle中处理
|
if (!context.Feature.IsWait) // 批量case服务商日志延迟到 handle中处理
|
||||||
{
|
{
|
||||||
// 写服务商日志
|
// 写服务商日志
|
||||||
await logRepository.AddLogAsync(context.ServiceProviderRequestLog);
|
await logRepository.AddLogAsync(context.ServiceProviderRequestLog);
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user