基于thinkphp3.2的京东接口第三方类库-php手册-php.cn

通过京东接口，实现商品信息的同步，商品的库存同步，订单获取，订单状态同步等功能，通过修改京东的SDK当做thinkphp的第三方类库，方便调用。
第一步：在http://jos.jd.com/申请成为开发者，这时候就有了用户的key和secret
第二步：开通 “京东宙斯-京东开放API服务”，然后去http://i.jcloud.com/ 去新建应用
第三步：新建应用里面要求填写回调地址，你可以填写自己电脑的本地地址，那么这个时候就只有你自己这台电脑可以测试http://localhost/admin.php?m=Admin&c=Jd&a=callback，点击保存，这个时候你的应用就是测试应用了，会分配App Key和App Secret给你
第四部：去https://code.jd.com/from201304_m/jos-php-sdk下载原生的PHP-SDK文件，自己可以去看看源码
改造源码步骤
首先我们必须有oauth认证登陆，我在Org/Util文件夹里面建了一个Jdsdk.class.php用于认证登陆授权<?php namespace Org\Util; class Jdsdk{ const CSRF_TOKEN = 1; const CSRF_AUTHORIZE = 2; public $redirectUri; protected $authorizeUrl = 'https://oauth.jd.com/oauth/authorize'; protected $tokenUrl = 'https://oauth.jd.com/oauth/token'; protected $gatewayUrl='https://api.jd.com/routerjson'; protected $apiVersion='2.0'; public function __construct(){ $config=C('JOS_CONFIG'); $this->redirectUri=$config['REDIRECT_URI']; $this->appkey=$config['APP_KEY']; $this->secretKey=$config['SECRET_KEY']; } /** * 授权登录 **/ public function getAuthorizeUrl($redirectUri = null){ $redirectUri || $redirectUri = $this->redirectUri; $param['response_type'] = 'code'; $param['client_id'] = $this->appkey; $param['redirect_uri'] = $redirectUri; $param['state'] = $this->mkCsrf(self::CSRF_AUTHORIZE); $param['scope'] = 'read'; return $this->authorizeUrl . '?' . http_build_query($param); } /** * 获取accessToken ***/ public function fetchAccessToken($code, $redirectUri = null){ $redirectUri || $redirectUri = $this->redirectUri; $param = array( 'grant_type' => 'authorization_code', 'client_id' => $this->appkey, 'client_secret' => $this->secretKey, 'code' => $code, 'redirect_uri' => $redirectUri, 'scope' => 'read', 'state' => $this->mkCsrf(self::CSRF_TOKEN) ); $json = $this->curl($this->tokenUrl, $param); $json = iconv('gbk', 'utf-8', $json); $json = json_decode($json); if (isset($json->code) && isset($json->error_description)) { throw new \Exception($json->error_description, intval($json->code)); } return $json; } //获取商品列表信息 //public function //执行请求 public function execute(JosRequest $request, $session = null){ $result = new \stdClass(); if ($this->checkRequest) { try { $request->check(); } catch (Exception $e) { $result->code = $e->getCode(); $result->zh_desc = "api请求参数验证失败"; $result->en_desc = $e->getMessage(); return $result; } } // 组装系统参数 $sysParams['app_key'] = $this->appkey; $sysParams['v'] = $this->apiVersion; $sysParams['method'] = $request->getApiMethod(); if ($session !== null) { $sysParams['access_token'] = $_SESSION['token']->access_token; } $sysParams['timestamp'] = date('Y-m-d H:i:s'); // 获取业务参数 $apiParams['360buy_param_json'] = $request->getAppJsonParams(); // 签名 $sysParams['sign'] = $this->generateSign(array_merge($sysParams, $apiParams)); $requestUrl = $this->gatewayUrl . '?' . http_build_query($sysParams); //echo $requestUrl;die; // 发送http请求 try { $resp = $this->curl($requestUrl, $apiParams); } catch (Exception $e) { $result->code = $e->getCode(); $result->zh_desc = "curl发送http请求失败"; $result->en_desc = $e->getMessage(); return $result; } // 解析返回结果 $respWellFormed = false; $respObject = self::jsonDecode($resp); if (null !== $respObject) { $respWellFormed = true; foreach ($respObject as $propKey => $propValue) { $respObject = $propValue; } } if (false === $respWellFormed) { $result->code = 1; $result->zh_desc = "api返回数据错误或程序无法解析返回参数"; $result->en_desc = "HTTP_RESPONSE_NOT_WELL_FORMED"; $result->resp = $resp; return $result; } return $respObject; } private static function jsonDecode($str) { // 特殊字符处理 $str = str_replace([chr(0),chr(4),chr(15),chr(16),chr(19),chr(31),'\\v'], '\\t', $str); if (defined('JSON_BIGINT_AS_STRING')) { return json_decode($str, false, 512, JSON_BIGINT_AS_STRING); } else { return PhplutilsJSON::decode($str); } } /** * 签名 * * @param $params 业务参数 * @return void */ private function generateSign($params){ if ($params != null) { ksort($params); $stringToBeSigned = $this->secretKey; foreach ($params as $k => $v) { $stringToBeSigned .= "$k$v"; } unset($k, $v); $stringToBeSigned .= $this->secretKey; } else { $stringToBeSigned = $this->secretKey; $stringToBeSigned .= $this->secretKey; } return strtoupper(md5($stringToBeSigned)); } /** * 重新生成csrf * * @param unknown $key * @return string */ public function mkCsrf($key){ // TODO // $v = uniqid('', true); // $_SESSION['jos_' . $key] = $v; return ''; } /** * 验证csrf正确性，单次验证 * * @param unknown $key * @param unknown $value * @return boolean */ public function checkCsrf($key, $value){ // $v = $_SESSION['jos_' . $key]; // $r = $v ? $v === $value : false; // unset($_SESSION['jos_' . $key]); // TODO return true; } //curl请求 public function curl($url, $postFields = null){ $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $url); curl_setopt($ch, CURLOPT_FAILONERROR, false); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // https 请求 if (strlen($url) > 5 && strtolower(substr($url, 0, 5)) == "https") { curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); } if (is_array($postFields) && 0 curl_setopt($ch, CURLOPT_POST, true); $postMultipart = false; foreach ($postFields as $k => $v) { if ('@' == substr($v, 0, 1)) { $postMultipart = true; break; } } unset($k, $v); if ($postMultipart) { curl_setopt($ch, CURLOPT_POSTFIELDS, $postFields); } else { curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($postFields)); } } $reponse = curl_exec($ch); if (curl_errno($ch)) { throw new \Exception(curl_error($ch), 0); } else { $httpStatusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE); if (200 !== $httpStatusCode) { throw new \Exception($reponse, $httpStatusCode); } } curl_close($ch); return $reponse; } }然后写一个controller类<?php // +---------------------------------------------------------------------- // | Author: 前度天下 // +---------------------------------------------------------------------- namespace Admin\Controller; use Think\Controller; class JdController extends Controller { private $jos; private $jos_config; public function __construct() { $this->jos_config = C('JOS_CONFIG'); //这里的配置是写在配置文件中的 $this->jos = new \Org\Util\Jdsdk(); //这里是jd的sdk改造后的类 parent::__construct(); } public function index() { if (isset($_SESSION['is_jd_success'])) { if ($_SESSION['is_jd_success'] == 1) { $status = 1; } elseif ($_SESSION['is_jd_success'] == 0) { $status = 0; } $this->assign("is_jd_success", $status); } //获取商品列表 $this->goods = $this->getCateList(); $this->assign("page", $_SESSION['page_num']); $this->display(); } //获取商品列表 public function getCateList($page = 1) { $obj = new \Org\Util\Jos\WareInfoByInfoRequest(); $obj->setPage($page); $obj->setPageSize(18); $resp = $this->jos->execute($obj, $_SESSION['token']->access_token); //保存页码 $rzt = $resp->total / 18; $_SESSION['page_num'] = ceil($rzt); $_SESSION['current_page'] = $page; return $resp->ware_infos; } //回调地址 public function callback() { $code = I("code", "", "trim"); $token = $this->jos->fetchAccessToken($code); if ($token->code != 0) { $_SESSION['is_jd_success'] = 0; $this->error("登录失败", U("Jd/index")); } else { $_SESSION['token'] = $token; $_SESSION['is_jd_success'] = 1; $this->success("登录成功", U("Jd/index")); } } //授权登录 public function login() { $url = $this->jos->getAuthorizeUrl(); header("location:" . $url); } ?>下面是jd的配置文件写在config.php里面 //京东接口配置 'JOS_CONFIG'=>array( 'APP_KEY'=>'', 'SECRET_KEY'=>'', 'REDIRECT_URI'=>'http://localhost/admin.php?m=Admin&c=Jd&a=callback' ),放一个登陆按钮在页面中，调用控制器的login方法，这个时候就是输入商家的账号和密码，同意授权就登陆成功了

附件中是我对js的sdk的部分改写，下载解压后将Jos文件夹一起放在Org/Util下面
下图中中文件名后缀带有.class.php是我修改了的文件，其他我没有用到就没有修改，修改方法很简单，下面告诉大家
基于thinkphp3.2的京东接口第三方类库
比如：你想获取商品信息，这个时候先去京东的api文档看是哪个方法http://jos.jd.com/api/index.htm
文档中说用的是 360buy.wares.list.get 批量获取商品信息
然后去jos文件夹对所有文件进行全局搜索360buy.wares.list.get这个关键词，
会找到C:\wamp\www\ThinkPHP\Library\Org\Util\Jos\WareListRequest.php
这个时候改造步骤就开始了
先该文件名称WareListRequest.php换成WareListRequest.class.php
打开文件在头部加上命名空间
namespace Org\Util\Jos;
就可以了，接下来是调用
jd的调用输入参数时分为系统级别输入参数和应用级别输入参数，这里已经把系统级别的参数都绑定好了所以不用管了，直接输入应用级别的参数
基于thinkphp3.2的京东接口第三方类库
对应的就是类中的两个方法

想批量获取商品信息，在controller控制器中写一个方法
例如
function getGoodsList(){
$obj = new \Org\Util\Jos\WareListRequest();
$obj->setWareIds($id); //商品的id，用逗号分隔，最多不能超过10个
$obj->setFields('ware_id'); //需返回的字段列表。可选值：ware结构体中的所有字段；字段之间用“,”分隔
$resp = $this->jos->execute($obj, $_SESSION['token']->access_token); //这段代码所用的调用都需要加上的都是一样的
print_r($resp);
}

可能有些地方我表达的不清楚，希望各位指出来，提出建议，希望大家有好的代码分享出来，玩过stackoverflow的都知道，国外的码农乐于分享，共同进步，一起分享

Jos.zip ( 42.28 KB 下载：52 次 )

AD：真正免费，域名+虚机+企业邮箱=0元