package ;
import ;
import ;
import 44j;
import ;
import ;
import ;
@Component
@Slf4j
public class MessageReceiver {
WebSocketServer webSocketServer = new WebSocketServer();
/**Battery*/
public void receiveMessage(String message){
("data：{}"+message);
try {
(message);
} catch (Exception e) {
("消息发送失败！IO异常"+e);
();
}
//return message;
}
/**CH4*/
public void receiveMessage2(String message){
("CH4："+message);
//CH4.add(message);
List list = new ArrayList();
list.add("CH4");
list.add(("\\\\",""));
String json = (list);
("CH4 Data is loading out");
try {
(json);
} catch (Exception e) {
("消息发送失败！IO异常"+e);
();
}
//return message;
}
/**Humiture*/
public void receiveMessage3(String message){
("Humiture："+message);
//Humiture.add(message);
List list = new ArrayList();
list.add("Humiture");
list.add(("\\\\",""));
String json = (list);
("Humiture Data is loading out");
try {
(json);
} catch (Exception e) {
("消息发送失败！IO异常"+e);
();
}
//return message;
}
/**Location*/
public void receiveMessage4(String message){
("Location："+message);
//Location.add(message);
List list = new ArrayList();
list.add("Location");
list.add(("\\\\",""));
String json = (list);
("Location Data is loading out");
try {
(json);
} catch (Exception e) {
("消息发送失败！IO异常"+e);
();
}
//return message;
}
/**Pressure*/
public void receiveMessage5(String message){
("Pressure："+message);
//Pressure.add(message);
List list = new ArrayList();
list.add("Pressure");
list.add(("\\\\",""));
String json = (list);
("Pressure Data is loading out");
try {
(json);
} catch (Exception e) {
("消息发送失败！IO异常"+e);
();
}
//return message;
}
/**SignalIntensity*/
public void receiveMessage6(String message){
("SignalIntensity："+message);
//SignalIntensity.add(message);
List list = new ArrayList();
list.add("SignalIntensity");
list.add(("\\\\",""));
String json = (list);
("SignalIntensity Data is loading out");
try {
(json);
} catch (Exception e) {
("消息发送失败！IO异常"+e);
();
}
//return message;
}
/**Warn*/
public void receiveMessage7(String message){
("Warn："+message);
//Warn.add(message);
List list = new ArrayList();
list.add("Warn");
list.add(("\\\\",""));
String json = (list);
("Warn Data is loading out");
try {
(json);
} catch (Exception e) {
("消息发送失败！IO异常"+e);
();
}
//return message;
}
public void receiveMessageTimeOut(String message){
if(("accessToken")){
// 1小时超时
// 调用刷新accessToken接口
("accessToken超时");
try {
// ();
} catch (Exception e) {
("accessToken超时:刷新accessToken失败！");
();
}
}
if( ("refreshToken")){
// 1天超时
// 调用刷新鉴权接口获取 accessToken 和 refreshToken
("refreshToken超时");
try {
// ();
} catch (Exception e) {
("refreshToken超时:重新获取accessToken失败！");
();
}
}
}
}