initial release of FinFollowBCS

.env

@@ -18,3 +18,25 @@
 APP_ENV=dev
 APP_SECRET=433b91b597b7ee4854b62c68fd2f5174
 ###< symfony/framework-bundle ###
+
+##
+IMAP_PATH=
+IMAP_USERNAME=
+IMAP_STORE_ATTACHMENTS_DIR="%kernel.project_dir%/var/imap/attachments"
+
+###> doctrine/doctrine-bundle ###
+# Format described at https://www.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/configuration.html#connecting-using-a-url
+# IMPORTANT: You MUST configure your server version, either here or in config/packages/doctrine.yaml
+#
+# DATABASE_URL="sqlite:///%kernel.project_dir%/var/data.db"
+# DATABASE_URL="mysql://app:!ChangeMe!@127.0.0.1:3306/app?serverVersion=8.0.32&charset=utf8mb4"
+# DATABASE_URL="mysql://app:!ChangeMe!@127.0.0.1:3306/app?serverVersion=10.11.2-MariaDB&charset=utf8mb4"
+DATABASE_URL="postgresql://db_user:secret@127.0.0.1:5432/finfollow?serverVersion=11&charset=utf8"
+###< doctrine/doctrine-bundle ###
+
+###> symfony/telegram-notifier ###
+TELEGRAM_DSN=telegram://bot_token@default?channel=channel_id
+###< symfony/telegram-notifier ###
+
+TELEGRAM_BOT_TOKEN=
+TELEGRAM_CHAT_ID=

composer.json

@@ -7,14 +7,24 @@
         "php": ">=8.2",
         "ext-ctype": "*",
         "ext-iconv": "*",
+        "doctrine/dbal": "^3",
+        "doctrine/doctrine-bundle": "^2.12",
+        "doctrine/doctrine-migrations-bundle": "^3.3",
+        "doctrine/orm": "^3.2",
+        "secit-pl/imap-bundle": "^3.2",
         "symfony/console": "7.1.*",
         "symfony/dotenv": "7.1.*",
+        "symfony/filesystem": "7.1.*",
         "symfony/flex": "^2",
         "symfony/framework-bundle": "7.1.*",
+        "symfony/monolog-bundle": "^3.10",
+        "symfony/notifier": "7.1.*",
         "symfony/runtime": "7.1.*",
