package com.doumee.service.business.impl.mqtt;

import com.alibaba.fastjson.JSONObject;
import com.doumee.mqtt.config.MqttConfig;
import com.doumee.mqtt.service.MqttBizService;
import com.doumee.mqtt.service.MqttToolService;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
 *  与硬件对接服务
 * @author 江蹄蹄
 * @date 2023/10/09 18:06
 */
@Service
@Slf4j
public class MqttSubServiceImpl implements MqttBizService {
    @Autowired
    private MqttPushCallback callBack ;
    @Override
    public MqttClient subscribe(MqttClient client,MqttConfig config,String[] topics){
        log.error("mqtt订阅开始========开始"+ JSONObject.toJSONString(config));
        client = MqttToolService.subscribe(client,config, topics,callBack);
        log.error("mqtt订阅开始========结束"+ JSONObject.toJSONString(config));
        return client;
    }
    @Override
    public MqttClient unsubscribe(MqttClient client,MqttConfig config,String[] topics){
        log.error("mqtt订阅开始========开始"+ JSONObject.toJSONString(config));
        client = MqttToolService.unsubscribe(client,config, topics,callBack);
        log.error("mqtt订阅开始========结束"+ JSONObject.toJSONString(config));
        return client;
    }

    @Override
    public MqttClient publish(MqttClient client,MqttConfig config, String topic, String param){
        log.error("mqtt发布消息========开始"+ JSONObject.toJSONString(config)+"\n"+param);
        client = MqttToolService.pubMessage(client,config,param,topic,callBack);
        log.error("mqtt发布消息========结束"+ JSONObject.toJSONString(config));
        return client;
    }
}