From 76536a0c70d2407d85e03dfb63a51ae974a2f334 Mon Sep 17 00:00:00 2001 From: Sweidan Omar Date: Mon, 6 Dec 2021 12:02:35 +0000 Subject: [PATCH] git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32471 --- .../steps/shared/PlanAirExtensions.java | 198 +++++++++--------- 1 file changed, 101 insertions(+), 97 deletions(-) diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/shared/PlanAirExtensions.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/shared/PlanAirExtensions.java index 50a32812..05553a56 100644 --- a/server/user.jobengine.executors/src/user/jobengine/server/steps/shared/PlanAirExtensions.java +++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/shared/PlanAirExtensions.java @@ -34,90 +34,95 @@ import user.jobengine.db.IStatementDecorator; public class PlanAirExtensions { private static final Logger logger = LogManager.getLogger(); - // @Operation int, @@@Options int, @@ItemID int, @@IntParam1 int=Null, @@IntParam2 int=Null, @@IntParam3 int=Null, - // @@StrParam1 varchar(200)=Null, @@StrParam2 varchar(max)=Null, @@DateParam1 datetime=Null, @@DateParam2 datetime=Null - private static final String MATERIAL_SQL = "{call dbo.clIFsp_EC_MAM(1002, Null, Null, Null, Null, Null, ?)}";//musorid - // item.v_ProgrammeID = (int)ReadInt(reader, ref f); - // item.v_Live = (bool)ReadBool(reader, ref f); - // item.v_EpisodeID = ReadString(reader, ref f); - // item.v_VariantID = ReadInt(reader, ref f); - // item.v_MediaID = ReadString(reader, ref f); - // item.v_VariantTypeID = ReadInt(reader, ref f); - // item.v_ProgTitle = ReadString(reader, ref f); - // item.v_EpTitle = ReadString(reader, ref f); - // item.v_Episode = ReadShort(reader, ref f); - // item.v_VariantType = ReadString(reader, ref f); - // item.v_VariantKeywords = ReadString(reader, ref f); - // item.v_VariantLengthTC = ReadString(reader, ref f); - // item.v_VariantLengthFrame = ReadInt(reader, ref f); - // item.v_VariantNrSegments = ReadInt(reader, ref f); - // item.v_FirstBroadcastDate = ReadDateTime(reader, ref f); - // item.v_NextBroadcastDate = ReadDateTime(reader, ref f); - // item.v_OkForAir = ReadBool(reader, ref f); - // item.v_ForTransm = ReadBool(reader, ref f); + // @Operation int, @@@Options int, @@ItemID int, @@IntParam1 int=Null, + // @@IntParam2 int=Null, @@IntParam3 int=Null, + // @@StrParam1 varchar(200)=Null, @@StrParam2 varchar(max)=Null, @@DateParam1 + // datetime=Null, @@DateParam2 datetime=Null + private static final String MATERIAL_SQL = "{call dbo.clIFsp_EC_MAM(1002, Null, Null, Null, Null, Null, ?)}";// musorid + // item.v_ProgrammeID = (int)ReadInt(reader, ref f); + // item.v_Live = (bool)ReadBool(reader, ref f); + // item.v_EpisodeID = ReadString(reader, ref f); + // item.v_VariantID = ReadInt(reader, ref f); + // item.v_MediaID = ReadString(reader, ref f); + // item.v_VariantTypeID = ReadInt(reader, ref f); + // item.v_ProgTitle = ReadString(reader, ref f); + // item.v_EpTitle = ReadString(reader, ref f); + // item.v_Episode = ReadShort(reader, ref f); + // item.v_VariantType = ReadString(reader, ref f); + // item.v_VariantKeywords = ReadString(reader, ref f); + // item.v_VariantLengthTC = ReadString(reader, ref f); + // item.v_VariantLengthFrame = ReadInt(reader, ref f); + // item.v_VariantNrSegments = ReadInt(reader, ref f); + // item.v_FirstBroadcastDate = ReadDateTime(reader, ref f); + // item.v_NextBroadcastDate = ReadDateTime(reader, ref f); + // item.v_OkForAir = ReadBool(reader, ref f); + // item.v_ForTransm = ReadBool(reader, ref f); - private static final String MATERIAL_SEGMENTS_SQL = "{call dbo.clIFsp_EC_MAM(1010, Null, ?)}";//variantid - // item.v_SegID = (int)ReadInt(reader, ref f); - // item.v_VariantID = ReadInt(reader, ref f); - // item.v_SegTitle = ReadString(reader, ref f); - // item.v_SegKeyWords = ReadString(reader, ref f); - // item.v_SegNumber = ReadInt(reader, ref f); - // item.v_TcIn = ReadInt(reader, ref f); - // item.v_TcOut = ReadInt(reader, ref f); - // item.v_Duration = ReadInt(reader, ref f); - // item.v_TcInTC = ReadString(reader, ref f); - // item.v_TcOutTC = ReadString(reader, ref f); - // item.v_DurationTC = ReadString(reader, ref f); - // item.v_Dropable = ReadBool(reader, ref f); + private static final String MATERIAL_SEGMENTS_SQL = "{call dbo.clIFsp_EC_MAM(1010, Null, ?)}";// variantid + // item.v_SegID = (int)ReadInt(reader, ref f); + // item.v_VariantID = ReadInt(reader, ref f); + // item.v_SegTitle = ReadString(reader, ref f); + // item.v_SegKeyWords = ReadString(reader, ref f); + // item.v_SegNumber = ReadInt(reader, ref f); + // item.v_TcIn = ReadInt(reader, ref f); + // item.v_TcOut = ReadInt(reader, ref f); + // item.v_Duration = ReadInt(reader, ref f); + // item.v_TcInTC = ReadString(reader, ref f); + // item.v_TcOutTC = ReadString(reader, ref f); + // item.v_DurationTC = ReadString(reader, ref f); + // item.v_Dropable = ReadBool(reader, ref f); private static final String PROMO_SQL = "{call dbo.clIFsp_EC_MAM(2002, Null, Null, Null, Null, Null, ?)}"; - // item.t_SpotID = (int)ReadInt(reader, ref f); - // item.t_MediaID = ReadString(reader, ref f); - // item.v_Title = ReadString(reader, ref f); - // item.v_PromoType = ReadString(reader, ref f); - // item.v_ProgTitle = ReadString(reader, ref f); - // item.v_Episode = ReadShort(reader, ref f); - // item.t_PSStart = ReadDateTime(reader, ref f); - // item.t_PSEnd = ReadDateTime(reader, ref f); - // item.v_EstimatedDuration = ReadInt(reader, ref f); - // item.t_TcIn = ReadInt(reader, ref f); - // item.t_TcOut = ReadInt(reader, ref f); - // item.t_Duration = ReadInt(reader, ref f); - // item.v_TcIn = ReadString(reader, ref f); - // item.v_TcOut = ReadString(reader, ref f); - // item.v_Duration = ReadString(reader, ref f); - // item.v_Stations = ReadString(reader, ref f); - // item.t_OkForAir = ReadBool(reader, ref f); - // item.v_OkForAirs = ReadString(reader, ref f); - // item.v_IsInactive = ReadBool(reader, ref f); + // item.t_SpotID = (int)ReadInt(reader, ref f); + // item.t_MediaID = ReadString(reader, ref f); + // item.v_Title = ReadString(reader, ref f); + // item.v_PromoType = ReadString(reader, ref f); + // item.v_ProgTitle = ReadString(reader, ref f); + // item.v_Episode = ReadShort(reader, ref f); + // item.t_PSStart = ReadDateTime(reader, ref f); + // item.t_PSEnd = ReadDateTime(reader, ref f); + // item.v_EstimatedDuration = ReadInt(reader, ref f); + // item.t_TcIn = ReadInt(reader, ref f); + // item.t_TcOut = ReadInt(reader, ref f); + // item.t_Duration = ReadInt(reader, ref f); + // item.v_TcIn = ReadString(reader, ref f); + // item.v_TcOut = ReadString(reader, ref f); + // item.v_Duration = ReadString(reader, ref f); + // item.v_Stations = ReadString(reader, ref f); + // item.t_OkForAir = ReadBool(reader, ref f); + // item.v_OkForAirs = ReadString(reader, ref f); + // item.v_IsInactive = ReadBool(reader, ref f); private static final String AD_SQL = "{call dbo.clIFsp_EC_MAM(3002, Null, Null, Null, Null, Null, ?)}"; - // item.t_SpotID = (int)ReadInt(reader, ref f); - // item.t_MediaID = ReadString(reader, ref f); - // item.v_Title = ReadString(reader, ref f); - // item.t_Advertiser = ReadString(reader, ref f); - // item.v_EstimatedDuration = ReadInt(reader, ref f); - // item.t_TcIn = ReadInt(reader, ref f); - // item.t_TcOut = ReadInt(reader, ref f); - // item.t_Duration = ReadInt(reader, ref f); - // item.v_TcIn = ReadString(reader, ref f); - // item.v_TcOut = ReadString(reader, ref f); - // item.v_Duration = ReadString(reader, ref f); - // item.t_OkForAir = ReadBool(reader, ref f); - // item.v_OkForAirs = ReadString(reader, ref f); + // item.t_SpotID = (int)ReadInt(reader, ref f); + // item.t_MediaID = ReadString(reader, ref f); + // item.v_Title = ReadString(reader, ref f); + // item.t_Advertiser = ReadString(reader, ref f); + // item.v_EstimatedDuration = ReadInt(reader, ref f); + // item.t_TcIn = ReadInt(reader, ref f); + // item.t_TcOut = ReadInt(reader, ref f); + // item.t_Duration = ReadInt(reader, ref f); + // item.v_TcIn = ReadString(reader, ref f); + // item.v_TcOut = ReadString(reader, ref f); + // item.v_Duration = ReadString(reader, ref f); + // item.t_OkForAir = ReadBool(reader, ref f); + // item.v_OkForAirs = ReadString(reader, ref f); private static final String SQLSERVER_JDBC_SQL_SERVER_DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; private static final String HYPHEN_SPACES = " - "; private static Connection connection; - private static void appendInstanceData(Document doc, Node node, String name, String deviceID, Timecode tcIn, Timecode tcOut) { + private static void appendInstanceData(Document doc, Node node, String name, String deviceID, Timecode tcIn, + Timecode tcOut) { node.appendChild(doc.createElement("Long_File_Id")).appendChild(doc.createTextNode(name)); node.appendChild(doc.createElement("Device_Id")).appendChild(doc.createTextNode(deviceID)); node.appendChild(doc.createElement("Timecode_In")).appendChild(doc.createTextNode(tcIn.toString(""))); node.appendChild(doc.createElement("Timecode_Out")).appendChild(doc.createTextNode(tcOut.toString(""))); - node.appendChild(doc.createElement("Quality_Check")).appendChild(doc.createTextNode(new SimpleDateFormat("dd/MM/yyyy").format(new Date()))); + node.appendChild(doc.createElement("Quality_Check")) + .appendChild(doc.createTextNode(new SimpleDateFormat("dd/MM/yyyy").format(new Date()))); } - private static void appendItemData(Document doc, Node node, String name, String title, Timecode duration, String type) { + private static void appendItemData(Document doc, Node node, String name, String title, Timecode duration, + String type) { node.appendChild(doc.createElement("Material_Id")).appendChild(doc.createTextNode(name)); node.appendChild(doc.createElement("Title")).appendChild(doc.createTextNode(title)); @@ -154,24 +159,17 @@ public class PlanAirExtensions { } /* - - - - - XMLTEST011 - Teszt Mozi - 00000914 - PROGRAMME //PROGRAMME, COMMERCIAL, JUNCTION - - - ISILON - 09/11/2017 - XMLTEST011 - - - - */ - public static String getMorpeusXML(IItemManager manager, String dbUrl, String userName, String password, String name, String deviceID) throws Exception { + * + * XMLTEST011 Teszt Mozi + * 00000914 + * PROGRAMME //PROGRAMME, COMMERCIAL, JUNCTION + * ISILON + * 09/11/2017 + * XMLTEST011 + * + */ + public static String getMorpeusXML(IItemManager manager, String dbUrl, String userName, String password, + String name, String deviceID) throws Exception { String result = null; try { Class.forName(SQLSERVER_JDBC_SQL_SERVER_DRIVER); @@ -185,7 +183,7 @@ public class PlanAirExtensions { Node instanceNode = importItemNode.appendChild(doc.createElement("Instance")); connection = DriverManager.getConnection(dbUrl, userName, password); - //TODO hiba esetén exception + // TODO hiba esetén exception switch (type) { case TrafficMaterial: manager.executeQuery(connection, MATERIAL_SQL, rs -> { @@ -210,7 +208,8 @@ public class PlanAirExtensions { int out = segments.get(segments.size() - 1)[1]; int in = segments.get(0)[0]; appendItemData(doc, itemNode, name, title, new Timecode(out - in, Type.PAL), "PROGRAMME"); - appendInstanceData(doc, instanceNode, name, deviceID, new Timecode(in, Type.PAL), new Timecode(out, Type.PAL)); + appendInstanceData(doc, instanceNode, name, deviceID, new Timecode(in, Type.PAL), + new Timecode(out, Type.PAL)); return false; }, st -> { st.setString(1, name); @@ -222,7 +221,8 @@ public class PlanAirExtensions { int in = rs.getInt("t_TcIn"); int out = rs.getInt("t_TcOut"); appendItemData(doc, itemNode, name, title, new Timecode(out - in, Type.PAL), "COMMERCIAL"); - appendInstanceData(doc, instanceNode, name, deviceID, new Timecode(in, Type.PAL), new Timecode(out, Type.PAL)); + appendInstanceData(doc, instanceNode, name, deviceID, new Timecode(in, Type.PAL), + new Timecode(out, Type.PAL)); return false; }, st -> { st.setString(1, name); @@ -234,7 +234,8 @@ public class PlanAirExtensions { int in = rs.getInt("t_TcIn"); int out = rs.getInt("t_TcOut"); appendItemData(doc, itemNode, name, title, new Timecode(out - in, Type.PAL), "JUNCTION"); - appendInstanceData(doc, instanceNode, name, deviceID, new Timecode(in, Type.PAL), new Timecode(out, Type.PAL)); + appendInstanceData(doc, instanceNode, name, deviceID, new Timecode(in, Type.PAL), + new Timecode(out, Type.PAL)); return false; }, st -> { st.setString(1, name); @@ -254,14 +255,15 @@ public class PlanAirExtensions { return result; } - public static Connection search(Connection con, MetadataType type, IItemManager manager, String dbUrl, String userName, String password, - IResultSetConsumer consumer, IStatementDecorator decorator) throws Exception { + public static Connection search(Connection con, MetadataType type, IItemManager manager, String dbUrl, + String userName, String password, IResultSetConsumer consumer, IStatementDecorator decorator) + throws Exception { try { Class.forName(SQLSERVER_JDBC_SQL_SERVER_DRIVER); if (con == null) connection = DriverManager.getConnection(dbUrl, userName, password); - //TODO hiba esetén exception + // TODO hiba esetén exception switch (type) { case TrafficMaterial: manager.executeQuery(connection, MATERIAL_SQL, consumer, decorator); @@ -272,13 +274,15 @@ public class PlanAirExtensions { case TrafficAD: manager.executeQuery(connection, AD_SQL, consumer, decorator); break; + default: + break; } } catch (Exception e) { logger.catching(e); throw e; } finally { - // if (connection != null) - // connection.close(); + // if (connection != null) + // connection.close(); } return connection; } @@ -287,7 +291,7 @@ public class PlanAirExtensions { DOMSource domSource = new DOMSource(doc); TransformerFactory tf = TransformerFactory.newInstance(); Transformer transformer = tf.newTransformer(); - //transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes"); + // transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes"); transformer.setOutputProperty(OutputKeys.STANDALONE, "yes"); transformer.setOutputProperty(OutputKeys.METHOD, "xml"); transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8"); -- 2.54.0