+        "symfony/telegram-notifier": "7.1.*",
         "symfony/yaml": "7.1.*"
     },
     "require-dev": {
+        "symfony/maker-bundle": "^1.59"
     },
     "config": {
         "allow-plugins": {

config/bundles.php

@@ -2,4 +2,9 @@
 
 return [
     Symfony\Bundle\FrameworkBundle\FrameworkBundle::class => ['all' => true],
+    Symfony\Bundle\MakerBundle\MakerBundle::class => ['dev' => true],
+    SecIT\ImapBundle\ImapBundle::class => ['all' => true],
+    Doctrine\Bundle\DoctrineBundle\DoctrineBundle::class => ['all' => true],
+    Doctrine\Bundle\MigrationsBundle\DoctrineMigrationsBundle::class => ['all' => true],
+    Symfony\Bundle\MonologBundle\MonologBundle::class => ['all' => true],
 ];

config/packages/doctrine.yaml

@@ -0,0 +1,52 @@
+doctrine:
+    dbal:
+        url: '%env(resolve:DATABASE_URL)%'
+
+        # IMPORTANT: You MUST configure your server version,
+        # either here or in the DATABASE_URL env var (see .env file)
+        #server_version: '16'
+
+        profiling_collect_backtrace: '%kernel.debug%'
+        use_savepoints: true
+    orm:
+        auto_generate_proxy_classes: true
+        enable_lazy_ghost_objects: true
+        report_fields_where_declared: true
+        validate_xml_mapping: true
+        naming_strategy: doctrine.orm.naming_strategy.underscore_number_aware
+        auto_mapping: true
+        mappings:
+            App:
+                type: attribute
+                is_bundle: false
+                dir: '%kernel.project_dir%/src/Entity'
+                prefix: 'App\Entity'
+                alias: App
+        controller_resolver:
+            auto_mapping: false
+
+when@test:
+    doctrine:
+        dbal:
+            # "TEST_TOKEN" is typically set by ParaTest
+            dbname_suffix: '_test%env(default::TEST_TOKEN)%'
+
+when@prod:
+    doctrine:
+        orm:
+            auto_generate_proxy_classes: false
+            proxy_dir: '%kernel.build_dir%/doctrine/orm/Proxies'
+            query_cache_driver:
+                type: pool
+                pool: doctrine.system_cache_pool
+            result_cache_driver:
+                type: pool
+                pool: doctrine.result_cache_pool
+
+    framework:
+        cache:
+            pools:
+                doctrine.result_cache_pool:
+                    adapter: cache.app
+                doctrine.system_cache_pool:
+                    adapter: cache.system

config/packages/doctrine_migrations.yaml

@@ -0,0 +1,6 @@
+doctrine_migrations:
+    migrations_paths:
+        # namespace is arbitrary but should be different from App\Migrations
+        # as migrations classes should NOT be autoloaded
+        'DoctrineMigrations': '%kernel.project_dir%/migrations'
+    enable_profiler: false

config/packages/imap.yaml

@@ -0,0 +1,8 @@
+imap:
+    connections:
+        finfollow:
+            imap_path: "%env(IMAP_PATH)%"
+            username: "%env(IMAP_USERNAME)%"
+            password: "%env(IMAP_PASSWORD)%"
+            attachments_dir: "%env(IMAP_STORE_ATTACHMENTS_DIR)%"
+#            server_encoding: "UTF-8"

config/packages/monolog.yaml

@@ -0,0 +1,62 @@
+monolog:
+    channels:
+        - deprecation # Deprecations are logged in the dedicated "deprecation" channel when it exists
+
+when@dev:
+    monolog:
+        handlers:
+            main:
+                type: stream
+                path: "%kernel.logs_dir%/%kernel.environment%.log"
+                level: debug
+                channels: ["!event"]
+            # uncomment to get logging in your browser
+            # you may have to allow bigger header sizes in your Web server configuration
+            #firephp:
+            #    type: firephp
+            #    level: info
+            #chromephp:
+            #    type: chromephp
+            #    level: info
+            console:
+                type: console
+                process_psr_3_messages: false
+                channels: ["!event", "!doctrine", "!console"]
+
+when@test:
+    monolog:
+        handlers:
+            main:
+                type: fingers_crossed
+                action_level: error
+                handler: nested
+                excluded_http_codes: [404, 405]
+                channels: ["!event"]
+            nested:
+                type: stream
+                path: "%kernel.logs_dir%/%kernel.environment%.log"
+                level: debug
+
+when@prod:
+    monolog:
+        handlers:
+            main:
+                type: fingers_crossed
+                action_level: error
+                handler: nested
+                excluded_http_codes: [404, 405]
+                buffer_size: 50 # How many messages should be saved? Prevent memory leaks
+            nested:
+                type: stream
+                path: php://stderr
+                level: debug
+                formatter: monolog.formatter.json
+            console:
+                type: console
+                process_psr_3_messages: false
+                channels: ["!event", "!doctrine"]
+            deprecation:
+                type: stream
+                channels: [deprecation]
+                path: php://stderr
+                formatter: monolog.formatter.json

config/packages/notifier.yaml

@@ -0,0 +1,13 @@
+framework:
+    notifier:
+        chatter_transports:
+            telegram: '%env(TELEGRAM_DSN)%'
+        texter_transports:
+        channel_policy:
+            # use chat/slack, chat/telegram, sms/twilio or sms/nexmo
+            urgent: ['email']
+            high: ['email']
+            medium: ['email']
+            low: ['email']
+        admin_recipients:
+            - { email: admin@example.com }

config/services.yaml

@@ -22,3 +22,7 @@ services:
 
     # add more service definitions when explicit configuration is needed
     # please note that last definitions always *replace* previous ones
+    App\Service\TelegramNotifier:
+        arguments:
+            $telegramBotToken: '%env(TELEGRAM_BOT_TOKEN)%'
+            $telegramChatId: '%env(TELEGRAM_CHAT_ID)%'

migrations/Version20240608120637.php

@@ -0,0 +1,45 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20240608120637 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('CREATE TABLE portfolio (id SERIAL NOT NULL, client_agreement VARCHAR(255) NOT NULL, xml_data TEXT NOT NULL, start_date DATE NOT NULL, end_date DATE NOT NULL, PRIMARY KEY(id))');
+        $this->addSql('COMMENT ON COLUMN portfolio.start_date IS \'(DC2Type:date_immutable)\'');
+        $this->addSql('COMMENT ON COLUMN portfolio.end_date IS \'(DC2Type:date_immutable)\'');
+        $this->addSql('CREATE TABLE portfolio_detail (id SERIAL NOT NULL, portfolio_id INT NOT NULL, security VARCHAR(32) NOT NULL, quantity_start INT NOT NULL, quantity_end INT NOT NULL, price_start NUMERIC(10, 3) NOT NULL, price_end NUMERIC(10, 3) NOT NULL, sum_start NUMERIC(10, 3) NOT NULL, sum_end NUMERIC(10, 3) NOT NULL, issuer VARCHAR(255) NOT NULL, PRIMARY KEY(id))');
+        $this->addSql('CREATE INDEX IDX_28ED92A6B96B5643 ON portfolio_detail (portfolio_id)');
+        $this->addSql('CREATE TABLE portfolio_movement (id SERIAL NOT NULL, portfolio_id INT NOT NULL, security VARCHAR(255) NOT NULL, period TIMESTAMP(0) WITHOUT TIME ZONE NOT NULL, quantity_start INT NOT NULL, quantity_end INT NOT NULL, quantity_income INT NOT NULL, quantity_outcome INT NOT NULL, PRIMARY KEY(id))');
+        $this->addSql('CREATE INDEX IDX_8857CF6FB96B5643 ON portfolio_movement (portfolio_id)');
+        $this->addSql('COMMENT ON COLUMN portfolio_movement.period IS \'(DC2Type:datetime_immutable)\'');
+        $this->addSql('ALTER TABLE portfolio_detail ADD CONSTRAINT FK_28ED92A6B96B5643 FOREIGN KEY (portfolio_id) REFERENCES portfolio (id) NOT DEFERRABLE INITIALLY IMMEDIATE');
+        $this->addSql('ALTER TABLE portfolio_movement ADD CONSTRAINT FK_8857CF6FB96B5643 FOREIGN KEY (portfolio_id) REFERENCES portfolio (id) NOT DEFERRABLE INITIALLY IMMEDIATE');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('CREATE SCHEMA public');
+        $this->addSql('ALTER TABLE portfolio_detail DROP CONSTRAINT FK_28ED92A6B96B5643');
+        $this->addSql('ALTER TABLE portfolio_movement DROP CONSTRAINT FK_8857CF6FB96B5643');
+        $this->addSql('DROP TABLE portfolio');
+        $this->addSql('DROP TABLE portfolio_detail');
+        $this->addSql('DROP TABLE portfolio_movement');
+    }
+}

