// Здесь мы сообщаем системе, что у нас есть новая очередь и отдельный элемент этой очереди нужно обрабатывать функцией aa_create_node. Один запуск очереди - 60 секунд.

function aa_importer_cron_queue_info() {
  $queues['aa_importer_queue'] = array(
    'worker callback' => 'aa_create_node',
    'time' => 60, // time in second for each worker
  );
  return $queues;
}

//Для того, чтобы это все взлетело, нужно поставить все наше огромное количество объектов для импорта в очередь. Делаем это по крону, используя Queue API.

function aa_importer_cron() {
  $queue = DrupalQueue::get('aa_importer_queue');
  $queue->createQueue();
 
  $files = file_scan_directory('public://carcopy/test', '/.*\.xml$/');

foreach ($files as $key => $value) {
$file=simplexml_load_file(drupal_realpath($key));
//dvm($file);
foreach ($file->offers->offer as $offer) {
 $queue->createItem($offer->asXML());
}
}
 
//Здесь мы потихонечку парсим xml файлы и загоняем отдельные объекты в очередь.  
 
}

function aa_create_node($data) {

$data = new SimpleXMLElement($data);

$result = db_select('field_data_field_car_id', 'id')
    ->fields('id')
    ->condition('field_car_id_value', $data->id,'=')  
    ->execute()
    ->fetchAssoc();  
//Ноды создаются только в том случае, если в базе еще нет ноды с таким значением id. В противном случае нода не создается.
 
    if (!($result)) {
$files=array();

//Грузим картинки на сервер
//Картинка грузится только в том случае, если она картинка. Т.е. предварительно мы проверяем что там находится на другом конце.

foreach ($data->photos->photo as $photo) {
if (getimagesize($data->photos->attributes().$photo[0])) {
$file=drupal_http_request($data->photos->attributes().$photo[0]);
$newfile=file_save_data($file->data,'public://'.uniqid().'.jpg');
if ($newfile) {

$files[]['fid']=$newfile->fid;
}
}
}

//Формируем объект ноды.

$new_node = new StdClass();
$new_node->type = 'car';
$new_node->status = 1;
$new_node->promote = 0;
$new_node->comment = 2;
$new_node->sticky = 0;
$new_node->uid = 1;
$new_node->field_image['und']=$files; // Изображения машинки
$new_node->field_agency_price['und'][0]['value']=$data->price; // Цена машинки
$new_node->field_model['und'][]['tid']=aa_create_term($data->make,$data->model); // Таксономия модели
$new_node->field_car_id['und'][0]['value']=$data->id; //id машинки
$new_node->field_condition['und'][0]['value']=$data->category; //Состояние
$new_node->field_kuzov['und'][0]['value']=$data->{'body-type'}; //Состояние
$new_node->field_engine_type['und'][0]['value']=$data->{'engine-type'}; //Состояние
$new_node->field_year['und'][0]['value']=$data->year; //Состояние
$new_node->field_track['und'][0]['value']=$data->run; //Состояние
$new_node->field_kuzov_color['und'][0]['value']=$data->color; //Состояние
$new_node->field_dverei['und'][0]['value']=$data->doors; //Состояние
$new_node->field_engine_power['und'][0]['value']=$data->power; //Состояние
$new_node->field_kpp['und'][0]['value']=$data->transmission; //Состояние
$new_node->field_engine_volume['und'][0]['value']=$data->{'cubic-capacity'}; //Состояние
$new_node->field_drive['und'][0]['value']=$data->drive; //Состояние
$new_node->field_mesto_osmotra['und'][0]['value']=$data->{'location-address'}; //Состояние
$new_node->field_prodavec_phone['und'][0]['value']=$data->{'seller-phone'}; //Состояние
$new_node->field_dtp['und'][0]['value']=$data->accident; //Состояние
$new_node->field_sost_auto['und'][0]['value']=$data->condition; //Состояние
$new_node->field_dop_info['und'][0]['value']=$data->comment; //Состояние

node_save($new_node);
}
}

//Тут создаются новые термины таксономии, если их нет.

function aa_create_term($parent,$child = NULL) {

$tree  = taxonomy_get_tree(2,0,1);

$parent_tid = 0;
foreach ($tree as $term) {
if ($term->name == $parent) {$parent_tid=$term->tid;}
}

if ($parent_tid == 0) {

$term = array(
  'name' => $parent,
  'vid' => 2,
  'parent' => $parent_tid,
);
$term = (object) $term;
taxonomy_term_save($term);
$tid = $term->tid;
if ($child) {
$term = array(
  'name' => $child,
  'vid' => 2,
  'parent' => $tid,
);
$term = (object) $term;
taxonomy_term_save($term);
$tid = $term->tid;
}
} else {

$tree  = taxonomy_get_tree(2,$parent_tid,1);
$child_tid = 0;
foreach ($tree as $term) {
if ($term->name == $child) {$child_tid=$term->tid;}
}

if ($child_tid == 0) {
$term = array(
  'name' => $child,
  'vid' => 2,
  'parent' => $parent_tid,
);
$term = (object) $term;
taxonomy_term_save($term);
$tid = $term->tid;

} else {$tid=$child_tid;}
}
return $tid;
}