weidian-api/app/Http/Controllers/MiniPayController.php

<?php

namespace App\Http\Controllers;

use App\Events\RetailOutboundEvent;
use App\Events\NewOrder;
use App\Models\Amount;
use App\Models\Integral;
use App\Models\LogW;
use App\Models\VipLog;
use App\Models\Address;
use App\Models\DwbsUser;
use App\Models\Goods;
use App\Models\GoodSku;
use App\Models\Order;
use App\Models\OrderDetail;
use App\Models\Store;
use App\Models\User;
use Carbon\Carbon;
use EasyWeChat\Factory;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class MiniPayController extends Controller
{
    protected $option = [];
    protected $header = array();
    protected $retryTimes;
    public function pay(Request $request)
    {
        $order_no=$request->input('order_no');
        try{
            DB::transaction(function()use($order_no, &$order ,&$seconds){
                $order=Order::where('order_no',$order_no)->lockForUpdate()->first();
                $seconds=Carbon::now()->subSeconds(60)->toDateTimeString();//限制调起支付60秒
                if(empty($order)){
                    throw new \Exception("订单有误");
                }
                if($order->prepare_pay_at >= $seconds){
                    throw new \Exception("订单正在支付中");
                }
                $order->prepare_pay_at=Carbon::now();
                $order->save();
            });
        }catch(\Exception $e){
            return $this->error('450001',$e->getMessage());
        }
        if($order->apply_cancel == 2){
            return $this->error('450001','订单已取消');
        }
        if($order->is_pay != 0 || $order->status != 0){
            return $this->error('450001','订单状态有误');
        }
        if($order->account <= 0){
            return $this->error('450001','支付金额有误');
        }
        $openid=User::where('id',Auth::user()->id)->value('openId');
        $store=Store::where('id',$order->store_id)->first();
        if(empty($store)){
            return $this->error('450001','代理店铺信息有误');
        }
        if($store->status==1){
            return $this->error('450001','代理店铺已被禁用');
        }
        $options = $this->options($order->store_id);
        $payment = Factory::payment($options);
        $jssdk = $payment->jssdk;
        Log::info(round($order->account/1000,2));
        Log::info(round($order->account/10));
        $two_minutes=Carbon::now()->addSeconds(55)->toDateTimeString();//限制支付时间55秒
        $cancel_time=Carbon::parse($order->created_at)->addMinutes(59)->toDateTimeString();//系统自动取消时间前一分钟
        if(Carbon::now() >= $cancel_time){
            return $this->error('450001','订单将被取消');
        }
        if($two_minutes <= $cancel_time){
            $expire=date("YmdHis",strtotime($two_minutes));
        }else{
            $expire=date("YmdHis",strtotime($cancel_time));
        }
        Log::info('1qaqaqaqaqa'.$expire);
        $attributes = [
            'time_expire'       => $expire,
            'trade_type'        => 'JSAPI',                 // 支付方式
            'body'              => '订单支付',                // 订单说明
            'out_trade_no'      => mt_rand('1000','9999').'_'.$order_no,               // 自定义订单号
            'total_fee'         => $order->account*100,     // 单位：分
            'sub_openid'            => $openid,    // 当前用户的openId
            'profit_sharing'    => 'Y'
        ];
        $result = $payment->order->unify($attributes);
        if ($result['return_code'] == 'SUCCESS' && $result['result_code'] == 'SUCCESS') {
            $prepayId = $result['prepay_id'];
            $config = $jssdk->sdkConfig($prepayId);
            return response()->json([
                'error_code'=>200,
                'msg'=>'成功',
                'data'=>$config
            ]);
        }
        if ($result['return_code'] == 'FAIL' && array_key_exists('return_msg', $result)) {
            Log::info('订单支付失败：'.$order->user_id.'/'.$order_no.'/'.$order->money.'/'.$result['return_msg']);
            return response()->json([
                'error_code'=>401,
                'msg'=> $result['return_msg'],
            ]);
        }
        Log::info('订单支付失败：'.$order->user_id.'/'.$order_no.'/'.$order->money.'/'.$result['err_code_des']);
        return response()->json([
            'error_code'=>401,
            'msg'=> $result['err_code_des'],
        ]);
    }
    protected function options($id){
        return  [
            'app_id' => 'wxf536016d4923e584',//config('wechat.payment.default.app_id'),
            'mch_id' => config('wechat.payment.default.mch_id'),
            'sub_mch_id' => Store::where('id',$id)->value('sub_mchid'),
            'key' => config('wechat.payment.default.key'),
            'notify_url' => url('api/payment/notify')
        ];
    }
    public function notify(Request $request)
    {
        Log::info('支付回调成功');
        $options = [
            'app_id' => 'wxf536016d4923e584',//config('wechat.payment.default.app_id'),
            'mch_id' => config('wechat.payment.default.mch_id'),
            'key' => config('wechat.payment.default.key'),
            'notify_url' => url('api/payment/notify')
        ];
        $payment = Factory::payment($options);
        $response = $payment->handlePaidNotify(function ($message, $fail)
        {
            Log::info('支付返回数据:'.json_encode($message));
            LogW::create([
                'content'=>json_encode($message),
                'type'=>1
            ]);
            // 根据返回的订单号查询订单数据
            Log::info($message['out_trade_no']);
            $rand_no=explode('_',$message['out_trade_no'])[0];
            $message['out_trade_no']=explode('_',$message['out_trade_no'])[1];
            Log::info($message['out_trade_no']);
            $order=Order::where('order_no',$message['out_trade_no'])->first();
            if($order->is_pay==1){
                Log::info('订单号为:'.$message['out_trade_no'].'的订单已支付');
                return true;
            }
            if (!$order || $order->status  == 1) {
                Log::info('订单不存在,订单号:'.$message['out_trade_no'].'/支付单号:'.$message['transaction_id'].'/支付状态:'.$message['result_code']);
                return true;//订单不存在 或者 订单已支付
            }
            if ($message['result_code'] === 'FAIL') {  //支付失败
                Log::warning('支付失败');
                return true;
            }
            if ($message['return_code'] === 'SUCCESS') { // return_code 表示通信状态，不代表支付状态
                Log::info('支付成功，微信支付单号:'.$message['transaction_id']);
                // 支付成功后的业务逻辑
                if($message['result_code'] === 'SUCCESS') {
                    $total_fee=$message['total_fee']/100;
                    DB::transaction(function()use($order,$message,$total_fee,$rand_no){
                        //修改订单状态
                        $order->status          = 1;
                        $order->is_pay          = 1;
                        $order->pay_type        = 1;
                        $order->pay_money       = $total_fee;
                        $order->rand_no         = $rand_no;
                        $order->pay_open_id     = $message['openid'];
                        $order->self_pay        = 0;
                        $order->wechat_pay_no   = $message['transaction_id'];
                        $order->pay_at          = $message['time_end'];
                        $order->save();
                        //学分变更
                        $integral=$order->total*5;
                        Integral::create([
                            'store_id'=>$order->store_id,
                            'order_no'=>$order->order_no,
                            'num'=>$order->total,
                            'integral'=>$integral,
                            'integral_double'=>$integral,
                            'type'=>1,
                            'remark'=>'下单成功'
                        ]);
                        //店铺信息
                        $store=Store::where('id',$order->store_id)->lockForUpdate()->first();
                        $start_money= $store->pending_amount;
                        $store->pending_amount = $store->pending_amount += $total_fee;
                        $store->integral += $integral;
                        $store->save();
                        //规格销量
                        $details=OrderDetail::where('order_no',$order->order_no)->get();
                        foreach($details as $key=>$val){
                            $where=[];
                            $where['goods_id']=$val->goods_id;
                            $where['size']=$val->size;
                            $where['type']=$val->type;
                            //规格销量
                            $sku=GoodSku::where($where)->lockForUpdate()->first();
                            $sku->sale_num += $val->num;
                            $sku->save();
                            //商品销量
                            $goods=Goods::where('id',$val->goods_id)->lockForUpdate()->first();
                            $goods->sale_num += $val->num;
                            $goods->save();
                        }
                        //用户vip变更
                        $vipLog=VipLog::where('user_id',$order->user_id)
                            ->where('store_id',$order->store_id)->first();
                        if(empty($vipLog) && $order->total>=2){
                            VipLog::create([
                                'user_id'=>$order->user_id,
                                'store_id'=>$order->store_id,
                                'order_no'=>$message['out_trade_no']
                            ]);
                            Order::where('order_no',$message['out_trade_no'])->update([
                                'vip'=>1
                            ]);
                        }
                        //支付日志
                        Amount::create([
                            'user_id'       =>  $order->user_id,
                            'store_id'      =>  $order->store_id,
                            'order_no'      =>  $message['out_trade_no'],
                            'transaction_id'=>  $message['transaction_id'],
                            'money'         =>  $total_fee,
                            'type'          =>  1,  //支付
                            'status'        =>  1,  //成功
                            'service_fee'   =>  0,
                            'start_money'   =>  $start_money,//支付前冻结金额
                            'end_money'     =>  $store->pending_amount,//支付后冻结金额
                            'start_amount'  =>  $store->available_amount,//支付前可用金额
                            'end_amount'    =>  $store->available_amount,//支付后可用金额
                            'remark'        =>  '收款',
                        ]);
                    });
                    //减库存
                    DB::connection('mysql_dwbs')->transaction(function()use($order) {
                        event(new RetailOutboundEvent($order->order_no));
                    },5);
                    //新订单通知
                    $store=Store::where('id',$order->store_id)->first();
                    $user=DwbsUser::withTrashed()->where('id',$store->user_id)->first();
                    if($user->openid){
                        Log::info($user->openid);
                        $data['openid']=$user->openid;
                        $data['data']=[
                            'first' => '您有新的客户订单，请及时处理',
                            'keyword1' => User::where('id',$order->user_id)->value('nickname'),
                            'keyword2' => number_format($order->account, 2),
                            'keyword3' => $order->order_no,
                            'keyword4' => $order->created_at
                        ];
                        event(new NewOrder($data));
                    }
                }
                Log::info('支付结束');
                return true;
            }else{
                Log::info('通信失败');
                return $fail('通信失败，请稍后再通知我');
            }
        });
        return $response;
    }
}