src/Command/FetchEmailsCommand.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace App\Command;
+
+use App\Service\MailFetcher;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+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: 'app:fetch-emails',
+    description: 'Fetch emails and process them',
+)]
+class FetchEmailsCommand extends Command
+{
+    private MailFetcher $mailFetcher;
+
+    public function __construct(MailFetcher $mailFetcher)
+    {
+        parent::__construct();
+        $this->mailFetcher = $mailFetcher;
+    }
+
+    protected function configure(): void
+    {
+        $this
+            ->addArgument('arg1', InputArgument::OPTIONAL, 'Argument description')
+            ->addOption('option1', null, InputOption::VALUE_NONE, 'Option description');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $io = new SymfonyStyle($input, $output);
+        $arg1 = $input->getArgument('arg1');
+
+        if ($arg1) {
+            $io->note(sprintf('You passed an argument: %s', $arg1));
+        }
+
+        if ($input->getOption('option1')) {
+            // ...
+        }
+
+        $this->mailFetcher->fetchNewEmails();
+
+
+        $io->success('You have a new command! Now make it your own! Pass --help to see your options.');
+
+        return Command::SUCCESS;
+    }
+}

src/Domain/Entity/ParsedPortfolio.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace App\Domain\Entity;
+
+final readonly class ParsedPortfolio
+{
+    private array $header;
+
+    private array $details;
+
+    private array $movements;
+
+
+    public function __construct(array $header, array $details, array $movements)
+    {
+        $this->header = $header;
+        $this->details = $details;
+        $this->movements = $movements;
+    }
+
+    public function getHeader(): array
+    {
+        return $this->header;
+    }
+
+    public function getDetails(): array
+    {
+        return $this->details;
+    }
+
+    public function getMovements(): array
+    {
+        return $this->movements;
+    }
+
+}

src/Entity/Portfolio.php

@@ -0,0 +1,161 @@
+<?php
+
+namespace App\Entity;
+
+use App\Repository\PortfolioRepository;
+use Doctrine\Common\Collections\ArrayCollection;
+use Doctrine\Common\Collections\Collection;
+use Doctrine\DBAL\Types\Types;
+use Doctrine\ORM\Mapping as ORM;
+
+#[ORM\Entity(repositoryClass: PortfolioRepository::class)]
+class Portfolio
+{
+    #[ORM\Id]
+    #[ORM\GeneratedValue(strategy: "IDENTITY")]
+    #[ORM\Column]
+    private ?int $id = null;
+
+    #[ORM\Column(length: 255)]
+    private ?string $clientAgreement = null;
+
+    #[ORM\Column(type: Types::TEXT)]
+    private ?string $xmlData = null;
+
+    #[ORM\Column(type: Types::DATE_IMMUTABLE)]
+    private ?\DateTimeImmutable $startDate = null;
+
+    #[ORM\Column(type: Types::DATE_IMMUTABLE)]
+    private ?\DateTimeImmutable $endDate = null;
+
+    /**
+     * @var Collection<int, PortfolioDetail>
+     */
+    #[ORM\OneToMany(targetEntity: PortfolioDetail::class, mappedBy: 'portfolio')]
+    private Collection $portfolioDetails;
+
+    /**
+     * @var Collection<int, PortfolioMovement>
+     */
+    #[ORM\OneToMany(targetEntity: PortfolioMovement::class, mappedBy: 'portfolio')]
+    private Collection $portfolioMovements;
+
+    public function __construct()
+    {
+        $this->portfolioDetails = new ArrayCollection();
+        $this->portfolioMovements = new ArrayCollection();
+    }
+
+    public function getId(): ?int
+    {
+        return $this->id;
+    }
+
+    public function getClientAgreement(): ?string
+    {
+        return $this->clientAgreement;
+    }
+
+    public function setClientAgreement(string $clientAgreement): static
+    {
+        $this->clientAgreement = $clientAgreement;
+
+        return $this;
+    }
+
+    public function getXmlData(): ?string
+    {
+        return $this->xmlData;
+    }
+
+    public function setXmlData(string $xmlData): static
+    {
+        $this->xmlData = $xmlData;
+
+        return $this;
+    }
+
+    public function getStartDate(): ?\DateTimeImmutable
+    {
+        return $this->startDate;
+    }
+
+    public function setStartDate(\DateTimeImmutable $startDate): static
+    {
+        $this->startDate = $startDate;
+
+        return $this;
+    }
+
+    public function getEndDate(): ?\DateTimeImmutable
+    {
+        return $this->endDate;
+    }
+
+    public function setEndDate(\DateTimeImmutable $endDate): static
+    {
+        $this->endDate = $endDate;
+
+        return $this;
+    }
+
+    /**
+     * @return Collection<int, PortfolioDetail>
+     */
+    public function getPortfolioDetails(): Collection
+    {
+        return $this->portfolioDetails;
+    }
+
+    public function addPortfolioDetail(PortfolioDetail $portfolioDetail): static
+    {
+        if (!$this->portfolioDetails->contains($portfolioDetail)) {
+            $this->portfolioDetails->add($portfolioDetail);
+            $portfolioDetail->setPortfolio($this);
+        }
+
+        return $this;
+    }
+
+    public function removePortfolioDetail(PortfolioDetail $portfolioDetail): static
+    {
+        if ($this->portfolioDetails->removeElement($portfolioDetail)) {
+            // set the owning side to null (unless already changed)
+            if ($portfolioDetail->getPortfolio() === $this) {
+                $portfolioDetail->setPortfolio(null);
+            }
+        }
+
+        return $this;
+    }
+
+    /**
+     * @return Collection<int, PortfolioMovement>
+     */
+    public function getPortfolioMovements(): Collection
+    {
+        return $this->portfolioMovements;
+    }
+
+    public function addPortfolioMovement(PortfolioMovement $portfolioMovement): static
+    {
+        if (!$this->portfolioMovements->contains($portfolioMovement)) {
+            $this->portfolioMovements->add($portfolioMovement);
+            $portfolioMovement->setPortfolio($this);
+        }
+
+        return $this;
+    }
+
+    public function removePortfolioMovement(PortfolioMovement $portfolioMovement): static
+    {
+        if ($this->portfolioMovements->removeElement($portfolioMovement)) {
+            // set the owning side to null (unless already changed)
+            if ($portfolioMovement->getPortfolio() === $this) {
+                $portfolioMovement->setPortfolio(null);
+            }
+        }
+
+        return $this;
+    }
+}

