<?php

namespace app\modules\api\components;

use PhpMqtt\Client\MQTTClient;

class Mqtt
{

    public $mqtt;
    public $data = [];

    public function __construct()
    {
        try {
            $redis_name = "api:cxaibc:mqtt:config";
            $data = \Yii::$app->redis->get($redis_name);
            if (!empty($data)) {
                $data = json_decode($data, true);
                $server = $data['mqtt_server'];
                $port = intval($data['mqtt_port']);
                $username = $data['mqtt_user'];
                $password = $data['mqtt_pass'];
            } else {
                $server = \Yii::$app->params['mqtt']['server'];
                $port = \Yii::$app->params['mqtt']['port'];
                $username = \Yii::$app->params['mqtt']['username'];
                $password = \Yii::$app->params['mqtt']['password'];
            }
            $clientId = md5(microtime(true));
            $this->mqtt = new MqttClient($server, $port, $clientId);
            $this->mqtt->connect($username, $password);
        } catch (\Exception $e) {
            $this->data = ['code' => 1, 'msg' => "链接mqtt失败"];
        }
    }

    /**
     * @ Author : Lw
     * @ CreateTime : 2022-11-02
     * @ Info : 启动，关闭车辆
     * @param string $number 球车编号
     * @param int $OPERATION_ENABLE -- 0.禁止使用，1.允许使用
     * @param int $OPERATION_LEVEL -- 0.助力模式，1.遥杆模式，2.跟随模式 -- 现在应该是传入0
     * @return array 此操作仅做请求，最终车辆的信息请查找redis中车辆的最新数据
     */
    public function sendOpen(string $number, int $OPERATION_ENABLE, int $OPERATION_LEVEL)
    {
        if (!empty($this->data)) {
            return $this->data;
        }
        // 车辆状态，1.启动，0.关闭
        $redis_name = "api:cxaibc:sendOpen:{$number}";
        try {
            $time_base = time();
            $str_res = pack('l', $time_base) . pack('C', $OPERATION_ENABLE) . pack('C', $OPERATION_LEVEL) . strtoupper(md5(str_pad($number, 16, "0", STR_PAD_LEFT) . '+' . $time_base));//请求启动车辆
            $res = $this->x_o($str_res);
            $str_res .= chr($res);
            $this->mqtt->publish("$number/Permission", $str_res);
//            $this->sendAck($number);
            \Yii::$app->redis->set($redis_name, $OPERATION_ENABLE);
        } catch (\Exception $e) {
            return ['code' => 1, 'msg' => $e->getMessage()];
        }
        $this->getInfo($number,1);
        return ['code' => 0, 'msg' => '成功'];
    }

    /**
     * @ Author : Lw
     * @ CreateTime : 2022-11-02
     * @ Info : 主动获取车辆状态，请求后对方服务器会及时推送一条消息到本服务器上
     * @param string $number 球车编号
     * @param int $type 类型，1.车辆详情，2、定位信息，4.告警信息，7.三种信息都查
     * @return array 查询的信息都会订阅中，先存入redis后再存入mysql，此操作只做请求
     */
    public function getInfo(string $number, int $type)
    {
        if (!empty($this->data)) {
            return $this->data;
        }
        try {
            $time_base = time();
            $str_res = pack('l', $time_base) . pack('L', $type);
            $res = $this->x_o($str_res);
            $str_res .= chr($res);
            $this->mqtt->publish("$number/Query", $str_res);
//            $this->sendAck($number);
        } catch (\Exception $e) {
            return ['code' => 1, 'msg' => $e->getMessage()];
        }
        return ['code' => 0, 'msg' => ''];
    }

    /**
     * @ Author : Lw
     * @ CreateTime : 2022-11-07
     * @ Info : 发送ack消息，用于同步时间戳
     */
    public function sendAck(string $number)
    {
        if (!empty($this->data)) {
            return $this->data;
        }
        try {
            $time_base = time();
            $str_res = pack('l', $time_base) . pack('l', 1);
            $res = $this->x_o($str_res);
            $str_res .= chr($res);
            $this->mqtt->publish("$number/Ack", $str_res);
        } catch (\Exception $e) {
            return ['code' => 1, 'msg' => $e->getMessage()];
        }
        return ['code' => 0, 'msg' => ''];
    }

    public function x_o($data)
    {
        $t = 0;
        for ($i = 0; $i < strlen($data); $i++) {
            if ($i) {
                $t ^= ord($data[$i]);
            } else {
                $t = ord($data[$i]) ^ 0;
            }
        }
        return $t;
    }

}