From bd3c3dcecdf34b8593b808247ee12180b767a444 Mon Sep 17 00:00:00 2001 From: Sweidan Omar Date: Mon, 6 Dec 2021 12:25:02 +0000 Subject: [PATCH] git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32488 --- .../steps/NEXIOMetadataPersisterStep.java | 60 ++++++++++--------- 1 file changed, 31 insertions(+), 29 deletions(-) diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/NEXIOMetadataPersisterStep.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/NEXIOMetadataPersisterStep.java index ffaf54a3..a854e179 100644 --- a/server/user.jobengine.executors/src/user/jobengine/server/steps/NEXIOMetadataPersisterStep.java +++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/NEXIOMetadataPersisterStep.java @@ -20,7 +20,7 @@ import user.jobengine.server.steps.shared.EscortFiles; public class NEXIOMetadataPersisterStep extends JobStep { private static final Logger logger = LogManager.getLogger(); - private static final String DOT_XML = ".xml"; +// private static final String DOT_XML = ".xml"; @StepEntry public Object[] execute(StoreUri targetStoreUri, String escortFile) throws Exception { @@ -45,22 +45,22 @@ public class NEXIOMetadataPersisterStep extends JobStep { RemoteFile remoteFile = targetStoreUri.getFileWithContent(downloadable.getString("title") + ".xml"); - //TODO mediafile lastmodified = feltoltott file nexio xml lastmodified + // TODO mediafile lastmodified = feltoltott file nexio xml lastmodified Timestamp lastModified = getLastModified(remoteFile); logger.info("Setting last modification time on {} to {}", downloadable.getString("title"), lastModified); mediaFile.setLastModified(lastModified); getManager().modify(mediaFile); - // if (!RemoteStoreProtocol.FTP.equals(targetStoreUri.getProtocol())) - // return null; + // if (!RemoteStoreProtocol.FTP.equals(targetStoreUri.getProtocol())) + // return null; // - // String title = downloadable.getString("title"); - // String fileName = downloadable.getString("fileName"); - // Date created = downloadable.getDate("created"); - // Date modified = downloadable.getDate("modified"); - // byte[] metadata = EscortFiles.createNEXIODatesMeta(title, created, modified); - // uploadMeta(targetStoreUri, fileName, metadata); + // String title = downloadable.getString("title"); + // String fileName = downloadable.getString("fileName"); + // Date created = downloadable.getDate("created"); + // Date modified = downloadable.getDate("modified"); + // byte[] metadata = EscortFiles.createNEXIODatesMeta(title, created, modified); + // uploadMeta(targetStoreUri, fileName, metadata); } catch (Exception e) { logger.error(getSessionMarker(), e.getMessage()); throw e; @@ -87,24 +87,26 @@ public class NEXIOMetadataPersisterStep extends JobStep { return result; } - // private void uploadMeta(StoreUri storeUri, String fileName, byte[] metadata) throws Exception { - // logger.info(getMarker(), "Uploading metadata for {}", fileName); - // OutputStream outStream = null; - // try { - // FTPClient sourceFtp = ((FtpDirectoryLister) storeUri.getLister()).connect(); - // outStream = sourceFtp.storeFileStream(fileName + DOT_XML); - // if (outStream == null) - // throw new NullPointerException("Can not create: " + fileName + DOT_XML + " on FTP. Reply is:" + sourceFtp.getReplyString()); - // outStream.write(metadata); - // outStream.flush(); - // } catch (Exception e) { - // logger.catching(e); - // throw e; - // } finally { - // if (outStream != null) - // outStream.close(); - // storeUri.cleanUp(); - // } - // } + // private void uploadMeta(StoreUri storeUri, String fileName, byte[] metadata) + // throws Exception { + // logger.info(getMarker(), "Uploading metadata for {}", fileName); + // OutputStream outStream = null; + // try { + // FTPClient sourceFtp = ((FtpDirectoryLister) storeUri.getLister()).connect(); + // outStream = sourceFtp.storeFileStream(fileName + DOT_XML); + // if (outStream == null) + // throw new NullPointerException("Can not create: " + fileName + DOT_XML + " on + // FTP. Reply is:" + sourceFtp.getReplyString()); + // outStream.write(metadata); + // outStream.flush(); + // } catch (Exception e) { + // logger.catching(e); + // throw e; + // } finally { + // if (outStream != null) + // outStream.close(); + // storeUri.cleanUp(); + // } + // } } -- 2.54.0