custom/static-plugins/K3nMerchant/src/K3nMerchant.php line 19

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace K3n\Merchant;
  7. use Shopware\Core\Defaults;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\Plugin;
  12. use Shopware\Core\Framework\Plugin\Context\InstallContext;
  13. use Shopware\Core\Framework\Context;
  14. use Shopware\Core\System\Language\LanguageEntity;
  15. use Shopware\Core\System\StateMachine\Aggregation\StateMachineState\StateMachineStateEntity;
  16. use Shopware\Core\System\StateMachine\StateMachineEntity;
  17. use Shopware\Core\Framework\Uuid\Uuid;
  19. class K3nMerchant extends Plugin
  20. {
  21.     private const STATE_MACHINE_STATE_ACCEPTED = 'accepted';
  22.     private const STATE_MACHINE_STATE_ACCEPTED_ID = '6ae733b8491047c9bac615e399105a7e';
  23.     private const STATE_MACHINE_STATE_REJECTED = 'rejected';
  24.     private const STATE_MACHINE_STATE_REJECTED_ID = '3d17146ff9a24e9a809b7e75ac39df82';
  25.     private const STATE_MACHINE_STATE_PURCHASE = 'purchase';
  26.     private const STATE_MACHINE_STATE_PURCHASE_ID = 'ef4c30a065535c27e2f5818ff550e0d8';
  28.     private const STATE_MACHINE_TRANSITION_ACCEPTED_ID = '6fd97d792b549594df4fb55b617c4f9b';
  29.     private const STATE_MACHINE_TRANSITION_REJECTED_ID = 'd51c3cc92d88cbf02f32408cbbee97bc';
  30.     private const STATE_MACHINE_TRANSITION_CANCEL_REJECTED_ID = '1d45e961e8fedf3dd1ed953818804f7c';
  31.     private const STATE_MACHINE_TRANSITION_PURCHASE_ID = 'c13a25d781e8ceb3309626c1a50bc868';
  32.     private const STATE_MACHINE_TRANSITION_OPEN_PURCHASED_ID = 'ab2f9d882cdea7dd4f25cb9e97c14eb1';
  33.     private const STATE_MACHINE_TRANSITION_REJECT_ACCEPTED_ID = 'baef4894edd1d48807d24f53517b8294';
  34.     private const STATE_MACHINE_TRANSITION_OPEN_DONE_ID = 'cf20a65c00fa9f274791243e4939324a';
  36.     public function install(InstallContext $installContext): void
  37.     {
  38.         $context = $installContext->getContext();
  40.         $stateMachineStateRepository = $this->container->get('state_machine_state.repository');
  41.         $stateMachineTransitionRepository = $this->container->get('state_machine_transition.repository');
  43.         // 'accepted' state
  44.         $stateMachineAcceptedState = $stateMachineStateRepository->search(new Criteria([self::STATE_MACHINE_STATE_ACCEPTED_ID]), $context)->getElements();
  46.         $STATE_MACHINE_ORDER_ID = $this->getOrderStateMachineId($context);
  48.         $GERMAN_LANGUAGE_ID  = $this->getLanguageId($context, 'de-DE');
  49.         $ENGLISH_LANGUAGE_ID = $this->getLanguageId($context, 'en-GB');
  50.         $POLISH_LANGUAGE_ID  = $this->getLanguageId($context, 'pl-PL');
  52.         $STATE_MACHINE_STATE_OPEN_ID      = $this->getOrderStateMachineStateId($context, $STATE_MACHINE_ORDER_ID, 'open');
  53.         $STATE_MACHINE_STATE_CANCELLED_ID = $this->getOrderStateMachineStateId($context, $STATE_MACHINE_ORDER_ID, 'cancelled');
  54.         $STATE_MACHINE_STATE_DONE_ID      = $this->getOrderStateMachineStateId($context, $STATE_MACHINE_ORDER_ID, 'completed');
  56.         if (count($stateMachineAcceptedState) == 0) {
  57.             $stateMachineStateRepository->create([
  58.                 [
  59.                     'id' => self::STATE_MACHINE_STATE_ACCEPTED_ID,
  60.                     'technicalName' => self::STATE_MACHINE_STATE_ACCEPTED,
  61.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  62.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  63.                     'translations' => [
  64.                         $GERMAN_LANGUAGE_ID => [
  65.                             'name' => 'Akzeptiert'
  66.                         ],
  67.                         $ENGLISH_LANGUAGE_ID => [
  68.                             'name' => 'Accepted'
  69.                         ],
  70.                         $POLISH_LANGUAGE_ID => [
  71.                             'name' => 'Przyjęty'
  72.                         ]
  73.                     ]
  74.                 ],
  75.             ], $context);
  76.         }
  78.         $stateMachineAcceptedTransition = $stateMachineTransitionRepository->search(new Criteria([self::STATE_MACHINE_TRANSITION_ACCEPTED_ID]), $context)->getElements();
  79.         if (count($stateMachineAcceptedTransition) == 0) {
  80.             $stateMachineTransitionRepository->create([
  81.                 [
  82.                     'id' => self::STATE_MACHINE_TRANSITION_ACCEPTED_ID,
  83.                     'actionName' => 'accepted',
  84.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  85.                     'fromStateId' => $STATE_MACHINE_STATE_OPEN_ID,
  86.                     'toStateId' => self::STATE_MACHINE_STATE_ACCEPTED_ID,
  87.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  88.                 ],
  89.             ], $context);
  90.         }
  92.         // 'rejected' state
  93.         $stateMachineRejectedState = $stateMachineStateRepository->search(new Criteria([self::STATE_MACHINE_STATE_REJECTED_ID]), $context)->getElements();
  94.         if (count($stateMachineRejectedState) == 0) {
  95.             $stateMachineStateRepository->create([
  96.                 [
  97.                     'id' => self::STATE_MACHINE_STATE_REJECTED_ID,
  98.                     'technicalName' => self::STATE_MACHINE_STATE_REJECTED,
  99.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  100.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  101.                     'translations' => [
  102.                         $GERMAN_LANGUAGE_ID => [
  103.                             'name' => 'Abgelehnt'
  104.                         ],
  105.                         $ENGLISH_LANGUAGE_ID => [
  106.                             'name' => 'Rejected'
  107.                         ],
  108.                         $POLISH_LANGUAGE_ID => [
  109.                             'name' => 'Odrzucony'
  110.                         ],
  111.                     ]
  112.                 ],
  113.             ], $context);
  114.         }
  116.         $stateMachineRejectedTransition = $stateMachineTransitionRepository->search(new Criteria([self::STATE_MACHINE_TRANSITION_REJECTED_ID]), $context)->getElements();
  117.         if (count($stateMachineRejectedTransition) == 0) {
  118.             $stateMachineTransitionRepository->create([
  119.                 [
  120.                     'id' => self::STATE_MACHINE_TRANSITION_REJECTED_ID,
  121.                     'actionName' => 'rejected',
  122.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  123.                     'fromStateId' => $STATE_MACHINE_STATE_OPEN_ID,
  124.                     'toStateId' => self::STATE_MACHINE_STATE_REJECTED_ID,
  125.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  126.                 ],
  127.             ], $context);
  128.         }
  130.         $stateMachineCancelRejectedTransition = $stateMachineTransitionRepository->search(new Criteria([self::STATE_MACHINE_TRANSITION_CANCEL_REJECTED_ID]), $context)->getElements();
  131.         if (count($stateMachineCancelRejectedTransition) == 0) {
  132.             $stateMachineTransitionRepository->create([
  133.                 [
  134.                     'id' => self::STATE_MACHINE_TRANSITION_CANCEL_REJECTED_ID,
  135.                     'actionName' => 'cancel_rejected',
  136.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  137.                     'fromStateId' => self::STATE_MACHINE_STATE_REJECTED_ID,
  138.                     'toStateId' => $STATE_MACHINE_STATE_CANCELLED_ID,
  139.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  140.                 ],
  141.             ], $context);
  142.         }
  145.         // 'purchase' state
  146.         $stateMachinePurchaseState = $stateMachineStateRepository->search(new Criteria([self::STATE_MACHINE_STATE_PURCHASE_ID]), $context)->getElements();
  147.         if (count($stateMachinePurchaseState) == 0) {
  148.             $stateMachineStateRepository->create([
  149.                 [
  150.                     'id' => self::STATE_MACHINE_STATE_PURCHASE_ID,
  151.                     'technicalName' => self::STATE_MACHINE_STATE_PURCHASE,
  152.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  153.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  154.                     'translations' => [
  155.                         $GERMAN_LANGUAGE_ID => [
  156.                             'name' => 'Kauf'
  157.                         ],
  158.                         $ENGLISH_LANGUAGE_ID => [
  159.                             'name' => 'Purchase'
  160.                         ],
  161.                         $POLISH_LANGUAGE_ID => [
  162.                             'name' => 'Zakup'
  163.                         ],
  164.                     ]
  165.                 ],
  166.             ], $context);
  167.         }
  169.         $stateMachinePurchaseTransition = $stateMachineTransitionRepository->search(new Criteria([self::STATE_MACHINE_TRANSITION_PURCHASE_ID]), $context)->getElements();
  170.         if (count($stateMachinePurchaseTransition) == 0) {
  171.             $stateMachineTransitionRepository->create([
  172.                 [
  173.                     'id' => self::STATE_MACHINE_TRANSITION_PURCHASE_ID,
  174.                     'actionName' => 'purchase',
  175.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  176.                     'fromStateId' => self::STATE_MACHINE_STATE_ACCEPTED_ID,
  177.                     'toStateId' => self::STATE_MACHINE_STATE_PURCHASE_ID,
  178.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  179.                 ],
  180.             ], $context);
  181.         }
  183.         $stateMachineOpenPurchasedTransition = $stateMachineTransitionRepository->search(new Criteria([self::STATE_MACHINE_TRANSITION_OPEN_PURCHASED_ID]), $context)->getElements();
  184.         if (count($stateMachineOpenPurchasedTransition) == 0) {
  185.             $stateMachineTransitionRepository->create([
  186.                 [
  187.                     'id' => self::STATE_MACHINE_TRANSITION_OPEN_PURCHASED_ID,
  188.                     'actionName' => 'open_purchased',
  189.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  190.                     'fromStateId' => self::STATE_MACHINE_STATE_PURCHASE_ID,
  191.                     'toStateId' => $STATE_MACHINE_STATE_OPEN_ID,
  192.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  193.                 ],
  194.             ], $context);
  195.         }
  198.         // transition from accepted to rejected
  199.         $stateMachineRejectAcceptedTransition = $stateMachineTransitionRepository->search(new Criteria([self::STATE_MACHINE_TRANSITION_REJECT_ACCEPTED_ID]), $context)->getElements();
  200.         if (count($stateMachineRejectAcceptedTransition) == 0) {
  201.             $stateMachineTransitionRepository->create([
  202.                 [
  203.                     'id' => self::STATE_MACHINE_TRANSITION_REJECT_ACCEPTED_ID,
  204.                     'actionName' => 'reject_accepted',
  205.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  206.                     'fromStateId' => self::STATE_MACHINE_STATE_ACCEPTED_ID,
  207.                     'toStateId' => self::STATE_MACHINE_STATE_REJECTED_ID,
  208.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  209.                 ],
  210.             ], $context);
  211.         }
  213.         // transition from open to done
  214.         $stateMachineOpenDoneTransition = $stateMachineTransitionRepository->search(new Criteria([self::STATE_MACHINE_TRANSITION_OPEN_DONE_ID]), $context)->getElements();
  215.         if (count($stateMachineOpenDoneTransition) == 0) {
  216.             $stateMachineTransitionRepository->create([
  217.                 [
  218.                     'id' => self::STATE_MACHINE_TRANSITION_OPEN_DONE_ID,
  219.                     'actionName' => 'reject_accepted',
  220.                     'stateMachineId' => $STATE_MACHINE_ORDER_ID,
  221.                     'fromStateId' => $STATE_MACHINE_STATE_OPEN_ID,
  222.                     'toStateId' => $STATE_MACHINE_STATE_DONE_ID ,
  223.                     'createdAt' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT),
  224.                 ],
  225.             ], $context);
  226.         }
  228.     }
  230.     private function getOrderStateMachineId(Context $context): string
  231.     {
  232.         /**
  233.          * @var EntityRepositoryInterface $stateMachineRepository
  234.          */
  235.         $stateMachineRepository = $this->container->get('state_machine.repository');
  237.         $criteria = new Criteria();
  238.         $criteria->addFilter(new EqualsFilter('technicalName', 'order.state'));
  240.         /**
  241.          * @var StateMachineEntity $orderStateMachine
  242.          */
  243.         $orderStateMachine = $stateMachineRepository->search($criteria, $context)->first();
  244.         return $orderStateMachine->getId();
  245.     }
  247.     private function getLanguageId(Context $context, string $languageCode): ?string
  248.     {
  249.         /**
  250.          * @var EntityRepositoryInterface $languageRepository
  251.          */
  252.         $languageRepository = $this->container->get('language.repository');
  254.         $criteria = new Criteria();
  255.         $criteria->addAssociation('locale');
  256.         $criteria->addFilter(new EqualsFilter('locale.code', $languageCode));
  258.         /**
  259.          * @var LanguageEntity $language
  260.          */
  261.         $language = $languageRepository->search($criteria, $context)->first();
  262.         if ($language) {
  263.             return $language->getId();
  264.         }
  265.         return null;
  266.     }
  268.     private function getOrderStateMachineStateId(Context $context, string $orderStateMachineId, string $technicalName): string
  269.     {
  270.         /**
  271.          * @var EntityRepositoryInterface $stateMachineStateRepository
  272.          */
  273.         $stateMachineStateRepository = $this->container->get('state_machine_state.repository');
  275.         $criteria = new Criteria();
  276.         $criteria->addFilter(new EqualsFilter('stateMachineId', $orderStateMachineId));
  277.         $criteria->addFilter(new EqualsFilter('technicalName', $technicalName));
  279.         /**
  280.          * @var StateMachineStateEntity $stateMachineState
  281.          */
  282.         $stateMachineState = $stateMachineStateRepository->search($criteria, $context)->first();
  283.         return $stateMachineState->getId();
  285.     }
  287.     public function update(InstallContext $installContext): void
  288.     {
  289.         $this->updateRetailerRole($installContext->getContext());
  290.     }
  292.     private function updateRetailerRole(Context $context)
  293.     {
  294.         /**
  295.          * @var EntityRepositoryInterface
  296.          */
  297.         $aclRoleRepository = $this->container->get('acl_role.repository');
  299.         $aclRetailerRole = [
  300.             'id' => 'a390397f72be4b4ab1f8d61e08849108',
  301.             'name' => 'Retailer',
  302.             'description' => 'As a Retailer you can see your own orders.',
  303.             'privileges' => [
  304.                 "country:read",
  305.                 "country_state:read",
  306.                 "currency:read",
  307.                 "custom_field:read",
  308.                 "custom_field_set:read",
  309.                 "custom_field_set_relation:read",
  310.                 "customer:read",
  311.                 "customer_address:read",
  312.                 "document:create",
  313.                 "document:read",
  314.                 "document:update",
  315.                 "document_type:read",
  316.                 "iwv_extra_order_file:create",
  317.                 "iwv_extra_order_file:delete",
  318.                 "iwv_extra_order_file:read",
  319.                 "iwv_extra_order_file:update",
  320.                 "language:read",
  321.                 "locale:read",
  322.                 "log_entry:create",
  323.                 "mail_template:read",
  324.                 "mail_template_sales_channel:create",
  325.                 "mail_template_sales_channel:read",
  326.                 "mail_template_type:read",
  327.                 "message_queue_stats:read",
  328.                 "order.editor",
  329.                 "order.viewer",
  330.                 "order:delete",
  331.                 "order:read",
  332.                 "order:update",
  333.                 "order_address:create",
  334.                 "order_address:read",
  335.                 "order_address:update",
  336.                 "order_customer:read",
  337.                 "order_customer:update",
  338.                 "order_delivery:read",
  339.                 "order_delivery:update",
  340.                 "order_line_item:create",
  341.                 "order_line_item:read",
  342.                 "order_line_item:update",
  343.                 "order_tag:create",
  344.                 "order_tag:delete",
  345.                 "order_tag:read",
  346.                 "order_tag:update",
  347.                 "order_transaction:read",
  348.                 "payment_method:read",
  349.                 "product:read",
  350.                 "product_visibility:read",
  351.                 "property_group:read",
  352.                 "property_group_option:read",
  353.                 "sales_channel:read",
  354.                 "salutation:read",
  355.                 "shipping_method:read",
  356.                 "state_machine:read",
  357.                 "state_machine_history:create",
  358.                 "state_machine_history:read",
  359.                 "state_machine_state:read",
  360.                 "state_machine_transition:read",
  361.                 "swag_language_pack_language:read",
  362.                 "tag:create",
  363.                 "tag:read",
  364.                 "user:read",
  365.                 "user_config:create",
  366.                 "user_config:read",
  367.                 "user_config:update",
  368.                 "vio_representative_agent:read",
  369.                 "customer_group:read",
  370.                 "acl_role:read", // Result in error: Access to entity "acl_role" are not allowed in scope "user"
  371.                 "version:delete"
  372.             ]
  373.         ];
  375.         $aclRoleRepository->upsert([$aclRetailerRole], $context);
  376.     }
  377. }