Detailed introduction to using Yii2 WeChat backend development-WeChat Development-php.cn

Yii2 is a high-performance, component-based PHP framework. This article introduces you to the development of WeChat backend using Yii2 in detail. Let's take a look together.

There are many tutorials on Yii2.0 WeChat development on the Internet, but they are too complicated and messy, so today I will summarize the series of development using Yii2 WeChat backend for your reference.

1: Access WeChat

Yii2 background configuration

1. Configure token parameters in app/config/params.php

return [
 //微信接入
 &#39;wechat&#39; =>[
 &#39;token&#39; => &#39;your token&#39;,
 ],
];

Copy after login

2. Configure routing in app/config/main.php

Because the interface module uses RESTful API, routing rules need to be defined.

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

Copy after login

3. Create a new WechatController in 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;
  }
 }
 }

}

Copy after login

WeChat public account background configuration

Configure the URL and Token in the WeChat public account background, and then submit for verification.

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

Copy after login

2: Obtain user information

User table design

The code is as follows :

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`);

Copy after login

Related interfaces for obtaining user information

1. User authorization interface: obtain access_token, openId, etc.; obtain and save user information to the database

The code is as follows:

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);
    }
}

Copy after login

2. Get user information from WeChat

The code is as follows:

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;
}

Copy after login

3 .Get user information interface

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;
}

Copy after login

3: WeChat payment

1 .WeChat payment interface: packaged payment data

The code is as follows:

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;
}

Copy after login

2. Receive asynchronous payment result notification sent by WeChat

code As follows:

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;;
    }
}

Copy after login

3. Wechat payment class WechatPay.php

The code is as follows:

<?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;
    }
}

Copy after login

Four: Get JS- SDK config parameters

According to the WeChat public platform developer documentation:

All pages that need to use JS-SDK must first inject configuration information, otherwise they will not be able to be called (same as A URL only needs to be called once. The SPA web app that changes the URL can be called every time the URL changes. Currently, the Android WeChat client does not support the new H5 feature of pushState, so using pushState to implement the web app page will result in signatures. Failed, this problem will be fixed in Android 6.2).

That is:

The code is as follows:

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

Copy after login

1. Wechat payment class WechatPay.php

The code is as follows:

<?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."&timestamp=".$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;
    }
}

Copy after login

2. Get config parameter interface

public function actionConfig(){
 if (isset($_REQUEST[&#39;url&#39;])) {
 $url = $_REQUEST[&#39;url&#39;];
 //微信支付参数
 $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);
 $package = $wx_pay->getSignPackage($url);
 $result[&#39;error&#39;] = 0;
 $result[&#39;msg&#39;] = &#39;获取成功&#39;;
 $result[&#39;config&#39;] = $package;
 } else {
 $result[&#39;error&#39;] = 1;
 $result[&#39;msg&#39;] = &#39;参数错误&#39;;
 }
 return $result;
}

Copy after login

The above is the detailed content of Detailed introduction to using Yii2 WeChat backend development. For more information, please follow other related articles on the PHP Chinese website!