jiankangtv/application/api/controller/Notify.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use wxpay;
use addons\epay\library\Service;

/**
 * 支付回调
 */
class Notify extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    // 定单支付回调
    public function notify() {
//        require_once($_SERVER['DOCUMENT_ROOT'] . "/Plugins/WxPay/WxPay.php");
        $wxPay = new wxpay\WxPay();
        //验证是否是微信发送
        $flag = $wxPay->WxPayNotifyCheck();
        //LL($flag,'./log1.txt');
        //验证成功
        if ($flag['status']) {
            if ($flag['data']['return_code'] == 'SUCCESS' && $flag['data']['result_code'] == 'SUCCESS') {
                $total_fee = trim($flag['data']['total_fee']); //支付的金额, 单位:分
                $order_sn = trim($flag['data']['out_trade_no']);//商家订单号

                $PayResult = M('PayResult');
                $where['out_trade_no'] = $order_sn;
                $order_info = $PayResult->where($where)->find();
                if ($order_info['total_amount'] != $total_fee) {
                    $r_arr['return_code'] = 'FAIL';
                    $r_arr['return_msg'] = '回调失败';
                    echo $wxPay->arrayToXml($r_arr);
                    die;
                }
                if ($order_info['status'] == 1) {
                    $r_arr['return_code'] = 'SUCCESS';
                    $r_arr['return_msg'] = '回调成功';
                    echo $wxPay->arrayToXml($r_arr);
                    die;
                }

                //查询订单信息
                $order_time = M('Order')->field('shop_id, add_time, arrive_time')->where(['order_id' => $order_info['order_id'], 'user_id' => $order_info['user_id'], 'order_status' => 0])->find();
                $order_data = [
                    'order_status' => 1,
                    'add_time' => time(),
//                    'arrive_time' => $order_time['arrive_time'] + time() - $order_time['add_time']
                ];

                //验证成功, 修改订单状态
                $results = M('Order')->where(['order_id' => $order_info['order_id'], 'user_id' => $order_info['user_id'], 'order_status' => 0])->setField($order_data);
                if (!$results) {
                    $_data['pay_status'] = $order_info['type'];
                } else {
                    //给商家发消息
                    $shop_user_id = M('Shop')->where(['shop_id' => $order_time['shop_id']])->getField('user_id');
                    $data = [
                        'user_id' => $shop_user_id,
                        'title' => '新订单',
                        'content' => '您有新的订单，请注意查看！',
                        'create_time' => time()
                    ];
                    M('UserAuditNotice')->add($data);
                    $extra['type'] = '6';
                    jPushShop(C('WEB_TITLE'), '您有新的订单，请注意查看！', $shop_user_id, NULL, $extra);
                }

                $_data['trade_no'] = trim($flag['data']['transaction_id']); //微信交易凭证
                $_data['status'] = 1;
                $_data['pay_time'] = time();
                $PayResult->where($where)->save($_data);

                $r_arr['return_code'] = 'SUCCESS';
                $r_arr['return_msg'] = '回调成功';
                echo $wxPay->arrayToXml($r_arr);
                die;
            }
        }
        $r_arr['return_code'] = 'FAIL';
        $r_arr['return_msg'] = '回调失败';
        echo $wxPay->arrayToXml($r_arr);
        file_put_contents('wx_pay_error_logs.txt', date('Y-m-d H:i:s').'支付失败！'.json_encode($flag), FILE_APPEND);
        die;
    }

    /**
     * 支付回调
     */
    public function notify1() {
        $paytype = $this->request->param('paytype');
        $pay = Service::checkNotify($paytype);
//        Log::record("=======================", 'info');
//        Log::record("pay:", 'info');
//        Log::record($pay, 'info');
//        Log::record("=======================", 'info');
        if (!$pay) {
            echo '签名错误';
            return;
        }
        $data = $pay->verify();
        $time = time();
        try {
            $payamount = $paytype == 'alipay' ? $data['total_amount'] : $data['total_fee'] / 100;
            $out_trade_no = $data['out_trade_no'];
            Db::startTrans();
            try{
                $orderModel = new \app\common\model\RecharOrder();
                $userModel = new \app\common\model\User();
                $orderInfo = $orderModel->where(["order_no"=>$out_trade_no])->find();
                $userInfo = $userModel->where(["id"=>$orderInfo["user_id"]])->find();
                $res1 = false;
                $res2 = false;
                $res3 = false;
                if($orderInfo['status'] == 0) {
                    // 修改订单状态
                    $res1 = $orderModel->update(["status"=>1,"updatetime"=>$time],["order_no"=>$out_trade_no, 'status' => 0]);
                    // 充值后
                    switch($orderInfo['purpose']) {
                        case 1:
                            // 修改用户为已缴纳认证费
                            $userInfo->recharge_auth = 1;
                            $res2 = $userInfo->save();
                            $res3 = true;
                            break;
                        case 2:
                            // 添加有眼缘记录--单次付费
                            $data = [];
                            $data['user_id'] = $userInfo->id;
                            $data['fate_user_id'] = $orderInfo->fate_user_id;
                            if(!\app\common\model\UserFate::where($data)->find()) {
                                $data['createtime'] = $time;
                                $res2 = \app\common\model\UserFate::insert($data);
                            } else {
                                $res2 = true;
                            }

                            // 返利
                            $preuser_id = $userInfo->pre_user_id;
                            if($userInfo->vip_duetime < $time) {
                                $memo = '用户充值获得收益！';
                                $profit = $payamount * config('site.userProfitRate') * 0.01;
                            } else {
                                $memo = '会员充值获得收益！';
                                $profit = $payamount * config('site.vipProfitRate') * 0.01;
                            }
                            if($profit>=0.01 && $preuser_id > 0) {
                                $res3 = \app\common\model\User::profit($profit,$preuser_id,$memo);
                            } else {
                                $res3 = true;
                            }

                            break;
                        case 3:
                            // 获取vip配置信息
                            $vip_config_id = $orderInfo['vip_config_id'];
                            $vipConfigInfo = \app\admin\model\vip\Config::where(['id'=>$vip_config_id])->find();
                            // 计算vip到期时间
                            if($userInfo->vip_duetime < $time) {
                                $duetime = strtotime ( '+'.intval($vipConfigInfo['time']).' month' );
                            } else {
                                $duetime = strtotime ( '+'.intval($vipConfigInfo['time']).' month',$userInfo->vip_duetime);
                            }
                            // 修改用户为vip
                            if($userInfo->vip_duetime <= time()) {
                                $userInfo->view_count = $vipConfigInfo->give_times; // 今日剩余次数
                                $userInfo->view_date = date('Y-m-d'); // 次数最后更新日期
                            }
                            $userInfo->vip_duetime = $duetime;
                            $res2 = $userInfo->save();
                            // 添加查看次数
                            $data = [];
                            $data['user_id'] = $userInfo->id;
                            $data['end_date'] = date("Y-m-d",$duetime);
                            $data['times'] = $vipConfigInfo->give_times;
                            $data['createtime'] = time();
                            $res3 = \app\common\model\GiveFateLog::insert($data);
                            break;
                        case 4:
                            // 获取钻石配置信息
                            $vip_config_id = $orderInfo['vip_config_id'];
                            $vipConfigInfo = Db::name('diamond')->where(['id'=>$vip_config_id])->find();
                            //修改用户钻石余额
                            $diamond = $userInfo['diamond'] + $vipConfigInfo['number'];
                            $res2 = Db::name('user')->where(['id' => $userInfo['id'], 'diamond' => $userInfo['diamond']])->setField('diamond', $diamond);
                            // 添加钻石明细
                            $diamond_log = Db::name('user_diamond_log')->where(['user_id' => $userInfo['id']])->order('id', 'desc')->find();
                            if (!$diamond_log && $userInfo['diamond'] > 0) {
                                $res3 = false;
                                break;
                            }
                            if ($diamond_log && $diamond_log['after'] != $userInfo['diamond']) {
                                $res3 = false;
                                break;
                            }
                            $data = [];
                            $data['user_id'] = $userInfo['id'];
                            $data['diamond'] = $vipConfigInfo['number'];
                            $data['before'] = $userInfo['diamond'];
                            $data['after'] = $diamond;
                            $data['memo'] = '充值';
                            $data['createtime'] = time();

                            $res3 = Db::name('user_diamond_log')->insertGetId($data);
                            break;
                    }
                }


                if($res1 && $res2 !== false && $res3) {
                    Db::commit();
                } else {
                    Db::rollback();
                }
            }catch (ValidateException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (PDOException $e) {
                Db::rollback();
                $this->error($e->getMessage());
            } catch (Exception $e) {
                Db::rollback();
                $this->error($e->getMessage());
            }

            //你可以在此编写订单逻辑
        } catch (Exception $e) {
        }
        echo $pay->success();
    }

}