git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...
authorSweidan Omar <TFS\sweidan.omar>
Mon, 2 May 2022 10:05:43 +0000 (10:05 +0000)
committerSweidan Omar <TFS\sweidan.omar>
Mon, 2 May 2022 10:05:43 +0000 (10:05 +0000)
server/user.jobengine.executors/src/user/jobengine/server/steps/TSMWriterStep.java

index bf57f390ab3e2e379173c4ae15a5553972e865f1..8ce88bfa2c665da71b02b8bfbc286e53b8cc99b9 100644 (file)
@@ -58,28 +58,31 @@ public class TSMWriterStep extends JobStep {
 \r
                        getJobRuntime().setDescription(details);\r
 \r
-                       //TODO mxf helyett az osszes kiterjesztest!!!!!\r
-                       //A dupla ellenorzes a napon beluli ismetlesek miatt kell\r
+                       // TODO mxf helyett az osszes kiterjesztest!!!!!\r
+                       // A dupla ellenorzes a napon beluli ismetlesek miatt kell\r
                        long existingMediaId = archiveItem.getExistingMediaId();\r
                        if (sourceMediaFile.length() == 0 && existingMediaId == 0) {\r
-                               existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager, sourceFileName.replace(MXFEXT, ""));\r
+                               existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager,\r
+                                               sourceFileName.replace(MXFEXT, ""));\r
                                if (existingMediaId == 0)\r
                                        existingMediaId = -1;\r
                        }\r
 \r
                        if (existingMediaId == 0)\r
-                               existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager, sourceFileName.replace(MXFEXT, ""));\r
+                               existingMediaId = ItemManagerExtensions.getExistingRundownMedia(manager,\r
+                                               sourceFileName.replace(MXFEXT, ""));\r
 \r
                        String targetFileName;\r
                        if (RANDOMIZE_ARCHIVES) {\r
                                // a-z, A-Z, 0-9. For example: WRMcpIk7, s57JwCVA\r
-                               //veletlenszeru neveket adunk!\r
+                               // veletlenszeru neveket adunk!\r
                                targetFileName = String.format("%s-%s", RandomStringUtils.randomAlphanumeric(8), sourceFileName);\r
                        } else\r
                                targetFileName = sourceFileName;\r
 \r
                        if (existingMediaId == 0) {\r
-                               StoreUri sourceUri = manager.createStoreUri(RemoteStoreProtocol.LOCAL, sourceMediaFile.getParent().toString());\r
+                               StoreUri sourceUri = manager.createStoreUri(RemoteStoreProtocol.LOCAL,\r
+                                               sourceMediaFile.getParent().toString());\r
 \r
                                final IJobRuntime runtime = getJobRuntime();\r
                                sourceUri.addProgressListener(new IProgressEventListener() {\r
@@ -99,11 +102,14 @@ public class TSMWriterStep extends JobStep {
                        }\r
 \r
                        if (existingMediaId > 0)\r
-                               logger.info(marker, "Az '{}' TSM mentése nem szükséges, mert már megtalálható az archívumban.", sourceFileName);\r
+                               logger.info(marker, "Az '{}' TSM mentése nem szükséges, mert már megtalálható az archívumban.",\r
+                                               sourceFileName);\r
 \r
-                       //Fel kell szabadítani, hogy a kovetkezo archivalaskor is nekifusson\r
+                       // Fel kell szabadítani, hogy a kovetkezo archivalaskor is nekifusson\r
                        if (existingMediaId == -1) {\r
-                               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);\r
+                               logger.info(marker,\r
+                                               "Az '{}' mentése jelenleg nem lehetséges, mert a szükséges metaadat még nem található meg az archívumban.",\r
+                                               sourceFileName);\r
                                if (!archiveItem.removeCatchedFile())\r
                                        logger.error(marker,\r
                                                        "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!",\r
@@ -118,7 +124,8 @@ public class TSMWriterStep extends JobStep {
 \r
                } catch (Exception e) {\r
                        logger.catching(e);\r
-                       Message m = new ParameterizedMessage("Az '{}' állomány archiválása sikertelen. A rendszer hibaüzenete: {}", details, e.getMessage());\r
+                       Message m = new ParameterizedMessage("Az '{}' állomány archiválása sikertelen. A rendszer hibaüzenete: {}",\r
+                                       details, e.getMessage());\r
                        logger.error(marker, m);\r
                        if (!archiveItem.removeCatchedFile())\r
                                logger.error(marker,\r
@@ -160,7 +167,8 @@ public class TSMWriterStep extends JobStep {
                mediaCubeMedia.modify();\r
        }\r
 \r
-       private void setAndCheck(ArchiveItem archiveItem, Media mediaCubeMedia, IJobEngine jobEngine) throws JobEngineException, IOException {\r
+       private void setAndCheck(ArchiveItem archiveItem, Media mediaCubeMedia, IJobEngine jobEngine)\r
+                       throws JobEngineException, IOException {\r
                if (jobEngine == null) {\r
                        logger.error(marker, "Az folyamatkezelő réteg nem elérhető.");\r
                        throw new NullPointerException("Internal error, missing JobEngine reference.");\r
@@ -177,11 +185,13 @@ public class TSMWriterStep extends JobStep {
                sourceMediaFile = new File(archiveItem.getMediaFile());\r
                if (sourceMediaFile == null) {\r
                        logger.error(marker, "A folyamat 'archiveItem' bemeneti paraméter 'mediaFile' értéke üres.");\r
-                       throw new NullPointerException("System is not configured properly, missing 'mediaFile' value in 'archiveItem' input parameter.");\r
+                       throw new NullPointerException(\r
+                                       "System is not configured properly, missing 'mediaFile' value in 'archiveItem' input parameter.");\r
                }\r
                if (!sourceMediaFile.exists()) {\r
-                       logger.error(marker, "Az {} állomány nem létezik vagy nem érhető el.", sourceMediaFile.getName());\r
-                       throw new IOException(String.format("Input file {} not exists or unreachable.", sourceMediaFile.getName()));\r
+                       logger.error(marker, "A(z) {} állomány nem létezik vagy nem érhető el.", sourceMediaFile.getName());\r
+                       throw new IOException(\r
+                                       String.format("Input file {} does not exist or unreachable.", sourceMediaFile.getName()));\r
                }\r
                tsmStore = manager.getSystemStore(false);\r
                if (tsmStore == null) {\r
@@ -200,7 +210,8 @@ public class TSMWriterStep extends JobStep {
                }\r
                if (mediaCubeMedia == null) {\r
                        logger.error(marker, "A folyamat 'mediaCubeMedia' bemeneti paramétere üres.");\r
-                       throw new NullPointerException("System is not configured properly, 'mediaCubeMedia' input parameter missing.");\r
+                       throw new NullPointerException(\r
+                                       "System is not configured properly, 'mediaCubeMedia' input parameter missing.");\r
                }\r
 \r
        }\r