⑱MWS実践-フィード（出品/改定）-PHP

2015年10月14日
Amazon_MWS徹底解説

AmazonのMWSで追加出品・価格・在庫改定を実施するサンプルプログラムを提供します。
Amazonライブラリを使わずにPHPプログラムを記載していますので、カスタマイズされたい方にお勧めです。
MWSのフィード処理の動作は以前にこちらで説明していますので参照してください。(以前とのプログラム差分はAamzonライブラリを利用しているかいないかの違いです。)
動作はCentOS上で確認していますが、基本的にはどこでも動くはずです。
★★★設定必要★★★の部分をMWS登録で取得したIDに置き換えてください。

<?php
// Amazon MWS Sample Program
// PHP Amazonライブラリ未使用
// 出品/価格・在庫改定処理
// H27.10.14

// 各パラメータ設定
$country = 'US';        // JP,US,CA
$csvFile = 'csvFileUs.csv';        // csvFile
$jobType = 2;        // 1:_POST_FLAT_FILE_INVLOADER_DATA_,2:_POST_FLAT_FILE_PRICEANDQUANTITYONLY_UPDATE_DATA_,3:_POST_FLAT_FILE_LISTINGS_DATA_

$currentDir = getcwd();
define("DIR_DATA_UPLD",     $currentDir);
define("AllListChange",     0);             // 完全上書き：1、追加修正：0
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


$resultFile = sprintf('%s/%s_RESULT_%s.txt', DIR_DATA_UPLD, $country, date('Ymd') );

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;
}

//ディレクトリ・ハンドルをオープン
$fullName = DIR_DATA_UPLD . "/" . $csvFile;

// 送信ファイルを$feedに読み込む
if ( !$feed = file_get_contents($fullName) ) {
    printf ( "MWS[SubmitFeed]にてファイル読み込み失敗=%s\n", $fullName );
}

// ファイルの行数を読む
if ( $jobType == 3 ) {
    $fileCount = 1;
} else {
    $fileCount = count( file( $fullName ) ) - 1;
}

// ***************** SubmitFeed ****************
$params=array();
$params['AWSAccessKeyId']    = $access_key_id;
$params['Merchant']          = $merchant_id;
$params['SignatureMethod']   = 'HmacSHA256';
$params['SignatureVersion']  = '2';
$params['Version']           = '2009-01-01';
$params['Timestamp']         = gmdate('Y-m-d\TH:i:s\Z');    // Timeは毎回Checkされる【ISO8601,UTC(GMT)】
$params['Action']            = 'SubmitFeed';
$params['MarketplaceIdList.Id.1']    = $marketplace_id;

if ( $jobType == 1 ) {
    $params['FeedType']      = '_POST_FLAT_FILE_INVLOADER_DATA_';
    if ( AllListChange == 1 ) {
        $params['PurgeAndReplace']       = 'true';
        } else {
        $params['PurgeAndReplace']       = 'false';
        }
} elseif( $jobType == 2 ) {
        $params['FeedType'] = '_POST_FLAT_FILE_PRICEANDQUANTITYONLY_UPDATE_DATA_';
        $params['PurgeAndReplace']       = 'false';
} elseif( $jobType == 3 ) {
        $params['FeedType'] = '_POST_FLAT_FILE_LISTINGS_DATA_';
        $params['PurgeAndReplace']       = 'false';
}

// URLの作成
$url = makeUrl($params, $baseurl, $secret_access_key, 2);

// ファイルハンドルへの記載
$feedHandle = @fopen('php://temp', 'rw+');
fwrite($feedHandle, $feed);
rewind($feedHandle);

// Headerの情報の作成
$culc_md5 = base64_encode(md5(stream_get_contents($feedHandle), true));
rewind($feedHandle);
$headParam = array(
    "Expect: ",
    "Accept: ",
    "Transfer-Encoding: chunked",
    "Content-MD5: $culc_md5",
    "Content-Type: application/octet-stream"
);

// UserAgentの作成
$userAgent = 'YnetSubmitFeed/1.0';
$userAgent .= ' (';
$userAgent .= 'Language=PHP/' . phpversion();
$userAgent .= '; ';
$userAgent .= 'Platform=' . php_uname('s') . '/' . php_uname('m') . '/' . php_uname('r');
$userAgent .= '; ';
$userAgent .= 'MWSClientVersion=2011-08-01';

// HTTPアクセスを行う処理（HTTP_TRY_NUM回のリトライを行う）
for ($i=1; $i <= HTTP_TRY_NUM; $i++) {

    // CURLの設定
    $curlOpts_arry = array(
        CURLOPT_POST              => true ,
        CURLOPT_USERAGENT         => $userAgent ,
        CURLOPT_VERBOSE           => true ,
        CURLOPT_RETURNTRANSFER    => true ,
        CURLOPT_SSL_VERIFYPEER    => true ,
        CURLOPT_SSL_VERIFYHOST    => 2 ,
        CURLOPT_URL               => $url ,
        CURLOPT_HTTPHEADER        => $headParam ,
        CURLOPT_INFILE            => $feedHandle ,
        CURLOPT_UPLOAD            => true ,
        CURLOPT_CUSTOMREQUEST     => "POST"
    );

    $curlOpts = curl_init();
    curl_setopt_array($curlOpts, $curlOpts_arry);

    // HTMLアクセスを行う（送受信する）
    if( $contents = curl_exec($curlOpts) ) { 
        break; 
    }
    printf ( "SubmitFeedでcurl_exeエラー=%s\n", curl_error($curlOpts));
    trigger_error(curl_error($curlOpts));
    if( $i == HTTP_TRY_NUM ) { 
        exit;
    } 
    curl_close($curlOpts);
}

