renun/zfile
1
0
Fork 0
mirror of https://github.com/zfile-dev/zfile.git synced 2025-04-19 05:34:52 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

✨ 根据查询条件批量删除直链

Browse Source
This commit is contained in:
zhaojun
2023-03-05 15:28:14 +08:00
parent aefa928a19
commit 9328e0ea9d
2 changed files with 31 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/main/java/im/zhaojun/zfile/module/log/controller/DownloadLogManagerController.java
View File

@@ -75,17 +75,17 @@ public class DownloadLogManagerController {
.like(StrUtil.isNotEmpty(queryDownloadLogRequest.getUserAgent()), "user_agent", queryDownloadLogRequest.getUserAgent())
.ge(StrUtil.isNotEmpty(queryDownloadLogRequest.getDateFrom()), "create_time", queryDownloadLogRequest.getDateFrom())
.le(StrUtil.isNotEmpty(queryDownloadLogRequest.getDateTo()), "create_time", queryDownloadLogRequest.getDateTo());
Page<DownloadLog> selectResult = downloadLogService.selectPage(pages, queryWrapper);
Map<String, StorageSource> cache = new HashMap<>();
Stream<DownloadLogResult> shortLinkResultList = selectResult.getRecords().stream().map(model -> {
String storageKey = model.getStorageKey();
StorageSource storageSource = cache.getOrDefault(storageKey, storageSourceService.findByStorageKey(storageKey));
cache.put(storageKey, storageSource);
return downloadLogConvert.entityToResultList(model, storageSource);
});
return AjaxJson.getPageData(selectResult.getTotal(), shortLinkResultList);
@@ -113,4 +113,25 @@ public class DownloadLogManagerController {
return AjaxJson.getSuccess();
}
@ApiOperationSupport(order = 4)
@PostMapping("/delete/batch/query")
@ResponseBody
@ApiOperation(value = "根据查询条件批量删除直链")
public AjaxJson<Void> batchDeleteBySearchParams(@RequestBody QueryDownloadLogRequest queryDownloadLogRequest) {
DownloadLog downloadLog = new DownloadLog();
QueryWrapper<DownloadLog> queryWrapper =
new QueryWrapper<>(downloadLog)
.eq(StrUtil.isNotEmpty(queryDownloadLogRequest.getStorageKey()), "storage_key", queryDownloadLogRequest.getStorageKey())
.like(StrUtil.isNotEmpty(queryDownloadLogRequest.getPath()), "path", queryDownloadLogRequest.getPath())
.like(StrUtil.isNotEmpty(queryDownloadLogRequest.getShortKey()), "short_key", queryDownloadLogRequest.getShortKey())
.like(StrUtil.isNotEmpty(queryDownloadLogRequest.getIp()), "ip", queryDownloadLogRequest.getIp())
.like(StrUtil.isNotEmpty(queryDownloadLogRequest.getReferer()), "referer", queryDownloadLogRequest.getReferer())
.like(StrUtil.isNotEmpty(queryDownloadLogRequest.getUserAgent()), "user_agent", queryDownloadLogRequest.getUserAgent())
.ge(StrUtil.isNotEmpty(queryDownloadLogRequest.getDateFrom()), "create_time", queryDownloadLogRequest.getDateFrom())
.le(StrUtil.isNotEmpty(queryDownloadLogRequest.getDateTo()), "create_time", queryDownloadLogRequest.getDateTo());
downloadLogService.deleteByQueryWarpper(queryWrapper);
return AjaxJson.getSuccess();
}
}

11
src/main/java/im/zhaojun/zfile/module/log/service/DownloadLogService.java
View File

@@ -28,18 +28,21 @@ public class DownloadLogService {
public Page<DownloadLog> selectPage(Page<DownloadLog> pages, QueryWrapper<DownloadLog> queryWrapper) {
return downloadLogMapper.selectPage(pages, queryWrapper);
}
public void removeById(Integer id) {
downloadLogMapper.deleteById(id);
}
@Transactional(rollbackFor = Exception.class)
public void removeBatchByIds(List<Integer> ids) {
downloadLogMapper.deleteBatchIds(ids);
}
public void deleteByQueryWarpper(QueryWrapper<DownloadLog> queryWrapper) {
downloadLogMapper.delete(queryWrapper);
}
public int deleteByStorageKey(String storageKey) {
return downloadLogMapper.deleteByStorageKey(storageKey);
}
}