Amazon中国輸入 | KeepaAPIを使用して商品リサーチの一部をシステム化してみた

B01LLES2VW
B00JTHF84S
B01J79JUNM
B01J79JX0W
B01J79K7PC
B01J79K388
B01J79JZAU
B01J79K5XQ
B01KRROGKA
B00BOP5PY6
・
・
・

<?php
// API キー
const API_KEY = "KeepaAPIキーを入力してください";
// API リンク
const API_URL = "https://api.keepa.com/product";
// 一回のバッジ実行で何行まで指定
const MAX_ROW = 80;
// ASINをコピペしたファイルを指定
const ASIN_LIST_FILE_PATH = "/var/www/html/amazon-sample/io/asinlist.txt";
// アウトプットするファイル名指定 ※可変にしないと実行の度に重複してしまいます。そのため定数でなく変数にしてます。
$output_file_path = "/var/www/html/amazon-sample/io/output" . date("YmdHis") . ".txt";

// ASINをコピペしたファイルからASINを配列で取得
$asin_list = returnTargetAsin();

// Keepa APIリンク組み立て
$target_asins_text =  implode(",", $asin_list);
$url = API_URL . "?key=". API_KEY . "&domain=5&stats=90&rating=1&asin=" . $target_asins_text;

// Keepa API接続
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_MAXREDIRS, 1);
curl_setopt($ch,CURLOPT_FOLLOWLOCATION,true);
curl_setopt($ch, CURLOPT_ENCODING, "gzip");
$response = curl_exec($ch);
curl_close($ch);

// Keepa APIから戻り値取得 + 変換
$productsArray = json_decode($response, true)["products"];

if (empty($productsArray)) {
    var_dump("トークン切れ");
    exit();
}

// Keepaから取得した商品リストから絞り込む
filterAsinItem($productsArray, $output_file_path);

// 処理したファイル行を処理
$fp2 = file(ASIN_LIST_FILE_PATH);
foreach ($asin_list as $key => $value) {
    // ファイル対象行削除
    unset($fp2[$key-1]);
    file_put_contents(ASIN_LIST_FILE_PATH, $fp2);
}

var_dump("処理完了！");
exit();



/**
 * asinlist.txtからAsinリストを処理できる形にします
 */
function returnTargetAsin() {
    // 処理
}

/**
 * Keepaから取得した商品から条件に合致する商品をリンク化してテキストにアウトプットします
 * 
 * @param array $items  KeepaAPIから取得した商品のリスト
 * @param string $output_file_path  対象となった商品をリンクとして書き出す際のファイルパス
 */
function filterAsinItem($items, $output_file_path) {
    // 処理
}

/**
 * asinlist.txtからAsinリストを処理できる形にします
 */
function returnTargetAsin() {
    $asin_list = array();

    if (file_exists(ASIN_LIST_FILE_PATH) && is_file(ASIN_LIST_FILE_PATH)) {
        $file = fopen(ASIN_LIST_FILE_PATH, "r");
        $i = 0;

        while (!feof($file)) {
            // 指定の行以上は処理しない
            if ($i >= MAX_ROW) {
                break;
            }
            // 改行コードを削ってコードを取得
            $line = fgets($file);
            $asin_code = str_replace("\n", '', rtrim($line));

            // 対象データと行数を保持しておく
            $i++;
            // 行末など、改行のみの場合があるため念のためチェック
            if (empty($asin_code)) {
                continue;
            }
            $asin_list[$i] = $asin_code;
        }
        fclose($file);
    }
    return $asin_list;
}

/**
 * Keepaから取得した商品から条件に合致する商品をリンク化してテキストにアウトプットします
 * 
 * @param array $items  KeepaAPIから取得した商品のリスト
 * @param string $output_file_path  対象となった商品をリンクとして書き出す際のファイルパス
 */
