12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758 |
- <?php
- namespace app\jobs\order;
- use app\services\order\StoreOrderStatusServices;
- use app\services\order\StoreOrderTakeServices;
- use crmeb\basic\BaseJobs;
- use crmeb\traits\QueueTrait;
- use think\facade\Log;
- class OrderTakeJob extends BaseJobs
- {
- use QueueTrait;
-
- protected static function queueName()
- {
- return 'CRMEB_PRO_TASK';
- }
- public function doJob($order)
- {
- if (!$order) return true;
-
- $service = app()->make(StoreOrderTakeServices::class);
-
- $statusService = app()->make(StoreOrderStatusServices::class);
- $res = $service->update($order['id'], ['status' => 2]) && $statusService->save([
- 'oid' => $order['id'],
- 'change_type' => 'user_take_delivery',
- 'change_message' => '用户已收货',
- 'change_time' => time()
- ]);
- $order = $service->get((int)$order['id']);
- $res = $res && $service->storeProductOrderUserTakeDelivery($order);
- if (!$res) {
- Log::error('收货失败:' . $order['order_id']);
- }
- return true;
- }
- }
|