|
@@ -195,11 +195,36 @@ class Events
|
|
|
case 'debug':
|
|
case 'debug':
|
|
|
self::debug($message['data']);
|
|
self::debug($message['data']);
|
|
|
break;
|
|
break;
|
|
|
|
|
+ case 'cancelqueue':
|
|
|
|
|
+ self::cancelqueue($message['data']);
|
|
|
|
|
+ break;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
return true;
|
|
return true;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ //用户取消排队
|
|
|
|
|
+ public function cancelqueue($messageArray)
|
|
|
|
|
+ {
|
|
|
|
|
+ $uid = intval($messageArray['uid']);
|
|
|
|
|
+ if (empty($uid)) {
|
|
|
|
|
+ return false;
|
|
|
|
|
+ }
|
|
|
|
|
+ $sessionuid = intval($_SESSION['uid']);
|
|
|
|
|
+ if ($sessionuid != $uid) {
|
|
|
|
|
+ return false;
|
|
|
|
|
+ }
|
|
|
|
|
+ $listu = self::$redis->hget(self::USERLIST, $uid);
|
|
|
|
|
+ if ($listu) {
|
|
|
|
|
+ self::$redis->hdel(self::USERLIST, $uid);
|
|
|
|
|
+ Gateway::sendToCurrentClient(json_encode(['message_type' => 'cancelqueueret', 'data' => ['flag' => 1, 'msg' => '取消排队成功!']], 256));
|
|
|
|
|
+ return;
|
|
|
|
|
+ } else {
|
|
|
|
|
+ Gateway::sendToCurrentClient(json_encode(['message_type' => 'cancelqueueret', 'data' => ['flag' => 0, 'msg' => '取消排队失败!']], 256));
|
|
|
|
|
+ }
|
|
|
|
|
+ return;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
// 弹出评价.
|
|
// 弹出评价.
|
|
|
public static function getEvaluate($message)
|
|
public static function getEvaluate($message)
|
|
|
{
|
|
{
|