Subversion Repositories cheapmusic

<?php

include_once('php/constants.php');

error_reporting(E_ALL);

// Get linkshare listings

function get_linkshare($query, $searchType) {

    $vendors = Vendors::getInstance();

    $config = $vendors->getVendor(Vendors::LINKSHARE);

    $token = getLinkshareToken($config);

    if ($token === false) {

        return [];

    }

    $arr = [];

    foreach($config["advertiser"] as $advertiser) {

        $arrTemp = get_linkshareAdvertiser($config, $token, $query, $searchType, $advertiser);

        $arr = array_merge($arr, $arrTemp);

    }

    return($arr);

}

// Get linkshare listings by advertiser id

function get_linkshareAdvertiser($config, $token, $query, $searchType, $advertiserId) {

// API request variables

	$safequery = urlencode($query);

	$numResults = $config['numResults'];

	$numResultsMid = $config['numResultsMid'];

	$resultsMid = [];

// Construct the findItemsByKeywords HTTP GET call

    $url = "https://api.rakutenmarketing.com/productsearch/1.0";

    $url .= "?keyword=" . $safequery;

    $url .= "&max=" . $numResults;

    $url .= "&pagenumber=1";

    $url .= "&sort=retailprice";

    $url .= "&sorttype=asc";

    $url .= "&mid=" . $advertiserId;

    $header = array(

        'Content-Type: application/x-www-form-urlencoded',

        'Accept: application/xml',

        'Accept-Language: en-US,en;q=0.5',

        'Accept-Charset: UTF-8,*;q=0.5',

        'Authorization: Bearer ' . $token

        );

    $ch = curl_init();

    curl_setopt($ch, CURLOPT_HTTPHEADER, $header);

    curl_setopt($ch, CURLOPT_ENCODING, "gzip,deflate");

    curl_setopt($ch, CURLOPT_URL, $url);

    curl_setopt($ch, CURLOPT_AUTOREFERER, true);

    curl_setopt($ch, CURLOPT_HEADER, 0);

    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

    $result = curl_exec ($ch);

	$result = utf8_encode($result);

	$result = simplexml_load_string($result);

    curl_close($ch);

//echo "$url<br><pre>";print_r($result);echo "</pre>";

	$arr = [];

// Check to see if the request found any results

	if (isset($result->TotalMatches)) {

  // If the response was loaded, parse it and store in array

		foreach ($result->item as $item) {

			$merchantId = strval($item->mid);

			$merchantName = (string)$item->merchantname;

			$barcode = (string)$item->upccode;

			$barcodeType = clsLibGTIN::GTINCheck($barcode, false, 1);

			$title = (string)$item->productname;

			$pic = str_replace('http://', 'https://', (string)$item->imageurl);

			if (empty($pic)) {

			    continue;

			}

			$url = str_replace('http://', 'https://', (string)$item->linkurl);

			if (empty($url)) {

			    continue;

			}

			switch ($merchantId) {

			    case 35126: // Sam Ash Music

			        if ($item->category->primary == "Books/Dvds") {

                        $type = 'New';

   	    			    $condition = "Brand New";

    	    			$category = "Book";

        			    $freeShippingCap = 0.00; // 9.99 on webpage

            			$handlingTime = 1;

            			$shippingCost = 0.00;

            			$shippingCurrency = 'USD';

    	    		} else {

    	    		    continue 2; // next loop

    	    		}

			        break;

			    case 13770: // Music Notes

                    $type = 'New';

   				    $condition = "Brand New";

    				$category = "Book";

       			    $freeShippingCap = 0.00;

           			$handlingTime = 1;

        			$shippingCost = 0.00;

        			$shippingCurrency = 'USD';

			        break;

			    case 2653: // alibris (does not return any search results) bugbug

       			    $freeShippingCap = 39.00;

           			$handlingTime = 1;

        			$shippingCost = 3.99;

        			$shippingCurrency = 'USD';

			        break;

   				default:

                    $type = 'Used';

   				    $condition = "Used";

    				$category = "CD";

       			    $freeShippingCap = 0.00;

        			$handlingTime = -1;

        			$shippingCost = 0.00;

        			$shippingCurrency = 'USD';

    				break;

			}

			$country = 'US';

			$bestOffer = false;

			$price = 0;

			if (!empty($item->price) && !empty($item->saleprice)) {

    			$price = minNotNull(array($item->price, $item->saleprice));

    		} else if (!empty($item->price)) {

    			$price = $item->price;

    		} else if (!empty($item->saleprice)) {

    			$price = $item->saleprice;

    		}

			$price = number_format(floatval($price), 2, '.', '');

			if ($price <= "0.00") {

			    continue;

			}

			$currency = 'USD';

			$timeLeft = 0;

			$listingType = 'Fixed';

			$location = 'US';

			$zip = '';

			$feedbackScore = -1;

			$feedbackPercent = -1;

			$sellerName = '';

// bugbug

//ls_cj_csv(array($merchantName,(string)$item->category->primary,(string)$item->productname,(string)$item->description->short,"'".$barcode,$barcodeType,minNotNull(array($item->price, (string)$item->saleprice)),(string)$item->linkurl));

            // this is last after all checks

			$resultsMid[] = $merchantId;

			if (array_count_values($resultsMid)[$merchantId] > $numResultsMid) {

			    continue;

			}

			$arr[] = array(

				"Merchant" => $merchantName,

				"Type" => "$type",

				"Title" => "$title",

				"Barcode" => "$barcode",

				"BarcodeType" => "$barcodeType",

				"Image" => "$pic",

				"URL" => "$url",

				"Category" => "$category",

				"Condition" => "$condition",

				"Country" => "$country",

				"BestOffer" => "$bestOffer",

				"TimeLeft" => "$timeLeft",

				"Price" => "$price",

				"Currency" => "$currency",

				"ListingType" => "$listingType",

				"Location" => "$location",

				"Zip" => "$zip",

				"FeedbackScore" => "$feedbackScore",

				"FeedbackPercent" => "$feedbackPercent",

				"SellerName" => "$sellerName",

				"HandlingTime" => "$handlingTime",

				"ShippingCost" => "$shippingCost",

				"ShippingCurrency" => "$shippingCurrency",

				"FreeShippingCap" => "$freeShippingCap",

				"Show" => true

			);

		}

	}

// If the response does not indicate 'Success,' log the error(s)

	else {

		foreach ($result->Errors as $error) {

		    if ($error->ErrorID != "7186919") { // no product found, not an error

    			error_log($url);

	    		error_log("$error->ErrorText ($error->ErrorId)");

	    	}

		}

	}

	return $arr;

}

