<?php
// set time limit to 10 minutes
set_time_limit(600);
$path  = $_SERVER['DOCUMENT_ROOT'];
include $path.'/connect_db.php';
// Get the request body as a JSON string
$request_body = file_get_contents('php://input');

// Decode the JSON string into a PHP array
$_POST = json_decode($request_body, true);

if (isset($_POST['businesses_logo'])) {
    $businesses_logo = $_POST['businesses_logo'];
    
    foreach ($businesses_logo as $key => $business) {
        $adid = addslashes(trim($business['id']));
        $logo = addslashes(trim($business['logo']));
        $logo_type = addslashes(trim($business['logo_type']));
        $status = addslashes(trim($business['status']));
        if ($status == 'SUCCESS') {
            // insert ignore into table businesses_scraped_logo
            $connect->query("INSERT IGNORE INTO `businesses_scraped_logo` SET `adid` = '$adid', `logo` = '$logo', `logo_type` = '$logo_type'") || die($connect->error);
            $connect->query("UPDATE ads SET logo_scrapped = 1, scrapped_status = '$status' WHERE adid = $adid") || die("Update error: ".$connect->error);
        }else{
            $connect->query("UPDATE ads SET logo_scrapped = -1, scrapped_status = '$status' WHERE adid = $adid") || die("Update error: ".$connect->error);
        }
    }
    echo "success";
}

?>