From 52d0c4bc36d555b55b3016e92da57cd2e916993c Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Mon, 7 Apr 2025 09:51:10 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B8=85=E7=90=86=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/ycwl/basic/task/FaceCleaner.java | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/ycwl/basic/task/FaceCleaner.java b/src/main/java/com/ycwl/basic/task/FaceCleaner.java
index 07ef7dd..fc92a00 100644
--- a/src/main/java/com/ycwl/basic/task/FaceCleaner.java
+++ b/src/main/java/com/ycwl/basic/task/FaceCleaner.java
@@ -1,7 +1,6 @@
 package com.ycwl.basic.task;
 
 import cn.hutool.core.date.DateUtil;
-import com.alibaba.fastjson.JSONObject;
 import com.ycwl.basic.constant.StorageConstant;
 import com.ycwl.basic.facebody.adapter.IFaceBodyAdapter;
 import com.ycwl.basic.mapper.FaceMapper;
@@ -23,7 +22,6 @@ import com.ycwl.basic.model.pc.video.req.VideoReqQuery;
 import com.ycwl.basic.model.pc.video.resp.VideoRespVO;
 import com.ycwl.basic.repository.ScenicRepository;
 import com.ycwl.basic.service.pc.ScenicService;
-import com.ycwl.basic.service.task.TaskFaceService;
 import com.ycwl.basic.storage.StorageFactory;
 import com.ycwl.basic.storage.adapters.IStorageAdapter;
 import com.ycwl.basic.storage.entity.StorageFileObject;
@@ -36,7 +34,6 @@ import org.springframework.stereotype.Component;
 
 import java.util.Date;
 import java.util.List;
-import java.util.Map;
 import java.util.Objects;
 
 import static com.ycwl.basic.constant.FaceConstant.USER_FACE_DB_NAME;
@@ -63,10 +60,10 @@ public class FaceCleaner {
     private ScenicService scenicService;
 
     @Scheduled(cron = "0 0 1 * * ?")
-    public void clean(){
+    public void deleteExpireSample(){
         ScenicReqQuery scenicQuery = new ScenicReqQuery();
         List<ScenicRespVO> scenicList = scenicMapper.list(scenicQuery);
-        scenicList.forEach(scenic -> {
+        scenicList.parallelStream().forEach(scenic -> {
             log.info("当前景区{}，开始删除人脸样本", scenic.getId());
             IFaceBodyAdapter adapter = scenicService.getScenicFaceBodyAdapter(scenic.getId());
             ScenicConfigEntity scenicConfig = scenicRepository.getScenicConfig(scenic.getId());