|
@@ -12,12 +12,15 @@ import org.springblade.core.mp.base.BaseServiceImpl;
|
|
import org.springblade.core.mp.support.Condition;
|
|
import org.springblade.core.mp.support.Condition;
|
|
import org.springblade.core.mp.support.Query;
|
|
import org.springblade.core.mp.support.Query;
|
|
import org.springblade.core.tool.utils.Func;
|
|
import org.springblade.core.tool.utils.Func;
|
|
|
|
+import org.springblade.resource.feign.NewIOSSClient;
|
|
import org.springblade.system.entity.DictBiz;
|
|
import org.springblade.system.entity.DictBiz;
|
|
import org.springblade.system.feign.IDictBizClient;
|
|
import org.springblade.system.feign.IDictBizClient;
|
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
|
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
|
+import java.util.concurrent.ExecutorService;
|
|
|
|
|
|
/**
|
|
/**
|
|
* 服务实现类
|
|
* 服务实现类
|
|
@@ -30,6 +33,9 @@ import java.util.*;
|
|
public class ArchiveFileServiceImpl extends BaseServiceImpl<ArchiveFileMapper, ArchiveFile> implements IArchiveFileService {
|
|
public class ArchiveFileServiceImpl extends BaseServiceImpl<ArchiveFileMapper, ArchiveFile> implements IArchiveFileService {
|
|
|
|
|
|
private final IDictBizClient dictBizClient;
|
|
private final IDictBizClient dictBizClient;
|
|
|
|
+ private final NewIOSSClient iossClient;
|
|
|
|
+
|
|
|
|
+ private ExecutorService executorService;
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public IPage<ArchiveFileVO> selectArchiveFilePage(ArchiveFileVO vo) {
|
|
public IPage<ArchiveFileVO> selectArchiveFilePage(ArchiveFileVO vo) {
|
|
@@ -107,10 +113,29 @@ public class ArchiveFileServiceImpl extends BaseServiceImpl<ArchiveFileMapper, A
|
|
// return integer-t1;
|
|
// return integer-t1;
|
|
// }
|
|
// }
|
|
// });
|
|
// });
|
|
|
|
+ StringBuffer ids = new StringBuffer();
|
|
Collections.sort(listInt);
|
|
Collections.sort(listInt);
|
|
for (int i = 0; i < list.size(); i++) {
|
|
for (int i = 0; i < list.size(); i++) {
|
|
list.get(i).setSort(listInt.get(i));
|
|
list.get(i).setSort(listInt.get(i));
|
|
|
|
+ if(list.get(i).getIsUpdateUrl() == 1) {
|
|
|
|
+ ids.append(list.get(i).getId() + ",");
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
+ if(ids != null && ids.length()>0){
|
|
|
|
+ List<String> removeFiles = new ArrayList<>();
|
|
|
|
+ List<ArchiveFile> archiveFileByFileIds = baseMapper.getArchiveFileByFileIds(Func.toLongList(ids.toString()));
|
|
|
|
+ if(archiveFileByFileIds!=null && archiveFileByFileIds.size()>0){
|
|
|
|
+ for(ArchiveFile archiveFile:archiveFileByFileIds){
|
|
|
|
+ if(StringUtils.isNotEmpty(archiveFile.getFileUrl().trim())){
|
|
|
|
+ removeFiles.add(archiveFile.getFileUrl());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ executorService.execute(()->{
|
|
|
|
+ iossClient.removeFiles(removeFiles);
|
|
|
|
+ });
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
this.updateBatchById(JSONArray.parseArray(JSONObject.toJSONString(list), ArchiveFile.class));
|
|
this.updateBatchById(JSONArray.parseArray(JSONObject.toJSONString(list), ArchiveFile.class));
|
|
}
|
|
}
|
|
|
|
|