事件溯源与聚合根：高效处理业务不变性规则的策略

class ProductAggregateRoot
{
    private $price;
    private $availability;

    // ... 构造函数和状态恢复方法 ...

    public function changePrice(ChangeProductPrice $command): self
    {
        // 不变性规则1: 产品不可用时不能改变价格
        if ($this->availability->equals(Availability::UNAVAILABLE())) {
            throw CannotChangePriceException::unavailableProduct();
        }

        // 不变性规则2: 价格未发生变化时无需改变
        if ($this->price->equals($command->newPrice)) {
            throw CannotChangePriceException::priceHasntChanged();
        }

        $this->recordThat(
            new ProductPriceChanged($this->price, $command->newPrice)
        );

        return $this;
    }

    // ... 其他方法 ...
}

class ProductSynchronizationService
{
    public function synchronizeProduct(ProductId $productId, ExternalProductState $state): void
    {
        $aggregate = $this->productRepository->get($productId);

        try {
            $aggregate->changePrice(new ChangeProductPrice(
                $productId,
                $state->getPrice()
            ));
        } catch (CannotChangePriceException $ex) {
            // 忽略或记录异常，感觉“不自然”
        }

        try {
            // 假设也有一个 changeAvailability 方法
            $aggregate->changeAvailability(new ChangeProductAvailability(
                $productId,
                $state->getAvailability()
            ));
        } catch (CannotChangeAvailabilityException $ex) {
            // 同样处理，感觉“不自然”
        }

        $this->productRepository->save($aggregate);
    }
}

// 定义一个更具业务意图的命令
class UpdateProductDetailsFromExternalSource
{
    public ProductId $productId;
    public Money $newPrice;
    public Availability $newAvailability;

    public function __construct(ProductId $productId, Money $newPrice, Availability $newAvailability)
    {
        $this->productId = $productId;
        $this->newPrice = $newPrice;
        $this->newAvailability = $newAvailability;
    }
}

class ProductAggregateRoot
{
    private $price;
    private $availability;

    // ...

    public function updateDetailsFromExternalSource(UpdateProductDetailsFromExternalSource $command): self
    {
        $priceChanged = !$this->price->equals($command->newPrice);
        $availabilityChanged = !$this->availability->equals($command->newAvailability);

        // 在这里进行更宏观的不变性检查
        // 例如：如果产品不可用，但外部源要求将其设置为可用，则允许
        // 如果外部源要求将价格设置为某个值，即使当前不可用，也可能允许，
        // 但如果只是更新价格，且产品不可用，则可能抛出异常。
        // 这里的逻辑需要根据具体的业务规则来定。

        if ($priceChanged) {
            // 可以在这里添加针对价格更新的特定不变性，例如：
            // if ($command->newPrice->isNegative()) { throw InvalidPriceException(); }
            $this->recordThat(new ProductPriceChanged($this->price, $command->newPrice));
        }

        if ($availabilityChanged) {
            $this->recordThat(new ProductAvailabilityChanged($this->availability, $command->newAvailability));
        }

        // 如果没有任何变化，则不发布任何事件，也不抛出异常
        // 这符合幂等性原则，避免了不必要的异常捕获

        return $this;
    }
    // ...
}

class ProductSynchronizationService
{
    public function synchronizeProduct(ProductId $productId, ExternalProductState $state): void
    {
        $aggregate = $this->productRepository->get($productId);

        $aggregate->updateDetailsFromExternalSource(new UpdateProductDetailsFromExternalSource(
            $productId,
            $state->getPrice(),
            $state->getAvailability()
        ));

        $this->productRepository->save($aggregate);
    }
}

class ProductAggregateRoot
{
    private $price;
    private $availability;

    // ...

    public function changePrice(ChangeProductPrice $command): self
    {
        // 不变性规则1: 产品不可用时不能改变价格
        // 这是一个硬性业务规则，若违反则抛出异常
        if ($this->availability->equals(Availability::UNAVAILABLE())) {
            throw CannotChangePriceException::unavailableProduct();
        }

        // 策略二应用：如果价格未发生变化，则不抛出异常，直接返回
        if ($this->price->equals($command->newPrice)) {
            return $this; // 视为幂等操作，不发布事件
        }

        $this->recordThat(
            new ProductPriceChanged($this->price, $command->newPrice)
        );

        return $this;
    }
    // ...
}