修復bug

jiangping

2023-10-09 67b65fae0919158f232f3d5ccf57be03ab673536

修復bug

 server/services/src/main/java/com/doumee/core/mqtt/config/MqttClientInit.java

@@ -11,8 +11,6 @@

public class MqttClientInit {
        static MqttClient client;
        private String userName = "doumee";
        private String passWord = "doumee@168";

        public static synchronized MqttClient getInstance(MqttConfig config,MqttPushCallback callBack){
            if(client !=null){
@@ -41,7 +39,6 @@
                //遗嘱
                options.setWill(topic, "close".getBytes(), 1, true);
                client.connect(options);

            } catch (Exception e) {
                e.printStackTrace();
            }

 server/services/src/main/java/com/doumee/service/business/DeviceService.java

@@ -15,6 +15,7 @@
     * @return String
     */
    boolean openLock(Locks locks);

    void startSubcribe();

}

 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,10 +15,8 @@
 */
@Service
public class DeviceServiceImpl implements DeviceService {

    @Autowired
    private MqttToolService mqttToolService;

    @Override
    @PostConstruct
    public void startSubcribe() {
@@ -31,5 +27,4 @@
        mqttToolService.pubMessage(locks.getName(), Constants.MqttTopic.openLock);
        return true;
    }

}