Commit a88388f4 authored by zhoushiguang's avatar zhoushiguang

Merge remote-tracking branch 'origin/master'

parents 756a98f9 1dd57693
...@@ -24,15 +24,15 @@ public class LaneSnapShotDataDelTask { ...@@ -24,15 +24,15 @@ public class LaneSnapShotDataDelTask {
@Resource @Resource
private RestHighLevelClient client; private RestHighLevelClient client;
@Scheduled(cron = "0 0 0 * * ?") @Scheduled(fixedRate = 1000 * 3600)
public void delLast24HourData() throws Exception { public void delLast24HourData() throws Exception {
try { try {
DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest(Constants.LANE_SNAPSHOT_DATA_ES_INDEX); DeleteByQueryRequest deleteByQueryRequest = new DeleteByQueryRequest(Constants.LANE_SNAPSHOT_DATA_ES_INDEX);
Date date = new Date(); Date date = new Date();
long currentTime = date.getTime() / 1000; long currentTime = date.getTime() / 1000;
long lastDay = currentTime - 86400L; long lastDay = currentTime - 86400L;
RangeQueryBuilder gte = QueryBuilders.rangeQuery("timeStamp").lte(lastDay); RangeQueryBuilder lte = QueryBuilders.rangeQuery("timeStamp").lte(lastDay);
deleteByQueryRequest.setQuery(gte); deleteByQueryRequest.setQuery(lte);
client.deleteByQuery(deleteByQueryRequest, RequestOptions.DEFAULT); client.deleteByQuery(deleteByQueryRequest, RequestOptions.DEFAULT);
} catch (Exception e) { } catch (Exception e) {
log.error("定时删除elastic前一天数据失败", e); log.error("定时删除elastic前一天数据失败", e);
......
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