OrderPayed.php 1.5 KB
<?php

namespace addons\groupon\job;

use addons\groupon\library\traits\Groupon;
use addons\groupon\library\traits\StockSale;
use addons\groupon\model\GoodsComment;
use addons\groupon\model\Order;
use addons\groupon\model\OrderAction;
use addons\groupon\model\OrderItem;
use think\queue\Job;

/**
 * 订单支付完成
 */
class OrderPayed extends BaseJob
{
    use StockSale;

    /**
     * 订单支付完成
     */
    public function payed(Job $job, $data){
        try {
            $order = $data['order'];
            $user = $data['user'];

            $order = Order::with('item')->where('id', $order['id'])->find();

            // 数据库删订单的问题常见,这里被删的订单直接把队列移除
            if ($order) {
                \think\Db::transaction(function () use ($order, $user, $data) {
                    // 触发订单支付完成事件
                    $data = ['order' => $order];
                    \think\Hook::listen('groupon_order_payed_after', $data);
                });
            }
            
            // 删除 job
            $job->delete();
        } catch (\Exception $e) {
            // 队列执行失败
            $error = json_encode([
            'a' => $e->getLine(),
            'b' => $e->getFile(),
            'c' =>$e->getTrace(),
            'd' => $e->getMessage()
            ], JSON_UNESCAPED_UNICODE);

            
            \think\Log::error('queue-' . get_class() . '-payed' . ':执行失败,错误信息:' . $error);
        }
    }
}