';
require_once("soap.php");
$cl = new SyndisConnector("http://172.21.11.101/SyndisSpm.wsdl"); //zmienić URL na inny - ten kieruje na moj komputer
//$cl->__setLocation('http://172.20.43.10:3615/');
$cl->__setLocation('http://172.21.11.101:3615/');
echo 'connected ...
';
echo 'Start: '.date("Y-m-d H:i:s").'
';
date_default_timezone_set('Europe/Warsaw');
require_once("func.php");
require_once("dbaccess.php");
$polacz = mysql_connect($db_host, $db_user, $db_user_pass) or die ('cannot connect to db');
mysql_select_db($db_name);
mysql_query("SET NAMES utf8");
mysql_query("SET CHARACTER_SET utf8_general_ci");
function convertDataUTC2Cur($insertDate)
{
unset($res);
//re-contruct to format
$res = date('Y-m-d H:i:s', strtotime($insertDate));
return $res;
}
function convertDataCur2UTC($insertDate)
{
unset($res);
$dt = new DateTime($insertDate);
$dt->setTimezone(new DateTimeZone('UTC'));
$res = $dt->format('Y-m-d').'T'.$dt->format('H:i:s').'Z';
return $res;
}
function objectToArray($d) {
if (is_object($d)) {
// Gets the properties of the given object
// with get_object_vars function
$d = get_object_vars($d);
}
if (is_array($d)) {
/*
* Return array converted to object
* Using __FUNCTION__ (Magic constant)
* for recursive call
*/
return array_map(__FUNCTION__, $d);
}
else {
// Return array
return $d;
}
}
/*
echo convertDataUTC2Cur('2017-01-31T07:52:01Z');
echo"
";
echo convertDataCur2UTC('2017-01-31 07:52:01');
echo"
";
echo"
";
*/
unset($recArray);
$recArray = sqlGetResAsArray("select * from rep_onoff_proccessing where W_STATUS=0 limit 1");
$scriptDate = '2014-01-01 12:00:00';
/*
echo $scriptDate;
echo"
";
echo convertDataCur2UTC($scriptDate);
echo"
";
*/
if (!empty($recArray[0]['W_NAME']))
{
unset($wellArray);
$wellArray = objectToArray($cl->GetPumpSwitchAndReasonsHistory($recArray[0]['W_NAME'],convertDataCur2UTC($scriptDate)));
$devID = sqlStringValue("select DRS_ID from seg_wells,seg_dev_resources where DRS_DEV_ID=WLL_ID and DRS_DEV_TYPE=12 and WLL_CAT_DIC_ID in (18,19) and WLL_NAME='".$recArray[0]['W_NAME']."'", "DRS_ID");
echo"Studnia: ".$recArray[0]['W_NAME']."
";
if (count($wellArray['probes'])>0 && $devID>0)
{
// ======================================================================================================
// sprawdza ile jest pomiarów załącz/wyłącz dla danego obiektu w bazie MySQL: dla danej daty większej od
// ======================================================================================================
unset($ileSQL);
$ileSQL=0;
$ileSQL = sqlValue("
select count(*) from (
select * from seg_dev_resources_det where DRD_RESOURCES_DETAIL=507 and DRD_AUDIT_USR='SYNDIS' and DRD_DRS_ID=".$devID." and DRD_AUDIT_DATE>='".$scriptDate."'
union
select * from seg_dev_resources_det_his where DRD_RESOURCES_DETAIL=507 and DRD_AUDIT_USR='SYNDIS' and DRD_DRS_ID=".$devID." and DRD_AUDIT_DATE>='".$scriptDate."'
) tb
");
echo "Ilość w MySQL: ". $ileSQL;
echo"
";
// ======================================================================================================
// ======================================================================================================
// sprawdza ile jest pomiarów załącz/wyłącz dla danego obiektu w SOAP SYNDIS: dla danej daty większej od
// ======================================================================================================
unset($ileSYNDIS);
$ileSYNDIS=0;
$ileSYNDIS = count($wellArray['probes']);
echo "Ilość w SYNDIS: ".$ileSYNDIS;
echo"
";
echo"
";
// ======================================================================================================
// jeśli jest różnica
if ($ileSYNDIS != $ileSQL)
// ======================================================================================================
{
mysql_query("delete from seg_dev_resources_det_his where DRD_RESOURCES_DETAIL=507 and DRD_AUDIT_USR='SYNDIS' and DRD_DRS_ID=".$devID);
mysql_query("delete from seg_dev_resources_det where DRD_RESOURCES_DETAIL=507 and DRD_AUDIT_USR='SYNDIS' and DRD_DRS_ID=".$devID);
$zalacz = 0;
$wylacz = 0;
for ($i=0; $i";
$zalacz++;
}
// jeśli wyłącz
elseif ($wellArray['probes'][$i]['value'] == 0)
{
mysql_query("INSERT INTO seg_dev_resources_det SET DRD_DRS_ID=".$devID.",DRD_RESOURCES_DETAIL=507,DRD_VALUE='OFF',DRD_DESCRIPTION='".$wellArray['probes'][$i]['reason']."',DRD_EXPORT_SEGAP='1',DRD_AUDIT_USR='SYNDIS',DRD_AUDIT_DATE='".convertDataUTC2Cur($wellArray['probes'][$i]['date'])."'");
//echo("INSERT INTO seg_dev_resources_det SET DRD_DRS_ID=".$devID.",DRD_RESOURCES_DETAIL=507,DRD_VALUE='OFF',DRD_DESCRIPTION='".$wellArray['probes'][$i]['reason']."',DRD_EXPORT_SEGAP='1',DRD_AUDIT_USR='SYNDIS',DRD_AUDIT_DATE='".convertDataUTC2Cur($wellArray['probes'][$i]['date'])."'");
//echo"
";
$wylacz++;
}
}
echo"Dodano ".$zalacz." wpisów o załączeniu.";
echo"
";
echo"Dodano ".$wylacz." wpisów o wyłączeniu.";
echo"
";
echo"
";
}
// ======================================================================================================
}
}
mysql_query("UPDATE rep_onoff_proccessing SET W_STATUS=1 WHERE W_ID=".$recArray[0]['W_ID']);
mysql_close($polacz);
echo 'finish processing ...
';
echo 'Finish: '.date("Y-m-d H:i:s").'
';
?>