View source
<?php
namespace Drupal\simple_node_importer\Form;
use Drupal\field\Entity\FieldStorageConfig;
use Drupal\file\Entity\File;
use Drupal\Core\Form\FormBase;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\Core\Form\FormStateInterface;
use Drupal\node\NodeInterface;
use Drupal\user\PrivateTempStoreFactory;
use Drupal\file\FileUsage\FileUsageInterface;
use Symfony\Component\HttpFoundation\RedirectResponse;
use Drupal\Core\Logger\LoggerChannelFactoryInterface;
use Drupal\simple_node_importer\Services\GetServices;
class SimpleUserImporterMappingForm extends FormBase {
protected $tempStore;
protected $services;
protected $fileUsage;
protected $logger;
public function __construct(GetServices $getServices, PrivateTempStoreFactory $sessionVariable, FileUsageInterface $file_usage, LoggerChannelFactoryInterface $logger) {
$this->services = $getServices;
$this->tempStore = $sessionVariable
->get('simple_node_importer');
$this->fileUsage = $file_usage;
$this->logger = $logger;
}
public function getFormId() {
return 'simple_node_importer_mapping_form';
}
public function buildForm(array $form, FormStateInterface $form_state, $option = NULL, NodeInterface $node = NULL) {
global $base_url;
$type = 'module';
$module = 'simple_node_importer';
$filepath = $base_url . '/' . drupal_get_path($type, $module) . '/css/files/mapping.png';
$fid = $node
->get('field_upload_csv')
->getValue()[0]['target_id'];
$file = File::load($fid);
$uri = $file
->getFileUri();
if (empty($node)) {
$type = 'Simple Node Importer';
$message = 'Node object is not valid.';
$this->logger
->get($type)
->error($message, []);
}
elseif ($this->tempStore
->get('file_upload_session') == FALSE) {
$response = new RedirectResponse('/node/add/simple-node');
$response
->send();
}
else {
$headers = $this->services
->simpleNodeImporterGetAllColumnHeaders($uri);
$entity_type = $option;
$selected_option = $option;
$type = 'mapping';
$get_field_list = $this->services
->snpGetFieldList($entity_type, $selected_option, $type);
$parameters = [
'option' => $option,
'node' => $node
->id(),
];
$this->tempStore
->set('parameters', $parameters);
$form['helptext'] = [
'#theme' => 'mapping_help_text_info',
'#fields' => [
'filepath' => $filepath,
],
];
$form['mapping_form']['#theme'] = 'simple_node_import_table';
$defaultFieldArr = [
'name',
'mail',
'status',
'roles',
];
foreach ($get_field_list as $key => $field) {
if ($entity_type == 'user') {
$field_name = $field
->getName();
if (in_array($key, $defaultFieldArr)) {
$field_label = $field
->getLabel()
->render();
$fieldcardinality = $field
->getCardinality();
}
else {
$field_info = FieldStorageConfig::loadByName($entity_type, $field_name);
$fieldcardinality = $field_info
->get('cardinality');
$field_label = $field
->getLabel();
}
}
if ($fieldcardinality == -1 || $fieldcardinality > 1) {
$form['mapping_form'][$key] = [
'#type' => 'select',
'#title' => $field_label,
'#options' => $headers,
'#multiple' => TRUE,
'#required' => $field
->isRequired() ? TRUE : FALSE,
'#empty_option' => $this
->t('Select'),
'#empty_value' => '',
];
}
else {
$form['mapping_form'][$key] = [
'#type' => 'select',
'#title' => $field_label,
'#options' => $headers,
'#required' => $field
->isRequired() ? TRUE : FALSE,
'#empty_option' => $this
->t('Select'),
'#empty_value' => '',
];
}
}
$form = $this->services
->simpleNodeImporterGetPreSelectedValues($form, $headers);
$form['import'] = [
'#type' => 'submit',
'#value' => $this
->t('Import'),
'#weight' => 49,
];
$form['cancel'] = [
'#type' => 'submit',
'#value' => $this
->t('cancel'),
'#weight' => 3,
'#submit' => [
'::snpRedirectToCancel',
],
];
return $form;
}
}
public function validateForm(array &$form, FormStateInterface $form_state) {
$valarray = [];
$duplicates = [];
$count_array = [];
$form_state
->cleanValues();
foreach ($form_state
->getValues() as $key => $val) {
if ($val && is_array($val)) {
foreach ($val as $v) {
$valarray[] = $v;
}
}
elseif ($val) {
$valarray[] = $val;
}
}
$count_array = array_count_values($valarray);
foreach ($count_array as $field => $count) {
if ($count > 1) {
$duplicates[] = $field;
}
}
foreach ($duplicates as $duplicate_val) {
foreach ($form_state
->getValues() as $key => $val) {
if ($val == $duplicate_val) {
$form_state
->setErrorByName($key, $this
->t('Duplicate Mapping detected for %duplval', [
'%duplval' => $duplicate_val,
]));
}
elseif (is_array($val)) {
foreach ($val as $v) {
if ($v == $duplicate_val) {
$form_state
->setErrorByName($key, $this
->t('Duplicate Mapping detected for %duplval', [
'%duplval' => $duplicate_val,
]));
}
}
}
}
}
if (isset($_SESSION['messages']['error'])) {
$_SESSION['messages']['error'] = array_unique($_SESSION['messages']['error']);
}
}
public function submitForm(array &$form, FormStateInterface $form_state) {
$haystack = 'snp_';
foreach ($form_state
->getValues() as $key => $val) {
if (strpos($key, $haystack) === FALSE) {
$mapvalues[$key] = $val;
}
}
$this->tempStore
->set('mapvalues', $mapvalues);
$parameters = $this->tempStore
->get('parameters');
$form_state
->cleanValues();
$form_state
->setRedirect('simple_node_importer.user_confirmation_form', $parameters);
}
public static function create(ContainerInterface $container) {
return new static($container
->get('snp.get_services'), $container
->get('user.private_tempstore'), $container
->get('file.usage'), $container
->get('logger.factory'));
}
public function snpRedirectToCancel(array &$form, FormStateInterface $form_state) {
$parameters = $this->tempStore
->get('parameters');
$form_state
->setRedirect('simple_node_importer.delete_node', $parameters);
}
}