';
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").'
';
$scriptDate = date("Y-m-d H:i:s");
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 update_new_record($devID, $dicID, $value,$insertDate)
{
$insertDate = str_replace(array('T','Z'), array(' ',''),$insertDate);
$value = round($value,2);
$drdID = sqlValue("select SQL_NO_CACHE max(DRD_ID) from seg_dev_resources_det where DRD_RESOURCES_DETAIL=".$dicID." and DRD_DRS_ID=".$devID);
if ($drdID>0)
{
mysql_query("UPDATE seg_dev_resources_det SET DRD_VALUE='".round($value,2)."',DRD_AUDIT_DATE='".$insertDate."',DRD_AUDIT_USR='SYNDIS' WHERE DRD_ID=".$drdID);
// echo sqlStringValue("select DIC_POL_LANG from sys_dictionaries where DIC_ID=".$dicID, "DIC_POL_LANG")." [$dicID]: ".$value;
}
//echo"";
}
function isNewestData($devID,$dicID,$insertDate)
{
$res = false;
$insertDate = str_replace(array('T','Z'), array(' ',''),$insertDate);
$insertDateValue = (float) str_replace(array('-',':',' '),array('','',''),$insertDate);
$lastMasureDate = sqlStringValue("select getLastMeasureDate(".$dicID.",".$devID.") MT","MT");
$lastMasureDateValue = (float) str_replace(array('-',':',' '),array('','',''),$lastMasureDate);
if ($insertDateValue>$lastMasureDateValue)
$res=true;
return $res;
}
// pobieramy tablice studni
$well_array=null;
$wynik = mysql_query("select DISTINCT DRD_OBJECT_NAME from seg_dev_major_data left join seg_wells on DRD_OBJECT_NAME=WLL_NAME where DRD_OBJECT_TYPE='WELL' and DMD_WORK_STATUS='1' and WLL_HH_SCOPE>0 and WLL_CAT_DIC_ID in (18,19)");
if($wynik)while ($r = mysql_fetch_array($wynik))
{
$well_array[] = $r["DRD_OBJECT_NAME"];
}
//print_r($cl->GetWellsDataAsArray(array('G52','G54'))); //Pobieranie danych dla wszystkich studni
$wl = $cl->GetWellsDataAsArray($well_array);
for($i=0; $i";
$devID=null; $wellID=null; $vpp=null; $vhh=null;
$wynik_W = mysql_query("select DRS_ID,WLL_ID,WLL_PP_SCOPE,WLL_HH_SCOPE,WLL_CAT_DIC_ID from seg_wells left join seg_dev_resources on WLL_ID=DRS_DEV_ID and DRS_DEV_TYPE=12 where WLL_NAME='".$wl["wells"][$i]["well"]["id"]."'");
if($wynik_W)while ($r_W = mysql_fetch_array($wynik_W))
{
$devID = $r_W["DRS_ID"];
$wellID = $r_W["WLL_ID"];
$vpp=$r_W["WLL_PP_SCOPE"]; if ($vpp==0) $vpp=500;
$vhh=$r_W["WLL_HH_SCOPE"];
$wellType = $r_W["WLL_CAT_DIC_ID"];
}
//sprawdza stan załączenia pompy
if (sqlStringValue("select getLastValue(507,".$devID.") ONF", "ONF")=='ON' && $wl["wells"][$i]["pumpOnOff"]["value"]==0)
{
//INSERT INTO seg_dev_resources_det SET DRD_DRS_ID=1234,DRD_RESOURCES_DETAIL=507,DRD_VALUE='OFF',DRD_EXPORT_SEGAP='1',DRD_AUDIT_USR='SYNDIS',DRD_AUDIT_DATE=now();
mysql_query("INSERT INTO seg_dev_resources_det SET DRD_DRS_ID=".$devID.",DRD_RESOURCES_DETAIL=507,DRD_VALUE='OFF',DRD_EXPORT_SEGAP='1',DRD_AUDIT_USR='SYNDIS',DRD_AUDIT_DATE='".$scriptDate."'");
}
//sprawdza stan załączenia pompy
elseif (sqlStringValue("select getLastValue(507,".$devID.") ONF", "ONF")=='OFF' && $wl["wells"][$i]["pumpOnOff"]["value"]==1)
{
//INSERT INTO seg_dev_resources_det SET DRD_DRS_ID=1234,DRD_RESOURCES_DETAIL=507,DRD_VALUE='OFF',DRD_EXPORT_SEGAP='1',DRD_AUDIT_USR='SYNDIS',DRD_AUDIT_DATE=now();
mysql_query("INSERT INTO seg_dev_resources_det SET DRD_DRS_ID=".$devID.",DRD_RESOURCES_DETAIL=507,DRD_VALUE='ON',DRD_EXPORT_SEGAP='1',DRD_AUDIT_USR='SYNDIS',DRD_AUDIT_DATE='".$scriptDate."'");
}
// sprawdza, czy pompa jest włączona
if ($wl["wells"][$i]["pumpOnOff"]["value"]==1)
{
//rejestruje dane bez względu na ich jakość - prezentacja informacji w SYNDIS
//INSERT INTO rep_soap_syndis_quality_data SET SQD_DRS_ID=111,SQD_OBJECT_NAME='111',SQD_NAME='111',SQD_VAL_Q=111,SQD_FLG_Q='111',SQD_VAL_P1=111,SQD_FLG_P1='111',SQD_VAL_P2=111,SQD_FLG_P2='111',SQD_VAL_PE=111,SQD_FLG_PE='111',SQD_VAL_PP=111,SQD_FLG_PP='111',SQD_VAL_HH=111,SQD_FLG_HH='111',SQD_VAL_HD=111,SQD_FLG_HD='111',SQD_VAL_ONOFF=111,SQD_FLG_ONOFF='111',SQD_AUDIT_CD=now();
if (sqlValue("select count(*) from rep_soap_syndis_quality_data where SQD_DRS_ID=".$devID)==0)
{
//przeliczenie PP
unset($ppValue); unset($ppFlag); unset($hhValue); unset($hhFlag);
// ==============================================================================
if ($wl["wells"][$i]["pressureInPistonBody"]["value"]>0)
{
$ppValue = (float) $wl["wells"][$i]["pressureInPistonBody"]["value"];
$ppFlag = $wl["wells"][$i]["pressureInPistonBody"]["flag"];
}
else
{
$ppValue = (float) (($wl["wells"][$i]["pressureInPistonBodymA"]["value"] - 4) / 16 * $vpp - (($wl["wells"][$i]["barometricPressuremA"]["value"] * 10) / 98));
$ppFlag = $wl["wells"][$i]["pressureInPistonBodymA"]["flag"];
}
//przeliczanie HH
if ($wl["wells"][$i]["waterTablePosition"]["value"]>0)
{
$hhValue = (float) $wl["wells"][$i]["waterTablePosition"]["value"];
$hhFlag = $wl["wells"][$i]["waterTablePosition"]["flag"];
}
else
{
$hhValue = (float) (($wl["wells"][$i]["waterTablePositionmA"]["value"] - 4) / 16 * $vhh - (($wl["wells"][$i]["barometricPressuremA"]["value"] * 10) / 98));
$hhFlag = $wl["wells"][$i]["waterTablePositionmA"]["flag"];
}
// ==============================================================================
mysql_query("
INSERT INTO rep_soap_syndis_quality_data SET
SQD_DRS_ID=".$devID.",
SQD_OBJECT_NAME='".$wl["wells"][$i]["well"]["id"]."',
SQD_VAL_Q=".($wl["wells"][$i]["pumpEfficiency"]["value"] * 60).",
SQD_FLG_Q='".$wl["wells"][$i]["pumpEfficiency"]["flag"]."',
SQD_VAL_P1=".$wl["wells"][$i]["pressureBeforeThrottle"]["value"].",
SQD_FLG_P1='".$wl["wells"][$i]["pressureBeforeThrottle"]["flag"]."',
SQD_VAL_P2=".$wl["wells"][$i]["pressureAfterThrottle"]["value"].",
SQD_FLG_P2='".$wl["wells"][$i]["pressureAfterThrottle"]["flag"]."',
SQD_VAL_PE=".$wl["wells"][$i]["activePower"]["value"].",
SQD_FLG_PE='".$wl["wells"][$i]["activePower"]["flag"]."',
SQD_VAL_PP=".$ppValue.",
SQD_FLG_PP='".$ppFlag."',
SQD_VAL_HH=".$hhValue.",
SQD_FLG_HH='".$hhFlag."',
SQD_VAL_HD=".$wl["wells"][$i]["dynamicWaterTable"]["value"].",
SQD_FLG_HD='".$wl["wells"][$i]["dynamicWaterTable"]["flag"]."',
SQD_VAL_ONOFF=".$wl["wells"][$i]["pumpOnOff"]["value"].",
SQD_FLG_ONOFF='".$wl["wells"][$i]["pumpOnOff"]["flag"]."',
SQD_AUDIT_CD='".$scriptDate."'
");
}
else {
//przeliczenie PP
unset($ppValue); unset($ppFlag); unset($hhValue); unset($hhFlag);
// ==============================================================================
if ($wl["wells"][$i]["pressureInPistonBody"]["value"]>0)
{
$ppValue = (float) $wl["wells"][$i]["pressureInPistonBody"]["value"];
$ppFlag = $wl["wells"][$i]["pressureInPistonBody"]["flag"];
}
else
{
$ppValue = (float) (($wl["wells"][$i]["pressureInPistonBodymA"]["value"] - 4) / 16 * $vpp - (($wl["wells"][$i]["barometricPressuremA"]["value"] * 10) / 98));
$ppFlag = $wl["wells"][$i]["pressureInPistonBodymA"]["flag"];
}
//przeliczanie HH
if ($wl["wells"][$i]["waterTablePosition"]["value"]>0)
{
$hhValue = (float) $wl["wells"][$i]["waterTablePosition"]["value"];
$hhFlag = $wl["wells"][$i]["waterTablePosition"]["flag"];
}
else
{
$hhValue = (float) (($wl["wells"][$i]["waterTablePositionmA"]["value"] - 4) / 16 * $vhh - (($wl["wells"][$i]["barometricPressuremA"]["value"] * 10) / 98));
$hhFlag = $wl["wells"][$i]["waterTablePositionmA"]["flag"];
}
// ==============================================================================
mysql_query("
update rep_soap_syndis_quality_data SET
SQD_OBJECT_NAME='".$wl["wells"][$i]["well"]["id"]."',
SQD_VAL_Q=".($wl["wells"][$i]["pumpEfficiency"]["value"] * 60).",
SQD_FLG_Q='".$wl["wells"][$i]["pumpEfficiency"]["flag"]."',
SQD_VAL_P1=".$wl["wells"][$i]["pressureBeforeThrottle"]["value"].",
SQD_FLG_P1='".$wl["wells"][$i]["pressureBeforeThrottle"]["flag"]."',
SQD_VAL_P2=".$wl["wells"][$i]["pressureAfterThrottle"]["value"].",
SQD_FLG_P2='".$wl["wells"][$i]["pressureAfterThrottle"]["flag"]."',
SQD_VAL_PE=".$wl["wells"][$i]["activePower"]["value"].",
SQD_FLG_PE='".$wl["wells"][$i]["activePower"]["flag"]."',
SQD_VAL_PP=".$ppValue.",
SQD_FLG_PP='".$ppFlag."',
SQD_VAL_HH=".$hhValue.",
SQD_FLG_HH='".$hhFlag."',
SQD_VAL_HD=".$wl["wells"][$i]["dynamicWaterTable"]["value"].",
SQD_FLG_HD='".$wl["wells"][$i]["dynamicWaterTable"]["flag"]."',
SQD_VAL_ONOFF=".$wl["wells"][$i]["pumpOnOff"]["value"].",
SQD_FLG_ONOFF='".$wl["wells"][$i]["pumpOnOff"]["flag"]."',
SQD_AUDIT_CD='".$scriptDate."' where SQD_DRS_ID=".$devID
);
}
// ==============================================================================
}
if ($devID>0 && $wl["wells"][$i]["currentL1"]["flag"] == "CORRECT" && $wl["wells"][$i]["pumpEfficiency"]["flag"]=="CORRECT" && $wl["wells"][$i]["pressureInPistonBodymA"]["flag"]=="CORRECT")
{
if ($wl["wells"][$i]["pumpOnOff"]["value"]==1 && $wl["wells"][$i]["pumpEfficiency"]["value"]>0 && $wl["wells"][$i]["currentL1"]["value"]>0)
{
//prąd fazy L1 zasilania pompy
if (isNewestData($devID,270,$wl["wells"][$i]["currentL1"]["date"]))
update_new_record($devID, 270, $wl["wells"][$i]["currentL1"]["value"],$scriptDate);
//prąd fazy L2 zasilania pompy
if (isNewestData($devID,710,$wl["wells"][$i]["currentL2"]["date"]))
update_new_record($devID, 710, $wl["wells"][$i]["currentL2"]["value"],$scriptDate);
//prąd fazy L3 zasilania pompy
if (isNewestData($devID,711,$wl["wells"][$i]["currentL3"]["date"]))
update_new_record($devID, 711, $wl["wells"][$i]["currentL3"]["value"],$scriptDate);
//[voltageL12] => U L12 [V] - napięcie międzyfazowe L1-L2
if (isNewestData($devID,275,$wl["wells"][$i]["voltageL12"]["date"]))
update_new_record($devID, 275, $wl["wells"][$i]["voltageL12"]["value"],$scriptDate);
//[voltageL23] => U L23 [V] - napięcie międzyfazowe L2-L3
if (isNewestData($devID,712,$wl["wells"][$i]["voltageL23"]["date"]))
update_new_record($devID, 712, $wl["wells"][$i]["voltageL23"]["value"],$scriptDate);
//[throttlePosition] => Położenie przepustnicy [*]
if (isNewestData($devID,730,$wl["wells"][$i]["throttlePosition"]["date"]) && $wellType==19)
update_new_record($devID, 730, $wl["wells"][$i]["throttlePosition"]["value"],$scriptDate);
elseif (isNewestData($devID,730,$wl["wells"][$i]["throttlePosition"]["date"]) && $wellType==18)
{
$tmpDivP1P2=0;
$tmpDivP1P2 = ($wl["wells"][$i]["pressureAfterThrottle"]["value"] / $wl["wells"][$i]["pressureBeforeThrottle"]["value"]);
if ($tmpDivP1P2>0.93)
{
update_new_record($devID, 730, 100,$scriptDate);
$wl["wells"][$i]["throttlePosition"]["value"] = 100;
}
else
{
update_new_record($devID, 730, 50,$scriptDate);
$wl["wells"][$i]["throttlePosition"]["value"] = 50;
}
}
//[waterTemperature] => Tw [*C]
if (isNewestData($devID,245,$wl["wells"][$i]["waterTemperature"]["date"]))
update_new_record($devID, 245, $wl["wells"][$i]["waterTemperature"]["value"],$scriptDate);
//[so52v21ksoTemperature] => Temperatura sterownika [*C]
if (isNewestData($devID,720,$wl["wells"][$i]["so52v21ksoTemperature"]["date"]))
update_new_record($devID, 720, $wl["wells"][$i]["so52v21ksoTemperature"]["value"],$scriptDate);
//[activePower] => P [kW]
if (isNewestData($devID,260,$wl["wells"][$i]["activePower"]["date"]))
update_new_record($devID, 260, $wl["wells"][$i]["activePower"]["value"],$scriptDate);
//[cos] => cos(FI)
if (isNewestData($devID,280,$wl["wells"][$i]["cos"]["date"]))
update_new_record($devID, 280, $wl["wells"][$i]["cos"]["value"],$scriptDate);
//[activeEnergy] => E [kWh]
if (isNewestData($devID,265,$wl["wells"][$i]["activeEnergy"]["date"]))
update_new_record($devID, 265, $wl["wells"][$i]["activeEnergy"]["value"],$scriptDate);
//[pumpedWaterAmount] => V [m3]
if (isNewestData($devID,230,$wl["wells"][$i]["pumpedWaterAmount"]["date"]))
update_new_record($devID, 230, $wl["wells"][$i]["pumpedWaterAmount"]["value"],$scriptDate);
//[ClInPumpedWater] => ch [mg/l]
if (isNewestData($devID,719,$wl["wells"][$i]["ClInPumpedWater"]["date"]))
update_new_record($devID, 719, $wl["wells"][$i]["ClInPumpedWater"]["value"],$scriptDate);
//[energyConsumption] => Jednostkowe zużycie energii [kWh/m3/m]
if (isNewestData($devID,721,$wl["wells"][$i]["energyConsumption"]["date"]))
update_new_record($devID, 721, $wl["wells"][$i]["energyConsumption"]["value"],$scriptDate);
//[pumpRuntime] => t [h]
if (isNewestData($devID,290,$wl["wells"][$i]["pumpRuntime"]["date"]))
update_new_record($devID, 290, $wl["wells"][$i]["pumpRuntime"]["value"],$scriptDate);
//[dynamicWaterTable] => HD [m]
if ($wl["wells"][$i]["dynamicWaterTable"]["value"]>0 && isNewestData($devID,205,$wl["wells"][$i]["dynamicWaterTable"]["date"]))
update_new_record($devID, 205, $wl["wells"][$i]["dynamicWaterTable"]["value"],$scriptDate);
//[HdFromSetpoint] => Zadana wartość Hd od [m]
// update_new_record($devID, 722, $wl["wells"][$i]["HdFromSetpoint"]["value"],$scriptDate);
//[HdToSetpoint] => Zadana wartość Hd do [m]
// update_new_record($devID, 723, $wl["wells"][$i]["HdToSetpoint"]["value"],$scriptDate);
//[pressureBeforeThrottle] => p1 [kPa]
if (isNewestData($devID,215,$wl["wells"][$i]["pressureBeforeThrottle"]["date"]))
update_new_record($devID, 215, $wl["wells"][$i]["pressureBeforeThrottle"]["value"],$scriptDate);
//[pressureAfterThrottle] => p2 [kPa]
if (isNewestData($devID,220,$wl["wells"][$i]["pressureAfterThrottle"]["date"]))
update_new_record($devID, 220, $wl["wells"][$i]["pressureAfterThrottle"]["value"],$scriptDate);
//[barometricPressuremA] => Ciśnienie barometryczne pB[mA] - zakres 4-20
if (isNewestData($devID,225,$wl["wells"][$i]["barometricPressuremA"]["date"]))
update_new_record($devID, 225, $wl["wells"][$i]["barometricPressuremA"]["value"] * 10,$scriptDate);
//[pumpEfficiency] => Q [m3/min]
if (isNewestData($devID,200,$wl["wells"][$i]["pumpEfficiency"]["date"]))
update_new_record($devID, 200, $wl["wells"][$i]["pumpEfficiency"]["value"] * 60,$scriptDate);
//[QFromSetpoint] => Zadana wartość wydajności od [m3/min]
// update_new_record($devID, 724, $wl["wells"][$i]["QFromSetpoint"]["value"] * 60,$scriptDate);
//[QToSetpoint] => Zadana wartość wydajności do [m3/min]
// update_new_record($devID, 725, $wl["wells"][$i]["QToSetpoint"]["value"] * 60,$scriptDate);
//[QminSetpoint] => Zadana wartość minimalnej wydajności [m3/min]
// update_new_record($devID, 726, $wl["wells"][$i]["QminSetpoint"]["value"],$scriptDate);
//[currentDiagnosticsOperationState] => Działanie/niedziałanie [1/0] diagnostyki prądowej
if (isNewestData($devID,708,$wl["wells"][$i]["currentDiagnosticsOperationState"]["date"]))
update_new_record($devID, 708, $wl["wells"][$i]["currentDiagnosticsOperationState"]["value"],$scriptDate);
$bar = ($wl["wells"][$i]["barometricPressuremA"]["value"] * 10) / 98;
//[pressureInPistonBodymA] => pp [mA] - zakres 4-20
$pp_tmp = (($wl["wells"][$i]["pressureInPistonBodymA"]["value"] - 4) / 16 * $vpp - $bar);
if ($pp_tmp <0) $pp_tmp=0;
if (isNewestData($devID,401,$wl["wells"][$i]["pressureInPistonBodymA"]["date"]))
update_new_record($devID, 401, $pp_tmp,$scriptDate);
//[waterTablePositionmA] => HH [mA] - zakres 4-20
$hh_tmp = (($wl["wells"][$i]["waterTablePositionmA"]["value"] - 4) / 16 * $vhh - $bar);
if ($hh_tmp <0) $hh_tmp=0;
if (isNewestData($devID,402,$wl["wells"][$i]["waterTablePositionmA"]["date"]))
update_new_record($devID, 402, $hh_tmp,$scriptDate);
// wpisuje dane do tabeli major_data (logi + FastAccess)
//INSERT INTO seg_dev_major_data SET DRD_OBJECT_TYPE='WELL',DMD_DRS_ID=3134,DRD_OBJECT_NAME='G54',DRD_L1=1,DRD_L2=1,DRD_L3=1,DRD_U_L12=1,DRD_U_L23=1,DRD_THROTTLE=1,DRD_WATER_TEMP=1,DRD_POWER=1,DRD_COS_FI=1,DRD_ENERGY=1,DRD_WATER_PUMPED=1,DRD_RUN_TIME=1,DRD_HD=1,DRD_P1=1,DRD_P2=1,DRD_PB=1,DRD_Q=1,DRD_PP=1,DRD_HH=1,DRD_HST=1,DMD_WORK_STATUS='ON',DRD_AUDIT_CD=now()
mysql_query("INSERT INTO seg_dev_major_data SET DRD_OBJECT_TYPE='WELL',DMD_DRS_ID=".$devID.",DRD_OBJECT_NAME='".$wl["wells"][$i]["well"]["id"]."',DRD_L1=".$wl["wells"][$i]["currentL1"]["value"].",DRD_L2=".$wl["wells"][$i]["currentL2"]["value"].",DRD_L3=".$wl["wells"][$i]["currentL3"]["value"].",DRD_U_L12=".$wl["wells"][$i]["voltageL12"]["value"].",DRD_U_L23=".$wl["wells"][$i]["voltageL23"]["value"].",DRD_THROTTLE=".$wl["wells"][$i]["throttlePosition"]["value"].",DRD_WATER_TEMP=".$wl["wells"][$i]["waterTemperature"]["value"].",DRD_POWER=".$wl["wells"][$i]["activePower"]["value"].",DRD_COS_FI=".$wl["wells"][$i]["cos"]["value"].",DRD_ENERGY=".$wl["wells"][$i]["activeEnergy"]["value"].",DRD_WATER_PUMPED=".$wl["wells"][$i]["pumpedWaterAmount"]["value"].",DRD_RUN_TIME=".$wl["wells"][$i]["pumpRuntime"]["value"].",DRD_HD=".$wl["wells"][$i]["dynamicWaterTable"]["value"].",DRD_P1=".$wl["wells"][$i]["pressureBeforeThrottle"]["value"].",DRD_P2=".$wl["wells"][$i]["pressureAfterThrottle"]["value"].",DRD_PB=".($wl["wells"][$i]["barometricPressuremA"]["value"] * 10).",DRD_Q=".($wl["wells"][$i]["pumpEfficiency"]["value"] * 60).",DRD_PP=".$pp_tmp.",DRD_HH=".$hh_tmp.",DRD_HST=".$wl["wells"][$i]["staticWaterTable"]["value"].",DMD_WORK_STATUS='".$wl["wells"][$i]["pumpOnOff"]["value"]."',DRD_AUDIT_CD='".$scriptDate."'");
// wpisuje dane do tabeli odnośnie energochłonności
// ====================================================================== //
$getEnergyValue=null;
$qParam = $wl["wells"][$i]["pumpEfficiency"]["value"] * 60;
$resHD = $wl["wells"][$i]["dynamicWaterTable"]["value"];
$P2param = $wl["wells"][$i]["pressureAfterThrottle"]["value"];
$PEparam = $wl["wells"][$i]["activePower"]["value"];
if (empty($PEparam)) $PEparam=1;
$resETA = ($qParam*($resHD+$P2param))/(367*$PEparam);
$RedYellowParam = setRedYellowLimes(sqlValue("select PUP_Q_N from seg_pumps where PUP_ID=(select DRS_DEV_ID from seg_dev_resources where DRS_ID=(select RWL_PUP_DRS_ID from seg_dev_resources left join seg_well_pump_eng_rel on RWL_WLL_ID=DRS_DEV_ID where DRS_ID=".$devID."))"));
$YellowGreenParam = setYellowGreenLimes(sqlValue("select PUP_Q_N from seg_pumps where PUP_ID=(select DRS_DEV_ID from seg_dev_resources where DRS_ID=(select RWL_PUP_DRS_ID from seg_dev_resources left join seg_well_pump_eng_rel on RWL_WLL_ID=DRS_DEV_ID where DRS_ID=".$devID."))"));
if ($resETA<=$RedYellowParam)
$getEnergyValue = "R";
else if ($RedYellowParam<$resETA && $resETA<=$YellowGreenParam)
$getEnergyValue = "Y";
else if ($resETA>$YellowGreenParam)
$getEnergyValue = "G";
//mysql_query("INSERT INTO rep_dev_details SET RDD_DRS_ID=".$devID.",RDD_RESOURCES_DETAIL=729,RDD_VALUE='".$getEnergyValue."',RDD_AUDIT_USR='SYNDIS',RDD_AUDIT_DATE='".$scriptDate."'");
if (sqlValue("select count(1) from rep_soap_well_energy where SWE_DRS_ID=".$devID)>0)
mysql_query("UPDATE rep_soap_well_energy SET SWE_VALUE='".$getEnergyValue."',SWE_AUDIT_USR='SYNDIS',SWE_WORK_STATUS='".$wl["wells"][$i]["pumpOnOff"]["value"]."',SWE_AUDIT_DATE='".$scriptDate."' WHERE SWE_DRS_ID=".$devID);
else
mysql_query("INSERT INTO rep_soap_well_energy SET SWE_DRS_ID=".$devID.",SWE_WELL_ID=".$wellID.",SWE_NAME='".$wl["wells"][$i]["well"]["id"]."',SWE_VALUE='".$getEnergyValue."',SWE_AUDIT_USR='SYNDIS',SWE_WORK_STATUS='".$wl["wells"][$i]["pumpOnOff"]["value"]."',SWE_AUDIT_DATE='".$scriptDate."'");
// ====================================================================== //
}
//[staticWaterTable] => HST [m]
//update_new_record($devID, 210, $wl["staticWaterTable"]["value"],$scriptDate);
//echo"currentL1: ".$wl["currentL1"]["value"]."";
// log do bazy
//mysql_query("INSERT INTO sys_syndis_logs SET SYL_WELL='" . $wName . "',SYL_CURRENTL1='" . $wl["currentL1"]["value"] . "',SYL_CURRENTL2='" . $wl["currentL2"]["value"] . "',SYL_CURRENTL3='" . $wl["currentL3"]["value"] . "',SYL_VOLTAGEL12='" . $wl["voltageL12"]["value"] . "',SYL_VOLTAGEL23='" . $wl["voltageL23"]["value"] . "',SYL_ACTIVEPOWER='" . $wl["activePower"]["value"] . "',SYL_COS='" . $wl["cos"]["value"] . "',SYL_ACTIVEENERGY='" . $wl["activeEnergy"]["value"] . "',SYL_WATERTEMPERATURE='" . $wl["waterTemperature"]["value"] . "',SYL_CLINPUMPEDWATER='" . $wl["ClInPumpedWater"]["value"] . "',SYL_CURRENTDIAGNOSTICS='" . $wl["currentDiagnosticsOperationState"]["value"] . "',SYL_STATICWATERTABLE='" . $wl["staticWaterTable"]["value"] . "',SYL_DYNAMICWATERTABLE='" . $wl["dynamicWaterTable"]["value"] . "',SYL_PRESSUREBEFORETHROTTLEMA='" . $wl["pressureBeforeThrottlemA"]["value"] . "',SYL_PRESSUREAFTERTHROTTLEMA='" . $wl["pressureAfterThrottlemA"]["value"] . "',SYL_PRESSUREINPISTONBODYMA='" . $wl["pressureInPistonBodymA"]["value"] . "',SYL_PUMPEFFICIENCYMA='" . $wl["pumpEfficiencymA"]["value"] . "',SYL_WATERTABLEPOSITIONMA='" . $wl["waterTablePositionmA"]["value"] . "',SYL_BAROMETRICPRESSUREMA='" . $wl["barometricPressuremA"]["value"] . "',SYL_DATA='" . $scriptDate . "'");
}
else
{
echo"Dane InCorrect ";
}
// aktualizauje status pomiaru
mysql_query("UPDATE rep_soap_well_energy SET SWE_WORK_STATUS='".$wl["wells"][$i]["currentL1"]["flag"]."' WHERE SWE_NAME='".$wl["wells"][$i]["well"]["id"]."'");
/*
![well] => nazwa studni, np. "G50"
![piezometer] => nazwa piezometru, np. "PS-110-1"
![staticWaterTable] => HST [m]
*/
//echo"";
}
mysql_close($polacz);
echo 'finish processing ...
';
echo 'Finish: '.date("Y-m-d H:i:s").'
';
/**
*
*echo "
---------------------------------
";
*print_r($cl->GetWellDataAsArray('PUMP23')); //Pobieranie danych jednej pompy - zwraca dane jako tablica
*
*echo "
---------------------------------
Indeksy piezometru";
*print_r($cl->GetPiezometerData('PIEZO23')); //Pobieranie danych jednego piezometru - zwraca dane jako obiekt
*
*echo "
---------------------------------
";
*var_dump($cl->GetPiezometerDataAsArray('PIEZO23')); //Pobieranie danych jednego piezometru - zwraca dane jako tablice
*
*echo "
---------------------------------
";
*var_dump($cl->GetWellsDataAsArray(array('PUMP23','PUMP24'))); //retruns associate array
*
*echo "
---------------------------------
";
*v8ar_dump($cl->GetPiezometersDataAsArray(array('PUMP23','PUMP24'))); //retruns associate array
*/
?>