From eccf6f140617d9c3098463e9510b72a9ce121a11 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E5=8D=9A?= Date: Fri, 1 Nov 2024 10:04:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E5=88=A0=E9=99=A4=E8=BF=87?= =?UTF-8?q?=E6=9C=9F=E8=AE=BF=E5=AE=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/job/task/PersonProcessTask.java | 23 ++++++++++++------- 1 file changed, 15 insertions(+), 8 deletions(-) diff --git a/shapelight-admin/src/main/java/net/shapelight/modules/job/task/PersonProcessTask.java b/shapelight-admin/src/main/java/net/shapelight/modules/job/task/PersonProcessTask.java index 93fb643..311fe2e 100644 --- a/shapelight-admin/src/main/java/net/shapelight/modules/job/task/PersonProcessTask.java +++ b/shapelight-admin/src/main/java/net/shapelight/modules/job/task/PersonProcessTask.java @@ -3,8 +3,10 @@ package net.shapelight.modules.job.task; import lombok.Data; +import lombok.extern.slf4j.Slf4j; import net.shapelight.common.utils.Constant; import net.shapelight.common.utils.DateUtils; +import net.shapelight.modules.face.util.UserRamGroup; import net.shapelight.modules.nettyapi.service.ServerApiService; import net.shapelight.modules.sys.entity.SysDbBakEntity; import net.shapelight.modules.sys.service.SysDbBakService; @@ -27,6 +29,7 @@ import java.util.List; */ @Component("personProcessTask") @Data +@Slf4j public class PersonProcessTask implements ITask { private Logger logger = LoggerFactory.getLogger(getClass()); @@ -39,22 +42,26 @@ public class PersonProcessTask implements ITask { @Override public void run(String params) { - logger.debug("personProcessTask定时任务正在执行，参数为：{}", params); + logger.debug("personProcessTask定时任务正在执行................................."); //1. 遍历人员表，找出所有过期的访客并设置为过期不可用 List guestList = tenPersonService.getAllExpireGuest(); for (TenPersonEntity guest : guestList) { guest.setStatus(Constant.PESON_SUATUS_GUEST_DATE_OUT); //修改人员表 tenPersonService.updateStatusById(guest); + //特征保存到内存 + UserRamGroup.removeUser(guest.getPersonId()+"",guest.getCellId()+""); +// UserRamCache.removeUser(guest.getPersonId()+""); + log.debug("内存删除人员:"+guest.getPersonId()+" 姓名："+guest.getName()); //修改同步表 - List syncEntityList = tenPersonSyncService.findByPersonId(guest.getPersonId(),guest.getTenantId()); - for(TenPersonSyncEntity syncEntity: syncEntityList){ - syncEntity.setState(Constant.PERSON_SYNC_DELETE); - tenPersonSyncService.updateById(syncEntity); - } +// List syncEntityList = tenPersonSyncService.findByPersonId(guest.getPersonId(),guest.getTenantId()); +// for(TenPersonSyncEntity syncEntity: syncEntityList){ +// syncEntity.setState(Constant.PERSON_SYNC_DELETE); +// tenPersonSyncService.updateById(syncEntity); +// } } //断开说有设备 - serverApiService.closeAll(); - logger.debug("personProcessTask定时任务执行完毕"); +// serverApiService.closeAll(); + logger.debug("personProcessTask定时任务执行完毕...................."); } }