123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159 |
- <?php
- namespace App\Handlers;
- use App\Utils\Admin;
- use Illuminate\Support\Facades\Redis;
- class BikeStatusInfoSyncHandler
- {
-
- const ROLE_USER = 'user';
-
- const ROLE_WORKER = 'worker';
-
- const ROLE_SERVER = 'server';
-
- const ROLE_BIND = 'bind';
-
- const CLOSE_BIKE_TTL = 10;
- private static $redis = '';
-
- const REDIS_BIKE_LOCATION_TAG = 'bike_locations';
- const REDIS_RIDE_BIKE_ORDERS_TAG = 'ride_orders:';
- const REDIS_RIDE_BIKE_WORKER_ORDERS_TAG = 'ride_orders_worker';
- public function __construct()
- {
- self::$redis = Redis::connection();
- }
-
- public function toBikeRideStatus($role, $bike_no, $data = [], $is_put_status = 1)
- {
- $data['role'] = $role;
- self::$redis->set(self::REDIS_RIDE_BIKE_ORDERS_TAG . $bike_no, serialize($data));
-
- if ($is_put_status) {
- self::$redis->zrem(self::REDIS_BIKE_LOCATION_TAG, $bike_no);
- }
- if ($role == self::ROLE_WORKER) {
- self::$redis->hset(self::REDIS_RIDE_BIKE_WORKER_ORDERS_TAG, $bike_no, Admin::user()->id);
- }
- }
-
- public function toBikeWaitRideStatus($bike_no, $lng = 0, $lat = 0, $is_put_status = 1)
- {
- self::$redis->expire(self::REDIS_RIDE_BIKE_ORDERS_TAG . $bike_no, self::CLOSE_BIKE_TTL);
- if ($is_put_status) {
- self::$redis->geoadd(self::REDIS_BIKE_LOCATION_TAG, $lng, $lat, $bike_no);
- }
-
- self::$redis->hdel(self::REDIS_RIDE_BIKE_WORKER_ORDERS_TAG, $bike_no);
- }
-
- public function toBikeOnLineStatus($bike_no, $lng = 0, $lat = 0)
- {
- self::$redis->del([self::REDIS_RIDE_BIKE_ORDERS_TAG . $bike_no]);
- self::$redis->geoadd(self::REDIS_BIKE_LOCATION_TAG, $lng, $lat, $bike_no);
- }
-
- public function toBikeOffLineStatus($bike_no)
- {
-
- self::$redis->zrem(self::REDIS_BIKE_LOCATION_TAG, $bike_no);
- }
-
- public function getRideBikeOrderInfo($bike_no)
- {
- $order = self::$redis->get(self::REDIS_RIDE_BIKE_ORDERS_TAG . $bike_no);
- if (!$order) return false;
- return unserialize($order);
- }
-
- public function toBikeRentRideStatus($bike_no)
- {
- $data = $this->getRideBikeOrderInfo($bike_no);
- $data['is_close_bike'] = 0;
- self::$redis->set(self::REDIS_RIDE_BIKE_ORDERS_TAG . $bike_no, serialize($data));
- }
-
- public function toBikeRentWaitRideStatus($bike_no)
- {
- $data = $this->getRideBikeOrderInfo($bike_no);
- $data['is_close_bike'] = 1;
- self::$redis->set(self::REDIS_RIDE_BIKE_ORDERS_TAG . $bike_no, serialize($data));
- }
-
- public function toBikeGetElectric($bike_no)
- {
- $data = $this->getRideBikeOrderInfo($bike_no);
- $data['is_out_area_lost_electric'] = 0;
- self::$redis->set(self::REDIS_RIDE_BIKE_ORDERS_TAG . $bike_no, serialize($data));
- }
-
- public function toBikeNoElectric($bike_no)
- {
- $data = $this->getRideBikeOrderInfo($bike_no);
- $data['is_low_electric_close_bike'] = 0;
- self::$redis->set(self::REDIS_RIDE_BIKE_ORDERS_TAG . $bike_no, serialize($data));
- }
- }
|