沃尔玛api接口

摇蓝發表於 2022-5-18 16:31:00

接口文档：https://developer.walmart.com/home/us-mp/
沃尔玛api 分为US站点和CA站点
US站点是获取token的方式
MX站点获取方式和US差不多多一个参数  "WM_MARKET: mx",
CA站点是签名的方式
US刷新token
<div class="cnblogs_code">
<pre> /**
* walmart获取token （ us站点和 mx站点）
* @url /services/walmart/walmartpromotions/batchupdatetoken
*/
public function actionBatchupdatetoken() {
 ini_set("memory_limit","500M");
 set_time_limit(3600);
 $model =YbModel::model('WalmartAccount');
 $id = Yii::app()->request->getParam('id');
 $where = " site in('us','mx') and status=1 ";
 if($id){
 $where .=" and id=". $id;
 }
 $sql = "select * from yibai_walmart_account where ".$where;
 $accountList = $model->getDbConnection()->createCommand($sql)->queryAll();
 if($accountList) {
 $i = 1;
 foreach ($accountList as $val) {
 $accountInfo = YbModel::model('WalmartAccount')->findByPk($val['id']);
 if ($accountInfo) {
 $this->client_id = $accountInfo['client_id'];
 $this->client_sec = $accountInfo['client_sec'];
 if (!empty($accountInfo['client_id'] && !empty($accountInfo)))
 {
 $result = $accountInfo->getTokenFromRefreshToken();
 if (isset($result['access_token']) && !empty($result['access_token'])) {
 $accountInfo->access_token = $result['access_token'];
 $accountInfo->expires_in = $result['expires_in'];
 $accountInfo->expiry_time = date('Y-m-d H:i:s', time() + $result['expires_in']);
 $accountInfo->update_time = date('Y-m-d H:i:s', time());
 $accountInfo->save(false);
 echo $val['id'].' ';
 $i++;
 }
 }

 }
 }
 }
 echo '共更新账号数：'.$i.' ';
}

/*
获取token
*/
public function getTokenFromRefreshToken()
{
 $clientId =$this->client_id;
 $clientSecret =$this->client_sec;
 $site = $this->site;
 $qos = uniqid();
 if($site=="us"){
 $header = array(
 "Authorization: Basic " . base64_encode("" .$clientId . ":" . $clientSecret . ""),
 'Content-Type: application/x-www-form-urlencoded',
 'Accept: application/json',
 'WM_SVC.NAME: Walmart Marketplace',
 'WM_QOS.CORRELATION_ID: '.$qos,
 'WM_SVC.VERSION: 1.0.0'
 );
 }elseif($site=="mx"){
 $header = array(
 "WM_MARKET: mx",
 "Authorization: Basic " . base64_encode("" .$clientId . ":" . $clientSecret . ""),
 'Content-Type: application/x-www-form-urlencoded',
 'Accept: application/json',
 'WM_SVC.NAME: Walmart Marketplace',
 'WM_QOS.CORRELATION_ID: '.$qos,
 'WM_SVC.VERSION: 1.0.0'
 );
 }

 $param=array(
 'grant_type'=>'client_credentials',
 );
 $url=self::TOKEN_URL;
 return self::CurlRequest($url, $param, $header,600);
}

private static function CurlRequest($url, $data='', $header=array(), $timeout=300)
{
 $opts = array();
 $opts = $url;
 $opts = 0;
 $opts = $header;
 $opts = 1;
 if(!empty($data))//POST请求
 {
 $opts = 1;
 $opts = is_array($data) ? http_build_query($data) : $data;
 }
 $opts = $timeout;
 $opts = 0;
 $opts = 0;
 $ch = curl_init();
 curl_setopt_array($ch, $opts);
 $response_raw = curl_exec($ch);
 $errno = curl_errno($ch);
 if (0 !== $errno) { #返回头信息
 return curl_getinfo($ch) + array('errno'=>$errno, 'error'=>curl_error($ch));
 }
 curl_close($ch);
 $response = json_decode($response_raw, 1);
 if(!is_array($response))
 {
 $response = ['errno'=>500, 'error'=>$response_raw];
 }
 //echo '<pre>';
 //print_r($response);
 return $response;
}</pre>
</div>
  追加：
沃尔玛拉取listing 有下载文件形式的 getReport  （系统自动申请报告，只适合 mx和ca站点）
<div class="cnblogs_code">
<pre> /**
* 下载压缩包->actionGetallitemreport(解压压缩包)
* 拉取Item report
* 返回与沃尔玛平台上设置的Seller项目相关的所有信息。
* /services/walmart/walmartlisting/getzip/account_id/1
*/
public function actionGetZip()
{
 ini_set("memory_limit","3000M");
 set_time_limit(3600);
 $start_time = microtime(true);
 $account_id = Yii::app()->request->getParam('account_id');
 if ($account_id) {
 /******************* 添加执行日志start ***********************/
 $execute_param = array(
 "type" => 301,
 "type_name" => "拉取listing压缩文件",
 "keyword" => "getzip",
 "exp3" => $account_id,
 "exp1" => "walmartlisting",
 );
 YbModel::model('WalmartExecuteLog')->insertData($execute_param);
 /******************* 添加执行日志end ***********************/

 $idArr =explode(',',$account_id);
 foreach ($idArr as $id){
 $walmartPostService = new WalmartListingData($id);
 $walmartPostService->getAllItemreport($id);
 }
 }else{
 $accountList = YbModel::model('WalmartAccount')->getInfoByWhere( "status = 1 and site in('mx','ca')", "id");
 $accountList = array_column($accountList,'id');
 if(!empty($accountList)){
 foreach ($accountList as $val){
 MHelper::runThreadSOCKET('/services/walmart/walmartlisting/getzip/account_id/'.$val);
 sleep(5);
 }
 }
 }
 $end_time = microtime(true);
 echo '执行完成, 耗时：' . round(($end_time - $start_time), 3).'秒';
 exit;
}

/**
* 拉取Item report
* @param $accountId
* @return bool|int
*/
public function getAllItemreport($accountId)
{
 $accountInfo = array();

 if($this->site=='ca'){
 $url = "https://marketplace.walmartapis.com/v3/getReport?type=item_ca"; //v2->v3更新时间 2019-10-30
 $extra = [
 "Accept"=>"application/xml",
 "Content-Type"=>"application/xml",
 ];
 }elseif($this->site=='us'){
 $url = "https://marketplace.walmartapis.com/v3/getReport?type=item"; //v2->v3更新时间 2019-10-30
 $extra = [
 "Accept"=>"application/xml",
 "content-type"=>"text/plain",
 ];
 }elseif($this->site=='mx'){
 $url = "https://marketplace.walmartapis.com/v3/getReport?type=item_mx"; //v2->v3更新时间 2019-10-30
 $extra = [
 "Accept"=>"application/xml",
 "content-type"=>"text/plain",
 ];
 }

 $headers = $this->getHeaders($url, 'GET', $accountInfo, $extra);
 $result=$this->getResult($url, $headers);
 $date = date('Ymd');
 $path = Yii::getPathOfAlias('webroot') . '/upload/erp_log/walmartreport/';
 if (!file_exists($path)) {
 mkdir(Yii::getPathOfAlias('webroot') . '/upload/erp_log/', 0777);
 mkdir($path, 0777);
 }

 $filename = $path.'walmartreport_'.$date.'_'.$accountId.'.zip'; //设置文件名
 //$filename =Yii::app()->params['FILE_BASE_DIR'].'/erp_log/walmartreport/walmartreport_'.$date.'_'.$accountId.'.zip'; //设置文件名
 file_put_contents($filename,$result);
}

