From 2eb003b210f27096f58120c845b31bd1e1e80499 Mon Sep 17 00:00:00 2001 From: Sweidan Omar Date: Mon, 10 Jan 2022 14:14:38 +0000 Subject: [PATCH] git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32702 --- ...PeableBeachMissingMaterialCheckerStep.java | 100 ++++++++++-------- 1 file changed, 53 insertions(+), 47 deletions(-) diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/PeableBeachMissingMaterialCheckerStep.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/PeableBeachMissingMaterialCheckerStep.java index f171cdf9..47f46053 100644 --- a/server/user.jobengine.executors/src/user/jobengine/server/steps/PeableBeachMissingMaterialCheckerStep.java +++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/PeableBeachMissingMaterialCheckerStep.java @@ -31,8 +31,9 @@ public class PeableBeachMissingMaterialCheckerStep extends JobStep { private static final String appendExtension = ".mxf"; @StepEntry - public Object[] execute(String escortStoreName, BasicDBList lookupStoreNames, String targetStoreName, String targetProtocol, String primaryEndPoint, - String primaryUserName, String primaryPassword, String secondaryEndPoint, String secondaryUserName, String secondaryPassword, int rangeForwardHours) + public Object[] execute(String escortStoreName, BasicDBList lookupStoreNames, String targetStoreName, + String targetProtocol, String primaryEndPoint, String primaryUserName, String primaryPassword, + String secondaryEndPoint, String secondaryUserName, String secondaryPassword, int rangeForwardHours) throws Exception { StoreUri escortStoreUri = null; try { @@ -40,7 +41,8 @@ public class PeableBeachMissingMaterialCheckerStep extends JobStep { escortStoreUri = getManager().getStoreUri(escortStoreName, RemoteStoreProtocol.LOCAL); StoreUri sourceStoreUri = getManager().getStoreUri("TSM", RemoteStoreProtocol.TSM); - StoreUri targetStoreUri = getManager().getStoreUri(targetStoreName, Enum.valueOf(RemoteStoreProtocol.class, targetProtocol)); + StoreUri targetStoreUri = getManager().getStoreUri(targetStoreName, + Enum.valueOf(RemoteStoreProtocol.class, targetProtocol)); LinkedHashSet poolContent = new LinkedHashSet<>(); @@ -55,7 +57,8 @@ public class PeableBeachMissingMaterialCheckerStep extends JobStep { } String lookupStoreName = String.valueOf(lookup); - StoreUri lookupStoreUri = getManager().getStoreUri(lookupStoreName, Enum.valueOf(RemoteStoreProtocol.class, targetProtocol)); + StoreUri lookupStoreUri = getManager().getStoreUri(lookupStoreName, + Enum.valueOf(RemoteStoreProtocol.class, targetProtocol)); logger.info(getMarker(), "Checking pool {}", lookupStoreName); List lookupContent = getPoolContent(lookupStoreName, lookupStoreUri); poolContent.addAll(lookupContent); @@ -64,15 +67,14 @@ public class PeableBeachMissingMaterialCheckerStep extends JobStep { setProgress(progress); } /* - if (1 == 1) { - - logger.info(getMarker(), "Kikapcsolva"); - return null; - } - */ + * if (1 == 1) { + * + * logger.info(getMarker(), "Kikapcsolva"); return null; } + */ PBQuery query = new PBQuery(); - query.init(primaryEndPoint, primaryUserName, primaryPassword, secondaryEndPoint, secondaryUserName, secondaryPassword, rangeForwardHours); + query.init(primaryEndPoint, primaryUserName, primaryPassword, secondaryEndPoint, secondaryUserName, + secondaryPassword, rangeForwardHours); Collection medias = query.getPossibelMissingMaterialNames(new ArrayList<>(poolContent)); logger.info(getMarker(), "API returned {} items", medias == null ? 0 : medias.size()); @@ -124,7 +126,7 @@ public class PeableBeachMissingMaterialCheckerStep extends JobStep { int pos = name.lastIndexOf("."); if (pos > -1) { name = name.substring(0, pos); - //logger.info(getMarker(), "Adding {}", name); + // logger.info(getMarker(), "Adding {}", name); poolContent.add(name); } } @@ -135,50 +137,52 @@ public class PeableBeachMissingMaterialCheckerStep extends JobStep { } } - // List remoteFiles = targetStoreUri.getRemoteFiles(); - // if (remoteFiles != null) { - // logger.info(getMarker(), "Remote file list size :{}", remoteFiles.size()); - // for (RemoteFile rf : remoteFiles) { - // try { - // String name = rf.getName(); - // if (name.toLowerCase().endsWith(".mxf")) { - // int pos = name.lastIndexOf("."); - // if (pos > -1) { - // name = name.substring(0, pos); - // //logger.info(getMarker(), "Adding {}", name); - // poolContent.add(name); - // } - // } - // } catch (Exception e) { - // logger.error(e.getMessage()); - // } + // List remoteFiles = targetStoreUri.getRemoteFiles(); + // if (remoteFiles != null) { + // logger.info(getMarker(), "Remote file list size :{}", remoteFiles.size()); + // for (RemoteFile rf : remoteFiles) { + // try { + // String name = rf.getName(); + // if (name.toLowerCase().endsWith(".mxf")) { + // int pos = name.lastIndexOf("."); + // if (pos > -1) { + // name = name.substring(0, pos); + // //logger.info(getMarker(), "Adding {}", name); + // poolContent.add(name); + // } + // } + // } catch (Exception e) { + // logger.error(e.getMessage()); + // } // - // } - // } + // } + // } logger.info(getMarker(), "Pool {} contains {} items", storeName, poolContent == null ? 0 : poolContent.size()); return poolContent; } - //csak visszaterunk + // csak visszaterunk private String normalizeName(String mediaName) { String result = mediaName; if (StringUtils.isNotBlank(appendExtension)) result += appendExtension; - // if (StringUtils.isNotBlank(mediaName)) { - // result = mediaName.trim().toLowerCase(); - // } + // if (StringUtils.isNotBlank(mediaName)) { + // result = mediaName.trim().toLowerCase(); + // } return result; } - private void processRecord(MMMedia mmedia, StoreUri sourceStoreUri, String targetStoreName, StoreUri targetStoreUri, StoreUri escortStoreUri) { - //TODO kisbetu/nagybetu problema kezelese + private void processRecord(MMMedia mmedia, StoreUri sourceStoreUri, String targetStoreName, StoreUri targetStoreUri, + StoreUri escortStoreUri) { + // TODO kisbetu/nagybetu problema kezelese Media media = null; - //duplikatum miatt + // duplikatum miatt try { media = getManager().getMedia(mmedia.getName()); } catch (Exception e) { - logger.error(getMarker(), "Can't identify missing material {}. System message is: {}", mmedia.getName(), e.getMessage()); + logger.error(getMarker(), "Can't identify missing material {}. System message is: {}", mmedia.getName(), + e.getMessage()); return; } @@ -189,8 +193,9 @@ public class PeableBeachMissingMaterialCheckerStep extends JobStep { return; } - DownloadableMedia downloadable = DownloadableMedia.create(mmedia.getName(), fileName, media.getModified(), media.getCreated(), media.getLength(), 0L, - sourceStoreUri.getId(), targetStoreUri.getId(), media.getId()); + DownloadableMedia downloadable = DownloadableMedia.create(mmedia.getName(), fileName, media.getModified(), + media.getCreated(), media.getLength(), 0L, sourceStoreUri.getId(), targetStoreUri.getId(), + media.getId()); downloadable.put("priority", 50); String usage = mmedia.getUsage(); usage = usage.replace("-", "").replace(":", ""); @@ -198,30 +203,31 @@ public class PeableBeachMissingMaterialCheckerStep extends JobStep { Path outputPath = null; try { outputPath = Paths.get(escortStoreUri.toString(true)); - boolean exsists = statusFileExists(outputPath, fileName); - if (exsists) + boolean exists = statusFileExists(outputPath, fileName); + if (exists) return; EscortFiles.createMetadata(outputPath.toString(), escortFileName, downloadable.toPrettyString("")); logger.info(getMarker(), "Status file created {}", escortFileName); } catch (Exception e) { - logger.error(getSessionMarker(), "Can't create status file {}", Paths.get(outputPath.toString(), escortFileName)); + logger.error(getSessionMarker(), "Can't create status file {}", + Paths.get(outputPath.toString(), escortFileName)); } } private boolean statusFileExists(Path outputPath, String fileName) { - boolean exsists = false; + boolean exists = false; Path statusPath = Paths.get(outputPath.toString(), EscortFiles.STATUSFOLDER); try (DirectoryStream p = Files.newDirectoryStream(statusPath, "*" + fileName + EscortFiles.DOT_JSON)) { if (p.iterator().hasNext()) { logger.info(getMarker(), "Status file for {} already exists", fileName); - exsists = true; + exists = true; } } catch (Exception e1) { logger.error(getSessionMarker(), e1.getMessage()); } - return exsists; + return exists; } } -- 2.54.0