mingde-bd/application/api/controller/h5/Notify.php

<?php
namespace app\api\controller\h5;

use app\hander\HelpHander;
use EasyWeChat\Factory;
use think\Controller;
use think\Db;
use think\Exception;

class Notify extends Controller
{

    public function phorder(){
        $config = config('app.wx_config');
        $app = Factory::payment($config);
        $response = $app->handlePaidNotify(function ($message, $fail) {
            if ($message['return_code'] === 'SUCCESS' && $message['result_code'] === 'SUCCESS') { // return_code 表示通信状态，不代表支付状态
                // 用户是否支付成功
                $tradeNo = $message['out_trade_no'];
                // 使用通知里的 "微信支付订单号" 或者 "商户订单号" 去自己的数据库找到订单
                $order = Db::name('ph_order_pay')->where('sn',$tradeNo)->find();
                if (!$order || $order['status'] != 0) { // 如果订单不存在 或者 订单已经支付过了
                    return true; // 告诉微信，我已经处理完了，订单没找到，别再通知我了
                }
                $ret = model('PhOrderPay')->paySuccess($order['id'],2);
                if(!$ret){
                    trace('订单修改失败');
                    $fail('订单修改失败');
                }
            } else {
                return $fail('通信失败，请稍后再通知我');
            }

            return true; // 返回处理完成
        });

        $response->send();
    }
    public function xshopOrder(){
        $config = config('app.wx_config');
        $app = Factory::payment($config);
        $response = $app->handlePaidNotify(function ($message, $fail) {
            if ($message['return_code'] === 'SUCCESS' && $message['result_code'] === 'SUCCESS') { // return_code 表示通信状态，不代表支付状态
                // 用户是否支付成功
                $tradeNo = $message['out_trade_no'];
                // 使用通知里的 "微信支付订单号" 或者 "商户订单号" 去自己的数据库找到订单
                $order = Db::name('g_orders')->where('order_sn',$tradeNo)->find();
                if (!$order || $order['status'] != 0) { // 如果订单不存在 或者 订单已经支付过了
                    return true; // 告诉微信，我已经处理完了，订单没找到，别再通知我了
                }
                $ret = Db::name('g_orders')->where('id',$order['id'])->update(['status'=>1,'pay_time'=>date('Y-m-d H:i:s')]);
                $goods = Db::name('g_order_goods')->where('order_id',$order['id'])->select();
               //增加销量
                foreach ($goods as $k=>$v){
                   Db::name('g_goods')
                        ->where('id',$v['id'])
                        ->inc('sale',$v['nums'])
                        ->update();
                }
                if(!$ret){
                    trace('订单修改失败');
                    $fail('订单修改失败');
                }
            } else {
                return $fail('通信失败，请稍后再通知我');
            }

            return true; // 返回处理完成
        });

        $response->send();
    }

}