src/Entity/PortfolioDetail.php

@@ -0,0 +1,157 @@
+<?php
+
+namespace App\Entity;
+
+use App\Repository\PortfolioDetailRepository;
+use Doctrine\DBAL\Types\Types;
+use Doctrine\ORM\Mapping as ORM;
+
+#[ORM\Entity(repositoryClass: PortfolioDetailRepository::class)]
+class PortfolioDetail
+{
+    #[ORM\Id]
+    #[ORM\GeneratedValue(strategy: "IDENTITY")]
+    #[ORM\Column]
+    private ?int $id = null;
+
+    #[ORM\Column(length: 32)]
+    private ?string $security = null;
+
+    #[ORM\Column]
+    private ?int $quantityStart = null;
+
+    #[ORM\Column]
+    private ?int $quantityEnd = null;
+
+    #[ORM\Column(type: Types::DECIMAL, precision: 10, scale: 3)]
+    private ?string $priceStart = null;
+
+    #[ORM\Column(type: Types::DECIMAL, precision: 10, scale: 3)]
+    private ?string $priceEnd = null;
+
+    #[ORM\Column(type: Types::DECIMAL, precision: 10, scale: 3)]
+    private ?string $sumStart = null;
+
+    #[ORM\Column(type: Types::DECIMAL, precision: 10, scale: 3)]
+    private ?string $sumEnd = null;
+
+    #[ORM\Column(length: 255)]
+    private ?string $issuer = null;
+
+    #[ORM\ManyToOne(inversedBy: 'portfolioDetails')]
+    #[ORM\JoinColumn(nullable: false)]
+    private ?Portfolio $portfolio = null;
+
+    public function getId(): ?int
+    {
+        return $this->id;
+    }
+
+    public function getSecurity(): ?string
+    {
+        return $this->security;
+    }
+
+    public function setSecurity(string $security): static
+    {
+        $this->security = $security;
+
+        return $this;
+    }
+
+    public function getQuantityStart(): ?int
+    {
+        return $this->quantityStart;
+    }
+
+    public function setQuantityStart(int $quantityStart): static
+    {
+        $this->quantityStart = $quantityStart;
+
+        return $this;
+    }
+
+    public function getQuantityEnd(): ?int
+    {
+        return $this->quantityEnd;
+    }
+
+    public function setQuantityEnd(int $quantityEnd): static
+    {
+        $this->quantityEnd = $quantityEnd;
+
+        return $this;
+    }
+
+    public function getPriceStart(): ?string
+    {
+        return $this->priceStart;
+    }
+
+    public function setPriceStart(string $priceStart): static
+    {
+        $this->priceStart = $priceStart;
+
+        return $this;
+    }
+
+    public function getPriceEnd(): ?string
+    {
+        return $this->priceEnd;
+    }
+
+    public function setPriceEnd(string $priceEnd): static
+    {
+        $this->priceEnd = $priceEnd;
+
+        return $this;
+    }
+
+    public function getSumStart(): ?string
+    {
+        return $this->sumStart;
+    }
+
+    public function setSumStart(string $sumStart): static
+    {
+        $this->sumStart = $sumStart;
+
+        return $this;
+    }
+
+    public function getSumEnd(): ?string
+    {
+        return $this->sumEnd;
+    }
+
+    public function setSumEnd(string $sumEnd): static
+    {
+        $this->sumEnd = $sumEnd;
+
+        return $this;
+    }
+
+    public function getIssuer(): ?string
+    {
+        return $this->issuer;
+    }
+
+    public function setIssuer(string $issuer): static
+    {
+        $this->issuer = $issuer;
+
+        return $this;
+    }
+
+    public function getPortfolio(): ?Portfolio
+    {
+        return $this->portfolio;
+    }
+
+    public function setPortfolio(?Portfolio $portfolio): static
+    {
+        $this->portfolio = $portfolio;
+
+        return $this;
+    }
+}

src/Entity/PortfolioMovement.php

