From: Sweidan Omar Date: Mon, 2 May 2022 10:05:43 +0000 (+0000) Subject: git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube... X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=d883c991a4371c04a9c42bda5616d5609d36ec4e;p=mediacube.git git-tfs-id: [tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C33270 --- diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/TSMWriterStep.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/TSMWriterStep.java index bf57f390..8ce88bfa 100644 --- a/server/user.jobengine.executors/src/user/jobengine/server/steps/TSMWriterStep.java +++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/TSMWriterStep.java @@ -58,28 +58,31 @@ public class TSMWriterStep extends JobStep { getJobRuntime().setDescription(details); - //TODO mxf helyett az osszes kiterjesztest!!!!! - //A dupla ellenorzes a napon beluli ismetlesek miatt kell + // TODO mxf helyett az osszes kiterjesztest!!!!! + // A dupla ellenorzes a napon beluli ismetlesek miatt kell long existingMediaId = archiveItem.getExistingMediaId(); if (sourceMediaFile.length() == 0 && existingMediaId == 0) { - existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager, sourceFileName.replace(MXFEXT, "")); + existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager, + sourceFileName.replace(MXFEXT, "")); if (existingMediaId == 0) existingMediaId = -1; } if (existingMediaId == 0) - existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager, sourceFileName.replace(MXFEXT, "")); + existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager, + sourceFileName.replace(MXFEXT, "")); String targetFileName; if (RANDOMIZE_ARCHIVES) { // a-z, A-Z, 0-9. For example: WRMcpIk7, s57JwCVA - //veletlenszeru neveket adunk! + // veletlenszeru neveket adunk! targetFileName = String.format("%s-%s", RandomStringUtils.randomAlphanumeric(8), sourceFileName); } else targetFileName = sourceFileName; if (existingMediaId == 0) { - StoreUri sourceUri = manager.createStoreUri(RemoteStoreProtocol.LOCAL, sourceMediaFile.getParent().toString()); + StoreUri sourceUri = manager.createStoreUri(RemoteStoreProtocol.LOCAL, + sourceMediaFile.getParent().toString()); final IJobRuntime runtime = getJobRuntime(); sourceUri.addProgressListener(new IProgressEventListener() { @@ -99,11 +102,14 @@ public class TSMWriterStep extends JobStep { } if (existingMediaId > 0) - logger.info(marker, "Az '{}' TSM mentése nem szükséges, mert már megtalálható az archívumban.", sourceFileName); + logger.info(marker, "Az '{}' TSM mentése nem szükséges, mert már megtalálható az archívumban.", + sourceFileName); - //Fel kell szabadítani, hogy a kovetkezo archivalaskor is nekifusson + // Fel kell szabadítani, hogy a kovetkezo archivalaskor is nekifusson if (existingMediaId == -1) { - logger.info(marker, "Az '{}' mentése jelenleg nem lehetséges, mert a szükséges metaadat még nem található meg az archívumban.", sourceFileName); + logger.info(marker, + "Az '{}' mentése jelenleg nem lehetséges, mert a szükséges metaadat még nem található meg az archívumban.", + sourceFileName); if (!archiveItem.removeCatchedFile()) logger.error(marker, "Az '{}' állomány .catched jelző állománya nem törölhető. Az újabb archiválási kísérlethez annak kézi eltávolítása szükséges!", @@ -118,7 +124,8 @@ public class TSMWriterStep extends JobStep { } catch (Exception e) { logger.catching(e); - Message m = new ParameterizedMessage("Az '{}' állomány archiválása sikertelen. A rendszer hibaüzenete: {}", details, e.getMessage()); + Message m = new ParameterizedMessage("Az '{}' állomány archiválása sikertelen. A rendszer hibaüzenete: {}", + details, e.getMessage()); logger.error(marker, m); if (!archiveItem.removeCatchedFile()) logger.error(marker, @@ -160,7 +167,8 @@ public class TSMWriterStep extends JobStep { mediaCubeMedia.modify(); } - private void setAndCheck(ArchiveItem archiveItem, Media mediaCubeMedia, IJobEngine jobEngine) throws JobEngineException, IOException { + private void setAndCheck(ArchiveItem archiveItem, Media mediaCubeMedia, IJobEngine jobEngine) + throws JobEngineException, IOException { if (jobEngine == null) { logger.error(marker, "Az folyamatkezelő réteg nem elérhető."); throw new NullPointerException("Internal error, missing JobEngine reference."); @@ -177,11 +185,13 @@ public class TSMWriterStep extends JobStep { sourceMediaFile = new File(archiveItem.getMediaFile()); if (sourceMediaFile == null) { logger.error(marker, "A folyamat 'archiveItem' bemeneti paraméter 'mediaFile' értéke üres."); - throw new NullPointerException("System is not configured properly, missing 'mediaFile' value in 'archiveItem' input parameter."); + throw new NullPointerException( + "System is not configured properly, missing 'mediaFile' value in 'archiveItem' input parameter."); } if (!sourceMediaFile.exists()) { - logger.error(marker, "Az {} állomány nem létezik vagy nem érhető el.", sourceMediaFile.getName()); - throw new IOException(String.format("Input file {} not exists or unreachable.", sourceMediaFile.getName())); + logger.error(marker, "A(z) {} állomány nem létezik vagy nem érhető el.", sourceMediaFile.getName()); + throw new IOException( + String.format("Input file {} does not exist or unreachable.", sourceMediaFile.getName())); } tsmStore = manager.getSystemStore(false); if (tsmStore == null) { @@ -200,7 +210,8 @@ public class TSMWriterStep extends JobStep { } if (mediaCubeMedia == null) { logger.error(marker, "A folyamat 'mediaCubeMedia' bemeneti paramétere üres."); - throw new NullPointerException("System is not configured properly, 'mediaCubeMedia' input parameter missing."); + throw new NullPointerException( + "System is not configured properly, 'mediaCubeMedia' input parameter missing."); } }