/**
* @desc 获取要发送的头部信息
* @access protected
* @param string $url 请求沃尔玛的地址
* @param string $method 请求方式
* @param array $account_info 包含私钥的沃尔玛账户信息
* @param array $extra 除默认的头部信息之外每个接口要单独设置的头部信息
*/
protected function getHeaders($url, $method='GET', $account_info, $extra=array())
{
 if (empty($url)) {
 return false;
 }
 //默认的而且是必须的头部信息
 /* $default = [
 "WM_SVC.NAME: Walmart Marketplace",
 "WM_QOS.CORRELATION_ID: " . $this->getRandStr(),
 "WM_SEC.TIMESTAMP: " . $timestamp,
 "WM_SEC.AUTH_SIGNATURE: " . $signature,
 "WM_CONSUMER.CHANNEL.TYPE: " . $api_config['channel_type'],
 "WM_CONSUMER.ID: " . $api_config['consumer_id'],
 "Expect:",
 ]; */

 if($this->site =='ca'){
 //获取签名和时间戳
 list($signature, $timestamp) = $this->getSignatureAndTimestamp($url, $method, $account_info);
 $default = [
 "WM_SVC.NAME" => "Walmart Marketplace",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "WM_SEC.TIMESTAMP" => $timestamp,
 "WM_SEC.AUTH_SIGNATURE" => $signature,
 "WM_CONSUMER.CHANNEL.TYPE" => $this->channel_type,
 "WM_CONSUMER.ID" => $this->consumer_id,
 ];
 } elseif($this->site =='us') {
 $default = [
 "WM_SVC.NAME" => "Walmart Marketplace",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "Authorization" => "Basic " . base64_encode($this->client_id . ":" . $this->client_sec),
 "WM_SEC.ACCESS_TOKEN" => $this->access_token,
 ];
 }elseif($this->site =='mx') {
 $default = [
 "WM_MARKET" => "mx",
 "WM_SVC.NAME" => "Walmart Marketplace",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "Authorization" => "Basic " . base64_encode($this->client_id . ":" . $this->client_sec),
 "WM_SEC.ACCESS_TOKEN" => $this->access_token,
 ];

 }
 $ss = array_merge($this->header_params,$default,$extra);
 return $this->structureHeaders($ss);
}</pre>
</div>
基础类 WalmartAp.php
<div class="cnblogs_code">
<pre><?php
/**
*沃尔玛请求接口父类文件
*包含了获取沃尔玛接口签名方法，以及组装沃尔玛头部认证的头部信息
*包含了沃尔玛get接口请求实例,以及post接口请求实例
*所有的沃尔玛相关业务接口均继承本类
* @author YB
* @version v3
* @since 1.0
*/
class WalmartApi {
public function __construct() {
}
/**
* @desc 生成沃尔玛相关接口的签名和时间戳
* @access protected
* @param string $url 要请求的接口的完整url包括参数
* @param string $method 请求接口的方式(GET,POST)
* @param array $account_info 包含账户私钥的沃尔玛账户信息
*/
protected function getSignatureAndTimestamp($url, $method, $account_info)
{
 //生成以毫秒为单位的时间戳
 list($tmp1, $tmp2) = explode(' ', microtime());
 $timestamp = (float)sprintf('%.0f', (floatval($tmp1) + floatval($tmp2)) * 1000);

 //沃尔玛api账户信息包含要签名的私钥
 //$api_config = $account_info;

 //引入签名的第三方库
 Yii::import("application.vendors.*");
 include_once "phpseclib/Crypt/RSA.php";
 include_once "phpseclib/Math/BigInteger.php";

 //待签名的字符
 $signature_str = $this->consumer_id . "\n" . $url . "\n" . $method . "\n" . $timestamp . "\n";

 $rsa = new Crypt_RSA();
 $rsa->setPrivateKeyFormat(CRYPT_RSA_PRIVATE_FORMAT_PKCS8);
 $rsa->setPublicKeyFormat(CRYPT_RSA_PUBLIC_FORMAT_PKCS8);
 $rsa->loadKey($this->private_key); // private key
 $rsa->setHash('sha256');
 $rsa->setSignatureMode(CRYPT_RSA_SIGNATURE_PKCS1);
 $signature = $rsa->sign($signature_str);

 //返回签名后的字符和时间戳
 return ;
}
/**
* @desc 获取要发送的头部信息
* @access protected
* @param string $url 请求沃尔玛的地址
* @param string $method 请求方式
* @param array $account_info 包含私钥的沃尔玛账户信息
* @param array $extra 除默认的头部信息之外每个接口要单独设置的头部信息
*/
protected function getHeadersnew($url, $method='GET', $account_info, $extra=array())
{
 if (empty($url)) {
 return false;
 }

 if(!empty($account_info)){
 $this->site = $account_info['site'];
 $this->client_id = $account_info['client_id'];
 $this->client_sec = $account_info['client_sec'];
 $this->access_token = $account_info['access_token'];
 $this->channel_type = $account_info['channel_type'];
 }
 if($this->site !='us'){
 //获取签名和时间戳
 list($signature, $timestamp) = $this->getSignatureAndTimestamp($url, $method, $account_info);
 $default = [
 "WM_SVC.NAME" => "Walmart Marketplace",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "WM_SEC.TIMESTAMP" => $timestamp,
 "WM_SEC.AUTH_SIGNATURE" => $signature,
 "WM_CONSUMER.CHANNEL.TYPE" => $this->channel_type,
 "WM_CONSUMER.ID" => $this->consumer_id,
 ];
 } else {
 $default = [
 "WM_SVC.NAME" => "Walmart Marketplace",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "Authorization" => "Basic " . base64_encode($this->client_id . ":" . $this->client_sec),
 "WM_SEC.ACCESS_TOKEN" => $this->access_token,
 ];
 }
 return $this->structureHeaders(array_merge($this->header_params,$default,$extra));
}

/**
* @desc 获取要发送的头部信息
* @access protected
* @param string $url 请求沃尔玛的地址
* @param string $method 请求方式
* @param array $account_info 包含私钥的沃尔玛账户信息
* @param array $extra 除默认的头部信息之外每个接口要单独设置的头部信息
*/
protected function getHeaders($url, $method='GET', $account_info, $extra=array())
{
 if (empty($url)) {
 return false;
 }
 //默认的而且是必须的头部信息
 /* $default = [
 "WM_SVC.NAME: Walmart Marketplace",
 "WM_QOS.CORRELATION_ID: " . $this->getRandStr(),
 "WM_SEC.TIMESTAMP: " . $timestamp,
 "WM_SEC.AUTH_SIGNATURE: " . $signature,
 "WM_CONSUMER.CHANNEL.TYPE: " . $api_config['channel_type'],
 "WM_CONSUMER.ID: " . $api_config['consumer_id'],
 "Expect:",
 ]; */

 if($this->site =='ca'){
 //获取签名和时间戳
 list($signature, $timestamp) = $this->getSignatureAndTimestamp($url, $method, $account_info);
 $default = [
 "WM_SVC.NAME" => "Walmart Marketplace",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "WM_SEC.TIMESTAMP" => $timestamp,
 "WM_SEC.AUTH_SIGNATURE" => $signature,
 "WM_CONSUMER.CHANNEL.TYPE" => $this->channel_type,
 "WM_CONSUMER.ID" => $this->consumer_id,
 ];
 } elseif($this->site =='us') {
 $default = [
 "WM_SVC.NAME" => "Walmart Marketplace",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "Authorization" => "Basic " . base64_encode($this->client_id . ":" . $this->client_sec),
 "WM_SEC.ACCESS_TOKEN" => $this->access_token,
 ];
 }elseif($this->site =='mx') {
 $default = [
 "WM_MARKET" => "mx",
 "WM_SVC.NAME" => "Walmart Marketplace",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "Authorization" => "Basic " . base64_encode($this->client_id . ":" . $this->client_sec),
 "WM_SEC.ACCESS_TOKEN" => $this->access_token,
 ];

 }
 $ss = array_merge($this->header_params,$default,$extra);
 return $this->structureHeaders($ss);
}
/**
* @desc 生成随机的数字和字母的组合的一个字符串
* @access private
* @return string
*/
private function getRandStr()
{
 $chars = array(
 "a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k",
 "l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v",
 "w", "x", "y", "z",
 );
 $chars_len = count($chars) - 1;
 shuffle($chars);
 list($letter, $number) = ["",""];
 for ($i=0; $i<4; $i++) {
 $letter .= $chars;
 $number .= mt_rand(1, 9);
 }
 return $number . $letter;
}
/**
* @desc get方法请求接口获取请求结果
* @access protected
* @param string $url 请求的接口地址包括参数
* @param array $headers 要设置的头部信息
*/
protected function getResult($url, $headers)
{
 $ch = curl_init();
 curl_setopt($ch, CURLOPT_URL, $url);
 curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
 curl_setopt($ch, CURLOPT_HTTPGET, true);
 curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // 对认证证书来源的检查
 curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
 curl_setopt($ch, CURLOPT_TIMEOUT, 500);
 curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
 $data = curl_exec($ch);
 if($_GET['istest']==1){
 $curlInfo = curl_getinfo($ch);
 // var_dump($data);
 echo '<pre>';print_r($curlInfo);
 }
 curl_close($ch);
 return $data;
}
/**
* @desc post方法请求接口获取请求结果
* @access protected
* @param string $url 要请求的沃尔玛接口地址
* @param array $body 要发送请求body
* @param array $header 要设置的头部信息
* @param array $formart 返回值类型 xml、json
*/
protected function postResult($url, $body, $header,$formart='json')
{
 $ch = curl_init();
 curl_setopt($ch, CURLOPT_URL, $url);
 curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
 curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
 curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,false);
 curl_setopt($ch, CURLOPT_TIMEOUT, 120);
 curl_setopt($ch, CURLOPT_POST, 1);
 curl_setopt($ch,CURLOPT_ENCODING,""); // 返回数据支持所有编码，不乱码；如果为空字符串""，会发送所有支持的编码类型。
 curl_setopt($ch, CURLOPT_POSTFIELDS,$body);
 $data = curl_exec($ch);
 $curlInfo = curl_getinfo($ch);
 if($_GET['istest']==1){
 var_dump($data);
 echo '<pre>';print_r($curlInfo);
 $version = curl_version();
 echo '<pre>';print_r($version);
 }
 curl_close($ch);
 if($formart == 'json'){

 }elseif($formart == 'xml'){
 $preg = "/(<|<\/)(?:\w+:)/is";
 $newXmlStr = preg_replace($preg,"\\1",$data);
 //echo $newXmlStr;
 $data = simplexml_load_string($newXmlStr);
 $data = $data?$data:array('http_code'=>$curlInfo['http_code']);
 }
 return $data;
}
/**
* 获取标记已发货接口要发送的请求体的信息
* @access protected
* @param array $params 要标记发货要求发送的请求body信息
*/
protected function getShipOrderRequestBodyData($params)
{
 $orderLineArr = array(); //保存多个item
 if((isset($params['otherCarrier'])) && ($params['otherCarrier'] == "OTHER-ST")){
 foreach( $params['lineNumbers'] as $key=>$val ){
 $orderLineArr["orderLine"][] = array(
 "lineNumber" => $val,
 "orderLineStatuses" => array(
 "orderLineStatus" => array(
 array(
 "status" => "Shipped",
 "statusQuantity" => array(
 "unitOfMeasurement" => "EACH",
// "amount" => "1",
 "amount" => !empty($params['amount'][$val]) && $params['amount'][$val] > 1 ?$params['amount'][$val]:1,
 ),
 "trackingInfo" => array(
 "shipDateTime" => $params['shipDateTime'],
 "carrierName" => array(
 "otherCarrier" => $params['otherCarrier'],
 ),
 "methodCode" => 'Standard',
 "trackingNumber" => $params['trackingNumber'],
// "trackingURL" => $params['trackingURL'],
 "trackingURL" => 'http://tracking.asendiausa.com/t.aspx?p'
 ),
 ),
 ),
 ),
 );
 }
 $add_message = array();
 $add_message['account_id'] = $params['account_id'];
 $add_message['task_name'] = "WALMART_biaoji";
 $add_message['start_time'] = date("Y-m-d H:i:s");
 $add_message['end_time'] = date("Y-m-d H:i:s");
 $add_message['order_id'] = $params['order_id'];
 $add_message['platform_order_id'] = $params['platform_order_id'];
 $add_message['status'] = 'WALMART';
 Yii::app()->db->createCommand()->insert('{{system}}.{{mall_api_log}}', $add_message);

 }else{
 foreach( $params['lineNumbers'] as $key=>$val ){
 $orderLineArr["orderLine"][] = array(
 "lineNumber" => $val,
 "orderLineStatuses" => array(
 "orderLineStatus" => array(
 array(
 "status" => "Shipped",
 "statusQuantity" => array(
 "unitOfMeasurement" => "EACH",
// "amount" => "1",
 "amount" => !empty($params['amount'][$val]) && $params['amount'][$val] > 1?$params['amount'][$val]:1,
 ),
 "trackingInfo" => array(
 "shipDateTime" => $params['shipDateTime'],
 "carrierName" => array(
 "otherCarrier" => null,
 "carrier" => $params['carrier']
 ),
 "methodCode" => $params['methodCode'],
 "trackingNumber" => $params['trackingNumber'],
 "trackingURL" => $params['trackingURL'],
 ),
 ),
 ),
 ),
 );
 }
 }

 $body = array(
 "orderShipment" => array(
 "orderLines" => $orderLineArr,
 ),
 );
 //返回要发送的json格式数据
 return json_encode($body);
}

