Maison  >  Article  >  Applet WeChat  >  Yii2.0 implémente le développement backend des comptes publics WeChat

Yii2.0 implémente le développement backend des comptes publics WeChat

Y2J
Y2Joriginal
2017-04-18 10:48:392653parcourir

Cet article contient beaucoup de contenu, notamment l'accès à WeChat, l'obtention d'informations sur les utilisateurs WeChat, le paiement WeChat et l'obtention des paramètres de configuration JSSDK. Si le lecteur n'a pas une compréhension subjective du développement de WeChat, il est recommandé qu'il étudie d'abord la Documentation du développeur de la plateforme publique WeChat, puis de lire cet article pour de meilleurs résultats ! De plus, la version chapitre par section de cet article est disponible sur le blog de Babao Porridge.

Connectez-vous à WeChat

Configuration en arrière-plan de Yii2

1. Configurez les paramètres du jeton dans app/config/params.php

return [
    //微信接入
    'wechat' =>[
        'token' => 'your token',
    ],
];

2. . Configurez le routage

dans app/config/main.php car le module d'interface utilise l'API RESTful, vous devez donc définir des règles de routage . .

'urlManager' => [
    'enablePrettyUrl' => true,
    'enableStrictParsing' => true,
    'showScriptName' => false,
    'rules' => [
        [
            'class' => 'yii\rest\UrlRule',
            'controller' => 'wechat',
            'extraPatterns' => [
                'GET valid' => 'valid',
            ],
        ],
    ],
],

3. Créez un nouveau WechatController dans app/controllers

<?php

namespace api\controllers;

use Yii;
use yii\rest\ActiveController;

class WechatController extends ActiveController
{

    public $modelClass = &#39;&#39;;

    public function actionValid()
    {
        $echoStr = $_GET["echostr"];
        $signature = $_GET["signature"];
        $timestamp = $_GET["timestamp"];
        $nonce = $_GET["nonce"];
        //valid signature , option
        if($this->checkSignature($signature,$timestamp,$nonce)){
            echo $echoStr;
        }
    }

