Add drush command

app/docroot/modules/custom/mymodule/mymodule.module

@@ -82,5 +82,3 @@ function mymodule_form_alter(&$form, \Drupal\Core\Form\FormStateInterface $form_
     $form["actions"]["reset"]["#access"] = true;
   }
 }
-
-

app/docroot/modules/custom/mymodule/mymodule.services.yml

@@ -2,3 +2,7 @@ services:
   mymodule.custom_services:
     class: Drupal\mymodule\API
     arguments: ['@http_client']
+  mymodule.commands:
+    class: \Drupal\mymodule\Commands\BatchCommands
+    tags:
+      - { name: drush.command }

app/docroot/modules/custom/mymodule/src/API.php

@@ -60,4 +60,43 @@ class API {
     $queue_api->createItem($item);
   }
 
+  public function getNodeByUrl($uri) {
+    $bundle = $this->getTypeNode($uri);
+    $swapi_id = $this->getSwapiId($uri);
+    $nodes = \Drupal::entityTypeManager()
+      ->getStorage('node')
+      ->loadByProperties([
+        'type' => $bundle,
+        'field_swapi_id' => $swapi_id,
+      ]);
+
+    foreach ($nodes as $value) {
+      $node = $value;
+    }
+    return $node;
+  }
+
+  public function edited($data, $node) {
+    foreach ($data as $key => $value) {
+      $field_name = "field_" . $key;
+      $bool = (bool)($key != 'name' and $key != 'title' and $key != 'homeworld' and $key != 'url' and $key != 'created' and $key != 'people_exclude');
+      if ($bool and !is_array($value)) {
+        !empty($value) ? $node->set("field_" . strtolower($key), $value) : '';
+      }
+      if (is_array($value)) {
+        $node->set($field_name, NULL);
+        foreach ($value as $item) {
+          $nodeAdd = $this->getNodeByUrl($item);
+          !empty($nodeAdd) ? $node->$field_name[] = $nodeAdd : '';
+        }
+      }
+      if ($key == 'homeworld' and !empty($value)) {
+        $node->$field_name= $this->getNodeByUrl($value);
+      }
+      if ($key == 'name' or $key == 'title') {
+        $node->setTitle($value);
+      }
+    }
+    $node->save();
+  }
 }

app/docroot/modules/custom/mymodule/src/Commands/BatchCommands.php

+<?php
+
+namespace Drupal\mymodule\Commands;
+
+use Drush\Commands\DrushCommands;
+
+/**
+ * A Drush command file.
+ *
+ * @package Drupal\mymodule\Commands
+ */
+class BatchCommands extends DrushCommands {
+  /**
+   * Drush command that displays the given text.
+   *
+   * @param string $date
+   * @command mymodule:custom
+   * @aliases custom
+   * @usage drush custom $date
+   */
+  public function custom($date = '01.01.1970') {
+    $api = \Drupal::service('mymodule.custom_services');
+    $result_api = $api->getResponse('https://swapi.dev/api');
+    $queue_api = \Drupal::queue('mymodule_swapi_drush');
+    $count_create_node = 0;
+    $count_queue = 0;
+    $queue_api->deleteQueue();
+
+    foreach($result_api as $item) {
+      $bundle = $api->getTypeNode($item);
+      if ($api->checkBundle($bundle)) {
+        $uri = $item;
+        while (!empty($uri)) {
+          $result = $api->getResponse($uri);
+          foreach($result['results'] as $value) {
+            $bundle = $api->getTypeNode($value['url']);
+            $swapi_id = $api->getSwapiId($value['url']);
+            $node = \Drupal::entityTypeManager()
+              ->getStorage('node')
+              ->loadByProperties([
+                'type' => $bundle,
+                'field_swapi_id' => $swapi_id,
+              ]);
+            foreach ($node as $val) {
+              $node_edited = $val;
+            }
+            if (!empty($node)) {
+              $swapi_edited = date_parse($value['edited']);
+              $swapi_edited = $swapi_edited['day'] . "." . $swapi_edited['month'] . "." . $swapi_edited['year'];
+
+              $swapi_edited = strtotime($swapi_edited);
+              $date = strtotime($date);
+
+              if ($date - $swapi_edited < 0) {
+                $queue_api->createItem($value);
+                $count_queue++;
+              }
+            } else {
+              $api->createNode($value);
+              $title = !empty($value['title']) ? $value['title'] : $value['name'];
+              $this->output()->writeln("Страница $title создана");
+              $count_create_node++;
+              $queue_api->createItem($value);
+            }
+          }
+          $uri = $result['next'];
+        }
+      } else {
+        $this->output()->writeln("Content type $bundle не создан");
+      }
+    }
+
+    while ($item = $queue_api->claimItem()) {
+      if (!empty($item->data['url'])) {
+        $node = $api->getNodeByUrl($item->data['url']);
+        $api->edited($item->data, $node);
+
+        $title = !empty($item->data['title']) ? $item->data['title'] : $item->data['name'];
+        $message = "Страница $title обновлена";
+        $this->output()->writeln($message);
+        $queue_api->deleteItem($item);
+      }
+    }
+
+    $this->output()->writeln("Страниц обновлено " . $count_queue . ", страниц создано " . $count_create_node);
+  }
+}

app/docroot/modules/custom/mymodule/src/Plugin/QueueWorker/QueueSwapi.php

@@ -16,49 +16,8 @@ use Drupal\Core\Queue\QueueWorkerBase;
 class QueueSwapi extends QueueWorkerBase {
 
   public function processItem($data) {
-    $node = $this->getNodeByUrl($data['url']);
-
-    $this->edited($data, $node);
-  }
-
-  private function edited($data, $node) {
-    foreach ($data as $key => $value) {
-      $field_name = "field_" . $key;
-      $bool = (bool)($key != 'name' and $key != 'title' and $key != 'homeworld' and $key != 'url' and $key != 'created' and $key != 'people_exclude');
-      if ($bool and !is_array($value)) {
-        !empty($value) ? $node->set("field_" . strtolower($key), $value) : '';
-      }
-      if (is_array($value)) {
-        $node->set($field_name, NULL);
-        foreach ($value as $item) {
-          $nodeAdd = $this->getNodeByUrl($item);
-          !empty($nodeAdd) ? $node->$field_name[] = $nodeAdd : '';
-        }
-      }
-      if ($key == 'homeworld' and !empty($value)) {
-        $node->$field_name= $this->getNodeByUrl($value);
-      }
-      if ($key == 'name' or $key == 'title') {
-        $node->setTitle($value);
-      }
-    }
-    $node->save();
-  }
-
-  private function getNodeByUrl($uri) {
     $api = \Drupal::service('mymodule.custom_services');
-    $bundle = $api->getTypeNode($uri);
-    $swapi_id = $api->getSwapiId($uri);
-    $nodes = \Drupal::entityTypeManager()
-      ->getStorage('node')
-      ->loadByProperties([
-        'type' => $bundle,
-        'field_swapi_id' => $swapi_id,
-      ]);
-
-    foreach ($nodes as $value) {
-      $node = $value;
-    }
-    return $node;
+    $node = $api->getNodeByUrl($data['url']);
+    $api->edited($data, $node);
   }
 }