@@ -0,0 +1,126 @@
+<?php
+
+namespace App\Entity;
+
+use App\Repository\PortfolioMovementRepository;
+use Doctrine\ORM\Mapping as ORM;
+
+#[ORM\Entity(repositoryClass: PortfolioMovementRepository::class)]
+class PortfolioMovement
+{
+    #[ORM\Id]
+    #[ORM\GeneratedValue(strategy: "IDENTITY")]
+    #[ORM\Column]
+    private ?int $id = null;
+
+    #[ORM\Column(length: 255)]
+    private ?string $security = null;
+
+    #[ORM\Column]
+    private ?\DateTimeImmutable $period = null;
+
+    #[ORM\Column]
+    private ?int $quantityStart = null;
+
+    #[ORM\Column]
+    private ?int $quantityEnd = null;
+
+    #[ORM\Column]
+    private ?int $quantityIncome = null;
+
+    #[ORM\Column]
+    private ?int $quantityOutcome = null;
+
+    #[ORM\ManyToOne(inversedBy: 'portfolioMovements')]
+    #[ORM\JoinColumn(nullable: false)]
+    private ?Portfolio $portfolio = null;
+
+    public function getId(): ?int
+    {
+        return $this->id;
+    }
+
+    public function getSecurity(): ?string
+    {
+        return $this->security;
+    }
+
+    public function setSecurity(string $security): static
+    {
+        $this->security = $security;
+
+        return $this;
+    }
+
+    public function getPeriod(): ?\DateTimeImmutable
+    {
+        return $this->period;
+    }
+
+    public function setPeriod(\DateTimeImmutable $period): static
+    {
+        $this->period = $period;
+
+        return $this;
+    }
+
+    public function getQuantityStart(): ?int
+    {
+        return $this->quantityStart;
+    }
+
+    public function setQuantityStart(int $quantityStart): static
+    {
+        $this->quantityStart = $quantityStart;
+
+        return $this;
+    }
+
+    public function getQuantityEnd(): ?int
+    {
+        return $this->quantityEnd;
+    }
+
+    public function setQuantityEnd(int $quantityEnd): static
+    {
+        $this->quantityEnd = $quantityEnd;
+
+        return $this;
+    }
+
+    public function getQuantityIncome(): ?int
+    {
+        return $this->quantityIncome;
+    }
+
+    public function setQuantityIncome(int $quantityIncome): static
+    {
+        $this->quantityIncome = $quantityIncome;
+
+        return $this;
+    }
+
+    public function getQuantityOutcome(): ?int
+    {
+        return $this->quantityOutcome;
+    }
+
+    public function setQuantityOutcome(int $quantityOutcome): static
+    {
+        $this->quantityOutcome = $quantityOutcome;
+
+        return $this;
+    }
+
+    public function getPortfolio(): ?Portfolio
+    {
+        return $this->portfolio;
+    }
+
+    public function setPortfolio(?Portfolio $portfolio): static
+    {
+        $this->portfolio = $portfolio;
+
+        return $this;
+    }
+}

src/Presentation/PortfolioPresenter.php

@@ -0,0 +1,69 @@
+<?php
+
+namespace App\Presentation;
+
+use App\Domain\Entity\ParsedPortfolio;
+use Symfony\Component\Console\Helper\Table;
+use Symfony\Component\Console\Output\BufferedOutput;
+use Symfony\Component\Console\Helper\TableStyle;
+
+class PortfolioPresenter
+{
+    public static function toPrint(ParsedPortfolio $parsedPortfolio): string
+    {
+        $output = new BufferedOutput();
+
+        $tableStyle = new TableStyle();
+        $tableStyle->setPadType(STR_PAD_BOTH);
+
+        $table = new Table($output);
+
+        $table->setHeaderTitle("СОСТАВ: {$parsedPortfolio->getHeader()['НачПериода']} - {$parsedPortfolio->getHeader()['КонПериода']}");
+
+        $table->setHeaders([
+            'ЦБ', 'НКол.', 'НЦена', 'ККол.', 'КЦена'
+        ]);
+
+        foreach ($parsedPortfolio->getDetails() as $detail) {
+            $table->addRow([
+                $detail['ЦБ'],// . ' ' . $detail['Эмитент'],
+                $detail['КоличествоНО'],
+                $detail['НОЦена'],
+                //$detail['СуммаНКДНО'],
+                $detail['КоличествоКО'],
+                $detail['КОЦена'],
+                //$detail['СуммаНКДКО'],
+            ]);
+        }
+
+        $table->setStyle($tableStyle)->render();
+
+        $txt = $output->fetch();
+
+        $table = new Table($output);
+
+
+        $table->setHeaderTitle("ДВИЖ: {$parsedPortfolio->getHeader()['НачПериода']} - {$parsedPortfolio->getHeader()['КонПериода']}");
+
+        $table->setHeaders([
+            'ЦБ', 'НКол.', 'Приход', 'Расход', 'ККол.'
+        ]);
+
+        foreach ($parsedPortfolio->getMovements() as $movement) {
+            $table->addRow([
+                $movement['ЦБ'],
+                //$movement['Период'],
+                $movement['НО'],
+                $movement['Приход']>0 ? '+'.$movement['Приход'] : $movement['Приход'],
+                $movement['Расход']>0 ? '-'.$movement['Расход'] : $movement['Расход'],
+                $movement['КО'],
+            ]);
+        }
+
+        $table->setStyle($tableStyle)->render();
+        $txt .= PHP_EOL . $output->fetch();
+
+        return $txt;
+    }
+
+}

src/Repository/PortfolioDetailRepository.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Repository;
+
+use App\Entity\PortfolioDetail;
+use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
+use Doctrine\Persistence\ManagerRegistry;
+
+/**
+ * @extends ServiceEntityRepository<PortfolioDetail>
+ */
+class PortfolioDetailRepository extends ServiceEntityRepository
+{
+    public function __construct(ManagerRegistry $registry)
+    {
+        parent::__construct($registry, PortfolioDetail::class);
+    }
+
+    //    /**
+    //     * @return PortfolioDetail[] Returns an array of PortfolioDetail objects
+    //     */
+    //    public function findByExampleField($value): array
+    //    {
+    //        return $this->createQueryBuilder('p')
+    //            ->andWhere('p.exampleField = :val')
+    //            ->setParameter('val', $value)
+    //            ->orderBy('p.id', 'ASC')
+    //            ->setMaxResults(10)
+    //            ->getQuery()
+    //            ->getResult()
+    //        ;
+    //    }
+
+    //    public function findOneBySomeField($value): ?PortfolioDetail
+    //    {
+    //        return $this->createQueryBuilder('p')
+    //            ->andWhere('p.exampleField = :val')
+    //            ->setParameter('val', $value)
+    //            ->getQuery()
+    //            ->getOneOrNullResult()
+    //        ;
+    //    }
+}