protected function getShipOrderRequestBodyData_bak($params)
{
 $orderLineArr = array(); //保存多个item
 foreach( $params['lineNumbers'] as $key=>$val ){
 $orderLineArr["orderLine"][] = array(
 "lineNumber" => $val,
 "orderLineStatuses" => array(
 "orderLineStatus" => array(
 array(
 "status" => "Shipped",
 "statusQuantity" => array(
 "unitOfMeasurement" => "EA",
 "amount" => "1",
 ),
 "trackingInfo" => array(
 "shipDateTime" => $params['shipDateTime'],
 "carrierName" => array(
 "otherCarrier" => null,
 "carrier" => $params['carrier']
 ),
 "methodCode" => $params['methodCode'],
 "trackingNumber" => $params['trackingNumber'],
 //"trackingURL" => $order_info['trackingURL']
 ),
 ),
 ),
 ),
 );
 }

 $body = array(
 "orderShipment" => array(
 "orderLines" => $orderLineArr,
 ),
 );
 //返回要发送的json格式数据
 return json_encode($body);
}

/**
* 获取标记已发货接口要发送的请求体的信息[针对dsv]
* @access protected
* @param array $params 要标记发货要求发送的请求body信息
*/
protected function getShipOrderRequestBodyDataDsv($params){
 $orderLineArr = array(); //保存多个item
 foreach( $params['lineNumbers'] as $key=>$val ){
 $orderLineArr["orderLine"][] = array(
 "lineNumber" => $val,
 "orderLineStatuses" => array(
 "orderLineStatus" => array(
 "status" => "Shipped",
 "statusQuantity" => array(
 "unitOfMeasurement" => "Each",
// "amount" => "1",
 "amount" => !empty($params['amount'][$val]) && $params['amount'][$val] > 1?$params['amount'][$val]:1,
 ),
 "trackingInfo" => array(
 "shipDateTime" => $params['shipDateTime'],
 "carrierName" => array(
 //"otherCarrier" => $params['carrier'],
 "carrier" => $params['carrier']
 ),
 "methodCode" => $params['methodCode'],
 "trackingNumber" => $params['trackingNumber'],
 //"trackingURL" => $params['tracking_url']
 ),
 ),
 ),
 );
 }

 $body = array(
 "orderLines" => $orderLineArr,
 );
 //返回要发送的json格式数据
 return $this->requestXmlBody($body);

}

/**
* @desc 获取要发送的头部信息[针对dsv]
* @access protected
* @param string $url 请求沃尔玛的地址
* @param string $method 请求方式
* @param array $account_info 包含私钥的沃尔玛账户信息
* @param array $extra 除默认的头部信息之外每个接口要单独设置的头部信息
*/
protected function getHeadersDsv($url, $method='GET', $account_info, $extra=array())
{
 if (empty($url)) {
 return false;
 }
 //获取签名和时间戳
 list($signature, $timestamp) = $this->getSignatureAndTimestamp($url, $method, $account_info);

 //默认的而且是必须的头部信息
 /* $default = [
 "WM_SVC.NAME: Drop Ship Vendor Services",
 "WM_QOS.CORRELATION_ID: " . $this->getRandStr(),
 "WM_SEC.TIMESTAMP: " . $timestamp,
 "WM_SEC.AUTH_SIGNATURE: " . $signature,
 "WM_CONSUMER.CHANNEL.TYPE: " . $api_config['channel_type'],
 "WM_CONSUMER.ID: " . $api_config['consumer_id'],
 ]; */

 $default = [
 "WM_SVC.NAME" => "Drop Ship Vendor Services",
 "WM_QOS.CORRELATION_ID" => $this->getRandStr(),
 "WM_SEC.TIMESTAMP" => $timestamp,
 "WM_SEC.AUTH_SIGNATURE" => $signature,
 "WM_CONSUMER.CHANNEL.TYPE" => $this->channel_type,
 "WM_CONSUMER.ID" => $this->consumer_id,
 ];
 //return array_merge($default, $extra);
 return $this->structureHeaders(array_merge($this->header_params,$default,$extra));
}

public static function getXmlGeneratorObj() {
 return new XmlGenerator();
}

/**
* request xml body
*/
public function requestXmlBody(array $params=array()) {
 $xmlObj = self::getXmlGeneratorObj();
 $xmlObj->XmlWriter()
 ->push('ns2:orderShipment', array( 'xmlns:ns2' => 'http://walmart.com/mp/v3/orders','xmlns:ns3' => 'http://walmart.com/'))
 ->buildXMLFilterArr($params,'',array(),'ns2')
 ->pop();

 return $xmlObj->getXml();
}

/**
* @param string $xmlStr
* @return SimpleXMLElement
*/
public function parseXML($xmlStr = '')
{
 $preg = "/(<|<\/)(?:\w+:)/is";
 $newXmlStr = preg_replace($preg,"\\1",$xmlStr);
 $data = simplexml_load_string($newXmlStr);
 return $data;
}
/**
* 对象转关联数组
* @author YB
* @param object $obj
* @return array
*/
public function object_to_array($obj){
 $_arr = is_object($obj) ? get_object_vars($obj) : $obj;
 foreach ($_arr as $key => $val){
 $val = (is_array($val) || is_object($val)) ? $this->object_to_array($val) : $val;
 $arr[$key] = $val;
 }
 return $arr;
}

/**
* @desc 构建http请求头部
*/
public function structureHeaders(array $headers = []){
 $ret = [];
 foreach($headers as $key=>$value){
 if($key) $ret[] = $key.': '.$value;
 }
 return $ret;
}
protected function deleteResult($url, $body, $header)
{
 $ch = curl_init();
 curl_setopt($ch, CURLOPT_URL, $url);
 curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
 curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
 curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,false);
 curl_setopt($ch, CURLOPT_TIMEOUT, 120);
 curl_setopt($ch, CURLOPT_POST, 1);
 curl_setopt($ch, CURLOPT_POSTFIELDS,$body);
 curl_setopt ($ch, CURLOPT_CUSTOMREQUEST, "DELETE");
 $data = curl_exec($ch);
 $curlInfo = curl_getinfo($ch);
 if($_GET['istest']==1){

 var_dump($data);
 echo '<pre>';print_r($curlInfo);
 }
 curl_close($ch);
 $preg = "/(<|<\/)(?:\w+:)/is";
 $newXmlStr = preg_replace($preg,"\\1",$data);
 //echo $newXmlStr;
 $data = simplexml_load_string($newXmlStr);
 $data = $data?$data:array('http_code'=>$curlInfo['http_code']);
 return $data;
}
}</pre>
</div>
 
