package com.jepsoninfo.config;

import com.jepsoninfo.dao.CommonConfigDao;
import com.jepsoninfo.entity.CommonConfig;
import com.jepsoninfo.service.HardService;
import com.jepsoninfo.service.ThreadDeviceCmdMqtt;
import com.jepsoninfo.service.ThreadRecvCmdMqtt;
import com.jepsoninfo.util.ConstUtil;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.annotation.Resource;

@Configuration
public class MqttConfig {
    @Resource
    private HardService hardService;
    @Resource
    private CommonConfigDao commonConfigDao;

    @Bean
    public void initMqtt(){
        CommonConfig config;

        //get config info
        config = commonConfigDao.selectByName("mqtt_broker");
        ConstUtil.MQTT_BROKER = config.getCnValue();

        config = commonConfigDao.selectByName("mqtt_topic_prefix");
        ConstUtil.MQTT_TOPIC = config.getCnValue();

        config = commonConfigDao.selectByName("mqtt_user_name");
        ConstUtil.MQTT_USER_NAME = config.getCnValue();

        config = commonConfigDao.selectByName("mqtt_password");
        ConstUtil.MQTT_PASSWORD = config.getCnValue();

        config = commonConfigDao.selectByName("mqtt_clientid");
        ConstUtil.MQTT_CLIENTID = config.getCnValue();

       config = commonConfigDao.selectByName("mqtt_device_broker");
       ConstUtil.MQTT_DEVICE_BROKER = config.getCnValue();

       config = commonConfigDao.selectByName("mqtt_device_topic_prefix");
       ConstUtil.MQTT_DEVICE_TOPIC = config.getCnValue();

       config = commonConfigDao.selectByName("mqtt_device_user_name");
       ConstUtil.MQTT_DEVICE_USER_NAME = config.getCnValue();

       config = commonConfigDao.selectByName("mqtt_device_password");
       ConstUtil.MQTT_DEVICE_PASSWORD = config.getCnValue();

       config = commonConfigDao.selectByName("mqtt_device_clientid");
       ConstUtil.MQTT_DEVICE_CLIENTID = config.getCnValue();

       config = commonConfigDao.selectByName("mqtt_device_type");
       ConstUtil.MQTT_DEVICE_TYPE = config.getCnValue();

        ThreadRecvCmdMqtt thread = new ThreadRecvCmdMqtt(hardService);
        thread.start();

       ThreadDeviceCmdMqtt devThread = new ThreadDeviceCmdMqtt(hardService);
       devThread.start();
    }
}