Added Notification Support for /Batch/Bulk/** and /Authorization/**

Author: jateeter

src/main/java/org/energyos/espi/thirdparty/web/NotificationController.java

@@ -93,6 +93,9 @@ private void doImportAsynchronously(String subscriptionUri) {
         System.out.printf("Start Asynchronous Input: %s: %s\n  ", threadName, subscriptionUri);
 
         String resourceUri = subscriptionUri;
+        String accessToken = "";
+        Authorization authorization = null;
+        RetailCustomer retailCustomer = null;
 
         if (subscriptionUri.indexOf("?") > -1) {										// Does message contain a query element
         	resourceUri = subscriptionUri.substring(0, subscriptionUri.indexOf("?"));	// Yes, remove the query element
@@ -118,12 +121,22 @@ private void doImportAsynchronously(String subscriptionUri) {
 
     	} else {
         	try {
-        		Authorization authorization = resourceService.findByResourceUri(resourceUri, Authorization.class);
-        	   	
-        		RetailCustomer retailCustomer = authorization.getRetailCustomer();
-
-        		String accessToken = authorization.getAccessToken();
-        	
+        		if ((resourceUri.contains("/Batch/Bulk")) || (resourceUri.contains("/Authorization"))) {
+    				// mutate the resourceUri to be of the form .../Batch/Bulk
+        			resourceUri = (resourceUri.substring(0, resourceUri.indexOf("/resource/") + "/resource/".length()).concat("Batch/Bulk"));
+
+        		} else {
+                    // mutate the resourceUri for the form /Subscription/{subscriptionId}/**
+        			String temp = resourceUri.substring(resourceUri.indexOf("/Subscription/") + "/Subscription/".length());
+        			if (temp.contains("/")) {
+        				resourceUri = resourceUri.substring(0, resourceUri.indexOf("/Subscription") + "/Subscription".length()).concat(temp.substring(0, temp.indexOf("/")));
+        			}
+  		        }
+        		
+    			authorization = resourceService.findByResourceUri(resourceUri, Authorization.class);
+				retailCustomer = authorization.getRetailCustomer();
+    			accessToken = authorization.getAccessToken();
+        		
         		try {
 
         			HttpHeaders requestHeaders = new HttpHeaders();