Added skipping data updates if they have already been updated by anot…

…her service.
simba77 · Jul 17, 2024 · e32a375 · e32a375
1 parent f302dff
commit e32a375
Show file tree

Hide file tree

Showing 4 changed files with 33 additions and 3 deletions.
diff --git a/src/Command/GetBondsCommand.php b/src/Command/GetBondsCommand.php
@@ -7,6 +7,7 @@
 use App\Entity\Bond;
 use App\Services\AccountCalculator;
 use App\Services\MarketData\Securities\MoexBondsProvider;
+use Carbon\Carbon;
 use Doctrine\ORM\EntityManagerInterface;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;
@@ -39,6 +40,14 @@ protected function execute(InputInterface $input, OutputInterface $output): int
         foreach ($bonds as $item) {
             $bond = $bondRepository->findOneBy(['ticker' => $item->getTicker()]);
             if ($bond) {
+                $updatePeriodStart = Carbon::now()->subMinutes(5);
+                $updated = $bond->updatedAt();
+
+                // If the share has been updated by another service, skip this update
+                if($updatePeriodStart->diffInMinutes($updated) < 5) {
+                    continue;
+                }
+
                 if (empty($item->getPrice())) {
                     continue;
                 }

diff --git a/src/Command/GetFuturesCommand.php b/src/Command/GetFuturesCommand.php
@@ -7,6 +7,7 @@
 use App\Entity\Future;
 use App\Services\AccountCalculator;
 use App\Services\MarketData\Securities\MoexFuturesProvider;
+use Carbon\Carbon;
 use Doctrine\ORM\EntityManagerInterface;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;
@@ -37,6 +38,16 @@ protected function execute(InputInterface $input, OutputInterface $output): int
         foreach ($futures as $item) {
             $future = $futureRepository->findOneBy(['ticker' => $item->getTicker()]);
             if ($future) {
+
+                $updatePeriodStart = Carbon::now()->subMinutes(5);
+                $updated = $future->updatedAt();
+
+                // If the share has been updated by another service, skip this update
+                if($updatePeriodStart->diffInMinutes($updated) < 5) {
+                    continue;
+                }
+
+
                 if (empty($item->getPrice())) {
                     continue;
                 }

diff --git a/src/Command/GetMoexSharesCommand.php b/src/Command/GetMoexSharesCommand.php
@@ -7,6 +7,7 @@
 use App\Entity\Share;
 use App\Services\AccountCalculator;
 use App\Services\MarketData\Securities\MoexSharesProvider;
+use Carbon\Carbon;
 use Doctrine\ORM\EntityManagerInterface;
 use Symfony\Component\Console\Attribute\AsCommand;
 use Symfony\Component\Console\Command\Command;
@@ -37,6 +38,15 @@ protected function execute(InputInterface $input, OutputInterface $output): int
         foreach ($shares as $item) {
             $share = $shareRepository->findOneBy(['ticker' => $item->getTicker()]);
             if ($share) {
+
+                $updatePeriodStart = Carbon::now()->subMinutes(5);
+                $updated = $share->updatedAt();
+
+                // If the share has been updated by another service, skip this update
+                if($updatePeriodStart->diffInMinutes($updated) < 5) {
+                    continue;
+                }
+
                 if (empty($item->getPrice())) {
                     continue;
                 }

diff --git a/src/Command/ScheduleCommand.php b/src/Command/ScheduleCommand.php
@@ -28,10 +28,10 @@ protected function execute(InputInterface $input, OutputInterface $output): int
 
             // Tasks
             $scheduler->php($rootDir . '/bin/console accounts:save-stat')->everyMinute(30);
-            $scheduler->php($rootDir . '/bin/console securities:get-moex-bonds')->everyMinute(5);
+            $scheduler->php($rootDir . '/bin/console securities:get-moex-bonds')->everyMinute(15);
             $scheduler->php($rootDir . '/bin/console currency:get-rates')->everyMinute();
-            $scheduler->php($rootDir . '/bin/console securities:get-moex-futures')->everyMinute(5);
-            $scheduler->php($rootDir . '/bin/console securities:get-moex-shares')->everyMinute(5);
+            $scheduler->php($rootDir . '/bin/console securities:get-moex-futures')->everyMinute(15);
+            $scheduler->php($rootDir . '/bin/console securities:get-moex-shares')->everyMinute(15);
             // $scheduler->php($rootDir . '/bin/console securities:get-spb-shares')->everyMinute(5);
             $scheduler->php($rootDir . '/bin/console securities:get-tinvest-shares')->daily(22);
             $scheduler->php($rootDir . '/bin/console securities:get-market-data')->everyMinute(2);