基于thinkphp3.2的京东接口第三方类库

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

附件中是我对js的sdk的部分改写，下载解压后将Jos文件夹一起放在Org/Util下面
下图中中文件名后缀带有.class.php是我修改了的文件，其他我没有用到就没有修改，修改方法很简单，下面告诉大家

比如：你想获取商品信息，这个时候先去京东的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的调用输入参数时分为系统级别输入参数和应用级别输入参数，这里已经把系统级别的参数都绑定好了 所以不用管了，直接输入应用级别的参数

对应的就是类中的两个方法

想批量获取商品信息，在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元