Template hasznalat alapjan ellenorzi es kimasolja a job-okat

diff --git a/server/hu.user.mediacube.executors.tests/.settings/org.eclipse.core.resources.prefs b/server/hu.user.mediacube.executors.tests/.settings/org.eclipse.core.resources.prefs
index fd2d99407b210aefe75edc0da273f0a4f3b6dad8..5140e0447187fe828819d91afecf678a752d04e5 100644 (file)
--- a/server/hu.user.mediacube.executors.tests/.settings/org.eclipse.core.resources.prefs
+++ b/server/hu.user.mediacube.executors.tests/.settings/org.eclipse.core.resources.prefs
@@ -2,5 +2,6 @@ eclipse.preferences.version=1
 encoding//src/hu/user/mediacube/executors/tests/SupportAttachLowres.java=UTF-8\r
 encoding//src/hu/user/mediacube/executors/tests/SupportCheckDelete.java=UTF-8\r
 encoding//src/hu/user/mediacube/executors/tests/SupportCheckItem.java=UTF-8\r
+encoding//src/hu/user/mediacube/executors/tests/SupportCheckJobStepUsage.java=UTF-8\r
 encoding//src/hu/user/mediacube/executors/tests/SupportCreateItems.java=UTF-8\r
 encoding//src/hu/user/mediacube/executors/tests/SupportSyncMCToTSM.java=UTF-8\r

diff --git a/server/hu.user.mediacube.executors.tests/src/hu/user/mediacube/executors/tests/SupportCheckJobStepUsage.java b/server/hu.user.mediacube.executors.tests/src/hu/user/mediacube/executors/tests/SupportCheckJobStepUsage.java
new file mode 100644 (file)
index 0000000..72d452e
--- /dev/null
+++ b/server/hu.user.mediacube.executors.tests/src/hu/user/mediacube/executors/tests/SupportCheckJobStepUsage.java
@@ -0,0 +1,64 @@
+package hu.user.mediacube.executors.tests;\r
+\r
+import java.io.IOException;\r
+import java.nio.file.Files;\r
+import java.nio.file.Path;\r
+import java.nio.file.Paths;\r
+import java.nio.file.StandardCopyOption;\r
+import java.util.Map;\r
+import java.util.stream.Stream;\r
+\r
+import org.junit.AfterClass;\r
+import org.junit.BeforeClass;\r
+import org.junit.Test;\r
+\r
+import user.commons.configuration.IConfiguration;\r
+import user.commons.configuration.SystemConfiguration;\r
+import user.jobengine.server.IJobStepExecutor;\r
+import user.jobengine.server.JobEngine;\r
+import user.jobengine.server.JobEngineConfiguration;\r
+\r
+public class SupportCheckJobStepUsage {\r
+       @BeforeClass\r
+       static public void setUpConnection() {\r
+       }\r
+\r
+       @AfterClass\r
+       static public void tearDownConnection() {\r
+       }\r
+\r
+       @Test\r
+       public void process() throws Exception {\r
+               String sourceSharedFolder = "c:/work/user/mediacube/server/user.jobengine.executors/src/user/jobengine/server/steps/shared";\r
+               String sourceFolder = "c:/work/user/mediacube/server/user.jobengine.executors/src/user/jobengine/server/steps";\r
+               String targetFolder = "c:/work/user/mediacube/server/-product/production/HIRTV/jobs/steps";\r
+\r
+               try (Stream<Path> sharedFiles = Files.list(Paths.get(sourceSharedFolder))) {\r
+                       sharedFiles.forEach(src -> {\r
+                               try {\r
+                                       Files.copy(src, Paths.get(targetFolder, "shared", src.getFileName().toString()), StandardCopyOption.REPLACE_EXISTING);\r
+                               } catch (IOException e) {\r
+                                       e.printStackTrace();\r
+                               }\r
+                       });\r
+               }\r
+               System.setProperty("user.dir", "c:/work/user/mediacube/server/-product/production/HIRTV");\r
+               IConfiguration systemConfiguration = SystemConfiguration.getInstance();\r
+               JobEngineConfiguration jobengineConfiguration = JobEngineConfiguration.getInstance();\r
+               jobengineConfiguration.bindSystemConfiguration(systemConfiguration);\r
+               JobEngine jobEngine = JobEngine.getInstance();\r
+               jobEngine.bindJobEngineConfiguration(jobengineConfiguration);\r
+               jobEngine.startup();\r
+               Map<String, IJobStepExecutor> executors = jobEngine.getJobEngineConfiguration().getExecutors();\r
+               executors.keySet().forEach(key -> {\r
+                       try {\r
+                               Files.copy(Paths.get(sourceFolder, key), Paths.get(targetFolder, key), StandardCopyOption.REPLACE_EXISTING);\r
+                       } catch (IOException e) {\r
+                               e.printStackTrace();\r
+                       }\r
+                       System.out.println(key);\r
+               });\r
+               jobEngine.shutdown();\r
+       }\r
+\r
+}\r