src/Repository/PortfolioMovementRepository.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Repository;
+
+use App\Entity\PortfolioMovement;
+use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
+use Doctrine\Persistence\ManagerRegistry;
+
+/**
+ * @extends ServiceEntityRepository<PortfolioMovement>
+ */
+class PortfolioMovementRepository extends ServiceEntityRepository
+{
+    public function __construct(ManagerRegistry $registry)
+    {
+        parent::__construct($registry, PortfolioMovement::class);
+    }
+
+    //    /**
+    //     * @return PortfolioMovement[] Returns an array of PortfolioMovement objects
+    //     */
+    //    public function findByExampleField($value): array
+    //    {
+    //        return $this->createQueryBuilder('p')
+    //            ->andWhere('p.exampleField = :val')
+    //            ->setParameter('val', $value)
+    //            ->orderBy('p.id', 'ASC')
+    //            ->setMaxResults(10)
+    //            ->getQuery()
+    //            ->getResult()
+    //        ;
+    //    }
+
+    //    public function findOneBySomeField($value): ?PortfolioMovement
+    //    {
+    //        return $this->createQueryBuilder('p')
+    //            ->andWhere('p.exampleField = :val')
+    //            ->setParameter('val', $value)
+    //            ->getQuery()
+    //            ->getOneOrNullResult()
+    //        ;
+    //    }
+}

src/Repository/PortfolioRepository.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Repository;
+
+use App\Entity\Portfolio;
+use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
+use Doctrine\Persistence\ManagerRegistry;
+
+/**
+ * @extends ServiceEntityRepository<Portfolio>
+ */
+class PortfolioRepository extends ServiceEntityRepository
+{
+    public function __construct(ManagerRegistry $registry)
+    {
+        parent::__construct($registry, Portfolio::class);
+    }
+
+//    /**
+//     * @return ReportHeader[] Returns an array of ReportHeader objects
+//     */
+//    public function findByExampleField($value): array
+//    {
+//        return $this->createQueryBuilder('r')
+//            ->andWhere('r.exampleField = :val')
+//            ->setParameter('val', $value)
+//            ->orderBy('r.id', 'ASC')
+//            ->setMaxResults(10)
+//            ->getQuery()
+//            ->getResult()
+//        ;
+//    }
+
+//    public function findOneBySomeField($value): ?ReportHeader
+//    {
+//        return $this->createQueryBuilder('r')
+//            ->andWhere('r.exampleField = :val')
+//            ->setParameter('val', $value)
+//            ->getQuery()
+//            ->getOneOrNullResult()
+//        ;
+//    }
+}

src/Service/MailFetcher.php

@@ -0,0 +1,167 @@
+<?php
+
+namespace App\Service;
+
+use PhpImap\IncomingMail;
+use PhpImap\IncomingMailAttachment;
+use Psr\Log\LoggerInterface;
+use SecIT\ImapBundle\Connection\ConnectionInterface;
+use Symfony\Component\DependencyInjection\Attribute\Target;
+use Symfony\Component\Filesystem\Filesystem;
+use Symfony\Component\Filesystem\Path;
+use App\Presentation\PortfolioPresenter as PresentationPortfolio;
+use Symfony\Component\Notifier\Bridge\Telegram\TelegramOptions;
+use Symfony\Component\Notifier\Bridge\Telegram\TelegramTransport;
+use Symfony\Component\Notifier\Chatter;
+use Symfony\Component\Notifier\Message\ChatMessage;
+use Symfony\Component\Notifier\Notifier;
+use Symfony\Component\Notifier\NotifierInterface;
+use App\Service\TelegramNotifier;
+
+readonly class MailFetcher
+{
+    public function __construct(
+        #[Target('finfollowConnection')]
+        private ConnectionInterface   $connection,
+        private XmlParser             $xmlParser,
+        private PortfolioManager      $portfolioManager,
+        private LoggerInterface       $logger,
+        private TelegramNotifier      $telegramNotifier,
+    )
+    {
+    }
+
+    public function fetchNewEmails(): void
+    {
+        $mailbox = $this->connection->getMailbox();
+        try {
+            // Get all emails (messages)
+            // PHP.net imap_search criteria: http://php.net/manual/en/function.imap-search.php
+            $mailsIds = $mailbox->searchMailbox('ALL');
+        } catch (PhpImap\Exceptions\ConnectionException $ex) {
+            $this->logger->error("IMAP connection failed: " . implode(",", $ex->getErrors('all')));
+            die();
+        }
+
+        if (!$mailsIds) {
+            $this->logger->info('Mailbox is empty');
+
+            $this->logger->warn("Here we should send info about no changes performed..");
+
+            return;
+        }
+
+// If '__DIR__' was defined in the first line, it will automatically
+// save all attachments to the specified directory
+
+        foreach ($mailsIds as $mailId) {
+            $mail = $mailbox->getMail($mailId);
+
+            $this->logger->debug(print_r([
+                'date' => $mail->date,
+                'message_id' => $mail->messageId,
+                'from' => $mail->fromAddress,
+                'subject' => $mail->subject,
+                'hasAttachments' => $mail->hasAttachments(),
+            ], true));
+
+            if ($this->canProcessMail($mail)) {
+                if ($this->processMail($mail)) {
+
+                    //break;
+
+                }
+
+                //$mailbox->deleteMail($mailId);
+                $this->logger->debug("Deleted email with id=" . $mailId);
+            } else {
+                $this->logger->debug("Skipped mail with id=" . $mailId);
+            }
+        }
+
+        $mailbox->disconnect();
+    }
+
+    private function canProcessMail(IncomingMail $mail): bool
+    {
+        if (!$mail->hasAttachments()) {
+            return false;
+        }
+
+        if (mb_stripos($mail->subject, 'Broker report') === false) {
+            return false;
+        }
+
+        if (mb_stripos($mail->fromAddress, '@bcs.ru') === false) {
+            return false;
+        }
+
+        return true;
+    }
+
+    private function processMail(IncomingMail $mail): bool
+    {
+        $mailProcessed = false;
+
+        foreach ($mail->getAttachments() as $attachment) {
+            if ($attachment->mimeType != 'application/zip') {
+                continue;
+            }
+
+            $mailProcessed |= $this->processZipArchiveAttachment($attachment);
+        }
+
+        return $mailProcessed;
+    }
+
+    private function processZipArchiveAttachment(IncomingMailAttachment $attachment): bool
+    {
+        $zip = new \ZipArchive();
+        if ($zip->open($attachment->filePath) !== true) {
+            $this->logger->error('ZIP open error: ' . $zip);
+            return false;
+        }
+
+        $xmlFound = false;
+        for ($i = 0; $i < $zip->numFiles; $i++) {
+            $stat = $zip->statIndex($i);
+
+            if (pathinfo($stat['name'])['extension'] !== 'xml') {
+                continue;
+            }
+
+            $tmpdir = $this->getTmpDir();
+
+            $zip->extractTo($tmpdir, [$stat['name']]);
+            $this->logger->debug("Extracted '$stat[name]' into '$tmpdir'");
+
+            $xmlString = file_get_contents($tmpdir . '/' . $stat['name']);
+            $xml = simplexml_load_string($xmlString);
+
+            $parsedPortfolio = $this->xmlParser->processXml($xml);
+            $message = PresentationPortfolio::toPrint($parsedPortfolio);
+
+             if ($this->portfolioManager->updatePortfolio($parsedPortfolio, $xmlString)) {
+                 $this->telegramNotifier->notify($message);
+            }
+
+            $fs = new Filesystem();
+            $fs->remove($tmpdir);
+
+            $xmlFound = true;
+        }
+
+        return $xmlFound;
+    }
+
+    private function getTmpDir(): string
+    {
+        $tmpdir = Path::normalize(sys_get_temp_dir() . '/FINFOLLOW-' . random_int(0, 100));
+
+        $filesystem = new Filesystem();
+        $filesystem->mkdir($tmpdir);
+
+        return $tmpdir;
+    }
+
+}

