View source
<?php
function globallink_webform_send_for_translations($lids, $pd4, $submission_name, $due_date, $project_code, $source_locale, $target_locale_arr, $submission_details, $submission_priority, $parents) {
module_load_include('inc', 'globallink', 'gl_ws/gl_ws_send_translations');
$globallink_arr = array();
$submitter = $submission_details['submitter'];
$final_tgt_arr = array();
foreach ($target_locale_arr as $target_locale) {
foreach ($parents as $pid => $p) {
foreach ($p as $lid) {
$active_row = globallink_webform_get_sent_tpt_rows_by_lid_and_target($lid, $target_locale);
if ($active_row != NULL) {
continue;
}
if (isset($final_tgt_arr[$target_locale][$pid])) {
array_push($final_tgt_arr[$target_locale][$pid], $lid);
}
else {
$final_tgt_arr[$target_locale][$pid] = array();
array_push($final_tgt_arr[$target_locale][$pid], $lid);
}
}
}
}
foreach ($final_tgt_arr as $target_locale_code => $final_parent_arr) {
$xmls = globallink_webform_get_xml($final_parent_arr);
foreach ($xmls as $parent => $xml) {
$tgt_arr = array();
$tgt_arr[] = $target_locale_code;
$name = 'Webform_' . $parent . '.xml';
watchdog('GlobalLink', 'XML - %xml', array(
'%xml' => $xml,
), WATCHDOG_DEBUG);
$globallink = new GlobalLink();
$globallink->type = 'webform';
$globallink->metadata = 'webform';
$globallink->sourceLocale = $source_locale;
$globallink->targetLocale = $tgt_arr;
$globallink->sourceXML = $xml;
$globallink->sourceFileName = $name;
$globallink->submissionName = $submission_name;
$globallink->submissionPriority = $submission_priority;
$globallink->dueDate = $due_date;
$globallink->otherObjectId = $parent;
$globallink->submissionInstructions = $submission_details['instructions'] . "\nSubmitter: " . $submitter;
$globallink->lids = $final_parent_arr[$parent];
$globallink_arr[] = $globallink;
}
}
if (!empty($globallink_arr)) {
globallink_send_documents_for_translation_to_pd($globallink_arr, $pd4, $project_code, $submitter);
}
return $globallink_arr;
}
function globallink_webform_get_xml($parents) {
$xmls = array();
foreach ($parents as $parent => $lids) {
$dom = new DOMDocument('1.0', 'UTF-8');
$dom->formatOutput = TRUE;
$root = $dom
->createElement('content');
$dom
->appendChild($root);
$property_arr = array();
if (!is_array($lids)) {
$string_result = db_select('i18n_string', 's')
->fields('s')
->condition('lid', $lids, '=')
->execute();
foreach ($string_result as $row) {
$property_arr['property'] = $row->property;
}
$id = $dom
->createAttribute('pid');
$id->value = $parent;
$root
->appendChild($id);
$result = db_select('locales_source', 'ls')
->fields('ls')
->condition('lid', $lids, '=')
->execute();
foreach ($result as $row) {
globallink_insert_child_element($dom, $root, 'webform', $row->source, array(
'name' => $property_arr['property'],
'lid' => $lids,
'location' => $row->location,
'format' => isset($lids['format']) ? $lids['format'] : '',
));
}
}
else {
foreach ($lids as $lid) {
$string_result = db_select('i18n_string', 's')
->fields('s')
->condition('lid', $lid, '=')
->execute();
foreach ($string_result as $row) {
$property_arr['property'] = $row->property;
}
$id = $dom
->createAttribute('pid');
$id->value = $parent;
$root
->appendChild($id);
$result = db_select('locales_source', 'ls')
->fields('ls')
->condition('lid', $lid, '=')
->execute();
foreach ($result as $row) {
globallink_insert_child_element($dom, $root, 'webform', $row->source, array(
'name' => $property_arr['property'],
'lid' => $lid,
'location' => $row->location,
'format' => isset($lid['format']) ? $lid['format'] : '',
));
}
}
}
$xml = $dom
->saveXML();
$xmls[$parent] = $xml;
}
return $xmls;
}
function globallink_webform_update_ticket_id($arr, $project_code) {
foreach ($arr as $globallink) {
$target_locale_arr = $globallink->targetLocale;
$type = $globallink->type;
if ($type != 'webform') {
continue;
}
$parent = $globallink->otherObjectId;
$lids = $globallink->lids;
foreach ($target_locale_arr as $target_locale) {
foreach ($lids as $lid) {
$webform = globallink_load_source_data($lid);
$row = globallink_webform_get_row($lid, $type, $globallink->sourceLocale, $target_locale);
if ($row) {
db_update('globallink_core_webform')
->fields(array(
'title' => $webform[0]->source,
'document_ticket' => $globallink->documentTicket,
'submission' => $globallink->submissionName,
'submission_ticket' => $globallink->submissionTicket,
'status' => 'Sent for Translations',
'timestamp' => REQUEST_TIME,
'last_modified' => REQUEST_TIME,
'project_code' => $project_code,
))
->condition('rid', $row->rid, '=')
->execute();
}
else {
db_insert('globallink_core_webform')
->fields(array(
'parent_id' => $parent,
'object_id' => $lid,
'object_type' => $globallink->type,
'title' => $webform[0]->source,
'source' => $globallink->sourceLocale,
'target' => $target_locale,
'document_ticket' => $globallink->documentTicket,
'submission' => $globallink->submissionName,
'submission_ticket' => $globallink->submissionTicket,
'status' => 'Sent for Translations',
'timestamp' => REQUEST_TIME,
'last_modified' => REQUEST_TIME,
'project_code' => $project_code,
))
->execute();
}
}
}
}
}
function globallink_webform_update_deleted_records($pd4, $globallink) {
try {
$globallink->status = 'Source Deleted';
globallink_send_download_confirmation($globallink->targetTicket, $pd4);
globallink_webform_update_status($globallink, 'Source Deleted');
} catch (SoapFault $se) {
watchdog('GlobalLink', 'SOAP Exception - %function - Code[%faultcode], Message[%faultstring]', array(
'%function' => __FUNCTION__,
'%faultcode' => $se->faultcode,
'%faultstring' => $se->faultstring,
), WATCHDOG_ERROR);
form_set_error('', t('Web Services Error: @faultcode - @faultstring', array(
'@faultcode' => $se->faultcode,
'@faultstring' => $se->faultstring,
)));
return FALSE;
} catch (Exception $e) {
watchdog('GlobalLink', 'Exception - %function - File[%file], Line[%line], Code[%code], Message[%message]', array(
'%function' => __FUNCTION__,
'%file' => $e
->getFile(),
'%line' => $e
->getLine(),
'%code' => $e
->getCode(),
'%message' => $e
->getMessage(),
), WATCHDOG_ERROR);
form_set_error('', t('Error: @message', array(
'@message' => $e
->getMessage(),
)));
return FALSE;
}
return TRUE;
}
function globallink_webform_get_translated($pd4, &$globallink_arr) {
module_load_include('inc', 'globallink', 'globallink');
$count = 0;
foreach ($globallink_arr as $globallink) {
$target_xml = globallink_download_target_resource($pd4, $globallink->targetTicket);
if ($globallink->sourceDeleted) {
continue;
}
if (!isset($target_xml)) {
continue;
}
$globallink->lids = array();
$language = globallink_get_drupal_locale_code($globallink->targetLocale);
$translated_arr = globallink_webform_get_translated_items($target_xml);
try {
$parent = $translated_arr['pid'];
foreach ($translated_arr as $w_key => $lid_arr) {
if ($w_key == 'pid') {
continue;
}
$lid = $w_key;
array_push($globallink->lids, $lid);
foreach ($lid_arr as $attribute => $translations) {
if ($attribute == 'lid') {
continue;
}
$webform = '';
if ($translations == '#title' || $translations == '#description' || strpos($translations, '#options-') !== false) {
$webform = globallink_load_source_data($lid);
if ($webform == '') {
throw new Exception('Source string not found for webform id ' . $lid . ' and field name ' . $attribute);
}
$report =& drupal_static(__FUNCTION__, array(
'additions' => 0,
'updates' => 0,
'deletes' => 0,
'skips' => 0,
));
$count++;
_locale_import_one_string_db($report, $language, $webform[0]->context, $webform[0]->source, $lid_arr['translation'], 'webform', $lid_arr['location'], LOCALE_IMPORT_OVERWRITE);
}
}
}
if ($globallink->status != 'Error') {
if ($globallink->status != 'Node Deleted') {
globallink_send_download_confirmation($globallink->targetTicket, $pd4);
}
globallink_webform_update_status($globallink);
}
else {
$count--;
}
} catch (SoapFault $se) {
$count--;
globallink_webform_update_status($globallink, 'Error');
form_set_error('', t('Web Services Error: @faultcode - @faultstring', array(
'@faultcode' => $se->faultcode,
'@faultstring' => $se->faultstring,
)));
} catch (Exception $ex) {
$count--;
globallink_webform_update_status($globallink, 'Error');
form_set_error('', t('Error: @message', array(
'@message' => $ex
->getMessage(),
)));
}
}
return $count;
}
function globallink_webform_get_translate_filter_query() {
$filter = array();
if (isset($_SESSION['globallink_webform_filter'])) {
foreach ($_SESSION['globallink_webform_filter'] as $key => $value) {
$filter[$key] = $value;
}
}
return $filter;
}
function globallink_webform_get_submission_status($lid, $locale_code) {
$result = db_select('globallink_core_webform', 'tcw')
->fields('tcw', array(
'status',
))
->condition('object_id', $lid, '=')
->condition('target', $locale_code, '=')
->execute();
while ($record = $result
->fetchAssoc()) {
return $record;
}
}
function globallink_webform_locale_languages($lid) {
$mapped_locales = globallink_get_mapped_locales_with_drupal_desc(TRUE);
$translation_status = '';
foreach ($mapped_locales as $code => $locale) {
$result = globallink_webform_get_submission_status($lid, $code);
if ($result) {
$translation_status .= $locale . ' - ' . $result['status'] . '<br />';
}
}
return $translation_status;
}
function globallink_webform_get_sent_tpt_rows_by_lid($lid) {
$result = db_select('globallink_core_webform', 'tcw')
->fields('tcw')
->condition('object_id', $lid, '=')
->condition('status', array(
'Sent for Translations',
'Error',
), 'IN')
->execute();
$rows = array();
foreach ($result as $row) {
$rows[] = $row;
}
return $rows;
}
function globallink_webform_get_sent_tpt_rows_by_lid_and_target($lid, $target) {
$result = db_select('globallink_core_webform', 'tcw')
->fields('tcw')
->condition('object_id', $lid, '=')
->condition('target', $target, '=')
->condition('status', array(
'Sent for Translations',
'Error',
), 'IN')
->execute();
foreach ($result as $row) {
return $row;
}
return NULL;
}
function globallink_webform_update_status(&$globallink, $status = 'Pending Translations') {
db_update('globallink_core_webform')
->fields(array(
'status' => $status,
'timestamp' => REQUEST_TIME,
))
->condition('submission', $globallink->submissionName, '=')
->condition('document_ticket', $globallink->documentTicket, '=')
->condition('source', $globallink->sourceLocale, '=')
->condition('target', $globallink->targetLocale, '=')
->execute();
}
function globallink_webform_get_row($object_id, $object_type, $source, $target) {
$result = db_select('globallink_core_webform', 'tcw')
->fields('tcw')
->condition('object_id', $object_id, '=')
->condition('object_type', $object_type, '=')
->condition('source', $source, '=')
->condition('target', $target, '=')
->execute();
foreach ($result as $row) {
return $row;
}
return FALSE;
}
function globallink_webform_get_active_submission_names() {
$query = db_select('globallink_core_webform', 'tcw');
$query
->condition('status', array(
'Sent for Translations',
'Error',
), 'IN');
$query
->distinct();
$query
->fields('tcw');
$results = $query
->execute();
$arr = array(
'' => '-- Select a Submission --',
);
foreach ($results as $row) {
$arr[$row->submission_ticket] = $row->submission;
}
return $arr;
}
function globallink_webform_get_submission_name($submission_ticket) {
$query = db_select('globallink_core_webform', 'tcw');
$query
->fields('tcw');
$query
->condition('submission_ticket', $submission_ticket, '=');
$results = $query
->execute();
foreach ($results as $row) {
if ($row->submission != '') {
return $row->submission;
}
}
}
function globallink_webform_cancel_submission($selected_submission) {
$pd4 = globallink_get_project_director_details();
$globallink = new GlobalLink();
$submission_name = globallink_webform_get_submission_name($selected_submission);
$globallink->submissionName = $submission_name;
$globallink->submissionTicket = $selected_submission;
globallink_cancel_pd_submission($pd4, $globallink);
globallink_webform_update_submission($globallink);
}
function globallink_webform_cancel_records($rowids, $pd4) {
$globallink_arr = array();
foreach ($rowids as $rid) {
$row = globallink_webform_get_other_row($rid);
$globallink = new GlobalLink();
$globallink->tptRowId = $row->rid;
$globallink->targetLocale = $row->target;
$globallink->documentTicket = $row->document_ticket;
$globallink->submissionTicket = $row->submission_ticket;
$globallink_arr[$rid] = $globallink;
}
globallink_cancel_select_documents($pd4, $globallink_arr);
globallink_webform_update_row_document($globallink_arr);
}
function globallink_webform_get_other_row($row_id) {
$result = db_select('globallink_core_webform', 'tcw')
->fields('tcw')
->condition('rid', $row_id, '=')
->execute();
foreach ($result as $row) {
return $row;
}
}
function globallink_webform_update_submission(&$globallink) {
db_update('globallink_core_webform')
->fields(array(
'status' => 'Cancelled',
'timestamp' => REQUEST_TIME,
))
->condition('submission_ticket', $globallink->submissionTicket, '=')
->condition('submission', $globallink->submissionName, '=')
->execute();
}
function globallink_webform_update_row_document(&$globallink_arr) {
foreach ($globallink_arr as $globallink) {
if ($globallink->cancelled) {
db_update('globallink_core_webform')
->fields(array(
'status' => 'Pending Translations',
'timestamp' => REQUEST_TIME,
))
->condition('rid', $globallink->tptRowId, '=')
->execute();
}
}
}
function globallink_webform_get_distinct_active_submission_names() {
$query = db_select('globallink_core_webform', 'tcw');
$query
->condition('status', array(
'Sent for Translations',
'Error',
), 'IN');
$query
->distinct();
$query
->fields('tcw');
$results = $query
->execute();
$arr = array(
'[any]' => t('Any'),
);
foreach ($results as $row) {
$arr[$row->submission] = $row->submission;
}
return $arr;
}
function globallink_webform_get_translated_items($xml) {
if (is_null($xml) || !is_string($xml) || $xml == '') {
return array();
}
$dom = new DomDocument();
$dom->preserveWhiteSpace = FALSE;
$dom
->loadXML($xml);
$contents = $dom
->getElementsByTagName('content');
$parent = '';
foreach ($contents as $content) {
if (!is_null($content->attributes)) {
foreach ($content->attributes as $attr_name => $attr_node) {
if ($attr_name == 'pid') {
$parent = $attr_node->value;
}
}
}
}
if ($parent == '') {
return array();
}
$webform_arr = array();
$webform_arr['pid'] = $parent;
$webforms = $dom
->getElementsByTagName('webform');
foreach ($webforms as $webform) {
if (!is_null($webform->attributes)) {
$lid = '';
foreach ($webform->attributes as $attr_name => $attr_node) {
if ($attr_name == 'lid') {
$lid = $attr_node->value;
break;
}
}
$w_arr = array();
foreach ($webform->attributes as $attr_name => $attr_node) {
$w_arr[$attr_name] = $attr_node->value;
}
$w_arr['translation'] = $webform->nodeValue;
$webform_arr[$lid] = $w_arr;
}
}
return $webform_arr;
}
function globallink_webform_get_translation_status($lid, $tgt_locale, &$title) {
$query = db_select('globallink_core_webform', 'tcw');
$query
->condition('object_id', $lid, '=');
$query
->condition('target', $tgt_locale, '=');
$query
->distinct();
$query
->fields('tcw');
$results = $query
->execute();
foreach ($results as $row) {
$title = $row->title;
$webform = globallink_load_source_data($lid);
if (!$webform || is_null($webform)) {
return 'Source Deleted';
}
elseif ($row->status == 'Sent for Translations') {
return 'Translation Completed';
}
elseif ($row->status == 'Error') {
return 'Error';
}
}
return 'Sent for Translations';
}
function globallink_webform_get_sent_tpt_rows_by_lid_target($lid, $target) {
$result = db_select('globallink_core_webform', 'tcw')
->fields('tcw')
->condition('object_id', $lid, '=')
->condition('target', $target, '=')
->condition('status', array(
'Sent for Translations',
'Error',
), 'IN')
->execute();
$rows = array();
foreach ($result as $row) {
$rows[] = $row;
}
return $rows;
}
function globallink_webform_get_row_id_from_submission($submission_ticket, $document_ticket, $target_locale) {
$query = db_select('globallink_core_webform', 'tc');
$query
->condition('submission_ticket', $submission_ticket, '=');
$query
->condition('document_ticket', $document_ticket, '=');
$query
->condition('target', $target_locale, '=');
$query
->fields('tc');
$results = $query
->execute();
foreach ($results as $row) {
return $row->rid;
}
}
function globallink_webform_get_active_submission_rows_by_lid($lids) {
$query = db_select('globallink_core_webform', 'tci');
$query
->condition('status', 'Sent for Translations', '=');
$query
->condition('object_id', $lids, 'IN');
$query
->fields('tci');
$results = $query
->execute();
$arr = array();
foreach ($results as $row) {
if (array_key_exists($row->object_id, $arr)) {
array_push($arr[$row->object_id], $row);
}
else {
$arr[$row->object_id] = array(
$row,
);
}
}
$final_arr = array();
foreach ($arr as $lid => $lid_arr) {
$sub_arr = array();
foreach ($lid_arr as $r) {
if (array_key_exists($r->submission, $sub_arr)) {
array_push($sub_arr[$r->submission], $r->target);
}
else {
$sub_arr[$r->submission] = array(
$r->target,
);
}
}
if (count($sub_arr) > 0) {
$final_arr[$lid] = $sub_arr;
}
}
if (count($final_arr) > 0) {
return $final_arr;
}
return FALSE;
}
function globallink_webform_update_submission_status($submission_ticket, $status = 'Cancelled') {
db_update('globallink_core_webform')
->fields(array(
'status' => $status,
'timestamp' => REQUEST_TIME,
))
->condition('submission_ticket', $submission_ticket, '=')
->execute();
}
function globallink_webform_get_pd_submission_status() {
module_load_include('inc', 'globallink', 'globallink_settings');
module_load_include('inc', 'globallink', 'gl_ws/gl_ws_common');
$query = db_select('globallink_core_webform', 'tc');
$query
->fields('tc', array(
'submission_ticket',
));
$query
->distinct();
$query
->condition('status', 'Sent for Translations', '=');
$results = $query
->execute();
foreach ($results as $row) {
if ($row->submission_ticket) {
try {
$pd4 = globallink_get_project_director_details();
$doc_status = globallink_get_status($pd4, $row->submission_ticket);
if (!$doc_status || $doc_status == 'CANCELLED') {
globallink_webform_update_submission_status($row->submission_ticket);
}
} catch (SoapFault $se) {
globallink_webform_update_submission_status($row->submission_ticket);
} catch (Exception $ex) {
globallink_webform_update_submission_status($row->submission_ticket);
}
}
}
}
function globallink_webform_check_status($rids_arr) {
$status = TRUE;
$query = db_select('globallink_core_webform', 'tc')
->fields('tc', array(
'rid',
))
->condition('status', array(
'Sent for Translations',
'Error',
), 'IN');
$results = $query
->execute();
$rows = array();
foreach ($results as $item) {
$rows[$item->rid] = $item->rid;
}
foreach ($rids_arr as $val) {
if (!in_array($val, $rows)) {
unset($rids_arr[$val]);
$status = FALSE;
}
}
if (!$status) {
drupal_set_message(t('Cannot cancel documents that have been cancelled in Globallink.'), 'warning', NULL);
}
return $rids_arr;
}
function globallink_webform_clear_cancelled_documents() {
$count = 0;
$query = db_select('globallink_core_webform', 'tc')
->fields('tc', array(
'submission_ticket',
))
->distinct()
->condition('status', 'Cancelled', '=');
$results = $query
->execute();
foreach ($results as $item) {
globallink_webform_update_submission_status($item->submission_ticket, 'Pending Translations');
$count++;
}
return $count;
}
