namespace Test;

[ServiceRoute]
public interface ITestAppService
{
   Task<string> Echo(string ping);
}

namespace Test;

[ServiceRoute]
public interface ITestAppService
{
   [HttpGet]
   Task<string> Echo(string ping);
}

    [ServiceRoute]
    public interface ITestAppService
    {
        ///  新增接口测试([post]/api/test)
        [GetCachingIntercept("name:{Name}")]
        Task<TestOut> Create(TestInput input);

        ///  更新接口测试([put]/api/test)
        Task<string> Update(TestInput input);

        /// 删除接口测试([delete]/api/test)
        [RemoveCachingIntercept("ITestApplication.Test.Dtos.TestOut", "name:{name}")]
        [Transaction]
        Task<string> Delete(string name);

        /// 查询接口测试([get]/api/test/search)
        [HttpGet]
        Task<string> Search([FromQuery] TestInput query);

        /// 以表单格式提交数据([post]/api/test/form)
        [HttpPost]
        string Form([FromForm] TestInput query);

        /// 通过name获取单条数据([get]/api/test/{name:string},以path参数传参,并约束参数类型为string)
        [HttpGet("{name:string}")]
        [Governance(ShuntStrategy = ShuntStrategy.HashAlgorithm)]
        [GetCachingIntercept("name:{name}")]
        Task<TestOut> Get(string name);

        /// 通过id获取单条数据([get]/api/test/{id:long},以path参数传参,并约束参数类型为long)
        [HttpGet("{id:long}")]
        [Governance(ShuntStrategy = ShuntStrategy.HashAlgorithm)]
        [GetCachingIntercept("id:{id}")]
        Task<TestOut> GetById(long id);

        ///更新部分数据，使用patch请求 ([patch]/api/test)
        [HttpPatch]
        Task<string> UpdatePart(TestInput input);
    }

/// 应用服务接口(如:可定义在ITestApplication.csproj项目)
[ServiceRoute]
public interface ITestAppService
{
    Task<string> Create(TestInput input);
   // 其他服务条目方法略
}


//------------------------------------//
/// 应用服务实例类1 (如:可定义在TestApplication.csproj项目)
[ServiceKey("v1", 3)]
public class TestAppService : ITestAppService
{
  public Task<string> Create(TestInput input)
  {
      return Task.FromResult("create v1")
  }
  // 其他接口实现方法略
}

//------------------------------------//
/// 应用服务实例类2  (如:可定义在TestApplication.csproj项目)
[ServiceKey("v2", 1)]
public class TestV2AppService : ITestAppService
{
  public Task<string> Create(TestInput input)
  {
      return Task.FromResult("create v2")
  }
   // 其他接口实现方法略
}

private readonly IServiceKeyExecutor _serviceKeyExecutor;

public TestProxyAppService(ITestAppService testAppService,
    IServiceKeyExecutor serviceKeyExecutor)
{
    _testAppService = testAppService;
    _serviceKeyExecutor = serviceKeyExecutor;
}

public async Task<string> CreateProxy(TestInput testInput)
{
   return await _serviceKeyExecutor.Execute(() => _testAppService.Create(testInput), "v2");
}

// 自定义服务端过滤器示例：记录服务条目执行耗时
public class ServerTimingFilterAttribute : ServerFilterAttribute
{
    private readonly ILogger<ServerTimingFilterAttribute> _logger;
    private Stopwatch _stopwatch;

    public ServerTimingFilterAttribute(ILogger<ServerTimingFilterAttribute> logger)
    {
        _logger = logger;
    }

    public override void OnActionExecuting(ServerInvokeExecutingContext context)
    {
        _stopwatch = Stopwatch.StartNew();
    }

    public override void OnActionExecuted(ServerInvokeExecutedContext context)
    {
        _stopwatch.Stop();
        _logger.LogInformation("ServiceEntry {Id} executed in {Elapsed}ms",
            context.ServiceEntry.Id, _stopwatch.ElapsedMilliseconds);
    }
}

// 标注到应用服务接口或特定方法上
[ServiceRoute]
[ServerTiming]  // 作用于整个服务接口的所有方法
public interface IOrderAppService
{
    Task<OrderOutput> GetOrderAsync(long id);
}

// 自定义客户端过滤器示例：在调用前附加自定义请求头
public class ClientCorrelationFilterAttribute : ClientFilterAttribute
{
    public override void OnActionExecuting(ClientInvokeExecutingContext context)
    {
        // 在发起 RPC 调用前，向 RpcContext 附件中写入自定义信息
        RpcContext.Context.SetInvokeAttachment("x-correlation-id", Guid.NewGuid().ToString());
    }
}

// 标注到应用服务接口或特定方法上
[ServiceRoute]
public interface IInventoryAppService
{
    [ClientCorrelationFilter]  // 仅作用于此方法
    Task<int> GetStockAsync(long productId);
}