修改资源清除逻辑

src/main/java/com/fdkankan/ucenter/service/impl/SceneCleanServiceImpl.java

@@ -63,6 +63,7 @@ public class SceneCleanServiceImpl extends ServiceImpl<ISceneCleanMapper, SceneC
         List<SceneBean> sceneProEntityList = selectNeadCleanScene(0,sceneCleanSize, time);
         //如果查出来的场景集合是空，证明已经没有场景资源需要删除，则需要把查询下表删除，等待下一次定时任务执行
         if (CollectionUtils.isEmpty(sceneProEntityList)) {
+            log.info("未查询到过期场景，退出任务！");
             return;
         }
         List<String> numList = sceneProEntityList.parallelStream().map(SceneBean::getNum).collect(Collectors.toList());
@@ -96,16 +97,18 @@ public class SceneCleanServiceImpl extends ServiceImpl<ISceneCleanMapper, SceneC
 
         //写库
         if(!CollectionUtils.isEmpty(insertList)){
+            insertList.parallelStream().forEach(insert -> log.info("清除资源目录:{}", insert.getNum()));
             this.saveBatch(insertList);
         }
         if(!CollectionUtils.isEmpty(updateSet)){
+            updateSet.parallelStream().forEach(num -> log.info("清除更新资源目录:{}", num));
             this.update(new LambdaUpdateWrapper<SceneClean>()
                     .set(SceneClean::getState, CommonStatus.YES.code())
                     .set(SceneClean::getUpdateTime,new Date())
                     .in(SceneClean::getNum, updateSet));
         }
 
-        redisLockUtil.unlock(RedisLockKey.LOCK_SCENE_CLEAN);
+        redisLockUtil.unlockLua(RedisLockKey.LOCK_SCENE_CLEAN);
     }
 
     private List<SceneClean> findAllByDateSource(String dataSource) {