Update: 2026-07-22 23:06:34
This commit is contained in:
@@ -91,6 +91,10 @@ try {
|
|||||||
$validDrivers[] = $hasCache ? array_merge($public, [
|
$validDrivers[] = $hasCache ? array_merge($public, [
|
||||||
'id' => $d_id,
|
'id' => $d_id,
|
||||||
'driver_id' => $d_id,
|
'driver_id' => $d_id,
|
||||||
|
'latitude' => $d_coord[1],
|
||||||
|
'longitude' => $d_coord[0],
|
||||||
|
'heading' => $profile['heading'] ?? $public['heading'] ?? 0,
|
||||||
|
'speed' => $profile['speed'] ?? $public['speed'] ?? 0,
|
||||||
'distance' => $d_dist,
|
'distance' => $d_dist,
|
||||||
'cached' => true
|
'cached' => true
|
||||||
]) : [
|
]) : [
|
||||||
|
|||||||
@@ -890,6 +890,13 @@ $io->on('connection', function ($socket) use ($INTERNAL_KEY) {
|
|||||||
if ($needExpireRefresh || $needHmset) {
|
if ($needExpireRefresh || $needHmset) {
|
||||||
$eventBuffer[$driverId]['expire'] = 900;
|
$eventBuffer[$driverId]['expire'] = 900;
|
||||||
$state['expire_ts'] = $now;
|
$state['expire_ts'] = $now;
|
||||||
|
if (!isset($eventBuffer[$driverId]['hmset'])) {
|
||||||
|
$eventBuffer[$driverId]['hmset'] = [
|
||||||
|
'id' => $driverId, 'lat' => $lat, 'lng' => $lng, 'updated_at' => $now
|
||||||
|
];
|
||||||
|
} else {
|
||||||
|
$eventBuffer[$driverId]['hmset']['updated_at'] = $now;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if ($statusChanged) {
|
if ($statusChanged) {
|
||||||
|
|||||||
Reference in New Issue
Block a user