OrderPayed.php
1.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
<?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);
}
}
}