Bug #79 Tömeges visszatöltés esetén két email

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

diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/BatchRetrieveForkStep.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/BatchRetrieveForkStep.java
index 101e9047f1020843a652b60b0cb5679e109b9a06..b605404f56fd3d15b2a7968141e9a70906af5b22 100644 (file)
--- a/server/user.jobengine.executors/src/user/jobengine/server/steps/BatchRetrieveForkStep.java
+++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/BatchRetrieveForkStep.java
@@ -6,6 +6,7 @@ import java.util.Map;
 import org.apache.logging.log4j.LogManager;\r
 import org.apache.logging.log4j.Logger;\r
 \r
+import user.commons.MediaCubeFinishMarker;\r
 import user.commons.MediaCubeMarker;\r
 import user.jobengine.db.Media;\r
 import user.jobengine.server.IJobEngine;\r
@@ -19,28 +20,31 @@ public class BatchRetrieveForkStep extends JobStep {
        private static final String MEDIACUBEMEDIA = "mediaCubeMedia";\r
        private static final String RECIPIENT = "successRecipient";\r
        private static final String HOUSEID = "houseId";\r
-       private MediaCubeMarker systemMarker;\r
+       private MediaCubeMarker marker;\r
 \r
        @StepEntry\r
        public Object[] execute(List<Media> basket, String houseId, String recipient, String targetPathType, IJobEngine jobEngine, IJobRuntime jobRuntime)\r
                        throws Exception {\r
-               systemMarker = (MediaCubeMarker) jobRuntime.getMarker();\r
-               systemMarker.setTo(recipient);\r
+               marker = (MediaCubeMarker) jobRuntime.getMarker();\r
+               marker.setTo(recipient);\r
 \r
                if (basket == null || basket.size() == 0)\r
                        return null;\r
                setProgress(10);\r
 \r
-               //              StringBuilder sb = new StringBuilder();\r
-               //              sb.append("A visszatöltések elindultak az alábbi állományokra:</br>");\r
+               MediaCubeMarker mailMarker = new MediaCubeMarker(recipient);\r
+               mailMarker.setSessionName("Archívum viszatöltés");\r
+               mailMarker.setSessionID(houseId);\r
+               logger.info(mailMarker, "A visszatöltések elindultak az alábbi állományokra:");\r
+\r
                if (jobRuntime.forkPrepare()) {\r
                        for (Media mediaCubeMedia : basket) {\r
-                               //                              sb.append(mediaCubeMedia.getMediaFilesName() + "</br>");\r
+                               logger.info(mailMarker, mediaCubeMedia.getMediaFilesName());\r
                                submit(mediaCubeMedia, recipient, houseId, targetPathType, jobEngine, jobRuntime);\r
                        }\r
                }\r
                setProgress(50);\r
-               //              logger.info(new MediaCubeMarker(recipient), sb.toString());\r
+               logger.info(new MediaCubeFinishMarker(mailMarker), "A visszatöltések végeztével megerősítő üzenetet küldünk.");\r
                jobRuntime.forkWaitComplete();\r
                setProgress(100);\r
                return null;\r
@@ -59,7 +63,7 @@ public class BatchRetrieveForkStep extends JobStep {
                        ((MediaCubeMarker) child.getMarker()).setTo(recipient);\r
                } catch (Exception e) {\r
                        logger.catching(e);\r
-                       logger.error(systemMarker, "Hiba a kötegelt visszatöltésben. A rendszer üzenete: {}", e.getMessage());\r
+                       logger.error(marker, "Hiba a kötegelt visszatöltésben. A rendszer üzenete: {}", e.getMessage());\r
                }\r
 \r
        }\r