commerce_amazon_sp_api.module

<?php

/**
 * @file
 * Provides a UI for managing amazon entities.
 */

use Drupal\commerce_amazon_sp_api\Exception\AmazonApiException;
use Drupal\Core\Entity\EntityInterface;
use Drupal\Core\Url;

/**
 * Implements hook_theme().
 */
function commerce_amazon_sp_api_theme() {
  return [
    'commerce_amazon_marketplace_form' => [
      'render element' => 'form',
    ],
  ];
}

/**
 * Implements hook_cron().
 */
function commerce_amazon_sp_api_cron() {
  /** @var \Drupal\commerce_amazon_sp_api\Entity\AmazonMarketplaceInterface[] $marketplaces */
  $marketplaces = Drupal::entityTypeManager()->getStorage('commerce_amazon_marketplace')->loadByProperties(['status' => TRUE]);
  $key_value = \Drupal::keyValue('commerce_amazon_sp_api');
  foreach ($marketplaces as $marketplace) {
    $sync_next_run = $key_value->get($marketplace->id());
    if (time() > $sync_next_run) {
      $sync_period = $marketplace->getInventorySyncPeriod();
      $sync_run = time() + $sync_period;

      try {
        \Drupal::service('commerce_amazon_sp_api.inventory')->sync($marketplace);
      }
      catch (AmazonApiException $exception) {
        Drupal::logger('commerce_amazon_sp_api')->error($exception->getMessage());
        return;
      }

      try {
        \Drupal::service('commerce_amazon_sp_api.fulfillment_order')->syncFulfillments($marketplace);
      }
      catch (AmazonApiException $exception) {
        Drupal::logger('commerce_amazon_sp_api')->error($exception->getMessage());
        return;
      }

      $key_value->set($marketplace->id(), $sync_run);
    }
  }

}

/**
 * Implements hook_views_data().
 */
function commerce_amazon_sp_api_views_data() {
  $data['commerce_amazon_inventory']['table']['group'] = t('Amazon inventory');

  $data['commerce_amazon_inventory']['table']['join'] = [
    'commerce_amazon_item' => [
      'left_field' => 'sku',
      'field' => 'sku',
      'left_table' => 'commerce_amazon_item',
      'table' => 'commerce_amazon_inventory',
      'extra' => 'commerce_amazon_inventory.marketplace = commerce_amazon_item.marketplace',
      'type' => 'LEFT',
    ],
  ];

  $data['commerce_amazon_inventory']['fulfillableQuantity'] = [
    'title' => t('Fulfillable Quantity'),
    'help' => t('The total number of items which are fulfillable.'),
    'field' => [
      'id' => 'numeric',
      'click sortable' => TRUE,
    ],
    'filter' => [
      'id' => 'numeric',
    ],
    'argument' => [
      'id' => 'numeric',
    ],
    'sort' => [
      'id' => 'standard',
    ],
  ];

  $data['commerce_amazon_inventory']['timestamp'] = [
    'title' => t('Last update'),
    'help' => t('The most recent time the inventory has been updated.'),
    'field' => [
      'id' => 'timestamp',
      'click sortable' => TRUE,
    ],
    'filter' => [
      'id' => 'date',
    ],
    'argument' => [
      'id' => 'date',
    ],
    'sort' => [
      'id' => 'standard',
    ],
  ];

  return $data;
}

/**
 * Implements hook_entity_operation().
 */
function commerce_amazon_sp_api_entity_operation(EntityInterface $entity) {
  $current_user = \Drupal::currentUser();
  $operations = [];
  if ($entity->getEntityTypeId() === 'commerce_amazon_marketplace' &&
    $current_user->hasPermission('edit commerce_amazon_marketplace')) {
    $operations['items'] = [
      'title' => t('Items'),
      'url' => Url::fromRoute('entity.commerce_amazon_marketplace.canonical', [
        'commerce_amazon_marketplace' => $entity->id(),
      ]),
      'weight' => 50,
    ];
    $operations['settings'] = [
      'title' => t('Settings'),
      'url' => Url::fromRoute('entity.commerce_amazon_marketplace.integration', [
        'commerce_amazon_marketplace' => $entity->id(),
      ]),
      'weight' => 50,
    ];
  }
  return $operations;
}