src/Service/PortfolioManager.php

@@ -0,0 +1,89 @@
+<?php
+
+namespace App\Service;
+
+use App\Domain\Entity\ParsedPortfolio;
+use App\Entity\Portfolio;
+use App\Entity\PortfolioDetail;
+use App\Entity\PortfolioMovement;
+use Doctrine\ORM\EntityManagerInterface;
+use Psr\Log\LoggerInterface;
+
+readonly class PortfolioManager
+{
+    public function __construct(private EntityManagerInterface $entityManager, private LoggerInterface $logger)
+    {
+    }
+
+    public function updatePortfolio(ParsedPortfolio $parsedPortfolio, string $xmlString): bool
+    {
+        $startDate = \DateTime::createFromFormat('d.m.Y', $parsedPortfolio->getHeader()['НачПериода']);
+        $endDate = \DateTime::createFromFormat('d.m.Y', $parsedPortfolio->getHeader()['КонПериода']);
+
+        $portfolio = $this->entityManager->getRepository(Portfolio::class)->findOneBy([
+            'clientAgreement' => $parsedPortfolio->getHeader()['Клиент'],
+            'startDate' => new \DateTimeImmutable($startDate->format('Y-m-d')),
+            'endDate' => new \DateTimeImmutable($endDate->format('Y-m-d')),
+        ]);
+
+        if ($portfolio) {
+            $this->logger->debug("Found existing portfolio with id: " . $portfolio->getId() . ', skipped..');
+            return false;
+        } else {
+            $newPortfolio = $this->savePortfolio($parsedPortfolio, $xmlString);
+            $this->logger->debug("Saved new portfolio with id: " . $newPortfolio->getId());
+            return true;
+        }
+    }
+
+    private function savePortfolio(ParsedPortfolio $parsedPortfolio, string $xmlString): Portfolio
+    {
+        $this->logger->debug(print_r($parsedPortfolio, true));
+
+        $startDate = \DateTime::createFromFormat('d.m.Y', $parsedPortfolio->getHeader()['НачПериода']);
+        $endDate = \DateTime::createFromFormat('d.m.Y', $parsedPortfolio->getHeader()['КонПериода']);
+
+        $portfolio = new Portfolio();
+
+        $portfolio->setClientAgreement($parsedPortfolio->getHeader()['Клиент']);
+        $portfolio->setStartDate(new \DateTimeImmutable($startDate->format('Y-m-d')));
+        $portfolio->setEndDate(new \DateTimeImmutable($endDate->format('Y-m-d')));
+        $portfolio->setXmlData($xmlString);
+
+        $this->entityManager->persist($portfolio);
+
+        foreach ($parsedPortfolio->getDetails() as $parsedDetail) {
+            $detail = new PortfolioDetail();
+
+            $detail->setPortfolio($portfolio);
+            $detail->setIssuer($parsedDetail['Эмитент']);
+            $detail->setSecurity($parsedDetail['ЦБ']);
+            $detail->setPriceStart($parsedDetail['НОЦена']);
+            $detail->setPriceEnd($parsedDetail['КОЦена']);
+            $detail->setQuantityStart($parsedDetail['КоличествоНО']);
+            $detail->setQuantityEnd($parsedDetail['КоличествоКО']);
+            $detail->setSumStart($parsedDetail['СуммаНКДНО']);
+            $detail->setSumEnd($parsedDetail['СуммаНКДКО']);
+
+            $this->entityManager->persist($detail);
+        }
+
+        foreach ($parsedPortfolio->getMovements() as $parsedMovement) {
+            $movement = new PortfolioMovement();
+
+            $movement->setPortfolio($portfolio);
+            $movement->setSecurity($parsedMovement['ЦБ']);
+            $movement->setPeriod(new \DateTimeImmutable($parsedMovement['Период']));
+            $movement->setQuantityStart($parsedMovement['НО']);
+            $movement->setQuantityEnd($parsedMovement['КО']);
+            $movement->setQuantityIncome($parsedMovement['Приход']);
+            $movement->setQuantityOutcome($parsedMovement['Расход']);
+
+            $this->entityManager->persist($movement);
+        }
+
+        $this->entityManager->flush();
+
+        return $portfolio;
+    }
+}

src/Service/TelegramNotifier.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace App\Service;
+
+use Symfony\Component\Notifier\Bridge\Telegram\TelegramTransport;
+use Symfony\Component\Notifier\Chatter;
+use Symfony\Component\Notifier\Bridge\Telegram\TelegramOptions;
+use Symfony\Component\Notifier\Message\ChatMessage;
+
+readonly class TelegramNotifier
+{
+    private string $telegramBotToken;
+    private string $telegramChatId;
+
+    public function __construct(string $telegramBotToken, string $telegramChatId)
+    {
+        $this->telegramBotToken = $telegramBotToken;
+        $this->telegramChatId = $telegramChatId;
+    }
+
+    public function notify(string $message): void
+    {
+        $telegramTransport = new TelegramTransport($this->telegramBotToken, $this->telegramChatId);
+        $chatter = new Chatter($telegramTransport);
+        $chatMessage = new ChatMessage('<pre>' . $message . '</pre>');
+
+        $telegramOptions = new TelegramOptions();
+        $telegramOptions->parseMode(TelegramOptions::PARSE_MODE_HTML);
+        $chatMessage->options($telegramOptions);
+
+        $chatter->send($chatMessage);
+    }
+}

src/Service/XmlParser.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace App\Service;
+
+use App\Domain\Entity\ParsedPortfolio;
+
+class XmlParser
+{
+    public function processXml(\SimpleXMLElement $xml): ParsedPortfolio
+    {
+        $portfolio = [
+            'header' => $this->processXmlHeader($xml),
+            'details' => $this->processXmlElement($xml->{'ЗаголовокПортфель'}->{'ШапкаПортфель'}),
+            'movements' => $this->processXmlElement($xml->{'ШапкаДвиженияИОстаткиЦБ'}),
+        ];
+
+        return new ParsedPortfolio(...$portfolio);
+    }
+
+
+    private function processXmlHeader(\SimpleXMLElement $xml): array
+    {
+        $header = [];
+        foreach (['ШапкаГенСог', 'ШапкаПериод'] as $h) {
+            foreach ($xml->{$h}->attributes() as $key => $value) {
+                $header[$key] = get_object_vars($value)[0];
+            }
+        }
+
+        return $header;
+    }
+
+    private function processXmlElement(\SimpleXMLElement $xml): array
+    {
+        $securities = [];
+
+        foreach (get_object_vars($xml) as $key => $value) {
+
+            if (mb_strpos($key, 'Детали') !== false) {
+
+                if (!is_array($value)) {
+                    $value = [$value];
+                }
+
+                foreach ($value as $line) {
+                    $attr = [];
+
+                    foreach ($line->attributes() as $k1 => $v1) {
+                        $attr[$k1] = get_object_vars($v1)[0];
+                    }
+
+                    $securities[$attr['ЦБ']] = $attr;
+                }
+            }
+        }
+
+        return $securities;
+    }
+}

symfony.lock

@@ -1,4 +1,43 @@
 {
+    "doctrine/doctrine-bundle": {
+        "version": "2.12",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "2.12",
+            "ref": "7266981c201efbbe02ae53c87f8bb378e3f825ae"
+        },
+        "files": [
+            "config/packages/doctrine.yaml",
+            "src/Entity/.gitignore",
+            "src/Repository/.gitignore"
+        ]
+    },
+    "doctrine/doctrine-migrations-bundle": {
+        "version": "3.3",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "3.1",
+            "ref": "1d01ec03c6ecbd67c3375c5478c9a423ae5d6a33"
+        },
+        "files": [
+            "config/packages/doctrine_migrations.yaml",
+            "migrations/.gitignore"
+        ]
+    },
+    "secit-pl/imap-bundle": {
+        "version": "3.2",
+        "recipe": {
+            "repo": "github.com/symfony/recipes-contrib",
+            "branch": "main",
+            "version": "1.0",
+            "ref": "2303e00839856f36b1829d0b189e5d959153aefb"
+        },
+        "files": [
+            "config/packages/imap.yaml"
+        ]
+    },
     "symfony/console": {
         "version": "7.1",
         "recipe": {
@@ -42,6 +81,39 @@
             "src/Kernel.php"
         ]
     },
+    "symfony/maker-bundle": {
+        "version": "1.59",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "1.0",
+            "ref": "fadbfe33303a76e25cb63401050439aa9b1a9c7f"
+        }
+    },
+    "symfony/monolog-bundle": {
+        "version": "3.10",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "3.7",
+            "ref": "aff23899c4440dd995907613c1dd709b6f59503f"
+        },
+        "files": [
+            "config/packages/monolog.yaml"
+        ]
+    },
+    "symfony/notifier": {
+        "version": "7.1",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "5.0",
+            "ref": "178877daf79d2dbd62129dd03612cb1a2cb407cc"
+        },
+        "files": [
+            "config/packages/notifier.yaml"
+        ]
+    },
     "symfony/routing": {
         "version": "7.1",
         "recipe": {
@@ -54,5 +126,14 @@
             "config/packages/routing.yaml",
             "config/routes.yaml"
         ]
+    },
+    "symfony/telegram-notifier": {
+        "version": "7.1",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "5.0",
+            "ref": "6cecb59a0e96c9e1cee469f2b82fa920101a68e8"
+        }
     }
 }