bike-admin/app/Observers/BikeObserver.php

<?php
/**
 * Created by PhpStorm.
 * User: Mead
 * Date: 2019/9/19
 * Time: 10:09 AM
 */

namespace App\Observers;

use App\Handlers\BikeStatusInfoSyncHandler;
use App\Models\Bike;
use App\Models\LocationsLog;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Redis;

class BikeObserver
{

    public function created(Bike $bike)
    {
        $bike_no = $bike->bike_no;
        $box_no = $bike->box_no;
        if ($bike_no && $box_no) {
            $redis = Redis::connection();
            $redis->hset(Bike::REDIS_BOX_NO_AND_BIKE_NO_TAG, $box_no, $bike_no);
        }
    }

    public function updated(Bike $bike)
    {
        $bike_no = $bike->bike_no;
        $box_no = $bike->box_no;
        $redis = Redis::connection();

        if ($bike->isDirty('box_no')) {
            DB::table('bikes')->where('id', $bike->id)->update([
                'is_link' => Bike::LINK_OFFLINE
            ]);
            $old_box_no = $bike->getOriginal('box_no');
            $redis->hdel(Bike::REDIS_BOX_NO_AND_BIKE_NO_TAG, [$old_box_no]);
        }

        if ($bike_no && $box_no) {

            $redis->hset(Bike::REDIS_BOX_NO_AND_BIKE_NO_TAG, $box_no, $bike_no);

            if ($bike->isDirty('put_status')) {
                $BikeStatusInfoSyncHandler = (new BikeStatusInfoSyncHandler());
                if ($bike->put_status === Bike::PUT_STATUS_NO) {
                    $BikeStatusInfoSyncHandler->toBikeOffLineStatus($bike_no);
                } else {
                    $location = LocationsLog::getNewestLocationByBikeNo($bike_no);
                    $BikeStatusInfoSyncHandler->toBikeOnLineStatus($bike_no, $location['lng'], $location['lat']);
                }
            }

        }
    }

    public function deleted(Bike $bike)
    {
        $box_no = $bike->box_no;
        $redis = Redis::connection();
        $redis->hdel(Bike::REDIS_BOX_NO_AND_BIKE_NO_TAG, [$box_no]);

    }
}