454 lines
24 KiB
PHP
454 lines
24 KiB
PHP
<META HTTP-EQUIV="Content-type" CONTENT="text/html; charset=utf-8">
|
|
<?php
|
|
error_reporting(E_ALL);
|
|
echo 'starting ...<br>';
|
|
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 ...<br>';
|
|
echo 'Start: '.date("Y-m-d H:i:s").'<br>';
|
|
|
|
$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"</br>";
|
|
}
|
|
|
|
|
|
|
|
|
|
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;
|
|
}
|
|
|
|
function convertData($insertDate)
|
|
{
|
|
unset($res);
|
|
$res = str_replace(array('T','Z'), array(' ',''),$insertDate);
|
|
|
|
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<count($wl["wells"]); $i++)
|
|
{
|
|
//echo "Name: ". $wl["wells"][$i]["well"]["id"]."<br/>";
|
|
|
|
$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"];
|
|
|
|
$ppValue = (float) ($ppValue - (($wl["wells"][$i]["barometricPressuremA"]["value"]*10)/98));
|
|
}
|
|
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
|
|
unset($lpValue);
|
|
$lpValue = (float) sqlStringValue("select getLastValue(240,".$devID.") HHV", "HHV");
|
|
$hhValue = (float) $lpValue - ($wl["wells"][$i]["dynamicWaterTable"]["value"]);
|
|
$hhFlag = $wl["wells"][$i]["dynamicWaterTable"]["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"];
|
|
|
|
$ppValue = (float) ($ppValue - (($wl["wells"][$i]["barometricPressuremA"]["value"]*10)/98));
|
|
}
|
|
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
|
|
unset($lpValue);
|
|
$lpValue = (float) sqlStringValue("select getLastValue(240,".$devID.") HHV", "HHV");
|
|
$hhValue = (float) $lpValue - ($wl["wells"][$i]["dynamicWaterTable"]["value"]);
|
|
$hhFlag = $wl["wells"][$i]["dynamicWaterTable"]["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);
|
|
|
|
|
|
$pp_tmp = $ppValue;
|
|
if (isNewestData($devID,401,$wl["wells"][$i]["pressureInPistonBodymA"]["date"]))
|
|
update_new_record($devID, 401, $pp_tmp,$scriptDate);
|
|
|
|
$hh_tmp = $hhValue;
|
|
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";
|
|
|
|
if ($wellType==20) $getEnergyValue = "NN";
|
|
|
|
//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"]."</br>";
|
|
|
|
// 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 </br>";
|
|
|
|
}
|
|
|
|
|
|
// 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"</br></br>";
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
mysql_close($polacz);
|
|
echo 'finish processing ...<br>';
|
|
echo 'Finish: '.date("Y-m-d H:i:s").'<br>';
|
|
|
|
/**
|
|
*
|
|
*echo "</pre><br>---------------------------------<br><pre>";
|
|
*print_r($cl->GetWellDataAsArray('PUMP23')); //Pobieranie danych jednej pompy - zwraca dane jako tablica
|
|
*
|
|
*echo "</pre><br>---------------------------------<br>Indeksy piezometru<pre>";
|
|
*print_r($cl->GetPiezometerData('PIEZO23')); //Pobieranie danych jednego piezometru - zwraca dane jako obiekt
|
|
*
|
|
*echo "</pre><br>---------------------------------<br>";
|
|
*var_dump($cl->GetPiezometerDataAsArray('PIEZO23')); //Pobieranie danych jednego piezometru - zwraca dane jako tablice
|
|
*
|
|
*echo "</pre><br>---------------------------------<br><pre>";
|
|
*var_dump($cl->GetWellsDataAsArray(array('PUMP23','PUMP24'))); //retruns associate array
|
|
*
|
|
*echo "</pre><br>---------------------------------<br><pre>";
|
|
*v8ar_dump($cl->GetPiezometersDataAsArray(array('PUMP23','PUMP24'))); //retruns associate array
|
|
*/
|
|
|
|
|
|
?>
|