配置
<div class="cnblogs_code">
<pre>'header_params' => ['us' => ['WM_SVC.NAME' => 'Walmart Marketplace',

 'WM_QOS.CORRELATION_ID' => '',

 'WM_SEC.TIMESTAMP' => '',

 'WM_SEC.AUTH_SIGNATURE' => '',

 'WM_CONSUMER.CHANNEL.TYPE' => '',

 'WM_CONSUMER.ID' => '',

 'Accept' => 'application/json',

 'Expect'=>''],

 'mx' => [
 'WM_MARKET' => 'mx',

 'WM_SVC.NAME' => 'Walmart Marketplace',

 'WM_QOS.CORRELATION_ID' => '',

 'WM_SEC.TIMESTAMP' => '',

 'WM_SEC.AUTH_SIGNATURE' => '',

 'WM_CONSUMER.CHANNEL.TYPE' => '',

 'WM_CONSUMER.ID' => '',

 'Accept' => 'application/json',

 'Expect'=>''],

 'ca' => ['WM_SVC.NAME' => 'Walmart Marketplace',

 'WM_QOS.CORRELATION_ID' => '',

 'WM_SEC.TIMESTAMP' => '',

 'WM_SEC.AUTH_SIGNATURE' => '',

 'WM_CONSUMER.CHANNEL.TYPE' => '',

 'WM_CONSUMER.ID' => '',

 'WM_TENANT_ID' => 'WALMART.CA',

 'WM_LOCALE_ID' => 'en_CA',

 'Accept' => 'application/json',

 'Content-Type' => 'multipart/form-data'],



 'us_dsv' => ['WM_SVC.NAME' => 'Drop Ship Vendor Services',

 'WM_QOS.CORRELATION_ID' => '',

 'WM_SEC.TIMESTAMP' => '',

 'WM_SEC.AUTH_SIGNATURE' => '',

 'WM_CONSUMER.CHANNEL.TYPE' => '',

 'WM_CONSUMER.ID' => '',

 'Accept' => 'application/xml',

 'Content-Type' => 'application/xml']

 ],</pre>
</div>
解压数据包
<div class="cnblogs_code">
<pre> /**
* 拉取listing数据两阶段
* 一阶段：解压压缩包更新数据
* @url /services/walmart/walmartlisting/getallitemreport/account_id/83
*/
public function actionGetallitemreport(){
 ini_set("memory_limit","3000M");
 set_time_limit(3600);
 $start_time = microtime(true);
 $account_id = Yii::app()->request->getParam('account_id');

 if ($account_id) {
 $keyword = date("YmdHis").'_'.$account_id;

 /******************* 添加执行日志start ***********************/
 $execute_param = array(
 "type" => 3,
 "type_name" => "listing解压缩",
 "keyword" => $keyword,
 "exp3" => $account_id,
 "exp1" => "walmartlisting",
 "exp2" => "getallitemreport",
 );
 YbModel::model('WalmartExecuteLog')->insertData($execute_param);
 /******************* 添加执行日志end ***********************/

 $date = date('Ymd');
 $filename =Yii::getPathOfAlias('webroot') . '/upload/erp_log/walmartreport/walmartreport_'.$date.'_'.$account_id.'.zip'; //设置文件名
 if (!file_exists($filename)) {
 $message = "未发现压缩文件";
 echo $message;
 } else {
 $walmartPostService = new WalmartListingData($account_id);
 $re = $walmartPostService->unZip($account_id, $filename);
 $message = "执行完成";
 if (!empty($re)) {
 $message = "执行异常:".$re;
 }
 }

 //更新日志执行结果
 $walmartExecuteLogModel = new WalmartExecuteLog();
 $walmartExecuteLogModel->getDbConnection()->createCommand()->update
 (
 $walmartExecuteLogModel->tableName(),
 [
 'content'=> $message,
 ],
 "type=3 and keyword='{$keyword}'"
 );

 }else{
 $accountList = YbModel::model('WalmartAccount')->getInfoByWhere( "status = 1 and site in('mx','ca')", "id");
 $accountList = array_column($accountList,'id');
 $limit = ceil(count($accountList)/100);//每次执行一个账号（4-7点每五分钟一次）
 $accountIdList = $this->getExeId($limit,'walmart_listing_account');
 if(!empty($accountIdList)){
 foreach ($accountIdList as $val){
 MHelper::runThreadSOCKET('/services/walmart/walmartlisting/getallitemreport/account_id/'.$val);
 }
 }
 }

 $end_time = microtime(true);
 echo '执行完成, 耗时：' . round(($end_time - $start_time), 3).'秒';
 exit;
}

/**
* 描述:获取需要执行的id
* @author YB
* @param int $limit每次执行几个
* @return array
*/
private function getExeId($limit,$key=null)
{
 if(empty($key)){
 $key = 'walmart_listing_account';
 }

 $ids = EbuyMemcache::getCache($key);
 $idsArr = json_decode($ids,true);
 if(empty($idsArr))
 {
 $accountList = YbModel::model('WalmartAccount')->getAccountList();
 $ids = array_column($accountList,'id');
 }
 else
 {
 $ids = $idsArr;
 }
 $_ids =$ids;
 array_splice($ids,$limit);
 $new_ids = array_diff($_ids,$ids);
 $str_list = json_encode($new_ids);
 EbuyMemcache::setCache($key,$str_list,86400);
 return $ids;
}

