1 回答
TA贡献1809条经验 获得超8个赞
我为此使用 StateMachineTransitionEvent。使用 Shopware 6.2 进行测试。
<?php declare(strict_types=1);
namespace Your\Namespace;
use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionDefinition;
use Shopware\Core\Checkout\Order\Aggregate\OrderTransaction\OrderTransactionStates;
use Shopware\Core\Checkout\Order\OrderEntity;
use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
use Shopware\Core\System\StateMachine\Event\StateMachineTransitionEvent;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
class OrderStateSubscriber implements EventSubscriberInterface {
/**
* @var EntityRepositoryInterface
*/
private $stateMachineStateRepository;
/**
* @var EntityRepositoryInterface
*/
private $orderRepository;
public function __construct(EntityRepositoryInterface $stateMachineStateRepository, EntityRepositoryInterface $orderRepository)
{
$this->stateMachineStateRepository = $stateMachineStateRepository;
$this->orderRepository = $orderRepository;
}
public static function getSubscribedEvents(): array
{
return [
StateMachineTransitionEvent::class => 'onStateTransition'
];
}
public function onStateTransition(StateMachineTransitionEvent $event) {
// Since you are only interested in order transitions
if ($event->getEntityName() !== OrderTransactionDefinition::ENTITY_NAME) {
return;
}
$orderTransactionsStatePaidId = $this->getOrderTransactionsStatePaidId($event->getContext());
if ($orderTransactionsStatePaidId === null) {
return;
}
// Check if it was transitioned to paid
if ($event->getToPlace()->getId() !== $orderTransactionsStatePaidId) {
return;
}
// Transaction was changed to paid do your thing
$order = $this->getOrder($event->getEntityId(), $event->getContext());
}
private function getOrderTransactionsStatePaidId(Context $context): ?string {
$criteria = new Criteria();
// Add filter for OrderTransactionStateMachine
$criteria->addFilter(
new EqualsFilter('stateMachine.technicalName', \sprintf('%s.state', OrderTransactionDefinition::ENTITY_NAME)),
new EqualsFilter('technicalName', OrderTransactionStates::STATE_PAID)
);
return $this->stateMachineStateRepository->searchIds($criteria, $context)->firstId();
}
private function getOrder(string $orderTransactionId, Context $context): ?OrderEntity
{
$criteria = new Criteria();
$criteria->addFilter(
new EqualsFilter('transactions.id', $orderTransactionId)
);
return $this->orderRepository->search($criteria, $context)->first();
}
}
在您的 services xml 中添加如下内容。当然你需要调整FQCN(FullyQualifiedClassName)。
<service id="Your\Namespace\OrderStateSubscriber">
<argument type="service" id="state_machine_state.repository"/>
<argument type="service" id="order.repository"/>
<tag name="kernel.event_subscriber"/>
</service>
- 1 回答
- 0 关注
- 87 浏览
添加回答
举报