Index: branches/APG_ES_Site/BW/APG_ES_Site/Processes/NSight/Site-Write/Feed/ReceivePaidDeliveryCutoff.process =================================================================== diff -u -r230342 -r255408 --- branches/APG_ES_Site/BW/APG_ES_Site/Processes/NSight/Site-Write/Feed/ReceivePaidDeliveryCutoff.process (.../ReceivePaidDeliveryCutoff.process) (revision 230342) +++ branches/APG_ES_Site/BW/APG_ES_Site/Processes/NSight/Site-Write/Feed/ReceivePaidDeliveryCutoff.process (.../ReceivePaidDeliveryCutoff.process) (revision 255408) @@ -1,5 +1,5 @@ - + Processes/NSight/Site-Write/Feed/ReceivePaidDeliveryCutoff.process JMS Queue Receiver @@ -345,8 +345,8 @@ com.tibco.pe.core.CatchActivity ae.activities.catch - 426 - 387 + 882 + 398 true true @@ -356,8 +356,8 @@ com.tibco.pe.core.CallProcessActivity ae.process.subprocess - 716 - 392 + 1021 + 395 /UtilityServices/Interface/SendException.process @@ -396,6 +396,39 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + @@ -456,8 +489,8 @@ com.tibco.pe.core.CallProcessActivity ae.process.subprocess - 810 - 122 + 809 + 125 /UtilityServices/Interface/SendLog.process true @@ -502,6 +535,34 @@ + + com.tibco.plugin.jms.JMSQueueSendActivity + ae.activities.JMSQueueSendActivity + 584 + 371 + + Text + + false + 1 + 1 + + + PERSISTENT + 0 + 4 + + 0 + /SharedResources/Connections/JMS/JMS-APP.sharedjmscon + + + + + + + + + JMS Queue Receiver LogUpdateStart @@ -521,7 +582,7 @@ lookupsite Default -16777216 - always + otherwise SendJDE @@ -580,4 +641,19 @@ -16777216 always + + SiteDeliveryFeed + SendToGCP + Default + -16777216 + xpath + $_globalVariables/ns1:GlobalVariables/InterfaceSpecific/GCP/SendUPSToGCP="true" + + + SendToGCP + lookupsite + Default + -16777216 + always + \ No newline at end of file Index: branches/APG_ES_Site/BW/APG_ES_Site/defaultVars/InterfaceSpecific/GCP/defaultVars.substvar =================================================================== diff -u -r255358 -r255408 --- branches/APG_ES_Site/BW/APG_ES_Site/defaultVars/InterfaceSpecific/GCP/defaultVars.substvar (.../defaultVars.substvar) (revision 255358) +++ branches/APG_ES_Site/BW/APG_ES_Site/defaultVars/InterfaceSpecific/GCP/defaultVars.substvar (.../defaultVars.substvar) (revision 255408) @@ -2,6 +2,14 @@ + Delivery_URI + no value + true + false + String + 1713336216346 + + Host no value true @@ -42,6 +50,14 @@ 1713094231676 + SendUPSToGCP + false + true + false + String + 1713417881350 + + URI no value true Index: branches/APG_ES_Site/BW/APG_ES_Site/defaultVars/Destinations/Queues/defaultVars.substvar =================================================================== diff -u -r255342 -r255408 --- branches/APG_ES_Site/BW/APG_ES_Site/defaultVars/Destinations/Queues/defaultVars.substvar (.../defaultVars.substvar) (revision 255342) +++ branches/APG_ES_Site/BW/APG_ES_Site/defaultVars/Destinations/Queues/defaultVars.substvar (.../defaultVars.substvar) (revision 255408) @@ -10,6 +10,22 @@ 1594229810614 + GCPDeliveryFeedQueue + APG.NAM.GCP.DELIVERYFEED.Q.V10 + true + false + String + 1713339434538 + + + GCPPaidDeliveryQueue + APG.NAM.GCP.PAIDCUTOFF.Q.V.10 + true + false + String + 1713418271644 + + GCPSiteFeedQueue APG.NAM.SITEFEED.GCP.Q.V10 true @@ -159,7 +175,8 @@ true false String - 1527007786624 + + 1713339434080 SiteSDGSyncDelete Index: branches/APG_ES_Site/BW/APG_ES_Site/Processes/NSight/Site-Write/Feed/Extract_PaidDelivery.process =================================================================== diff -u --- branches/APG_ES_Site/BW/APG_ES_Site/Processes/NSight/Site-Write/Feed/Extract_PaidDelivery.process (revision 0) +++ branches/APG_ES_Site/BW/APG_ES_Site/Processes/NSight/Site-Write/Feed/Extract_PaidDelivery.process (revision 255408) @@ -0,0 +1,634 @@ + + + + Processes/NSight/Site-Write/Feed/Extract_PaidDelivery.process + JMS Queue Receiver + 0 + 0 + + + com.tibco.plugin.jms.JMSQueueEventSource + ae.activities.JMSQueueEventSource + 81 + 64 + + Text + + false + 1 + 1 + + + PERSISTENT + 0 + 4 + + /SharedResources/Connections/JMS/JMS-APP.sharedjmscon + + + + End + 912 + 73 + + + http://xmlns.example.com/1713259237963 + + com.tibco.plugin.cassandra.inbound.QueryActivity + ae.activities.CassandraQuery + 223 + 68 + + EMPTY + EMPTY + false + /SharedResources/Connections/Cassandra/Cassandra-NSight.cassandraconn + select * from site_delivery_source allow filtering; + + + ship_from_site_identifier + UUID + REQUIRED + + + delivery_service_type + TEXT + REQUIRED + + + data_as_of_ts + TIMESTAMP + REQUIRED + + + friday_cutoff_time + TIME + OPTIONAL + + + monday_cutoff_time + TIME + OPTIONAL + + + saturday_cutoff_time + TIME + OPTIONAL + + + service_duration_designator + TEXT + OPTIONAL + + + service_duration_max_value + INT + OPTIONAL + + + service_duration_min_value + INT + OPTIONAL + + + solr_query + TEXT + OPTIONAL + + + sunday_cutoff_time + TIME + OPTIONAL + + + thursday_cutoff_time + TIME + OPTIONAL + + + tuesday_cutoff_time + TIME + OPTIONAL + + + wednesday_cutoff_time + TIME + OPTIONAL + + + + + + + com.tibco.pe.core.LoopGroup + ae.process.group + 307 + 6 + 545 + 141 + 57 + 70 + + inherit + + inputLoop + false + $Query_deliverysource/pfx:QueryActivityResult/Rows/Row + iterdelivery + index + + false + + + true + + start + Query_Site + Default + -16777216 + always + + + Send HTTP Request + end + Default + -16777216 + always + + + Render JSON + Send HTTP Request + Default + -16777216 + always + + + Query_Site + Render JSON + Default + -16777216 + always + + + com.tibco.plugin.json.activities.JSONRenderActivity + ae.activities.JSONRenderActivity + 562 + 76 + + xsdType + false + + + + + +
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
+
+
+
+ + com.tibco.plugin.http.client.HttpRequestActivity + httppalette.httpRequest + 739 + 73 + + 5.3.0 + true + NONE + true + + false + %%BW_GLOBAL_TRUSTED_CA_STORE%% + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + com.tibco.plugin.cassandra.inbound.QueryActivity + ae.activities.CassandraQuery + 403 + 77 + + EMPTY + EMPTY + false + /SharedResources/Connections/Cassandra/Cassandra-NSight.cassandraconn + select alias_name,alias_value from site where site_identifier=? allow filtering; + + + site_identifier + UUID + REQUIRED + + + + + alias_name + TEXT + REQUIRED + + + alias_value + TEXT + REQUIRED + + + + + + + + + + + + + +
+ + com.tibco.pe.core.CallProcessActivity + ae.process.subprocess + 899 + 218 + + /UtilityServices/Interface/SendException.process + true + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + com.tibco.pe.core.CatchActivity + ae.activities.catch + 750 + 218 + true + + true + + + + + JMS Queue Receiver + Query_deliverysource + Default + -16777216 + always + + + Query_deliverysource + Group + Default + -16777216 + always + + + Group + End + Default + -16777216 + always + + + Catch + SendException + Default + -16777216 + always + + + SendException + End + Default + -16777216 + always + +
\ No newline at end of file