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

index a543b60a71f26cf7b1700583f7c9a90d61726431..cb3f5d5847fc9df392875644fbe21d449595ee89 100644 (file)
@@ -56,7 +56,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
 \r
                        DBObject rundown = octopusAPI.getRundown(scheduledStart);\r
                        if (rundown == null) {\r
-                               logger.error(marker, "A '{}' anyaghoz nem található tükör '{}' kezdéssel, ezért nem archiválható.", clipName, scheduledStart);\r
+                               logger.error(marker, "A '{}' anyaghoz nem található tükör '{}' kezdéssel, ezért nem archiválható.",\r
+                                               clipName, scheduledStart);\r
                                return null;\r
                        }\r
                        result = processRundow(octopusAPI, rundown);\r
@@ -68,7 +69,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                                cal.add(Calendar.MINUTE, 5);\r
                                rundown = octopusAPI.getRundown(cal.getTime());\r
                                if (rundown == null) {\r
-                                       logger.error(marker, "A '{}' anyaghoz nem található tükör '{}' kezdéssel, ezért nem archiválható.", clipName, scheduledStart);\r
+                                       logger.error(marker, "A '{}' anyaghoz nem található tükör '{}' kezdéssel, ezért nem archiválható.",\r
+                                                       clipName, scheduledStart);\r
                                        return null;\r
                                }\r
                                ArchiveItem item2 = processRundow(octopusAPI, rundown);\r
@@ -76,7 +78,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                                        return null;\r
 \r
                                result.setItemTitle(result.getItemTitle() + " + NAPIAKT");\r
-                               result.setMediaDescription(result.getMediaDescription() + "\r\n\r\n****** NAPIAKT ******\r\n\r\n" + item2.getMediaDescription());\r
+                               result.setMediaDescription(result.getMediaDescription() + "\r\n\r\n****** NAPIAKT ******\r\n\r\n"\r
+                                               + item2.getMediaDescription());\r
                        }\r
 \r
                        result.setMediaTitle(clipName);\r
@@ -85,7 +88,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                        result.setCatchedFile(catchedFilePath.toString());\r
                } catch (Exception e) {\r
                        logger.catching(e);\r
-                       logger.error(getJobRuntime().getSessionMarker(), "A metaadat nem elérhető. A rendszer üzenete: {}", e.getMessage());\r
+                       logger.error(getJobRuntime().getSessionMarker(), "A metaadat nem elérhető. A rendszer üzenete: {}",\r
+                                       e.getMessage());\r
                        return null;\r
                }\r
 \r
@@ -98,7 +102,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                        Files.createFile(catchedFilePath);\r
                } catch (IOException e) {\r
                        logger.catching(e);\r
-                       logger.error(marker, "A '{}' jelzőfájl nem hozható létre. A rendszer üzenete: {}", catchedFilePath, e.getMessage());\r
+                       logger.error(marker, "A '{}' jelzőfájl nem hozható létre. A rendszer üzenete: {}", catchedFilePath,\r
+                                       e.getMessage());\r
                        throw e;\r
                }\r
        }\r
@@ -143,7 +148,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                                                item = processPathItem(file);\r
                                        } catch (IOException e) {\r
                                                logger.catching(e);\r
-                                               logger.error(marker, "Az '{}' állomány feldolgozása sikertelen. A rendszer hibaüzenete: {}", file, e.getMessage());\r
+                                               logger.error(marker, "Az '{}' állomány feldolgozása sikertelen. A rendszer hibaüzenete: {}",\r
+                                                               file, e.getMessage());\r
                                                throw e;\r
                                        }\r
                                        if (item == null) {\r
@@ -159,7 +165,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
 \r
                } catch (Exception e) {\r
                        logger.catching(e);\r
-                       logger.error(marker, "Az '{}' mappa elérése sikertelen. A rendszer hibaüzenete: {}", sourcePath, e.getMessage());\r
+                       logger.error(marker, "Az '{}' mappa elérése sikertelen. A rendszer hibaüzenete: {}", sourcePath,\r
+                                       e.getMessage());\r
                        throw e;\r
                } finally {\r
                }\r
@@ -173,7 +180,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                        String mediaFile = archiveItem.getMediaFile();\r
                        String name = new File(mediaFile).getName();\r
                        int extPos = name.toLowerCase().lastIndexOf(LXFEXT);\r
-                       targetFileName = String.format("20%s-%s", Paths.get(mediaFile).getParent().getFileName(), name.substring(0, extPos));\r
+                       targetFileName = String.format("20%s-%s", Paths.get(mediaFile).getParent().getFileName(),\r
+                                       name.substring(0, extPos));\r
                        if (targetFileName.length() > 32) {\r
                                targetFileName = targetFileName.substring(0, 28) + "_PGM";\r
                        }\r
@@ -190,7 +198,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                        return null;\r
                }\r
                if (recordDate == null) {\r
-                       logger.warn(marker, "Az '{}' fájl rögzítésének ideje nem meghatározható, ezért nem archiválható.", clipName);\r
+                       logger.warn(marker, "Az '{}' fájl rögzítésének ideje nem meghatározható, ezért nem archiválható.",\r
+                                       clipName);\r
                        return null;\r
                }\r
 \r
@@ -212,17 +221,18 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                Path catchedFilePath = Paths.get(dotStorePath.toString(), mediaFile.getName() + CATCHEDEXT);\r
                File catchedFile = catchedFilePath.toFile();\r
                if (catchedFile.exists()) {\r
-                       //logger.info("'{}' file is already catched", mediaFilePath);\r
+                       // logger.info("'{}' file is already catched", mediaFilePath);\r
                        return null;\r
                }\r
                createCatchedFile(catchedFilePath);\r
                if (!catchedFile.exists()) {\r
-                       logger.warn("'{}' catchfile not exists.", catchedFilePath);\r
+                       logger.warn("'{}' catchfile does not exist.", catchedFilePath);\r
                        return null;\r
                }\r
 \r
                if (mediaFile.isDirectory() || !mediaFile.getName().toLowerCase().endsWith(LXFEXT.toLowerCase())\r
-                               || mediaFilePath.getParent().toFile().getName().length() != 6 || !mediaFile.getName().toLowerCase().contains("_pgm_")) {\r
+                               || mediaFilePath.getParent().toFile().getName().length() != 6\r
+                               || !mediaFile.getName().toLowerCase().contains("_pgm_")) {\r
                        logger.info("Skipping '{}'", mediaFilePath);\r
                        return null;\r
                }\r
@@ -234,7 +244,8 @@ public class RecordingsArchiveItemBuilderStep extends JobStep {
                        return null;\r
                }\r
 \r
-               DBObject existingRecording = existingRecordings.findOne(new BasicDBObject("title", archiveItem.getItemTitle().substring(0, 16)));\r
+               DBObject existingRecording = existingRecordings\r
+                               .findOne(new BasicDBObject("title", archiveItem.getItemTitle().substring(0, 16)));\r
 \r
                if (existingRecording != null) {\r
                        logger.warn("'{}' already archived, skipping.", archiveItem.getItemTitle());\r