From: Sweidan Omar <TFS\sweidan.omar>
Date: Tue, 18 Jan 2022 13:05:22 +0000 (+0000)
Subject: #311
X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=e16dc10d7f6730899a5e9ab714134a5f5cd4be9c;p=mediacube.git

#311

git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32763
---

diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/MoveJpegToIsilonStep.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/MoveJpegToIsilonStep.java
new file mode 100644
index 00000000..27f7d0e1
--- /dev/null
+++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/MoveJpegToIsilonStep.java
@@ -0,0 +1,72 @@
+package user.jobengine.server.steps;
+
+import java.io.IOException;
+import java.nio.file.FileVisitResult;
+import java.nio.file.FileVisitor;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.nio.file.SimpleFileVisitor;
+import java.nio.file.attribute.BasicFileAttributes;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import user.commons.StoreUri;
+
+public class MoveJpegToIsilonStep extends JobStep {
+	private static final Logger logger = LogManager.getLogger();
+
+	@StepEntry
+	public Object[] execute(StoreUri uri, String protocol) throws Exception {
+		// TODO szerezzük a path-t meg az uri-ból
+		Path sourcePath;
+		List<String> files = new ArrayList<>();
+		String fileNamePattern = "yyyymmdd";
+
+		try {
+			sourcePath = Paths.get(uri.toString());
+
+			Pattern pattern = Pattern.compile(fileNamePattern, Pattern.CASE_INSENSITIVE);
+
+			FileVisitor<Path> visitor = new SimpleFileVisitor<Path>() {
+
+				@Override
+				public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException {
+					if (!file.getFileName().toString().contains("_DONE")) {
+						Matcher matcher = pattern.matcher(file.getFileName().toString());
+						if (matcher.find())
+							files.add(file.toString());
+					}
+					return FileVisitResult.CONTINUE;
+				}
+
+				@Override
+				public FileVisitResult visitFileFailed(Path file, IOException exc) throws IOException {
+					return FileVisitResult.CONTINUE;
+				}
+			};
+
+			try {
+				Files.walkFileTree(sourcePath, visitor);
+			} catch (Exception e) {
+				logger.error(getMarker(), "Error processing '{}'. System message: {}", sourcePath, e.getMessage());
+				logger.catching(e);
+				throw e;
+			} finally {
+			}
+
+			logger.info(getMarker(), "Found {} files", files.size());
+
+		} catch (Exception e) {
+			logger.debug("e.stackTrace: {}", e.getStackTrace());
+		}
+
+//		return new Object[] { files };
+		return null;
+	}
+}
\ No newline at end of file