package com.xiaopeng.automaticPilot.util;
|
|
import com.xiaopeng.api.vo.automaticPilot.VehiclePosition;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.data.mongodb.core.MongoTemplate;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
|
@Slf4j
|
@Component
|
public class TaskUtil {
|
|
@Resource
|
private MongoTemplate mongoTemplate;
|
|
//删除过期的车辆定位数据
|
@Scheduled(cron = "0/30 * * * * ?")
|
public void task() {
|
log.info("执行删除无效的车辆定位数据");
|
mongoTemplate.remove(Query.query(Criteria.where("addTime").isNull()), VehiclePosition.class);
|
mongoTemplate.remove(Query.query(Criteria.where("addTime").lte(LocalDateTime.now().minusMinutes(1))), VehiclePosition.class);
|
}
|
}
|
