-package user.jobengine.server.steps;\r
+package obsolate;\r
\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.JobStep;\r
+import user.jobengine.server.steps.StepEntry;\r
\r
public class AFakeStep extends JobStep {\r
int count = 10;\r
-package user.jobengine.server.steps;\r
+package obsolate;\r
\r
import java.util.UUID;\r
\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
import user.jobengine.server.JobEngineException;\r
+import user.jobengine.server.steps.JobStep;\r
+import user.jobengine.server.steps.StepEntry;\r
\r
public class DownloadStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
-package user.jobengine.server.steps;\r
+package obsolate;\r
\r
import java.util.ArrayList;\r
import java.util.List;\r
import user.jobengine.db.SceneContent;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.JobStep;\r
+import user.jobengine.server.steps.StepEntry;\r
\r
public class GetItemSourcesStep extends JobStep {\r
\r
-package user.jobengine.server.steps;\r
+package obsolate;\r
\r
import java.util.List;\r
\r
import user.jobengine.db.MediaFile;\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
+import user.jobengine.server.steps.JobStep;\r
+import user.jobengine.server.steps.StepEntry;\r
\r
public class ImportWriteDataToDBStep extends JobStep {\r
\r
}\r
\r
private void configure(IItemManager manager, Item item, List<Media> medias) {\r
- Store store = manager.getStore("Archívum gyorstár");\r
+ Store store = manager.getStore("Arch�vum gyorst�r");\r
item.setMedias(medias);\r
if (medias != null) {\r
for (Media media : medias) {\r
FileType fileType = manager.getFileType(media.getTitle());\r
if (fileType == null)\r
- fileType = manager.getFileType("bináris");\r
+ fileType = manager.getFileType("bin�ris");\r
List<MediaFile> files = media.getMediaFiles();\r
for (MediaFile file: files) {\r
file.setFileType(fileType);\r
-package user.jobengine.server.steps;\r
+package obsolate;\r
\r
import java.util.List;\r
\r
import user.jobengine.db.MediaFile;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.JobEngineException;\r
+import user.jobengine.server.steps.JobStep;\r
+import user.jobengine.server.steps.StepEntry;\r
\r
public class MediaDBWriterStep extends JobStep {\r
\r
-package user.jobengine.server.steps;\r
+package obsolate;\r
\r
import java.util.UUID;\r
\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
import user.jobengine.server.JobEngineException;\r
+import user.jobengine.server.steps.JobStep;\r
+import user.jobengine.server.steps.StepEntry;\r
\r
public class MediaDownloadStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
-package user.jobengine.server.steps;\r
+package obsolate;\r
\r
import java.util.List;\r
\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.JobStep;\r
+import user.jobengine.server.steps.StepEntry;\r
\r
public class MediaUploadStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
\r
import java.io.IOException;\r
import java.nio.file.Path;\r
+import java.sql.Timestamp;\r
+import java.util.Date;\r
\r
import org.apache.logging.log4j.LogManager;\r
import org.apache.logging.log4j.Logger;\r
String sourceFileName = inputFilePath.toFile().getName();\r
RemoteFile remoteFile = sourceUri.transferFrom(targetStoreUri, sourceFileName, sourceFileName);\r
\r
- MediaFile mediaFile = manager.createMediaFile(sourceFileName, fileType, targetStore, mediaCubeMedia);\r
- mediaCubeMedia.appendMediaFile(mediaFile);\r
+ saveMetadata(mediaCubeMedia, sourceFileName);\r
\r
} catch (Exception e) {\r
logger.catching(e);\r
return null;\r
}\r
\r
+ private void saveMetadata(Media mediaCubeMedia, String sourceFileName) {\r
+ MediaFile mediaFile = manager.createMediaFile(sourceFileName, fileType, targetStore, mediaCubeMedia);\r
+ mediaFile.add();\r
+ mediaCubeMedia.setPersister(manager);\r
+ mediaCubeMedia.setArchived(new Timestamp(new Date().getTime()));\r
+ mediaCubeMedia.modify();\r
+ }\r
+\r
private void setAndCheck(IJobEngine jobEngine, ArchiveItem archiveItem, Media mediaCubeMedia) throws JobEngineException, IOException {\r
manager = jobEngine.getItemManager();\r
if (manager == null)\r