From 24f49aecb50c4b9d544b406cf9ad73c04a288b6a Mon Sep 17 00:00:00 2001
From: Sweidan Omar <TFS\sweidan.omar>
Date: Mon, 29 Nov 2021 16:27:49 +0000
Subject: [PATCH] =?utf8?q?MD5=20sz=C3=A1m=C3=ADt=C3=A1shoz=20f=C3=A1jlok?=
 =?utf8?q?=20l=C3=A9trehoz=C3=A1sa?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32388
---
 .../MEDIAVIVANTIS/jobs/executors.xml          |  1 +
 .../jobs/steps/CalculateMD5Step.java          | 31 +++++++++++++++++++
 .../jobs/templates/calculatemd5.xml           | 17 ++++++++++
 .../server/steps/CalculateMD5Step.java        | 22 +++++++++++++
 4 files changed, 71 insertions(+)
 create mode 100644 server/-product/production/MEDIAVIVANTIS/jobs/steps/CalculateMD5Step.java
 create mode 100644 server/-product/production/MEDIAVIVANTIS/jobs/templates/calculatemd5.xml
 create mode 100644 server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java

diff --git a/server/-product/production/MEDIAVIVANTIS/jobs/executors.xml b/server/-product/production/MEDIAVIVANTIS/jobs/executors.xml
index a0541aae..d0a69954 100644
--- a/server/-product/production/MEDIAVIVANTIS/jobs/executors.xml
+++ b/server/-product/production/MEDIAVIVANTIS/jobs/executors.xml
@@ -22,6 +22,7 @@
 	<executor className="CreateMissingLowresStep.java" maxConcurrent="1" isRemote="false" />
 	<executor className="FileCopyStep.java" maxConcurrent="20" isRemote="false" />
 	<executor className="HSMMigrateStep.java" maxConcurrent="1" isRemote="false" />
+	<executor className="CalculateMD5Step.java" maxConcurrent="1" isRemote="false "/>
 	<executor className="MediaToolStep.java" maxConcurrent="1" isRemote="false" />
 	<executor className="MetadataTransformStep.java" maxConcurrent="1" isRemote="false" />
 	<executor className="MXFCutterStep.java" maxConcurrent="1" isRemote="false" />
diff --git a/server/-product/production/MEDIAVIVANTIS/jobs/steps/CalculateMD5Step.java b/server/-product/production/MEDIAVIVANTIS/jobs/steps/CalculateMD5Step.java
new file mode 100644
index 00000000..6cb33747
--- /dev/null
+++ b/server/-product/production/MEDIAVIVANTIS/jobs/steps/CalculateMD5Step.java
@@ -0,0 +1,31 @@
+package user.jobengine.server.steps;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.message.Message;
+import org.apache.logging.log4j.message.ParameterizedMessage;
+
+import user.commons.MediaCubeMarker;
+
+public class CalculateMD5Step extends JobStep {
+	private static final Logger logger = LogManager.getLogger();
+
+	@StepEntry
+	public Object[] execute(int param) throws Exception {
+		logger.info(getMarker(), "Executing");
+		Message msg = new ParameterizedMessage("");
+		logger.info(new MediaCubeMarker("vasary@elgekko.net,vasary@gmail.com", "MediaCube rendszerüzenet"), msg);
+
+		for (int i = 0; i < 10; i++) {
+			logger.info(getMarker(), "Executing {}", i);
+			if (getJobRuntime().isWaitingCancel())
+				break;
+			Thread.sleep(100);
+			int progress = (i + 1) * 100 / 10;
+			setProgress(progress);
+		}
+
+		return null;
+	}
+
+}
diff --git a/server/-product/production/MEDIAVIVANTIS/jobs/templates/calculatemd5.xml b/server/-product/production/MEDIAVIVANTIS/jobs/templates/calculatemd5.xml
new file mode 100644
index 00000000..3c8426d5
--- /dev/null
+++ b/server/-product/production/MEDIAVIVANTIS/jobs/templates/calculatemd5.xml
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<jobtemplate multiInstance="true" useSessionLog="false">
+	<declarations>
+		<parameters>
+			<parameter name="param" type="java.lang.Integer" />
+		</parameters>
+	</declarations>
+	<commands>
+		<calljobstep remote="true" type="CalculateMD5Step.java" weight="1" >
+			<inputs>
+				<input>
+					<parameter name="param" />
+				</input>
+			</inputs>
+		</calljobstep>
+	</commands>
+</jobtemplate>
\ No newline at end of file
diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java
new file mode 100644
index 00000000..8dbdc1df
--- /dev/null
+++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java
@@ -0,0 +1,22 @@
+package user.jobengine.server.steps;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+public class CalculateMD5Step extends JobStep {
+	private static final Logger logger = LogManager.getLogger();
+
+	@StepEntry
+	public Object[] execute(int param) throws Exception {
+		logger.info(getMarker(), "Executing with param {}", param);
+		for (int i = 0; i < 10; i++) {
+			if (getJobRuntime().isWaitingCancel())
+				break;
+			Thread.sleep(10);
+			int progress = (i + 1) * 100 / 10;
+			setProgress(progress);
+		}
+		return null;
+	}
+
+}
-- 
2.54.0