Commit cf7a7d3d authored by Gorodkov Denis's avatar Gorodkov Denis

Commit

parent c5d0be44
......@@ -12,9 +12,7 @@ function mymodule_cron() {
$result_api = $api->getResponse('https://swapi.dev/api');
$queue_api = \Drupal::queue('mymodule_swapi');
$date = new DateTime();
$date = $date->getTimestamp();
\Drupal::state()->set('date_queue_swapi', $date);
$time = \Drupal::state()->get('date_queue_swapi');
foreach($result_api as $item) {
$bundle = $api->getTypeNode($item);
......@@ -35,7 +33,10 @@ function mymodule_cron() {
$node_edited = $val;
}
if (!empty($node)) {
if ($node_edited->field_edited->value !== $value['edited']) {
$changed = $node_edited->get('changed')->getValue();
$changed = $changed[0]['value'];
if ($time - $changed < 0) {
$queue_api->createItem($value);
}
} else {
......@@ -48,6 +49,10 @@ function mymodule_cron() {
\Drupal::logger('Queue mymodule_api')->notice("Content type $bundle не создан!");
}
}
$date = new DateTime();
$date = $date->getTimestamp();
\Drupal::state()->set('date_queue_swapi', $date);
}
/**
......
......@@ -18,10 +18,7 @@ class QueueSwapi extends QueueWorkerBase {
public function processItem($data) {
$node = $this->getNodeByUrl($data['url']);
if ($data['edited'] != $node->field_edited) {
$this->edited($data, $node);
}
$this->edited($data, $node);
}
private function edited($data, $node) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment