#pgsql 运营监控

jiaosong

2023-10-10 cac8f41a47915de2a30a8784fe1fc35c364e86df

 server/services/src/main/java/com/doumee/service/business/impl/DeviceServiceImpl.java

@@ -1,13 +1,11 @@
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;

/**
@@ -17,19 +15,16 @@
 */
@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 String openLock(Locks locks) {
    public boolean openLock(Locks locks) {
        mqttToolService.pubMessage(locks.getName(), Constants.MqttTopic.openLock);
        return null;
        return true;
    }

}