60 lines
2.7 KiB
C#
60 lines
2.7 KiB
C#
using Store.Shops.Services;
|
|
using Store.Users.Entities;
|
|
using YourNamespace;
|
|
|
|
namespace Store.Shops.Tests;
|
|
|
|
/// <summary>验证公共到期查询集中后仍保留批量范围和列表到期规则。</summary>
|
|
public sealed class ShopQueryTests
|
|
{
|
|
[Fact]
|
|
public async Task Expirations_ReadRequestedShopsInOneQuery_AndEmptyInputReturnsNothing()
|
|
{
|
|
using var context = new ShopTestContext();
|
|
await context.Db.Insert(new[]
|
|
{
|
|
new ShopExpireEntity { ShopId = "first", ExpireTime = 100 },
|
|
new ShopExpireEntity { ShopId = "second", ExpireTime = 200 },
|
|
new ShopExpireEntity { ShopId = "outside", ExpireTime = 300 }
|
|
}).ExecuteAffrowsAsync();
|
|
var queries = 0;
|
|
context.Db.Aop.CurdBefore += (_, _) => queries++;
|
|
|
|
var rows = await context.Repository.GetExpireTimes(["first", "second", "first", "missing"]);
|
|
|
|
Assert.Equal(1, queries);
|
|
Assert.Equal(new[] { "first", "second" }, rows.Select(r => r.ShopId).Order().ToArray());
|
|
Assert.Equal(100, rows.Single(r => r.ShopId == "first").ExpireTime);
|
|
Assert.Equal(200, rows.Single(r => r.ShopId == "second").ExpireTime);
|
|
Assert.Empty(await context.Repository.GetExpireTimes([]));
|
|
}
|
|
|
|
[Fact]
|
|
public async Task Search_PreservesMissingAndPermanentExpiration_AndReadsUpdatedValue()
|
|
{
|
|
using var context = new ShopTestContext { UserName = "admin" };
|
|
await context.Db.Insert(new[]
|
|
{
|
|
new ShopEntity { ShopId = "dated", UserName = "owner" },
|
|
new ShopEntity { ShopId = "missing", UserName = "owner" },
|
|
new ShopEntity { ShopId = "permanent", UserName = "owner", NeverExpires = true }
|
|
}).ExecuteAffrowsAsync();
|
|
await context.Db.Insert(new ShopExpireEntity { ShopId = "dated", ExpireTime = 100 }).ExecuteAffrowsAsync();
|
|
var service = new ShopService(context.Db, context, context, context.Gateway,
|
|
context.Configuration, context.Repository);
|
|
|
|
var page = await service.Search(new(), admin: true);
|
|
|
|
Assert.Equal(3, page.Total);
|
|
Assert.Equal(100, page.Items.Single(s => s.ShopId == "dated").ExpireTime);
|
|
Assert.Equal(0, page.Items.Single(s => s.ShopId == "missing").ExpireTime);
|
|
Assert.Equal(1893427200, page.Items.Single(s => s.ShopId == "permanent").ExpireTime);
|
|
|
|
await context.Db.Update<ShopExpireEntity>().Where(e => e.ShopId == "dated")
|
|
.Set(e => e.ExpireTime, 200).ExecuteAffrowsAsync();
|
|
var updated = await service.Search(new() { ShopIds = ["dated"] }, admin: true);
|
|
Assert.Equal(200, Assert.Single(updated.Items).ExpireTime);
|
|
Assert.Empty((await service.Search(new() { Page = 2 }, admin: true)).Items);
|
|
}
|
|
}
|