/**
* 解压压缩包
*/
public function unZip($accountId, $filename) {
 if (empty($filename) || empty($accountId)) {
 return null;
 }
 $zip = new ZipArchive;
 $res = $zip->open($filename);
 if ($res === TRUE) {
 //解压缩到log文件夹
 $zip->extractTo(Yii::getPathOfAlias('webroot') . '/upload/erp_log/walmartreport/');
 $file = $zip->getNameIndex(0);
 $zip->close();
 $file_excel = Yii::getPathOfAlias('webroot') . '/upload/erp_log/walmartreport/'.$file;
 $file = fopen($file_excel,'r');
 $i =0;
 $msg = '';
 $walmartListingModel = new WalmartListing();

 while (($data = fgetcsv($file))!== false) { //每次读取CSV里面的一行内容
 if(strpos($this->short_name,'DSV') !==false){ //dsv
 continue;
 }elseif ($this->site=='ca'){
 if($data[0]=='PARTNER ID' && $data[1]=='SKU'){
 continue;
 }
 $sellerSku =trim($data[1],'="');
 $sellerSku =trim(trim($sellerSku,'"'));
 $item_id = trim($data[15]);
 $skuMap = YbModel::model('Walmartskumap')->find("seller_sku ='{$sellerSku}'");
 $row =array(
 'partner_id' => $data[0],
 'seller_sku' => $sellerSku,
 'product_name' => $data[2],
 'product_category' => $data[3],
 'price' => $data[4]?$data[4]:0.00,
 'currency' => $data[5],
 'buybox_item_price_ca' => $data[6]?$data[6]:0.00,//购物车价格
 'buybox_ship_price_ca' => $data[7]?$data[7]:0.00,//购物车运费
 'won_buy_box' => $data[8],//WON BUY BOX?

 'publish_status' => $data[9],
 'status_change_reason' => $data[10],
 'lifecycle_status' => $data[11],
 'inventory_count' => $data[12]?$data[12]:0,
 'ship_method' => $data[13],
 'wpid' => $data[14] ?$data[14] : '',
 'item_id' => $data[15],
 'gtin' => $data[16] ? $data[16] : '',
 'upc' => $data[17] ? $data[17] : '',
 'main_url' => $data[18],//PRIMARY IMAGE URL
 'shelf_name' => $data[19],
 'primary_cat_path' => $data[20],
 'offer_start_date' => date('Y-m-d H:i:s',strtotime($data[21])),
 'offer_end_date' => date('Y-m-d H:i:s',strtotime($data[22])),
 'item_creation_date' => date('Y-m-d H:i:s',strtotime($data[23])),
 'item_last_updated' => date('Y-m-d H:i:s',strtotime($data[24])),
 'item_page_url' => $data[25],
 'reviews_count' => $data[26],
 'average_rating' => $data[27]?$data[27]:0,
 'searchable' => $data[27],
 'account_id' => $accountId,
 'sku' => $skuMap->sku,
 'original_price' => $data[4]?$data[4]:0.00,
 );
 }elseif ($this->site=='mx'){
 if($data[0]=='ID de la Tienda' && $data[1]=='SKU'){
 continue;
 }
 if($data[15]){
 $t1 = explode('/',$data[15]);
 $t1d = $t1[2].'-'.$t1[1].'-'.$t1[0];
 }
 if($data[16]){
 $t2 = explode('/',$data[16]);
 $t2d = $t2[2].'-'.$t2[1].'-'.$t2[0];
 }
 if($data[17]){
 $t3 = explode('/',$data[17]);
 $t3d = $t3[2].'-'.$t3[1].'-'.$t3[0];
 }
 if($data[18]){
 $t4 = explode('/',$data[18]);
 $t4d = $t4[2].'-'.$t4[1].'-'.$t4[0];
 }
 $row =array(
 'account_id' => $accountId,
 'partner_id' => $data[0],
 'seller_sku' => $data[1],
 'product_name' => $data[2],
 'product_category' => $data[3],
 'price' => $data[4]?$data[4]:0.00,
 'currency' => $data[5],
 'publish_status' => $data[6],
 'status_change_reason' => $data[7],
 'lifecycle_status' => $data[8],
 'wpid' => $data[9],
 'gtin' => $data[10],
 'upc' => $data[11],
 'main_url'=> $data[12],
 'shelf_name'=> $data[13],
 'primary_cat_path'=> $data[14],
 'offer_start_date' => date('Y-m-d H:i:s',strtotime($t1d)),
 'offer_end_date' => date('Y-m-d H:i:s',strtotime($t2d)),
 'item_creation_date' => date('Y-m-d H:i:s',strtotime($t3d)),
 'item_last_updated' => date('Y-m-d H:i:s',strtotime($t4d)),

 );
 }else{
 if($data[0]=='PARTNER ID' && $data[1]=='SKU'){
 continue;
 }
 $sellerSku =trim($data[1],'="');
 $sellerSku =trim(trim($sellerSku,'"'));
 $item_id = trim($data[12]);
 $skuMap = YbModel::model('Walmartskumap')->find("seller_sku ='{$sellerSku}'");
 $row =array(
 'partner_id' => $data[0],
 'seller_sku' => $sellerSku,
 'product_name' => $data[2],
 'product_category' => $data[3],
 'price' => $data[4],
 'currency' => $data[5],
 'publish_status' => $data[6],
 'status_change_reason' => $data[7],
 'lifecycle_status' => $data[8],
 'inventory_count' => $data[9],
 'ship_method' => $data[10],
 'wpid' => $data[11] ?$data[11] : '',
 'item_id' => $data[12],
 'gtin' => $data[13] ? $data[13] : '',
 'upc' => $data[14] ? $data[14] : '',
 'main_url' => $data[15],//PRIMARY IMAGE URL
 'shelf_name' => $data[16],
 'primary_cat_path' => $data[17],
 'offer_start_date' => date('Y-m-d H:i:s',strtotime($data[18])),
 'offer_end_date' => date('Y-m-d H:i:s',strtotime($data[19])),
 'item_creation_date' => date('Y-m-d H:i:s',strtotime($data[20])),
 'item_last_updated' => date('Y-m-d H:i:s',strtotime($data[21])),
 'item_page_url' => $data[22],
 'reviews_count' => $data[23],
 'average_rating' => $data[24],
 'searchable' => $data[25],
 'account_id' => $accountId,
 'sku' => $skuMap->sku,
 'original_price' => $data[4],
 );
 }
 if($row['offer_start_date']=='1970-01-01 08:00:00'){
 $row['offer_start_date'] = date('Y-m-d H:i:s');
 }
 if($row['offer_end_date']=='1970-01-01 08:00:00'){
 $row['offer_end_date'] = date('Y-m-d H:i:s');
 }
 if($row['item_creation_date']=='1970-01-01 08:00:00'){
 $row['item_creation_date'] = date('Y-m-d H:i:s');
 }
 if($row['item_last_updated']=='1970-01-01 08:00:00'){
 $row['item_last_updated'] = date('Y-m-d H:i:s');
 }
 $taskRow = $this->getWalmartTaskRowByListing($row["item_id"], $row["sku"], $row["account_id"]);
 if(!empty($taskRow)){
 $row["task_id"] = $taskRow["id"];
 $row["source_type"] = $taskRow["source_type"];
 }
 $WalmartListingModel =YbModel::model('WalmartListing')->find("account_id = $accountId and seller_sku ='{$sellerSku}' and item_id='{$item_id}'");
 if($WalmartListingModel){
 if($WalmartListingModel->original_price >0){
 unset($row['original_price']);
 }
 $row['update_time']= date('Y-m-d H:i:s');
 $re_update = $walmartListingModel->getDbConnection()->createCommand()->update(
 $walmartListingModel->tableName(),
 $row,
 "account_id = $accountId and seller_sku ='{$sellerSku}' and item_id='{$item_id}'"
 );
 if ($re_update) {
 $i++;
 }
 }else{
 $row['create_time']= date('Y-m-d H:i:s');
 $model = new WalmartListing();
 if(!$model->getDbConnection()->createCommand()->insert($model->tableName(), $row)){
 $i++;
 }
 }
// echo '<pre>'; print_r($data); //此为一个数组，要获得每一个数据，访问数组下标即可
// exit;
 }

 fclose($file);
 fclose($file_excel);
 unlink($file);
 unlink($file_excel);
 unlink($filename);

 } else {
 return false;
 }
 return $msg;
}</pre>
</div>
 用item_id去更新listing  —— 可以废弃
<div class="cnblogs_code">
<pre> /**
* 补拉拉取listing
* @url /services/walmart/walmartlisting/repairgetlisting/account_id/2
*/
public function actionRepairGetListing(){
 $account_id = Yii::app()->request->getParam('account_id');
 $type = Yii::app()->request->getParam('type');
 $modellisting = YbModel::model('WalmartListing');
 if($type=='see'){
 $accountss = Yii::app()->memcache->get('walmart_listing_line');
 $lines = json_decode($accountss,true);
 VHelper::dump($lines);exit();
 }
 if($account_id){
 $date = date('Y-m-d');
 $sqlac = "SELECT item_idFROM yibai_walmart_listing WHERE update_time<'".$date."' and account_id=".$account_id." limit 1000";
 $list = $modellisting->getDbConnection()->createCommand($sqlac)->queryColumn();
 if($list){
 $walmartPostService = new WalmartListingData($account_id);
 foreach ($list as $val){
 $res = $walmartPostService->getanitems($val);
 if($res[0]==200){
 $info = json_decode($res[1],true);
 if($info['totalItems']>=1){
 $arr['price'] = $info['ItemResponse'][0]['price']['amount'];
 $arr['currency'] = $info['ItemResponse'][0]['price']['currency'];
 $arr['seller_sku'] = $info['ItemResponse'][0]['sku'];
 $arr['wpid'] = $info['ItemResponse'][0]['wpid'];
 $arr['gtin'] = $info['ItemResponse'][0]['gtin'];
 $arr['publish_status'] = $info['ItemResponse'][0]['publishedStatus'];
 $arr['lifecycle_status'] = $info['ItemResponse'][0]['lifecycleStatus'];
 $arr['update_time'] = date('Y-m-d H:i:s');
 $modellisting->updateAll($arr,"account_id={$account_id} and item_id='".$val."'");
 }else{
 $arr['publish_status'] = 'NOT_SEARCH';
 $arr['update_time'] = date('Y-m-d H:i:s');
 $modellisting->updateAll($arr,"account_id={$account_id} and item_id='".$val."'");
 }
 }
 }
 MHelper::runThreadSOCKET('/services/walmart/walmartlisting/repairgetlisting/account_id/'.$account_id);
 sleep(2);
 }
 }else{
 if(Yii::app()->request->getParam('type')=='delete'){
 Yii::app()->memcache->delete('walmart_listing_line');
 die('删除换成成功');
 }
 $accountss = Yii::app()->memcache->get('walmart_listing_line');
 $lines = json_decode($accountss,true);
 if(empty($lines)){
 $account = YbModel::model('WalmartAccount');
 $accounts = $account->getDbConnection()->createCommand()
 ->select('id,account_name,MOD(id,10)as line')
 ->from($account->tableName())
 ->where('status=1')
 ->order('id asc')
 ->queryAll();
 $accounts_line=array_column($accounts,null,'id');
 foreach($accounts_line as $val){
 $lines[$val['line']][] = $val['id'];
 }
 //Yii::app()->memcache->set('amazon_listing_line',json_encode($lines),5*3600);
 }
 for($i=0;$i<10;$i++){
 if(!empty($lines[$i])){
 $account_id = array_shift($lines[$i]);
 Yii::app()->memcache->set('walmart_listing_line',json_encode($lines),5*3600);
 $url = sprintf('%s/services/walmart/walmartlisting/repairgetlisting/account_id/%s', $_SERVER['HTTP_HOST'], $account_id);
 echo $url;echo ' ';
 MHelper::curl_post_async($url);
 }else{
 continue;
 }
 }

 }
}

public function getanitems($itemid){
 $accountInfo = array();
 $url = "https://marketplace.walmartapis.com/v3/items/{$itemid}?productIdType=ITEM_ID";
 $extra = [
 "Accept"=>"application/json",
 "Content-Type"=>"application/x-www-form-urlencoded",
 ];
 $headers = $this->getHeaders($url, 'GET', $accountInfo, $extra);
 $res = $this->cur_request($url,'GET','',$headers);
 return $res;
}</pre>
</div>
 mx 和 ca 的库存只能通过接口（无法通过申请报告形式）