    private function checkSignature($signature,$timestamp,$nonce)
    {
        // you must define TOKEN by yourself
        $token = Yii::$app->params[&#39;wechat&#39;][&#39;token&#39;];
        if (!$token) {
            echo &#39;TOKEN is not defined!&#39;;
        } else {
            $tmpArr = array($token, $timestamp, $nonce);
            // use SORT_STRING rule
            sort($tmpArr, SORT_STRING);
            $tmpStr = implode( $tmpArr );
            $tmpStr = sha1( $tmpStr );

            if( $tmpStr == $signature ){
                return true;
            }else{
                return false;
            }
        }
    }

}

Configuration en arrière-plan du compte officiel WeChat

Configurez l'URL et le jeton en arrière-plan du compte officiel WeChat. , puis soumettez-le. Vérifiez simplement.

URL:http://app.demo.com/wechats/valid
Token:your token

Obtenir des informations utilisateur

Conception de la table utilisateur

CREATE TABLE `wechat_user` (
  `id` int(11) NOT NULL,
  `openid` varchar(255) COLLATE utf8_unicode_ci NOT NULL,
  `nickname` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT &#39;微信昵称&#39;,
  `sex` tinyint(4) NOT NULL COMMENT &#39;性别&#39;,
  `headimgurl` varchar(255) COLLATE utf8_unicode_ci NOT NULL COMMENT &#39;头像&#39;,
  `country` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT &#39;国家&#39;,
  `province` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT &#39;省份&#39;,
  `city` varchar(50) COLLATE utf8_unicode_ci NOT NULL COMMENT &#39;城市&#39;,
  `access_token` varchar(255) COLLATE utf8_unicode_ci NOT NULL,
  `refresh_token` varchar(255) COLLATE utf8_unicode_ci NOT NULL,
  `created_at` timestamp NULL DEFAULT CURRENT_TIMESTAMP
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

ALTER TABLE `wechat_user`
  ADD PRIMARY KEY (`id`);

Interfaces associées pour obtenir des informations utilisateur

Interface d'autorisation utilisateur : obtenir access_token , openid, etc. ; obtenir et enregistrer les informations utilisateur dans la base de données

public function actionAccesstoken()
{
    $code = $_GET["code"];
    $state = $_GET["state"];
    $appid = Yii::$app->params[&#39;wechat&#39;][&#39;appid&#39;];
    $appsecret = Yii::$app->params[&#39;wechat&#39;][&#39;appsecret&#39;];
    $request_url = &#39;https://api.weixin.qq.com/sns/oauth2/access_token?appid=&#39;.$appid.&#39;&secret=&#39;.$appsecret.&#39;&code=&#39;.$code.&#39;&grant_type=authorization_code&#39;;

    //初始化一个curl会话
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $request_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    $result = curl_exec($ch);
    curl_close($ch);
    $result = $this->response($result);

    //获取token和openid成功,数据解析
    $access_token = $result[&#39;access_token&#39;];
    $refresh_token = $result[&#39;refresh_token&#39;];
    $openid = $result[&#39;openid&#39;];

    //请求微信接口,获取用户信息
    $userInfo = $this->getUserInfo($access_token,$openid);
    $user_check = WechatUser::find()->where([&#39;openid&#39;=>$openid])->one();
    if ($user_check) {
        //更新用户资料
    } else {
        //保存用户资料
    }

    //前端网页的重定向
    if ($openid) {
        return $this->redirect($state.$openid);
    } else {
        return $this->redirect($state);
    }
}

2. Obtenir les informations utilisateur de WeChat

public function getUserInfo($access_token,$openid)
{
    $request_url = &#39;https://api.weixin.qq.com/sns/userinfo?access_token=&#39;.$access_token.&#39;&openid=&#39;.$openid.&#39;&lang=zh_CN&#39;;
    //初始化一个curl会话
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $request_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    $result = curl_exec($ch);
    curl_close($ch);
    $result = $this->response($result);
    return $result;
}

3. Obtenir l'interface d'informations utilisateur

public function actionUserinfo()
{
    if(isset($_REQUEST["openid"])){
        $openid = $_REQUEST["openid"];
        $user = WechatUser::find()->where([&#39;openid&#39;=>$openid])->one();
        if ($user) {
            $result[&#39;error&#39;] = 0;
            $result[&#39;msg&#39;] = &#39;获取成功&#39;;
            $result[&#39;user&#39;] = $user;
        } else {
            $result[&#39;error&#39;] = 1;
            $result[&#39;msg&#39;] = &#39;没有该用户&#39;;
        }
    } else {
        $result[&#39;error&#39;] = 1;
        $result[&#39;msg&#39;] = &#39;openid为空&#39;;
    }
    return $result;
}
Paiement WeChat

1. Interface de paiement WeChat : données de paiement packagées

public function actionPay(){
    if(isset($_REQUEST["uid"])&&isset($_REQUEST["oid"])&&isset($_REQUEST["totalFee"])){
        //uid、oid、totalFee
        $uid = $_REQUEST["uid"];
        $oid = $_REQUEST["oid"];
        $totalFee = $_REQUEST["totalFee"];
        $timestamp = time();

        //微信支付参数
        $appid = Yii::$app->params[&#39;wechat&#39;][&#39;appid&#39;];
        $mchid = Yii::$app->params[&#39;wechat&#39;][&#39;mchid&#39;];
        $key = Yii::$app->params[&#39;wechat&#39;][&#39;key&#39;];
        $notifyUrl = Yii::$app->params[&#39;wechat&#39;][&#39;notifyUrl&#39;];

        //支付打包
        $wx_pay = new WechatPay($mchid, $appid, $key);
        $package = $wx_pay->createJsBizPackage($uid, $totalFee, $oid, $notifyUrl, $timestamp);
        $result[&#39;error&#39;] = 0;
        $result[&#39;msg&#39;] = &#39;支付打包成功&#39;;
        $result[&#39;package&#39;] = $package;
        return $result;
    }else{
        $result[&#39;error&#39;] = 1;
        $result[&#39;msg&#39;] = &#39;请求参数错误&#39;;
    }
    return $result;
}
2. Recevez une notification de résultat de paiement asynchrone envoyée par WeChat

public function actionNotify(){
    $postStr = $GLOBALS["HTTP_RAW_POST_DATA"];
    $postObj = simplexml_load_string($postStr, &#39;SimpleXMLElement&#39;, LIBXML_NOCDATA);
    //
    if ($postObj === false) {
        die(&#39;parse xml error&#39;);
    }
    if ($postObj->return_code != &#39;SUCCESS&#39;) {
        die($postObj->return_msg);
    }
    if ($postObj->result_code != &#39;SUCCESS&#39;) {
        die($postObj->err_code);
    }

    //微信支付参数
    $appid = Yii::$app->params[&#39;wechat&#39;][&#39;appid&#39;];
    $mchid = Yii::$app->params[&#39;wechat&#39;][&#39;mchid&#39;];
    $key = Yii::$app->params[&#39;wechat&#39;][&#39;key&#39;];
    $wx_pay = new WechatPay($mchid, $appid, $key);

    //验证签名
    $arr = (array)$postObj;
    unset($arr[&#39;sign&#39;]);
    if ($wx_pay->getSign($arr, $key) != $postObj->sign) {
        die("签名错误");
    }

    //支付处理正确-判断是否已处理过支付状态
    $orders = Order::find()->where([&#39;uid&#39;=>$postObj->openid, &#39;oid&#39;=>$postObj->out_trade_no, &#39;status&#39; => 0])->all();

    if(count($orders) > 0){
        //更新订单状态
        foreach ($orders as $order) {
            //更新订单
            $order[&#39;status&#39;] = 1;
            $order->update();
        }
        return &#39;<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>&#39;;
    } else {
        //订单状态已更新,直接返回
        return &#39;<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>&#39;;
    }
}
3. . Classe de paiement WeChat WechatPay.php

<?php

namespace api\sdk;

use Yii;

class WechatPay
{
    protected $mchid;
    protected $appid;
    protected $key;

    public function construct($mchid, $appid, $key){
        $this->mchid = $mchid;
        $this->appid = $appid;
        $this->key = $key;
    }

    public function createJsBizPackage($openid, $totalFee, $outTradeNo, $orderName, $notifyUrl, $timestamp){
        $config = array(
            &#39;mch_id&#39; => $this->mchid,
            &#39;appid&#39; => $this->appid,
            &#39;key&#39; => $this->key,
        );
        $unified = array(
            &#39;appid&#39; => $config[&#39;appid&#39;],
            &#39;attach&#39; => &#39;支付&#39;,
            &#39;body&#39; => $orderName,
            &#39;mch_id&#39; => $config[&#39;mch_id&#39;],
            &#39;nonce_str&#39; => self::createNonceStr(),
            &#39;notify_url&#39; => $notifyUrl,
            &#39;openid&#39; => $openid,
            &#39;out_trade_no&#39; => $outTradeNo,
            &#39;spbill_create_ip&#39; => &#39;127.0.0.1&#39;,
            &#39;total_fee&#39; => intval($totalFee * 100),
            &#39;trade_type&#39; => &#39;JSAPI&#39;,
        );
        $unified[&#39;sign&#39;] = self::getSign($unified, $config[&#39;key&#39;]);
        $responseXml = self::curlPost(&#39;https://api.mch.weixin.qq.com/pay/unifiedorder&#39;, self::arrayToXml($unified));
        $unifiedOrder = simplexml_load_string($responseXml, &#39;SimpleXMLElement&#39;, LIBXML_NOCDATA);
        if ($unifiedOrder === false) {
            die(&#39;parse xml error&#39;);
        }
        if ($unifiedOrder->return_code != &#39;SUCCESS&#39;) {
            die($unifiedOrder->return_msg);
        }
        if ($unifiedOrder->result_code != &#39;SUCCESS&#39;) {
            die($unifiedOrder->err_code);
        }
        $arr = array(
            "appId" => $config[&#39;appid&#39;],
            "timeStamp" => $timestamp,
            "nonceStr" => self::createNonceStr(),
            "package" => "prepay_id=" . $unifiedOrder->prepay_id,
            "signType" => &#39;MD5&#39;,
        );
        $arr[&#39;paySign&#39;] = self::getSign($arr, $config[&#39;key&#39;]);
        return $arr;
    }

    public static function curlGet($url = &#39;&#39;, $options = array()){
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        if (!empty($options)) {
            curl_setopt_array($ch, $options);
        }
        //https请求 不验证证书和host
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        $data = curl_exec($ch);
        curl_close($ch);
        return $data;
    }


    public static function curlPost($url = &#39;&#39;, $postData = &#39;&#39;, $options = array()){
        if (is_array($postData)) {
            $postData = http_build_query($postData);
        }
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $postData);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30); //设置cURL允许执行的最长秒数
        if (!empty($options)) {
            curl_setopt_array($ch, $options);
        }
        //https请求 不验证证书和host
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        $data = curl_exec($ch);
        curl_close($ch);
        return $data;
    }

    public static function createNonceStr($length = 16){
        $chars = &#39;abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789&#39;;
        $str = &#39;&#39;;
        for ($i = 0; $i<$length; $i++){
            $str .= substr($chars, mt_rand(0, strlen($chars) - 1), 1);
        }
        return $str;
    }

    public static function arrayToXml($arr){
        $xml = "<xml>";
        foreach ($arr as $key => $val){
            if (is_numeric($val)) {
                $xml .= "<" . $key . ">" . $val . "</" . $key . ">";
            } else {
                $xml .= "<" . $key . "><![CDATA[" . $val . "]]></" . $key . ">";
            }
        }
        $xml .= "</xml>";
        return $xml;
    }

    public static function getSign($params, $key){
        ksort($params, SORT_STRING);
        $unSignParaString = self::formatQueryParaMap($params, false);
        $signStr = strtoupper(md5($unSignParaString . "&key=" . $key));
        return $signStr;
    }

    protected static function formatQueryParaMap($paraMap, $urlEncode = false){
        $buff = "";
        ksort($paraMap);
        foreach ($paraMap as $k => $v){
            if (null != $v && "null" != $v) {
                if ($urlEncode) {
                    $v = urlencode($v);
                }
                $buff .= $k . "=" . $v . "&";
            }
        }
        $reqPar = &#39;&#39;;
        if (strlen($buff)>0) {
            $reqPar = substr($buff, 0, strlen($buff) - 1);
        }
        return $reqPar;
    }

}
Obtenez les paramètres de configuration du JS-SDK

Selon la documentation du développeur de la plateforme publique WeChat :

Toutes les pages qui doivent le faire. utiliser JS-SDK doit d'abord injecter les informations de configuration, sinon elles ne seront pas appelées (la même URL ne doit être appelée qu'une seule fois. L'application Web du SPA qui modifie l'URL peut être appelée à chaque fois que l'URL change. Actuellement

Le client Android WeChat ne prend pas en charge pushState. H5 est une nouvelle fonctionnalité, donc l'utilisation de pushState pour implémenter des pages d'application Web entraînera un échec de signature. Ce problème sera résolu dans Android 6.2).

C'est-à-dire :

wx.config({
    debug: true, // 开启调试模式,调用的所有api的返回值会在客户端alert出来,若要查看传入的参数,可以在pc端打开,参数信息会通过log打出,仅在pc端时才会打印。
    appId: &#39;&#39;, // 必填,公众号的唯一标识
    timestamp: , // 必填,生成签名的时间戳
    nonceStr: &#39;&#39;, // 必填,生成签名的随机串
    signature: &#39;&#39;,// 必填,签名,见附录1
    jsApiList: [] // 必填,需要使用的JS接口列表,所有JS接口列表见附录2
});
1. Classe de paiement Wechat WechatPay.php

<?php

namespace api\sdk;

use Yii;

class WechatPay
{

    public function getSignPackage($url) {
        $jsapiTicket = self::getJsApiTicket();

        $timestamp = time();
        $nonceStr = self::createNonceStr();

        // 这里参数的顺序要按照 key 值 ASCII 码升序排序
        $string = "jsapi_ticket=".$jsapiTicket."&noncestr=".$nonceStr."×tamp=".$timestamp."&url=".$url;

        $signature = sha1($string);

        $signPackage = array(
            "appId"     => $this->appid,
            "nonceStr"  => $nonceStr,
            "timestamp" => $timestamp,
            "url"       => $url,
            "signature" => $signature,
            "rawString" => $string
        );
        return $signPackage;
    }

    public static function getJsApiTicket() {
        //使用Redis缓存 jsapi_ticket
        $redis = Yii::$app->redis;
        $redis_ticket = $redis->get(&#39;wechat:jsapi_ticket&#39;);
        if ($redis_ticket) {
            $ticket = $redis_ticket;
        } else {
            $accessToken = self::getAccessToken();
            $url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?type=jsapi&access_token=".$accessToken;
            $res = json_decode(self::curlGet($url));
            $ticket = $res->ticket;
            if ($ticket) {
                $redis->set(&#39;wechat:jsapi_ticket&#39;, $ticket);
                $redis->expire(&#39;wechat:jsapi_ticket&#39;, 7000);
            }
        }
        return $ticket;
    }

    public static function getAccessToken() {
        //使用Redis缓存 access_token
        $redis = Yii::$app->redis;
        $redis_token = $redis->get(&#39;wechat:access_token&#39;);
        if ($redis_token) {
            $access_token = $redis_token;
        } else {
            $appid = Yii::$app->params[&#39;wechat&#39;][&#39;appid&#39;];
            $appsecret = Yii::$app->params[&#39;wechat&#39;][&#39;appsecret&#39;];
            $url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=".$appid."&secret=".$appsecret;
            $res = json_decode(self::curlGet($url));
            $access_token = $res->access_token;
            if ($access_token) {
                $redis->set(&#39;wechat:access_token&#39;, $access_token);
                $redis->expire(&#39;wechat:access_token&#39;, 7000);
            }
        }
        return $access_token;
    }

    public static function curlGet($url = &#39;&#39;, $options = array()){
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        if (!empty($options)) {
            curl_setopt_array($ch, $options);
        }
        //https请求 不验证证书和host
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        $data = curl_exec($ch);
        curl_close($ch);
        return $data;
    }

    public static function curlPost($url = &#39;&#39;, $postData = &#39;&#39;, $options = array()){
        if (is_array($postData)) {
            $postData = http_build_query($postData);
        }
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $postData);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30); //设置cURL允许执行的最长秒数
        if (!empty($options)) {
            curl_setopt_array($ch, $options);
        }
        //https请求 不验证证书和host
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        $data = curl_exec($ch);
        curl_close($ch);
        return $data;
    }

    public static function createNonceStr($length = 16){
        $chars = &#39;abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789&#39;;
        $str = &#39;&#39;;
        for ($i = 0; $i<$length; $i++){
            $str .= substr($chars, mt_rand(0, strlen($chars) - 1), 1);
        }
        return $str;
    }

}
2. Obtenez l'interface des paramètres de configuration

.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn