{\r
"title": "PLAYOUT",\r
- "active": true,\r
+ "active": false,\r
"startInTray": false,\r
"enableNameOverride": false,\r
"player": {\r
{\r
"$type": "TrafficMetadata",\r
"server": {\r
- "address": "Data Source=folkloredb.hu\\sql08,33860;Initial Catalog=CLArchiveTF_0;Persist Security Info=True;",\r
+ "address": "Data Source=10.10.1.45\\sql16;Initial Catalog=PA_Echo;Persist Security Info=True;",\r
"userName": "MAM",\r
"password": "Echotv.hu",\r
"timeout": 5\r
"source": {\r
"$type": "UNCSource",\r
"local": {\r
- "address": "file://localhost/watch"\r
+ "address": "file://10.10.1.100/BRAAVOS/_TEST_/_ECHO/hirado/170901"\r
},\r
"remote": {\r
- "address": "ftp://localhost:21/watch",\r
- "userName": "dani",\r
- "password": "dani"\r
+ "address": "ftp://10.10.1.100:21/_TEST_/_ECHO/hirado/170901",\r
+ "userName": "mediacube",\r
+ "password": "Broadca5T"\r
}\r
},\r
"metadatas": [\r
{\r
"$type": "MediaCubeMetadata",\r
"server": {\r
- "address": "http://localhost:8080/services/rest/jobengine/",\r
- "userName": "dani",\r
- "password": "dani"\r
+ "address": "http://10.10.1.28:8080/services/rest/jobengine/",\r
+ "userName": "-",\r
+ "password": "-"\r
}\r
}\r
],\r
"outputFormat": "{0}-{1}",\r
"killDateDays": 1,\r
"remote": {\r
- "address": "ftp://localhost:21/out",\r
+ "address": "ftp://10.10.1.100:21/ARCHIVE",\r
"userName": "dani",\r
"password": "dani"\r
}\r
"createSubFolder": true,\r
"useMetadata": true,\r
"remote": {\r
- "address": "ftp://localhost:21/out",\r
+ "address": "ftp://10.10.1.100:21/READY",\r
"userName": "dani",\r
"password": "dani"\r
}\r
<stringAttribute key="org.eclipse.jdt.launching.JRE_CONTAINER" value="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>\r
<stringAttribute key="org.eclipse.jdt.launching.PROGRAM_ARGUMENTS" value="-os ${target.os} -ws ${target.ws} -arch ${target.arch} -nl ${target.nl} -consoleLog -console"/>\r
<stringAttribute key="org.eclipse.jdt.launching.SOURCE_PATH_PROVIDER" value="org.eclipse.pde.ui.workbenchClasspathProvider"/>\r
-<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Dorg.eclipse.equinox.http.jetty.http.port=8080 -Dorg.eclipse.epp.logging.aeri.skipReports=true -Declipse.ignoreApp=true -Dosgi.noShutdown=true -Djobengine.jobsteps.root="${workspace_loc}/user.jobengine.executors/config" -Djobengine.jobtemplates.root="${workspace_loc}/user.jobengine.executors/jobtemplates" -Djobengine.db.url=jdbc:db2://10.10.1.26:50000/mc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.db.user=db2admin -Djobengine.db.password=password -Djobengine.loglevel=INFO -Dlog4j.configurationFile="${workspace_loc}/-configuration/log4j2.xml" -Djobengine.jobsteps.alternate.root="${workspace_loc}/user.jobengine.executors/bin/user/jobengine/server/steps" -Djetty.home="${workspace_loc:}/-configuration/jetty" -Djetty.etc.config.urls=etc/user-jetty.xml,etc/user-jetty-ssl.xml,etc/user-jetty-ssl-context.xml,,etc/user-jetty-http.xml,etc/user-jetty-https.xml -Djobengine.octopus.api.address=http://10.10.1.21/api/v1 -Djobengine.octopus.api.user=mam -Djobengine.octopus.api.password=napocska -Djobengine.nosql.db.url=jdbc:db2://10.10.1.26:50000/mc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.nosql.db.user=db2admin -Djobengine.nosql.db.password=password -Djobengine.nosql.db.schema=test -Djobengine.selenio.address=http://10.10.1.71:44000/TranscodeMgrWS?wsdl -Djobengine.selenio.projectfilepath=\\10.10.1.71\Data\Blueprints\MP4_H264_AAC_v4.zenium -Djobengine.jobscheduling.config="${workspace_loc}/-configuration/scheduledjobs.json" -Dnexio.host=10.10.1.55"/>\r
+<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Dorg.eclipse.equinox.http.jetty.http.port=8080 -Dorg.eclipse.epp.logging.aeri.skipReports=true -Declipse.ignoreApp=true -Dosgi.noShutdown=true -Djobengine.jobsteps.root="${workspace_loc}/user.jobengine.executors/config" -Djobengine.jobtemplates.root="${workspace_loc}/user.jobengine.executors/jobtemplates" -Djobengine.db.url=jdbc:db2://10.10.1.28:50000/mc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.db.user=db2admin -Djobengine.db.password=password -Djobengine.loglevel=INFO -Dlog4j.configurationFile="${workspace_loc}/-configuration/log4j2.xml" -Djobengine.jobsteps.alternate.root="${workspace_loc}/user.jobengine.executors/bin/user/jobengine/server/steps" -Djetty.home="${workspace_loc:}/-configuration/jetty" -Djetty.etc.config.urls=etc/user-jetty.xml,etc/user-jetty-ssl.xml,etc/user-jetty-ssl-context.xml,,etc/user-jetty-http.xml,etc/user-jetty-https.xml -Djobengine.octopus.api.address=http://10.10.1.21/api/v1 -Djobengine.octopus.api.user=mam -Djobengine.octopus.api.password=napocska -Djobengine.nosql.db.url=jdbc:db2://10.10.1.28:50000/mc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.nosql.db.user=db2admin -Djobengine.nosql.db.password=password -Djobengine.nosql.db.schema=test -Djobengine.selenio.address=http://10.10.1.71:44000/TranscodeMgrWS?wsdl -Djobengine.selenio.projectfilepath=\\10.10.1.71\Data\Blueprints\MP4_H264_AAC_v4.zenium -Djobengine.jobscheduling.config="${workspace_loc}/-configuration/scheduledjobs.json" -Dnexio.host=10.10.1.55"/>\r
<stringAttribute key="pde.version" value="3.3"/>\r
<booleanAttribute key="show_selected_only" value="false"/>\r
<stringAttribute key="target_bundles" value="cglib@default:default,com.auth0.java-jwt@default:default,com.fasterxml.jackson.core.jackson-annotations@default:default,com.fasterxml.jackson.core.jackson-core@default:default,com.fasterxml.jackson.core.jackson-databind@default:default,com.fasterxml.jackson.dataformat.jackson-dataformat-yaml@default:default,com.fasterxml.jackson.datatype.jackson-datatype-joda@default:default,com.fasterxml.jackson.jaxrs.jackson-jaxrs-base@default:default,com.fasterxml.jackson.jaxrs.jackson-jaxrs-json-provider@default:default,com.fasterxml.jackson.module.jackson-module-jaxb-annotations@default:default,com.google.guava@default:default,com.ibm.db2jcc4@default:default,com.ibm.nosql@default:default,com.microsoft.sqlserver.sqljdbc@default:default,com.sun.el.javax.el@default:default,commons-logging@default:default,javassist@default:default,javax.annotation-api@default:default,javax.inject@default:default,javax.mail@default:default,javax.servlet-api@default:default,javax.servlet.jsp-api@default:default,javax.validation.api@default:default,javax.ws.rs-api@default:default,jcifs@default:default,joda-time@default:default,org.apache.aries.spifly.dynamic.bundle@default:default,org.apache.aries.util@default:default,org.apache.commons.beanutils@default:default,org.apache.commons.codec@default:default,org.apache.commons.collections@default:default,org.apache.commons.digester@default:default,org.apache.commons.io@default:default,org.apache.commons.lang3@default:default,org.apache.commons.lang@default:default,org.apache.commons.logging@default:default,org.apache.commons.net@default:default,org.apache.felix.gogo.command@default:default,org.apache.felix.gogo.runtime@default:default,org.apache.felix.gogo.shell@default:default,org.apache.httpcomponents.httpclient@default:default,org.apache.httpcomponents.httpcore@default:default,org.apache.jasper.glassfish@default:default,org.apache.logging.log4j.api@1:true,org.apache.logging.log4j.core@default:default,org.apache.logging.log4j.slf4j-impl@default:default,org.apache.servicemix.bundles.quartz@default:default,org.eclipse.equinox.common@2:true,org.eclipse.equinox.console@default:default,org.eclipse.equinox.ds@1:true,org.eclipse.equinox.util@default:default,org.eclipse.jdt.core.compiler.batch@default:default,org.eclipse.jetty.client@default:default,org.eclipse.jetty.deploy@default:default,org.eclipse.jetty.http@default:default,org.eclipse.jetty.io@default:default,org.eclipse.jetty.jsp@default:default,org.eclipse.jetty.osgi.boot.jsp@default:false,org.eclipse.jetty.osgi.boot@default:true,org.eclipse.jetty.schemas@default:default,org.eclipse.jetty.security@default:default,org.eclipse.jetty.server@default:default,org.eclipse.jetty.servlet@default:default,org.eclipse.jetty.util@default:default,org.eclipse.jetty.webapp@default:default,org.eclipse.jetty.websocket.api@default:default,org.eclipse.jetty.websocket.client@default:default,org.eclipse.jetty.websocket.common@default:default,org.eclipse.jetty.websocket.server@default:default,org.eclipse.jetty.websocket.servlet@default:default,org.eclipse.jetty.xml@default:default,org.eclipse.osgi.services@default:default,org.eclipse.osgi@-1:true,org.hamcrest.core@default:default,org.jboss.resteasy.client@default:default,org.jboss.resteasy.jaxrs@default:default,org.jmock.junit4@default:default,org.jmock@default:default,org.junit@default:default,org.jvnet.mimepull@default:default,org.objectweb.asm.commons@default:default,org.objectweb.asm.tree@default:default,org.objectweb.asm@default:default,org.reflections@default:default,slf4j.api@default:default,slf4j.simple@default:false"/>\r
<stringAttribute key="org.eclipse.jdt.launching.JRE_CONTAINER" value="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>\r
<stringAttribute key="org.eclipse.jdt.launching.PROGRAM_ARGUMENTS" value="-os ${target.os} -ws ${target.ws} -arch ${target.arch} -nl ${target.nl} -consoleLog -console"/>\r
<stringAttribute key="org.eclipse.jdt.launching.SOURCE_PATH_PROVIDER" value="org.eclipse.pde.ui.workbenchClasspathProvider"/>\r
-<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Dorg.eclipse.equinox.http.jetty.http.port=8080 -Dorg.eclipse.epp.logging.aeri.skipReports=true -Declipse.ignoreApp=true -Dosgi.noShutdown=true -Djobengine.jobsteps.root="${workspace_loc}/user.jobengine.executors/config" -Djobengine.jobtemplates.root="${workspace_loc}/user.jobengine.executors/jobtemplates" -Djobengine.db.url=jdbc:db2://localhost:50000/mc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.db.user=db2admin -Djobengine.db.password=salabakter -Djobengine.loglevel=INFO -Djobengine.rcc.host=localhost -Djobengine.rcc.defaultlowresprofile="WindowsMedia - Web Streaming - DSL or Cable Modem" -Dlog4j.configurationFile="${workspace_loc}/-configuration/log4j2.xml" -Djobengine.jobsteps.alternate.root="${workspace_loc}/user.jobengine.executors/bin/user/jobengine/server/steps" -Djobengine.transcoder.source=c:\_Movie\hires\ -Djetty.home="${workspace_loc:-configuration}/jetty" -Djetty.etc.config.urls=etc/user-jetty.xml,etc/user-jetty-ssl.xml,etc/user-jetty-ssl-context.xml,,etc/user-jetty-http.xml,etc/user-jetty-https.xml -Djobengine.octopus.api.address=http://10.10.1.21/api/v1 -Djobengine.octopus.api.user=mam -Djobengine.octopus.api.password=napocska -Djobengine.nosql.db.url=jdbc:db2://localhost:50000/mc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.nosql.db.user=db2admin -Djobengine.nosql.db.password=salabakter -Djobengine.nosql.db.schema=test -Djobengine.nexio.db.url=jdbc:sqlserver://10.10.1.59:1433;databaseName=NXDB; -Djobengine.nexio.db.user=sa -Djobengine.nexio.db.password=resolve -Djobengine.selenio.address=http://10.10.1.71:44000/TranscodeMgrWS?wsdl -Djobengine.selenio.projectfilepath=\\10.10.1.71\Data\Blueprints\MP4_H264_AAC_v4.zenium -Djobengine.jobscheduling.config="${workspace_loc}/-configuration/scheduledjobs.json""/>\r
+<stringAttribute key="org.eclipse.jdt.launching.VM_ARGUMENTS" value="-Dorg.eclipse.equinox.http.jetty.http.port=8080 -Dorg.eclipse.epp.logging.aeri.skipReports=true -Declipse.ignoreApp=true -Dosgi.noShutdown=true -Djobengine.jobsteps.root="${workspace_loc}/user.jobengine.executors/config" -Djobengine.jobtemplates.root="${workspace_loc}/user.jobengine.executors/jobtemplates" -Djobengine.db.url=jdbc:db2://localhost:50000/mc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.db.user=db2admin -Djobengine.db.password=salabakter -Djobengine.loglevel=INFO -Djobengine.rcc.host=localhost -Djobengine.rcc.defaultlowresprofile="WindowsMedia - Web Streaming - DSL or Cable Modem" -Dlog4j.configurationFile="${workspace_loc}/-configuration/log4j2.xml" -Djobengine.jobsteps.alternate.root="${workspace_loc}/user.jobengine.executors/bin/user/jobengine/server/steps" -Djobengine.transcoder.source=c:\_Movie\hires\ -Djetty.home="${workspace_loc:-configuration}/jetty" -Djetty.etc.config.urls=etc/user-jetty.xml,etc/user-jetty-ssl.xml,etc/user-jetty-ssl-context.xml,,etc/user-jetty-http.xml,etc/user-jetty-https.xml -Djobengine.octopus.api.address=http://10.10.1.21/api/v1 -Djobengine.octopus.api.user=mam -Djobengine.octopus.api.password=napocska -Djobengine.nosql.db.url=jdbc:db2://localhost:50000/mc:retrieveMessagesFromServerOnGetMessage=true; -Djobengine.nosql.db.user=db2admin -Djobengine.nosql.db.password=salabakter -Djobengine.nosql.db.schema=test -Djobengine.nexio.db.url=jdbc:sqlserver://10.10.1.59:1433;databaseName=NXDB; -Djobengine.nexio.db.user=sa -Djobengine.nexio.db.password=resolve -Djobengine.selenio.address=http://10.10.1.71:44000/TranscodeMgrWS?wsdl -Djobengine.selenio.projectfilepath=\\10.10.1.71\Data\Blueprints\MP4_H264_AAC_v4.zenium -Djobengine.jobscheduling.config="${workspace_loc}/-configuration/scheduledjobs.json" -Dnexio.host=10.10.1.55"/>\r
<stringAttribute key="pde.version" value="3.3"/>\r
<booleanAttribute key="show_selected_only" value="false"/>\r
<stringAttribute key="target_bundles" value="cglib@default:default,com.auth0.java-jwt@default:default,com.fasterxml.jackson.core.jackson-annotations@default:default,com.fasterxml.jackson.core.jackson-core@default:default,com.fasterxml.jackson.core.jackson-databind@default:default,com.fasterxml.jackson.dataformat.jackson-dataformat-yaml@default:default,com.fasterxml.jackson.datatype.jackson-datatype-joda@default:default,com.fasterxml.jackson.jaxrs.jackson-jaxrs-base@default:default,com.fasterxml.jackson.jaxrs.jackson-jaxrs-json-provider@default:default,com.fasterxml.jackson.module.jackson-module-jaxb-annotations@default:default,com.google.guava@default:default,com.ibm.db2jcc4@default:default,com.ibm.nosql@default:default,com.microsoft.sqlserver.sqljdbc@default:default,com.sun.el.javax.el@default:default,commons-logging@default:default,javassist@default:default,javax.annotation-api@default:default,javax.inject@default:default,javax.mail@default:default,javax.servlet-api@default:default,javax.servlet.jsp-api@default:default,javax.validation.api@default:default,javax.ws.rs-api@default:default,jcifs@default:default,joda-time@default:default,org.apache.aries.spifly.dynamic.bundle@default:default,org.apache.aries.util@default:default,org.apache.commons.beanutils@default:default,org.apache.commons.codec@default:default,org.apache.commons.collections@default:default,org.apache.commons.digester@default:default,org.apache.commons.io@default:default,org.apache.commons.lang3@default:default,org.apache.commons.lang@default:default,org.apache.commons.logging@default:default,org.apache.commons.net@default:default,org.apache.felix.gogo.command@default:default,org.apache.felix.gogo.runtime@default:default,org.apache.felix.gogo.shell@default:default,org.apache.httpcomponents.httpclient@default:default,org.apache.httpcomponents.httpcore@default:default,org.apache.jasper.glassfish@default:default,org.apache.logging.log4j.api@1:true,org.apache.logging.log4j.core@default:default,org.apache.logging.log4j.slf4j-impl@default:default,org.apache.servicemix.bundles.quartz@default:default,org.eclipse.equinox.common@2:true,org.eclipse.equinox.console@default:default,org.eclipse.equinox.ds@1:true,org.eclipse.equinox.util@default:default,org.eclipse.jdt.core.compiler.batch@default:default,org.eclipse.jetty.client@default:default,org.eclipse.jetty.deploy@default:default,org.eclipse.jetty.http@default:default,org.eclipse.jetty.io@default:default,org.eclipse.jetty.jsp@default:default,org.eclipse.jetty.osgi.boot.jsp@default:false,org.eclipse.jetty.osgi.boot@default:true,org.eclipse.jetty.schemas@default:default,org.eclipse.jetty.security@default:default,org.eclipse.jetty.server@default:default,org.eclipse.jetty.servlet@default:default,org.eclipse.jetty.util@default:default,org.eclipse.jetty.webapp@default:default,org.eclipse.jetty.websocket.api@default:default,org.eclipse.jetty.websocket.client@default:default,org.eclipse.jetty.websocket.common@default:default,org.eclipse.jetty.websocket.server@default:default,org.eclipse.jetty.websocket.servlet@default:default,org.eclipse.jetty.xml@default:default,org.eclipse.osgi.services@default:default,org.eclipse.osgi@-1:true,org.hamcrest.core@default:default,org.jboss.resteasy.client@default:default,org.jboss.resteasy.jaxrs@default:default,org.jmock.junit4@default:default,org.jmock@default:default,org.junit@default:default,org.jvnet.mimepull@default:default,org.objectweb.asm.commons@default:default,org.objectweb.asm.tree@default:default,org.objectweb.asm@default:default,org.reflections@default:default,slf4j.api@default:default,slf4j.simple@default:false"/>\r
package user.jobengine.server.steps;\r
\r
-import java.io.File;\r
-import java.nio.file.Path;\r
import java.util.ArrayList;\r
\r
import org.apache.logging.log4j.LogManager;\r
ListUtils.asMap(ARCHIVE_ITEM, archiveItem, GLOBAL_INPUT_FOLDER, globalInputFolder));\r
} catch (Exception e) {\r
if (archiveItem != null)\r
- removeCatchedFile(archiveItem.getCatchedFile());\r
+ archiveItem.removeCatchedFile();\r
throw e;\r
}\r
}\r
} catch (Exception e) {\r
logger.catching(e);\r
}\r
- return new Object[] {};\r
- }\r
-\r
- private void removeCatchedFile(Path catchedFilePath) {\r
- if (catchedFilePath != null) {\r
- File catchedFile = catchedFilePath.toFile();\r
- if (catchedFile.exists())\r
- catchedFile.delete();\r
- }\r
+ return null;\r
}\r
\r
}\r
*/\r
public class ArchiveListBuilderStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
- private static final String UTF8 = "utf-8";\r
+ // private static final String UTF8 = "utf-8";\r
private static final String CATCHED = "catched";\r
- private static final String STOREFOLDER = ".STORE";\r
+ private static final String STATUSFOLDER = ".STATUS";\r
private static final String MEDIAEXT = ".mxf";\r
private static final String JSONEXT = ".json";\r
private static final String CATCHEDEXT = ".catched";\r
return;\r
}\r
\r
- Path dotStorePath = Paths.get(mediaFilePath.getParent().toString(), STOREFOLDER);\r
+ Path dotStorePath = Paths.get(mediaFilePath.getParent().toString(), STATUSFOLDER);\r
Path catchedFilePath = Paths.get(dotStorePath.toString(), mediaFile.getName() + CATCHEDEXT);\r
File catchedFile = catchedFilePath.toFile();\r
if (catchedFile.exists()) {\r
--- /dev/null
+package user.jobengine.server.steps;\r
+\r
+import org.apache.logging.log4j.LogManager;\r
+import org.apache.logging.log4j.Logger;\r
+\r
+import user.commons.RemoteFile;\r
+import user.commons.StoreUri;\r
+import user.commons.remotestore.RemoteStoreProtocol;\r
+import user.jobengine.db.IItemManager;\r
+import user.jobengine.server.IJobEngine;\r
+import user.jobengine.server.IJobRuntime;\r
+\r
+public class DeleteMaterialsStep extends JobStep {\r
+ private static final Logger logger = LogManager.getLogger();\r
+ private static final String UTF8 = "utf-8";\r
+ private static final String STATUSFOLDER = ".STATUS";\r
+ private static final String MEDIAEXT = ".mxf";\r
+ private static final String KILLDATE = ".catched";\r
+\r
+ @StepEntry\r
+ public Object[] execute(String inputFolder, String userName, String password, IJobEngine jobEngine, IJobRuntime jobRuntime) {\r
+ //"\\\\10.10.1.100\\BRAAVOS\\ARCHIVE"\r
+ //"mediacube"\r
+ //"Broadca5T"\r
+ IItemManager manager = jobEngine.getItemManager();\r
+ StoreUri sourceUri = manager.createStoreUri(RemoteStoreProtocol.SMB, inputFolder);\r
+ sourceUri.setUserName(userName);\r
+ sourceUri.setPassword(password);\r
+ try {\r
+ sourceUri.getRemoteFiles(f -> processPathItem(f));\r
+ } catch (Exception e) {\r
+ logger.error("", e);\r
+ } finally {\r
+ }\r
+ return null;\r
+ }\r
+\r
+ private boolean processPathItem(RemoteFile remoteFile) {\r
+ //KILLDATE\r
+ //{0}.{1}.KILLDATE\r
+\r
+ //MODIFIED\r
+\r
+ //NAME PATTERN\r
+\r
+ return true;\r
+ }\r
+}\r
--- /dev/null
+package user.jobengine.server.steps;\r
+\r
+import org.apache.logging.log4j.LogManager;\r
+import org.apache.logging.log4j.Logger;\r
+\r
+import user.commons.RemoteFile;\r
+import user.jobengine.server.IJobEngine;\r
+import user.jobengine.server.IJobRuntime;\r
+\r
+public class NexioDeleteMaterialsStep extends JobStep {\r
+ private static final Logger logger = LogManager.getLogger();\r
+\r
+ @StepEntry\r
+ public Object[] execute(String inputFolder, IJobEngine jobEngine, IJobRuntime jobRuntime) {\r
+\r
+ try {\r
+ } catch (Exception e) {\r
+ logger.error("", e);\r
+ } finally {\r
+ }\r
+ return null;\r
+ }\r
+\r
+ private boolean processPathItem(RemoteFile remoteFile) {\r
+ //MODIFIED\r
+\r
+ //NAME PATTERN\r
+\r
+ //AGENCY\r
+\r
+ return true;\r
+ }\r
+}\r
private Timestamp modify;\r
private long size;\r
private boolean isFolder = false;;\r
+ private Object sourceObject = null;\r
\r
@XmlJavaTypeAdapter(TimestampAdapter.class)\r
public Timestamp getCreated() {\r
return created;\r
}\r
\r
+ public String getExtension() {\r
+ String result = null;\r
+ if (name != null) {\r
+ if (name.contains("."))\r
+ result = name.substring(name.lastIndexOf(".") + 1);\r
+ }\r
+ return result;\r
+ }\r
+\r
public boolean getIsFolder() {\r
return isFolder;\r
}\r
return size;\r
}\r
\r
+ public Object getSourceObject() {\r
+ return sourceObject;\r
+ }\r
+\r
public void setCreated(Timestamp created) {\r
this.created = created;\r
}\r
this.size = size;\r
}\r
\r
- public String getExtension() {\r
- String result = null;\r
- if (name != null) {\r
- if (name.contains("."))\r
- result = name.substring(name.lastIndexOf(".") + 1);\r
- }\r
- return result;\r
+ public void setSourceObject(Object sourceObject) {\r
+ this.sourceObject = sourceObject;\r
}\r
}\r
}\r
}\r
\r
+ @Override\r
+ public void delete(RemoteFile remoteFile) {\r
+ // TODO Auto-generated method stub\r
+\r
+ }\r
+\r
@Override\r
public RemoteFile get(String fileName) throws Exception {\r
RemoteFile result = null;\r
\r
void cleanUp() throws Exception;\r
\r
+ void delete(RemoteFile remoteFile) throws Exception;\r
+\r
RemoteFile get(String fileName) throws Exception;\r
\r
InputStream getInputStream(RemoteFile remoteFile) throws Exception;\r
public void cleanUp() {\r
}\r
\r
+ @Override\r
+ public void delete(RemoteFile remoteFile) {\r
+ // TODO Auto-generated method stub\r
+\r
+ }\r
+\r
@Override\r
public RemoteFile get(String fileName) throws Exception {\r
String path = storeUri.toString(true);\r
import java.util.List;\r
\r
import jcifs.smb.NtlmPasswordAuthentication;\r
+import jcifs.smb.SmbException;\r
import jcifs.smb.SmbFile;\r
import user.commons.IRemoteFileListCallback;\r
import user.commons.RemoteFile;\r
public void cleanUp() throws Exception {\r
}\r
\r
+ @Override\r
+ public void delete(RemoteFile remoteFile) throws Exception {\r
+ if (remoteFile.getSourceObject() instanceof SmbFile) {\r
+ SmbFile smbFile = (SmbFile) remoteFile.getSourceObject();\r
+ try {\r
+ smbFile.delete();\r
+ } catch (SmbException e) {\r
+ throw new Exception("Can not delete file.", e);\r
+ }\r
+ }\r
+ }\r
+\r
@Override\r
public RemoteFile get(String fileName) throws Exception {\r
RemoteFile result = null;\r
result.setModify(new Timestamp(file.getLastModified()));\r
result.setIsFolder((file.getAttributes() & SmbFile.ATTR_DIRECTORY) == SmbFile.ATTR_DIRECTORY);\r
result.setSize(file.length());\r
+ result.setSourceObject(file);\r
return result;\r
}\r
}\r
client.disconnect();\r
}\r
\r
+ @Override\r
+ public void delete(RemoteFile remoteFile) {\r
+ // TODO Auto-generated method stub\r
+\r
+ }\r
+\r
@Override\r
public RemoteFile get(String fileName) throws Exception {\r
RemoteFile result = null;\r
<custom-attributes org.zkoss.zul.listbox.rod="true" />\r
<custom-attributes org.zkoss.zul.listbox.initRodSize="50" />\r
<custom-attributes org.zkoss.zul.listbox.preloadSize="50" />\r
- \r
- <div id="scdiv" width="100%" height="100%" apply="org.zkoss.bind.BindComposer" viewModel="@id('svm') @init('user.jobengine.zk.model.SearchModel')" >\r
- \r
+\r
+ <div id="scdiv" width="100%" height="100%" apply="org.zkoss.bind.BindComposer" viewModel="@id('svm') @init('user.jobengine.zk.model.SearchModel')">\r
+\r
\r
<borderlayout>\r
<west border="none" size="25%" splittable="true" minsize="250">\r
<div height="100%" width="100%">\r
<groupbox vflex="min" closable="false">\r
- <caption sclass="boldfont" label="Kereső kifejezés:" />\r
- <!-- label sclass="boldfont" value="Itemek keresése:" width="180px" / -->\r
- <textbox style="border:none" instant="true" value="@bind(svm.searchValue)" width="300px" tooltiptext="Keresőérték"/>\r
- <button sclass="buttonboldfont" label="${labels.button_search}" onClick="@command('doSearch')" autodisable="self" />\r
+ <caption sclass="boldfont" label="Kereső" />\r
+ <textbox style="border:none" instant="true" value="@bind(svm.searchValue)" width="100%" tooltiptext="Keresőérték"\r
+ onOK="@command('doSearch')" />\r
+ <!-- <button sclass="buttonboldfont" label="${labels.button_search}" onClick="@command('doSearch')" autodisable="self" /> -->\r
</groupbox>\r
- \r
- <listbox id="itemResults" model="@load(svm.searchResult)" multiple="false" autopaging="true" mold="paging" vflex="true" \r
- selectedItem="@bind(svm.selectedItem)" style="border: none; background: #e3e3e3 !important;" oddRowSclass="listbox-odd-style" sclass="listbox-normal-style" >\r
- <listhead>\r
- <listheader label="Id" width="70px" sort="auto(id)" align="left"/>\r
- <listheader label="Cím" width="120px" sort="auto(status)" align="left"/>\r
- <listheader label="Leírás" width="120px" sort="auto(tipus)" align="left"/>\r
- </listhead>\r
- \r
- <template name="model">\r
- <listitem>\r
- <listcell label="@load(each.id)"/>\r
- <listcell label="@load(each.title)"/>\r
- <listcell label="@load(each.description)"/>\r
- </listitem>\r
- </template>\r
- </listbox>\r
- \r
- <!-- label sclass="boldfont" value="Media list: " width="180px" / -->\r
+\r
<groupbox vflex="true" closable="false">\r
- <caption sclass="boldfont" label="Media list:" />\r
- \r
- <listbox id="mediaList" onSelect="@command('onSelectMedia', media=event.reference.value)" model="@load(svm.selectedItem.medias)" multiple="false" vflex="true"\r
- selectedItem="@bind(svm.selectedMedia)" style="border: none; background: #e3e3e3 !important;" oddRowSclass="listbox-odd-style" sclass="listbox-normal-style" >\r
- <listhead>\r
- <listheader label="Id" width="70px" sort="auto(id)" align="left"/>\r
- <listheader label="Cím" width="120px" sort="auto(status)" align="left"/>\r
- <listheader label="Leírás" width="120px" sort="auto(tipus)" align="left"/>\r
- </listhead>\r
- \r
- <template name="model">\r
- <listitem>\r
- <listcell label="@load(each.id)"/>\r
- <listcell label="@load(each.title)"/>\r
- <listcell label="@load(each.description)"/>\r
- </listitem>\r
- </template>\r
- </listbox>\r
+ <caption sclass="boldfont" label="Találatok" />\r
+ <listbox id="itemResults" model="@load(svm.searchResult)" multiple="false" autopaging="true" mold="paging" vflex="true"\r
+ selectedItem="@bind(svm.selectedItem)" style="border: none; background: #e3e3e3 !important;" oddRowSclass="listbox-odd-style"\r
+ sclass="listbox-normal-style">\r
+ <listhead>\r
+ <listheader label="Id" width="70px" sort="auto(id)" align="left" />\r
+ <listheader label="Cím" width="120px" sort="auto(status)" align="left" />\r
+ <listheader label="Leírás" width="120px" sort="auto(tipus)" align="left" />\r
+ </listhead>\r
+\r
+ <template name="model">\r
+ <listitem>\r
+ <listcell label="@load(each.id)" />\r
+ <listcell label="@load(each.title)" />\r
+ <listcell label="@load(each.description)" />\r
+ </listitem>\r
+ </template>\r
+ </listbox>\r
</groupbox>\r
- \r
+\r
+ <groupbox vflex="true" closable="false">\r
+ <caption sclass="boldfont" label="Kapcsolódó anyagok" />\r
+\r
+ <listbox id="mediaList" onSelect="@command('onSelectMedia', media=event.reference.value)" model="@load(svm.selectedItem.medias)"\r
+ multiple="false" vflex="true" selectedItem="@bind(svm.selectedMedia)" style="border: none; background: #e3e3e3 !important;"\r
+ oddRowSclass="listbox-odd-style" sclass="listbox-normal-style">\r
+ <listhead>\r
+ <listheader label="Id" width="70px" sort="auto(id)" align="left" />\r
+ <listheader label="Cím" width="120px" sort="auto(status)" align="left" />\r
+ <listheader label="Leírás" width="120px" sort="auto(tipus)" align="left" />\r
+ </listhead>\r
+\r
+ <template name="model">\r
+ <listitem>\r
+ <listcell label="@load(each.id)" />\r
+ <listcell label="@load(each.title)" />\r
+ <listcell label="@load(each.description)" />\r
+ </listitem>\r
+ </template>\r
+ </listbox>\r
+ </groupbox>\r
+\r
</div>\r
</west>\r
<!-- media player -->\r
<center border="none">\r
- \r
+\r
<borderlayout height="100%" width="100%">\r
<north border="none" size="90%" splittable="true">\r
<div align="center" height="100%" width="100%" visible="@load(svm.hasLowresMediaFile)">\r
- <label value="@bind(svm.selectedMedia.description)" />\r
- <iframe id="mediaPlayer" height="100%" width="100%" autohide="false" src="@load(svm.lowresMediaFilePath)">\r
- </iframe>\r
+ <label value="@bind(svm.selectedMedia.description)" />\r
+ <iframe id="mediaPlayer" height="100%" width="100%" autohide="false" src="@load(svm.lowresMediaFilePath)"></iframe>\r
</div>\r
</north>\r
<south border="none" size="10%">\r
<div align="center" height="100%" width="100%" visible="@load(svm.hasTSMMediaFile)">\r
- <button label="Visszatöltés" onClick="@command('downloadMedia')" autodisable="self" disabled="@load(not svm.hasTSMMediaFile)" sclass="buttonboldfont" />\r
+ <button label="Visszatöltés" onClick="@command('downloadMedia')" autodisable="self" disabled="@load(not svm.hasTSMMediaFile)"\r
+ sclass="buttonboldfont" />\r
</div>\r
</south>\r
</borderlayout>\r
- \r
+\r
</center>\r
</borderlayout>\r
\r
- \r
+\r
</div>\r
</zk>
\ No newline at end of file
\r
import org.apache.logging.log4j.LogManager;\r
import org.apache.logging.log4j.Logger;\r
-import org.eclipse.core.runtime.adaptor.EclipseStarter;\r
import org.eclipse.osgi.framework.console.CommandInterpreter;\r
import org.eclipse.osgi.framework.console.CommandProvider;\r
-import org.osgi.framework.Bundle;\r
-import org.osgi.framework.BundleContext;\r
-import org.osgi.framework.FrameworkUtil;\r
-import org.osgi.framework.wiring.BundleRevision;\r
\r
public class ConsoleCommandProvider implements CommandProvider {\r
private static final Logger logger = LogManager.getLogger();\r
@SuppressWarnings("restriction")\r
public Object _halt(CommandInterpreter intp) {\r
StringBuffer buffer = new StringBuffer();\r
- Thread shutdownThread = new Thread(() -> {\r
- try {\r
- Thread.sleep(1000);\r
- BundleContext bundleContext = FrameworkUtil.getBundle(this.getClass()).getBundleContext();\r
- if (bundleContext != null) {\r
- Bundle[] bundles = bundleContext.getBundles();\r
- for (Bundle b : bundles) {\r
- if ((b.adapt(BundleRevision.class).getTypes() & BundleRevision.TYPE_FRAGMENT) != 0)\r
- continue;\r
- if ("org.eclipse.equinox.ds".equals(b.getSymbolicName()))\r
- continue;\r
- if ("user.jobengine.osgi.commons".equals(b.getSymbolicName()))\r
- continue;\r
-\r
- logger.info("Stopping {} ", b.getSymbolicName());\r
- b.stop();\r
- }\r
- }\r
- EclipseStarter.shutdown();\r
-\r
- System.exit(0);\r
- } catch (Exception e) {\r
- logger.error("Error:", e);\r
- }\r
- });\r
- buffer.append("Shutdown initiated");\r
- shutdownThread.start();\r
+ // Thread shutdownThread = new Thread(() -> {\r
+ // try {\r
+ // Thread.sleep(1000);\r
+ // BundleContext bundleContext = FrameworkUtil.getBundle(this.getClass()).getBundleContext();\r
+ // if (bundleContext != null) {\r
+ // Bundle[] bundles = bundleContext.getBundles();\r
+ // for (Bundle b : bundles) {\r
+ // if ((b.adapt(BundleRevision.class).getTypes() & BundleRevision.TYPE_FRAGMENT) != 0)\r
+ // continue;\r
+ // if ("org.eclipse.equinox.ds".equals(b.getSymbolicName()))\r
+ // continue;\r
+ // if ("user.jobengine.osgi.commons".equals(b.getSymbolicName()))\r
+ // continue;\r
+ //\r
+ // logger.info("Stopping {} ", b.getSymbolicName());\r
+ // b.stop();\r
+ // }\r
+ // }\r
+ // EclipseStarter.shutdown();\r
+ //\r
+ // System.exit(0);\r
+ // } catch (Exception e) {\r
+ // logger.error("Error:", e);\r
+ // }\r
+ // });\r
+ // shutdownThread.start();\r
+ // buffer.append("Shutdown initiated");\r
+ buffer.append("...and catch fire!");\r
return buffer.toString();\r
}\r
\r
//protocol + address + relativepath\r
//store.getStoreUris().get(0).getProtocol().getValue()\r
ret = Paths.get(store.getStoreUris().get(0).toString(false), mf.getRelativePath()).toString();\r
+ break;\r
}\r
}\r
}\r
+\r
+ ret = "http://10.10.1.28:90/";\r
return ret;\r
}\r
\r
}\r
return ret;\r
}\r
-\r
+ \r
public boolean getHasSelectedMediaFile(){\r
String mediaFilePath =getMediaFilePath();\r
return (mediaFilePath != null && !"".equals(mediaFilePath));\r
}\r
\r
@Command\r
- @NotifyChange({ "mediaFilePath", "hasSelectedMediaFile", "hasLowresMediaFile" })\r
+ @NotifyChange({ "mediaFilePath", "hasSelectedMediaFile", "hasLowresMediaFile", "lowresMediaFilePath", "hasTSMMediaFile" })\r
public void onSelectMedia(@BindingParam("media") Media m) {\r
this.selectedMedia = m;\r
}\r
https://git.useribm.hu / mediacube.git / commitdiff