Browse Source

Refactor IInventoryActorProvider

pull/161/head
gdlcf88 4 years ago
parent
commit
5870875c91
  1. 4
      plugins/Inventories/DaprActors/src/EasyAbp.EShop.Products.DaprActorsInventory.Domain/EasyAbp/EShop/Products/DaprActorsInventory/DaprActorsProductInventoryProvider.cs
  2. 3
      plugins/Inventories/DaprActors/src/EasyAbp.EShop.Products.DaprActorsInventory.Domain/EasyAbp/EShop/Products/DaprActorsInventory/IInventoryActorProvider.cs
  3. 6
      plugins/Inventories/DaprActors/src/EasyAbp.EShop.Products.DaprActorsInventory.Domain/EasyAbp/EShop/Products/DaprActorsInventory/InventoryActorProvider.cs
  4. 2
      plugins/Inventories/DaprActors/test/EasyAbp.EShop.Products.DaprActorsInventory.Domain.Tests/TestInventoryActorProvider.cs

4
plugins/Inventories/DaprActors/src/EasyAbp.EShop.Products.DaprActorsInventory.Domain/EasyAbp/EShop/Products/DaprActorsInventory/DaprActorsProductInventoryProvider.cs

@ -17,8 +17,6 @@ public class DaprActorsProductInventoryProvider : IProductInventoryProvider, ITr
public string InventoryProviderName { get; } = DaprActorsProductInventoryProviderName;
public static string ActorType { get; set; } = "InventoryActor";
private readonly ILogger<DaprActorsProductInventoryProvider> _logger;
protected IInventoryActorProvider InventoryActorProvider { get; }
@ -102,7 +100,7 @@ public class DaprActorsProductInventoryProvider : IProductInventoryProvider, ITr
protected virtual async Task<IInventoryActor> GetActorAsync(InventoryQueryModel model)
{
return await InventoryActorProvider.GetAsync(GetActorId(model), ActorType);
return await InventoryActorProvider.GetAsync(GetActorId(model));
}
protected virtual ActorId GetActorId(InventoryQueryModel model)

3
plugins/Inventories/DaprActors/src/EasyAbp.EShop.Products.DaprActorsInventory.Domain/EasyAbp/EShop/Products/DaprActorsInventory/IInventoryActorProvider.cs

@ -1,11 +1,10 @@
using System.Threading.Tasks;
using Dapr.Actors;
using EasyAbp.EShop.Plugins.Inventories.DaprActors;
using JetBrains.Annotations;
namespace EasyAbp.EShop.Products.DaprActorsInventory;
public interface IInventoryActorProvider
{
Task<IInventoryActor> GetAsync(ActorId actorId, [NotNull] string actorType);
Task<IInventoryActor> GetAsync(ActorId actorId);
}

6
plugins/Inventories/DaprActors/src/EasyAbp.EShop.Products.DaprActorsInventory.Domain/EasyAbp/EShop/Products/DaprActorsInventory/InventoryActorProvider.cs

@ -8,8 +8,10 @@ namespace EasyAbp.EShop.Products.DaprActorsInventory;
public class InventoryActorProvider : IInventoryActorProvider, ITransientDependency
{
public virtual Task<IInventoryActor> GetAsync(ActorId actorId, string actorType)
public static string ActorType { get; set; } = "InventoryActor";
public virtual Task<IInventoryActor> GetAsync(ActorId actorId)
{
return Task.FromResult(ActorProxy.Create<IInventoryActor>(actorId, actorType));
return Task.FromResult(ActorProxy.Create<IInventoryActor>(actorId, ActorType));
}
}

2
plugins/Inventories/DaprActors/test/EasyAbp.EShop.Products.DaprActorsInventory.Domain.Tests/TestInventoryActorProvider.cs

@ -19,7 +19,7 @@ public class TestInventoryActorProvider : IInventoryActorProvider, ITransientDep
_serviceProvider = serviceProvider;
}
public Task<IInventoryActor> GetAsync(ActorId actorId, string actorType)
public Task<IInventoryActor> GetAsync(ActorId actorId)
{
return Task.FromResult(Actor ??= _serviceProvider.GetRequiredService<FakeInventoryActor>());
}

Loading…
Cancel
Save