fernando/luos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote branch 'upstream/master'

Browse Source
This commit is contained in:
Brayan Osmar Pereyra Suxo
2012-10-23 09:04:10 -04:00
parent 0d475304e7 757d79242b
commit c6b75dc9cd
23 changed files with 3279 additions and 3273 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
workflow/engine/classes/triggers/class.pmTalendFunctions.php
View File

@@ -1,4 +1,5 @@
<?php
/**
* class.pmTalend.pmFunctions.php
*
@@ -19,17 +20,15 @@
/**
* Talend ETL Integration
* @class pmTalend
*
* @name Talend ETL Integration
* @icon /images/triggers/TalendOpenStudio.gif
* @className class.pmTalend.pmFunctions.php
*/
/**
* @method
*
* Executes a Talend Web Service..
* @method Executes a Talend Web Service..
*
* @name executeTalendWebservice
* @label Executes a Talend Web Service.
@@ -40,43 +39,48 @@
* @return array | $return | Talend Array
*
*/
function executeTalendWebservice($wsdl,$params=array(), $message){
$client = new SoapClient($wsdl,array('trace' => 1));
function executeTalendWebservice ($wsdl, $message, $params = array())
{
$client = new SoapClient( $wsdl, array ('trace' => 1
) );
//Apply proxy settings
$sysConf = System::getSystemConfiguration();
if ($sysConf['proxy_host'] != '') {
curl_setopt($client, CURLOPT_PROXY, $sysConf['proxy_host'] . ($sysConf['proxy_port'] != '' ? ':' . $sysConf['proxy_port'] : ''));
if ($sysConf['proxy_port'] != '') {
curl_setopt($client, CURLOPT_PROXYPORT, $sysConf['proxy_port']);
//Apply proxy settings
$sysConf = System::getSystemConfiguration();
if ($sysConf['proxy_host'] != '') {
curl_setopt( $client, CURLOPT_PROXY, $sysConf['proxy_host'] . ($sysConf['proxy_port'] != '' ? ':' . $sysConf['proxy_port'] : '') );
if ($sysConf['proxy_port'] != '') {
curl_setopt( $client, CURLOPT_PROXYPORT, $sysConf['proxy_port'] );
}
if ($sysConf['proxy_user'] != '') {
curl_setopt( $client, CURLOPT_PROXYUSERPWD, $sysConf['proxy_user'] . ($sysConf['proxy_pass'] != '' ? ':' . $sysConf['proxy_pass'] : '') );
}
curl_setopt( $client, CURLOPT_HTTPHEADER, array ('Expect:'
) );
}
if ($sysConf['proxy_user'] != '') {
curl_setopt($client, CURLOPT_PROXYUSERPWD, $sysConf['proxy_user'] . ($sysConf['proxy_pass'] != '' ? ':' . $sysConf['proxy_pass'] : ''));
$params[0] = "";
foreach ($params as $paramO) {
$params[] = "--context_param" . $paramO[0] . "=" . $paramO[1];
}
curl_setopt($client, CURLOPT_HTTPHEADER, array('Expect:'));
}
$result = $client->__SoapCall( 'runJob', array ($params
) );
$params[0]="";
foreach($params as $paramO){
$params[]="--context_param".$paramO[0]."=".$paramO[1];
}
$result = $client->__SoapCall('runJob', array($params));
/*
$params[1]="--context_param nb_line=".@=Quantity;
/*
$params[1]="--context_param nb_line=".@=Quantity;
$result = $client->__SoapCall('runJob', array($params));
foreach ($result->item as $keyItem => $item){
$gridRow=$keyItem+1;
@=USERSINFO[$gridRow]['NAME']=$item->item[1];
@=USERSINFO[$gridRow]['LASTNAME']=$item->item[2];
@=USERSINFO[$gridRow]['DATE']=$item->item[0];
@=USERSINFO[$gridRow]['STREET']=$item->item[3];
@=USERSINFO[$gridRow]['CITY']=$item->item[4];
@=USERSINFO[$gridRow]['STATE']=$item->item[5];
@=USERSINFO[$gridRow]['STATEID']=$item->item[6];
$result = $client->__SoapCall('runJob', array($params));
foreach ($result->item as $keyItem => $item){
$gridRow=$keyItem+1;
@=USERSINFO[$gridRow]['NAME']=$item->item[1];
@=USERSINFO[$gridRow]['LASTNAME']=$item->item[2];
@=USERSINFO[$gridRow]['DATE']=$item->item[0];
@=USERSINFO[$gridRow]['STREET']=$item->item[3];
@=USERSINFO[$gridRow]['CITY']=$item->item[4];
@=USERSINFO[$gridRow]['STATE']=$item->item[5];
@=USERSINFO[$gridRow]['STATEID']=$item->item[6];
}
*/
G::SendMessageText( "<font color='blue'>Information from Talend ETL webservice</font><font color='darkgray'><br>" . $wsdl . "</font>", "INFO" );
}
}
*/
G::SendMessageText( "<font color='blue'>Information from Talend ETL webservice</font><font color='darkgray'><br>".$wsdl."</font>", "INFO");
}