custom/static-plugins/integration-business-central/src/IntegrationBusinessCentral.php line 13

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Wexo\Integration\BusinessCentral;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Framework\Plugin;
  7. use Shopware\Core\Framework\Plugin\Context\InstallContext;
  9. /**
  10.  * Class IntegrationBusinessCentral
  11.  * @package Wexo\Integration\BusinessCentral
  12.  */
  13. class IntegrationBusinessCentral extends Plugin
  14. {
  15.     /**
  16.      * @param InstallContext $installContext
  17.      */
  18.     public function install(InstallContext $installContext): void
  19.     {
  20.         $connection = $this->container->get(Connection::class);
  21.         if (! $connection) {
  22.             return;
  23.         }
  25.         // TODO:
  26.         try {
  27.             $connection->executeStatement(<<<SQL
  28.                 CREATE TABLE IF NOT EXISTS `wexo_integration_business_central` (
  29.                 `id` BINARY(16) NOT NULL,
  30.                 `active` TINYINT(1) NOT NULL,
  31.                 `message_queue` TINYINT(1) NULL,
  32.                 `name` VARCHAR(100) NOT NULL,
  33.                 `profile` VARCHAR(100) NOT NULL,
  34.                 `service_id` VARCHAR(100) NOT NULL,
  35.                 `url` VARCHAR(255) NOT NULL,
  36.                 `username` VARCHAR(50) NOT NULL,
  37.                 `password` VARCHAR(255) NULL,
  38.                 `method` VARCHAR(50) NULL,
  39.                 `company` VARCHAR(255) NULL,
  40.                 `endpoint` VARCHAR(50) NULL,
  41.                 `created_at` DATETIME(3) NOT NULL,
  42.                 `updated_at` DATETIME(3) NULL,
  43.                 PRIMARY KEY (`id`)
  44.                 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
  45.             SQL);
  46.         } catch (\Exception $e) {
  47.             // do nothing
  48.         }
  50.         try {
  51.             $connection->executeStatement(<<<SQL
  52.                 CREATE TABLE IF NOT EXISTS `wexo_integration_business_central_sales_channel` (
  53.                 `id` BINARY(16) NOT NULL,
  54.                 `business_central_id` BINARY(16) NOT NULL,
  55.                 `sales_channel_id` BINARY(16) NOT NULL,
  56.                 `created_at` DATETIME(3) NOT NULL,
  57.                 `updated_at` DATETIME(3) NULL,
  58.                 PRIMARY KEY (`id`),
  59.                 CONSTRAINT `fk.business_central_sales_channel.business_central_id` FOREIGN KEY (`business_central_id`)
  60.                 REFERENCES `wexo_integration_business_central` (`id`) ON DELETE CASCADE ON UPDATE CASCADE,
  61.                 CONSTRAINT `fk.business_central_sales_channel.sales_channel_id` FOREIGN KEY (`sales_channel_id`)
  62.                 REFERENCES `sales_channel` (`id`) ON DELETE CASCADE ON UPDATE CASCADE
  63.                 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
  64.             SQL);
  65.         } catch (\Exception $e) {
  66.             // do nothing
  67.         }
  69.         try {
  70.             $connection->executeStatement(<<<SQL
  71.                 CREATE TABLE IF NOT EXISTS `wexo_integration_business_central_order` (
  72.                 `order_id` BINARY(16) NOT NULL,
  73.                 `order_version_id` BINARY(16) NOT NULL,
  74.                 `exported` TINYINT(1) NULL DEFAULT '0',
  75.                 `error_message` TEXT NULL,
  76.                 `created_at` DATETIME(3) NOT NULL,
  77.                 `updated_at` DATETIME(3) NULL,
  78.                 CONSTRAINT `fk.wexo_integration_business_central_order.order_id__version_id`
  79.                 FOREIGN KEY (`order_id`, `order_version_id`) REFERENCES `order` (id, version_id)
  80.                 ON UPDATE CASCADE ON DELETE CASCADE,
  81.                 PRIMARY KEY (`order_id`, `order_version_id`)
  82.                 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
  83.             SQL);
  84.         } catch (\Exception $e) {
  85.             //do nothing
  86.         }
  88.         try {
  89.             $connection->executeStatement(<<<SQL
  90.                 CREATE TABLE IF NOT EXISTS `wexo_integration_business_central_profile` (
  91.                     `id` BINARY(16) NOT NULL,
  92.                     `business_central_id` BINARY(16) NOT NULL,
  93.                     `profile_id` BINARY(16) NOT NULL,
  94.                     `created_at` DATETIME(3) NOT NULL,
  95.                     `updated_at` DATETIME(3) NULL,
  96.                     PRIMARY KEY (`id`)
  97.                 ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
  98.             SQL);
  99.         } catch (\Exception $e) {
  100.             //do nothing
  101.         }
  102.     }
  103. }