package com.doumee.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.doumee.core.constants.Constants;
|
import com.doumee.core.mqtt.config.MqttConfig;
|
import com.doumee.core.mqtt.service.MqttToolService;
|
import com.doumee.dao.business.MqttLogMapper;
|
import com.doumee.dao.business.model.Locks;
|
import com.doumee.dao.business.model.MqttLog;
|
import com.doumee.service.MqttSubService;
|
import com.doumee.service.business.DeviceService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.PostConstruct;
|
import java.util.Date;
|
|
/**
|
* 与硬件对接服务
|
* @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});
|
}
|
}
|
