using IStation.DataDockingMqtt;
using MQTTnet.Client.Connecting;
using MQTTnet.Client.Options;
using MQTTnet.Client.Receiving;
using MQTTnet.Extensions.ManagedClient;
using MQTTnet;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using IStation.DataDockingMqtt4SQI_DEMO.sub;

namespace IStation.DataDockingMqtt4SQI_DEMO
{
    public class Mqtt
    {
        static string TopicName = "MK-S906/up/Data/SHHM22100001";
        static string TopicName2 = "tkg07342A3521633000/msg/up";

        static string MqttUserName = "test";
        static string MqttUserPwd = "123456";
        static string MqttHostAdress = "106.14.83.94";
        static int MqttHostPort = 8810;

        public static async void Connect()
        {
            //连接到MQTT服务器
            IManagedMqttClient _mqttClient = new MqttFactory().CreateManagedMqttClient();
            _mqttClient.ConnectedHandler = new MqttClientConnectedHandlerDelegate(e =>
            {
                Console.WriteLine("链接 MQTT 服务器成功!");
            });
            _mqttClient.ConnectingFailedHandler = new ClientConnectingFaildHandler(e =>
            {
                Console.WriteLine("链接 MQTT 服务器失败!");
            });
            _mqttClient.UseDisconnectedHandler(ee =>
            {
                Console.WriteLine("链接 MQTT 服务器断开连接!");
            });
            _mqttClient.UseConnectedHandler(ee =>
            {
                Console.WriteLine("链接 MQTT 连接到服务!");
            });
            //client.DisconnectedHandler
            _mqttClient.ApplicationMessageReceivedHandler = new MqttApplicationMessageReceivedHandlerDelegate(Client_ApplicationMessageReceived);

            IMqttClientOptions clientOptions = new MqttClientOptionsBuilder()
                .WithClientId("EventechDemo01")
                .WithTcpServer(MqttHostAdress, MqttHostPort)
                .WithCredentials(MqttUserName, MqttUserPwd)
                .WithCleanSession(false)//false 接收离线消息 服务端需要启用之久会话 WithPersistentSessions
                                        //.WithWillMessage(new MqttApplicationMessage { Topic = "ooo", Payload = Encoding.UTF8.GetBytes("下线通知"), Retain = true })
                .WithWillDelayInterval(1)
                .Build();
            IManagedMqttClientOptions options = new ManagedMqttClientOptionsBuilder()
                .WithAutoReconnectDelay(TimeSpan.FromSeconds(5))
                .WithClientOptions(clientOptions)
                .Build();

            await _mqttClient.StartAsync(options);// 异步连接到服务器

            // 订阅主题过滤器1
            MqttTopicFilter topicFilter = new MqttTopicFilterBuilder()
                .WithTopic(TopicName)// 主题 
                .WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce)
                .Build();
            await _mqttClient.SubscribeAsync(topicFilter);

            // 订阅主题过滤器2
            MqttTopicFilter topicFilter2 = new MqttTopicFilterBuilder()
                .WithTopic(TopicName2)// 主题
                .WithQualityOfServiceLevel(MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce)
                .Build();
            await _mqttClient.SubscribeAsync(topicFilter2);

        }

        static void Client_ApplicationMessageReceived(MqttApplicationMessageReceivedEventArgs e)
        {
            if (e.ApplicationMessage == null)
                return;
            if (e.ApplicationMessage.Topic == TopicName)
            {
                Mqtt1.Client_ApplicationMessageReceived(e);
            }
            else
            {
                Mqtt2.Client_ApplicationMessageReceived(e);
            }
        }


    }



}