|
@@ -370,9 +370,9 @@ public class MqttConfig {
|
|
|
JSONObject jsonObject = FireLaborUtil.getFireStatus(messageStr);
|
|
JSONObject jsonObject = FireLaborUtil.getFireStatus(messageStr);
|
|
|
logger.info("灭火主机状态:" + jsonObject + "采集器编号" + receivedTopic + ",响应时间key:" + CacheConstants.FIRE_DEVICE_RESPOND_TIME + receivedTopic);
|
|
logger.info("灭火主机状态:" + jsonObject + "采集器编号" + receivedTopic + ",响应时间key:" + CacheConstants.FIRE_DEVICE_RESPOND_TIME + receivedTopic);
|
|
|
//redis存值 采集器编号:主机状态json
|
|
//redis存值 采集器编号:主机状态json
|
|
|
- redisService.setCacheObject(receivedTopic, jsonObject, 1L, TimeUnit.MINUTES);
|
|
|
|
|
|
|
+ redisService.setCacheObject(receivedTopic, jsonObject, 5L, TimeUnit.MINUTES);
|
|
|
//redis存值 灭火主机响应时间
|
|
//redis存值 灭火主机响应时间
|
|
|
- redisService.setCacheObject(CacheConstants.FIRE_DEVICE_RESPOND_TIME + receivedTopic, System.currentTimeMillis(), 1L, TimeUnit.MINUTES);
|
|
|
|
|
|
|
+ redisService.setCacheObject(CacheConstants.FIRE_DEVICE_RESPOND_TIME + receivedTopic, System.currentTimeMillis(), 5L, TimeUnit.MINUTES);
|
|
|
logger.info("灭火消息,redis存值完毕========");
|
|
logger.info("灭火消息,redis存值完毕========");
|
|
|
|
|
|
|
|
Integer fireNumber = Integer.valueOf(jsonObject.get("fireNumber").toString());
|
|
Integer fireNumber = Integer.valueOf(jsonObject.get("fireNumber").toString());
|