Online PHP Javascript Script Decoder

Online PHP and Javascript Decoder decode hidden script to uncover its real functionality

Original code:

<?php
 use VDV\datasource_file_import\model\TimeZoneShifter; $path = realpath(dirname(__FILE__) . "\x2f\x2e\56\57\56\x2e\x2f\56\56\57\x2e\56\x2f\166\x64\x76\137\167\x77\x77"); require_once $path . "\57\143\x6f\155\x70\x6f\x6e\145\x6e\164\x73\x2f\166\x64\166\57\144\141\x74\x61\x73\x6f\x75\162\143\x65\x5f\146\151\x6c\145\137\151\155\x70\x6f\x72\x74\x2f\155\x6f\144\x65\154\x2f\106\x69\x6c\145\120\141\162\x73\145\x72\56\x70\x68\160"; require_once $path . "\x2f\x63\x6f\155\x70\x6f\156\145\x6e\164\x73\x2f\166\x64\x76\57\144\141\x74\x61\163\157\x75\162\x63\x65\x5f\146\151\x6c\x65\137\151\x6d\160\157\x72\x74\57\155\157\x64\145\154\x2f\x46\164\160\114\x6f\x63\141\164\x69\x6f\156\x44\142\56\x70\150\160"; set_time_limit(0); class FileImporter extends Worker { private $filePath; private $fileId; private $fileName; private $formatId; private $fileContent; private $ftp; private $ftp_user; private $ftp_password; private $lastModificationTime; private $parser; private $directoryInfo; private $oldLastModTime; private $lastModTime; private $oldLastTimeStamp; private $lastTimeStamp; private $fileInfo; private $Username; private $Password; private $DbName; private $Host; private $Portnumber; private $chunkSize; private $dataDesc = 0; private $timeStart; private $type; private $calibrationFilename; private $serial; private $saaType; private $saaUnits; private $saaAzimuth; private $saaReference; private $convergence; private $saaSections; private $siteTimeZoneId = 0; private $siteShiftTimeZoneId = 0; public function __construct($fileInfo, $format, $index) { global $DbName, $Username, $Password, $Host, $Portnumber; $this->Username = $Username; $this->Password = $Password; $this->DbName = $DbName; $this->Host = $Host; $this->Portnumber = $Portnumber; if ($fileInfo["\146\164\160"] == 1) { $locationDb = new FtpLocationDb(); $fileInfo["\x66\164\x70\137\160\x61\163\x73\167\157\162\x64"] = $locationDb->decrypt($fileInfo["\146\x74\160\137\x70\141\163\x73\167\157\162\x64"]); } if ($fileInfo["\x74\171\160\x65"] === "\x53\x41\x41") { $format->setType($fileInfo["\164\x79\160\x65"]); } $this->fileName = $fileInfo["\x6e\141\155\x65"]; $this->fileId = $fileInfo["\x66\151\x6c\x65\x49\144"]; $this->ftp = $fileInfo["\x66\164\x70"]; $this->ftp_user = $fileInfo["\146\164\160\x5f\x75\163\145\x72"]; $this->ftp_password = $fileInfo["\x66\x74\160\137\160\141\x73\163\x77\157\x72\144"]; $this->locationName = $fileInfo["\x6c\x6f\143\141\x74\151\157\156\x4e\x61\x6d\145"]; $this->location = $fileInfo["\x70\x61\164\150"]; $this->formatId = $fileInfo["\146\157\162\155\141\164\111\144"]; $this->format = $format; $this->directoryInfo = $fileInfo; $this->filePath = $fileInfo["\x66\151\x6c\x65\120\x61\164\x68"]; $this->oldLastModTime = $fileInfo["\x6c\x61\163\x74\115\157\144\151\x66\151\143\141\164\151\x6f\156\124\x69\155\145"]; $this->oldLastTimeStamp = $fileInfo["\154\x61\163\x74\x44\x61\x74\141"]; $this->fileInfo = $fileInfo; $this->detectedEncoding = mb_detect_encoding($this->fileInfo["\146\x69\154\145\x50\162\x65\x66\x69\170"]); $this->fileInfo["\x66\x69\x6c\x65\120\162\x65\x66\x69\170"] = mb_convert_encoding($this->fileInfo["\x66\x69\154\x65\120\x72\145\x66\x69\170"], $this->detectedEncoding, "\125\124\x46\55\70"); $this->datFilePath = $fileInfo["\146\x69\x6c\x65\137\160\141\x74\x68"]; $this->index = $index; $this->chunkSize = $this->fileInfo["\x69\x6e\x63\162\145\x6d\145\156\x74\141\x6c"] == 0 ? 10000 : 10; $this->dataDesc = $this->format->getProperty("\x64\141\x74\141\104\x65\163\143"); $this->timeStart = microtime(true); $this->siteTimeZoneId = intval($fileInfo["\164\x69\155\145\172\157\156\x65\137\x69\x64"]); $this->siteShiftTimeZoneId = intval($fileInfo["\163\150\x69\146\164\x54\151\x6d\145\x5a\x6f\156\145\x49\144"]); $this->format->columnCount = $this->getTableColumns(); $this->type = $fileInfo["\164\171\x70\145"]; $this->calibrationFilename = $fileInfo["\143\141\154\x69\142\162\141\x74\151\157\x6e\106\151\154\x65\156\141\155\145"]; $this->serial = $fileInfo["\x73\145\162\x69\141\154"]; $this->saaType = $fileInfo["\163\141\141\x54\171\160\145"]; $this->saaUnits = $fileInfo["\163\x61\141\125\x6e\x69\164\x73"]; $this->saaAzimuth = $fileInfo["\x73\x61\141\101\x7a\151\x6d\x75\164\x68"]; $this->saaReference = $fileInfo["\163\x61\x61\122\145\x66\145\162\x65\x6e\143\x65"]; $this->convergence = $fileInfo["\143\x6f\x6e\166\145\162\147\x65\x6e\143\145"]; $this->saaSections = $fileInfo["\163\145\143\164\151\157\x6e\163"]; } public function run() { echo $this->fileName . "\x20\x73\x74\x61\x72\x74\x65\x64" . "\12"; $this->checkIfDatFileExistsAndIfNotCreate(); if ($this->type === "\123\101\x41" && $this->saaType === null) { $this->setFileNotInProgress($this->fileId); return; } $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, $this->chunkSize, null); $fileMtime = $this->fileInfo["\x69\156\x63\162\x65\155\x65\156\x74\141\154"] == 0 ? $parser->checkFileModificationTime() : 0; $this->lastModTime = $this->fileInfo["\151\156\143\162\x65\x6d\145\x6e\164\141\154"] == 0 ? gmdate("\131\x2d\x6d\x2d\144\40\x48\x3a\151\x3a\x73", $fileMtime) : date("\131\55\155\x2d\x64\x20\x48\x3a\151\72\x73"); $lt = null; if ($this->format->getProperty("\x69\163\x4a\163\157\x6e") == true) { $parsedArray = []; $data = $parser->getDataJson(false); foreach ($data as $dataLine) { if ($this->fileInfo["\154\x61\x73\x74\x5f\x74\x69\x6d\145\163\164\141\x6d\x70"] >= $dataLine[0]) { continue; } $dataLine[0] = "\42" . $dataLine[0] . "\x22"; array_splice($dataLine, 1, 0, "\x30"); array_push($parsedArray, implode("\54", $dataLine)); } if (count($parsedArray) > 0) { $this->getNewJsonData($parser, $parsedArray); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); } else { $this->updateFile($this->fileId, $this->oldLastModTime, $this->oldLastTimeStamp); } echo "\111\x6d\x70\157\162\x74\145\x64\x20" . count($parsedArray) . "\x20\154\x69\x6e\x65\163\40\146\162\x6f\x6d\x20" . $this->fileName . "\40\151\x6e\40" . round(microtime(true) - $this->timeStart, 1) . "\40\163\x65\143\157\x6e\144\163" . "\12"; return true; } if ($this->oldLastModTime == "\x30\60\60\x30\x2d\60\60\x2d\60\x30\40\60\60\72\60\60\x3a\60\60" || $this->oldLastModTime == null) { if ($this->fileInfo["\x69\x6e\143\x72\x65\155\145\156\x74\x61\154"] == 0) { $parser->parse(); } $data = $parser->getData(); if ($this->dataDesc == 1) { $this->convertDataToDesc($data); } $dataCount = count($data); $this->lastTimeStamp = $parser->getLastTimestamp(); $this->oldLastTimeStamp = $this->lastTimeStamp; $printData = implode("\xd\12", $data); $this->performWrite($this->datFilePath, $printData); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); if ($dataCount >= $this->chunkSize || $this->fileInfo["\x69\x6e\x63\162\145\x6d\145\156\x74\x61\x6c"] == 1) { $this->oldLastModTime = "\61\x39\x37\60\x2d\x30\x31\x2d\60\x31\x20\x30\x30\x3a\x30\x30\x3a\60\60"; $this->getNewData($this->chunkSize, $parser->getParsedIndex()); } echo "\111\x6d\x70\x6f\162\x74\145\144\40" . count($data) . "\x20\x6c\x69\156\x65\163\x20\x66\162\x6f\x6d\x20" . $this->fileName . "\x20\151\x6e\40" . round(microtime(true) - $this->timeStart, 1) . "\40\x73\145\143\157\x6e\144\x73" . "\xa"; } else { $this->getNewData(1000, null); } } private function getNewJsonData($parser, $newData) { $this->lastTimeStamp = $parser->getLastTimestamp(); $datFPath = mb_convert_encoding($this->datFilePath, "\x49\x53\117\x2d\x38\x38\65\71\55\x31", "\125\124\x46\x2d\x38"); $printData = implode("\xd\12", $newData); $this->performWrite($datFPath, $printData); } private function getNewData($chunkSize, $parsedIndex) { if ($this->lastModTime > $this->oldLastModTime || $this->fileInfo["\x69\156\x63\162\x65\x6d\x65\x6e\x74\141\x6c"] == 1) { $oldLastTimestamp = $this->oldLastTimeStamp; do { if ($this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); $shiftedTimeZone = $timezoneShifter->convertBackFromTimeZones($this->oldLastTimeStamp); $this->oldLastTimeStamp = $shiftedTimeZone; } $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, $chunkSize, $parsedIndex); $newData = $parser->getNewData($this->oldLastTimeStamp); $newDataCount = count($newData); if ($newDataCount > 0) { if ($this->fileInfo["\x6f\x76\145\162\162\151\x64\145\104\x61\x74\141"] == 1) { $newData = $this->writeToDatabase($newData); } if (count($newData) > 0) { $printData = implode("\15\12", $newData); $this->lastTimeStamp = $parser->getLastTimestamp(); $this->oldLastTimeStamp = $this->lastTimeStamp; $datFPath = mb_convert_encoding($this->datFilePath, "\111\x53\x4f\x2d\x38\x38\65\x39\x2d\x31", "\125\x54\x46\x2d\70"); $this->performWrite($datFPath, $printData); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); } echo "\111\155\x70\x6f\x72\164\145\144\40" . count($newData) . "\40\x6c\x69\x6e\145\163\x20\146\162\x6f\155\40" . $this->fileName . "\x20\x69\x6e\40" . round(microtime(true) - $this->timeStart, 1) . "\40\163\145\143\157\156\144\x73" . "\12"; } else { $this->updateFile($this->fileId, $this->oldLastModTime, $oldLastTimestamp); break; } $parsedIndex = $parser->getParsedIndex(); } while ($newDataCount >= $chunkSize); } else { $this->updateFile($this->fileId, $this->oldLastModTime, $this->oldLastTimeStamp); } } private function convertDataToDesc(array &$data) { $data = array_reverse($data, false); } private function getFileInfo() { return array("\163\151\172\x65" => filesize($this->filePath), "\154\141\x73\164\x4d\157\144\151\x66\x69\145\144" => filemtime($this->filePath)); } public function getMTime() { return filemtime($this->directoryInfo["\160\x61\x74\150"] . $this->filePath); } private function checkIfDatFileExistsAndIfNotCreate() { $isSensorData = $this->format->isSensorData(); if (!file_exists($this->datFilePath) && $isSensorData === false) { $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, null, null); $parser->parse(); $header = $parser->getDatHeader(); $header = explode("\54", $header); $header = str_replace("\x22", '', $header); $parser->openDatFile($this->datFilePath, $header); } } private function performWrite($datFilePath, $data) { if ($this->type === "\x53\x41\x41") { $isFirstParse = $this->oldLastModTime == "\x30\x30\60\60\55\60\60\55\60\x30\x20\60\60\x3a\x30\x30\x3a\x30\x30" || $this->oldLastModTime == null; $path = realpath(dirname(__FILE__) . "\x2f\x2e\x2e\57\x2e\56\x2f\56\56\57\x2e\56\x2f\166\144\x76\137\167\167\167"); require_once $path . "\x2f\143\x6f\155\x70\157\x6e\145\156\x74\x73\57\166\144\x76\x2f\144\141\164\x61\x73\157\x75\162\143\145\x5f\163\141\141\57\155\x6f\144\145\x6c\x2f\123\x41\x41\x43\157\x6c\154\x65\143\x74\x6f\162\x2e\x70\x68\x70"; require_once $path . "\x2f\x63\157\x6d\160\157\x6e\x65\x6e\164\163\x2f\166\144\166\57\144\x61\164\x61\163\x6f\x75\162\143\x65\x5f\163\141\141\x2f\x6d\x6f\x64\x65\x6c\x2f\x43\162\x65\141\164\145\123\x69\x74\x65\x46\x69\154\x65\x46\x6f\162\123\x41\101\x2e\160\x68\160"; $saaCollector = new \vdv\datasource_saa\model\SAACollector($datFilePath); $saaCollector->setCalibrationFile($this->calibrationFilename); $saaCollector->setSettings($this->saaType, $this->saaUnits, $this->saaAzimuth, $this->saaReference, $this->convergence, $this->saaSections, $isFirstParse); $saaCollector->setSerial($this->serial); $data = $saaCollector->parseData($data); } if ($this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); $data = $timezoneShifter->convertDatStringFromFileImport($data); $latestTimestamp = $timezoneShifter->getLatestTimestamp(); $this->oldLastTimeStamp = $latestTimestamp; $this->lastTimeStamp = $latestTimestamp; $this->updateFile($this->fileId, $this->lastModificationTime, $latestTimestamp); } $isTimeZone = $this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId; if ($this->type === "\123\x41\101" && $isTimeZone === false) { $this->writeToFile($datFilePath, $data); } else { $this->writeToFile($datFilePath, $data); $this->writeToFile($datFilePath, "\xd\12"); } } private function writeToFile($filename, $text_data) { $error_code = 0; if (is_writable($filename)) { if (!($handle = fopen($filename, "\141"))) { $error_code = 1; } else { if (fwrite($handle, $text_data) === FALSE) { $error_code = 2; } else { } fclose($handle); } } else { $error_code = 3; } return $error_code; } private function writeToDatabase($data) { $stationId = $this->fileInfo["\x73\164\x61\164\x69\x6f\x6e\111\144"]; $db = new PDO("\155\171\163\x71\154\72\150\157\163\x74\75{$this->Host}\73\x70\157\x72\x74\x3d{$this->Portnumber}\x3b\144\142\x6e\141\x6d\x65\x3d{$this->DbName}", $this->Username, $this->Password); $sql = "\163\145\154\x65\143\x74\40\52\x20\146\x72\x6f\x6d\40\x76\x61\162\x69\141\142\154\x65\x5f\151\x6e\x66\x6f\40\x57\x48\x45\x52\105\x20\x73\164\141\164\151\x6f\156\x5f\x69\x64\x20\75\x20\x3a\x73\164\141\x74\151\x6f\x6e\111\x64\x20\101\x4e\104\40\50\143\141\154\x63\165\154\141\x74\145\144\x5f\166\x61\x72\151\x61\142\x6c\145\40\151\163\40\x4e\x55\x4c\114\40\x4f\x52\40\x63\x61\154\x63\x75\154\x61\x74\x65\144\137\x76\x61\162\151\141\142\x6c\145\x20\75\40\x30\x29\x20\x4f\122\104\x45\x52\40\x42\131\40\146\x69\154\x65\x5f\x63\x6f\154\137\x6e\x75\x6d\142\x65\x72"; $stmt = $db->prepare($sql); $stmt->execute(["\x3a\x73\x74\x61\164\151\x6f\156\x49\144" => $stationId]); $variables = $stmt->fetchAll(PDO::FETCH_ASSOC); $lastTimestamp = $this->fileInfo["\154\x61\x73\x74\x5f\164\151\155\x65\x73\164\141\x6d\160"]; $columnNames = array_column($variables, "\x64\x62\x5f\143\157\x6c\137\156\x61\155\145"); $isTimeZoneShift = $this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId; if ($isTimeZoneShift === true) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); } foreach ($data as $key => $line) { $dataLine = explode("\x2c", $line); $timestamp = str_replace("\x22", '', $dataLine[0]); if ($isTimeZoneShift === true) { $timestamp = $timezoneShifter->convertBetweenTimeZones($timestamp); } if ($timestamp <= $lastTimestamp) { unset($dataLine[0]); unset($dataLine[1]); $dataLine = array_values($dataLine); $this->saveDbLineToDatabase($timestamp, $dataLine, $columnNames, $db); unset($data[$key]); } } return array_values($data); } private function saveDbLineToDatabase($timestamp, $line, $columns, $db) { $sqlArray = []; if (count($columns) === count($line)) { $line = array_values($line); $columns = array_values($columns); $sqlArray = array_combine($columns, $line); } $query = "\125\120\x44\101\x54\105\x20" . $this->fileInfo["\164\x61\x62\154\145\137\156\141\155\x65"] . "\x20\123\x45\124\x20"; end($sqlArray); $lastKey = key($sqlArray); foreach ($sqlArray as $column => $value) { if (is_numeric($value)) { $query .= $column . "\x20\75\x20" . $value; } else { $query .= $column . "\40\x3d\40\x6e\165\x6c\154"; } if ($column !== $lastKey) { $query .= "\54\40"; } } $query .= "\x20\127\110\105\x52\x45\40\164\x69\x6d\145\x5f\163\x74\x61\155\160\40\75\40\x3a\x74\151\x6d\x65\x73\x74\141\x6d\160"; $stmt = $db->prepare($query); $stmt->execute(["\72\164\x69\155\x65\x73\164\141\155\160" => $timestamp]); } private function updateFile($fileId, $lastModificationTime, $lastTimeStamp) { $Host = $this->Host; $Port = $this->Portnumber; $DbName = $this->DbName; $db = new PDO("\155\171\x73\x71\x6c\x3a\150\157\x73\164\x3d{$Host}\73\160\157\162\x74\75{$Port}\73\x64\x62\156\141\x6d\145\75{$DbName}", $this->Username, $this->Password); $query = "\x55\120\104\x41\124\105\40\144\x61\164\x61\x5f\x73\157\x75\162\x63\145\x5f\146\151\154\145\x20\123\x45\x54\40\154\141\163\164\x4d\157\144\x69\x66\x69\143\141\164\151\x6f\x6e\124\151\155\145\x20\75\40\x3a\x6c\x61\163\164\115\157\x64\x69\x66\151\x63\x61\x74\x69\157\x6e\124\x69\x6d\x65\x2c\x20\xd\xa\x20\40\40\x20\x20\x20\40\x20\154\141\163\164\104\x61\x74\141\40\75\40\72\154\x61\163\164\x44\141\x74\141\54\xd\xa\40\x20\40\x20\x20\x20\x20\x20\x69\156\120\162\157\147\162\x65\163\163\x20\x3d\x20\x30\xd\xa\40\x20\x20\40\x20\40\x20\x20\127\x48\105\x52\105\40\151\x64\x20\75\x20\x3a\151\x64"; $stmt = $db->prepare($query); $stmt->execute(array("\x3a\151\x64" => $fileId, "\x3a\x6c\x61\163\164\x4d\x6f\x64\x69\146\x69\x63\x61\164\x69\x6f\156\x54\x69\x6d\145" => $lastModificationTime, "\72\154\141\x73\x74\x44\141\164\141" => $lastTimeStamp)); if ($stmt->errorInfo()["\60"] != "\60\60\x30\60\60") { print_r($stmt->errorInfo()); } } private function setFileNotInProgress($fileId) { $Host = $this->Host; $Port = $this->Portnumber; $DbName = $this->DbName; $db = new PDO("\155\x79\x73\x71\154\x3a\x68\x6f\x73\164\x3d{$Host}\73\160\157\162\164\x3d{$Port}\x3b\x64\142\x6e\141\x6d\145\75{$DbName}", $this->Username, $this->Password); $query = "\125\x50\104\101\x54\105\x20\144\141\x74\x61\x5f\163\157\x75\x72\x63\145\137\146\151\x6c\145\x20\123\105\124\40\151\156\x50\x72\157\147\x72\x65\163\163\x20\75\x20\60\x20\127\x48\105\122\x45\x20\151\x64\40\x3d\40\x3a\151\x64"; $stmt = $db->prepare($query); $stmt->execute(array("\72\x69\x64" => $fileId)); if ($stmt->errorInfo()["\x30"] != "\x30\x30\x30\x30\x30") { print_r($stmt->errorInfo()); } } private function getTableColumns() { $db = new PDO("\155\x79\x73\x71\x6c\x3a\150\157\163\164\75{$this->Host}\x3b\x70\157\x72\164\x3d{$this->Portnumber}\x3b\x64\142\156\141\155\145\x3d{$this->DbName}", $this->Username, $this->Password); $sql = "\123\x45\x4c\105\103\x54\40\143\157\165\x6e\164\x28\52\51\40\141\x73\x20\143\157\154\165\155\156\103\157\165\x6e\x74\xd\xa\x20\40\40\x20\40\x20\x20\x20\106\x52\x4f\x4d\x20\x69\156\146\x6f\162\155\141\x74\x69\x6f\156\137\163\x63\x68\x65\155\x61\56\x63\157\154\165\155\x6e\163\15\xa\x20\x20\x20\40\x20\40\40\40\127\x48\x45\122\x45\x20\x74\141\x62\154\x65\x5f\x6e\x61\155\145\x20\x3d\x20\72\164\141\142\x6c\145\x5f\156\x61\x6d\145"; $stmt = $db->prepare($sql); $stmt->execute(array("\x3a\x74\141\x62\x6c\x65\137\x6e\x61\x6d\x65" => $this->fileInfo["\164\141\x62\x6c\x65\x5f\x6e\x61\x6d\145"])); $columnCount = $stmt->fetch(PDO::FETCH_ASSOC)["\143\x6f\x6c\165\x6d\x6e\x43\157\x75\x6e\x74"]; return intval($columnCount) - 2; } }

