yueke/application/api/controller/Notify.php

<?php
namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use addons\epay\library\Service;
/**
 * 订单支付回调
 */
class Notify extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    //充值金币 异步回调对外方法
    public function recharge_notify_base(){

        //验签
        $paytype = input('paytype','hitpay');
        $notify_file = $this->notify_log_start($paytype);
        $pay = Service::checkNotify($paytype);
        if (!$pay) {
            echo '签名错误';
            exit;
        }

        //验证，拿订单号等信息
        $data = $pay->verify();
        $out_trade_no = $data['out_trade_no'];
        //订单查询
        $info = Db::name('pay_order')->where('out_trade_no',$out_trade_no)->find();

        if(empty($info)){
            echo $pay->success();
            exit;
        }

        if($info['order_status'] != 0)
        {
            echo $pay->success();
            exit;
        }
        //你可以在此编写订单逻辑
        $rs = $this->recharge_notify_do($out_trade_no);
        if($rs === false){
            //不论结果都应返回success
            echo $pay->success();
            exit;
        }else{
            //不论结果都应返回success
            echo $pay->success();
            exit;
        }

        //默认
        echo $pay->success();
        exit;
    }

    //充值金币 逻辑
    private function recharge_notify_do($out_trade_no){

        $time = time();

        Db::startTrans();
        $orderInfo = Db::name('pay_order')->where(['out_trade_no' => $out_trade_no])->lock(true)->find();
        if (empty($orderInfo)) {
            Db::rollback();
            return false;
        }

        if($orderInfo['order_status'] != 0){
            Db::rollback();
            return false;
        }

        //逻辑开始
        //试课预约
        if($orderInfo['table_name'] == 'trylesson_order'){
            $update = [
                'order_status' => 10,
                'paytime'      => $time,
                'updatetime'   => $time,
            ];
            $rs = Db::name('trylesson_order')->where('id',$orderInfo['table_id'])->update($update);
            if($rs === false){
                Db::rollback();
                return false;
            }
        }
        //售课预约
        if($orderInfo['table_name'] == 'lesson_order'){
            $update = [
                'order_status' => 10,
                'paytime'      => $time,
                'updatetime'   => $time,
            ];
            $rs = Db::name('lesson_order')->where('id',$orderInfo['table_id'])->update($update);
            if($rs === false){
                Db::rollback();
                return false;
            }
        }
        //售课预约买套餐
        if($orderInfo['table_name'] == 'package_order'){
            //修改套餐单
            $update = [
                'order_status' => 1,
                'paytime'      => $time,
                'updatetime'   => $time,
            ];
            $rs = Db::name('package_order')->where('order_no',$orderInfo['out_trade_no'])->update($update); //这里不用id，是因为另有赠品单
            if($rs === false){
                Db::rollback();
                return false;
            }

            //修改预约单。这一块最好搬到计划任务里
            $args = json_decode($orderInfo['args'],true);
            if(isset($args['lesson_order_id']) && !empty($args['lesson_order_id'])){

                $package_order = Db::name('package_order')->where('order_no',$orderInfo['out_trade_no'])->where('is_gift',0)->find();
                $lesson_order  = Db::name('lesson_order')->where('id',$args['lesson_order_id'])->find();

                //课时能够支撑报名人数
                if($package_order['remain'] >= $lesson_order['number']){

                    //扣除一节
                    $update = [
                        'remain'     => $package_order['remain'] - $lesson_order['number'],
                        'updatetime' => time(),
                    ];
                    $rs1 = Db::name('package_order')->where('id',$package_order['id'])->update($update);
                    if($rs1 === false){
                        Db::rollback();
                        return false;
                    }

                    //修改预约单状态
                    $update = [
                        'order_status' => 10,
                        'paytime'      => $time,
                        'updatetime'   => $time,
                        'package_order_id' => $package_order['id'],
                    ];
                    if($lesson_order['number'] > 1){
                        $update['package_remark'] = ($package_order['sessions'] - $package_order['remain'] + 1) . '-' . ($package_order['sessions'] - $package_order['remain'] + $lesson_order['number']) .'/'. $package_order['sessions'];
                    }else{
                        $update['package_remark'] = ($package_order['sessions'] - $package_order['remain'] + 1) .'/'. $package_order['sessions'];
                    }
                    $rs = Db::name('lesson_order')->where('id',$args['lesson_order_id'])->update($update);
                    if($rs === false){
                        Db::rollback();
                        return false;
                    }
                }
            }

        }

        //逻辑结束

        //状态
        $ros = Db::name('pay_order')->where(['out_trade_no' => $out_trade_no])->update(['order_status'=>1,'notifytime'=>$time]);
        if($ros === false) {
            Db::rollback();
            return false;
        }

        //默认提交
        Db::commit();
        return true;
    }

    //异步日志
    private function notify_log_start($paytype = 'wechat'){
        //记录支付回调数据
        ignore_user_abort(); // run script in background
        set_time_limit(30);
        // 日志文件 start
        $log_base_dir = '../paylog/'.$paytype.'/';
        if (!is_dir($log_base_dir))
        {
            mkdir($log_base_dir, 0770, true);
            @chmod($log_base_dir, 0770);
        }
        $notify_file = $log_base_dir.'notify.txt';
        if(!file_exists($notify_file)) {
            @touch($notify_file);
            @chmod($notify_file, 0770);
        }
        if(filesize($notify_file)>5242880)//大于5M自动切换
        {
            rename($notify_file, $log_base_dir.'notify_'.date('Y_m_d_H_i_s').'.txt');
        }
        if(!file_exists($notify_file)) {
            @touch($notify_file);
            @chmod($notify_file, 0770);
        }
        // 日志文件 end
        //开始写入
        $xml = file_get_contents("php://input");
        file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流原始数据] \n".$xml, FILE_APPEND);

        ini_set('display_errors','On');

        return $notify_file;

    }
}