package com.ruoyi.device.mqtt;

import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.*;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class MQPublic {

	/**
	 * 通信质量qos为0：表示WEB服务器向MQTT服务器只发送一次，不管MQTT服务器有没有收到
	 * WEB服务器向MQTT服务器发布数据，此方法封装了publish函数
	 * @param topic 向底层网关发送数据，官方话：称此为主题，向那个主题发送数据 网关：即主题，设备唯一标识
	 * @param pushMessage WEB服务器向MQTT服务器发送的数据
	 */
	public void publish_0(int qos, String topic, byte[] pushMessage) {
		publish(0, false, topic, pushMessage);
	}

	/**
	 * 通信质量qos为1：表示WEB服务器向MQTT服务器发送数据，MQTT服务器一定会收到一次数据，如果MQTT服务器没有响应“收到数据”，那么WEB服务器就会一直发送数据
	 * WEB服务器向MQTT服务器发布数据，调用此函数，此方法封装了publish函数，通信质量qos为1
	 * @param topic 向底层网关发送数据，官方话：称此为主题，向那个主题发送数据 网关：即主题，设备唯一标识
	 * @param pushMessage WEB服务器向MQTT服务器发送的数据
	 */
	public void publish_1(String topic, byte[] pushMessage) {
		publish(1, false, topic, pushMessage);
	}

	/**
	 *通信质量qos为2：表示WEB服务器向MQTT服务器发送数据，两者会进行至少两次请求/响应流程，避免数据在传输中的丢失，但是相应的也会消耗计算机中的资源
	 * WEB服务器向MQTT服务器发布数据，此方法封装了publish函数，通信质量：2
	 * @param topic 向底层网关发送数据，官方话：称此为主题，向那个主题发送数据 网关：即主题，设备唯一标识
	 * @param pushMessage WEB服务器向MQTT服务器发送的数据
	 */
	public void publish_2(String topic, byte[] pushMessage) {
		publish(2,false, topic, pushMessage);
	}

	/**
	 * 发布函数：WEB服务器向MQTT服务器发送数据
	 *
	 * @param qos 通信质量
	 * @param retained 默认：false-非持久化（是指一条消息消费完，就会被删除；持久化，消费完，还会保存在服务器中，当新的订阅者出现，继续给新订阅者消费）
	 * @param topic 向底层网关发送数据，官方话：称此为主题，向那个主题发送数据 网关：即主题，设备唯一标识
	 * @param pushMessage WEB服务器向MQTT服务器发送的数据
	 */
	public void publish(int qos, boolean retained, String topic, byte[] pushMessage) {
		MqttMessage message = new MqttMessage();
		message.setQos(qos);
		message.setRetained(retained);
		// 将String[]数组转换为byte数组发送
		message.setPayload(pushMessage);
		MqttTopic mTopic = MQClient.getClient().getTopic(topic);
		if (null == mTopic) {
			log.error("===============>>>MQTT {} 不存在<<=======================",topic);
		}
		MqttDeliveryToken token;
		try {
			token = mTopic.publish(message);
			token.waitForCompletion();
		} catch (MqttPersistenceException e) {
			e.printStackTrace();
		} catch (MqttException e) {
			e.printStackTrace();
		}
	}
}