iden_server/src/main/java/com/care/bms/mqtt/MqttInit.java

package com.care.bms.mqtt;




import com.care.bms.service.BmsEventOrderService;

import com.care.common.service.*;
import com.care.common.util.CommonConfUtil;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.core.annotation.Order;



@Order(1)
public class MqttInit implements CommandLineRunner {

    private static final Logger logger = LogManager.getLogger(MqttInit.class);

    @Autowired
    private CareDeviceService careDeviceService;
    @Autowired
    private BmsEventOrderService bmsEventOrderService;
    @Autowired
    private CareEventOrderService careEventOrderService;
    @Autowired
    private CareHouseService careHouseService;
    @Autowired
    private CareOrganizationService careOrganizationService;
    @Autowired
    private CareStationService careStationService;
    @Autowired
    private CareMqttMsgService careMqttMsgService;

    @Override
    public void run(String... args) throws Exception {
        String mqttOn = CommonConfUtil.getConf("mqtt.on");
        if ("1".equals(mqttOn)){
            logger.info("初始化MQTTstart ...........................");
            MqttTool.init(careDeviceService,bmsEventOrderService,careEventOrderService,careHouseService,careOrganizationService,careStationService,careMqttMsgService);
            logger.info("初始化MQTTend ...........................");
        }
    }

}