|
|
@@ -1,17 +1,20 @@
|
|
|
package cn.tr.module.sys.storage.job;
|
|
|
|
|
|
import cn.hutool.core.collection.CollectionUtil;
|
|
|
+import cn.tr.core.annotation.TenantIgnore;
|
|
|
import cn.tr.core.utils.JsonUtils;
|
|
|
import cn.tr.module.api.sys.storage.SysStorageApi;
|
|
|
import cn.tr.module.sys.storage.po.SysStorageRecordPO;
|
|
|
import cn.tr.module.sys.storage.repository.SysStorageRecordRepository;
|
|
|
import cn.tr.module.sys.storage.service.IStorageFileService;
|
|
|
import cn.tr.module.sys.storage.service.ISysStorageRecordService;
|
|
|
+import cn.tr.plugin.biz.tenant.utils.TenantUtils;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import lombok.AllArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
+import javax.annotation.PostConstruct;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
import java.util.stream.Collectors;
|
|
|
@@ -29,6 +32,8 @@ public class StorageJob {
|
|
|
private final SysStorageRecordRepository sysStorageRecordRepository;
|
|
|
|
|
|
private final IStorageFileService storageFileService;
|
|
|
+
|
|
|
+ @TenantIgnore
|
|
|
public void delExpireFile(){
|
|
|
Date now = new Date();
|
|
|
List<SysStorageRecordPO> expireStorageRecord = sysStorageRecordRepository.selectList(new LambdaQueryWrapper<SysStorageRecordPO>()
|