feat: clean code

Author: hhhhsc701

backend/services/data-cleaning-service/src/main/java/com/datamate/cleaning/application/CleaningTaskService.java

@@ -149,6 +149,7 @@ public List<CleaningResultDto> getTaskResults(String taskId) {
     }
 
     public List<CleaningTaskLog> getTaskLog(String taskId) {
+        cleanTaskValidator.checkTaskId(taskId);
         String logPath = FLOW_PATH + "/" + taskId + "/output.log";
         try (Stream<String> lines = Files.lines(Paths.get(logPath))) {
             List<CleaningTaskLog> logs = new ArrayList<>();
@@ -188,6 +189,7 @@ private String getLogLevel(String logLine, String defaultLevel) {
 
     @Transactional
     public void deleteTask(String taskId) {
+        cleanTaskValidator.checkTaskId(taskId);
         cleaningTaskRepo.deleteTaskById(taskId);
         operatorInstanceRepo.deleteByInstanceId(taskId);
         cleaningResultRepo.deleteByInstanceId(taskId);
@@ -322,6 +324,7 @@ private void scanDataset(String taskId, String srcDatasetId, Set<String> succeed
     }
 
     private void doScan(String taskId, String srcDatasetId, Predicate<DatasetFile> filterCondition) {
+        cleanTaskValidator.checkTaskId(taskId);
         String targetFilePath = FLOW_PATH + "/" + taskId + "/dataset.jsonl";
         File targetFile = new File(targetFilePath);
         if (targetFile.getParentFile() != null && !targetFile.getParentFile().exists()) {

backend/services/data-cleaning-service/src/main/java/com/datamate/cleaning/infrastructure/validator/CleanTaskValidator.java

@@ -4,19 +4,25 @@
 import com.datamate.cleaning.domain.repository.CleaningTaskRepository;
 import com.datamate.cleaning.interfaces.dto.OperatorInstanceDto;
 import com.datamate.common.infrastructure.exception.BusinessException;
+import com.datamate.common.infrastructure.exception.SystemErrorCode;
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Component;
 
 import java.util.List;
 import java.util.Locale;
+import java.util.regex.Pattern;
 
 
 @Component
 @RequiredArgsConstructor
 public class CleanTaskValidator {
     private final CleaningTaskRepository cleaningTaskRepo;
 
+    private final Pattern UUID_PATTERN = Pattern.compile(
+            "^[0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{4}-[0-9a-fA-F]{12}$"
+    );
+
     public void checkNameDuplication(String name) {
         if (cleaningTaskRepo.isNameExist(name)) {
             throw BusinessException.of(CleanErrorCode.DUPLICATE_TASK_NAME);
@@ -39,4 +45,10 @@ public void checkInputAndOutput(List<OperatorInstanceDto> operators) {
                             front.getName(), back.getName()));
         }
     }
+
+    public void checkTaskId(String id) {
+        if (id == null || !UUID_PATTERN.matcher(id).matches()) {
+            throw BusinessException.of(SystemErrorCode.INVALID_PARAMETER);
+        }
+    }
 }