我有以下课程:
命令:
public class Order {
private Order()
{
//some code to initialise object
}
//more properties
public Prepayment Prepayment { get; private set; }
//more methods and properties
}
预付款:
public class Prepayment:ValueObject<Prepayment>
{
private Prepayment()
{
}
public Money AmountPrepaid { get; private set; }
public bool HasPrepaymentBeenTaken => AmountPrepaid.Amount > 0;
}
钱:
public class Money {
private Money()
{
}
private Money(decimal amount)
: this()
{
Amount = amount;
}
public decimal Amount { get; private set; }
}
然后我通过以下方式将 Order 类映射到数据库:
modelBuilder.Entity<Order>()
.OwnsOne(x => x.Prepayment,
prepayment =>
{
prepayment.OwnsOne(x => x.AmountPrepaid,
amountPrepaid =>
{
amountPrepaid.Property(x => x.Amount)
.HasColumnName("PrepaymentAmount")
.HasColumnType("decimal(7,2)");
});
});
SaveChanges 的存储库代码:
public async Task<int> SaveAsync(Order order)
{
if (order.Id == 0)
{
await _context.AddAsync(order);
}
else
{
_context.Update(order);
}
return await _context.SaveChangesAsync();
}
请理解,我从代码中删除了所有不重要的属性,以使示例更清晰。
上面的代码适用于INSERT
预付款 -> 货币 -> 金额正确保存到数据库中的场景。UPDATE
虽然似乎没有反映在数据库中。
请注意,我在该模型中有很多 Owned Types,并且它们都运行良好。据我所知,唯一的区别是Prepayment
property 有另一个嵌套的 Owned 类型 - Money
。
Order
传递到存储库的类对象,首先从数据库中提取,然后在该实例上应用更改,最后保存回数据库。Customer
示例中未提及的其他属性也是 aOwnedType
并且UPDATE
按预期工作。
以防万一 - 用于在更新之前检索对象的代码:
public async Task<Order> GetOrderByIdAsync(int orderId)
{
var result = (from order in _context.Orders
where order.Id == orderId
select order).Include(x => x.OrderLines);
return await result.FirstOrDefaultAsync();
}
我正在使用的 Entity Framework Core 的确切版本是:2.2.0
任何帮助将不胜感激。谢谢你。
编辑:
更新数据的代码如下所示:
public async Task<int> Handle(EditOrderCommand request, CancellationToken cancellationToken)
{
var order = await _orderRepository.GetOrderByIdAsync(request.Id);
var customer = new Customer(
request.FirstName,
request.LastName,
request.TelephoneNumber);
var prepayment = new Prepayment(
Money.SomeMoney(
request.PrepaymentAmount
)
);
order.ApplyChanges(
request.UserId,
request.AdditionalInformation,
collectionDate,
customer,
prepayment);
await _orderRepository.SaveAsync(order);
return order.Id;
}
以及设置预付款的 ApplyChanges 方法的一部分:
private void SetPrepayment(Prepayment prepayment)
{
Prepayment = prepayment ?? throw new ArgumentNullException(nameof(prepayment));
}