微信支付回调

<?php

namespace wxpay;

//use think\Loader;

//require_once 'lib/WxPayException.php';

//Loader::import('wxpay.lib.WxPayApi');

//Loader::import('wxpay.lib.WxPayNotify');

require '../extend/wxpay/lib/WxPayException.php';

require '../extend/wxpay/lib/WxPayApi.php';

require '../extend/wxpay/lib/WxPayNotify.php';

//require '../extend/wxpay/lib/log.php';

//

////初始化日志

//$logHandler= new CLogFileHandler("../public/uploads/wx_logs/".date('Y-m-d').'.log');

//$log = Log::Init($logHandler, 15);

/**

 * 异步通知处理类

*/

class Notify extends \WxPayNotify

{

    /**

     * 此为主函数, 即处理自己业务的函数, 重写后, 框架会自动调用

     *

     * @param array $data 微信传递过来的参数数组

     * @param string $msg 错误信息, 用于记录日志

     */

    public function NotifyProcess($data, &$msg)

    {

        // 一下均为实例代码

        // 1.校检参数

        if(!array_key_exists("transaction_id", $data)){

            $msg = "输入参数不正确";

            return false;

        }

        // 2.微信服务器查询订单，判断订单真实性(可不需要)

        if(!$this->Queryorder($data["transaction_id"])){

            $msg = "订单查询失败";

            return false;

        }

        // 3.去本地服务器检查订单状态(强烈建议需要)

        $order = $this->getOrder($data);

        if(empty($order)) {

            $msg = '本地订单不存在';

            return false;

        }

        // 4.检查订单状态

        if($this->checkOrderStatus($order)) {

            // 如果订单处理过, 则直接返回true

            return true;

        }

        // 订单状态未修改情况下, 进行处理业务

        $result = $this->processOrder($order, $data);

        if(!$result) {

            $msg = '订单处理失败';

            return false;

        }

        return true;

    }

    /**

     * 处理核心业务

     * @param  array $order 订单信息

     * @param  array $data  通知数组

     * @return Bollean

     */

    public function processOrder($order, $data)

    {

        // 进行核心业务处理, 如更新状态, 发送通知等等

        // 处理成功, 返回true, 处理失败, 返回false

        // 例如:

        //$result = db('order')->where('id', $order['id'])->update(['status'=>1, 'transaction_id'=>$data['transaction_id']]);

        return $result;

    }

    // 去微信服务器查询是否有此订单

    public function Queryorder($transaction_id)

    {

        $input = new \WxPayOrderQuery();

        $input->SetTransaction_id($transaction_id);

        $result = \WxPayApi::orderQuery($input);

        if(array_key_exists("return_code", $result)

            && array_key_exists("result_code", $result)

            && $result["return_code"] == "SUCCESS"

            && $result["result_code"] == "SUCCESS")

        {

            return true;

        }

        return false;

    }

    // 去本地服务器查询订单信息

    public function getOrder($data)

    {

        // 可根据商户订单号进行查询

        // 例如:

        $order = db('order')->where('number', $data['out_trade_no'])->find();

        return $order;

    }

    /**

     * 检查order状态, 是否已经做过修改, 避免重复修改

     * 原因: 可能由于业务处理较慢, 还未等回复微信服务器, 同一订单的另一个通知已到达,

     *      为了避免重复修改订单, 需要对状态进行检查

     *

     * @return Bollean

     */

    public function checkOrderStatus($order)

    {

        // 检查还未修改, 则返回true, 检查已经修改过了, 则返回false

        // 例如:

        return $order['status'] == 1 ? true : false;

    }

}