orion76 + спасибо воспользовался вашим советом!
$receive_folder = ftp_nlist($conn_id, ""); // содержит название папок (получение папок)
$add_place = DrupalQueue::get('all_phone_folders'); // добавление в очередь
foreach ($receive_folder as $name_folder) {
if ($name_folder === '.' || $name_folder === '..') {
continue;
}
$add_place->createitem($name_folder);
}
}
Как сделать проверку , существует ли такая запись? то есть когда он все папки с файлами добавит , он заново пойдёт добавлять очередь которые уже добавлены

Модуль который делает запрос на фтп сервер получает файл типа 201210291843-15332-121.mp3 1. дата 2. логин это провайдер присылает такого типа файл, логин это внутренний номер (подставляет провайдер 153) в компании( кто проивзёл звонок ) звонок 3. внутренний номер (кто принял звонок)
что есть на данный момент я запрашиваю через фтп этот файл и закидываю его в обработчик разбивая его на несколько частей
1.2012-10-29 дата 2.18:43 время 3. 15332 логин - 132 внутренний номер если у нас в компании есть такой логин - (внутренний номер)
то присваиваю ему id юзера совершивший звонок 4. id(кто произвёл звонок) 5. внутренний номер(кто принял звонок) если есть такой в компании зарегистрированный пользователь с таким внутренним номером присваиваю ему id юзера приневший звонок 6.id (кто принял звонок) 7. время разговора и 8. комментарии к звонку и записываю это в бд в таком виде
теперь все просто , к каждому юзеру криплю свою запись ! вся суть задачи!
ЦЕЛЬ!!! Теперь что осталось доделать как писал выше сделал очереди , теперь суть такова в очереди стоят 100 папок за определенный время допустим 2012-10.29, 2012-10-30 и.т.д. как сделать проверку если все записи с 2012-по 2014 записаны и уже идут записи за 2015 чтобы он не ставил в очередь папки которые уже были записанны , а так же крон запускается каждые пол часа и в очередь он ставит папки а не файлы если в папку 2015-01.21 добавилась запись он должен добавить этот файл

мысли такие что в очередь начать ставить не папки а файлы тогда он будет получать данные о всех файлах которые добавились ( забыл написать файлы падают на фтп каждые пол часа , поэтому и крон запускается каждые пол часа) чтобы все записи сразу крепились, тока успеет ли создать такую большую очередь сейчас файлов примерно 60к+ через год их может стать 100к+

1

orion76 могли бы вы написать в аську 391001931 или скайп neee_ooon

Ну вообщем решил сам ) если интерестно
$ftp_dir_list_info = parsed_listing($conn_id, ""); // получение данных когда файл последний раз был изменён)
foreach ($ftp_dir_list_info as $dir_info) {
if ($dir_info['name'] == 'aspnet_client') {
continue;
}
// Previous moderation date.
$prev_mod_date = db_query("SELECT modification_date FROM modification_folder WHERE name_folder = '" . $dir_info['name'] . "'")->fetchField();
if ($prev_mod_date) {
// ФАЙЛ ЕСТЬ - ПРОВЕРЯЕМ ДАТУ МОДИФИКАЦИИ ИЗ БД
if ($prev_mod_date == $dir_info['date']) {
continue;
} else {
// Если у папки была изменина дата модификации то сделать апдейт в бд этой папки и добавить в очередь
db_update('modification_folder')
->fields(array('modification_date' => $dir_info['date']))
->condition('name_folder', $dir_info['name'])
->execute();
}
} else {
// Если файла в БД нема! ТО пишем его БД!
$data_folder = db_insert('modification_folder'); // запись в бд
$data_folder->fields(array(
'modification_date', // дата модификации
'name_folder', // имя папки
'status_processing' // Статус папки 1. Обработана 0. поставить в очередь
), array(
$dir_info['date'],
$dir_info['name'],
0
));
$data_folder->execute();
}

$add_place = DrupalQueue::get('all_phone_folders');
$interval = variable_get("time_fortnight", 0);
$add_place->createitem($dir_info['name']);
variable_set("time_out", time() + $interval);
}
}
Заранее сори за название переменных )) тока получилось написать а так работает как надо