<div class="cnblogs_code">
<pre> /**
* 获取库存
* @url /services/walmart/walmartlisting/getinventory
*/
public function actionGetinventory(){
 $account_id = Yii::app()->request->getParam('account_id');
 $date = Yii::app()->request->getParam('date');
 $type = Yii::app()->request->getParam('type');
 $modellisting = YbModel::model('WalmartListing');
 if($type=='see'){
 $accountss = Yii::app()->memcache->get('walmart_listing_inventory');
 $lines = json_decode($accountss,true);
 VHelper::dump($lines);exit();
 }
 if($account_id){
 $date = $date?$date:date('Y-m-d');
 $sqlac = "SELECT seller_sku,item_idFROM yibai_walmart_listing WHERE inventory_updatetime<'".$date."' and account_id=".$account_id." limit 1000";
 $list = $modellisting->getDbConnection()->createCommand($sqlac)->queryAll();
 if($list){
 $walmartPostService = new WalmartListingData($account_id);
 foreach ($list as $val){
 $res = $walmartPostService->getinventory($val['seller_sku']);
 if(isset($res['quantity'])){
 $arr['inventory_count'] = $res['quantity']['amount'];
 $arr['inventory_updatetime'] = date('Y-m-d H:i:s');
 }else{
 $arr['inventory_count'] = 0;
 $arr['inventory_updatetime'] = date('Y-m-d H:i:s');
 }
 $modellisting->updateAll($arr,"account_id={$account_id} and item_id='".$val['item_id']."'");
 }
 MHelper::runThreadSOCKET('/services/walmart/walmartlisting/getinventory/account_id/'.$account_id);
 sleep(2);
 }
 }else{
 if(Yii::app()->request->getParam('type')=='delete'){
 Yii::app()->memcache->delete('walmart_listing_inventory');
 die('删除换成成功');
 }
 $accountss = Yii::app()->memcache->get('walmart_listing_inventory');
 $lines = json_decode($accountss,true);
 if(empty($lines)){
 $account = YbModel::model('WalmartAccount');
 $accounts = $account->getDbConnection()->createCommand()
 ->select('id,account_name,MOD(id,10)as line')
 ->from($account->tableName())
 ->where('status=1 and site in("ca","mx")')
 ->order('id asc')
 ->queryAll();
 $accounts_line=array_column($accounts,null,'id');
 foreach($accounts_line as $val){
 $lines[$val['line']][] = $val['id'];
 }
 //Yii::app()->memcache->set('amazon_listing_line',json_encode($lines),5*3600);
 }
 for($i=0;$i<10;$i++){
 if(!empty($lines[$i])){
 $account_id = array_shift($lines[$i]);
 Yii::app()->memcache->set('walmart_listing_inventory',json_encode($lines),5*3600);
 $url = sprintf('%s/services/walmart/walmartlisting/getinventory/account_id/%s', $_SERVER['HTTP_HOST'], $account_id);
 echo $url;echo ' ';
 MHelper::curl_post_async($url);
 }else{
 continue;
 }
 }
 }
}</pre>
</div>
获取库存接口
<div class="cnblogs_code">
<pre> //获取库存
public function getinventory($sku){
 $accountInfo = [];
 if($this->site=='ca'){
 $url = "https://marketplace.walmartapis.com/v3/ca/inventory?sku=".$sku;
 $extra = [
 "Accept"=>"application/json",
 "Content-Type"=>"application/x-www-form-urlencoded",
 ];
 }elseif($this->site=='us'){
 $url = "https://marketplace.walmartapis.com/v3/inventory?sku=".$sku;
 $extra = [
 "Accept"=>"application/json",
 "Content-Type"=>"application/x-www-form-urlencoded",
 ];
 }elseif($this->site=='mx'){
 $url = "https://marketplace.walmartapis.com/v3/inventory?sku=".$sku;
 $extra = [
 "Accept"=>"application/json",
 "Content-Type"=>"application/x-www-form-urlencoded",
 ];
 }
 $headers = $this->getHeaders($url, 'GET', $accountInfo, $extra);
 $result= $this->getResult($url, $headers);
 $result = json_decode($result,true);
 return $result;
}</pre>
</div>
us 拉取listing和拉取库存通过申请报告形式的方式  接口文档  Onrequestreports - US - API Reference - Walmart Developer Portal
任务表：
<div class="cnblogs_code">
<pre>CREATE TABLE `yibai_walmart_listing_task` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',
`account_id` int(11) NOT NULL DEFAULT '0' COMMENT '账户ID',
`account_name` varchar(50) NOT NULL DEFAULT '' COMMENT '账户名称',
`site` varchar(10) NOT NULL DEFAULT '' COMMENT '站点',
`report_type` tinyint(1) NOT NULL DEFAULT '1' COMMENT '1:ITEM2:INVENTORY',
`request_body` text COMMENT '请求报告参数',
`response_body` text COMMENT '请求报告返回',
`status` varchar(50) NOT NULL DEFAULT '' COMMENT '报告状态',
`type` tinyint(1) NOT NULL DEFAULT '0' COMMENT '0:未处理 1:已处理',
`requestid` varchar(500) NOT NULL DEFAULT '' COMMENT '申请的requestid',
`is_down` tinyint(1) NOT NULL DEFAULT '0' COMMENT '0：未下载 1：已经下载',
`down_url` varchar(1000) NOT NULL DEFAULT '' COMMENT '下载地址',
`create_date` datetime NOT NULL DEFAULT '0000-00-00 00:00:00' COMMENT '创建时间',
`update_date` datetime DEFAULT '0000-00-00 00:00:00' COMMENT '修改时间',
PRIMARY KEY (`id`),
KEY `idx_account_id` (`account_id`),
KEY `idx_report_type` (`report_type`),
KEY `idx_status` (`status`),
KEY `idx_type` (`type`),
KEY `idx_is_down` (`is_down`)
) ENGINE=InnoDB AUTO_INCREMENT=217 DEFAULT CHARSET=utf8 COMMENT='拉取listing任务表';</pre>
</div>
1. 创建任务  report_type=1 listing任务   report_type=2 库存任务 
<div class="cnblogs_code">
<pre> /**
* 创建报告
* @url /services/walmart/walmartlisting/createreporttask
*/
public function actionCreatereporttask(){
 $del = Yii::app()->request->getParam('del');
 $type = Yii::app()->request->getParam('type');
 $id = Yii::app()->request->getParam('id');
 $model = YbModel::model('WalmartListingTask');
 if($del==1){
 if(!$type){
 die('参数不对');
 }
 $model->deleteAll("report_type=".$type);
 die('删除us拉取listing的申请报告');
 }
 if(!$type){
 die('参数不对');
 }
 /*$job = $model->findAll('report_type=1 and create_date>"'.date('Y-m-d').'"');
 if($job){die('当天数据已经存在');}*/
 $where = '';
 if($id){
 $where .=' and id='.$id;
 }
 $sql = "select id,short_name,site from yibai_system.yibai_walmart_account where site='us' and status=1 ".$where;
 $list = $model->getDbConnection()->createCommand($sql)->queryAll();
 if($list){
 $inlist = $indata = [];
 $datetime = date('Y-m-d H:i:s');
 foreach ($list as $val){
 $indata['account_id'] = $val['id'];
 $indata['account_name'] = $val['short_name'];
 $indata['site'] = $val['site'];
 $indata['report_type'] = $type;
 $indata['status'] = '';
 $indata['type'] = 0;
 $indata['is_down'] = 0;
 $indata['create_date'] = $datetime;
 $inlist[] = $indata;
 $indata = [];
 }
 }
 if($inlist){
 $model->batchInsertAll($model->tableName(), array_keys($inlist[0]), $inlist, true);
 }
 echo 'DOLL';
}</pre>
</div>
2.申请报告 
 2.1 listing 接口  https://marketplace.walmartapis.com/v3/reports/reportRequests?reportType=ITEM&reportVersion=v4
2.2 库存接口  https://marketplace.walmartapis.com/v3/reports/reportRequests?reportType=INVENTORY&reportVersion=v1
<div class="cnblogs_code">
<pre>/**
* 申请报告
* @url /services/walmart/walmartlisting/createreport
*/
public function actionCreatereport(){
$model = YbModel::model('WalmartListingTask');
$datetime = date('Y-m-d');
$sql = "select id,account_id,report_type from yibai_walmart_listing_task where report_type in(1,2) and type=0 and is_down=0 and create_date>".$datetime;
$list = $model->getDbConnection()->createCommand($sql)->queryAll();
if($list){
 foreach ($list as $val){
 $data = [];
 $walmartPostService = new WalmartListingData($val['account_id']);
 if($account_info->site=='ca'){
 $type=$val['report_type']==1?'ITEM_CA':'INVENTORY_CA';
 }elseif ($account_info->site=='mx'){
 $type=$val['report_type']==1?'ITEM_MX':'INVENTORY_MX';
 }elseif ($account_info->site=='us'){
 $type=$val['report_type']==1?'ITEM':'INVENTORY';
 }
 $res = json_decode($walmartPostService->createreportlisting($type),true);
 $data['request_body'] = '';
 $data['response_body'] = json_encode($res);
 $data['update_date'] = date('Y-m-d H:i:s');
 if(isset($res['requestId'])){
 $data['requestid'] = $res['requestId'];
 $data['status'] = $res['requestStatus'];
 $data['type'] = 1;
 }
 $model->updateAll($data,"id=".$val['id']);
 }
}
echo 'DOLL';
}

