Commit dd585911 authored by 赵啸非's avatar 赵啸非

添加定时删除七天前的人流数据

parent fb0d4158
...@@ -62,7 +62,7 @@ public class RealTimePeopleStatTaskImpl implements ITaskExcuteService { ...@@ -62,7 +62,7 @@ public class RealTimePeopleStatTaskImpl implements ITaskExcuteService {
if (!ObjectUtils.isEmpty(realtimeDataflowEntities)) { if (!ObjectUtils.isEmpty(realtimeDataflowEntities)) {
log.info("需要删除的实时监控数据量:{}", realtimeDataflowEntities.size()); log.info("需要删除的实时监控数据量:{}", realtimeDataflowEntities.size());
Long[] delIds = realtimeDataflowEntities.stream().map(i -> i.getId()).toArray(Long[]::new); Long[] delIds = realtimeDataflowEntities.stream().map(i -> i.getId()).toArray(Long[]::new);
realtimeDataflowStatService.remove(delIds, null); realtimeDataflowService.remove(delIds, null);
for (RealtimeDataflowEntity entity : realtimeDataflowEntities) { for (RealtimeDataflowEntity entity : realtimeDataflowEntities) {
if (ObjectUtils.isEmpty(entity.getPicture())) continue; if (ObjectUtils.isEmpty(entity.getPicture())) continue;
uploadService.deleteFile(entity.getPicture()); uploadService.deleteFile(entity.getPicture());
......
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