package com.doumee.service.impl; 
 | 
  
 | 
import com.doumee.core.constants.Constants; 
 | 
import com.doumee.core.mqtt.config.MqttConfig; 
 | 
import com.doumee.core.mqtt.service.MqttSubService; 
 | 
import com.doumee.core.mqtt.service.MqttToolService; 
 | 
import com.doumee.dao.business.MqttLogMapper; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.stereotype.Service; 
 | 
  
 | 
import javax.annotation.PostConstruct; 
 | 
  
 | 
/** 
 | 
 *  与硬件对接服务 
 | 
 * @author 江蹄蹄 
 | 
 * @date 2023/10/09 18:06 
 | 
 */ 
 | 
@Service 
 | 
public class MqttSubServiceImpl implements MqttSubService { 
 | 
    @Autowired 
 | 
    private MqttToolService mqttToolService; 
 | 
    @Autowired 
 | 
    private MqttLogMapper mqttLogMapper; 
 | 
    @Autowired 
 | 
    private MqttConfig mqttConfig; 
 | 
    @Override 
 | 
    @PostConstruct 
 | 
    public void startSubcribe() { 
 | 
        mqttToolService.subscribe( 
 | 
                new String[]{ Constants.MqttTopic.sub_lockInfo, 
 | 
                              Constants.MqttTopic.sub_siteInfo, 
 | 
                              Constants.MqttTopic.sub_adminCard, 
 | 
                              Constants.MqttTopic.sub_closeLock, 
 | 
                              Constants.MqttTopic.sub_health}); 
 | 
    } 
 | 
} 
 |