<?php
// Amazon MWS Sample Program
// PHP Amazonライブラリ未使用
// 注文リストの取得
// H27.10.14
// 各パラメータ設定
$country = 'US'; // JP,US,CA
$fromGetDay = 3; // 何日前からのオーダを確認するかを設定
$currentDir = getcwd();
define("DIR_DATA_LIST", $currentDir);
define("HTTP_TRY_TIMER", 30); // HTTPアクセスに関する設定（任意に変更してください）
define("HTTP_TRY_NUM", 10); // HTTPアクセスに関する設定（任意に変更してください）
// MWSログイン情報（MWS_）
define("MWS_ACCESS_KEY_JP", '★★★設定必要★★★'); // MWSアクセス用JP
define("MWS_SECRET_KEY_JP", '★★★設定必要★★★'); // MWSアクセス用JP
define("MWS_SELLER_ID_JP", '★★★設定必要★★★'); // MWSアクセス用JP
define("MWS_ACCESS_KEY_US", '★★★設定必要★★★'); // MWSアクセス用US
define("MWS_SECRET_KEY_US", '★★★設定必要★★★'); // MWSアクセス用US
define("MWS_SELLER_ID_US", '★★★設定必要★★★'); // MWSアクセス用US
define("MWS_ACCESS_KEY_EU", '★★★設定必要★★★'); // MWSアクセス用EU
define("MWS_SECRET_KEY_EU", '★★★設定必要★★★'); // MWSアクセス用EU
define("MWS_SELLER_ID_EU", '★★★設定必要★★★'); // MWSアクセス用EU
// MARKETPLACE BASEURL
define("MWS_MARKETPLACE_JP", 'A1VC38T7YXB528'); // MWSアクセス用JP
define("MWS_BASEURL_JP", 'https://mws.amazonservices.jp/'); // MWSアクセス用JP
define("MWS_MARKETPLACE_US", 'ATVPDKIKX0DER'); // MWSアクセス用US
define("MWS_BASEURL_US", 'https://mws.amazonservices.com/'); // MWSアクセス用US
define("MWS_MARKETPLACE_CA", 'A2EUQ1WTGCTBG2'); // MWSアクセス用CA
define("MWS_BASEURL_CA", 'https://mws.amazonservices.ca/'); // MWSアクセス用CA
define("MWS_MARKETPLACE_UK", 'A1F83G8C2ARO7P'); // MWSアクセス用UK
define("MWS_BASEURL_UK", 'https://mws.amazonservices.co.uk/'); // MWSアクセス用UK
define("MWS_MARKETPLACE_DE", 'A1PA6795UKMFR9'); // MWSアクセス用DE
define("MWS_BASEURL_DE", 'https://mws.amazonservices.de/'); // MWSアクセス用DE
define("MWS_MARKETPLACE_FR", 'A13V1IB3VIYZZH'); // MWSアクセス用FR
define("MWS_BASEURL_FR", 'https://mws.amazonservices.fr/'); // MWSアクセス用FR
define("MWS_MARKETPLACE_IT", 'APJ6JRA9NG5V4'); // MWSアクセス用IT
define("MWS_BASEURL_IT", 'https://mws.amazonservices.it/'); // MWSアクセス用IT
define("MWS_MARKETPLACE_ES", 'A1RKKUPIHCS9HS'); // MWSアクセス用ES
define("MWS_BASEURL_ES", 'https://mws.amazonservices.es/'); // MWSアクセス用ES
// 出力ファイルの設定
$outFile = sprintf('%s/%s_ORDER_%s_%s.csv', DIR_DATA_LIST, $country, date('Ymd'), date('His'));
if ($country == 'JP' ) { // JP
$access_key_id = MWS_ACCESS_KEY_JP;
$secret_access_key = MWS_SECRET_KEY_JP;
$merchant_id = MWS_SELLER_ID_JP;
$marketplace_id = MWS_MARKETPLACE_JP;
$baseurl = MWS_BASEURL_JP;
}elseif ($country == 'US' ) { // US
$access_key_id = MWS_ACCESS_KEY_US;
$secret_access_key = MWS_SECRET_KEY_US;
$merchant_id = MWS_SELLER_ID_US;
$marketplace_id = MWS_MARKETPLACE_US;
$baseurl = MWS_BASEURL_US;
}elseif ($country == 'CA') { // CA
$access_key_id = MWS_ACCESS_KEY_CA;
$secret_access_key = MWS_SECRET_KEY_CA;
$merchant_id = MWS_SELLER_ID_CA;
$marketplace_id = MWS_MARKETPLACE_CA;
$baseurl = MWS_BASEURL_CA;
}elseif ($country == 'UK' ) { // UK
$access_key_id = MWS_ACCESS_KEY_EU;
$secret_access_key = MWS_SECRET_KEY_EU;
$merchant_id = MWS_SELLER_ID_EU;
$marketplace_id = MWS_MARKETPLACE_UK;
$baseurl = MWS_BASEURL_UK;
}elseif ($country == 'DE' ) { // DE
$access_key_id = MWS_ACCESS_KEY_EU;
$secret_access_key = MWS_SECRET_KEY_EU;
$merchant_id = MWS_SELLER_ID_EU;
$marketplace_id = MWS_MARKETPLACE_DE;
$baseurl = MWS_BASEURL_DE;
}elseif ($country == 'FR' ) { // FR
$access_key_id = MWS_ACCESS_KEY_EU;
$secret_access_key = MWS_SECRET_KEY_EU;
$merchant_id = MWS_SELLER_ID_EU;
$marketplace_id = MWS_MARKETPLACE_FR;
$baseurl = MWS_BASEURL_FR;
}elseif ($country == 'IT' ) { // IT
$access_key_id = MWS_ACCESS_KEY_EU;
$secret_access_key = MWS_SECRET_KEY_EU;
$merchant_id = MWS_SELLER_ID_EU;
$marketplace_id = MWS_MARKETPLACE_IT;
$baseurl = MWS_BASEURL_IT;
}elseif ($country == 'ES' ) { // ES
$access_key_id = MWS_ACCESS_KEY_EU;
$secret_access_key = MWS_SECRET_KEY_EU;
$merchant_id = MWS_SELLER_ID_EU;
$marketplace_id = MWS_MARKETPLACE_ES;
$baseurl = MWS_BASEURL_ES;
}else{
exit;
}
// ***************** RequestReport ****************
$params=array();
$params['AWSAccessKeyId'] = $access_key_id;
$params['SellerId'] = $merchant_id;
$params['SignatureMethod'] = 'HmacSHA256';
$params['SignatureVersion'] = '2';
$params['Version'] = '2013-09-01';
$params['Timestamp'] = gmdate('Y-m-d\TH:i:s\Z'); // Timeは毎回Checkされる【ISO8601,UTC(GMT)】
$params['Action'] = 'ListOrders';
$params['LastUpdatedAfter'] = gmdate('Y-m-d\TH:i:s\Z', strtotime("- $fromGetDay days"));
$params['MarketplaceId.Id.1']= $marketplace_id;
$baseurl = $baseurl . 'Orders/' . $params['Version'];
// URLの作成
$url = makeUrl($params, $baseurl, $secret_access_key, 1);
// HTMLアクセスを行う
$amazon_xml = accessHttp( $url, 0 ); // 0:XML解析要
$getOrderId = '';
foreach($amazon_xml->ListOrdersResult->Orders->Order as $responseOrder){
$getOrderId = $getOrderId . $responseOrder->AmazonOrderId . ':';
}
printf ("SUCCESS : MWS ListOrders completed! OrderId=%s\n", $getOrderId );
exit;
// ***************** 関数の処理 ****************
// HTTPアクセスを行う処理（HTTP_TRY_NUM回のリトライを行う）
function accessHttp( $url, $jobType ) {
for ($i=1; $i <= HTTP_TRY_NUM; $i++) {
$http_response_header = null;
$response = @file_get_contents( $url );
// HTTPエラーの検出
$pos = strpos($http_response_header[0], '200');
if ($pos === false) {
// エラー処理
if (strstr($http_response_header[0], '400 Bad Request')) {
// ERROR
printf ("ERROR : HTTP ACCESS 400!\n");
exit;
} elseif (strstr($http_response_header[0], '403 Forbidden')) {
// ERROR
printf ("ERROR : HTTP ACCESS 403!\n");
exit;
} elseif (strstr($http_response_header[0], '404 NotFound')) {
printf ("ERROR : HTTP ACCESS 404!\n");
// 404はサーバ負荷により発生する可能性あり
// exit;
}
if ( $i == HTTP_TRY_NUM ){
exit;
}
// HTTPがOK時
} else {
// XML解析不要時 "$jobType = 1"
if ( $jobType == 1 ) {
return $response;
}
// MWSエラーのチェック
$response = preg_replace("/ns2:/", "ns2_", $response);
$amazon_xml = simplexml_load_string($response);
if ( isset($amazon_xml->Error->Message) ) {
// エラー処理
printf ("ERROR : HTTP ACCESS MWS i=%d!\n", $i );
// ERROR
if ( $i == HTTP_TRY_NUM ){
exit;
}
} else {
return $amazon_xml;
}
}
// Sleep (HTTP_TRY_TIMER) Seconds
sleep(HTTP_TRY_TIMER);
}
}
// URLを作る処理
function makeUrl($params, $baseurl, $secret_access_key, $jobType) {
// パラメータの順序を昇順に並び替えます
ksort($params);
// URLの追加部分を作成します
$option_string = '';
foreach ($params as $k => $v) {
// URLの追加部分をURLエンコードして&でつなげる。
$option_string .= '&'.urlencode_rfc3986($k).'='.urlencode_rfc3986($v);
}
// 最初の"&"のみ削除
$option_string = substr($option_string, 1);
// URL作成
$parsed_url = parse_url($baseurl);
if ( $jobType == 2 ){
$string_to_sign = "POST\n{$parsed_url['host']}\n{$parsed_url['path']}\n{$option_string}";
}else{
$string_to_sign = "GET\n{$parsed_url['host']}\n{$parsed_url['path']}\n{$option_string}";
}
// - HMAC-SHA256 を計算し、BASE64 エンコード
$signature = base64_encode(hash_hmac('sha256', $string_to_sign, $secret_access_key, true));
// - リクエストの末尾に署名を追加
$url = $baseurl.'?'.$option_string.'&Signature='.urlencode_rfc3986($signature);
// URLを返す
return $url;
}
// RFC3986 形式で URL エンコードする関数
function urlencode_rfc3986($str){
return str_replace('%7E', '~', rawurlencode($str));
}
?>
