git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...
authorVásáry Dániel <daniel.vasary@userrendszerhaz.hu>
Wed, 20 Dec 2017 15:39:04 +0000 (15:39 +0000)
committerVásáry Dániel <daniel.vasary@userrendszerhaz.hu>
Wed, 20 Dec 2017 15:39:04 +0000 (15:39 +0000)
21 files changed:
client/DxPlay/Properties/AssemblyInfo.cs
client/Maestro/Configuration/-configuration-nle.json [moved from client/Maestro/Configuration/configuration-nle.json with 100% similarity]
client/Maestro/Configuration/-configuration-studio.json [moved from client/Maestro/Configuration/configuration-studio.json with 100% similarity]
client/Maestro/Configuration/configuration-playout-ingest.json [moved from client/Maestro/Configuration/-configuration-playout-ingest.json with 95% similarity]
client/Maestro/Installer/installforge-installer-project.ifp
client/Maestro/Maestro.csproj
client/Maestro/Properties/AssemblyInfo.cs
client/MaestroShared/Metadata/Timecode.cs
server/-configuration/debug-mediacube-remote.launch
server/-configuration/scheduledjobs.json
server/-product/mediacube.product
server/user.jobengine.executors/src/user/jobengine/server/steps/CopyForArchiveNEXIOMaterialsStep.java
server/user.jobengine.executors/src/user/jobengine/server/steps/OctopusDataMiner.java
server/user.jobengine.executors/test-deploy-steps-to-bsh-bkup.bat [moved from server/user.jobengine.executors/deploy-steps-to-bsh-bkup.bat with 89% similarity]
server/user.jobengine.executors/test-deploy-steps-to-bsh-bkup.launch [moved from server/user.jobengine.executors/deploy-steps-to-bsh-bkup.launch with 83% similarity]
server/user.jobengine.executors/test-deploy-steps-to-bsh-main.bat [new file with mode: 0644]
server/user.jobengine.executors/test-deploy-steps-to-bsh-main.launch [new file with mode: 0644]
server/user.jobengine.osgi.db/src/user/jobengine/db/Media.java
server/user.jobengine.osgi.server/pages/index.zul
server/user.jobengine.osgi.server/pages/search_items.zul
server/user.jobengine.osgi.services/src/user/jobengine/osgi/rest/octopus/OctopusRESTService.java

index 83b07a225faf697fe125b260d9fa7d5a9c5cd2b8..97fa846a5484a7e9581c96906ebcadf8b64743b7 100644 (file)
@@ -26,7 +26,7 @@ using System.Runtime.CompilerServices;
 // You can specify all the values or you can default the Revision and Build Numbers \r
 // by using the '*' as shown below:\r
 \r
-[assembly: AssemblyVersion("2.0.6.9")]\r
+[assembly: AssemblyVersion("2.0.7.0")]\r
 \r
 //\r
 // In order to sign your assembly you must specify a key to use. Refer to the \r
@@ -56,5 +56,5 @@ using System.Runtime.CompilerServices;
 [assembly: AssemblyDelaySign(false)]\r
 [assembly: AssemblyKeyFile("")]\r
 [assembly: AssemblyKeyName("")]\r
-[assembly: AssemblyFileVersion("2.0.6.9")]\r
+[assembly: AssemblyFileVersion("2.0.7.0")]\r
 \r
