diff --git a/stwzhj-modules/wzhj-data2es/src/main/java/org/dromara/data2es/schedule/RedisOnlineUserSchedule.java b/stwzhj-modules/wzhj-data2es/src/main/java/org/dromara/data2es/schedule/RedisOnlineUserSchedule.java index 22df8593..87786d56 100644 --- a/stwzhj-modules/wzhj-data2es/src/main/java/org/dromara/data2es/schedule/RedisOnlineUserSchedule.java +++ b/stwzhj-modules/wzhj-data2es/src/main/java/org/dromara/data2es/schedule/RedisOnlineUserSchedule.java @@ -4,6 +4,7 @@ import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; import cn.hutool.json.JSONObject; +import lombok.extern.slf4j.Slf4j; import org.dromara.common.redis.utils.RedisUtils; import org.dromara.data2es.domain.EsGpsInfoVO2; import org.dromara.data2es.service.IGpsService; @@ -22,13 +23,14 @@ import java.util.List; * @date 2021-05-18 18:23 */ +@Slf4j @Configuration public class RedisOnlineUserSchedule { @Autowired IGpsService gpsService; - @Scheduled(cron = "0 0/20 * * * ?") + @Scheduled(cron = "0 0/10 * * * ?") public void redisTimeOutRemove(){ List jlist = RedisUtils.searchAndGetKeysValues("online_users:*"); List gpsInfoVO2s = new ArrayList<>(); @@ -48,6 +50,7 @@ public class RedisOnlineUserSchedule { } } if (gpsInfoVO2s.size() > 0){ + log.error("下线设备集合={}",gpsInfoVO2s.toString()); gpsService.updateOnlineStatusBatch(gpsInfoVO2s); } }