From: vasary.daniel <TFS\vasary.daniel>
Date: Mon, 21 Mar 2022 20:15:30 +0000 (+0000)
Subject: Metaadat szinkronizacio
X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=65f78e222a99bd5decfae79592d1d996658a4d17;p=mediacube.git

Metaadat szinkronizacio

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

diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/MetadataSyncRecursiveStep.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/MetadataSyncRecursiveStep.java
index 7ea6612b..423bcae5 100644
--- a/server/user.jobengine.executors/src/user/jobengine/server/steps/MetadataSyncRecursiveStep.java
+++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/MetadataSyncRecursiveStep.java
@@ -12,6 +12,7 @@ import java.util.Arrays;
 import java.util.List;
 
 import org.apache.commons.io.FilenameUtils;
+import org.apache.ibatis.jdbc.SQL;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 
@@ -88,6 +89,11 @@ public class MetadataSyncRecursiveStep extends JobStep implements FileVisitor<Pa
 
 		String fileName = filePath.getFileName().toString();
 		String mediaHouseId = FilenameUtils.removeExtension(fileName);
+
+		String mediaHouseIdUpper = mediaHouseId.toUpperCase();
+		if (mediaHouseIdUpper.endsWith("_CLEAN"))
+			mediaHouseId = mediaHouseIdUpper.replace("_CLEAN", "");
+
 		try {
 			result = getPlanAirMetadata(mediaHouseId);
 
@@ -190,7 +196,7 @@ public class MetadataSyncRecursiveStep extends JobStep implements FileVisitor<Pa
 		if (fileName.startsWith(".") || fileName.endsWith(".nomd"))
 			return true;
 
-		logger.info(getSessionMarker(), "Checking {}", mediaPath);
+		// logger.info(getSessionMarker(), "Checking {}", mediaPath);
 
 		ArchiveItem archiveItem = createArchiveItem(mediaPath);
 		MediaFile mediaFile = getMediaFile(fileName);
@@ -216,24 +222,62 @@ public class MetadataSyncRecursiveStep extends JobStep implements FileVisitor<Pa
 				tsmSize = tsmFile.getSize();
 				sizeEquals = tsmSize == size;
 
-				if (sizeEquals && !metadataEquals) {
-					logger.info(getSessionMarker(), "Metadata sync required for {}", mediaPath);
+				if (archiveItem == null) {
+					// korabban mentettuk metaadat nelkul
+					logger.info(getSessionMarker(), "Metadata not available for {}", mediaPath);
+				} else {
+					if (sizeEquals && !metadataEquals) {
+						syncMetadata(mediaPath, item, media, archiveItem, mediaFile);
+						logger.info(getSessionMarker(), "Metadata sync applied for {}", mediaPath);
+					}
 				}
+
 			}
 		}
 
 		return true;
 	}
 
+	public String createUpdateItemQuery(long itemId, ArchiveItem archiveItem) {
+		SQL sql = new SQL();
+		sql.UPDATE("ITEM");
+		sql.SET(String.format("HOUSEID='%s'", archiveItem.getItemHouseId()));
+		sql.SET(String.format("TITLE='%s'", archiveItem.getItemTitle()));
+		sql.WHERE(String.format("ID = %d", itemId));
+		return sql.toString();
+	}
+
+	public String createUpdateMediaQuery(long mediaId, ArchiveItem archiveItem) {
+		SQL sql = new SQL();
+		sql.UPDATE("MEDIA");
+		sql.SET(String.format("HOUSEID='%s'", archiveItem.getMediaHouseId()));
+		sql.SET(String.format("TITLE='%s'", archiveItem.getMediaTitle()));
+		sql.SET(String.format("DESCRIPTION='%s'", archiveItem.getMediaDescription()));
+		sql.WHERE(String.format("ID = %d", mediaId));
+		return sql.toString();
+	}
+
+	private void syncMetadata(Path mediaPath, Item item, Media media, ArchiveItem archiveItem, MediaFile mediaFile) {
+		String sql = createUpdateItemQuery(item.getId(), archiveItem);
+		getManager().executeUpdate(sql, null, null);
+		// logger.info(getSessionMarker(), sql);
+		sql = createUpdateMediaQuery(media.getId(), archiveItem);
+		// logger.info(getSessionMarker(), sql);
+		getManager().executeUpdate(sql, null, null);
+	}
+
 	@Override
 	public FileVisitResult visitFile(Path filePath, BasicFileAttributes paramBasicFileAttributes) throws IOException {
+		FileVisitResult result = FileVisitResult.CONTINUE;
+
 		try {
 			if (!processPathItem(filePath))
-				return FileVisitResult.TERMINATE;
+				result = FileVisitResult.TERMINATE;
 		} catch (Exception e) {
 			logger.catching(e);
+			result = FileVisitResult.TERMINATE;
 		}
-		return FileVisitResult.CONTINUE;
+		return result;
 	}
 
 	@Override
@@ -245,6 +289,7 @@ public class MetadataSyncRecursiveStep extends JobStep implements FileVisitor<Pa
 	MediaFile getMediaFile(String fileName) {
 		MediaFile result = null;
 		MediaFileDAO mfDAO = (MediaFileDAO) getManager().getBaseDAO(MediaFile.class);
+		// a houseid az mxf kiterjesztesu file
 		List<IEntityBase> mfList = mfDAO.getByHouseId(fileName);
 		if (mfList != null && mfList.size() == 1)
 			result = (MediaFile) mfList.get(0);
diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/SafeDeleteRecursive.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/SafeDeleteRecursive.java
index bd9a89bf..143a9920 100644
--- a/server/user.jobengine.executors/src/user/jobengine/server/steps/SafeDeleteRecursive.java
+++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/SafeDeleteRecursive.java
@@ -292,7 +292,9 @@ public class SafeDeleteRecursive extends JobStep implements FileVisitor<Path> {
 			Media media = getManager().getMedia(mediaFile.getMediaId());
 			mcArchivedDate = media.getCreated();
 			Item item = getManager().getItem(media.getItemId());
-			metadataEquals = checkArchiveItem(mediaPath, archiveItem, item, media);
+
+			// mivel nincs metaadat, nem ellenorizheto
+			metadataEquals = archiveItem == null || checkArchiveItem(mediaPath, archiveItem, item, media);
 
 			// tsm
 			String tsmFileName = mediaFile.getRelativePath();