From: Vásáry Dániel <daniel.vasary@userrendszerhaz.hu>
Date: Fri, 16 Nov 2018 13:24:02 +0000 (+0000)
Subject: Bug #79 Tömeges visszatöltés esetén két email
X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=db75b237b44e9518b75ba88e99ae3ee4b3bf1ef7;p=mediacube.git

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