$amazon_xml = simplexml_load_string($contents);

// レスポンスヘッダを確認する
if (isset($amazon_xml->SubmitFeedResult->FeedSubmissionInfo->FeedSubmissionId)) {
    $FeedSubmissionId    = $amazon_xml->SubmitFeedResult->FeedSubmissionInfo->FeedSubmissionId;
} else {
    printf ( "SubmitFeedで正常なレスポンスがありません\n" );
    exit;
}

// ログに記載
printf ( "MWS[SubmitFeed]にてファイルUPLOAD完了 FeedSubmissionId=%s 送信数=%s\n", $FeedSubmissionId, $fileCount);


// ***************** GetFeedSubmissionList ****************

// DONEになるまで繰り返す
while(true) {

    $params=array();
    $params['AWSAccessKeyId']    = $access_key_id;
    $params['Merchant']          = $merchant_id;
    $params['SignatureMethod']   = 'HmacSHA256';
    $params['SignatureVersion']  = '2';
    $params['Version']           = '2009-01-01';
    $params['Timestamp']         = gmdate('Y-m-d\TH:i:s\Z');    // Timeは毎回Checkされる【ISO8601,UTC(GMT)】

    $params['Action']            = 'GetFeedSubmissionList';
    $params['FeedSubmissionIdList.Id.1']    = $FeedSubmissionId;

    // URLの作成
    $url = makeUrl($params, $baseurl, $secret_access_key, 1);

    // HTMLアクセスを行う
    $amazon_xml    = accessHttp( $url, 0 );

    // FeedProcessingStatusの取得
    if (isset($amazon_xml->GetFeedSubmissionListResult->FeedSubmissionInfo->FeedProcessingStatus)) {
        $FeedProcessingStatus    = $amazon_xml->GetFeedSubmissionListResult->FeedSubmissionInfo->FeedProcessingStatus;
    } else {
        printf( "GetFeedSubmissionListで正常な応答がありません\n" );
        exit;
    }

    if ( $FeedProcessingStatus == '_DONE_') {
        // ログに記載
        printf( "MWS[GetFeedSubmissionList]にて「_DONE_」を確認 FeedSubmissionId=%s\n", $FeedSubmissionId);
        // ループを抜ける
        break;
    }
    sleep(180);
}


// ***************** GetFeedSubmissionResult ****************

$params=array();
$params['AWSAccessKeyId']    = $access_key_id;
$params['Merchant']          = $merchant_id;
$params['SignatureMethod']   = 'HmacSHA256';
$params['SignatureVersion']  = '2';
$params['Version']           = '2009-01-01';
$params['Timestamp']         = gmdate('Y-m-d\TH:i:s\Z');    // Timeは毎回Checkされる【ISO8601,UTC(GMT)】
$params['Action']            = 'GetFeedSubmissionResult';
$params['FeedSubmissionId']  = $FeedSubmissionId;

// URLの作成
$url = makeUrl($params, $baseurl, $secret_access_key, 1);

// HTMLアクセスを行う
$get_contents    = accessHttp( $url, 1 );

// ファイルに書き込み
$fp = fopen( $resultFile , 'a');
$tmpWord = "\n------------------------------- [ UploadFile = $csvFile ]--------------------------------\n";
fwrite($fp, $tmpWord);
fwrite($fp, $get_contents);
fclose($fp);

// ログに記載
printf ( "MWS[GetFeedSubmissionResult]にて結果ファイル作成完了 File=%s\n", $resultFile );

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));
}

?>

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

341

342

343

344

345

346

347

348

349

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366

367

368

369

370

371

372

373

<?php

// Amazon MWS Sample Program

// PHP Amazonライブラリ未使用

// 出品/価格・在庫改定処理

// H27.10.14

// 各パラメータ設定

$country = 'US'; // JP,US,CA

$csvFile = 'csvFileUs.csv'; // csvFile

$jobType = 2; // 1:_POST_FLAT_FILE_INVLOADER_DATA_,2:_POST_FLAT_FILE_PRICEANDQUANTITYONLY_UPDATE_DATA_,3:_POST_FLAT_FILE_LISTINGS_DATA_

$currentDir = getcwd();

define("DIR_DATA_UPLD", $currentDir);

define("AllListChange", 0); // 完全上書き：1、追加修正：0

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

$resultFile = sprintf('%s/%s_RESULT_%s.txt', DIR_DATA_UPLD, $country, date('Ymd') );

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;