fix

app/code/Joshine/Script/Console/Command/ProductFirstImageAsBaseFixer.php

@@ -37,12 +37,15 @@ class ProductFirstImageAsBaseFixer extends Command
 
 
     protected function execute(InputInterface $input, OutputInterface $output)
     protected function execute(InputInterface $input, OutputInterface $output)
     {
     {
-        //$this->fixBaseImage($input, $output, $pid);
-        $criteria = $this->searchCriteriaBuilder->create();
-        $products = $this->productRepository->getList($criteria);
+        $objectManager = \Magento\Framework\App\ObjectManager::getInstance();
 
 
-        foreach ($products as $product) {
-            $output->writeln('pid' . $product->getId());
+        $collection  = $objectManager->create('Magento\Catalog\Model\ResourceModel\Product\Collection');
+
+        foreach ($collection as $item) {
+            $pid = $item->getId();
+            if ($pid == '8822') {
+                $this->fixBaseImage($input, $output, $pid);
+            }
         }
         }
     }
     }
 
 

app/code/Joshine/Script/Model/ImageQueryResource.php

@@ -83,24 +83,9 @@ class ImageQueryResource
         $select->reset(\Magento\Framework\DB\Select::COLUMNS);
         $select->reset(\Magento\Framework\DB\Select::COLUMNS);
         $select->columns(['g.value', 'v.position']);
         $select->columns(['g.value', 'v.position']);
         $select->order('v.position');
         $select->order('v.position');
-        //$select->limit(1);
+        $select->limit(1);
 
 
-        $result = $this->resourceConnection->getConnection()->fetchAll($select);
-
-        $minPosition = 2000;
-        $position = [];
-        $minImage = '';
-        foreach ($result as $row) {
-            if ($row['position'] < $minPosition) {
-                $minPosition = $row['position'];
-                $minImage = $row['value'];
-                $position[$row['position']] = 1;
-            }
-        }
-
-        if (count($position) > 1) {
-            return $minImage;
-        }
+        return $this->resourceConnection->getConnection()->fetchOne($select);
     }
     }
 
 
     public function updatePosition(int $valueId, int $position)
     public function updatePosition(int $valueId, int $position)