更新异常队列

This commit is contained in:
yaooo 2023-09-08 12:02:18 +08:00
parent b112ab5f42
commit 00ca6da34d

View File

@ -28,15 +28,18 @@ class SendGoodsCodeJob implements JobInterface
{ {
$this->event = $data; $this->event = $data;
Log::info("sendGoodsCodeJob ============= handle监听order_id " . $this->event['order_id']); Log::info("sendGoodsCodeJob ============= handle监听order_id " . $this->event['order_id']);
if ($this->event['activity_type'] == 0) { try {
//发起物流信息返回快递员手机 if ($this->event['activity_type'] == 0) {
$logisticsPhone = $this->sendLogistics($this->event['order_id'], $this->event['order_sn']); //发起物流信息返回快递员手机
//生成用户的收货码 $logisticsPhone = $this->sendLogistics($this->event['order_id'], $this->event['order_sn']);
$this->generateLogisticsCode($this->event['uid'], $this->event['order_id'], $this->event['order_sn'], $logisticsPhone); //生成用户的收货码
//记录订单收货地址记录 $this->generateLogisticsCode($this->event['uid'], $this->event['order_id'], $this->event['order_sn'], $logisticsPhone);
$this->recordOrderAddr($this->event); //记录订单收货地址记录
$this->recordOrderAddr($this->event);
}
} catch (\Exception $e) {
Log::info('sendGoodsCodeJob 异常:' . $e->getMessage());
} }
$job->delete(); $job->delete();
} }