package com.doumee.service.business.impl;
|
|
import com.doumee.core.constants.Constants;
|
import com.doumee.core.mqtt.service.MqttToolService;
|
import com.doumee.dao.business.model.Locks;
|
import com.doumee.service.business.DeviceService;
|
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 DeviceServiceImpl implements DeviceService {
|
@Autowired
|
private MqttToolService mqttToolService;
|
@Override
|
@PostConstruct
|
public void startSubcribe() {
|
mqttToolService.subscribe(new String[]{ Constants.MqttTopic.openLock, Constants.MqttTopic.closeLock});
|
}
|
@Override
|
public boolean openLock(Locks locks) {
|
mqttToolService.pubMessage(locks.getName(), Constants.MqttTopic.openLock);
|
return true;
|
}
|
}
|
