Tianqi-Dotes commented on code in PR #12552:
URL:
https://github.com/apache/dolphinscheduler/pull/12552#discussion_r1010236311
##########
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/service/impl/ResourcesServiceImpl.java:
##########
@@ -1871,6 +1874,61 @@ public Resource queryResourcesFileInfo(String userName,
String fileName) {
return (Resource) resourceResponse.getData();
}
+ @Override
+ public Map<String, Object> deleteDataTransferData(User loginUser, Integer
days) {
+ Map<String, Object> result = new HashMap<>();
+
+ User user = userMapper.selectById(loginUser.getId());
+ if (user == null) {
+ logger.error("user {} not exists", loginUser.getId());
+ putMsg(result, Status.USER_NOT_EXIST, loginUser.getId());
+ return result;
+ }
+
+ Tenant tenant = tenantMapper.queryById(user.getTenantId());
+ if (tenant == null) {
+ logger.error("tenant not exists");
+ putMsg(result, Status.CURRENT_LOGIN_USER_TENANT_NOT_EXIST);
+ return result;
+ }
+ String tenantCode = tenant.getTenantCode();
+
+ String baseFolder = storageOperate.getResourceFileName(tenantCode,
"DATA_TRANSFER");
+
+ LocalDateTime now = LocalDateTime.now();
+ now = now.minus(days, ChronoUnit.DAYS);
+ String deleteDate = now.toLocalDate().toString().replace("-", "");
+ List<StorageEntity> storageEntities;
+ try {
+ storageEntities = new ArrayList<>(
+ storageOperate.listFilesStatus(baseFolder, baseFolder,
tenantCode, ResourceType.FILE));
+ } catch (Exception e) {
+ logger.error("delete data transfer data error", e);
+ putMsg(result, Status.DELETE_RESOURCE_ERROR);
+ return result;
+ }
+
+ List<String> successList = new ArrayList<>();
+ List<String> failList = new ArrayList<>();
+ for (StorageEntity storageEntity : storageEntities) {
Review Comment:
consider transaction
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
