Silias-Public/Zefix_search
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

prepared Task Executer

Browse Source
This commit is contained in:
schrom01
2023-09-25 15:45:26 +02:00
parent b178df10e3
commit 3fa9fa6d79
3 changed files with 53 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
taskExecuter.php
+47 -6
View File
@@ -1,12 +1,49 @@
<?php
include "zefixAPI.php";
$maxExecutionTime = 80;
$taskDir = 'tasks';
$downloadDir = 'download';
$latesEndTime = time() + $maxExecutionTime;
function doRequest($task)
if(!is_dir($downloadDir)){
mkdir($downloadDir, 0755, true);
}
function doRequest($data, $filename, $username, $password)
{
echo "doing Request: ".json_encode($task);
echo "doing Request: ".json_encode($data);
echo "<br>";
$response = sendAPICompanySearchRequest($username, $password, $data);
$companyArray = json_decode($response, true);
// TODO implement
$companyData = [
['John', 30, 'New York'],
['Alice', 25, 'Los Angeles'],
['Bob', 35, 'Chicago'],
];
$companyData = array();
foreach ($companyArray as $company) {
$companyData[] = [$company['name'],$company['ehraid'],$company['uid'],$company['chid'],$company['legalSeat'],$company['registryOfCommerceId'],$company['legalForm']['name']['de'],$company['status'],$company['sogcDate'],$company['deletionDate']];
}
if (! file_exists($filename)) {
// If File doesn't exist yet
$file = fopen($filename, 'w');
if($file) {
// TODO change headers
fputcsv($file, ['name', 'ehraid', 'uid', 'chid', 'legalSeat', 'registryOfCommerceId', 'legalForm', 'status', 'sogcDate', 'deletionDate']);
}
} else {
// If file already exists
$file = fopen($filename, 'a');
}
if ($file) {
foreach ($companyData as $row){
fputcsv($file, $row);
}
fclose($file);
}
}
function sendEmail($emailAddress, $filename)
@@ -20,15 +57,16 @@ while($latesEndTime - time() > 60){
$taskfiles = scandir($taskDir);
$taskfiles = array_diff($taskfiles, array('.', '..'));
sort($taskfiles);
// if there are any taks which are older then 2 Minutes. To be sure the file writing process is finished.
if(count($taskfiles) > 0 && intval(explode("-", $taskfiles[0])[0]) + 120 < time()) {
// if there are any taks which are older then 1 Minutes. To be sure the file writing process is finished.
if(count($taskfiles) > 0 && intval(explode("-", $taskfiles[0])[0]) + 60 < time()) {
$taskString = file_get_contents($taskDir.'/'.$taskfiles[0]);
$task = json_decode($taskString, true);
// if there are any requests to do, do the first
if(count($task['requests']) > 0) {
doRequest($task['requests'][0]);
doRequest($task['requests'][0], str_replace(".json", ".csv", $downloadDir.'/'.$taskfiles[0]), $username , $password);
echo "Request done";
echo "<br>";
array_shift($task['requests']);
$taskString = json_encode($task);
$taskfile = fopen($taskDir.'/'.$taskfiles[0], 'w');
@@ -39,15 +77,18 @@ while($latesEndTime - time() > 60){
}
// if there are no Requests left, send the E-Mail
else {
sendEmail($task['email'], $taskDir.'/'.$taskfiles[0]);
sendEmail($task['email'], str_replace(".json", ".csv", $downloadDir.'/'.$taskfiles[0]));
echo "Email sent";
echo "<br>";
unlink($taskDir.'/'.$taskfiles[0]);
echo "Task File deleted";
echo "<br>";
}
} else {
// acutal Time - start time
echo "nothing to do after: ".strval(time() - ($latesEndTime - $maxExecutionTime));
echo "sleeping 10 seconds";
echo "<br>";
sleep(10);
}
}