|
|
@@ -184,7 +184,7 @@ public class MqttMsgService {
|
|
|
//计算当前和最近之间时间，若超过1秒，删除之前的存储的，重新计数存储当前的
|
|
|
String lastContent = (String)redisUtil.hget(RedisKeyConstant.PEOPLEEVENT_ACTIVE_INFO,lastIndex + "@" + careDevice.getDevCode() + "_" + tid );
|
|
|
long duration = (date.getTime() - Long.parseLong(lastContent.split("_")[0]));
|
|
|
- if (duration > 1000) { //超过1秒,删除之前的存储的,从头开始
|
|
|
+ if (duration > 3000) { //超过1秒,删除之前的存储的,从头开始
|
|
|
delBeforeContent(lastIndex,careDevice.getDevCode(),tid);
|
|
|
redisUtil.hset(RedisKeyConstant.PEOPLEEVENT_ACTIVE_INFO, 1 + "@" + careDevice.getDevCode() + "_" + tid , System.currentTimeMillis() + "_" + x + "_" + y, RedisKeyConstant.PEOPLEEVENT_ACTIVE_INFO_TIME);
|
|
|
redisUtil.hset(RedisKeyConstant.PEOPLEEVENT_ACTIVE_INFO_LAST_INDEX, careDevice.getDevCode() + "_" + tid , 1 , RedisKeyConstant.PEOPLEEVENT_ACTIVE_INFO_ACTIVE_LAST_INDEX_TIME);
|
suntianwu