//创建报告请求listing(/v3/reports/reportRequests) ITEM:listingINVENTORY:库存
public function createreportlisting($type){
$accountInfo = [];
if($this->site=='ca'){
 $reportVersion = $type=='ITEM_CA'?'v4':'v1';
 $url = "https://marketplace.walmartapis.com/v3/ca/reports/reportRequests?reportType=".$type."&reportVersion=".$reportVersion;
 $extra = [
 "Accept"=>"application/json",
 "content-type"=>"application/json",
 ];
 $body = '';
}elseif($this->site=='us'){
 $reportVersion = $type=='ITEM'?'v4':'v1';
 $url = "https://marketplace.walmartapis.com/v3/reports/reportRequests?reportType=".$type."&reportVersion=".$reportVersion;
 $extra = [
 "Accept"=>"application/json",
 "content-type"=>"application/json",
 ];
 $body='';
}elseif($this->site=='mx'){
 $reportVersion = $type=='ITEM_MX'?'v4':'v1';
 $url = "https://marketplace.walmartapis.com/v3/reports/reportRequests?reportType=".$type."&reportVersion=".$reportVersion;
 $extra = [
 "Accept"=>"application/json",
 "content-type"=>"application/json",
 ];
}
$headers = $this->getHeaders($url, 'GET', $accountInfo, $extra);
$result=$this->postResult($url, '', $headers,'json');
return $result;
}</pre>
</div>
3.根据requestid获取报告状态
<div class="cnblogs_code">
<pre>/**
* 根据requestid获取报告状态
* @url /services/walmart/walmartlisting/getreportstatus
*/
public function actionGetreportstatus(){
 $model = YbModel::model('WalmartListingTask');
 $datetime = date('Y-m-d');
 $sql = "select id,account_id,requestid from yibai_walmart_listing_task where report_type in(1,2) and type=1 and is_down=0 and status in('INPROGRESS','RECEIVED') and create_date>".$datetime;
 $list = $model->getDbConnection()->createCommand($sql)->queryAll();
 if(!$list){
 die('没有数据需要处理');
 }
 foreach ($list as $val){
 $walmartPostService = new WalmartListingData($val['account_id']);
 $res = $walmartPostService->getreportstatus($val['requestid']);
 if(isset($res['requestId'])){
 $model->updateAll(['status'=>$res['requestStatus'],"update_date"=>date('Y-m-d H:i:s')],"id=".$val['id']);
 }
 }
 echo 'DOLL';
}

//报告请求状态(/v3/reports/reportRequests/{requestId})
public function getreportstatus($requestid){
 $accountInfo = [];
 if($this->site=='ca'){

 }elseif($this->site=='us'){
 $url = "https://marketplace.walmartapis.com/v3/reports/reportRequests/".$requestid;
 $extra = [
 "Accept"=>"application/json",
 "content-type"=>"application/json",
 ];
 }elseif($this->site=='mx'){

 }
 $headers = $this->getHeaders($url, 'GET', $accountInfo, $extra);
 $result= $this->getResult($url, $headers);
 $result = json_decode($result,true);
 return $result;
}</pre>
</div>
4.获取所有报告结果  （这个用来查看就行了）
<div class="cnblogs_code">
<pre>/**
* 获取所有报告结果
* @url /services/walmart/walmartlisting/getallreport
*/
public function actionGetallreport(){
 $type = Yii::app()->request->getParam('type');
 $id = Yii::app()->request->getParam('id');
 $account_id = $id;
 $type=$type==1?'ITEM':'INVENTORY';
 $walmartPostService = new WalmartListingData($account_id);
 $ra = $walmartPostService->getallreport($type);
 print_r('<pre>');
 print_r($ra);
 print_r('</pre>');
 exit();
}

//获取所有报告请求(/v3/reports/reportRequests)
public function getallreport($type){
 $accountInfo = [];
 $url = "https://marketplace.walmartapis.com/v3/reports/reportRequests?reportType=".$type."&reportVersion=v3";
 $extra = [
 "Accept"=>"application/json",
 "content-type"=>"application/json",
 ];
 $headers = $this->getHeaders($url, 'GET', $accountInfo, $extra);
 $result= $this->getResult($url, $headers);
 $result = json_decode($result,true);
 return $result;
}</pre>
</div>
5.解析数据  （因为下载链接几分钟就失效，所以获取链接了马上解析数据）
<div class="cnblogs_code">
<pre> /**
* 解析报告new
* @url /services/walmart/walmartlisting/analysislisting
*/
public function actionAnalysislisting(){
 $del = Yii::app()->request->getParam('del');
 $account_id = Yii::app()->request->getParam('account_id');
 $modeltask = YbModel::model('WalmartListingTask');
 $model = new WalmartListing();
 $datetime = date('Y-m-d');
 if($del==1 && $account_id){
 $model->deleteAll("account_id=".$account_id);
 die('删除数据成功');
 }
 $sql = "select id,account_id,report_type,requestid from yibai_walmart_listing_task where report_type=1 and type=1 and is_down=0 and status='READY'and create_date>".$datetime;
 $list = $modeltask->getDbConnection()->createCommand($sql)->queryAll();
 if(!$list){
 $sql = "select id,account_id,report_type,requestid from yibai_walmart_listing_task where report_type=2 and type=1 and is_down=0 and status='READY'and create_date>".$datetime;
 $list = $modeltask->getDbConnection()->createCommand($sql)->queryAll();
 if(!$list){
 die('没有数据需要处理');
 }
 }
 $date = date('Ymd');
 $path = Yii::getPathOfAlias('webroot') . '/upload/erp_log/walmartreport/';
 if (!file_exists($path)) {
 mkdir(Yii::getPathOfAlias('webroot') . '/upload/erp_log/', 0777);
 mkdir($path, 0777);
 }
 foreach ($list as $val){
 $walmartPostService = new WalmartListingData($val['account_id']);
 $res = $walmartPostService->downloadreport($val['requestid']);
 if(isset($res['requestId'])){
 $modeltask->updateAll(['down_url'=>$res['downloadURL'],"update_date"=>date('Y-m-d H:i:s')],"id=".$val['id']);
 }else{
 $modeltask->updateAll(['is_down'=>1,"update_date"=>date('Y-m-d H:i:s')],"id=".$val['id']);
 continue;
 }
 $walmartPostService = new WalmartListingData($val['account_id']);
 $accountinfo = YbModel::model('WalmartAccount')->findByPk($val['account_id']);
 $filename = 'walmartreport_'.$date.'_'.$val['account_id'].'_'.$val['report_type'].'.zip'; //设置文件名
 if (!file_exists($path.$filename)){
 @unlink($path.$filename);
 }
 $walmartPostService->getFile($res['downloadURL'],$path,$filename);
 $zip = new ZipArchive;
 $res = $zip->open($path.$filename);
 $datatimes = date('Y-m-d H:i:s');
 if ($res === TRUE) {
 //解压缩到log文件夹
 $zip->extractTo(Yii::getPathOfAlias('webroot') . '/upload/erp_log/walmartreport/');
 $file = $zip->getNameIndex(0);
 $zip->close();
 $file_excel = Yii::getPathOfAlias('webroot') . '/upload/erp_log/walmartreport/'.$file;
 $file = fopen($file_excel,'r');
 $i =0;
 $msg = '';
 $walmartListingModel = new WalmartListing();
 if($val['report_type']==1) {
 while (($data = fgetcsv($file)) !== false) { //每次读取CSV里面的一行内容
 if ($data[0] == 'SKU' && $data[1] == 'Item ID') {
 continue;
 }
 $item_id = trim($data[1]);
 $sellerSku = trim($data[0], '="');
 $sellerSku = trim(trim($sellerSku, '"'));
 $accountId = $val['account_id'];
 $skuMap = YbModel::model('Walmartskumap')->find("seller_sku ='{$sellerSku}'");
 $row = array(
 'partner_id' => $accountinfo->partner_id,
 'seller_sku' => $sellerSku,
 'item_id' => $item_id,
 'product_name' => $data[2],
 'lifecycle_status' => $data[3],
 'publish_status' => $data[4],
 'status_change_reason' => $data[5],
 'product_category' => $data[6],
 'price' => $data[7] ? $data[7] : 0.00,
 'currency' => $data[8],
 'buybox_item_price_ca' => $data[9] ? $data[9] : 0.00,//购物车价格
 'buybox_ship_price_ca' => $data[10] ? $data[10] : 0.00,//购物车运费
 'wpid' => $data[20] ? $data[20] : '',
 'gtin' => $data[21] ? $data[21] : '',
 'upc' => $data[22] ? $data[22] : '',
 'offer_start_date' => date('Y-m-d H:i:s', strtotime($data[28])),
 'offer_end_date' => date('Y-m-d H:i:s', strtotime($data[29])),
 'item_creation_date' => date('Y-m-d H:i:s', strtotime($data[30])),
 'item_last_updated' => date('Y-m-d H:i:s', strtotime($data[31])),
 'reviews_count' => $data[32]?(int)$data[32]:0,
 'average_rating' => $data[33] ? $data[33] : 0,
 'searchable' => $data[34],
 'original_price' => $data[7] ? $data[7] : 0.00,
 'account_id' => $accountId,
 'item_page_url'=>$data[23] ? $data[23] : '',
 'main_url'=>$data[24] ? $data[24] : '',
 'sku' => $skuMap->sku,
 );
 if($row['offer_start_date']=='1970-01-01 08:00:00'){
 $row['offer_start_date'] = date('Y-m-d H:i:s');
 }
 if($row['offer_end_date']=='1970-01-01 08:00:00'){
 $row['offer_end_date'] = date('Y-m-d H:i:s');
 }
 if($row['item_creation_date']=='1970-01-01 08:00:00'){
 $row['item_creation_date'] = date('Y-m-d H:i:s');
 }
 if($row['item_last_updated']=='1970-01-01 08:00:00'){
 $row['item_last_updated'] = date('Y-m-d H:i:s');
 }
 $taskRow = $walmartPostService->getWalmartTaskRowByListing($row["item_id"], $row["sku"], $row["account_id"]);
 if (!empty($taskRow)) {
 $row["task_id"] = $taskRow["id"];
 $row["source_type"] = $taskRow["source_type"];
 }
 $WalmartListingModel = YbModel::model('WalmartListing')->find("account_id = $accountId and seller_sku ='{$sellerSku}' and item_id='{$item_id}'");
 if ($WalmartListingModel) {
 if ($WalmartListingModel->original_price > 0) {
 unset($row['original_price']);
 }
 $row['update_time'] = date('Y-m-d H:i:s');
 $re_update = $walmartListingModel->getDbConnection()->createCommand()->update(
 $walmartListingModel->tableName(),
 $row,
 "account_id = $accountId and seller_sku ='{$sellerSku}' and item_id='{$item_id}'"
 );
 if ($re_update) {
 $i++;
 }
 } else {
 $row['create_time'] = date('Y-m-d H:i:s');
 if (!$model->getDbConnection()->createCommand()->insert($model->tableName(), $row)) {
 $i++;
 }
 }
 }
 }else{
 while (($data = fgetcsv($file)) !== false) { //每次读取CSV里面的一行内容
 if ($data[0] == 'SKU' && $data[1] == 'Item ID') {
 continue;
 }
 $WalmartListingModel = $model->find("account_id = {$val['account_id']}and item_id='{$data}'");
 if($WalmartListingModel){
 $inventory_count = $data[6]?$data[6]:0;
 $model->updateAll(['inventory_count'=>$inventory_count,'inventory_updatetime'=>$datatimes],"account_id = {$val['account_id']}and item_id='{$data}'");
 }
 }
 }
 }
 $modeltask->updateAll(['is_down'=>1,'update_date'=>date('Y-m-d H:i:s')],"id=".$val['id']);
 fclose($file);
 fclose($file_excel);
 unlink($file);
 unlink($file_excel);
 unlink($filename);

 }
 echo 'DOLL';
}

//下载报告网址(/v3/reports/downloadReport)
public function downloadreport($requestid){
 $accountInfo = [];
 if($this->site=='ca'){

 }elseif($this->site=='us'){
 $url = "https://marketplace.walmartapis.com/v3/reports/downloadReport?requestId=".$requestid;
 $extra = [
 "Accept"=>"application/json",
 "content-type"=>"application/json",
 ];
 }elseif($this->site=='mx'){

 }
 $headers = $this->getHeaders($url, 'GET', $accountInfo, $extra);
 $result= $this->getResult($url, $headers);
 $result = json_decode($result,true);
 return $result;
}

/**
* description: 文件下载
* @throws CException
*/
public function getFile($url, $save_dir = '', $filename = '', $type = 0)
{
 if (trim($url) == '') {
 return false;
 }
 if (trim($save_dir) == '') {
 $save_dir = './';
 }
 if (0 !== strrpos($save_dir, '/')) {
 $save_dir .= '/';
 }
 //创建保存目录
 if (!file_exists($save_dir) && !mkdir($save_dir, 0777, true)) {
 return false;
 }
 //获取远程文件所采用的方法
 if ($type) {
 $ch = curl_init();
 $timeout = 5;
 curl_setopt($ch, CURLOPT_URL, $url);
 curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
 curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
 $content = curl_exec($ch);
 curl_close($ch);
 } else {
 ob_start();
 readfile($url);
 $content = ob_get_contents();
 ob_end_clean();
 }
 //echo $content;
 $size = strlen($content);
 //文件大小
 $fp2 = @fopen($save_dir . $filename, 'a');
 @fwrite($fp2, $content);
 @fclose($fp2);
 unset($content, $url);
 return array(
 'status' => 1,
 'file_name' => $filename,
 'save_path' => $save_dir . $filename,
 'file_size' => $size
 );
}</pre>
</div>
解析库存
<div class="cnblogs_code">
<pre> /**
* 获取库存
* @url /services/walmart/walmartlisting/getinventory
*/
public function actionGetinventory(){
 $account_id = Yii::app()->request->getParam('account_id');
 $date = Yii::app()->request->getParam('date');
 $type = Yii::app()->request->getParam('type');
 $modellisting = YbModel::model('WalmartListing');
 if($type=='see'){
 $accountss = Yii::app()->memcache->get('walmart_listing_inventory');
 $lines = json_decode($accountss,true);
 VHelper::dump($lines);exit();
 }
 if($account_id){
 $date = $date?$date:date('Y-m-d');
 $sqlac = "SELECT seller_sku,item_idFROM yibai_walmart_listing WHERE inventory_updatetime<'".$date."' and account_id=".$account_id." limit 1000";
 $list = $modellisting->getDbConnection()->createCommand($sqlac)->queryAll();
 if($list){
 $walmartPostService = new WalmartListingData($account_id);
 foreach ($list as $val){
 $res = $walmartPostService->getinventory($val['seller_sku']);
 if(isset($res['quantity'])){
 $arr['inventory_count'] = $res['quantity']['amount'];
 $arr['inventory_updatetime'] = date('Y-m-d H:i:s');
 }else{
 $arr['inventory_count'] = 0;
 $arr['inventory_updatetime'] = date('Y-m-d H:i:s');
 }
 $modellisting->updateAll($arr,"account_id={$account_id} and item_id='".$val['item_id']."'");
 }
 MHelper::runThreadSOCKET('/services/walmart/walmartlisting/getinventory/account_id/'.$account_id);
 sleep(2);
 }
 }else{
 if(Yii::app()->request->getParam('type')=='delete'){
 Yii::app()->memcache->delete('walmart_listing_inventory');
 die('删除换成成功');
 }
 $accountss = Yii::app()->memcache->get('walmart_listing_inventory');
 $lines = json_decode($accountss,true);
 if(empty($lines)){
 $account = YbModel::model('WalmartAccount');
 $accounts = $account->getDbConnection()->createCommand()
 ->select('id,account_name,MOD(id,10)as line')
 ->from($account->tableName())
 ->where('status=1 and site in("ca","mx")')
 ->order('id asc')
 ->queryAll();
 $accounts_line=array_column($accounts,null,'id');
 foreach($accounts_line as $val){
 $lines[$val['line']][] = $val['id'];
 }
 //Yii::app()->memcache->set('amazon_listing_line',json_encode($lines),5*3600);
 }
 for($i=0;$i<10;$i++){
 if(!empty($lines[$i])){
 $account_id = array_shift($lines[$i]);
 Yii::app()->memcache->set('walmart_listing_inventory',json_encode($lines),5*3600);
 $url = sprintf('%s/services/walmart/walmartlisting/getinventory/account_id/%s', $_SERVER['HTTP_HOST'], $account_id);
 echo $url;echo ' ';
 MHelper::curl_post_async($url);
 }else{
 continue;
 }
 }
 }
}

//获取库存这里的ca和mx 不需要
public function getinventory($sku){
 $accountInfo = [];
 if($this->site=='ca'){
 $url = "https://marketplace.walmartapis.com/v3/ca/inventory?sku=".$sku;
 $extra = [
 "Accept"=>"application/json",
 "Content-Type"=>"application/x-www-form-urlencoded",
 ];
 }elseif($this->site=='us'){
 $url = "https://marketplace.walmartapis.com/v3/inventory?sku=".$sku;
 $extra = [
 "Accept"=>"application/json",
 "Content-Type"=>"application/x-www-form-urlencoded",
 ];
 }elseif($this->site=='mx'){
 $url = "https://marketplace.walmartapis.com/v3/inventory?sku=".$sku;
 $extra = [
 "Accept"=>"application/json",
 "Content-Type"=>"application/x-www-form-urlencoded",
 ];
 }
 $headers = $this->getHeaders($url, 'GET', $accountInfo, $extra);
 $result= $this->getResult($url, $headers);
 $result = json_decode($result,true);
 return $result;
}</pre>
</div>
  
来源：https://www.cnblogs.com/xiangshihua/p/16285202.html

頁: [1]

琼殿技术论坛's Archiver

沃尔玛api接口