Show other level

Decrypted code level 1:

use VDV\datasource_file_import\model\TimeZoneShifter; $path = realpath(dirname(__FILE__) . "/../../../../vdv_www"); require_once $path . "/components/vdv/datasource_file_import/model/FileParser.php"; require_once $path . "/components/vdv/datasource_file_import/model/FtpLocationDb.php"; set_time_limit(0); class FileImporter extends Worker { private $filePath; private $fileId; private $fileName; private $formatId; private $fileContent; private $ftp; private $ftp_user; private $ftp_password; private $lastModificationTime; private $parser; private $directoryInfo; private $oldLastModTime; private $lastModTime; private $oldLastTimeStamp; private $lastTimeStamp; private $fileInfo; private $Username; private $Password; private $DbName; private $Host; private $Portnumber; private $chunkSize; private $dataDesc = 0; private $timeStart; private $type; private $calibrationFilename; private $serial; private $saaType; private $saaUnits; private $saaAzimuth; private $saaReference; private $convergence; private $saaSections; private $siteTimeZoneId = 0; private $siteShiftTimeZoneId = 0; public function __construct($fileInfo, $format, $index) { global $DbName, $Username, $Password, $Host, $Portnumber; $this->Username = $Username; $this->Password = $Password; $this->DbName = $DbName; $this->Host = $Host; $this->Portnumber = $Portnumber; if ($fileInfo["ftp"] == 1) { $locationDb = new FtpLocationDb(); $fileInfo["ftp_password"] = $locationDb->decrypt($fileInfo["ftp_password"]); } if ($fileInfo["type"] === "SAA") { $format->setType($fileInfo["type"]); } $this->fileName = $fileInfo["name"]; $this->fileId = $fileInfo["fileId"]; $this->ftp = $fileInfo["ftp"]; $this->ftp_user = $fileInfo["ftp_user"]; $this->ftp_password = $fileInfo["ftp_password"]; $this->locationName = $fileInfo["locationName"]; $this->location = $fileInfo["path"]; $this->formatId = $fileInfo["formatId"]; $this->format = $format; $this->directoryInfo = $fileInfo; $this->filePath = $fileInfo["filePath"]; $this->oldLastModTime = $fileInfo["lastModificationTime"]; $this->oldLastTimeStamp = $fileInfo["lastData"]; $this->fileInfo = $fileInfo; $this->detectedEncoding = mb_detect_encoding($this->fileInfo["filePrefix"]); $this->fileInfo["filePrefix"] = mb_convert_encoding($this->fileInfo["filePrefix"], $this->detectedEncoding, "UTF-8"); $this->datFilePath = $fileInfo["file_path"]; $this->index = $index; $this->chunkSize = $this->fileInfo["incremental"] == 0 ? 10000 : 10; $this->dataDesc = $this->format->getProperty("dataDesc"); $this->timeStart = microtime(true); $this->siteTimeZoneId = intval($fileInfo["timezone_id"]); $this->siteShiftTimeZoneId = intval($fileInfo["shiftTimeZoneId"]); $this->format->columnCount = $this->getTableColumns(); $this->type = $fileInfo["type"]; $this->calibrationFilename = $fileInfo["calibrationFilename"]; $this->serial = $fileInfo["serial"]; $this->saaType = $fileInfo["saaType"]; $this->saaUnits = $fileInfo["saaUnits"]; $this->saaAzimuth = $fileInfo["saaAzimuth"]; $this->saaReference = $fileInfo["saaReference"]; $this->convergence = $fileInfo["convergence"]; $this->saaSections = $fileInfo["sections"]; } public function run() { echo $this->fileName . " started
"; $this->checkIfDatFileExistsAndIfNotCreate(); if ($this->type === "SAA" && $this->saaType === null) { $this->setFileNotInProgress($this->fileId); return; } $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, $this->chunkSize, null); $fileMtime = $this->fileInfo["incremental"] == 0 ? $parser->checkFileModificationTime() : 0; $this->lastModTime = $this->fileInfo["incremental"] == 0 ? gmdate("Y-m-d H:i:s", $fileMtime) : date("Y-m-d H:i:s"); $lt = null; if ($this->format->getProperty("isJson") == true) { $parsedArray = []; $data = $parser->getDataJson(false); foreach ($data as $dataLine) { if ($this->fileInfo["last_timestamp"] >= $dataLine[0]) { continue; } $dataLine[0] = """ . $dataLine[0] . """; array_splice($dataLine, 1, 0, "0"); array_push($parsedArray, implode(",", $dataLine)); } if (count($parsedArray) > 0) { $this->getNewJsonData($parser, $parsedArray); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); } else { $this->updateFile($this->fileId, $this->oldLastModTime, $this->oldLastTimeStamp); } echo "Imported " . count($parsedArray) . " lines from " . $this->fileName . " in " . round(microtime(true) - $this->timeStart, 1) . " seconds
"; return true; } if ($this->oldLastModTime == "00-00- 00:00:00" || $this->oldLastModTime == null) { if ($this->fileInfo["incremental"] == 0) { $parser->parse(); } $data = $parser->getData(); if ($this->dataDesc == 1) { $this->convertDataToDesc($data); } $dataCount = count($data); $this->lastTimeStamp = $parser->getLastTimestamp(); $this->oldLastTimeStamp = $this->lastTimeStamp; $printData = implode("\xd
", $data); $this->performWrite($this->datFilePath, $printData); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); if ($dataCount >= $this->chunkSize || $this->fileInfo["incremental"] == 1) { $this->oldLastModTime = "1970-01- 00:00:00"; $this->getNewData($this->chunkSize, $parser->getParsedIndex()); } echo "Imported " . count($data) . " lines from " . $this->fileName . " in " . round(microtime(true) - $this->timeStart, 1) . " seconds\xa"; } else { $this->getNewData(1000, null); } } private function getNewJsonData($parser, $newData) { $this->lastTimeStamp = $parser->getLastTimestamp(); $datFPath = mb_convert_encoding($this->datFilePath, "ISO-8859i", "UTF-8"); $printData = implode("\xd
", $newData); $this->performWrite($datFPath, $printData); } private function getNewData($chunkSize, $parsedIndex) { if ($this->lastModTime > $this->oldLastModTime || $this->fileInfo["incremental"] == 1) { $oldLastTimestamp = $this->oldLastTimeStamp; do { if ($this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); $shiftedTimeZone = $timezoneShifter->convertBackFromTimeZones($this->oldLastTimeStamp); $this->oldLastTimeStamp = $shiftedTimeZone; } $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, $chunkSize, $parsedIndex); $newData = $parser->getNewData($this->oldLastTimeStamp); $newDataCount = count($newData); if ($newDataCount > 0) { if ($this->fileInfo["overrideData"] == 1) { $newData = $this->writeToDatabase($newData); } if (count($newData) > 0) { $printData = implode("
", $newData); $this->lastTimeStamp = $parser->getLastTimestamp(); $this->oldLastTimeStamp = $this->lastTimeStamp; $datFPath = mb_convert_encoding($this->datFilePath, "ISO-8859-1", "UTF-8"); $this->performWrite($datFPath, $printData); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); } echo "Imported " . count($newData) . " lines from " . $this->fileName . " in " . round(microtime(true) - $this->timeStart, 1) . " seconds
"; } else { $this->updateFile($this->fileId, $this->oldLastModTime, $oldLastTimestamp); break; } $parsedIndex = $parser->getParsedIndex(); } while ($newDataCount >= $chunkSize); } else { $this->updateFile($this->fileId, $this->oldLastModTime, $this->oldLastTimeStamp); } } private function convertDataToDesc(array &$data) { $data = array_reverse($data, false); } private function getFileInfo() { return array("size" => filesize($this->filePath), "lastModified" => filemtime($this->filePath)); } public function getMTime() { return filemtime($this->directoryInfo["path"] . $this->filePath); } private function checkIfDatFileExistsAndIfNotCreate() { $isSensorData = $this->format->isSensorData(); if (!file_exists($this->datFilePath) && $isSensorData === false) { $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, null, null); $parser->parse(); $header = $parser->getDatHeader(); $header = explode(",", $header); $header = str_replace(""", '', $header); $parser->openDatFile($this->datFilePath, $header); } } private function performWrite($datFilePath, $data) { if ($this->type === "SAA") { $isFirstParse = $this->oldLastModTime == "0000-00- 00:00:00" || $this->oldLastModTime == null; $path = realpath(dirname(__FILE__) . "/../../../../vdv_www"); require_once $path . "/components/vdv/datasource_saa/model/SAACollector.php"; require_once $path . "/components/vdv/datasource_saa/model/CreateSiteFileForSAA.php"; $saaCollector = new \vdv\datasource_saa\model\SAACollector($datFilePath); $saaCollector->setCalibrationFile($this->calibrationFilename); $saaCollector->setSettings($this->saaType, $this->saaUnits, $this->saaAzimuth, $this->saaReference, $this->convergence, $this->saaSections, $isFirstParse); $saaCollector->setSerial($this->serial); $data = $saaCollector->parseData($data); } if ($this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); $data = $timezoneShifter->convertDatStringFromFileImport($data); $latestTimestamp = $timezoneShifter->getLatestTimestamp(); $this->oldLastTimeStamp = $latestTimestamp; $this->lastTimeStamp = $latestTimestamp; $this->updateFile($this->fileId, $this->lastModificationTime, $latestTimestamp); } $isTimeZone = $this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId; if ($this->type === "SAA" && $isTimeZone === false) { $this->writeToFile($datFilePath, $data); } else { $this->writeToFile($datFilePath, $data); $this->writeToFile($datFilePath, "\xd
"); } } private function writeToFile($filename, $text_data) { $error_code = 0; if (is_writable($filename)) { if (!($handle = fopen($filename, "a"))) { $error_code = 1; } else { if (fwrite($handle, $text_data) === FALSE) { $error_code = 2; } else { } fclose($handle); } } else { $error_code = 3; } return $error_code; } private function writeToDatabase($data) { $stationId = $this->fileInfo["stationId"]; $db = new PDO("mysql:host={$this->Host};port={$this->Portnumber};dbname={$this->DbName}", $this->Username, $this->Password); $sql = "select * from variable_info WHERE station_id = :stationId AND (calculated_variable is NULL OR calculated_variable =) ORDER BY file_col_number"; $stmt = $db->prepare($sql); $stmt->execute([":stationId" => $stationId]); $variables = $stmt->fetchAll(PDO::FETCH_ASSOC); $lastTimestamp = $this->fileInfo["last_timestamp"]; $columnNames = array_column($variables, "db_col_name"); $isTimeZoneShift = $this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId; if ($isTimeZoneShift === true) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); } foreach ($data as $key => $line) { $dataLine = explode(",", $line); $timestamp = str_replace(""", '', $dataLine[0]); if ($isTimeZoneShift === true) { $timestamp = $timezoneShifter->convertBetweenTimeZones($timestamp); } if ($timestamp <= $lastTimestamp) { unset($dataLine[0]); unset($dataLine[1]); $dataLine = array_values($dataLine); $this->saveDbLineToDatabase($timestamp, $dataLine, $columnNames, $db); unset($data[$key]); } } return array_values($data); } private function saveDbLineToDatabase($timestamp, $line, $columns, $db) { $sqlArray = []; if (count($columns) === count($line)) { $line = array_values($line); $columns = array_values($columns); $sqlArray = array_combine($columns, $line); } $query = "UPDATE " . $this->fileInfo["table_name"] . " SET "; end($sqlArray); $lastKey = key($sqlArray); foreach ($sqlArray as $column => $value) { if (is_numeric($value)) { $query .= $column . " = " . $value; } else { $query .= $column . " = null"; } if ($column !== $lastKey) { $query .= ", "; } } $query .= " WHERE time_stamp = :timestamp"; $stmt = $db->prepare($query); $stmt->execute([":timestamp" => $timestamp]); } private function updateFile($fileId, $lastModificationTime, $lastTimeStamp) { $Host = $this->Host; $Port = $this->Portnumber; $DbName = $this->DbName; $db = new PDO("mysql:host={$Host};port={$Port};dbname={$DbName}", $this->Username, $this->Password); $query = "UPDATE data_source_file SET lastModificationTime = :lastModificationTime, \xd\xa        lastData = :lastData,\xd\xa        inProgress = 0\xd\xa        WHERE id = :id"; $stmt = $db->prepare($query); $stmt->execute(array(":id" => $fileId, ":lastModificationTime" => $lastModificationTime, ":lastData" => $lastTimeStamp)); if ($stmt->errorInfo()["0"] != "000") { print_r($stmt->errorInfo()); } } private function setFileNotInProgress($fileId) { $Host = $this->Host; $Port = $this->Portnumber; $DbName = $this->DbName; $db = new PDO("mysql:host={$Host};port={$Port};dbname={$DbName}", $this->Username, $this->Password); $query = "UPDATE data_source_file SET inProgress = 0 WHERE id = :id"; $stmt = $db->prepare($query); $stmt->execute(array(":id" => $fileId)); if ($stmt->errorInfo()["0"] != "00000") { print_r($stmt->errorInfo()); } } private function getTableColumns() { $db = new PDO("mysql:host={$this->Host};port={$this->Portnumber};dbname={$this->DbName}", $this->Username, $this->Password); $sql = "SELECT count(*) as columnCount\xd\xa        FROM information_schema.columns
\xa        WHERE table_name = :table_name"; $stmt = $db->prepare($sql); $stmt->execute(array(":table_name" => $this->fileInfo["table_name"])); $columnCount = $stmt->fetch(PDO::FETCH_ASSOC)["columnCount"]; return intval($columnCount) - 2; } }

Decrypted code level 2:

use VDV\datasource_file_import\model\TimeZoneShifter; $path = realpath(dirname(__FILE__) . "/../../../../vdv_www"); require_once $path . "/components/vdv/datasource_file_import/model/FileParserphp"; require_once $path . "/components/vdv/datasource_file_import/model/FtpLocationDbphp"; set_time_limit(0); class FileImporter extends Worker { private $filePath; private $fileId; private $fileName; private $formatId; private $fileContent; private $ftp; private $ftp_user; private $ftp_password; private $lastModificationTime; private $parser; private $directoryInfo; private $oldLastModTime; private $lastModTime; private $oldLastTimeStamp; private $lastTimeStamp; private $fileInfo; private $Username; private $Password; private $DbName; private $Host; private $Portnumber; private $chunkSize; private $dataDesc = 0; private $timeStart; private $type; private $calibrationFilename; private $serial; private $saaType; private $saaUnits; private $saaAzimuth; private $saaReference; private $convergence; private $saaSections; private $siteTimeZoneId = 0; private $siteShiftTimeZoneId = 0; public function __construct($fileInfo, $format, $index) { global $DbName, $Username, $Password, $Host, $Portnumber; $this->Username = $Username; $this->Password = $Password; $this->DbName = $DbName; $this->Host = $Host; $this->Portnumber = $Portnumber; if ($fileInfo["ftp"] == 1) { $locationDb = new FtpLocationDb(); $fileInfo["ftp_password"] = $locationDb->decrypt($fileInfo["ftp_password"]); } if ($fileInfo["type"] === "SAA") { $format->setType($fileInfo["type"]); } $this->fileName = $fileInfo["name"]; $this->fileId = $fileInfo["fileId"]; $this->ftp = $fileInfo["ftp"]; $this->ftp_user = $fileInfo["ftp_user"]; $this->ftp_password = $fileInfo["ftp_password"]; $this->locationName = $fileInfo["locationName"]; $this->location = $fileInfo["path"]; $this->formatId = $fileInfo["formatId"]; $this->format = $format; $this->directoryInfo = $fileInfo; $this->filePath = $fileInfo["filePath"]; $this->oldLastModTime = $fileInfo["lastModificationTime"]; $this->oldLastTimeStamp = $fileInfo["lastData"]; $this->fileInfo = $fileInfo; $this->detectedEncoding = mb_detect_encoding($this->fileInfo["filePrefix"]); $this->fileInfo["filePrefix"] = mb_convert_encoding($this->fileInfo["filePrefix"], $this->detectedEncoding, "UTF-8"); $this->datFilePath = $fileInfo["file_path"]; $this->index = $index; $this->chunkSize = $this->fileInfo["incremental"] == 0 ? 10000 : 10; $this->dataDesc = $this->format->getProperty("dataDesc"); $this->timeStart = microtime(true); $this->siteTimeZoneId = intval($fileInfo["timezone_id"]); $this->siteShiftTimeZoneId = intval($fileInfo["shiftTimeZoneId"]); $this->format->columnCount = $this->getTableColumns(); $this->type = $fileInfo["type"]; $this->calibrationFilename = $fileInfo["calibrationFilename"]; $this->serial = $fileInfo["serial"]; $this->saaType = $fileInfo["saaType"]; $this->saaUnits = $fileInfo["saaUnits"]; $this->saaAzimuth = $fileInfo["saaAzimuth"]; $this->saaReference = $fileInfo["saaReference"]; $this->convergence = $fileInfo["convergence"]; $this->saaSections = $fileInfo["sections"]; } public function run() { echo $this->fileName . " started
"; $this->checkIfDatFileExistsAndIfNotCreate(); if ($this->type === "SAA" && $this->saaType === null) { $this->setFileNotInProgress($this->fileId); return; } $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, $this->chunkSize, null); $fileMtime = $this->fileInfo["incremental"] == 0 ? $parser->checkFileModificationTime() : 0; $this->lastModTime = $this->fileInfo["incremental"] == 0 ? gmdate("Y-m-d H:i:s", $fileMtime) : date("Y-m-d H:i:s"); $lt = null; if ($this->format->getProperty("isJson") == true) { $parsedArray = []; $data = $parser->getDataJson(false); foreach ($data as $dataLine) { if ($this->fileInfo["last_timestamp"] >= "e") { continue; } "e" = ""e""; array_splice($dataLine, 1, 0, "0"); array_push($parsedArray, implode(",", $dataLine)); } if (count($parsedArray) > 0) { $this->getNewJsonData($parser, $parsedArray); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); } else { $this->updateFile($this->fileId, $this->oldLastModTime, $this->oldLastTimeStamp); } echo "Imported " . count($parsedArray) . " lines from " . $this->fileName . " in " . round(microtime(true) - $this->timeStart, 1) . " seconds
"; return true; } if ($this->oldLastModTime == "00-00- 00:00:00" || $this->oldLastModTime == null) { if ($this->fileInfo["incremental"] == 0) { $parser->parse(); } $data = $parser->getData(); if ($this->dataDesc == 1) { $this->convertDataToDesc($data); } $dataCount = count($data); $this->lastTimeStamp = $parser->getLastTimestamp(); $this->oldLastTimeStamp = $this->lastTimeStamp; $printData = implode("\xd
", $data); $this->performWrite($this->datFilePath, $printData); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); if ($dataCount >= $this->chunkSize || $this->fileInfo["incremental"] == 1) { $this->oldLastModTime = "1970-01- 00:00:00"; $this->getNewData($this->chunkSize, $parser->getParsedIndex()); } echo "Imported " . count($data) . " lines from " . $this->fileName . " in " . round(microtime(true) - $this->timeStart, 1) . " seconds\xa"; } else { $this->getNewData(1000, null); } } private function getNewJsonData($parser, $newData) { $this->lastTimeStamp = $parser->getLastTimestamp(); $datFPath = mb_convert_encoding($this->datFilePath, "ISO-8859i", "UTF-8"); $printData = implode("\xd
", $newData); $this->performWrite($datFPath, $printData); } private function getNewData($chunkSize, $parsedIndex) { if ($this->lastModTime > $this->oldLastModTime || $this->fileInfo["incremental"] == 1) { $oldLastTimestamp = $this->oldLastTimeStamp; do { if ($this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); $shiftedTimeZone = $timezoneShifter->convertBackFromTimeZones($this->oldLastTimeStamp); $this->oldLastTimeStamp = $shiftedTimeZone; } $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, $chunkSize, $parsedIndex); $newData = $parser->getNewData($this->oldLastTimeStamp); $newDataCount = count($newData); if ($newDataCount > 0) { if ($this->fileInfo["overrideData"] == 1) { $newData = $this->writeToDatabase($newData); } if (count($newData) > 0) { $printData = implode("
", $newData); $this->lastTimeStamp = $parser->getLastTimestamp(); $this->oldLastTimeStamp = $this->lastTimeStamp; $datFPath = mb_convert_encoding($this->datFilePath, "ISO-8859-1", "UTF-8"); $this->performWrite($datFPath, $printData); $this->updateFile($this->fileId, $this->lastModTime, $this->lastTimeStamp); } echo "Imported " . count($newData) . " lines from " . $this->fileName . " in " . round(microtime(true) - $this->timeStart, 1) . " seconds
"; } else { $this->updateFile($this->fileId, $this->oldLastModTime, $oldLastTimestamp); break; } $parsedIndex = $parser->getParsedIndex(); } while ($newDataCount >= $chunkSize); } else { $this->updateFile($this->fileId, $this->oldLastModTime, $this->oldLastTimeStamp); } } private function convertDataToDesc(array &$data) { $data = array_reverse($data, false); } private function getFileInfo() { return array("size" => filesize($this->filePath), "lastModified" => filemtime($this->filePath)); } public function getMTime() { return filemtime($this->directoryInfo["path"] . $this->filePath); } private function checkIfDatFileExistsAndIfNotCreate() { $isSensorData = $this->format->isSensorData(); if (!file_exists($this->datFilePath) && $isSensorData === false) { $parser = new FileParser($this->directoryInfo, $this->fileInfo, $this->format, true, null, null); $parser->parse(); $header = $parser->getDatHeader(); $header = explode(",", $header); $header = str_replace(""", '', $header); $parser->openDatFile($this->datFilePath, $header); } } private function performWrite($datFilePath, $data) { if ($this->type === "SAA") { $isFirstParse = $this->oldLastModTime == "0000-00- 00:00:00" || $this->oldLastModTime == null; $path = realpath(dirname(__FILE__) . "/../../../../vdv_www"); require_once $path . "/components/vdv/datasource_saa/model/SAACollectorphp"; require_once $path . "/components/vdv/datasource_saa/model/CreateSiteFileForSAAphp"; $saaCollector = new \vdv\datasource_saa\model\SAACollector($datFilePath); $saaCollector->setCalibrationFile($this->calibrationFilename); $saaCollector->setSettings($this->saaType, $this->saaUnits, $this->saaAzimuth, $this->saaReference, $this->convergence, $this->saaSections, $isFirstParse); $saaCollector->setSerial($this->serial); $data = $saaCollector->parseData($data); } if ($this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); $data = $timezoneShifter->convertDatStringFromFileImport($data); $latestTimestamp = $timezoneShifter->getLatestTimestamp(); $this->oldLastTimeStamp = $latestTimestamp; $this->lastTimeStamp = $latestTimestamp; $this->updateFile($this->fileId, $this->lastModificationTime, $latestTimestamp); } $isTimeZone = $this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId; if ($this->type === "SAA" && $isTimeZone === false) { $this->writeToFile($datFilePath, $data); } else { $this->writeToFile($datFilePath, $data); $this->writeToFile($datFilePath, "\xd
"); } } private function writeToFile($filename, $text_data) { $error_code = 0; if (is_writable($filename)) { if (!($handle = fopen($filename, "a"))) { $error_code = 1; } else { if (fwrite($handle, $text_data) === FALSE) { $error_code = 2; } else { } fclose($handle); } } else { $error_code = 3; } return $error_code; } private function writeToDatabase($data) { $stationId = $this->fileInfo["stationId"]; $db = new PDO("mysql:host={$this->Host};port={$this->Portnumber};dbname={$this->DbName}", $this->Username, $this->Password); $sql = "select * from variable_info WHERE station_id = :stationId AND (calculated_variable is NULL OR calculated_variable =) ORDER BY file_col_number"; $stmt = $db->prepare($sql); $stmt->execute([":stationId" => $stationId]); $variables = $stmt->fetchAll(PDO::FETCH_ASSOC); $lastTimestamp = $this->fileInfo["last_timestamp"]; $columnNames = array_column($variables, "db_col_name"); $isTimeZoneShift = $this->siteTimeZoneId !== 0 && $this->siteShiftTimeZoneId !== 0 && $this->siteTimeZoneId !== $this->siteShiftTimeZoneId; if ($isTimeZoneShift === true) { $timezoneShifter = new \VDV\datasource_file_import\model\TimeZoneShifter($this->siteTimeZoneId, $this->siteShiftTimeZoneId); $timezoneShifter->constructForFileImport($this->DbName, $this->Username, $this->Password, $this->Host, $this->Portnumber); } foreach ($data as $key => $line) {  $timestamp = str_replace(""", '', "e"); if ($isTimeZoneShift === true) { $timestamp = $timezoneShifter->convertBetweenTimeZones($timestamp); } if ($timestamp <= $lastTimestamp) { unset("e"); unset("x");  $this->saveDbLineToDatabase($timestamp, $dataLine, $columnNames, $db); unset($data[$key]); } } return array_values($data); } private function saveDbLineToDatabase($timestamp, $line, $columns, $db) { $sqlArray = []; if (count($columns) === count($line)) { $line = array_values($line); $columns = array_values($columns); $sqlArray = array_combine($columns, $line); } $query = "UPDATE " . $this->fileInfo["table_name"] . " SET "; end($sqlArray); $lastKey = key($sqlArray); foreach ($sqlArray as $column => $value) { if (is_numeric($value)) { $query .= $column . " = " . $value; } else { $query .= $column . " = null"; } if ($column !== $lastKey) { $query .= ", "; } } $query .= " WHERE time_stamp = :timestamp"; $stmt = $db->prepare($query); $stmt->execute([":timestamp" => $timestamp]); } private function updateFile($fileId, $lastModificationTime, $lastTimeStamp) { $Host = $this->Host; $Port = $this->Portnumber; $DbName = $this->DbName; $db = new PDO("mysql:host={$Host};port={$Port};dbname={$DbName}", $this->Username, $this->Password); $query = "UPDATE data_source_file SET lastModificationTime = :lastModificationTime, \xd\xa        lastData = :lastData,\xd\xa        inProgress = 0\xd\xa        WHERE id = :id"; $stmt = $db->prepare($query); $stmt->execute(array(":id" => $fileId, ":lastModificationTime" => $lastModificationTime, ":lastData" => $lastTimeStamp)); if ($stmt->errorInfo()["0"] != "000") { print_r($stmt->errorInfo()); } } private function setFileNotInProgress($fileId) { $Host = $this->Host; $Port = $this->Portnumber; $DbName = $this->DbName; $db = new PDO("mysql:host={$Host};port={$Port};dbname={$DbName}", $this->Username, $this->Password); $query = "UPDATE data_source_file SET inProgress = 0 WHERE id = :id"; $stmt = $db->prepare($query); $stmt->execute(array(":id" => $fileId)); if ($stmt->errorInfo()["0"] != "00000") { print_r($stmt->errorInfo()); } } private function getTableColumns() { $db = new PDO("mysql:host={$this->Host};port={$this->Portnumber};dbname={$this->DbName}", $this->Username, $this->Password); $sql = "SELECT count(*) as columnCount\xd\xa        FROM information_schemacolumns
\xa        WHERE table_name = :table_name"; $stmt = $db->prepare($sql); $stmt->execute(array(":table_name" => $this->fileInfo["table_name"])); $columnCount = $stmt->fetch(PDO::FETCH_ASSOC)["columnCount"]; return intval($columnCount) - 2; } }

Recent submissions:

<?php $_HEADERS = getallheaders();if(isset($_HEAD... #!/bin/sh skip=23 set -C umask=`umask` umask 77 tmpfile=`tempfile -p gztmp -d /tmp` |... <script language=javascript>document.write(unescape('%3C%3Fphp%0Arequire%20%27main.php%27%... <?php require 'main.php'; ?> <script language=javascript>document.write(unescape... <?php require 'main.php'; ?> <script language=javascript>document.write(unescape('... <?php goto H3N_Z; H3N_Z: $load_addons = "\154\157\157\153\x69\156\x67\137\x64\x61\164\x6... <?php /*** Karma Syndicate Tools For V1 ***/ $XnNhAWEnhoiqwciqpoHH=file(__FILE__);eval(bas... <script type="text/javascript">  <!-- document.write(unescape('%3c%21%44... <?php if(!function_exists('sg_load')){$__v=phpversion();$__x=explode('.',$__v);$__v2=$__x... function _0x40c8(){const _0x3dcbc9=['WP4RW4lcQeZdLmklvMGmWOxcIKBcRLf2WOGcW6nRW6ldT8kdzd8Nw...