// Get Linkshare Bearer Token

function getLinkshareToken($config)

{

    static $expiration = 0;

    static $accessToken = '';

    static $refreshToken = '';

    if ($expiration == 0 || time() > $expiration) {

        $url="https://api.rakutenmarketing.com/token";

        $postdata = "grant_type=password&username=" . $config['user'] . "&password=" . $config['password'] . "&scope=" . $config['scope'];

        $header = array(

            'Content-Type: application/x-www-form-urlencoded',

            'Authorization: ' . $config['authorizationToken']

            );

        $ch = curl_init();

        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);

        curl_setopt($ch, CURLOPT_URL, $url);

        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);

        curl_setopt($ch, CURLOPT_TIMEOUT, 60);

        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 0);

        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);

        curl_setopt($ch, CURLOPT_REFERER, $url);

        curl_setopt($ch, CURLOPT_POSTFIELDS, $postdata);

        curl_setopt($ch, CURLOPT_POST, 1);

        $result = json_decode(curl_exec ($ch));

        curl_close($ch);

        if (empty($result)) {

            return false;

        }

        $expiration = time() + $result->{'expires_in'};

        $accessToken = $result->{'access_token'};

        $refreshToken = $result->{'refresh_token'};

        $tokenType =  $result->{'token_type'};

    }

    return $accessToken;

}