微信支付 - 图1
    NotifyController.class.php是异步

    1. <?php
    2. namespace Home\Controller;
    3. use Think\Controller;
    4. use Think\Hook;
    6. class NotifyController extends Controller {
    8.     //初始化
    9.     public function _initialize()
    10.     {
    11.         vendor('WxPayPubHelper.WxPayPubHelper');
    12.     }
    14.     // 支付回调
    15.     public function notify(){
    16.         $log_name= "./Public/Pay/notify_url.log";//log文件路径
    17.         $wechatinfo['appid'] = M('mp_setting')->where(array('mpid'=>3,'name'=>'appid'))->getField('value');
    18.         $wechatinfo['mchid'] = M('mp_setting')->where(array('mpid'=>3,'name'=>'mchid'))->getField('value');
    19.         $wechatinfo['key'] = M('mp_setting')->where(array('mpid'=>3,'name'=>'paysignkey'))->getField('value');
    20.         $wechatinfo['appsecret'] = M('mp_setting')->where(array('mpid'=>3,'name'=>'appsecret'))->getField('value');
    22.         //存储微信的回调
    23.         $xml = $GLOBALS['HTTP_RAW_POST_DATA'];
    25.         //使用通用通知接口
    26.         $notify = new \Notify_pub($wechatinfo);
    27.         $notify->saveData($xml);
    29.         //验证签名，并回应微信。
    30.         //对后台通知交互时，如果微信收到商户的应答不是成功或超时，微信认为通知失败，
    31.         //微信会通过一定的策略（如30分钟共8次）定期重新发起通知，
    32.         //尽可能提高通知的成功率，但微信不保证通知最终能成功。
    33.         if($notify->checkSign() == FALSE){
    34.             $notify->setReturnParameter("return_code","FAIL");//返回状态码
    35.             $notify->setReturnParameter("return_msg","签名失败");//返回信息
    36.         }else{
    37.             $notify->setReturnParameter("return_code","SUCCESS");//设置返回码
    38.         }
    39.         $returnXml = $notify->returnXml();
    41.         if($notify->checkSign() == TRUE)
    42.         {
    43.             if (($notify->data["return_code"] == "SUCCESS")&&($notify->data["result_code"] == "SUCCESS")) {
    44.                 $where['number'] = $notify->data["out_trade_no"];
    45.                 $data['wx_number'] = $notify->data["transaction_id"];
    46.                 $data['deal_time'] = $notify->data["time_end"];
    47.                 $data['is_pay'] = 1;
    48.                 $data['access'] = 1;
    50.                 // 支付完成后清除session的所有信息
    51.                 session('Cart',null);
    52.                 // 清除总价
    53.                 session('total',null);
    54.                 // 清除数量
    55.                 session('num',null);
    56.                 // 商品的id
    57.                 session('shop_id',null);
    59.                 if(!D('order')->where($where)->save($data)){
    60.                     file_put_contents($log_name,"【支付成功 , 数据库修改失败信息】:\n".json_encode($notify->data)."\n", FILE_APPEND);
    61.                 }
    62.             }else{
    63.                 file_put_contents($log_name,"【支付失败通知】:\n".json_encode($notify->data)."\n", FILE_APPEND);
    64.             }
    65.         }                          
    66.     }
    68. }
    73. //WxpayController是支付方法
    75. <?php
    76. namespace Home\Controller;
    77. use Think\Controller;
    78. use Think\Hook;
    80. class WxpayController extends Controller {
    82.     //初始化
    83.     public function _initialize()
    84.     {   
    85.         if(session('userinfo.openid')){
    86.             vendor('WxPayPubHelper.WxPayPubHelper');
    87.         }else{
    88.             cookie('controller',CONTROLLER_NAME);
    89.             cookie('action',ACTION_NAME);
    90.             $this->redirect('Base/getsession');
    91.         }
    92.     }
    95.     /*
    96.     前台给支付传一个id即可
    97.     */
    98.     // 统一支付
    99.     public function pay(){
    100.         if($_GET['orderid']){
    102.             $orderinfo = D('order')->find($_GET['orderid']);
    103.             if(($orderinfo['is_pay'] == 0) && ($orderinfo['status'] == 1)){
    104.                 $wechatinfo['appid'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'appid'))->getField('value');
    105.                 $wechatinfo['mchid'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'mchid'))->getField('value');
    106.                 $wechatinfo['key'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'paysignkey'))->getField('value');
    107.                 $wechatinfo['appsecret'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'appsecret'))->getField('value');
    108.                 //统一支付
    109.                 $unifiedOrder = new \UnifiedOrder_pub($wechatinfo);
    110.                 $unifiedOrder->setParameter("openid",session('userinfo.openid'));
    111.                 $unifiedOrder->setParameter("body",'谢谢光顾');
    112.                 $unifiedOrder->setParameter("out_trade_no",$orderinfo['number']);
    113.                 $unifiedOrder->setParameter("total_fee",$orderinfo['cash_fee']);
    114.                 $unifiedOrder->setParameter("notify_url", C('HTTP_HOST') . '/index.php/Home/Notify/notify');
    115.                 $unifiedOrder->setParameter("trade_type","JSAPI");
    116.                 $prepay_id = $unifiedOrder->getPrepayId();
    117.                 $jsApi = new \JsApi_pub($wechatinfo); 
    118.                 $jsApi->setPrepayId($prepay_id);
    119.                 $jsApiParameters = $jsApi->getParameters();
    120.                 $this->assign('jsApiParameters',$jsApiParameters)->assign('money',$orderinfo['cash_fee']/1000);
    121.                 $this->display();                
    122.             }
    123.         }
    124.     }
    126.     // 退款
    127.     public function refundmoney() {
    128.         if($_GET['orderid']){
    129.             $orderinfo = D('order')->find($_GET['orderid']);
    130.             // 订单状态必须是已支付,申请退款,订单未结束
    131.             if(($orderinfo['refund'] == 1) && ($orderinfo['is_pay'] == 1) && ($orderinfo['status'] == 1)){
    132.                 // 查出商户信息
    133.                 $wechatinfo['appid'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'appid'))->getField('value');
    134.                 $wechatinfo['mchid'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'mchid'))->getField('value');
    135.                 $wechatinfo['key'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'paysignkey'))->getField('value');
    136.                 $wechatinfo['appsecret'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'appsecret'))->getField('value');
    137.                 $sslcert = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'sslcert'))->getField('value');
    138.                 $sslkey = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'sslkey'))->getField('value');
    139.                 $wechatinfo['sslcert_path'] = '/cert/apiclient_'.$orderinfo['mpid'].'_cert.pem';
    140.                 $wechatinfo['sslkey_path'] =  '/cert/apiclient_'.$orderinfo['mpid'].'_key.pem';
    141.                 $dirpath = explode('\App',dirname(__FILE__));
    142.                 $sslcertpath = $dirpath[0].'\ThinkPHP\Library\Vendor\WxPayPubHelper\cert\apiclient_'.$orderinfo['mpid'].'_cert.pem';
    143.                 $sslkeypath = $dirpath[0].'\ThinkPHP\Library\Vendor\WxPayPubHelper\cert\apiclient_'.$orderinfo['mpid'].'_key.pem';
    144.                 file_put_contents($sslcertpath, isset($sslcert) ? $sslcert : '');
    145.                 file_put_contents($sslkeypath, isset($sslkey) ? $sslkey : '');
    146.                 // 退款
    147.                 $refundpay = new \Refund_pub($wechatinfo);
    148.                 $refundpay->setParameter('transaction_id', $orderinfo['wx_number']);
    149.                 $refundpay->setParameter('out_refund_no', $orderinfo['cash_fee'].$orderinfo['wx_number']);
    150.                 $refundpay->setParameter('total_fee', $orderinfo['total_fee']);
    151.                 $refundpay->setParameter('refund_fee', $orderinfo['cash_fee']);
    152.                 $refundpay->setParameter('op_user_id', '920518');
    153.                 $result = $refundpay->getResult();
    154.                 $log_name= "./Public/Pay/refund_url.log";//log文件路径
    155.                 // 成功
    156.                 if (isset($result['return_code']) && isset($result['result_code']) && $result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
    157.                     $data['id'] = $_GET['orderid'];
    158.                     $data['wxrefund_number'] = $result['refund_id'];
    159.                     $data['refund'] = 2;
    160.                     $data['status'] = 2;
    161.                     if(D('order')->save($data)){
    162.                         $return['return_code'] = 200;
    163.                         $return['return_msg'] = '退款成功';
    164.                     }else{
    165.                         file_put_contents($log_name,"【退款成功 , 数据库修改失败通知】:\n".json_encode($result)."\n", FILE_APPEND);
    166.                         $return['return_code'] = 201;
    167.                         $return['return_msg'] = '退款成功,但是数据库修改失败';
    168.                     }   
    169.                 }else{
    170.                     file_put_contents($log_name,"【退款失败通知】:\n".json_encode($result)."\n", FILE_APPEND);
    171.                     $return['return_code'] = 400;
    172.                     $return['return_msg'] = '退款失败';
    173.                 }
    174.                 unlink($sslcertpath);
    175.                 unlink($sslkeypath);
    176.                 $this->ajaxReturn($return);
    177.             }
    178.         }
    179.     }
    181.     // 二维码支付
    182.     public function qrcodepay(){
    183.         if($_GET['orderid'] && is_int($_GET['orderid'])){
    184.             $orderinfo = D('order')->find($_GET['orderid']);
    185.             if(!$orderinfo){
    186.                 $return['return_code'] = 201;
    187.                 $return['return_msg'] = '订单不存在';
    188.             }else{
    189.                 if(($orderinfo['is_pay'] == 0) && ($orderinfo['status'] == 1)){
    190.                     $wechatinfo['appid'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'appid'))->getField('value');
    191.                     $wechatinfo['mchid'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'mchid'))->getField('value');
    192.                     $wechatinfo['key'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'paysignkey'))->getField('value');
    193.                     $wechatinfo['appsecret'] = M('mp_setting')->where(array('mpid'=>$orderinfo['mpid'],'name'=>'appsecret'))->getField('value');
    194.                     //统一支付
    195.                     $unifiedOrder = new \UnifiedOrder_pub($wechatinfo);
    196.                     $unifiedOrder->setParameter("body",'谢谢光顾');
    197.                     $unifiedOrder->setParameter("out_trade_no",$orderinfo['number']);
    198.                     $unifiedOrder->setParameter("total_fee",$orderinfo['cash_fee']);
    199.                     $unifiedOrder->setParameter("notify_url", C('HTTP_HOST') . '/index.php/Home/Notify/notify');
    200.                     $unifiedOrder->setParameter("trade_type","NATIVE");
    201.                     $unifiedOrder->setParameter("product_id",$orderinfo['number']);
    202.                     $prepay_url = $unifiedOrder->getPrepayUrl();
    203.                     $data['qrcodeimage'] = 'http://paysdk.weixin.qq.com/example/qrcode.php?data='.urlencode($prepay_url);
    204.                     $return['return_code'] = 200;
    205.                     $return['return_msg'] = '订单二维码';
    206.                     $return['return_data'] = $data;
    207.                     $this->ajaxReturn($return);               
    208.                 }else{
    209.                     if($orderinfo['is_pay'] == 1){
    210.                         $return['return_code'] = 201;
    211.                         $return['return_msg'] = '订单不可重复支付';
    212.                     }
    213.                 }
    214.             }
    215.         }else{
    216.             $return['return_code'] = 400;
    217.             $return['return_msg'] = '订单格式错误';
    218.         }
    219.     }
    221.     public function qecodeindex(){
    222.         $this->display();
    223.     }
    226.     // 创建订单
    227.     public function createorder(){
    228.         $money = I('post.money');
    229.         $type = I('post.type');
    230.         $mpid = I('post.mpid');
    232.         $data['number'] = time('YmdHis').rand(100,999).session('userinfo.id');
    233.         $data['total_fee'] = $money*100;
    234.         $data['cash_fee'] = $money*100;
    235.         $data['type'] = 1;
    236.         $data['mpid'] = session('userinfo.mpid');
    237.         $data['status'] = 1;
    238.         $data['userid'] = session('userinfo.id');
    240.         $orderid = D('order')->add($data);
    241.         if($orderid){
    242.             $order['id'] = $orderid;
    243.             $return['return_code'] = 200;
    244.             $return['return_msg'] = '添加成功';
    245.             $return['return_data'] = $order;
    246.         }else{
    247.             $return['return_code'] = 400;
    248.             $return['return_msg'] = '添加失败';
    249.         }
    250.         $this->ajaxReturn($return);
    251.     }
    253.     // 饭厅生成二维码
    254.     public function getqrcode(){
    256.         vendor('phpqrcode.qrcodecreate');
    258.         $qrcodeimage = new \QRcodeCreate();
    260.         $result = $qrcodeimage->projectqrcode();
    262.         $QR = imagecreatefromgd(file_get_contents($result));    
    264.         //输出图片    
    265.         // imagepng($QR, 'qrcode.png');    
    266.         // imagedestroy($QR);  
    267.         // return '<img src="qrcode.png" alt="使用微信扫描支付">';
    269.         file_put_contents('./Public/getqrcode',$QR);
    270.     }
    273. }

    tp3.2.rar
    微信支付 - 图2
    存放微信支付扩展