Implement Bitrix24Partners support (issue #70)

composer.json

@@ -50,7 +50,10 @@
     "doctrine/doctrine-bundle": "*",
     "doctrine/doctrine-migrations-bundle": "*",
     "knplabs/knp-paginator-bundle": "^6",
+    "league/csv": "^9.0",
+    "odolbeau/phone-number-bundle": "^3.0",
     "symfony/event-dispatcher": "^7",
+    "symfony/http-client": "^7",
     "symfony/serializer": "^7",
     "symfony/uid": "^7",
     "symfony/yaml": "^7",

config/xml/Bitrix24.Lib.Bitrix24Partners.Entity.Bitrix24Partner.dcm.xml

@@ -0,0 +1,35 @@
+<doctrine-mapping xmlns="http://doctrine-project.org/schemas/orm/doctrine-mapping"
+                  xmlns:xs="https://www.w3.org/2001/XMLSchema"
+                  xmlns:orm="https://www.doctrine-project.org/schemas/orm/doctrine-mapping.xsd">
+    <entity name="Bitrix24\Lib\Bitrix24Partners\Entity\Bitrix24Partner" table="bitrix24_partners">
+        <id name="id" type="uuid" column="id">
+
+        </id>
+
+        <field name="title" type="string" column="title" nullable="false"/>
+
+        <field name="site" type="string" column="site" nullable="true"/>
+
+        <field name="phone" type="phone_number" column="phone" nullable="true"/>
+
+        <field name="email" type="string" column="email" nullable="true"/>
+
+        <field name="bitrix24PartnerId" type="integer" column="b24_partner_id" nullable="false">
+            <options>
+                <option name="unique">true</option>
+            </options>
+        </field>
+
+        <field name="openLineId" type="string" column="open_line_id" nullable="true"/>
+
+        <field name="externalId" type="string" column="external_id" nullable="true"/>
+
+        <field name="status" enum-type="string" column="status" nullable="false"/>
+
+        <field name="comment" type="text" column="comment" nullable="true"/>
+
+        <field name="createdAt" type="carbon_immutable" column="created_at_utc" precision="3" nullable="false"/>
+
+        <field name="updatedAt" type="carbon_immutable" column="updated_at_utc" precision="3" nullable="false"/>
+    </entity>
+</doctrine-mapping>

src/Bitrix24Partners/Console/ImportPartnersCsvCommand.php

@@ -0,0 +1,208 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Bitrix24\Lib\Bitrix24Partners\Console;
+
+use Bitrix24\Lib\Bitrix24Partners\UseCase\Create\Command as CreateCommand;
+use Bitrix24\Lib\Bitrix24Partners\UseCase\Create\Handler as CreateHandler;
+use League\Csv\Reader;
+use League\Csv\Statement;
+use libphonenumber\NumberParseException;
+use libphonenumber\PhoneNumberUtil;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Helper\ProgressBar;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Style\SymfonyStyle;
+
+#[AsCommand(
+    name: 'bitrix24:partners:import',
+    description: 'Import partners from CSV file into database'
+)]
+class ImportPartnersCsvCommand extends Command
+{
+    public function __construct(
+        private readonly CreateHandler $createHandler
+    ) {
+        parent::__construct();
+    }
+
+    #[\Override]
+    protected function configure(): void
+    {
+        $this
+            ->addArgument(
+                'file',
+                InputArgument::REQUIRED,
+                'Path to CSV file to import'
+            )
+            ->addOption(
+                'skip-errors',
+                's',
+                InputOption::VALUE_NONE,
+                'Skip rows with errors and continue processing'
+            );
+    }
+
+    #[\Override]
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $io = new SymfonyStyle($input, $output);
+
+        $file = $input->getArgument('file');
+        $skipErrors = $input->getOption('skip-errors');
+
+        if (!file_exists($file)) {
+            $io->error(sprintf('File not found: %s', $file));
+
+            return Command::FAILURE;
+        }
+
+        $io->title('Importing Bitrix24 Partners from CSV');
+        $io->info(sprintf('Reading file: %s', $file));
+
+        try {
+            $imported = $this->importFromCsv($file, $skipErrors, $io, $output);
+
+            $io->success(sprintf('Successfully imported %d partners', $imported));
+
+            return Command::SUCCESS;
+        } catch (\Exception $e) {
+            $io->error(sprintf('Error: %s', $e->getMessage()));
+
+            return Command::FAILURE;
+        }
+    }
+
+    private function importFromCsv(string $file, bool $skipErrors, SymfonyStyle $io, OutputInterface $output): int
+    {
+        $csv = Reader::createFromPath($file, 'r');
+        $csv->setHeaderOffset(0);
+
+        $phoneUtil = PhoneNumberUtil::getInstance();
+        $imported = 0;
+        $skipped = 0;
+
+        // Validate header
+        $expectedHeaders = ['title', 'site', 'phone', 'email', 'bitrix24_partner_id', 'open_line_id', 'external_id'];
+        $actualHeaders = $csv->getHeader();
+        if ($actualHeaders !== $expectedHeaders) {
+            $io->warning(sprintf(
+                'CSV header mismatch. Expected: %s, Got: %s',
+                implode(', ', $expectedHeaders),
+                implode(', ', $actualHeaders)
+            ));
+        }
+
+        // Get records
+        $records = Statement::create()->process($csv);
+        $totalRecords = iterator_count($records);
+
+        if (0 === $totalRecords) {
+            $io->warning('No records found in CSV file');
+
+            return 0;
+        }
+
+        // Reset iterator
+        $records = Statement::create()->process($csv);
+
+        // Create progress bar
+        $progressBar = new ProgressBar($output, $totalRecords);
+        $progressBar->setFormat(' %current%/%max% [%bar%] %percent:3s%% %elapsed:6s%/%estimated:-6s% %memory:6s%');
+        $progressBar->start();
+
+        $lineNumber = 1; // Header is line 1
+
+        foreach ($records as $record) {
+            $lineNumber++;
+            $progressBar->advance();
+
+            try {
+                // Skip empty rows
+                if (empty(array_filter($record))) {
+                    continue;
+                }
+
+                // Parse row data
+                $title = isset($record['title']) ? trim($record['title']) : '';
+                $siteRaw = isset($record['site']) ? trim($record['site']) : '';
+                $site = '' !== $siteRaw ? $siteRaw : null;
+                $phoneStringRaw = isset($record['phone']) ? trim($record['phone']) : '';
+                $phoneString = '' !== $phoneStringRaw ? $phoneStringRaw : null;
+                $emailRaw = isset($record['email']) ? trim($record['email']) : '';
+                $email = '' !== $emailRaw ? $emailRaw : null;
+                $bitrix24PartnerIdRaw = isset($record['bitrix24_partner_id']) ? trim($record['bitrix24_partner_id']) : '';
+                $bitrix24PartnerId = '' !== $bitrix24PartnerIdRaw ? (int) $bitrix24PartnerIdRaw : null;
+                $openLineIdRaw = isset($record['open_line_id']) ? trim($record['open_line_id']) : '';
+                $openLineId = '' !== $openLineIdRaw ? $openLineIdRaw : null;
+                $externalIdRaw = isset($record['external_id']) ? trim($record['external_id']) : '';
+                $externalId = '' !== $externalIdRaw ? $externalIdRaw : null;
+
+                // Validate required fields
+                if ('' === $title) {
+                    throw new \InvalidArgumentException('Title is required');
+                }
+
+                if (null === $bitrix24PartnerId) {
+                    throw new \InvalidArgumentException('Bitrix24 Partner ID is required');
+                }
+
+                // Parse phone number
+                $phone = null;
+                if (null !== $phoneString) {
+                    try {
+                        $phone = $phoneUtil->parse($phoneString, 'RU');
+                    } catch (NumberParseException $e) {
+                        if (!$skipErrors) {
+                            throw new \InvalidArgumentException(
+                                sprintf('Invalid phone number: %s', $phoneString),
+                                0,
+                                $e
+                            );
+                        }
+                        $phone = null;
+                    }
+                }
+
+                // Create partner
+                $command = new CreateCommand(
+                    $title,
+                    $bitrix24PartnerId,
+                    $site,
+                    $phone,
+                    $email,
+                    $openLineId,
+                    $externalId
+                );
+
+                $this->createHandler->handle($command);
+                $imported++;
+            } catch (\Exception $e) {
+                if (!$skipErrors) {
+                    $progressBar->finish();
+                    throw new \RuntimeException(
+                        sprintf('Error on line %d: %s', $lineNumber, $e->getMessage()),
+                        0,
+                        $e
+                    );
+                }
+
+                $skipped++;
+            }
+        }
+
+        $progressBar->finish();
+        $io->newLine(2);
+
+        if ($skipped > 0) {
+            $io->note(sprintf('Skipped %d rows due to errors', $skipped));
+        }
+
+        return $imported;
+    }
+}