60 lines
2.3 KiB
PHP
60 lines
2.3 KiB
PHP
<?php
|
|
namespace app\common\workerman\xhs\handlers;
|
|
|
|
use app\common\workerman\xhs\BaseMessageHandler;
|
|
use app\common\workerman\xhs\WorkerEnum;
|
|
use Workerman\Connection\TcpConnection;
|
|
class CheckInitHandler extends BaseMessageHandler
|
|
{
|
|
protected int $msgType;
|
|
public function handle(TcpConnection $connection, string $uid, array $payload): void
|
|
{
|
|
$content = !is_array($payload['content']) ? json_decode($payload['content'], true) : $payload['content'];
|
|
try {
|
|
$this->uid = $uid;
|
|
$this->payload = $payload;
|
|
$this->connection = $connection;
|
|
|
|
$this->userId = $content['userId'] ?? 0;
|
|
|
|
$worker = $this->service->getWorker();
|
|
$uid = $worker->devices[$this->payload['deviceId']] ?? '';
|
|
if($uid == ''){
|
|
$this->payload['reply'] = "设备{$this->payload['deviceId']}不在线,无法获取账号信息";
|
|
$this->payload['code'] = WorkerEnum::DEVICE_NOT_ONLINE;
|
|
$this->sendError($this->connection, $this->payload);
|
|
return;
|
|
}
|
|
|
|
$isInit = $worker->uidConnections[$uid]->initial == 1 ? 1 : 0;
|
|
|
|
$message = array(
|
|
'messageId' => $uid,
|
|
'type' => WorkerEnum::WEB_INIT_CHECK_TEXT,
|
|
'deviceId' => $this->payload['deviceId'],
|
|
'appVersion' => $this->payload['appVersion'],
|
|
'appType' => $this->payload['appType'] ?? 3,
|
|
'reply' => [
|
|
'type' => WorkerEnum::WEB_INIT_CHECK_TEXT,
|
|
'msg' => '设备初始化检查',
|
|
'deviceId' => $this->payload['deviceId'],
|
|
'isInit' => $isInit,
|
|
'code' => WorkerEnum::INIT_CHECK
|
|
],
|
|
'code' => WorkerEnum::SUCCESS_CODE,
|
|
);
|
|
$this->setLog($message, 'init');
|
|
$this->sendResponse($this->uid, $message, $message['reply']);
|
|
|
|
} catch (\Exception $e) {
|
|
$this->setLog('异常信息'. $e, 'init');
|
|
|
|
$this->payload['reply'] = $e->getMessage();
|
|
$this->payload['code'] = WorkerEnum::INIT_CHECK_ERROR_CODE;
|
|
$this->payload['type'] = 'error';
|
|
$this->sendError($this->connection, $this->payload);
|
|
}
|
|
}
|
|
|
|
|
|
} |