package com.sandu.ximon.admin.localMQTT.client;

import com.sandu.ximon.admin.localMQTT.config.MqttConfig;
import com.sandu.ximon.admin.localMQTT.model.MqttClientVO;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.List;

/**
 * @author van
 * @version 1.0
 * msg：
 * @date 2022/11/29 13:46
 */
@Slf4j
@EnableScheduling
@Component
public class KeepEMQXClient {

    @Autowired
    private MqttConfig mqttConfig;

    @Resource
    private MqttClientManager mqttClientManager;

    @Scheduled(cron = "*/30 * * * * * ")
    public void keepClient()  {

        List<MqttClientVO> mqttClientList = mqttConfig.getClientList();
        for (MqttClientVO mqttClientVO : mqttClientList) {
            //创建客户端，客户端ID：demo，回调类跟客户端ID一致
            MqttClient mqttClient = MqttClientManager.getInstance().getMqttClientById(mqttClientVO.getClientId());

            if (null == mqttClient) {
                log.error("Not exist mqttClient where it's clientId is {}", mqttClientVO.getClientId());
                mqttClientManager.createMqttClient(mqttClientVO.getClientId(), mqttClientVO.getSubscribeTopic(), mqttClientVO.getUserName(), mqttClientVO.getPassword());
                System.out.println(mqttClient.getClientId() + "重新创建完成");

            }
            else {
                try {
                    mqttClient.publish("v1/devices/keepAlive", new MqttMessage() );
                } catch (MqttException e) {
                    log.error("mqttClient.getClientId()..发送消息失败...........");
                    mqttClientManager.createMqttClient(mqttClientVO.getClientId(), mqttClientVO.getSubscribeTopic(), mqttClientVO.getUserName(), mqttClientVO.getPassword());
                    log.error("创建."+mqttClient.getClientId()+".成功...........");
                }
            }
        }}


}