package com.doumee.service.business.impl;

import com.doumee.core.constants.Constants;
import com.doumee.core.mqtt.service.MqttPushCallback;
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;
    }

}