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_closeLock,Constants.MqttTopic.sub_health}); } }