function filterAsinItem($items, $output_file_path) {
    $res = "";
    $importCost = 700; // 輸入コスト（一旦決め打ち）
    foreach ($items as $product) {
        try {
            // 商品重量が2キロ以上は不要
            if ($product["packageWeight"] >= 2000) {
                continue;
            }

            // サイズチェック
            // 縦（ミリでくるのでセンチに変換）
            $packageHeightCenti = $product["packageHeight"] / 10;
            // 横（ミリでくるのでセンチに変換）
            $packageWidthCenti = $product["packageWidth"] / 10;
            // 高さ（ミリでくるのでセンチに変換）
            $packageLengthCenti = $product["packageLength"] / 10;
            $size = $packageHeightCenti * $packageWidthCenti * $packageLengthCenti / 6000;
            // 縦 * 横 * 高さ / 6000 >= 2 にならない大きさの商品は不要
            if ($size >= 2) {
                continue;
            }

            // 新品商品価格の履歴
            $new_product_price = $product["csv"][1];
            $new_product_price = $new_product_price[count($new_product_price)-1]; //最新
            // 商品価格が1600円以下なら不要
            if ($new_product_price <= 1600) {
                continue;
            }

            // 30日間の販売数
            $salesRankDrops30 = $product["stats"]["salesRankDrops30"];
            // 90日間の販売数
            //$salesRankDrops90 = $product["stats"]["salesRankDrops90"];
            // 30日間の販売数が4以下なら不要
            if ($salesRankDrops30 <= 4) {
                continue;
            }

            // 販売価格
            $sellePrice = $new_product_price;
            // 仕入れ額(仮) ※ここでは甘めに1/3くらいを設定
            $prediction_purchase_cost = floor($sellePrice / 3); // 切り捨て
            // FBA手数料
            $selleFee = 30; // 一旦決め打ち
            $totalFbaFee = $product["fbaFees"]["pickAndPackFee"] + $product["fbaFees"]["storageFee"] + $selleFee;
            // 予測利益額(利益額 = 販売価格 - 仕入れ単価 - FBA手数料 - 輸入経費)
            $prediction_profit = $sellePrice - $prediction_purchase_cost - $totalFbaFee - $importCost;
            // 予測利益率(利益率 = 利益額 / 販売価格)
            $prediction_profit_par = ($prediction_profit / $sellePrice) * 100;
            // 甘めに見積もった利益率が20%を下回るようなら不要
            if ($prediction_profit_par < 20) {
                continue;
            }

            // 新品の出品者の数の履歴
            // 5日？間隔のデータを取得
            $count_new = $product["csv"][11];
            $new_product_seller_count_1 = empty($count_new[count($count_new)-1]) ? 0 : $count_new[count($count_new)-1]; //最新
            //$new_product_seller_time_1 = ($count_new[count($count_new)-2] + 21564000) * 60;
            $new_product_seller_count_2 = empty($count_new[count($count_new)-5]) ? 0 : $count_new[count($count_new)-5];
            //$new_product_seller_time_2 = ($count_new[count($count_new)-6] + 21564000) * 60;
            $new_product_seller_count_3 = empty($count_new[count($count_new)-11]) ? 0 : $count_new[count($count_new)-11];
            //$new_product_seller_time_3 = ($count_new[count($count_new)-12] + 21564000) * 60;
            // 直近の出費者の数をチェック
            if ($new_product_seller_count_1 > 1 || $new_product_seller_count_2 > 1 || $new_product_seller_count_3 > 1) {
                // nothing
            } else {
                continue;
            }

            // 評価の履歴 評価は0〜50の整数です（たとえば、45 = 4.5スター）
            $rating = $product["csv"][16];
            $rating_1 = $rating[count($rating)-1]; //最新
            // 直近の評価が3.5以下なら不要
            if ($rating_1 <= 3.5) {
                continue;
            }

            // 結果
            $res .= $product["title"] . "\n";
            $res .= "https://www.amazon.co.jp/dp/" . $product["asin"] . "\n\n";
        } catch (\Throwable $e) {
            continue;
        }
    }

    // 対象リストをファイルへ書き出しする
    if (empty($res) === false) {
        var_dump($res);
        $fp = fopen($output_file_path, "a");
        fwrite($fp, $res);
        fclose($fp);
    }
}