1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677 |
- <?php
- namespace App\Jobs;
- use App\Handlers\ClientServer;
- use App\Models\Device;
- use App\Models\Order;
- use App\Repositories\Enums\DeviceLuTypeEnum;
- use App\Repositories\Enums\OrderStatusEnum;
- use App\Repositories\Enums\OrderWorkTypeCodeEnum;
- use Carbon\Carbon;
- use Illuminate\Bus\Queueable;
- use Illuminate\Contracts\Queue\ShouldBeUnique;
- use Illuminate\Contracts\Queue\ShouldQueue;
- use Illuminate\Foundation\Bus\Dispatchable;
- use Illuminate\Queue\InteractsWithQueue;
- use Illuminate\Queue\SerializesModels;
- use Illuminate\Support\Facades\Log;
- class CloseDeviceJob implements ShouldQueue
- {
- use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
- private $order_id = 0;
- /**
- * Create a new job instance.
- *
- * @return void
- */
- public function __construct($order_id)
- {
- $this->order_id = $order_id;
- }
- /**
- * Execute the job.
- *
- * @return void
- */
- public function handle()
- {
- $order = Order::query()->find($this->order_id);
- if (!$order) return;
- if (!in_array($order->status, [OrderStatusEnum::IN_SERVICE, OrderStatusEnum::ORDER_PAUSE])) {
- return;
- }
- $order->status = OrderStatusEnum::ORDER_OVER;
- $order->end_use_time = now();
- $order->save();
- //关闭设备
- $device = Device::query()->where('id', $order->device_id)->first();
- if (!$device) return;
- switch ($order->work_type) {
- case OrderWorkTypeCodeEnum::A:
- $device->a = DeviceLuTypeEnum::FREE;
- break;
- case OrderWorkTypeCodeEnum::B:
- $device->b = DeviceLuTypeEnum::FREE;
- break;
- case OrderWorkTypeCodeEnum::AB:
- $device->a = DeviceLuTypeEnum::FREE;
- $device->b = DeviceLuTypeEnum::FREE;
- break;
- }
- $device->save();
- Log::error("CloseDeviceJob||" . $order->no . '||' . $order->pay_time . '||' . $order->work_time . '||' . now());
- ClientServer::closeBoxByOrder($order, $device->box_no, $device->a, $device->b);
- }
- }
|