Zefix_search/taskExecuter.php

<?php
include "zefixAPI.php";
include 'simpleXMLElement.php';

$maxExecutionTime = 480;
$taskDir = 'tasks';
$downloadDir = 'download';
$latesEndTime = time() + $maxExecutionTime;


if(!is_dir($downloadDir)){
    mkdir($downloadDir, 0755, true);
}

function doRequest($data, $filename, $username, $password)
{
    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)
{
    echo "sending ".$filename." too ".$emailAddress;
}
// Stop executing bevore reaching PHP Max Execution Time
function convertcsvToXlsx(string $csvFile, string $xlsxFile)
{
    // Read the CSV file
    $csvData = file_get_contents($csvFile);

    // Split the CSV data into rows
    $csvRows = explode("\n", $csvData);

    // Create a SimpleXMLElement for the workbook
    $xmlWorkbook = new SimpleXMLElement('<?xml version="1.0" encoding="UTF-8"?>
        <Workbook xmlns="urn:schemas-microsoft-com:office:spreadsheet"
          xmlns:o="urn:schemas-microsoft-com:office:office"
          xmlns:x="urn:schemas-microsoft-com:office:excel"
          xmlns:ss="urn:schemas-microsoft-com:office:spreadsheet"
          xmlns:html="http://www.w3.org/TR/REC-html40">
          <Worksheet ss:Name="Sheet1">
            <Table>
            </Table>
          </Worksheet>
        </Workbook>');

    // Reference to the Worksheet's Table
    $xmlTable = $xmlWorkbook->Worksheet->Table;

    // Loop through CSV rows and create XML elements
    foreach ($csvRows as $csvRow) {
        // Split the CSV row into cells
        $csvCells = str_getcsv($csvRow);

        // Create a new row in the XML table
        $xmlRow = $xmlTable->addChild('Row');

        // Add cells to the row
        foreach ($csvCells as $csvCell) {
            $xmlCell = $xmlRow->addChild('Cell');
            $xmlData = $xmlCell->addChild('Data', htmlspecialchars($csvCell));
            $xmlData->addAttribute('ss:Type', 'String');
        }
    }

    // Save the XML data to a file
    $xmlWorkbook->asXML($xlsxFile);
}

while($latesEndTime - time() > 60){
    // If the directory for Tasks is already created
    if(is_dir($taskDir)) {
        $taskfiles = scandir($taskDir);
        $taskfiles = array_diff($taskfiles, array('.', '..'));
        sort($taskfiles);
        // 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], 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');
                if($taskfile){
                    fwrite($taskfile, $taskString);
                    fclose($taskfile);
                }
            }
            // if there are no Requests left, send the E-Mail
        else {
                convertcsvToXlsx(str_replace(".json", ".csv", $downloadDir.'/'.$taskfiles[0]), str_replace(".json", ".xlsx", $downloadDir.'/'.$taskfiles[0]));
//                unlink(str_replace(".json", ".csv", $downloadDir.'/'.$taskfiles[0]));
                sendEmail($task['email'], str_replace(".json", ".xlsx", $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);
        }
    }
}


?>