package com.dingzhuo.energy.project.conglomeratepush.mqtt;
|
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONException;
|
import com.alibaba.fastjson.JSONObject;
|
import com.dingzhuo.energy.common.core.lang.UUID;
|
import com.dingzhuo.energy.project.gateway.domain.GatewayHbtLog;
|
import com.dingzhuo.energy.project.gateway.domain.GatewaySetting;
|
import com.dingzhuo.energy.project.gateway.service.IGatewayHbtLogService;
|
import com.dingzhuo.energy.project.gateway.service.IGatewaySettingService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
|
import org.eclipse.paho.client.mqttv3.MqttCallback;
|
import org.eclipse.paho.client.mqttv3.MqttMessage;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.nio.charset.StandardCharsets;
|
import java.util.Date;
|
import java.util.Iterator;
|
|
/**
|
* MQTT回调函数
|
*MqttClientCallback 回调函数类中可能不能用 @Autowired 注入的， 解决办法 SpringContextHolder 类引入
|
* @author zhw
|
* @since 2022/04/05
|
*/
|
@Slf4j
|
@Component
|
public class InitCallback implements MqttCallback {
|
|
@Autowired
|
private IGatewayHbtLogService gatewayHbtLogService;
|
|
@Autowired
|
private IGatewaySettingService gatewaySettingService;
|
|
/**
|
* MQTT 断开连接会执行此方法
|
*/
|
@Override
|
public void connectionLost(Throwable cause)
|
{
|
log.error(cause.getMessage(), cause);
|
}
|
|
/**
|
* publish发布成功后会执行到这里
|
*/
|
@Override
|
public void deliveryComplete(IMqttDeliveryToken token) {
|
//发布完成后 记录日志信息 并断开连接
|
}
|
|
/**
|
* subscribe订阅后得到的消息会执行到这里
|
*/
|
@Override
|
public void messageArrived(String topic, MqttMessage message) {
|
String result = new String(message.getPayload(), StandardCharsets.UTF_8);
|
try {
|
// JSONObject jsonObject = JSON.parseObject(result);
|
// Date hbtTime = jsonObject.getDate("ts");
|
// Iterator<String> keys = jsonObject.getJSONObject("d").keySet().iterator();
|
// if(keys.hasNext())
|
// {
|
// String key = keys.next();
|
// //更新实时状态
|
// GatewaySetting gatewaySetting = new GatewaySetting();
|
// gatewaySetting.setGatewayNum(key);
|
// gatewaySetting.setHbtTime(hbtTime);
|
// gatewaySettingService.updateGatewaySettingByNum(gatewaySetting);
|
//
|
// //记录日志表
|
// GatewayHbtLog gatewayHbtLog = new GatewayHbtLog();
|
// gatewayHbtLog.setId(UUID.fastUUID().toString());
|
// gatewayHbtLog.setGatewayNo(key);
|
// gatewayHbtLog.setHbtTime(hbtTime);
|
// gatewayHbtLog.setContent(result);
|
// gatewayHbtLogService.insertGatewayHbtLog(gatewayHbtLog);
|
// }
|
|
} catch (JSONException e) {
|
log.error("JSON Format Parsing Exception : {}", result);
|
}
|
}
|
}
|