similarity index 95%
rename from client/Maestro/Configuration/-configuration-playout-ingest.json
rename to client/Maestro/Configuration/configuration-playout-ingest.json
index aa818ef78d9a56e12fce43f666f94ee12d06375c..04854ee1a0d703f8a93d4aef598ce3dc0c766953 100644 (file)
@@ -12,7 +12,7 @@
     "$type": "UNCSource",\r
     "filter": "avi,wav,mxf",\r
     "local": {\r
-      "address": "file://10.10.1.100/BRAAVOS/READY",\r
+      "address": "file://10.10.1.100/BRAAVOS/PLAYOUT/Video",\r
       "userName": "mediacube",\r
       "password": "Dn8t4gfHcK98o8hyPgLDhr5SgSji4JCxsfpMJsODikUp3nXgrM0UNCi45lLAK8ZOnmEneO44P9qpJ4QDqhctN6MxZodjJgdZTyoZKmSa+ECzEzLr/wPYNgxVaXrVotEy",\r
       "timeout": 1000\r
index a59de308abf132099858b570da9dccd62ebb5560..72c89d73dc667034b2ac89be17be32aee41f1dca 100644 (file)
Binary files a/client/Maestro/Installer/installforge-installer-project.ifp and b/client/Maestro/Installer/installforge-installer-project.ifp differ
index 16808a978fd89cf45826b04edf9a527ffaa33b54..ee0d9d0b51f8c428273220177b3086b8806db7a6 100644 (file)
     <None Include="Configuration\-configuration-editor.json">\r
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>\r
     </None>\r
-    <None Include="Configuration\configuration-nle.json">\r
+    <None Include="Configuration\-configuration-nle.json">\r
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>\r
     </None>\r
-    <None Include="Configuration\-configuration-playout-ingest.json">\r
+    <None Include="Configuration\configuration-playout-ingest.json">\r
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>\r
     </None>\r
     <None Include="Configuration\-configuration-tqc-check.json">\r
     <None Include="Configuration\-configuration-sxs.json">\r
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>\r
     </None>\r
-    <None Include="Configuration\configuration-studio.json">\r
+    <None Include="Configuration\-configuration-studio.json">\r
       <CopyToOutputDirectory>Always</CopyToOutputDirectory>\r
     </None>\r
   </ItemGroup>\r
index 571031c3e91f58d1bf684667a27176b97e5bf878..6f5109cc49d2180ca5849104057fb5b97b5e4a81 100644 (file)
@@ -32,5 +32,5 @@ using System.Runtime.InteropServices;
 // You can specify all the values or you can default the Build and Revision Numbers\r
 // by using the '*' as shown below:\r
 // [assembly: AssemblyVersion("1.0.*")]\r
-[assembly: AssemblyVersion("2.0.6.9")]\r
-[assembly: AssemblyFileVersion("2.0.6.9")]\r
+[assembly: AssemblyVersion("2.0.7.0")]\r
+[assembly: AssemblyFileVersion("2.0.7.0")]\r
index 254c1517366e1af68715ff63195c1de65de5b413..6ef6bd5520b9351e2b4811f227acf1f786bbbc7c 100644 (file)
@@ -16,8 +16,10 @@ namespace MaestroShared.Metadata {
         }\r
 \r
         public Timecode(int frames, float frameRate) {\r
-            this.frameRate = frameRate; \r
-            Set(frames);\r
+            this.frameRate = frameRate;\r
+            //Set(frames);\r
+            startFrame = frames;   \r
+            currentFrame = frames;\r
         }\r
 \r
         public Timecode(Timecode tc) {\r
index b715dd617238cffce6e4c46c700826a987fe5c33..4a99bae5a323aa8999953d1ca0c1338e83296ee9 100644 (file)
@@ -10,7 +10,7 @@
 <stringAttribute key="org.eclipse.debug.core.source_locator_memento" value="&lt;?xml version=&quot;1.0&quot; encoding=&quot;UTF-8&quot; standalone=&quot;no&quot;?&gt;&#13;&#10;&lt;sourceLookupDirector&gt;&#13;&#10;&lt;sourceContainers duplicates=&quot;false&quot;&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;javaProject name=&amp;quot;user.commons.log4j2&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.javaProject&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;javaProject name=&amp;quot;user.jobengine.executors&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.javaProject&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;javaProject name=&amp;quot;user.jobengine.osgi.commons&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.javaProject&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;javaProject name=&amp;quot;user.jobengine.osgi.db&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.javaProject&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;javaProject name=&amp;quot;user.jobengine.osgi.server&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.javaProject&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zkcharts.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/classes&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/commons-codec-1.10.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/commons-fileupload-1.2.1.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/commons-io-1.4.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/commons-logging-1.1.1.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zcommon.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zel.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zhtml.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_bsh.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_commons-collections.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_elinez.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_eplotz.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_Filters.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_flashchart.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_gmapsz.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_jackson-annotations.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_jackson-core.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_jackson-databind.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_jasperreports.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_javassist.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_jcommon.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_jfreechart.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_jsp.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_monitor.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_psz.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_sapphire.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_shchart.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_silvertail.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_timelinez.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_timeplotz.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk_zuljsp.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zk.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zkbind.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zkex_r.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zkmax.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zkplus.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zml.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zsoup.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zul.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zuti.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;packageFragmentRoot handle=&amp;quot;=user.jobengine.osgi.server/WEB-INF\/lib\/zweb.jar&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.packageFragmentRoot&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;javaProject name=&amp;quot;user.jobengine.osgi.services&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.javaProject&quot;/&gt;&#13;&#10;&lt;container memento=&quot;&amp;lt;?xml version=&amp;quot;1.0&amp;quot; encoding=&amp;quot;UTF-8&amp;quot; standalone=&amp;quot;no&amp;quot;?&amp;gt;&amp;#13;&amp;#10;&amp;lt;javaProject name=&amp;quot;user.tsm.client&amp;quot;/&amp;gt;&amp;#13;&amp;#10;&quot; typeId=&quot;org.eclipse.jdt.launching.sourceContainer.javaProject&quot;/&gt;&#13;&#10;&lt;/sourceContainers&gt;&#13;&#10;&lt;/sourceLookupDirector&gt;&#13;&#10;"/>\r
 <booleanAttribute key="org.eclipse.jdt.launching.ALLOW_TERMINATE" value="false"/>\r
 <mapAttribute key="org.eclipse.jdt.launching.CONNECT_MAP">\r
-<mapEntry key="hostname" value="10.10.1.29"/>\r
+<mapEntry key="hostname" value="10.10.1.28"/>\r
 <mapEntry key="port" value="8888"/>\r
 </mapAttribute>\r
 <stringAttribute key="org.eclipse.jdt.launching.PROJECT_ATTR" value="user.jobengine.osgi.server"/>\r
index 47183e21f07527b7ac6126014942e4de12f2af77..092f719ce889047c7f45b921e8d16d4d70fd9399 100644 (file)
       "parameters": [ {"name": "itemID", "value": 1, "type": "java.lang.Long"} ]\r
        },\r
        {\r
-      "active": true,\r
+      "active": false,\r
          "name" : "Teszt folyamat",\r
       "template": "fake-noparams.xml",\r
       "executeimmediate": false,\r
index 82fbbf900f873c6a4964da53cc754768dc8076a4..02f309505cab019f9607647f77bd4bc7c422fd75 100644 (file)
@@ -9,23 +9,23 @@
    <launcherArgs>\r
       <programArgs>-consoleLog -console 5555\r
       </programArgs>\r
-      <vmArgs>-Xms512m\r
--Xmx1024m\r
--Dfile.encoding=UTF-8\r
--agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=8888\r
--Djavax.ws.rs.ext.RuntimeDelegate=org.jboss.resteasy.spi.ResteasyProviderFactory\r
-\r
-#System\r
--Djetty.home=/opt/mediacube/configuration/jetty\r
--Dlog4j.configurationFile=/opt/mediacube/configuration/log4j2.xml\r
--Djobengine.jobsteps.root=/opt/mediacube/configuration/executors\r
--Djobengine.jobtemplates.root=/opt/mediacube/configuration/jobtemplates\r
--Djobengine.jobscheduling.config=/opt/mediacube/configuration/scheduledjobs.json\r
-\r
--Dorg.eclipse.epp.logging.aeri.skipReports=true \r
--Declipse.ignoreApp=true \r
--Dosgi.noShutdown=true\r
--Djobengine.loglevel=INFO\r
+      <vmArgs>-Xms512m
+-Xmx1024m
+-Dfile.encoding=UTF-8
+-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=8888
+-Djavax.ws.rs.ext.RuntimeDelegate=org.jboss.resteasy.spi.ResteasyProviderFactory
+
+#System
+-Djetty.home=/opt/mediacube/configuration/jetty
+-Dlog4j.configurationFile=/opt/mediacube/configuration/log4j2.xml
+-Djobengine.jobsteps.root=/opt/mediacube/configuration/executors
+-Djobengine.jobtemplates.root=/opt/mediacube/configuration/jobtemplates
+-Djobengine.jobscheduling.config=/opt/mediacube/configuration/scheduledjobs.json
+
+-Dorg.eclipse.epp.logging.aeri.skipReports=true 
+-Declipse.ignoreApp=true 
+-Dosgi.noShutdown=true
+-Djobengine.loglevel=INFO
 -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\r
       </vmArgs>\r
       <vmArgsLin>#Database
index 262c54ff8d7429c3399d6051059c7390afd7f5e9..655e8cf8c69604be6ea4bba9c9070ab20d4ad672 100644 (file)
@@ -75,30 +75,24 @@ public class CopyForArchiveNEXIOMaterialsStep extends JobStep {
        private void copy(RundownArchive rundownArchive) throws Exception {\r
                for (StoryArchive storyArchive : rundownArchive.getStoryArchives()) {\r
                        for (FileArchive fileArchive : storyArchive.getFileArchives()) {\r
-                               copyFile(fileArchive, rundownArchive, storyArchive);\r
+                               try {\r
+                                       copyFile(fileArchive, rundownArchive, storyArchive);\r
+                               } catch (Exception e) {\r
+                                       logger.error(getMarker(), "A '{}' clip archiválása sikertelen. A rendszer üzenete: {}", fileArchive.getFileName(), e.getMessage());\r
+                               }\r
                        }\r
                }\r
        }\r
 \r
        private void copyFile(FileArchive fileArchive, RundownArchive rundownArchive, StoryArchive storyArchive) throws Exception {\r
-               String fileName = fileArchive.getFileName();\r
-               //TODO file existance\r
-               //              targetFtp = ((FtpDirectoryLister) RemoteFileHandler.createLister(targetUri)).connect();\r
-               //              int version = 1;\r
-               //              while (true) {\r
-               //                      targetFtp.listNames(arg0)\r
-               //              }\r
-               //\r
-               //              if (targetUri != null)\r
-               //                      targetUri.cleanUp();\r
+               String origFileName = fileArchive.getFileName();\r
+               String fileName = String.format("%s-%s", origFileName, rundownArchive.getItemHouseId());\r
                String videoFileName = fileName + MXFEXT;\r
 \r
-               transferFile(videoFileName);\r
+               transferFile(origFileName + MXFEXT, videoFileName);\r
                BasicDBObject metadata = createMetadata(rundownArchive, storyArchive, fileArchive);\r
                transferMetadata(videoFileName, metadata);\r
-               //targetFtp.changeToParentDirectory();\r
-               createSourceKillDateFile(rundownArchive, fileName);\r
-\r
+               createSourceKillDateFile(rundownArchive, origFileName);\r
        }\r
 \r
        private BasicDBObject createMetadata(RundownArchive rundownArchive, StoryArchive storyArchive, FileArchive fileArchive) {\r
@@ -127,10 +121,10 @@ public class CopyForArchiveNEXIOMaterialsStep extends JobStep {
        }\r
 \r
        private void createSourceKillDateFile(RundownArchive rundownArchive, String fileName) throws Exception {\r
-               //sourceFtp = ((FtpDirectoryLister) RemoteFileHandler.createLister(sourceUri)).connect();\r
+               logger.info("Create killdate/agency for {}", fileName);\r
                OutputStream outStream = null;\r
                try {\r
-                       sourceFtp.enterLocalActiveMode();\r
+                       sourceFtp = ((FtpDirectoryLister) sourceUri.getLister()).connect();\r
                        Calendar killDate = CalendarUtils.createCalendar(rundownArchive.getScheduleDate());\r
                        killDate.add(Calendar.DAY_OF_YEAR, nexioKillDateDays);\r
                        byte[] killDateFile = EscortFiles.createNEXIOKillDateFile(fileName, killDate.getTime(), null, nexioAgency);\r
@@ -146,8 +140,7 @@ public class CopyForArchiveNEXIOMaterialsStep extends JobStep {
                } finally {\r
                        if (outStream != null)\r
                                outStream.close();\r
-                       //                      if (sourceUri != null)\r
-                       //                              sourceUri.cleanUp();\r
+                       sourceUri.cleanUp();\r
                }\r
        }\r
 \r
@@ -164,16 +157,32 @@ public class CopyForArchiveNEXIOMaterialsStep extends JobStep {
                        return null;\r
                }\r
 \r
-               sourceFtp = ((FtpDirectoryLister) sourceUri.getLister()).connect();\r
-               targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
                processRundowns(rundowns);\r
-               if (sourceUri != null)\r
-                       sourceUri.cleanUp();\r
-               if (targetUri != null)\r
-                       targetUri.cleanUp();\r
                return null;\r
        }\r
 \r
+       //      private String getVersionedFileName(String fileName, String extension) throws Exception {\r
+       //              String result = fileName;\r
+       //              try {\r
+       //                      targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
+       //                      FTPFile[] listFiles = targetFtp.listFiles();\r
+       //                      List<String> fileNames = new ArrayList<>();\r
+       //                      for (FTPFile ftpFile : listFiles) {\r
+       //                              fileNames.add(ftpFile.getName());\r
+       //                      }\r
+       //                      while (fileNames.contains(result + extension)) {\r
+       //\r
+       //                      }\r
+       //\r
+       //              } catch (Exception e) {\r
+       //                      logger.catching(e);\r
+       //                      throw e;\r
+       //              } finally {\r
+       //                      targetUri.cleanUp();\r
+       //              }\r
+       //              return result;\r
+       //      }\r
+\r
        private FileArchive processMosObject(BasicDBObject rundown, BasicDBObject story, BasicDBObject mosObject) throws Exception {\r
                String mosID = mosObject.getString(IOctopusAPI.OBJ_ID);\r
                if (MetadataTypeDetector.GuessMetadataType(mosID) != MetadataType.OCTOPUSPLACEHOLDER) {\r
@@ -226,7 +235,9 @@ public class CopyForArchiveNEXIOMaterialsStep extends JobStep {
        }\r
 \r
        private void processRundowns(List<DBObject> rundowns) {\r
-               db.getCollection(ARCHIVEDRUNDOWNS).drop();\r
+\r
+               //TODO kiveni publikálás előtt\r
+               //db.getCollection(ARCHIVEDRUNDOWNS).drop();\r
                List<BasicDBObject> archivedRundowns = queryArchivedRundowns();\r
 \r
                int index = 1;\r
@@ -336,6 +347,10 @@ public class CopyForArchiveNEXIOMaterialsStep extends JobStep {
                sourceUri.setPortNumber(nexioPort);\r
                sourceUri.setUserName(nexioUserName);\r
                sourceUri.setPassword(nexioPassword);\r
+               if (sourceUri == null) {\r
+                       logger.error(getMarker(), "A forrás nem elérhető.");\r
+                       throw new NullPointerException("Internal error, missing 'sourceUri'.");\r
+               }\r
 \r
                check(archiveFtp, "archiveFtp");\r
                check(archiveUserName, "archiveUserName");\r
@@ -344,61 +359,66 @@ public class CopyForArchiveNEXIOMaterialsStep extends JobStep {
                targetUri = manager.createStoreUri(new URI(archiveFtp));\r
                targetUri.setUserName(archiveUserName);\r
                targetUri.setPassword(archivePassword);\r
+               if (targetUri == null) {\r
+                       logger.error(getMarker(), "A cél nem elérhető.");\r
+                       throw new NullPointerException("Internal error, missing 'targetUri'.");\r
+               }\r
 \r
        }\r
 \r
-       private void transferFile(String fileName) throws Exception {\r
+       private void transferFile(String sourceFileName, String targetFileName) throws Exception {\r
                int reply = 0;\r
-               //              sourceFtp = ((FtpDirectoryLister) RemoteFileHandler.createLister(sourceUri)).connect();\r
-               //              targetFtp = ((FtpDirectoryLister) RemoteFileHandler.createLister(targetUri)).connect();\r
-               //              if (sourceUri != null)\r
-               //                      sourceUri.cleanUp();\r
-               //              if (targetUri != null)\r
-               //                      targetUri.cleanUp();\r
-\r
-               if (!targetFtp.enterRemotePassiveMode())\r
-                       throw new Exception("!PASV");\r
+               logger.info("Transfer clip {}", sourceFileName);\r
+               try {\r
+                       sourceFtp = ((FtpDirectoryLister) sourceUri.getLister()).connect();\r
+                       targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
+                       if (!targetFtp.enterRemotePassiveMode())\r
+                               throw new Exception("!PASV");\r
 \r
-               reply = sourceFtp.port(InetAddress.getByName(targetFtp.getPassiveHost()), targetFtp.getPassivePort());\r
-               if (!FTPReply.isPositiveCompletion(reply))\r
-                       throw new Exception("!PORT");\r
+                       reply = sourceFtp.port(InetAddress.getByName(targetFtp.getPassiveHost()), targetFtp.getPassivePort());\r
+                       if (!FTPReply.isPositiveCompletion(reply))\r
+                               throw new Exception("PORT parancs válasza: " + sourceFtp.getReplyString());\r
 \r
-               if (!sourceFtp.setFileType(FTP.BINARY_FILE_TYPE))\r
-                       throw new Exception("!SOURCE TYPE");\r
+                       if (!sourceFtp.setFileType(FTP.BINARY_FILE_TYPE))\r
+                               throw new Exception("!SOURCE TYPE");\r
 \r
-               sourceFtp.retr(fileName);\r
+                       reply = sourceFtp.retr(sourceFileName);\r
+                       if (!FTPReply.isPositivePreliminary(reply))\r
+                               throw new Exception("RETR parancs válasza: " + sourceFtp.getReplyString());\r
 \r
-               if (!targetFtp.setFileType(FTP.BINARY_FILE_TYPE))\r
-                       throw new Exception("!TARGET TYPE");\r
+                       if (!targetFtp.setFileType(FTP.BINARY_FILE_TYPE))\r
+                               throw new Exception("!TARGET TYPE");\r
 \r
-               targetFtp.stor(fileName);\r
+                       reply = targetFtp.stor(targetFileName);\r
+                       if (!FTPReply.isPositivePreliminary(reply))\r
+                               throw new Exception("STOR parancs válasza: " + sourceFtp.getReplyString());\r
 \r
-               while (true) {\r
-                       reply = sourceFtp.stat();\r
-                       if (!FTPReply.isPositiveCompletion(reply))\r
-                               throw new Exception("!STAT");\r
+                       while (true) {\r
+                               reply = sourceFtp.stat();\r
+                               if (!FTPReply.isPositiveCompletion(reply))\r
+                                       throw new Exception("STAT parancs válasza: " + sourceFtp.getReplyString());\r
 \r
-                       //String replyText = sourceFtp.getReplyString();\r
-                       //logger.info("Status: {}", replyText);\r
-                       if (reply == 226) {\r
-                               break;\r
+                               logger.info("Status: {}", sourceFtp.getReplyString());\r
+                               if (reply == 226) {\r
+                                       break;\r
+                               }\r
+                               Thread.sleep(1000);\r
                        }\r
-                       Thread.sleep(100);\r
+               } catch (Exception e) {\r
+                       logger.catching(e);\r
+                       throw e;\r
+               } finally {\r
+                       sourceUri.cleanUp();\r
+                       targetUri.cleanUp();\r
                }\r
 \r
-               //              if (sourceUri != null)\r
-               //                      sourceUri.cleanUp();\r
-               //              if (targetUri != null)\r
-               //                      targetUri.cleanUp();\r
-\r
        }\r
 \r
        private void transferMetadata(String fileName, BasicDBObject metadata) throws Exception {\r
+               logger.info("Transfer metadata {}", fileName);\r
                OutputStream outStream = null;\r
-               if (targetUri != null)\r
-                       targetUri.cleanUp();\r
-               targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
                try {\r
+                       targetFtp = ((FtpDirectoryLister) targetUri.getLister()).connect();\r
                        if (!targetFtp.changeWorkingDirectory(EscortFiles.STATUSFOLDER)) {\r
                                targetFtp.makeDirectory(EscortFiles.STATUSFOLDER);\r
                                if (!targetFtp.changeWorkingDirectory(EscortFiles.STATUSFOLDER))\r
@@ -411,15 +431,14 @@ public class CopyForArchiveNEXIOMaterialsStep extends JobStep {
                        }\r
                        outStream.write(metadata.toString().getBytes(UTF_8));\r
                        outStream.flush();\r
-                       targetFtp.changeToParentDirectory();\r
+                       //targetFtp.changeToParentDirectory();\r
                } catch (Exception e) {\r
                        logger.catching(e);\r
                        throw e;\r
                } finally {\r
                        if (outStream != null)\r
                                outStream.close();\r
-                       //                      if (targetUri != null)\r
-                       //                              targetUri.cleanUp();\r
+                       targetUri.cleanUp();\r
                }\r
        }\r
 \r
index 6a65db58a3012735be1cafee0342fc9070848d9f..307b8dbbcd445760fe3f2212865c416c317162a0 100644 (file)
@@ -6,6 +6,7 @@ import java.util.HashMap;
 import java.util.HashSet;\r
 import java.util.List;\r
 import java.util.Map;\r
+import java.util.Set;\r
 import java.util.concurrent.ConcurrentHashMap;\r
 \r
 import javax.swing.event.EventListenerList;\r
@@ -180,6 +181,18 @@ public class OctopusDataMiner {
                return concatParentsToStoryFolder(parent, newName);\r
        }\r
 \r
+       private void deleteDiff(Set<Long> oldIDs, Set<Long> newIDs, String collectionName) {\r
+               if (oldIDs == null || oldIDs.size() == 0)\r
+                       return;\r
+               if (newIDs != null && newIDs.size() > 0)\r
+                       oldIDs.removeAll(newIDs);\r
+               DBCollection collection = db.getCollection(collectionName);\r
+               for (long id : oldIDs) {\r
+                       logger.info("Deleting {} from {}", id, collectionName);\r
+                       collection.remove(new BasicDBObject(IOctopusAPI.ID, id));\r
+               }\r
+       }\r
+\r
        private void deleteOrphanRundowns() {\r
                try {\r
                        DBCollection collection = db.getCollection(RUNDOWN_COLLECTION);\r
@@ -270,6 +283,9 @@ public class OctopusDataMiner {
                processRundowns(rundowns);\r
                processStoryFolders(storyFolders);\r
 \r
+               deleteDiff(currentRundowns.keySet(), storyRundowns.keySet(), RUNDOWN_COLLECTION);\r
+               deleteDiff(currentFolder.keySet(), storyStoryFolders.keySet(), RUNDOWN_COLLECTION);\r
+               deleteDiff(currentStories.keySet(), storyIDs, RUNDOWN_COLLECTION);\r
                //              deleteOrphanRundowns();\r
                //              deleteOrphanStoryFolders();\r
                //              deleteOrphanStories();\r
similarity index 89%
rename from server/user.jobengine.executors/deploy-steps-to-bsh-bkup.bat
rename to server/user.jobengine.executors/test-deploy-steps-to-bsh-bkup.bat
index 8235a56223c339e389fc3e16e61673d9b222c436..4e1ba9cc2f5fe6bb4942d186faa680fdd4b39c36 100644 (file)
@@ -1,7 +1,7 @@
 @ECHO OFF\r
 \r
 SET REMOTE_HOST=10.10.1.29\r
-SET REMOTE_LOCATION=/opt/mediacube/configuration/executors\r
+SET REMOTE_LOCATION=/opt/test-mediacube/configuration/executors\r
 SET REMOTE_SERVER_HOSTKEY=ssh-ed25519 256 ea:ab:67:70:79:63:2f:6a:34:81:48:e2:b9:dd:ca:d4\r
 SET REMOTE_SERVER_ADDRESS=scp://root:password@%REMOTE_HOST%\r
 SET LOCAL_STEPS_LOCATION=bin/user/jobengine/server/steps\r
similarity index 83%
rename from server/user.jobengine.executors/deploy-steps-to-bsh-bkup.launch
rename to server/user.jobengine.executors/test-deploy-steps-to-bsh-bkup.launch
index 7e5b62eb3c949eb6df93db52a28e7ef932507cc0..628a1712c8efb48a728ca673c8cb117c2a1453eb 100644 (file)
@@ -3,6 +3,6 @@
 <listAttribute key="org.eclipse.debug.ui.favoriteGroups">\r
 <listEntry value="org.eclipse.ui.externaltools.launchGroup"/>\r
 </listAttribute>\r
-<stringAttribute key="org.eclipse.ui.externaltools.ATTR_LOCATION" value="${workspace_loc:/user.jobengine.executors/deploy-steps-to-bsh-bkup.bat}"/>\r
+<stringAttribute key="org.eclipse.ui.externaltools.ATTR_LOCATION" value="${workspace_loc:/user.jobengine.executors/test-deploy-steps-to-bsh-bkup.bat}"/>\r
 <stringAttribute key="org.eclipse.ui.externaltools.ATTR_WORKING_DIRECTORY" value="${workspace_loc:/user.jobengine.executors}"/>\r
 </launchConfiguration>\r
diff --git a/server/user.jobengine.executors/test-deploy-steps-to-bsh-main.bat b/server/user.jobengine.executors/test-deploy-steps-to-bsh-main.bat
new file mode 100644 (file)
index 0000000..8a83ec7
--- /dev/null
@@ -0,0 +1,32 @@
+@ECHO OFF\r
+\r
+SET REMOTE_HOST=10.10.1.28\r
+SET REMOTE_LOCATION=/opt/test-mediacube/configuration/executors\r
+SET REMOTE_SERVER_HOSTKEY=ssh-ed25519 256 ea:ab:67:70:79:63:2f:6a:34:81:48:e2:b9:dd:ca:d4\r
+SET REMOTE_SERVER_ADDRESS=scp://root:password@%REMOTE_HOST%\r
+SET LOCAL_STEPS_LOCATION=bin/user/jobengine/server/steps\r
+SET LOCAL_CONFIG_LOCATION=config\r
\r
+       ECHO *** Begin deploy steps to server %REMOTE_HOST% ***\r
+       ECHO --- Deploying\r
+       \r
+       WinSCP.com /command ^\r
+       "open %REMOTE_SERVER_ADDRESS% -hostkey=""%REMOTE_SERVER_HOSTKEY%"" -timeout=60" ^\r
+       "cd %REMOTE_LOCATION%" ^\r
+       "lcd %LOCAL_STEPS_LOCATION%" ^\r
+       "synchronize remote" ^\r
+       "lcd ..\" ^\r
+       "lcd ..\" ^\r
+       "lcd ..\" ^\r
+       "lcd ..\" ^\r
+       "lcd ..\" ^\r
+       "lcd %LOCAL_CONFIG_LOCATION%" ^\r
+       "synchronize remote -filemask=config.xml" ^\r
+       "cd .." ^\r
+       "synchronize remote -filemask=scheduledjobs.json" ^\r
+       "exit"\r
+       \r
+       ECHO *** Completed ***\r
+@ECHO ON\r
+\r
\r
diff --git a/server/user.jobengine.executors/test-deploy-steps-to-bsh-main.launch b/server/user.jobengine.executors/test-deploy-steps-to-bsh-main.launch
new file mode 100644 (file)
index 0000000..773c638
--- /dev/null
@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>\r
+<launchConfiguration type="org.eclipse.ui.externaltools.ProgramLaunchConfigurationType">\r
+<listAttribute key="org.eclipse.debug.ui.favoriteGroups">\r
+<listEntry value="org.eclipse.ui.externaltools.launchGroup"/>\r
+</listAttribute>\r
+<stringAttribute key="org.eclipse.ui.externaltools.ATTR_LOCATION" value="${workspace_loc:/user.jobengine.executors/test-deploy-steps-to-bsh-main.bat}"/>\r
+<stringAttribute key="org.eclipse.ui.externaltools.ATTR_WORKING_DIRECTORY" value="${workspace_loc:/user.jobengine.executors}"/>\r
+</launchConfiguration>\r
index aa343583272f558019448424c6ee3a26d8200567..3c95f49c533978540547c05ad000ab1767d981a7 100644 (file)
@@ -75,6 +75,10 @@ public class Media extends DynamicAttributes {
                return getMediaFiles() == null ? 0 : getMediaFiles().size();
        }
 
+       public String getMediaFilesName() {
+               return (getMediaFiles() == null || getMediaFiles().size() == 0) ? "" : getMediaFiles().get(0).getHouseId();
+       }
+
        public byte[] getPoster() {
                return poster;
        }
index c39b3fd1ba0669d7f300074cb06aa42362593f26..8e44f53b1a198df673fe2927d6de061db96d3f7e 100644 (file)
@@ -57,7 +57,7 @@
                                                                <image src="/img/mediacube_logo_v2_50x50.png">\r
 <!--                                                           <custom-attributes org.zkoss.zul.image.preload="true" /> -->\r
                                                                </image>\r
-                                                               <label style="color:#e3e3e3;font-size:20px;font-weight:bold">MediaCube v2.1.9</label>\r
+                                                               <label style="color:#e3e3e3;font-size:20px;font-weight:bold">MediaCube </label><label style="color:#e3e3e3;font-size:10px;font-weight:bold">2.2</label> \r
                                                        </div>\r
                                                </west>\r
                                                <center border="0">\r
index c94b2347d7aeb3c4be74f0c84aa948f50929cdf0..e064d2471fae31e321657cdcee6cf9b62d8daefe 100644 (file)
                                                        <listhead sizable="true">\r
                                                                <listheader label="ID" hflex="1" align="left" />\r
                                                                <listheader label="Cím" hflex="6" align="left" />\r
+                                                               <listheader label="Fájlnév" hflex="6" align="left" />\r
                                                                <listheader label="Kópiák" hflex="1" align="left" />\r
                                                        </listhead>\r
                                                        <template name="model">\r
                                                                <listitem>\r
                                                                        <listcell label="@load(each.houseId)" />\r
                                                                        <listcell label="@load(each.title)" />\r
+                                                                       <listcell label="@load(each.mediaFilesName)" />\r
                                                                        <listcell label="@load(each.mediaFilesCount)" />\r
                                                                </listitem>\r
                                                        </template>\r
index 9bd723c9284619baf566e404c17d2b3cbe81491d..b92266ccc16d4f192b9642370689f9e13a231e49 100644 (file)
@@ -47,7 +47,7 @@ public class OctopusRESTService {
        @Consumes({ MediaType.APPLICATION_JSON })
        @Produces({ MediaType.APPLICATION_JSON })
        public Response getRundowns(@PathParam("scheduledDate") String scheduledDate) {
-               logger.info("Entry {}", scheduledDate);
+               logger.trace("Entry {}", scheduledDate);
                Response result = null;
                try {
                        Date calendar = null;
@@ -186,14 +186,14 @@ public class OctopusRESTService {
        }
 
        @GET
-       @Path("/storyFoldersByPlaceHolderID/{id}")
+       @Path("/storyFoldersByParentStoryID/{id}")
        @Consumes({ MediaType.APPLICATION_JSON })
        @Produces({ MediaType.APPLICATION_JSON })
-       public Response getStoryFoldersByPlaceHolderID(@PathParam(ID) String id) {
+       public Response getStoryFoldersByParentStoryID(@PathParam(ID) String id) {
                logger.trace("Entry");
                Response result = null;
                try {
-                       List<DBObject> storyFolders = octopusService.getStoryFoldersByPlaceHolderID(id);
+                       List<DBObject> storyFolders = octopusService.getStoryFoldersByParentStoryID(id);
                        result = Response.ok(storyFolders).build();
                } catch (Exception e) {
                        result = createErrorResponse(e);
@@ -203,14 +203,14 @@ public class OctopusRESTService {
        }
 
        @GET
-       @Path("/storyFoldersByParentStoryID/{id}")
+       @Path("/storyFoldersByPlaceHolderID/{id}")
        @Consumes({ MediaType.APPLICATION_JSON })
        @Produces({ MediaType.APPLICATION_JSON })
-       public Response getStoryFoldersByParentStoryID(@PathParam(ID) String id) {
+       public Response getStoryFoldersByPlaceHolderID(@PathParam(ID) String id) {
                logger.trace("Entry");
                Response result = null;
                try {
-                       List<DBObject> storyFolders = octopusService.getStoryFoldersByParentStoryID(id);
+                       List<DBObject> storyFolders = octopusService.getStoryFoldersByPlaceHolderID(id);
                        result = Response.ok(storyFolders).build();
                } catch (Exception e) {
                        result = createErrorResponse(e);