Commit 7a6ba0d8 authored by 赵啸非's avatar 赵啸非

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

parent 274581b3
...@@ -26,7 +26,7 @@ import org.springframework.stereotype.Service; ...@@ -26,7 +26,7 @@ import org.springframework.stereotype.Service;
* @date: 2023/5/9 13:44 * @date: 2023/5/9 13:44
*/ */
@Slf4j @Slf4j
@Service("CreateAppointPersonToHikBlackPlanByDay") //@Service("CreateAppointPersonToHikBlackPlanByDay")
public class CreateAppointPersonToHikBlackPlanByDayTaskImpl implements ITaskExcuteService { public class CreateAppointPersonToHikBlackPlanByDayTaskImpl implements ITaskExcuteService {
@Autowired @Autowired
......
...@@ -59,7 +59,7 @@ public class RealTimePeopleStatTaskImpl implements ITaskExcuteService { ...@@ -59,7 +59,7 @@ public class RealTimePeopleStatTaskImpl implements ITaskExcuteService {
realtimeDataflowQuery.setCreateTimeEnd(endTimeStr); realtimeDataflowQuery.setCreateTimeEnd(endTimeStr);
List<RealtimeDataflowEntity> realtimeDataflowEntities = realtimeDataflowService.find(realtimeDataflowQuery, null); List<RealtimeDataflowEntity> realtimeDataflowEntities = realtimeDataflowService.find(realtimeDataflowQuery, null);
log.info("定时删除人流数据,endTimeStr:{},size:{}", endTimeStr, realtimeDataflowEntities.size()); log.info("定时删除人流数据,endTimeStr:{},size:{}", endTimeStr, realtimeDataflowEntities.size());
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); realtimeDataflowStatService.remove(delIds, null);
......
...@@ -337,9 +337,9 @@ public class FacePlanServiceImpl extends AbstractCRUDServiceImpl<FacePlanDao, Fa ...@@ -337,9 +337,9 @@ public class FacePlanServiceImpl extends AbstractCRUDServiceImpl<FacePlanDao, Fa
//创建人脸tohik //创建人脸tohik
for (AppointmentPersonEntity appointmentPersonEntity : appointmentPersonEntities) { for (AppointmentPersonEntity appointmentPersonEntity : appointmentPersonEntities) {
PersonEntity personEntity = personService.getCache(appointmentPersonEntity.getPersonId().toString()); PersonEntity personEntity = personService.getCache(appointmentPersonEntity.getIdCard());
if (ObjectUtils.isEmpty(personEntity)) { if (ObjectUtils.isEmpty(personEntity)) {
log.info("注册人员不能为空,persionId:{}", appointmentPersonEntity.getPersonId()); log.info("注册人员不能为空,idcard:{}", appointmentPersonEntity.getIdCard());
continue; continue;
} }
//查询图片并转成base64 //查询图片并转成base64
......
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