Commit a8371b2b authored by litengwei's avatar litengwei

任务 17602

parent d79b844d
......@@ -641,13 +641,13 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
ext.put("name", equipmentSpecificIndex.getEquipmentSpecificName());
ext.put("time", new SimpleDateFormat(DateUtils.DATE_TIME_PATTERN).format(new Date()));
model.setExtras(ext);
try {
Token token = remoteSecurityService.getServerToken();
systemctlFeign.create(token.getAppKey(), token.getProduct(), token.getToke(), model);
} catch (Exception e) {
log.error("调用平台出错!");
}
log.info(String.format("调用平台消息服务成功:%s", JSON.toJSONString(model)));
// try {
// Token token = remoteSecurityService.getServerToken();
// systemctlFeign.create(token.getAppKey(), token.getProduct(), token.getToke(), model);
// } catch (Exception e) {
// log.error("调用平台出错!");
// }
// log.info(String.format("调用平台消息服务成功:%s", JSON.toJSONString(model)));
alarmFlag = true;
messageBody.put("messageBody", equipmentSpecificIndex.getEquipmentSpecificName() + "-" + body);
}
......@@ -714,9 +714,9 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
ext.put("name", (String) map.get("name"));
ext.put("time", new SimpleDateFormat(DateUtils.DATE_TIME_PATTERN).format(new Date()));
model.setExtras(ext);
Token token = remoteSecurityService.getServerToken();
systemctlFeign.create(token.getAppKey(), token.getProduct(), token.getToke(), model);
log.info(String.format("调用平台消息服务成功:%s", JSON.toJSONString(model)));
// Token token = remoteSecurityService.getServerToken();
// systemctlFeign.create(token.getAppKey(), token.getProduct(), token.getToke(), model);
// log.info(String.format("调用平台消息服务成功:%s", JSON.toJSONString(model)));
alarmFlag = true;
messageBody.put("messageBody", map.get("name") + "-" + body);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment